|
|
@ -38,7 +38,7 @@ public class DataSyncJob { |
|
|
|
private String dataSyncUrl; |
|
|
|
@Value("${dataSync.enabled:false}") |
|
|
|
private Boolean dataSyncEnabled; |
|
|
|
@Value("${dataSync.paths:}") |
|
|
|
@Value("#{${dataSync.paths:{}}}") |
|
|
|
private Map<String, String> paths = new HashMap<>(); |
|
|
|
@Autowired |
|
|
|
private DataCenterRestTemplateUtils dataCenterRestTemplateUtils; |
|
|
@ -95,17 +95,18 @@ public class DataSyncJob { |
|
|
|
String updateStr = tableInfo.getFieldList().stream() |
|
|
|
.filter(f -> !"id".equalsIgnoreCase(f.getColumn())) |
|
|
|
.map(f -> f.getColumn() + "=values(" + f.getColumn() + ")").collect(Collectors.joining(",")); |
|
|
|
if (!checkTableExist(table.getName())) { |
|
|
|
String tableName = table.getTableName(); |
|
|
|
if (!checkTableExist(tableName)) { |
|
|
|
log.error("--------数据同步{},表不存在--------", table); |
|
|
|
return; |
|
|
|
} |
|
|
|
doSync(table.getName(), paths.get(table.getTableName()), (records) -> { |
|
|
|
doSync(tableName, paths.get(tableName), (records) -> { |
|
|
|
//records = JSONArray.parseArray("[{\"resCode\":'123456',\"resName\":'测试',\"startDate\":'2024-02-03 00:00:00',\"watShedArea\":23.232},{\"resCode\":'a123456',\"resName\":'a测试',\"cmun\":'数元科技',\"watShedArea\":211.232}]");
|
|
|
|
// 解析数据
|
|
|
|
List<Object[]> dataList = processDataList(records, fieldStr, fieldInfoMap, table); |
|
|
|
|
|
|
|
// 插入数据
|
|
|
|
insertData(filed, updateStr, dataList, table.getName()); |
|
|
|
insertData(filed, updateStr, dataList, tableName); |
|
|
|
return dataList.size(); |
|
|
|
}); |
|
|
|
} |
|
|
|