liuxiaolong
2020-05-13 649f2557ab1ce741a5573b14b00011206f79be74
sync.go
@@ -5,6 +5,7 @@
   sdb "basic.com/Android/syncdb.git"
   "basic.com/valib/logger.git"
   "encoding/json"
   "github.com/micro/go-micro/logger"
   "strings"
)
type ReceiveSqlInterface2 interface {
@@ -144,14 +145,14 @@
   }
   var dumpSqls *[]string
   dumpSqls, err = agent.GetTableDataFromCluster(syncTables)
   dumpSqls, err := agent.GetTableDataFromCluster(syncTables)
   if dumpSqls != nil {
      for _, dumpSql := range *dumpSqls {
         sqls = append(sqls, dumpSql)
      }
   }
   logger.Debug("成功获取集群中数据")
   logger.Debug("成功获取集群中数据,err:",err)
   //timeUnix := time.Now().Unix()
   //fmtTimeStr := time.Unix(timeUnix, 0).Format("2006-01-02 15:04:05")