blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
skyouc
2025-05-30 1de6b39bfe3967916dcab8122be0d69fbaba8cca 
 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java


@@ -17,10 +17,7 @@


import org.springframework.stereotype.Component;


import org.springframework.transaction.annotation.Transactional;




import java.util.ArrayList;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.*;


import java.util.stream.Collectors;




/**


@@ -52,11 +49,13 @@


     */


    @Scheduled(cron = "0/3 * * * * ?")


    public void completeInStock() throws Exception {


        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_IN.id));


        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_IN.id).select(Task::getId));


        if (tasks.isEmpty()) {


            return;


        }


        taskService.complateInTask(tasks);


        List<Long> longSet = tasks.stream().map(Task::getId).collect(Collectors.toList());


        List<Task> vaildTasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, longSet));


        taskService.complateInTask(vaildTasks);


    }




    /**


@@ -67,11 +66,15 @@


     */


    @Scheduled(cron = "0/5 * * * * ?  ")


    public void complateOutStock() throws Exception {


        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskStatus, TaskStsType.COMPLETE_OUT.id));


        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()


                .eq(Task::getTaskStatus, TaskStsType.COMPLETE_OUT.id)


                .select(Task::getId));


        if (tasks.isEmpty()) {


            return;


        }


        taskService.completeTask(tasks);


        List<Long> longSet = tasks.stream().map(Task::getId).collect(Collectors.toList());


        List<Task> vaildTasks = taskService.list(new LambdaQueryWrapper<Task>().in(Task::getId, longSet));


        taskService.completeTask(vaildTasks);


    }




    /**