report/loop.go
@@ -2,9 +2,10 @@ import ( "context" "time" "kingdee-dbapi/config" "kingdee-dbapi/logger" "time" ) var ctx context.Context @@ -37,7 +38,7 @@ // 测试查询请求 //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)