From 59e6096769bc175516c1bcbbc12e4711d1ff294c Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 15 八月 2023 18:08:17 +0800
Subject: [PATCH] 调整代码结构
---
kingdee/query.go | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/kingdee/query.go b/kingdee/query.go
index 2da57a5..e905a4a 100644
--- a/kingdee/query.go
+++ b/kingdee/query.go
@@ -10,7 +10,9 @@
"kingdee-dbapi/nsqclient"
)
-type QueryMsg struct {
+// 閫氱敤sql鏌ヨ鎺ュ彛
+
+type SqlQueryMsg struct {
Key string // 璇锋眰
Command string
Success bool
@@ -18,8 +20,8 @@
Result []byte
}
-func QueryMsgHandle(msg []byte) error {
- var query QueryMsg
+func SqlQueryHandle(msg []byte) error {
+ var query SqlQueryMsg
if err := json.Unmarshal(msg, &query); err != nil {
logger.Warn("瑙ｆ瀽璇锋眰澶辫触, %s", err.Error())
@@ -45,7 +47,7 @@
}
replyData, _ := json.Marshal(query)
- ok := nsqclient.Produce(config.Options.ReplyTopic, replyData)
+ ok := nsqclient.Produce(config.Options.SqlReplyTopic, replyData)
logger.Warn("搴旂瓟鏌ヨ璇锋眰缁撴灉:%t, key:%s", ok, query.Key)
return nil
--
Gitblit v1.8.0