package com.gkhy.safePlatform.specialWork.service.impl;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gkhy.safePlatform.account.rpc.apimodel.AccountDepartmentService;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.DepInfoRPCRespDTO;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.enums.E;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.exception.BusinessException;
import com.gkhy.safePlatform.commons.query.PageQuery;
import com.gkhy.safePlatform.commons.utils.StringUtils;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
import com.gkhy.safePlatform.specialWork.entity.ApprovalRuleItemStand;
import com.gkhy.safePlatform.specialWork.entity.ApprovalRuleItemStandDO;
import com.gkhy.safePlatform.specialWork.enums.RuleItemStandStatusEnum;
import com.gkhy.safePlatform.specialWork.enums.WorkStandTypeEnum;
import com.gkhy.safePlatform.specialWork.model.update.EntityStatusBatchUO;
import com.gkhy.safePlatform.specialWork.model.dto.req.ApprovalRuleStandAddReqDTO;
import com.gkhy.safePlatform.specialWork.model.dto.req.ApprovalRuleStandModReqDTO;
import com.gkhy.safePlatform.specialWork.model.dto.req.DeleteForm;
import com.gkhy.safePlatform.specialWork.model.dto.resp.ApprovalRuleItemStandPageRespDTO;
import com.gkhy.safePlatform.specialWork.model.dto.resp.ApprovalRuleStandListRespDTO;
import com.gkhy.safePlatform.specialWork.model.query.ApprovalRuleStandListQuery;
import com.gkhy.safePlatform.specialWork.model.query.ApprovalRuleStandPageQuery;
import com.gkhy.safePlatform.specialWork.model.query.db.ApprovalRuleStandListDBQuery;
import com.gkhy.safePlatform.specialWork.model.query.db.ApprovalRuleStandPageDBQuery;
import com.gkhy.safePlatform.specialWork.service.RuleStandService;
import com.gkhy.safePlatform.specialWork.service.baseService.ApprovalRuleStandService;
import com.gkhy.safePlatform.specialWork.service.baseService.ApprovalRuleUnitItemService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;


@Service("ruleStandService")
public class RuleStandServiceImpl implements RuleStandService {

    @DubboReference(check = false)
    private AccountDepartmentService accountDepartmentService;
    @Autowired
    private ApprovalRuleStandService approvalRuleStandService;
    @Autowired
    private ApprovalRuleUnitItemService approvalRuleUnitItemService;


    @Override
    public void saveRuleStand(ContextCacheUser currentUser, ApprovalRuleStandAddReqDTO addReqDTO) {
        ;
        if (addReqDTO.getRuleStandType() == null) {
            throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
        }
        if (StringUtils.isBlank(addReqDTO.getTitle())) {
            throw new AusinessException(E.DATA_PARAM_NULL, "标题为空");
        }
        WorkStandTypeEnum standTypeEnum = WorkStandTypeEnum.parse(addReqDTO.getRuleStandType());
        if (standTypeEnum == null) {
            throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "标准类型参数不合法");
        }

        // 1.保存审批项标准
        ApprovalRuleItemStand itemStandEntity = new ApprovalRuleItemStand();
//        itemStandEntity.setDepId(addReqDTO.getDepId());
        itemStandEntity.setType(addReqDTO.getRuleStandType());
//        itemStandEntity.setEid(addReqDTO.getEid());
        itemStandEntity.setMaxVal(addReqDTO.getMaxVal());
        itemStandEntity.setMaxValMatchPattern(addReqDTO.getMaxValMatchPattern());
        itemStandEntity.setMinVal(addReqDTO.getMinVal());
        itemStandEntity.setMinValMatchPattern(addReqDTO.getMinValMatchPattern());
        itemStandEntity.setTitle(addReqDTO.getTitle());
        itemStandEntity.setInfo(addReqDTO.getInfo());
        itemStandEntity.setCreateUid(currentUser.getUid());
        itemStandEntity.setCreateUname(currentUser.getRealName());
        itemStandEntity.setGmtCreate(LocalDateTime.now());
        itemStandEntity.setStatus(RuleItemStandStatusEnum.VALID.getCode());
        approvalRuleStandService.saveRuleStand(itemStandEntity);
    }

    @Override
    public void updateRuleStand(ContextCacheUser currentUser, ApprovalRuleStandModReqDTO modReqDTO) {
        ;
        if (modReqDTO.getRuleStandType() == null ||
                modReqDTO.getRuleStandId() == null) {
            throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
        }
        if (StringUtils.isBlank(modReqDTO.getTitle())) {
            throw new AusinessException(E.DATA_PARAM_NULL, "标题为空");
        }
        WorkStandTypeEnum standTypeEnum = WorkStandTypeEnum.parse(modReqDTO.getRuleStandType());
        if (standTypeEnum == null) {
            throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "标准类型参数不合法");
        }
        ApprovalRuleItemStandDO ruleStandDO = approvalRuleStandService.getRuleStandDOById(modReqDTO.getRuleStandId());
        if (ruleStandDO == null) {
            throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "审批标准不存在");
        }
        if (!ruleStandDO.getStatus().equals(RuleItemStandStatusEnum.VALID.getCode())) {
            throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "审批标准不存在");
        }

        if (!WorkStandTypeEnum.checkWorkStandType(modReqDTO.getRuleStandType())) {
            throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "标准类型参数不合法");
        }
        // 更新
        ApprovalRuleItemStand itemStandEntity = new ApprovalRuleItemStand();
        itemStandEntity.setId(modReqDTO.getRuleStandId());
//        itemStandEntity.setDepId(modReqDTO.getDepId());
        itemStandEntity.setTitle(modReqDTO.getTitle());
        itemStandEntity.setMinVal(modReqDTO.getMinVal());
        itemStandEntity.setMinValMatchPattern(modReqDTO.getMinValMatchPattern());
        itemStandEntity.setMaxVal(modReqDTO.getMaxVal());
        itemStandEntity.setMaxValMatchPattern(modReqDTO.getMaxValMatchPattern());
        itemStandEntity.setType(modReqDTO.getRuleStandType());
        itemStandEntity.setInfo(modReqDTO.getInfo());
        itemStandEntity.setGmtModified(LocalDateTime.now());
        itemStandEntity.setModifiedUid(currentUser.getUid());
        itemStandEntity.setModifiedUname(currentUser.getRealName());
        approvalRuleStandService.updateRuleStand(itemStandEntity);
    }

    @Override
    public List<ApprovalRuleStandListRespDTO> listRuleStand(ContextCacheUser currentUser,ApprovalRuleStandListQuery query) {
        ;
        // 查询对象
        ApprovalRuleStandListDBQuery dbQuery = new ApprovalRuleStandListDBQuery();
        dbQuery.setRuleStandType(query.getRuleStandType());
        dbQuery.setStatus(RuleItemStandStatusEnum.VALID.getCode());
        dbQuery.setTitle(query.getTitle());
        // 执行
        List<ApprovalRuleItemStandDO> dbData = approvalRuleStandService.listRuleStandDO(dbQuery);
        List<ApprovalRuleStandListRespDTO> respDTOs = new ArrayList<>(dbData.size());
        ApprovalRuleStandListRespDTO respDTO;
        RuleItemStandStatusEnum itemStandStatusEnum;
        WorkStandTypeEnum standTypeEnum;
        if (dbData.size() > 0) {
            for (ApprovalRuleItemStandDO ruleItemStandDO : dbData) {
                respDTO = new ApprovalRuleStandListRespDTO();
                respDTO.setTitle(ruleItemStandDO.getTitle());
                respDTO.setRuleStandId(ruleItemStandDO.getId());
                respDTO.setTitle(ruleItemStandDO.getTitle());
                respDTO.setMaxVal(ruleItemStandDO.getMaxVal());
                respDTO.setMaxValMatchPattern(ruleItemStandDO.getMaxValMatchPattern());
                respDTO.setMinVal(ruleItemStandDO.getMinVal());
                respDTO.setMinValMatchPattern(ruleItemStandDO.getMinValMatchPattern());
                respDTO.setRuleStandType(ruleItemStandDO.getType());
                respDTO.setStatus(ruleItemStandDO.getStatus());
                respDTO.setInfo(ruleItemStandDO.getInfo());
                standTypeEnum = WorkStandTypeEnum.parse(ruleItemStandDO.getType());
                if (standTypeEnum != null) {
                    respDTO.setRuleStandTypeDesc(standTypeEnum.getDesc());
                }
                itemStandStatusEnum = RuleItemStandStatusEnum.parse(ruleItemStandDO.getStatus());
                if (itemStandStatusEnum != null) {
                    respDTO.setStatusDesc(itemStandStatusEnum.getValue());
                }
                respDTOs.add(respDTO);
            }
        }
        return respDTOs;
    }

    @Override
    public SearchResultVO<List<ApprovalRuleItemStandPageRespDTO>> listRuleStandByPage(ContextCacheUser currentUser, PageQuery<ApprovalRuleStandPageQuery> query) {
        ;
        // 查询对象
        ApprovalRuleStandPageDBQuery dbQuery = new ApprovalRuleStandPageDBQuery();
        dbQuery.setStatus(RuleItemStandStatusEnum.VALID.getCode());
        if (query.getSearchParams() != null) {
            dbQuery.setTitle(query.getSearchParams().getTitle());
            dbQuery.setRuleStandType(query.getSearchParams().getRuleStandType());
        }
        // 分页对象
        Page<ApprovalRuleItemStand> page = new Page<>(query.getPageIndex(), query.getPageSize());
        List<ApprovalRuleItemStand> dbData = approvalRuleStandService.listRuleStandByPage(page, dbQuery);
        List<ApprovalRuleItemStandPageRespDTO> respDTOs = new ArrayList<>(dbData.size());
        ApprovalRuleItemStandPageRespDTO respDTO;
        RuleItemStandStatusEnum itemStandStatusEnum;
        WorkStandTypeEnum standTypeEnum;
        if (dbData.size() > 0) {
            for (ApprovalRuleItemStand ruleItemStandDO : dbData) {
                respDTO = new ApprovalRuleItemStandPageRespDTO();
                respDTO.setRuleStandId(ruleItemStandDO.getId());
                respDTO.setMaxVal(ruleItemStandDO.getMaxVal());
                respDTO.setMaxValMatchPattern(ruleItemStandDO.getMaxValMatchPattern());
                respDTO.setMinVal(ruleItemStandDO.getMinVal());
                respDTO.setMinValMatchPattern(ruleItemStandDO.getMinValMatchPattern());
                respDTO.setRuleStandType(ruleItemStandDO.getType());
                respDTO.setTitle(ruleItemStandDO.getTitle());
                respDTO.setInfo(ruleItemStandDO.getInfo());
                respDTO.setStatus(ruleItemStandDO.getStatus());
                respDTO.setCreateUid(ruleItemStandDO.getCreateUid());
                respDTO.setCreateUname(ruleItemStandDO.getCreateUname());
                respDTO.setGmtCreate(ruleItemStandDO.getGmtCreate());
                respDTO.setModifiedUid(ruleItemStandDO.getModifiedUid());
                respDTO.setModifiedUname(ruleItemStandDO.getModifiedUname());
                respDTO.setGmtModified(ruleItemStandDO.getGmtModified());
                standTypeEnum = WorkStandTypeEnum.parse(ruleItemStandDO.getType());
                if (standTypeEnum != null) {
                    respDTO.setRuleStandTypeDesc(standTypeEnum.getDesc());
                }
                itemStandStatusEnum = RuleItemStandStatusEnum.parse(ruleItemStandDO.getStatus());
                if (itemStandStatusEnum != null) {
                    respDTO.setStatusDesc(itemStandStatusEnum.getValue());
                }
                respDTOs.add(respDTO);
            }
        }

        return new SearchResultVO<>(
                true,page.getCurrent(),
                page.getSize(),
                page.getPages(),
                page.getTotal(),
                respDTOs,
                ResultCodes.OK);
    }

    @Override
    public void deleteRuleStand(ContextCacheUser currentUser, DeleteForm deleteForm) {
        ;
        if (deleteForm.getIds() == null || deleteForm.getIds().size() == 0) {
            throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
        }
        if (deleteForm.getIds().size() > 10) {
            throw new BusinessException(ResultCodes.SERVER_DEL_OVER_SIZE);
        }
        ApprovalRuleItemStandDO ruleItemStandDO;
        long count;
        for (Long ruleStandId : deleteForm.getIds()) {
            ruleItemStandDO = approvalRuleStandService.getRuleStandDOById(ruleStandId);
            if (ruleItemStandDO == null) {
                throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT,"审批项标准不存在");
            }
            if (!ruleItemStandDO.getStatus().equals(RuleItemStandStatusEnum.VALID.getCode())) {
                throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID,"审批项标准不存在");
            }
            // 是否被审批项占用
            count = approvalRuleUnitItemService.countByRuleStandId(ruleStandId);
            if (count > 0) {
                throw new AusinessException(E.DATA_BING_RELATION, "审批项关联，无法删除");
            }
        }
        EntityStatusBatchUO batchDeleteObj = new EntityStatusBatchUO();
        batchDeleteObj.setIds(deleteForm.getIds());
        batchDeleteObj.setModifiedUname(currentUser.getRealName());
        batchDeleteObj.setGmtModified(LocalDateTime.now());
        batchDeleteObj.setModifiedUid(currentUser.getUid());
        batchDeleteObj.setStatus(RuleItemStandStatusEnum.ABANDONED.getCode());
        approvalRuleStandService.deleteBatch(batchDeleteObj);
    }
}