From ac63d5e3aaf10d11fc864d27319d05897073bd24 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Thu, 5 Dec 2024 17:42:22 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=AD=E4=BF=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/aliyun_sms_record_consume.go | 3 +++ consume/md/consume_key.go | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) 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",