From 1b8120cacac0037fcb1f8ae747c2f54eb735368b Mon Sep 17 00:00:00 2001 From: ludc Date: 星期二, 09 五月 2023 18:50:51 +0800 Subject: [PATCH] 代码整合 --- Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyProcessTempServiceImpl.java | 68 +++++++++++++++++---------------- 1 files changed, 35 insertions(+), 33 deletions(-) diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyProcessTempServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyProcessTempServiceImpl.java index b1a1ecd..1a3647e 100644 --- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyProcessTempServiceImpl.java +++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeClassifyProcessTempServiceImpl.java @@ -2,27 +2,27 @@ import com.alibaba.cloud.commons.lang.StringUtils; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; -import com.baomidou.mybatisplus.extension.service.IService; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.core.JsonParser; +import com.vci.ubcs.code.constant.MdmBtmTypeConstant; import com.vci.ubcs.code.dto.CodeClassifyProcessTempDTO; -import com.vci.ubcs.code.entity.CodeClassify; import com.vci.ubcs.code.entity.CodeClassifyProcessTemp; -import com.vci.ubcs.code.mapper.CodeClassifyMapper; import com.vci.ubcs.code.mapper.CodeClassifyProcessTempMapper; -import com.vci.ubcs.code.mapper.CodeClassifyTemplateAttrMapper; import com.vci.ubcs.code.service.ICodeClassifyProcessTempService; import com.vci.ubcs.code.vo.pagemodel.CodeClassifyProcessTempVO; +import com.vci.ubcs.code.wrapper.CodeClassifyProcessTempWrapper; +import com.vci.ubcs.common.utils.PageDO2PageVO; import com.vci.ubcs.starter.exception.VciBaseException; import com.vci.ubcs.starter.revision.service.RevisionModelUtil; -import com.vci.ubcs.starter.web.pagemodel.DataGrid; +import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil; import com.vci.ubcs.starter.web.pagemodel.PageHelper; import com.vci.ubcs.starter.web.util.BeanUtil; import com.vci.ubcs.starter.web.util.BeanUtilForVCI; import com.vci.ubcs.starter.web.util.VciBaseUtil; -import com.vci.ubcs.starter.web.wrapper.VciQueryWrapperForDO; import org.springblade.core.mp.support.Condition; import org.springblade.core.mp.support.Query; import org.springblade.core.tool.api.R; @@ -34,9 +34,11 @@ import javax.annotation.Resource; import java.sql.Wrapper; +import java.text.SimpleDateFormat; import java.util.*; import static com.vci.ubcs.code.constant.FrameWorkLangCodeConstant.*; +import static com.vci.ubcs.code.constant.MdmBtmTypeConstant.CODE_CLASSIFY_PROCESS_TEMPLATE; /** * 鍒嗙被浣跨敤鐨勬祦绋嬫ā鏉挎湇鍔℃帴鍙� @@ -59,7 +61,6 @@ @Autowired private RevisionModelUtil revisionModelUtil; - /** * 鏌ヨ鎵�鏈夌殑鍒嗙被浣跨敤鐨勬祦绋嬫ā鏉� * @param conditionMap 鏌ヨ鏉′欢 @@ -68,10 +69,10 @@ * @throws VciBaseException 鏌ヨ鏉′欢鍜屽垎椤靛嚭閿欑殑鏃跺�欎細鎶涘嚭寮傚父 */ @Override - public DataGrid<CodeClassifyProcessTempVO> gridCodeClassifyProcessTemp(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException { + public IPage<CodeClassifyProcessTempVO> gridCodeClassifyProcessTemp(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException { Query query = new Query(); if (pageHelper == null) { - pageHelper = new PageHelper(-1); + //pageHelper = new PageHelper(-1); query.setSize(-1); }else { query.setSize(pageHelper.getLimit()); @@ -81,14 +82,15 @@ CodeClassifyProcessTemp codeClassifyProcessTemp = new CodeClassifyProcessTemp(); BeanMap beanMap = BeanMap.create(codeClassifyProcessTemp); beanMap.putAll(conditionMap); - IPage<CodeClassifyProcessTemp> doList = codeClassifyProcessTempMapper.selectPage(Condition.getPage(query), Condition.getQueryWrapper(codeClassifyProcessTemp)); - DataGrid<CodeClassifyProcessTempVO> dataGrid=new DataGrid<>(); + IPage<CodeClassifyProcessTempVO> voList = new Page<CodeClassifyProcessTempVO>(); + //DataGrid<CodeClassifyProcessTempVO> dataGrid=new DataGrid<>(); if (!CollectionUtils.isEmpty(doList.getRecords())) { - dataGrid.setData(codeClassifyProcessTempDO2VOs(doList.getRecords())); - dataGrid.setTotal(VciBaseUtil.getInt(String.valueOf(codeClassifyProcessTempMapper.selectCount(Condition.getQueryWrapper(codeClassifyProcessTemp))))); + voList.setRecords(CodeClassifyProcessTempWrapper.build().listVO(doList.getRecords())); + //鍒嗛〉鍙傛暟杞埌pageVO瀵硅薄 + voList = PageDO2PageVO.pageDO2PageVO(doList,voList); } - return dataGrid; + return voList; } /** @@ -137,8 +139,8 @@ @Override @Transactional(rollbackFor = Exception.class) public CodeClassifyProcessTempVO addSave(CodeClassifyProcessTempDTO codeClassifyProcessTempDTO) throws VciBaseException{ - VciBaseUtil.alertNotNull(codeClassifyProcessTempDTO,"闇�瑕佹坊鍔犵殑鏁版嵁瀵硅薄",codeClassifyProcessTempDTO.getProcessVersion(),"娴佺▼妯℃澘鐨勭増鏈彿",codeClassifyProcessTempDTO.getCodeprocessuse(),"妯℃澘娴佺▼鐨勭敤閫�"); - if (StringUtils.isBlank(codeClassifyProcessTempDTO.getCodeprocessuse())){ + VciBaseUtil.alertNotNull(codeClassifyProcessTempDTO,"闇�瑕佹坊鍔犵殑鏁版嵁瀵硅薄",codeClassifyProcessTempDTO.getProcessVersion(),"娴佺▼妯℃澘鐨勭増鏈彿",codeClassifyProcessTempDTO.getCodeProcessUse(),"妯℃澘娴佺▼鐨勭敤閫�"); + if (StringUtils.isBlank(codeClassifyProcessTempDTO.getCodeProcessUse())){ throw new VciBaseException("妯℃澘娴佺▼鐢ㄩ�斾笉鑳戒负绌�"); } Long count = countProcessTemplate(codeClassifyProcessTempDTO); @@ -148,10 +150,11 @@ //灏咲TO杞崲涓篋O CodeClassifyProcessTemp codeClassifyProcessTempDO = new CodeClassifyProcessTemp(); BeanUtilForVCI.copyPropertiesIgnoreCase(codeClassifyProcessTempDTO,codeClassifyProcessTempDO); + DefaultAttrAssimtUtil.addDefaultAttrAssimt(codeClassifyProcessTempDO, MdmBtmTypeConstant.CODE_CLASSIFY_PROCESS_TEMPLATE); codeClassifyProcessTempMapper.insert(codeClassifyProcessTempDO); //鍥犱负涓氬姟绫诲瀷鏈韩娌℃湁鎺у埗鐗堟湰锛屾墍鏈夊己鍒剁粰鐗堟湰revisionValue璁剧疆鍊硷紝骞冲彴涔熶細鍙樻垚绌恒�傘�傘�傘�� //鐗堟湰鍙蜂笉鑳戒娇鐢ㄩ粯璁ょ殑灞炴�� - return codeClassifyProcessTempDO2VO(codeClassifyProcessTempDO); + return CodeClassifyProcessTempWrapper.build().entityVO(codeClassifyProcessTempDO); } /** @@ -167,8 +170,9 @@ //灏咲TO杞崲涓篋O CodeClassifyProcessTemp codeClassifyProcessTempDO = selectByOid(codeClassifyProcessTempDTO.getOid()); revisionModelUtil.copyFromDTOIgnore(codeClassifyProcessTempDTO,codeClassifyProcessTempDO); + DefaultAttrAssimtUtil.updateDefaultAttrAssimt(codeClassifyProcessTempDO); codeClassifyProcessTempMapper.updateById(codeClassifyProcessTempDO); - return codeClassifyProcessTempDO2VO(codeClassifyProcessTempDO); + return CodeClassifyProcessTempWrapper.build().entityVO(codeClassifyProcessTempDO); } /** @@ -183,7 +187,7 @@ VciBaseUtil.alertNotNull(codeClassifyProcessTempDTO,"鍒嗙被浣跨敤鐨勬祦绋嬫ā鏉挎暟鎹璞�",codeClassifyProcessTempDTO.getOid(),"鍒嗙被浣跨敤鐨勬祦绋嬫ā鏉跨殑涓婚敭"); CodeClassifyProcessTemp codeClassifyProcessTempDO = selectByOid(codeClassifyProcessTempDTO.getOid()); R baseResult = checkIsCanDeleteForDO(codeClassifyProcessTempDTO,codeClassifyProcessTempDO); - if(!baseResult.isSuccess()) { + if(baseResult.isSuccess()) { }else{ return baseResult; } @@ -200,7 +204,7 @@ */ @Override public CodeClassifyProcessTempVO getObjectByOid(String oid) throws VciBaseException{ - return codeClassifyProcessTempDO2VO(selectByOid(oid)); + return CodeClassifyProcessTempWrapper.build().entityVO((selectByOid(oid))); } /** @@ -213,7 +217,7 @@ public Collection<CodeClassifyProcessTempVO> listCodeClassifyProcessTempByOids(Collection<String> oidCollections) throws VciBaseException{ VciBaseUtil.alertNotNull(oidCollections,"鏁版嵁瀵硅薄涓婚敭闆嗗悎"); List<CodeClassifyProcessTemp> codeClassifyProcessTempDOList = listCodeClassifyProcessTempDOByOidCollections(oidCollections); - return codeClassifyProcessTempDO2VOs(codeClassifyProcessTempDOList); + return CodeClassifyProcessTempWrapper.build().listVO(codeClassifyProcessTempDOList); } /** @@ -224,7 +228,7 @@ * @throws VciBaseException 鏌ヨ鏉′欢鍜屽垎椤靛嚭閿欑殑鏃跺�欎細鎶涘嚭寮傚父 */ @Override - public DataGrid<CodeClassifyProcessTempVO> refDataGridCodeClassifyProcessTemp(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException{ + public IPage<CodeClassifyProcessTempVO> refDataGridCodeClassifyProcessTemp(Map<String, String> conditionMap, PageHelper pageHelper) throws VciBaseException{ if(conditionMap == null){ conditionMap = new HashMap<String, String>(); } @@ -250,7 +254,7 @@ LambdaQueryWrapper<CodeClassifyProcessTemp> wrapper = Wrappers.<CodeClassifyProcessTemp>query() .lambda().eq(CodeClassifyProcessTemp::getClassifyTemplateOid, codeTemplateOid) .eq(CodeClassifyProcessTemp::getCodeProcessUse, processUse); - return codeClassifyProcessTempDO2VOs(codeClassifyProcessTempMapper.selectList(wrapper)); + return CodeClassifyProcessTempWrapper.build().listVO(codeClassifyProcessTempMapper.selectList(wrapper)); } /** @@ -261,7 +265,7 @@ @Override public List<CodeClassifyProcessTempVO> selectByWrapper(LambdaQueryWrapper<CodeClassifyProcessTemp> queryWrapper) { List<CodeClassifyProcessTemp> codeClassifyProcessTempDOList= codeClassifyProcessTempMapper.selectList(queryWrapper); - return codeClassifyProcessTempDO2VOs(codeClassifyProcessTempDOList); + return CodeClassifyProcessTempWrapper.build().listVO(codeClassifyProcessTempDOList); } /** @@ -293,7 +297,7 @@ private R checkIsCanDeleteForDO(CodeClassifyProcessTempDTO codeClassifyProcessTempDTO, CodeClassifyProcessTemp codeClassifyProcessTempDO) { CodeClassifyProcessTemp tempDO = new CodeClassifyProcessTemp(); BeanUtil.convert(codeClassifyProcessTempDTO,tempDO); - if (!checkTs(tempDO)) { + if (!checkTs(tempDO,codeClassifyProcessTempDO)) { return R.fail(TS_NOT_PROCESS); } if(!checkIsLinked(codeClassifyProcessTempDO.getOid())) { @@ -308,12 +312,10 @@ * @param tempDO * @return */ - private boolean checkTs(CodeClassifyProcessTemp tempDO){ - LambdaQueryWrapper<CodeClassifyProcessTemp> wrapper = Wrappers.<CodeClassifyProcessTemp>query() - .lambda().eq(CodeClassifyProcessTemp::getOid,tempDO.getOid()).select(CodeClassifyProcessTemp::getTs); - long dbTs = codeClassifyProcessTempMapper.selectById(wrapper).getTs().getTime(); - long currentTs = tempDO.getTs().getTime(); - if(dbTs == currentTs){ + private boolean checkTs(CodeClassifyProcessTemp tempDO, CodeClassifyProcessTemp codeClassifyProcessTempDO){ + Date dbTs = codeClassifyProcessTempDO.getTs(); + Date currentTs = tempDO.getTs(); + if(currentTs == null ? dbTs == null:currentTs.compareTo(dbTs)==0){ return true; } return false; @@ -355,7 +357,7 @@ throw new VciBaseException("妯℃澘娴佺▼鍚嶇О涓嶈兘涓虹┖"); } LambdaQueryWrapper<CodeClassifyProcessTemp> wrapper = Wrappers.<CodeClassifyProcessTemp>query() - .lambda().eq(CodeClassifyProcessTemp::getCodeProcessUse, codeClassifyProcessTempDTO.getCodeprocessuse()) + .lambda().eq(CodeClassifyProcessTemp::getCodeProcessUse, codeClassifyProcessTempDTO.getCodeProcessUse()) .eq(CodeClassifyProcessTemp::getClassifyTemplateOid, codeClassifyProcessTempDTO.getClassifyTemplateOid()) .eq(CodeClassifyProcessTemp::getId, codeClassifyProcessTempDTO.getId()); Long count = codeClassifyProcessTempMapper.selectCount(wrapper); -- Gitblit v1.9.3