public <T, E> T execute(RequestExecutor<T, E> executor, String uri, E data) throws WxErrorException {
    int retryTimes = 0;

    while(true) {
        try {
            return this.executeInternal(executor, uri, data);
        } catch (WxErrorException var10) {
            if (retryTimes + 1 > this.maxRetryTimes) {
                log.warn("重试达到最大次数【{}】", this.maxRetryTimes);
                throw new RuntimeException("微信服务端异常，超出重试次数");
            }

            WxError error = var10.getError();
            if (error.getErrorCode() != -1) {
                throw var10;
            }

            int sleepMillis = this.retrySleepMillis * (1 << retryTimes);

            try {
                log.warn("微信系统繁忙，{} ms 后重试(第{}次)", sleepMillis, retryTimes + 1);
                Thread.sleep((long)sleepMillis);
            } catch (InterruptedException var9) {
                throw new RuntimeException(var9);
            }

            if (retryTimes++ >= this.maxRetryTimes) {
                log.warn("重试达到最大次数【{}】", this.maxRetryTimes);
                throw new RuntimeException("微信服务端异常，超出重试次数");
            }
        }
    }
}

protected <T, E> T executeInternal(RequestExecutor<T, E> executor, String uri, E data) throws WxErrorException {
    E dataForLog = DataUtils.handleDataWithSecret(data);
    if (uri.contains("access_token=")) {
        throw new IllegalArgumentException("uri参数中不允许有access_token: " + uri);
    } else {
        String accessToken = this.getAccessToken(false);
        String uriWithAccessToken = uri + (uri.contains("?") ? "&" : "?") + "access_token=" + accessToken;

        try {
            T result = executor.execute(uriWithAccessToken, data, WxType.MP);
            log.debug("\n【请求地址】: {}\n【请求参数】：{}\n【响应数据】：{}", new Object[]{uriWithAccessToken, dataForLog, result});
            return result;
        } catch (WxErrorException var9) {
            WxError error = var9.getError();
            if (error.getErrorCode() == 42001 || error.getErrorCode() == 40001 || error.getErrorCode() == 40014) {
                this.getWxMpConfigStorage().expireAccessToken();
                if (this.getWxMpConfigStorage().autoRefreshToken()) {
                    return this.execute(executor, uri, data);
                }
            }

            if (error.getErrorCode() != 0) {
                log.error("\n【请求地址】: {}\n【请求参数】：{}\n【错误信息】：{}", new Object[]{uriWithAccessToken, dataForLog, error});
                throw new WxErrorException(error, var9);
            } else {
                return null;
            }
        } catch (IOException var10) {
            log.error("\n【请求地址】: {}\n【请求参数】：{}\n【异常信息】：{}", new Object[]{uriWithAccessToken, dataForLog, var10.getMessage()});
            throw new WxErrorException(WxError.builder().errorMsg(var10.getMessage()).build(), var10);
        }
    }
}