ubcs.git - Gitblit

			@@ -32,14 +32,19 @@
			import lombok.extern.slf4j.Slf4j;
			import org.springblade.core.log.exception.ServiceException;
			import org.springblade.core.secure.utils.AuthUtil;
			import org.springblade.core.tool.utils.Func;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.context.annotation.Lazy;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.TransactionStatus;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.transaction.support.DefaultTransactionDefinition;
			import org.springframework.transaction.support.TransactionTemplate;
			import org.springframework.util.CollectionUtils;

			import javax.annotation.Resource;
			import java.util.*;
			import java.util.concurrent.CopyOnWriteArrayList;
			import java.util.concurrent.atomic.AtomicReference;
			import java.util.stream.Collectors;

			@@ -79,12 +84,16 @@
			@Autowired
			private FormulaServiceImpl formulaService;

			// 注入事务管理器
			// @Autowired
			// private TransactionTemplate transactionTemplate;

			@Override
			@Transactional(rollbackFor = VciBaseException.class)
			@Transactional(rollbackFor = Exception.class)
			public List<String> productCodeAndSaveData(CodeClassifyFullInfoBO classifyFullInfoBO, CodeClassifyTemplateVO templateVO, CodeRuleVO ruleVO, List<CodeOrderSecDTO> secDTOList, List<BaseModel> dataCBOList) throws Exception {
			dataCBOList = dataCBOList.stream().sorted(((o1, o2) -> o1.getCreateTime().compareTo(o2.getCreateTime()))).collect(Collectors.toList());
			List<String> codeList = new ArrayList<>();

			final CodeRuleVO finalRuleVO = ruleVO;
			/*****
			* 保证并发的时候，最大流水号都对的，但是这种加锁有弊端
			*/
			@@ -95,20 +104,20 @@
			//历史数据执行的时候，这个系统会很卡
			//主要是为了录入最大流水号和allcode
			//SessionInfo sessionInfo = VciBaseUtil.getCurrentUserSessionInfo();
			List<CodeAllCode> allCodeDOList = new ArrayList<>();
			List<CodeAllCode> allCodeDOList = new CopyOnWriteArrayList<>();
			Map<String/流水依据/, Map<String/码段的主键/,Double/最大流水号/>> maxSerialMap = new HashMap<>();
			// TODO 多线程流引发的问题已修改
			dataCBOList.parallelStream().forEach(cbo->{
			log.info("code:----->"+cbo.getId());
			//VciBaseUtil.setCurrentUserSessionInfo(sessionInfo);
			String code = cbo.getId();
			List<String> serialUnitList = new ArrayList<>();
			List<String> serialUnitList = new CopyOnWriteArrayList<>();
			String seclenghStr=cbo.getData().get(CODE_SEC_LENGTH_FIELD);
			String[] secLengths = cbo.getData().get(CODE_SEC_LENGTH_FIELD).split("#");
			cbo.getData().remove(CODE_SEC_LENGTH_FIELD);//将此key除去
			cbo.getData().remove(IMPORT_ROW_INDEX);//将此key除去
			cbo.getData().remove("codeclassifyid");//将此key除去
			List<CodeBasicSecVO> secVOList = ruleVO.getSecVOList().stream().sorted(((o1, o2) -> o1.getOrderNum().compareTo(o2.getOrderNum()))).collect(Collectors.toList());
			List<CodeBasicSecVO> secVOList = finalRuleVO.getSecVOList().stream().sorted(((o1, o2) -> o1.getOrderNum().compareTo(o2.getOrderNum()))).collect(Collectors.toList());
			Map<String/码段的主键/,String/码段的值/> serialValueMap = new HashMap<>();
			Map<String, CodeBasicSecVO> secVOMap = secVOList.stream().collect(Collectors.toMap(s -> s.getOid(), t -> t));
			for (int i = 0; i < secLengths.length; i++) {
			@@ -125,7 +134,7 @@
			start += VciBaseUtil.getInt(secLengths[j]);
			}
			thisSecValue = code.substring(start,start+VciBaseUtil.getInt(secLengths[i]));
			// }
			// }
			if(VciBaseUtil.getBoolean(secVO.getSerialDependFlag())){
			serialUnitList.add(thisSecValue);
			}
			@@ -140,13 +149,15 @@
			//要看是不是补位的
			CodeBasicSecVO secVO = secVOMap.get(secOid);
			Double serialDb = null;
			// 截取掉前后缀之后的码段
			String subSecValue = killPriffixSuffix(secValue, secVO.getPrefixCode(), secVO.getSuffixCode());
			if(OsCodeFillTypeEnum.NONE.getValue().equalsIgnoreCase(secVO.getCodeFillType())){
			//不补码
			//把所有不是数字的去掉，因为可能会是老数据，新规则
			serialDb = VciBaseUtil.getDouble(killUnNumberChar(secValue));
			serialDb = VciBaseUtil.getDouble(killUnNumberChar(subSecValue));
			}else {
			//左右填充的，我们需要
			serialDb = VciBaseUtil.getDouble(killUnNumberChar(killFillChar(secValue,secVO.getCodeFillSeparator(),
			serialDb = VciBaseUtil.getDouble(killUnNumberChar(killFillChar(subSecValue,secVO.getCodeFillSeparator(),
			OsCodeFillTypeEnum.LEFT.getValue().equalsIgnoreCase(secVO.getCodeFillType()))));
			}
			Map<String, Double> thisUnitMaxMap = maxSerialMap.getOrDefault(serialUnitString, new HashMap<>());
			@@ -165,7 +176,7 @@
			CodeAllCode allCodeDO = new CodeAllCode();
			DefaultAttrAssimtUtil.addDefaultAttrAssimt(allCodeDO, MdmBtmTypeConstant.CODE_ALL_CODE);
			allCodeDO.setCodeClassifyOid(classifyFullInfoBO.getCurrentClassifyVO().getOid());
			allCodeDO.setCodeRuleOid(ruleVO.getOid());
			allCodeDO.setCodeRuleOid(finalRuleVO.getOid());
			allCodeDO.setId(cbo.getId());
			allCodeDO.setCodeClassifyTemplateOid(templateVO.getOid());
			allCodeDO.setCreateCodeBtm(cbo.getBtmname());
			@@ -183,7 +194,7 @@
			maxSerialMap.forEach((serialUnit,secOidMaxMap)->{
			secOidMaxMap.forEach((secOid,maxSerial)->{
			QueryWrapper<CodeSerialValue> queryWrapper = new QueryWrapper<>();
			queryWrapper.eq("codeRuleOid", ruleVO.getOid());
			queryWrapper.eq("codeRuleOid", finalRuleVO.getOid());
			queryWrapper.eq("serialUnit", serialUnit);
			//这个字段是为了解决多个流水的问题
			queryWrapper.eq("codeSecOid", secOid);
			@@ -202,7 +213,7 @@
			//没有
			CodeSerialValue serialValueDO = new CodeSerialValue();
			DefaultAttrAssimtUtil.addDefaultAttrAssimt(serialValueDO, MdmBtmTypeConstant.CODE_SERIAL_VALUE);
			serialValueDO.setCodeRuleOid(ruleVO.getOid());
			serialValueDO.setCodeRuleOid(finalRuleVO.getOid());
			serialValueDO.setSerialUnit(serialUnit);
			serialValueDO.setCodeSecOid(secOid);
			serialValueDO.setMaxSerial(maxSerial.toString());
			@@ -225,8 +236,8 @@
			// TODO 历史数据导入的时候这儿偶尔会触发空指针异常
			Map<String,List<CodeAllCode>> ruleGroup = allCodeDOList.stream().collect(Collectors.groupingBy(s -> s.getCodeRuleOid()));
			Map<String, CodeAllCode> codeDOMap = allCodeDOList.stream().collect(Collectors.toMap(s -> s.getCodeRuleOid() + "${SEP}" + s.getId(), t -> t));
			List<CodeAllCode> addCodeDOs = new ArrayList<>();
			List<CodeAllCode> editCodeDOs = new ArrayList<>();
			List<CodeAllCode> addCodeDOs = new CopyOnWriteArrayList<>();
			List<CodeAllCode> editCodeDOs = new CopyOnWriteArrayList<>();
			ruleGroup.forEach((ruleOid,allCodeDOS)->{
			VciBaseUtil.switchCollectionForOracleIn(allCodeDOS).stream().forEach(codeDOs->{
			QueryWrapper<CodeAllCode> allCodeWrapper = new QueryWrapper<>();
			@@ -261,6 +272,10 @@
			if(!CollectionUtils.isEmpty(editCodeDOs)){
			codeAllCodeService.updateBatchById(editCodeDOs);
			}
			// 获取事务定义
			//DefaultTransactionDefinition def = new DefaultTransactionDefinition();
			// 开始事务
			//TransactionStatus status = transactionTemplate.getTransactionManager().getTransaction(def);
			if(!CollectionUtils.isEmpty(addCodeDOs)){
			Map<String, String> statusMap = addCodeDOs.stream().collect(Collectors.toMap(s -> s.getOid(), s -> s.getLcStatus()));
			addCodeDOs.stream().filter(s -> StringUtils.equalsIgnoreCase("codeallcode",s.getBtmname())).forEach(s -> {
			@@ -271,7 +286,7 @@
			.collectingAndThen(
			Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(CodeAllCode::getId))),
			ArrayList::new));
			if( distinctCodeAllCOdes.size() != addCodeDOs.size() ){
			if(distinctCodeAllCOdes.size() != addCodeDOs.size() ){
			throw new VciBaseException("编码数据重复，无法保存，请注意！");
			}
			QueryWrapper<CodeAllCode> wrapper = new QueryWrapper<>();
			@@ -292,20 +307,22 @@
			if(codeAllCode.getId().equals(next.getId())){
			codeAllCode.setCreateCodeOid(next.getCreateCodeOid());
			codeAllCode.setLcStatus(next.getLcStatus());
			iterator.remove();
			// TODO: 这儿先暂时注释掉，没看懂这儿为什么要这样做，导致报错
			//iterator.remove();
			}
			}
			}
			if(takeBack.size()>0){
			codeAllCodeService.updateBatchById(takeBack);
			}

			codeAllCodeService.saveBatch(addCodeDOs);
			}
			mdmEngineService.insertBatchByType(dataCBOList.get(0).getBtmname(),dataCBOList);
			}
			return codeList;
			}else {
			List<CodeBasicSecVO> secVOList = ruleVO.getSecVOList().stream().sorted(((o1, o2) -> o1.getOrderNum().compareTo(o2.getOrderNum()))).collect(Collectors.toList());
			List<CodeBasicSecVO> secVOList = finalRuleVO.getSecVOList().stream().sorted(((o1, o2) -> o1.getOrderNum().compareTo(o2.getOrderNum()))).collect(Collectors.toList());
			List<String> serialUnitList = new LinkedList<>();
			List<String> secValueList = new ArrayList<>();
			Map<String, String> secValueMap = secDTOList.stream().collect(Collectors.toMap(s -> s.getSecOid(), s -> s.getSecValue()==null?"":s.getSecValue()));
			@@ -341,7 +358,7 @@
			switchAttrSecValue(attrSecVOList, cbo, thisSecValueList, attrSevIsSerialDepend, thisSerialUnitList);

			String serialUnitString = thisSerialUnitList.size() == 0 ? EMPTY_SERIAL_UNIT : thisSerialUnitList.stream().collect(Collectors.joining(SERIAL_UNIT_SPACE));
			switchSerialSecValue(serialSecVOList, attrSevIsSerialDepend, ruleVO, serialUnitString, maxSerialValueMap, thisSecValueList, lastMaxSerialValueMap, i == 0);
			switchSerialSecValue(serialSecVOList, attrSevIsSerialDepend, finalRuleVO, serialUnitString, maxSerialValueMap, thisSecValueList, lastMaxSerialValueMap, i == 0);

			//组装编码的值
			cbo.setId(thisSecValueList.stream().collect(Collectors.joining()));
			@@ -356,21 +373,19 @@
			}
			}
			//要存储最后的全部allcode
			wrapperAllCode(classifyFullInfoBO, ruleVO, cbo, templateVO, allCodeDOList, serialUnitString, sb.toString());
			wrapperAllCode(classifyFullInfoBO, finalRuleVO, cbo, templateVO, allCodeDOList, serialUnitString, sb.toString());
			}
			//处理最大流水
			saveSerialValue( ruleVO, lastMaxSerialValueMap, maxSerialValueMap);
			saveSerialValue( finalRuleVO, lastMaxSerialValueMap, maxSerialValueMap);

			allCodeDOList.stream().forEach(
			allCode -> {DefaultAttrAssimtUtil.addDefaultAttrAssimt(allCode,"codeallcode");allCode.setLctid("codeAllCodeLC");}
			);


			Map<String, String> statusMap = allCodeDOList.stream().collect(Collectors.toMap(s -> s.getOid(), s -> s.getLcStatus()));
			allCodeDOList.stream().filter(s -> StringUtils.equalsIgnoreCase("codeallcode",s.getBtmname())).forEach(s -> {
			s.setLcStatus(statusMap.get(s.getOid()));
			});


			//通过ID来进行去重
			List<CodeAllCode> distinctCodeAllCOdes = allCodeDOList.stream().collect(Collectors
			@@ -409,7 +424,6 @@
			codeAllCodeService.saveBatch(allCodeDOList);
			// iCodeWupinService.saveBatch(dataCBOList);
			mdmEngineService.insertBatchByType(dataCBOList.get(0).getBtmname(),dataCBOList);

			// batchCBO.getCreateCbos().stream().filter(s -> StringUtils.equalsIgnoreCase("codeallcode",s.getBtmName())).forEach(s -> {
			// s.setLcStatus(statusMap.get(s.getOid()));
			// try {
			@@ -452,7 +466,8 @@
			for (int j = 0; j < thisSecValueList.size(); j++) {
			String secValue = thisSecValueList.get(j);
			if (secValue.equalsIgnoreCase("${attr_" + attrSevVO.getOid() + "}")) {
			thisSecValueList.set(j, value);
			// TODO: 属性码段生成码值后，拼接前后缀
			thisSecValueList.set(j, joinPreffixAndSuffix(attrSevVO,value));
			}
			}
			if (attrSevIsSerialDepend) {
			@@ -460,7 +475,7 @@
			for (int j = 0; j < serialUnitList.size(); j++) {
			String secValue = serialUnitList.get(j);
			if (secValue.equalsIgnoreCase("${attr_" + attrSevVO.getOid() + "}")) {
			serialUnitList.set(j, value);
			serialUnitList.set(j, joinPreffixAndSuffix(attrSevVO,value));
			}
			}
			}
			@@ -536,7 +551,8 @@
			for (int z = 0; z < thisSecValueList.size(); z++) {
			String secValue = thisSecValueList.get(z);
			if (secValue.equalsIgnoreCase("${" + secVO.getOid() + "}")) {
			thisSecValueList.set(z, serialString);
			// TODO: 流水生成码值后拼接前后缀
			thisSecValueList.set(z, joinPreffixAndSuffix(secVO, serialString));
			}
			}
			Map<String, Double> unitSerialMap = lastMaxSerialValueMap.getOrDefault(secVO.getOid(), new HashMap<>());
			@@ -564,18 +580,19 @@
			String secValue = secValueMap.getOrDefault(secVO.getOid(), "");
			switch (secType) {
			case CODE_FIXED_SEC:
			secValue = joinPreffixAndSuffix(secVO, secValue);
			//固定码段的，直接用码值,不论码值的长度是多少，因为可变长度和固定长度是控制在码段管理里面的码值定义的
			break;
			case CODE_DATE_SEC:
			//时间码段，需要将当前时间依据时间格式进行转换.
			//时间码段不涉及到是否补位
			secValue = VciDateUtil.date2Str(new Date(), secVO.getCodeDateFormatStr());
			secValue =joinPreffixAndSuffix(secVO, VciDateUtil.date2Str(new Date(), secVO.getCodeDateFormatStr()));
			break;
			case CODE_CLASSIFY_SEC:
			//分类码段的，也是从前端选择了码值即可，不论码值的长度是多少
			CodeClassifyValue codeClassifyValueDO= codeClassifyValueMapper.selectById(secValue);
			if(codeClassifyValueDO!=null) {
			secValue = codeClassifyValueDO.getId();
			secValue = joinPreffixAndSuffix(secVO, codeClassifyValueDO.getId());
			}
			break;
			case CODE_LEVEL_SEC:
			@@ -628,10 +645,12 @@
			secValue = secValue.substring(secValue.length() - secVO.getValueCutLength());
			}
			}
			secValue = joinPreffixAndSuffix(secVO,secValue);
			break;
			case CODE_REFER_SEC:
			//引用的在页面上已经选择了，所以直接使用前端上传递的值
			//引用就是参照，可能是其他的分类（业务类型）下的数据，所以只在页面上选择
			secValue = joinPreffixAndSuffix(secVO,secValue);
			break;
			case CODE_ATTR_SEC:
			//属性与引用的区别是，属性是当前数据里的属性，而引用可能是引用其他的分类的（业务类型）
			@@ -646,6 +665,7 @@
			}
			OsCodeFillTypeEnum fillTypeEnum = OsCodeFillTypeEnum.forValue(secVO.getCodeFillType());
			secValue = fillString(VciBaseUtil.getInt(secVO.getCodeSecLength()), fillTypeEnum, secValue, secVO.getCodeFillSeparator());
			secValue = joinPreffixAndSuffix(secVO,secValue);
			break;
			case CODE_SERIAL_SEC:
			//流水码段
			@@ -658,6 +678,27 @@
			serialUnitList.add(secValue);
			}
			secValueList.add(secValue);
			}

			/**
			* 拼接前后缀
			* @param secVO
			* @param secValue
			* @return
			*/
			private String joinPreffixAndSuffix(CodeBasicSecVO secVO, String secValue){
			StringBuilder joinSecValue = new StringBuilder();
			// 拼接前缀
			if (Func.isNotEmpty(secVO.getPrefixCode())) {
			joinSecValue = joinSecValue.append(secVO.getPrefixCode());
			}
			// 在中间拼接值
			joinSecValue.append(secValue);
			// 拼接后缀
			if(Func.isNotEmpty(secVO.getSuffixCode())){
			joinSecValue = joinSecValue.append(secVO.getSuffixCode());
			}
			return joinSecValue.toString();
			}

			/**
			@@ -778,6 +819,23 @@
			}

			/**
			* 去掉前后缀
			* @param secValue 字符
			* @param priffix 前缀
			* @param suffix 后缀
			* @return 替换后的值
			*/
			private String killPriffixSuffix(String secValue, String priffix,String suffix){
			if (priffix != null && secValue.startsWith(priffix)) {
			secValue = secValue.substring(priffix.length());
			}
			if (suffix != null && secValue.endsWith(suffix)) {
			secValue = secValue.substring(0, secValue.length() - suffix.length());
			}
			return secValue;
			}

			/**
			* 去除补位字符
			* @param s 字符
			* @param fillString 补位字符