package com.huaheng.api.wcs.controller; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.huaheng.common.utils.Wrappers; import com.huaheng.common.constant.QuantityConstant; import com.huaheng.framework.aspectj.lang.annotation.ApiLogger; import com.huaheng.framework.web.controller.BaseController; import com.huaheng.framework.web.domain.AjaxResult; import com.huaheng.pc.config.container.domain.Container; import com.huaheng.pc.config.container.service.ContainerService; import com.huaheng.pc.config.location.domain.Location; import com.huaheng.pc.config.location.service.LocationService; import com.huaheng.pc.inventory.inventoryDetail.service.InventoryDetailService; import com.huaheng.pc.task.taskDetail.service.TaskDetailService; import com.huaheng.pc.task.taskHeader.domain.TaskHeader; import com.huaheng.pc.task.taskHeader.service.TaskHeaderService; import io.swagger.annotations.ApiOperation; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import java.util.Map; @RestController @RequestMapping("/API/WMS/v2") public class ArrivedNoticeController extends BaseController { @Resource private TaskHeaderService taskHeaderService; @Resource private TaskDetailService taskDetailService; @Resource private InventoryDetailService inventoryDetailService; @Resource private ContainerService containerService; @Resource private LocationService locationService; @PostMapping("/arrivedNotice") @ApiOperation("到达拣选台") @ApiLogger(apiName = "到达拣选台", from="ROBOT") @Transactional(rollbackFor = Exception.class) @ResponseBody public AjaxResult arrivedNotice(@RequestBody Map<String,String> map) { String warehouseCode = map.get("warehouseCode"); String taskNo = map.get("taskNo"); String port = map.get("port"); String msg = map.get("msg"); String state = map.get("state"); LambdaQueryWrapper<TaskHeader> taskHeaderLambdaQueryWrapper = Wrappers.lambdaQuery(); taskHeaderLambdaQueryWrapper.eq(TaskHeader::getId, taskNo); TaskHeader taskHeader = taskHeaderService.getOne(taskHeaderLambdaQueryWrapper); if(taskHeader == null) { return AjaxResult.error("没有找到任务taskNo:" + taskNo); } // if (taskHeader.getStatus() == 100) { // return AjaxResult.success("任务已完成"); // } // if (taskHeader.getType() == 200 || taskHeader.getType() == 400 || taskHeader.getType() == 700 // || taskHeader.getType() == 900) { // //解锁容器 //// Container container = new Container(); //// container.setCode(taskHeader.getContainerCode()); //// container.setWarehouseCode(warehouseCode); //// container = containerService.selectFirstEntity(container); //// if (container == null) { //// return AjaxResult.error(taskHeader.getContainerCode() + "在系统中不存在"); //// } // // //解锁库位 // Location location = new Location(); // location.setCode(taskHeader.getFromLocation()); // location.setWarehouseCode(warehouseCode); // location = locationService.selectFirstEntity(location); // if (location == null) { // return AjaxResult.error(taskHeader.getFromLocation() + "在系统中不存在"); // } //// container.setLocationCode(""); //// container.setStatus("empty"); //// containerService.updateById(container); // location.setContainerCode(""); // location.setStatus("empty"); // locationService.updateById(location); // } taskHeader.setStatus(QuantityConstant.TASK_STATUS_ARRIVED_STATION); boolean result = taskHeaderService.updateById(taskHeader); if(!result) { return AjaxResult.error("更新到达站台失败"); } return AjaxResult.success("更新到达站台成功"); } }