抽取标准表修改

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");
 		}
 	}