| | |
| | | boolean bool = false; |
| | | try { |
| | | headParam.put("taskNo", taskWrk.getTaskNo()); |
| | | headParam.put("sourceLocNo",taskWrk.getStartPoint());//源库位 |
| | | headParam.put("staNo",taskWrk.getTargetPoint());//目标站 |
| | | headParam.put("sourceLocNo", taskWrk.getStartPoint());//源库位 |
| | | headParam.put("staNo", taskWrk.getTargetPoint());//目标站 |
| | | log.info("wcs派发任务给RCS出库={}", taskWrk); |
| | | response = new HttpHandler.Builder() |
| | | .setUri(wcsUrl) |
| | |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | if(jsonObject.get("code").equals(200)){ |
| | | //派发出库任务给RCS==>成功下发出库任务 |
| | | taskWrk.setWrkSts(11); |
| | | taskWrk.setWrkSts(12); |
| | | taskWrkService.updateById(taskWrk); |
| | | bool = true; |
| | | } |
| | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | public void executeIn() { |
| | | List<TaskWrk> taskWrks = taskWrkService.selectList(new EntityWrapper<TaskWrk>() |
| | | .eq("wrk_sts", 1).eq("io_type", 2)); |
| | | .eq("wrk_sts", 1).eq("io_type", 1)); |
| | | for(TaskWrk taskWrk:taskWrks){ |
| | | HashMap<String, Object> headParam = new HashMap<>(); |
| | | String response = ""; |
| | | boolean bool = false; |
| | | try { |
| | | headParam.put("taskNo", taskWrk.getTaskNo()); |
| | | headParam.put("sourceStaNo",taskWrk.getOriginStartPoint());//源站 |
| | | headParam.put("staNo",taskWrk.getOriginTargetPoint());//目标站 |
| | | headParam.put("locNo",taskWrk.getTargetPoint());//目标库位 |
| | | headParam.put("sourceStaNo", 1000 + Integer.parseInt(taskWrk.getOriginStartPoint()));//源站 |
| | | headParam.put("staNo", 1000 + Integer.parseInt(taskWrk.getOriginTargetPoint()));//目标站 |
| | | headParam.put("locNo", taskWrk.getTargetPoint());//目标库位 |
| | | |
| | | log.info("wcs派发任务给RCS入库={}", taskWrk); |
| | | response = new HttpHandler.Builder() |