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