| | |
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)
|
|---|
| | | //输送线节点编码，不是源库位
|
|---|
| | | // .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .set(Task::getOriginLoc, arrivedParam.getSlotCode())
|
|---|
| | | .eq(Task::getBarcode, arrivedParam.getContainerCode()));
|
|---|
| | | } else {
|
|---|
| | | //容器到达时更新任务状态为：入库完成，定时任务根据状态码更新库存
|
|---|
| | |
|---|
| | | .eq(Task::getTaskNo, callbackParam.getTaskCode()));
|
|---|
| | | if (!Collections.isEmpty(list)) {
|
|---|
| | | list.forEach(task -> {
|
|---|
| | | // ESS只能配置一个状态上报接口，根据任务号判断是入库任务或出库任务
|
|---|
| | | String taskType = task.getTaskType() > 100 ? "outStock":"inStock";
|
|---|
| | | TaskStsType taskStsType = null;
|
|---|
| | | if (stockType.equals("inStock")) { //入库任务
|
|---|
| | | if (taskType.equals("inStock")) { //入库任务
|
|---|
| | | if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //上报取箱状态
|
|---|
| | | if (task.getTaskSts() == TaskStsType.WCS_CONVEYOR_START.id) {
|
|---|
| | | taskStsType = TaskStsType.WCS_TOTE_LOAD;
|
|---|
| | |
|---|
| | | //播种完成，释放绑定站点
|
|---|
| | | List<CacheSite> cacheSites = cacheSiteService.list(new LambdaQueryWrapper<CacheSite>().eq(CacheSite::getOrderNo, orderNo));
|
|---|
| | | for (CacheSite cacheSite : cacheSites) {
|
|---|
| | | if (Objects.isNull(cacheSite.getPlatformId())) {
|
|---|
| | | throw new CoolException("");
|
|---|
| | | }
|
|---|
| | | if (!cacheSite.getSiteStatus().equals(CacheSiteStatusType.O.id)) {
|
|---|
| | | cacheSite.setSiteStatus(CacheSiteStatusType.O.id);
|
|---|
| | | cacheSite.setOrderId(null);
|
|---|
