From 3902d55295e749ce8cda6762d083076ab27706ef Mon Sep 17 00:00:00 2001
From: huanghai <10402852@qq.com>
Date: Fri, 17 Jul 2020 10:04:54 +0800
Subject: [PATCH] 'commit'

---
 dsBaseRpc/DataExchange/DataExchange.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dsBaseRpc/DataExchange/DataExchange.go b/dsBaseRpc/DataExchange/DataExchange.go
index 9d212275..1bab01e4 100644
--- a/dsBaseRpc/DataExchange/DataExchange.go
+++ b/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