diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportController.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportController.java index 9be7fff..d2043a3 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportController.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/controller/ScreenBaseReportController.java @@ -2,6 +2,7 @@ package com.elink.esua.epdc.modules.screen.controller; import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.modules.screen.service.ScreenBaseReportService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; @@ -13,6 +14,7 @@ import org.springframework.web.bind.annotation.RestController; * @author zhy * @date 2021/6/28 11:07 */ +@Slf4j @RestController @RequestMapping("data/stats/basereport") public class ScreenBaseReportController { @@ -30,6 +32,7 @@ public class ScreenBaseReportController { */ @PostMapping("gridHotTopic") public Result gridHotTopic() { + log.info("定时任务执行"); return screenBaseReportService.gridHotTopic(); } @@ -43,6 +46,7 @@ public class ScreenBaseReportController { */ @PostMapping("agencyHotTopic") public Result agencyHotTopic() { + log.info("定时任务执行"); return screenBaseReportService.agencyHotTopic(); } @@ -56,6 +60,7 @@ public class ScreenBaseReportController { */ @PostMapping("gridIssue") public Result gridIssue() { + log.info("定时任务执行"); return screenBaseReportService.gridIssue(); } @@ -69,6 +74,7 @@ public class ScreenBaseReportController { */ @PostMapping("agencyIssue") public Result agencyIssue() { + log.info("定时任务执行"); return screenBaseReportService.agencyIssue(); } @@ -82,6 +88,7 @@ public class ScreenBaseReportController { */ @PostMapping("gridRegUser") public Result gridRegUser() { + log.info("定时任务执行"); return screenBaseReportService.gridRegUser(); } @@ -95,7 +102,109 @@ public class ScreenBaseReportController { */ @PostMapping("agencyRegUser") public Result agencyRegUser() { + log.info("定时任务执行"); return screenBaseReportService.agencyRegUser(); } + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + @PostMapping("gridtopicstatus") + Result gridTopicStatus() { + log.info("定时任务执行"); + return screenBaseReportService.gridTopicStatus(); + } + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + @PostMapping("agencytopicstatus") + Result agencyTopicStatus() { + log.info("定时任务执行"); + return screenBaseReportService.agencyTopicStatus(); + } + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + @PostMapping("gridtopicissue") + Result gridTopicIssue() { + log.info("定时任务执行"); + return screenBaseReportService.gridTopicIssue(); + } + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + @PostMapping("agencytopicissue") + Result agencyTopicIssue() { + log.info("定时任务执行"); + return screenBaseReportService.agencyTopicIssue(); + } + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridproject") + Result selectGridProjectList() { + log.info("定时任务执行"); + return screenBaseReportService.selectGridProjectList(); + } + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencyproject") + Result selectCommunityProjectList() { + log.info("定时任务执行"); + return screenBaseReportService.selectCommunityProjectList(); + } + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("gridgrouptotal") + Result selectGridGroupTotalList() { + log.info("定时任务执行"); + return screenBaseReportService.selectGridGroupTotalList(); + } + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + @PostMapping("agencygrouptotal") + Result selectCommunityGroupTotalList() { + log.info("定时任务执行"); + return screenBaseReportService.selectCommunityGroupTotalList(); + } + } diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDao.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDao.java index e8bf0cb..686b112 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDao.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/dao/ScreenBaseReportDao.java @@ -3,6 +3,7 @@ package com.elink.esua.epdc.modules.screen.dao; import com.elink.esua.epdc.commons.mybatis.dao.BaseDao; import com.elink.esua.epdc.dto.screen.result.*; import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; import java.util.List; @@ -88,4 +89,78 @@ public interface ScreenBaseReportDao extends BaseDao * @date 2021/6/28 14:07 */ List agencyRegUser(); + + /** + * @return java.util.List + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectGridTopicStatusList(@Param("customId") String customId); + + /** + * @return java.util.List + * @Description 社区状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectCommunityTopicStatusList(@Param("customId") String customId); + + /** + * @return java.util.List + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectGridTopicIssueList(@Param("customId") String customId); + + /** + * @return java.util.List + * @Description 社区话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectCommunityTopicIssueList(@Param("customId") String customId); + + /** + * @return java.util.List + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectGridProjectList(@Param("customId") String customId); + + /** + * @return java.util.List + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectCommunityProjectList(@Param("customId") String customId); + + + /** + * @return java.util.List + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectGridGroupTotalList(@Param("customId") String customId); + + + /** + * @return java.util.List + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + List selectCommunityGroupTotalList(@Param("customId") String customId); } diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportService.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportService.java index b26f775..456c8fe 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportService.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/ScreenBaseReportService.java @@ -70,4 +70,75 @@ public interface ScreenBaseReportService { */ Result agencyRegUser(); + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 网格状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + Result gridTopicStatus(); + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 组织状态话题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + Result agencyTopicStatus(); + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 网格话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + Result gridTopicIssue(); + + /** + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Description 组织话题转议题数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [] + **/ + Result agencyTopicIssue(); + + /** + * @Description 网格项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridProjectList(); + + /** + * @Description 组织项目数据 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectCommunityProjectList(); + + + /** + * @Description 网格群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectGridGroupTotalList(); + + + /** + * @Description 组织群组总数 + * @Author songyunpeng + * @Date 2021/6/25 + * @Param [customId] + **/ + Result selectCommunityGroupTotalList(); + + } diff --git a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportServiceImpl.java b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportServiceImpl.java index f1d84c9..41b23f4 100644 --- a/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportServiceImpl.java +++ b/epdc-cloud-analysis-pc/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/ScreenBaseReportServiceImpl.java @@ -8,7 +8,7 @@ import com.elink.esua.epdc.dto.screen.result.*; import com.elink.esua.epdc.modules.screen.dao.ScreenBaseReportDao; import com.elink.esua.epdc.modules.screen.service.ScreenBaseReportService; import com.elink.esua.epdc.utils.EpmetUtils; -import lombok.extern.slf4j.Slf4j; +import com.elink.esua.epdc.utils.ScreenDataUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -23,7 +23,6 @@ import java.util.List; * @date 2021/6/28 13:51 */ @Service -@Slf4j public class ScreenBaseReportServiceImpl extends BaseServiceImpl implements ScreenBaseReportService { @Autowired @@ -97,4 +96,77 @@ public class ScreenBaseReportServiceImpl extends BaseServiceImpl gridTopicStatusResultDTOS = baseDao.selectGridTopicStatusList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(gridTopicStatusResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_STATUS, dataJson); + return new Result(); + } + + @Override + public Result agencyTopicStatus() { + List communityTopicStatusResultDTOS = baseDao.selectCommunityTopicStatusList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(communityTopicStatusResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_TOPIC_STATUS, dataJson); + return new Result(); + } + + @Override + public Result gridTopicIssue() { + List gridTopicIssueResultDTOS = baseDao.selectGridTopicIssueList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(gridTopicIssueResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_TOPIC_ISSUE, dataJson); + return new Result(); + } + + @Override + public Result agencyTopicIssue() { + List communityTopicIssueResultDTOS = baseDao.selectCommunityTopicIssueList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(communityTopicIssueResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGNENCY_TOPIC_ISSUE, dataJson); + return new Result(); + } + + @Override + public Result selectGridProjectList() { + List gridGridProjectResultDTOS = baseDao.selectGridProjectList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(gridGridProjectResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_PROJECT, dataJson); + return new Result(); + } + + @Override + public Result selectCommunityProjectList() { + List communityProjectResultDTOS = baseDao.selectCommunityProjectList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(communityProjectResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_PROJECT, dataJson); + return new Result(); + } + + @Override + public Result selectGridGroupTotalList() { + List gridGroupTotalResultDTOS = baseDao.selectGridGroupTotalList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(gridGroupTotalResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_GRID_GROUP_TOTAL, dataJson); + return new Result(); + } + + @Override + public Result selectCommunityGroupTotalList() { + List communityTopicIssueResultDTOS = baseDao.selectCommunityTopicIssueList(EPMET_CONFIG_CUSTOMER_ID); + String dataJson = ScreenDataUtils.getScreenDateJson(communityTopicIssueResultDTOS, true); + // 数据上报 + epmetUtils.httpPost(EpmetConstant.EPMET_SCREEN_BASE_REPORT_AGENCY_GROUP_TOTAL, dataJson); + return new Result(); + } + } diff --git a/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenBaseReportDao.xml b/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenBaseReportDao.xml index 265da84..f91b88b 100644 --- a/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenBaseReportDao.xml +++ b/epdc-cloud-analysis-pc/src/main/resources/mapper/screen/ScreenBaseReportDao.xml @@ -1267,4 +1267,386 @@ ) + + + + + + + + +