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