## 小程序获取用户是否关注其关联的公众号：
**资料：**
https://developers.weixin.qq.com/community/develop/doc/000c02190182e0d79cb65e3ca5b400?page=1#comment-list
https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/union-id.html
小程序-登陆：https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/login/auth.code2Session.html
公号-事件消息：https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Receiving_event_pushes.html
公号-获取用户信息：https://developers.weixin.qq.com/doc/offiaccount/User_Management/Get_users_basic_information_UnionID.html
----
### 流程
1. 小程序这边登陆时可以获取 `openid` 和 `unionId`
2. 用户关注公众号
3. 公众号收到 关注事件消息，得到 用户与 公众号 对应的 `openid
`，以及 `unionid` （通过接口 [获取用户基本信息(UnionID机制)](https://developers.weixin.qq.com/doc/offiaccount/User_Management/Get_users_basic_information_UnionID.html#UinonId) 获取）
4. 更新关注表 `weixin_subscribe: (id, openid, unionid, subscribe)
`
5. 小程序这边 通过 `unionid` 查 关注表就知道用户是否关注公号了
>[tip] 注意：1 中的 `openid` 和 3 中的 `openid` 是不一样的
>
> 注意：1 中 `unionid` 只能从 解密数据中获取，`code2Session` 中如果用户没关注 时是取不到的
>
> 注意：1 中是 `unionId` 大写的 `I` 而不是 `unionid`（汗）
----
### 三方登陆源码
```php
<?php
namespace app\brand_xcx\logic;
use app\common\server\WeChatMiniProgram\Api as WeChatMiniProgramApi;
class User
{
// 直接更新SessionKey，而不是连服务端有效的登录态也否决掉重新登录一遍没必要
public function upSessionKey()
{
$code = !empty($_REQUEST['code']) ? trim($_REQUEST['code']) : '';
if (!$code) {
return ['error' => 1, 'message' => 'code invalid'];
}
$_res = WeChatMiniProgramApi::getSessionKeyByCode($code);
if (isset($_res['errmsg'])) {
return ['error' => $_res['errcode'], 'message' => $_res['errmsg']];
} else {
$apiInfo = [
'openid' => $_res->openid,
'session_key' => $_res->session_key,
];
if (isset($_res['unionid'])) {
$apiInfo['unionid'] = $_res['unionid'];
}
}
$this->setWeSession($apiInfo);
return ['status' => 1, 'msg' => 'ok'];
}
/**
* 第三方登录（允许重复登录）
* @param array $res 来自第三方的用户信息
* @return array 用户信息
*/
public function thirdLogin()
{
global $miniProgramConfig, $db;
$code = !empty($_REQUEST['code']) ? trim($_REQUEST['code']) : '';
if (!$code) {
return ['error' => 1, 'message' => 'code invalid'];
}
$_res = WeChatMiniProgramApi::getSessionKeyByCode($code);
trace($_res, 'debug');
if (isset($_res->errmsg)) {
return ['error' => $_res->errcode, 'message' => $_res->errmsg];
} else {
$apiInfo = [
'openid' => $_res->openid,
'session_key' => $_res->session_key,
];
// 这个是关注了公众号才会返回
// https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/union-id.html
// > 如果开发者帐号下存在同主体的公众号，并且该用户已经关注了该公众号。开发者可以直接通过 wx.login + code2Session 获取到该用户 UnionID，无须用户再次授权。
if (isset($_res->unionid)) {
$apiInfo['unionid'] = $_res->unionid;
}
}
unset($_res);
$openid = $apiInfo['openid'];
$sessionKey = $apiInfo['session_key'];
/** 进行合法性签名校验与数据解密 **/
// 签名检验（确保数据完整性，安全性，不被篡改）
// 开发者如果遇到因为session_key不正确而校验签名失败或解密失败，还可能是sessionKey失效
$rawData = stripcslashes($_REQUEST['rawData']);
$signature = $_REQUEST['signature'];
trace(['rawData' => $rawData, 'signature' => $signature, 'sessionKey' => $sessionKey], 'debug');
// 这里会有一定几率出现错误，原因是微信开发工具，发现如果wx.getUserInfo 会出现旧签名情况，感觉这是微信的BUG
// 有可能客户端的 sessionKey 没有过期，但是 这里每次都是用接口获取最新的 sessionKey，导致和客户端加密时的不一致
if (!WeChatMiniProgramApi::checkSignature($rawData, $signature, $sessionKey)) {
return ['error' => 22, 'message' => 'check signature not pass'];
}
/** 数据解密 & 数据的有效性校验 **/
$encryptedData = $_REQUEST['encryptedData'];
$iv = $_REQUEST['iv'];
$plainData = WeChatMiniProgramApi::dataCrypt($encryptedData, $iv, $sessionKey);
trace($plainData, '>plainData-debug');
// 这里不会因为密匙失效而发生解密失败，因为获取openid的同时就获取到了最新的用户密匙，所以OAuth不会出现密匙失效问题
// 倒是其他接口，可能会出现密匙失效的情况，比如wx.getShareInfo的回调参数中有需要解密的
// 密匙有效期不公开，只能通过在前端小程序检测密匙有效性，如果失效就调用wx.login() > code > sns/jscode2session 后端更新密匙
if (is_numeric($plainData)) {
return ['error' => $plainData, 'message' => 'dataCrypt fail'];
}
$plainData = json_decode($plainData, true);
// 再次判断加密数据中的openid与登录凭证校验接口换取的openid是否一致
if ($plainData['openId'] != $openid) {
return ['error' => 1, 'message' => 'openid illegal'];
}
// 敏感数据归属appid，开发者可校验此参数与自身appid是否一致
if ($plainData['watermark']['appid'] != $miniProgramConfig['app_id']) {
return ['error' => 2, 'message' => 'APPID illegal'];
}
// 超过60s上传的数据视为过期数据，将不通过有效数据校验
if (($plainData['watermark']['timestamp'] + 60) < time()) {
return ['error' => 3, 'message' => 'api data timeout'];
}
$unionId = null;
if (!empty($plainData['unionId'])) {
// 注意解密出来的是 unionId 大写的 I
$unionId = $plainData['unionId'];
}
// TODO: 保存远程图像到OSS
$plainData['nickName'] = mb_substr($plainData['nickName'], 0, 12, 'utf-8');
$userData = [
'openid' => $openid,
'nickname' => empty($plainData['nickName']) ? '用户昵称' : $plainData['nickName'],
'avatar' => empty($plainData['avatarUrl']) ? '/static/images/avatar/avatar.png' : $plainData['avatarUrl'],
'gender' => $plainData['gender'],
'province' => $plainData['province'],
'city' => $plainData['city'],
'country' => $plainData['country'],
// watermark:timestamp 可作为上次信息获取时间，以此来判断是否进行信息更新
'oauth_return_json' => json_encode($plainData),
'status' => 1,
'create_ip' => real_ip(),
'create_time' => time(),
];
if ($unionId) {
$userData['unionid'] = $unionId;
}
$errMsg = '';
try {
$db->startTrans();
if (!$userInfo = $db->lock(true)->getRow("SELECT * FROM xcx_brand_member WHERE openid = '{$openid}'")) {
$db->autoExecute('xcx_brand_member', $userData, 'INSERT');
$newId = $db->insert_id();
} else {
// 这两个更新下，防止用户换图像，这边信息过期了
$db->autoExecute('xcx_brand_member', [
'nickname' => $userData['nickname'],
'avatar' => $userData['avatar'],
], 'UPDATE', " openid = '{$openid}' ");
}
$userInfo = $db->lock(true)->getRow("SELECT * FROM xcx_brand_member WHERE openid = '{$openid}'");
$db->commit();
} catch (\Exception $e) {
$db->rollback();
$errMsg = $e->getMessage() ?: '系统忙！';
$errCode = $e->getCode() ?: 1;
}
if ($errMsg == '') {
// 登录处理操作
$this->loginAfter($userInfo, $apiInfo);
$res = ['error' => 0, 'message' => 'oauth login success!', 'data' => $userInfo];
} else {
trace($errMsg, 'error');
$res = ['error' => $errCode, 'message' => $errMsg];
}
return $res;
}
// 用户登录之后的一些处理操作
private function loginAfter($userInfo, $apiInfo = [])
{
// 登录验证后的session处理（包括签名信息）
$this->setLoginSession($userInfo);
// 设置小程序的api数据信息
!empty($apiInfo) && $this->setWeSession($apiInfo);
// 登录后的用户信息更新
$this->upUserLoginData($userInfo);
// TODO 用户登录后的日志记录
$this->UserLoginLog($userInfo);
}
// 登录验证后的session处理（包括签名信息）
// 设置系统用户的登录态，有效期为 cookie[PHPSESSION]的有效期 session文件的有效期（gc有概率回收）
private function setLoginSession($userInfo)
{
$_SESSION['user_id'] = $userInfo['id'];
$_SESSION['user'] = $userInfo;
}
// 设置小程序的api数据信息
// 小程序用户的sessionKey临时会话密匙，这也是有有效期的，这个和系统登录态没有关系，是雷锋和雷峰塔的关系
// 但是会话密匙过期后也是需要再次获取的（再走登录流程），所以这个“也算是登录态”，也就是说系统的登录态受本身session登录态和用户临时会话密匙的影响
private function setWeSession($apiInfo)
{
$_SESSION['userApi'] = [
'session_key' => $apiInfo['session_key'],
'openid' => $apiInfo['openid'],
];
}
// 登录后的用户信息更新
private function upUserLoginData($userInfo)
{
global $db;
$db->autoExecute('xcx_brand_member', [
'login' => ['exp', 'login+1'],
'last_login_time' => time(),
'last_login_ip' => real_ip(),
], 'UPDATE', "id = {$userInfo['id']}");
}
// TODO 用户登录后的日志记录
private function UserLoginLog($userInfo)
{
# TODO
}
}
/**
* https://developers.weixin.qq.com/community/develop/doc/000c02190182e0d79cb65e3ca5b400?page=1#comment-list
*
* https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/union-id.html
*
* 小程序-登陆：https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/login/auth.code2Session.html
*
* 公号-事件消息：https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Receiving_event_pushes.html
*
* 公号-获取用户信息：https://developers.weixin.qq.com/doc/offiaccount/User_Management/Get_users_basic_information_UnionID.html
*
* ## 小程序获取用户是否关注其关联的公众号：
*
* 1. 小程序这边登陆时可以获取 openid 和 unionid
* 2. 用户关注公众号
* 3. 公众号收到 关注事件消息，得到 用户与 公众号 对应的 openid
* 4. 公号通过 openid 获取用户 是否关注了
* 5. 更新关注表 weixin_subscribe: (id, unionId, subscribe)
* 6. 小程序这边 通过 unionid 查 关注表就知道用户是否关注公号了
*
* 注意：1 中的 openid 和 3 中的 openid 是不一样的
*
* 注意：1 中 unionid 只能从 解密数据中获取，code2Session 中如果用户没关注 时是取不到的
*
* 注意：1 中是 unionId 大写的I 而不是 unionid（汗）
*/
```
### 关注事件响应
```php
// 事件类型
case 'subscribe':
case 'unsubscribe':
...
// 纯 unionid , openid , subscribe 关系与状态, 无任何业务逻辑
if (!($_mp_openid_id = m('wechat_mp_openid')->getmou('id', " appid = '{$weChatConfig['appid']}' and openid = '{$openid}' "))) {
$_mp_openid_id = m('wechat_mp_openid')->insert([
'appid' => $weChatConfig['appid'],
'openid' => $openid,
]);
}
if ($wechatUserInfo['subscribe']) {
m('wechat_mp_openid')->update([
'unionid' => $wechatUserInfo['unionid'],
'subscribe' => 1,
'subscribe_time' => $wechatUserInfo['subscribe_time'],
], " id = '{$_mp_openid_id}' ");
} else {
m('wechat_mp_openid')->update([
'subscribe' => 0,
'unsubscribe_time' => time(),
], " id = '{$_mp_openid_id}' ");
}
```
----
last update: 2020-08-13 17:45:53
- 开始
- 公益
- 更好的使用看云
- 推荐书单
- 优秀资源整理
- 技术文章写作规范
- SublimeText - 编码利器
- PSR-0/PSR-4命名标准
- php的多进程实验分析
- 高级PHP
- 进程
- 信号
- 事件
- IO模型
- 同步、异步
- socket
- Swoole
- PHP扩展
- Composer
- easyswoole
- php多线程
- 守护程序
- 文件锁
- s-socket
- aphp
- 队列&并发
- 队列
- 讲个故事
- 如何最大效率的问题
- 访问式的web服务（一）
- 访问式的web服务（二）
- 请求
- 浏览器访问阻塞问题
- Swoole
- 你必须理解的计算机核心概念 - 码农翻身
- CPU阿甘 - 码农翻身
- 异步通知，那我要怎么通知你啊？
- 实时操作系统
- 深入实时 Linux
- Redis 实现队列
- redis与队列
- 定时-时钟-阻塞
- 计算机的生命
- 多进程/多线程
- 进程通信
- 拜占庭将军问题深入探讨
- JAVA CAS原理深度分析
- 队列的思考
- 走进并发的世界
- 锁
- 事务笔记
- 并发问题带来的后果
- 为什么说乐观锁是安全的
- 内存锁与内存事务 - 刘小兵2014
- 加锁还是不加锁，这是一个问题 - 码农翻身
- 编程世界的那把锁 - 码农翻身
- 如何保证万无一失
- 传统事务与柔性事务
- 大白话搞懂什么是同步/异步/阻塞/非阻塞
- redis实现锁
- 浅谈mysql事务
- PHP异常
- php错误
- 文件加载
- 路由与伪静态
- URL模式之分析
- 字符串处理
- 正则表达式
- 数组合并与+
- 文件上传
- 常用验证与过滤
- 记录
- 趣图
- foreach需要注意的问题
- Discuz!笔记
- 程序设计思维
- 抽象与具体
- 配置
- 关于如何学习的思考
- 编程思维
- 谈编程
- 如何安全的修改对象
- 临时
- 临时笔记
- 透过问题看本质
- 程序后门
- 边界检查
- session
- 安全
- 王垠
- 第三方数据接口
- 验证码问题
- 还是少不了虚拟机
- 程序员如何谈恋爱
- 程序员为什么要一直改BUG，为什么不能一次性把代码写好？
- 碎碎念
- 算法
- 实用代码
- 相对私密与绝对私密
- 学习目标
- 随记
- 编程小知识
- foo
- 落盘
- URL编码的思考
- 字符编码
- Elasticsearch
- TCP-IP协议
- 碎碎念2
- Grafana
- EFK、ELK
- RPC
- 依赖注入
- 开发笔记
- 经纬度格式转换
- php时区问题
- 解决本地开发时调用远程AIP跨域问题
- 后期静态绑定
- 谈tp的跳转提示页面
- 无限分类问题
- 生成微缩图
- MVC名词
- MVC架构
- 也许模块不是唯一的答案
- 哈希算法
- 开发后台
- 软件设计架构
- mysql表字段设计
- 上传表如何设计
- 二开心得
- awesomes-tables
- 安全的代码部署
- 微信开发笔记
- 账户授权相关
- 小程序获取是否关注其公众号
- 支付相关
- 提交订单
- 微信支付笔记
- 支付接口笔记
- 支付中心开发
- 下单与支付
- 支付流程设计
- 订单与支付设计
- 敏感操作验证
- 排序设计
- 代码的运行环境
- 搜索关键字的显示处理
- 接口异步更新ip信息
- 图片处理
- 项目搭建
- 阅读文档的新方式
- mysql_insert_id并发问题思考
- 行锁注意事项
- 细节注意
- 如何处理用户的输入
- 不可见的字符
- 抽奖
- 时间处理
- 应用开发实战
- python 学习记录
- Scrapy 教程
- Playwright 教程
- stealth.min.js
- Selenium 教程
- requests 教程
- pyautogui 教程
- Flask 教程
- PyInstaller 教程
- python 文档相似度验证
- thinkphp5.0数据库与模型的研究
- workerman进程管理
- workerman网络分析
- java学习记录
- docker
- 笔记
- kubernetes
- Kubernetes
- PaddlePaddle
- composer
- oneinstack
- 人工智能 AI
- 京东
- pc_detailpage_wareBusiness
- doc
- 电商网站设计
- iwebshop
- 商品规格分析
- 商品属性分析
- tpshop
- 商品规格分析
- 商品属性分析
- 电商表设计
- 设计记录
- 优惠券
- 生成唯一订单号
- 购物车技术
- 分类与类型
- 微信登录与绑定
- 京东到家库存系统架构设计
- crmeb
- 命名规范
- Nginx https配置
- 关于人工智能
- 从人的思考方式到二叉树
- 架构
- 今日有感
- 文章保存
- 安全背后: 浏览器是如何校验证书的
- 避不开的分布式事务
- devops自动化运维、部署、测试的最后一公里 —— ApiFox 云时代的接口管理工具
- 找到自己今生要做的事
- 自动化生活
- 开源与浆果
- Apifox: API 接口自动化测试指南