From 8d0f60bfbcbc9a9abae9d65a3bdfb33e515c3fb0 Mon Sep 17 00:00:00 2001
From: wen <1455474577@qq.com>
Date: Fri, 29 Oct 2021 10:59:24 +0800
Subject: [PATCH] =?UTF-8?q?QueryEquipBusinessPolicyController=E5=A2=9E?=
 =?UTF-8?q?=E5=8A=A0=E4=BA=86=E7=A9=BA=E6=8C=87=E9=92=88=E5=BC=82=E5=B8=B8?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../evcs/api/QueryEquipBusinessPolicyController.java   | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/api/QueryEquipBusinessPolicyController.java b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/api/QueryEquipBusinessPolicyController.java
index e87b0090..dbeee3a1 100644
--- a/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/api/QueryEquipBusinessPolicyController.java
+++ b/evcs-modules/evcs-core/src/main/java/com/xhpc/evcs/api/QueryEquipBusinessPolicyController.java
@@ -33,8 +33,18 @@ public class QueryEquipBusinessPolicyController {
         //获取枪所对应的桩编码
         String bySerialNumber = xhpcTerminalRepository.selectBySql(connectorId);
         String pileSerialNumber = bySerialNumber;
+
+        //找不到对应的桩编码，说明充电设备接口编码有误
+        if (pileSerialNumber == null) {
+            CommonResponse commonResponse = new CommonResponse();
+            commonResponse.setMsg("error connectorId");
+            commonResponse.setRet("1");
+            commonResponse.setData(null);
+            return commonResponse;
+        }
         //通过桩编码，进入redis，找到其所用的费率模型id
         Map<String, Object> cacheMap = REDIS.getCacheMap("pile:" + pileSerialNumber);
+
         Long rateModelId = (Long) cacheMap.get("rateModelId");
         //通过指定费率模型id，找到其对应的费率模型
         CacheRateModel rateModel = REDIS.getCacheObject("rateModel:" + rateModelId);