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