src/main/java/com/huaheng/api/mes/controller/MesController.java

package com.huaheng.api.mes.controller;
import com.huaheng.api.mes.domain.*;
import com.huaheng.api.mes.service.MesService;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.utils.DateUtils;
import com.huaheng.common.utils.StringUtils;
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.framework.web.domain.AjaxResultMES;
import com.huaheng.pc.task.taskHeader.service.WorkTaskService;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
/**
 * @author 游杰
 */
@RestController
@RequestMapping("/API/WMS/v2")
public class MesController extends BaseController {
    @Resource
    private WorkTaskService workTaskService;
    @Resource
    private MesService mesService;
    /**
     * 生成空托盘入库任务
     * 7 料点呼叫移走空载具
     *
     * @return
     */
    @PostMapping("/receiptEmptyContainer")
    @ApiOperation("生成空托盘入库任务")
    @ApiLogger(apiName = "7 生成空托盘入库任务", from = "MES")
    @ResponseBody
    public AjaxResult receiptEmptyContainer(@RequestBody MesEmptyContainer mesEmptyContainer) {
        String taskNo = mesEmptyContainer.getTaskNo();
        String orderCode = mesEmptyContainer.getOrderCode();
        String fromPort = mesEmptyContainer.getFromPort();
        // 交换载具和盛具的值
        String containerTypeCode = mesEmptyContainer.getVehicleTypeCode();
        String containerCode = mesEmptyContainer.getVehicleCode();
        String vehicleTypeCode = mesEmptyContainer.getContainerTypeCode();
        String vehicleCode = mesEmptyContainer.getContainerCode();
        boolean isEmptyVehBack = mesEmptyContainer.getIsEmptyVehBack() == 1;
        if (StringUtils.isEmpty(containerCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        if (StringUtils.isEmpty(containerTypeCode)) {
            return AjaxResult.error("containerTypeCode 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(fromPort)) {
            return AjaxResult.error("fromPort 为空");
        }
        if (!isEmptyVehBack && StringUtils.isEmpty(vehicleTypeCode)) {
            return AjaxResult.error("containerTypeCode 为空");
        }
        if (!isEmptyVehBack && StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("containerCode 为空");
        }
        // 因MES传的载具和盛具码是反的，此处交换载具与盛具的值 反着入参
        return handleMultiProcess(() -> workTaskService.createEmptyIn(
                taskNo, fromPort, orderCode, containerCode, vehicleCode, null));
    }
    /**
     * 5 MES下发空托盘出库
     *
     * @return
     */
    @PostMapping("/shipmentEmptyContainer")
    @ApiOperation("MES下发空托盘出库")
    @ApiLogger(apiName = "5 MES下发空托盘出库", from = "MES")
    public AjaxResult shipmentEmptyContainer(@RequestBody MesEmptyContainer mesEmptyContainer) {
        String taskNo = mesEmptyContainer.getTaskNo();
        String orderCode = mesEmptyContainer.getOrderCode();
        String toPort = mesEmptyContainer.getToPort();
        String containerTypeCode = mesEmptyContainer.getContainerTypeCode();
        String vehicleTypeCode = mesEmptyContainer.getVehicleTypeCode();
        if (StringUtils.isEmpty(containerTypeCode)) {
            return AjaxResult.error("containerTypeCode 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(toPort)) {
            return AjaxResult.error("toPort 为空");
        }
        if (StringUtils.isEmpty(vehicleTypeCode)) {
            return AjaxResult.error("vehicleTypeCode 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        // 载具与盛具和MES那边定义是反的，故WMS交换值
        String temp = containerTypeCode;
        containerTypeCode = vehicleTypeCode;
        vehicleTypeCode = temp;
        String finalContainerTypeCode = containerTypeCode;
        String finalVehicleTypeCode = vehicleTypeCode;
        return handleMultiProcess(() -> workTaskService.shipmentEmptyContainer(
                taskNo, orderCode, toPort, finalContainerTypeCode, finalVehicleTypeCode));
    }
    /**
     * 1 MES查询库存
     *
     * @return
     */
    @PostMapping("/searchInventory")
    @ApiOperation("MES查询库存")
    @ApiLogger(apiName = "1 MES查询库存", from = "MES")
    public AjaxResultMES searchInventory(@RequestBody MesSearch mesSearch) {
        String taskNo = mesSearch.getTaskNo();
        List<MaterialDataQuery> list = mesSearch.getMaterialDataList();
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResultMES.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(list)) {
            return AjaxResultMES.error("materialDataList 为空");
        }
        try {
            return mesService.searchInventory(mesSearch);
        } catch (Exception e) {
            return AjaxResultMES.error(e.getMessage());
        }
    }
    /**
     * 2 MES主工单下发
     *
     * @return
     */
    @PostMapping("/workOrder")
    @ApiOperation("MES主工单下发")
    @ApiLogger(apiName = "2 MES主工单下发", from = "MES")
    public synchronized AjaxResult workOrder(@RequestBody MesWorkOrder workOrder) {
        if (StringUtils.isEmpty(workOrder.getTaskNo())) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(workOrder.getOrderCode())) {
            return AjaxResult.error("orderCode 为空");
        }
        if (workOrder.getOrderStatus() == null) {
            return AjaxResult.error("orderStatus 为空");
        }
        if (StringUtils.isEmpty(workOrder.getProductCode())) {
            return AjaxResult.error("productCode 为空");
        }
        if (workOrder.getProductQty() == null) {
            return AjaxResult.error("productQty 为空");
        }
        if (StringUtils.isEmpty(workOrder.getPlanStartTime())) {
            return AjaxResult.error("planStartTime 为空");
        }
        if (StringUtils.isEmpty(workOrder.getPlanEndTime())) {
            return AjaxResult.error("planEndTime 为空");
        }
        if (StringUtils.isEmpty(workOrder.getMaterialDataList()) || workOrder.getMaterialDataList().isEmpty()) {
            return AjaxResult.error("materialDataList 为空");
        }
        return mesService.workOrder(workOrder);
    }
    /**
     * MES工单入库单(弃用)
     * 已经取消该接口 9
     *
     * @return
     */
    @Deprecated
    @PostMapping("/receiptOrder")
    @ApiOperation("MES工单入库单")
    @ApiLogger(apiName = "MES工单入库单", from = "MES")
    public AjaxResult receiptOrder(@RequestBody MesOrder mesOrder) {
        String orderCode = mesOrder.getOrderCode();
        String taskNo = mesOrder.getTaskNo();
        List<MesOrderMaterial> list = mesOrder.getMaterialDataList();
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getChidOrderCode())) {
            return AjaxResult.error("chidOrderCode 为空");
        }
        if (mesOrder.getOrderStatus() == null) {
            return AjaxResult.error("orderStatus 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getReceiptReferCode())) {
            return AjaxResult.error("receiptReferCode 为空");
        }
        if (StringUtils.isEmpty(list) || list.isEmpty()) {
            return AjaxResult.error("materialDataList 为空");
        }
        return handleMultiProcess(() -> mesService.receiptOrder(mesOrder));
    }
    /**
     * 3 MES工单领料单出库单
     *
     * @return
     */
    @PostMapping("/shipmentOrder")
    @ApiOperation("MES工单领料单出库单")
    @ApiLogger(apiName = "3 MES工单领料单出库单", from = "MES")
    public AjaxResult shipmentOrder(@RequestBody MesShipmentOrder mesOrder) {
        String orderCode = mesOrder.getOrderCode();
        String taskNo = mesOrder.getTaskNo();
        BigDecimal orderQty = mesOrder.getOrderQty();
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getChidOrderCode())) {
            return AjaxResult.error("childOrderCode 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getProductCode())) {
            return AjaxResult.error("productCode 为空");
        }
        if (StringUtils.isNull(mesOrder.getShipmentReferStatus())) {
            return AjaxResult.error("shipmentReferStatus 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getShipmentReferCode())) {
            return AjaxResult.error("shipmentReferCode 为空");
        }
        if (orderQty == null) {
            return AjaxResult.error("orderQty 为空");
        }
        if (StringUtils.isEmpty(mesOrder.getMaterialDataList())) {
            return AjaxResult.error("materialDataList 为空");
        }
        return handleMultiProcess(() -> mesService.shipmentOrder(mesOrder));
    }
    /**
     * MES成品出库
     *
     * @return
     */
    @PostMapping("/shipmentProduct")
    @ApiOperation("MES成品出库")
    @ApiLogger(apiName = "MES成品出库", from = "MES")
    public AjaxResult shipmentProduct(@RequestBody MesShipmentProduct mesShipmentProduct) {
        String containerCode = mesShipmentProduct.getContainerCode();
        String fromPort = mesShipmentProduct.getFromPort();
        String toPort = mesShipmentProduct.getToPort();
        String taskNo = mesShipmentProduct.getTaskNo();
        String vehicleCode = mesShipmentProduct.getVehicleCode();
        String orderCode = mesShipmentProduct.getOrderCode();
        if (StringUtils.isEmpty(containerCode)) {
            return AjaxResult.error("containerCode 为空");
        }
        if (StringUtils.isEmpty(fromPort)) {
            return AjaxResult.error("fromPort 为空");
        }
        if (StringUtils.isEmpty(toPort)) {
            return AjaxResult.error("toPort 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        return handleMultiProcess(() -> mesService.shipmentProduct(mesShipmentProduct));
    }
    /**
     * 工位之间载具流转 11
     *
     * @return
     */
    @PostMapping("/overStation")
    @ApiOperation("MES载具流转")
    @ApiLogger(apiName = "MES载具流转", from = "MES")
    public AjaxResult overStation(@RequestBody MesOverStationDto mesOverStationDto) {
        String containerCode = mesOverStationDto.getContainerCode();
        String fromPort = mesOverStationDto.getFromPort();
        String toPort = mesOverStationDto.getToPort();
        String taskNo = mesOverStationDto.getTaskNo();
        String vehicleCode = mesOverStationDto.getVehicleCode();
        String orderCode = mesOverStationDto.getOrderCode();
        if (StringUtils.isEmpty(containerCode)) {
            return AjaxResult.error("containerCode 为空");
        }
        if (StringUtils.isEmpty(fromPort)) {
            return AjaxResult.error("fromPort 为空");
        }
        if (StringUtils.isEmpty(toPort)) {
            return AjaxResult.error("toPort 为空");
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        // 交换载具盛具的值，MES给的与WMS的是反的
        mesOverStationDto.setContainerCode(vehicleCode);
        mesOverStationDto.setVehicleCode(containerCode);
        return handleMultiProcess(() -> mesService.createOverStation(mesOverStationDto));
    }
    /**
     * MES物料入库
     * 6 料点呼叫移走物料
     *
     * @return
     */
    @PostMapping("/receipt")
    @ApiOperation("MES物料入库")
    @ApiLogger(apiName = "6 MES物料入库", from = "MES")
    public AjaxResult receipt(@RequestBody MesReceipt mesReceipt) {
        String taskNo = mesReceipt.getTaskNo();
        //设置入库单类型为半成品入库
        mesReceipt.setReceiptType(QuantityConstant.RECEIPT_TYPE_SEMI);
        String orderCode = mesReceipt.getOrderCode();
        String containerType = mesReceipt.getContainerTypeCode();
        String containerCode = mesReceipt.getContainerCode();
        String fromPort = mesReceipt.getFromPort();
        String vehicleCode = mesReceipt.getVehicleCode();
        String vehicleTypeCode = mesReceipt.getVehicleTypeCode();
        List<MaterialData> materialDataList = mesReceipt.getMaterialDataList();
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        if (StringUtils.isEmpty(containerType)) {
            return AjaxResult.error("containerType 为空");
        }
        if (StringUtils.isEmpty(containerCode)) {
            return AjaxResult.error("containerCode 为空");
        }
        if (StringUtils.isEmpty(fromPort)) {
            return AjaxResult.error("fromPort 为空");
        }
        if (StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(vehicleTypeCode)) {
            return AjaxResult.error("vehicleTypeCode 为空");
        }
        if (StringUtils.isEmpty(materialDataList)) {
            return AjaxResult.error("materialDataList 为空");
        }
        HashMap<String, String> quTest = new HashMap<>();
        for (MaterialData data : mesReceipt.getMaterialDataList()) {
            if (data.getLocationNoX() == -1 || data.getLocationNoY() == -1) {
                return AjaxResult.error("请填写xy信息");
            }
            String key = data.getLocationNoX() + "  " + data.getLocationNoY();
            if (quTest.get(key) == null) {
                quTest.put(key, key);
            } else {
                return AjaxResult.error("坐标重复: " + key);
            }
        }
        // 交换载具盛具的值，MES给的与WMS的是反的
        mesReceipt.setContainerCode(vehicleCode);
        mesReceipt.setContainerTypeCode(vehicleTypeCode);
        mesReceipt.setVehicleCode(containerCode);
        mesReceipt.setVehicleTypeCode(containerType);
        return handleMultiProcess(() -> mesService.receipt(mesReceipt));
    }
    /**
     * 10余料回库
     *
     * @return
     */
    @PostMapping("/rawReceipt")
    @ApiOperation("余料回库")
    @ApiLogger(apiName = "10 余料回库", from = "MES")
    public AjaxResult rawReceipt(@RequestBody MesReceipt mesReceipt) {
        //mes调用接口时，代表入库单类型为余料退库
        mesReceipt.setReceiptType(QuantityConstant.RECEIPT_TYPE_BACK);
        String taskNo = mesReceipt.getTaskNo();
        String containerType = mesReceipt.getContainerTypeCode();
        String containerCode = mesReceipt.getContainerCode();
        String fromPort = mesReceipt.getFromPort();
        String vehicleCode = mesReceipt.getVehicleCode();
        String vehicleTypeCode = mesReceipt.getVehicleTypeCode();
        List<MaterialData> materialData = mesReceipt.getMaterialDataList();
        HashMap<String, String> quTest = new HashMap<>();
        for (MaterialData data : mesReceipt.getMaterialDataList()) {
            if (data.getLocationNoX() == -1 || data.getLocationNoY() == -1) {
                return AjaxResult.error("请填写xy信息");
            }
            String key = data.getLocationNoX() + "  " + data.getLocationNoY();
            if (quTest.get(key) == null) {
                quTest.put(key, key);
            } else {
                return AjaxResult.error("坐标重复: " + key);
            }
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(containerType)) {
            return AjaxResult.error("containerType 为空");
        }
        if (StringUtils.isEmpty(containerCode)) {
            return AjaxResult.error("containerCode 为空");
        }
        if (StringUtils.isEmpty(fromPort)) {
            return AjaxResult.error("fromPort 为空");
        }
        if (StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(vehicleTypeCode)) {
            return AjaxResult.error("vehicleTypeCode 为空");
        }
        if (StringUtils.isEmpty(materialData)) {
            return AjaxResult.error("materialData 为空");
        }
        // 交换载具盛具的值，MES给的与WMS的是反的
        mesReceipt.setContainerCode(vehicleCode);
        mesReceipt.setContainerTypeCode(vehicleTypeCode);
        mesReceipt.setVehicleCode(containerCode);
        mesReceipt.setVehicleTypeCode(containerType);
        return handleMultiProcess(() -> mesService.receipt(mesReceipt));
    }
    /**
     * 原材料入库
     *
     * @return
     */
    @PostMapping("/wmsReceipt")
    @ApiOperation("原材料入库")
    @ApiLogger(apiName = "原材料入库", from = "wms-pc")
    public AjaxResult wmsReceipt(@RequestBody MesReceipt mesReceipt) {
        //wms调用接口时，代表入库单类型为原材料入库
        mesReceipt.setReceiptType(QuantityConstant.RECEIPT_TYPE_RAW);
        String taskNo = mesReceipt.getTaskNo();
        String orderCode = mesReceipt.getOrderCode();
        String vehicleCode = mesReceipt.getVehicleCode();
        String vehicleTypeCode = mesReceipt.getVehicleTypeCode();
        List<MaterialData> materialData = mesReceipt.getMaterialDataList();
        HashMap<String, String> quTest = new HashMap<>();
        // 通用盛具不做校验
        if (!QuantityConstant.VEHICLE_TYPE_COMMON.equals(vehicleTypeCode)) {
            for (MaterialData data : mesReceipt.getMaterialDataList()) {
                if (data.getLocationNoX() == -1 || data.getLocationNoY() == -1) {
                    return AjaxResult.error("请填写xy信息");
                }
                String key = data.getLocationNoX() + "  " + data.getLocationNoY();
                if (quTest.get(key) == null) {
                    quTest.put(key, key);
                } else {
                    return AjaxResult.error("坐标重复: " + key);
                }
            }
        }
        if (StringUtils.isEmpty(taskNo)) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(vehicleCode)) {
            return AjaxResult.error("vehicleCode 为空");
        }
        if (StringUtils.isEmpty(vehicleTypeCode)) {
            return AjaxResult.error("vehicleTypeCode 为空");
        }
        if (StringUtils.isEmpty(materialData)) {
            return AjaxResult.error("materialData 为空");
        }
        if (StringUtils.isEmpty(orderCode)) {
            return AjaxResult.error("orderCode 为空");
        }
        return handleMultiProcess(() -> mesService.wmsReceipt(mesReceipt));
    }
    /**
     * 物料出库
     * 4 料点呼叫送物料
     *
     * @return
     */
    @PostMapping("/shipment")
    @ApiOperation("物料出库")
    @ApiLogger(apiName = "4 物料出库", from = "MES")
    public AjaxResult shipment(@RequestBody MesShipment mesShipment) {
        if (StringUtils.isEmpty(mesShipment.getTaskNo())) {
            return AjaxResult.error("taskNo 为空");
        }
        if (StringUtils.isEmpty(mesShipment.getOrderCode())) {
            return AjaxResult.error("orderCode 为空");
        }
        if (StringUtils.isEmpty(mesShipment.getShipmentReferCode())) {
            return AjaxResult.error("shipmentReferCode 为空");
        }
        if (StringUtils.isEmpty(mesShipment.getToPort())) {
            return AjaxResult.error("toPort 为空");
        }
        if (mesShipment.getVehicleinsert() == null) {
            return AjaxResult.error("vehicleinsert 为空");
        }
        if (StringUtils.isEmpty(mesShipment.getMaterialDataList())) {
            return AjaxResult.error("materialData 为空");
        }
        if (mesShipment.getSequenceCount() <= 0) {
            return AjaxResult.error("sequenceCount 为空");
        }
        if (StringUtils.isEmpty(mesShipment.getSequenceGroup())) {
            return AjaxResult.error("sequenceGroup 为空");
        }
        return handleMultiProcess(() -> mesService.shipment(mesShipment));
    }
    /**
     * 入库回传
     */
    @PostMapping("/backReceipt")
    @ResponseBody
    @ApiLogger(from = "WMS", to = "MES", apiName = "入库回传")
    public AjaxResult backReceipt(Integer id) {
        if (StringUtils.isNull(id)) {
            return AjaxResult.error("id不能为空");
        }
        return mesService.backReceipt(id);
    }
    /**
     * 出库回传
     */
    @PostMapping("/backShipment")
    @ResponseBody
    @ApiLogger(from = "WMS", to = "MES", apiName = "出库回传")
    public AjaxResult backShipment(String id) {
        if (StringUtils.isEmpty(id)) {
            return AjaxResult.error("id不能为空");
        }
        return mesService.backShipment(id);
    }
    /**
     * 工位之间载具流转回传
     */
    @PostMapping("/backChangeStation")
    @ResponseBody
    @ApiLogger(from = "WMS", to = "MES", apiName = "工位之间载具流转回传")
    public AjaxResult backEmpty(String id) {
        if (StringUtils.isEmpty(id)) {
            return AjaxResult.error("任务id不能为空");
        }
        return mesService.backChangeStation(id);
    }
}