devbox
菜鸟追梦旅行
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

微信小程序(旧): java实现获取手机号方式_java 微信小程序获取手机号

作者：菜鸟追梦旅行 | 2024-03-22 02:31:01

赞

踩

java 微信小程序获取手机号

目录

1. 现在比较简单的方式

-> 接口名

---> 功能描述

-> 调用方式

---> HTTPS 调用

---> 第三方调用

---> 请求参数

---> 返回参数

2. 实现方式

1. 加入fastjson依赖 

2. http请求类

3. Json串工具类

4.接口方法

3.另外介绍一点access_token

1. 现在比较简单的方式

统一封装最新文章地址(可跳过): 微信小程序02: 使用手机号快速验证获取手机号(新版)

下面(旧版)的可以直接使用, 上面的文章(最新)进行了同一封装

-> 接口名

getPhoneNumber

---> 功能描述

该接口需配合手机号快速填写组件能力一起使用，当用户点击并同意之后，可以通过 bindgetphonenumber 事件回调获取到动态令牌code，再调用该接口将code换取用户手机号。

注意：每个code只能使用一次，code的有效期为5min。

-> 调用方式

---> HTTPS 调用

  1.  
  2. POST https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=ACCESS_TOKEN 
  3.

---> 第三方调用

  • 调用方式以及出入参和HTTPS相同，仅是调用的token不同

  • 该接口所属的权限集id为：18

  • 服务商获得其中之一权限集授权后，可通过使用authorizer_access_token代商家进行调用

---> 请求参数

属性类型必填说明
access_tokenstring是接口调用凭证，该参数为 URL 参数，非 Body 参数。使用access_token或者authorizer_access_token
codestring是手机号获取凭证

---> 返回参数

属性类型说明
errcodenumber错误码
errmsgstring错误信息
phone_infoobject用户手机号信息
属性类型说明
phoneNumberstring用户绑定的手机号（国外手机号会有区号）
purePhoneNumberstring没有区号的手机号
countryCodestring区号
watermarkobject数据水印
属性类型说明
timestampnumber用户获取手机号操作的时间戳
appidstring小程序appid

2. 实现方式

1. 加入fastjson依赖 

  1.         <dependency>
  2.             <groupId>com.alibaba</groupId>
  3.             <artifactId>fastjson</artifactId>
  4.             <version>1.2.75</version>
  5.         </dependency>

2. http请求类

  1. import lombok.extern.slf4j.Slf4j;
  2. import org.apache.http.client.config.RequestConfig;
  3. import org.apache.http.client.entity.UrlEncodedFormEntity;
  4. import org.apache.http.client.methods.CloseableHttpResponse;
  5. import org.apache.http.client.methods.HttpGet;
  6. import org.apache.http.client.methods.HttpPost;
  7. import org.apache.http.entity.ContentType;
  8. import org.apache.http.entity.StringEntity;
  9. import org.apache.http.impl.client.CloseableHttpClient;
  10. import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
  11. import org.apache.http.impl.client.HttpClients;
  12. import org.apache.http.message.BasicHeader;
  13. import org.apache.http.message.BasicNameValuePair;
  14. import org.apache.http.util.EntityUtils;
  15. import org.slf4j.MDC;
  16. import org.springframework.http.HttpStatus;
  17. import org.springframework.util.CollectionUtils;
  18.  
  19. import java.io.IOException;
  20. import java.util.ArrayList;
  21. import java.util.List;
  22. import java.util.Map;
  23.  
  24. /**
  25.  * HTTP/HTTPS 请求封装: GET / POST
  26.  * 默认失败重试3次
  27.  * @author admin
  28.  */
  29. @Slf4j
  30. public class HttpClientSslUtils {
  31.  
  32. 	/**
  33. 	 * 默认的字符编码格式
  34. 	 */
  35. 	private static final String DEFAULT_CHAR_SET = "UTF-8";
  36. 	/**
  37. 	 * 默认连接超时时间 (毫秒)
  38. 	 */
  39. 	private static final Integer DEFAULT_CONNECTION_TIME_OUT = 2000;
  40. 	/**
  41. 	 * 默认socket超时时间 (毫秒)
  42. 	 */
  43. 	private static final Integer DEFAULT_SOCKET_TIME_OUT = 3000;
  44.  
  45. 	/** socketTimeOut上限 */
  46. 	private static final Integer SOCKET_TIME_OUT_UPPER_LIMIT = 10000;
  47.  
  48. 	/** socketTimeOut下限 */
  49. 	private static final Integer SOCKET_TIME_OUT_LOWER_LIMIT = 1000;
  50.  
  51. 	private static CloseableHttpClient getHttpClient() {
  52. 		RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(DEFAULT_SOCKET_TIME_OUT)
  53. 			.setConnectTimeout(DEFAULT_CONNECTION_TIME_OUT).build();
  54. 		return HttpClients.custom().setDefaultRequestConfig(requestConfig)
  55. 			.setRetryHandler(new DefaultHttpRequestRetryHandler()).build();
  56. 	}
  57.  
  58. 	private static CloseableHttpClient getHttpClient(Integer socketTimeOut) {
  59. 		RequestConfig requestConfig =
  60. 			RequestConfig.custom().setSocketTimeout(socketTimeOut).setConnectTimeout(DEFAULT_CONNECTION_TIME_OUT)
  61. 				.build();
  62. 		return HttpClients.custom().setDefaultRequestConfig(requestConfig)
  63. 			.setRetryHandler(new DefaultHttpRequestRetryHandler()).build();
  64. 	}
  65.  
  66. 	public static String doPost(String url, String requestBody) throws Exception {
  67. 		return doPost(url, requestBody, ContentType.APPLICATION_JSON);
  68. 	}
  69.  
  70. 	public static String doPost(String url, String requestBody, Integer socketTimeOut) throws Exception {
  71. 		return doPost(url, requestBody, ContentType.APPLICATION_JSON, null, socketTimeOut);
  72. 	}
  73.  
  74. 	public static String doPost(String url, String requestBody, ContentType contentType) throws Exception {
  75. 		return doPost(url, requestBody, contentType, null);
  76. 	}
  77.  
  78. 	public static String doPost(String url, String requestBody, List<BasicHeader> headers) throws Exception {
  79. 		return doPost(url, requestBody, ContentType.APPLICATION_JSON, headers);
  80. 	}
  81.  
  82. 	public static String doPost(String url, String requestBody, ContentType contentType, List<BasicHeader> headers)
  83. 		throws Exception {
  84. 		return doPost(url, requestBody, contentType, headers, getHttpClient());
  85. 	}
  86.  
  87. 	public static String doPost(String url, String requestBody, ContentType contentType, List<BasicHeader> headers,
  88.                                 Integer socketTimeOut) throws Exception {
  89. 		if (socketTimeOut < SOCKET_TIME_OUT_LOWER_LIMIT || socketTimeOut > SOCKET_TIME_OUT_UPPER_LIMIT) {
  90. 			log.error("socketTimeOut非法");
  91. 			throw new Exception();
  92. 		}
  93. 		return doPost(url, requestBody, contentType, headers, getHttpClient(socketTimeOut));
  94. 	}
  95.  
  96.  
  97. 	/**
  98. 	 * 通用Post远程服务请求
  99. 	 * @param url
  100. 	 * 	请求url地址
  101. 	 * @param requestBody
  102. 	 * 	请求体body
  103. 	 * @param contentType
  104. 	 * 	内容类型
  105. 	 * @param headers
  106. 	 * 	请求头
  107. 	 * @return String 业务自行解析
  108. 	 * @throws Exception
  109. 	 */
  110. 	public static String doPost(String url, String requestBody, ContentType contentType, List<BasicHeader> headers,
  111.                                 CloseableHttpClient client) throws Exception {
  112.  
  113. 		// 构造http方法,设置请求和传输超时时间,重试3次
  114. 		CloseableHttpResponse response = null;
  115. 		long startTime = System.currentTimeMillis();
  116. 		try {
  117. 			HttpPost post = new HttpPost(url);
  118. 			if (!CollectionUtils.isEmpty(headers)) {
  119. 				for (BasicHeader header : headers) {
  120. 					post.setHeader(header);
  121. 				}
  122. 			}
  123. 			StringEntity entity =
  124. 				new StringEntity(requestBody, ContentType.create(contentType.getMimeType(), DEFAULT_CHAR_SET));
  125. 			post.setEntity(entity);
  126. 			response = client.execute(post);
  127. 			if (response.getStatusLine().getStatusCode() != HttpStatus.OK.value()) {
  128. 				log.error("业务请求返回失败:{}", EntityUtils.toString(response.getEntity()));
  129. 				throw new Exception();
  130. 			}
  131. 			String result = EntityUtils.toString(response.getEntity());
  132. 			return result;
  133. 		} finally {
  134. 			releaseResourceAndLog(url, requestBody, response, startTime);
  135. 		}
  136. 	}
  137.  
  138. 	/**
  139. 	 * 暂时用于智慧园区业务联调方式
  140. 	 * @param url 业务请求url
  141. 	 * @param param 业务参数
  142. 	 * @return
  143. 	 * @throws Exception
  144. 	 */
  145.     public static String doPostWithUrlEncoded(String url,
  146.                                               Map<String, String> param) throws Exception {
  147.         // 创建Httpclient对象
  148.         CloseableHttpClient httpClient = getHttpClient();
  149.         CloseableHttpResponse response = null;
  150.         long startTime = System.currentTimeMillis();
  151.         try {
  152.             // 创建Http Post请求
  153.             HttpPost httpPost = new HttpPost(url);
  154.             // 创建参数列表
  155.             if (param != null) {
  156.                 List<org.apache.http.NameValuePair> paramList = new ArrayList<>();
  157.                 for (String key : param.keySet()) {
  158.                     paramList.add(new BasicNameValuePair(key, param.get(key)));
  159.                 }
  160.                 // 模拟表单
  161.                 UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList, DEFAULT_CHAR_SET);
  162.                 httpPost.setEntity(entity);
  163.             }
  164.             // 执行http请求
  165.             response = httpClient.execute(httpPost);
  166.             if (response.getStatusLine().getStatusCode() != HttpStatus.OK.value()) {
  167. 				log.error("业务请求返回失败:{}" , EntityUtils.toString(response.getEntity()));
  168. 				throw new Exception();
  169.             }
  170.             String resultString = EntityUtils.toString(response.getEntity(), DEFAULT_CHAR_SET);
  171.             return resultString;
  172.         } finally {
  173.             releaseResourceAndLog(url, param == null ? null : param.toString(), response, startTime);
  174.         }
  175.     }
  176.  
  177. 	private static void releaseResourceAndLog(String url, String request, CloseableHttpResponse response, long startTime) {
  178. 		if (null != response) {
  179. 			try {
  180. 				response.close();
  181. 				recordInterfaceLog(startTime, url, request);
  182. 			} catch (IOException e) {
  183. 				log.error(e.getMessage());
  184. 			}
  185. 		}
  186. 	}
  187.  
  188. 	public static String doGet(String url) throws Exception {
  189. 		return doGet(url, ContentType.DEFAULT_TEXT);
  190. 	}
  191.  
  192. 	public static String doGet(String url, ContentType contentType) throws Exception {
  193. 		return doGet(url, contentType, null);
  194. 	}
  195.  
  196. 	public static String doGet(String url, List<BasicHeader> headers) throws Exception {
  197. 		return doGet(url, ContentType.DEFAULT_TEXT, headers);
  198. 	}
  199.  
  200. 	/**
  201. 	 * 通用Get远程服务请求
  202. 	 * @param url
  203. 	 * 	请求参数
  204. 	 * @param contentType
  205. 	 * 	请求参数类型
  206. 	 * @param headers
  207. 	 * 	请求头可以填充
  208. 	 * @return String 业务自行解析数据
  209. 	 * @throws Exception
  210. 	 */
  211. 	public static String doGet(String url, ContentType contentType, List<BasicHeader> headers) throws Exception {
  212. 		CloseableHttpResponse response = null;
  213. 		long startTime = System.currentTimeMillis();
  214. 		try {
  215. 			CloseableHttpClient client = getHttpClient();
  216. 			HttpGet httpGet = new HttpGet(url);
  217. 			if (!CollectionUtils.isEmpty(headers)) {
  218. 				for (BasicHeader header : headers) {
  219. 					httpGet.setHeader(header);
  220. 				}
  221. 			}
  222. 			if(contentType != null){
  223. 				httpGet.setHeader("Content-Type", contentType.getMimeType());
  224. 			}
  225. 			response = client.execute(httpGet);
  226. 			if (response.getStatusLine().getStatusCode() != HttpStatus.OK.value()) {
  227. 				log.error("业务请求返回失败:{}", EntityUtils.toString(response.getEntity()));
  228. 				throw new Exception();
  229. 			}
  230. 			String result = EntityUtils.toString(response.getEntity());
  231. 			return result;
  232. 		} finally {
  233. 			releaseResourceAndLog(url, null, response, startTime);
  234. 		}
  235. 	}
  236.  
  237. 	private static void recordInterfaceLog(long startTime, String url, String request) {
  238. 		long endTime = System.currentTimeMillis();
  239. 		long timeCost = endTime - startTime;
  240. 		MDC.put("totalTime", String.valueOf(timeCost));
  241. 		MDC.put("url", url);
  242. 		MDC.put("logType", "third-platform-service");
  243. 		log.info("HttpClientSslUtils 远程请求:{} 参数:{} 耗时:{}ms", url, request, timeCost);
  244. 	}
  245. }

3. Json串工具类

  1. import com.alibaba.fastjson.TypeReference;
  2. import com.fasterxml.jackson.annotation.JsonInclude;
  3. import com.fasterxml.jackson.core.JsonProcessingException;
  4. import com.fasterxml.jackson.databind.DeserializationFeature;
  5. import com.fasterxml.jackson.databind.JsonNode;
  6. import com.fasterxml.jackson.databind.ObjectMapper;
  7. import com.fasterxml.jackson.databind.SerializationFeature;
  8. import lombok.extern.slf4j.Slf4j;
  9. import org.springframework.util.StringUtils;
  10.  
  11. import java.text.SimpleDateFormat;
  12.  
  13. @Slf4j
  14. public class JsonUtil {
  15.  
  16.     /**
  17.      * 定义映射对象
  18.      */
  19.     public static ObjectMapper objectMapper = new ObjectMapper();
  20.  
  21.     /**
  22.      * 日期格式化
  23.      */
  24.     private static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
  25.  
  26.     static {
  27.         //对象的所有字段全部列入
  28.         objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
  29.         //取消默认转换timestamps形式
  30.         objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false);
  31.         //忽略空Bean转json的错误
  32.         objectMapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
  33.         //所有的日期格式都统一为以下的样式，即yyyy-MM-dd HH:mm:ss
  34.         objectMapper.setDateFormat(new SimpleDateFormat(DATE_FORMAT));
  35.         //忽略 在json字符串中存在，但是在java对象中不存在对应属性的情况。防止错误
  36.         objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
  37.  
  38.     }
  39.  
  40.     /**
  41.      * string转JsonNode
  42.      *
  43.      * @param jsonString
  44.      * @return com.fasterxml.jackson.databind.JsonNode
  45.      */
  46.     public static JsonNode stringToJsonNode(String jsonString) throws JsonProcessingException {
  47.  
  48.         return objectMapper.readTree(jsonString);
  49.  
  50.     }
  51.  
  52.     /**
  53.      * 对象转json字符串
  54.      *
  55.      * @param obj
  56.      * @param <T>
  57.      */
  58.     public static <T> String objToString(T obj) {
  59.  
  60.         if (obj == null) {
  61.             return null;
  62.         }
  63.         try {
  64.             return obj instanceof String ? (String) obj : objectMapper.writeValueAsString(obj);
  65.         } catch (JsonProcessingException e) {
  66.             log.warn("Parse Object to String error : {}", e.getMessage());
  67.             return null;
  68.         }
  69.     }
  70.  
  71.     /**
  72.      * 对象转格式化的字符串字符串
  73.      *
  74.      * @param obj
  75.      * @param <T>
  76.      * @return
  77.      */
  78.     public static <T> String objToPrettyString(T obj) {
  79.         if (obj == null) {
  80.             return null;
  81.         }
  82.         try {
  83.             return obj instanceof String ? (String) obj : objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(obj);
  84.         } catch (JsonProcessingException e) {
  85.             log.warn("Parse Object to String error : {}", e.getMessage());
  86.             return null;
  87.         }
  88.     }
  89.  
  90.     /**
  91.      * json字符串转对象
  92.      *
  93.      * @param jsonString
  94.      * @param cls
  95.      * @param <T>
  96.      */
  97.     public static <T> T stringToObj(String jsonString, Class<T> cls) {
  98.         if (StringUtils.isEmpty(jsonString) || cls == null) {
  99.             return null;
  100.         }
  101.         try {
  102.             return cls.equals(String.class) ? (T) jsonString : objectMapper.readValue(jsonString, cls);
  103.         } catch (JsonProcessingException e) {
  104.             log.warn("Parse String to Object error : {}", e.getMessage());
  105.             return null;
  106.         }
  107.     }
  108.  
  109. }

4.接口方法

  1.  @PostMapping("/getPhone")
  2.     public ResultResponse getPhone(@RequestBody @Valid WxMiniGetPhone param) {
  3.         JSONObject wxJson;
  4.         // 获取token
  5.         String token_url = null;
  6.  
  7.         /**
  8.          * appid切换
  9.          */
  10.         if (param.getWxAppletType() == 1) {
  11.             token_url = String.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s", bAppID, bAppSecret);
  12.         } else if (param.getWxAppletType() == 2) {
  13.             token_url = String.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s", aAppId, aSecret);
  14.         } else {
  15.             throw new UserServiceException("异常");
  16.         }
  17.  
  18.  
  19.         try {
  20.             JSONObject token = JSON.parseObject(HttpClientSslUtils.doGet(token_url));
  21.             if (token == null) {
  22.                 log.info("获取token失败");
  23.                 return null;
  24.             }
  25.             String accessToken = token.getString("access_token");
  26.             if (StringUtils.isEmpty(accessToken)) {
  27.                 log.info("获取token失败");
  28.                 return null;
  29.             }
  30.             log.info("token : {}", accessToken);
  31.             //获取phone
  32.             String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber"
  33.                     + "?access_token=" + accessToken;
  34.             JSONObject jsonObject = new JSONObject();
  35.             jsonObject.put("code", param.getCode());
  36.             String reqJsonStr = JsonUtil.objToString(jsonObject);
  37.             wxJson = JSON.parseObject(HttpClientSslUtils.doPost(url, reqJsonStr));
  38.  
  39.             if (wxJson == null) {
  40.                 log.info("获取手机号失败");
  41.                 return ResultResponse.error("获取手机号失败!");
  42.             }
  43.             return ResultResponse.ok("获取成功!").setData(wxJson);
  44.         } catch (Exception e) {
  45.             e.printStackTrace();
  46.         }
  47.         return ResultResponse.error("获取失败,请重试!");
  48.     }

3.另外介绍一点access_token

access_token是有次数限制的 一天2000次 超过了需要刷新accessToken限制次数,10次/月

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/284659
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号