diff --git a/app/queue/redis/SendWechatTemp.php b/app/queue/redis/SendWechatTemp.php
index 21920bc..5c47f79 100644
--- a/app/queue/redis/SendWechatTemp.php
+++ b/app/queue/redis/SendWechatTemp.php
@@ -117,7 +117,6 @@ class SendWechatTemp implements Consumer
                                             ],
                                         ]);
 
-                                        Db::startTrans();
                                         Db::table('ac_push_event')->where(['id' => $record['id']])->update([
                                             'status' => 1,
                                             'update_time' => date('Y-m-d H:i:s'),
@@ -125,6 +124,7 @@ class SendWechatTemp implements Consumer
                                         ]);
                                         Log::info('模版发送结果' . json_encode($wechat_res));
                                         if($wechat_res['errcode'] == 0 && $wechat_res['errmsg'] == 'ok') {
+                                            Db::startTrans();
                                             Log::info('OKKKKK了');
                                             Db::table('sms_push_event_record')->insert([
                                                 'shop_id' => $record['shop_id'],
@@ -141,8 +141,8 @@ class SendWechatTemp implements Consumer
                                                 'update_time' => date('Y-m-d H:i:s'),
                                                 'send_time' => date('Y-m-d H:i:s'),
                                             ]);
+                                            Db::commit();
                                         }
-                                        Db::commit();
                                     }else {
                                         Log::info('用户' . $user['u_user_id'] . 'open_id 为空。不发送');
                                     }
@@ -157,7 +157,7 @@ class SendWechatTemp implements Consumer
                     Log::info('发送营销短信未查询到');
                 }
             }
-        }catch (Exception $e) {
+        }catch (\Throwable $e) {
             Db::rollback();
             Log::error($e->getMessage());
         }