Verified Commit 6d346185 authored by Cui's avatar Cui

fix bug

parent 155a8cfd
...@@ -6,7 +6,7 @@ import ( ...@@ -6,7 +6,7 @@ import (
. "gitlab.qingclass.cn/cuiweiqiang/utils" . "gitlab.qingclass.cn/cuiweiqiang/utils"
) )
func Sender(accessToken string, message MessageStruct) (int, string) { func Sender(accessToken string, message MessageStruct) (code int, msg string) {
log := Logger.WithFields(logrus.Fields{ log := Logger.WithFields(logrus.Fields{
"position": "wrapper.go", "position": "wrapper.go",
"func": "Sender", "func": "Sender",
...@@ -23,12 +23,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) { ...@@ -23,12 +23,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) {
log. log.
WithField("error", err). WithField("error", err).
Error(msg) Error(msg)
return -10001, msg code = -10001
break
} }
code, msg := CustomerMessageSender(accessToken, &cmi) code, msg = CustomerMessageSender(accessToken, &cmi)
break
return code, msg
case "TEMPLATE": case "TEMPLATE":
var tm TemplateMessage var tm TemplateMessage
err := json.Unmarshal(message.MessageData, &tm) err := json.Unmarshal(message.MessageData, &tm)
...@@ -38,10 +38,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) { ...@@ -38,10 +38,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) {
log. log.
WithField("error", err). WithField("error", err).
Error(msg) Error(msg)
return -10002, msg code = -10002
break
} }
return TemplateMessageSender(accessToken, tm) code, msg = TemplateMessageSender(accessToken, tm)
break
case "SUBSCRIBE": case "SUBSCRIBE":
var sm SubscribeMessage var sm SubscribeMessage
err := json.Unmarshal(message.MessageData, &sm) err := json.Unmarshal(message.MessageData, &sm)
...@@ -51,10 +53,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) { ...@@ -51,10 +53,12 @@ func Sender(accessToken string, message MessageStruct) (int, string) {
log. log.
WithField("error", err). WithField("error", err).
Error(msg) Error(msg)
return -10003, msg code = -10003
break
} }
return SubscribeMessageSender(accessToken, sm) code, msg = SubscribeMessageSender(accessToken, sm)
break
case "SMS": case "SMS":
var sm SmsMessage var sm SmsMessage
err := json.Unmarshal(message.MessageData, &sm) err := json.Unmarshal(message.MessageData, &sm)
...@@ -64,17 +68,19 @@ func Sender(accessToken string, message MessageStruct) (int, string) { ...@@ -64,17 +68,19 @@ func Sender(accessToken string, message MessageStruct) (int, string) {
log. log.
WithField("error", err). WithField("error", err).
Error(msg) Error(msg)
return -10004, msg code = -10004
break
} }
return SmsMessageSender(sm, message.SmsAppId, message.SmsAppKey) code, msg = SmsMessageSender(sm, message.SmsAppId, message.SmsAppKey)
break
default: default:
msg := "MessageType is not match" msg := "MessageType is not match"
log.WithField("MessageType", message.MessageType).Error(msg) log.WithField("MessageType", message.MessageType).Error(msg)
return -10000, msg code = -10000
} }
return 0, "" return
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment