package com.product.kt.test.service2;
|
|
import java.util.Map;
|
|
import com.google.common.collect.Maps;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.product.kt.test.config.SyncConfig;
|
import net.minidev.json.JSONObject;
|
|
@Service
|
public class ToolsThread2 {
|
|
private static final Logger LOG = LoggerFactory.getLogger(ToolsThread2.class);
|
|
@Autowired
|
SyncToolsHandler2 syncToolsHandler;
|
|
// 连接map
|
public static Map<String, String> dataSourceMap = SyncConfig.DATA_SOURCE_MAP;
|
|
// 同步表map
|
public static Map<String, JSONObject> readTableMap = SyncConfig.SYNC_TABLE_MAP;
|
//每次读取数据量大小
|
public static int pageSize = SyncConfig.PAGE_SIZE;
|
|
public void receiveBookJobRun() {
|
if (!readTableMap.isEmpty()) {
|
|
// 入库开始时间
|
Long inserOrUpdateBegin = System.currentTimeMillis();
|
LOG.info("数据更新开始时间:" + inserOrUpdateBegin);
|
|
//遍历同步表
|
readTableMap.forEach((tableName, specialField) -> {
|
String orderField = specialField.getAsString("order_field");
|
String timeField = specialField.getAsString("time_field");
|
|
dataSourceMap.forEach((sourceLinkUUID, targetLinkUUID) -> {
|
syncToolsHandler.syncToolData(sourceLinkUUID, tableName, orderField, timeField);
|
});
|
|
});
|
syncToolsHandler.clearExecutor();
|
Long inserOrUpdateEnd = System.currentTimeMillis();
|
LOG.info("数据更新结束时间:" + inserOrUpdateEnd + "。此次更新数据花费时间为：" + (inserOrUpdateEnd - inserOrUpdateBegin));
|
}
|
}
|
}
|
