'commit'

dsBaseRpc/DataExchange/DataExchange.go

@@ -92,8 +92,8 @@ func InitFull() {
 		//判断文件是不是存在
 		if !FileUtil.PathExists(logName) {
 			//SQL内容
-			sql := FileUtil.ReadFileContent("./Sql/" + FullSqlDict[i].TableName + ".sql")
-
+			isql := FileUtil.ReadFileContent("./Sql/" + FullSqlDict[i].TableName + ".sql")
+			sql:=isql
 			var list []map[string]interface{}
 			//如果是组织机构表，那么需要变更一下查询的排序条件
 			if FullSqlDict[i].TableName == "t_base_organization" {
@@ -131,7 +131,7 @@ func InitFull() {
 			//对于组织机构进行特殊处理
 			if FullSqlDict[i].TableName == "t_base_organization" {
 				//记录日志
-				maxSql := sql + " order by t1.last_updated_time desc,t1.id_int desc limit 1"
+				maxSql := isql + " order by t1.last_updated_time desc,t1.id_int desc limit 1"
 				var l logStruct
 				l.IdInt = 0
 				l.StartUpdateTs = defaultStartTs