package com.vci.ubcs.code.service.impl; import com.vci.ubcs.code.constant.MdmBtmTypeConstant; import com.vci.ubcs.code.mapper.CodePhaseAttrMapper; import com.vci.ubcs.code.mapper.CodeTemplatePhaseMapper; import com.vci.ubcs.code.entity.CodeClassifyTemplateAttrDO; import com.vci.ubcs.code.entity.CodePhaseAttrDO; import com.vci.ubcs.code.entity.CodeTemplatePhaseDO; import com.vci.ubcs.code.service.CodeClassifyTemplateAttrServiceI; import com.vci.ubcs.code.service.CodePhaseAttrServiceI; import com.vci.ubcs.code.service.CodeTemplatePhaseServiceI; import com.vci.starter.revision.service.RevisionModelUtil; import com.vci.starter.web.constant.QueryOptionConstant; import com.vci.starter.web.exception.VciBaseException; import com.vci.starter.web.pagemodel.BaseResult; import com.vci.starter.web.pagemodel.DataGrid; import com.vci.starter.web.pagemodel.PageHelper; import com.vci.starter.web.util.BeanUtil; import com.vci.starter.web.util.BeanUtilForVCI; import com.vci.starter.web.util.VciBaseUtil; import com.vci.web.pageModel.BatchCBO; import com.vci.web.service.WebBoServiceI; import com.vci.web.util.WebUtil; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.vci.ubcs.code.dto.CodeTemplatePhaseDTO; import com.vci.ubcs.code.vo.pagemodel.CodeClassifyTemplateAttrVO; import com.vci.ubcs.code.vo.pagemodel.CodeTemplatePhaseVO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.util.*; import java.util.stream.Collectors; import static com.vci.frameworkcore.constant.FrameWorkLangCodeConstant.*; /** * 模板阶段服务 * @author weidy * @date 2022-01-24 */ @Service public class CodeTemplatePhaseServiceImpl implements CodeTemplatePhaseServiceI { /** * 日志 */ private Logger logger = LoggerFactory.getLogger(getClass()); /** * 数据操作层 */ @Resource private CodeTemplatePhaseMapper codeTemplatePhaseMapper; /** * 模板属性的服务 */ @Autowired @Lazy private CodeClassifyTemplateAttrServiceI tempAttrService; /** * 业务类型操作的服务 */ @Autowired @Lazy private WebBoServiceI boService; /** * 对象的操作 */ @Autowired private RevisionModelUtil revisionModelUtil; /** * 阶段的属性 */ @Autowired private CodePhaseAttrServiceI phaseAttrService; /** * 数据操作层 */ @Resource private CodePhaseAttrMapper codePhaseAttrMapper; /** * 查询所有的模板阶段 * @param conditionMap 查询条件 * @param pageHelper 分页和排序 * @return 执行结果 * @throws VciBaseException 查询条件和分页出错的时候会抛出异常 */ @Override public DataGrid gridCodeTemplatePhase(Map conditionMap, PageHelper pageHelper) throws VciBaseException{ if (pageHelper == null) { pageHelper = new PageHelper(-1); } pageHelper.addDefaultDesc("createTime"); List doList = codeTemplatePhaseMapper.selectByCondition(conditionMap,pageHelper); DataGrid dataGrid=new DataGrid(); if (!CollectionUtils.isEmpty(doList)) { dataGrid.setData(codeTemplatePhaseDO2VOs(doList)); dataGrid.setTotal(VciBaseUtil.getInt(String.valueOf(codeTemplatePhaseMapper.countByCondition(conditionMap)))); } return dataGrid; } /** * 批量数据对象转换为显示对象 * @param codeTemplatePhaseDOs 数据对象列表 * @return 显示对象 * @throws VciBaseException 参数为空或者不存在的时候会抛出异常 */ @Override public List codeTemplatePhaseDO2VOs(Collection codeTemplatePhaseDOs) throws VciBaseException{ List voList = new ArrayList(); if(!CollectionUtils.isEmpty(codeTemplatePhaseDOs)){ for(CodeTemplatePhaseDO s: codeTemplatePhaseDOs){ CodeTemplatePhaseVO vo = codeTemplatePhaseDO2VO(s); if(vo != null){ voList.add(vo); } } } return voList; } /** * 数据对象转换为显示对象 * @param codeTemplatePhaseDO 数据对象 * @return 显示对象 * @throws VciBaseException 拷贝属性出错的时候会抛出异常 */ @Override public CodeTemplatePhaseVO codeTemplatePhaseDO2VO(CodeTemplatePhaseDO codeTemplatePhaseDO) throws VciBaseException{ CodeTemplatePhaseVO vo = new CodeTemplatePhaseVO(); if(codeTemplatePhaseDO != null){ BeanUtilForVCI.copyPropertiesIgnoreCase(codeTemplatePhaseDO,vo); //如果有lcstatus的类的话 } return vo; } /** * 增加模板阶段 * @param codeTemplatePhaseDTO 模板阶段数据传输对象 * @return 执行结果 * @throws VciBaseException 参数为空，唯一项，必输项不通过时会抛出异常 */ @Override public CodeTemplatePhaseVO addSave(CodeTemplatePhaseDTO codeTemplatePhaseDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(codeTemplatePhaseDTO,"需要添加的数据对象",codeTemplatePhaseDTO.getAttributes(),"包含的属性"); //将DTO转换为DO CodeTemplatePhaseDO codeTemplatePhaseDO = new CodeTemplatePhaseDO(); codeTemplatePhaseDO.setOid(VciBaseUtil.getPk()); BeanUtilForVCI.copyPropertiesIgnoreCase(codeTemplatePhaseDTO,codeTemplatePhaseDO); WebUtil.setPersistence(false); BatchCBO batchCBO = codeTemplatePhaseMapper.insert(codeTemplatePhaseDO); List attrDOList = new ArrayList<>(); codeTemplatePhaseDTO.getAttributes().stream().forEach(attrDTO->{ CodePhaseAttrDO attrDO = new CodePhaseAttrDO(); BeanUtilForVCI.copyPropertiesIgnoreCase(attrDTO,attrDO); attrDO.setOid(VciBaseUtil.getPk()); attrDO.setCodePhaseOid(codeTemplatePhaseDO.getOid()); attrDOList.add(attrDO); }); BatchCBO attrCBO = codePhaseAttrMapper.batchInsert(attrDOList); batchCBO.copyFromOther(attrCBO); WebUtil.setPersistence(true); boService.persistenceBatch(batchCBO); return codeTemplatePhaseDO2VO(codeTemplatePhaseDO); } /** * 修改模板阶段 * @param codeTemplatePhaseDTO 模板阶段数据传输对象 * @return 执行结果 * @throws VciBaseException 参数为空，唯一项，必输项不通过时会抛出异常 */ @Override public CodeTemplatePhaseVO editSave(CodeTemplatePhaseDTO codeTemplatePhaseDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(codeTemplatePhaseDTO,"数据对象",codeTemplatePhaseDTO.getOid(),"模板阶段主键",codeTemplatePhaseDTO.getAttributes(),"包含的属性"); //将DTO转换为DO CodeTemplatePhaseDO codeTemplatePhaseDO = selectByOid(codeTemplatePhaseDTO.getOid()); revisionModelUtil.copyFromDTOIgnore(codeTemplatePhaseDTO,codeTemplatePhaseDO); WebUtil.setPersistence(false); BatchCBO batchCBO = codeTemplatePhaseMapper.updateByPrimaryKey(codeTemplatePhaseDO); //把以前的删除 List phaseAttrDOS = listPhaseAttrDOByPhaseOid(codeTemplatePhaseDO.getOid()); if(!CollectionUtils.isEmpty(phaseAttrDOS)){ BatchCBO delCBO = codePhaseAttrMapper.batchDeleteByOids(phaseAttrDOS.stream().map(CodePhaseAttrDO::getOid).collect(Collectors.toList())); batchCBO.copyFromOther(delCBO); } List attrDOList = new ArrayList<>(); codeTemplatePhaseDTO.getAttributes().stream().forEach(attrDTO->{ CodePhaseAttrDO attrDO = new CodePhaseAttrDO(); BeanUtilForVCI.copyPropertiesIgnoreCase(attrDTO,attrDO); attrDO.setOid(VciBaseUtil.getPk()); attrDO.setCodePhaseOid(codeTemplatePhaseDO.getOid()); attrDOList.add(attrDO); }); BatchCBO attrCBO = codePhaseAttrMapper.batchInsert(attrDOList); batchCBO.copyFromOther(attrCBO); WebUtil.setPersistence(true); boService.persistenceBatch(batchCBO); return codeTemplatePhaseDO2VO(codeTemplatePhaseDO); } /** * 使用阶段主键获取包含的属性 * @param codePhaseOid 阶段的主键 * @return 包含属性的数据对象 */ private List listPhaseAttrDOByPhaseOid(String codePhaseOid){ Map conditionMap = new HashMap<>(); conditionMap.put("codePhaseOid",codePhaseOid); List phaseAttrDOS = codePhaseAttrMapper.selectByCondition(conditionMap, new PageHelper(-1)); return phaseAttrDOS; } /** * 校验是否可以删除，如果存在下级，并且下级有数据引用则不能删除 * @param codeTemplatePhaseDTO 数据传输对象 * @param codeTemplatePhaseDO 数据库中的数据对象 * @return success为true为可以删除，false表示有数据引用，obj为true表示有下级 */ private BaseResult checkIsCanDeleteForDO(CodeTemplatePhaseDTO codeTemplatePhaseDTO, CodeTemplatePhaseDO codeTemplatePhaseDO) { CodeTemplatePhaseDO tsDO = new CodeTemplatePhaseDO(); BeanUtil.convert(codeTemplatePhaseDTO,tsDO); boService.checkTs(tsDO); if(!checkIsLinked(codeTemplatePhaseDO.getOid())) { return BaseResult.success(); }else{ return BaseResult.fail(DATA_LINKED_NOT_DELETE,new String[]{""}); } } /** * 校验是否被引用 * @param oid 主键 * @throws VciBaseException 被引用的时候会抛出异常 */ private boolean checkIsLinked(String oid) throws VciBaseException{ //TODO 添加需要校验引用的地方 return false; } /** * 删除模板阶段 * @param codeTemplatePhaseDTO 模板阶段数据传输对象，oid和ts需要传输 * @return 删除结果反馈：：success：成功，fail：失败 * @throws VciBaseException 参数为空，被引用时抛出异常 */ @Override public BaseResult deleteCodeTemplatePhase(CodeTemplatePhaseDTO codeTemplatePhaseDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(codeTemplatePhaseDTO,"模板阶段数据对象",codeTemplatePhaseDTO.getOid(),"模板阶段的主键"); CodeTemplatePhaseDO codeTemplatePhaseDO = selectByOid(codeTemplatePhaseDTO.getOid()); BaseResult baseResult = checkIsCanDeleteForDO(codeTemplatePhaseDTO,codeTemplatePhaseDO); if(baseResult.isSuccess()) { }else{ return baseResult; } //执行删除操作 WebUtil.setPersistence(false); BatchCBO batchCBO = codeTemplatePhaseMapper.deleteByPrimaryKey(codeTemplatePhaseDO.getOid()); //需要删除属性 List phaseAttrDOS = listPhaseAttrDOByPhaseOid(codeTemplatePhaseDO.getOid()); if(!CollectionUtils.isEmpty(phaseAttrDOS)) { BatchCBO deleteCBO = codePhaseAttrMapper.batchDeleteByOids(phaseAttrDOS.stream().map(CodePhaseAttrDO::getOid).collect(Collectors.toList())); batchCBO.copyFromOther(deleteCBO); } WebUtil.setPersistence(true); boService.persistenceBatch(batchCBO); return (batchCBO!=null && batchCBO.getDeleteCbos() !=null &&batchCBO.getDeleteCbos().size() > 0)?BaseResult.successMsg(DELETE_SUCCESS):BaseResult.fail(DELETE_FAIL); } /** * 模板修改触发功能 * @param attrDOList 属性的数据对象 * @return 受影响的数据 */ @Override public BatchCBO codeTemplateAttrModifyTrigger(List attrDOList){ //属性修改的时候，需要同步修改对应属性的名称 BatchCBO batchCBO = new BatchCBO(); List phaseAttrDOS =listLinkAttrDOByTemplateAttrDOS(attrDOList); if(!CollectionUtils.isEmpty(phaseAttrDOS)){ //说明有属性,我们去替换一下 Map attrDOMap = attrDOList.stream().collect(Collectors.toMap(s -> s.getId(), t -> t)); phaseAttrDOS.stream().forEach(phaseAttrDO->{ if(attrDOMap.containsKey(phaseAttrDO.getId())){ CodeClassifyTemplateAttrDO attrDO = attrDOMap.get(phaseAttrDO.getId()); phaseAttrDO.setId(attrDO.getId()); phaseAttrDO.setName(attrDO.getName()); phaseAttrDO.setAttributeGroup(attrDO.getAttributeGroup()); } }); BatchCBO updateCBO = codePhaseAttrMapper.batchUpdate(phaseAttrDOS); batchCBO.copyFromOther(updateCBO); } return batchCBO; } /** * 使用模板的属性获取阶段中包含的属性内容 * @param attrDOList 属性的数据对象 * @return 阶段里的属性数据对象 */ private List listLinkAttrDOByTemplateAttrDOS(List attrDOList){ if(!CollectionUtils.isEmpty(attrDOList)) { //查询这个模板里包含的所有阶段的这些属性 //因为oracle里表的字段不能超过1000个，所以我们这里默认属性个数是小于1000的； Map conditionMap = new HashMap<>(); conditionMap.put("codePhaseOid", QueryOptionConstant.IN + "(select oid from " + getPhaseTable() + " where codeClassifyTemplateOid='" + attrDOList.get(0).getClassifyTemplateOid() + "')"); conditionMap.put("id", QueryOptionConstant.IN + "(" + VciBaseUtil.toInSql(attrDOList.stream().map(CodeClassifyTemplateAttrDO::getId).collect(Collectors.toList()).toArray(new String[0])) + ")"); return codePhaseAttrMapper.selectByCondition(conditionMap, new PageHelper(-1)); }else{ return new ArrayList<>(); } } /** * 阶段的表名 * @return 表名 */ private String getPhaseTable(){ return VciBaseUtil.getTableName(MdmBtmTypeConstant.CODE_TEMPLATE_PHASE); } /** * 阶段属性的表名 * @return 表名 */ private String getPhaseAttrTable(){ return VciBaseUtil.getTableName(MdmBtmTypeConstant.CODE_PHASE_ATTR); } /** * 模板属性删除的时候触发 * @param attrDOList 属性的数据对象 * @return 受影响的数据 */ @Override public BatchCBO codeTemplateAttrDeleteTrigger(List attrDOList){ BatchCBO batchCBO = new BatchCBO(); List phaseAttrDOS =listLinkAttrDOByTemplateAttrDOS(attrDOList); if(!CollectionUtils.isEmpty(phaseAttrDOS)){ //属性被删除的时候，阶段里面也一样要被删除 batchCBO.copyFromOther(codePhaseAttrMapper.batchDeleteByOids(phaseAttrDOS.stream().map(CodePhaseAttrDO::getOid).collect(Collectors.toList()))); } return batchCBO; } /** * 模板删除的时候触发 * * @param classifyTemplateOid 模板的主键 * @return 受影响的数据 */ @Override public BatchCBO codeTemplateDeleteTrigger(String classifyTemplateOid) { BatchCBO batchCBO = new BatchCBO(); Map conditionMap = new HashMap<>(); conditionMap.put("codeClassifyTemplateOid",classifyTemplateOid); List templatePhaseDOS = codeTemplatePhaseMapper.selectByCondition(conditionMap, new PageHelper(-1)); conditionMap.clear(); if(!CollectionUtils.isEmpty(templatePhaseDOS)) { batchCBO.copyFromOther(codeTemplatePhaseMapper.batchDeleteByOids(templatePhaseDOS.stream().map(CodeTemplatePhaseDO::getOid).collect(Collectors.toList()))); conditionMap.put("codePhaseOid", QueryOptionConstant.IN + "(select oid from " + getPhaseTable() + " where codeClassifyTemplateOid='" + classifyTemplateOid + "')"); List phaseAttrDOS = codePhaseAttrMapper.selectByCondition(conditionMap, new PageHelper(-1)); if(!CollectionUtils.isEmpty(phaseAttrDOS)){ batchCBO.copyFromOther(codePhaseAttrMapper.batchDeleteByOids(phaseAttrDOS.stream().map(CodePhaseAttrDO::getOid).collect(Collectors.toList()))); } } return batchCBO; } /** * 主键获取模板阶段 * @param oid 主键 * @return 模板阶段显示对象 * @throws VciBaseException 参数为空，数据不存在时会抛出异常 */ @Override public CodeTemplatePhaseVO getObjectByOid(String oid) throws VciBaseException{ return codeTemplatePhaseDO2VO(selectByOid(oid)); } /** * 主键查询数据对象 * @param oid 主键 * @return 数据对象 * @throws VciBaseException 参数为空，并且数据不存在的时候会抛出异常 */ private CodeTemplatePhaseDO selectByOid(String oid) throws VciBaseException{ VciBaseUtil.alertNotNull(oid,"主键"); CodeTemplatePhaseDO codeTemplatePhaseDO = codeTemplatePhaseMapper.selectByPrimaryKey(oid.trim()); if(codeTemplatePhaseDO == null || StringUtils.isBlank(codeTemplatePhaseDO.getOid())){ throw new VciBaseException(DATA_OID_NOT_EXIST); } return codeTemplatePhaseDO; } /** * 主键批量获取模板阶段 * @param oidCollections 主键集合，但是受性能影响，建议一次查询不超过10000个 * @return 模板阶段显示对象 * @throws VciBaseException 查询出现异常时会抛出 */ @Override public Collection listCodeTemplatePhaseByOids(Collection oidCollections) throws VciBaseException{ VciBaseUtil.alertNotNull(oidCollections,"数据对象主键集合"); List codeTemplatePhaseDOList = listCodeTemplatePhaseDOByOidCollections(oidCollections); return codeTemplatePhaseDO2VOs(codeTemplatePhaseDOList); } /** * 使用主键集合查询数据对象 * @param oidCollections 主键的集合 * @return 数据对象列表 */ private List listCodeTemplatePhaseDOByOidCollections(Collection oidCollections){ List codeTemplatePhaseDOList = new ArrayList(); if(!CollectionUtils.isEmpty(oidCollections)){ Collection> oidCollectionsList = VciBaseUtil.switchCollectionForOracleIn(oidCollections); for(Collection oids: oidCollectionsList){ List tempDOList = codeTemplatePhaseMapper.selectByPrimaryKeyCollection(oids); if(!CollectionUtils.isEmpty(tempDOList)){ codeTemplatePhaseDOList.addAll(tempDOList); } } } return codeTemplatePhaseDOList; } /** * 参照模板阶段列表 * @param conditionMap 查询条件 * @param pageHelper 分页和排序 * @return 模板阶段显示对象列表，生效的内容 * @throws VciBaseException 查询条件和分页出错的时候会抛出异常 */ @Override public DataGrid refDataGridCodeTemplatePhase(Map conditionMap, PageHelper pageHelper) throws VciBaseException{ if(conditionMap == null){ conditionMap = new HashMap(); } return gridCodeTemplatePhase(conditionMap,pageHelper); } /** * 阶段不包含的属性 * * @param conditionMap 查询对象，必须要有模板的主键（classifyTemplateOid），否则不能确定属性 * @param pageHelper 分页对象 * @return 属性的信息 */ @Override public DataGrid gridUnUsedAttribute(Map conditionMap, PageHelper pageHelper) { if(conditionMap == null){ conditionMap = new HashMap(); } if(!conditionMap.containsKey("classifyTemplateOid")){ return new DataGrid<>("没有模板的主键"); } //需要判断阶段的主键是否存在 String codePhaseOid = conditionMap.getOrDefault("codePhaseOid", null); if(StringUtils.isNotBlank(codePhaseOid)){ //排除阶段上使用的 conditionMap.remove("codePhaseOid"); conditionMap.put("id", QueryOptionConstant.NOTIN + "(select id from " + getPhaseAttrTable() + " where codePhaseOid ='" +codePhaseOid + "')"); } return tempAttrService.gridCodeClassifyTemplateAttr(conditionMap,pageHelper); } /** * 阶段包含的属性 * * @param conditionMap 查询对象，必须要阶段的主键(codePhaseOid) * @param pageHelper 分页对象 * @return 属性的信息 */ @Override public DataGrid gridUsedAttribute(Map conditionMap, PageHelper pageHelper) { if(conditionMap == null){ conditionMap = new HashMap(); } String codePhaseOid = conditionMap.getOrDefault("codePhaseOid", null); if(StringUtils.isBlank(codePhaseOid)){ return new DataGrid<>(); } conditionMap.remove("codePhaseOid"); CodeTemplatePhaseDO phaseDO = selectByOid(codePhaseOid); conditionMap.put("id",QueryOptionConstant.IN + "(select id from " + getPhaseAttrTable() + " where codePhaseOid ='" +codePhaseOid + "')"); conditionMap.put("classifyTemplateOid",phaseDO.getCodeClassifyTemplateOid()); return tempAttrService.gridCodeClassifyTemplateAttr(conditionMap,pageHelper); } }