增加移动端任务设置站台接口

周峰
1 parent c84ec7ee
Showing 3 changed files with 52 additions and 1 deletions
src/main/java/com/huaheng/mobile/shipment/MobileShipmentController.java
src/main/java/com/huaheng/mobile/task/MobileTaskController.java
src/main/java/com/huaheng/pc/config/station/controller/stationController.java
@@ -42,6 +42,7 @@ import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentHeader;
 import com.huaheng.pc.shipment.shipmentHeader.mapper.ShipmentHeaderMapper;
 import com.huaheng.pc.shipment.shipmentHeader.service.ShipmentHeaderService;
 import com.huaheng.pc.task.taskHeader.domain.ShipmentTaskCreateModel;
+import com.huaheng.pc.task.taskHeader.domain.TaskHeader;
 import com.huaheng.pc.task.taskHeader.service.ShipmentTaskService;
 import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;
 import io.swagger.annotations.ApiOperation;
@@ -90,6 +91,9 @@ public class MobileShipmentController extends BaseController {
  
     @Resource
     private LocationService locationService;
+
+    @Resource
+    private TaskHeaderService taskHeaderService;
     /**
      * 自动组盘
      * @param
@@ -353,6 +357,30 @@ public class MobileShipmentController extends BaseController {
         return AjaxResult.success(stationList);
     }
  
+    @PostMapping("/getStationByTaskId")
+    @ApiOperation("移动端根据任务ID查询可用站台")
+    @Log(title = "移动端根据任务ID查询可用站台", action = BusinessType.OTHER)
+    public AjaxResult getStationByTaskId(Integer id){
+        TaskHeader header = taskHeaderService.getById(id);
+
+        int taskType = header.getTaskType().intValue();
+        int stationType = -1;
+        if(taskType == QuantityConstant.TASK_TYPE_WHOLESHIPMENT ||
+                taskType == QuantityConstant.TASK_TYPE_EMPTYSHIPMENT)  {
+            stationType = QuantityConstant.STATION_OUT;
+        } else if(taskType == QuantityConstant.TASK_TYPE_SUPPLEMENTRECEIPT ||
+                taskType == QuantityConstant.TASK_TYPE_SORTINGSHIPMENT ||
+                taskType == QuantityConstant.TASK_TYPE_VIEW ||
+                taskType == QuantityConstant.TASK_TYPE_CYCLECOUNT) {
+            stationType = QuantityConstant.STATION_PICK;
+        } else {
+            throw new ServiceException("任务类型不需要选站台");
+        }
+
+        List<Station> stationList = getStationListByContainerAndType(header.getContainerCode(), stationType);
+        return AjaxResult.success(stationList);
+    }
+
     /**
      * 从StationController.getStationFromType移植过来
      * @param containerCode
@@ -460,7 +488,7 @@ public class MobileShipmentController extends BaseController {
         return mShipmentDetailIds;
     }
  
-    @Log(title = "移动端设置站台", operating = "设置站台", action = BusinessType.GRANT)
+    @Log(title = "移动端设置出库站台", operating = "设置站台", action = BusinessType.GRANT)
     @PostMapping("/setStation")
     @ResponseBody
     public AjaxResult setStation (String id, String station){
@@ -186,4 +186,16 @@ public class MobileTaskController  {
         return AjaxResult.success(todayInfo);
     }
  
+    @Log(title = "移动端设置任务的站台", operating = "设置站台", action = BusinessType.GRANT)
+    @PostMapping("/setTaskStation")
+    @ResponseBody
+    public AjaxResult setTaskStation (String id, String port){
+        LambdaQueryWrapper<TaskHeader> taskHeaderLambdaQueryWrapper = Wrappers.lambdaQuery();
+        taskHeaderLambdaQueryWrapper.eq(TaskHeader::getId, id);
+        TaskHeader taskHeader1 = taskHeaderService.getOne(taskHeaderLambdaQueryWrapper);
+        taskHeader1.setPort(port);
+        taskHeaderService.update(taskHeader1, taskHeaderLambdaQueryWrapper);
+        return AjaxResult.success();
+    }
+
 }
@@ -58,6 +58,17 @@ public class stationController extends BaseController {
         return prefix + "/station";
     }
  
+    @PostMapping("/getStationByCode")
+    @ResponseBody
+    public AjaxResult<Station> getStationByCode(String code){
+        LambdaQueryWrapper<Station> lambdaQueryWrapper = Wrappers.lambdaQuery();
+        lambdaQueryWrapper.eq(Station::getCode, code)
+                .orderByDesc(Station::getType)
+                .last("limit 1");
+        Station station = stationService.getOne(lambdaQueryWrapper);
+        return AjaxResult.success(station);
+    }
+
     /**
      * 查询出库类型
      */