diff --git a/application/service/controller/Index.php b/application/service/controller/Index.php index 6ea21eae4..bac807ad4 100644 --- a/application/service/controller/Index.php +++ b/application/service/controller/Index.php @@ -14,8 +14,8 @@ namespace app\service\controller; -use app\service\service\Build; -use app\service\service\Wechat; +use app\service\service\BuildService; +use app\service\service\WechatService; use library\Controller; use think\Db; @@ -57,7 +57,7 @@ class Index extends Controller public function clearQuota() { $appid = input('appid'); - $result = Wechat::WeChatLimit($appid)->clearQuota(); + $result = WechatService::WeChatLimit($appid)->clearQuota(); if (empty($result['errcode']) && $result['errmsg'] === 'ok') { $this->success('接口调用次数清零成功！'); } elseif (isset($result['errmsg'])) { @@ -77,7 +77,7 @@ class Index extends Controller $where = ['authorizer_appid' => $appid, 'is_deleted' => '0', 'status' => '1']; $author = Db::name('WechatServiceConfig')->where($where)->find(); empty($author) && $this->error('无效的授权信息，请同步其它公众号！'); - $data = Build::filter(Wechat::service()->getAuthorizerInfo($appid)); + $data = BuildService::filter(WechatService::service()->getAuthorizerInfo($appid)); $data['authorizer_appid'] = $appid; $where = ['authorizer_appid' => $data['authorizer_appid']]; $appkey = Db::name('WechatServiceConfig')->where($where)->value('appkey'); @@ -98,10 +98,10 @@ class Index extends Controller public function syncall() { try { - $wechat = Wechat::service(); + $wechat = WechatService::service(); $result = $wechat->getAuthorizerList(); foreach ($result['list'] as $item) if (!empty($item['refresh_token']) && !empty($item['auth_time'])) { - $data = Build::filter($wechat->getAuthorizerInfo($item['authorizer_appid'])); + $data = BuildService::filter($wechat->getAuthorizerInfo($item['authorizer_appid'])); $data['is_deleted'] = '0'; $data['authorizer_appid'] = $item['authorizer_appid']; $data['authorizer_refresh_token'] = $item['refresh_token']; diff --git a/application/service/controller/api/Client.php b/application/service/controller/api/Client.php index dd889b3e5..88f9d31e6 100644 --- a/application/service/controller/api/Client.php +++ b/application/service/controller/api/Client.php @@ -14,7 +14,7 @@ namespace app\service\controller\api; -use app\service\service\Wechat; +use app\service\service\WechatService; use think\Controller; use think\Db; @@ -104,13 +104,13 @@ class Client extends Controller $weminiClassName = 'Account,Basic,Code,Domain,Tester,User,Crypt,Plugs,Poi,Qrcode,Template,Total'; $wechatClassName = 'Card,Custom,Limit,Media,Menu,Oauth,Pay,Product,Qrcode,Receive,Scan,Script,Shake,Tags,Template,User,Wifi'; if ($this->type === 'wechat' && stripos($wechatClassName, $this->name) !== false) { - $instance = Wechat::instance($this->name, $this->appid, 'WeChat'); + $instance = WechatService::instance($this->name, $this->appid, 'WeChat'); } elseif ($this->type === 'wemini' && stripos($weminiClassName, $this->name) !== false) { - $instance = Wechat::instance($this->name, $this->appid, 'WeMini'); + $instance = WechatService::instance($this->name, $this->appid, 'WeMini'); } elseif (stripos('Service,MiniApp', $this->name) !== false) { - $instance = Wechat::instance($this->name, $this->appid, 'WeOpen'); + $instance = WechatService::instance($this->name, $this->appid, 'WeOpen'); } elseif (stripos('Wechat,Config,Handler', $this->name) !== false) { - $className = "\\app\\service\\handler\\Wechat"; + $className = "\\app\\service\\handler\\WechatHandler"; $instance = new $className($this->config); } if (!empty($instance)) return $instance; diff --git a/application/service/controller/api/Push.php b/application/service/controller/api/Push.php index 2c6e641b2..c983942dc 100644 --- a/application/service/controller/api/Push.php +++ b/application/service/controller/api/Push.php @@ -14,8 +14,8 @@ namespace app\service\controller\api; -use app\service\service\Build; -use app\service\service\Wechat; +use app\service\service\BuildService; +use app\service\service\WechatService; use library\Controller; use think\Db; @@ -41,12 +41,13 @@ class Push extends Controller */ public function notify($appid) { - /* 全网发布接口测试 */ if ($appid === 'wx570bc396a51b8ff8') { - return \app\service\handler\Publish::handler($appid); + # 全网发布接口测试 + return \app\service\handler\PublishHandler::handler($appid); + } else { + # 接口类正常服务 + return \app\service\handler\ReceiveHandler::handler($appid); } - /* 接口类正常服务 */ - return \app\service\handler\Receive::handler($appid); } /** @@ -61,7 +62,7 @@ class Push extends Controller public function ticket() { try { - $server = Wechat::service(); + $server = WechatService::service(); if (!($data = $server->getComonentTicket())) { return "Ticket event handling failed."; } @@ -98,7 +99,7 @@ class Push extends Controller $this->request->get('mode'), $this->request->get('state'), $this->request->get('enurl'), $this->request->get('sessid'), ]; - $service = Wechat::service(); + $service = WechatService::service(); $result = $service->getOauthAccessToken($appid); if (empty($result['openid'])) throw new \think\Exception('网页授权失败, 无法进一步操作！'); cache("{$appid}_{$sessid}_openid", $result['openid'], 3600); @@ -127,7 +128,7 @@ class Push extends Controller return '请传入回跳Redirect参数 ( 请使用ENCODE加密 )'; } # 预授权码不为空，则表示可以进行授权处理 - $service = Wechat::service(); + $service = WechatService::service(); if (($auth_code = $this->request->get('auth_code'))) { return $this->applyAuth($service, $fromRedirect); } @@ -164,7 +165,7 @@ class Push extends Controller return '获取授权数据失败, 请稍候再试!'; } // 生成公众号授权参数 - $update = array_merge(Build::filter($update), [ + $update = array_merge(BuildService::filter($update), [ 'status' => '1', 'is_deleted' => '0', 'expires_in' => time() + 7000, 'create_at' => date('y-m-d H:i:s'), ]); // 微信接口APPKEY处理与更新 diff --git a/application/service/handler/Publish.php b/application/service/handler/Publish.php deleted file mode 100644 index 40f557ff5..000000000 --- a/application/service/handler/Publish.php +++ /dev/null @@ -1,67 +0,0 @@ - - * @date 2016/10/27 14:14 - */ -class Publish -{ - - /** - * 当前微信APPID - * @var string - */ - protected static $appid; - - /** - * 事件初始化 - * @param string $appid - * @return string - * @throws \WeChat\Exceptions\InvalidDecryptException - * @throws \think\Exception - * @throws \think\exception\PDOException - */ - public static function handler($appid) - { - try { - $wechat = Wechat::WeChatReceive($appid); - } catch (\Exception $e) { - return "Wechat message handling failed, {$e->getMessage()}"; - } - /* 分别执行对应类型的操作 */ - switch (strtolower($wechat->getMsgType())) { - case 'text': - $receive = $wechat->getReceive(); - if ($receive['Content'] === 'TESTCOMPONENT_MSG_TYPE_TEXT') { - return $wechat->text('TESTCOMPONENT_MSG_TYPE_TEXT_callback')->reply([], true); - } - $key = str_replace("QUERY_AUTH_CODE:", '', $receive['Content']); - Wechat::instance('Service')->getQueryAuthorizerInfo($key); - return $wechat->text("{$key}_from_api")->reply([], true); - case 'event': - $receive = $wechat->getReceive(); - return $wechat->text("{$receive['Event']}from_callback")->reply([], true); - default: - return 'success'; - } - } - -} diff --git a/application/service/handler/Receive.php b/application/service/handler/Receive.php deleted file mode 100644 index 074bbfc34..000000000 --- a/application/service/handler/Receive.php +++ /dev/null @@ -1,64 +0,0 @@ - - * @date 2016/10/27 14:14 - */ -class Receive -{ - - /** - * 事件初始化 - * @param string $appid - * @return string - * @throws \think\db\exception\DataNotFoundException - * @throws \think\db\exception\ModelNotFoundException - * @throws \think\exception\DbException - * @throws \think\Exception - */ - public static function handler($appid) - { - try { - $service = Wechat::WeChatReceive($appid); - } catch (\Exception $e) { - return "Wechat message handling failed, {$e->getMessage()}"; - } - // 验证微信配置信息 - $config = Db::name('WechatServiceConfig')->where(['authorizer_appid' => $appid])->find(); - if (empty($config) || empty($config['appuri'])) { - \think\facade\Log::error(($message = "微信{$appid}授权配置验证无效")); - return $message; - } - try { - list($data, $openid) = [$service->getReceive(), $service->getOpenid()]; - if (isset($data['EventKey']) && is_object($data['EventKey'])) $data['EventKey'] = (array)$data['EventKey']; - $input = ['openid' => $openid, 'appid' => $appid, 'receive' => serialize($data), 'encrypt' => intval($service->isEncrypt())]; - if (is_string($result = http_post($config['appuri'], $input, ['timeout' => 30]))) { - return $result; - } - } catch (\Exception $e) { - \think\facade\Log::error("微信{$appid}接口调用异常，{$e->getMessage()}"); - } - return 'success'; - } - -} diff --git a/application/service/handler/Wechat.php b/application/service/handler/Wechat.php deleted file mode 100644 index 1d56380e4..000000000 --- a/application/service/handler/Wechat.php +++ /dev/null @@ -1,160 +0,0 @@ - - */ -class Wechat -{ - /** - * 当前微信APPID - * @var string - */ - protected $appid; - - /** - * 当前微信配置 - * @var array - */ - protected $config; - - /** - * 错误消息 - * @var string - */ - protected $message; - - /** - * Wechat constructor. - * @param array $config - */ - public function __construct($config = []) - { - $this->config = $config; - $this->appid = isset($config['authorizer_appid']) ? $config['authorizer_appid'] : ''; - } - - /** - * 检查微信配置服务初始化状态 - * @return boolean - * @throws \think\Exception - */ - private function checkInit() - { - if (!empty($this->config)) return true; - throw new \think\Exception('Wechat Please bind Wechat first'); - } - - /** - * 获取当前公众号配置 - * @return array|boolean - * @throws \think\Exception - */ - public function getConfig() - { - $this->checkInit(); - $info = Db::name('WechatServiceConfig')->where(['authorizer_appid' => $this->appid])->find(); - if (empty($info)) return false; - if (isset($info['id'])) unset($info['id']); - return $info; - } - - /** - * 设置微信接口通知URL地址 - * @param string $notifyUri 接口通知URL地址 - * @return boolean - * @throws \think\Exception - * @throws \think\exception\PDOException - */ - public function setApiNotifyUri($notifyUri) - { - $this->checkInit(); - if (empty($notifyUri)) throw new \think\Exception('请传入微信通知URL'); - list($where, $data) = [['authorizer_appid' => $this->appid], ['appuri' => $notifyUri]]; - return Db::name('WechatServiceConfig')->where($where)->update($data) !== false; - } - - /** - * 更新接口Appkey(成功返回新的Appkey) - * @return bool|string - * @throws \think\Exception - * @throws \think\exception\PDOException - */ - public function updateApiAppkey() - { - $this->checkInit(); - $data = ['appkey' => md5(uniqid())]; - Db::name('WechatServiceConfig')->where(['authorizer_appid' => $this->appid])->update($data); - return $data['appkey']; - } - - /** - * 获取公众号的配置参数 - * @param string $name 参数名称 - * @return array|string - * @throws \think\Exception - */ - public function config($name = null) - { - $this->checkInit(); - return WechatLogic::WeChatScript($this->appid)->config->get($name); - } - - /** - * 微信网页授权 - * @param string $sessid 当前会话id(可用session_id()获取) - * @param string $selfUrl 当前会话URL地址(需包含域名的完整URL地址) - * @param int $fullMode 网页授权模式(0静默模式,1高级授权) - * @return array|bool - * @throws \think\Exception - */ - public function oauth($sessid, $selfUrl, $fullMode = 0) - { - $this->checkInit(); - $fans = cache("{$this->appid}_{$sessid}_fans"); - $openid = cache("{$this->appid}_{$sessid}_openid"); - if (!empty($openid) && (empty($fullMode) || !empty($fans))) { - return ['openid' => $openid, 'fans' => $fans, 'url' => '']; - } - $service = WechatLogic::service(); - $mode = empty($fullMode) ? 'snsapi_base' : 'snsapi_userinfo'; - $url = url('@service/api.push/oauth', '', true, true); - $params = ['mode' => $fullMode, 'sessid' => $sessid, 'enurl' => encode($selfUrl)]; - $authurl = $service->getOauthRedirect($this->appid, $url . '?' . http_build_query($params), $mode); - return ['openid' => $openid, 'fans' => $fans, 'url' => $authurl]; - } - - /** - * 微信网页JS签名 - * @param string $url 当前会话URL地址(需包含域名的完整URL地址) - * @return array|boolean - * @throws \WeChat\Exceptions\InvalidResponseException - * @throws \WeChat\Exceptions\LocalCacheException - * @throws \think\Exception - */ - public function jsSign($url) - { - $this->checkInit(); - return WechatLogic::WeChatScript($this->appid)->getJsSign($url); - } - -} \ No newline at end of file diff --git a/application/service/service/Build.php b/application/service/service/Build.php deleted file mode 100644 index 4954ea0f6..000000000 --- a/application/service/service/Build.php +++ /dev/null @@ -1,52 +0,0 @@ - env('runtime_path') . 'wechat', - 'component_appid' => sysconf('component_appid'), - 'component_token' => sysconf('component_token'), - 'component_appsecret' => sysconf('component_appsecret'), - 'component_encodingaeskey' => sysconf('component_encodingaeskey'), - ]; - // 注册授权公众号 AccessToken 处理 - $config['GetAccessTokenCallback'] = function ($authorizerAppid) use ($config) { - $where = ['authorizer_appid' => $authorizerAppid]; - if (!($refreshToken = Db::name('WechatServiceConfig')->where($where)->value('authorizer_refresh_token'))) { - throw new \think\Exception('The WeChat information is not configured.', '404'); - } - $open = new \WeOpen\MiniApp($config); - $result = $open->refreshAccessToken($authorizerAppid, $refreshToken); - if (empty($result['authorizer_access_token']) || empty($result['authorizer_refresh_token'])) { - throw new \think\Exception($result['errmsg'], '0'); - } - Db::name('WechatServiceConfig')->where($where)->update([ - 'authorizer_access_token' => $result['authorizer_access_token'], - 'authorizer_refresh_token' => $result['authorizer_refresh_token'], - ]); - return $result['authorizer_access_token']; - }; - $app = new \WeOpen\MiniApp($config); - if (in_array(strtolower($name), ['service', 'miniapp'])) { - return $app; - } - if (!in_array($type, ['WeChat', 'WeMini'])) { - $type = self::$type; - } - return $app->instance($name, $appid, $type); - } - - /** - * 静态初始化对象 - * @param string $name - * @param array $arguments - * @return mixed - * @throws \think\Exception - * @throws \think\exception\PDOException - */ - public static function __callStatic($name, $arguments) - { - if (substr($name, 0, 6) === 'WeMini') { - self::$type = 'WeMini'; - $name = substr($name, 6); - } elseif (substr($name, 0, 6) === 'WeChat') { - self::$type = 'WeChat'; - $name = substr($name, 6); - } elseif (substr($name, 0, 5) === 'WePay') { - self::$type = 'WePay'; - $name = substr($name, 5); - } - return self::instance($name, isset($arguments[0]) ? $arguments[0] : '', self::$type); - } - -} diff --git a/application/service/view/config/index.html b/application/service/view/config/index.html index 8210e748b..5bce33fa3 100644 --- a/application/service/view/config/index.html +++ b/application/service/view/config/index.html @@ -1,94 +1,100 @@ {extend name="admin@main"} {block name="content"} -
-
- 强烈建议安装 YAR 扩展来实现接口通信，SOAP 不能正常显示接口的异常信息。 -
-
- 授权参数 -
-
- -

开放平台服务 AppID，需要在微信开放平台获取。

-
-
- -

开放平台服务 AppSecret，需要在微信开放平台获取。

-
-
- -

开发者在代替微信接收到消息时，用此 Token 来校验消息。

-
-
- -

在代替微信收发消息过程中使用。必须是长度为43位的字符串，只能是字母和数字。

-
-
-
- -
-
-
+
-
- 对接信息 -
-

授权发起页域名

- -

必须从本域名内网页跳转到登录授权页，才可完成登录授权。无需填写 http:// 等域名协议前缀

+
+ 强烈建议安装 YAR 扩展来实现接口通信，SOAP 不能正常显示接口的异常信息 +
+ +
+
+
+ 授权参数 +
+
+ +

开放平台服务 AppID，需要在微信开放平台获取

+
+
+ +

开放平台服务 AppSecret，需要在微信开放平台获取

+
+
+ +

开发者在代替微信接收到消息时，用此 Token 来校验消息

+
+
+ +

在代替微信收发消息时使用，必须是长度为43位字母和数字组合的字符串

+
+
+
+ +
+
+
-
-

授权事件接收 URL

- -

用于接收取消授权通知、授权成功通知、授权更新通知，也用于接收 ticket，ticket 是验证平台方的重要凭据

+
+
+ 对接信息 +
+
+

授权发起页域名

+ +

从本域名跳转到登录授权页才可以完成登录授权，无需填写域名协议前缀

+
+
+

授权事件接收 URL

+ +

用于接收取消授权通知、授权成功通知、授权更新通知、接收 TICKET 凭据

+
+
+

微信消息与事件接收 URL

+ +

通过该 URL 接收微信消息和事件推送，$APPID$ 将被替换为微信 AppId

+
+
+

客户端系统 Yar 模块接口

+ +

客户端 Yar 接口，PARAM 规则 AppName-AppId-AppKey-AppType

+
+
+

客户端系统 Soap 模块接口

+ +

客户端 Soap 接口，PARAM 规则 AppName-AppId-AppKey-AppType

+
+
+
-
-

微信消息与事件接收 URL

- -

通过该 URL 接收微信消息和事件推送，该参数按规则填写，实际接收消息时 $APPID$ 将被替换为微信 AppId

-
-
-

客户端系统 Yar 模块接口

- -

客户端系统 Yar 接口 URL，PARAM 由调用参数组成（AppName-AppId-AppKey-AppType）

-
-
-

客户端系统 Soap 模块接口

- -

客户端系统 Soap 接口 URL，PARAM 由调用参数组成（AppName-AppId-AppKey-AppType）

-
-
+
+
{/block} {block name='style'}