package doumeemes.service.business.impl;

import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Utils;
import doumeemes.dao.business.*;
import doumeemes.dao.business.model.*;
import doumeemes.dao.ext.BomDetailExtMapper;
import doumeemes.dao.ext.MaterialDistributeExtMapper;
import doumeemes.dao.ext.bean.BomMaterialBean;
import doumeemes.service.business.BomDetailService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.ArrayList;
import java.util.List;
import java.util.Objects;

/**
 * 物料清单明细表Service实现
 * @author 江蹄蹄
 * @date 2022/04/20 09:33
 */
@Service
public class BomDetailServiceImpl implements BomDetailService {

    @Autowired
    private BomDetailMapper bomDetailMapper;

    @Autowired
    private BomMapper bomMapper;

    @Autowired
    private MaterialMapper materialMapper;

    @Autowired
    private UnitMapper unitMapper;

    @Autowired
    private ProceduresMapper proceduresMapper;

    @Autowired
    private BomVersionMapper bomVersionMapper;

    @Autowired
    private BomDetailExtMapper bomDetailExtMapper;

    @Autowired
    private MaterialDistributeExtMapper materialDistributeExtMapper;

    @Override
    public Integer create(BomDetail bomDetail) {
        bomDetailMapper.insert(bomDetail);
        return bomDetail.getId();
    }

    @Override
    public void deleteById(Integer id) {
        bomDetailMapper.deleteById(id);
    }

    @Override
    public void delete(BomDetail bomDetail) {
        UpdateWrapper<BomDetail> deleteWrapper = new UpdateWrapper<>(bomDetail);
        bomDetailMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        bomDetailMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(BomDetail bomDetail) {
        bomDetailMapper.updateById(bomDetail);
    }

    @Override
    public void updateByIdInBatch(List<BomDetail> bomDetails) {
        if (CollectionUtils.isEmpty(bomDetails)) {
            return;
        }
        for (BomDetail bomDetail: bomDetails) {
            this.updateById(bomDetail);
        }
    }

    @Override
    public BomDetail findById(Integer id) {
        return bomDetailMapper.selectById(id);
    }

    @Override
    public BomDetail findOne(BomDetail bomDetail) {
        QueryWrapper<BomDetail> wrapper = new QueryWrapper<>(bomDetail);
        return bomDetailMapper.selectOne(wrapper);
    }

    @Override
    public List<BomDetail> findList(BomDetail bomDetail) {
        QueryWrapper<BomDetail> wrapper = new QueryWrapper<>(bomDetail);
        return bomDetailMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<BomDetail> findPage(PageWrap<BomDetail> pageWrap) {
        IPage<BomDetail> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<BomDetail> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(BomDetail::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getDeleted() != null) {
            queryWrapper.lambda().eq(BomDetail::getDeleted, pageWrap.getModel().getDeleted());
        }
        if (pageWrap.getModel().getCreateUser() != null) {
            queryWrapper.lambda().eq(BomDetail::getCreateUser, pageWrap.getModel().getCreateUser());
        }
        if (pageWrap.getModel().getCreateTime() != null) {
            queryWrapper.lambda().ge(BomDetail::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime()));
            queryWrapper.lambda().le(BomDetail::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime()));
        }
        if (pageWrap.getModel().getUpdateUser() != null) {
            queryWrapper.lambda().eq(BomDetail::getUpdateUser, pageWrap.getModel().getUpdateUser());
        }
        if (pageWrap.getModel().getUpdateTime() != null) {
            queryWrapper.lambda().ge(BomDetail::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime()));
            queryWrapper.lambda().le(BomDetail::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime()));
        }
        if (pageWrap.getModel().getRemark() != null) {
            queryWrapper.lambda().eq(BomDetail::getRemark, pageWrap.getModel().getRemark());
        }
        if (pageWrap.getModel().getBomId() != null) {
            queryWrapper.lambda().eq(BomDetail::getBomId, pageWrap.getModel().getBomId());
        }
        if (pageWrap.getModel().getMaterialId() != null) {
            queryWrapper.lambda().eq(BomDetail::getMaterialId, pageWrap.getModel().getMaterialId());
        }
        if (pageWrap.getModel().getUnitId() != null) {
            queryWrapper.lambda().eq(BomDetail::getUnitId, pageWrap.getModel().getUnitId());
        }
        if (pageWrap.getModel().getProcedureId() != null) {
            queryWrapper.lambda().eq(BomDetail::getProcedureId, pageWrap.getModel().getProcedureId());
        }
        if (pageWrap.getModel().getNum() != null) {
            queryWrapper.lambda().eq(BomDetail::getNum, pageWrap.getModel().getNum());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(bomDetailMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(BomDetail bomDetail) {
        QueryWrapper<BomDetail> wrapper = new QueryWrapper<>(bomDetail);
        return bomDetailMapper.selectCount(wrapper);
    }


    @Override
    public List<BomDetail> findByMaterialId(Integer materialId) {
        List<BomDetail> bomDetails = new ArrayList<>() ;
        Bom bom = bomMapper.selectOne(new QueryWrapper<Bom>().eq("material_id",materialId));
        if(Objects.isNull(bom)){
            return bomDetails;
        }
        BomVersion bomVersion = bomVersionMapper.selectOne(new QueryWrapper<BomVersion>()
                .eq("BOM_ID",bom.getId())
                .eq("VERSION",bom.getVersion())
        );
        if(Objects.isNull(bomVersion)){
            return bomDetails;
        }
        bomDetails = bomDetailExtMapper.bomDetailListByBomVersionId(bomVersion.getId());
        return bomDetails;
    }

    @Override
    public List<BomMaterialBean> findMaterialListById(Integer bomId) {
        Bom bom = bomMapper.selectById(bomId);
        if(Objects.isNull(bom)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到BOM信息");
        }
        MaterialDistribute materialDistribute = materialDistributeExtMapper.selectById(bom.getMaterialId());
        if(Objects.isNull(materialDistribute)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到物料分配信息");
        }
        Material material = materialMapper.selectById(materialDistribute.getMaterialId());
        if(Objects.isNull(material)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到物料信息");
        }
        BomVersion bomVersion = bomVersionMapper.selectOne(new QueryWrapper<BomVersion>()
                .eq("BOM_ID",bom.getId())
                .eq("VERSION",bom.getVersion())
        );
        if(Objects.isNull(bomVersion)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到BOM历史版本信息");
        }
        List<BomDetail> bomDetails = bomDetailMapper.selectList(new QueryWrapper<BomDetail>()
                .eq("BOM_ID",bomVersion.getId())
        );
        List<BomMaterialBean> bomMaterialBeanListParent = new ArrayList<>();
        BomMaterialBean bomMaterialBeanParent = new BomMaterialBean();
        bomMaterialBeanParent.setMaterialId(material.getId());
        bomMaterialBeanParent.setMaterialCode(material.getCode());
        bomMaterialBeanParent.setMaterialName(material.getName());
        List<BomMaterialBean> bomMaterialBeanList = new ArrayList<>();
        bomDetails.forEach(i->{
            //TODO bomDetails 缺失数据补充 物料信息 物料名称 单位 工序
            Material detailMaterial = materialMapper.selectById(i.getMaterialId());
            i.setMaterialCode(detailMaterial.getCode());
            i.setMaterialName(detailMaterial.getName());

            BomMaterialBean bomMaterialBean = new BomMaterialBean();
            bomMaterialBean.setMaterialId(i.getMaterialId());
            bomMaterialBean.setMaterialCode(i.getMaterialCode());
            bomMaterialBean.setMaterialName(i.getMaterialName());
            bomMaterialBeanList.add(bomMaterialBean);
        });
        bomMaterialBeanParent.setBomMaterialBeanList(bomMaterialBeanList);
        bomMaterialBeanListParent.add(bomMaterialBeanParent);
        return bomMaterialBeanListParent;
    }

    @Override
    public BomMaterialBean bomMaterialTree(Integer bomId) {
        Bom bom = bomMapper.selectById(bomId);
        if(Objects.isNull(bom)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到BOM信息");
        }
        MaterialDistribute materialDistribute = materialDistributeExtMapper.selectById(bom.getMaterialId());
        if(Objects.isNull(materialDistribute)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到物料分配信息");
        }
        Material material = materialMapper.selectById(materialDistribute.getMaterialId());
        if(Objects.isNull(material)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到物料信息");
        }
        BomVersion bomVersion = bomVersionMapper.selectOne(new QueryWrapper<BomVersion>()
                .eq("BOM_ID",bom.getId())
                .eq("VERSION",bom.getVersion())
        );
        if(Objects.isNull(bomVersion)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "数据异常：未查询到BOM历史版本信息");
        }
        List<BomDetail> bomDetails = bomDetailMapper.selectList(new QueryWrapper<BomDetail>()
                .eq("BOM_ID",bomVersion.getId())
        );
        BomMaterialBean bomMaterialBeanParent = new BomMaterialBean();
        bomMaterialBeanParent.setMaterialId(bom.getMaterialId());
        bomMaterialBeanParent.setMaterialCode(material.getCode());
        bomMaterialBeanParent.setMaterialName(material.getName());
        List<BomMaterialBean> bomMaterialBeanList = new ArrayList<>();
        bomDetails.forEach(i->{
            MaterialDistribute materialDistributeDetail = materialDistributeExtMapper.selectById(i.getMaterialId());
            Material detailMaterial = materialMapper.selectById(materialDistributeDetail.getMaterialId());
            BomMaterialBean bomMaterialBean = new BomMaterialBean();
            bomMaterialBean.setMaterialId(i.getMaterialId());
            bomMaterialBean.setMaterialCode(detailMaterial.getCode());
            bomMaterialBean.setMaterialName(detailMaterial.getName());
            bomMaterialBeanList.add(bomMaterialBean);
        });
        bomMaterialBeanParent.setBomMaterialBeanList(bomMaterialBeanList);
        return bomMaterialBeanParent;
    }
}