package doumeemes.service.ext.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import doumeemes.biz.system.SystemDictDataBiz;
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.DateUtil;
import doumeemes.core.utils.redis.RedisUtil;
import doumeemes.dao.business.model.CategoryUnion;
import doumeemes.dao.business.model.CompanyUser;
import doumeemes.dao.business.model.WorkorderCheck;
import doumeemes.dao.ext.CategoryUnionExtMapper;
import doumeemes.dao.ext.CompanyUserExtMapper;
import doumeemes.dao.ext.WorkorderCheckExtMapper;
import doumeemes.dao.ext.dto.QueryWorkorderCheckExtDTO;
import doumeemes.dao.ext.vo.CategoryExtListVO;
import doumeemes.dao.ext.vo.DepartmentExtListVO;
import doumeemes.dao.ext.vo.WorkorderCheckExtListVO;
import doumeemes.dao.ext.vo.WorkorderCheckGroupListVO;
import doumeemes.service.ext.CategoryExtService;
import doumeemes.service.ext.DepartmentExtService;
import doumeemes.service.ext.WorkorderCheckExtService;
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 java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 检验信息Service实现
 * @author 江蹄蹄
 * @date 2022/04/20 10:56
 */
@Service
public class WorkorderCheckExtServiceImpl implements WorkorderCheckExtService {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;
    @Autowired
    private WorkorderCheckExtMapper workorderCheckExtMapper;
    @Autowired
    private CompanyUserExtMapper companyUserExtMapper;
    @Autowired
    private CategoryExtService  categoryExtService;

    @Autowired
    private CategoryUnionExtMapper  categoryUnionExtMapper;
    @Autowired
    private DepartmentExtService departmentExtService;
    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Override
    public PageData<WorkorderCheckExtListVO> findPage(PageWrap<QueryWorkorderCheckExtDTO> pageWrap) {
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！");
        }
        //只能查看当前根组织的数据
        pageWrap.getModel().setDeleted(Constants.ZERO);
        pageWrap.getModel().setRootDepartId(user.getRootDepartment().getId());
//        if(!Constants.equalsInteger(user.getCurComDepartment().getId(),user.getRootDepartment().getId())){
            //如果当前选择的公司级组织非根组织信息，只能查看当前选择公司级组织数据
            pageWrap.getModel().setDepartId(user.getCurComDepartment().getId());
//        }
        //数据权限
        List<Integer> dataPermission = user.getDepartPermissionList();
        if(dataPermission!=null){
           // pageWrap.getModel().setPmodelUserId(user.getId());
            pageWrap.getModel().setDepartIds(dataPermission);
            pageWrap.getModel().setCreateUser(user.getId());
        /*    if(dataPermission.size() == 0){
                //只能看自己的
                pageWrap.getModel().setPmodelUserId(user.getId());
            }else{
                //否则走数据权限
                pageWrap.getModel().setDepartIds(dataPermission);
            }*/
        }

        List<Integer> procedureIds=user.getProcedureIds();//权限范围内工序
        if(procedureIds!=null){
            if(procedureIds.size()>0){
                pageWrap.getModel().setProcedureIds(procedureIds);
            }

        }
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity());
        pageWrap.getModel().setDeleted(Constants.ZERO);
        List<WorkorderCheckExtListVO> result = workorderCheckExtMapper.selectListNew(pageWrap.getModel());
        if(result.size()>0){
            List<DepartmentExtListVO> allDepartList = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_DEPART_LIST_KEY+user.getCompany().getId(),ArrayList.class);
            for(int i=0;i<result.size();i++){
                WorkorderCheckExtListVO data=result.get(i);
                initProuserIds(user,data,allDepartList);
                initCheckUser(user,data,allDepartList);
                initCheckInfo(data,user);
            }
        }
        return PageData.from(new PageInfo<>(result));
    }

    private void initCheckUser(LoginUserInfo user, WorkorderCheckExtListVO data, List<DepartmentExtListVO> allDepartList) {
        if(data.getCheckUserId() ==null){
            return;
        }
        CompanyUser query=new CompanyUser();
        query.setUserId(data.getCheckUserId());
        query.setDeleted(Constants.ZERO);
        query.setRootDepartId(user.getRootDepartment().getId());
        CompanyUser comp= companyUserExtMapper.selectOne(new QueryWrapper<>(query));
        if(comp!=null){
            DepartmentExtListVO d = departmentExtService.getModelById(user.getCompany().getId(),comp.getDepartmentId(),allDepartList);
            String dName =d==null?"":StringUtils.defaultString(d.getName(),"");
            data.setCheckUserDepartName(dName);
        }
    }

    private void initProuserIds(LoginUserInfo user, WorkorderCheckExtListVO data, List<DepartmentExtListVO> allDepartList) {
        if(StringUtils.isNotEmpty(data.getProUserids())){
            String[] str=data.getProUserids().split(",");
            for(String id:str){
                id = StringUtils.strip(id,"[]");
                CompanyUser query=new CompanyUser();
                query.setUserId(Integer.valueOf(id));
                Integer rootDepartId=data.getRootDepartId();
                query.setRootDepartId(rootDepartId);
                CompanyUser comp= companyUserExtMapper.selectOne(new QueryWrapper<>(query).last(" limit 1"));
                if(comp!=null){
                    DepartmentExtListVO d = departmentExtService.getModelById(user.getCompany().getId(),comp.getDepartmentId(),allDepartList);
                    String dName =d==null?"":StringUtils.defaultString(d.getName(),"");
                    data.setProUserids(comp.getName()+"-"+dName);
                }
            }
        }
    }

    @Override
    public  WorkorderCheckExtListVO findDetailById(Integer tid){
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！");
        }
        QueryWorkorderCheckExtDTO pageWrap = new QueryWorkorderCheckExtDTO();
        pageWrap.setId(tid);
        //只能查看当前根组织的数据
        pageWrap.setDeleted(Constants.ZERO);
        List<WorkorderCheckExtListVO> result = workorderCheckExtMapper.selectListNew(pageWrap);
        WorkorderCheckExtListVO data = null;
        if(result != null && result.size()>0){
            data=result.get(0);
            List<DepartmentExtListVO> allDepartList = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_DEPART_LIST_KEY+user.getCompany().getId(),ArrayList.class);
            initProuserIds(user,data,allDepartList);
            initCheckUser(user,data,allDepartList);
            initCheckInfo(data,user);
        }
        return data;
    }
    private void initCheckInfo(WorkorderCheckExtListVO data, LoginUserInfo user) {
        if(StringUtils.isNotBlank(data.getCheckInfo())){
            try {
                List<CategoryExtListVO> clist = RedisUtil.getObject(redisTemplate,Constants.RedisKeys.COM_CATEGORY_KEY+user.getCompany().getId(),ArrayList.class);
                CategoryUnion uModel = categoryUnionExtMapper.selectById(Integer.parseInt(data.getCheckInfo()));
                if(uModel!= null ){
                    String cnamge = getCatenameById(user,uModel.getCateBigId(),clist)+ getCatenameById(user,uModel.getCateMiddleId(),clist)+ getCatenameById(user,uModel.getCateSmallId(),clist);
                    data.setCheckInfo(cnamge);

                }
            }catch (Exception e){

            }
        }
    }

    private String getCatenameById(LoginUserInfo user, Integer cateId, List<CategoryExtListVO> clist) {
        if(cateId!=null){
            CategoryExtListVO bc = categoryExtService.getByCategoryId(user.getCompany().getId(),cateId,clist);
            if(bc!=null){
                return StringUtils.defaultString(bc.getName(),"");
            }
        }
        return "";
    }

    @Override
    public  List<WorkorderCheckGroupListVO> listGroupByAppliance(QueryWorkorderCheckExtDTO pageWrap){
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！");
        }
        if(pageWrap.getWorkorderId() == null){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "对不起，请求参数不正确！");
        }

        WorkorderCheck cParam = new WorkorderCheck();
        cParam.setWorkorderId(pageWrap.getWorkorderId());
        cParam.setDeleted(Constants.ZERO);
        //查询工单全部检验记录
        List<WorkorderCheck> checkList = workorderCheckExtMapper.selectGroupList(cParam);
        List<WorkorderCheckGroupListVO> result = new ArrayList<>();
        Integer scrapId =   systemDictDataBiz.queryByCode(Constants.SYSTEM_APPLIANCE_TYPE,Constants.APPLIANCES_TYPE_LABLE.scrap).getId();
        if(checkList !=null){
            for(WorkorderCheck c : checkList){
                if( Constants.formatIntegerNum(c.getUnqualifiedNum())>0){
                    WorkorderCheckGroupListVO tModel = new WorkorderCheckGroupListVO();
                    tModel.setId(c.getQualifiedApplianceId());
                    tModel.setCode(c.getQualifiedApplianceCode());
                    tModel.setMaterialName(c.getMaterialName());
                    tModel.setNum(c.getUnqualifiedNum());
                    if(Constants.equalsInteger(c.getDoneType(),scrapId)){
                        //如果是报废品
                        tModel.setType(Constants.ONE);
                    }else {
                        //如果是不良品
                        tModel.setType(Constants.ZERO);
                    }
                    result.add(tModel);
                }
            }
        }
        return result;
    }
    @Override
    public synchronized  String  getNextCode(Integer comId ){
        String prefix =   DateUtil.getDate(new Date(),"yyyyMMdd") +"-";
        Integer countNum  = RedisUtil.getObject(redisTemplate, Constants.RedisKeys.COM_CHECK_CODE_KEY+comId,Integer.class);
        countNum = Constants.formatIntegerNum(countNum)+1;
        //更新缓存
        RedisUtil.addObject(redisTemplate,Constants.RedisKeys.COM_CHECK_CODE_KEY+comId,countNum);
        String nextIndex =Integer.toString( countNum);
        return prefix + StringUtils.leftPad(nextIndex,4,"0");
    }
}