| | |
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void conveyorStart() {
|
|---|
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()
|
|---|
| | | .eq(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id).eq(Task::getStatus, 1));
|
|---|
| | | .eq(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)
|
|---|
| | | .eq(Task::getStatus, 1));
|
|---|
| | | tasks.forEach(task -> {
|
|---|
| | | try {
|
|---|
| | | ConveyorStarParam conveyorStarParam = new ConveyorStarParam();
|
|---|
| | |
|---|
| | | }
|
|---|
| | | } catch (Exception ex) {
|
|---|
| | | log.error(ex.getMessage());
|
|---|
| | | } finally {
|
|---|
| | | //如果异常修改禁用状态
|
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>().set(Task::getStatus, 0).eq(Task::getId, task.getId()));
|
|---|
| | | }
|
|---|
| | | });
|
|---|
| | |
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 生成自动盘点任务
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/50 * * * * ?")
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | // @Scheduled(cron = "0/50 * * * * ?")
|
|---|
| | | // @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void genCheckTask() {
|
|---|
| | | Loc locs = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getLocStsId, LocStsType.F.val()).orderByAsc(Loc::getLocNo).last("limit 1"));
|
|---|
| | | if (Objects.isNull(locs)) {
|
|---|
| | |
|---|
| | | throw new CoolException("库位状态修改失败！！");
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | /***
|
|---|
| | | * 入库任务---下发入库任务
|
|---|
