diff --git a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/ScreenProjectServiceImpl.java b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/ScreenProjectServiceImpl.java index 3d673b31c4..a23152697e 100644 --- a/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/ScreenProjectServiceImpl.java +++ b/epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/ScreenProjectServiceImpl.java @@ -1,6 +1,7 @@ package com.epmet.datareport.service.evaluationindex.screen.impl; import com.epmet.commons.dynamic.datasource.annotation.DataSource; +import com.epmet.commons.tools.constant.AppClientConstant; import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.redis.common.CustomerStaffRedis; import com.epmet.commons.tools.utils.ConvertUtils; @@ -11,6 +12,7 @@ import com.epmet.datareport.dao.evaluationindex.screen.ScreenEventImgDataDao; import com.epmet.datareport.dao.evaluationindex.screen.ScreenProjectCategoryOrgDailyDao; import com.epmet.datareport.dao.evaluationindex.screen.ScreenProjectDataDao; import com.epmet.datareport.service.evaluationindex.screen.ScreenProjectService; +import com.epmet.dto.UserDTO; import com.epmet.dto.form.CustomerAgencyUserRoleFormDTO; import com.epmet.dto.form.screen.CategoryAnalysisFormDTO; import com.epmet.dto.form.screen.ColorProjectTotalFormDTO; @@ -23,7 +25,6 @@ import com.epmet.evaluationindex.screen.dto.result.ProjectDetailResultDTO; import com.epmet.evaluationindex.screen.dto.result.ScreenProjectDetailResultDTO; import com.epmet.evaluationindex.screen.dto.result.ScreenProjectDistributionResultDTO; import com.epmet.feign.EpmetUserOpenFeignClient; -import com.epmet.feign.OperCrmOpenFeignClient; import com.epmet.project.CustomerProjectCategoryDTO; import com.epmet.project.dto.form.CategoryTopAppealFormDTO; import com.epmet.project.dto.result.CategoryTopAppealResultDTO; @@ -60,8 +61,6 @@ public class ScreenProjectServiceImpl implements ScreenProjectService { @Autowired private ScreenProjectCategoryOrgDailyDao screenProjectCategoryOrgDailyDao; @Autowired - private OperCrmOpenFeignClient operCrmOpenFeignClient; - @Autowired private EpmetUserOpenFeignClient userOpenFeignClient; /** @@ -118,9 +117,13 @@ public class ScreenProjectServiceImpl implements ScreenProjectService { CustomerAgencyUserRoleFormDTO userRoleFormDTO = new CustomerAgencyUserRoleFormDTO(); userRoleFormDTO.setCustomerId(formDTO.getCustomerId()); userRoleFormDTO.setStaffId(item.getReportUserId()); - Map staffRoleMap = CustomerStaffRedis.getStaffRoleMap(formDTO.getCustomerId(), item.getReportUserId()); - if (!CollectionUtils.isEmpty(staffRoleMap)){ - item.setReportUserRoleSet(staffRoleMap.keySet()); + //只有工作端的用户才调用此接口 + Result userDTOResult = userOpenFeignClient.queryUserClient(item.getReportUserId()); + if (userDTOResult.success() && null != userDTOResult.getData() && AppClientConstant.APP_GOV.equals(userDTOResult.getData().getFromApp())) { + Map staffRoleMap = CustomerStaffRedis.getStaffRoleMap(formDTO.getCustomerId(), item.getReportUserId()); + if (!CollectionUtils.isEmpty(staffRoleMap)) { + item.setReportUserRoleSet(staffRoleMap.keySet()); + } } } diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java index 2c913bd585..cbec879b5b 100644 --- a/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java +++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java @@ -635,4 +635,15 @@ public interface EpmetUserOpenFeignClient { */ @PostMapping("/epmetuser/statsstaffpatrolrecorddaily/patrolinfo") Result> patrolInfo(@RequestParam("agencyId")String agencyId); + + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return + * @author yinzuomei + * @date 2021/9/10 8:56 上午 + */ + @GetMapping(value = "/epmetuser/user/queryUserClient/{userId}") + Result queryUserClient(@PathVariable("userId") String userId); } diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java index a68cab52f5..183196dad8 100644 --- a/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java +++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java @@ -450,4 +450,17 @@ public class EpmetUserOpenFeignClientFallback implements EpmetUserOpenFeignClien public Result> patrolInfo(String agencyId) { return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "patrolInfo", agencyId); } + + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return + * @author yinzuomei + * @date 2021/9/10 8:56 上午 + */ + @Override + public Result queryUserClient(String userId) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "queryUserClient", userId); + } } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserController.java index d4a4148450..f1cbcb114a 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserController.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserController.java @@ -12,11 +12,9 @@ import com.epmet.dto.UserWechatDTO; import com.epmet.dto.form.*; import com.epmet.dto.result.*; import com.epmet.service.UserService; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; /** * @Description @@ -172,4 +170,19 @@ public class UserController { return new Result().ok(userService.saveUserInfo(formDTO)); } + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return com.epmet.commons.tools.utils.Result + * @author yinzuomei + * @date 2021/9/10 8:49 上午 + */ + @GetMapping("queryUserClient/{userId}") + public Result queryUserClient(@PathVariable String userId){ + if(StringUtils.isBlank(userId)){ + return new Result<>(); + } + return new Result().ok(userService.queryUserClient(userId)); + } } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserDao.java index 7dc2a768d8..e4c7a2cec5 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserDao.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserDao.java @@ -1,6 +1,7 @@ package com.epmet.dao; import com.epmet.commons.mybatis.dao.BaseDao; +import com.epmet.dto.UserDTO; import com.epmet.dto.form.CreatedTimeByUserIdFormDTO; import com.epmet.dto.form.UserBasicInfoFormDTO; import com.epmet.dto.result.CreatedTimeByUserIdResultDTO; @@ -52,4 +53,14 @@ public interface UserDao extends BaseDao { * @Description 居民端-查询用户基础信息 **/ UserBasicInfo selectUserBasicInfo(UserBasicInfoFormDTO formDTO); + + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return com.epmet.dto.UserDTO + * @author yinzuomei + * @date 2021/9/10 8:51 上午 + */ + UserDTO selectByUserId(String userId); } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserService.java index cc2fb1aecf..33e7b1c7ad 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserService.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserService.java @@ -94,4 +94,14 @@ public interface UserService extends BaseService { * @date 2021/1/19 上午10:35 */ UserDTO saveUserInfo(UserInfoFormDTO formDTO); + + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return com.epmet.dto.UserDTO + * @author yinzuomei + * @date 2021/9/10 8:50 上午 + */ + UserDTO queryUserClient(String userId); } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java index 515f2ccba9..6c56b705a8 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java @@ -329,4 +329,17 @@ public class UserServiceImpl extends BaseServiceImpl implem return result; } + /** + * 根据userId查询用户所属终端,是居民端的用户还是工作人员,还是运营人员 + * + * @param userId + * @return com.epmet.dto.UserDTO + * @author yinzuomei + * @date 2021/9/10 8:50 上午 + */ + @Override + public UserDTO queryUserClient(String userId) { + return baseDao.selectByUserId(userId); + } + } diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/UserDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/UserDao.xml index a46001c8c6..bbdaf024ba 100644 --- a/epmet-user/epmet-user-server/src/main/resources/mapper/UserDao.xml +++ b/epmet-user/epmet-user-server/src/main/resources/mapper/UserDao.xml @@ -67,4 +67,18 @@ AND u.id = #{userId} LIMIT 1 + + +