| | |
|---|
| | | * 任务自动下发 |
|---|
| | | * @throws Exception |
|---|
| | | */ |
|---|
| | | // @Scheduled(cron = "0/5 * * * * ? ") |
|---|
| | | @Scheduled(cron = "0/5 * * * * ? ") |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void taskToWCS() throws Exception { |
|---|
| | | Long loginUserId = SystemAuthUtils.getLoginUserId(); |
|---|
| | |
|---|
| | | LocToTaskParams params = new LocToTaskParams(); |
|---|
| | | params.setOrgLoc(shallowLoc).setType(TaskType.TASK_TYPE_LOC_MOVE.type + ""); |
|---|
| | | //生成移库任务 |
|---|
| | | locItemService.genMoveTask(params, loginUserId); |
|---|
| | | Task moveTask = locItemService.genMoveTask(params, loginUserId); |
|---|
| | | moveTask.setSort(task.getSort() + 1); |
|---|
| | | if (!taskService.updateById(moveTask)) { |
|---|
| | | throw new Exception("任务优先级更新失败！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //TODO 调用下发任务接口 |
|---|
| | | } |
|---|
| | |
|---|
| | | @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)); |
|---|
| | | 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.in(Task::getTaskStatus, TaskStsType.REPORT_IN.id); |
|---|
