From 942f3416b333304bde50f0dca5581595f397eafa Mon Sep 17 00:00:00 2001
From: gigibox <gigibox@163.com>
Date: 星期一, 19 六月 2023 16:27:26 +0800
Subject: [PATCH] 完善功能,添加日志,添加nsq tcp上报
---
config/config.go | 12 +++++++-----
1 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/config/config.go b/config/config.go
index b50fcf5..4d731e0 100644
--- a/config/config.go
+++ b/config/config.go
@@ -15,10 +15,12 @@
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
+ QueryTopic string `json:"query_topic"` // 閲戣澏鏌ヨ鎺ュ彛鐨則opic
SyncInterval int `json:"interval"` // 鍚屾鐨勬椂闂撮棿闅�, 鍗曚綅/绉�
+ Debug bool `json:"debug"` // 鏈湴璋冭瘯, 鍙栨湰鍦版暟鎹�
}
const configPath = "config.json"
@@ -33,9 +35,11 @@
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.QueryTopic = "aps.factory.erp.k3resource"
Options.SyncInterval = 60
+ Options.Debug = false
}
func Load() {
@@ -49,8 +53,6 @@
fd := json.NewDecoder(file)
fd.Decode(&Options)
-
- fmt.Printf("%v\n", Options)
}
}
--
Gitblit v1.8.0