wms / wms_ningboyongqiang · Files

package com.huaheng.api.mes.controller;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;

import com.huaheng.api.general.domain.CallEmptyContainer;

import com.huaheng.api.mes.dto.Detail;
import com.huaheng.api.mes.dto.GetOrderHistoryDTO;
import com.huaheng.api.mes.dto.ReceiptDTO;

import com.huaheng.api.mes.result.ReturnInfo;
import com.huaheng.api.mes.service.IMesService;
import com.huaheng.api.mes.utils.CallaMOM;
import com.huaheng.api.mes.utils.SqlServer;
import com.huaheng.api.mes.vo.InventoryTransactionVO;

import com.huaheng.api.mes.vo.InventoryVO;

import com.huaheng.api.wcs.service.taskAssignService.TaskAssignService;

import com.huaheng.common.constant.QuantityConstant;
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.pc.config.address.service.AddressService;

import com.huaheng.pc.config.container.service.ContainerService;
import com.huaheng.pc.config.containerType.service.ContainerTypeService;

import com.huaheng.pc.config.labelCode.domain.LabelCode;

import com.huaheng.pc.config.location.service.LocationService;

import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.material.service.MaterialService;

import com.huaheng.pc.config.station.service.StationService;

import com.huaheng.pc.inventory.inventoryDetail.domain.InventoryDetail;
import com.huaheng.pc.inventory.inventoryDetail.service.InventoryDetailService;

import com.huaheng.pc.inventory.inventoryHeader.service.InventoryHeaderService;

import com.huaheng.pc.inventory.inventoryTransaction.domain.InventoryTransaction;
import com.huaheng.pc.inventory.inventoryTransaction.service.InventoryTransactionService;
import com.huaheng.pc.momLog.service.IMomLogService;
import com.huaheng.pc.receipt.receiptDetail.service.ReceiptDetailService;
import com.huaheng.pc.receipt.receiptHeader.service.ReceiptHeaderService;
import com.huaheng.pc.shipment.shipmentDetail.service.ShipmentDetailService;
import com.huaheng.pc.shipment.shipmentHeader.service.ShipmentHeaderService;
import com.huaheng.pc.system.user.service.IUserService;
import com.huaheng.pc.task.taskDetail.domain.TaskDetail;
import com.huaheng.pc.task.taskDetail.service.TaskDetailService;

import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;

import io.swagger.annotations.ApiOperation;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.io.UnsupportedEncodingException;

import java.math.BigDecimal;

import java.sql.ResultSet;
import java.sql.SQLException;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@RestController

@Slf4j

@RequestMapping("/API/WMS/v2")
public class MesReceiptController extends BaseController {
    @Resource
    private ReceiptHeaderService receiptHeaderService;
    @Resource
    private ReceiptDetailService receiptDetailService;
    @Resource
    private ShipmentHeaderService shipmentHeaderService;
    @Resource
    private ShipmentDetailService shipmentDetailService;
    @Resource
    private InventoryDetailService inventoryDetailService;
    @Resource
    private TaskDetailService taskDetailService;
    @Resource
    private InventoryTransactionService inventoryTransactionService;
    @Resource
    private MaterialService materialService;
    @Resource
    private IMomLogService momLogService;
    @Resource
    private IMesService mesService;
    @Resource
    private IUserService userService;
    @Resource
    private AddressService addressService;

    @Resource
    private TaskAssignService taskAssignService;
    @Resource
    private ContainerService containerService;
    @Resource
    private LocationService locationService;
    @Resource
    private TaskHeaderService taskHeaderService;
    @Resource
    private ContainerTypeService containerTypeService;

    @Resource
    private StationService stationService;

    @Resource
    private InventoryHeaderService inventoryHeaderService;

    /**
     * 入库单单据取消
     */
    @PostMapping("/cancelEnterWarehouse")
    @ApiOperation("入库单单据取消")

    @ApiLogger(apiName = "入库单单据取消", from = "ROBOT")

    public AjaxResult cancelEnterWarehouse(@RequestBody ReceiptDTO receiptDTO) {
        AjaxResult ajaxResult = handleQuest("cancelEnterWarehouse", new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {
                AjaxResult ajaxResult = mesService.cancelEnterWarehouse(receiptDTO);
                return ajaxResult;
            }
        });
        return ajaxResult;
    }


    /**
     * 出库单单据取消
     */
    @PostMapping("/cancelOutWarehouse")
    @ApiOperation("出库单单据取消")

    @ApiLogger(apiName = "出库单单据取消", from = "ROBOT")

    public AjaxResult cancelOutWarehouse(@RequestBody ReceiptDTO receiptDTO) {
        AjaxResult ajaxResult = handleQuest("cancelOutWarehouse", new MultiProcessListener() {
            @Override
            public AjaxResult doProcess() {
                AjaxResult ajaxResult = mesService.cancelOutWarehouse(receiptDTO);
                return ajaxResult;
            }
        });
        return ajaxResult;
    }


    /**
     * 查询库存
     */
    @PostMapping("/searchInventory")

    @ApiLogger(apiName = "查询库存", from = "ROBOT")

    @ApiOperation("查询库存")
    public AjaxResult searchInventory(@RequestBody Detail detailed) {

        String materialName = detailed.getMaterialName();

        String materialCode = detailed.getMaterialCode();
        String containerCode = detailed.getContainerCode();

        LambdaQueryWrapper<InventoryDetail> lambdaQueryWrapper = Wrappers.lambdaQuery();
        // 物料编码

        if (StringUtils.isNotEmpty(materialName)) {

            lambdaQueryWrapper.eq(InventoryDetail::getMaterialName, materialName);
        }
        // 物料名称

        if (StringUtils.isNotEmpty(materialCode)) {

            lambdaQueryWrapper.eq(InventoryDetail::getMaterialCode, materialCode);
        }
        // 托盘号

        if (StringUtils.isNotEmpty(containerCode)) {

            lambdaQueryWrapper.eq(InventoryDetail::getContainerCode, containerCode);
        }

        if (StringUtils.isEmpty(materialName) && StringUtils.isEmpty(containerCode) && StringUtils.isEmpty(containerCode)) {

            lambdaQueryWrapper.gt(InventoryDetail::getQty, 0);
        }
        List<InventoryDetail> detailList = inventoryDetailService.list(lambdaQueryWrapper);

        List<InventoryVO> inventoryVOList = new ArrayList<>();

        detailList.forEach(detail -> {

            InventoryVO inventoryVO = new InventoryVO();

            BeanUtils.copyProperties(detail, inventoryVO);

            inventoryVO.setWarehouse("035");
            inventoryVOList.add(inventoryVO);
        });

        return AjaxResult.success(inventoryVOList);

    }

    /**
     * 获取出入库单明细记录

     *

     * @return AjaxResult
     */
    @PostMapping("/getShipmentDetail")

    @ApiLogger(apiName = "获取出入库单明细记录", from = "ROBOT")

    @ApiOperation("获取出入库单明细记录")
    public AjaxResult getShipmentDetail(@RequestBody GetOrderHistoryDTO getOrderHistoryDTO) {

        if (StringUtils.isEmpty(getOrderHistoryDTO.getEndTime()) || StringUtils.isEmpty(getOrderHistoryDTO.getStartTime())) {

            return AjaxResult.error("开始时间和结束时间不能为空！！！");
        }
        LambdaQueryWrapper<InventoryTransaction> lambdaQueryWrapper = Wrappers.lambdaQuery();
        lambdaQueryWrapper
                .ge(InventoryTransaction::getCreated, getOrderHistoryDTO.getStartTime())
                .le(InventoryTransaction::getCreated, getOrderHistoryDTO.getEndTime());
        List<InventoryTransaction> list = inventoryTransactionService.list(lambdaQueryWrapper);
        List<InventoryTransactionVO> inventoryTransactionVOList = new ArrayList<>();
        list.forEach(inventoryTransaction -> {
            InventoryTransactionVO inventoryTransactionVO = new InventoryTransactionVO();
            BeanUtils.copyProperties(inventoryTransaction, inventoryTransactionVO);
            inventoryTransactionVOList.add(inventoryTransactionVO);
        });
        return AjaxResult.success(inventoryTransactionVOList);
    }

    public List<LabelCode> getLabelCodeList() {
        List<LabelCode> labelCodeList = new ArrayList<>();
        try {

            String sql = "SELECT * FROM [dbo].[V_WCS_Code] WHERE datediff( DAY, createtime, getdate( ) ) = 0";
            ResultSet resultSet = SqlServer.find(sql);
            if (resultSet == null) {
                return labelCodeList;
            }
            while (resultSet.next()) {
                // 字段要与表一致
                String code = resultSet.getString("materialCode");//物料编码
                String name = resultSet.getString("materialName");//物料名称
                String unit = resultSet.getString("materialUnit");//单位名称
                String spec = resultSet.getString("materialSpec");//物料规格
                String fcode = resultSet.getString("Fcode");//标签条码
                String batch = resultSet.getString("BatchNo");//批次
                BigDecimal qty = resultSet.getBigDecimal("Qty");//qty
                LabelCode labelCode = new LabelCode();
                labelCode.setCode(code);
                labelCode.setName(name);
                labelCode.setUnit(unit);
                labelCode.setSpec(spec);
                labelCode.setQty(qty);
                labelCode.setLabelCode(fcode);
                labelCode.setBatch(batch);
                labelCode.setWarehouseCode("CS0001");
                labelCode.setCompanyCode("BHF");
                labelCodeList.add(labelCode);
            }
        } catch (SQLException throwable) {
            throwable.printStackTrace();
        }
        log.debug("******************************同步标签条码数据：" + labelCodeList.size() + "条数据！！！");
        return labelCodeList;
    }

    public List<LabelCode> getAllLabelCodeList() {
        List<LabelCode> labelCodeList = new ArrayList<>();
        try {
            String sql = "SELECT * FROM [dbo].[V_WCS_Code]";

            ResultSet resultSet = SqlServer.find(sql);
            if (resultSet == null) {
                return labelCodeList;
            }
            while (resultSet.next()) {
                // 字段要与表一致
                String code = resultSet.getString("materialCode");//物料编码
                String name = resultSet.getString("materialName");//物料名称
                String unit = resultSet.getString("materialUnit");//单位名称
                String spec = resultSet.getString("materialSpec");//物料规格
                String fcode = resultSet.getString("Fcode");//标签条码
                String batch = resultSet.getString("BatchNo");//批次
                BigDecimal qty = resultSet.getBigDecimal("Qty");//qty
                LabelCode labelCode = new LabelCode();
                labelCode.setCode(code);
                labelCode.setName(name);
                labelCode.setUnit(unit);
                labelCode.setSpec(spec);
                labelCode.setQty(qty);
                labelCode.setLabelCode(fcode);
                labelCode.setBatch(batch);
                labelCode.setWarehouseCode("CS0001");
                labelCode.setCompanyCode("BHF");
                labelCodeList.add(labelCode);
            }
        } catch (SQLException throwable) {
            throwable.printStackTrace();
        }
        log.debug("******************************同步标签条码数据：" + labelCodeList.size() + "条数据！！！");
        return labelCodeList;
    }

    /**
     * 获取sqlServer数据库中物料信息, 同步到本地数据库中
     */
    @PostMapping("/getMaterial")

    @ApiOperation("更新物料信息")

    public List<Material> getMaterial() {

        List<Material> materialList = new ArrayList<>();
        try {

            // */10 * * * *
            String sql = "SELECT * FROM [dbo].[V_WCS_MATERIAL] WHERE ( datediff( DAY, createtime, getdate( ) ) = 0 OR updatetime >= DATEADD( MINUTE, - 10, GETDATE( ) ) )";

            ResultSet resultSet = SqlServer.find(sql);
            if (resultSet == null) {
                return materialList;
            }
            while (resultSet.next()) {
                String code = resultSet.getString("materialCode");//物料编码
                String name = resultSet.getString("materialName");//物料名称
                String unit = resultSet.getString("materialUnit");//单位名称
                String spec = resultSet.getString("materialSpec");//物料规格

                Integer ERPID = resultSet.getInt("materialId");//id

                Date createtime = resultSet.getTimestamp("createtime");//创建时间
                Date updatetime = resultSet.getTimestamp("updatetime");//更新时间

                Material material = new Material();
                material.setCode(code);
                material.setName(name);
                material.setUnit(unit);
                material.setSpec(spec);

                material.setERPID(ERPID);

                material.setCreated(createtime);
                material.setLastUpdated(updatetime);
                material.setWarehouseCode("CS0001");
                material.setCompanyCode("BHF");
                materialList.add(material);
            }
        } catch (SQLException throwable) {
            throwable.printStackTrace();
        }
        log.debug("******************************同步物料:" + materialList.size() + "条数据！！！");
        return materialList;
    }


    @ApiOperation("获取全部物料信息")
    public List<Material> getAllMaterial() {
        List<Material> materialList = new ArrayList<>();
        try {
            String sql = "SELECT * FROM [dbo].[V_WCS_MATERIAL]";

            ResultSet resultSet = SqlServer.find(sql);

            if (resultSet == null) {

                return materialList;
            }

            while (resultSet.next()) {
                String code = resultSet.getString("materialCode");//物料编码
                String name = resultSet.getString("materialName");//物料名称
                String unit = resultSet.getString("materialUnit");//单位名称
                String spec = resultSet.getString("materialSpec");//物料规格

                Integer ERPID = resultSet.getInt("materialId");//id

                Date createtime = resultSet.getTimestamp("createtime");//创建时间
                Date updatetime = resultSet.getTimestamp("updatetime");//更新时间

                Material material = new Material();
                material.setCode(code);
                material.setName(name);

                material.setUnit(unit);

                material.setSpec(spec);

                material.setERPID(ERPID);

                material.setCreated(createtime);
                material.setLastUpdated(updatetime);

                material.setWarehouseCode("CS0001");
                material.setCompanyCode("BHF");
                materialList.add(material);
            }
        } catch (SQLException throwable) {
            throwable.printStackTrace();
        }

        log.debug("******************************同步物料:" + materialList.size() + "条数据！！！");

        return materialList;
    }

    /**
     * 查询站台任务明细列表
     */

    @ApiLogger(apiName = "查询站台任务明细列表", from = "ROBOT")

    @PostMapping("/kanbanInfo")
    @CrossOrigin

    public AjaxResult kanbanInfo(@RequestBody TaskDetail taskDetail) {

        String fromLocation = taskDetail.getFromLocation();
        if (StringUtils.isEmpty(fromLocation)) {
            return AjaxResult.error("站台不能为空!!!");
        }
        LambdaQueryWrapper<TaskDetail> wrapper = Wrappers.lambdaQuery();
        wrapper.eq(TaskDetail::getFromLocation, fromLocation)

                .lt(TaskDetail::getStatus, "100");

        List<TaskDetail> taskDetailList = taskDetailService.list(wrapper);
        return AjaxResult.success(taskDetailList);
    }

    /**

     * utf-8 转 GB2312
     */
    public String getGB(String action) {
        byte[] Rd_Out; //中间用ISO-8859-1过渡

        String data = null;
        try {
            Rd_Out = action.getBytes("8859_1");
            data = new String(Rd_Out, "GB2312"); //转换成GB2312字符
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        return data;
    }

    /**
     * @param action  MOM行为
     * @param JObject 行为参数
     * @return
     */
    public ReturnInfo postMOM(String action, JSONObject JObject, String apiName) {

        String url = addressService.selectAddress(QuantityConstant.MOM);

        return CallaMOM.getMsg(action, JObject, apiName, url);

    }

    /**
     * MES呼叫空托盘
     */
    @PostMapping("/callEmptyContainer")
    @ResponseBody
    @ApiLogger(apiName = "MES呼叫空托盘", from = "MES")
    public AjaxResult callEmptyContainer(@RequestBody CallEmptyContainer callEmptyContainer) {
        if (StringUtils.isEmpty(callEmptyContainer.getContainerType())) {
            return AjaxResult.error("托盘类型为空");
        }

        return handleQuest("callEmptyContainer", () -> mesService.callEmptyContainer(callEmptyContainer));

    }

    /**
     * MES空托盘入库
     */
    @PostMapping("/inEmptyContainer")
    @ResponseBody
    @ApiLogger(apiName = "MES空托盘入库", from = "MES")
    public AjaxResult inEmptyContainer(@RequestBody CallEmptyContainer callEmptyContainer) {
        if (StringUtils.isEmpty(callEmptyContainer.getContainerCode())) {
            return AjaxResult.error("托盘号不能为空");
        }

        return handleQuest("inEmptyContainer", () -> mesService.inEmptyContainer(callEmptyContainer));

    }

    /**
     * WCS呼叫空托盘
     */
    @PostMapping("/outEmptyContainer")
    @ResponseBody
    @ApiLogger(apiName = "WCS呼叫空托盘", from = "WCS")
    public AjaxResult outEmptyContainer(@RequestBody CallEmptyContainer callEmptyContainer) {
        if (StringUtils.isEmpty(callEmptyContainer.getContainerType())) {
            return AjaxResult.error("托盘类型为空");

        }

        return handleQuest("outEmptyContainer", () -> mesService.outEmptyContainer(callEmptyContainer));

    }

}