| | |
| | | .or().eq("io_type",11)); |
| | | if(!Cools.isEmpty(agvWrkMastList)){ |
| | | agvWrkMastList.stream().forEach(agvWrkMast -> { |
| | | ReturnT<String> returnT = agvWrkMastHandler.completedPutWayWrk(agvWrkMast); |
| | | agvWrkMastHandler.completedPutWayWrk(agvWrkMast); |
| | | }); |
| | | } |
| | | } |
| | |
| | | List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50) |
| | | ,new EntityWrapper<AgvWrkMast>() |
| | | .eq("wrk_sts", 21) |
| | | .like("loc_no","@") |
| | | .andNew().eq("io_type", 101) |
| | | .or().eq("io_type", 103) |
| | | .or().eq("io_type", 11) |
| | |
| | | } |
| | | } |
| | | } |
| | | |
| | | /* |
| | | 定时处理等待执行的任务 工作状态为21.生成出库任务 且目标库位中不含@字符 |
| | | */ |
| | | @Scheduled(cron = "0/5 * * * * ? ") |
| | | public void dealWatiWrk(){ |
| | | List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("wrk_sts", 21).like(false, "loc_no", "@")); |
| | | if(!Cools.isEmpty(agvWrkMastList)){ |
| | | try { |
| | | ReturnT<String> returnT = agvWrkMastHandler.dealWatiWrk(agvWrkMastList); |
| | | } catch (IOException e) { |
| | | log.error(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |