添加定时任务--出库任务

skyouc

2 天以前 4b1c3470712263e8ff9feb7749eebab2c1c6b25a

添加定时任务--出库任务

 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/ScheduleJobs.java

@@ -159,6 +159,7 @@
                .setAsnCode(asnOrder.getCode())
                .setAsnId(asnOrder.getId())
                .setProdTime(orderItem.getProdTime())
                .setPlatItemId(orderItem.getPlatItemId())
                .setPlatOrderCode(orderItem.getPlatOrderCode())
                .setPlatWorkCode(orderItem.getPlatWorkCode())
                .setProjectCode(orderItem.getProjectCode())

 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java

@@ -65,6 +65,21 @@
        taskService.completeTask(tasks);
    }

    /**
     * @author Ryan
     * @date 2025/5/20
     * @description: 完成出库任务，更新库存
     * @version 1.0
     */
    @Scheduled(cron = "0/5 * * * * ?")
    @Transactional(rollbackFor = Exception.class)
    public void complateOutStock() throws Exception {
        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_OUT.id));
        if (tasks.isEmpty()) {
            return;
        }
        taskService.completeTask(tasks);
    }

    /**
    * @author Ryan

 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/TaskService.java

@@ -17,6 +17,6 @@
    R generateAGVTasks(WaitPakin waitPakins,String locCode,String orgSta, Long loginUserId);

//    R completeTask(String id);
     void completeTask(List<Task> task) throws Exception;

    void completeTask(List<Task> task) throws Exception;
}

 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java

@@ -371,7 +371,7 @@
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void completeTask(List<Task> tasks) throws Exception {
    public synchronized void completeTask(List<Task> tasks) throws Exception {
        for (Task task : tasks) {
            if (task.getTaskType() < TaskType.TASK_TYPE_OUT.type) {
                //入库任务
@@ -390,7 +390,7 @@
     * @version 1.0
     */
    @Transactional(rollbackFor = Exception.class)
    public void complateOutStock(Task task) {
    public synchronized void complateOutStock(Task task) {
        if (Objects.isNull(task)) {
            return;
        }