package com.doumee.service.system.impl; 
 | 
  
 | 
import com.baomidou.mybatisplus.core.conditions.Wrapper; 
 | 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; 
 | 
import com.doumee.core.constants.ResponseStatus; 
 | 
import com.doumee.core.exception.BusinessException; 
 | 
import com.doumee.core.model.LoginUserInfo; 
 | 
import com.doumee.core.model.PageData; 
 | 
import com.doumee.core.model.PageWrap; 
 | 
import com.doumee.core.utils.Constants; 
 | 
import com.doumee.dao.system.SystemDictDataMapper; 
 | 
import com.doumee.dao.system.SystemDictMapper; 
 | 
import com.doumee.dao.system.dto.QuerySystemDictDataDTO; 
 | 
import com.doumee.dao.system.dto.VisitConfigDTO; 
 | 
import com.doumee.dao.system.model.SystemDict; 
 | 
import com.doumee.dao.system.model.SystemDictData; 
 | 
import com.doumee.dao.system.vo.SystemDictDataListVO; 
 | 
import com.doumee.service.system.SystemDictDataService; 
 | 
import com.github.pagehelper.PageHelper; 
 | 
import com.github.pagehelper.PageInfo; 
 | 
import lombok.extern.java.Log; 
 | 
import org.apache.shiro.SecurityUtils; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.stereotype.Service; 
 | 
import org.springframework.transaction.annotation.Transactional; 
 | 
import org.springframework.util.CollectionUtils; 
 | 
import org.springframework.util.StringUtils; 
 | 
  
 | 
import java.util.Date; 
 | 
import java.util.List; 
 | 
import java.util.Objects; 
 | 
  
 | 
/** 
 | 
 * 字典数据Service实现 
 | 
 * @author Eva.Caesar Liu 
 | 
 * @date 2023/03/21 14:49 
 | 
 */ 
 | 
@Service 
 | 
public class SystemDictDataServiceImpl implements SystemDictDataService { 
 | 
  
 | 
    @Autowired 
 | 
    private SystemDictDataMapper systemDictDataMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private SystemDictMapper systemDictMapper; 
 | 
    @Override 
 | 
    public Integer create(SystemDictData systemDictData) { 
 | 
        systemDictDataMapper.insert(systemDictData); 
 | 
        return systemDictData.getId(); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void deleteById(Integer id) { 
 | 
        SystemDictData systemDictData = new SystemDictData(); 
 | 
        systemDictData.setId(id); 
 | 
        systemDictData.setDeleted(Boolean.TRUE); 
 | 
        this.updateById(systemDictData); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void deleteByIdInBatch(List<Integer> ids) { 
 | 
        if (CollectionUtils.isEmpty(ids)) { 
 | 
            return; 
 | 
        } 
 | 
        for (Integer id : ids) { 
 | 
            this.deleteById(id); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateById(SystemDictData systemDictData) { 
 | 
        systemDictDataMapper.updateById(systemDictData); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void updateByIdInBatch(List<SystemDictData> systemDictDatas) { 
 | 
        if (CollectionUtils.isEmpty(systemDictDatas)) { 
 | 
            return; 
 | 
        } 
 | 
        for (SystemDictData systemDictData: systemDictDatas) { 
 | 
            this.updateById(systemDictData); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public SystemDictData findById(Integer id) { 
 | 
        return systemDictDataMapper.selectById(id); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public SystemDictData findOne(SystemDictData systemDictData) { 
 | 
        Wrapper<SystemDictData> wrapper = new QueryWrapper<>(systemDictData); 
 | 
        return systemDictDataMapper.selectOne(wrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public List<SystemDictData> findList(SystemDictData systemDictData) { 
 | 
        Wrapper<SystemDictData> wrapper = new QueryWrapper<>(systemDictData); 
 | 
        return systemDictDataMapper.selectList(wrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public PageData<SystemDictDataListVO> findPage(PageWrap<QuerySystemDictDataDTO> pageWrap) { 
 | 
        PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); 
 | 
        return PageData.from(new PageInfo<>(systemDictDataMapper.selectManageList(pageWrap.getModel()))); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public long count(SystemDictData systemDictData) { 
 | 
        Wrapper<SystemDictData> wrapper = new QueryWrapper<>(systemDictData); 
 | 
        return systemDictDataMapper.selectCount(wrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public List<SystemDictData> findList(Integer dicId,List<String> codes) { 
 | 
        QueryWrapper<SystemDictData> wrapper = new QueryWrapper<>(); 
 | 
        wrapper.lambda() 
 | 
                .eq(Objects.nonNull(dicId),SystemDictData::getDictId,dicId) 
 | 
                .in(SystemDictData::getLabel,codes); 
 | 
        return systemDictDataMapper.selectList(wrapper); 
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
    private SystemDictData getSystemDictDataListVO(SystemDict systemDict) { 
 | 
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); 
 | 
        SystemDictData systemDictData = new SystemDictData(); 
 | 
        systemDictData.setDictId(systemDict.getId()); 
 | 
        systemDictData.setDisabled(true); 
 | 
        systemDictData.setSort(Constants.ONE); 
 | 
        systemDictData.setCreateTime(new Date()); 
 | 
        systemDictData.setUpdateTime(new Date()); 
 | 
        systemDictData.setCreateUser(loginUserInfo.getId()); 
 | 
        systemDictData.setUpdateUser(loginUserInfo.getId()); 
 | 
  
 | 
        return systemDictData; 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public VisitConfigDTO getVisitConfigDTO() { 
 | 
        VisitConfigDTO visitConfigDTO = new VisitConfigDTO(); 
 | 
        SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); 
 | 
        if(Objects.isNull(systemDict)){ 
 | 
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"字典类不存在"); 
 | 
        } 
 | 
        List<SystemDictData> systemDictList = systemDictDataMapper.selectList( 
 | 
                new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); 
 | 
        if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ 
 | 
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"字典不存在"); 
 | 
        } 
 | 
        try {visitConfigDTO.setReservationWay(Integer.parseInt(setDataByLabel(systemDictList,Constants.MDJ_VISIT_REQUIRED))); }catch (Exception e){   } 
 | 
        try {visitConfigDTO.setCheckVisit(Integer.parseInt(setDataByLabel(systemDictList,Constants.BEVISITED_USER_VALID)));}catch (Exception e){} 
 | 
        try {visitConfigDTO.setHealthCard(Integer.parseInt(setDataByLabel(systemDictList,Constants.HEALTH_CARD)));}catch (Exception e){} 
 | 
        try {visitConfigDTO.setIsAnswer(Integer.parseInt(setDataByLabel(systemDictList,Constants.PROBLEM_VISIT_REQUIRED)));}catch (Exception e){} 
 | 
        visitConfigDTO.setTheme(setDataByLabel(systemDictList,Constants.THEME)); 
 | 
        visitConfigDTO.setDescription(setDataByLabel(systemDictList,Constants.DESCRIPTION)); 
 | 
        visitConfigDTO.setVisitNotice(setDataByLabel(systemDictList,Constants.VISIT_NOTICE)); 
 | 
        try {visitConfigDTO.setDoorsVisitRequired(Integer.parseInt(setDataByLabel(systemDictList,Constants.SELECT_DOORS_VISIT_REQUIRED)));}catch (Exception e){} 
 | 
        try {visitConfigDTO.setFrezzDays(Integer.parseInt(setDataByLabel(systemDictList,Constants.TIMEOUT_FREEZE)));}catch (Exception e){} 
 | 
        visitConfigDTO.setVisitTips(setDataByLabel(systemDictList,Constants.VISIT_TIPS)); 
 | 
        visitConfigDTO.setVisitMap(setDataByLabel(systemDictList,Constants.VISIT_GUIDEMAP)); 
 | 
        return visitConfigDTO; 
 | 
    } 
 | 
  
 | 
    private String setDataByLabel(List<SystemDictData> systemDictList, String visitGuidemap) { 
 | 
        for(SystemDictData dictData : systemDictList){ 
 | 
            if(org.apache.commons.lang3.StringUtils.equals(dictData.getLabel(),visitGuidemap)){ 
 | 
                return  (dictData!=null?dictData.getCode():""); 
 | 
            } 
 | 
        } 
 | 
        return ""; 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    @Transactional 
 | 
    public void updateVisitConfig(VisitConfigDTO visitConfigDTO) { 
 | 
        if(Objects.isNull(visitConfigDTO) 
 | 
                && Objects.isNull(visitConfigDTO.getReservationWay()) 
 | 
                && Objects.isNull(visitConfigDTO.getCheckVisit()) 
 | 
                && Objects.isNull(visitConfigDTO.getHealthCard()) 
 | 
                && Objects.isNull(visitConfigDTO.getIsAnswer()) 
 | 
                && StringUtils.isEmpty(visitConfigDTO.getTheme()) 
 | 
                && StringUtils.isEmpty(visitConfigDTO.getDoorsVisitRequired()) 
 | 
                && StringUtils.isEmpty(visitConfigDTO.getVisitMap()) 
 | 
                && StringUtils.isEmpty(visitConfigDTO.getVisitTips()) 
 | 
                && StringUtils.isEmpty(visitConfigDTO.getDescription()) 
 | 
        ){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST); 
 | 
        } 
 | 
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); 
 | 
        if(loginUserInfo == null){ 
 | 
            loginUserInfo = visitConfigDTO.getLoginUserInfo(); 
 | 
        } 
 | 
        SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); 
 | 
        if(Objects.isNull(systemDict)){ 
 | 
            systemDict = new SystemDict(); 
 | 
            systemDict.setCreateUser(loginUserInfo.getId()); 
 | 
            systemDict.setCreateTime(new Date()); 
 | 
            systemDict.setUpdateUser(systemDict.getCreateUser()); 
 | 
            systemDict.setUpdateTime(systemDict.getCreateTime()); 
 | 
            systemDict.setCode(Constants.SYSTEM); 
 | 
            systemDict.setRemark("系统配置"); 
 | 
            systemDict.setDeleted(Boolean.FALSE); 
 | 
            systemDictMapper.insert(systemDict); 
 | 
        } 
 | 
        List<SystemDictData> systemDictList = systemDictDataMapper.selectList( 
 | 
                new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); 
 | 
        if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ 
 | 
            throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"字典不存在"); 
 | 
        } 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.MDJ_VISIT_REQUIRED,"访客来访预约方式",loginUserInfo, visitConfigDTO.getReservationWay()==null?"":visitConfigDTO.getReservationWay().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.BEVISITED_USER_VALID,"访客被访人校验方式",loginUserInfo, visitConfigDTO.getCheckVisit()==null?"":visitConfigDTO.getCheckVisit().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.HEALTH_CARD,"访客健康证是否必填",loginUserInfo, visitConfigDTO.getHealthCard()==null?"":visitConfigDTO.getHealthCard().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.PROBLEM_VISIT_REQUIRED,"访客是否需要答题",loginUserInfo, visitConfigDTO.getIsAnswer()==null?"":visitConfigDTO.getIsAnswer().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.THEME,"访客答题主题",loginUserInfo, visitConfigDTO.getTheme()==null?"":visitConfigDTO.getTheme().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.DESCRIPTION,"访客答题说明",loginUserInfo, visitConfigDTO.getDescription()==null?"":visitConfigDTO.getDescription().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.VISIT_NOTICE,"入厂须知",loginUserInfo, visitConfigDTO.getVisitNotice()==null?"":visitConfigDTO.getVisitNotice().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.SELECT_DOORS_VISIT_REQUIRED,"自选门禁配置",loginUserInfo, visitConfigDTO.getDoorsVisitRequired()==null?"":visitConfigDTO.getDoorsVisitRequired().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.TIMEOUT_FREEZE,"人员门禁授权冻结天数配置",loginUserInfo, visitConfigDTO.getFrezzDays()==null?"":visitConfigDTO.getFrezzDays().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.VISIT_TIPS,"访客预约指南",loginUserInfo, visitConfigDTO.getVisitTips()==null?"":visitConfigDTO.getVisitTips().toString()); 
 | 
        dealDictData(systemDictList,systemDict.getId(),Constants.VISIT_GUIDEMAP,"访客园区导览图",loginUserInfo, visitConfigDTO.getVisitMap()==null?"":visitConfigDTO.getVisitMap().toString()); 
 | 
    } 
 | 
  
 | 
    private void dealDictData(List<SystemDictData> systemDictList,Integer dictId, String label, String remark, LoginUserInfo loginUserInfo, String code) { 
 | 
        SystemDictData reservationWay =null; 
 | 
        for(SystemDictData dictData : systemDictList){ 
 | 
            if(org.apache.commons.lang3.StringUtils.equals(dictData.getLabel(),label)){ 
 | 
                reservationWay = dictData; 
 | 
                break; 
 | 
            } 
 | 
        } 
 | 
        if(Objects.isNull(reservationWay)){ 
 | 
            reservationWay = new SystemDictData(); 
 | 
            reservationWay.setCreateUser(loginUserInfo.getId()); 
 | 
            reservationWay.setCreateTime(new Date()); 
 | 
            reservationWay.setUpdateUser(loginUserInfo.getId()); 
 | 
            reservationWay.setUpdateTime(reservationWay.getCreateTime()); 
 | 
            reservationWay.setLabel(label); 
 | 
            reservationWay.setCode(code); 
 | 
            reservationWay.setDictId(dictId); 
 | 
            reservationWay.setRemark(remark); 
 | 
            systemDictDataMapper.insert(reservationWay); 
 | 
        }else{ 
 | 
            reservationWay.setCode(code); 
 | 
            reservationWay.setUpdateUser(loginUserInfo.getId()); 
 | 
            reservationWay.setUpdateTime(new Date()); 
 | 
            systemDictDataMapper.updateById(reservationWay); 
 | 
        } 
 | 
    } 
 | 
} 
 |