hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

系统添加不加在数据库操作

This commit is contained in:
lvleigang 2024-07-09 15:30:27 +08:00
parent be5923d8ea
commit 2ad4ff5be5
4 changed files with 26 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
buildpackage/src/main/resources/application.yml
View File

@ -122,3 +122,5 @@ jeecg :
minio_name: ?? minio_name: ??
minio_pass: ?? minio_pass: ??
bucketName: ?? bucketName: ??
data:
use: true

2
common/src/main/java/com/hzya/frame/datasource/DataSourceUtilProperties.java
View File

@ -12,7 +12,7 @@ public class DataSourceUtilProperties {
public static final String MYSQLDRIVER_6 = "com.mysql.jdbc.Driver"; // mysql数据库的驱动类 public static final String MYSQLDRIVER_6 = "com.mysql.jdbc.Driver"; // mysql数据库的驱动类
public static final String MYSQLDRIVER = "com.mysql.jdbc.Driver"; // mysql数据库的驱动类 public static final String MYSQLDRIVER = "com.mysql.jdbc.Driver"; // mysql数据库的驱动类
public static final String ORACLEDRIVER = "oracle.jdbc.OracleDriver"; // oracles数据库的驱动类 public static final String ORACLEDRIVER = "oracle.jdbc.OracleDriver"; // oracles数据库的驱动类
public static final String SQL2005DRIVER = "net.sourceforge.jtds.jdbc.Driver"; // sqlserver数据库的驱动类 public static final String SQL2005DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; // sqlserver数据库的驱动类
public static final String SQL2000DRIVER = "net.sourceforge.jtds.jdbc.Driver"; // sqlserver数据库的驱动类 public static final String SQL2000DRIVER = "net.sourceforge.jtds.jdbc.Driver"; // sqlserver数据库的驱动类
public static final String dm = "dm.jdbc.driver.DmDriver"; // 达梦数据库的驱动类 public static final String dm = "dm.jdbc.driver.DmDriver"; // 达梦数据库的驱动类

7
webapp/src/main/java/com/hzya/frame/web/init/MyApplicationListener.java
View File

@ -10,6 +10,7 @@ import com.hzya.frame.sysnew.integtationTaskLiving.entity.IntegrationTaskLivingE
import com.hzya.frame.web.quartz.QuartzJobFactoryUtils; import com.hzya.frame.web.quartz.QuartzJobFactoryUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.event.ApplicationReadyEvent; import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener; import org.springframework.context.ApplicationListener;
import org.springframework.core.annotation.Order; import org.springframework.core.annotation.Order;
@ -34,13 +35,17 @@ public class MyApplicationListener implements ApplicationListener<ApplicationRea
private IIntegrationTaskLivingDao iIntegrationTaskLivingDao; private IIntegrationTaskLivingDao iIntegrationTaskLivingDao;
@Resource @Resource
private IIntegrationTaskCacheableService iIntegrationTaskCacheableService; private IIntegrationTaskCacheableService iIntegrationTaskCacheableService;
@Value("${data.use}")
private boolean dataUse;
@Override @Override
public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) { public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {
initTask(); initTask();
} }
private void initTask() { private void initTask() {
if(!dataUse){
return;
}
//查询所有任务，添加到任务执行计划中 //查询所有任务，添加到任务执行计划中
IntegrationTaskEntity queryEntity = new IntegrationTaskEntity(); IntegrationTaskEntity queryEntity = new IntegrationTaskEntity();
//任务状态1、启用 //任务状态1、启用

31
webapp/src/main/java/com/hzya/frame/webapp/web/listener/InitCommandLineRunner.java
View File

@ -10,6 +10,7 @@ import com.hzya.frame.web.action.ApplicationContextUtil;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.event.ApplicationReadyEvent; import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationListener; import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -36,25 +37,27 @@ public class InitCommandLineRunner implements ApplicationListener<ApplicationRea
Logger logger = LoggerFactory.getLogger(InitCommandLineRunner.class); Logger logger = LoggerFactory.getLogger(InitCommandLineRunner.class);
@Resource @Resource
private ApplicationCache applicationCache; private ApplicationCache applicationCache;
@Value("${data.use}")
private boolean dataUse;
@Resource @Resource
private InterfaceCache interfaceCache; private InterfaceCache interfaceCache;
@Override @Override
public void onApplicationEvent(ApplicationReadyEvent event) { public void onApplicationEvent(ApplicationReadyEvent event) {
logger.info("初始化ApplicationCache Map start <<<<<<<<<<<<<<<<<<<<<<<<"); if(dataUse){
applicationCache.reloadData("1"); logger.info("初始化ApplicationCache Map start <<<<<<<<<<<<<<<<<<<<<<<<");
applicationCache.reloadData("2"); applicationCache.reloadData("1");
applicationCache.reloadData("3"); applicationCache.reloadData("2");
applicationCache.reloadData("4"); applicationCache.reloadData("3");
applicationCache.reloadData("4");
interfaceCache.reloadData("1");
interfaceCache.reloadData("2");
interfaceCache.reloadData("3");
interfaceCache.reloadData("4");
interfaceCache.reloadData("5");
interfaceCache.reloadData("6");
logger.info("初始化ApplicationCache Map END <<<<<<<<<<<<<<<<<<<<<<<<");
interfaceCache.reloadData("1");
interfaceCache.reloadData("2");
interfaceCache.reloadData("3");
interfaceCache.reloadData("4");
interfaceCache.reloadData("5");
interfaceCache.reloadData("6");
logger.info("初始化ApplicationCache Map END <<<<<<<<<<<<<<<<<<<<<<<<");
}
String path = InitCommandLineRunner.class.getClassLoader().getResource("").getPath(); String path = InitCommandLineRunner.class.getClassLoader().getResource("").getPath();
; ;
logger.info("cfgHomeClassURL:" + path); logger.info("cfgHomeClassURL:" + path);