elink-star
/
epdc-cloud-admin-yushan
12
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

社区用户推送

master
wanggongfeng 3 years ago
parent
62bff6e22b
commit
61da16bfba
3 changed files with 71 additions and 53 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      epdc-cloud-admin/src/main/java/com/elink/esua/epdc/dao/SysUserDao.java
  2. 111
      epdc-cloud-admin/src/main/java/com/elink/esua/epdc/service/impl/SysUserServiceImpl.java
  3. 11
      epdc-cloud-admin/src/main/resources/mapper/SysUserDao.xml

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

@ -150,4 +150,6 @@ public interface SysUserDao extends BaseDao<SysUserEntity> {
* @since 2021/8/28 22:18
*/
List<EpdcAppGridManListResultDTO> selectListGridmanInfo(EpdcAppGridManFormDTO formDto);
List<SysUserDTO> getIsGridLeaderByUserId(@Param("userId") Long userId);
}

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

@ -380,63 +380,68 @@ public class SysUserServiceImpl extends BaseServiceImpl<SysUserDao, SysUserEntit
* @date 2022/12/9 04:56
*/
private void sendInfo(SysUserDTO dto, SysUserEntity entity, int type) {
try {
// 获取网格的ManageId
SysDeptInfoResultDTO sysDeptInfoResultDTO = sysDeptInfoService.getSysDeptInfo(entity.getDeptId().toString());
if (type == NumConstant.ZERO) {
if(sysDeptInfoResultDTO.getGridManageId() != null && sysDeptInfoResultDTO.getCommunityManageId() != null){
ManageUserAddFormDTO userAddFormDTO = new ManageUserAddFormDTO();
userAddFormDTO.setGridId(sysDeptInfoResultDTO.getGridManageId());
userAddFormDTO.setUserName(entity.getUsername());
userAddFormDTO.setPhone(entity.getMobile());
userAddFormDTO.setGender(entity.getGender() == null ? "" : entity.getGender().toString());
userAddFormDTO.setBornTime("");
userAddFormDTO.setWorkDate("");
userAddFormDTO.setHeadImage(entity.getHeadUrl());
userAddFormDTO.setIntroduction(entity.getRemark());
userAddFormDTO.setDescription("");
userAddFormDTO.setCreateTime(entity.getCreateDate().toString());
userAddFormDTO.setOldManageId(entity.getId().toString());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserAddFormDTO:" + userAddFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.addManageUser(userAddFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserAdd result:" + result);
communityManageHandle(result, dto, entity);
}
} else if (type == NumConstant.ONE) {
SysUserEntity userEntity = baseDao.selectById(dto.getId());
if (userEntity != null && userEntity.getManageId() != null) {
ManageUserUpdFormDTO userUpdFormDTO = new ManageUserUpdFormDTO();
userUpdFormDTO.setUserName(entity.getUsername());
userUpdFormDTO.setGender(entity.getGender() == null ? "" : entity.getGender().toString());
userUpdFormDTO.setBornTime("");
userUpdFormDTO.setWorkDate("");
userUpdFormDTO.setHeadImage(entity.getHeadUrl());
userUpdFormDTO.setIntroduction(entity.getRemark());
userUpdFormDTO.setDescription("");
userUpdFormDTO.setId(userEntity.getManageId());
userUpdFormDTO.setGridId(sysDeptInfoResultDTO.getGridManageId());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserUpdFormDTO:" + userUpdFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.updManageUser(userUpdFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserupd result:" + result);
communityManageHandle(result, dto, entity);
}
} else if (type == NumConstant.TWO) {
SysUserEntity userEntity = baseDao.selectById(dto.getId());
if (userEntity != null && userEntity.getManageId() != null) {
ManageUserDelFormDTO userDelFormDTO = new ManageUserDelFormDTO();
userDelFormDTO.setId(userEntity.getManageId());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserDelFormDTO:" + userDelFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.delManageUser(userDelFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserDel result:" + result);
// 校验是否包含网格长角色
List<SysUserDTO> sysUserDTOS = baseDao.getIsGridLeaderByUserId(entity.getId());
if(sysUserDTOS != null && sysUserDTOS.size() > 0){
try {
// 获取网格的ManageId
SysDeptInfoResultDTO sysDeptInfoResultDTO = sysDeptInfoService.getSysDeptInfo(entity.getDeptId().toString());
if (type == NumConstant.ZERO) {
if(sysDeptInfoResultDTO.getGridManageId() != null){
ManageUserAddFormDTO userAddFormDTO = new ManageUserAddFormDTO();
userAddFormDTO.setGridId(sysDeptInfoResultDTO.getGridManageId());
userAddFormDTO.setUserName(entity.getUsername());
userAddFormDTO.setPhone(entity.getMobile());
userAddFormDTO.setGender(entity.getGender() == null ? "" : entity.getGender().toString());
userAddFormDTO.setBornTime("");
userAddFormDTO.setWorkDate("");
userAddFormDTO.setHeadImage(entity.getHeadUrl());
userAddFormDTO.setIntroduction(entity.getRemark());
userAddFormDTO.setDescription("");
userAddFormDTO.setCreateTime(entity.getCreateDate().toString());
userAddFormDTO.setOldManageId(entity.getId().toString());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserAddFormDTO:" + userAddFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.addManageUser(userAddFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserAdd result:" + result);
communityManageHandle(result, dto, entity);
}
} else if (type == NumConstant.ONE) {
SysUserEntity userEntity = baseDao.selectById(dto.getId());
if (userEntity != null && userEntity.getManageId() != null) {
ManageUserUpdFormDTO userUpdFormDTO = new ManageUserUpdFormDTO();
userUpdFormDTO.setUserName(entity.getUsername());
userUpdFormDTO.setGender(entity.getGender() == null ? "" : entity.getGender().toString());
userUpdFormDTO.setBornTime("");
userUpdFormDTO.setWorkDate("");
userUpdFormDTO.setHeadImage(entity.getHeadUrl());
userUpdFormDTO.setIntroduction(entity.getRemark());
userUpdFormDTO.setDescription("");
userUpdFormDTO.setId(userEntity.getManageId());
userUpdFormDTO.setGridId(sysDeptInfoResultDTO.getGridManageId());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserUpdFormDTO:" + userUpdFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.updManageUser(userUpdFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserupd result:" + result);
communityManageHandle(result, dto, entity);
}
} else if (type == NumConstant.TWO) {
SysUserEntity userEntity = baseDao.selectById(dto.getId());
if (userEntity != null && userEntity.getManageId() != null) {
ManageUserDelFormDTO userDelFormDTO = new ManageUserDelFormDTO();
userDelFormDTO.setId(userEntity.getManageId());
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserDelFormDTO:" + userDelFormDTO);
Result<GlobalResultDTO> result = communityManageFeignClient.delManageUser(userDelFormDTO);
log.info("++++++++++++++++++++++++++++++++++++++++++++sysUserDel result:" + result);
// communityManageHandle(result, dto, entity);
}
}
} catch (Exception e) {
log.error("推送社区管理接口失败：type>>" + type + "||id>>" + entity.getId());
}
} catch (Exception e) {
log.error("推送社区管理接口失败：type>>" + type + "||id>>" + entity.getId());
}
}
/**

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

@ -235,4 +235,15 @@
eur.CREATED_TIME DESC
LIMIT #{pageIndex}, #{pageSize}
</select>
<select id="getIsGridLeaderByUserId" parameterType="java.lang.Long" resultType="com.elink.esua.epdc.dto.SysUserDTO">
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.ID = #{userId}
</select>
</mapper>

Write Preview
Loading…
Cancel
Save