From 70b628b4465ca71bdd6c84abae79ed1e605538f9 Mon Sep 17 00:00:00 2001
From: BrandWang <rj090123@163.com>
Date: Wed, 24 May 2023 17:55:23 +0800
Subject: [PATCH] =?UTF-8?q?feat(=E5=8F=AF=E5=9B=9E=E6=BA=AF):=20=E9=85=8D?=
 =?UTF-8?q?=E7=BD=AE=E7=94=9F=E6=88=90=E8=A7=86=E9=A2=91=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

增加xxljobp配置
---
 afis-recall-web/pom.xml                       |  7 +++
 .../recall/jobtask/GenVideoJobHandler.java    | 23 +++++++++
 .../recall/jobtask/XXLJobConfig.java          | 47 +++++++++++++++++++
 3 files changed, 77 insertions(+)
 create mode 100644 afis-recall-web/src/main/java/com/wabestway/recall/jobtask/GenVideoJobHandler.java
 create mode 100644 afis-recall-web/src/main/java/com/wabestway/recall/jobtask/XXLJobConfig.java

diff --git a/afis-recall-web/pom.xml b/afis-recall-web/pom.xml
index 336f336..f51bb4c 100644
--- a/afis-recall-web/pom.xml
+++ b/afis-recall-web/pom.xml
@@ -23,6 +23,13 @@
         <alibaba.boot.druid>1.1.22</alibaba.boot.druid>
     </properties>
     <dependencies>
+
+        <dependency>
+            <groupId>com.xuxueli</groupId>
+            <artifactId>xxl-job-core</artifactId>
+            <version>2.3.0</version>
+        </dependency>
+
         <dependency>
             <groupId>com.wabestway.recall</groupId>
             <artifactId>afis-recall-api</artifactId>
diff --git a/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/GenVideoJobHandler.java b/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/GenVideoJobHandler.java
new file mode 100644
index 0000000..b229a24
--- /dev/null
+++ b/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/GenVideoJobHandler.java
@@ -0,0 +1,23 @@
+package com.wabestway.recall.jobtask;
+
+import com.wabestway.recall.trace.service.RecallOrderApiService;
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class GenVideoJobHandler {
+    @Autowired
+    private RecallOrderApiService recallOrderApiService;
+
+    @XxlJob("VideoGenJobHandler")
+    public ReturnT<String> genRecallVideo() {
+        log.info("[定时器：回溯视频]-开始执行");
+        recallOrderApiService.traceVideo();
+        log.info("[定时器：回溯视频]-执行完成");
+        return ReturnT.SUCCESS;
+    }
+}
diff --git a/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/XXLJobConfig.java b/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/XXLJobConfig.java
new file mode 100644
index 0000000..9a65e8a
--- /dev/null
+++ b/afis-recall-web/src/main/java/com/wabestway/recall/jobtask/XXLJobConfig.java
@@ -0,0 +1,47 @@
+package com.wabestway.recall.jobtask;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class XXLJobConfig {
+
+	private Logger logger = LoggerFactory.getLogger(XXLJobConfig.class);
+
+	@Value("${xxl.job.admin.addresses}")
+	private String adminAddresses;
+
+	@Value("${xxl.job.accessToken}")
+	private String accessToken;
+
+	@Value("${xxl.job.executor.appname}")
+	private String appname;
+
+	@Value("${xxl.job.executor.port:-1}")
+	private int port;
+
+	@Value("${xxl.job.executor.logpath}")
+	private String logPath;
+
+	@Value("${xxl.job.executor.logretentiondays}")
+	private int logRetentionDays;
+
+	@Bean
+	public XxlJobSpringExecutor xxlJobExecutor() {
+		logger.info(">>>>>>>>>>> xxl-job config init.");
+		XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+		xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+		xxlJobSpringExecutor.setAppname(appname);
+		xxlJobSpringExecutor.setPort(port);
+		xxlJobSpringExecutor.setAccessToken(accessToken);
+		xxlJobSpringExecutor.setLogPath(logPath);
+		xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+		return xxlJobSpringExecutor;
+	}
+
+}
\ No newline at end of file