| | |
|---|
| | | @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();
|
|---|
| | |
|---|
| | | if (task == null) {
|
|---|
| | | return R.error("任务不存在！！");
|
|---|
| | | }
|
|---|
| | | log.info("容器到达接收，任务号：{}，当前状态：{}，上报状态：{}",task.getTaskNo(),task.getTaskSts$(),TaskStsType.WCS_CONTAINER_RECEIVE.desc);
|
|---|
| | | log.info("容器到达接收，任务号：{}，当前状态：{}，上报状态：{}, 接收参数：{}",task.getTaskNo(),task.getTaskSts$(),TaskStsType.WCS_CONTAINER_RECEIVE.desc, JSONObject.toJSONString(arrivedParam));
|
|---|
| | |
|
|---|
| | | taskType = task.getTaskType() > 100 ? "outStock":"inStock";
|
|---|
| | |
|
|---|
| | |
|---|
| | | .setMatnr(orderdetl.getMatnr())
|
|---|
| | | .setDetlId(orderdetl.getDetlId())
|
|---|
| | | .setIoStatus(0)
|
|---|
| | | .setOrderNo(orderdetl.getOrderNo()).setOrderId(orderdetl.getOrderId()).setStatus(1);
|
|---|
| | | .setOrderNo(orderdetl.getOrderNo())
|
|---|
| | | .setOrderId(orderdetl.getOrderId())
|
|---|
| | | .setStatus(1);
|
|---|
| | | waitPakins.add(waitPakin);
|
|---|
| | | });
|
|---|
| | |
|
|---|
