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