| | |
| | | * @description: 自动获取已生成盘点任务的盘点列表 |
| | | * @version 1.0 |
| | | */ |
| | | @Scheduled(cron = "0/25 * * * * ?") |
| | | @Scheduled(cron = "0/5 * * * * ?") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void genReCheck() { |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>() |
| | | .notExists("SELECT 1 FROM man_check_diff_item cdi WHERE id != cdi.task_item_id")); |
| | | List<CheckDiffItem> list = checkDiffItemService.list(new LambdaQueryWrapper<CheckDiffItem>().select(CheckDiffItem::getTaskItemId)); |
| | | if (list.isEmpty()) { |
| | | return; |
| | | } |
| | | List<Long> itemIds = list.stream().map(CheckDiffItem::getTaskItemId).collect(Collectors.toList()); |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().notIn(TaskItem::getId, itemIds)); |
| | | if (taskItems.isEmpty()) { |
| | | return; |
| | | } |
| | |
| | | checkDiff.setAnfme(order.getAnfme()) |
| | | .setCheckType(order.getCheckType()) |
| | | .setOrderCode(order.getCode()) |
| | | .setExceStatus(CheckDiffExceStatus.CHECK_DIFF_EXCE_STATUS_ING.val) |
| | | .setExceStatus(CheckDiffExceStatus.CHECK_DIFF_EXCE_STATUS_INIT.val) |
| | | .setCreateBy(loginUserId) |
| | | .setCreateTime(new Date()) |
| | | .setUpdateBy(loginUserId) |