From 3c01fbc988ff90ef1f195232beb98c7776d47277 Mon Sep 17 00:00:00 2001 From: yxFwq <1> Date: 星期六, 23 十一月 2024 14:25:48 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/JarThread.java | 5 ++ src/main/resources/mapper/BasJarMapper.xml | 2 + src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 38 +++++++++--------- src/main/java/com/zy/core/model/protocol/JarProtocol.java | 3 + src/main/java/com/zy/core/enums/JarStatusType.java | 11 +++-- src/main/java/com/zy/asrs/entity/BasJar.java | 14 +++++++ 6 files changed, 48 insertions(+), 25 deletions(-) diff --git a/src/main/java/com/zy/asrs/entity/BasJar.java b/src/main/java/com/zy/asrs/entity/BasJar.java index e4a5fb9..5ec2df0 100644 --- a/src/main/java/com/zy/asrs/entity/BasJar.java +++ b/src/main/java/com/zy/asrs/entity/BasJar.java @@ -153,6 +153,20 @@ @ApiModelProperty(value= "鍐峰嵈") private Integer burial; + /** + * 娓╁害 + */ + @ApiModelProperty(value= "娓╁害") + @TableField("jar_temperature") + private Float jarTemperature; + + /** + * 鍘嬪姏 + */ + @ApiModelProperty(value= "鍘嬪姏") + @TableField("jar_pressure") + private Float jarPressure; + public BasJar() {} public BasJar(Integer jarNo,Integer region,Integer jarCode,Integer staNo,Integer jarStatus,Integer jarCount,Integer jarErr,String leftDoor,String rightDoor,String leftInEnable,String leftOutEnable,String autoing,Integer jarMode,String rightInEnable,String rightOutEnable) { diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index a6f4905..ae3c037 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -5231,7 +5231,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -5261,7 +5261,7 @@ //鑷姩銆佺┖闂层�佸彸闂ㄥ叧闂�� Other宸﹂棬鍏抽棴 if (jarProtocol.isAutoing() && jarProtocol.jarErr==0 && jarProtocol.leftDoorOpen==0 && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0 && jarProtocol.rightDoorClose==0){ - if (jarProtocol.statusType != JarStatusType.SOS){ + if (jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType != JarStatusType.SOS2){ log.error("Jar浠诲姟鍒涘缓===銆嬫墽琛�===>琛�={}",4537); BasJarMast basJarMast = new BasJarMast(basJar, wrkMast, jarLocDigit); basJarMast.setJarEnterStaNo(staNo);//鍏ョ~鍖栫綈绔欑偣 @@ -5610,7 +5610,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ return false; } if (jarProtocol.getJarTemperature()>jarTemperature){ @@ -5718,7 +5718,7 @@ return false; } - if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -5744,7 +5744,7 @@ } //闂ㄤ綔涓� 鏃� - if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.jarErr==0 + if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType!= JarStatusType.SOS2 && jarProtocol.jarErr==0 && jarProtocol.isRightDoor() && jarProtocol.isLeftDoor() && jarProtocol.leftDoorOpen==0 && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0 && jarProtocol.rightDoorClose==0){ //鍏宠繘鏂欓棬 @@ -5807,7 +5807,7 @@ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -5837,7 +5837,7 @@ log.error("JarWrkMastExecute浠诲姟鍒涘缓===>鎵ц寮傚父===銆嬪紓甯告暟鎹細BasJar:"+ JSON.toJSONString(basJar)+";BasJarMast:"+JSON.toJSONString(basJarMastSign)); } return true; - } else if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS + } else if (jarProtocol.isAutoing() && jarProtocol.statusType != JarStatusType.SOS && jarProtocol.statusType != JarStatusType.SOS2 && jarProtocol.statusType != JarStatusType.WAITING2 && jarProtocol.jarErr==0 && jarProtocol.isLeftDoor() && jarProtocol.isRightDoor() && jarProtocol.leftDoorOpen==0 && jarProtocol.leftDoorClose==0 && jarProtocol.rightDoorOpen==0 && jarProtocol.rightDoorClose==0){ @@ -5914,7 +5914,7 @@ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -6482,7 +6482,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -6610,7 +6610,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -6738,7 +6738,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -6854,7 +6854,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.WAITING2) || jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -6970,7 +6970,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -7106,7 +7106,7 @@ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -7578,7 +7578,7 @@ return false; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); return false; } @@ -7630,7 +7630,7 @@ continue; } - if (jarProtocolOther.statusType .equals(JarStatusType.SOS)){ + if (jarProtocolOther.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ // log.error("{}鍙风~鍖栫綈鏌ヨ璁惧姝e湪纭寲涓紝浠诲姟寮傚父锛侊紒锛�",jarProtocol.getJarNo()); continue; } @@ -8515,7 +8515,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ continue; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ continue; } if (jarProtocol.getJarTemperature()>jarTemperature){ @@ -8606,7 +8606,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ continue; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ continue; } if (jarProtocol.getJarTemperature()>jarTemperature){ @@ -8828,7 +8828,7 @@ if (jarProtocol.modeType != JarModeType.AUTO){ continue; } - if (jarProtocol.statusType .equals(JarStatusType.SOS)){ + if (jarProtocol.statusType .equals(JarStatusType.SOS) || jarProtocol.statusType .equals(JarStatusType.SOS2)){ continue; } if (jarProtocol.getJarTemperature()>jarTemperature){ diff --git a/src/main/java/com/zy/core/enums/JarStatusType.java b/src/main/java/com/zy/core/enums/JarStatusType.java index ff69ae1..5a12de0 100644 --- a/src/main/java/com/zy/core/enums/JarStatusType.java +++ b/src/main/java/com/zy/core/enums/JarStatusType.java @@ -4,13 +4,14 @@ IDLE(0, "绌洪棽"), MOVING(1, "寮�闂�"), - SOS(2, "纭寲涓�"), + SOS(2, "鍏抽棬"), WAITING1(3, "寮�闂�"), WAITING2(4, "纭寲瀹屾垚"), WAITING3(5, "闂ㄦ墦寮�涓�"), WAITING4(6, "闂ㄦ墦寮�涓�"), WAITING5(7, "闂ㄥ叧闂腑"), OFF_LINE(8, "闂ㄥ叧闂腑"), + SOS2(9, "淇濇俯涓�"), OTHER(100, "鍏跺畠"), ; @@ -23,25 +24,25 @@ public static JarStatusType get(Short id) { if (null == id) { - return null; + return OTHER; } for (JarStatusType type : JarStatusType.values()) { if (type.id.equals(id.intValue())) { return type; } } - return OFF_LINE; + return OTHER; } public static JarStatusType get(JarStatusType type) { if (null == type) { - return null; + return OTHER; } for (JarStatusType jarStatusType : JarStatusType.values()) { if (jarStatusType == type) { return jarStatusType; } } - return null; + return OTHER; } } diff --git a/src/main/java/com/zy/core/model/protocol/JarProtocol.java b/src/main/java/com/zy/core/model/protocol/JarProtocol.java index 9fdd2cb..2b391e3 100644 --- a/src/main/java/com/zy/core/model/protocol/JarProtocol.java +++ b/src/main/java/com/zy/core/model/protocol/JarProtocol.java @@ -110,6 +110,7 @@ public Integer rightDoorClose; public Float jarTemperature; + public Float jarPressure; /** @@ -150,6 +151,8 @@ basJar.setRightInEnable(rightInEnable?"Y":"N"); basJar.setRightOutEnable(rightOutEnable?"Y":"N"); basJar.setAutoing(autoing?"Y":"N"); + basJar.setJarTemperature(jarTemperature); + basJar.setJarPressure(jarPressure); return basJar; } diff --git a/src/main/java/com/zy/core/thread/JarThread.java b/src/main/java/com/zy/core/thread/JarThread.java index 4f1f973..8790090 100644 --- a/src/main/java/com/zy/core/thread/JarThread.java +++ b/src/main/java/com/zy/core/thread/JarThread.java @@ -139,7 +139,8 @@ return; } OperateResultExOne<byte[]> result = siemensS7Net.Read("V300", (short) 30); - if (result.IsSuccess) { + OperateResultExOne<byte[]> result338 = siemensS7Net.Read("V338", (short) 4); + if (result.IsSuccess && result338.IsSuccess) { if (null == jarProtocol) { jarProtocol = new JarProtocol(); jarProtocol.setJarNo(slave.getId()); @@ -173,6 +174,8 @@ jarProtocol.setStatus(siemensS7Net.getByteTransform().TransInt16(result.Content, 16));//鐘舵�� jarProtocol.setJarTemperature(siemensS7Net.getByteTransform().TransSingle(result.Content, 26));//娓╁害 + jarProtocol.setJarPressure(siemensS7Net.getByteTransform().TransSingle(result338.Content, 0));//鍘嬪姏 + jarProtocol.setAutoing(siemensS7Net.getByteTransform().TransInt16(result.Content, 12) == 2);//鑷姩 // diff --git a/src/main/resources/mapper/BasJarMapper.xml b/src/main/resources/mapper/BasJarMapper.xml index d7138f5..37ea04b 100644 --- a/src/main/resources/mapper/BasJarMapper.xml +++ b/src/main/resources/mapper/BasJarMapper.xml @@ -24,6 +24,8 @@ <result column="enter_rgv_no" property="enterRgvNo" /> <result column="out_rgv_no" property="outRgvNo" /> <result column="burial" property="burial" /> + <result column="jar_temperature" property="jarTemperature" /> + <result column="jar_pressure" property="jarPressure" /> </resultMap> -- Gitblit v1.9.1