添加bom查询

zhangzengfei

2023-08-14 8f750b461a4f442825e516016bf78d05ed66afcb

 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