!30 添加停止充电的TestController

* 添加停止充电的TestController

jcpp-app/src/main/java/sanbing/jcpp/app/adapter/TestController.java

@@ -37,6 +37,14 @@ public class TestController {
         return ResponseEntity.ok("success");
     }
 
+    @GetMapping("/api/stopCharge")
+    public ResponseEntity<String> stopCharge() {
+
+        pileProtocolService.stopCharge("20231212000010", "01");
+
+        return ResponseEntity.ok("success");
+    }
+
     @GetMapping("/api/restartPile")
     public ResponseEntity<String> restartPile() {
 

jcpp-app/src/main/java/sanbing/jcpp/app/service/PileProtocolService.java

@@ -78,6 +78,11 @@ public interface PileProtocolService {
      */
     void startCharge(String pileCode, String gunCode, BigDecimal limitYuan, String orderNo);
 
+    /**
+     * 停止充电
+     */
+    void stopCharge(String pileCode, String gunCode);
+
     /**
      * 重启充电
      */

jcpp-app/src/main/java/sanbing/jcpp/app/service/impl/DefaultPileProtocolService.java

@@ -6,8 +6,8 @@
  */
 package sanbing.jcpp.app.service.impl;
 
-import com.fasterxml.jackson.databind.node.ObjectNode;
 import cn.hutool.core.date.DateUtil;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -303,6 +303,27 @@ public class DefaultPileProtocolService implements PileProtocolService {
         downlinkCallService.sendDownlinkMessage(downlinkRequestMessageBuilder, pileCode);
     }
 
+    @Override
+    public void stopCharge(String pileCode, String gunCode) {
+
+        UUID messageId = UUID.randomUUID();
+        UUID requestId = UUID.randomUUID();
+
+        DownlinkRequestMessage.Builder downlinkRequestMessageBuilder = DownlinkRequestMessage.newBuilder()
+                .setMessageIdMSB(messageId.getMostSignificantBits())
+                .setMessageIdLSB(messageId.getLeastSignificantBits())
+                .setPileCode(pileCode)
+                .setRequestIdMSB(requestId.getMostSignificantBits())
+                .setRequestIdLSB(requestId.getLeastSignificantBits())
+                .setDownlinkCmd(DownlinkCmdEnum.REMOTE_STOP_CHARGING.name())
+                .setRemoteStopChargingRequest(RemoteStopChargingRequest.newBuilder()
+                        .setPileCode(pileCode)
+                        .setGunCode(gunCode)
+                        .build());
+
+        downlinkCallService.sendDownlinkMessage(downlinkRequestMessageBuilder, pileCode);
+    }
+
     @Override
     public void restartPile(String pileCode, Integer type) {
 

jcpp-protocol-yunkuaichong/src/main/java/sanbing/jcpp/protocol/yunkuaichong/enums/YunKuaiChongDownlinkCmdEnum.java

@@ -44,7 +44,6 @@ public enum YunKuaiChongDownlinkCmdEnum {
 
     OFFLINE_CARD_SYNC_REQUEST(0x44),
 
-
     SYNC_TIME_REQUEST(0x56),
 
     ;