下发阈值数据包

cloud-model/src/main/java/com/hssx/cloudmodel/service/impl/MouldEquipmentServiceImpl.java

@@ -105,20 +105,20 @@ public class MouldEquipmentServiceImpl extends ServiceImpl<MouldEquipmentMapper,
             lowPowerLimitStr = "0" + lowPowerLimitStr;
         }
         String workInterval = Integer.toHexString(mouldEquipment.getWorkInterval());
-            if (workInterval.length() == 1) {
-                workInterval = "0" + workInterval;
-            }
-            String freeInterval = Integer.toHexString(mouldEquipment.getFreeInterval());
-            if (freeInterval.length() == 1) {
-                freeInterval = "0" + freeInterval;
-            }
+        if (workInterval.length() == 1) {
+            workInterval = "0" + workInterval;
+        }
+        String freeInterval = Integer.toHexString(mouldEquipment.getFreeInterval());
+        if (freeInterval.length() == 1) {
+            freeInterval = "0" + freeInterval;
+        }
         String hotAlarmLimitStr = Integer.toHexString(mouldEquipment.getHotAlarmLimit());
         if (hotAlarmLimitStr.length() == 1) {
             hotAlarmLimitStr = "0" + hotAlarmLimitStr;
         }
         String isUseStr = "0" + Integer.toHexString(mouldEquipment.getIsUse());
-        String threshold="";
-        if(null != mouldEquipment.getThreshold()) {
+        String threshold = "";
+        if (null != mouldEquipment.getThreshold()) {
             threshold = String.format("%04d", Integer.parseInt(mouldEquipment.getThreshold()));
         }
         //判断是不是超级管理员，是才可操作
@@ -142,22 +142,24 @@ public class MouldEquipmentServiceImpl extends ServiceImpl<MouldEquipmentMapper,
                 equipment.setTemperature(mouldEquipment.getHotAlarmLimit());
                 mouldEquipmentMapper.update(equipment, new QueryWrapper<MouldEquipment>().eq("equipment_no", str));
                 MouldDownPacket mouldDownPacket = new MouldDownPacket();
-                if(!threshold.equals("")) {
+                if (!threshold.equals("")) {
                     mouldDownPacket.setThreshold(threshold);
                 }
+                mouldDownPacket.setId(packet.getId());
+                if (0 == mouldEquipment.getIsUse()) {
+                    setPacketMessage = "FAAF0007001e781e50003C";//停用
+                    String crcCode = CRC16Util.getCRC(setPacketMessage);
+                    setPacketMessage = setPacketMessage + crcCode;
+                } else {
+                    setPacketMessage = downProcessMsg(lowPowerLimitStr, hotAlarmLimitStr, isUseStr, freeInterval, workInterval);
+                }
+                mouldDownPacket.setPacketStr(setPacketMessage);
+                mouldDownPacket.setIsUse(mouldEquipment.getIsUse());
+                mouldDownPacket.setEquipmentNo(str);
                 if (packet != null) {
                     //已经存在更新下发数据包
-                    mouldDownPacket.setId(packet.getId());
-                    setPacketMessage = downProcessMsg(lowPowerLimitStr, hotAlarmLimitStr, isUseStr, freeInterval, workInterval);
-                    mouldDownPacket.setPacketStr(setPacketMessage);
-                    mouldDownPacket.setIsUse(mouldEquipment.getIsUse());
-                    mouldDownPacket.setEquipmentNo(str);
                     mouldDownPacketMapper.updateById(mouldDownPacket);
                 } else {
-                    setPacketMessage = downProcessMsg(lowPowerLimitStr, hotAlarmLimitStr, isUseStr, freeInterval, workInterval);
-                    mouldDownPacket.setPacketStr(setPacketMessage);
-                    mouldDownPacket.setIsUse(mouldEquipment.getIsUse());
-                    mouldDownPacket.setEquipmentNo(str);
                     mouldDownPacketMapper.insert(mouldDownPacket);
                 }
             }

cloud-socket/src/com/js/kbt/socket/UserHandler.java

@@ -294,7 +294,7 @@ public class UserHandler extends SimpleChannelInboundHandler<String> {
 			sendMsg(packet.getPacketStr());
 			if(null != packet.getThreshold()){
 				//下发阈值命令
-				sendMsg("#LIMIT VALUE="+packet.getThreshold());
+				sendMsg(strHexStr16("#LIMIT VALUE="+packet.getThreshold()));
 			}
 			if (count > 0) {
 				TbMouldEquipment me = tbMouldEquipmentMapper.selectByExample(meqExp).get(0);