From 5b3b0ab0785dfdbe2b39b37a3233a06d79b715bc Mon Sep 17 00:00:00 2001
From: Guoqs <123@jsowell.com>
Date: Fri, 26 Jul 2024 13:38:52 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=AA=E4=BA=BA=E6=A1=A9=E5=81=9C=E6=AD=A2?=
 =?UTF-8?q?=E5=85=85=E7=94=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/PileReservationInfoServiceImpl.java | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileReservationInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileReservationInfoServiceImpl.java
index 03b598a56..3696d1cb8 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileReservationInfoServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/PileReservationInfoServiceImpl.java
@@ -4,8 +4,10 @@ import com.alibaba.fastjson2.JSON;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.google.common.collect.Lists;
+import com.jsowell.common.constant.CacheConstants;
 import com.jsowell.common.constant.Constants;
 import com.jsowell.common.core.page.PageResponse;
+import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.enums.DelFlagEnum;
 import com.jsowell.common.enums.ykc.ReturnCodeEnum;
 import com.jsowell.common.exception.BusinessException;
@@ -57,6 +59,9 @@ public class PileReservationInfoServiceImpl implements PileReservationInfoServic
     @Autowired
     private PileMemberRelationService pileMemberRelationService;
 
+    @Autowired
+    private RedisCache redisCache;
+
     @Override
     public int deleteByPrimaryKey(Integer id) {
         return pileReservationInfoMapper.deleteByPrimaryKey(id);
@@ -431,6 +436,7 @@ public class PileReservationInfoServiceImpl implements PileReservationInfoServic
     public void personPileStopCharging(PersonPileStopChargingDTO dto) {
         String pileConnectorCode = dto.getPileConnectorCode();
         String pileSn = StringUtils.substring(pileConnectorCode, 0, pileConnectorCode.length() - 2);
+        String connectorCode = StringUtils.substring(pileConnectorCode, pileConnectorCode.length() - 2, pileConnectorCode.length());
         // 查询个人桩信息
         List<PileMemberRelation> pileMemberRelations = pileMemberRelationService.selectPileMemberRelationByPileSn(pileSn);
         Map<String, List<String>> listMap = pileMemberRelations.stream()
@@ -451,7 +457,11 @@ public class PileReservationInfoServiceImpl implements PileReservationInfoServic
         }
 
         if (stopFlag) {
-            log.info("发送停止指令");
+            String pileIsChargingKey = CacheConstants.PILE_IS_CHARGING + pileSn + connectorCode;
+            String redisResult = redisCache.getCacheObject(pileIsChargingKey);
+            // 发送停止充电指令
+            log.info("发送停止指令, pileSn:{}, connectorCode:{}, transactionCode:{}", pileSn, connectorCode, redisResult);
+            pileRemoteService.remoteStopCharging(pileSn, connectorCode, redisResult);
         }
     }