panbaolin/SourceTermAnalysisSystem_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: panbaolin:3dcf5db691649786da012431b0838edb22ee73b5
Branches Tags
panbaolin:master
panbaolin:main
..
compare: panbaolin:9fa131fe9c06b3a7c9b46d014ccc064e8002c1d3
Branches Tags
panbaolin:master
panbaolin:main

No commits in common. "3dcf5db691649786da012431b0838edb22ee73b5" and "9fa131fe9c06b3a7c9b46d014ccc064e8002c1d3" have entirely different histories.
3dcf5db691 ... 9fa131fe9c

3 changed files with 47 additions and 48 deletions
Show Stats Expand all files Collapse all files

10
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/controller/StasSyncStrategyController.java
View File

@ -71,7 +71,15 @@ public class StasSyncStrategyController extends JeecgController<StasSyncStrategy
@Operation(summary="同步策略表-在目标库创建表结构") @Operation(summary="同步策略表-在目标库创建表结构")
@PostMapping(value = "/createTargetTables") @PostMapping(value = "/createTargetTables")
public Result<String> createTargetTables(@RequestBody List<StasSyncStrategy> stasSyncStrategys) { public Result<String> createTargetTables(@RequestBody List<StasSyncStrategy> stasSyncStrategys) {
stasSyncStrategyService.createTargetTables(stasSyncStrategys); if(null != stasSyncStrategys && stasSyncStrategys.size() > 0) {
String taskId = stasSyncStrategys.get(0).getTaskId();
stasSyncStrategyService.remove(new LambdaQueryWrapper<StasSyncStrategy>().eq(StasSyncStrategy::getTaskId, taskId));
for (StasSyncStrategy stasSyncStrategy : stasSyncStrategys) {
if(stasSyncStrategyService.validateTables(stasSyncStrategy)){
stasSyncStrategyService.createTargetTables(stasSyncStrategy);
}
}
}
return Result.OK("添加成功！"); return Result.OK("添加成功！");
} }

5
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/service/IStasSyncStrategyService.java
View File

@ -4,7 +4,6 @@ import org.jeecg.modules.base.entity.StasSyncStrategy;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.List;
/** /**
* @Description: 同步策略表 * @Description: 同步策略表
@ -24,8 +23,8 @@ public interface IStasSyncStrategyService extends IService<StasSyncStrategy> {
/** /**
* 在目标库创建表结构 * 在目标库创建表结构
* @param stasSyncStrategys 同步策略信息 * @param stasSyncStrategy 同步策略信息
* @throws SQLException 数据库异常 * @throws SQLException 数据库异常
*/ */
void createTargetTables(List<StasSyncStrategy> stasSyncStrategys); void createTargetTables(StasSyncStrategy stasSyncStrategy);
} }

12
jeecg-module-sync/src/main/java/org/jeecg/stasSyncStrategy/service/impl/StasSyncStrategyServiceImpl.java
View File

@ -1,6 +1,5 @@
package org.jeecg.stasSyncStrategy.service.impl; package org.jeecg.stasSyncStrategy.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.jeecg.common.constant.enums.SourceDataTypeEnum; import org.jeecg.common.constant.enums.SourceDataTypeEnum;
import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.exception.JeecgBootException;
@ -33,7 +32,6 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
private final StasTaskConfigMapper stasTaskConfigMapper; private final StasTaskConfigMapper stasTaskConfigMapper;
private final StasDataSourceMapper stasDataSourceMapper; private final StasDataSourceMapper stasDataSourceMapper;
private final StasSyncStrategyMapper stasSyncStrategyService;
/** /**
@ -69,16 +67,12 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
/** /**
* 在目标库创建表结构 * 在目标库创建表结构
* @param stasSyncStrategys 同步策略信息 * @param stasSyncStrategy 同步策略信息
* @throws SQLException 数据库异常 * @throws SQLException 数据库异常
*/ */
@Transactional @Transactional
@Override @Override
public void createTargetTables(List<StasSyncStrategy> stasSyncStrategys) { public void createTargetTables(StasSyncStrategy stasSyncStrategy) {
if(null != stasSyncStrategys && stasSyncStrategys.size() > 0) {
String taskId = stasSyncStrategys.get(0).getTaskId();
stasSyncStrategyService.delete(new LambdaQueryWrapper<StasSyncStrategy>().eq(StasSyncStrategy::getTaskId, taskId));
for (StasSyncStrategy stasSyncStrategy : stasSyncStrategys) {
StasTaskConfig stasTaskConfig = stasTaskConfigMapper.selectById(stasSyncStrategy.getTaskId()); StasTaskConfig stasTaskConfig = stasTaskConfigMapper.selectById(stasSyncStrategy.getTaskId());
StasDataSource sourceInfo = stasDataSourceMapper.selectById(stasTaskConfig.getSourceId()); StasDataSource sourceInfo = stasDataSourceMapper.selectById(stasTaskConfig.getSourceId());
StasDataSource targetInfo = stasDataSourceMapper.selectById(stasTaskConfig.getTargetId()); StasDataSource targetInfo = stasDataSourceMapper.selectById(stasTaskConfig.getTargetId());
@ -122,8 +116,6 @@ public class StasSyncStrategyServiceImpl extends ServiceImpl<StasSyncStrategyMap
throw new JeecgBootException(e.getMessage()); throw new JeecgBootException(e.getMessage());
} }
} }
}
}
/** /**
* 获取创建表的SQL语句 * 获取创建表的SQL语句