封装通用第三方平台用户表(微信开放平台)

2024-08-21 19:44

本文主要是介绍封装通用第三方平台用户表(微信开放平台),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

    • 一. 注册微信开放平台
      • 1.1 开发者资质认证
      • 1.2 应用申请
      • 1.3 配置应用
    • 二.通用数据库表设计
    • 三.入库实体类
    • 四. 对接第三方平台
    • 4.1 微信开放平台VO对象
      • 4.2 通用方法


我们的系统可能要对接很多第三方系统,为了便利用户授权使用和对多平台账户的管理。有必要设计通用第三方平台表。用来统一用户管理,将以微信开放平台为例

一. 注册微信开放平台

首先强调的是 微信公众号平台和微信开放平台不是一个东西。 微信开放平台主要用于自己的系统对接微信。 而微信公众号平台主要使用微信公众号,小程序等微信内部程序对接微信开放接口。 而微信公众测试号不可用于微信开放平台。 微信开放平台必须通过企业认证注册应用实体,才能任意配置回调域使用测试域。

微信开放平台
微信开放平台文档
微信公众号平台
微信公众号平台测试号申请
微信公众号平台文档

1.1 开发者资质认证

在这里插入图片描述
主体必须以公司为认证实体
在这里插入图片描述

1.2 应用申请

扫描件内容必须与网站应用名称、网站应用简介、应用官网完全对应。 审查非常严格,不要得过且过。
在这里插入图片描述

1.3 配置应用

sercet只会出现一次,谨慎保管。如果我们需要登录或支付,其对应的接口状态必须为已获得
在这里插入图片描述
回调域配置,当认证通过后,我们可以使用内网穿透域名进行测试。或者使用公司公网,用nginx代理到个人电脑上进行测试开发
在这里插入图片描述
注意,授权回调域不要加http://或https:// 前缀,直接写域名即可,其中阅读开放平台开发文档时,让填写回调地址,那必须在接口请求时追加http:// 或https:// 前缀


二.通用数据库表设计

在这里插入图片描述

-- 第三方平台万能表  可以不绑定用户
-- access_token移除,作为token不入库
-- 移除 refresh_token ,让前端携带access_token同时携带refresh_token,保证可以刷新token
drop table if exists thirdauth_user;
create table thirdauth_user
(id          bigint unsigned                           not null comment '主键'primary key,user_id     bigint unsigned default 0 comment '用户id',tenant_id   varchar(32)     default '' comment '租户id 子平台再多,也不可能超过100个',nickname    varchar(32)     default ''                null comment '昵称',avator      varchar(255)    default ''                null comment '头像地址',scope       varchar(255)    default ''                null comment '授权范围',platform    varchar(32)                               not null comment '第三方平台名称',openid      varchar(64)                               not null comment '第三方平台用户id',unionid     varchar(64)     default ''                null comment '第三方内部跨平台id',create_time datetime        default CURRENT_TIMESTAMP null comment '创建时间',update_time datetime        default CURRENT_TIMESTAMP null on update CURRENT_TIMESTAMP comment '更新时间',is_delete   tinyint         default 0                 null comment '是否删除 0否 1是',unique `idx_platform_openid` (`platform`, `openid`)
) comment '用户第三方登录表';

三.入库实体类

/*** 用户第三方登录表* @TableName thirdauth_user*/
@TableName(value ="thirdauth_user")
@Data
public class ThirdauthUser implements Serializable {/*** 主键*/@TableIdprivate Long id;/*** 用户id*/@TableField(value = "user_id")private Long userId;/*** 租户id 内部系统哪个平台的用户id*/@TableField(value = "tenant_id")private Long tenantId;/*** 昵称*/@TableField(value = "nickname")private String nickname;/*** 头像地址*/@TableField(value = "avator")private String avator;/*** 第三方平台名称*/@TableField(value = "platform")private String platform;/*** 第三方平台用户id*/@TableField(value = "openid")private String openid;/*** 第三方内部跨平台id*/@TableField(value = "unionid")private String unionid;/*** scope*/@TableField(value = "scope")private String scope;/*** 创建时间*/@TableField(value = "create_time")private LocalDateTime createTime;/*** 更新时间*/@TableField(value = "update_time")private LocalDateTime updateTime;/*** 是否删除 0否 1是*/@TableField(value = "is_delete")@TableLogic(value = "0",delval = "1")private Integer isDelete;@TableField(exist = false)private static final long serialVersionUID = 1L;
}

四. 对接第三方平台

每个平台返回的数据总有差异,我们需要各种vo来协调,最后都归于上述实体类入库。这里仅列出微信开放平台的封装。

4.1 微信开放平台VO对象

/*** @author YuanJie* @date 2024/8/20 下午2:32*/
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class WeChatVO {/*** 用户授权唯一标识*/private String openid;/*** 用户授权的access_token*/private String access_token;/*** access_token接口调用凭证超时时间,单位(秒)*/private Long expires_in;/*** 用户昵称*/private String nickname;/*** 用户头像*/private String headimgurl;/*** 用户刷新access_token  30天有效*/private String refresh_token;/*** 用户唯一标识,请注意,在未关注公众号时,用户访问公众号的网页,也会产生一个用户和公众号唯一的OpenID*/private String unionid;/*** 授权资料*/private String scope;
}

4.2 通用方法

/*** @author YuanJie* @date 2024/6/20 下午2:02*/
@RestController
@RequestMapping("/oauth2/wx")
@Slf4j
@ApiOperation(value = "oauth2", tags = "oauth2")
public class WXController extends BaseController {@Value("${oauth2.wx.appid}")private String appid;@Value("${oauth2.wx.appSecret}")private String appSecret;@Resourceprivate ThirdauthUserService thirdauthUserService;@Resourceprivate RestTemplate restTemplate;private final List<String> states = Collections.synchronizedList(new ArrayList<>());private final ObjectMapper objectMapper = new ObjectMapper();private final String WX_PREFIX = "wx";/*** 127.0.0.1:8080/oauth2/wx/code?backendUrl=http://xxxxo.com/oauth2/wx/callback** @param request* @param response* @param backendUrl* @throws IOException*/@ApiOperation("获取微信code")@GetMapping("/code")public void getWxCode(HttpServletRequest request,HttpServletResponse response,@RequestParam("backendUrl") String backendUrl) throws IOException {String state = UUID.randomUUID().toString().replace("-", "");this.states.add(state);// 回调地址直接填 下面的getCallback()方法。让微信直接回调下面的方法,这里回调地址必须加http https 前缀String url = "https://open.weixin.qq.com/connect/qrconnect?" +"appid=" + appid +"&redirect_uri=" + UriEncoder.encode(backendUrl) +"&response_type=code" +"&scope=snsapi_login" +"&state=" + state + "#wechat_redirect";response.sendRedirect(url);}/*** 供微信调用* 获取access_token** @param code*/@ApiOperation("获取access_token")@GetMapping("/callback")public AjaxResult getCallback(@RequestParam("code") String code, @RequestParam("state") String state) throws JsonProcessingException {// 校验stateif (!this.states.contains(state)) {return error();}this.states.remove(state);// 获取access_tokenString url = "https://api.weixin.qq.com/sns/oauth2/access_token?" +"appid=" + appid +"&secret=" + appSecret +"&code=" + code +"&grant_type=authorization_code";ResponseEntity<String> forEntity = restTemplate.getForEntity(url, String.class);WeChatVO weChatVO = objectMapper.readValue(forEntity.getBody(), WeChatVO.class);if (weChatVO == null) {return error("获取微信信息异常");}// 获取用户信息准备入库WeChatVO userInfo = setUserInfo(weChatVO.getAccess_token(), weChatVO.getRefresh_token(), weChatVO.getOpenid());log.info("当前微信用户信息:{}", objectMapper.writeValueAsString(weChatVO));// 返回tokenreturn success(userInfo);}/*** 请求用户信息** @param accessToken* @param refreshToken* @param openid*/private WeChatVO setUserInfo(String accessToken, String refreshToken, String openid) throws JsonProcessingException {// 校验token是否有效 并刷新tokenaccessToken = checkToken(accessToken, refreshToken, openid);// 请求用户信息String userInfo = "https://api.weixin.qq.com/sns/userinfo?" +"access_token=" + accessToken +"&openid=" + openid;ResponseEntity<String> forEntity = restTemplate.getForEntity(userInfo, String.class);WeChatVO weChatVO = objectMapper.readValue(forEntity.getBody(), WeChatVO.class);if (weChatVO == null) {throw new RuntimeException("获取微信信息异常");}weChatVO.setAccess_token(accessToken);weChatVO.setRefresh_token(refreshToken);// 保存到数据库ThirdauthUser thirdauthUser = new ThirdauthUser();thirdauthUser.setPlatform(WX_PREFIX);thirdauthUser.setAvator(weChatVO.getHeadimgurl());BeanUtils.copyProperties(weChatVO, thirdauthUser);thirdauthUserService.saveOrUpdate(thirdauthUser,Wrappers.lambdaQuery(ThirdauthUser.class).eq(ThirdauthUser::getOpenid, weChatVO.getOpenid()).eq(ThirdauthUser::getPlatform, WX_PREFIX));return weChatVO;}/*** 校验token是否有效 并返回刷新的token** @param accessToken* @param refreshToken* @param openid*/private String checkToken(String accessToken, String refreshToken, String openid) throws JsonProcessingException {String checkToken = "https://api.weixin.qq.com/sns/auth?" +"access_token=" + accessToken +"&openid=" + openid;ResponseEntity<String> forEntity = restTemplate.getForEntity(checkToken, String.class);String body = forEntity.getBody();Map map = objectMapper.readValue(body, Map.class);if (map.get("errcode").equals(0)) {return refreshToken(refreshToken);}throw new RuntimeException("token失效,请重新登录");}/*** 刷新token 若refreshToken失效,则重新登录** @param refreshToken* @return*/private String refreshToken(String refreshToken) throws JsonProcessingException {String url = "https://api.weixin.qq.com/sns/oauth2/refresh_token?" +"appid=" + appid +"&grant_type=refresh_token" +"&refresh_token=" + refreshToken;ResponseEntity<String> forEntity = restTemplate.getForEntity(url, String.class);WeChatVO weChatVO = objectMapper.readValue(forEntity.getBody(), WeChatVO.class);if (weChatVO == null) {throw new RuntimeException("刷新token失败,refreshToken已过期,请重新登录");}return weChatVO.getAccess_token();}

在这里插入图片描述

这篇关于封装通用第三方平台用户表(微信开放平台)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1094110

相关文章

流媒体平台/视频监控/安防视频汇聚EasyCVR播放暂停后视频画面黑屏是什么原因?

视频智能分析/视频监控/安防监控综合管理系统EasyCVR视频汇聚融合平台,是TSINGSEE青犀视频垂直深耕音视频流媒体技术、AI智能技术领域的杰出成果。该平台以其强大的视频处理、汇聚与融合能力,在构建全栈视频监控系统中展现出了独特的优势。视频监控管理系统EasyCVR平台内置了强大的视频解码、转码、压缩等技术,能够处理多种视频流格式,并以多种格式(RTMP、RTSP、HTTP-FLV、WebS

W外链微信推广短连接怎么做?

制作微信推广链接的难点分析 一、内容创作难度 制作微信推广链接时,首先需要创作有吸引力的内容。这不仅要求内容本身有趣、有价值,还要能够激起人们的分享欲望。对于许多企业和个人来说,尤其是那些缺乏创意和写作能力的人来说,这是制作微信推广链接的一大难点。 二、精准定位难度 微信用户群体庞大,不同用户的需求和兴趣各异。因此,制作推广链接时需要精准定位目标受众,以便更有效地吸引他们点击并分享链接

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动,这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升:减少抖动,提高图像的清晰度和细节表现力,使得监控画面更加真实可信。 - 细节增强:在低光条件下,抖

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

如何解决线上平台抽佣高 线下门店客流少的痛点!

目前,许多传统零售店铺正遭遇客源下降的难题。尽管广告推广能带来一定的客流,但其费用昂贵。鉴于此,众多零售商纷纷选择加入像美团、饿了么和抖音这样的大型在线平台,但这些平台的高佣金率导致了利润的大幅缩水。在这样的市场环境下,商家之间的合作网络逐渐成为一种有效的解决方案,通过资源和客户基础的共享,实现共同的利益增长。 以最近在上海兴起的一个跨行业合作平台为例,该平台融合了环保消费积分系统,在短

Android平台播放RTSP流的几种方案探究(VLC VS ExoPlayer VS SmartPlayer)

技术背景 好多开发者需要遴选Android平台RTSP直播播放器的时候,不知道如何选的好,本文针对常用的方案,做个大概的说明: 1. 使用VLC for Android VLC Media Player(VLC多媒体播放器),最初命名为VideoLAN客户端,是VideoLAN品牌产品,是VideoLAN计划的多媒体播放器。它支持众多音频与视频解码器及文件格式,并支持DVD影音光盘,VCD影

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

随着区块链技术的快速发展,越来越多的企业开始将其应用于实际业务中。然而,区块链技术的专业性使得其集成开发成为一项挑战。针对此,广东中创智慧科技有限公司基于国产开源联盟链 FISCO BCOS 推出了区块链集成开发平台。该平台基于区块链技术,提供一套全面的区块链开发工具和开发环境,支持开发者快速开发和部署区块链应用。此外,该平台还可以提供一套全面的区块链开发教程和文档,帮助开发者快速上手区块链开发。

K8S(Kubernetes)开源的容器编排平台安装步骤详解

K8S(Kubernetes)是一个开源的容器编排平台,用于自动化部署、扩展和管理容器化应用程序。以下是K8S容器编排平台的安装步骤、使用方式及特点的概述: 安装步骤: 安装Docker:K8S需要基于Docker来运行容器化应用程序。首先要在所有节点上安装Docker引擎。 安装Kubernetes Master:在集群中选择一台主机作为Master节点,安装K8S的控制平面组件,如AP

衡石分析平台使用手册-单机安装及启动

单机安装及启动​ 本文讲述如何在单机环境下进行 HENGSHI SENSE 安装的操作过程。 在安装前请确认网络环境,如果是隔离环境,无法连接互联网时,请先按照 离线环境安装依赖的指导进行依赖包的安装,然后按照本文的指导继续操作。如果网络环境可以连接互联网,请直接按照本文的指导进行安装。 准备工作​ 请参考安装环境文档准备安装环境。 配置用户与安装目录。 在操作前请检查您是否有 sud

业务协同平台--简介

一、使用场景         1.多个系统统一在业务协同平台定义协同策略,由业务协同平台代替人工完成一系列的单据录入         2.同时业务协同平台将执行任务推送给pda、pad等执行终端,通知各人员、设备进行作业执行         3.作业过程中,可设置完成时间预警、作业节点通知,时刻了解作业进程         4.做完再给你做过程分析,给出优化建议         就问你这一套下