package com.dy.pipirrWebChat.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;

import java.nio.charset.StandardCharsets;
import java.util.List;
//import org.apache.http.client.HttpClient;

/**
 * @author ZhuBaoMin
 * @date 2024-02-23 15:42
 * @LastEditTime 2024-02-23 15:42
 * @Description
 */

@Configuration
public class RestTemplateConfig {
    @Autowired
    private RestTemplateWechatCertConfig restTemplateWechatCertConfig;

    //@Bean
    //public RestTemplate restTemplate() {
    //    return new RestTemplate();
    //}

    //@Bean
    //public RestTemplate restTemplate() {
    //    String mchid = PayInfo.mchid;
    //    RestTemplate restTemplate = null;
    //    try {
    //        KeyStore keyStore = KeyStore.getInstance("PKCS12");
    //        //InputStream cp = this.getClass().getResourceAsStream("apiclient_cert.p12");
    //        FileInputStream instream = new FileInputStream(new File("C:\\webchat\\apiclient_cert.p12"));
    //        keyStore.load(instream, mchid.toCharArray());
    //        // Trust own CA and all self-signed certs
    //        SSLContext sslcontext = SSLContextBuilder.create()
    //                .loadKeyMaterial(keyStore, mchid.toCharArray())
    //                .build();
    //         //Allow TLSv1 protocol only
    //        SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[]{"TLSv1"}, null, NoopHostnameVerifier.INSTANCE);
    //        CloseableHttpClient httpClient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
    //        HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory(httpClient);
    //
    //        restTemplate = new RestTemplate(factory);
    //        //将转换器的编码换成utf-8
    //        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(Charset.forName("utf-8")));
    //        //System.out.println("restTemplate.hashCode():" + restTemplate.hashCode());
    //    } catch (Exception e) {
    //        e.printStackTrace();
    //    }
    //    return restTemplate;
    //}

    //@Bean(name = "wechatRestTemplate")
    @Bean()
    public RestTemplate restTemplate() throws Exception {
        RestTemplate restTemplate = new RestTemplate(restTemplateWechatCertConfig.wechatHttpRequestFactory());
        // 添加拦截器
        //List<ClientHttpRequestInterceptor> interceptors = new ArrayList<>();
        //RestTemplateWechatCertConfig.MyRequestInterceptor myRequestInterceptor = new RestTemplateWechatCertConfig.MyRequestInterceptor();
        //interceptors.add(myRequestInterceptor);
        //restTemplate.setInterceptors(interceptors);

        // 中文乱码，主要是 StringHttpMessageConverter的默认编码为ISO导致的
        List<HttpMessageConverter<?>> list = restTemplate.getMessageConverters();
        for (HttpMessageConverter converter : list) {
            if (converter instanceof StringHttpMessageConverter) {
                ((StringHttpMessageConverter) converter).setDefaultCharset(StandardCharsets.UTF_8);
                break;
            }
        }

        return restTemplate;
    }
}