59 行
2.2 KiB
PHP
59 行
2.2 KiB
PHP
<?php
|
||
|
||
namespace addons\shopro\library\notify\channel;
|
||
|
||
use addons\shopro\notifications\Notification;
|
||
|
||
class WxMiniProgram
|
||
{
|
||
|
||
public function __construct()
|
||
{
|
||
}
|
||
|
||
|
||
/**
|
||
* 发送 微信模板消息
|
||
*
|
||
* @param mixed $notifiable // 通知用户
|
||
* @param 通知内容
|
||
* @return void
|
||
*/
|
||
public function send($notifiable, Notification $notification)
|
||
{
|
||
$data = [];
|
||
|
||
if (method_exists($notification, 'toWxMiniProgram')) {
|
||
$data = $notification->toWxMiniProgram($notifiable);
|
||
|
||
if ($data && isset($data['openid']) && isset($data['template_id']) && $data['template_id']) {
|
||
$data['touser'] = $data['openid'];
|
||
unset($data['openid']);
|
||
|
||
try {
|
||
// 发送模板消息
|
||
$result = (new \addons\shopro\library\Wechat('wxMiniProgram'))->getApp()->subscribe_message->send($data);
|
||
|
||
if ($result['errcode'] != 0) {
|
||
// 小程序模板发送失败
|
||
\think\Log::write('小程序模板消息发送失败：用户：'. $notifiable['id'] . '；类型：' . get_class($notification) . "；发送类型：" . $notification->event . "；错误信息：" . json_encode($result));
|
||
} else {
|
||
// 发送成功
|
||
$notification->sendOk('wxMiniProgram');
|
||
}
|
||
} catch (\Exception $e) {
|
||
// 因为配置较麻烦，这里捕获异常防止因为缺少字段，导致队列一直执行不成功
|
||
\think\Log::write('小程序模板消息发送失败：用户：' . $notifiable['id'] . '；类型：' . get_class($notification) . "；发送类型：" . $notification->event . "；错误信息：" . $e->getMessage());
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
// 没有openid
|
||
\think\Log::write('小程序模板消息发送失败，没有 openid：用户：' . $notifiable['id'] . '；类型：' . get_class($notification) . "；发送类型：" . $notification->event);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
}
|