From 07c83c163675e24252de05d029cef2eab046e583 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期二, 09 七月 2024 19:32:40 +0800
Subject: [PATCH] 完成基础数据导入
---
finance-admin-dept/src/main/java/com/finance/FinanceAdminDeptApplication.java | 29 ++++++++++++++++++++++++-----
1 files changed, 24 insertions(+), 5 deletions(-)
diff --git a/finance-admin-dept/src/main/java/com/finance/FinanceAdminDeptApplication.java b/finance-admin-dept/src/main/java/com/finance/FinanceAdminDeptApplication.java
index afa6c6a..d2fe96b 100644
--- a/finance-admin-dept/src/main/java/com/finance/FinanceAdminDeptApplication.java
+++ b/finance-admin-dept/src/main/java/com/finance/FinanceAdminDeptApplication.java
@@ -1,8 +1,11 @@
package com.finance;
+import com.finance.system.service.AsyncService;
import java.net.InetAddress;
import java.net.UnknownHostException;
import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
@@ -20,9 +23,12 @@
* @author ruoyi
*/
@Slf4j
-@EnableScheduling//开启定时任务
+@EnableScheduling// 开启定时任务
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class FinanceAdminDeptApplication {
+
+ @Autowired
+ private AsyncService asyncService;
public static void main(String[] args) throws UnknownHostException {
ConfigurableApplicationContext application = SpringApplication.run(
@@ -31,10 +37,10 @@
log.info("\n----------------------------------------------------------\n\t" +
"应用 '{}' 运行成功! 访问连接:\n\t" +
"Swagger文档: \t\thttp://{}:{}/doc.html\n" +
- "----------------------------------------------------------" ,
- env.getProperty("spring.application.name" , "后台"),
+ "----------------------------------------------------------",
+ env.getProperty("spring.application.name", "后台"),
InetAddress.getLocalHost().getHostAddress(),
- env.getProperty("server.port" , "8081"));
+ env.getProperty("server.port", "8081"));
}
/**
@@ -45,7 +51,7 @@
@Bean
@ConditionalOnMissingBean(name = "restTemplate")
public RestTemplate wxRestTemplate() {
- //复杂构造函数的使用
+ // 复杂构造函数的使用
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
// 设置超时
requestFactory.setConnectTimeout(6000);
@@ -55,4 +61,17 @@
return restTemplate;
}
+ @Bean
+ public ApplicationRunner applicationRunner() {
+ return applicationArguments -> {
+ long startTime = System.currentTimeMillis();
+ System.out.println(Thread.currentThread().getName() + "：开始调用异步业务");
+ asyncService.asyncTask();
+ long endTime = System.currentTimeMillis();
+ System.out.println(
+ Thread.currentThread().getName() + "：调用异步业务结束，耗时：" + (endTime
+ - startTime));
+ };
+ }
+
}
--
Gitblit v1.7.1