| | |
| | | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cn.hutool.core.util.ObjectUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.hutool.json.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | |
| | | import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; |
| | | import com.jcdm.main.da.passingStationCollection.domain.DaPassingStationCollection; |
| | | import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; |
| | | import com.jcdm.main.da.testDeviceInterface.domain.DaTestDeviceInterface; |
| | | import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService; |
| | | import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; |
| | | import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; |
| | | import com.jcdm.main.plcserver.conf.OPCElement; |
| | |
| | | |
| | | public static IOmProductionOrdeInfoService omProductionOrdeInfoService; |
| | | |
| | | private static IDaTestDeviceInterfaceService daTestDeviceInterfaceService; |
| | | |
| | | |
| | | public OPCUaSubscription(MiloService miloService, |
| | | IDaPassingStationCollectionService daPassingStationCollectionService, |
| | | IDaCollectionParamConfService collectionParamConfService, |
| | | IDaParamCollectionService daParamCollectionService, |
| | | IOmProductionOrdeInfoService omProductionOrdeInfoService) { |
| | | IOmProductionOrdeInfoService omProductionOrdeInfoService, |
| | | IDaTestDeviceInterfaceService daTestDeviceInterfaceService) { |
| | | OPCUaSubscription.miloService = miloService; |
| | | this.daPassingStationCollectionService = daPassingStationCollectionService; |
| | | OPCUaSubscription.collectionParamConfService = collectionParamConfService; |
| | | OPCUaSubscription.daParamCollectionService = daParamCollectionService; |
| | | OPCUaSubscription.omProductionOrdeInfoService = omProductionOrdeInfoService; |
| | | OPCUaSubscription.daTestDeviceInterfaceService = daTestDeviceInterfaceService; |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | if(testList.stream().anyMatch(s -> s.equals(device))){ |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build()); |
| | | // Object packCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".ModuleCode").getValue(); |
| | | // DaTestDeviceInterface deviceInterfaceOne = null; |
| | | // |
| | | // if (ObjectUtil.isNotNull(packCodeObject)) { |
| | | // String modelCode = packCodeObject.toString(); |
| | | // deviceInterfaceOne = daTestDeviceInterfaceService.getOne(new LambdaQueryWrapper<DaTestDeviceInterface>() |
| | | // .eq(DaTestDeviceInterface::getProductNum, modelCode) |
| | | // .eq(DaTestDeviceInterface::getStationCode, device)); |
| | | // } |
| | | // |
| | | // if (deviceInterfaceOne != null && "1".equals(deviceInterfaceOne.getTotalResult())) { |
| | | // writeToOpc(RecordDataDoneAddress, (short) 21); |
| | | // } else { |
| | | // writeToOpc(RecordDataDoneAddress, (short) 22); |
| | | // } |
| | | writeToOpc(RecordDataDoneAddress, (short) 21); |
| | | } |
| | | |
| | | |
| | | } |
| | | }else { |
| | | System.out.println("^"); |
| | |
| | | return; |
| | | } |
| | | |
| | | private static void writeToOpc(String identifier, short value) { |
| | | try { |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(identifier).value(value).build()); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |
| | | } |