Browse Source

通讯录消息相关接口

dev_shibei_match
zhaoqifeng 4 years ago
parent
commit
aaeb1ad4a7
  1. 2
      epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/epmetuser/result/RoleUsersResultDTO.java
  2. 2
      epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/govorg/ReceiverDTO.java
  3. 6
      epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
  4. 12
      epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java

2
epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/epmetuser/result/RoleUsersResultDTO.java

@ -20,6 +20,6 @@ public class RoleUsersResultDTO implements Serializable {
private String name; private String name;
private String headPhoto; private String headPhoto;
private String orgName; private String orgName;
private String gender; private Integer gender;
private List<String> roles; private List<String> roles;
} }

2
epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/govorg/ReceiverDTO.java

@ -35,5 +35,5 @@ public class ReceiverDTO implements Serializable {
/** /**
* 1男2女0未知 * 1男2女0未知
*/ */
private String gender; private Integer gender;
} }

6
epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java

@ -75,7 +75,11 @@ public class EpmetMessageServiceImpl implements EpmetMessageService {
ReceiverDTO dto = new ReceiverDTO(); ReceiverDTO dto = new ReceiverDTO();
dto.setStaffId(item.getStaffId()); dto.setStaffId(item.getStaffId());
dto.setReadFlag(item.getReadFlag()); dto.setReadFlag(item.getReadFlag());
//TODO redis获取用户信息 CustomerStaffInfoCacheResult staffInfoCache = customerStaffRedis.getStaffInfo(item.getCustomerId(), item.getStaffId());
dto.setStaffName(staffInfoCache.getRealName());
dto.setGender(staffInfoCache.getGender());
dto.setHeadPhoto(staffInfoCache.getHeadPhoto());
dto.setOrgName(staffInfoCache.getTwoOrgName());
return dto; return dto;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
result.setDataList(dataList); result.setDataList(dataList);

12
epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java

@ -5,7 +5,9 @@ import com.epmet.commons.dynamic.datasource.annotation.DataSource;
import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.commons.tools.constant.StrConstant; import com.epmet.commons.tools.constant.StrConstant;
import com.epmet.commons.tools.dto.form.IdAndNameDTO; import com.epmet.commons.tools.dto.form.IdAndNameDTO;
import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
import com.epmet.commons.tools.enums.OrgTypeEnum; import com.epmet.commons.tools.enums.OrgTypeEnum;
import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.utils.ConvertUtils;
import com.epmet.commons.tools.utils.DateUtils; import com.epmet.commons.tools.utils.DateUtils;
import com.epmet.constant.BadgeConstant; import com.epmet.constant.BadgeConstant;
@ -73,6 +75,8 @@ public class EpmetUserServiceImpl implements EpmetUserService {
private GovProjectService govProjectService; private GovProjectService govProjectService;
@Resource @Resource
private GovStaffRoleDao govStaffRoleDao; private GovStaffRoleDao govStaffRoleDao;
@Resource
private CustomerStaffRedis customerStaffRedis;
/** /**
* @Description 根据UserIds查询 * @Description 根据UserIds查询
@ -481,7 +485,13 @@ public class EpmetUserServiceImpl implements EpmetUserService {
return staffRoleList.stream().map(item -> { return staffRoleList.stream().map(item -> {
RoleUsersResultDTO dto = new RoleUsersResultDTO(); RoleUsersResultDTO dto = new RoleUsersResultDTO();
dto.setStaffId(item.getStaffId()); dto.setStaffId(item.getStaffId());
//TODO 从redis获取用户信息 //从redis获取用户信息
CustomerStaffInfoCacheResult staffInfoCache = customerStaffRedis.getStaffInfo(item.getCustomerId(), item.getStaffId());
dto.setGender(staffInfoCache.getGender());
dto.setHeadPhoto(staffInfoCache.getHeadPhoto());
dto.setName(staffInfoCache.getRealName());
dto.setOrgName(staffInfoCache.getTwoOrgName());
dto.setRoles(new ArrayList<>(staffInfoCache.getRoleMap().values()));
return dto; return dto;
}).collect(Collectors.toList()); }).collect(Collectors.toList());
} }

Loading…
Cancel
Save