| | |
| | | * @time 2025/4/2 12:37 |
| | | */ |
| | | @Scheduled(cron = "0/3 * * * * ?") |
| | | // @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 (tasks.isEmpty()) { |
| | |
| | | * @description: 完成出库任务,更新库存 |
| | | * @version 1.0 |
| | | */ |
| | | @Scheduled(cron = "0/30 * * * * ? ") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | @Scheduled(cron = "0/5 * * * * ? ") |
| | | public void complateOutStock() throws Exception { |
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_OUT.id)); |
| | | if (tasks.isEmpty()) { |
| | |
| | | * @description 已完成任务加入历史档 |
| | | * @time 2025/4/3 12:54 |
| | | */ |
| | | @Scheduled(cron = "0 0/05 * * * ? ") |
| | | @Scheduled(cron = "0 0/01 * * * ? ") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void taskLogUpdate() { |
| | | LambdaQueryWrapper<Task> queryWrapper = new LambdaQueryWrapper<Task>(); |
| | | Config config = configService.getOne(new LambdaQueryWrapper<Config>().eq(Config::getFlag, GlobalConfigCode.ORDER_INOF_REPORT_PLAT)); |
| | | if (!Objects.isNull(config)) { |
| | | if (Boolean.parseBoolean(config.getVal())) { |
| | | queryWrapper.eq(Task::getTaskStatus, TaskStsType.REPORT_IN.id); |
| | | queryWrapper.in(Task::getTaskStatus, TaskStsType.REPORT_IN.id); |
| | | } else { |
| | | queryWrapper.eq(Task::getTaskStatus, TaskStsType.UPDATED_IN.id); |
| | | queryWrapper.in(Task::getTaskStatus, TaskStsType.UPDATED_IN.id, TaskStsType.UPDATED_OUT.id); |
| | | } |
| | | } else { |
| | | queryWrapper.eq(Task::getTaskStatus, TaskStsType.UPDATED_IN.id); |
| | | queryWrapper.in(Task::getTaskStatus, TaskStsType.UPDATED_IN.id, TaskStsType.UPDATED_OUT.id); |
| | | } |
| | | List<Task> tasks = taskService.list(queryWrapper); |
| | | if (tasks.isEmpty()) { |