| | |
| | | CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> { |
| | | logger.info("OP100报工开始-工厂MES异步方法"); |
| | | String stationCode = "M1P100";//因为上层系统只支持6位,所有报工工位为M1P100 |
| | | String reportResult = RestfulService.getWorkReportResultFeedback(daParamCollection.getProductBarcode(), stationCode, format.format(new Date())); |
| | | //String reportResult = RestfulService.getWorkReportResultFeedback(daParamCollection.getProductBarcode(), stationCode, format.format(new Date())); |
| | | String reportResult = OPCUaSubscription.getWorkReportResultFeedback(daParamCollection.getProductBarcode(), stationCode, format.format(new Date())); |
| | | JSONObject jsonObject = new JSONObject(reportResult); |
| | | String code = jsonObject.getStr("code"); |
| | | if("success".equals(code)){ |
| | |
| | | |
| | | //半自动工位,先将自动数据保存到数据库 |
| | | public void saveParameters(DaParamCollection daParamCollection) { |
| | | OmProductionOrdeInfo omProductionOrdeInfo = omProductionOrdeInfoService.selectOrderByProductNum(daParamCollection.getProductBarcode()); |
| | | //添加自动工位参数数据 |
| | | //查询参数配置表 |
| | | List<DaCollectionParamConf> list = daCollectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>() |
| | | .eq(DaCollectionParamConf::getProcessesCode, daParamCollection.getLocationCode())//工位 |
| | | .eq(DaCollectionParamConf::getWhetherToCollect, Constants.ONE)//是否采集 |
| | | .eq(DaCollectionParamConf::getProductModel,omProductionOrdeInfo.getProductModel()) |
| | | );//类型 |
| | | |
| | | List<String> collectAddressList = list.stream() |