ubcs.git - Gitblit

package com.vci.ubcs.omd.service.impl;
 
import com.alibaba.cloud.commons.lang.StringUtils;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.vci.ubcs.omd.constant.BtmTypeConstant;
import com.vci.ubcs.omd.entity.Status;
import com.vci.ubcs.omd.mapper.StatusMapper;
import com.vci.ubcs.omd.service.IStatusService;
import com.vci.ubcs.omd.vo.StatusVO;
import com.vci.ubcs.omd.wrapper.StatusWrapper;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.web.util.BeanUtil;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.Func;
import org.springframework.cglib.beans.BeanMap;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
 
import java.util.*;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
 
/**
 * Description: 状态池的实现类
 *
 * @author LiHang
 * @date 2023/5/23
 */
@Service
public class StatusServiceImpl extends ServiceImpl<StatusMapper, Status> implements IStatusService {
 
    private final String REGEXP = "^[A-Za-z]+$";
 
    /**
     * 获取状态列表
     *
     * @param conditionMap 查询条件
     * @param pageHelper   分页信息和排序信息，默认使用id排序
     * @return 状态对象列表
     * @throws VciBaseException 查询出错时会抛出异常
     */
    @Override
    public IPage<StatusVO> listStatus(Map<String, Object> conditionMap, Query pageHelper) throws VciBaseException {
        return StatusWrapper.build().pageVO(baseMapper.selectPage(Condition.getPage(pageHelper), Condition.getQueryWrapper(conditionMap,Status.class).lambda().orderByAsc(Status::getId)));
    }
 
    /**
     * 获取状态列表
     *
     * @param conditionMap 查询条件
     * @return 状态对象列表
     * @throws VciBaseException 查询出错时会抛出异常
     */
    @Override
    public List<StatusVO> listStatusNoPage(Map<String, String> conditionMap) throws VciBaseException {
        Status queryVO = new Status();
        BeanMap.create(queryVO).putAll(conditionMap);
        return StatusWrapper.build().listEntityVO(baseMapper.selectList(Condition.getQueryWrapper(queryVO).lambda().orderByAsc(Status::getId)));
    }
 
    /**
     * 根据主键获取状态
     *
     * @param pkStatus 状态主键
     * @return 状态，如果不存在会返回null
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public StatusVO getStatusByOid(String pkStatus) throws VciBaseException {
        List<StatusVO> statusVOList = listStatusByOids(pkStatus);
        if (!CollectionUtils.isEmpty(statusVOList)){
            return statusVOList.get(0);
        }
        return null;
    }
 
    /**
     * 根据主键批量获取状态
     *
     * @param primaryKeys 状态主键，用逗号分隔
     * @return 状态列表，如果有不存在的不会返回，全部不存在的则返回空列表
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public List<StatusVO> listStatusByOids(String primaryKeys) throws VciBaseException {
        VciBaseUtil.alertNotNull(primaryKeys,"状态的主键");
        List<String> pkList = Func.toStrList(",", primaryKeys);
        return listStatusByOidCollection(pkList);
    }
 
    /**
     * 批量根据主键获取状态
     *
     * @param pkStatusCollection 状态主键集合
     * @return 状态列表，如果有不存在的不会返回，全部不存在的则返回空列表
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public List<StatusVO> listStatusByOidCollection(Collection<String> pkStatusCollection) throws VciBaseException {
        if(!CollectionUtils.isEmpty(pkStatusCollection)){
            List<Status> statusDOList = listStatusByOidCollectionDO(pkStatusCollection);
            if(!CollectionUtils.isEmpty(statusDOList)) {
                return StatusWrapper.build().listEntityVO(statusDOList);
            }
        }
        return null;
    }
 
    /**
     * 根据主键集合获取数据对象
     * @param oidCollection 主键集合
     * @return 查询出来的数据对象
     * @throws VciBaseException mybatis执行出错时会抛出异常
     */
    private List<Status> listStatusByOidCollectionDO(Collection<String> oidCollection) throws VciBaseException{
        if(!CollectionUtils.isEmpty(oidCollection)){
            List<Status> statusDOList = new ArrayList<>();
            Collection<Collection<String>> pksCollections = VciBaseUtil.switchCollectionForOracleIn(oidCollection);
            if(!CollectionUtils.isEmpty(pksCollections)) {
                pksCollections.forEach(s -> {
                    List<Status> queryResult = baseMapper.selectList(Wrappers.<Status>query().lambda().in(Status::getOid,s));
                    if(!CollectionUtils.isEmpty(queryResult)){
                        statusDOList.addAll(queryResult);
                    }
                });
            }
            return statusDOList;
        }
        return null;
    }
 
    /**
     * 根据英文名称获取状态
     *
     * @param id 英文名称
     * @return 状态，如果不存在会返回null
     * @throws VciBaseException 查询出错抛出异常
     */
    @Override
    public StatusVO getStatusById(String id) throws VciBaseException {
        List<StatusVO> statusVOList = listStatusByIds(id);
        if(!CollectionUtils.isEmpty(statusVOList)){
            return statusVOList.get(0);
        }
        return null;
    }
 
    /**
     * 根据英文名称批量获取状态
     *
     * @param ids 英文名称，使用逗号分隔
     * @return 状态列表，如果有不存在的不会返回，全部不存在的则返回空列表
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public List<StatusVO> listStatusByIds(String ids) throws VciBaseException {
        VciBaseUtil.alertNotNull(ids,"状态的英文名称");
        List<String> idList = Func.toStrList(",", ids);
        return listStatusByIdCollection(idList);
    }
 
    /**
     * 根据英文名称集合批量获取状态
     *
     * @param idCollection 英文名称集合
     * @return 状态列表，如果有不存在的不会返回，全部不存在的则返回空列表
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public List<StatusVO> listStatusByIdCollection(Collection<String> idCollection) throws VciBaseException {
        if(!CollectionUtils.isEmpty(idCollection)){
            List<Status> statusDOList = listStatusByIdCollectionDO(idCollection);
            if(!CollectionUtils.isEmpty(statusDOList)) {
                return StatusWrapper.build().listEntityVO(statusDOList);
            }
        }
        return null;
    }
 
    /**
     * 根据英文名称集合获取数据对象
     * @param idCollection 英文名称集合
     * @return 数据对象列表，如果有不存在的不会返回，全部不存在的则返回空列表
     * @throws VciBaseException mybatis查询出错的时候会抛出异常
     */
    private List<Status> listStatusByIdCollectionDO(Collection<String> idCollection) throws VciBaseException {
        if(CollectionUtils.isEmpty(idCollection)) {
            return null;
        }
        List<Status> statusDOList = new ArrayList<>();
        Collection<Collection<String>> idCollections = VciBaseUtil.switchCollectionForOracleIn(idCollection);
        if(!CollectionUtils.isEmpty(idCollections)) {
            idCollections.forEach(s -> {
                List<Status> queryResult = baseMapper.selectByIdIgnoreCase(s);
                if(!CollectionUtils.isEmpty(queryResult)){
                    statusDOList.addAll(queryResult);
                }
            });
        }
        return statusDOList;
    }
 
    /**
     * 根据状态主键获取中文名称
     *
     * @param oid 状态主键，多个使用逗号分隔
     * @return 中文名称，如果不存在会返回null
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public String getNameByOid(String oid) throws VciBaseException {
        VciBaseUtil.alertNotNull(oid,"状态对象主键");
        return Optional.ofNullable(getStatusByOid(oid)).orElseGet(StatusVO::new).getName();
    }
 
    /**
     * 根据状态英文名称获取中文名称
     *
     * @param id 状态英文名称
     * @return 中文名称，如果不存在会返回null
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public String getNameById(String id) throws VciBaseException {
        VciBaseUtil.alertNotNull(id,"状态对象主键");
        return Optional.ofNullable(getStatusById(id)).orElseGet(StatusVO::new).getName();
    }
 
    /**
     * 添加状态
     *
     * @param statusVO 状态显示对象（和DTO共用）
     * @return 添加后的状态
     * @throws VciBaseException 添加出错的时候会抛出异常
     */
    @Override
    public StatusVO addSave(StatusVO statusVO) throws VciBaseException {
        VciBaseUtil.alertNotNull(statusVO,"要添加的状态",statusVO.getId(),"状态英文名称",statusVO.getName(),"状态中文名称");
        List<StatusVO> statusVOS = new ArrayList<>();
        statusVOS.add(statusVO);
        List<StatusVO> statusVOList = batchAddSave(statusVOS);
        if(CollectionUtils.isEmpty(statusVOList)){
            return null;
        }
        return statusVOList.get(0);
    }
 
    /**
     * 批量添加状态
     *
     * @param statusVOList 状态显示对象列表(和DTO共用)
     * @return 批量添加后的状态
     * @throws VciBaseException 添加出错的时候会抛出异常
     */
    @Override
    public List<StatusVO> batchAddSave(List<StatusVO> statusVOList) throws VciBaseException {
        if(CollectionUtils.isEmpty(statusVOList)){
            throw new VciBaseException("要添加的状态对象不能为空");
        }
        //1. 判断各个属性是否必输项都输入了
        //2. 判断英文名称是否重复
        Set<String> idSet = new HashSet<>();
        String creator = AuthUtil.getUserAccount();
        Date now = new Date();
        Pattern pattern = Pattern.compile(REGEXP);
        statusVOList.forEach(s -> {
            if (!pattern.matcher(s.getId()).matches()){
                throw new VciBaseException("英文名称{0}只能是英文字母",new Object[]{s.getId()});
            }
            VciBaseUtil.alertNotNull(s.getId(),"状态英文名称",s.getName(),"状态中文名称");
            if(idSet.contains(s.getId().toLowerCase().trim())){
                throw new VciBaseException("英文名称为{0}的状态已经存在（不区分大小写）",new Object[]{s.getId()});
            }else{
                idSet.add(s.getId().toLowerCase().trim());
            }
            if(StringUtils.isBlank(s.getOid())){
                s.setOid(VciBaseUtil.getPk());
            }
            s.setBtmName(BtmTypeConstant.STATUS);
            s.setOwner(creator);
            s.setCreator(creator);
            s.setCreateTime(now);
            s.setLastModifier(creator);
            s.setLastModifyTime(now);
            s.setTs(now);
        });
        //判断是否存在
        List<Status> checkExistStatusDOList = listStatusByIdCollectionDO(idSet);
        if(!CollectionUtils.isEmpty(checkExistStatusDOList)){
            String existIds = checkExistStatusDOList.stream().map(Status::getId).collect(Collectors.joining(","));
            throw new VciBaseException("英文名称为{0}的状态的已经在系统中存在（不区分大小写），不能添加",new Object[]{existIds});
        }
        List<Status> statusDOList = StatusWrapper.build().batchCopyVO2DO(statusVOList);
        VciBaseUtil.switchCollectionForOracleIn(statusDOList,1000).forEach(this::saveBatch);
        return statusVOList;
    }
 
    /**
     * 修改状态
     *
     * @param statusVO 状态显示对象（和DTO共用）
     * @return 修改后的状态
     * @throws VciBaseException 修改出错的时候会抛出异常
     */
    @Override
    public StatusVO editSave(StatusVO statusVO) throws VciBaseException {
        VciBaseUtil.alertNotNull(statusVO,"要修改的状态对象",statusVO.getOid(),"要修改的状态对象的主键");
        List<StatusVO> needEditVOList = new ArrayList<>();
        needEditVOList.add(statusVO);
        List<StatusVO> statusVOList = batchEditSave(needEditVOList);
        if(!CollectionUtils.isEmpty(statusVOList)){
            return statusVOList.get(0);
        }
        return null;
    }
 
    /**
     * 批量修改状态
     *
     * @param statusVOList 状态显示对象列表（和DTO共用）
     * @return 批量修改后的状态
     * @throws VciBaseException 修改出错的时候会抛出异常
     */
    @Override
    public List<StatusVO> batchEditSave(List<StatusVO> statusVOList) throws VciBaseException {
        if(CollectionUtils.isEmpty(statusVOList)){
            throw new VciBaseException("要修改的状态对象不能为空");
        }
        //1. 判断各个属性是否必输项都输入了
        //2. 判断状态的英文名称是否重复
        Set<String> idSet = new HashSet<>();
        Map<String,StatusVO> oidObjectMap = new HashMap<>();
        String creator = AuthUtil.getUserAccount();
        Date now = new Date();
        statusVOList.forEach(s -> {
            //判断为空
            VciBaseUtil.alertNotNull(s.getOid(),"状态主键",s.getId(),"状态英文名称",s.getName(),"状态中文名称");
            //判断本次是否存在
            if(idSet.contains(s.getId().toLowerCase().trim())){
                throw new VciBaseException("英文名称为{0}的状态已经存在（不区分大小写）",new Object[]{s.getId()});
            }else{
                idSet.add(s.getId().toLowerCase().trim());
            }
            oidObjectMap.put(s.getOid(),s);
            s.setLastModifier(creator);
            s.setLastModifyTime(now);
            s.setTs(now);
        });
        //判断是否存在
        List<Status> statusDOList = listStatusByOidCollectionDO(oidObjectMap.keySet());
        if(CollectionUtils.isEmpty(statusDOList)){
            throw new VciBaseException("这些状态在系统中均不存在",new Object[]{});
        }
        //判断属性名称是否修改
        Set<String> oidInDbSet = new HashSet<>();
        statusDOList.forEach(s -> {
            StatusVO statusVO =  oidObjectMap.get(s.getOid());
            if(!statusVO.getId().equalsIgnoreCase(s.getId())){
                throw new VciBaseException("状态[{0}]的英文名称不允许修改，原名称{1},新名称{2}",new Object[]{s.getName(),s.getId(),statusVO.getId()});
            }
            BeanUtil.convert(statusVO,s);
            oidInDbSet.add(s.getOid());
        });
        oidObjectMap.forEach( (k,v) ->{
            if(!oidInDbSet.contains(k)){
                throw new VciBaseException("状态{0}[{1}]在系统中不存在",new Object[]{v.getId(),v.getName()});
            }
        });
        //看看是否有不在系统中存在的
        VciBaseUtil.switchCollectionForOracleIn(statusDOList).forEach(this::saveOrUpdateBatch);
        return statusVOList;
    }
 
    /**
     * 删除状态
     *
     * @param statusVO 状态显示对象
     * @throws VciBaseException 如果状态被引用，或者删除出错时会抛出异常
     */
    @Override
    public void delete(StatusVO statusVO) throws VciBaseException {
        VciBaseUtil.alertNotNull(statusVO,"要删除的状态对象",statusVO.getOid(),"要删除的状态对象的主键");
        List<StatusVO> needDeleteVOList = new ArrayList<>();
        needDeleteVOList.add(statusVO);
        batchDelete(needDeleteVOList);
    }
 
    /**
     * 批量删除状态
     *
     * @param statusVOList 要删除的状态显示对象列表
     * @throws VciBaseException 如果状态被引用，或者删除出错时会抛出异常
     */
    @Override
    public void batchDelete(List<StatusVO> statusVOList) throws VciBaseException {
        if(CollectionUtils.isEmpty(statusVOList)){
            throw new VciBaseException("要删除的状态对象不能为空");
        }
        Set<String> oidSet= new HashSet<>();
        statusVOList.stream().forEach( s -> {
            VciBaseUtil.alertNotNull(s.getOid(),"要删除的状态对象的主键");
            oidSet.add(s.getOid());
        });
        //查询
        List<Status> statusDOList = listStatusByOidCollectionDO(oidSet);
        if(CollectionUtils.isEmpty(statusDOList)){
            throw new VciBaseException("要删除的状态在系统中不存在,可能您需要刷新后再试");
        }
        Set<String> oidInDbSet = statusDOList.stream().map(Status::getOid).collect(Collectors.toSet());
        oidSet.forEach( s -> {
            if(!oidInDbSet.contains(s)){
                throw new VciBaseException("要删除的状态在系统中不存在,可能您需要刷新后再试");
            }
        });
        //检查属性是否被引用
        if(checkStatusUseds(oidSet)){
            throw new VciBaseException("要删除的状态在生命周期对象中被使用，无法删除");
        }
        Collection<Collection<String>> oidCollections = VciBaseUtil.switchCollectionForOracleIn(oidInDbSet);
        for(Collection<String> oidCollection : oidCollections){
            baseMapper.delete(Wrappers.<Status>query().lambda().in(Status::getOid,oidCollection));
        }
    }
 
    /**
     * 批量校验状态是否被使用
     *
     * @param oidCollection 主键集合
     * @return true表示被引用
     */
    @Override
    public boolean checkStatusUseds(Collection<String> oidCollection) {
        return false;
    }
 
    /**
     * 校验状态是否被引用
     *
     * @param pkStatus 状态的主键
     * @return true表示被引用， false表示没有被引用
     * @throws VciBaseException 参数为空或者查询出错时会抛出错误
     */
    @Override
    public boolean checkStatusUsed(String pkStatus) throws VciBaseException {
        return false;
    }
}