From cbf8bde456552777a2a0bd5f382448067cc14bf0 Mon Sep 17 00:00:00 2001 From: wangchao Date: Wed, 1 Jul 2020 15:37:07 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E8=AF=9D=E9=A2=98=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E6=9C=88=E4=BF=AE=E6=94=B9=E3=80=81=E7=BB=9F=E8=AE=A1=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=9F=A5=E8=AF=A2=E6=8C=89=E7=85=A7=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E5=88=86=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../data-statistical-server/pom.xml | 2 +- .../service/topic/impl/TopicServiceImpl.java | 6 +- .../com/epmet/dto/ScheduleJobTypeDTO.java | 45 ++++++++ .../controller/ScheduleJobController.java | 7 ++ .../java/com/epmet/dao/ScheduleJobDao.java | 9 ++ .../com/epmet/service/ScheduleJobService.java | 3 + .../service/impl/ScheduleJobServiceImpl.java | 108 +++++++++++++++++- .../main/resources/mapper/ScheduleJobDao.xml | 9 ++ 8 files changed, 183 insertions(+), 6 deletions(-) create mode 100644 epmet-module/epmet-job/epmet-job-client/src/main/java/com/epmet/dto/ScheduleJobTypeDTO.java diff --git a/epmet-module/data-statistical/data-statistical-server/pom.xml b/epmet-module/data-statistical/data-statistical-server/pom.xml index 8a9a478a65..3c2cbaf611 100644 --- a/epmet-module/data-statistical/data-statistical-server/pom.xml +++ b/epmet-module/data-statistical/data-statistical-server/pom.xml @@ -159,7 +159,7 @@ 6379 123456 - false + true 122.152.200.70:8848 fcd6fc8f-ca3a-4b01-8026-2b05cdc5976b diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/topic/impl/TopicServiceImpl.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/topic/impl/TopicServiceImpl.java index 77df964e59..b4d298fcc4 100644 --- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/topic/impl/TopicServiceImpl.java +++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/topic/impl/TopicServiceImpl.java @@ -190,17 +190,19 @@ public class TopicServiceImpl implements TopicService { calendar.set(Calendar.HOUR_OF_DAY, NumConstant.ZERO); calendar.set(Calendar.MINUTE, NumConstant.ZERO); calendar.set(Calendar.SECOND, NumConstant.ZERO); + //现在的目标日期是[T-1] OR [目标日期] Date targetDateCheck = null == targetDate ? calendar.getTime() : targetDate; - + //现在的日历对象是[T-1] OR [目标日期] calendar.setTime(targetDateCheck); //如果目标日期是当月的最后一天 //if(calendar.get(Calendar.DATE) == calendar.getActualMaximum(Calendar.DAY_OF_MONTH)){ //求出这个月的第一天 - calendar.setTime(new Date()); + calendar.set(Calendar.DAY_OF_MONTH, NumConstant.ONE); calendar.set(Calendar.HOUR_OF_DAY, NumConstant.ZERO); calendar.set(Calendar.MINUTE, NumConstant.ZERO); calendar.set(Calendar.SECOND, NumConstant.ZERO); + //现在的日历对象是 [T-1]当月的第一天 OR [目标日期]当月的第一天 // isMonthEnd = true; //} diff --git a/epmet-module/epmet-job/epmet-job-client/src/main/java/com/epmet/dto/ScheduleJobTypeDTO.java b/epmet-module/epmet-job/epmet-job-client/src/main/java/com/epmet/dto/ScheduleJobTypeDTO.java new file mode 100644 index 0000000000..5a22b63cea --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-client/src/main/java/com/epmet/dto/ScheduleJobTypeDTO.java @@ -0,0 +1,45 @@ +package com.epmet.dto; + +import com.epmet.commons.tools.validator.group.DefaultGroup; +import com.fasterxml.jackson.annotation.JsonProperty; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import org.hibernate.validator.constraints.Range; + +import javax.validation.constraints.NotBlank; +import java.io.Serializable; +import java.util.Date; + +/** + * @Description + * @ClassName ScheduleJobTypeDTO + * @Auth wangc + * @Date 2020-07-01 11:05 + */ +@Data +public class ScheduleJobTypeDTO implements Serializable { + private static final long serialVersionUID = 398827917988646220L; + + private Long id; + + @NotBlank(message = "{schedule.bean.require}", groups = DefaultGroup.class) + private String beanName; + + private String params; + + @NotBlank(message = "{schedule.cron.require}", groups = DefaultGroup.class) + private String cronExpression; + + @Range(min=0, max=1, message = "{schedule.status.range}", groups = DefaultGroup.class) + private Integer status; + + @ApiModelProperty(value = "备注") + private String remark; + + @JsonProperty(access = JsonProperty.Access.READ_ONLY) + private Date createDate; + + private String type; + + private Integer order; +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/controller/ScheduleJobController.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/controller/ScheduleJobController.java index e8f7614752..5c12cd27bf 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/controller/ScheduleJobController.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/controller/ScheduleJobController.java @@ -17,6 +17,7 @@ import com.epmet.commons.tools.validator.group.AddGroup; import com.epmet.commons.tools.validator.group.DefaultGroup; import com.epmet.commons.tools.validator.group.UpdateGroup; import com.epmet.dto.ScheduleJobDTO; +import com.epmet.dto.ScheduleJobTypeDTO; import com.epmet.service.ScheduleJobService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -121,4 +122,10 @@ public class ScheduleJobController { return new Result(); } + @GetMapping("pageByType") + public Result> pageByType(@ApiIgnore @RequestParam Map params){ + PageData page = scheduleJobService.pageByType(params); + + return new Result>().ok(page); + } } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/dao/ScheduleJobDao.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/dao/ScheduleJobDao.java index 14744f4914..259dd99845 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/dao/ScheduleJobDao.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/dao/ScheduleJobDao.java @@ -9,9 +9,13 @@ package com.epmet.dao; import com.epmet.commons.mybatis.dao.BaseDao; +import com.epmet.dto.ScheduleJobTypeDTO; import com.epmet.entity.ScheduleJobEntity; import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.springframework.web.bind.annotation.PathVariable; +import java.util.List; import java.util.Map; /** @@ -26,4 +30,9 @@ public interface ScheduleJobDao extends BaseDao { * 批量更新状态 */ int updateBatch(Map map); + + /** + * 拿到所有 + * */ + List selectAllJobs(@Param("beanName")String beanName); } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ScheduleJobService.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ScheduleJobService.java index 306a5d3e74..8ab151cdff 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ScheduleJobService.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/ScheduleJobService.java @@ -11,6 +11,7 @@ package com.epmet.service; import com.epmet.commons.mybatis.service.BaseService; import com.epmet.commons.tools.page.PageData; import com.epmet.dto.ScheduleJobDTO; +import com.epmet.dto.ScheduleJobTypeDTO; import com.epmet.entity.ScheduleJobEntity; import java.util.Map; @@ -60,4 +61,6 @@ public interface ScheduleJobService extends BaseService { * 恢复运行 */ void resume(Long[] ids); + + PageData pageByType(Map params); } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ScheduleJobServiceImpl.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ScheduleJobServiceImpl.java index a2954e5c42..e8f0f55d97 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ScheduleJobServiceImpl.java +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/ScheduleJobServiceImpl.java @@ -16,6 +16,7 @@ import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.dao.ScheduleJobDao; import com.epmet.dto.ScheduleJobDTO; +import com.epmet.dto.ScheduleJobTypeDTO; import com.epmet.entity.ScheduleJobEntity; import com.epmet.enums.ScheduleStatusEnum; import com.epmet.service.ScheduleJobService; @@ -26,9 +27,9 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; -import java.util.Arrays; -import java.util.HashMap; -import java.util.Map; +import java.util.*; +import java.util.stream.Collectors; + @Service public class ScheduleJobServiceImpl extends BaseServiceImpl implements ScheduleJobService { @@ -66,6 +67,7 @@ public class ScheduleJobServiceImpl extends BaseServiceImpl pageByType(Map params) { + + List all = baseDao.selectAllJobs((String)params.get("beanName")); + //1 dim + //2 stats + + //2.1 publicity : 2.1.1article (daily) 2.1.2tag : 2.1.2.1used(daily monthly QuarterlyAndYearly) 2.1.2.2viewed(daily monthly QuarterlyAndYearly) + //2.2 project (agency grid) + //2.3 issue + //2.4 group : 2.4.1 agency(daily monthly) : 2.4.2 grid(daily) + //2.5 topic + //2.6 user + //3 other + + + List types = new LinkedList<>(); + types.add("DIM");types.add("OTHER");types.add("USER");types.add("GROUP");types.add("TOPIC");types.add("PROJECT"); + types.add("ISSUE");types.add("ARTICLE");types.add("TAGUSED");types.add("TAGVIEWED"); + int otherOrder = 0; + for(ScheduleJobTypeDTO job : all){ + if(job.getBeanName().toUpperCase().contains("DIM")){ + job.setType("DIM"); + job.setOrder(0); + }else if(job.getBeanName().toUpperCase().contains("TAGUSED")){ + job.setType("TAGUSED"); + if(job.getBeanName().toUpperCase().contains("DAILY")){ + job.setOrder(0); + }else if(job.getBeanName().toUpperCase().contains("MONTHLY")){ + job.setOrder(1); + }else{ + job.setOrder(2); + } + }else if(job.getBeanName().toUpperCase().contains("TAGVIEWED")){ + job.setType("TAGVIEWED"); + if(job.getBeanName().toUpperCase().contains("DAILY")){ + job.setOrder(0); + }else if(job.getBeanName().toUpperCase().contains("MONTHLY")){ + job.setOrder(1); + }else{ + job.setOrder(2); + } + }else if(job.getBeanName().toUpperCase().contains("PROJECT")){ + job.setType("PROJECT"); + if(job.getBeanName().toUpperCase().contains("AGENCY")){ + job.setOrder(0); + }else{ + job.setOrder(1); + } + }else if(job.getBeanName().toUpperCase().contains("ARTICLE")){ + job.setType("ARTICLE"); + job.setOrder(1); + }else if(job.getBeanName().toUpperCase().contains("ISSUE")){ + job.setType("ISSUE"); + job.setOrder(0); + }else if(job.getBeanName().toUpperCase().contains("GROUP")){ + job.setType("GROUP"); + if(job.getBeanName().toUpperCase().contains("AGENCY")){ + if(job.getBeanName().toUpperCase().contains("DAILY")){ + job.setOrder(0); + }else{ + job.setOrder(1); + } + }else{ + job.setOrder(2); + } + }else if(job.getBeanName().toUpperCase().contains("TOPIC")){ + job.setType("TOPIC"); + job.setOrder(0); + }else if(job.getBeanName().toUpperCase().contains("USER")){ + job.setType("USER"); + job.setOrder(0); + }else { + //other + job.setType("OTHER"); + job.setOrder(otherOrder); + otherOrder++; + } + } + + List jobList = new LinkedList<>(); + types.forEach(type -> { + jobList.addAll( + all.stream().filter(job -> StringUtils.equals(job.getType(),type)).sorted(Comparator.comparing(ScheduleJobTypeDTO :: getOrder)).collect(Collectors.toList())); + }); + + Integer page = null == params.get("page") ? 1 : Integer.parseInt((String)params.get("page")); + Integer limit = null == params.get("limit") ? 10 : Integer.parseInt((String)params.get("limit")); + Integer startIndex = (page - 1) * limit; + Integer endIndex = 0; + if(jobList.size() - (page -1) * limit <= limit){ + endIndex = jobList.size() ; + }else{ + endIndex = startIndex + limit ; + } + + return new PageData(jobList.subList(startIndex,endIndex),all.size()); + } + + } diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/resources/mapper/ScheduleJobDao.xml b/epmet-module/epmet-job/epmet-job-server/src/main/resources/mapper/ScheduleJobDao.xml index cc612dfac7..b73d381cf6 100644 --- a/epmet-module/epmet-job/epmet-job-server/src/main/resources/mapper/ScheduleJobDao.xml +++ b/epmet-module/epmet-job/epmet-job-server/src/main/resources/mapper/ScheduleJobDao.xml @@ -11,4 +11,13 @@ + + From ded694782f0be5ff2064797175ec6387eff0346b Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Wed, 1 Jul 2020 15:51:50 +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 --- .../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 3/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