From 8455982258d5cbde1ba53dabecb3f1ca8e92c171 Mon Sep 17 00:00:00 2001
From: ZZ <coml_aaron@163.com>
Date: Mon, 23 Aug 2021 17:23:24 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=AE=9E=E6=97=B6=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/xhpc/pp/logic/RealtimeDataLogic.java     |  6 ++++++
 .../java/com/xhpc/pp/server/ChargingPileServer.java   | 11 +++++++++++
 2 files changed, 17 insertions(+)

diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java
index bc13b110..f38400b5 100644
--- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java
+++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RealtimeDataLogic.java
@@ -117,6 +117,12 @@ public class RealtimeDataLogic implements ServiceLogic {
                     REDIS.setCacheMap(orderkey, cacheOrder);
                 }
             }
+            if ("true".equals(cacheOrder.get("lordiss"))) {
+                cacheOrder.put("lordiss", "false");
+                pileOrderService.pileStop(orderNo, 4, "订单实时数据恢复");
+                REDIS.setCacheMap(orderkey, cacheOrder);
+            }
+            REDIS.setCacheMap(orderkey, cacheOrder);
         }
         return new ServiceResult(false);
     }
diff --git a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileServer.java b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileServer.java
index 6a8d4b3d..42db251b 100644
--- a/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileServer.java
+++ b/xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/ChargingPileServer.java
@@ -1,5 +1,6 @@
 package com.xhpc.pp.server;
 
+import com.xhpc.common.api.PileOrderService;
 import com.xhpc.common.redis.service.RedisService;
 import com.xhpc.pp.logic.FieldLogic;
 import com.xhpc.pp.utils.security.HexUtils;
@@ -43,6 +44,8 @@ public class ChargingPileServer {
     private FieldLogic fieldLogic;
     @Autowired
     public RedisService redisService;
+    @Autowired
+    private static PileOrderService pileOrderService;
 
     @PostConstruct
     public void init() {
@@ -97,6 +100,14 @@ public class ChargingPileServer {
             if (!cacheGun.isEmpty()) {
                 cacheGun.put("status", DISCONNECTED);
                 REDIS.setCacheMap(gunkey, cacheGun);
+                String orderkey = (String) cacheGun.get("orderkey");
+                if (orderkey != null) {
+                    Map<String, Object> cacheOrder = REDIS.getCacheMap(orderkey);
+                    cacheOrder.put("lordiss", "true");
+                    REDIS.setCacheMap(orderkey, cacheOrder);
+                    String orderNo = orderkey.replace("order:", "");
+                    pileOrderService.pileStop(orderNo, 3, "充电桩离线,订单实时数据可能中断");
+                }
             }
         }
         if (handler != null) {