社区用户推送

epdc-cloud-admin/src/main/java/com/elink/esua/epdc/controller/SysUserController.java

@@ -608,4 +608,18 @@ public class SysUserController {
         return new Result<List<Map<String, String>>>().ok(userList);
     }
 
+    /**
+     * 推送社区管理信息
+     *
+     * @param
+     * @return com.elink.esua.epdc.commons.tools.utils.Result
+     * @author wgf
+     * @date 2022/12/9 10:31
+     */
+    @PostMapping("manage/sendManageSysUser")
+    public Result sendManageSysUser() {
+        sysUserService.sendManageSysUser();
+        return new Result();
+    }
+
 }

epdc-cloud-admin/src/main/java/com/elink/esua/epdc/dao/SysUserDao.java

@@ -152,4 +152,6 @@ public interface SysUserDao extends BaseDao<SysUserEntity> {
     List<EpdcAppGridManListResultDTO> selectListGridmanInfo(EpdcAppGridManFormDTO formDto);
 
     List<SysUserDTO> getIsGridLeaderByUserId(@Param("userId") Long userId);
+
+    List<SysUserEntity> getManageSysUser();
 }

epdc-cloud-admin/src/main/java/com/elink/esua/epdc/service/SysUserService.java

@@ -188,4 +188,6 @@ public interface SysUserService extends BaseService<SysUserEntity> {
      * @since 2021/8/28 22:00
      */
     List<EpdcAppGridManListResultDTO> listGridmanInfo(EpdcAppGridManFormDTO formDto);
+
+    void sendManageSysUser();
 }

epdc-cloud-admin/src/main/java/com/elink/esua/epdc/service/impl/SysUserServiceImpl.java

@@ -35,6 +35,7 @@ import com.elink.esua.epdc.dto.epdc.result.EpdcAppGridManListResultDTO;
 import com.elink.esua.epdc.dto.management.form.*;
 import com.elink.esua.epdc.dto.management.result.GlobalResultDTO;
 import com.elink.esua.epdc.dto.result.SysDeptInfoResultDTO;
+import com.elink.esua.epdc.entity.SysDeptEntity;
 import com.elink.esua.epdc.entity.SysUserEntity;
 import com.elink.esua.epdc.feign.CommunityManageFeignClient;
 import com.elink.esua.epdc.service.*;
@@ -370,6 +371,21 @@ public class SysUserServiceImpl extends BaseServiceImpl<SysUserDao, SysUserEntit
         return listGridmanInfo;
     }
 
+    @Override
+    public void sendManageSysUser() {
+
+        List<SysUserEntity> list = baseDao.getManageSysUser();
+        log.info("本次推送社区管理信息数量SysUser>>" + list.size());
+        list.forEach(entity -> {
+            SysUserDTO dto = ConvertUtils.sourceToTarget(entity, SysUserDTO.class);
+            // 社区管理推送
+//            sendInfo(dto, entity, 0);
+        });
+
+
+
+    }
+
 
     /**
      * 推送处理

epdc-cloud-admin/src/main/resources/mapper/SysUserDao.xml

@@ -246,4 +246,16 @@
         and r.type_key = 'gridLeader'
         and user.ID = #{userId}
     </select>
+    <select id="getManageSysUser" resultType="com.elink.esua.epdc.entity.SysUserEntity">
+        select
+            user.*
+        from sys_user user
+        left join sys_role_user ru on ru.user_id = user.ID
+        left join sys_role r on r.Id = ru.role_id and r.del_flag = 0
+        where user.del_flag = 0
+        and user.status = 1
+        and r.type_key = 'gridLeader'
+        and user.MANAGE_ID IS NULL
+        group by user.ID
+    </select>
 </mapper>