user_id 保存

This commit is contained in:
2025-10-22 10:21:12 +08:00
parent 1ddef4432a
commit 90a58de0ce

View File

@@ -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'],