| | |
| | | } |
| | | } |
| | | |
| | | public String getContactAccessToken() throws IOException { |
| | | String url = String.format("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=%s&corpsecret=%s", |
| | | DataAcquisitionConfiguration.CORPID, |
| | | DataAcquisitionConfiguration.TXL_CORPSECRET); |
| | | |
| | | Request request = new Request.Builder() |
| | | .url(url) |
| | | .get() |
| | | .build(); |
| | | |
| | | try (Response response = client.newCall(request).execute()) { |
| | | if (!response.isSuccessful()) { |
| | | log.error("获取企业微信通讯录access_token失败,HTTP状态码: {}", response.code()); |
| | | throw new IOException("获取通讯录access_token失败: " + response.message()); |
| | | } |
| | | |
| | | String responseBody = response.body().string(); |
| | | WorkWXTokenResponse tokenResponse = objectMapper.readValue(responseBody, WorkWXTokenResponse.class); |
| | | |
| | | if (tokenResponse.getErrcode() != 0) { |
| | | log.error("获取企业微信通讯录access_token失败,错误码: {}, 错误信息: {}", |
| | | tokenResponse.getErrcode(), tokenResponse.getErrmsg()); |
| | | throw new IOException("获取通讯录access_token失败: " + tokenResponse.getErrmsg()); |
| | | } |
| | | |
| | | log.info("成功获取企业微信通讯录access_token,有效期: {}秒", tokenResponse.getExpiresIn()); |
| | | return tokenResponse.getAccessToken(); |
| | | } |
| | | } |
| | | |
| | | public String getUserIdByMobile(String mobile) throws IOException { |
| | | String accessToken = getAccessToken(); |
| | | String accessToken = getContactAccessToken(); |
| | | String url = String.format("https://qyapi.weixin.qq.com/cgi-bin/user/getuserid?access_token=%s", accessToken); |
| | | |
| | | Map<String, Object> requestBody = new HashMap<>(); |
| | |
| | | } |
| | | |
| | | public List<WorkWXUser> getUserList() throws IOException { |
| | | String accessToken = getAccessToken(); |
| | | String accessToken = getContactAccessToken(); |
| | | String url = String.format( |
| | | "https://qyapi.weixin.qq.com/cgi-bin/user/simplelist?access_token=%s&department_id=1&fetch_child=1", |
| | | accessToken); |