|
|
@@ -43,7 +43,7 @@ public class PersonMergeV2Impl implements RelationService {
|
|
|
"WITH p.person_id as person_id, p as first_node, apoc.coll.sort(collect(distinct ID(q))) as all_ids\n" +
|
|
|
"UNWIND all_ids as all_id\n" +
|
|
|
"MATCH(m:" + CompanyEnum.Lable.PERSON.code + ")-[r]-(x:" + CompanyEnum.Lable.COMPANY.code + ")\n" +
|
|
|
- "WHERE ID(m) in all_id\n" +
|
|
|
+ "WHERE ID(m) = all_id\n" +
|
|
|
"WITH person_id, first_node, m as other_node, x, r\n" +
|
|
|
"CALL apoc.merge.relationship.eager(first_node, TYPE(r), properties(r),{}, x,{}) YIELD rel\n" +
|
|
|
"SET first_node:" + CompanyUtils.getIncrPersonLabelV2("新增", CompanyEnum.SPLIT_HOUR) + "\n" +
|
xufei