add open write

wujian

2024-04-20 f6b9ee557155c205ea465f494292317d33541068

add open write

 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java

@@ -111,7 +111,7 @@
                                if (0==i){
                                    map.put(identifier + "的saveRequest的信号",i+1);
                                }
//                                miloService.writeToOpcByte(entity);
                                miloService.writeToOpcByte(entity);
                            }else if ("SaveRequestLast".equals(parts[2])){
                                ReadWriteEntity entity = new ReadWriteEntity(parts[0] + "." + parts[1] + ".SaveFeedLast", 1);
                                log.info("-------监听到,{}的SaveRequestLast的信号",identifier);
@@ -119,7 +119,7 @@
                                if (0==i){
                                    map.put(identifier + "的SaveRequestLast的信号",i+1);
                                }
//                                miloService.writeToOpcByte(entity);
                                miloService.writeToOpcByte(entity);
                            }
                        }
                    }
@@ -175,20 +175,20 @@
                        }

                        ReadWriteEntity entity2 = new ReadWriteEntity(parts[0]+"."+parts[1]+".OrderNumber", orderNum);
//                        miloService.writeToOpcByte(entity2);
                        miloService.writeToOpcByte(entity2);
                    }
                    //如果是返修工位需要传输返修工位号
                    if (OPCElement.OP465_ZZ_CODE_CHECK.equals(Node) || OPCElement.OP355_ZZ_CODE_CHECK.equals(Node)){
                        rework(SNCode);
                    }
//                miloService.writeToOpcByte(entity);
                miloService.writeToOpcByte(entity);
                }

            }
        }
    }

    private void rework(String SNCode) {
    private void rework(String SNCode)  throws Exception{
        BsOrderScheduling bsOrderScheduling = new BsOrderScheduling();
        bsOrderScheduling.setEngineNo(SNCode);
        List<String> allProcessCoed = new ArrayList<>();
@@ -227,13 +227,11 @@
                writeList.add(readWriteEntity);
            });
        }
        if (CollUtil.isNotEmpty(writeList)){
            ReadWriteEntity readWriteEntity = new ReadWriteEntity();
            readWriteEntity.setIdentifier("Repair_sign");
            readWriteEntity.setValue(1);
            writeList.add(readWriteEntity);
//                            miloService.writeToOpcByte(writeList);
        }
        ReadWriteEntity readWriteEntity = new ReadWriteEntity();
        readWriteEntity.setIdentifier("Repair_sign");
        readWriteEntity.setValue(1);
        writeList.add(readWriteEntity);
        miloService.writeToOpcByte(writeList);
    }