diff --git a/README.md b/README.md index 5367168..8dd64a7 100644 --- a/README.md +++ b/README.md @@ -31,7 +31,7 @@ - [x] 菜单操作(查询、创建、删除、个性化菜单) - [ ] 二维码(创建临时、永久二维码,查看二维码URL) - [x] 分组操作(查询、创建、修改、批量移动用户到分组, 批量从分组移除用户) -- [ ] 用户信息(查询用户基本信息、获取关注者列表) +- [x] 用户信息(批量查询用户基本信息、获取关注者列表) - [ ] 媒体文件(上传、获取) - [ ] 群发消息(文本、图片、语音、视频、图文) - [ ] 客服记录(查询客服记录,查看客服、查看在线客服) diff --git a/src/app.module.ts b/src/app.module.ts index 2334d0d..4c6dcf7 100644 --- a/src/app.module.ts +++ b/src/app.module.ts @@ -9,6 +9,7 @@ import { WechatTemplate } from './modules/template/wechat.template'; import { TestController } from './controller/test.controller'; import { WechatMenu } from './modules/menu/wechat.menu'; import { WechatGrouping } from './modules/grouping/wechat.grouping'; +import { WechatUser } from './modules/user/wechat.user'; @Module({ imports: [CacheModule.register({ @@ -23,6 +24,6 @@ import { WechatGrouping } from './modules/grouping/wechat.grouping'; { provide: APP_INTERCEPTOR, useClass: ErrorsInterceptor - }, AppService, WeChatUtil, WechatTemplate, WechatMenu, WechatGrouping], + }, AppService, WeChatUtil, WechatTemplate, WechatMenu, WechatGrouping, WechatUser], }) export class AppModule {} diff --git a/src/controller/test.controller.ts b/src/controller/test.controller.ts index fd6ccf8..3d0c614 100644 --- a/src/controller/test.controller.ts +++ b/src/controller/test.controller.ts @@ -3,6 +3,7 @@ import { WeChatUtil } from '../utile/wechat.util'; import { WechatTemplate } from '../modules/template/wechat.template'; import { WechatMenu } from '../modules/menu/wechat.menu'; import { WechatGrouping } from '../modules/grouping/wechat.grouping'; +import { WechatUser } from '../modules/user/wechat.user'; @Controller('test') export class TestController { @@ -15,6 +16,8 @@ export class TestController { private readonly wechatMenu: WechatMenu, @Inject(WechatGrouping) private readonly wechatGrouping: WechatGrouping, + @Inject(WechatUser) + private readonly wechatUser: WechatUser ) {} @@ -131,4 +134,18 @@ export class TestController { const data = await this.wechatGrouping.queryUserLabelList(appid, parameter); return data; } + + @Post('queryUserInformation') + async queryUserInformation(@Req() req, @Body() body: {appid: string, parameter: any}) { + const {appid, parameter} = body; + const data = await this.wechatUser.queryUserInformation(appid, parameter); + return data; + } + + @Post('queryUserList') + async queryUserList(@Req() req, @Body() body: {appid: string, parameter: any}) { + const {appid, parameter} = body; + const data = await this.wechatUser.queryUserList(appid, parameter); + return data; + } } \ No newline at end of file diff --git a/src/modules/user/wechat.user.ts b/src/modules/user/wechat.user.ts new file mode 100644 index 0000000..edf5dc4 --- /dev/null +++ b/src/modules/user/wechat.user.ts @@ -0,0 +1,155 @@ +import { HttpException, HttpService, Inject, Injectable } from '@nestjs/common'; +import { WeChatUtil } from '../../utile/wechat.util'; + +@Injectable() +export class WechatUser { + constructor( + @Inject(WeChatUtil) private readonly wechatUtil: WeChatUtil, + @Inject(HttpService) private readonly httpService: HttpService + ) {} + + /** + * 批量获取用户基本信息,开发者可通过该接口来批量获取用户基本信息。最多支持一次拉取100条。 + * 在关注者与公众号产生消息交互后,公众号可获得关注者的OpenID(加密后的微信号,每个用户对每个公众号的OpenID是唯一的。对于不同公众号,同一用户的openid不同)。公众号可通过本接口来根据OpenID获取用户基本信息,包括昵称、头像、性别、所在城市、语言和关注时间。 + * 请注意,如果开发者有在多个公众号,或在公众号、移动应用之间统一用户帐号的需求,需要前往微信开放平台(open.weixin.qq.com)绑定公众号后,才可利用UnionID机制来满足上述需求。 + * UnionID机制说明:开发者可通过OpenID来获取用户基本信息。特别需要注意的是,如果开发者拥有多个移动应用、网站应用和公众帐号,可通过获取用户基本信息中的unionid来区分用户的唯一性,因为只要是同一个微信开放平台帐号下的移动应用、网站应用和公众帐号,用户的unionid是唯一的。换句话说,同一用户,对同一个微信开放平台下的不同应用,unionid是相同的. + * parameter 格式:{ "user_list": [ + * { + * "openid": "otvxTs4dckWG7imySrJd6jSi0CWE", (必传) + * "lang": "zh_CN" (国家地区语言版本,可不传,默认zh-CN,有多个版本) + * } + * ] } + * 返回参数:正常情况下,微信会返回下述JSON数据包给公众号(示例中为一次性拉取了2个openid的用户基本信息,第一个是已关注的,第二个是未关注的): + * { + * "user_info_list": [ + * { + * "subscribe": 1, + * "openid": "otvxTs4dckWG7imySrJd6jSi0CWE", + * "nickname": "iWithery", + * "sex": 1, + * "language": "zh_CN", + * "city": "揭阳", + * "province": "广东", + * "country": "中国", + * + * "headimgurl": "http://thirdwx.qlogo.cn/mmopen/xbIQx1GRqdvyqkMMhEaGOX802l1CyqMJNgUzKP8MeAeHFicRDSnZH7FY4XB7p8XHXIf6uJA2SCunTPicGKezDC4saKISzRj3nz/0", + * + * "subscribe_time": 1434093047, + * "unionid": "oR5GjjgEhCMJFyzaVZdrxZ2zRRF4", + * "remark": "", + * + * "groupid": 0, + * "tagid_list":[128,2], + * "subscribe_scene": "ADD_SCENE_QR_CODE", + * "qr_scene": 98765, + * "qr_scene_str": "" + * + * }, + * { + * "subscribe": 0, + * "openid": "otvxTs_JZ6SEiP0imdhpi50fuSZg" + * } + * ] + * } + * 参数 说明 + * subscribe 用户是否订阅该公众号标识,值为0时,代表此用户没有关注该公众号,拉取不到其余信息。 + * openid 用户的标识,对当前公众号唯一 + * nickname 用户的昵称 + * sex 用户的性别,值为1时是男性,值为2时是女性,值为0时是未知 + * city 用户所在城市 + * country 用户所在国家 + * province 用户所在省份 + * language 用户的语言,简体中文为zh_CN + * headimgurl 用户头像,最后一个数值代表正方形头像大小(有0、46、64、96、132数值可选,0代表640*640正方形头像),用户没有头像时该项为空。若用户更换头像,原有头像URL将失效。 + * subscribe_time 用户关注时间,为时间戳。如果用户曾多次关注,则取最后关注时间 + * unionid 只有在用户将公众号绑定到微信开放平台帐号后,才会出现该字段。 + * remark 公众号运营者对粉丝的备注,公众号运营者可在微信公众平台用户管理界面对粉丝添加备注 + * groupid 用户所在的分组ID(暂时兼容用户分组旧接口) + * tagid_list 用户被打上的标签ID列表 + * subscribe_scene 返回用户关注的渠道来源,ADD_SCENE_SEARCH 公众号搜索,ADD_SCENE_ACCOUNT_MIGRATION 公众号迁移,ADD_SCENE_PROFILE_CARD 名片分享,ADD_SCENE_QR_CODE 扫描二维码,ADD_SCENEPROFILE LINK 图文页内名称点击,ADD_SCENE_PROFILE_ITEM 图文页右上角菜单,ADD_SCENE_PAID 支付后关注,ADD_SCENE_OTHERS 其他 + * qr_scene 二维码扫码场景(开发者自定义) + * qr_scene_str 二维码扫码场景描述(开发者自定义) + * 详情可参考 https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140839 + * @param {string} appid (必传) + * @param parameter (必传) + * @returns {Promise<{code: number; message: string; data: any}>} + */ + async queryUserInformation(appid: string, parameter: any) { + if (!appid) { + throw new HttpException('appid不存在!!', 500); + } + const accessToken: string = await this.wechatUtil.ensureAccessToken(appid); + const url = `https://api.weixin.qq.com/cgi-bin/user/info/batchget?access_token=${accessToken}`; + const { data } = await this.httpService.post(url, parameter).toPromise(); + if (data.errcode) { + throw new HttpException(data.errmsg, data.errcode); + } + return { code: 200, message: '获取用户基本信息成功!', data}; + } + + /** + * 公众号可通过本接口来获取帐号的关注者列表,关注者列表由一串OpenID(加密后的微信号,每个用户对每个公众号的OpenID是唯一的)组成。 + * 一次拉取调用最多拉取10000个关注者的OpenID,可以通过多次拉取的方式来满足需求。 + * parameter 格式:{ "nextOpenId": "OpenId" } + * 附:关注者数量超过10000时 + * 当公众号关注者数量超过10000时,可通过填写next_openid的值,从而多次拉取列表的方式来满足需求。 + * 具体而言,就是在调用接口时,将上一次调用得到的返回中的next_openid值,作为下一次调用中的next_openid值。 + * 示例: + * 公众账号A拥有23000个关注的人,想通过拉取关注接口获取所有关注的人,那么分别请求url如下:https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN 返回结果: + * { + * "total":23000, + * "count":10000, + * "data":{" + * openid":[ + * "OPENID1", + * "OPENID2", + * ..., + * "OPENID10000" + * ] + * }, + * "next_openid":"OPENID10000" + * }https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN&next_openid=NEXT_OPENID1返回结果: + * { + * "total":23000, + * "count":10000, + * "data":{ + * "openid":[ + * "OPENID10001", + * "OPENID10002", + * ..., + * "OPENID20000" + * ] + * }, + * "next_openid":"OPENID20000" + * }https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN&next_openid=NEXT_OPENID2返回结果(关注者列表已返回完时,返回next_openid为空): + * { + * "total":23000, + * "count":3000, + * "data":{" + * "openid":[ + * "OPENID20001", + * "OPENID20002", + * ..., + * "OPENID23000" + * ] + * }, + * "next_openid":"OPENID23000" + * } + * 详情可参考: https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140840 + * @param {string} appid + * @param parameter + * @returns {Promise<{code: number; message: string; data: any}>} + */ + async queryUserList(appid: string, parameter: any) { + if (!appid) { + throw new HttpException('appid不存在!!', 500); + } + const accessToken: string = await this.wechatUtil.ensureAccessToken(appid); + const url = `https://api.weixin.qq.com/cgi-bin/user/get?access_token=${accessToken}&next_openid=${parameter.nextOpenId}`; + const { data } = await this.httpService.get(url).toPromise(); + if (data.errcode) { + throw new HttpException(data.errmsg, data.errcode); + } + return { code: 200, message: '获取关注用户列表成功!', data}; + } +} \ No newline at end of file