aike/emis-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

demand: 定时扫描漏组批次添加treeId

Browse Source 
committer: heyu
This commit is contained in:
aike 2025-06-26 18:44:41 +08:00
parent 83fba12bba
commit fac835bcb2
2 changed files with 19 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
emis-biz/src/main/java/com/xdadan/erp/emis/domain/EmisTransPlanRule.java
View File

@ -25,8 +25,11 @@ public class EmisTransPlanRule extends BaseEntity {
/** id */ /** id */
private Long id; private Long id;
/** tree唯一id */
private String treeId;
/** 父id */ /** 父id */
private Long parentId; private String parentId;
/** 祖先节点 */ /** 祖先节点 */
private String ancestors; private String ancestors;

26
emis-biz/src/main/java/com/xdadan/erp/emis/service/EmisBaseService.java
View File

@ -4126,7 +4126,7 @@ public class EmisBaseService {
} }
} }
// 递归设置父ID和祖先节点ID // 递归设置父ID和祖先节点ID（以treeId为准）
for (EmisTransPlanRule root : result) { for (EmisTransPlanRule root : result) {
setParentAndAncestors(root, null, ""); setParentAndAncestors(root, null, "");
} }
@ -4141,23 +4141,20 @@ public class EmisBaseService {
* @param parentId 父节点ID * @param parentId 父节点ID
* @param ancestors 祖先节点ID字符串 * @param ancestors 祖先节点ID字符串
*/ */
private void setParentAndAncestors(EmisTransPlanRule node, Long parentId, String ancestors) { private void setParentAndAncestors(EmisTransPlanRule node, String parentId, String ancestors) {
if (node == null) { if (node == null) {
return; return;
} }
// 设置父ID // 设置父ID
node.setParentId(parentId); node.setParentId(parentId);
// 设置祖先节点ID // 设置祖先节点ID
node.setAncestors(ancestors); node.setAncestors(ancestors);
// 处理子节点，子节点的祖先包含当前节点和当前节点的所有祖先 // 处理子节点，子节点的祖先包含当前节点和当前节点的所有祖先
if (node.getChildren() != null && !node.getChildren().isEmpty()) { if (node.getChildren() != null && !node.getChildren().isEmpty()) {
String childAncestors = ancestors.isEmpty() ? node.getId().toString() : ancestors + "," + node.getId(); String childAncestors = ancestors.isEmpty() ? node.getTreeId() : ancestors + "," + node.getTreeId();
for (EmisTransPlanRule child : node.getChildren()) { for (EmisTransPlanRule child : node.getChildren()) {
setParentAndAncestors(child, node.getId(), childAncestors); setParentAndAncestors(child, node.getTreeId(), childAncestors);
} }
} }
} }
@ -4217,6 +4214,9 @@ public class EmisBaseService {
EmisTransPlanRule copy = new EmisTransPlanRule(); EmisTransPlanRule copy = new EmisTransPlanRule();
BeanUtils.copyProperties(source, copy); BeanUtils.copyProperties(source, copy);
// 为每个新节点生成唯一treeId
copy.setTreeId(com.xdadan.erp.common.utils.idgen.UUID.fastUUID().toString());
// 递归复制子节点 // 递归复制子节点
if (source.getChildren() != null) { if (source.getChildren() != null) {
List<EmisTransPlanRule> copiedChildren = new ArrayList<>(); List<EmisTransPlanRule> copiedChildren = new ArrayList<>();
@ -4573,6 +4573,10 @@ public class EmisBaseService {
allNodeMatched = true; allNodeMatched = true;
break; break;
} }
list = list.stream()
.collect(Collectors.collectingAndThen(
Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(EmisTransPlanRule::getId))),
ArrayList::new));
if (list.size() > filterRules.size()) { if (list.size() > filterRules.size()) {
filterRules = list; filterRules = list;
} }
@ -4591,15 +4595,15 @@ public class EmisBaseService {
return false; return false;
} }
EmisTransPlanRule filterRule = filterRules.get(0); EmisTransPlanRule filterRule = filterRules.get(0);
Long ancestor; String ancestor;
if (StringUtils.isEmpty(filterRule.getAncestors())) { if (StringUtils.isEmpty(filterRule.getAncestors())) {
ancestor = filterRule.getId(); ancestor = filterRule.getTreeId();
} else { } else {
String[] ancestors = filterRule.getAncestors().split(","); String[] ancestors = filterRule.getAncestors().split(",");
ancestor = Long.valueOf(ancestors[0]); ancestor = ancestors[0];
} }
List<EmisTransPlanRule> rules = ruleList.stream().filter(i -> i.getId().equals(ancestor)) List<EmisTransPlanRule> rules = ruleList.stream().filter(i -> i.getTreeId().equals(ancestor))
.collect(Collectors.toList()); .collect(Collectors.toList());
EmisTransPlanRule rule = rules.get(0); EmisTransPlanRule rule = rules.get(0);
setMissRecords(missRecords, rule, filterRules, waybill); setMissRecords(missRecords, rule, filterRules, waybill);