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 {