wms / wms_changshushengyi · Files

package com.huaheng.pc.sap.service;

import static java.util.stream.Collectors.toList;

import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.huaheng.api.general.service.BasicDataApiService;
import com.huaheng.api.sap.domain.ZarDomain;
import com.huaheng.api.sap.service.ZarApiService;
import com.huaheng.api.utils.SAPUtils;
import com.huaheng.api.wcs.service.warecellAllocation.WarecellAllocationService;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.exception.service.ServiceException;
import com.huaheng.common.utils.DateUtils;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.security.ShiroUtils;
import com.huaheng.framework.aspectj.lang.annotation.ProcessTrack;
import com.huaheng.framework.aspectj.lang.constant.ProcessCode;
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.config.material.domain.Material;
import com.huaheng.pc.config.material.domain.MaterialDiameter;
import com.huaheng.pc.config.material.service.MaterialDiameterService;
import com.huaheng.pc.config.material.service.MaterialService;
import com.huaheng.pc.config.station.domain.Station;
import com.huaheng.pc.config.station.service.StationService;
import com.huaheng.pc.config.zone.domain.Zone;
import com.huaheng.pc.config.zone.service.ZoneService;
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.receipt.receiptContainerHeader.service.ReceiptContainerHeaderService;
import com.huaheng.pc.receipt.receiptHeader.domain.ReceiptHeader;
import com.huaheng.pc.receipt.receiptHeader.service.ReceiptHeaderService;
import com.huaheng.pc.sap.domain.SAPTaskDomain;
import com.huaheng.pc.sap.domain.Zarsh;
import com.huaheng.pc.sap.domain.Zarsi;
import com.huaheng.pc.sap.mapper.ZarshMapper;
import com.huaheng.pc.shipment.shipmentContainerHeader.domain.ShipmentContainerHeader;
import com.huaheng.pc.shipment.shipmentContainerHeader.service.ShipmentContainerHeaderService;
import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentHeader;
import com.huaheng.pc.shipment.shipmentHeader.service.ShipmentHeaderService;
import com.huaheng.pc.task.agvTask.domain.AgvTask;
import com.huaheng.pc.task.agvTask.service.AgvTaskService;
import com.huaheng.pc.task.taskDetail.domain.TaskDetail;
import com.huaheng.pc.task.taskDetail.service.TaskDetailService;
import com.huaheng.pc.task.taskHeader.domain.TaskHeader;
import com.huaheng.pc.task.taskHeader.service.ReceiptTaskService;
import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;
import com.huaheng.pc.task.taskHeader.service.WorkTaskEmptyContainerService;
import com.huaheng.pc.task.taskHeader.service.WorkTaskService;

/**
 * Created by Enzo Cotter on 2022/5/11.
 * @author zhouhong
 */
@Service
public class ZarshService extends ServiceImpl<ZarshMapper, Zarsh> {
    @Resource
    private ZarsiService zarsiService;
    @Resource
    private ReceiptContainerHeaderService receiptContainerHeaderService;
    @Resource
    private ShipmentContainerHeaderService shipmentContainerHeaderService;
    @Resource
    private ReceiptHeaderService receiptHeaderService;
    @Resource
    private ShipmentHeaderService shipmentHeaderService;
    @Resource
    private TaskHeaderService taskHeaderService;
    @Resource
    private ContainerService containerService;
    @Resource
    private BackSapStatusService backSapStatusService;
    @Resource
    private ZoneService zoneService;
    @Resource
    private StationService stationService;
    @Resource
    private LocationService locationService;
    @Resource
    private TaskDetailService taskDetailService;
    @Resource
    private WorkTaskService workTaskService;
    @Resource
    private WorkTaskEmptyContainerService workTaskEmptyContainerService;
    @Resource
    private ZarshService zarshService;
    @Resource
    private ZarApiService zarApiService;
    @Resource
    private ReceiptTaskService receiptTaskService;
    @Resource
    private InventoryDetailService inventoryDetailService;
    @Resource
    private MaterialService materialService;
    @Resource
    private MaterialDiameterService materialDiameterService;
    @Resource
    private BasicDataApiService basicDataApiService;
    @Resource
    private WarecellAllocationService warecellAllocationService;
    @Resource
    private AgvTaskService agvTaskService;
    @Resource
    private InventoryHeaderService inventoryHeaderService;
    @Resource
    private LockSapUniqueIdService lockSapUniqueIdService;
    @Resource
    private ZarshLocationService zarshLocationService;

    public Zarsh checkZarshByUniqueId(String uniqueId) {
        LambdaQueryWrapper<Zarsh> lambdaQueryWrapper = Wrappers.lambdaQuery();
        lambdaQueryWrapper.eq(Zarsh::getUniqueId, uniqueId);
        lambdaQueryWrapper.last("limit 1");
        Zarsh zarsh = this.getOne(lambdaQueryWrapper);
        if (zarsh != null) {
            return zarsh;
        }
        return null;
    }

    public boolean saveZarsh(Zarsh zarsh) {
        Date date = new Date();
        String uniqueId = UUID.randomUUID().toString();
        zarsh.setUniqueId(uniqueId);
        zarsh.setCreated(date);
        zarsh.setCreateBy("wms");
        zarsh.setLastUpdatedBy("wms");
        zarsh.setLastUpdated(date);
        return this.save(zarsh);
    }

    public boolean editZarsh(Zarsh zarsh) {
        Date date = new Date();
        zarsh.setLastUpdatedBy("wms");
        zarsh.setLastUpdated(date);
        return this.updateById(zarsh);
    }

    public void removeByZarshId(String uniqueId, Integer id) {
        LambdaQueryWrapper<Zarsh> queryWrapper = Wrappers.lambdaQuery();
        queryWrapper.eq(StringUtils.isNotEmpty(uniqueId), Zarsh::getUniqueId, uniqueId);
        queryWrapper.eq(StringUtils.isNotNull(id), Zarsh::getId, id);
        queryWrapper.last("limit 1");
        Zarsh zarsh = this.getOne(queryWrapper);
        if (zarsh != null) {
            LambdaQueryWrapper<Zarsi> query = Wrappers.lambdaQuery();
            query.eq(Zarsi::getUniqueId, zarsh.getUniqueId());
            List<Zarsi> list = zarsiService.list(query);
            List<Integer> ids = list.stream().map(detail -> detail.getId()).collect(toList());
            if (ids.size() > 0) {
                zarsiService.removeByIds(ids);
            }
            this.removeById(zarsh.getId());
        }

    }

    public Zarsh getZarshByUnique(String uniqueId) {
        LambdaQueryWrapper<Zarsh> queryWrapper = Wrappers.lambdaQuery();
        queryWrapper.eq(StringUtils.isNotEmpty(uniqueId), Zarsh::getUniqueId, uniqueId);
        queryWrapper.last("limit 1");
        Zarsh zarsh = this.getOne(queryWrapper);
        return zarsh;
    }

    public AjaxResult saveSapDataByApi(ZarDomain zarDomain) {
        // 用主表UniqueId查找子表zarsi信息
        List<Zarsi> zarsiList = zarDomain.getZarsiList();
        Zarsh zarsh = zarDomain.getZarsh();
        /**
         * 任务取消
         */
        if (StringUtils.isNotEmpty(zarsh.getCFlag()) && zarsh.getCFlag().equals("D")) {
            // 取消
            return zarApiService.cancelTaskBySap(zarsh);
        }
        Zarsh zarsh1 = zarshService.checkZarshByUniqueId(zarsh.getUniqueId());
        if (zarsh1 != null) {
            return AjaxResult.error("单据已存在，请不要重复下发");
        }
        boolean tag = lockSapUniqueIdService.checkStationUniqueId(zarsh);
        if (tag) {
            return AjaxResult.error("站台有未成功的任务，请确认该站台入库任务后解锁站台");
        }
        return zarshService.createTaskBySAP(zarsiList, zarsh);
        /*
         * try {
         * zarshService.createTaskBySAP(zarsiList, zarsh);
         * } catch (Ex
         * ception e) {
         * e.printStackTrace();
         * backSapStatusService.addBackSapStatus(zarsh.getUniqueId(), zarsh.getLgnum(), null, zarsh.getMFlag(), "C",
         * null, e.getMessage());
         * return AjaxResult.error(e.getMessage());
         * }
         */
//        return AjaxResult.success("添加任务成功");
    }

    // 入库
    public TaskHeader receiptBySap(List<Zarsi> zarsiList, Zarsh zarsh) {
        TaskHeader taskHeader = null;
        // 空托盘入库
        if (zarsiList == null || zarsiList.size() == 0) {
            String area = zoneService.getZoneAreaByCode(zarsh.getLgnum());
            // SAP创建 空容器号的入库任务
            AjaxResult result = workTaskEmptyContainerService.createEmptyIn(zarsh.getDrumId(), "", area, zarsh.getFromPos(), zarsh.getCrnIn());
            if (result.hasErr()) {
                throw new ServiceException(result.getMsg());
            }
            Integer taskId = (Integer)result.getData();
            taskHeader = taskHeaderService.getById(taskId);
            taskHeader.setUniqueIds(zarsh.getUniqueId());
            taskHeaderService.updateById(taskHeader);
            // 调用sap的api，传递任务状态
            backSapStatusService.addBackSapStatus(zarsh.getUniqueId(), zarsh.getLgnum(), null, "1", "1", null, null);
            return null;
        }
        // 保存入库信息
        ReceiptHeader receiptHeader = null;
        for (Zarsi zarsi : zarsiList) {
            if (zarsi.getVerme() == null || zarsi.getVerme().compareTo(BigDecimal.ZERO) == 0) {
                throw new ServiceException("入库数量不能为0");
            }
        }
        AjaxResult ajaxResult = receiptHeaderService.saveReceiptBySap(zarsh, zarsiList);
        if (ajaxResult != null && ajaxResult.hasErr()) {
            throw new ServiceException(ajaxResult.getMsg());
        }
        receiptHeader = (ReceiptHeader)ajaxResult.getData();
        // 调用sap的api，传递任务状态
        backSapStatusService.addBackSapStatus(zarsh.getUniqueId(), zarsh.getLgnum(), null, "1", "1", null, null);
        // 如果是玻璃布2楼入库，机台到立库，站台机台，线边库到立库，站台立库口，机台到线边库

        Container container = containerService.getContainerByCode(zarsh.getDrumId(), QuantityConstant.WAREHOUSECODE);
        // 指定一个托盘生成任务
        if (StringUtils.isEmpty(zarsh.getDrumId()) || container == null) {
            if (zarsh.getLgnum().contains("A")) {
                Container container1 = containerService.createContainerByZoneNoTrasa("A");
                zarsh.setDrumId(container1.getCode());
                container = container1;
                // 创建临时托盘
            }
        }
        // 判断有没有托盘号，有则生成组盘
        if (StringUtils.isNotEmpty(zarsh.getDrumId()) && container != null) {
            // 保存组盘,生成任务信息
            // 设置wcs固定登录缓存，调用公共组盘接口
            ShiroUtils.setUserByWcsZone("SAP", QuantityConstant.WAREHOUSECODE, receiptHeader.getZoneCode());

            AjaxResult ajaxResult_receiptcontainerH = receiptContainerHeaderService.saveContainerByReceiptHeaderId(receiptHeader.getId(), zarsh.getDrumId());
            if (ajaxResult_receiptcontainerH != null && ajaxResult_receiptcontainerH.hasErr()) {
                throw new ServiceException(ajaxResult_receiptcontainerH.getMsg());
            }
//            AjaxResult ajaxResult_receiptcontainer =
//                receiptContainerHeaderService.saveReceiptContainerBySap(receiptHeader, zarsh.getDrumId(), zarsh.getFromPos(), zarsh.getToPos());
//            if (ajaxResult_receiptcontainer != null && ajaxResult_receiptcontainer.hasErr()) {
//                throw new ServiceException(ajaxResult_receiptcontainer.getMsg());
//            }
        }
        return taskHeader;
    }

    // 出库
    public TaskHeader shipmentBySap(List<Zarsi> zarsiList, Zarsh zarsh) {
        TaskHeader taskHeader = null;
        // 空托盘出库
        if (zarsiList == null || zarsiList.size() == 0) {
            // 获取对应库区编码 zarsh.getLgnum() --> F
            List<Location> list = containerService.getEmptyContainerInLocation(zarsh.getLgnum(), "", "", QuantityConstant.WAREHOUSECODE);
            List<String> emptyContainerCodeList = list.stream().map(t -> t.getContainerCode()).collect(toList());
            List<String> removeContainerList = new ArrayList<>();
            for (String containerCode : emptyContainerCodeList) {
                Container container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
                if (container.getStatus().equals(QuantityConstant.STATUS_CONTAINER_LOCK)) {
                    removeContainerList.add(containerCode);
                }
            }
            emptyContainerCodeList.removeAll(removeContainerList);

            if (emptyContainerCodeList == null || emptyContainerCodeList.isEmpty()) {
                throw new ServiceException("库内没有找到空容器");
            }
            // 自动匹配空容器出库
            Container container = null;
            if (StringUtils.isNotEmpty(zarsh.getDrumId())) {
                container = containerService.getContainerByCode(zarsh.getDrumId(), QuantityConstant.WAREHOUSECODE);
            } else {
                container = containerService.getContainerByCode(emptyContainerCodeList.get(0), QuantityConstant.WAREHOUSECODE);
            }
            if (container == null) {
                throw new ServiceException("请检查容器码:" + zarsh.getDrumId() + "是否正确！");
            }
            // 创建空容器出库任务
            AjaxResult result = workTaskService.createEmptyOut(container.getCode(), container.getLocationCode(), zarsh.getToPos(), QuantityConstant.WAREHOUSECODE,
                zarsh.getUniqueId());

            if (result.hasErr()) {
                throw new ServiceException(result.getMsg());
            }
            // 调用sap的api，传递任务状态
            backSapStatusService.addBackSapStatus(zarsh.getUniqueId(), zarsh.getLgnum(), null, "2", "1", null, null);
            return taskHeader;
        }
        // 有料出库
        // 保存出库信息
        ShipmentHeader shipmentHeader = null;
        AjaxResult ajaxResult = shipmentHeaderService.saveShipmentBySap(zarsh, zarsiList);
        if (ajaxResult != null && ajaxResult.hasErr()) {
            throw new ServiceException(ajaxResult.getMsg());
        }
        shipmentHeader = (ShipmentHeader)ajaxResult.getData();
        // 调用sap的api，传递任务状态
        backSapStatusService.addBackSapStatus(zarsh.getUniqueId(), zarsh.getLgnum(), null, "2", "1", null, null);
        // 判断有没有库位号，有则生成组盘
        if (StringUtils.isNotEmpty(zarsh.getLocation())) {
            // 保存组盘信息
            ShipmentContainerHeader shipmentContainerHeader = null;
            AjaxResult result = shipmentContainerHeaderService.saveShipmentContainerBySap(shipmentHeader, zarsh);
            if (result != null && result.hasErr()) {
                throw new ServiceException(result.getMsg());
            }
            shipmentContainerHeader = (ShipmentContainerHeader)result.getData();
            // 创建任务表数据
            AjaxResult ajaxResult_taskheader = taskHeaderService.saveTaskBySapLK(shipmentContainerHeader);
            // 生成任务成功之后在修改 组盘状态
            if (ajaxResult_taskheader.hasErr()) {
                throw new ServiceException("生成任务失败");
            }
        }
        return taskHeader;
    }

    @Transactional(rollbackFor = Exception.class)
    public AjaxResult createTaskBySAP(List<Zarsi> zarsiList, Zarsh zarsh) {
        String zoneCode = SAPUtils.getZoneCode(zarsh);
        String area = zoneService.getZoneAreaByCode(zoneCode);
        String port = null;
        if (StringUtils.isNotEmpty(area)) {
            switch (zarsh.getMFlag()) {
                case "2":
                case "B":
                    port = zarsh.getFromPos();
                    break;
                case "1":
                case "3":
                    port = zarsh.getToPos();
                    if (StringUtils.isNotEmpty(zarsh.getLocation()) && zarsh.getLocation().equals(port)) {
                        throw new ServiceException("出库终点和库位不能一样:" + port + ":" + zarsh.getLocation());
                    }
                    break;
                default:
            }
            if (StringUtils.isEmpty(port)) {
                throw new ServiceException("指定：" + zarsh.getMFlag() + " 站台不存在");
            }
            Station station = stationService.getStationBySAPCode(port);
            if (StringUtils.isNull(station)) {
                throw new ServiceException("指定：" + zarsh.getMFlag() + " 站台未找到：" + port);
            }
            // 不允许跨区域 选择站台
            if (!area.equals(station.getArea().toString()) && station.getDefineProperty() != 1) {
                throw new ServiceException("不允许跨区域 选择站台：" + zarsh.getLgnum() + "/" + port);
            }
        }

        /**
         * 1:整盘 / 等待组盘
         * 2:空托
         */
        Integer billType = zarsh.getInKind();
        String type = zarsh.getMFlag();
        String uniqueId = zarsh.getUniqueId();
        SAPTaskDomain domain = new SAPTaskDomain();
        domain.setZarsh(zarsh);
        domain.setZarsiList(zarsiList);

        if (!zarshService.save(zarsh)) {
            throw new ServiceException("保存主表数据失败");
        }
        if (!zarsiService.saveBatchs(zarsiList, zarsh)) {
            throw new ServiceException("保存子表数据失败");
        }
        // 商片仓2061只能出空托，和入库，2058只能出库
        switch (billType) {
            case 1:
                createHavingTask(domain);
                break;
            case 0:
                createEmptyTask(domain);
                break;
            default:
                throw new ServiceException("inKind不支持的业务类型");
        }
        backSapStatusService.addBackSapStatus(uniqueId, zoneCode, null, type, "1", null, null);
        return AjaxResult.success("添加任务成功");
    }

    /**
     * SAP无货指令
     * @param domain
     */
    public void createEmptyTask(SAPTaskDomain domain) {
        Zarsh zarsh = domain.getZarsh();
        String formPort = zarsh.getFromPos();
        String toPort = zarsh.getToPos();
        String type = zarsh.getMFlag();
        Integer containerType = zarsh.getPlType();
        String containerCode = zarsh.getDrumId();
        String locationCode = zarsh.getLocation();
        String uniqueId = zarsh.getUniqueId();
        String crnIn = zarsh.getCrnIn();
        String zoneCode = SAPUtils.getZoneCode(zarsh);
        List<Zarsi> zarsiList = domain.getZarsiList();

        // 入库站台属性
        switch (type) {
            // 入库
            case "2":
            case "B":
                LambdaQueryWrapper<Station> lambdaQuery1 = Wrappers.lambdaQuery();
                lambdaQuery1.eq(Station::getByName, formPort);
                Station inStation = stationService.getOne(lambdaQuery1);
                if (inStation == null) {
                    throw new ServiceException(toPort + "站台异常，未找到站台");
                }
                if (inStation.getType().equals("2")) {
                    throw new ServiceException(formPort + "：出库站台不能入库");
                }
                // 站台托盘判断
                zarshService.checkStationContainer(inStation, containerCode);

                String area = SAPUtils.getArea(zarsh);
                // 判断有无空闲库位分配
                AjaxResult checkAjax = zarshLocationService.checkLocationByZarsh(zarsh, area);
                if (checkAjax.hasErr()) {
                    throw new ServiceException(checkAjax.getMsg());
                }
                // 判断站台属性是否为AGV站台
                if (inStation.getDefineProperty() == 1) {
                    if (StringUtils.isEmpty(toPort)) {
                        // 获取 AGV立库交互站台
                        createReceiptAGVTask(zarsh, zarsiList, inStation.getCode());
                    } else {
                        createStation2Station(zarsh, zarsiList, inStation.getCode());
                    }
                } else {
                    AjaxResult ajaxResult = workTaskService.createEmptyIn(containerCode, null, area, inStation.getCode(), uniqueId);
                    if (ajaxResult.hasErr()) {
                        throw new ServiceException(ajaxResult.getMsg());
                    }
                }

                break;
            // 出库
            case "1":
            case "3":
                LambdaQueryWrapper<Station> lambdaQuery2 = Wrappers.lambdaQuery();
                lambdaQuery2.eq(Station::getByName, toPort);
                Station outStation = stationService.getOne(lambdaQuery2);
                if (outStation == null) {
                    throw new ServiceException(toPort + "站台异常，未找到站台");
                }
                Integer defineProperty = outStation.getDefineProperty();
                // 判断库区
                if (StringUtils.isNotEmpty(zarsh.getCrnIn())) {
                    zoneCode = zarsh.getCrnIn();
                } else {
                    Location location1 = locationService.getLocationByCode(locationCode, QuantityConstant.WAREHOUSECODE);
                    if (location1 != null) {
                        zoneCode = location1.getZoneCode();
                    }
                }
                if (StringUtils.isEmpty(zoneCode)) {
                    zoneCode = SAPUtils.getZoneCode(zarsh);
                }
                // 获取库区
                if (zoneCode.contains("X")) {
                    if (2 == defineProperty) {
                        createShipmentAGVTask(zarsh, zarsiList, outStation.getCode());
                    }
                    if (1 == defineProperty) {
                        Station station = stationService.getStationBySAPCode(toPort);
                        if (station != null && station.getDefineProperty() == 1) {
                            createStation2Station(zarsh, zarsiList, outStation.getCode());
                        } else {
                            createShipmentAGVTask(zarsh, zarsiList, outStation.getCode());
                        }
                    }

                } else {
                    // 区域移库 映射站台 SAP任务下发的是移入库区的站台 通过移入站台获取到 出库的站台
                    if (1 == defineProperty) {
                        String port = getLKAGVPort(zoneCode, outStation.getLayer(), null, QuantityConstant.SHIPMENT_STATION_TYPE, outStation.getOutSlicePalletArea(),
                            outStation.getOutRollPalletArea(), outStation.getRangeStation());
                        if (StringUtils.isEmpty(port)) {
                            throw new ServiceException("立库AGV交互站台未配置请先配置立库AGV交互站台");
                        }
                        outStation = stationService.getStaionByCode(port);
                    }
                    String shipmentStationCode = null;
                    if (StringUtils.isEmpty(outStation.getByPassPort())) {
                        shipmentStationCode = outStation.getCode();
                    } else {
                        shipmentStationCode = outStation.getCode();
                    }
                    String areaByWcs = outStation.getAreaByWcs();
                    Station station2 = stationService.getOne(new LambdaQueryWrapper<Station>().eq(Station::getCode, shipmentStationCode));
                    if (station2 == null) {
                        throw new ServiceException(shipmentStationCode + "站台异常，未找到站台");
                    }
                    String roadWay = station2.getRoadWay();
                    String[] split = roadWay.split(",");
                    List<String> roadWays = Arrays.asList(split);
                    // 根据 SAP containerType 来获取托盘类型
                    String palletCode = null;
                    if (StringUtils.isNotEmpty(locationCode)) {
                        Location location = locationService.getLocationByCode(locationCode, QuantityConstant.WAREHOUSECODE);
                        if (location == null) {
                            palletCode = location.getContainerCode();
                        }
                    } else {
                        palletCode = containerService.getEmptyContainerList(zoneCode, roadWays, areaByWcs, containerType);
                    }
                    if (StringUtils.isEmpty(palletCode)) {
                        throw new ServiceException(containerType + "容器类型未匹配成功");
                    }
                    Container container = containerService.getContainerByCode(palletCode, QuantityConstant.WAREHOUSECODE);
                    if (container == null) {
                        throw new ServiceException(palletCode + "容器异常，未找到容器");
                    }
                    AjaxResult emptyOut = workTaskService.createEmptyOut(container.getCode(), container.getLocationCode(), shipmentStationCode,
                        QuantityConstant.WAREHOUSECODE, uniqueId, outStation.getCode());
                    if (emptyOut.hasErr()) {
                        throw new ServiceException(emptyOut.getMsg());
                    }
                }

                break;
            default:
                throw new ServiceException("MFlag不支持的业务类型");
        }
    }

    /**
     * SAP有货指令
     * @param domain
     */
    public void createHavingTask(SAPTaskDomain domain) {
        Zarsh zarsh = domain.getZarsh();
        String crnIn = zarsh.getCrnIn();
        String formPort = zarsh.getFromPos();
        String toPort = zarsh.getToPos();
        String type = zarsh.getMFlag();
        String zoneCode = null;
        String containerCode = zarsh.getDrumId();
        String locationCode = zarsh.getLocation();
        String uniqueId = zarsh.getUniqueId();
        List<Zarsi> zarsiList = domain.getZarsiList();

        // 校验或添加物料
        checkMaterialCode(zarsiList);

        // 校验判断 有料方法 一定需要托盘号

        switch (type) {
            // 入库
            case "2":
            case "B":
                Station station = stationService.getStationBySAPCode(formPort);
                if (station == null) {
                    throw new ServiceException("站台未找到！" + formPort);
                }
                if (station.getType().equals("2")) {
                    throw new ServiceException(formPort + "：出库站台不能入库");
                }
                // 校验是否为入库站台
                checkReceiptPort(station);
                zarshService.checkStationContainer(station, containerCode);

                if (StringUtils.isNotNull(zarsiList)) {
                    switch (SAPUtils.getZoneCode(zarsh)) {
                        case "A":
                            if (zarsiList.size() > 1) {
                                throw new ServiceException("玻璃仓入库明细数量限制为1条！");
                            }
                            break;
                        case "C":
                            if (zarsiList.size() > 2) {
                                throw new ServiceException("铜箔仓入库明细数量限制为2条！");
                            }
                            break;
                        default:
                    }
                }
                // 标志是否有 容器编码
                int containerFlag = 0;
                Container container = null;
                if (StringUtils.isNotEmpty(containerCode)) {
                    container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
                    if (container != null) {
                        containerFlag = 1;

                        TaskHeader task = taskHeaderService.checkTaskByContainerCode(containerCode);
                        if (task != null) {
                            if (task.getInternalTaskType().intValue() == 100) {
                                throw new ServiceException("有货入库,该容器已存在未完成的入库任务,请不要重复下发" + containerCode);
                            } else if (task.getInternalTaskType().intValue() == 200) {
                                throw new ServiceException(
                                    "有货入库,该容器已存在未完成的出库任务,出库任务未完成，请到WCS中未完成任务查看是否有改任务，任务状态是否是响应接出站台请求，如果是直接手动强制完成该任务即可恢复正常，同时告知电气或WCS；" + containerCode);
                            } else {
                                throw new ServiceException("有货入库,该容器已存在未完成的任务" + containerCode);
                            }

                        }
                        AgvTask agvTask = taskHeaderService.checkAgvTaskByContainerCode(containerCode);
                        if (agvTask != null) {
                            throw new ServiceException("有货入库,该容器已存在未完成的agv任务,请不要重复下发" + containerCode);
                        }
                        // 不是出库入库或agv任务
                        if (QuantityConstant.STATUS_LOCATION_LOCK.equals(container.getStatus())) {
                            // 没有任务直接解锁
                            containerService.updateLocationCodeAndStatus(containerCode, "", QuantityConstant.STATUS_LOCATION_EMPTY, QuantityConstant.WAREHOUSECODE);
                        }
                        if (StringUtils.isNotEmpty(container.getLocationCode())) {
                            AjaxResult ajaxResult = inventoryHeaderService.removeInventoryByContainer(containerCode);
                            if (ajaxResult.hasErr()) {
                                throw new ServiceException(ajaxResult.getMsg());
                            }
                        }
                        List<InventoryDetail> inventoryDetails =
                            inventoryDetailService.list(new LambdaQueryWrapper<InventoryDetail>().eq(InventoryDetail::getContainerCode, container.getCode()));
                        if (!inventoryDetails.isEmpty()) {
                            AjaxResult ajaxResult = inventoryHeaderService.removeInventoryByContainer(containerCode);
                            if (ajaxResult.hasErr()) {
                                throw new ServiceException(ajaxResult.getMsg());
                            }
                        }
                    }
                }
                // 入库站台编码
                String formPortCode = station.getCode();
                // 入库站台属性
                Integer defineProperty = station.getDefineProperty();
                String area = SAPUtils.getArea(zarsh);
                // 判断有无空闲库位分配
                AjaxResult checkAjax = zarshLocationService.checkLocationByZarsh(zarsh, area);
                if (checkAjax.hasErr()) {
                    throw new ServiceException(checkAjax.getMsg());
                }
                switch (containerFlag) {
                    // 无托盘
                    case 0:
                        // agv站台
                        if (defineProperty == 1) {
                            // 创建agv任务
                            AgvTask agvTask = createReceiptAGVTask(zarsh, zarsiList, formPortCode);
                            if (StringUtils.isEmpty(crnIn)) {
                                // 获取分配agv任务去向的站台
                                String toPoint = agvTask.getToPoint();
                                zarsh.setFromPos(toPoint);
                                receiptHeaderService.saveReceiptHeaderBySap(uniqueId, zarsh, zarsiList);
                            }
                            break;
                        }
                        // 生成入库单 用于AGV调用组盘接口
                        receiptHeaderService.saveReceiptHeaderBySap(uniqueId, zarsh, zarsiList);
                        break;
                    // 有托盘
                    case 1:
                        // 判断 from_pos 来源
                        domain.setFormPort(formPortCode);
                        // 立库agv交互点入库
                        // 指定去那边
                        if ((defineProperty == 2 && StringUtils.isEmpty(zarsh.getCrnIn())) || defineProperty == 0) {
                            createSAPReceiptTask(uniqueId, zarsh, zarsiList);
                        }
                        // agv站台入库
                        if (defineProperty == 1 || (defineProperty == 2 && StringUtils.isNotEmpty(zarsh.getCrnIn()))) {
                            createReceiptAGVTask(zarsh, zarsiList, formPortCode);
                        }
                        break;
                    default:
                        throw new IllegalStateException("Unexpected value: " + containerFlag);
                }
                break;
            // 出库
            case "1":
            case "3":
                Station stationLocation = stationService.getStationBySAPCode(locationCode);
                if (stationLocation != null) {
                    Station toStation = stationService.getStationBySAPCode(toPort);
                    if (toStation == null) {
                        throw new ServiceException("站台未找到！" + formPort);
                    }
                    createStation2Station(zarsh, zarsiList, toStation.getCode());
                    break;
                }
                // 判断库区
                Location location = locationService.getLocationByCode(locationCode, QuantityConstant.WAREHOUSECODE);
                if (location == null) {
                    throw new ServiceException("SAP库位为空请检查数据" + zarsh.getLocation());
                }
                zoneCode = location.getZoneCode();
                Station toStation = stationService.getStationBySAPCode(toPort);
                if (toStation == null) {
                    throw new ServiceException("站台未找到！" + toPort);
                }
                // 校验是否为出库站台
                checkShipmentPort(toStation);
                // 出库站台编码
                String toPortCode1 = toStation.getCode();
                Integer defineProperty1 = toStation.getDefineProperty();
                if (StringUtils.isEmpty(locationCode)) {
                    throw new ServiceException("SAP数据异常 locationCode 值为空");
                }
                // 边线库区
                if (zoneCode.contains("X")) {
                    // 先生成AGV任务
                    switch (defineProperty1) {
                        case 1:
                            createShipmentAGVTask(zarsh, zarsiList, toPortCode1);
                            break;
                        case 2:
                            createShipmentAGVTask(zarsh, zarsiList, toPortCode1);
                            // 临时托盘生成 入库单
                            if (!location.getContainerCode().contains("TP")) {
                                receiptHeaderService.saveReceiptHeaderBySap(uniqueId, zarsh, zarsiList);
                            }
                            break;
                        default:
                            throw new ServiceException("SAP数据异常");
                    }
                } else {
                    // 生成立库任务
                    switch (defineProperty1) {
                        case 1:
                            // 获取立库AGV交互站台
                            String port = getLKAGVPort(zoneCode, toStation.getLayer(), location.getRoadway(), QuantityConstant.SHIPMENT_STATION_TYPE, 0, 0,
                                toStation.getRangeStation());
                            createSAPShipmentTask(zarsh, zarsiList, port);
                            break;
                        default:
                            createSAPShipmentTask(zarsh, zarsiList, toPortCode1);
                    }
                }
            default:
        }
    }

    private void checkMaterialCode(List<Zarsi> zarsiList) {
        Set<String> materialCodes = zarsiList.stream().map(Zarsi::getMatnr).collect(Collectors.toSet());
        for (String materialCode : materialCodes) {
            Material material = materialService.getMaterialByCode(materialCode, QuantityConstant.WAREHOUSECODE);
            if (StringUtils.isNull(material)) {
                material = new Material();
                material.setCode(materialCode);
                material.setName(materialCode);
                basicDataApiService.material(material);
            }
        }

    }

    /**
     * 根据sap创建入库任务
     */
    @ProcessTrack(taskName = "创建入库任务", processCode = ProcessCode.RECEIPT_TASK_CODE)
    public void createSAPReceiptTask(String uniqueId, Zarsh zarsh, List<Zarsi> zarsiList) {
        String warehouseCode = QuantityConstant.WAREHOUSECODE;
        Integer priority = 10;
        String containerCode = zarsh.getDrumId();
        String port = zarsh.getFromPos();
        Station station = stationService.getStationBySAPCode(port);
        if (station != null) {
            port = station.getCode();
            priority = station.getPriority();
        }
        String zoneCode = SAPUtils.getZoneCode(zarsh);
        Container container = containerService.getContainerByCode(containerCode, warehouseCode);
        if (StringUtils.isNull(container)) {
            throw new ServiceException("托盘不存在！");
        }
        if (container.getStatus().equals(QuantityConstant.STATUS_CONTAINER_LOCK)) {
            throw new ServiceException("托盘已经锁定！");
        }

        containerService.updateStatus(container.getCode(), QuantityConstant.STATUS_LOCATION_LOCK, warehouseCode);

        // 创建任务头
        TaskHeader task = new TaskHeader();
        task.setTaskType(QuantityConstant.TASK_TYPE_WHOLERECEIPT);
        task.setUniqueIds(uniqueId);
        task.setZoneCode(zoneCode);
        task.setInternalTaskType(QuantityConstant.TASK_INTENERTYPE_RECEIPT);
        task.setAllocationHeadId(0);
        task.setWarehouseCode(warehouseCode);
        task.setAssignedUser(ShiroUtils.getLoginName() == null ? QuantityConstant.PLATFORM_WCS : ShiroUtils.getLoginName());
        task.setConfirmedBy(ShiroUtils.getLoginName() == null ? QuantityConstant.PLATFORM_WCS : ShiroUtils.getLoginName());
        task.setPort(port);
        task.setStatus(QuantityConstant.TASK_STATUS_BUILD);
        task.setContainerCode(container.getCode());
        task.setCompanyCode(QuantityConstant.COMPANYCODE);
        task.setCreatedBy(QuantityConstant.PLATFORM_SAP);
        task.setCreated(DateUtils.getNowDate());
        task.setPriority(priority);
        if (StringUtils.isNotEmpty(zarsh.getHFlag())) {
            task.setHFlag(Integer.parseInt(zarsh.getHFlag()));
        }
        if (StringUtils.isNotEmpty(zarsh.getRlFlag())) {
            task.setRlFlag(Integer.parseInt(zarsh.getRlFlag()));
        }

        // 剪切线分配库位
        task = receiptTaskService.getLocationByH(task.getPort(), task);
        if (!taskHeaderService.save(task)) {
            throw new ServiceException("生成任务失败");
        }
        List<TaskDetail> taskDetailList = new ArrayList<>();
        for (Zarsi zarsi : zarsiList) {
            String materialCode = zarsi.getMatnr();
            Material material = materialService.getMaterialByCode(materialCode, warehouseCode);
            if (material == null) {
                material = new Material();
                material.setCode(materialCode);
                material.setName(materialCode);
                basicDataApiService.material(material);
            }
            TaskDetail taskDetail = new TaskDetail();
            taskDetail.setTaskId(task.getId());
            taskDetail.setTaskType(task.getTaskType());
            taskDetail.setInternalTaskType(QuantityConstant.TASK_INTENERTYPE_RECEIPT);
            taskDetail.setWarehouseCode(task.getWarehouseCode());
            taskDetail.setAllocationId(0);
            taskDetail.setCompanyCode(task.getCompanyCode());
            taskDetail.setMaterialCode(material.getCode());
            taskDetail.setMaterialName(material.getName());
            taskDetail.setMaterialSpec(material.getSpec());
            taskDetail.setMaterialUnit(material.getUnit());
            taskDetail.setInventorySts(QuantityConstant.GOOD);
            taskDetail.setBillCode(QuantityConstant.EMPTY_STRING);
            taskDetail.setContainerDetailNumber(zarsi.getPosnr());
            taskDetail.setBillDetailId(0);
            taskDetail.setLot(zarsi.getWjffh());
            // 查找上游号
            taskDetail.setReferenceCode(uniqueId);
            taskDetail.setQty(zarsi.getVerme());
            taskDetail.setContainerCode(task.getContainerCode());
            taskDetail.setFromLocation(task.getFromLocation());
            taskDetail.setRollNumber(zarsi.getCharg());
            taskDetail.setCreatedBy(QuantityConstant.PLATFORM_SAP);
            taskDetail.setCreated(DateUtils.getNowDate());
            taskDetailList.add(taskDetail);
        }
        taskDetailService.saveBatch(taskDetailList);

    }

    /**
     * 根据sap创建出库任务
     */
    public void createSAPShipmentTask(Zarsh zarsh, List<Zarsi> zarsiList, String allocationStationCode) {
        String warehouseCode = QuantityConstant.WAREHOUSECODE;
        String locationCode = zarsh.getLocation();
        String uniqueId = zarsh.getUniqueId();
        Integer priority = 10;
        Location location = locationService.getLocationByCode(locationCode, warehouseCode);
        if (StringUtils.isNull(location)) {
            throw new ServiceException("库位禁用或不存在！");
        }
        Station station = stationService.getStaionByCode(allocationStationCode);
        if (station != null) {
            priority = station.getPriority();
        }
        if (StringUtils.isEmpty(location.getContainerCode())) {
            throw new ServiceException("库位容器不存在 请联系现场人员是否通过WMS出库！");
        }
        Container container = containerService.getContainerByCode(location.getContainerCode(), warehouseCode);
        if (StringUtils.isNull(container)) {
            throw new ServiceException("托盘不存在！");
        }
        if (container.getStatus().equals(QuantityConstant.STATUS_CONTAINER_LOCK)) {
            throw new ServiceException("托盘已经锁定！");
        }

        containerService.updateStatus(container.getCode(), QuantityConstant.STATUS_LOCATION_LOCK, warehouseCode);
        locationService.updateStatus(location.getCode(), QuantityConstant.STATUS_LOCATION_LOCK, warehouseCode);

        List<InventoryDetail> inventoryDetails =
            inventoryDetailService.list(new LambdaQueryWrapper<InventoryDetail>().eq(InventoryDetail::getLocationCode, locationCode));

        TaskHeader task = new TaskHeader();
        task.setAllocationHeadId(0);
        task.setInternalTaskType(QuantityConstant.TASK_INTENERTYPE_SHIPMENT);
        task.setWarehouseCode(warehouseCode);
        task.setZoneCode(location.getZoneCode());
        task.setCompanyCode(QuantityConstant.COMPANYCODE);
        task.setStatus(QuantityConstant.TASK_STATUS_BUILD);
        task.setTaskType(QuantityConstant.TASK_TYPE_WHOLESHIPMENT);
        task.setFromLocation(locationCode);
        task.setCrnIn(zarsh.getCrnIn());
        task.setContainerCode(container.getCode());
        task.setPort(allocationStationCode);
        task.setSendTo(0);
        task.setUniqueIds(uniqueId);
        task.setCreatedBy(QuantityConstant.PLATFORM_SAP);
        task.setPriority(priority);
        // 剪切线检验库位和站台的限制
        locationService.checkPreLocationByCode(locationCode, allocationStationCode, task.getZoneCode());
        taskHeaderService.save(task);

        List<Zarsi> zarsis = zarsiList.stream().filter(e -> "X".equals(e.getUseFlag())).collect(toList());
        if (zarsis.isEmpty()) {
            if ("B".equals(SAPUtils.getZoneCode(zarsh))) {
                throw new ServiceException("没有USE_FLAG使用标识");
            }
        }
        List<String> lots = zarsis.stream().map(Zarsi::getCharg).collect(toList());
        Map<String, Zarsi> maps = new HashMap<>();
        for (Zarsi zarsi : zarsiList) {
            String charg = zarsi.getCharg();
            maps.put(charg, zarsi);
        }
        List<TaskDetail> taskDetailList = new ArrayList<>();
        for (InventoryDetail inventoryDetail : inventoryDetails) {
            TaskDetail taskDetail = new TaskDetail();

            taskDetail.setTaskId(task.getId());
            taskDetail.setInternalTaskType(task.getInternalTaskType());
            taskDetail.setWarehouseCode(task.getWarehouseCode());
            taskDetail.setCompanyCode(task.getCompanyCode());
            taskDetail.setTaskType(task.getTaskType());
            taskDetail.setToInventoryId(inventoryDetail.getId());
            taskDetail.setFromInventoryId(inventoryDetail.getId());
            taskDetail.setAllocationId(0);
            taskDetail.setBillCode(QuantityConstant.EMPTY_STRING);
            taskDetail.setMaterialCode(inventoryDetail.getMaterialCode());
            taskDetail.setMaterialName(inventoryDetail.getMaterialName());
            taskDetail.setMaterialSpec(inventoryDetail.getMaterialSpec());
            taskDetail.setMaterialUnit(inventoryDetail.getMaterialUnit());
            taskDetail.setLevel(inventoryDetail.getLevel());
            taskDetail.setQty(inventoryDetail.getQty());
            taskDetail.setContainerCode(task.getContainerCode());
            taskDetail.setFromLocation(task.getFromLocation());
            taskDetail.setLot(inventoryDetail.getLot());
            taskDetail.setBatch(inventoryDetail.getBatch());
            taskDetail.setProjectNo(inventoryDetail.getProjectNo());
            taskDetail.setStatus(QuantityConstant.TASK_STATUS_BUILD);
            taskDetail.setWaveId(0);
            taskDetail.setInventorySts(inventoryDetail.getInventorySts());
            taskDetail.setReferenceCode(inventoryDetail.getReferCode());
            taskDetail.setRollNumber(inventoryDetail.getRollNumber());
            taskDetail.setContainerDetailNumber(inventoryDetail.getContainerDetailNumber());
            taskDetailList.add(taskDetail);
            inventoryDetail.setTaskQty(inventoryDetail.getQty());
            if (!lots.contains(inventoryDetail.getRollNumber())) {
                continue;
            }
            //
            Zarsi zarsi = maps.get(inventoryDetail.getRollNumber());
            if (StringUtils.isNotNull(zarsi)) {
                zarsi.setPosnr(inventoryDetail.getContainerDetailNumber());
                zarsiService.updateById(zarsi);
            }
        }
        if (inventoryDetails == null || inventoryDetails.size() == 0) {
            throw new ServiceException(locationCode + "库位没库存！");
        }
        inventoryDetailService.updateBatchById(inventoryDetails);
        taskDetailService.saveBatch(taskDetailList);

    }

    public AgvTask createReceiptAGVTask(Zarsh zarsh, List<Zarsi> zarsiList, String allocationStationCode) {
        Station station = stationService.getStaionByCode(allocationStationCode);
        if (station == null) {
            throw new ServiceException(allocationStationCode + "站台异常，未找到站台");
        }
        int layer = station.getLayer();
        // 来源点位
        String fromPoint = station.getCode();
        String taskTypes = QuantityConstant.RECEIPT_AGV;
        // 来源点位
        String toPoint = "";
        String toPos = zarsh.getToPos();
        // 去向位置 如果找不到去向位置 就在后面分配库位 或者 分配立库交互站台 根据 库区类型来
        if (StringUtils.isNotEmpty(toPos)) {
            Station station1 = stationService.getStationBySAPCode(toPos);
            toPoint = station1.getCode();
        }

        String zoneCode = station.getZoneCode();
        String containerCode = zarsh.getDrumId();
        Integer pointType = -1;
        Container container = null;
        if (StringUtils.isEmpty(containerCode)) {
            containerCode = containerService.createContainerByZone(zoneCode);
        }
        container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
        // 没有托盘创建虚拟托盘
        if (container == null) {
            containerCode = containerService.createContainerByZone(zoneCode);
            container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
        }
        TaskHeader task = taskHeaderService.checkTaskByContainerCode(containerCode);
        if (task != null) {
            if (task.getInternalTaskType().intValue() == 100) {
                throw new ServiceException("入库,该容器已存在未完成的立库入库任务,请不要重复下发" + containerCode);
            } else if (task.getInternalTaskType().intValue() == 200) {
                throw new ServiceException("入库,该容器已存在未完成的立库出库任务,出库任务未完成，请到WCS中未完成任务查看是否有改任务，任务状态是否是响应接出站台请求，如果是直接手动强制完成该任务即可恢复正常，同时告知电气或WCS；" + containerCode);
            } else {
                throw new ServiceException("入库,该容器已存在未完成的任务" + containerCode);
            }
        }
        AgvTask agvTask1 = taskHeaderService.checkAgvTaskByContainerCode(containerCode);
        if (agvTask1 != null) {
            throw new ServiceException("入库,该容器已存在未完成的agv任务,请不要重复下发" + containerCode);
        }
        // 不是出库入库
        if (QuantityConstant.STATUS_LOCATION_LOCK.equals(container.getStatus())) {
            // 没有任务直接解锁
            containerService.updateLocationCodeAndStatus(containerCode, "", QuantityConstant.STATUS_LOCATION_EMPTY, QuantityConstant.WAREHOUSECODE);
//                            throw new ServiceException("容器状态为锁定" + containerCode);
        }
        if (StringUtils.isNotNull(container.getPlType())) {
            if (container.getPlType() == 0) {
                pointType = 1;
            }
            if (container.getPlType() == 1) {
                pointType = 2;
            }
            if (container.getPlType() == 2) {
                pointType = 2;
            }
        }
        if (StringUtils.isNotEmpty(container.getLocationCode())) {
//            throw new ServiceException("容器在库位" + container.getLocationCode() + "上！");
            AjaxResult ajaxResult = inventoryHeaderService.removeInventoryByContainer(containerCode);
            if (ajaxResult.hasErr()) {
                throw new ServiceException(ajaxResult.getMsg());
            }
        }
        int unCompleteTask = agvTaskService.getUnCompleteTask(containerCode);
        if (unCompleteTask > 0) {
            throw new ServiceException(containerCode + "容器存在未完成的AGV任务！");
        }

        AgvTask agvTask = new AgvTask();
        agvTask.setLayer(layer);
        agvTask.setIsEmpty(zarsh.getInKind());
        agvTask.setFromPoint(fromPoint);
        agvTask.setToPoint(toPoint);
        agvTask.setZoneCode(zoneCode);
        // AGV任务类型都为配送
        agvTask.setTaskType(QuantityConstant.PEISONG_AGV);
        agvTask.setTaskTypes(taskTypes);
        agvTask.setPalletNo(containerCode);
        agvTask.setUniqueId(zarsh.getUniqueId());
        agvTask.setCreatedBy(QuantityConstant.PLATFORM_SAP);
        agvTask.setCreated(DateUtils.getNowDate());
        agvTask.setPointType(pointType);
        // 添加上布物料直径
        if (zarsiList != null && zarsiList.size() == 1) {
            agvTask.setLot(zarsiList.get(0).getCharg());
            MaterialDiameter materialDiameter =
                materialDiameterService.getOne(new LambdaQueryWrapper<MaterialDiameter>().eq(MaterialDiameter::getLot, agvTask.getLot()));
            if (materialDiameter != null) {
                agvTask.setMaterialDiameter(materialDiameter.getDiameter());
            }
        }
        agvTaskService.save(agvTask);
        containerService.updateStatus(containerCode, QuantityConstant.STATUS_CONTAINER_LOCK, QuantityConstant.WAREHOUSECODE);
        if (StringUtils.isEmpty(agvTask.getToPoint())) {
            if (StringUtils.isEmpty(zarsh.getCrnIn())) {
                // 根据库区 楼层 巷道 获取终点站台
                String port = getLKAGVPort(SAPUtils.getZoneCode(zarsh), layer, null, QuantityConstant.RECEIPT_STATION_TYPE, station.getOutSlicePalletArea(),
                    station.getOutRollPalletArea(), station.getRangeStation());
                agvTask.setToPoint(port);
                agvTaskService.updateById(agvTask);
            } else if (StringUtils.isNotEmpty(zarsh.getCrnIn()) && StringUtils.isEmpty(zarsh.getToPos())) {
                warecellAllocationService.agvWarecellAllocation(agvTask);
            }
        }
        return agvTask;
    }

    public AgvTask createShipmentAGVTask(Zarsh zarsh, List<Zarsi> zarsiList, String allocationStationCode) {
        String zoneCode = null;
        String locationCode = zarsh.getLocation();
        Station station = stationService.getStaionByCode(allocationStationCode);
        if (station == null) {
            throw new ServiceException(allocationStationCode + "站台异常，未找到站台");
        }
        int layer = station.getLayer();
        // 校验站台是否可以直接使用
        if (StringUtils.isEmpty(locationCode)) {
            List<String> roadways = new ArrayList<>();
            roadways.add("0");
            zoneCode = SAPUtils.getZoneCode(zarsh);
            String palletCode = containerService.getEmptyContainerList(zoneCode, roadways, null, zarsh.getPlType());
            if (StringUtils.isEmpty(palletCode)) {
                throw new ServiceException(zoneCode + " AGV缓存区没有空容器可以出");
            }
            Container container1 = containerService.getContainerByCode(palletCode, QuantityConstant.WAREHOUSECODE);
            locationCode = container1.getLocationCode();
        }
        Location location = locationService.getLocationByCode(locationCode, QuantityConstant.WAREHOUSECODE);
        if (location == null) {
            throw new ServiceException(locationCode + " 系统内未找到改库位");
        }
        Container container = containerService.getContainerByCode(location.getContainerCode(), QuantityConstant.WAREHOUSECODE);
        if (container == null) {
            throw new ServiceException(locationCode + " 系统内未找到改库位");
        }
        if (zarsh.getInKind() == 0) {
            if (!container.getStatus().equals(QuantityConstant.STATUS_CONTAINER_EMPTY)) {
                throw new ServiceException(locationCode + " 容器状态不为空");
            }
        }
        int pointType = -1;
        if (StringUtils.isNotNull(container.getPlType())) {
            if (container.getPlType() == 0) {
                pointType = 3;
            }
            if (container.getPlType() == 1) {
                pointType = 0;
            }
        }
        String fromPoint = locationCode;
        String taskTypes = QuantityConstant.SHIPMENT_AGV;
        String toPoint = station.getCode();
        if (layer == 2 && location.getZoneCode().equals("A")) {
            if ("2".equals(location.getRoadway())) {
                toPoint = "P1040";
            }
            if ("1".equals(location.getRoadway())) {
                toPoint = "P1039";
            }
        }

        AgvTask agvTask = new AgvTask();
        agvTask.setLayer(layer);
        agvTask.setIsEmpty(zarsh.getInKind());
        agvTask.setFromPoint(fromPoint);
        agvTask.setToPoint(toPoint);
        agvTask.setZoneCode(location.getZoneCode());
        // AGV任务类型都为配送
        agvTask.setTaskType(QuantityConstant.PEISONG_AGV);
        agvTask.setTaskTypes(taskTypes);
        agvTask.setPalletNo(location.getContainerCode());
        agvTask.setUniqueId(zarsh.getUniqueId());
        agvTask.setCreatedBy(QuantityConstant.PLATFORM_SAP);
        agvTask.setCreated(DateUtils.getNowDate());
        agvTask.setPointType(pointType);
        if (zarsiList.size() == 1) {
            agvTask.setLot(zarsiList.get(0).getCharg());
            MaterialDiameter materialDiameter =
                materialDiameterService.getOne(new LambdaQueryWrapper<MaterialDiameter>().eq(MaterialDiameter::getLot, agvTask.getLot()));
            if (materialDiameter != null) {
                agvTask.setMaterialDiameter(materialDiameter.getDiameter());
            }
        }
        agvTaskService.save(agvTask);
        List<Zarsi> zarsis = zarsiList.stream().filter(e -> "X".equals(e.getUseFlag())).collect(toList());
        if (zarsis.isEmpty()) {
            if ("B".equals(SAPUtils.getZoneCode(zarsh))) {
                throw new ServiceException("没有USE_FLAG使用标识");
            }
        }
        List<String> lots = zarsis.stream().map(Zarsi::getCharg).collect(toList());
        Map<String, Zarsi> maps = new HashMap<>();
        for (Zarsi zarsi : zarsiList) {
            String charg = zarsi.getCharg();
            maps.put(charg, zarsi);
        }
        List<InventoryDetail> inventoryDetails =
            inventoryDetailService.list(new LambdaQueryWrapper<InventoryDetail>().eq(InventoryDetail::getLocationCode, locationCode));
        for (InventoryDetail inventoryDetail : inventoryDetails) {
            if (!lots.contains(inventoryDetail.getRollNumber())) {
                continue;
            }
            Zarsi zarsi = maps.get(inventoryDetail.getRollNumber());
            if (StringUtils.isNotNull(zarsi)) {
                zarsi.setPosnr(inventoryDetail.getContainerDetailNumber());
                zarsiService.updateById(zarsi);
            }
        }

        containerService.updateStatus(container.getCode(), QuantityConstant.STATUS_CONTAINER_LOCK, QuantityConstant.WAREHOUSECODE);
        locationService.updateStatus(locationCode, QuantityConstant.STATUS_CONTAINER_LOCK, QuantityConstant.WAREHOUSECODE);
        return agvTask;
    }

    public AgvTask createStation2Station(Zarsh zarsh, List<Zarsi> zarsiList, String allocationStationCode) {
        String locationCode = zarsh.getLocation();
        Station station = stationService.getStaionByCode(allocationStationCode);
        if (station == null) {
            throw new ServiceException(allocationStationCode + "站台异常，未找到站台");
        }
        int layer = station.getLayer();
        int pointType = -1;
        if (StringUtils.isNotNull(zarsh.getInKind())) {
            if (zarsh.getInKind() == 0) {
                pointType = 3;
            }
            if (zarsh.getInKind() == 1) {
                pointType = 0;
            }
        }
        Station station1 = stationService.getStationBySAPCode(locationCode);
        String fromPoint = station1.getCode();
        String taskTypes = QuantityConstant.STATION_2_STATION_AGV;
        String toPoint = station.getCode();

        AgvTask agvTask = new AgvTask();
        agvTask.setLayer(layer);
        agvTask.setIsEmpty(zarsh.getInKind());
        agvTask.setFromPoint(fromPoint);
        agvTask.setToPoint(toPoint);
        agvTask.setZoneCode(station.getZoneCode());
        // AGV任务类型都为配送
        agvTask.setTaskType(QuantityConstant.PEISONG_AGV);
        agvTask.setTaskTypes(taskTypes);
        agvTask.setUniqueId(zarsh.getUniqueId());
        agvTask.setCreatedBy(QuantityConstant.PLATFORM_SAP);
        agvTask.setCreated(DateUtils.getNowDate());
        agvTask.setPointType(pointType);
        if (zarsiList.size() == 1) {
            agvTask.setLot(zarsiList.get(0).getCharg());
            MaterialDiameter materialDiameter =
                materialDiameterService.getOne(new LambdaQueryWrapper<MaterialDiameter>().eq(MaterialDiameter::getLot, agvTask.getLot()));
            if (materialDiameter != null) {
                agvTask.setMaterialDiameter(materialDiameter.getDiameter());
            }
        }
        agvTaskService.save(agvTask);
        return agvTask;
    }

    public String getLKAGVPort(String toZoneCode, int layer, String roadWay, int inOut, int outSlicePalletArea, int outRollPalletArea, int range) {
        List<Integer> inOuts = new ArrayList<>();
        switch (inOut) {
            case 1:
                inOuts.add(1);
                inOuts.add(3);
                break;
            case 2:
                inOuts.add(2);
                inOuts.add(3);
                break;
        }
        if (toZoneCode.contains("X")) {
            toZoneCode = toZoneCode.replace("X", "");
        }
        List<Station> list =
            stationService.list(new LambdaQueryWrapper<Station>().eq(Station::getZoneCode, toZoneCode).eq(Station::getDefineProperty, QuantityConstant.LK_AGV_PORT)
                .eq(Station::getLayer, layer).eq(Station::getRangeStation, range).eq(outSlicePalletArea > 0, Station::getOutSlicePalletArea, outSlicePalletArea)
                .eq(outRollPalletArea > 0, Station::getOutRollPalletArea, outRollPalletArea).in(Station::getType, inOuts)
                .like(StringUtils.isNotEmpty(roadWay), Station::getRoadWay, roadWay));
        List<String> stationCodes = list.stream().map(Station::getCode).collect(toList());

        if (stationCodes.isEmpty()) {
            throw new ServiceException("该库区没有配置AGV 立库站台请前往配置");
        }

        LambdaQueryWrapper<TaskHeader> queryWrapper = Wrappers.lambdaQuery();
        queryWrapper.eq(TaskHeader::getZoneCode, toZoneCode).in(TaskHeader::getPort, stationCodes)
            .in(TaskHeader::getTaskType, 100, 200, 300, 400, 500, 600, 1100, 1200).le(TaskHeader::getStatus, QuantityConstant.TASK_STATUS_ARRIVED_STATION);
        List<TaskHeader> list1 = taskHeaderService.list(queryWrapper);

        if (list1.isEmpty()) {
            return stationCodes.get(0);
        }
        Map<String, Integer> map = new HashMap<>();
        for (String stationCode : stationCodes) {
            map.put(stationCode, 0);
        }
        for (TaskHeader taskHeader : list1) {
            if (map.containsKey(taskHeader)) {
                int num = map.get(taskHeader.getPort());
                num++;
                map.put(taskHeader.getPort(), num);
            } else {
                map.put(taskHeader.getPort(), 1);
            }
        }
        List<Map.Entry<String, Integer>> list2 = new ArrayList(map.entrySet());
        Collections.sort(list2, (o1, o2) -> (o1.getValue() - o2.getValue()));
        List<String> ports = list2.stream().map(Map.Entry::getKey).collect(toList());
        String s = ports.get(0);
        return s;
    }

    public void checkStationContainer(Station station, String containerCode) {
        String formPort = station.getByName();
        switch (station.getForceContainer()) {
            case 1:
                if (StringUtils.isNotEmpty(containerCode)) {

                    Container container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
                    if (container == null) {
                        throw new ServiceException(formPort + "入库站台站点容器号 不存在系统" + containerCode);
                    }
                    if (station.getArea() == 4 || station.getArea() == 5) {
                        if (!container.getArea().equals("4") && !container.getArea().equals("5")) {
                            throw new ServiceException("：容器和站台不匹配:" + formPort + ":" + containerCode);
                        }
                    } else {
                        if (!station.getArea().toString().equals(container.getArea())) {
                            throw new ServiceException("容器和站台不匹配:" + formPort + ":" + containerCode);
                        }
                    }
                } else {
                    throw new ServiceException(formPort + "入库站台站点容器号 不能为空");
                }
                break;
            case 2:
                // 该站台不能
                Container container = containerService.getContainerByCode(containerCode, QuantityConstant.WAREHOUSECODE);
                if (container != null) {
                    throw new ServiceException("组盘站点不需要输入托盘号！！");
                }
                break;
            default:
        }
    }

    public void checkReceiptPort(Station receiptStation) {
        if (receiptStation == null) {
            throw new ServiceException("入库站台不能为空");
        }
        switch (receiptStation.getType()) {
            case "1":
            case "3":
            case "0":
                break;
            default:
                throw new ServiceException("入库站台类型不匹配");
        }
    }

    public void checkShipmentPort(Station shipmentStation) {
        if (shipmentStation == null) {
            throw new ServiceException("出库站台不能为空");
        }
        switch (shipmentStation.getType()) {
            case "2":
            case "3":
            case "0":
                break;
            default:
                throw new ServiceException("出库站台类型不匹配");
        }
    }

    /**
     * 1、去向为站台
     * 2、去向为库位
     * @return
     */
    public int agvToPointChooseStationOrLocation(Zarsh zarsh) {

        // 1.校验库区是否存在
        String zoneCode = SAPUtils.getZoneCode(zarsh);
        // 2.校验库区为边线区还是立库区
        Zone zone = zoneService.getZoneByCode(zoneCode);
        if (zone == null) {
            return 0;
        }
        if (StringUtils.isNotEmpty(zone.getUserDef1())) {
            switch (zone.getUserDef1()) {
                case "1":
                case "2":
                    break;
                default:
            }
        }
        // 3.校验边线库区是否存在库位
        return 0;

    }

}