From afe36ffe1d928ef03857445443de2d3f9dc9fd90 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Tue, 23 Aug 2022 17:43:14 +0800
Subject: [PATCH] /icPartyOrg/adjustOrgPath

---
 .../controller/IcPartyOrgController.java      | 10 +++++++++
 .../partyOrg/service/IcPartyOrgService.java   |  5 +++++
 .../service/impl/IcPartyOrgServiceImpl.java   | 22 +++++++++++++++++++
 3 files changed, 37 insertions(+)

diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/controller/IcPartyOrgController.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/controller/IcPartyOrgController.java
index 0d43188623..80b8007b9a 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/controller/IcPartyOrgController.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/controller/IcPartyOrgController.java
@@ -167,4 +167,14 @@ public class IcPartyOrgController {
     public Result<DefaultPartyOrgResDTO> defaultPartyOrg(@LoginUser TokenDto tokenDto){
         return new Result<DefaultPartyOrgResDTO>().ok(icPartyOrgService.defaultPartyOrg(tokenDto.getCustomerId(), tokenDto.getUserId()));
     }
+
+    /**
+     * 调整历史数据 ORG_PIDS
+     * @return
+     */
+    @PostMapping("adjustOrgPath")
+    public Result adjustOrgPath(@RequestBody List<String> customerIds){
+        icPartyOrgService.adjustOrgPath(customerIds);
+        return new Result();
+    }
 }
diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/IcPartyOrgService.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/IcPartyOrgService.java
index 3bd50cf946..4f52b137cb 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/IcPartyOrgService.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/IcPartyOrgService.java
@@ -144,4 +144,9 @@ public interface IcPartyOrgService extends BaseService<IcPartyOrgEntity> {
      * @return
      */
     IcPartyOrgInfo queryIcPartyOrgInfo(String icPartyOrgId);
+
+    /**
+     * 调整历史数据 ORG_PIDS
+     */
+    void adjustOrgPath(List<String> customerIds);
 }
diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgServiceImpl.java
index 8ead407a81..39941fc013 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgServiceImpl.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgServiceImpl.java
@@ -457,4 +457,26 @@ public class IcPartyOrgServiceImpl extends BaseServiceImpl<IcPartyOrgDao, IcPart
         map.put("namePath", StringUtils.join(names.toArray(),StrConstant.HYPHEN));
         return map;
     }
+
+    /**
+     * 调整历史数据 ORG_PIDS
+     */
+    @Override
+    public void adjustOrgPath(List<String> customerIds) {
+        LambdaQueryWrapper<IcPartyOrgEntity> queryWrapper=new LambdaQueryWrapper<>();
+        queryWrapper.in(org.apache.commons.collections4.CollectionUtils.isNotEmpty(customerIds),IcPartyOrgEntity::getCustomerId,customerIds);
+        List<IcPartyOrgEntity> list=baseDao.selectList(queryWrapper);
+        int num=1;
+        for(IcPartyOrgEntity entity:list){
+            List<String> pids=new ArrayList<>();
+            List<String> names=new ArrayList<>();
+            Map<String,String> map=getPartyOrgIdPath(pids,names,entity.getOrgPid());
+            String partyOrgIdPath = map.containsKey("idPath") ? map.get("idPath") : StrConstant.EPMETY_STR;
+            String partyOrgNamePath = map.containsKey("namePath") ? map.get("namePath") : StrConstant.EPMETY_STR;
+            log.info(num+":::"+entity.getId()+entity.getPartyOrgName()+";path="+partyOrgIdPath+";"+partyOrgNamePath);
+            entity.setOrgPids(partyOrgIdPath);
+            baseDao.updateById(entity);
+            num++;
+        }
+    }
 }