修改重连后收到历史数据，导致数据重复bug的处理

chenshijun

2019-09-28 790130e3b01a9daa0ba10fe1510410bf4139347a

 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
      }

@@ -286,8 +290,8 @@
// Stop serf agent
func (a *Agent) Stop() {
   if a.errorCh != nil {
      a.Leave()
      a.Shutdown()
      logger.Info("a.Shutdown()", a.Leave())
      logger.Info("a.Shutdown()", a.Shutdown())
      close(a.errorCh)
      a.errorCh = nil
   }