心跳检测

src/main/java/com/tmzn/devicelinkykc/frameMsg/frameType/HeartFrameSend.java

@@ -28,7 +28,7 @@ public class HeartFrameSend {
             deviceConnectionMsg.getOutputStream().write(bytes);
             deviceConnectionMsg.getOutputStream().flush();
         } catch (IOException e) {
-            log.info("pileCode:"+device.getPileCode()+" ,heart push frame Exception");
+            log.info("pileCode:"+device.getPileCode()+" ,heart push frame Exception。{}",e.getMessage());
             e.printStackTrace();
             return false;
         }

src/main/java/com/tmzn/devicelinkykc/message/DeviceMsgHandle.java

@@ -961,6 +961,10 @@ public class DeviceMsgHandle {
             one.setEndTime(System.currentTimeMillis());
             one.setReasonStopCharging(TransConstant.OTHER_STOP);
             orderStatusService.updateById(one);
+
+            //再发一次停止充电的指令 避免设备状态变位没有停掉
+            deviceControlerService.stopCharge(imei, imei, port);
+
         }
         logger.info("上传空闲状态{}",imei);
         realTimeStatusPushFrame.deviceStatusPush(deviceConnectionMsg, FrameDataSplicing.transactionNum(null, 0), statusServiceOne.getPileCode(), (byte) port, gunsStatus, insertGunStatus, 0, 0, zero, zero, 0);

src/main/java/com/tmzn/devicelinkykc/taskQueue/runner/MsgHeartRunner.java

@@ -112,7 +112,7 @@ public class MsgHeartRunner {
         }
 
         //检查多久没有心跳时间了
-        if (oneDs.getOnlineStatus() == DeviceOnlineStatus.ONLINE && (System.currentTimeMillis() - heartTime) > 120 * 1000L) {
+        if (oneDs.getOnlineStatus() == DeviceOnlineStatus.ONLINE && (System.currentTimeMillis() - heartTime) > 180 * 1000L) {
             log.info("heart_over..{},{}" ,devicePileCode, (System.currentTimeMillis() - heartTime));
             socketHandle.removeDeviceConnection(devicePileCode);
             deviceControlerService.sendImeiDetail(oneDs.getDeviceImei());

src/main/resources/application.yml

@@ -3,7 +3,7 @@ server:
   port: 8063
 spring:
   profiles:
-    active: test
+    active: prod
 #mybatis-plus:
 #  configuration:
 #    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl