完成查询接口

gigibox

2023-06-20 4983adc4d20798a980025be4cd45c77558c74265

 report/loop.go

File was renamed from report/report.go
@@ -3,9 +3,6 @@
import (
   "context"
   "kingdee-dbapi/logger"
   "time"

   "kingdee-dbapi/config"
)

var ctx context.Context
@@ -36,7 +33,12 @@
         // 上报即时库存
         SendInventory()

         time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second)
         // 测试查询请求
         //sql := []byte("select * from t_icitem where FItemID=3316")
         //ok := nsqclient.Produce(config.Options.QueryTopic, sql)
         //logger.Debug("测试请求接口, %v", ok)
         //
         //time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second)
      }
   }
}