'commit'

dsBaseRpc/DataExchange/DataExchange.go

@@ -37,7 +37,7 @@ func DataExchange() {
 		//本轮上报的数量，如果是0，休息5秒后再继续上传
 		postCount := UploadData()
 		if postCount == 0 {
-			fmt.Println("同步：本轮没有可以上报的数据，将休息5秒！")
+			fmt.Println(CommonUtil.GetCurrentTime()+"	同步：本轮没有可以上报的数据，将休息5秒！")
 			time.Sleep(5 * 1e9)
 		}
 	}
@@ -77,7 +77,7 @@ func UploadData() int {
 				startUpdateTs = logstruct.StartUpdateTs
 				idInt = logstruct.IdInt
 			} else {
-				fmt.Println("解析JSON文件失败:" + err.Error())
+				fmt.Println(CommonUtil.GetCurrentTime()+"	解析JSON文件失败:" + err.Error())
 			}
 		}
 		//一直循环
@@ -102,7 +102,7 @@ func UploadData() int {
 			}
 			FileUtil.WriteContent(logName, string(jsonBytes))
 			//提示信息
-			fmt.Println("同步：" + tableName + ",上报" + CommonUtil.ConvertIntToString(count) +
+			fmt.Println(CommonUtil.GetCurrentTime()+"	同步：" + tableName + ",上报" + CommonUtil.ConvertIntToString(count) +
 				"个，start_update_ts=" + startUpdateTs + ",id_int=" + CommonUtil.ConvertInt64ToString(idInt))
 		}
 		postCount = postCount + count