| | |
| | | * @description 已完成任务加入历史档 |
| | | * @time 2025/4/3 12:54 |
| | | */ |
| | | @Scheduled(cron = "0 0/01 * * * ? ") |
| | | @Scheduled(cron = "0/15 * * * * ? ") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void taskLogUpdate() { |
| | | LambdaQueryWrapper<Task> queryWrapper = new LambdaQueryWrapper<Task>(); |
| | |
| | | tasks.forEach(task -> { |
| | | TaskLog taskLog = new TaskLog(); |
| | | BeanUtils.copyProperties(task, taskLog); |
| | | taskLog.setTaskId(task.getId()) |
| | | .setId(null); |
| | | taskLog.setTaskId(task.getId()).setId(null); |
| | | if (!taskLogService.save(taskLog)) { |
| | | throw new CoolException("任务历史档保存失败!!"); |
| | | } |
| | | List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId())); |
| | | |
| | | //入库单据明细上报 |
| | | if (task.getTaskType() <= TaskType.TASK_TYPE_CHECK_IN.type) { |
| | | for (TaskItem taskItem : taskItems) { |
| | |
| | | try { |
| | | reportStationStatus(task); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | throw new CoolException(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | LocSiteParams locSiteParams = new LocSiteParams(); |
| | | locSiteParams.setStatus(LocStsType.getLocSts(LocStsType.LOC_STS_TYPE_O.type)) |
| | | locSiteParams |
| | | .setStatus(LocStsType.getRcsLocSts(LocStsType.LOC_STS_TYPE_O.type)) |
| | | .setType("site") |
| | | .setCode(station.getStationName()); |
| | | |