zhangzengfei
2023-06-29 1bed0e1cecc21294580e3447516a90d4b3e270a7
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)