20191114 分布式job的配置

server/src/main/java/com/pica/cloud/account/account/server/configuration/PropertiesConfiguration.java

 package com.pica.cloud.account.account.server.configuration;
 
+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.cloud.context.config.annotation.RefreshScope;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
 @RefreshScope
 public class PropertiesConfiguration {
+    private Logger logger = LoggerFactory.getLogger(PropertiesConfiguration.class);
 
     @Value("${pica.cloud.message.url}")
     private String messageUrl;
@@ -20,4 +25,41 @@ public class PropertiesConfiguration {
         this.messageUrl = messageUrl;
     }
 
+
+
+    @Value("${xxl.job.admin.addresses}")
+    private String adminAddresses;
+
+    @Value("${xxl.job.executor.appname}")
+    private String appName;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.accessToken}")
+    private String accessToken;
+
+    @Value("${xxl.job.executor.logpath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logretentiondays}")
+    private int logRetentionDays;
+
+    @Bean(initMethod = "start", destroyMethod = "destroy")
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        logger.info("pica-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppName(appName);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+        return xxlJobSpringExecutor;
+    }
 }

server/src/main/java/com/pica/cloud/account/account/server/job/AccountRepeatDataJob.java

@@ -24,6 +24,6 @@ public class AccountRepeatDataJob extends IJobHandler {
     public ReturnT<String> execute(String s) throws Exception {
         accountInfoDetailMapper.processAccountRepeatData();
         XxlJobLogger.log("刷新数据");
-        return null;
+        return SUCCESS;
     }
 }

server/src/main/java/com/pica/cloud/account/account/server/util/AESUtil.java

@@ -168,7 +168,7 @@ public class AESUtil {
     public static void main(String[] args) throws Exception {
         String KEY="zJJ$c5md3$yuuhWW";
         System.out.println("-------------加密---------");
-        String content = "13024112666";
+        String content = "15607244444";
         System.out.println("加密前：" + content);
         System.out.println("加密密钥和解密密钥：" + KEY);