diff --git a/app/queue/redis/SendWechatTemp.php b/app/queue/redis/SendWechatTemp.php index 4d3505a..21920bc 100644 --- a/app/queue/redis/SendWechatTemp.php +++ b/app/queue/redis/SendWechatTemp.php @@ -34,7 +34,7 @@ class SendWechatTemp implements Consumer if($data) { // 发送任务 // $record = Db::table('sms_push_event')->where(['id' => $sms_push_event_id, 'push_type' => 2])->find(); - $record = Db::table('ac_push_event')->where(['id' => $sms_push_event_id, 'status' => 0])->find(); + $record = Db::table('ac_push_event')->where(['id' => $sms_push_event_id, 'status' => 0, 'is_del' => 0])->find(); if($record) { // 查询是否是定时发送 if($record['send_type'] == 2 && $record['send_time'] > date('Y-m-d H:i:s')) { @@ -82,6 +82,7 @@ class SendWechatTemp implements Consumer ->alias('su') ->join('tb_user_info ui', 'su.user_id = ui.id') ->where('su.main_shop_id', $shop_id) + ->where('ui.is_ac', 1) ->where('ui.wechat_ac_open_id', '<>', '') ->whereNotNull('ui.wechat_ac_open_id') ->field('DISTINCT ui.wechat_ac_open_id,ui.id,ui.phone') @@ -106,6 +107,7 @@ class SendWechatTemp implements Consumer 'template_id' => 'hGsUGZlWqWC9TMm4ZGZuz0OwE4gwSmvgbr5ecmTDvq4', 'miniprogram' => [ 'appid' => 'wxd88fffa983758a30', // 零点八零 + 'pagepath' => 'pages/index/index', // 零点八零 ], 'data' => [ 'thing7' => $record['shop_name'],