shop_id

app/queue/redis/SendMarkSms.php

@@ -20,7 +20,6 @@ class SendMarkSms implements Consumer
     public function consume($data)
     {
         try {
-            Db::startTrans();
             Log::info('消息队列【发送营销短信】接收到消息' . $data);
             // 区分数据
             $arr = explode(',', $data);
@@ -89,6 +88,7 @@ class SendMarkSms implements Consumer
                                                 'signName' => config('cons.sms_sign'),
                                             ];
                                             $res = AlibabaSms::main($data);
+                                            Db::startTrans();
                                             Db::table('sms_push_event')->where(['id' => $record['id']])->update([
                                                 'status' => '1',
                                                 'update_time' => date('Y-m-d H:i:s'),
@@ -105,8 +105,8 @@ class SendMarkSms implements Consumer
                                                     'create_time' => date('Y-m-d H:i:s'),
                                                     'status' => 1,
                                                 ]);
-                                                Db::commit();
                                             }
+                                            Db::commit();
                                         }else {
                                             Log::info('商户【'  . $record['shop_id'] . '】余额不足');
                                         }