| | |
|---|
| | | * @return |
|---|
| | | * @time 2025/4/2 12:37 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron = "0 0/05 * * * ? ") |
|---|
| | | // @Scheduled(cron = "0/5 * * * * ?") |
|---|
| | | // @Scheduled(cron = "0 0/05 * * * ? ") |
|---|
| | | @Scheduled(cron = "0/15 * * * * ?") |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void completeInStock() throws Exception { |
|---|
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_IN.id)); |
|---|
| | |
|---|
| | | if (taskItems.isEmpty()) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | List<TaskLog> taskLogs = new ArrayList<>(); |
|---|
| | | tasks.forEach(task -> { |
|---|
| | | TaskLog taskLog = new TaskLog(); |
|---|
| | |
|---|
| | | throw new CoolException("任务历史档保存失败！！"); |
|---|
| | | } |
|---|
| | | List<TaskItemLog >itemLogs = new ArrayList<>(); |
|---|
| | | |
|---|
| | | taskItems.forEach(item -> { |
|---|
| | | TaskItemLog itemLog = new TaskItemLog(); |
|---|
| | | BeanUtils.copyProperties(item, itemLog); |
|---|
| | | itemLog.setId(null).setTaskItemId(item.getId()); |
|---|
| | | itemLogs.add(itemLog); |
|---|
| | | }); |
|---|
| | | |
|---|
| | | if (!taskItemLogService.saveBatch(itemLogs)) { |
|---|
| | | throw new CoolException("任务明细历史档保存失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (!taskService.removeByIds(list)) { |
|---|
| | | throw new CoolException("原始任务删除失败！！"); |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
