diff --git a/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java b/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java index aaf628e6..db043e90 100644 --- a/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java +++ b/src/com/platform/service/thread/ThreadExtractStandardSqlServer.java @@ -8,6 +8,7 @@ import java.io.IOException; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.sql.Connection; +import java.util.Date; import java.util.List; import com.base.CustomException; @@ -20,6 +21,7 @@ import com.platform.oracle.OracleConnector; import com.platform.service.OracleExtractHelper; import com.platform.utils.Configs; import com.platform.utils.Constant; +import com.platform.utils.DateForm; import com.platform.utils.FileOperateHelper; /** sqlServer 抽取 标准表 线程 @@ -53,7 +55,20 @@ public class ThreadExtractStandardSqlServer extends Thread{ public void run() { for (CheckoutEntity element : Extractlist) { //校验结果:成功或失 0:未校验,1:不需校验,2:正在校验,3:校验成功,4:校验失败,5:待抽取,6:正在抽取,7:抽取完成 + //设置 日志 的 文件名 + OracleConnectorParams collectOracle = new OracleConnectorParams(); + collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion()); //TODO 开始抽取 + // sql日志记录时间: + FileOperateHelper + .fileWrite( + Configs.EXTRACT_STANDARD_LOG_LOCALTION + + collectOracle.getName() + + ".log", + "\r\n 开始抽取标准表 \r\n" + + DateForm + .date2StringBysecond(new Date()) + + "\r\n"); //如果校验成功的 才 进行 抽取----支付标准表 if (Constant.CHECKOUT_STATUS_FIVE.equals(element.getPayResultLast()) || Constant.CHECKOUT_STATUS_SIX.equals(element.getPayResultLast())) { @@ -73,9 +88,6 @@ public class ThreadExtractStandardSqlServer extends Thread{ //获取连接 Connection conn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":" + oracleConnect.getDatabaseName(), oracleConnect.getUser(), oracleConnect.getPassword(), null); - //设置 日志 的 文件名 - OracleConnectorParams collectOracle = new OracleConnectorParams(); - collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion()); // 创建表空间 创建 抽取标准表的 用户并授权 oracleExtract.createTableSpace(conn, collectOracle , oracleConnect); // oracleExtract.createOnlyUser(conn, collectOracle, oracleConnect);// @@ -136,9 +148,6 @@ public class ThreadExtractStandardSqlServer extends Thread{ File execSql = new File(execFilePath); Connection conn = OracleConnector.connectionBuilder("jdbc:oracle:thin:@" + oracleConnect.getIp() + ":" + oracleConnect.getPort() + ":" + oracleConnect.getDatabaseName(), oracleConnect.getUser(), oracleConnect.getPassword(), null); - //设置 日志 的 文件名 - OracleConnectorParams collectOracle = new OracleConnectorParams(); - collectOracle.setName("CQ"+ element.getAreaCode().toLowerCase()+"_"+element.getSysCode()+"_"+element.getDataVersion()); // 创建表空间 创建 抽取标准表的 用户并授权 oracleExtract.createTableSpace(conn, collectOracle , oracleConnect); // oracleExtract.createOnlyUser(conn, collectOracle, oracleConnect);// @@ -182,6 +191,16 @@ public class ThreadExtractStandardSqlServer extends Thread{ } } + // sql日志记录时间: + FileOperateHelper + .fileWrite( + Configs.EXTRACT_STANDARD_LOG_LOCALTION + + collectOracle.getName() + + ".log", + "\r\n 抽取标准表结束 >>>>>>>>>> " + + DateForm + .date2StringBysecond(new Date()) + + "\r\n\r\n\n"); } }