package doumeemes.service.ext.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.LoginUserInfo;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.core.utils.excel.EasyExcelUtil;
import doumeemes.core.utils.redis.RedisUtil;
import doumeemes.dao.business.MaterialMapper;
import doumeemes.dao.business.dto.QueryUnitExtDTO;
import doumeemes.dao.business.model.BarcodeParam;
import doumeemes.dao.business.model.Material;
import doumeemes.dao.business.vo.UnitExtListVO;
import doumeemes.dao.ext.MaterialExtMapper;
import doumeemes.dao.ext.bean.MaterialDetailBean;
import doumeemes.dao.ext.dto.QueryCategoryUnionExtDTO;
import doumeemes.dao.ext.dto.QueryMaterialDistributeExtDTO;
import doumeemes.dao.ext.dto.QueryMaterialExtDTO;
import doumeemes.dao.ext.vo.CategoryExtListVO;
import doumeemes.dao.ext.vo.CategoryUnionExtListVO;
import doumeemes.dao.ext.vo.MaterialDistributeExtListVO;
import doumeemes.dao.ext.vo.MaterialExtListVO;
import doumeemes.service.business.BarcodeParamService;
import doumeemes.service.business.UnitExtService;
import doumeemes.service.business.impl.MaterialDistributeServiceImpl;
import doumeemes.service.business.impl.MaterialServiceImpl;
import doumeemes.service.ext.CategoryUnionExtService;
import doumeemes.service.ext.MaterialDistributeExtService;
import doumeemes.service.ext.MaterialExtService;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.util.*;

/**
 * 物料基本信息Service实现
 * @author 江蹄蹄
 * @date 2022/04/20 10:59
 */
@Service
public class MaterialExtServiceImpl implements MaterialExtService {

    @Autowired
    private MaterialExtMapper materialExtMapper;

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;


    @Autowired
    private MaterialDistributeExtService materialDistributeExtService;
    @Autowired
    private MaterialServiceImpl materialServiceimpl;

    @Autowired
    private MaterialMapper materialMapper;

    @Autowired
    private MaterialDistributeServiceImpl materialDistributeServiceimpl;

    @Autowired
    private UnitExtService unitExtService;

    @Autowired
    private CategoryUnionExtService categoryUnionExtService;


    @Autowired
    private BarcodeParamService barcodeParamService;


    @Override
    public PageData<MaterialExtListVO> findPage(PageWrap<QueryMaterialExtDTO> pageWrap) {
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());

        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        pageWrap.getModel().setDeleted(Constants.ZERO);
        pageWrap.getModel().setRootDepartId(user.getRootDepartment().getId());

        List<MaterialExtListVO> result = materialExtMapper.getListByCondition(pageWrap.getModel());

        List<CategoryExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_CATEGORY_KEY+user.getCompany().getId(), ArrayList.class);

        for(int i=0;i<result.size();i++){
            MaterialExtListVO materialExtListVO=result.get(i);
            for(int j=0;j<clist.size();j++){
                CategoryExtListVO categoryExtListVO=clist.get(j);
                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateBigId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateBigId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodelName(categoryExtListVO.getName());
                    }
                }

                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateMiddleId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateMiddleId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodel1Name(categoryExtListVO.getName());

                    }
                }

                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateSmallId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateSmallId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodel2Name(categoryExtListVO.getName());

                    }
                }
                if(StringUtils.isNotEmpty(materialExtListVO.getCmodelName())){
                    if(StringUtils.isNotEmpty(materialExtListVO.getCmodel1Name())){
                        if(StringUtils.isNotEmpty(materialExtListVO.getCmodel2Name())){
                            materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName()+"-"+materialExtListVO.getCmodel1Name()+"-"+materialExtListVO.getCmodel2Name());
                        }else{
                            materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName()+"-"+materialExtListVO.getCmodel1Name());
                        }
                    }else{
                        materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName());
                    }
                }

            }
        }
        /*for(int i=0;i<result.size();i++){
            MaterialExtListVO mev=result.get(i);
            if(StringUtils.isNotEmpty(mev.getCmodelName())){
                if(StringUtils.isNotEmpty(mev.getCmodel1Name())){
                    if(StringUtils.isNotEmpty(mev.getCmodel2Name())){
                        mev.setUnionCategoryName(mev.getCmodelName()+"-"+mev.getCmodel1Name()+"-"+mev.getCmodel2Name());
                    }else{
                        mev.setUnionCategoryName(mev.getCmodelName()+"-"+mev.getCmodel1Name());
                    }
                }else{
                    mev.setUnionCategoryName(mev.getCmodelName());
                }
            }

        }*/
        return PageData.from(new PageInfo<>(result));
    }



    @Override
    public MaterialDetailBean findDetailById(Integer id) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        MaterialDetailBean materialDetailBean=new MaterialDetailBean();
        QueryMaterialExtDTO query=new QueryMaterialExtDTO();
        query.setId(id);
        List<MaterialExtListVO> result = materialExtMapper.getListByCondition(query);

        List<CategoryExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_CATEGORY_KEY+user.getCompany().getId(), ArrayList.class);
        for(int i=0;i<result.size();i++){
            MaterialExtListVO materialExtListVO=result.get(i);
            for(int j=0;j<clist.size();j++){
                CategoryExtListVO categoryExtListVO=clist.get(j);
                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateBigId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateBigId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodelName(categoryExtListVO.getName());
                    }
                }

                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateMiddleId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateMiddleId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodel1Name(categoryExtListVO.getName());

                    }
                }

                if(StringUtils.isNotEmpty(materialExtListVO.getCumodelCateSmallId())){
                    if(Constants.equalsInteger(Integer.valueOf(materialExtListVO.getCumodelCateSmallId()),categoryExtListVO.getId())){
                        materialExtListVO.setCmodel2Name(categoryExtListVO.getName());

                    }
                }
                if(StringUtils.isNotEmpty(materialExtListVO.getCmodelName())){
                    if(StringUtils.isNotEmpty(materialExtListVO.getCmodel1Name())){
                        if(StringUtils.isNotEmpty(materialExtListVO.getCmodel2Name())){
                            materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName()+"-"+materialExtListVO.getCmodel1Name()+"-"+materialExtListVO.getCmodel2Name());
                        }else{
                            materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName()+"-"+materialExtListVO.getCmodel1Name());
                        }
                    }else{
                        materialExtListVO.setUnionCategoryName(materialExtListVO.getCmodelName());
                    }
                }

            }
        }
        if(result!=null&&result.size()>0){
            MaterialExtListVO mev=result.get(0);

            materialDetailBean=new MaterialDetailBean().toMaterialDetail(mev);

            //获取分配公司级组织信息
            QueryMaterialDistributeExtDTO que=new QueryMaterialDistributeExtDTO();
            que.setRootDepartId(user.getRootDepartment().getId());
            que.setMaterialId(id);
            que.setDeleted(Constants.ZERO);
            List<MaterialDistributeExtListVO> mdList= materialDistributeExtService.findListByCondition(que);
            List<Map<String ,Object>> res=new ArrayList<>();
            if(mdList.size()>0){
                for(int i=0;i<mdList.size();i++){
                    MaterialDistributeExtListVO mdev=mdList.get(i);
                    Map<String ,Object> map=new HashMap<>();
                    map.put("id",mdev.getId());
                    System.out.println(mdev.getDmodelName());
                    map.put("dmodelName",mdev.getDmodelName());
                    if(mdev.getStatus()!=null){
                        if(mdev.getStatus()==0){
                            map.put("status","无效");
                        }else if(mdev.getStatus()==1){
                            map.put("status","有效");
                        }
                    }else{
                        map.put("status",null);
                    }

                    map.put("createTime",mdev.getCreateTime());
                    res.add(map);
                }
            }
            materialDetailBean.setMdlist(res);
            return materialDetailBean;
        }else{
            return materialDetailBean;
        }
    }


    @Override
    public List<MaterialExtListVO> getListByCondition(QueryMaterialExtDTO pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        pageWrap.setDeleted(Constants.ZERO);
        pageWrap.setRootDepartId(user.getRootDepartment().getId());
        List<MaterialExtListVO> result = materialExtMapper.getListByCondition(pageWrap);
        for(int i=0;i<result.size();i++){
            MaterialExtListVO mev=result.get(i);
            if(StringUtils.isNotEmpty(mev.getCmodelName())){
                if(StringUtils.isNotEmpty(mev.getCmodel1Name())){
                    if(StringUtils.isNotEmpty(mev.getCmodel2Name())){
                        mev.setUnionCategoryName(mev.getCmodelName()+"-"+mev.getCmodel1Name()+"-"+mev.getCmodel2Name());
                    }else{
                        mev.setUnionCategoryName(mev.getCmodelName()+"-"+mev.getCmodel1Name());
                    }
                }else{
                    mev.setUnionCategoryName(mev.getCmodelName());
                }
            }

        }
        return result;
    }


    @Transactional(rollbackFor = {BusinessException.class,Exception.class})
    @Override
    public void importmaterial(MultipartFile file)  {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！");
        }
        //解析excel
        List<Material> materialList = EasyExcelUtil.importExcel(file, 1, 1, Material.class);
        if(materialList == null || materialList.size()==0){
            throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "导入数据内容有误！");
        }

     for(int i=0;i<materialList.size();i++){
         Integer counter=i+2;
         Material material=materialList.get(i);
         if(StringUtils.isEmpty(material.getName())||StringUtils.isEmpty(material.getCode())||StringUtils.isEmpty(material.getUnitname())
         ||StringUtils.isEmpty(material.getFormationname())||StringUtils.isEmpty(material.getAttr())
                 ||StringUtils.isEmpty(material.getCateUnionName())){

             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "第"+counter+"行：导入数据内容不能为空！");
         }
         material.setDeleted(Constants.ZERO);
         material.setRootDepartId(user.getRootDepartment().getId());
         material.setCreateTime(new Date());
         material.setCreateUser(user.getId());

         Material findMi=new Material();
         findMi.setDeleted(Constants.ZERO);
         findMi.setRootDepartId(user.getRootDepartment().getId());
         findMi.setCode(material.getCode());
         List<Material> list=materialServiceimpl.findList(findMi);
         if(list.size()>0){
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "第"+counter+"行：主组织内编码不能重复！");
         }

         Material findMi1=new Material();
         findMi1.setDeleted(Constants.ZERO);
         findMi1.setRootDepartId(user.getRootDepartment().getId());
         findMi1.setName(material.getName());
         List<Material> list1=materialServiceimpl.findList(findMi1);
         if(list1.size()>0){
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"第"+counter+"行：主组织内名称不能重复！");
         }

         QueryUnitExtDTO pageWrap=new QueryUnitExtDTO();
         pageWrap.setDeleted(Constants.ZERO);
         pageWrap.setRootDepartId(user.getRootDepartment().getId());
         pageWrap.setType(Constants.ZERO);
         pageWrap.setStatus(Constants.ONE);
         pageWrap.setName(material.getUnitname().trim());
         List<UnitExtListVO> unitlist=unitExtService.getUnitListByOrg(pageWrap);
         if(unitlist!=null&&unitlist.size()>0){
             material.setUnitId(unitlist.get(0).getId());
         }else{
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"第"+counter+"行：单位不存在/没有有效的单位！");
         }

         if(StringUtils.equals(material.getFormationname().trim(),"生产")){
             material.setFormation(0);
         }else if(StringUtils.equals(material.getFormationname().trim(),"采购")){
             material.setFormation(1);
         }else{
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"第"+counter+"行：形成方式类型错误！");
         }


         QueryCategoryUnionExtDTO categoryUnion=new QueryCategoryUnionExtDTO();
         categoryUnion.setDeleted(Constants.ZERO);
         categoryUnion.setRootDepartId(user.getRootDepartment().getId());
         categoryUnion.setBmodelCateType("0");
         List<CategoryUnionExtListVO> catelist=  categoryUnionExtService.getCategoryUnionListByOrg(categoryUnion);
         if(catelist!=null&&catelist.size()>0){
             for(int j=0;j<catelist.size();j++){
                 CategoryUnionExtListVO cuev=catelist.get(j);
                 if(StringUtils.equals(cuev.getCombinationName(),material.getCateUnionName().trim())){
                    material.setCateUnionId(cuev.getId());
                 }

             }
         }else{
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"第"+counter+"行：物料分类(组合名称)不存在！");
         }

         if(material.getCateUnionId()==null||material.getCateUnionId()==0){
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"第"+counter+"行：物料分类(组合名称)不存在！");
         }

         material.setStatus(Constants.ONE);
         material.setUnionName(material.getName()+material.getAttr());
         material.setValidTime(new Date());


         //获取二维码规则
         BarcodeParam queryparam=new BarcodeParam();
         queryparam.setDepartId(user.getCurComDepartment().getId());
         queryparam.setRootDepartId(user.getRootDepartment().getId());
         queryparam.setType(Constants.BARCODEPARAM_TYPE.material);
         BarcodeParam barcodeParam =barcodeParamService.findOne(queryparam);

         if(barcodeParam!=null){
             material.setQrcodeId(barcodeParam.getId()+"");
         }
         Integer maid=   materialMapper.insert(material);

         materialDistributeServiceimpl.insert(material.getId()+"",user.getRootDepartment().getId()+"");

     }

    }
}