init

pom.xml

@@ -112,21 +112,15 @@
             <artifactId>spring-boot-starter-data-redis</artifactId>
         </dependency>
 
-        <!-- hnqz 依赖 -->
         <dependency>
-            <groupId>com.qunzhixinxi</groupId>
-            <artifactId>hnqz-upms-api</artifactId>
-            <version>3.9.0</version>
-        </dependency>
-        <dependency>
-            <groupId>com.qunzhixinxi</groupId>
-            <artifactId>hnqz-common-log</artifactId>
-            <version>3.9.0</version>
+            <groupId>net.yyc.common</groupId>
+            <artifactId>yyc-common-core</artifactId>
+            <version>1.0.0-SNAPSHOT</version>
         </dependency>
         <dependency>
-            <groupId>com.qunzhixinxi</groupId>
-            <artifactId>hnqz-common-data</artifactId>
-            <version>3.9.0</version>
+            <groupId>net.yyc.common</groupId>
+            <artifactId>yyc-common-log</artifactId>
+            <version>1.0.0-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>net.yyc.common</groupId>

src/main/java/net/yyc/quartz/QuartzApplication.java

@@ -6,18 +6,14 @@ import net.yyc.common.security.annotation.EnableHnqzResourceServer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.cloud.client.SpringCloudApplication;
 
-/**
- * @author frwcloud
- * @date 2019/01/23 定时任务模块
- */
 @EnableHnqzFeignClients
 @SpringCloudApplication
 @EnableHnqzResourceServer
 @EnableDynamicDataSource
 public class QuartzApplication {
 
-	public static void main(String[] args) {
-		SpringApplication.run(QuartzApplication.class, args);
-	}
+    public static void main(String[] args) {
+        SpringApplication.run(QuartzApplication.class, args);
+    }
 
 }

src/main/java/net/yyc/quartz/config/QuartzFactory.java

@@ -39,14 +39,14 @@ import javax.annotation.Resource;
 public class QuartzFactory implements Job {
 
 	@Resource
-	private QuartzInvokeFactory hnqzQuartzInvokeFactory;
+	private QuartzInvokeFactory quartzInvokeFactory;
 
 	@Override
 	@SneakyThrows
 	public void execute(JobExecutionContext jobExecutionContext) {
 		SysJob sysJob = (SysJob) jobExecutionContext.getMergedJobDataMap()
 				.get(QuartzEnum.SCHEDULE_JOB_KEY.getType());
-		hnqzQuartzInvokeFactory.init(sysJob, jobExecutionContext.getTrigger());
+		quartzInvokeFactory.init(sysJob, jobExecutionContext.getTrigger());
 	}
 
 }

src/main/java/net/yyc/quartz/event/EventAutoConfiguration.java

@@ -50,7 +50,7 @@ public class EventAutoConfiguration {
 	}
 
 	@Bean
-	public QuartzInvokeFactory hnqzQuartzInvokeFactory(ApplicationEventPublisher publisher) {
+	public QuartzInvokeFactory quartzInvokeFactory(ApplicationEventPublisher publisher) {
 		return new QuartzInvokeFactory(publisher);
 	}
 

src/main/java/net/yyc/quartz/feign/RemoteInnerSignApiService.java

@@ -0,0 +1,25 @@
+package net.yyc.quartz.feign;
+
+import net.yyc.common.core.constant.SecurityConstants;
+import net.yyc.common.core.constant.ServiceNameConstants;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RequestHeader;
+
+/**
+ * 爱签内部API Feign服务
+ */
+@FeignClient(contextId = "remoteInnerSignApiService", value = ServiceNameConstants.UPMS_SERVICE)
+public interface RemoteInnerSignApiService {
+
+    /**
+     * 爱签人脸截图拉取任务
+     *
+     * @param params 参数
+     * @param from 调用来源
+     * @return 执行结果
+     */
+    @GetMapping("/inner-sign-api/asign-pull-face-photo-job")
+    String asignPullFacePhotoJob(@RequestParam("params") String params, @RequestHeader(value = SecurityConstants.FROM, required = false) String from);
+}

src/main/java/net/yyc/quartz/feign/RemoteScheduleTaskService.java

@@ -0,0 +1,82 @@
+package net.yyc.quartz.feign;
+
+import net.yyc.common.core.constant.SecurityConstants;
+import net.yyc.common.core.constant.ServiceNameConstants;
+import net.yyc.common.core.util.R;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RequestHeader;
+
+/**
+ * 调度任务 Feign 服务
+ */
+@FeignClient(contextId = "remoteScheduleTaskService", value = ServiceNameConstants.UPMS_SERVICE)
+public interface RemoteScheduleTaskService {
+
+    /**
+     * 每日GMV统计
+     */
+    @PostMapping("/schedule/statistics/daily-gmvs-statistic")
+    R<String> dailyGMVsStatistic(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 设置热门文章
+     */
+    @PostMapping("/schedule/article/set-hot-article")
+    R<String> setHotArticle(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 单会员多月相同金额检测
+     */
+    @PostMapping("/schedule/risk/single-member-settle-same-amount")
+    R<String> singleMemberSettleSameAmount(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 单会员多月超限检测
+     */
+    @PostMapping("/schedule/risk/single-member-settle-amount-overrun")
+    R<String> singleMemberSettleAmountOverrun(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 企业向多人支付相同金额检测
+     */
+    @PostMapping("/schedule/risk/single-enterprise-settle-same-amount")
+    R<String> singleEnterpriseSettleSameAmount(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 单会员多月无指定任务类型检测
+     */
+    @PostMapping("/schedule/risk/single-member-without-task-types")
+    R<String> singleMemberWithoutTaskTypes(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 刷新已结算积分包的任务终审积分
+     */
+    @PostMapping("/schedule/task/refresh-final-review-score")
+    R<String> refreshFinalReviewScoreForSettlement(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 发送当日结算数据给企业邮箱
+     */
+    @PostMapping("/schedule/task/send-settle-data-to-dept")
+    R<String> sendCurrentDaySettleDataToDept(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 发送锋信易申请数据给企业邮箱
+     */
+    @PostMapping("/schedule/promotion/send-fxy-apply")
+    R<String> sendFxyApply(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 发送推广点击记录给企业邮箱
+     */
+    @PostMapping("/schedule/promotion/send-promotion-record")
+    R<String> sendPromotionRecord(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+
+    /**
+     * 批量更新过期积分包状态
+     */
+    @PostMapping("/schedule/task/batch-update-package-status")
+    R<String> batchUpdatePackageStatus(@RequestParam String params, @RequestHeader(SecurityConstants.FROM) String from);
+}

src/main/java/net/yyc/quartz/task/SpringBeanTaskDemo.java

@@ -18,8 +18,8 @@
 package net.yyc.quartz.task;
 
 
-import com.qunzhixinxi.hnqz.admin.api.feign.RemoteInnerSignApiService;
-import com.qunzhixinxi.hnqz.admin.api.feign.RemoteScheduleTaskService;
+import net.yyc.quartz.feign.RemoteInnerSignApiService;
+import net.yyc.quartz.feign.RemoteScheduleTaskService;
 import net.yyc.quartz.constants.QuartzEnum;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;