report/loop.go
@@ -2,6 +2,9 @@ import ( "context" "time" "kingdee-dbapi/config" "kingdee-dbapi/logger" ) @@ -35,10 +38,10 @@ // 测试查询请求 //sql := []byte("select * from t_icitem where FItemID=3316") //ok := nsqclient.Produce(config.Options.QueryTopic, sql) //ok := nsqclient.Produce(config.Options.SqlQueryTopic, sql) //logger.Debug("测试请求接口, %v", ok) // //time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second) time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second) } } }