| | |
| | | CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> { |
| | | logger.info("OP100报工开始-工厂MES异步方法"); |
| | | String stationCode = "M2P100";//因为上层系统只支持6位,所有报工工位为M2P100 |
| | | 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 static String getWorkReportResultFeedback(String productNum,String stationCode,String confirmTime) |
| | | { |
| | | String result = ""; |
| | | try { |
| | | String url = Constants.FACTORY_EMS_UAT_GET_RUL + "workReportResultFeedback?siteCode="+Constants.FACTORY_EMS_SITE_CODE+"&stationCode="+stationCode+"&productNum="+productNum+"&confirmTime="+confirmTime; |
| | | try { |
| | | log.info("执行工厂MES报工方法start,序列号{}工位号{}url{}",productNum,stationCode ,url); |
| | | HttpResponse response = HttpRequest.get(url).execute(); |
| | | /* HttpRequest httpRequest = HttpRequest.get(url);*/ |
| | | //HttpRequest httpRequest = HttpRequest.get(url); |
| | | result = response.body(); |
| | | log.info("执行工厂MES报工方法第一次end,序列号{}工位号{}返回数据{}",productNum,stationCode ,result); |
| | | }catch (Exception e){ |
| | | throw new RuntimeException(e); |
| | | }finally { |
| | | if(result.isEmpty()){ |
| | | HttpResponse response = HttpRequest.get(url).execute(); |
| | | result = response.body(); |
| | | log.info("执行工厂MES报工方法第二次end,序列号{}工位号{}返回数据{}",productNum,stationCode ,result); |
| | | } |
| | | return result; |
| | | } |
| | | } |