diff --git a/consume/aliyun_sms_record_consume.go b/consume/aliyun_sms_record_consume.go index d6e443c..3d5751d 100644 --- a/consume/aliyun_sms_record_consume.go +++ b/consume/aliyun_sms_record_consume.go @@ -85,6 +85,9 @@ func handleAliyunSmsRecordConsume(msgData []byte) error { aliyunSmsSaleCode = msg.Code extra = msg.Extra } + if aliyunSmsSaleCode == "" { + return nil + } err = aliyun.AliyunSendSms(aliyunSmsId, aliyunSmsSecret, msg.Phone, aliyunSmsSignName, aliyunSmsSaleCode, extra) if err != nil { return err diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index e389a91..4a7bd43 100644 --- a/consume/md/consume_key.go +++ b/consume/md/consume_key.go @@ -112,7 +112,7 @@ var RabbitMqQueueKeyList = []*MqQueue{ }, { ExchangeName: "egg.aliyun_sms", - Name: "egg_aliyun_sms_record_queue", + Name: "egg_aliyun_sms_record_queue_new", Type: DirectQueueType, IsPersistent: false, RoutKey: "aliyun_sms_record",