54 lines
1.8 KiB
PHP
54 lines
1.8 KiB
PHP
<?php
|
||
// +------------------------------------------------+
|
||
// |http://www.cjango.com |
|
||
// +------------------------------------------------+
|
||
// | 修复BUG不是一朝一夕的事情，等我喝醉了再说吧！ |
|
||
// +------------------------------------------------+
|
||
// | Author: 小陈叔叔 <Jason.Chen> |
|
||
// +------------------------------------------------+
|
||
namespace job;
|
||
|
||
use app\common\model\Member as MemberModel;
|
||
use app\common\service\Wechat as WechatService;
|
||
use cjango\Wechat;
|
||
use cjango\Wechat\Template;
|
||
use think\queue\Job;
|
||
|
||
class Test extends _Init
|
||
{
|
||
public function fire(Job $job, $data)
|
||
{
|
||
if ($job->attempts() > 3) {
|
||
$data['msg'] = '重试3次';
|
||
parent::writelog($job->getName(), $data, 0);
|
||
$job->delete();
|
||
} else {
|
||
$openid = $data['openid'] ?? '';
|
||
$type = $data['type'] ?? '';
|
||
$d_array = $data['d_array'] ?? '';
|
||
$url = $data['url'] ?? '';
|
||
|
||
$user = MemberModel::where('openid', $openid)->find();
|
||
if ($user) {
|
||
WechatService::instance();
|
||
|
||
$tpl_data = json_decode($d_array, true);
|
||
$res = Template::send($openid, $type, $tpl_data, $url);
|
||
if ($res) {
|
||
$data['msg'] = '发送成功';
|
||
parent::writelog($job->getName(), $data, 1);
|
||
$job->delete();
|
||
} else {
|
||
$data['msg'] = Wechat::error();
|
||
parent::writelog($job->getName(), $data, 0);
|
||
$job->delete();
|
||
}
|
||
} else {
|
||
$data['msg'] = '用户不存在';
|
||
parent::writelog($job->getName(), $data, 0);
|
||
$job->delete();
|
||
}
|
||
}
|
||
}
|
||
}
|