From ded694782f0be5ff2064797175ec6387eff0346b Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Wed, 1 Jul 2020 15:51:50 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E8=AE=AE=E9=A2=98=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=B7=BB=E5=8A=A0=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epmet/commons/tools/utils/DateUtils.java | 10 ++++++++++ .../epmet/dto/issue/form/IssueJobFromDTO.java | 15 ++++++++++++++ .../feign/DataStatisticalOpenFeignClient.java | 12 +++++++++++ .../controller/StatsIssueController.java | 20 +++++++++++-------- .../service/impl/StatsIssueServiceImpl.java | 5 +++-- .../resources/mapper/issue/StatsIssueDao.xml | 2 +- .../com/epmet/service/StatsIssueService.java | 2 +- .../service/impl/StatsIssueServiceImpl.java | 9 ++++++++- .../java/com/epmet/task/StatsIssueTask.java | 2 +- 9 files changed, 63 insertions(+), 14 deletions(-) create mode 100644 epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/issue/form/IssueJobFromDTO.java diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/DateUtils.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/DateUtils.java index 532420581a..d0c21c4d9a 100644 --- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/DateUtils.java +++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/DateUtils.java @@ -471,4 +471,14 @@ public class DateUtils { } return result; } + + public static Date getLastDayOfMonth(Date date) { + Calendar cale = Calendar.getInstance(); + cale.setTime(date); + cale.add(Calendar.MONTH, 0); + cale.set(Calendar.DAY_OF_MONTH, 1); + cale.add(Calendar.MONTH, 1); + cale.set(Calendar.DAY_OF_MONTH, 0); + return cale.getTime(); + } } diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/issue/form/IssueJobFromDTO.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/issue/form/IssueJobFromDTO.java new file mode 100644 index 0000000000..2c1342b857 --- /dev/null +++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/issue/form/IssueJobFromDTO.java @@ -0,0 +1,15 @@ +package com.epmet.dto.issue.form; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @author zhaoqifeng + * @dscription + * @date 2020/7/1 15:25 + */ +@Data +public class IssueJobFromDTO implements Serializable { + private String date; +} diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java index dffd25d035..3e697227fe 100644 --- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java +++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java @@ -2,9 +2,11 @@ package com.epmet.feign; import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.issue.form.IssueJobFromDTO; import com.epmet.feign.impl.DataStatisticalOpenFeignClientFallBack; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestParam; import java.util.Date; @@ -118,6 +120,16 @@ public interface DataStatisticalOpenFeignClient { @PostMapping("/data/stats/statsissue/issuestats") Result agencyGridIssueStats(); + /** + * 指定日期统计 + * @author zhaoqifeng + * @date 2020/7/1 15:29 + * @param fromDTO + * @return com.epmet.commons.tools.utils.Result + */ + @PostMapping("/data/stats/statsissue/issuestatsofdate") + Result agencyGridIssueStatsOfDate(@RequestBody IssueJobFromDTO fromDTO); + /** * @Description 数据统计-项目-机关日月统计 * @Author sun diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/StatsIssueController.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/StatsIssueController.java index b78ca89680..5c03066bda 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/StatsIssueController.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/StatsIssueController.java @@ -2,6 +2,7 @@ package com.epmet.controller; import com.epmet.commons.tools.utils.DateUtils; import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.issue.form.IssueJobFromDTO; import com.epmet.service.StatsIssueService; import lombok.Data; import org.springframework.beans.factory.annotation.Autowired; @@ -35,14 +36,17 @@ public class StatsIssueController { statsIssueService.agencyGridIssueStats(); return new Result(); } - @Data - private static class StatsDate implements Serializable { - private static final long serialVersionUID = 149723067011918433L; - private String date; - } - @PostMapping("date") - public Result agencyGridIssueStatsOfDate(@RequestBody StatsDate statsDate) { - statsIssueService.agencyGridIssueStatsOfDate(DateUtils.parse(statsDate.getDate(), DateUtils.DATE_PATTERN)); + + /** + * 指定日期统计 + * @author zhaoqifeng + * @date 2020/7/1 15:29 + * @param fromDTO + * @return com.epmet.commons.tools.utils.Result + */ + @PostMapping("issuestatsofdate") + public Result agencyGridIssueStatsOfDate(@RequestBody IssueJobFromDTO fromDTO) { + statsIssueService.agencyGridIssueStatsOfDate(DateUtils.parse(fromDTO.getDate(), DateUtils.DATE_PATTERN)); return new Result(); } } diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java index a4d845ab90..cd65b93af3 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java @@ -108,14 +108,15 @@ public class StatsIssueServiceImpl implements StatsIssueService { * @return void */ private void customerStats(String customerId, Date date) { + Date lastDate = DateUtils.getLastDayOfMonth(date); //机关议题日统计 saveIssueAgencyDaily(customerId, date); //机关议题月统计 - saveIssueAgencyMonthly(customerId, date); + saveIssueAgencyMonthly(customerId, lastDate); //网格议题日统计 saveIssueGridDaily(customerId, date); //网格议题月统计 - saveIssueGridMonthly(customerId, date); + saveIssueGridMonthly(customerId, lastDate); } @Override diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/issue/StatsIssueDao.xml b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/issue/StatsIssueDao.xml index a96cc346f8..2b6c50fb7f 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/issue/StatsIssueDao.xml +++ b/epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/issue/StatsIssueDao.xml @@ -86,7 +86,7 @@ WHERE DEL_FLAG = '0' AND CUSTOMER_ID = #{customerId} - AND DATE(CREATED_TIME) = #{date} + AND DATE(CREATED_TIME) #{date} GROUP BY ORG_ID, GRID_ID, ISSUE_STATUS diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/StatsIssueService.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/StatsIssueService.java index 23590743e6..0d2f89583c 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/StatsIssueService.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/StatsIssueService.java @@ -15,5 +15,5 @@ public interface StatsIssueService { * @param * @return com.epmet.commons.tools.utils.Result */ - Result agencyGridIssueStats(); + Result agencyGridIssueStats(String params); } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java index a6415241cf..6612488799 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/StatsIssueServiceImpl.java @@ -1,8 +1,10 @@ package com.epmet.service.impl; import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.issue.form.IssueJobFromDTO; import com.epmet.service.StatsIssueService; import com.epmet.feign.DataStatisticalOpenFeignClient; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -17,7 +19,12 @@ public class StatsIssueServiceImpl implements StatsIssueService { private DataStatisticalOpenFeignClient dataStatisticalOpenFeignClient; @Override - public Result agencyGridIssueStats() { + public Result agencyGridIssueStats(String params) { + if (StringUtils.isNotBlank(params)) { + IssueJobFromDTO dto = new IssueJobFromDTO(); + dto.setDate(params); + return dataStatisticalOpenFeignClient.agencyGridIssueStatsOfDate(dto); + } return dataStatisticalOpenFeignClient.agencyGridIssueStats(); } } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsIssueTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsIssueTask.java index 20448d11d2..742974bb50 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsIssueTask.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StatsIssueTask.java @@ -22,7 +22,7 @@ public class StatsIssueTask implements ITask { @Override public void run(String params) { log.debug("StatsGroupGridDailyTask定时任务正在执行，参数为：{}", params); - Result result = statsIssueService.agencyGridIssueStats(); + Result result = statsIssueService.agencyGridIssueStats(params); if (result.success()){ log.debug("StatsGroupGridDailyTask定时任务正在执行定时任务执行成功"); }else { From f1bb1968fc60862e718f2a1d856223e91976d703 Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Wed, 1 Jul 2020 15:57:33 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E8=AE=AE=E9=A2=98=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=B7=BB=E5=8A=A0=E6=97=B6?= =?UTF-8?q?=E9=97=B4=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../feign/impl/DataStatisticalOpenFeignClientFallBack.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java index a15b468fdc..a731ebb8de 100644 --- a/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java +++ b/epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java @@ -3,6 +3,7 @@ package com.epmet.feign.impl; import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.utils.ModuleUtils; import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.issue.form.IssueJobFromDTO; import com.epmet.feign.DataStatisticalOpenFeignClient; import org.springframework.stereotype.Component; @@ -118,6 +119,11 @@ public class DataStatisticalOpenFeignClientFallBack implements DataStatisticalOp return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStats"); } + @Override + public Result agencyGridIssueStatsOfDate(IssueJobFromDTO fromDTO) { + return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStatsOfDate"); + } + /** * @Description 数据统计-项目-机关日月统计 * @Author sun From 1f9bb72722c4590d48ddf46aa3387a21842fe116 Mon Sep 17 00:00:00 2001 From: jianjun Date: Wed, 1 Jul 2020 16:01:36 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E6=97=A5=E5=BF=97=E9=94=99=E8=AF=AF?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/epmet/constant/ProjectConstant.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/constant/ProjectConstant.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/constant/ProjectConstant.java index cf30b35552..3758d966f1 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/constant/ProjectConstant.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/constant/ProjectConstant.java @@ -51,6 +51,6 @@ public interface ProjectConstant { /** * 统计数据执行失败日志前缀 */ - String STATS_FAILED_PREFIX = "统计数据执行失败：%s 客户ID：%s，统计日期：%s，异常信息：%s"; + String STATS_FAILED_PREFIX = "统计数据执行失败：%s 客户ID：%s，统计日期：%s"; }