From 8f750b461a4f442825e516016bf78d05ed66afcb Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期一, 14 八月 2023 18:14:50 +0800
Subject: [PATCH] 添加bom查询
---
report/task.go | 24 ++++++++++++++----------
1 files changed, 14 insertions(+), 10 deletions(-)
diff --git a/report/loop.go b/report/task.go
similarity index 61%
rename from report/loop.go
rename to report/task.go
index 4fddf91..f0011d1 100644
--- a/report/loop.go
+++ b/report/task.go
@@ -11,18 +11,18 @@
var ctx context.Context
var cancel context.CancelFunc
-func StartReport() {
+func Start() {
ctx, cancel = context.WithCancel(context.Background())
- go Loop(ctx)
+ go queryTasks(ctx)
}
func RestartReport() {
cancel()
- StartReport()
+ Start()
}
-func Loop(c context.Context) {
+func queryTasks(c context.Context) {
logger.Debug("鍚姩鏁版嵁涓婃姤浠诲姟")
for {
select {
@@ -31,15 +31,19 @@
return
default:
// 涓婃姤璁㈠崟
- SendOrder()
+ if config.Options.OrderTopic != "" {
+ SendOrder()
+ }
// 涓婃姤鍗虫椂搴撳瓨
- SendInventory()
+ if config.Options.InventoryTopic != "" {
+ SendInventory()
+ }
- // 娴嬭瘯鏌ヨ璇锋眰
- //sql := []byte("select * from t_icitem where FItemID=3316")
- //ok := nsqclient.Produce(config.Options.SqlQueryTopic, sql)
- //logger.Debug("娴嬭瘯璇锋眰鎺ュ彛, %v", ok)
+ // 涓婃姤bom
+ if config.Options.BomTopic != "" {
+ SendBom(true)
+ }
time.Sleep(time.Duration(config.Options.SyncInterval) * time.Second)
}
--
Gitblit v1.8.0