Skip to content

Y
yd-csf
Commit 95986bdf by zhangxingmin
Options

push

parent 092ea5a2
Showing with 46 additions and 46 deletions
yd-csf-api/src/main/java/com/yd/csf/api/service/impl/ApiExpectedFortuneServiceImpl.java
...@@ -634,8 +634,8 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService ...@@ -634,8 +634,8 @@ public class ApiExpectedFortuneServiceImpl implements ApiExpectedFortuneService
.build()); .build());
//异步处理-构建冷静期定时任务 //异步处理-构建冷静期定时任务
log.info("异步处理-构建冷静期定时任务=>请求前入参：{}",JSON.toJSONString(collectResDtos)); // log.info("异步处理-构建冷静期定时任务=>请求前入参：{}",JSON.toJSONString(collectResDtos));
apiExpectedFortuneAsyncService.buildCalmDateTask(collectResDtos,policyNo,exchangeRate); // apiExpectedFortuneAsyncService.buildCalmDateTask(collectResDtos,policyNo,exchangeRate);
return Result.success(); return Result.success();
} catch (Exception e) { } catch (Exception e) {
......
yd-csf-service/src/main/java/com/yd/csf/service/config/XxlJobConfig.java
package com.yd.csf.service.config; //package com.yd.csf.service.config;
//
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; //import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import lombok.extern.slf4j.Slf4j; //import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; //import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value; //import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; //import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.Bean; //import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; //import org.springframework.context.annotation.Configuration;
//
@Slf4j //@Slf4j
@Configuration //@Configuration
@ConditionalOnClass(XxlJobSpringExecutor.class) //@ConditionalOnClass(XxlJobSpringExecutor.class)
public class XxlJobConfig { //public class XxlJobConfig {
//
@Value("${xxl.job.admin.addresses:http://139.224.145.34:8686/xxl-job-admin}") // @Value("${xxl.job.admin.addresses:http://139.224.145.34:8686/xxl-job-admin}")
private String adminAddresses; // private String adminAddresses;
//
@Value("${xxl.job.executor.appname:csf-executor}") // @Value("${xxl.job.executor.appname:csf-executor}")
private String appname; // private String appname;
//
@Value("${xxl.job.executor.port:9999}") // @Value("${xxl.job.executor.port:9999}")
private int port; // private int port;
//
@Value("${xxl.job.accessToken:default_token}") // @Value("${xxl.job.accessToken:default_token}")
private String accessToken; // private String accessToken;
//
@Bean // @Bean
public XxlJobSpringExecutor xxlJobExecutor() { // public XxlJobSpringExecutor xxlJobExecutor() {
log.info(">>>>>>>>>>> xxl-job config init. appname: {}, port: {}, accessToken: {}", // log.info(">>>>>>>>>>> xxl-job config init. appname: {}, port: {}, accessToken: {}",
appname, port, StringUtils.isNotBlank(accessToken) ? "已配置" : "未配置"); // appname, port, StringUtils.isNotBlank(accessToken) ? "已配置" : "未配置");
//
XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); // XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
xxlJobSpringExecutor.setAdminAddresses(adminAddresses); // xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
xxlJobSpringExecutor.setAppname(appname); // xxlJobSpringExecutor.setAppname(appname);
xxlJobSpringExecutor.setPort(port); // xxlJobSpringExecutor.setPort(port);
// 设置accessToken // // 设置accessToken
xxlJobSpringExecutor.setAccessToken(accessToken); // xxlJobSpringExecutor.setAccessToken(accessToken);
xxlJobSpringExecutor.setLogRetentionDays(30); // xxlJobSpringExecutor.setLogRetentionDays(30);
//
return xxlJobSpringExecutor; // return xxlJobSpringExecutor;
} // }
} //}
\ No newline at end of file \ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment