From 89ce2bc6b71ea331c219c295074a289d09c808af Mon Sep 17 00:00:00 2001 From: zhangzengfei <zhangzengfei@smartai.com> Date: 星期四, 13 七月 2023 16:06:34 +0800 Subject: [PATCH] 修改车间代码的查询方式,返回正确的车间代码 --- config/config.go | 19 ++++++++++++++----- 1 files changed, 14 insertions(+), 5 deletions(-) diff --git a/config/config.go b/config/config.go index b50fcf5..fbeb267 100644 --- a/config/config.go +++ b/config/config.go @@ -15,10 +15,16 @@ SqlUsername string `json:"sql_username"` // 鏁版嵁搴撶敤鎴� SqlPassword string `json:"sql_password"` // 鏁版嵁搴撳瘑鐮� NsqServer string `json:"nsq_server"` // nsq TCP鏈嶅姟绔湴鍧� - NsqWebApi string `json:"nsq_server"` // nsq HTTP鎺ュ彛鍦板潃 + NsqWebApi string `json:"nsq_webapi"` // nsq HTTP鎺ュ彛鍦板潃 OrderTopic string `json:"order_topic"` // 璁㈠崟涓婃姤鐨則opic InventoryTopic string `json:"inventory_topic"` // 搴撳瓨涓婃姤鐨則opic + SqlQueryTopic string `json:"query_topic"` // 閲戣澏鏌ヨ鎺ュ彛鐨則opic + SqlReplyTopic string `json:"reply_topic"` // 閲戣澏鍝嶅簲鏌ヨ鎺ュ彛鐨則opic + CSTWebApi string `json:"cst_webapi"` // 鐢熶骇浠诲姟鍗曟彁浜ゅ湴鍧� + CSTQueryTopic string `json:"cst_query_topic"` // 鎻愪氦鐢熶骇浠诲姟鍗曚富棰� + CSTReplyTopic string `json:"cst_reply_topic"` // 鍝嶅簲鐢熶骇浠诲姟鍗曚富棰� SyncInterval int `json:"interval"` // 鍚屾鐨勬椂闂撮棿闅�, 鍗曚綅/绉� + Debug bool `json:"debug"` // 鏈湴璋冭瘯, 鍙栨湰鍦版暟鎹� } const configPath = "config.json" @@ -33,9 +39,14 @@ Options.SqlPassword = "123456" Options.NsqServer = "fai365.com:4150" Options.NsqWebApi = "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic" - Options.OrderTopic = "/province/city/factoryNo/kingdee_seOrder" - Options.InventoryTopic = "/province/city/factoryNo/kingdee_inventory" + Options.OrderTopic = "aps.factory.erp.seorder" + 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() { @@ -49,8 +60,6 @@ fd := json.NewDecoder(file) fd.Decode(&Options) - - fmt.Printf("%v\n", Options) } } -- Gitblit v1.8.0