package com.glxp.api.service.inout;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.glxp.api.constant.ConstantStatus;
import com.glxp.api.constant.ConstantType;
import com.glxp.api.entity.basic.BasicBussinessTypeEntity;
import com.glxp.api.entity.inout.*;
import com.glxp.api.entity.inv.InvPreinDetailEntity;
import com.glxp.api.res.inout.IoOrderDetailCodeResponse;
import com.glxp.api.service.basic.IBasicBussinessTypeService;
import com.glxp.api.service.inv.InvPreinDetailService;
import com.glxp.api.service.inv.InvPreinOrderService;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 校验出入库服务
 */
@Service
public class IoCheckInoutService {

    @Resource
    IoOrderService orderService;
    @Resource
    IoCodeService codeService;
    @Resource
    IoCodeTempService codeTempService;
    @Resource
    IBasicBussinessTypeService basicBussinessTypeService;
    @Resource
    IoOrderDetailCodeService orderDetailCodeService;
    @Resource
    IoOrderDetailBizService orderDetailBizService;
    @Resource
    IoOrderDetailResultService orderDetailResultService;
    @Resource
    InvPreinOrderService invPreinOrderService;
    @Resource
    InvPreinDetailService invPreinDetailService;
    @Resource
    IoGenInvService genInvService;

    //判断是否需要手动校验
    public boolean checkManual(String billNo) {
        IoOrderEntity orderEntity = orderService.findByBillNo(billNo);
        BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(orderEntity.getAction());
        if (!bussinessTypeEntity.isCheckEnable()) {
            return false;
        } else {
            if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_UDIMS) {
                if (!bussinessTypeEntity.isCheckUdims()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_WEBNEW) {
                if (!bussinessTypeEntity.isCheckWebNew()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAED) {
                if (!bussinessTypeEntity.isCheckPdaEd()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAUN) {
                if (!bussinessTypeEntity.isCheckPdaUn()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PC) {
                if (!bussinessTypeEntity.isCheckPc()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_CHANGE) {
                if (!bussinessTypeEntity.isCheckChange()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PEACE_CHANGE) {
                if (!bussinessTypeEntity.isCheckBalance()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_UDISP) {
                if (!bussinessTypeEntity.isCheckSp()) {
                    return false;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_COPY) {
                if (!bussinessTypeEntity.isCheckCopy()) {
                    return false;
                }
            }
            return true;
        }
    }

    //校验流程
    public void check(String orderId) {
        IoOrderEntity orderEntity = orderService.findByBillNo(orderId);
        //过滤非未校验或校验异常
        if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_CHECK && orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_CHECK_FAIL)
            return;
        BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(orderEntity.getAction());
        if (!bussinessTypeEntity.isCheckEnable()) {
            unCheckFirstFinish(orderEntity);
        } else {
            if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_UDIMS) {
                if (!bussinessTypeEntity.isCheckUdims()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_WEBNEW) {
                if (!bussinessTypeEntity.isCheckWebNew()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAED) {
                if (!bussinessTypeEntity.isCheckPdaEd()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAUN) {
                if (!bussinessTypeEntity.isCheckPdaUn()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PC) {
                if (!bussinessTypeEntity.isCheckPc()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_CHANGE) {
                if (!bussinessTypeEntity.isCheckChange()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PEACE_CHANGE) {
                if (!bussinessTypeEntity.isCheckBalance()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_UDISP) {
                if (!bussinessTypeEntity.isCheckSp()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_COPY) {
                if (!bussinessTypeEntity.isCheckCopy()) {
                    unCheckFirstFinish(orderEntity);
                    return;
                }
            }
            checkFirstFinish(orderEntity);
        }
    }

    public String checkCode(IoCodeTempEntity codeEntity) {

        boolean isBillExit = orderDetailBizService.isExit(codeEntity.getOrderId());
        if (!isBillExit) {
            return "请先录入业务详情";
        }

        IoOrderDetailBizEntity bizEntity = orderDetailBizService.findByUnique(codeEntity.getOrderId(), codeEntity.getRelId(), codeEntity.getBatchNo());
        if (bizEntity == null) {
            return "非此单产品!";
        }
        IoOrderDetailCodeEntity orderDetailCodeEntity = orderDetailCodeService.findByUnique(codeEntity.getOrderId(), codeEntity.getRelId(), codeEntity.getBatchNo());
        int curCount = 0;
        if (orderDetailCodeEntity != null) {
            curCount = orderDetailCodeEntity.getReCount() + codeEntity.getReCount();
        }
        if (curCount > bizEntity.getCount()) {
            return "当前产品数量超出！";
        }
        return null;
    }

    //一次校验（无需校验）完成
    public void unCheckFirstFinish(IoOrderEntity orderEntity) {

        List<IoOrderDetailCodeEntity> orderDetailCodeEntities = orderDetailCodeService.findByOrderId(orderEntity.getBillNo());

        if (CollUtil.isEmpty(orderDetailCodeEntities)) {
            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK_FAIL);
            orderEntity.setUpdateTime(new Date());
            orderEntity.setErrMsg("校验失败，扫码详情为空！");
            orderService.update(orderEntity);
            return;
        }
        orderDetailCodeEntities.forEach(orderDetailCodeEntity ->
        {
            //生成业务单据
            IoOrderDetailBizEntity orderDetailBizEntity = new IoOrderDetailBizEntity();
            BeanUtils.copyProperties(orderDetailCodeEntity, orderDetailBizEntity);
            orderDetailBizEntity.setId(null);
            orderDetailBizService.insert(orderDetailBizEntity);


            //生成单据结果
            IoOrderDetailResultEntity orderDetailResultEntity = new IoOrderDetailResultEntity();
            BeanUtils.copyProperties(orderDetailCodeEntity, orderDetailResultEntity);
            orderDetailResultEntity.setId(null);
            orderDetailResultService.insert(orderDetailResultEntity);

        });

        //临时表转正式表
        List<IoCodeTempEntity> codeTempEntities = codeTempService.findByOrderId(orderEntity.getBillNo());
        for (IoCodeTempEntity codeTempEntity : codeTempEntities) {
            IoCodeEntity codeEnttity = new IoCodeEntity();
            BeanUtils.copyProperties(codeTempEntity, codeEnttity);
            codeEnttity.setId(null);
            codeService.insert(codeEnttity);
        }
        codeTempService.deleteByBillNo(orderEntity.getBillNo());

        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK_SUCCESS);
        orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_POST);
        orderEntity.setUpdateTime(new Date());
        orderService.update(orderEntity);
        checkSecond(orderEntity);
    }

    //一次校验完成
    public void checkFirstFinish(IoOrderEntity orderEntity) {
        List<IoOrderDetailCodeEntity> orderDetailCodeEntities = orderDetailCodeService.findByOrderId(orderEntity.getBillNo());
        List<IoOrderDetailBizEntity> orderDetailBizEntities = orderDetailBizService.findByOrderId(orderEntity.getBillNo());

        if (CollUtil.isEmpty(orderDetailCodeEntities)) {
            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK);
            orderEntity.setUpdateTime(new Date());
            orderEntity.setErrMsg("校验失败，扫码详情为空！");
            orderService.update(orderEntity);
            return;
        }

        if (CollUtil.isEmpty(orderDetailBizEntities)) {
            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK);
            orderEntity.setUpdateTime(new Date());
            orderEntity.setErrMsg("校验失败，业务详情为空！");
            orderService.update(orderEntity);
            return;
        }

        String errMsg = "";
        //正向校验
        for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
            for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
                if (!bizEntity.isCheckSuccess() && !codeEntity.isCheckSuccess() && checkId(bizEntity, codeEntity) == null
                        && checkBatchNo(bizEntity, codeEntity) == null
                        && checkProductDate(bizEntity, codeEntity) == null
                        && checkExpireDate(bizEntity, codeEntity) == null
                ) {

                    if (checkCount(bizEntity, codeEntity) == null) {
                        bizEntity.setCheckSuccess(true);
                        bizEntity.setScanCount(codeEntity.getReCount());
                        codeEntity.setCheckSuccess(true);
                    }
                    break;
                }
            }
        }

        for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
            if (!bizEntity.isCheckSuccess()) {
                errMsg = errMsg + bizEntity.getCoName() + ";";
            }
        }

        //反向校验
        for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
            for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
                if (!bizEntity.isCheckSuccess() && !codeEntity.isCheckSuccess() && checkId(bizEntity, codeEntity) == null
                        && checkBatchNo(bizEntity, codeEntity) == null
                        && checkProductDate(bizEntity, codeEntity) == null
                        && checkExpireDate(bizEntity, codeEntity) == null
                ) {

                    if (checkCount(bizEntity, codeEntity) == null) {
                        bizEntity.setCheckSuccess(true);
                        codeEntity.setCheckSuccess(true);
                    }
                    break;
                }
            }
        }

        for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
            if (!codeEntity.isCheckSuccess()) {
                errMsg = errMsg + codeEntity.getCoName() + ";";
            }
        }

        if (StrUtil.isNotEmpty(errMsg)) {
            orderEntity.setErrMsg(errMsg + "校验失败");
            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK_FAIL);
            orderEntity.setUpdateTime(new Date());
            orderService.update(orderEntity);
        } else {
            //生成单据结果
            for (IoOrderDetailBizEntity orderDetailBizEntity : orderDetailBizEntities) {
                IoOrderDetailResultEntity orderDetailResultEntity = new IoOrderDetailResultEntity();
                BeanUtils.copyProperties(orderDetailBizEntity, orderDetailResultEntity);
                orderDetailResultEntity.setId(null);
                orderDetailResultEntity.setReCount(orderDetailBizEntity.getScanCount());
                orderDetailResultService.insert(orderDetailResultEntity);
            }

            //临时表转正式表
            List<IoCodeTempEntity> codeTempEntities = codeTempService.findByOrderId(orderEntity.getBillNo());
            for (IoCodeTempEntity codeTempEntity : codeTempEntities) {
                IoCodeEntity codeEnttity = new IoCodeEntity();
                BeanUtils.copyProperties(codeTempEntity, codeEnttity);
                codeService.insert(codeEnttity);
            }
            codeTempService.deleteByBillNo(orderEntity.getBillNo());
            orderEntity.setErrMsg("校验成功！");
            orderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK_SUCCESS);
            orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_POST);
            orderEntity.setUpdateTime(new Date());
            orderService.update(orderEntity);
            checkSecond(orderEntity);
        }
    }

    //业务单正向校验
    public String bizOrderCheck(List<IoOrderDetailBizEntity> orderDetailBizEntities, List<IoOrderDetailCodeEntity> orderDetailCodeEntities) {
        String errMsg = "";
        for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
            for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
                if (!bizEntity.isCheckSuccess() && !codeEntity.isCheckSuccess() && checkId(bizEntity, codeEntity) == null
                        && checkBatchNo(bizEntity, codeEntity) == null

                ) {

                    if (checkCount(bizEntity, codeEntity) == null) {
                        bizEntity.setCheckSuccess(true);
                        codeEntity.setCheckSuccess(true);
                        bizEntity.setScanCount(codeEntity.getReCount());
                    } else {
                        bizEntity.setScanCount(codeEntity.getReCount());
                        bizEntity.setCheckSuccess(false);
                    }
                    break;
                }
            }
        }

        for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
            if (!bizEntity.isCheckSuccess()) {
                errMsg = errMsg + bizEntity.getCoName() + ";";
            }
        }
        return errMsg;
    }


    /**
     *  && checkProductDate(bizEntity, codeEntity) == null
     *                         && checkExpireDate(bizEntity, codeEntity) == null
     */

    //扫码单反向校验
    public String codeOrderCheck(List<IoOrderDetailCodeEntity> orderDetailCodeEntities, List<IoOrderDetailBizEntity> orderDetailBizEntities) {
        for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
            for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
                if (!bizEntity.isCheckSuccess() && !codeEntity.isCheckSuccess() && checkId(bizEntity, codeEntity) == null
                        && checkBatchNo(bizEntity, codeEntity) == null
                        && checkProductDate(bizEntity, codeEntity) == null
                        && checkExpireDate(bizEntity, codeEntity) == null
                ) {

                    if (checkCount(bizEntity, codeEntity) == null) {
                        bizEntity.setCheckSuccess(true);
                        codeEntity.setCheckSuccess(true);
                        codeEntity.setOrderCount(bizEntity.getCount());
                    } else {
                        codeEntity.setCheckSuccess(false);
                        codeEntity.setOrderCount(bizEntity.getCount());
                    }
                    break;
                } else {
                    codeEntity.setCheckSuccess(false);
                }
            }
        }

        String errMsg = "";
        for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) {
            if (!codeEntity.isCheckSuccess()) {
                errMsg = errMsg + codeEntity.getCoName() + ";";
            }
        }
        return errMsg;
    }

    public void codeOrderCheck2(List<IoOrderDetailCodeResponse> orderDetailCodeEntities, List<IoOrderDetailBizEntity> orderDetailBizEntities) {
        for (IoOrderDetailCodeResponse codeResponse : orderDetailCodeEntities) {
            IoOrderDetailCodeEntity codeEntity = new IoOrderDetailCodeEntity();
            BeanUtils.copyProperties(codeResponse, codeEntity);
            for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
                if (!bizEntity.isCheckSuccess() && !codeEntity.isCheckSuccess() && checkId(bizEntity, codeEntity) == null
                        && checkBatchNo(bizEntity, codeEntity) == null
                        && checkProductDate(bizEntity, codeEntity) == null
                        && checkExpireDate(bizEntity, codeEntity) == null
                ) {

                    if (checkCount(bizEntity, codeEntity) == null) {
                        bizEntity.setCheckSuccess(true);
                        codeResponse.setCheckSuccess(true);
                        codeResponse.setOrderCount(bizEntity.getCount());
                    } else {
                        codeResponse.setCheckSuccess(false);
                        codeResponse.setOrderCount(bizEntity.getCount());
                    }
                    break;
                } else {
                    codeResponse.setCheckSuccess(false);
                }
            }
        }
    }


    //二次校验
    public void checkSecond(IoOrderEntity orderEntity) {
        BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(orderEntity.getAction());
        if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_AUDITED) {
            if (bussinessTypeEntity.isSecCheckEnable()) {
                if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_UDIMS) {
                    if (!bussinessTypeEntity.isSecCheckUdims()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_WEBNEW) {
                    if (!bussinessTypeEntity.isSecCheckWebNew()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAED) {
                    if (!bussinessTypeEntity.isSecCheckPdaEd()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PDAUN) {
                    if (!bussinessTypeEntity.isSecCheckPdaUn()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PC) {
                    if (!bussinessTypeEntity.isSecCheckPc()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_CHANGE) {
                    if (!bussinessTypeEntity.isSecCheckChange()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_PEACE_CHANGE) {
                    if (!bussinessTypeEntity.isSecCheckBalance()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                } else if (orderEntity.getFromType().intValue() == ConstantStatus.FROM_COPY) {
                    if (!bussinessTypeEntity.isSecCheckCopy()) {
                        orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
                    }
                }
            } else {
                orderEntity.setStatus(ConstantStatus.ORDER_STATUS_AUDITED);
            }
        }

        if (orderEntity.getStatus() == ConstantStatus.ORDER_STATUS_AUDITED) {
            orderEntity.setDealStatus(ConstantStatus.ORDER_DEAL_CHECK);
            orderEntity.setUpdateTime(new Date());
            orderService.update(orderEntity);
            genInv(orderEntity, bussinessTypeEntity);
        }
    }

    //校验完成后生成库存
    public void genInv(IoOrderEntity orderEntity, BasicBussinessTypeEntity bussinessTypeEntity) {

        //预验收出库，删掉对应预验收库存
        if (bussinessTypeEntity.getMainAction().equals(ConstantType.TYPE_OUT) && bussinessTypeEntity.isScanPreIn()) {
            List<IoCodeEntity> codeList = codeService.findByOrderId(orderEntity.getBillNo());
            Map<String, String> preInOrder = new HashMap<>();
            for (IoCodeEntity warehouseEntity : codeList) {
                List<InvPreinDetailEntity> invProductDetailEntities = invPreinDetailService.findByCode(warehouseEntity.getCode());
                if (invProductDetailEntities.size() > 0) {
                    preInOrder.put(invProductDetailEntities.get(0).getOrderId(), invProductDetailEntities.get(0).getOrderId());
                }
            }
            if (preInOrder.size() > 0) {
                String preInBillNo = "";
                for (String key : preInOrder.keySet()) {
                    preInBillNo = preInBillNo + "," + key;
                    IoOrderEntity preInEntity = orderService.findByBillNo(key);
                    preInEntity.setPreOutBillNo(orderEntity.getBillNo());
                    orderService.update(preInEntity);
                    invPreinOrderService.deleteByOrderId(preInEntity.getBillNo());
                    invPreinDetailService.deleteByOrderId(preInEntity.getBillNo());
                }
                orderEntity.setPreInBillNo(preInBillNo.substring(1));
                orderService.update(orderEntity);
            }
        }

        //生成库存
        if (bussinessTypeEntity.isPreIn()) {
            genInvService.genPreInInv(orderEntity.getBillNo());
        } else {
            genInvService.genNorInv(orderEntity.getBillNo());
        }

    }


    public String checkId(IoOrderDetailBizEntity bizEntity, IoOrderDetailCodeEntity codeEntity) {

        if (bizEntity.getBindRlFk().longValue() == codeEntity.getBindRlFk().longValue()) {
            return null;
        } else {
            return "产品ID不匹配";
        }
    }

    public String checkBatchNo(IoOrderDetailBizEntity bizEntity, IoOrderDetailCodeEntity codeEntity) {

        if (StrUtil.nullToEmpty(bizEntity.getBatchNo()).equals(StrUtil.nullToEmpty(codeEntity.getBatchNo()))) {
            return null;
        } else {
            return bizEntity.getCoName() + "批次号不匹配";
        }
    }

    public String checkProductDate(IoOrderDetailBizEntity bizEntity, IoOrderDetailCodeEntity codeEntity) {
        if (StrUtil.nullToEmpty(bizEntity.getProductDate()).equals(StrUtil.nullToEmpty(codeEntity.getProductDate()))) {
            return null;
        } else {
            return bizEntity.getCoName() + "生产日期不匹配";
        }
    }

    public String checkExpireDate(IoOrderDetailBizEntity bizEntity, IoOrderDetailCodeEntity codeEntity) {
        if (StrUtil.nullToEmpty(bizEntity.getExpireDate()).equals(StrUtil.nullToEmpty(codeEntity.getExpireDate()))) {
            return null;
        } else {
            return bizEntity.getCoName() + "失效日期不匹配";
        }
    }

    public String checkCount(IoOrderDetailBizEntity bizEntity, IoOrderDetailCodeEntity codeEntity) {
        if (bizEntity.getCount() == codeEntity.getReCount()) {
            return null;
        }
        return bizEntity.getCoName() + "数量不匹配！";
    }
}