WAREAMS/warewms-ams/src/main/java/com/ruoyi/ams/xuankuang/service/WcsToWmsApiService.java

package com.ruoyi.ams.xuankuang.service;

import cn.hutool.core.comparator.CompareUtil;
import cn.hutool.core.util.ObjectUtil;
import com.ruoyi.ams.asn.domain.WmsDocAsnDetails;
import com.ruoyi.ams.asn.domain.WmsDocAsnHeader;
import com.ruoyi.ams.asn.mapper.WmsDocAsnDetailsMapper;
import com.ruoyi.ams.asn.mapper.WmsDocAsnHeaderMapper;
import com.ruoyi.ams.asn.service.IWmsDocAsnDetailsService;
import com.ruoyi.ams.config.domain.dto.LotattDTO;
import com.ruoyi.ams.task.domain.WcsTask;
import com.ruoyi.ams.task.service.IWcsTaskService;
import com.ruoyi.ams.xuankuang.domain.form.*;
import com.ruoyi.ams.xuankuang.domain.vo.LocationCoordinateVo;
import com.ruoyi.ams.xuankuang.facade.IUnpackingMachineFacade;
import com.ruoyi.base.constant.Constant;
import com.ruoyi.base.domain.BaseLocationInfo;
import com.ruoyi.base.domain.vo.BaseLocationLotattVO;
import com.ruoyi.base.service.IBaseLocationInfoService;
import com.ruoyi.base.service.IBaseSkuService;
import com.ruoyi.base.utils.IdSequenceUtils;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.hard.xuankang.StirringTankClient;
import com.ruoyi.hard.xuankang.UnpackingMachineSubClient;
import io.jsonwebtoken.lang.Assert;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;

import static com.ruoyi.ams.xuankuang.service.BaseLocationInfoSubService.OUT_ZONES;

/**
 * @author HuKang
 * @version 1.0
 * @date 2023/3/30 15:42
 */
@Slf4j
@Service
public class WcsToWmsApiService {

    @Autowired
    private IBaseSkuService iBaseSkuService;
    @Autowired
    private IBaseLocationInfoService iBaseLocationInfoService;
    @Autowired
    private BaseLocationInfoSubService baseLocationInfoSubService;
    @Autowired
    private InvLotLocIdSubService InvLotLocIdSubService;
    @Autowired
    private WcsTaskSubService wcsTaskSubService;
    @Autowired
    private IWcsTaskService iWcsTaskService;
    @Autowired
    private WmsDocAsnHeaderMapper wmsDocAsnHeaderMapper;
    @Autowired
    private WmsDocAsnDetailsMapper wmsDocAsnDetailsMapper;
    @Autowired
    private IdSequenceUtils idSequenceUtils;
    @Autowired
    private StirringTankClient stirringTankClient;
    @Autowired
    private UnpackingMachineSubClient unpackingMachineSubClient;

    @Autowired
    private IUnpackingMachineFacade unpackingMachineFacade;
    @Autowired
    private IWcsTaskService wcsTaskService;
    @Autowired
    private IWmsDocAsnDetailsService wmsDocAsnDetailsService;
    @Autowired
    private WmsDocAsnSubService wmsDocAsnSubService;
    @Autowired
    private AgvCallProxyService agvCallProxyService;


    /**
     * 组盘上报
     *
     * @param stackingCompletion
     * @return
     */
    @Transactional
    public AjaxResult stackingCompletion(StackingCompletionForm stackingCompletion) {
        // 上报类型
        int reportType = stackingCompletion.getReportType();
        // 托盘号
        String palletNo = stackingCompletion.getPalletNo();
        // Wcs物料类型
        String materialType = stackingCompletion.getMaterialType();
        // wms物料编码
        String sku = iBaseSkuService.selectBaseSkuByMaterialType(materialType).getSku();
        // 数量
        Double qty = (double) stackingCompletion.getQty();
        // 入库单号
        String asnNo = stackingCompletion.getRelatedWmsNo();
        // 任务号
        String wcsNo = stackingCompletion.getWcsNo();

        if (StringUtils.isBlank(asnNo)) {
            AjaxResult ajaxResult1 = generateAShippingOrder(sku, new BigDecimal(qty));
            asnNo = ajaxResult1.getData().toString();
        }
        return insertTaskAndInvLotLocId(asnNo, palletNo, wcsNo, sku, qty);
    }

    private AjaxResult insertTaskAndInvLotLocId(String asnNo, String palletNo, String wcsNo, String sku, Double qty){
        WcsTask wcsTaskQuery = new WcsTask();
        wcsTaskQuery.setExt1(asnNo);
        wcsTaskQuery.setExt2(palletNo);
        wcsTaskQuery.setExt3(wcsNo);
        wcsTaskQuery.setState(Long.parseLong(Constant.TASK_STS.TASK10.getValue().toString()));
        WcsTask wcsTask = iWcsTaskService.selectWcsTaskByModel(wcsTaskQuery);
        if (wcsTask != null) {
            BaseLocationInfo baseLocationInfo = iBaseLocationInfoService.selectBaseLocationInfoByIdOrNo(wcsTask.getLocationTo(), Constant.WAREHOUSE_ID);
            return AjaxResult.success("仓位获取成功!", buildLocationCoordinateVo(wcsTask.getTaskNo(), baseLocationInfo.getLocationNo(), baseLocationInfo.getShiftNo(), baseLocationInfo.getRowNo(), baseLocationInfo.getRowIndex(), baseLocationInfo.getUserdefine4()));
        }
        // 推荐目标库位
        BaseLocationLotattVO baseLocationLotattVO = baseLocationInfoSubService.recommendAReceiptLocation(sku);
        if (baseLocationLotattVO == null) {
            return AjaxResult.error("没有可以推荐的目标库位！");
        }
        // 生成任务
        AjaxResult ajaxResult = wcsTaskSubService.addWcsTask(Constant.LOC_STAGE_CACHE.toString()
                , baseLocationLotattVO.getId().toString()
                , asnNo
                , palletNo
                , wcsNo);
        if (!ajaxResult.isSuccess()) {
            return ajaxResult;
        }
        String taskNo = ajaxResult.get("data").toString();
        // 入库缓存位生成库存
        InvLotLocIdSubService.initInv(Constant.LOC_STAGE_CACHE.toString(), sku, palletNo, asnNo, taskNo, qty);
        // 反馈
        return AjaxResult.success("仓位获取成功!", buildLocationCoordinateVo(taskNo, baseLocationLotattVO.getLocationNo(), baseLocationLotattVO.getShiftNo(), baseLocationLotattVO.getRowNo(), baseLocationLotattVO.getRowIndex(), baseLocationLotattVO.getUserdefine4()));
    }

    private LocationCoordinateVo buildLocationCoordinateVo(String taskNo, String locationId, String floor, String col, String row, String wcsLocation){
        LocationCoordinateVo locationCoordinateVo = new LocationCoordinateVo();
        locationCoordinateVo.setTaskNo(taskNo);
        locationCoordinateVo.setLocationId(locationId);
        locationCoordinateVo.setFloor(Integer.valueOf(floor));
        locationCoordinateVo.setCol(Integer.valueOf(col));
        locationCoordinateVo.setRow(Integer.valueOf(row));
        locationCoordinateVo.setWcsLocation(wcsLocation);
        return locationCoordinateVo;
    }

    /**
     * 空托仓位请求
     *
     * @param emptyPalletLocForm
     * @return
     */
    @Transactional
    public AjaxResult EmptyPalletLoc(EmptyPalletLocForm emptyPalletLocForm) {
        // 空托仓位请求类型
        int taskType = emptyPalletLocForm.getTaskType();
        // 任务号
        String wcsNo = emptyPalletLocForm.getWcsNo();

        if (taskType == 0) {
            return AjaxResult.error("未传入空托仓位请求类型");
        }

        if (taskType == 1) {
            return insertTaskAndInvLotLocId(StringUtils.EMPTY, StringUtils.EMPTY, wcsNo, Constant.PALLET_TYPE, 1.0);
      }
        //出库仓位
        List<BaseLocationLotattVO> baseLocationLotattVOS = baseLocationInfoSubService.selectAllocatingInventoryAccordingConditionsOrderBy(OUT_ZONES, new LotattDTO(), Constant.PALLET_TYPE, StringUtils.EMPTY);
        if (baseLocationLotattVOS.size() == 0) {
            return AjaxResult.error("仓库中无库存");
        }
        BaseLocationLotattVO baseLocationLotattVO = filterInv1(baseLocationLotattVOS);
        Assert.isTrue(ObjectUtil.isNotNull(baseLocationLotattVO), "仓库中无库存");

        String pallentNo = ObjectUtil.isNotNull(baseLocationLotattVO.getLotattVO())
                ? baseLocationLotattVO.getLotattVO().getLotatt07() : StringUtils.EMPTY;
        String locationFrom = baseLocationLotattVO.getLocationNo();

        // 生成四向车出库任务
        AjaxResult ajaxResult = wcsTaskSubService.addWcsOutTask(locationFrom, Constant.LOC_SORTATION_CACHE.toString(), "", pallentNo, wcsNo);
        return AjaxResult.success("仓位获取成功", buildLocationCoordinateVo(ajaxResult.get("data").toString(), baseLocationLotattVO.getLocationNo(), baseLocationLotattVO.getShiftNo(), baseLocationLotattVO.getRowNo(), baseLocationLotattVO.getRowIndex(), baseLocationLotattVO.getUserdefine4()));
    }


    /**
     * 任务状态反馈
     *
     * @param taskStatusForm
     * @return
     */
    public AjaxResult taskStatusResponse(TaskStatusForm taskStatusForm) {
        String taskNo = taskStatusForm.getTaskNo();
        int status = taskStatusForm.getStatus();
        wcsTaskSubService.callBack(taskNo, status, null);
        return AjaxResult.success();
    }

    /**
     * 匹配库存
     *
     * @param locationLotattList
     * @return
     */
    public synchronized BaseLocationLotattVO filterInv1(List<BaseLocationLotattVO> locationLotattList) {
        return locationLotattList.parallelStream()
                .filter(item -> ObjectUtil.isNotNull(item)
                        && StringUtils.equals(Constant.PALLET_TYPE, item.getSku())
                        && CompareUtil.compare(item.getQty(), 1F) == 0).findFirst().orElse(null);
    }

    /**
     * 生成入库单
     *
     * @param sku
     * @param qty
     * @return
     */
    public AjaxResult generateAShippingOrder(String sku, BigDecimal qty) {
        WmsDocAsnHeader wmsDocAsnHeader = new WmsDocAsnHeader();
        //生成单头
        String asnNo = idSequenceUtils.generateId("ASNNO");
        wmsDocAsnHeader.setAsnNo(asnNo);
        wmsDocAsnHeader.setEdiSendFlag("N");
        wmsDocAsnHeader.setAsnType(Constant.ASN_TYP.HK.getValue());
        wmsDocAsnHeader.setCreateTime(new Date());
        wmsDocAsnHeader.setAsnStatus(Constant.ASN_STS.STS10.getValue());
        wmsDocAsnHeader.setCreateBy("Wms");
        wmsDocAsnHeaderMapper.insertWmsDocAsnHeader(wmsDocAsnHeader);

        //生成明细
        WmsDocAsnDetails wmsDocAsnDetails = new WmsDocAsnDetails();
        wmsDocAsnDetails.setAsnNo(asnNo);
        wmsDocAsnDetails.setAsnLineNo(1l);
        wmsDocAsnDetails.setSku(sku);
        wmsDocAsnDetails.setCreateTime(new Date());
        wmsDocAsnDetails.setExpectedQty(qty);
        wmsDocAsnDetails.setExpectedQtyEach(qty);
        wmsDocAsnDetails.setReceivedQty(new BigDecimal(0));
        wmsDocAsnDetails.setReceivedQtyEach(new BigDecimal(0));
        wmsDocAsnDetails.setLineStatus(Constant.ASN_STS.STS10.getValue());
        wmsDocAsnDetails.setCreateTime(new Date());
        wmsDocAsnDetails.setCreateBy("Wms");
        wmsDocAsnDetailsMapper.insertWmsDocAsnDetails(wmsDocAsnDetails);
        return AjaxResult.success("操作成功！", asnNo);
    }

    /**
     * 拆包机开启接口
     *
     * @param lineOpenNotificationForm
     * @return
     */
    public AjaxResult lineOpenNotification(LineOpenNotificationForm lineOpenNotificationForm) {
        String lineId = lineOpenNotificationForm.getLineId();
        boolean[] booleans = stirringTankClient.readTank14();
        return unpackingMachineFacade.unpackingMachineOpen(lineId, booleans) ? AjaxResult.success() : AjaxResult.error();
    }


    /**
     * 正常关闭1号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpacker() {
        new Thread(() -> {
            try {
                Thread.sleep(300000);
                //写关闭拆包机信号
                unpackingMachineSubClient.writeV141_2();
                //写仓库注入碳酸钠完成
                stirringTankClient.writeTank05();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        return AjaxResult.success();
    }

    /**
     * 正常关闭2号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpacker1() {
        new Thread(() -> {
            try {
                Thread.sleep(300000);
                //写关闭拆包机信号
                unpackingMachineSubClient.writeV141_3();
                //写仓库注入丁黄药完成
                stirringTankClient.writeTank05_1();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        return AjaxResult.success();
    }

    /**
     * 正常关闭3号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpacker2() {
        new Thread(() -> {
            try {
                Thread.sleep(300000);
                //写关闭拆包机信号
                unpackingMachineSubClient.writeV141_4();
                //写仓库注入六偏磷酸钠完成
                stirringTankClient.writeTank05_3();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        return AjaxResult.success();
    }

    /**
     * 正常关闭4号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpacker3() {
        new Thread(() -> {
            try {
                Thread.sleep(300000);
                //写关闭拆包机信号
                unpackingMachineSubClient.writeV141_5();
                //写仓库注入硫酸铵完成
                stirringTankClient.writeTank05_4();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        return AjaxResult.success();
    }

    /**
     * 正常关闭5号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpacker4() {
        new Thread(() -> {
            try {
                Thread.sleep(300000);
                //写关闭拆包机信号
                unpackingMachineSubClient.writeV141_6();
                //写仓库注入乙黄药完成
                stirringTankClient.writeTank05_5();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        return AjaxResult.success();
    }

    /**
     * 异常关闭1号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpackererror() {
        //写仓库注入碳酸钠失败
        stirringTankClient.writeTank04();
        stirringTankClient.writeTank05f();
        //写关闭拆包机信号
        unpackingMachineSubClient.writeV141_2();
        return AjaxResult.success();
    }

    /**
     * 异常关闭2号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpackererror1() {
        //写仓库注入丁黄药失败
        stirringTankClient.writeTank04_1();
        stirringTankClient.writeTank05_1f();
        unpackingMachineSubClient.writeV141_3();
        return AjaxResult.success();
    }

    /**
     * 异常关闭3号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpackererror2() {
        //写仓库注入六偏磷酸钠失败
        stirringTankClient.writeTank04_3();
        stirringTankClient.writeTank05_3f();
        unpackingMachineSubClient.writeV141_4();
        return AjaxResult.success();
    }

    /**
     * 异常关闭4号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpackererror3() {
        //写仓库注入硫酸铵失败
        stirringTankClient.writeTank04_4();
        stirringTankClient.writeTank05_4f();
        unpackingMachineSubClient.writeV141_5();
        return AjaxResult.success();
    }

    /**
     * 异常关闭5号拆包机
     *
     * @return
     */
    public AjaxResult turnOffTheUnpackererror4() {
        //写仓库注入乙黄药失败
        stirringTankClient.writeTank04_5();
        stirringTankClient.writeTank05_5f();
        unpackingMachineSubClient.writeV141_6();
        return AjaxResult.success();
    }

    /**
     * 更新数据接口
     *
     * @param updateForm
     * @return
     */
    public AjaxResult updateAsnData(UpdateForm updateForm) {
        String asnNo = updateForm.getDocNo();
        String asnLineNo = updateForm.getLineNo();
        Integer num = updateForm.getNum();
        WmsDocAsnDetails wmsDocAsnDetails = wmsDocAsnDetailsMapper.selectWmsDocAsnDetailsByAsnLineNo(asnNo, asnLineNo);
        wmsDocAsnDetails.setExpectedQty(new BigDecimal(num));
        wmsDocAsnDetails.setExpectedQtyEach(new BigDecimal(num));
        wmsDocAsnDetailsMapper.updateWmsDocAsnDetails(wmsDocAsnDetails);
        return AjaxResult.success();
    }

    /**
     * 桶装入库
     * @return
     */
    @Transactional
    public synchronized AjaxResult theBucketIsLoadedIntoTheLibrary(String sku, String asnNo, String palletNo, BigDecimal num) {
        // 数量
        Double qty = num.doubleValue();

        return insertTaskAndInvLotLocId(asnNo, palletNo, StringUtils.EMPTY, sku, qty);
    }

    /**
     * 安全交握
     * @param callbackTaskFrom
     * @return
     */
    public AjaxResult secureHandover(CallbackTaskFrom callbackTaskFrom) {
        if (callbackTaskFrom.getSafeCode().equals("1")){
            WcsTask wcsTask = new WcsTask();
            wcsTask.setState(new Long(13));
            WcsTask wcsTask1 = wcsTaskService.selectWcsTaskByModel(wcsTask);
            wcsTask1.setState(new Long(9));
            int i = wcsTaskService.updateWcsTask(wcsTask1);
            if (i>0){
                return AjaxResult.success();
            }
        }else if (callbackTaskFrom.getSafeCode().equals("0")){
            log.error(callbackTaskFrom.getMessage());
            return AjaxResult.success("未执行");
        }
        return AjaxResult.success();
    }

    /**
     * 出库任务下发
     * @return
     */
    public AjaxResult outboundRequest(OutboundForm outboundForm) {
        String locationFrom = "100733";
        String locationTo = "";
        String palletNo = outboundForm.getPalletNo();
        String wcsId = outboundForm.getWcsId();
        AjaxResult ajaxResult = agvCallProxyService.barrelsOutOfStorage(locationFrom, locationTo, palletNo,wcsId);
        if (ajaxResult.isSuccess()){
            return AjaxResult.success("任务创建成功");
        }
        return AjaxResult.error("任务创建失败");
    }

    /**
     * 回调卸货完成前
     * @return
     */
    public AjaxResult agvCallbackWCSBeforeUnloadingIsCompleted() {
        // 查询出状态为10，包含物料信息为丁铵黑药的入库单
        WmsDocAsnDetails wmsDocAsnDetails = new WmsDocAsnDetails();
        wmsDocAsnDetails.setSku("C4H9O2PSSNH4");
        wmsDocAsnDetails.setLineStatus(Constant.ASN_STS.STS10.getValue());
        WmsDocAsnDetails wmsDocAsnDetails1 = wmsDocAsnDetailsService.selectWmsDocAsnDetailsByModel(wmsDocAsnDetails);
        String asnNo = wmsDocAsnDetails1.getAsnNo();
        // 根据入库单号（Ext1）查询出所对应的任务
        WcsTask wcsTask = new WcsTask();
        wcsTask.setExt1(asnNo);
        WcsTask wcsTask1 = wcsTaskService.selectWcsTaskByModel(wcsTask);
        // 根据查出来的任务编号反馈wcs卸货完成
        String taskNo = wcsTask1.getTaskNo();
        wmsDocAsnSubService.wmsAgvCallbackIntask(taskNo);
        return AjaxResult.success();
    }
}