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.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.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.mapper.PdaMapper;
import com.ruoyi.pda.trayMsg.service.ITrayMsgService;
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;


    @Override
    public AjaxResult addInJob(RequestEnter requestEnter) {
       if(requestEnter.getEntranceId()!=null && "G1005".equals(requestEnter.getEntranceId())){
           MydoJob mydoJob = new MydoJob();
           mydoJob.setEntranceId(requestEnter.getEntranceId());
           mydoJob.setStatus("1");
           MydoJob mydoJob1 = mydoJobService.selectMydoJobByEntranceId(mydoJob);
           if(mydoJob1!=null){
               return AjaxResult.error("该入口已有补码作业");
           }
       }
        AjaxResult ajaxResult = iToWmsService.requestEnterByTrayCode(requestEnter);
        return ajaxResult;

    }

    @Override
    public AjaxResult selectDetailByTray(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");
        List<MydoJobDetail> mydoJobDetails = mydoJobDetailService.selectMydoJobDetailListByExit(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");
        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) {

        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(trayCodeMakeSure.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", trayCodeMakeSure.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());
        }
    }


}