CRMEB/crmeb/app/api/controller/wechat/WechatController.php
2019-11-22 18:54:54 +08:00

118 lines
4.3 KiB
PHP

<?php
namespace app\api\controller\wechat;
use app\models\user\User;
use app\models\user\UserToken;
use app\models\user\WechatUser;
use app\Request;
use crmeb\utils\CanvasService;
use crmeb\services\WechatService;
use think\facade\Cookie;
/**
* 微信公众号
* Class WechatController
* @package app\api\controller\wechat
*/
class WechatController
{
/**
* 微信公众号服务
* @return \think\Response
*/
public function serve()
{
return WechatService::serve();
}
/**
* 支付异步回调
*/
public function notify()
{
WechatService::handleNotify();
}
/**
* 公众号权限配置信息获取
* @param Request $request
* @return mixed
*/
public function config(Request $request)
{
return app('json')->success(json_decode(WechatService::jsSdk($request->get('url')), true));
}
/**
* 公众号授权登陆
* @param Request $request
* @return mixed
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public function auth(Request $request)
{
$spreadId = intval($request->param('spread'));
$login_type = $request->param('login_type', '');
try {
$wechatInfo = WechatService::oauthService()->user()->getOriginal();
} catch (\Exception $e) {
return app('json')->fail('授权失败');
}
if (!isset($wechatInfo['nickname'])) {
$wechatInfo = WechatService::getUserInfo($wechatInfo['openid']);
if (!$wechatInfo['subscribe'] && !isset($wechatInfo['nickname']))
exit(WechatService::oauthService()->scopes(['snsapi_userinfo'])
->redirect($this->request->url(true))->send());
if (isset($wechatInfo['tagid_list']))
$wechatInfo['tagid_list'] = implode(',', $wechatInfo['tagid_list']);
} else {
if (isset($wechatInfo['privilege'])) unset($wechatInfo['privilege']);
if (!WechatUser::be(['openid' => $wechatInfo['openid']]))
$wechatInfo['subscribe'] = 0;
}
$openid = $wechatInfo['openid'];
event('WechatOauthAfter', [$openid, $wechatInfo, $spreadId, $login_type]);
$user = User::where('uid', WechatUser::openidToUid($openid, 'openid'))->find();
if (!$user)
return app('json')->fail('获取用户信息失败');
if ($user->login_type == 'h5' && ($h5UserInfo = User::where(['account' => $user->phone, 'phone' => $user->phone, 'user_type' => 'h5'])->find()))
$token = UserToken::createToken($h5UserInfo, 'wechat');
else
$token = UserToken::createToken($user, 'wechat');
// 设置推广关系
User::setSpread(intval($spreadId), $user->uid);
if ($token) {
event('UserLogin', [$user, $token]);
return app('json')->success('登录成功', ['token' => $token->token, 'expires_time' => $token->expires_time]);
} else
return app('json')->fail('登录失败');
}
public function follow()
{
$canvas = CanvasService::instance();
$path = 'uploads/follow/';
$imageType = 'jpg';
$name = 'follow';
$siteUrl = sysConfig('site_url');
if (file_exists($path . $name . '.' . $imageType)) {
return app('json')->success('ok', ['path' => $siteUrl . '/' . $path . $name . '.' . $imageType]);
}
$canvas->setImageUrl('static/qrcode/follow.png')->setImageHeight(720)->setImageWidth(500)->pushImageValue();
$wechatQrcode = sysConfig('wechat_qrcode');
if (($strlen = stripos($wechatQrcode, 'uploads')) !== false) {
$wechatQrcode = substr($wechatQrcode, $strlen);
}
if (!$wechatQrcode)
return app('json')->fail('请上传二维码');
$canvas->setImageUrl($wechatQrcode)->setImageHeight(344)->setImageWidth(344)->setImageLeft(76)->setImageTop(76)->pushImageValue();
$image = $canvas->setFileName($name)->setImageType($imageType)->setPath($path)->setBackgroundWidth(500)->setBackgroundHeight(720)->starDrawChart();
return app('json')->success('ok', ['path' => $image ? $siteUrl . '/' . $image : '']);
}
}