feat: 临时入库策略：托盘从哪来回哪去

pengyongcheng
1 parent 1738cdb6
Showing 4 changed files with 25 additions and 0 deletions
src/main/java/com/huaheng/pc/task/taskHeader/service/ReceiptTaskServiceImpl.java
src/main/java/com/huaheng/pc/task/taskHeader/service/TaskHeaderService.java
src/main/java/com/huaheng/pc/task/taskHeader/service/TaskHeaderServiceImpl.java
src/main/java/com/huaheng/pc/task/taskHeader/service/WorkTaskServiceImpl.java
@@ -183,6 +183,8 @@ public class ReceiptTaskServiceImpl implements ReceiptTaskService {
                 taskHeader.setFromPort(receiptContainerHeader.getPort());
                 taskHeader.setCreatedBy(QuantityConstant.PLATFORM_MES);
                 taskHeader.setLastUpdatedBy(QuantityConstant.PLATFORM_MES);
+                // TODO 临时入库策略
+//                taskHeaderService.appointLocation(taskHeader);
                 if (!taskHeaderService.save(taskHeader)) {
                     throw new ServiceException("任务生成失败，保存任务头表失败");
                 }
@@ -125,4 +125,10 @@ public interface TaskHeaderService extends IService&lt;TaskHeader&gt; {
      * @param materialDataList 物料信息
      */
     void assemble(Integer taskHeaderId, /*String vehicleCode,*/ List<MaterialData> materialDataList);
+
+    /**
+     * TODO 临时策略：载具从哪个库出来的就回哪个库
+     * @param taskHeader 入库任务
+     */
+    void appointLocation(TaskHeader taskHeader);
 }
@@ -998,6 +998,21 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
         }
     }
+    @Override
+    public void appointLocation(TaskHeader taskHeader) {
+        LambdaQueryWrapper<TaskHeader> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.and(x ->
+                x.eq(TaskHeader::getTaskType, QuantityConstant.TASK_TYPE_WHOLESHIPMENT)
+                .or()
+                .eq(TaskHeader::getTaskType, QuantityConstant.TASK_TYPE_EMPTYSHIPMENT))
+                .orderByDesc(TaskHeader::getCreated)
+                .last("limit 1");
+        TaskHeader queryTaskHeader = super.getOne(queryWrapper);
+        if (queryTaskHeader != null) {
+            taskHeader.setToLocation(queryTaskHeader.getFromLocation());
+        }
+    }
+
     /**
      * 移动端创建入库任务
      *
@@ -198,6 +198,8 @@ public class WorkTaskServiceImpl implements WorkTaskService {
             taskHeader.setVehicleCode(vehicleCode);
             taskHeader.setVehicleType(vehicle.getVehicleType());
         }
+        // TODO 临时入库策略
+//        taskHeaderService.appointLocation(taskHeader);
         // 设置任务为未回传状态
         taskHeader.setIsBack(QuantityConstant.MES_TASK_NOT_BACK);
         if (!taskHeaderService.save(taskHeader)) {