| | |
|---|
| | | // SessionInfo sessionInfo = VciBaseUtil.getCurrentUserSessionInfo(); |
|---|
| | | List<CodeAllCode> allCodeDOList = new ArrayList<>(); |
|---|
| | | Map<String/**流水依据**/, Map<String/**码段的主键**/,Double/**最大流水号**/>> maxSerialMap = new HashMap<>(); |
|---|
| | | // TODO 多线程流引发的问题已修改 |
|---|
| | | dataCBOList.parallelStream().forEach(cbo->{ |
|---|
| | | // VciBaseUtil.setCurrentUserSessionInfo(sessionInfo); |
|---|
| | | String code = cbo.getId(); |
|---|
| | |
|---|
| | | } |
|---|
| | | //处理allCode |
|---|
| | | if(!CollectionUtils.isEmpty(allCodeDOList)){ |
|---|
| | | // 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<>(); |
|---|
| | |
|---|
| | | //要存储最后的全部allcode |
|---|
| | | wrapperAllCode(classifyFullInfoBO, ruleVO, cbo, templateVO, allCodeDOList, serialUnitString, sb.toString()); |
|---|
| | | } |
|---|
| | | //处理最大流水 |
|---|
| | | saveSerialValue( ruleVO, lastMaxSerialValueMap, maxSerialValueMap); |
|---|
| | | |
|---|
| | | allCodeDOList.stream().forEach( |
|---|
