diff --git a/app/queue/redis/SendMarkSms.php b/app/queue/redis/SendMarkSms.php index 977daa2..6a37dac 100644 --- a/app/queue/redis/SendMarkSms.php +++ b/app/queue/redis/SendMarkSms.php @@ -41,7 +41,7 @@ class SendMarkSms implements Consumer if($data) { // 发送任务 // $record = Db::table('sms_push_event')->where(['id' => $sms_push_event_id, 'push_type' => 2])->find(); - $record = Db::table('sms_push_event')->where(['id' => $sms_push_event_id])->find(); + $record = Db::table('sms_push_event')->where(['id' => $sms_push_event_id, 'status' => 0])->find(); if($record) { // 查询是否是定时发送 if($record['send_type'] == 2 && $record['send_time'] > date('Y-m-d H:i:s')) { @@ -109,11 +109,9 @@ class SendMarkSms implements Consumer } }else { Log::info('商户【' . $record['shop_id'] . '】余额不足'); - return false; } }else { Log::info('商户【' . $record['shop_id'] . '】余额为空'); - return false; } sleep(1); }