blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
Junjie
2024-11-28 a19133219811f9286fa71a0fb8c1deb628cf74a3 
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/timer/TaskTimer.java


@@ -6,6 +6,7 @@


import com.zy.asrs.framework.exception.CoolException;


import com.zy.asrs.wms.asrs.entity.*;


import com.zy.asrs.wms.asrs.entity.enums.LocStsType;


import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;


import com.zy.asrs.wms.asrs.service.*;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.scheduling.annotation.Scheduled;


@@ -62,7 +63,7 @@


        InterceptorIgnoreHelper.handle(IgnoreStrategy.builder().tenantLine(true).build());


        try {


            //获取入库完成任务


            List<Task> list = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, 99));


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


            if (list.isEmpty()) {


                return;


            }


@@ -80,7 +81,7 @@


                        throw new CoolException("未知任务类型");


                }




                task.setTaskSts(100L);//100.库存更新完成


                task.setTaskSts(TaskStsType.UPDATED_IN.id);//100.库存更新完成


                task.setUpdateTime(new Date());


                if (!taskService.updateById(task)) {


                    throw new CoolException("库存更新失败");


@@ -100,7 +101,7 @@


        InterceptorIgnoreHelper.handle(IgnoreStrategy.builder().tenantLine(true).build());


        try {


            //获取出库完成任务


            List<Task> list = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, 199));


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


            if (list.isEmpty()) {


                return;


            }


@@ -117,7 +118,7 @@


                        throw new CoolException("未知任务类型");


                }




                task.setTaskSts(200L);//200.库存更新完成


                task.setTaskSts(TaskStsType.UPDATED_OUT.id);//200.库存更新完成


                if (!taskService.updateById(task)) {


                    throw new CoolException("库存更新失败");


                }