From 119dadc564220b4da1604bd3d2d207557e4cdbbd Mon Sep 17 00:00:00 2001
From: huangjiajun <582604932@qq.com>
Date: Thu, 5 Dec 2024 18:04:46 +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      | 2 +-
 consume/egg_fin_withdraw_apply_consume.go | 3 +--
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/consume/aliyun_sms_record_consume.go b/consume/aliyun_sms_record_consume.go
index 3d5751d..ea656d0 100644
--- a/consume/aliyun_sms_record_consume.go
+++ b/consume/aliyun_sms_record_consume.go
@@ -85,7 +85,7 @@ func handleAliyunSmsRecordConsume(msgData []byte) error {
 		aliyunSmsSaleCode = msg.Code
 		extra = msg.Extra
 	}
-	if aliyunSmsSaleCode == "" {
+	if aliyunSmsSaleCode == "" || msg.Phone == "" {
 		return nil
 	}
 	err = aliyun.AliyunSendSms(aliyunSmsId, aliyunSmsSecret, msg.Phone, aliyunSmsSignName, aliyunSmsSaleCode, extra)
diff --git a/consume/egg_fin_withdraw_apply_consume.go b/consume/egg_fin_withdraw_apply_consume.go
index 49d5673..fd5d6fe 100644
--- a/consume/egg_fin_withdraw_apply_consume.go
+++ b/consume/egg_fin_withdraw_apply_consume.go
@@ -38,7 +38,7 @@ func EggFinWithdrawApplyDataConsume(queue md.MqQueue) {
 	//2、取出数据进行消费
 	ch.Qos(1)
 	delivery := ch.Consume(queue.Name, false)
-
+	egg_system_rules.Init(cfg.RedisAddr)
 	var alipayStruct *InitAlipayStruct
 	client, err := InitAlipay(alipayStruct)
 	if err != nil {
@@ -48,7 +48,6 @@ func EggFinWithdrawApplyDataConsume(queue md.MqQueue) {
 		}))
 		return
 	}
-	egg_system_rules.Init(cfg.RedisAddr)
 	var res amqp.Delivery
 	var ok bool
 	for {