job修改

epmet-module/epmet-job/epmet-job-server/pom.xml

@@ -90,6 +90,12 @@
             <version>2.0.0</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.epmet</groupId>
+            <artifactId>gov-issue-client</artifactId>
+            <version>2.0.0</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/GovIssueFeignClient.java

@@ -2,6 +2,7 @@ package com.epmet.feign;
 
 import com.epmet.commons.tools.constant.ServiceConstant;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 import com.epmet.feign.impl.GovIssueFeignClientFallBack;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -22,7 +23,7 @@ public interface GovIssueFeignClient {
      * @date 2020.05.20 15:39
      **/
     @PostMapping(value = "gov/issue/issuevotestatisticaldaily/dailystatisticalvotejob")
-    Result dailyStatisticalVoteJob();
+    Result dailyStatisticalVoteJob(DailyStatisticalVoteJob form);
 
     /**
      * @Description 将所有表决中的投票数从缓存同步到数据库，要进行数据对比，若数据一致无需更新

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/feign/impl/GovIssueFeignClientFallBack.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.form.DailyStatisticalVoteJob;
 import com.epmet.feign.GovIssueFeignClient;
 import org.springframework.stereotype.Component;
 
@@ -15,8 +16,8 @@ import org.springframework.stereotype.Component;
 @Component
 public class GovIssueFeignClientFallBack implements GovIssueFeignClient {
     @Override
-    public Result dailyStatisticalVoteJob() {
-        return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "dailyStatisticalVoteJob");
+    public Result dailyStatisticalVoteJob(DailyStatisticalVoteJob form) {
+        return ModuleUtils.feignConError(ServiceConstant.GOV_ISSUE_SERVER, "dailyStatisticalVoteJob",form);
     }
 
     @Override

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/IssueVotingDailyStatisticalTaskService.java

@@ -2,6 +2,7 @@ package com.epmet.service;
 
 
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 
 /**
  * @Description 生成议题表决日统计数定时任务
@@ -10,6 +11,6 @@ import com.epmet.commons.tools.utils.Result;
  */
 public interface IssueVotingDailyStatisticalTaskService {
 
-    Result issueVotingDailyStatistical();
+    Result issueVotingDailyStatistical(DailyStatisticalVoteJob form);
 
 }

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/IssueVotingDailyStatisticalTaskServiceImpl.java

@@ -1,6 +1,7 @@
 package com.epmet.service.impl;
 
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 import com.epmet.feign.GovIssueFeignClient;
 import com.epmet.service.IssueVotingDailyStatisticalTaskService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -18,7 +19,7 @@ public class IssueVotingDailyStatisticalTaskServiceImpl implements IssueVotingDa
     private GovIssueFeignClient govIssueFeignClient;
 
     @Override
-    public Result issueVotingDailyStatistical() {
-        return govIssueFeignClient.dailyStatisticalVoteJob();
+    public Result issueVotingDailyStatistical(DailyStatisticalVoteJob form) {
+        return govIssueFeignClient.dailyStatisticalVoteJob(form);
     }
 }

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/DailyStatisticalVoteTask.java

@@ -1,7 +1,10 @@
 package com.epmet.task;
 
+import com.alibaba.fastjson.JSON;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.form.DailyStatisticalVoteJob;
 import com.epmet.service.IssueVotingDailyStatisticalTaskService;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,7 +27,11 @@ public class DailyStatisticalVoteTask implements ITask{
     @Override
     public void run(String params) {
         logger.debug("dailyStatisticalVoteTask定时任务正在执行，参数为：{}", params);
-        Result result=issueVotingDailyStatisticalTaskService.issueVotingDailyStatistical();
+        DailyStatisticalVoteJob form = new DailyStatisticalVoteJob();
+        if (StringUtils.isNotBlank(params)) {
+            form = JSON.parseObject(params, DailyStatisticalVoteJob.class);
+        }
+        Result result=issueVotingDailyStatisticalTaskService.issueVotingDailyStatistical(form);
         if(result.success()){
             logger.debug("dailyStatisticalVoteTask定时任务正在执行定时任务执行成功");
         }else{