2023年06月08日20:34:33

wjc

2023-06-08 f5f9d439cfc6b45acc486ec52ed7a0288e92d189

 app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java

@@ -1,4 +1,203 @@
package com.hdl.photovoltaic.internet;

import android.net.Uri;
import android.text.TextUtils;

import androidx.annotation.NonNull;

import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.reflect.TypeToken;
import com.hdl.hdlhttp.utils.GsonConvert;
import com.hdl.photovoltaic.bean.ResponsePack;
import com.hdl.photovoltaic.config.ConfigManagement;
import com.hdl.photovoltaic.listener.BaseSuccessFailureCallBeak;
import com.hdl.photovoltaic.utils.HDLMD5Utils;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Objects;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.FormBody;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

public class HttpClient {

    private static volatile HttpClient sHttpClient;

    public static synchronized HttpClient getInstance() {
        if (sHttpClient == null) {
            synchronized (HttpClient.class) {
                if (sHttpClient == null) {
                    sHttpClient = new HttpClient();
                }
            }

        }
        return sHttpClient;
    }

    /**
     * 请求服务器的方法
     *
     * @param requestUrl     请求接口
     * @param json           请求数据
     * @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
     * @param isExecute      是否是同步(true=同步,false=异步)
     */
    public void requestHttp(String requestUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
        String fullUrl = ConfigManagement.getUserRegionUrl() + requestUrl;
        this.requestHttps(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
    }

    /**
     * 请求服务器的方法(目前只用在获取获取账号区域信息)
     *
     * @param fullUrl        绝对地址(地址+接口)
     * @param json           请求数据
     * @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
     * @param isExecute      是否是同步(true=同步,false=异步)
     */
    public void requestFullHttp(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
        this.requestHttps(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
    }


    /**
     * 请求服务器的方法
     *
     * @param fullUrl        绝对请求地址
     * @param json           请求数据
     * @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
     * @param isExecute      是否是同步(true=同步,false=异步)
     */
    private void requestHttps(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    OkHttpClient okHttpClient = new OkHttpClient();
                    RequestBody requestBody = FormBody.create(MediaType.parse("application/json; charset=utf-8"), getJson(json));
                    final Request request = new Request.Builder()
                            .url(fullUrl)//请求的url//
                            .addHeader("Authorization", "accessToken")
                            .post(requestBody)
                            .build();
                    if (isExecute) {
                        Response response = okHttpClient.newCall(request).execute();//同步
                        if (response.isSuccessful()) {
                            String s = Objects.requireNonNull(response.body()).string();
                            ResponsePack responsePack = new Gson().fromJson(s, ResponsePack.class);
                            baseSuccessCallBeak.onSuccess(responsePack);
                        } else {
                            //throw new IOException("Unexpected code " + response);
                            baseSuccessCallBeak.onFailure(new Exception());
                        }
                    } else {

                        Call call = okHttpClient.newCall(request);
                        call.enqueue(new Callback() {//异步
                            @Override
                            public void onFailure(@NonNull Call call, @NonNull IOException e) {
                                System.out.println("失败" + e.toString());
                            }

                            @Override
                            public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {
                                System.out.println("url连接信息" + response.code());
                                if (response.code() == 200) {
                                    String s = Objects.requireNonNull(response.body()).string();
                                    ResponsePack responsePack = new Gson().fromJson(s, ResponsePack.class);
                                    baseSuccessCallBeak.onSuccess(responsePack);
                                } else {
                                    baseSuccessCallBeak.onFailure(new Exception());
                                }
                            }
                        });
                    }
                } catch (Exception e) {
                    baseSuccessCallBeak.onFailure(e);
                }

            }

        }).start();
    }

    /**
     * 添加sign字段
     */
    private String getJson(String json) {
        final String timestamp = String.valueOf(System.currentTimeMillis());
        final String appKey = ConfigManagement.getAppKey();
        final String appSecret = ConfigManagement.getAppSecret();
        JsonObject jsonObject = new Gson().fromJson(json, JsonObject.class);
        if (jsonObject == null) {
            jsonObject = new JsonObject();
        }
        jsonObject.addProperty("appKey", appKey);
        jsonObject.addProperty("timestamp", timestamp);
        jsonObject.addProperty("sign", getSign(jsonObject, appSecret));

        return jsonObject.toString();
    }

    /**
     * 需要按字母排序
     *
     * @param json 所有字段使用urlParameter拼接，除了appSecret
     */
    private String getSign(JsonObject json, String appSecret) {
        String builder = jsonToUrlParameter(json) +
                appSecret;
        return HDLMD5Utils.encodeMD5(builder);
    }


    private String jsonToUrlParameter(JsonObject object) {
        final Map<String, String> map = GsonConvert.getGson().fromJson(object, new TypeToken<Map<String, String>>() {
        }.getType());
        final Uri.Builder builder = new Uri.Builder();
        List<String> list = new ArrayList<>(map.keySet());
        Collections.sort(list);
        for (String key : list) {
            //判断当前值是否需要参与签名，保持跟云端一致
            if (IfValueNeedSign(map.get(key))) {
                builder.appendQueryParameter(key, map.get(key));
//                HDLSDKLog.e("要签名：" + key + " ：" + map.get(key));
            } else {
//                HDLSDKLog.e("不需要签名：" + key + " ：" + map.get(key));
            }
        }
        return builder.build().getQuery();
    }

    /**
     * 判断当前值是否需要参与签名，保持跟云端一致
     * 空字符串不参与
     * 数组,集合,对象不参与
     *
     * @param valueStr -
     * @return -
     */
    private boolean IfValueNeedSign(String valueStr) {
        if (TextUtils.isEmpty(valueStr))
            return false;
        final char[] strChar = valueStr.substring(0, 1).toCharArray();
        final char firstChar = strChar[0];
        //System.out.println("getJSONType firstChar = "+firstChar);
        if (firstChar != '{' && firstChar != '[')
            return true;

        return false;
    }
}