服务措施分析返回icResiUserId或者epmetUserId

epmet-module/epmet-heart/epmet-heart-client/src/main/java/com/epmet/dto/form/demand/DemandResearchAnalysisFormDTO.java

@@ -23,7 +23,7 @@ public class DemandResearchAnalysisFormDTO implements Serializable {
     @NotBlank(message = "firstCategoryCode不能为空",groups = AddUserInternalGroup.class)
     private String firstCategoryCode;
 
-    @NotBlank(message = "isResiUserId不能为空",groups = AddUserInternalGroup.class)
+    //@NotBlank(message = "isResiUserId不能为空",groups = AddUserInternalGroup.class)
     private String icResiUserId;
 
     private List<String> epmetUserIdList;
@@ -31,4 +31,11 @@ public class DemandResearchAnalysisFormDTO implements Serializable {
 
     @NotBlank(message = "tokenDto中的customerId不能为空",groups = AddUserInternalGroup.class)
     private String customerId;
+
+    /**
+     * 个人档案：personal-data
+     * 服务措施分析：demand-analysis
+     */
+    @NotBlank(message = "个人档案：personal-data;服务措施分析：demand-analysis",groups = AddUserInternalGroup.class)
+    private String queryOrigin;
 }

epmet-module/epmet-heart/epmet-heart-client/src/main/java/com/epmet/dto/result/demand/DemandRecResultDTO.java

@@ -114,4 +114,7 @@ public class DemandRecResultDTO implements Serializable {
      * 完成情况
      */
     private String finishDesc;
+
+    private String icResiUserId;
+    private String epmetUserId;
 }

epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/constant/UserDemandConstant.java

@@ -50,4 +50,12 @@ public interface UserDemandConstant {
     String SOCIAL_ORG="social_org";
     String COMMUNITY_ORG="community_org";
     String PARTY_UNIT="party_unit";
+
+
+    /**
+     * 个人档案：personal-data
+     * 服务措施分析：demand-analysis
+     */
+    String PERSONAL_DATA="personal-data";
+    String DEMAND_ANALYSIS="demand-analysis";
 }

epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/IcUserDemandRecServiceImpl.java

@@ -42,9 +42,11 @@ import com.epmet.dto.CustomerAgencyDTO;
 import com.epmet.dto.CustomerGridDTO;
 import com.epmet.dto.IcUserDemandRecDTO;
 import com.epmet.dto.form.CustomerGridFormDTO;
+import com.epmet.dto.form.ResiUserFormDTO;
 import com.epmet.dto.form.demand.*;
 import com.epmet.dto.result.AllGridsByUserIdResultDTO;
 import com.epmet.dto.result.IcResiUserBriefDTO;
+import com.epmet.dto.result.ResiUserResDTO;
 import com.epmet.dto.result.UserBaseInfoResultDTO;
 import com.epmet.dto.result.demand.*;
 import com.epmet.entity.*;
@@ -583,7 +585,7 @@ public class IcUserDemandRecServiceImpl extends BaseServiceImpl<IcUserDemandRecD
         }
         IcResiUserBriefDTO icResiUserDTO = userRes.getData();
         DemandResearchAnalysisResultDTO resultDTO = ConvertUtils.sourceToTarget(icResiUserDTO, DemandResearchAnalysisResultDTO.class);
-        resultDTO.setEpmetUserIdList(CollectionUtils.isNotEmpty(formDTO.getEpmetUserIdList()) ? formDTO.getEpmetUserIdList() : Collections.emptyList());
+
 
         //返参格式套一层类别和类别名称
         List<DemandDataDTO> demandData=new ArrayList<>();
@@ -593,12 +595,34 @@ public class IcUserDemandRecServiceImpl extends BaseServiceImpl<IcUserDemandRecD
         demandDataDTO.setDemandList(new ArrayList<>());
         demandData.add(demandDataDTO);
 
+        //如果是服务措施分析来的，并且是pc录入的需求，需要先去找epmetUserIdList
+        if(UserDemandConstant.DEMAND_ANALYSIS.equals(formDTO.getQueryOrigin())
+                &&CollectionUtils.isEmpty(formDTO.getEpmetUserIdList())){
+            ResiUserFormDTO resiUserFormDTO=new ResiUserFormDTO();
+            resiUserFormDTO.setCustomerId(formDTO.getCustomerId());
+            resiUserFormDTO.setIcResiUserId(formDTO.getIcResiUserId());
+            Result<ResiUserResDTO> resiRes=epmetUserOpenFeignClient.findEpmetUser(resiUserFormDTO);
+            if(!resiRes.success()){
+                throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询小程序用户异常");
+            }
+            if (null != resiRes.getData() && CollectionUtils.isNotEmpty(resiRes.getData().getEpmetUserIdList())) {
+                formDTO.setEpmetUserIdList(resiRes.getData().getEpmetUserIdList());
+            }
+        }
         //获取当前需求人，相同分类的需求列表。不分页，直接返回所有
         List<String> userIds=new ArrayList<>();
-        userIds.add(formDTO.getIcResiUserId());
+        if(StringUtils.isNotBlank(formDTO.getIcResiUserId())){
+            userIds.add(formDTO.getIcResiUserId());
+        }
         if(CollectionUtils.isNotEmpty(formDTO.getEpmetUserIdList())){
             userIds.addAll(formDTO.getEpmetUserIdList());
         }
+        if(StringUtils.isBlank(formDTO.getIcResiUserId())&&CollectionUtils.isEmpty(formDTO.getEpmetUserIdList())){
+            //需求人不能为空
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "需求人不能为空，icResiUserId与epmetUserIdList不能同时为空");
+        }
+
+
         IcResiUserDemandFromDTO icResiUserDemandFromDTO=new IcResiUserDemandFromDTO();
         icResiUserDemandFromDTO.setUserIds(userIds);
         icResiUserDemandFromDTO.setFirstCategoryCode(formDTO.getFirstCategoryCode());
@@ -625,6 +649,8 @@ public class IcUserDemandRecServiceImpl extends BaseServiceImpl<IcUserDemandRecD
             }
             demandData.get(NumConstant.ZERO).setDemandList(CollectionUtils.isNotEmpty(demandList) ? demandList : Collections.emptyList());
         }
+
+        resultDTO.setEpmetUserIdList(CollectionUtils.isNotEmpty(formDTO.getEpmetUserIdList()) ? formDTO.getEpmetUserIdList() : Collections.emptyList());
         resultDTO.setDemandData(demandData);
         return resultDTO;
     }

epmet-module/epmet-heart/epmet-heart-server/src/main/resources/mapper/IcUserDemandRecDao.xml

@@ -75,7 +75,17 @@
             case when r.PARENT_CODE !='0' then r.PARENT_CODE
             ELSE R.CATEGORY_CODE
             END
-            ) as firstCategoryCode
+            ) as firstCategoryCode,
+            (
+                CASE WHEN R.DEMAND_USER_TYPE='ic_resi_user' THEN R.DEMAND_USER_ID
+                ELSE ''
+                END
+            ) as icResiUserId,
+            (
+                CASE WHEN R.DEMAND_USER_TYPE='mini_resi' THEN R.DEMAND_USER_ID
+                ELSE ''
+                END
+            ) as epmetUserId
         FROM
             ic_user_demand_rec r
             left JOIN ic_user_demand_service s ON ( r.id = s.DEMAND_REC_ID AND s.DEL_FLAG = '0' )
@@ -182,7 +192,17 @@
             IFNULL(s.FINISH_DESC,'') as  finishDesc,
             '' AS serviceShowName,
             s.id as serviceId,
-            left(r.CATEGORY_CODE,4) as firstCategoryCode
+            left(r.CATEGORY_CODE,4) as firstCategoryCode,
+            (
+                CASE WHEN R.DEMAND_USER_TYPE='ic_resi_user' THEN R.DEMAND_USER_ID
+                ELSE ''
+                END
+            ) as icResiUserId,
+            (
+                CASE WHEN R.DEMAND_USER_TYPE='mini_resi' THEN R.DEMAND_USER_ID
+                ELSE ''
+                END
+            ) as epmetUserId
         FROM
             ic_user_demand_rec r
             left JOIN ic_user_demand_service s ON ( r.id = s.DEMAND_REC_ID AND s.DEL_FLAG = '0' )
@@ -235,7 +255,17 @@
         case when r.PARENT_CODE !='0' then r.PARENT_CODE
         ELSE R.CATEGORY_CODE
         END
-        ) as firstCategoryCode
+        ) as firstCategoryCode,
+        (
+            CASE WHEN R.DEMAND_USER_TYPE='ic_resi_user' THEN R.DEMAND_USER_ID
+            ELSE ''
+            END
+        ) as icResiUserId,
+        (
+            CASE WHEN R.DEMAND_USER_TYPE='mini_resi' THEN R.DEMAND_USER_ID
+            ELSE ''
+            END
+        ) as epmetUserId
         FROM
         ic_user_demand_rec r
         left JOIN ic_user_demand_service s ON ( r.id = s.DEMAND_REC_ID AND s.DEL_FLAG = '0' )