From d7a83f1396425c4e47da9b95f287b26cd5bb3344 Mon Sep 17 00:00:00 2001
From: ludc
Date: 星期三, 12 四月 2023 10:18:53 +0800
Subject: [PATCH] 后端代码整合
---
Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeRuleServiceImpl.java | 222 +++++++++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 206 insertions(+), 16 deletions(-)
diff --git a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeRuleServiceImpl.java b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeRuleServiceImpl.java
index 0366b45..ec1607b 100644
--- a/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeRuleServiceImpl.java
+++ b/Source/UBCS/ubcs-service/ubcs-code/src/main/java/com/vci/ubcs/code/service/impl/CodeRuleServiceImpl.java
@@ -17,16 +17,18 @@
package com.vci.ubcs.code.service.impl;
import com.alibaba.cloud.commons.lang.StringUtils;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
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.code.dto.CodeBasicSecDTO;
import com.vci.ubcs.code.dto.CodeRuleDTO;
-import com.vci.ubcs.code.entity.CodeAllCode;
-import com.vci.ubcs.code.entity.CodeClassify;
-import com.vci.ubcs.code.entity.CodeRule;
+import com.vci.ubcs.code.entity.*;
import com.vci.ubcs.code.lifecycle.CodeRuleLC;
import com.vci.ubcs.code.mapper.CodeRuleMapper;
-import com.vci.ubcs.code.service.ICodeAllcodeService;
+import com.vci.ubcs.code.mapper.CodeSerialValueMapper;
+import com.vci.ubcs.code.mapper.CommonsMapper;
+import com.vci.ubcs.code.service.ICodeAllCodeService;
import com.vci.ubcs.code.service.ICodeBasicSecService;
import com.vci.ubcs.code.service.ICodeClassifyService;
import com.vci.ubcs.code.service.ICodeRuleService;
@@ -36,19 +38,21 @@
import com.vci.ubcs.code.wrapper.CodeRuleWrapper;
import com.vci.ubcs.com.vci.starter.exception.VciBaseException;
import com.vci.ubcs.com.vci.starter.revision.service.RevisionModelUtil;
+import com.vci.ubcs.com.vci.starter.web.pagemodel.KeyValue;
+import com.vci.ubcs.com.vci.starter.web.util.BeanUtilForVCI;
import com.vci.ubcs.com.vci.starter.web.util.VciBaseUtil;
+import com.vci.ubcs.com.vci.starter.web.util.WebUtil;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.BeanUtil;
+import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import javax.annotation.Resource;
-import java.util.Collection;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
+import java.util.*;
+import java.util.stream.Collectors;
import static com.vci.ubcs.code.constant.FrameWorkDefaultValueConstant.FRAMEWORK_RELEASE_EDITING;
import static com.vci.ubcs.code.constant.FrameWorkLangCodeConstant.DATA_OID_NOT_EXIST;
@@ -68,13 +72,19 @@
*/
@Resource
private CodeRuleMapper codeRuleMapper;
-
@Resource
+ private CommonsMapper commonsMapper;
+ @Resource
+ private CodeSerialValueMapper codeSerialValueMapper;
+
+ /**
+ * 鍏朵粬鏈嶅姟灞�
+ */
+ @Resource
+ @Lazy
private ICodeClassifyService codeClassifyServcie;
-
@Resource
- private ICodeAllcodeService codeAllcodeService;
-
+ private ICodeAllCodeService codeAllcodeService;
@Resource
private ICodeBasicSecService codeBasicSecService;
@@ -85,7 +95,7 @@
private RevisionModelUtil revisionModelUtil;
@Override
- public IPage<CodeRuleVO> selectPlCodeRulePage(IPage<CodeRuleVO> page, CodeRuleVO codeRule) {
+ public IPage<CodeRuleVO> gridCodeRule(IPage<CodeRuleVO> page, CodeRuleVO codeRule) {
//瀵圭敓鍛藉懆鏈熺殑鏋氫妇杩涜杞崲
if(!StringUtils.isEmpty(codeRule.getLcStatusText())){
codeRule.setLcStatus(CodeRuleLC.getValueByText(codeRule.getLcStatusText()));
@@ -183,16 +193,62 @@
}
}
- List<CodeAllCode> codeDOList = codeAllcodeService.selectByWrapper(Wrappers.<CodeAllCode>query().eq("codeRuleOid", codeRuleDTO.getOid()));
+ List<CodeAllCode> codeDOList = codeAllcodeService.selectByWrapper(Wrappers.<CodeAllCode>query().lambda().eq(CodeAllCode::getCodeRuleOid, codeRuleDTO.getOid()));
if (!CollectionUtils.isEmpty(codeDOList)) {
return R.fail("缂栫爜瑙勫垯宸茬敓鎴愮紪鐮侊紝涓嶅厑璁稿垹闄�");
}
//鎵ц鍒犻櫎鎿嶄綔
//WebUtil.setPersistence(false);
boolean resBoolean = codeBasicSecService.batchDeleteSecByCodeRuleOid(codeRule.getOid());
- resBoolean = codeRuleMapper.deleteById(codeRule.getOid())>0;
+ boolean resBoolean1 = codeRuleMapper.deleteById(codeRule.getOid()) > 0;
//WebUtil.setPersistence(true);
- return R.status(resBoolean);
+ return R.status(resBoolean&&resBoolean1);
+ }
+
+ /**
+ * 缂栫爜瑙勫垯娓呯┖鎵�鏈夊凡鐢熸垚鐨勭紪鐮�
+ *
+ * @param oid 缂栫爜瑙勫垯涓婚敭
+ * @return 鎵ц缁撴灉
+ */
+ @Override
+ public R clearAllCode(String oid) {
+ WebUtil.alertNotNull(oid, "缂栫爜瑙勫垯涓婚敭");
+ List<CodeAllCode> codeDOList = codeAllcodeService.selectByWrapper(Wrappers.<CodeAllCode>query().lambda().eq(CodeAllCode::getCodeRuleOid, oid));
+ if (CollectionUtils.isEmpty(codeDOList)) {
+ return R.fail("褰撳墠缂栫爜瑙勫垯娌℃湁鐢熸垚缂栫爜,鏃犻渶娓呯┖");
+ }
+ //鏄惁闇�瑕佽繘琛宐tm涓嶇粺涓�鐨勫垽鏂�?
+ String btmType = codeDOList.get(0).getCreateCodeBtm();
+ //澶氱绫诲瀷涓嬬殑鏌ヨ
+ Set<String> btmTypeSet = codeDOList.stream().filter(s -> {
+ return !btmType.equalsIgnoreCase(s.getCreateCodeBtm());
+ }).map(s -> s.getCreateCodeBtm()).collect(Collectors.toSet());
+ List<Map<String,String>> businessDataList = new ArrayList<>();
+ if (btmTypeSet.size() > 1) {
+ for (String btm : btmTypeSet) {
+ Map<String,String> businessData = commonsMapper.selectByCount("PL_CODE_"+btm,oid,btm);
+ businessDataList.add(businessData);
+ }
+ }else {
+ Map<String,String> businessData = commonsMapper.selectByCount("PL_CODE_"+btmType,oid,btmType);
+ businessDataList.add(businessData);
+ }
+ if (CollectionUtils.isEmpty(businessDataList) || StringUtils.isBlank(businessDataList.get(0).get("count"))) {
+ //鏃犳晥鏌ヨ
+ return R.fail("鏌ヨ澶辫触");
+ } else if (!"0".equalsIgnoreCase(businessDataList.get(0).get("count"))) {
+ return R.fail("缂栫爜瑙勫垯鐢熸垚鐨勭紪鐮佸凡鍦ㄤ笟鍔℃暟鎹腑搴旂敤锛屼笉鍏佽娓呯┖");
+ }
+ //娌℃湁鏁版嵁锛屽彲浠ュ畨鍏ㄥ垹闄�
+ WebUtil.setPersistence(false);
+ //鍒犻櫎鐮佸�艰〃涓殑鏁版嵁锛屼絾涓嶅锛屽鏋滄湁娴佹按鐨勭爜娈碉紝闇�瑕侀噸鏂拌绠楁祦姘�
+ List<CodeSerialValue> serialValueList = codeSerialValueMapper.selectByCodeRoleId(oid);
+ /*BatchCBO batchCBO = boService.batchDelete(codeDOList);
+ batchCBO.getDeleteCbos().addAll(serialValueList);
+ WebUtil.setPersistence(true);
+ boService.persistenceBatch(batchCBO);*/
+ return R.success("娓呯┖鐮佸�兼垚鍔燂紒");
}
/**
@@ -239,4 +295,138 @@
return CodeClassifyWrapper.build().listVO(codeClassifies);
}
+ /**
+ * 涓婚敭鑾峰彇涓绘暟鎹紪鐮佽鍒�
+ *
+ * @param oid 涓婚敭
+ * @return 涓绘暟鎹紪鐮佽鍒欐樉绀哄璞�
+ * @throws VciBaseException 鍙傛暟涓虹┖锛屾暟鎹笉瀛樺湪鏃朵細鎶涘嚭寮傚父
+ */
+ @Override
+ public CodeRuleVO getObjectByOid(String oid) throws VciBaseException {
+ CodeRule codeRule = selectByOid(oid);
+ return CodeRuleWrapper.build().entityVO(codeRule);
+ }
+
+ /**
+ * 涓婚敭鎵归噺鑾峰彇涓绘暟鎹紪鐮佽鍒�
+ *
+ * @param oidCollections 涓婚敭闆嗗悎锛屼絾鏄彈鎬ц兘褰卞搷锛屽缓璁竴娆℃煡璇笉瓒呰繃10000涓�
+ * @return 涓绘暟鎹紪鐮佽鍒欐樉绀哄璞�
+ * @throws VciBaseException 鏌ヨ鍑虹幇寮傚父鏃朵細鎶涘嚭
+ */
+ @Override
+ public Collection<CodeRuleVO> listCodeRuleByOids(Collection<String> oidCollections) throws VciBaseException {
+ VciBaseUtil.alertNotNull(oidCollections, "鏁版嵁瀵硅薄涓婚敭闆嗗悎");
+ List<CodeRule> codeRuleDOList = listCodeRuleDOByOidCollections(oidCollections);
+ return CodeRuleWrapper.build().listVO(codeRuleDOList);
+ }
+
+ /**
+ * 浣跨敤涓婚敭闆嗗悎鏌ヨ鏁版嵁瀵硅薄
+ *
+ * @param oidCollections 涓婚敭鐨勯泦鍚�
+ * @return 鏁版嵁瀵硅薄鍒楄〃
+ */
+ private List<CodeRule> listCodeRuleDOByOidCollections(Collection<String> oidCollections) {
+ List<CodeRule> codeRuleDOList = new ArrayList<CodeRule>();
+ if (!CollectionUtils.isEmpty(oidCollections)) {
+ Collection<Collection<String>> oidCollectionsList = VciBaseUtil.switchCollectionForOracleIn(oidCollections);
+ for (Collection<String> oids : oidCollectionsList) {
+ List<CodeRule> tempDOList = codeRuleMapper.selectBatchIds(oids);
+ if (!CollectionUtils.isEmpty(tempDOList)) {
+ codeRuleDOList.addAll(tempDOList);
+ }
+ }
+ }
+ return codeRuleDOList;
+ }
+
+ /**
+ * 鍙傜収涓绘暟鎹紪鐮佽鍒欏垪琛�
+ *
+ * @param codeRule 鏌ヨ鏉′欢
+ * @param page 鍒嗛〉鍜屾帓搴�
+ * @return 涓绘暟鎹紪鐮佽鍒欐樉绀哄璞″垪琛紝鐢熸晥鐨勫唴瀹�
+ * @throws VciBaseException 鏌ヨ鏉′欢鍜屽垎椤靛嚭閿欑殑鏃跺�欎細鎶涘嚭寮傚父
+ */
+ @Override
+ public IPage<CodeRuleVO> refDataGridCodeRule(IPage<CodeRuleVO> page, CodeRuleVO codeRule) throws VciBaseException {
+ return gridCodeRule(page, codeRule);
+ }
+
+ /**
+ * 鍋滅敤涓庡惎鐢ㄧ紪鐮佽鍒�
+ *
+ * @param oid 缂栫爜瑙勫垯涓婚敭
+ * @param update enable:鍚敤 disable:鍋滅敤 release:鍙戝竷
+ * @return 鎵ц缁撴灉
+ */
+ @Override
+ public R updateStatus(String oid, String update) {
+ int count = 0;
+ //鍏堟煡璇㈠璞�
+ CodeRule codeRuleDO = selectByOid(oid);
+ //鍒涘缓淇敼瀵硅薄鐨勭殑wrapper鏉′欢
+ LambdaUpdateWrapper<CodeRule> wrapper = Wrappers.<CodeRule>update()
+ .lambda()
+ .eq(CodeRule::getOid, oid);
+ if ("enable".equalsIgnoreCase(update)) {
+ if (!CodeRuleLC.DISABLED.getValue().equals(codeRuleDO.getLcStatus())) {
+ return R.fail("闈炲仠鐢ㄧ姸鎬佺殑缂栫爜瑙勫垯鏃犻渶鐐瑰嚮鍚敤");
+ }
+ count = codeRuleMapper.update(null,wrapper.set(CodeRule::getLcStatus, CodeRuleLC.RELEASED.getValue()));
+ } else if ("disable".equalsIgnoreCase(update)) {
+ if (!CodeRuleLC.RELEASED.getValue().equals(codeRuleDO.getLcStatus())) {
+ return R.fail("闈炲彂甯冪姸鎬佺殑缂栫爜瑙勫垯鏃犳硶鍋滅敤");
+ }
+ count = codeRuleMapper.update(null,wrapper.set(CodeRule::getLcStatus, CodeRuleLC.DISABLED.getValue()));
+ } else if ("release".equalsIgnoreCase(update)) {
+ if (!CodeRuleLC.EDITING.getValue().equals(codeRuleDO.getLcStatus())) {
+ return R.fail("闈炵紪杈戠姸鎬佺殑缂栫爜瑙勫垯鏃犳硶鍙戝竷");
+ }
+ count = codeRuleMapper.update(null,wrapper.set(CodeRule::getLcStatus, CodeRuleLC.RELEASED.getValue()));
+ } else {
+ return R.fail("鏆備笉鏀寔鐨勬搷浣滅被鍨�");
+ }
+ if (count > 0) {
+ return R.success("鏇存柊鐘舵�佹垚鍔�");
+ } else {
+ return R.fail("鏇存柊鐘舵�佸け璐�");
+ }
+ }
+
+ /**
+ * 鍏嬮殕缂栫爜瑙勫垯
+ *
+ * @param codeRuleDTO 涓绘暟鎹紪鐮佽鍒欐暟鎹紶杈撳璞★紝oid鍜宼s闇�瑕佷紶杈�
+ * @return 涓绘暟鎹紪鐮佽鍒欐樉绀哄璞�
+ */
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public R cloneCodeRule(CodeRuleDTO codeRuleDTO) {
+ VciBaseUtil.alertNotNull(codeRuleDTO, "闇�瑕佹坊鍔犵殑鏁版嵁瀵硅薄");
+ CodeRule codeRuleDO = new CodeRule();
+ BeanUtilForVCI.copyPropertiesIgnoreCase(codeRuleDTO, codeRuleDO);
+ boolean exFlag = codeRuleMapper.insert(codeRuleDO)>0;
+ List<CodeBasicSecDTO> secList = codeRuleDTO.getElements();
+ List<CodeBasicSec> codeBasicSecs = new ArrayList<>();
+ secList.forEach(codeBasicSecDTO -> {
+ codeBasicSecDTO.setPkCodeRule(codeRuleDO.getOid());
+ KeyValue attrKv = codeBasicSecService.checkAttrNullableBySecType(codeBasicSecDTO);
+ if (!"success".equals(attrKv.getKey())) {
+ throw new VciBaseException(attrKv.getValue() + "涓嶈兘涓虹┖");
+ }
+ CodeBasicSec codeBasicSecDO = new CodeBasicSec();
+ BeanUtilForVCI.copyPropertiesIgnoreCase(codeBasicSecDTO, codeBasicSecDO);
+ codeBasicSecDO.setOid("");
+ codeBasicSecDO.setRevisionOid("");
+ codeBasicSecDO.setNameOid("");
+ codeBasicSecs.add(codeBasicSecDO);
+ });
+ boolean exFlag1 = this.codeBasicSecService.saveBatch(codeBasicSecs);
+ return R.data(exFlag&&exFlag1);
+ }
+
+
}
--
Gitblit v1.9.3