From 21071361fe851f6463500c8a739d36272e4ee797 Mon Sep 17 00:00:00 2001 From: Anyon Date: Mon, 9 Dec 2019 17:36:15 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BE=AE=E4=BF=A1=E6=8E=88?= =?UTF-8?q?=E6=9D=83=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/wechat/controller/Config.php | 111 ++++++++ app/wechat/controller/Fans.php | 78 +++++- app/wechat/controller/Keys.php | 210 ++++++++++++++ app/wechat/controller/Menu.php | 167 ++++++++++++ app/wechat/controller/News.php | 176 ++++++++++++ app/wechat/controller/api/Js.php | 62 +++++ app/wechat/controller/api/Push.php | 333 +++++++++++++++++++++++ app/wechat/controller/api/Review.php | 105 +++++++ app/wechat/controller/api/Tools.php | 250 +++++++++++++++++ app/wechat/service/FansService.php | 63 +++++ app/wechat/service/MediaService.php | 89 ++++++ app/wechat/service/WechatService.php | 116 +++++++- app/wechat/view/config/options.html | 43 +++ app/wechat/view/config/options_api.html | 65 +++++ app/wechat/view/config/options_help.html | 42 +++ app/wechat/view/config/options_thr.html | 68 +++++ app/wechat/view/config/payment.html | 84 ++++++ app/wechat/view/fans/index.html | 98 +++++++ app/wechat/view/fans/index_search.html | 59 ++++ app/wechat/view/keys/form.html | 271 ++++++++++++++++++ app/wechat/view/keys/index.html | 180 ++++++++++++ app/wechat/view/keys/index_search.html | 54 ++++ app/wechat/view/menu/index.html | 203 ++++++++++++++ app/wechat/view/news/form-style.html | 84 ++++++ app/wechat/view/news/form.html | 215 +++++++++++++++ app/wechat/view/news/index.html | 158 +++++++++++ app/wechat/view/news/push.html | 112 ++++++++ app/wechat/view/news/select.html | 77 ++++++ composer.json | 6 +- 29 files changed, 3571 insertions(+), 8 deletions(-) create mode 100644 app/wechat/controller/Config.php create mode 100644 app/wechat/controller/Keys.php create mode 100644 app/wechat/controller/Menu.php create mode 100644 app/wechat/controller/News.php create mode 100644 app/wechat/controller/api/Js.php create mode 100644 app/wechat/controller/api/Push.php create mode 100644 app/wechat/controller/api/Review.php create mode 100644 app/wechat/controller/api/Tools.php create mode 100644 app/wechat/service/FansService.php create mode 100644 app/wechat/service/MediaService.php create mode 100644 app/wechat/view/config/options.html create mode 100644 app/wechat/view/config/options_api.html create mode 100644 app/wechat/view/config/options_help.html create mode 100644 app/wechat/view/config/options_thr.html create mode 100644 app/wechat/view/config/payment.html create mode 100644 app/wechat/view/fans/index.html create mode 100644 app/wechat/view/fans/index_search.html create mode 100644 app/wechat/view/keys/form.html create mode 100644 app/wechat/view/keys/index.html create mode 100644 app/wechat/view/keys/index_search.html create mode 100644 app/wechat/view/menu/index.html create mode 100644 app/wechat/view/news/form-style.html create mode 100644 app/wechat/view/news/form.html create mode 100644 app/wechat/view/news/index.html create mode 100644 app/wechat/view/news/push.html create mode 100644 app/wechat/view/news/select.html diff --git a/app/wechat/controller/Config.php b/app/wechat/controller/Config.php new file mode 100644 index 000000000..4899e5d6b --- /dev/null +++ b/app/wechat/controller/Config.php @@ -0,0 +1,111 @@ +_applyFormToken(); + $this->thrNotify = url('@wechat/api.push', [], false, true); + if ($this->request->isGet()) { + $this->title = '微信授权绑定'; + $this->geoip = $this->app->cache->get('mygeoip', ''); + if (empty($this->geoip)) { + $this->geoip = gethostbyname($this->request->host()); + $this->app->cache->set('mygeoip', $this->geoip, 360); + } + try { + if (input('?appid') && input('?appkey')) { + sysconf('wechat.type', 'thr'); + sysconf('wechat.appid', input('appid')); + sysconf('wechat.appkey', input('appkey')); + WechatService::ThinkAdminConfig(input('appid'))->setApiNotifyUri($this->thrNotify); + } + $source = enbase64url(url('@admin', [], false, true) . '#' . $this->request->url()); + $this->authurl = "http://open.cuci.cc/service/api.push/auth?source={$source}"; + $this->wechat = WechatService::ThinkAdminConfig(WechatService::instance()->getAppid())->getConfig(); + } catch (\Exception $e) { + $this->wechat = []; + } + $this->fetch(); + } else { + foreach ($this->request->post() as $k => $v) sysconf($k, $v); + if ($this->request->post('wechat.type') === 'thr') { + WechatService::ThinkAdminConfig(input('appid'))->setApiNotifyUri($this->thrNotify); + } + sysoplog('微信管理', '修改微信授权配置成功'); + $uri = url('wechat/config/options'); + $this->success('微信参数修改成功！', url('@admin') . "#{$uri}"); + } + } + + /** + * 微信支付配置 + * @auth true + * @menu true + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function payment() + { + $this->_applyFormToken(); + if ($this->request->isGet()) { + $this->title = '微信支付配置'; + $file = Storage::instance('local'); + $this->wechat_mch_ssl_cer = sysconf('wechat_mch_ssl_cer'); + $this->wechat_mch_ssl_key = sysconf('wechat_mch_ssl_key'); + $this->wechat_mch_ssl_p12 = sysconf('wechat_mch_ssl_p12'); + if (!$file->has($this->wechat_mch_ssl_cer, true)) $this->wechat_mch_ssl_cer = ''; + if (!$file->has($this->wechat_mch_ssl_key, true)) $this->wechat_mch_ssl_key = ''; + if (!$file->has($this->wechat_mch_ssl_p12, true)) $this->wechat_mch_ssl_p12 = ''; + $this->fetch(); + } else { + if ($this->request->post('wechat_mch_ssl_type') === 'p12') { + if (!($sslp12 = $this->request->post('wechat_mch_ssl_p12'))) { + $mchid = $this->request->post('wechat_mch_id'); + $content = Storage::instance('local')->get($sslp12, true); + if (!openssl_pkcs12_read($content, $certs, $mchid)) { + $this->error('商户MCH_ID与支付P12证书不匹配！'); + } + } + } + foreach ($this->request->post() as $k => $v) sysconf($k, $v); + sysoplog('微信管理', '修改微信支付配置成功'); + $this->success('微信支付配置成功！'); + } + } + +} diff --git a/app/wechat/controller/Fans.php b/app/wechat/controller/Fans.php index dd4b244b6..c8c41f9fb 100644 --- a/app/wechat/controller/Fans.php +++ b/app/wechat/controller/Fans.php @@ -15,7 +15,9 @@ namespace app\wechat\controller; +use app\wechat\service\WechatService; use think\admin\Controller; +use think\exception\HttpResponseException; /** * 微信粉丝管理 @@ -28,12 +30,13 @@ class Fans extends Controller * 绑定数据表 * @var string */ - protected $table = 'wechatFans'; + protected $table = 'WechatFans'; /** * 微信粉丝管理 * @auth true * @menu true + * @throws \think\Exception * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException @@ -41,7 +44,76 @@ class Fans extends Controller public function index() { $this->title = '微信粉丝管理'; - $this->_query($this->table)->order('id desc')->page(); + $this->where = ['appid' => WechatService::instance()->getAppid()]; + $query = $this->_query($this->table)->like('nickname')->equal('subscribe,is_black'); + $query->dateBetween('subscribe_at')->where($this->where)->order('subscribe_time desc')->page(); } -} \ No newline at end of file + /** + * 列表数据处理 + * @param array $data + */ + protected function _index_page_filter(array &$data) + { + $tags = $this->app->db->name('WechatFansTags')->column('id,name'); + foreach ($data as &$user) { + $user['tags'] = []; + foreach (explode(',', $user['tagid_list']) as $tagid) { + if (isset($tags[$tagid])) $user['tags'][] = $tags[$tagid]; + } + } + } + + /** + * 批量拉黑粉丝 + * @auth true + */ + public function setBlack() + { + try { + $this->_applyFormToken(); + foreach (array_chunk(explode(',', $this->request->post('openid')), 20) as $openids) { + WechatService::WeChatUser()->batchBlackList($openids); + $this->app->db->name('WechatFans')->whereIn('openid', $openids)->update(['is_black' => '1']); + } + $this->success('拉黑粉丝信息成功！'); + } catch (HttpResponseException $exception) { + throw $exception; + } catch (\Exception $e) { + $this->error("拉黑粉丝信息失败，请稍候再试！{$e->getMessage()}"); + } + } + + /** + * 取消拉黑粉丝 + * @auth true + */ + public function delBlack() + { + try { + $this->_applyFormToken(); + foreach (array_chunk(explode(',', $this->request->post('openid')), 20) as $openids) { + WechatService::WeChatUser()->batchUnblackList($openids); + $this->app->db->name('WechatFans')->whereIn('openid', $openids)->update(['is_black' => '0']); + } + $this->success('取消拉黑粉丝信息成功！'); + } catch (HttpResponseException $exception) { + throw $exception; + } catch (\Exception $e) { + $this->error("取消拉黑粉丝信息失败，请稍候再试！{$e->getMessage()}"); + } + } + + + /** + * 删除粉丝信息 + * @auth true + * @throws \think\db\exception\DbException + */ + public function remove() + { + $this->_applyFormToken(); + $this->_delete($this->table); + } + +} diff --git a/app/wechat/controller/Keys.php b/app/wechat/controller/Keys.php new file mode 100644 index 000000000..44d4002aa --- /dev/null +++ b/app/wechat/controller/Keys.php @@ -0,0 +1,210 @@ + '文字', 'news' => '图文', 'image' => '图片', 'music' => '音乐', + 'video' => '视频', 'voice' => '语音', 'customservice' => '转客服', + ]; + + /** + * 回复规则管理 + * @auth true + * @menu true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function index() + { + // 关键字二维码生成 + if ($this->request->get('action') === 'qrc') { + try { + $wechat = WechatService::WeChatQrcode(); + $result = $wechat->create($this->request->get('keys', '')); + $this->success('生成二维码成功！', "javascript:$.previewImage('{$wechat->url($result['ticket'])}')"); + } catch (HttpResponseException $exception) { + throw $exception; + } catch (\Exception $e) { + $this->error("生成二维码失败，请稍候再试！
{$e->getMessage()}"); + } + } + // 关键字列表显示 + $this->title = '回复规则管理'; + $query = $this->_query($this->table)->like('keys,type')->equal('status')->dateBetween('create_at'); + $query->whereNotIn('keys', ['subscribe', 'default'])->order('sort desc,id desc')->page(); + } + + /** + * 列表数据处理 + * @param array $data + */ + protected function _index_page_filter(&$data) + { + foreach ($data as &$vo) { + $vo['qrc'] = url('@wechat/keys/index') . "?action=qrc&keys={$vo['keys']}"; + $vo['type'] = isset($this->types[$vo['type']]) ? $this->types[$vo['type']] : $vo['type']; + } + } + + /** + * 添加关键字 + * @auth true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function add() + { + $this->_applyFormToken(); + $this->title = '添加关键字规则'; + $this->_form($this->table, 'form'); + } + + /** + * 编辑关键字 + * @auth true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function edit() + { + $this->_applyFormToken(); + $this->title = '编辑关键字规则'; + $this->_form($this->table, 'form'); + } + + /** + * 删除关键字 + * @auth true + * @throws \think\db\exception\DbException + */ + public function remove() + { + $this->_applyFormToken(); + $this->_delete($this->table); + } + + /** + * 禁用关键字 + * @auth true + * @throws \think\db\exception\DbException + */ + public function forbid() + { + $this->_applyFormToken(); + $this->_save($this->table, ['status' => '0']); + } + + /** + * 启用关键字 + * @auth true + * @throws \think\db\exception\DbException + */ + public function resume() + { + $this->_applyFormToken(); + $this->_save($this->table, ['status' => '1']); + } + + /** + * 配置关注回复 + * @auth true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function subscribe() + { + $this->_applyFormToken(); + $this->title = '编辑关注回复规则'; + $this->_form($this->table, 'form', 'keys', [], ['keys' => 'subscribe']); + } + + /** + * 配置默认回复 + * @auth true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function defaults() + { + $this->_applyFormToken(); + $this->title = '编辑默认回复规则'; + $this->_form($this->table, 'form', 'keys', [], ['keys' => 'default']); + } + + /** + * 添加数据处理 + * @param array $data + */ + protected function _form_filter(array &$data) + { + if ($this->request->isPost() && isset($data['keys'])) { + $db = $this->app->db->name($this->table)->where('keys', $data['keys']); + empty($data['id']) || $db->where('id', 'neq', $data['id']); + if ($db->count() > 0) { + $this->error('关键字已经存在，请使用其它关键字！'); + } + } + if ($this->request->isGet()) { + $this->msgTypes = $this->types; + $root = rtrim(dirname(request()->basefile(true)), '\\/'); + $this->defaultImage = "{$root}/static/theme/img/image.png"; + } + } + + /** + * 表单结果处理 + * @param boolean $result + */ + protected function _form_result($result) + { + if ($result !== false) { + list($url, $keys) = ['', $this->request->post('keys')]; + if (!in_array($keys, ['subscribe', 'default'])) { + $url = url('@admin') . '#' . url('wechat/keys/index') . '?spm=' . $this->request->get('spm'); + } + $this->success('恭喜, 关键字保存成功!', $url); + } else { + $this->error('关键字保存失败, 请稍候再试!'); + } + } + +} diff --git a/app/wechat/controller/Menu.php b/app/wechat/controller/Menu.php new file mode 100644 index 000000000..19b36f109 --- /dev/null +++ b/app/wechat/controller/Menu.php @@ -0,0 +1,167 @@ + '匹配规则', + 'view' => '跳转网页', + 'miniprogram' => '打开小程序', + // 'customservice' => '转多客服', + 'scancode_push' => '扫码推事件', + 'scancode_waitmsg' => '扫码推事件且弹出“消息接收中”提示框', + 'pic_sysphoto' => '弹出系统拍照发图', + 'pic_photo_or_album' => '弹出拍照或者相册发图', + 'pic_weixin' => '弹出微信相册发图器', + 'location_select' => '弹出地理位置选择器', + ]; + + /** + * 微信菜单管理 + * @auth true + * @menu true + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function index() + { + if ($this->request->get('output') === 'json') { + $where = [['keys', 'notin', ['subscribe', 'default']], ['status', 'eq', '1']]; + $keys = $this->app->db->name('WechatKeys')->where($where)->order('sort desc,id desc')->select(); + $this->success('获取数据成功!', ['menudata' => sysdata('menudata'), 'keysdata' => $keys]); + } else { + $this->title = '微信菜单定制'; + $this->menuTypes = $this->menuType; + $this->fetch(); + } + } + + /** + * 编辑微信菜单 + * @auth true + */ + public function edit() + { + if ($this->request->isPost()) { + $data = $this->request->post('data'); + if (empty($data)) { // 删除菜单 + try { + WechatService::WeChatMenu()->delete(); + sysoplog('微信管理', '删除微信菜单成功'); + $this->success('删除微信菜单成功！', ''); + } catch (HttpResponseException $exception) { + throw $exception; + } catch (\Exception $e) { + sysoplog('微信管理', "删除微信菜单失败:{$e->getMessage()}"); + $this->error('删除微信菜单失败，请稍候再试！' . $e->getMessage()); + } + } else { + try { + sysdata('menudata', $this->_buildMenuData($menudata = json_decode($data, true))); + WechatService::WeChatMenu()->create(['button' => sysdata('menudata')]); + sysoplog('微信管理', '发布微信菜单成功'); + $this->success('保存发布菜单成功！', ''); + } catch (HttpResponseException $exception) { + throw $exception; + } catch (\Exception $e) { + sysoplog('微信管理', "发布微信菜单失败:{$e->getMessage()}"); + $this->error("微信菜单发布失败，请稍候再试！
{$e->getMessage()}"); + } + } + } + } + + /** + * 菜单数据处理 + * @param array $list + * @return array + */ + private function _buildMenuData(array $list) + { + foreach ($list as &$vo) { + unset($vo['active'], $vo['show']); + if (empty($vo['sub_button'])) { + $vo = $this->_buildMenuItemData($vo); + } else { + $item = ['name' => $vo['name'], 'sub_button' => []]; + foreach ($vo['sub_button'] as &$sub) { + unset($sub['active'], $sub['show']); + array_push($item['sub_button'], $this->_buildMenuItemData($sub)); + } + $vo = $item; + } + } + return $list; + } + + /** + * 单个微信菜单数据处理 + * @param array $item + * @return array + */ + private function _buildMenuItemData(array $item) + { + switch (strtolower($item['type'])) { + case 'pic_weixin': + case 'pic_sysphoto': + case 'scancode_push': + case 'location_select': + case 'scancode_waitmsg': + case 'pic_photo_or_album': + return ['name' => $item['name'], 'type' => $item['type'], 'key' => isset($item['key']) ? $item['key'] : $item['type']]; + case 'click': + if (empty($item['key'])) $this->error('匹配规则存在空的选项'); + return ['name' => $item['name'], 'type' => $item['type'], 'key' => $item['key']]; + case 'view': + return ['name' => $item['name'], 'type' => $item['type'], 'url' => $item['url']]; + case 'miniprogram': + return ['name' => $item['name'], 'type' => $item['type'], 'url' => $item['url'], 'appid' => $item['appid'], 'pagepath' => $item['pagepath']]; + } + } + + /** + * 取消微信菜单 + * @auth true + */ + public function cancel() + { + try { + WechatService::WeChatMenu()->delete(); + $this->success('菜单取消成功，重新关注可立即生效！', ''); + } catch (HttpResponseException $exception) { + sysoplog('微信管理', '取消微信菜单成功'); + throw $exception; + } catch (\Exception $e) { + $this->error("菜单取消失败，请稍候再试！
{$e->getMessage()}"); + } + } + +} diff --git a/app/wechat/controller/News.php b/app/wechat/controller/News.php new file mode 100644 index 000000000..430416030 --- /dev/null +++ b/app/wechat/controller/News.php @@ -0,0 +1,176 @@ +title = '微信图文列表'; + $this->_query($this->table)->where(['is_deleted' => '0'])->order('id desc')->page(); + } + + /** + * 图文列表数据处理 + * @param array $data + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\ModelNotFoundException + * @throws \think\exception\DbException + */ + protected function _index_page_filter(&$data) + { + foreach ($data as &$vo) $vo = MediaService::news($vo['id']); + } + + /** + * 图文选择器 + * @return string + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + * @auth true + */ + public function select() + { + $this->index(); + } + + /** + * 图文列表数据处理 + * @param array $data + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\ModelNotFoundException + * @throws \think\exception\DbException + */ + protected function _select_page_filter(&$data) + { + foreach ($data as &$vo) $vo = MediaService::news($vo['id']); + } + + /** + * 添加微信图文 + * @auth true + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function add() + { + if ($this->request->isGet()) { + $this->title = '新建图文'; + $this->fetch('form'); + } else { + $data = $this->request->post(); + if (($ids = $this->_apply_news_article($data['data'])) && !empty($ids)) { + if (data_save($this->table, ['article_id' => $ids, 'create_by' => session('user.id')], 'id') !== false) { + $url = url('@admin') . '#' . url('@wechat/news/index') . '?spm=' . $this->request->get('spm'); + $this->success('图文添加成功！', $url); + } + } + $this->error('图文添加失败，请稍候再试！'); + } + } + + /** + * 编辑微信图文 + * @auth true + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function edit() + { + if (($this->id = $this->request->get('id')) < 1) { + $this->error('参数错误，请稍候再试！'); + } + if ($this->request->isGet()) { + if ($this->request->get('output') === 'json') { + $this->success('获取数据成功！', MediaService::news($this->id)); + } else { + $this->fetch('form', ['title' => '编辑图文']); + } + } else { + $post = $this->request->post(); + if (isset($post['data']) && ($ids = $this->_apply_news_article($post['data']))) { + if (data_save('wechat_news', ['id' => $this->id, 'article_id' => $ids], 'id')) { + $this->success('图文更新成功！', url('@admin') . '#' . url('@wechat/news/index')); + } + } + $this->error('图文更新失败，请稍候再试！'); + } + } + + /** + * 图文更新操作 + * @param array $data + * @param array $ids + * @return string + */ + private function _apply_news_article($data, $ids = []) + { + foreach ($data as &$vo) { + if (empty($vo['digest'])) { + $vo['digest'] = mb_substr(strip_tags(str_replace(["\s", '　'], '', $vo['content'])), 0, 120); + } + $vo['create_at'] = date('Y-m-d H:i:s'); + if (empty($vo['id'])) { + $result = $id = Db::name('WechatNewsArticle')->insertGetId($vo); + } else { + $id = intval($vo['id']); + $result = Db::name('WechatNewsArticle')->where('id', $id)->update($vo); + } + if ($result !== false) { + array_push($ids, $id); + } + } + return join(',', $ids); + } + + /** + * 删除微信图文 + * @throws \think\db\exception\DbException + */ + public function remove() + { + $this->_delete($this->table); + } + +} diff --git a/app/wechat/controller/api/Js.php b/app/wechat/controller/api/Js.php new file mode 100644 index 000000000..20fdb5bc7 --- /dev/null +++ b/app/wechat/controller/api/Js.php @@ -0,0 +1,62 @@ +request->server('http_referer', $this->request->url(true)); + $wechat = WechatService::instance()->getWebOauthInfo($url, $this->request->get('mode', 1), false); + $openid = isset($wechat['openid']) ? $wechat['openid'] : ''; + $unionid = empty($wechat['fansinfo']['unionid']) ? '' : $wechat['fansinfo']['unionid']; + $configJson = json_encode(WechatService::instance()->getWebJssdkSign($url), JSON_UNESCAPED_UNICODE); + $fansinfoJson = json_encode(isset($wechat['fansinfo']) ? $wechat['fansinfo'] : [], JSON_UNESCAPED_UNICODE); + $html = <<contentType('application/x-javascript'); + } + +} diff --git a/app/wechat/controller/api/Push.php b/app/wechat/controller/api/Push.php new file mode 100644 index 000000000..197e71848 --- /dev/null +++ b/app/wechat/controller/api/Push.php @@ -0,0 +1,333 @@ +request->ip(); + } + + /** + * 消息推送处理接口 + * @return string + */ + public function index() + { + try { + if ($this->request->has('receive', 'post') && WechatService::instance()->getType() === 'thr') { + $this->forceJson = true; // 强制返回JSON到Service转发 + $this->forceCustom = false; // 强制使用客服消息模式推送 + $this->appid = $this->request->post('appid', '', null); + $this->openid = $this->request->post('openid', '', null); + $this->encrypt = boolval($this->request->post('encrypt', 0)); + $this->receive = $this->toLower(unserialize($this->request->post('receive', '', null))); + if (empty($this->appid) || empty($this->openid) || empty($this->receive)) { + throw new \think\Exception('微信API实例缺失必要参数[appid,openid,receive]'); + } + } else { + $this->forceJson = false; // 暂停返回JSON消息对象 + $this->forceCustom = false; // 暂停使用客户消息模式 + $this->wechat = WechatService::WeChatReceive(); + $this->appid = WechatService::instance()->getAppid(); + $this->openid = $this->wechat->getOpenid(); + $this->encrypt = $this->wechat->isEncrypt(); + $this->receive = $this->toLower($this->wechat->getReceive()); + } + $this->fromOpenid = $this->receive['tousername']; + // text, event, image, location + if (method_exists($this, ($method = $this->receive['msgtype']))) { + if (is_string(($result = $this->$method()))) return $result; + } + } catch (\Exception $e) { + sysoplog('微信接口', "{$e->getFile()}:{$e->getLine()} [{$e->getCode()}] {$e->getMessage()}"); + } + return 'success'; + } + + /** + * 数组KEY全部转小写 + * @param array $data + * @return array + */ + private function toLower(array $data) + { + $data = array_change_key_case($data, CASE_LOWER); + foreach ($data as $key => $vo) if (is_array($vo)) { + $data[$key] = $this->toLower($vo); + } + return $data; + } + + /** + * 文件消息处理 + * @return boolean|string + * @throws \WeChat\Exceptions\InvalidDecryptException + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\ModelNotFoundException + */ + protected function text() + { + return $this->keys("wechat_keys#keys#{$this->receive['content']}", false, $this->forceCustom); + } + + /** + * 事件消息处理 + * @return boolean|string + * @throws \WeChat\Exceptions\InvalidDecryptException + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + protected function event() + { + switch (strtolower($this->receive['event'])) { + case 'subscribe': + $this->updateFansinfo(true); + if (isset($this->receive['eventkey']) && is_string($this->receive['eventkey'])) { + if (($key = preg_replace('/^qrscene_/i', '', $this->receive['eventkey']))) { + return $this->keys("wechat_keys#keys#{$key}", false, true); + } + } + return $this->keys('wechat_keys#keys#subscribe', true, $this->forceCustom); + case 'unsubscribe': + return $this->updateFansinfo(false); + case 'click': + return $this->keys("wechat_keys#keys#{$this->receive['eventkey']}", false, $this->forceCustom); + case 'scancode_push': + case 'scancode_waitmsg': + if (empty($this->receive['scancodeinfo'])) return false; + if (empty($this->receive['scancodeinfo']['scanresult'])) return false; + return $this->keys("wechat_keys#keys#{$this->receive['scancodeinfo']['scanresult']}", false, $this->forceCustom); + case 'scan': + if (empty($this->receive['eventkey'])) return false; + return $this->keys("wechat_keys#keys#{$this->receive['eventkey']}", false, $this->forceCustom); + default: + return false; + } + } + + /** + * 关键字处理 + * @param string $rule 关键字规则 + * @param boolean $isLast 重复回复消息处理 + * @param boolean $isCustom 是否使用客服消息发送 + * @return boolean|string + * @throws \WeChat\Exceptions\InvalidDecryptException + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\ModelNotFoundException + * @throws \think\exception\DbException + * @throws \think\exception\PDOException + */ + private function keys($rule, $isLast = false, $isCustom = false) + { + list($table, $field, $value) = explode('#', $rule . '##'); + $data = Db::name($table)->where([$field => $value])->find(); + if (empty($data['type']) || (array_key_exists('status', $data) && empty($data['status']))) { + return $isLast ? false : $this->keys('wechat_keys#keys#default', true, $isCustom); + } + switch (strtolower($data['type'])) { + case 'keys': + $content = empty($data['content']) ? $data['name'] : $data['content']; + return $this->keys("wechat_keys#keys#{$content}", $isLast, $isCustom); + case 'text': + return $this->sendMessage('text', ['content' => $data['content']], $isCustom); + case 'customservice': + return $this->sendMessage('customservice', ['content' => $data['content']], false); + case 'voice': + if (empty($data['voice_url']) || !($mediaId = MediaService::upload($data['voice_url'], 'voice'))) return false; + return $this->sendMessage('voice', ['media_id' => $mediaId], $isCustom); + case 'image': + if (empty($data['image_url']) || !($mediaId = MediaService::upload($data['image_url'], 'image'))) return false; + return $this->sendMessage('image', ['media_id' => $mediaId], $isCustom); + case 'news': + list($news, $articles) = [MediaService::news($data['news_id']), []]; + if (empty($news['articles'])) return false; + foreach ($news['articles'] as $vo) array_push($articles, [ + 'url' => url("@wechat/api.review/view", '', false, true) . "?id={$vo['id']}", + 'title' => $vo['title'], 'picurl' => $vo['local_url'], 'description' => $vo['digest'], + ]); + return $this->sendMessage('news', ['articles' => $articles], $isCustom); + case 'music': + if (empty($data['music_url']) || empty($data['music_title']) || empty($data['music_desc'])) return false; + return $this->sendMessage('music', [ + 'thumb_media_id' => empty($data['music_image']) ? '' : MediaService::upload($data['music_image'], 'image'), + 'description' => $data['music_desc'], 'title' => $data['music_title'], + 'hqmusicurl' => $data['music_url'], 'musicurl' => $data['music_url'], + ], $isCustom); + case 'video': + if (empty($data['video_url']) || empty($data['video_desc']) || empty($data['video_title'])) return false; + $videoData = ['title' => $data['video_title'], 'introduction' => $data['video_desc']]; + if (!($mediaId = MediaService::upload($data['video_url'], 'video', $videoData))) return false; + return $this->sendMessage('video', ['media_id' => $mediaId, 'title' => $data['video_title'], 'description' => $data['video_desc']], $isCustom); + default: + return false; + } + } + + /** + * 发送消息到微信 + * @param string $type 消息类型（text|image|voice|video|music|news|mpnews|wxcard） + * @param array $data 消息内容数据对象 + * @param boolean $isCustom 是否使用客服消息发送 + * @return array|boolean + * @throws \WeChat\Exceptions\InvalidDecryptException + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\exception\PDOException + */ + private function sendMessage($type, $data, $isCustom = false) + { + if ($isCustom) { + WechatService::WeChatCustom()->send(['touser' => $this->openid, 'msgtype' => $type, "{$type}" => $data]); + } else switch (strtolower($type)) { + case 'text': // 发送文本消息 + $reply = ['CreateTime' => time(), 'MsgType' => 'text', 'ToUserName' => $this->openid, 'FromUserName' => $this->fromOpenid, 'Content' => $data['content']]; + return $this->forceJson ? json_encode($reply, JSON_UNESCAPED_UNICODE) : WechatService::WeChatReceive()->reply($reply, true, $this->encrypt); + case 'image': // 发送图片消息 + return $this->buildMessage($type, ['MediaId' => $data['media_id']]); + case 'voice': // 发送语言消息 + return $this->buildMessage($type, ['MediaId' => $data['media_id']]); + case 'video': // 发送视频消息 + return $this->buildMessage($type, ['Title' => $data['title'], 'MediaId' => $data['media_id'], 'Description' => $data['description']]); + case 'music': // 发送音乐消息 + return $this->buildMessage($type, ['Title' => $data['title'], 'Description' => $data['description'], 'MusicUrl' => $data['musicurl'], 'HQMusicUrl' => $data['musicurl'], 'ThumbMediaId' => $data['thumb_media_id']]); + case 'customservice': // 转交客服消息 + if ($data['content']) $this->sendMessage('text', $data, true); + return $this->buildMessage('transfer_customer_service'); + case 'news': // 发送图文消息 + $articles = []; + foreach ($data['articles'] as $article) array_push($articles, ['PicUrl' => $article['picurl'], 'Title' => $article['title'], 'Description' => $article['description'], 'Url' => $article['url']]); + $reply = ['CreateTime' => time(), 'MsgType' => 'news', 'ToUserName' => $this->openid, 'FromUserName' => $this->fromOpenid, 'Articles' => $articles, 'ArticleCount' => count($articles)]; + return $this->forceJson ? json_encode($reply, JSON_UNESCAPED_UNICODE) : WechatService::WeChatReceive()->reply($reply, true, $this->encrypt); + default: + return 'success'; + } + } + + /** + * 消息数据生成 + * @param string $type 消息类型 + * @param string|array $data 消息数据 + * @return string + * @throws \WeChat\Exceptions\InvalidDecryptException + */ + private function buildMessage($type, $data = []) + { + $reply = ['CreateTime' => time(), 'MsgType' => strtolower($type), 'ToUserName' => $this->openid, 'FromUserName' => $this->fromOpenid]; + if (!empty($data)) $reply[ucfirst(strtolower($type))] = $data; + return $this->forceJson ? json_encode($reply, JSON_UNESCAPED_UNICODE) : WechatService::WeChatReceive()->reply($reply, true, $this->encrypt); + } + + /** + * 同步粉丝状态 + * @param boolean $subscribe 关注状态 + * @return boolean + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + private function updateFansinfo($subscribe = true) + { + if ($subscribe) { + try { + $user = WechatService::WeChatUser()->getUserInfo($this->openid); + return FansService::instance()->set(array_merge($user, ['subscribe' => '1', 'appid' => $this->appid])); + } catch (\Exception $e) { + sysoplog('微信接口', __METHOD__ . " {$this->openid} get userinfo faild. {$e->getMessage()}"); + return false; + } + } else { + return FansService::instance()->set(['subscribe' => '0', 'openid' => $this->openid, 'appid' => $this->appid]); + } + } + +} diff --git a/app/wechat/controller/api/Review.php b/app/wechat/controller/api/Review.php new file mode 100644 index 000000000..0d844d8d9 --- /dev/null +++ b/app/wechat/controller/api/Review.php @@ -0,0 +1,105 @@ +id = empty($id) ? input('id') : $id; + $this->news = MediaService::news($this->id); + $this->fetch(); + } + + /** + * 文章展示 + * @param integer $id 文章ID + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function view($id = 0) + { + $where = ['id' => empty($id) ? input('id') : $id]; + $this->app->db->name('WechatNewsArticle')->where($where)->update(['read_num' => $this->app->db->raw('read_num+1')]); + $this->info = $this->app->db->name('WechatNewsArticle')->where($where)->find(); + $this->fetch(); + } + + /** + * 文本展示 + */ + public function text() + { + $this->content = strip_tags(input('content', ''), ''); + $this->fetch(); + } + + /** + * 图片展示 + */ + public function image() + { + $this->content = strip_tags(input('content', ''), ''); + $this->fetch(); + } + + /** + * 视频展示 + */ + public function video() + { + $this->url = strip_tags(input('url', ''), ''); + $this->title = strip_tags(input('title', ''), ''); + $this->fetch(); + } + + /** + * 语音展示 + */ + public function voice() + { + $this->url = strip_tags(input('url', ''), ''); + $this->fetch(); + } + + /** + * 音乐展示 + */ + public function music() + { + $this->url = strip_tags(input('url', ''), ''); + $this->desc = strip_tags(input('desc', ''), ''); + $this->title = strip_tags(input('title', ''), ''); + $this->fetch(); + } + +} diff --git a/app/wechat/controller/api/Tools.php b/app/wechat/controller/api/Tools.php new file mode 100644 index 000000000..4792e322b --- /dev/null +++ b/app/wechat/controller/api/Tools.php @@ -0,0 +1,250 @@ +url = $this->request->url(true); + $this->fans = WechatService::getWebOauthInfo($this->url, 1); + $this->fetch(); + } + + /** + * 显示网页授权二维码 + * @return \think\Response + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + */ + public function oauth_qrc() + { + $url = url('@wechat/api.tools/oauth', '', true, true); + return $this->showQrc($url); + } + + /** + * JSSDK测试 + * @return string + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\exception\PDOException + */ + public function jssdk() + { + $this->options = WechatService::getWebJssdkSign(); + $this->fetch(); + } + + /** + * 显示网页授权二维码 + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + */ + public function jssdk_qrc() + { + $this->url = url('@wechat/api.tools/jssdk', '', true, true); + return $this->showQrc($this->url); + } + + /** + * 微信扫码支付模式一二维码显示 + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + */ + public function scanOneQrc() + { + $pay = WechatService::WePayOrder(); + $result = $pay->qrcParams('8888888'); + $this->showQrc($result); + } + + /** + * 微信扫码支付模式一通知处理 + * -- 注意，需要在微信商户配置支付通知地址 + * @return string + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + */ + public function scanOneNotify() + { + $pay = WechatService::WePayOrder(); + $notify = $pay->getNotify(); + p('======= 来自扫码支付1的数据 ======'); + p($notify); + // 产品ID 你的业务代码，并实现下面的统一下单操作 + $product_id = $notify['product_id']; + // 微信统一下单处理 + $options = [ + 'body' => '测试商品，产品ID：' . $product_id, + 'out_trade_no' => time(), + 'total_fee' => '1', + 'trade_type' => 'NATIVE', + 'notify_url' => url('@wechat/api.tools/notify', '', true, true), + 'spbill_create_ip' => request()->ip(), + ]; + $order = $pay->create($options); + p('======= 来自扫码支付1统一下单结果 ======'); + p($order); + // 回复XML文本 + $result = [ + 'return_code' => 'SUCCESS', + 'return_msg' => '处理成功', + 'appid' => $notify['appid'], + 'mch_id' => $notify['mch_id'], + 'nonce_str' => \WeChat\Contracts\Tools::createNoncestr(), + 'prepay_id' => $order['prepay_id'], + 'result_code' => 'SUCCESS', + ]; + $result['sign'] = $pay->getPaySign($result); + p('======= 来自扫码支付1返回的结果 ======'); + p($result); + return \WeChat\Contracts\Tools::arr2xml($result); + } + + /** + * 扫码支付模式二测试二维码 + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + */ + public function scanQrc() + { + $pay = WechatService::WePayOrder(); + $result = $pay->create([ + 'body' => '测试商品', + 'out_trade_no' => time(), + 'total_fee' => '1', + 'trade_type' => 'NATIVE', + 'notify_url' => url('@wechat/api.tools/notify', '', true, true), + 'spbill_create_ip' => request()->ip(), + ]); + $this->showQrc($result['code_url']); + } + + + /** + * 微信JSAPI支付二维码 + * @return \think\Response + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + */ + public function jsapiQrc() + { + $this->url = url('@wechat/api.tools/jsapi', '', true, true); + return $this->showQrc($this->url); + } + + /** + * 微信JSAPI支付测试 + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\exception\PDOException + * @link wx-demo-jsapi + */ + public function jsapi() + { + $pay = WechatService::WePayOrder(); + $openid = WechatService::getWebOauthInfo(request()->url(true), 0)['openid']; + $options = [ + 'body' => '测试商品', + 'out_trade_no' => time(), + 'total_fee' => '1', + 'openid' => $openid, + 'trade_type' => 'JSAPI', + 'notify_url' => url('@wechat/api.tools/notify', '', true, true), + 'spbill_create_ip' => request()->ip(), + ]; + // 生成预支付码 + $result = $pay->create($options); + // 创建JSAPI参数签名 + $options = $pay->jsapiParams($result['prepay_id']); + $optionJSON = json_encode($options, JSON_UNESCAPED_UNICODE); + // JSSDK 签名配置 + $configJSON = json_encode(WechatService::getWebJssdkSign(), JSON_UNESCAPED_UNICODE); + + echo '
';
+        echo "当前用户OPENID: {$openid}";
+        echo "\n--- 创建预支付码 ---\n";
+        var_export($result);
+        echo '
'; + + echo '
';
+        echo "\n\n--- JSAPI 及 H5 参数 ---\n";
+        var_export($options);
+        echo '
'; + echo ""; + echo " + + "; + } + + /** + * 支付通知接收处理 + * @return string + * @throws \WeChat\Exceptions\InvalidResponseException + */ + public function notify() + { + $wechat = WechatService::WePayOrder(); + p($wechat->getNotify()); + return 'SUCCESS'; + } + + /** + * 创建二维码响应对应 + * @param string $url 二维码内容 + * @throws \Endroid\QrCode\Exceptions\ImageFunctionFailedException + * @throws \Endroid\QrCode\Exceptions\ImageFunctionUnknownException + * @throws \Endroid\QrCode\Exceptions\ImageTypeInvalidException + */ + protected function showQrc($url) + { + $qrCode = new \Endroid\QrCode\QrCode(); + $qrCode->setText($url)->setSize(300)->setPadding(20)->setImageType('png'); + response($qrCode->get(), 200, ['Content-Type' => 'image/png'])->send(); + } + +} diff --git a/app/wechat/service/FansService.php b/app/wechat/service/FansService.php new file mode 100644 index 000000000..ee8915dcd --- /dev/null +++ b/app/wechat/service/FansService.php @@ -0,0 +1,63 @@ +app->db->name('WechatFans')->where(['openid' => $openid])->find(); + } + +} diff --git a/app/wechat/service/MediaService.php b/app/wechat/service/MediaService.php new file mode 100644 index 000000000..ffab5a176 --- /dev/null +++ b/app/wechat/service/MediaService.php @@ -0,0 +1,89 @@ +app->db->name('WechatNews')->where(['id' => $id])->where($where)->find(); + list($data['articles'], $articleIds) = [[], explode(',', $data['article_id'])]; + $articles = $this->app->db->name('WechatNewsArticle')->whereIn('id', $articleIds)->select(); + foreach ($articleIds as $article_id) foreach ($articles as $article) { + if (intval($article['id']) === intval($article_id)) array_push($data['articles'], $article); + unset($article['create_by'], $article['create_at']); + } + return $data; + } + + /** + * 上传图片永久素材，返回素材media_id + * @param string $url 文件URL地址 + * @param string $type 文件类型 + * @param array $videoInfo 视频信息 + * @return string|null + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function upload($url, $type = 'image', $videoInfo = []) + { + $where = ['md5' => md5($url), 'appid' => WechatService::instance()->getAppid()]; + if (($mediaId = $this->app->db->name('WechatMedia')->where($where)->value('media_id'))) return $mediaId; + $result = WechatService::WeChatMedia()->addMaterial(self::getServerPath($url), $type, $videoInfo); + data_save('WechatMedia', [ + 'local_url' => $url, 'md5' => $where['md5'], 'appid' => $where['appid'], 'type' => $type, + 'media_url' => isset($result['url']) ? $result['url'] : '', 'media_id' => $result['media_id'], + ], 'type', $where); + return $result['media_id']; + } + + /** + * 文件位置处理 + * @param string $local + * @return string + * @throws \WeChat\Exceptions\LocalCacheException + */ + private function getServerPath($local) + { + if (file_exists($local)) { + return new MyCurlFile($local); + } else { + return new MyCurlFile(Storage::down($local)['file']); + } + } +} diff --git a/app/wechat/service/WechatService.php b/app/wechat/service/WechatService.php index 299901df8..b941aa026 100644 --- a/app/wechat/service/WechatService.php +++ b/app/wechat/service/WechatService.php @@ -105,9 +105,12 @@ class WechatService extends Service throw new \think\Exception("class {$name} not defined."); } $classname = "\\{$type}\\{$class}"; + if ($type === 'ThinkAdmin') { + throw new \think\Exception("Interface mode cannot instance {$classname}"); + } return new $classname(self::instance()->getConfig()); } else { - list($appid, $appkey) = [sysconf('wechat.appid'), sysconf('wechat.appkey')]; + list($appid, $appkey) = [sysconf('wechat.thr_appid'), sysconf('wechat.thr_appkey')]; $data = ['class' => $name, 'appid' => $appid, 'time' => time(), 'nostr' => uniqid()]; $data['sign'] = md5("{$data['class']}#{$appid}#{$appkey}#{$data['time']}#{$data['nostr']}"); $token = enbase64url(json_encode($data, JSON_UNESCAPED_UNICODE)); @@ -130,6 +133,38 @@ class WechatService extends Service } } + /** + * 获取当前微信APPID + * @return bool|string + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function getAppid() + { + if ($this->getType() === 'api') { + return sysconf('wechat.appid'); + } else { + return sysconf('wechat.thr_appid'); + } + } + + /** + * 获取接口授权模式 + * @return string + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function getType() + { + $type = strtolower(sysconf('wechat.type')); + if (in_array($type, ['api', 'thr'])) return $type; + throw new \think\Exception('请在后台配置微信对接授权模式'); + } + /** * 获取公众号配置参数 * @return array @@ -142,9 +177,84 @@ class WechatService extends Service return [ 'token' => sysconf('wechat.token'), 'appid' => sysconf('wechat.appid'), - 'appsecret' => sysconf('service.appsecret'), - 'encodingaeskey' => sysconf('service.encodingaeskey'), + 'appsecret' => sysconf('wechat.appsecret'), + 'encodingaeskey' => sysconf('wechat.encodingaeskey'), 'cache_path' => $this->app->getRuntimePath() . 'wechat', ]; } + + /** + * 获取网页授权信息 + * @param string $url + * @param integer $isfull + * @param boolean $isRedirect + * @return array + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function getWebOauthInfo($url, $isfull = 0, $isRedirect = true) + { + $appid = $this->getAppid(); + list($openid, $fansinfo) = [$this->app->session->get("{$appid}_openid"), $this->app->session->get("{$appid}_fansinfo")]; + if ((empty($isfull) && !empty($openid)) || (!empty($isfull) && !empty($openid) && !empty($fansinfo))) { + empty($fansinfo) || FansService::instance()->set($fansinfo); + return ['openid' => $openid, 'fansinfo' => $fansinfo]; + } + if ($this->getType() === 'api') { + $wechat = self::WeChatOauth(); + if (input('state') !== $appid) { + $snsapi = empty($isfull) ? 'snsapi_base' : 'snsapi_userinfo'; + $param = (strpos($url, '?') !== false ? '&' : '?') . 'rcode=' . encode($url); + $OauthUrl = $wechat->getOauthRedirect($url . $param, $appid, $snsapi); + if ($isRedirect) redirect($OauthUrl, 301)->send(); + exit("window.location.href='{$OauthUrl}'"); + } + if (($token = $wechat->getOauthAccessToken()) && isset($token['openid'])) { + $this->app->session->set("{$appid}_openid", $openid = $token['openid']); + if (empty($isfull) && input('rcode')) { + redirect(enbase64url(input('rcode')), 301)->send(); + } + $this->app->session->set("{$appid}_fansinfo", $fansinfo = $wechat->getUserInfo($token['access_token'], $openid)); + empty($fansinfo) || FansService::instance()->set($fansinfo); + } + redirect(enbase64url(input('rcode')), 301)->send(); + } else { + $result = self::ThinkAdminConfig()->oauth(session_id(), $url, $isfull); + session("{$appid}_openid", $openid = $result['openid']); + session("{$appid}_fansinfo", $fansinfo = $result['fans']); + if ((empty($isfull) && !empty($openid)) || (!empty($isfull) && !empty($openid) && !empty($fansinfo))) { + empty($fansinfo) || FansService::instance()->set($fansinfo); + return ['openid' => $openid, 'fansinfo' => $fansinfo]; + } + if ($isRedirect && !empty($result['url'])) { + redirect($result['url'], 301)->send(); + } + exit("window.location.href='{$result['url']}'"); + } + } + + /** + * 获取微信网页JSSDK + * @param string $url JS签名地址 + * @return array + * @throws \WeChat\Exceptions\InvalidResponseException + * @throws \WeChat\Exceptions\LocalCacheException + * @throws \think\Exception + * @throws \think\db\exception\DataNotFoundException + * @throws \think\db\exception\DbException + * @throws \think\db\exception\ModelNotFoundException + */ + public function getWebJssdkSign($url = null) + { + $url = is_null($url) ? $this->app->request->url(true) : $url; + if ($this->getType() === 'api') { + return self::WeChatScript()->getJsSign($url); + } else { + return self::ThinkAdminConfig($this->getAppid())->jsSign($url); + } + } } \ No newline at end of file diff --git a/app/wechat/view/config/options.html b/app/wechat/view/config/options.html new file mode 100644 index 000000000..c1b763245 --- /dev/null +++ b/app/wechat/view/config/options.html @@ -0,0 +1,43 @@ +{extend name="../../admin/view/main"} + +{block name="content"} + +
+
+
+ +
+ {foreach ['api'=>'公众号平台API模式','thr'=>'第三方平台授权模式','test'=>'接口功能测试'] as $k=>$v} + + {/foreach} +

请选择微信对接方式，其中第三方平台授权需要微信开放平台支持，同时需要搭建 SERVICE 服务！

+
+
+
+
+ +
+
{include file='config/options_api'}
+
{include file='config/options_thr'}
+
{include file='config/options_help'}
+
+ +{/block} + +{block name='script'} + +{/block} diff --git a/app/wechat/view/config/options_api.html b/app/wechat/view/config/options_api.html new file mode 100644 index 000000000..098dd2b55 --- /dev/null +++ b/app/wechat/view/config/options_api.html @@ -0,0 +1,65 @@ +
+ +
+ +
+ 使用API直接对接时，需要在微信公众号平台配置授权IP及网页授权域名，另外再将获取到的参数填写到下面！ +
+ +
+ +
+ +

公众号平台与系统对接认证Token，请优先填写此参数并保存，然后再在微信公众号平台操作对接。

+
+
+ +
+ +
+ +

公众号APPID是所有接口必要参数，可以在公众号平台 [ 开发 > 基本配置 ] 页面获取。

+
+
+ +
+ +
+ +

公众号应用密钥是所有接口必要参数，可以在公众号平台 [ 开发 > 基本配置 ] 页面授权后获取。

+
+
+ +
+ +
+ +

若开启了消息加密时必需填写，消息加密密钥必需填写并保持与公众号平台一致。

+
+
+ +
+ +
+
+ + +
+
+ + +
+

公众号服务平台消息推送接口及服务器授权IP地址，需在公众号接口开发处配置。

+
+
+ +
+ + +
+ +
+ +
+ +
\ No newline at end of file diff --git a/app/wechat/view/config/options_help.html b/app/wechat/view/config/options_help.html new file mode 100644 index 000000000..f0e885367 --- /dev/null +++ b/app/wechat/view/config/options_help.html @@ -0,0 +1,42 @@ +
+ +
+
+

+ 第三方平台授权
+ JSSDK签名测试需要在开放平台配置当前的授权域名：{:request()->host()} +

+

+ 普通接口强制绑定
+ 网页授权及JSSDK签名都需要在公众号平台配置授权域名：{:request()->host()} +

+

+ 支付测试配置
+ JSAPI支付测试需要在微信商户平台配置支付目录：{:url('@wechat/api.tools/',[],'',true)}
+ 扫码支付①需要在微信商户平台配置支付通知地址：{:url('@wechat/api.tools/scanOneNotify',[],'',true)} +

+
+
+
+ +

网页授权

+
+
+ +

JSSDK签名

+
+
+ +

JSAPI支付

+
+
+ +

扫码支付①

+
+
+ +

扫码支付②

+
+
+
+
diff --git a/app/wechat/view/config/options_thr.html b/app/wechat/view/config/options_thr.html new file mode 100644 index 000000000..29e2277e2 --- /dev/null +++ b/app/wechat/view/config/options_thr.html @@ -0,0 +1,68 @@ +
+ +
+ +
+ 使用第三方授权时，需要单独搭建 SERVICE 服务并将域名配置到 WECHAT 文件，二者需要使用 Yar 或 Soap 通信！ +
+ + +
+ +
+
+
+

微信昵称：{$wechat.nick_name|default=''}

+

微信类型：{if $wechat.service_type eq 2}服务号{elseif $wechat.service_type eq 3}小程序{else}订阅号{/if} / {$wechat.verify_type_info == -1 ? '未认证' : '已认证'}

+

注册公司：{$wechat.principal_name}

+

授权绑定：{$wechat.create_at|format_datetime}

+
+
+
+ + +
+ +
+ +

点击连接将跳转到微信第三方平台进行公众号授权。

+
+
+ +
+ +
+ +

众号 appid 通过微信第三方授权自动获取. 若没有值请进行微信第三方授权。

+
+
+ +
+ +
+ +

公众号服务平台接口密钥, 通过微信第三方授权自动获取, 若没有值请进行微信第三方授权。

+
+
+ +
+ +
+
+ + +
+

公众号服务平台接口通知URL, 公众号消息接收与回复等。

+
+
+ +
+ + +
+ +
+ +
+ +
\ No newline at end of file diff --git a/app/wechat/view/config/payment.html b/app/wechat/view/config/payment.html new file mode 100644 index 000000000..2977235b3 --- /dev/null +++ b/app/wechat/view/config/payment.html @@ -0,0 +1,84 @@ +{extend name="../../admin/view/main"} + +{block name="content"} +
+ +
+
+ + +
+
+
+ 微信商户证书MCH_CERT +
+ {foreach ['p12'=>'上传 P12 证书','pem'=>'上传 PEM 证书'] as $k=>$v} + + {/foreach} +

请选择需要上传证书类型，P12 和 PEM 二选一，证书需要从微信商户平台获取

+
+ + +

微信商户支付 P12 证书，实现订单退款、打款、发红包等支出功能都使用证书

+
+
+ + + + +

微信商户支付 PEM 双向证书，实现订单退款、打款、发红包等支出功能都使用证书

+
+
+
+
+
+ +
+
+ +
+{/block} + +{block name="script"} + +{/block} diff --git a/app/wechat/view/fans/index.html b/app/wechat/view/fans/index.html new file mode 100644 index 000000000..54d85f79a --- /dev/null +++ b/app/wechat/view/fans/index.html @@ -0,0 +1,98 @@ +{extend name="../../admin/view/main"} + +{block name="button"} + +{if auth("setblack")} + +{/if} + +{if auth("delblack")} + +{/if} + +{if auth("sync")} + +{/if} + +{/block} + +{block name="content"} +
+ {include file='fans/index_search'} + + {notempty name='list'} + + + + + + + + + + + + {/notempty} + + {foreach $list as $key=>$vo} + + + + + + + + + + {/foreach} + +
微信昵称粉丝标签性别语言关注时间
+ + + +
+ 昵称：{$vo.nickname|default='--'} +
+ 区域：{$vo.country|default='--'} {$vo.province} {$vo.city} +
+ 		+
{foreach $vo.tags as $t}

{$t|default='--'}

{/foreach}
+ 		+ 性别：{switch name='vo.sex'}{case value='1'}男{/case}{case value='2'}女{/case}{default}未知{/switch} +
+ 语言：{$vo.language|raw} + 		+ 日期：{$vo.subscribe_at|format_datetime|str_replace=' ','
时间：',###|raw} + 		+ {eq name='vo.subscribe' value='0'} + 未关注 + {else} + 已关注 + {/eq} +
+ {eq name='vo.is_black' value='0'} + 未拉黑 + {else} + 已拉黑 + {/eq} + 		+ + {eq name='vo.is_black' value='0'} + + 拉 黑 + + {else} + + 拉 白 + + {/eq} + + {if auth("remove")} + 删 除 + {/if} +
+ + {empty name='list'}没有记录哦{else}{$pagehtml|raw|default=''}{/empty} + +
+{/block} diff --git a/app/wechat/view/fans/index_search.html b/app/wechat/view/fans/index_search.html new file mode 100644 index 000000000..23e5612fb --- /dev/null +++ b/app/wechat/view/fans/index_search.html @@ -0,0 +1,59 @@ +
+ 条件搜索 +
+ +
+ +
+ +
+
+ +
+ +
+ +
+
+ +
+ +
+ +
+
+ +
+ +
+ +
+
+ +
+ +
+
+ +
+ + diff --git a/app/wechat/view/keys/form.html b/app/wechat/view/keys/form.html new file mode 100644 index 000000000..309c76250 --- /dev/null +++ b/app/wechat/view/keys/form.html @@ -0,0 +1,271 @@ +{extend name='admin@main'} + +{block name="style"} + +{/block} + +{block name="content"} +
+
+
公众号
+
+ +
+
+
+
+
+
编辑关键字
+
+ +
+ +
+ +
+
+ + + +
+ +
+ {foreach ['1'=>'启用','0'=>'禁用'] as $k=>$v} + + {/foreach} +
+
+ +
+ +
+ {foreach $msgTypes as $k=>$v} + + {/foreach} +
+
+ +
+ +
+ +
+
+ +
+ +
+ + 选择图文 +
+
+ +
+ +
+ + +

文件最大2Mb，支持bmp/png/jpeg/jpg/gif格式

+ +
+
+ +
+ +
+
+ + +
+

文件最大2Mb，播放长度不超过60s，mp3/wma/wav/amr格式

+
+
+ +
+ +
+ +
+
+ +
+ +
+
+ + +
+
+
+ +
+ +
+ +
+
+ +
+ +
+ + +

文件最大64KB，只支持JPG格式

+
+
+ +
+ +
+ +
+
+ +
+ +
+
+ + +
+

文件最大10MB，只支持MP4格式

+
+
+ +
+ +
+ +
+
+ +
+
+ + + + + {if isset($vo['id'])}{/if} +
+
+
+
+
+
+{/block} + +{block name="script"} + +{/block} \ No newline at end of file diff --git a/app/wechat/view/keys/index.html b/app/wechat/view/keys/index.html new file mode 100644 index 000000000..f096dc2f6 --- /dev/null +++ b/app/wechat/view/keys/index.html @@ -0,0 +1,180 @@ +{extend name="../../admin/view/main"} + +{block name="button"} + +{if auth("add")} + +{/if} + +{if auth("remove")} + +{/if} + +{/block} + +{block name='content'} +
+ {include file='keys/index_search'} + + {notempty name='list'} + + + + + + + + + + + + + {/notempty} + + {foreach $list as $key=>$vo} + + + + + + + + + + + {/foreach} + +
+ + + + 关键字类型预览添加时间状态
+ + + + + {notempty name='vo.qrc'}{/notempty} + {$vo.keys} + {$vo.type} + {if $vo.type eq '音乐'} + 预览 + {elseif in_array($vo.type,['文字','转客服'])} + 预览 + {elseif $vo.type eq '图片'} + 预览 + {elseif $vo.type eq '图文'} + 预览 + {elseif $vo.type eq '视频'} + 预览 + {elseif $vo.type eq '语音'} + 预览 + {else} + {$vo.content} + {/if} + {$vo.create_at|format_datetime}{if $vo.status eq 0}已禁用{elseif $vo.status eq 1}使用中{/if} + + {if auth("edit")} + 编 辑 + {/if} + + {if $vo.status eq 1 and auth("forbid")} + 禁 用 + {elseif auth("resume")} + 启 用 + {/if} + + {if auth("remove")} + 删 除 + {/if} + +
+ {empty name='list'}没有记录哦{else}{$pagehtml|raw|default=''}{/empty} +
+{/block} + +{block name="script"} + +{/block} diff --git a/app/wechat/view/keys/index_search.html b/app/wechat/view/keys/index_search.html new file mode 100644 index 000000000..a716b9ba2 --- /dev/null +++ b/app/wechat/view/keys/index_search.html @@ -0,0 +1,54 @@ +
+ 条件搜索 +
+
+ +
+ +
+
+
+ +
+ +
+
+
+ +
+ +
+
+
+ +
+ +
+
+
+ +
+
+
+ + diff --git a/app/wechat/view/menu/index.html b/app/wechat/view/menu/index.html new file mode 100644 index 000000000..05f1a5109 --- /dev/null +++ b/app/wechat/view/menu/index.html @@ -0,0 +1,203 @@ +{extend name="../../admin/view/main"} + +{block name='content'} + + + + +{/block} \ No newline at end of file diff --git a/app/wechat/view/news/form-style.html b/app/wechat/view/news/form-style.html new file mode 100644 index 000000000..530d71d49 --- /dev/null +++ b/app/wechat/view/news/form-style.html @@ -0,0 +1,84 @@ + \ No newline at end of file diff --git a/app/wechat/view/news/form.html b/app/wechat/view/news/form.html new file mode 100644 index 000000000..4e3d5eb11 --- /dev/null +++ b/app/wechat/view/news/form.html @@ -0,0 +1,215 @@ +{extend name='admin@main'} + +{block name="style"}{include file='wechat@news/form-style'}{/block} + +{block name='content'} +
+
+
+
+
+ ဆ + + + +
+
+
+
+ ဆ + + + +
+
+ +
+
+
+
+
+ + +
+ 图文封面大图片 +
+
+ +
+
+ +
+ +
+
+

封面大图片建议尺寸 900像素 * 500像素

+
+
+ 图文文章内容 + +
+ + +
+ + +
+
+
+
+
+ +{/block} + + +{block name='script'} + +{/block} \ No newline at end of file diff --git a/app/wechat/view/news/index.html b/app/wechat/view/news/index.html new file mode 100644 index 000000000..da13f5a6b --- /dev/null +++ b/app/wechat/view/news/index.html @@ -0,0 +1,158 @@ +{extend name="../../admin/view/main"} + +{block name="button"} + +{/block} + +{block name='content'} +
+
+ {foreach $list as $vo} +
+
+ 预览 + 编辑 + 删除 +
+ {foreach $vo.articles as $k => $v} + {if $k < 1} +
+ {if $v.title}

{$v.title}

{/if} +
+
+ {else} +
+ {$v.title} +
+
+
+ {/if} + {/foreach} +
+ {/foreach} +
+ {empty name='list'}没有记录哦{else}{$pagehtml|raw|default=''}{/empty} +
+{/block} + +{block name='script'} + +{/block} + +{block name="style"} + +{/block} diff --git a/app/wechat/view/news/push.html b/app/wechat/view/news/push.html new file mode 100644 index 000000000..15d4bf15e --- /dev/null +++ b/app/wechat/view/news/push.html @@ -0,0 +1,112 @@ +
+ +
+
微信图文
+
+ {foreach $vo.articles as $key=>$value} +
+
+ {$value.title} +
+
+ {/foreach} +
+
+ +
+
指定粉丝标签推送 全选
+
+ + {foreach $fans_tags as $tag} + + {/foreach} + + {literal} + + {/literal} +
+
+
+
+ +
+ + +
+ +
+ + + + \ No newline at end of file diff --git a/app/wechat/view/news/select.html b/app/wechat/view/news/select.html new file mode 100644 index 000000000..90d64bcf5 --- /dev/null +++ b/app/wechat/view/news/select.html @@ -0,0 +1,77 @@ +{extend name="../../admin/view/index/index"} + +{block name='style'} + +{/block} + +{block name="body"} +
+ {foreach $list as $vo} +
+ {foreach $vo.articles as $k => $v} + {if $k < 1} +
+ {if $v.title}

{$v.title}

{/if} +
+
+ {else} +
+
{$v.title}
+
+
+
+ {/if} + {/foreach} +
+ {/foreach} + {if empty($list)}

没有记录哦！

{/if} +
+
+
{if isset($pagehtml)}{$pagehtml|raw}{/if}
+{/block} + +{block name="script"} + +{/block} \ No newline at end of file diff --git a/composer.json b/composer.json index 0950b95e1..6797041f7 100644 --- a/composer.json +++ b/composer.json @@ -23,12 +23,14 @@ "ext-json": "*", "ext-curl": "*", "ext-iconv": "*", + "ext-openssl": "*", + "ext-mbstring": "*", "topthink/framework": "^6.0", "topthink/think-view": "^1.0", "topthink/think-multi-app": "^1.0", "zoujingli/ip2region": "^1.0", - "zoujingli/think-library": "6.0.*-dev", - "zoujingli/weopen-developer": "dev-master" + "zoujingli/weopen-developer": "dev-master", + "zoujingli/think-library": "6.0.*-dev" }, "autoload": { "psr-4": {