diff --git a/esua-epdc/epdc-admin/epdc-admin-client/src/main/java/com/elink/esua/epdc/dto/note/result/DeptRankResultDTO.java b/esua-epdc/epdc-admin/epdc-admin-client/src/main/java/com/elink/esua/epdc/dto/note/result/DeptRankResultDTO.java new file mode 100644 index 000000000..01efd4e38 --- /dev/null +++ b/esua-epdc/epdc-admin/epdc-admin-client/src/main/java/com/elink/esua/epdc/dto/note/result/DeptRankResultDTO.java @@ -0,0 +1,27 @@ +package com.elink.esua.epdc.dto.note.result; + +import lombok.Data; + +import java.io.Serializable; +import java.util.List; +import java.util.Map; + +/** + * @program: epdc-cloud-analysis + * @description: 街道、社区排行 + * @author: wangtong + * @create: 2020-11-25 09:22 + **/ +@Data +public class DeptRankResultDTO implements Serializable { + + /** + * 街道排行 + */ + private Map streetRank; + + /** + * 社区排行 + */ + private Map communityRank; +} \ No newline at end of file diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java new file mode 100644 index 000000000..fcf608093 --- /dev/null +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java @@ -0,0 +1,40 @@ +package com.elink.esua.epdc.feign; + +import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; +import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.note.result.DeptRankResultDTO; +import com.elink.esua.epdc.feign.fallback.AnalysisFeignClientFallback; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.GetMapping; + +import java.util.List; + +/** + * 调用 社区 街道 综合指标排名 + * @Author wk + * @Date 2022/11/25 11:00 + */ +@FeignClient(name = ServiceConstant.EPDC_ANALYSIS_SERVER, fallback = AnalysisFeignClientFallback.class) +public interface AnalysisFeignClient { + + + /** + * 测试 + * @Return: com.elink.esua.epdc.commons.tools.utils.Result + * @Author: lipengfei + * @Date: 2019/11/19 16:42 + */ + @GetMapping(value = "analysis/item/test", consumes = MediaType.APPLICATION_JSON_VALUE) + Result test(); + /* + * + * 调用街道,社区排名接口 + * @author wk + * @date 2020-11-25 10:16 + * @return com.elink.esua.epdc.commons.tools.utils.Result + */ + @GetMapping(value = "analysis/performanceScore/getDeptRank", consumes = MediaType.APPLICATION_JSON_VALUE) + Result getDeptRank(); + +} diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java new file mode 100644 index 000000000..e1dd21478 --- /dev/null +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java @@ -0,0 +1,29 @@ +package com.elink.esua.epdc.feign.fallback; + +import com.elink.esua.epdc.commons.tools.constant.ServiceConstant; +import com.elink.esua.epdc.commons.tools.utils.ModuleUtils; +import com.elink.esua.epdc.commons.tools.utils.Result; +import com.elink.esua.epdc.dto.note.result.DeptRankResultDTO; +import com.elink.esua.epdc.feign.AnalysisFeignClient; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @Author LPF + * @Date 2019/11/18 16:39 + */ +@Component +public class AnalysisFeignClientFallback implements AnalysisFeignClient { + + @Override + public Result test() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "test"); + } + + @Override + public Result getDeptRank() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "getDeptRank"); + } + +} diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/UserAnalysisNoteServiceImpl.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/UserAnalysisNoteServiceImpl.java index 276e98a1d..819425900 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/UserAnalysisNoteServiceImpl.java +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/UserAnalysisNoteServiceImpl.java @@ -27,13 +27,16 @@ import com.elink.esua.epdc.commons.tools.security.user.SecurityUser; import com.elink.esua.epdc.commons.tools.security.user.UserDetail; import com.elink.esua.epdc.commons.tools.utils.ConvertUtils; import com.elink.esua.epdc.commons.tools.constant.FieldConstant; +import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.dao.UserAnalysisNoteDao; import com.elink.esua.epdc.dto.ParentAndAllDeptDTO; import com.elink.esua.epdc.dto.SysUserDTO; import com.elink.esua.epdc.dto.UserAnalysisNoteDTO; import com.elink.esua.epdc.dto.form.SmsNoticeFormDTO; +import com.elink.esua.epdc.dto.note.result.DeptRankResultDTO; import com.elink.esua.epdc.entity.SysUserEntity; import com.elink.esua.epdc.entity.UserAnalysisNoteEntity; +import com.elink.esua.epdc.feign.AnalysisFeignClient; import com.elink.esua.epdc.feign.MessageFeignClient; import com.elink.esua.epdc.redis.UserAnalysisNoteRedis; import com.elink.esua.epdc.service.SysDeptService; @@ -63,6 +66,8 @@ public class UserAnalysisNoteServiceImpl extends BaseServiceImpl params = new HashMap<>(); List userNoteList = baseDao.getList(params); //获取街道排名和社区排名(这个要调接口) - MapstreeRanking = new HashMap<>(); - MapcommuniytRanking = new HashMap<>(); + Result deptRank = analysisFeignClient.getDeptRank(); + DeptRankResultDTO deptRankResultDto = deptRank.getData(); + MapstreeRanking = deptRankResultDto.getStreetRank(); + MapcommuniytRanking = deptRankResultDto.getCommunityRank(); //根据信息区分出街道账号和区级账号 for (UserAnalysisNoteDTO dto:userNoteList) { //查询部门类型