diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgLeaderServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgLeaderServiceImpl.java
index 3eeec453ea..ee0efc64ec 100755
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgLeaderServiceImpl.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyOrgLeaderServiceImpl.java
@@ -65,10 +65,13 @@ public class IcPartyOrgLeaderServiceImpl extends BaseServiceImpl<IcPartyOrgLeade
 
     private QueryWrapper<IcPartyOrgLeaderEntity> getWrapper(Map<String, Object> params){
         String id = (String)params.get(FieldConstant.ID_HUMP);
+        String partyOrgId = (String)params.get("partyOrgId");
 
         QueryWrapper<IcPartyOrgLeaderEntity> wrapper = new QueryWrapper<>();
         wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id);
 
+        wrapper.eq(StringUtils.isNotBlank(partyOrgId), "PARTY_ORG_ID", partyOrgId);
+
         return wrapper;
     }
 
@@ -82,7 +85,7 @@ public class IcPartyOrgLeaderServiceImpl extends BaseServiceImpl<IcPartyOrgLeade
     @Transactional(rollbackFor = Exception.class)
     public void save(IcPartyOrgLeaderDTO dto) {
         IcPartyOrgLeaderEntity entity = ConvertUtils.sourceToTarget(dto, IcPartyOrgLeaderEntity.class);
-        insert(entity);
+        saveOrUpdate(entity);
     }
 
     @Override