| | |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|---|
| | | import com.zy.asrs.framework.common.R;
|
|---|
| | | import com.zy.asrs.framework.exception.CoolException;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.domain.EssTaskStatus;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.enums.EssTaskStatus;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.entity.request.*;
|
|---|
| | | import com.zy.asrs.wms.apis.wcs.services.WcsApiService;
|
|---|
| | | import com.zy.asrs.wms.asrs.entity.Task;
|
|---|
| | |
|---|
| | | throw new CoolException(errMsg);
|
|---|
| | | }
|
|---|
| | | } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //上报完成状态
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id) {
|
|---|
| | | taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
|
|---|
| | | //出库任务完成，修改状态为播种中，定时任务生成播种波次
|
|---|
| | | taskStsType = TaskStsType.WAVE_SEED;
|
|---|
| | | } else {
|
|---|
| | | String errMsg = "任务编号：" + task.getTaskNo() + "状态为不匹配，" + "不能执行：" + TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.desc + "任务";
|
|---|
| | | log.error(errMsg);
|
|---|
