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 }