| | |
| | | package com.zy.common.service; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
| | | import com.core.common.Cools; |
| | | import com.core.exception.CoolException; |
| | |
| | | wrkMast.setLocNo(param.getLocNo()); // 目标库位 |
| | | wrkMast.setCrnNo(crnNo); |
| | | wrkMast.setWmsWrkNo(param.getTaskNo()); |
| | | wrkMast.setBarcode(sourceLocMast.getBarcode()); |
| | | wrkMast.setAppeTime(now); |
| | | wrkMast.setModiTime(now); |
| | | boolean res = wrkMastService.insert(wrkMast); |
| | |
| | | } |
| | | |
| | | //入库任务 |
| | | public boolean createInTask(CreateInTaskParam param) { |
| | | public WrkMast createInTask(CreateInTaskParam param) { |
| | | Date now = new Date(); |
| | | LocMast locMast = locMastService.queryByLoc(param.getLocNo()); |
| | | if (null == locMast) { |
| | |
| | | |
| | | //缓存记录当前命令堆垛机编号 |
| | | redisUtil.set(RedisKeyType.CURRENT_CIRCLE_TASK_CRN_NO.key, crnNo, 60 * 60 * 24); |
| | | return true; |
| | | return wrkMast; |
| | | } |
| | | |
| | | //出库任务 |
| | |
| | | public Integer findCrnNoByLocNo(String locNo) { |
| | | List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>()); |
| | | for (BasCrnp basCrnp : basCrnps) { |
| | | String controlRows = basCrnp.getControlRows(); |
| | | if (Cools.isEmpty(controlRows)) { |
| | | continue; |
| | | } |
| | | |
| | | List<Integer> rowList = JSON.parseArray(controlRows, Integer.class); |
| | | if(rowList.contains(Utils.getRow(locNo))) { |
| | | return basCrnp.getCrnNo(); |
| | | List<List<Integer>> rowList = basCrnp.getControlRows$(); |
| | | for (List<Integer> rows : rowList) { |
| | | if(rows.contains(Utils.getRow(locNo))) { |
| | | return basCrnp.getCrnNo(); |
| | | } |
| | | } |
| | | } |
| | | return null; |