From 8f750b461a4f442825e516016bf78d05ed66afcb Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期一, 14 八月 2023 18:14:50 +0800 Subject: [PATCH] 添加bom查询 --- config/config.go | 8 ++++++-- 1 files changed, 6 insertions(+), 2 deletions(-) diff --git a/config/config.go b/config/config.go index fbeb267..3994d37 100644 --- a/config/config.go +++ b/config/config.go @@ -17,6 +17,9 @@ NsqServer string `json:"nsq_server"` // nsq TCP鏈嶅姟绔湴鍧� NsqWebApi string `json:"nsq_webapi"` // nsq HTTP鎺ュ彛鍦板潃 OrderTopic string `json:"order_topic"` // 璁㈠崟涓婃姤鐨則opic + BomTopic string `json:"bom_topic"` // bom涓婃姤鐨則opic + BomQueryTopic string `json:"bom_query_topic"` // bom涓婃姤鐨則opic + BomChildTopic string `json:"bom_child_topic"` // bom瀛愰」涓婃姤鐨則opic InventoryTopic string `json:"inventory_topic"` // 搴撳瓨涓婃姤鐨則opic SqlQueryTopic string `json:"query_topic"` // 閲戣澏鏌ヨ鎺ュ彛鐨則opic SqlReplyTopic string `json:"reply_topic"` // 閲戣澏鍝嶅簲鏌ヨ鎺ュ彛鐨則opic @@ -24,7 +27,6 @@ CSTQueryTopic string `json:"cst_query_topic"` // 鎻愪氦鐢熶骇浠诲姟鍗曚富棰� CSTReplyTopic string `json:"cst_reply_topic"` // 鍝嶅簲鐢熶骇浠诲姟鍗曚富棰� SyncInterval int `json:"interval"` // 鍚屾鐨勬椂闂撮棿闅�, 鍗曚綅/绉� - Debug bool `json:"debug"` // 鏈湴璋冭瘯, 鍙栨湰鍦版暟鎹� } const configPath = "config.json" @@ -40,13 +42,15 @@ Options.NsqServer = "fai365.com:4150" Options.NsqWebApi = "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic" Options.OrderTopic = "aps.factory.erp.seorder" + Options.BomTopic = "aps.factory.erp.icBom" + Options.BomChildTopic = "aps.factory.erp.icBomChild" + Options.BomQueryTopic = "aps.factory.erp.icBomQuery" Options.InventoryTopic = "aps.factory.erp.inventory" Options.SqlQueryTopic = "aps.factory.erp.k3resource" Options.SqlReplyTopic = "aps.factory.erp.k3reply" Options.CSTQueryTopic = "aps.factory.erp.cstApply" Options.CSTReplyTopic = "aps.factory.erp.cstReply" Options.SyncInterval = 60 - Options.Debug = false } func Load() { -- Gitblit v1.8.0