| | |
| | | String productType = productTypeObjcet.toString();//产品类型 |
| | | String materialCode = Constants.materialMap.get(productType); |
| | | //调用工厂MES,保存到数据库,并且将工单传给PLC |
| | | receivingWorkOrders(thoroughfare, device,materialCode); |
| | | CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> { |
| | | receivingWorkOrders(thoroughfare, device,materialCode); |
| | | }); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(11).build()); |
| | | log.info("写入到工位{}的RecordDataDone数据:{}",device,11); |
| | | }else{ |
| | |
| | | } |
| | | } |
| | | |
| | | public void receivingWorkOrders(String thoroughfare ,String device ,String materialCode) |
| | | public synchronized void receivingWorkOrders(String thoroughfare ,String device ,String materialCode) |
| | | { |
| | | String paramProductNum = ""; |
| | | try { |
| | |
| | | //插入参数采集表 |
| | | daParamCollectionService.insertBatch(collectionList); |
| | | |
| | | //如果220工位,进行报工 |
| | | //如果220工位,进行报工,因为上层系统只支持6位,所有报工工位修改为M1P220 |
| | | if("M1OP220".equals(device)) { |
| | | getWorkReportResultFeedback(moduleCode, "M1OP220", format.format(new Date())); |
| | | getWorkReportResultFeedback(moduleCode, "M1P220", format.format(new Date())); |
| | | } |
| | | |
| | | //上传到工厂mes |
| | |
| | | String cellCode = value1.toString(); |
| | | List<DaTestDeviceInterfaceTemp> list = daTestDeviceInterfaceTempService.list(new LambdaQueryWrapper<DaTestDeviceInterfaceTemp>() |
| | | //.eq(DaTestDeviceInterfaceTemp::getStationCode, "M1OP020") |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode)); |
| | | .eq(DaTestDeviceInterfaceTemp::getProductNum,cellCode) |
| | | .orderByDesc(DaTestDeviceInterfaceTemp::getCreateTime) |
| | | ); |
| | | if (CollUtil.isNotEmpty(list)){ |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(list.size()-1); |
| | | DaTestDeviceInterfaceTemp daTestDeviceInterfaceTemp = list.get(0); |
| | | if (Constants.ONE.equals(daTestDeviceInterfaceTemp.getTotalResult())){ |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".CellStatus_1").value(1).build()); |
| | | }else { |