| | |
|---|
| | | } |
|---|
| | | LambdaQueryWrapper<BigStorageCageFeedTask> wrapper = new LambdaQueryWrapper<BigStorageCageFeedTask>() |
|---|
| | | .eq(BigStorageCageFeedTask::getTaskType, Const.BIG_STORAGE_IN_RUN) |
|---|
| | | .and(e -> e.isNull(BigStorageCageFeedTask::getTargetSlot).or().eq(BigStorageCageFeedTask::getTargetSlot, Const.OUT_TARGET_POSITION_ZERO)) |
|---|
| | | .eq(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP); |
|---|
| | | //获取可以启动卧转立的任务线路 |
|---|
| | | List<BigStorageCageFeedTask> feedTaskList = bigStorageCageFeedTaskService.list(wrapper); |
|---|
| | |
|---|
| | | // log.info("两条线都存在进片任务，结束任务"); |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | //获取两条线卧转立是否有玻璃，且任务状态都为2 |
|---|
| | | //获取两条线卧转立是否有玻璃，且任务状态为1/2 |
|---|
| | | List<Integer> lineList = bigStorageCageFeedTaskService.querySitToUpGlass(); |
|---|
| | | if (CollectionUtils.isEmpty(lineList)) { |
|---|
| | | Date endDate = new Date(); |
|---|
| | |
|---|
| | | */ |
|---|
| | | public Integer getStartLine() { |
|---|
| | | List<BigStorageCageFeedTask> taskList = bigStorageCageFeedTaskService.list(new LambdaQueryWrapper<BigStorageCageFeedTask>() |
|---|
| | | .inSql(BigStorageCageFeedTask::getId, "select min(id) from big_storage_cage_feed_task where task_state = 2 group by line")); |
|---|
| | | .inSql(BigStorageCageFeedTask::getId, "select min(id) from big_storage_cage_feed_task where task_state = 2" + |
|---|
| | | "and (target_slot = 0 or target_slot is null) group by line")); |
|---|
| | | Assert.isFalse(CollectionUtils.isEmpty(taskList), "卧转立两条线都没有玻璃进片任务"); |
|---|
| | | Map<String, Integer> taskMap = taskList.stream().collect(Collectors.toMap(BigStorageCageFeedTask::getGlassId, |
|---|
| | | BigStorageCageFeedTask::getLine)); |
|---|
| | |
|---|
| | | //1、获取任务表中的所有玻璃（指定线路且已经进卧转立完成） |
|---|
| | | List<BigStorageCageFeedTask> taskList = bigStorageCageFeedTaskService.list(new LambdaQueryWrapper<BigStorageCageFeedTask>() |
|---|
| | | .eq(BigStorageCageFeedTask::getLine, line) |
|---|
| | | .and(e -> e.isNull(BigStorageCageFeedTask::getTargetSlot).or().eq(BigStorageCageFeedTask::getTargetSlot, Const.OUT_TARGET_POSITION_ZERO)) |
|---|
| | | .in(BigStorageCageFeedTask::getTaskState, Const.BIG_STORAGE_IN_UP_ALL) |
|---|
| | | .orderByAsc(BigStorageCageFeedTask::getId)); |
|---|
| | | //2、去笼子内查找是否可以继续存放的笼子 |
|---|
| | |
|---|
| | | //打车剩余尺寸 |
|---|
| | | Integer remainWidth = carWidth; |
|---|
| | | for (T e : list) { |
|---|
| | | if (bigStorageCageOutTaskList.size() > outCarMaxSize || e.getWidth() > remainWidth) { |
|---|
| | | if (bigStorageCageOutTaskList.size() >= outCarMaxSize || e.getWidth() > remainWidth) { |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | remainWidth = remainWidth - (int) e.getWidth() - glassGap; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 更新笼子内格子的剩余尺寸 |
|---|
| | | * |
|---|
| | | * @param list |
|---|
| | | * @param taskGlassIds |
|---|
| | | * @param list 笼内可以出笼的玻璃信息 |
|---|
| | | * @param taskGlassIds 本次任务出去的玻璃ids |
|---|
| | | * @param <T> |
|---|
| | | */ |
|---|
| | | public <T extends BigStorageCageBaseInfo> void updateSlotRemain(List<T> list, List<String> taskGlassIds) { |
|---|
| | | //获取需要出去（包括待出去的）的所有玻璃格子号 |
|---|
| | | List<Integer> slotList = list.stream().map(T::getSlot).distinct().collect(Collectors.toList()); |
|---|
| | | //获取待出去的玻璃信息（等下车出去的玻璃） |
|---|
| | | //获取待出去的玻璃信息（等待本次任务结束后下车出去的玻璃） |
|---|
| | | Map<Integer, Double> slotRemainMap = list.stream().filter(e -> !taskGlassIds.contains(e.getGlassId())) |
|---|
| | | .collect(Collectors.groupingBy(T::getSlot, Collectors.summingDouble(item -> item.getWidth() + glassGap))); |
|---|
| | | if (CollectionUtils.isNotEmpty(slotRemainMap)) { |
|---|
