mirror of
https://gitee.com/zoujingli/ThinkAdmin.git
synced 2026-06-08 21:08:09 +08:00
34104dad22
Replace header text "Payment Plugin for ThinkAdmin" with "ThinkAdmin Plugin for ThinkAdmin" across project files (configs, controllers, plugins, php-cs-fixer, etc.) to unify branding. Add a new composer script "rewrite-model" to regenerate models and run php-cs-fixer. Also apply a minor newline fix in .copilot-commit-message-instructions.md.
149 lines
4.7 KiB
PHP
149 lines
4.7 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
/**
|
||
* +----------------------------------------------------------------------
|
||
* | ThinkAdmin Plugin for ThinkAdmin
|
||
* +----------------------------------------------------------------------
|
||
* | 版权所有 2014~2026 ThinkAdmin [ thinkadmin.top ]
|
||
* +----------------------------------------------------------------------
|
||
* | 官方网站: https://thinkadmin.top
|
||
* +----------------------------------------------------------------------
|
||
* | 开源协议 ( https://mit-license.org )
|
||
* | 免责声明 ( https://thinkadmin.top/disclaimer )
|
||
* | 会员特权 ( https://thinkadmin.top/vip-introduce )
|
||
* +----------------------------------------------------------------------
|
||
* | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
|
||
* | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
|
||
* +----------------------------------------------------------------------
|
||
*/
|
||
|
||
namespace plugin\wechat\service;
|
||
|
||
use plugin\wechat\service\model\WechatAuth;
|
||
use think\admin\Exception;
|
||
use think\admin\Model;
|
||
use think\admin\Service;
|
||
use think\db\exception\DataNotFoundException;
|
||
use think\db\exception\DbException;
|
||
use think\db\exception\ModelNotFoundException;
|
||
use WeChat\Exceptions\InvalidResponseException;
|
||
use WeChat\Exceptions\LocalCacheException;
|
||
|
||
/**
|
||
* 公众号授权配置
|
||
* Class ConfigService.
|
||
*/
|
||
class ConfigService extends Service
|
||
{
|
||
/**
|
||
* 数据查询条件.
|
||
* @var array
|
||
*/
|
||
private $map;
|
||
|
||
/**
|
||
* 当前微信APPID.
|
||
* @var string
|
||
*/
|
||
private $appid;
|
||
|
||
/**
|
||
* 当前微信配置.
|
||
* @var Model
|
||
*/
|
||
private $config;
|
||
|
||
/**
|
||
* 授权配置初始化.
|
||
* @return $this
|
||
* @throws Exception
|
||
* @throws DataNotFoundException
|
||
* @throws DbException
|
||
* @throws ModelNotFoundException
|
||
*/
|
||
public function init(string $appid): ConfigService
|
||
{
|
||
$this->map = ['authorizer_appid' => $this->appid = $appid];
|
||
$this->config = WechatAuth::mk()->where($this->map)->find();
|
||
if (empty($this->config)) {
|
||
throw new Exception("公众号{$appid}还没有授权！");
|
||
}
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 获取当前公众号配置.
|
||
*/
|
||
public function getConfig(): array
|
||
{
|
||
return $this->config->toArray();
|
||
}
|
||
|
||
/**
|
||
* 设置微信接口通知URL地址
|
||
* @param string $notify 接口通知URL地址
|
||
* @throws Exception
|
||
*/
|
||
public function setApiNotifyUri(string $notify): bool
|
||
{
|
||
if (empty($notify)) {
|
||
throw new Exception('请传入微信通知URL');
|
||
}
|
||
return WechatAuth::mk()->where($this->map)->update(['appuri' => $notify]) !== false;
|
||
}
|
||
|
||
/**
|
||
* 更新接口 AppKey.
|
||
*/
|
||
public function updateApiAppkey(): string
|
||
{
|
||
$data = ['appkey' => md5(uniqid())];
|
||
WechatAuth::mk()->where($this->map)->update($data);
|
||
return $data['appkey'];
|
||
}
|
||
|
||
/**
|
||
* 获取公众号的配置参数.
|
||
* @param null|string $name 参数名称
|
||
* @return array|string
|
||
*/
|
||
public function config(?string $name = null)
|
||
{
|
||
return AuthService::WeChatScript($this->appid)->config->get($name);
|
||
}
|
||
|
||
/**
|
||
* 微信网页授权.
|
||
* @param string $sessid 当前会话id(可用session_id()获取)
|
||
* @param string $source 当前会话URL地址(需包含域名的完整URL地址)
|
||
* @param int $type 网页授权模式(0静默模式,1高级授权)
|
||
* @return array|bool
|
||
*/
|
||
public function oauth(string $sessid, string $source, int $type = 0): array
|
||
{
|
||
$fans = $this->app->cache->get("{$this->appid}_{$sessid}_fans", []);
|
||
$token = $this->app->cache->get("{$this->appid}_{$sessid}_token", []);
|
||
$openid = $this->app->cache->get("{$this->appid}_{$sessid}_openid", '');
|
||
if (!empty($openid) && !empty($type) && !empty($fans)) {
|
||
return ['openid' => $openid, 'token' => $token, 'fans' => $fans, 'url' => ''];
|
||
}
|
||
$mode = empty($type) ? 'snsapi_base' : 'snsapi_userinfo';
|
||
$params = ['mode' => $type, 'sessid' => $sessid, 'enurl' => enbase64url($source)];
|
||
$location = url('api.push/oauth', [], false, true)->build() . '?' . http_build_query($params);
|
||
$oauthurl = AuthService::WeOpenService()->getOauthRedirect($this->appid, $location, $mode);
|
||
return ['openid' => $openid, 'token' => $token, 'fans' => $fans, 'url' => $oauthurl];
|
||
}
|
||
|
||
/**
|
||
* 微信网页JS签名.
|
||
* @param string $url 当前会话URL地址(需包含域名的完整URL地址)
|
||
* @throws InvalidResponseException
|
||
* @throws LocalCacheException
|
||
*/
|
||
public function jsSign(string $url): array
|
||
{
|
||
return AuthService::WeChatScript($this->appid)->getJsSign($url);
|
||
}
|
||
}
|