no message

bus-biz/src/main/java/bus/service/impl/WChatUserServiceImpl.java

@@ -82,6 +82,13 @@ public class WChatUserServiceImpl implements WChatUserService {
             req.setUniformCreditCode(creditCode);
             req.setIsAdmin(0);
             staffByUserName = staffClient.addStaff(req);
+            //保存数据库
+            WChatUserDto dto = new WChatUserDto();
+            dto.setMiniOpenId(dto.getMiniOpenId());
+            dto.setLastLoginTime(new Date());
+            dto.setWxName(wxName);
+            dto.setWxPhone(mobile);
+            save(dto);
         }
         List<HashMap<String,Object>> roleListByProId = (List<HashMap<String,Object>>) roleClient.getRoleListByProId(productId);
         List<String> filteredRoles = new ArrayList<>();
@@ -103,13 +110,7 @@ public class WChatUserServiceImpl implements WChatUserService {
         userLoginRequest.setAccount(mobile);
         userLoginRequest.setPassword(sub);
         SsoUserAuthDto ssoUserAuthDto = commonService.doLogin(request, response, userLoginRequest);
-        //保存数据库
-        WChatUserDto dto = new WChatUserDto();
-        dto.setMiniOpenId(dto.getMiniOpenId());
-        dto.setLastLoginTime(new Date());
-        dto.setWxName(wxName);
-        dto.setWxPhone(mobile);
-        save(dto);
+
         return ssoUserAuthDto;
     }
 

bus-boot/src/main/java/bus/config/JobConfig.java

@@ -0,0 +1,52 @@
+package bus.config;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+public class JobConfig {
+    @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.address}")
+    private String address;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.executor.logpath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logretentiondays}")
+    private int logRetentionDays;
+
+
+    @Bean
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        log.info(">>>>>>>>>>> xxl-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppname(appname);
+        xxlJobSpringExecutor.setAddress(address);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+
+        return xxlJobSpringExecutor;
+    }
+}

bus-boot/src/main/resources/bootstrap-dev.yaml

@@ -47,3 +47,16 @@ orcas:
 file-store:
   go-fastdfs:
     baseUrl: 58.221.153.58:48989
+
+xxl:
+  job:
+    admin:
+      addresses: http://58.221.153.58:48989/api-gateway/schedulecenter-server
+    accessToken: ""
+    executor:
+      appname: demo-executor
+      address: ""
+      ip: ""
+      port: 60066
+      logpath: logs
+      logretentiondays: 15

bus-common/pom.xml

@@ -31,6 +31,11 @@
 			<groupId>com.qzwisdom.qzframework</groupId>
 			<artifactId>qzframework-core-boot</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>com.xuxueli</groupId>
+			<artifactId>xxl-job-core</artifactId>
+			<version>2.2.0</version>
+		</dependency>
 	</dependencies>
 
 </project>

bus-web/src/main/java/bus/controller/biz/job/DemoesTask.java

@@ -0,0 +1,21 @@
+package bus.controller.biz.job;
+
+
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.springframework.stereotype.Component;
+
+@Component
+public class  DemoesTask {
+
+    @XxlJob("demoJobHandler")
+    public ReturnT<String> demoJobHandler(String param) {
+        try {
+            System.out.println("定时任务执行-参数：" + param);
+            System.out.println(1111);
+        } catch (Exception e) {
+            return ReturnT.FAIL;
+        }
+        return ReturnT.SUCCESS;
+    }
+}