From c02c0ac5e06ee1a556107baa071ef0c80a387a13 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 28 九月 2019 10:34:43 +0800
Subject: [PATCH] rm ltime save and get from sqlite
---
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