Merge remote-tracking branch 'origin/dev_ic_diaodong' into develop

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/IcStatsResiWarnUserResultDTO.java

@@ -43,5 +43,6 @@ public class IcStatsResiWarnUserResultDTO implements Serializable {
     private String neighborhoodName;
     private String buildingName;
     private String residentNames;
+    private List<UserWarnNameListResultDTO> userList;
 
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserWarnNameListResultDTO.java

@@ -0,0 +1,24 @@
+package com.epmet.dto.result;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/1/24 10:25 上午
+ * @DESC
+ */
+@Data
+public class UserWarnNameListResultDTO implements Serializable {
+
+    private static final long serialVersionUID = 6695538440686292540L;
+
+    @JsonIgnore
+    private String buildingId;
+
+    private String residentName;
+
+    private String userId;
+}

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcStatsResiWarnDao.java

@@ -20,6 +20,7 @@ package com.epmet.dao;
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.dto.IcResiCategoryStatsConfigDTO;
 import com.epmet.dto.PersonWarnLeftPieDTO;
+import com.epmet.dto.result.UserWarnNameListResultDTO;
 import com.epmet.entity.IcStatsResiWarnEntity;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
@@ -43,6 +44,11 @@ public interface IcStatsResiWarnDao extends BaseDao<IcStatsResiWarnEntity> {
                                           @Param("tableName") String tableName,
                                           @Param("columnName") String columnName);
 
+    List<UserWarnNameListResultDTO> userWarnListDTO(@Param("customerId") String customerId,
+                                                 @Param("buildingIdList") List<String> buildingIdList,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("columnName") String columnName);
+
     Integer countListByLevelAndCol(
             @Param("customerId") String customerId,
             @Param("tableName") String tableName,

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java

@@ -78,6 +78,7 @@ public interface UserResiInfoDao extends BaseDao<UserResiInfoEntity> {
 	 * @date 2020/5/11 11:18
 	 */
 	IssueInitiatorResultDTO selectIssueInitiator(IssueInitiatorFormDTO formDTO);
+	IssueInitiatorResultDTO issueInitiatorByBaseInfo(IssueInitiatorFormDTO formDTO);
 
 	/**
 	 * @param userId

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/StatsResiWarnServiceImpl.java

@@ -159,12 +159,25 @@ public class StatsResiWarnServiceImpl implements StatsResiWarnService {
         IcResiCategoryWarnConfigDTO icResiCategoryWarnConfigDTO = warnResult.getData();
 
         //根据buildingID，tableName he columnName获取名字
-        List<Map<String, String>> maps = icStatsResiWarnDao.userWarnList(customerId,buildingIdList, icResiCategoryWarnConfigDTO.getTableName(), icResiCategoryWarnConfigDTO.getColumnName());
+//        List<Map<String, String>> maps = icStatsResiWarnDao.userWarnList(customerId,buildingIdList, icResiCategoryWarnConfigDTO.getTableName(), icResiCategoryWarnConfigDTO.getColumnName());
-        result.forEach(item->{
+        List<UserWarnNameListResultDTO> dtos = icStatsResiWarnDao.userWarnListDTO(customerId, buildingIdList, icResiCategoryWarnConfigDTO.getTableName(), icResiCategoryWarnConfigDTO.getColumnName());
-            item.setConfigId(configId);
+//        result.forEach(item->{
-            List<Map<String, String>> buildingIds = maps.stream().filter(map -> item.getBuildingId().equals(map.get("buildingId"))).collect(Collectors.toList());
+//            item.setConfigId(configId);
-            item.setResidentNames(CollectionUtils.isEmpty(buildingIds)?"":buildingIds.get(0).get("residentNames"));
+//            List<Map<String, String>> buildingIds = maps.stream().filter(map -> item.getBuildingId().equals(map.get("buildingId"))).collect(Collectors.toList());
-        });
+//            item.setResidentNames(CollectionUtils.isEmpty(buildingIds)?"":buildingIds.get(0).get("residentNames"));
+//        });
+        if (!CollectionUtils.isEmpty(dtos)){
+            Map<String, List<UserWarnNameListResultDTO>> groupByBuild = dtos.stream().collect(Collectors.groupingBy(UserWarnNameListResultDTO::getBuildingId));
+            result.forEach(item->{
+                item.setConfigId(configId);
+                groupByBuild.forEach((k,v) -> {
+                    if (item.getBuildingId().equals(k)){
+                        item.setUserList(v);
+                    }
+                });
+            });
+        }
+
 
         return mapResult;
     }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java

@@ -387,7 +387,9 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
 	 */
 	@Override
 	public IssueInitiatorResultDTO selectIssueInitiator(IssueInitiatorFormDTO formDTO) {
-		return userResiInfoDao.selectIssueInitiator(formDTO);
+		//return userResiInfoDao.selectIssueInitiator(formDTO);
+		//市北赋能平台查询议题创建人姓名，因没有上传userWechat表 所以改去userbaseinfo表查询
+		return userResiInfoDao.issueInitiatorByBaseInfo(formDTO);
 	}
 
 	/**

epmet-user/epmet-user-server/src/main/resources/mapper/IcStatsResiWarnDao.xml

@@ -147,4 +147,29 @@
             )
         GROUP BY CONFIG_ID
     </select>
+
+    <select id="userWarnListDTO" resultType="com.epmet.dto.result.UserWarnNameListResultDTO">
+        select
+        BUILD_ID as buildingId,
+        name as residentName,
+        ID AS userId
+        from ic_resi_user
+        where
+        BUILD_ID in
+        <foreach collection="buildingIdList" item="buildingId" open="(" separator="," close=" )">
+            #{buildingId}
+        </foreach>
+        <if test="tableName=='ic_resi_user'">
+            and ${columnName} = '1'
+        </if>
+        <if test="tableName!='ic_resi_user'">
+            and ID in (
+            select IC_RESI_USER  from  ${tableName} where ${columnName} = '1' and CUSTOMER_ID = #{customerId} and DEL_FLAG = '0'
+            )
+        </if>
+        and CUSTOMER_ID = #{customerId}
+        and DEL_FLAG = '0'
+        group by ID
+    </select>
+
 </mapper>

epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml

@@ -168,6 +168,34 @@
             AND uw.del_flag = 0
     </select>
 
+    <select id="issueInitiatorByBaseInfo" parameterType="com.epmet.dto.form.IssueInitiatorFormDTO" resultType="com.epmet.dto.result.IssueInitiatorResultDTO">
+        SELECT
+            CONCAT(
+                uri.street,
+                '-',
+                uri.surname,
+                CASE
+            WHEN uri.GENDER = '1' THEN
+                '先生'
+            WHEN uri.GENDER = '2' THEN
+                '女士'
+            ELSE
+                '先生/女士'
+            END
+            ) AS issueInitiator,
+            CONCAT(
+                uri.street,
+                '-',
+                uri.surname,
+                uri.NAME
+            ) AS realUserName
+        FROM
+            user_base_info uri
+        WHERE
+            uri.user_id = #{userId}
+            AND uri.del_flag = 0
+    </select>
+
     <!--  根据要用户id,查询用户注册的信息  -->
     <select id="selectByUserId" resultType="com.epmet.dto.UserResiInfoDTO">
         SELECT