From be28fb5bb3b68f5dcce4273adde56bef669f711e Mon Sep 17 00:00:00 2001
From: cl <418351270@qq.com>
Date: 星期五, 06 九月 2024 09:22:49 +0800
Subject: [PATCH] 修改电芯挡位功能

---
 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java |   28 ++++++++++++++++++++--------
 1 files changed, 20 insertions(+), 8 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
index 6b5a617..7e08480 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -166,8 +166,9 @@
                             result = 16;//鐢佃姱鎸′綅涓虹┖
                         }else{
                             String cellGear = cellGearObjcet.toString();
-                      /*      List<String> cellCodeList = readCellCodeList(thoroughfare, device);
-                            result = checkCellGear(thoroughfare, device,cellCodeList,cellGear);//鏍¢獙鐢佃姱鎸′綅鍜岀粍鍒�*/
+                            List<String> cellCodeList = readCellCodeList(thoroughfare, device);
+                            result = checkCellGear(thoroughfare, device,cellCodeList,cellGear);//鏍¢獙鐢佃姱鎸′綅鍜岀粍鍒�
+                            Constants.OLD_CELL_GEAR = cellGear;//鎸′綅璧嬪��
                         }
                         miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(result).build());
 
@@ -864,7 +865,7 @@
      */
     private Integer checkCellGear(String thoroughfare, String device,List<String> cellCodeList,String cellGear) throws Exception {
         Integer result = 11;
-
+        String cellSerial = "";
         for(int i = 0; i < cellCodeList.size(); i ++){
             Integer cellStatus = 1;
             String cellCode = cellCodeList.get(i);
@@ -874,20 +875,31 @@
                 if(CollUtil.isNotEmpty(list)){
                     DaCellData daCellData = list.get(0);
                     String cellValue = daCellData.getCellValue();//鏁版嵁搴撲腑鐢佃姱鎸′綅
-                    String cellSerial = daCellData.getCellSerial();//鏁版嵁搴撲腑鐢佃姱缁勫埆
+                    cellSerial = daCellData.getCellSerial();//鏁版嵁搴撲腑鐢佃姱缁勫埆
                     if(!cellValue.isEmpty() && cellValue.equals(cellGear)){
                         cellStatus = 1;
                     }else {
                         cellStatus = 2;
                         result = 16;//鎸′綅鏍¢獙涓嶅悎鏍�
+                        log.info("鐢佃姱鎸′綅鏍¢獙涓嶅悎鏍硷細鐢佃姱鐮佷负{}锛孭LC璁剧疆鎸′綅涓簕}锛屽伐鍘侻ES涓嬪彂鎸′綅涓猴細{}",cellCode,cellGear,cellValue);
                     }
-                }/*else {
+                }else {
                     cellStatus = 2;
-                    result = 17;//鏌ヤ笉鍒拌鏍¢獙鐨勬尅浣�
-                }*/
-                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_"+(i+1)).value(cellStatus).build());
+                    result = 16;//鏌ヤ笉鍒拌鏍¢獙鐨勬尅浣�
+                    log.info("鐢佃姱鎸′綅鏍¢獙涓嶅悎鏍硷細鐢佃姱鐮佷负{}锛孭LC璁剧疆鎸′綅涓簕}锛屽伐鍘侻ES涓嬪彂鎸′綅涓虹┖锛屾煡璇笉鍒拌鏁版嵁",cellCode,cellGear);
+                }
+                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".Cell_Status_"+(i+1)).value(cellStatus).build());
             }
         }
+
+        //褰撶數鑺尅浣嶅彂鐢熷彉鍖栨椂锛屽苟涓旇�佺殑鎸′綅涓嶄负绌猴紝鍒犻櫎褰撳墠鐢佃姱鎵规
+        if(!Constants.OLD_CELL_GEAR.isEmpty() && !cellGear.equals(Constants.OLD_CELL_GEAR)){
+            if(!cellSerial.isEmpty()){
+                daCellDataService.deleteDaCellDataByCellSerial(cellSerial);
+            }
+            log.info("鐢佃姱鎸′綅鍙戠敓鏀瑰彉锛岃�佺殑鎸′綅涓猴細{}锛屾柊鐨勬尅浣嶄负锛歿}锛屾壒娆″彿涓簕}",Constants.OLD_CELL_GEAR,cellGear,cellSerial);
+        }
+
         return result;
     }
 

--
Gitblit v1.9.3