春风项目四线(合箱线、总装线)
yyt
6 天以前 dd44823b3c6cc003de21ea023cea7ea8d85a873c
jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -99,31 +99,33 @@
                        logger.info("-------监听到,{}的扫码枪扫码的CODE_CHECK的信号",identifier);
                        scannerGunMessage();
                    }
//                    if (identifier.equals(OPCElement.OP060_HX_CODE_CHECK) && "1".equals(value.toString())){
//                        Object SNCodeObject = miloService.readFromOpcUa("CFL4HX.OP060.Code1").getValue();
//                        if (null == SNCodeObject){
//                            SNCodeObject = miloService.readFromOpcUa("CFL4HX.OP060.Code").getValue();
//                        }
//                        if (null != SNCodeObject){
//                            String XT="";
//                            String CZ="";
//                            String SNCode = SNCodeObject.toString();
//                            DaParamCollection ParamCollection = new DaParamCollection();
//                            ParamCollection.setSfcCode(SNCode);
//                            List<DaParamCollection> DaParamCollectionlist=daParamCollectionService.selectDaParamCollectionList(ParamCollection);
//                            List<DaParamCollection> XTParamCollection = DaParamCollectionlist.stream().filter(x -> "箱体".equals(x.getParamName())).collect(Collectors.toList());
//                            if (CollUtil.isNotEmpty(XTParamCollection)){
//                                DaParamCollection lastOne = XTParamCollection.get(0);
//                                XT = lastOne.getParamValue();
//                            }
//                            List<DaParamCollection> CZParamCollection = DaParamCollectionlist.stream().filter(x -> "曲轴".equals(x.getParamName())).collect(Collectors.toList());
//                            if (CollUtil.isNotEmpty(CZParamCollection)){
//                                DaParamCollection lastOne = CZParamCollection.get(0);
//                                CZ = lastOne.getParamValue();
//                            }
//                            passingStationCollectionServiceImpl.sendMessage(XT+"*"+CZ,"OP060");
//                        }
//                    }
                    if (identifier.equals(OPCElement.OP060_HX_CODE_CHECK) && "1".equals(value.toString())){
                        Object SNCodeObject = miloService.readFromOpcUa("CFL4HX.OP060.Code1").getValue();
                        if (null == SNCodeObject){
                            SNCodeObject = miloService.readFromOpcUa("CFL4HX.OP060.Code").getValue();
                        }
                        if (null != SNCodeObject){
                            String XT=null;
                            String CZ=null;
                            String SNCode = SNCodeObject.toString();
                            DaParamCollection ParamCollection = new DaParamCollection();
                            ParamCollection.setSfcCode(SNCode);
                            List<DaParamCollection> DaParamCollectionlist=daParamCollectionService.selectDaParamCollectionList(ParamCollection);
                            List<DaParamCollection> XTParamCollection = DaParamCollectionlist.stream().filter(x -> "箱体".equals(x.getParamName())).collect(Collectors.toList());
                            if (CollUtil.isNotEmpty(XTParamCollection)){
                                DaParamCollection lastOne = XTParamCollection.get(0);
                                XT = lastOne.getParamValue();
                            }
                            List<DaParamCollection> CZParamCollection = DaParamCollectionlist.stream().filter(x -> "曲轴".equals(x.getParamName())).collect(Collectors.toList());
                            if (CollUtil.isNotEmpty(CZParamCollection)){
                                DaParamCollection lastOne = CZParamCollection.get(0);
                                CZ = lastOne.getParamValue();
                            }
                            if(null != XT&&null != CZ) {
                                passingStationCollectionServiceImpl.sendMessage(XT+"*"+CZ,"OP060");
                            }
                        }
                    }
                }
                if (collect2.contains(identifier)){
                    if ("1".equals(value.toString())){