package com.ruoyi.pda.service;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.ruoyi.api.domain.RequestEnter;
import com.ruoyi.api.domain.WcsPort;
import com.ruoyi.api.service.IToWcsService;
import com.ruoyi.api.service.IToWmsService;
import com.ruoyi.check.commit.domain.CheckCommitRecord;
import com.ruoyi.check.commit.service.ICheckCommitRecordService;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.utils.MessageUtils;

import com.ruoyi.in.stockindetail.domain.InStockinDetail;
import com.ruoyi.in.stockindetail.service.IInStockinDetailService;
import com.ruoyi.job.mydojob.domain.MydoJob;
import com.ruoyi.job.mydojob.service.IMydoJobService;
import com.ruoyi.job.mydojobdetail.domain.MydoJobDetail;
import com.ruoyi.job.mydojobdetail.service.IMydoJobDetailService;
import com.ruoyi.job.mydojobdetail.service.impl.MydoJobDetailServiceImpl;
import com.ruoyi.pda.domain.TrayCodeMakeSure;
import com.ruoyi.pda.domain.TrayCodeMsg;
import com.ruoyi.pda.mapper.PdaMapper;
import com.ruoyi.pda.trayMsg.domain.TrayMsg;
import com.ruoyi.pda.trayMsg.service.ITrayMsgService;
import com.ruoyi.stock.stock.domain.BasStock;
import com.ruoyi.stock.stock.mapper.BasStockMapper;
import com.ruoyi.system.service.ISysRoleService;
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.util.*;

@Service
@Slf4j
public class PdaServiceImp implements PdaService {
    @Autowired
    private PdaMapper pdaMapper;
    @Autowired
    private IMydoJobService mydoJobService;
    @Autowired
    ISysRoleService sysRoleService;
    @Autowired
    IInStockinDetailService inStockinDetailService;
    @Autowired
    ITrayMsgService trayMsgService;
    @Autowired
    private ICheckCommitRecordService checkCommitRecordService;
    @Autowired
    private IToWmsService iToWmsService;
    @Autowired
    private IMydoJobDetailService mydoJobDetailService;
    @Autowired
    private IToWcsService toWcsService;
    @Autowired
    private BasStockMapper basStockMapper;



    @Override
    public List<BasStock> selectHasHalfTray(String inStockinDetailId) {
        InStockinDetail inStockinDetail = inStockinDetailService.selectInStockinDetailByStockinDetailId(inStockinDetailId);
        List<BasStock> hasHalfTray = basStockMapper.selectHasHalfTray(inStockinDetail);
        return hasHalfTray;
    }


    @Override
    public AjaxResult halfTrayOut(String trayCode) {
        return null;
    }

    @Override
    public Object selectMsgByTray(TrayCodeMsg trayCodeMsg) {
        MydoJob mydoJob = new MydoJob();
        mydoJob.setTrayCode(trayCodeMsg.getTrayCode());
        //todo 半盘出库作业类型
        mydoJob.setInOrOut("");
        List<MydoJobDetail> mydoJobDetails = mydoJobDetailService.selectMydoJobDetailListByTrayCode(mydoJob);
        if(mydoJobDetails.size()==0){
            TrayMsg trayMsg = new TrayMsg();
            trayMsg.setTrayCode(trayCodeMsg.getTrayCode());
            List<TrayMsg> trayMsgList = trayMsgService.selectTrayMsgList(trayMsg);
            return trayMsgList;
        }else{
            return mydoJobDetails;
        }
    }

    @Override
    public AjaxResult bindTray(TrayCodeMsg trayCodeMsg) {

        HashMap<String, Object> map = new HashMap<>();
        map.put("v_tray_code", trayCodeMsg.getTrayCode());
        map.put("v_stockin_detail_id", trayCodeMsg.getStockinDetailId());
        map.put("v_quantity", Integer.valueOf(trayCodeMsg.getInQuantity()));
        pdaMapper.bindTray(map);
        if("10".equals(map.get("v_result").toString())){
            return AjaxResult.success();
        }else{
            return AjaxResult.error(map.get("v_resultmsg").toString());
        }

    }

    @Override
    public AjaxResult confirmIn(String trayCode) {
        //如果有出库作业，修改作业类型改为合盘入库类型
        //如果没有出库作业，正常生成入库作业
        return null;
    }







    @Override
    public AjaxResult addInJob(RequestEnter requestEnter) {
       if(requestEnter.getEntranceId()!=null){
           MydoJob mydoJob = new MydoJob();
           mydoJob.setEntranceId(requestEnter.getEntranceId());
           mydoJob.setStatus("1");
           MydoJob mydoJob1 = mydoJobService.selectMydoJobByEntranceId(mydoJob);
           if(mydoJob1!=null){
               return AjaxResult.error("该入口已有作业");
           }
       }else{
           return AjaxResult.error("请选择出口");
       }
       requestEnter.setFlag("1");
        AjaxResult ajaxResult = iToWmsService.requestEnterByTrayCode(requestEnter);
        return ajaxResult;

    }




    @Override
    public AjaxResult selectDetailByPDTray(TrayCodeMakeSure trayCodeMakeSure) {
        MydoJob mydoJob = new MydoJob();
        mydoJob.setExitId(trayCodeMakeSure.getExitId());
        mydoJob.setStatus("3");
        mydoJob.setInOrOut("26");
        List<MydoJobDetail> mydoJobDetails = mydoJobDetailService.selectPdMydoJobDetailListByExit(mydoJob);
        return AjaxResult.success(mydoJobDetails);
    }

    @Override
    public AjaxResult outMakeSure(TrayCodeMakeSure trayCodeMakeSure) {
        String trayCode = trayCodeMakeSure.getTrayCode();
        String[] split = trayCode.split(" ");
        String productId = split[8].substring(10);
        MydoJob mydoJob = new MydoJob();
        mydoJob.setExitId(trayCodeMakeSure.getExitId());
        mydoJob.setProductId(productId);
        mydoJob.setStatus("3");
        mydoJob.setInOrOut("21");
//        List<MydoJobDetail> mydoJobDetails = mydoJobDetailService.selectMydoJobDetailListByExit(mydoJob);
//        if(mydoJobDetails.size()==0){
//            return AjaxResult.error("该物料没有出库作业，请检查");
//        }
        HashMap<String, Object> map = new HashMap<>();
//        map.put("v_tray_code", mydoJobDetails.get(0).getTrayCode());
        pdaMapper.outMakeSure(map);
        String result = map.get("v_result").toString();
        if ("10".equals(result)) {
            return AjaxResult.success();
        } else {
           return AjaxResult.error( map.get("v_resultmsg").toString());
        }


    }


    @Override
    //@Transactional(rollbackFor = Exception.class)
    public AjaxResult checkMakeSure(TrayCodeMakeSure trayCodeMakeSure) {

        MydoJob mydoJob = new MydoJob();
        mydoJob.setExitId(trayCodeMakeSure.getExitId());
        mydoJob.setStatus("3");
        mydoJob.setInOrOut("26");
        List<MydoJobDetail> mydoJobDetails = mydoJobDetailService.selectPdMydoJobDetailListByExit(mydoJob);
        if(mydoJobDetails.isEmpty()){
            return AjaxResult.error("该物料没有盘点出库作业，请检查");
        }

        List<MydoJobDetail> mydoJobDetailList = trayCodeMakeSure.getMaterials();
        if (CollUtil.isNotEmpty(mydoJobDetailList)) {
            boolean flag = mydoJobDetailList.stream().anyMatch(x -> StrUtil.isEmpty(x.getStockId()) && "0".equals(x.getInQuantity()));
            if (flag) {
                return AjaxResult.warn(MessageUtils.message("warn.message8"));
            }
            for (MydoJobDetail mydoJobDetail : mydoJobDetailList) {
                //插入盘点提交表
                CheckCommitRecord checkCommitRecord = new CheckCommitRecord();
                checkCommitRecord.setQuantity(mydoJobDetail.getInQuantity());
                checkCommitRecord.setTrayCode(mydoJobDetails.get(0).getTrayCode());
                checkCommitRecord.setStockId(mydoJobDetail.getStockId());
                checkCommitRecord.setSpare1(mydoJobDetail.getInOrOutDId());
                checkCommitRecord.setSpare2(mydoJobDetail.getProductId());
                checkCommitRecord.setSpare3(mydoJobDetail.getOutQuantity());
                checkCommitRecordService.insertCheckCommitRecord(checkCommitRecord);

            }
        }
        HashMap<String, Object> map = new HashMap<>();
        map.put("v_tray_code", mydoJobDetails.get(0).getTrayCode());
        pdaMapper.checkMakeSure(map);
        //iToWcsService.pushInMydoJob();
        String result = map.get("v_result").toString();
        if ("10".equals(result)) {
            return AjaxResult.success(map.get("v_resultmsg").toString());
        } else {
            throw new RuntimeException(map.get("v_resultmsg").toString());
        }
    }

    @Override
    public AjaxResult selectWcsPort() {
        AjaxResult ajaxResult = toWcsService.selectWcsPort();
        return ajaxResult;
    }

    @Override
    public AjaxResult updateWcsPort(WcsPort wcsport) {
        AjaxResult ajaxResult = toWcsService.updateWcsPort(wcsport);
        return ajaxResult;
    }
}