From 4cb4e41df7c2cc7954e09ef3751ecb24de7c06d2 Mon Sep 17 00:00:00 2001
From: hdy <1105738590@qq.com>
Date: 星期五, 14 三月 2025 13:28:25 +0800
Subject: [PATCH] 修改

---
 billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java |   61 ++++++++++++++++++------------
 1 files changed, 37 insertions(+), 24 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 15e7766..20c97d0 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
@@ -148,10 +148,22 @@
                         omOrderScheduling.setStatus("1");
                         //鎵樼洏缁戝畾SFCCode鍜屽伐鍗曞拰浜х嚎
                         if(Constants.OP005.equals(device)){
+                            omProductionOrderInfoService.updateBodyStatus1();
                             omOrderScheduling.setRemarks("Body");
+                            sysCountService.updateSerialNumber();
+                            OmProductionOrderInfo getBodyOrder2 = omProductionOrderInfoService.getBodyOrder();
+                            if (Objects.equals(getBodyOrder2.getBodyQty(), getBodyOrder2.getPlanQty())){
+                                omProductionOrderInfoService.updateBodyStatus2();
+                            }
                         }
                         if(Constants.C005.equals(device)){
+                            omProductionOrderInfoService.updateHeadStatus1();
                             omOrderScheduling.setRemarks("Head");
+                            sysCountService.updateHeadNumber();
+                            OmProductionOrderInfo getHeadOrder2 = omProductionOrderInfoService.getHeadOrder();
+                            if (Objects.equals(getHeadOrder2.getHeadQty(), getHeadOrder2.getPlanQty())){
+                                omProductionOrderInfoService.updateHeadStatus2();
+                            }
                         }
                         omOrderSchedulingService.insertOmOrderScheduling(omOrderScheduling);
                     }else if(Constants.OFFLINE.contains(device)){
@@ -208,6 +220,13 @@
                             updateWrapper.eq("work_order_no", omProductionOrderInfoList.get(0).getWorkOrderNo());
                             updateWrapper.set("pre_status", "2");
                             omProductionOrderInfoService.update(new OmProductionOrderInfo(),updateWrapper);
+                        }
+
+                        sysCountService.updatePreNumber();
+                        omProductionOrderInfoService.updatePreStatus1();
+                        OmProductionOrderInfo getPreOrder2 = omProductionOrderInfoService.getPreOrder();
+                        if (Objects.equals(getPreOrder2.getPreQty(), getPreOrder2.getPlanQty())){
+                            omProductionOrderInfoService.updatePreStatus2();
                         }
                     }
                     //鏌ヨdescriptive瀛楁绛変簬1鐨勯噰闆嗛」淇濆瓨鍒版壂鐮佷繚瀛樺埌da_material_collection琛ㄩ噷
@@ -317,7 +336,6 @@
                                 String SFCCode = A1 + A2 + A3+ A4 + A5;
                                 miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                                 miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                                sysCountService.updateSerialNumber();
                             }else{
                                 sysCountService.clean();
                                 sysCountService.updateYear();
@@ -329,7 +347,6 @@
                                 String SFCCode = A1 + A2 + newA3+ A4 + A5;
                                 miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                                 miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                                sysCountService.updateSerialNumber();
                             }
                             // 鏇存柊 WorkOrderRequestDone 鍦板潃鍧�
                             BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
@@ -337,13 +354,13 @@
                             bsbomChildInfo.setBomCode(getBodyOrder.getWorkOrderNo());
                             //鍙戜笅宸ヨ壓閰嶆柟
                             formula(thoroughfare, device, bsbomChildInfo);
-                            omProductionOrderInfoService.updateBodyStatus1();
+//                          omProductionOrderInfoService.updateBodyStatus1();
                             //鍒ゆ柇缂镐綋宸ュ崟瀹屾垚
-                            OmProductionOrderInfo getBodyOrder2 = omProductionOrderInfoService.getBodyOrder();
-                            if (Objects.equals(getBodyOrder2.getBodyQty(), getBodyOrder2.getPlanQty())){
-                                omProductionOrderInfoService.updateBodyStatus2();
-                            }
-                            String PalletID = getBodyOrder2.getBodyQty().toString();
+//                            OmProductionOrderInfo getBodyOrder2 = omProductionOrderInfoService.getBodyOrder();
+//                            if (Objects.equals(getBodyOrder2.getBodyQty(), getBodyOrder2.getPlanQty())){
+//                                omProductionOrderInfoService.updateBodyStatus2();
+//                            }
+                            String PalletID = String.valueOf(getBodyOrder.getBodyQty() + 1);
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".PalletID").value(PalletID).build());
                             miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".WorkOrderRequestDone").value(11).build());
                     }
@@ -370,7 +387,6 @@
                             String SFCCode = A1 + A2 + A3+ A4 + A5;
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                            sysCountService.updateHeadNumber();
                         }else{
                             sysCountService.clean();
                             sysCountService.updateYear();
@@ -382,7 +398,6 @@
                             String SFCCode = A1 + A2 + newA3+ A4 + A5;
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                            sysCountService.updateHeadNumber();
                         }
                         // 鏇存柊 WorkOrderRequestDone 鍦板潃鍧�
                         BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
@@ -390,13 +405,13 @@
                         bsbomChildInfo.setBomCode(getHeadOrder.getWorkOrderNo());
                         //鍙戜笅宸ヨ壓閰嶆柟
                         formula(thoroughfare, device, bsbomChildInfo);
-                        omProductionOrderInfoService.updateHeadStatus1();
+//                        omProductionOrderInfoService.updateHeadStatus1();
                         //鍒ゆ柇缂镐綋宸ュ崟瀹屾垚
-                        OmProductionOrderInfo getHeadOrder2 = omProductionOrderInfoService.getHeadOrder();
-                        if (Objects.equals(getHeadOrder2.getHeadQty(), getHeadOrder2.getPlanQty())){
-                            omProductionOrderInfoService.updateHeadStatus2();
-                        }
-                        String PalletID = getHeadOrder2.getHeadQty().toString();
+//                        OmProductionOrderInfo getHeadOrder2 = omProductionOrderInfoService.getHeadOrder();
+//                        if (Objects.equals(getHeadOrder2.getHeadQty(), getHeadOrder2.getPlanQty())){
+//                            omProductionOrderInfoService.updateHeadStatus2();
+//                        }
+                        String PalletID = String.valueOf(getHeadOrder.getHeadQty() + 1);
                         miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".PalletID").value(PalletID).build());
                         miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".WorkOrderRequestDone").value(11).build());
                     }
@@ -422,7 +437,6 @@
                             String SFCCode = A1 + A2 + A3+ A4 + A5;
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                            sysCountService.updatePreNumber();
                         }else{
                             sysCountService.clean();
                             sysCountService.updateYear();
@@ -434,7 +448,6 @@
                             String SFCCode = A1 + A2 + newA3+ A4 + A5;
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SFCCode").value(SFCCode).build());
                             miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".MESSFCCode").value(SFCCode).build());
-                            sysCountService.updateHeadNumber();
                         }
                         // 鏇存柊 WorkOrderRequestDone 鍦板潃鍧�
                         BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
@@ -442,13 +455,13 @@
                         bsbomChildInfo.setBomCode(getPreOrder.getWorkOrderNo());
                         //鍙戜笅宸ヨ壓閰嶆柟
                         formula(thoroughfare, device, bsbomChildInfo);
-                        omProductionOrderInfoService.updatePreStatus1();
+//                        omProductionOrderInfoService.updatePreStatus1();
                         //鍒ゆ柇缂镐綋宸ュ崟瀹屾垚
-                        OmProductionOrderInfo getPreOrder2 = omProductionOrderInfoService.getPreOrder();
-                        if (Objects.equals(getPreOrder2.getPreQty(), getPreOrder2.getPlanQty())){
-                            omProductionOrderInfoService.updatePreStatus2();
-                        }
-                        String PalletID = getPreOrder2.getPreQty().toString();
+//                        OmProductionOrderInfo getPreOrder2 = omProductionOrderInfoService.getPreOrder();
+//                        if (Objects.equals(getPreOrder2.getPreQty(), getPreOrder2.getPlanQty())){
+//                            omProductionOrderInfoService.updatePreStatus2();
+//                        }
+                        String PalletID = String.valueOf(getPreOrder.getPreQty() + 1);
                         miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".PalletID").value(PalletID).build());
                         miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".WorkOrderRequestDone").value(11).build());
                     }

--
Gitblit v1.9.3