| | |
| | | |
| | | /** |
| | | * 自动上报开始 |
| | | * |
| | | * @throws IOException |
| | | */ |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | public synchronized void execute() throws IOException { |
| | | List<TaskWrk> taskWrks=taskWrkService.selectList(new EntityWrapper<TaskWrk>().eq("status",1).in("wrk_sts",12,13,3,4)); |
| | | if(taskWrks.size()>0){ |
| | | for(TaskWrk taskWrk:taskWrks){ |
| | | if(Cools.isEmpty(taskWrk.getMarkStart())||taskWrk.getMarkStart()==0){ |
| | | List<TaskWrk> taskWrks = taskWrkService.selectList(new EntityWrapper<TaskWrk>().eq("status", 1).in("wrk_sts", 12, 13, 2, 3, 4)); |
| | | if (taskWrks.size() > 0) { |
| | | for (TaskWrk taskWrk : taskWrks) { |
| | | if (Cools.isEmpty(taskWrk.getMarkStart()) || taskWrk.getMarkStart() == 0) { |
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
| | | hashMap.put("TaskNo",taskWrk.getTaskNo()); |
| | | hashMap.put("TaskNo", taskWrk.getTaskNo()); |
| | | String response = ""; |
| | | Boolean bool = false; |
| | | try { |
| | |
| | | .doPost(); |
| | | JSONObject jsonObject = JSON.parseObject(response); |
| | | |
| | | if(jsonObject.get("ReturnStatus").equals(0)){ |
| | | if (jsonObject.get("ReturnStatus").equals(0)) { |
| | | bool = true; |
| | | taskWrk.setMarkStart(1); |
| | | taskWrk.setStatus(2); |
| | |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | | }finally { |
| | | } finally { |
| | | apiLogService.save("wcs开始任务上报wms" |
| | | , wmsUrl + TaskExecCallback |
| | | , null |