12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364 |
- <?php
-
-
- namespace app\jobs\template;
-
-
- use crmeb\basic\BaseJobs;
- use crmeb\services\template\Template;
- use crmeb\traits\QueueTrait;
- use think\facade\Log;
- use think\facade\Route;
-
- /**
- * Class TemplateJob
- * @package app\jobs
- */
- class TemplateJob extends BaseJobs
- {
- use QueueTrait;
-
- /**
- * @param $type
- * @param $openid
- * @param $tempCode
- * @param $data
- * @param $link
- * @param $color
- * @return bool|mixed
- */
- public function doJob($type, $openid, $tempCode, $data, $link, $color)
- {
- try {
- if (!$openid) return true;
- $template = new Template($type ?: 'wechat');
- $template->to($openid);
- if ($color) {
- $template->color($color);
- }
- if ($link) {
-
- switch ($type) {
- case 'wechat':
- $link =
- sys_config('site_url') . Route::buildUrl($link)
- ->suffix('')
- ->domain(false)->build();
- break;
- }
-
- $template->url($link);
- }
- $res = $template->send($tempCode, $data);
- if (!$res) {
- $msg = $type == 'wechat' ? '微信模版消息' : '订阅消息';
- Log::error($msg . '发送失败,原因:' . $template->getError() . '----参数:' . json_encode(compact('tempCode', 'openid', 'data', 'link')));
- }
- return true;
- } catch (\Exception $e) {
- Log::error($e->getMessage());
- return true;
- }
- }
-
- }
|