From 790130e3b01a9daa0ba10fe1510410bf4139347a Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期六, 28 九月 2019 10:51:29 +0800
Subject: [PATCH] 修改重连后收到历史数据，导致数据重复bug的处理
---
agent.go | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/agent.go b/agent.go
index 7483a81..0a2a2ff 100644
--- a/agent.go
+++ b/agent.go
@@ -131,11 +131,15 @@
return
}
if sqlUe.Owner != a.conf.NodeName {
- //results, err := ExecuteWriteSql(sqlArr)
+
+ evTime := uint64(ev.LTime)
+ logger.Info("ev.LTime:",evTime,",SqlUserEvent.sql:",sqlUe.Sql)
+
flag, _ := ExecuteSqlByGorm(sqlUe.Sql)
logger.Info("userEvent exec ",sqlUe.Sql,",Result:",flag)
}
} else if ev.Name == UserEventSyncDbTablePersonCache {
+ logger.Info("LTime:",ev.LTime,",ev.Payload.len:",len(ev.Payload))
SyncDbTablePersonCacheChan <- ev.Payload
}
--
Gitblit v1.8.0