From 31960ffca93463cf4f6d417576c8694aed84138e Mon Sep 17 00:00:00 2001
From: hdy <1105738590@qq.com>
Date: 星期五, 07 三月 2025 12:40:31 +0800
Subject: [PATCH] 修改

---
 billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java |   37 +++++++++++++++++--------------------
 1 files changed, 17 insertions(+), 20 deletions(-)

diff --git a/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java b/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
index ae93b4b..00ed36a 100644
--- a/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
+++ b/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
@@ -93,19 +93,22 @@
                 //璇锋眰杩涚珯
                 } else if (Constants.ONE.equals(valueString)){
                     //1.1//棣栧伐绔�
-                    if(Constants.C005.equals(device) || Constants.OP005.equals(device) || Constants.P010.equals(device)){
+                    if(Constants.ONLINE.contains(device)){
                         miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value("11").build());
                     }
-                    ///////闄ら宸ョ珯鎵�鏈夊伐绔�
-                    else if(Constants.PLC1.contains(device) && Constants.OP310.contains(device)){
+                    //闄ら宸ョ珯鎵�鏈夊伐绔�
+                    else if(Constants.PLC1.contains(device) ||
+                            Constants.PLC2.contains(device) ||
+                            Constants.PLC3.contains(device) ||
+                            Constants.PLC4.contains(device) ||
+                            Constants.OFFLINE.contains(device)
+                    ){
                         //鏍¢獙SFCCode鏄惁瀛樺湪
                         Object SFCCode = miloService.readFromOpcUa(thoroughfare + "." + device + ".SFCCode").getValue();
-                        Object PalletID = miloService.readFromOpcUa(thoroughfare + "." + device + ".PalletID").getValue();
                         if (SFCCode == null ) {
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value("23").build());
                         } else {
                             OmOrderScheduling omOrderScheduling = new OmOrderScheduling();
-                            omOrderScheduling.setRemarks(PalletID.toString());
                             List<OmOrderScheduling> resultList = omOrderSchedulingService.selectOmOrderSchedulingList(omOrderScheduling);
                             log.info("鏌ヨ缁撴灉鏁伴噺: {}", resultList);
                             BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
@@ -114,7 +117,6 @@
                             //涓嬪彂閰嶆柟
                             formula(thoroughfare, device, bsbomChildInfo);
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value("11").build());
-
                         }
                     }
                 //鍑虹珯淇濆瓨鏁版嵁
@@ -148,12 +150,9 @@
                             List<OmProductionOrderInfo> omProductionOrderInfoList = omProductionOrderInfoService.selectOmProductionOrderInfoList(omProductionOrderInfo);
                             Object headQty = omProductionOrderInfoList.get(0).getHeadQty();
                             if (nowQty == headQty){
-//                                omProductionOrderInfoList.get(0).setHeadStatus("3");
-//                                omProductionOrderInfoService.updateOmProductionOrderInfo(omProductionOrderInfoList.get(0));
-
                                 UpdateWrapper<OmProductionOrderInfo> updateWrapper = new UpdateWrapper<>();
                                 updateWrapper.eq("work_order_no", omProductionOrderInfoList.get(0).getWorkOrderNo());
-                                updateWrapper.set("body_status", "3");
+                                updateWrapper.set("head_status", "3");
                                 omProductionOrderInfoService.update(new OmProductionOrderInfo(),updateWrapper);
                             }
                         } else if (Constants.OP310.equals(device)) {
@@ -166,10 +165,10 @@
                             List<OmProductionOrderInfo> omProductionOrderInfoList = omProductionOrderInfoService.selectOmProductionOrderInfoList(omProductionOrderInfo);
                             Object bodyQty = omProductionOrderInfoList.get(0).getBodyQty();
                             if (nowQty == bodyQty){
-                                omProductionOrderInfoList.get(0).setBodyStatus("3");
-
-
-                                omProductionOrderInfoService.updateOmProductionOrderInfo(omProductionOrderInfoList.get(0));
+                                UpdateWrapper<OmProductionOrderInfo> updateWrapper = new UpdateWrapper<>();
+                                updateWrapper.eq("work_order_no", omProductionOrderInfoList.get(0).getWorkOrderNo());
+                                updateWrapper.set("body_status", "3");
+                                omProductionOrderInfoService.update(new OmProductionOrderInfo(),updateWrapper);
                             }
                         }
                     } else if (Constants.P010.equals(device)) {
@@ -186,11 +185,10 @@
                         List<OmProductionOrderInfo> omProductionOrderInfoList = omProductionOrderInfoService.selectOmProductionOrderInfoList(omProductionOrderInfo);
                         Object preQty = omProductionOrderInfoList.get(0).getPreQty();
                         if (nowQty == preQty){
-                            omProductionOrderInfoList.get(0).setPreStatus("3");
-
-
-                            omProductionOrderInfoService.updateOmProductionOrderInfo(omProductionOrderInfoList.get(0));
-
+                            UpdateWrapper<OmProductionOrderInfo> updateWrapper = new UpdateWrapper<>();
+                            updateWrapper.eq("work_order_no", omProductionOrderInfoList.get(0).getWorkOrderNo());
+                            updateWrapper.set("pre_status", "3");
+                            omProductionOrderInfoService.update(new OmProductionOrderInfo(),updateWrapper);
                         }
                     }
                     //鏌ヨdescriptive瀛楁绛変簬1鐨勯噰闆嗛」淇濆瓨鍒版壂鐮佷繚瀛樺埌da_material_collection琛ㄩ噷
@@ -389,7 +387,6 @@
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
                             sysCountService.updateHeadNumber();
                         }
-
                         // 鏇存柊 WorkOrderRequestDone 鍦板潃鍧�
                         BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
                         bsbomChildInfo.setLocationCode(device);

--
Gitblit v1.9.3