更新充电桩设备信息记录

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BalanceUpdateReplyDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.BalanceUpdateReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class BalanceUpdateReplyDataLogic implements ServiceLogic {
 
     private static final Logger log = LoggerFactory.getLogger(BalanceUpdateReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,16 @@ public class BalanceUpdateReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         BalanceUpdateReplyData balanceUpdateReplyData = objectMapper.convertValue(req, BalanceUpdateReplyData.class);
         log.debug("balanceUpdateResult({}) [{}]", balanceUpdateReplyData.getPileNo(), balanceUpdateReplyData.getModifyResult());
+
+        String remark = "充电桩余额更新";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsChargerInterruptDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -20,16 +24,26 @@ public class BmsChargerInterruptDataLogic implements ServiceLogic {
     private static final Logger log = LoggerFactory.getLogger(BmsChargerInterruptDataLogic.class);
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
 
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
-
+        String remark = "充电桩与 BMS 充电阶段充电机中止报文";
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 充电阶段充电机中止报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsChargingCompletedDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -21,15 +25,28 @@ public class BmsChargingCompletedDataLogic implements ServiceLogic {
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
-
+        String remark = "充电桩与 BMS 充电结束阶段报文";
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 充电结束阶段报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsChargingConfigDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -21,15 +25,28 @@ public class BmsChargingConfigDataLogic implements ServiceLogic {
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
+        String remark  = "充电桩与 BMS 参数配置阶段报文";
 
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 参数配置阶段报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+        
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsChargingHandshakeDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -21,15 +25,28 @@ public class BmsChargingHandshakeDataLogic implements ServiceLogic {
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
+        String remark = "充电桩与 BMS 充电握手阶段报文";
 
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 充电握手阶段报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsErrorDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -20,16 +24,26 @@ public class BmsErrorDataLogic implements ServiceLogic {
     private static final Logger log = LoggerFactory.getLogger(BmsErrorDataLogic.class);
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
 
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
-
+        String remark = "充电桩与 BMS 充电错误报文";
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 充电错误报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/BmsInterruptDataLogic.java

@@ -1,7 +1,10 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.mapper.XhpcMessageMapper;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
 import com.xhpc.pp.domain.XhpcMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -20,16 +24,27 @@ public class BmsInterruptDataLogic implements ServiceLogic {
     private static final Logger log = LoggerFactory.getLogger(BmsInterruptDataLogic.class);
     @Autowired
     private XhpcMessageMapper xhpcMessageMapper;
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
 
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
-
+        String remark = "充电桩与 BMS 充电阶段 BMS 中止报文";
         Map<String, Object> req = sp.getParameters();
         XhpcMessage msg = new XhpcMessage();
         msg.setContent((String) req.get("hex"));
         msg.setChargeOrderNo((String) req.get("orderNo"));
-        msg.setRemark("充电桩与 BMS 充电阶段 BMS 中止报文");
+        msg.setRemark(remark);
         xhpcMessageMapper.insertItemsBy(msg);
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/OfflineCardEraseReplyDataLogic.java

@@ -1,5 +1,8 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -8,16 +11,30 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
+
 @Lazy
 @Component("OfflineCardEraseReplyDataLogic")
 public class OfflineCardEraseReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(OfflineCardEraseReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
         //todo
+        String remark = "充电桩下发离线卡数据清除";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) sp.getParameters().get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/OfflineCardInquiryReplyDataLogic.java

@@ -1,5 +1,8 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -8,16 +11,29 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
+
 @Lazy
 @Component("OfflineCardInquiryReplyDataLogic")
 public class OfflineCardInquiryReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(OfflineCardInquiryReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
         //todo
+        String remark = "充电桩下发离线卡数据查询";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) sp.getParameters().get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/OfflineCardSyncReplyDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.OfflineCardSyncReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class OfflineCardSyncReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(OfflineCardSyncReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,14 @@ public class OfflineCardSyncReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         OfflineCardSyncReplyData offlineCardSyncReplyData = objectMapper.convertValue(req, OfflineCardSyncReplyData.class);
         //todo
+        String remark = "充电桩下发离线卡数据同步";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/PileConfigReplyDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.PileConfigReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class PileConfigReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(PileConfigReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,14 @@ public class PileConfigReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
         //todo
+        String remark = "充电桩工作参数设置";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/PileStartChargingDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.PileStartChargingData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class PileStartChargingDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(PileStartChargingDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,14 @@ public class PileStartChargingDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         PileStartChargingData pileStartChargingData = objectMapper.convertValue(req, PileStartChargingData.class);
         //todo
+        String remark = "充电桩主动申请起动充电";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/PileTimeConfigReplyDataLogic.java

@@ -3,6 +3,9 @@ package com.xhpc.pp.logic;
 import cn.hutool.core.date.DateUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.PileTimeConfigReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 import static cn.hutool.core.date.DatePattern.NORM_DATETIME_FORMAT;
@@ -23,6 +27,9 @@ public class PileTimeConfigReplyDataLogic implements ServiceLogic {
 
     private static final Logger log = LoggerFactory.getLogger(PileTimeConfigReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -36,6 +43,15 @@ public class PileTimeConfigReplyDataLogic implements ServiceLogic {
         cachePile.put("configTime", configTime);
         REDIS.setCacheMap(pk, cachePile);
         log.debug("({}) set time success√: [{}]", pileNo, configTime);
+
+        String remark = "充电桩同步时钟";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RateModelConfigReplyDataLogic.java

@@ -3,6 +3,9 @@ package com.xhpc.pp.logic;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.api.dto.ChargingStationDto;
 import com.xhpc.common.data.up.PileConfigReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
@@ -22,6 +26,9 @@ public class RateModelConfigReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(RateModelConfigReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -29,6 +36,8 @@ public class RateModelConfigReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         PileConfigReplyData pileRateModelConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
         String configResult = pileRateModelConfigReplyData.getConfigResult();
+
+        String result = FAIL;
         if (HEX_01.equals(configResult)) {
 //            确定设置成功的rateModelId 可能涉及协议修改
             final String pkey = "pile:".concat(pileRateModelConfigReplyData.getPileNo());
@@ -36,9 +45,20 @@ public class RateModelConfigReplyDataLogic implements ServiceLogic {
             ChargingStationDto cacheStation = REDIS.getCacheObject("station:".concat(cachePile.get("stationId").toString()));
             cachePile.put("rateModelId", cacheStation.getRateModelId());
             REDIS.setCacheMap(pkey, cachePile);
-            return new ServiceResult(OK);
+            result = OK;
         }
-        return new ServiceResult(FAIL);
+
+        String remark = "充电桩收到计费模型应答";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessage.setReplyContent(result);
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
+        return new ServiceResult(result);
     }
 
 }

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RateModelRequestLogic.java

@@ -4,6 +4,9 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.xhpc.common.api.dto.ChargingStationDto;
 import com.xhpc.common.data.redis.CacheRateModel;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -14,6 +17,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 import static com.xhpc.common.data.redis.StaticBeanUtil.REDIS;
@@ -26,6 +30,9 @@ public class RateModelRequestLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(RateModelRequestLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -42,6 +49,16 @@ public class RateModelRequestLogic implements ServiceLogic {
             return new ServiceResult((byte[]) null, ServiceResult.FAIL, json);
         }
         String resultStr = translate(pileNo, stationRateModelId, "000A");
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(pileNo);
+        deviceMessage.setRemark("充电桩计费模型请求");
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessage.setReplyContent(resultStr);
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(HexUtils.toBytes(resultStr), ServiceResult.OK);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RateModelValidateLogic.java

@@ -1,6 +1,9 @@
 package com.xhpc.pp.logic;
 
 import com.xhpc.common.api.dto.ChargingStationDto;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 import static cn.hutool.core.util.NumberUtil.isInteger;
@@ -23,6 +27,9 @@ public class RateModelValidateLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(RateModelValidateLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -58,6 +65,16 @@ public class RateModelValidateLogic implements ServiceLogic {
         String resultStr =
                 "680E".concat(seq).concat("0006").concat(pileNo).concat(String.format("%04X", csRateModelId)).concat(hexCode);
         resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr));
+
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(pileNo);
+        deviceMessage.setRemark("计费模型验证请求");
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessage.setReplyContent(resultStr);
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(HexUtils.toBytes(resultStr), resultCode);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RegisterLogic.java

@@ -1,6 +1,9 @@
 package com.xhpc.pp.logic;
 
+import com.xhpc.common.enums.StationDeviceEnum;
 import com.xhpc.evcs.dto.ConnectorStatusInfo;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -11,6 +14,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Collection;
 import java.util.Map;
 import java.util.Set;
@@ -27,6 +31,9 @@ public class RegisterLogic implements ServiceLogic {
     public static final String REGISTERED = "已注册";
     private static final Logger log = LoggerFactory.getLogger(RegisterLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -76,6 +83,17 @@ public class RegisterLogic implements ServiceLogic {
         String seq = seqHex(skey);
         String resultStr = "680C".concat(seq).concat("0002").concat(pileNo).concat(hexCode);
         resultStr = resultStr.concat(CRCCalculator.calcCrc(resultStr));
+
+        // 写入设备日志表数据
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(pileNo);
+        deviceMessage.setRemark("充电桩登录认证");
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessage.setReplyContent(resultStr);
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(HexUtils.toBytes(resultStr), resultCode);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RemoteRestartReplyDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.PileConfigReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class RemoteRestartReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(RemoteRestartReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,15 @@ public class RemoteRestartReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         PileConfigReplyData pileConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
         //todo
+        String remark = "充电桩收到远程重启应答";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/logic/RemoteUpgradeReplyDataLogic.java

@@ -2,6 +2,9 @@ package com.xhpc.pp.logic;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.xhpc.common.data.up.PileConfigReplyData;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import com.xhpc.pp.tx.ServiceParameter;
 import com.xhpc.pp.tx.ServiceResult;
 import com.xhpc.pp.tx.logic.ServiceLogic;
@@ -10,6 +13,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Map;
 
 @Lazy
@@ -18,6 +22,9 @@ public class RemoteUpgradeReplyDataLogic implements ServiceLogic {
 
     private static Logger log = LoggerFactory.getLogger(RemoteUpgradeReplyDataLogic.class);
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Override
     public ServiceResult service(ServiceParameter sp) throws Exception {
 
@@ -25,6 +32,16 @@ public class RemoteUpgradeReplyDataLogic implements ServiceLogic {
         ObjectMapper objectMapper = new ObjectMapper();
         PileConfigReplyData pileRateModelConfigReplyData = objectMapper.convertValue(req, PileConfigReplyData.class);
         //todo
+
+        String remark = "充电桩收到远程更新应答";
+        XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+        deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+        deviceMessage.setSerialNumber(sp.getPileNo());
+        deviceMessage.setRemark(remark);
+        deviceMessage.setStatus(0);
+        deviceMessage.setContent((String) req.get("hex"));
+        deviceMessageMapper.insertByDomain(deviceMessage);
+
         return new ServiceResult(false);
     }
 

xhpc-modules/xhpc-power-pile/src/main/java/com/xhpc/pp/server/HBCheckTask.java

@@ -1,8 +1,14 @@
 package com.xhpc.pp.server;
 
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.xhpc.common.enums.StationDeviceEnum;
+import com.xhpc.pp.domain.XhpcDeviceMessage;
+import com.xhpc.pp.mapper.XhpcDeviceMessageMapper;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Calendar;
 import java.util.Map;
 import java.util.Set;
@@ -15,6 +21,9 @@ import static com.xhpc.pp.logic.RegisterLogic.DISCONNECTED;
 @Component
 public class HBCheckTask {
 
+    @Resource
+    XhpcDeviceMessageMapper deviceMessageMapper;
+
     @Scheduled(fixedRate = 10000)
     protected void run() {
 
@@ -29,6 +38,16 @@ public class HBCheckTask {
                 cacheGun.put("statusInt", OFF_LINE);
                 cacheGun.put("status", DISCONNECTED);
                 REDIS.setCacheMap(gunkey, cacheGun);
+
+                XhpcDeviceMessage deviceMessage = new XhpcDeviceMessage();
+                deviceMessage.setType(StationDeviceEnum.PILE.getCode());
+
+                String pileId= StrUtil.sub(gunkey.substring(gunkey.lastIndexOf(":") + 1), 0, -2);
+                deviceMessage.setSerialNumber(pileId);
+                deviceMessage.setContent(JSON.toJSONString(cacheGun));
+                deviceMessage.setStatus(0);
+                deviceMessage.setRemark("充电桩心跳掉线");
+                deviceMessageMapper.insertByDomain(deviceMessage);
             }
         }
     }