短信

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

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",