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

增加8接口

feature/zhy_unlock
zhangyuan 4 years ago
parent
6137dc4f54
commit
3577f34ed4
3 changed files with 300 additions and 9 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. 90
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java
  2. 41
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java
  3. 178
      epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportPushTaskImpl.java

90
epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AnalysisFeignClient.java
View File

@ -620,4 +620,94 @@ public interface AnalysisFeignClient {
*/
@PostMapping("analysis/data/stats/basereport/agencyRegUser")
Result agencyRegUser(ScreenJobFormDTO formDto);
/**
* 网格状态话题数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/gridtopicstatus")
Result gridtopicstatus(ScreenJobFormDTO formDto);
/**
* 组织状态话题数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/agencytopicstatus")
Result agencytopicstatus(ScreenJobFormDTO formDto);
/**
* 网格话题转议题数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/gridtopicissue")
Result gridtopicissue(ScreenJobFormDTO formDto);
/**
* 组织话题转议题数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/agencytopicissue")
Result agencytopicissue(ScreenJobFormDTO formDto);
/**
* 网格项目数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/gridproject")
Result gridproject(ScreenJobFormDTO formDto);
/**
* 组织项目数据
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/agencyproject")
Result agencyproject(ScreenJobFormDTO formDto);
/**
* 网格群组总数
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/gridgrouptotal")
Result gridgrouptotal(ScreenJobFormDTO formDto);
/**
* 组织群组总数
*
* @param formDto 定时入参
* @return com.elink.esua.epdc.commons.tools.utils.Result
* @author zhy
* @date 2021/6/28 10:57
*/
@PostMapping("analysis/data/stats/basereport/agencygrouptotal")
Result agencygrouptotal(ScreenJobFormDTO formDto);
}

41
epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AnalysisFeignClientFallback.java
View File

@ -299,4 +299,45 @@ public class AnalysisFeignClientFallback implements AnalysisFeignClient {
public Result agencyRegUser(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencyRegUser");
}
@Override
public Result gridtopicstatus(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridtopicstatus");
}
@Override
public Result agencytopicstatus(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencytopicstatus");
}
@Override
public Result gridtopicissue(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridtopicissue");
}
@Override
public Result agencytopicissue(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencytopicissue");
}
@Override
public Result gridproject(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridproject");
}
@Override
public Result agencyproject(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencyproject");
}
@Override
public Result gridgrouptotal(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "gridgrouptotal");
}
@Override
public Result agencygrouptotal(ScreenJobFormDTO formDto) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_ANALYSIS_SERVER, "agencygrouptotal");
}
}

178
epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportPushTaskImpl.java
View File

@ -1,7 +1,7 @@
package com.elink.esua.epdc.task.screen;
import com.alibaba.fastjson.JSONObject;
import com.elink.esua.epdc.dto.ScreenIndexBasicDataParamDTO;
import com.elink.esua.epdc.dto.ScreenBaseReportParamDTO;
import com.elink.esua.epdc.dto.screen.form.ScreenJobFormDTO;
import com.elink.esua.epdc.feign.AnalysisFeignClient;
import org.apache.commons.lang3.StringUtils;
@ -27,23 +27,38 @@ public class ScreenBaseReportPushTaskImpl implements ScreenBaseReportPushTask {
@Override
public void run(String param) {
// 参数处理
ScreenIndexBasicDataParamDTO paramDto = new ScreenIndexBasicDataParamDTO();
ScreenBaseReportParamDTO paramDto = new ScreenBaseReportParamDTO();
if (StringUtils.isNotEmpty(param)) {
paramDto = JSONObject.parseObject(param, ScreenIndexBasicDataParamDTO.class);
paramDto = JSONObject.parseObject(param, ScreenBaseReportParamDTO.class);
}
// 01、网格热议话题数据
gridHotTopic(paramDto.getGridPartyMemberData());
gridHotTopic(paramDto.getGridHotTopic());
// 02、组织热议话题数据
agencyHotTopic(paramDto.getGridPartyAbility());
agencyHotTopic(paramDto.getAgencyHotTopic());
// 03、网格议题数据
gridIssue(paramDto.getOrgPartyAbility());
gridIssue(paramDto.getGridIssue());
// 04、组织议题数据
agencyIssue(paramDto.getGridServiceAbility());
agencyIssue(paramDto.getAgencyIssue());
// 05、网格注册用户数据
gridRegUser(paramDto.getOrgServiceAbility());
gridRegUser(paramDto.getGridRegUser());
// 06、组织注册用户数据
agencyRegUser(paramDto.getGridGovernAbility());
agencyRegUser(paramDto.getAgencyRegUser());
gridtopicstatus(paramDto.getGridtopicstatus());
agencytopicstatus(paramDto.getAgencytopicstatus());
gridtopicissue(paramDto.getGridtopicissue());
agencytopicissue(paramDto.getAgencytopicissue());
gridproject(paramDto.getGridproject());
agencyproject(paramDto.getAgencyproject());
gridgrouptotal(paramDto.getGridgrouptotal());
agencygrouptotal(paramDto.getAgencygrouptotal());
}
/**
@ -154,4 +169,149 @@ public class ScreenBaseReportPushTaskImpl implements ScreenBaseReportPushTask {
logger.info("<" + methodName + "|组织注册用户数据>定时任务执行结束");
}
/**
* 网格状态话题数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void gridtopicstatus(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|网格状态话题数据>定时任务开始执行");
analysisFeignClient.gridtopicstatus(formDto);
logger.info("<" + methodName + "|网格状态话题数据>定时任务执行结束");
}
/**
* 组织状态话题数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void agencytopicstatus(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|组织状态话题数据>定时任务开始执行");
analysisFeignClient.agencytopicstatus(formDto);
logger.info("<" + methodName + "|组织状态话题数据>定时任务执行结束");
}
/**
* 网格话题转议题数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void gridtopicissue(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|网格话题转议题数据>定时任务开始执行");
analysisFeignClient.gridtopicissue(formDto);
logger.info("<" + methodName + "|网格话题转议题数据>定时任务执行结束");
}
/**
* 网格话题转议题数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void agencytopicissue(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|网格话题转议题数据>定时任务开始执行");
analysisFeignClient.agencytopicissue(formDto);
logger.info("<" + methodName + "|网格话题转议题数据>定时任务执行结束");
}
/**
* 网格项目数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void gridproject(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|网格项目数据>定时任务开始执行");
analysisFeignClient.gridproject(formDto);
logger.info("<" + methodName + "|网格项目数据>定时任务执行结束");
}
/**
* 组织项目数据
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void agencyproject(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|组织项目数据>定时任务开始执行");
analysisFeignClient.agencyproject(formDto);
logger.info("<" + methodName + "|组织项目数据>定时任务执行结束");
}
/**
* 网格群组总数
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void gridgrouptotal(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|网格群组总数>定时任务开始执行");
analysisFeignClient.gridgrouptotal(formDto);
logger.info("<" + methodName + "|网格群组总数>定时任务执行结束");
}
/**
* 组织群组总数
*
* @param yearMonth
* @return void
* @author zhy
* @date 2021/6/28 10:48
*/
public void agencygrouptotal(String yearMonth) {
ScreenJobFormDTO formDto = new ScreenJobFormDTO();
formDto.setYearMonth(yearMonth);
// 方法名
String methodName = Thread.currentThread().getStackTrace()[2].getMethodName();
logger.info("<" + methodName + "|组织群组总数>定时任务开始执行");
analysisFeignClient.agencygrouptotal(formDto);
logger.info("<" + methodName + "|组织群组总数>定时任务执行结束");
}
}

Write Preview
Loading…
Cancel
Save