WeChat Official Account Platform exposes REST endpoints for querying broadcast statistics and material quotas. Implementing these interfaces requires managing short-lived access tokens and handling JSON responses with proper error checking.

Authentication Flow

Acess tokens are obtained via the client_credential OAuth2 grant type. Secure your AppID and AppSecret using environment variables rather than embedding them in source code.

public class WeChatMetricsService {
    private static final String AUTH_ENDPOINT = "https://api.weixin.qq.com/cgi-bin/token";
    private static final String METRICS_ENDPOINT = "https://api.weixin.qq.com/cgi-bin/material/get_materialcount";
    
    private final HttpClient transport;
    private final JsonParser jsonParser;
    
    public WeChatMetricsService() {
        this.transport = HttpClient.newBuilder()
            .connectTimeout(Duration.ofSeconds(10))
            .followRedirects(HttpClient.Redirect.NEVER)
            .build();
        this.jsonParser = new JsonParser();
    }
    
    public String authenticate(String applicationId, String applicationSecret) 
            throws IOException, InterruptedException {
        var targetUri = String.format("%s?grant_type=client_credential&appid=%s&secret=%s",
            AUTH_ENDPOINT, applicationId, applicationSecret);
            
        var httpRequest = HttpRequest.newBuilder(URI.create(targetUri))
            .header("Accept", "application/json")
            .GET()
            .build();
            
        var httpResponse = transport.send(httpRequest, BodyHandlers.ofString(StandardCharsets.UTF_8));
        
        if (httpResponse.statusCode() != HttpURLConnection.HTTP_OK) {
            throw new IllegalStateException("Authentication rejected: " + httpResponse.body());
        }
        
        var tokenPayload = jsonParser.parse(httpResponse.body()).getAsJsonObject();
        return tokenPayload.get("access_token").getAsString();
    }
}

Fetching Broadcast Statistics

With a valid token, query the material count endpoint to determine total publication volume across different media types.

public PublicationSummary fetchBroadcastStats(String bearerToken) 
        throws IOException, InterruptedException {
    var resourceUri = String.format("%s?access_token=%s", METRICS_ENDPOINT, bearerToken);
    
    var apiRequest = HttpRequest.newBuilder(URI.create(resourceUri))
        .timeout(Duration.ofSeconds(5))
        .GET()
        .build();
        
    var apiResponse = transport.send(apiRequest, BodyHandlers.ofString());
    var data = jsonParser.parse(apiResponse.body()).getAsJsonObject();
    
    if (data.has("errcode") && data.get("errcode").getAsInt() != 0) {
        throw new RuntimeException("API error: " + data.get("errmsg").getAsString());
    }
    
    return new PublicationSummary(
        data.get("news_count").getAsInt(),
        data.get("image_count").getAsInt(),
        data.get("voice_count").getAsInt(),
        data.get("video_count").getAsInt()
    );
}

public record PublicationSummary(int articleCount, int imageCount, 
                                 int audioCount, int videoCount) {
    public int totalAssets() {
        return articleCount + imageCount + audioCount + videoCount;
    }
}

Execution and Caching Strategy

Access tokens remain valid for 7200 seconds. Store them in a thread-safe cache to minimize authentication requests, which are limited to 2000 invocations per day per account.

public static void main(String[] args) {
    var service = new WeChatMetricsService();
    var appIdentifier = System.getenv("WECHAT_APPID");
    var appKey = System.getenv("WECHAT_APPSECRET");
    
    try {
        var sessionToken = service.authenticate(appIdentifier, appKey);
        var metrics = service.fetchBroadcastStats(sessionToken);
        
        System.out.printf("Published articles: %d%n", metrics.articleCount());
        System.out.printf("Total media library size: %d assets%n", metrics.totalAssets());
        
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        System.err.println("Request interrupted");
    } catch (Exception e) {
        System.err.println("Metrics retrieval failed: " + e.getMessage());
    }
}

Error Handling Considerations

The WeChat API returns HTTP 200 even for logical errors, embedding status codes in the JSON payload. Always verify the errcode field before processing response data. Implement exponential backoff for errcode 45009 (API call quota exceeded) and 42001 (access token expired).