package doumeemes.service.business.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.ApiResponse;
import doumeemes.core.model.LoginUserInfo;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.core.utils.Utils;
import doumeemes.dao.business.BomDetailMapper;
import doumeemes.dao.business.BomMapper;
import doumeemes.dao.business.BomVersionMapper;
import doumeemes.dao.business.MaterialMapper;
import doumeemes.dao.business.model.Bom;
import doumeemes.dao.business.model.BomDetail;
import doumeemes.dao.business.model.BomVersion;
import doumeemes.dao.business.model.Material;
import doumeemes.dao.ext.BomExtMapper;
import doumeemes.dao.ext.MaterialDistributeExtMapper;
import doumeemes.dao.ext.bean.BomBean;
import doumeemes.dao.ext.bean.BomDetailBean;
import doumeemes.dao.ext.vo.BomExtListVO;
import doumeemes.service.business.BomService;
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 io.swagger.annotations.Api;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.xpath.operations.Bool;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

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

/**
 * 物料清单信息表Service实现
 * @author 江蹄蹄
 * @date 2022/04/20 09:33
 */
@Service
public class BomServiceImpl implements BomService {

    @Autowired
    private BomMapper bomMapper;

    @Autowired
    private BomDetailMapper bomDetailMapper;

    @Autowired
    private BomVersionMapper bomVersionMapper;

    @Autowired
    private MaterialMapper materialMapper;

    @Autowired
    private MaterialDistributeExtMapper materialDistributeExtMapper;

    @Autowired
    private BomExtMapper bomExtMapper;

    @Override
    public Integer create(Bom bom) {
        bomMapper.insert(bom);
        return bom.getId();
    }

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

    @Override
    public void delete(Bom bom) {
        UpdateWrapper<Bom> deleteWrapper = new UpdateWrapper<>(bom);
        bomMapper.delete(deleteWrapper);
    }

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

    @Override
    public void updateById(Bom bom) {
        bomMapper.updateById(bom);
    }

    @Override
    public void updateByIdInBatch(List<Bom> boms) {
        if (CollectionUtils.isEmpty(boms)) {
            return;
        }
        for (Bom bom: boms) {
            this.updateById(bom);
        }
    }

    @Override
    public Bom findById(Integer id) {
        return bomMapper.selectById(id);
    }

    @Override
    public Bom findOne(Bom bom) {
        QueryWrapper<Bom> wrapper = new QueryWrapper<>(bom);
        return bomMapper.selectOne(wrapper);
    }

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

    @Override
    public long count(Bom bom) {
        QueryWrapper<Bom> wrapper = new QueryWrapper<>(bom);
        return bomMapper.selectCount(wrapper);
    }


    @Override
    @Transactional
    public ApiResponse saveBean(BomBean bomBean,LoginUserInfo loginUserInfo){
        Bom bom = new Bom();
        BigDecimal bomVersionNum = BigDecimal.ONE.setScale(Constants.TWO);
        if(Objects.isNull(materialDistributeExtMapper.selectById(bomBean.getMaterialId()))){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "未查询到物料分配信息");
        };
        if(null == bomBean.getId() || bomBean.getId() == Constants.ONE){
            //查询物料是否已创建bom
//            if(bomExtMapper.selectCount(new QueryWrapper<Bom>()
//                    .eq("material_id",bomBean.getMaterialId()))>0){
//                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "当前物料已存在BOM信息,无法再次建立");
//            };
            if(bomExtMapper.checkIsHave(bomBean.getMaterialId(),bomBean.getRouteId())>0){
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "当前物料于当前工厂下已存在BOM信息,无法再次建立");
            }
            bom = bomBean.toBom(bom);
            bom.setVersion(bomVersionNum.toString());
            bom.setCreateTime(new Date());
            bom.setCreateUser(loginUserInfo.getId());
            bom.setRootDepartId(loginUserInfo.getRootDepartment().getId());
            bom.setDepartId(loginUserInfo.getCurComDepartment().getId());
            bomMapper.insert(bom);
        }else{
            Bom dbBom = bomMapper.selectById(bomBean.getId());
            if(2 == dbBom.getStatus()){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "已禁用失效，无法编辑保存");
            }
            if(0 != dbBom.getStatus()){
                bomVersionNum = new BigDecimal(dbBom.getVersion()).add(BigDecimal.valueOf(0.1)).setScale(2);
            }else{
                BomVersion dbBomVersion = bomVersionMapper.selectOne(new QueryWrapper<BomVersion>().eq("BOM_ID",bomBean.getId()));
                bomDetailMapper.delete(new QueryWrapper<BomDetail>().eq("BOM_ID",dbBomVersion.getId()));
                bomVersionMapper.deleteById(dbBomVersion.getId());
            }
            bom = bomBean.toBom(dbBom);
            bom.setVersion(bomVersionNum.toString());
            bom.setUpdateTime(new Date());
            bom.setUpdateUser(loginUserInfo.getId());
            bomMapper.updateById(bom);
        }
        BomVersion bomVersion = JSON.parseObject(JSONObject.toJSON(bomBean).toString(), BomVersion.class);
        bomVersion.setId(null);
        bomVersion.setBomId(bom.getId());
        bomVersion.setVersion(bomVersionNum.toString());
        bomVersion.setRootDepartId(loginUserInfo.getRootDepartment().getId());
        bomVersion.setDepartId(bom.getDepartId());
        bomVersionMapper.insert(bomVersion);
        //失效历史版本数据
        BomVersion updBomVersion = new BomVersion();
        updBomVersion.setStatus(2);
        updBomVersion.setValidTime(new Date());
        bomVersionMapper.update(updBomVersion,new UpdateWrapper<BomVersion>()
                .eq("BOM_ID",bomVersion.getBomId())
                .ne("id",bomVersion.getId())
        );
        saveBomDetail(bomBean.toBomDetail(),bomVersion.getId());
        return ApiResponse.success(bom);
    }


    @Override
    @Transactional
    public ApiResponse openOrClose(Integer id,Integer optType){
        Bom bom = bomMapper.selectById(id);
        if(Objects.isNull(bom)){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "未查询到对象信息");
        }
        if( 1 == optType){
            if(1 == bom.getStatus()){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "已启用生效，请勿重复操作");
            }else if(2 == bom.getStatus()){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "已禁用失效，无法启用");
            }else{
                bom.setValidTime(new Date());
            }
        }else if(2 == optType){
            //查询当前记录下是否存在被占用的物料
            List<Material> materialList = materialMapper.selectList(
                    new QueryWrapper<Material>()
                            .eq("id", bom.getMaterialId())
                            .apply(" id in ( select b2.MATERIAL_ID from  bom_version b1 inner join bom_detail b2  on b1.id = b2.bom_id  where b1.`STATUS` = 1  ) ")
            );
            if(materialList.size()>0){
                StringBuffer useName = new StringBuffer();
                for (Material material:materialList) {
                    useName.append(","+material.getName());
                }
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "物料使用中，无法禁用失效，占用者："+ useName.toString().substring(Constants.ONE,useName.length()));
            }
            if(0 == bom.getStatus()){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "未启用生效，无法禁用失效");
            }else  if(2 == bom.getStatus()){
                throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "已禁用失效，请勿重复操作");
            }else{
                bom.setInvalidTime(new Date());
            }
        }
        bom.setStatus(optType);
        bomMapper.updateById(bom);
        BomVersion bomVersion = new BomVersion();
        bomVersion.setStatus(optType);
        bomVersion.setValidTime(bom.getValidTime());
        bomVersion.setInvalidTime(bom.getInvalidTime());
        bomVersionMapper.update(bomVersion,new UpdateWrapper<BomVersion>().eq("BOM_ID",id));
        return ApiResponse.success(bom);
    }

    public void saveBomDetail(List<BomDetail> bomDetailList,Integer parentId){
        bomDetailList.forEach(i->{
            i.setBomId(parentId);
            bomDetailMapper.insert(i);
        });
    }


}