|
@@ -41,7 +41,7 @@ public class WxAccessTokenRemoteService {
|
|
|
.build(new CacheLoader<String, String>() {
|
|
|
@Override
|
|
|
public String load(String s) throws Exception {
|
|
|
- return getAccessToken(s);
|
|
|
+ return loadAccessToken(s);
|
|
|
}
|
|
|
});
|
|
|
|
|
@@ -54,7 +54,6 @@ public class WxAccessTokenRemoteService {
|
|
|
}
|
|
|
|
|
|
private String loadAccessToken(String gzhId) {
|
|
|
-
|
|
|
try {
|
|
|
Map<String, Object> param = new HashMap<>();
|
|
|
param.put("grant_type", "client_credential");
|
|
@@ -82,37 +81,4 @@ public class WxAccessTokenRemoteService {
|
|
|
}
|
|
|
return null;
|
|
|
}
|
|
|
-
|
|
|
- public WxUserGetResponse getAllUserLimit10000(String gzhId, String nextOpenId) {
|
|
|
- try {
|
|
|
-
|
|
|
- String accessToken = accessTokenMap.get(gzhId);
|
|
|
- if (StringUtils.isBlank(accessToken)) {
|
|
|
- log.error("gzh {} access_token not config", gzhId);
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- URIBuilder uriBuilder = new URIBuilder("https://api.weixin.qq.com/cgi-bin/user/get");
|
|
|
- uriBuilder.setParameter("gzhId", gzhId); // 假设需要传递gzhId参数
|
|
|
- uriBuilder.setParameter("access_token", accessToken);
|
|
|
- uriBuilder.setParameter("next_openid", nextOpenId);
|
|
|
- HttpGet httpGet = new HttpGet();
|
|
|
- httpGet.setURI(uriBuilder.build());
|
|
|
-
|
|
|
- CloseableHttpResponse response = client.execute(httpGet);
|
|
|
- StatusLine statusLine = response.getStatusLine();
|
|
|
- if (statusLine.getStatusCode() == 200) {
|
|
|
- HttpEntity responseEntity = response.getEntity();
|
|
|
- if (Objects.nonNull(responseEntity)) {
|
|
|
- String responseBody = EntityUtils.toString(responseEntity, "UTF-8");
|
|
|
- return JSONUtils.fromJson(responseBody, new TypeToken<WxUserGetResponse>() {
|
|
|
- }, null);
|
|
|
- }
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("get user error gzhId={} nextOpenId={} ", gzhId, nextOpenId, e);
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
}
|