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.HxHttp;
|
import com.hdl.hdlhttp.utils.GsonConvert;
|
import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
|
import com.hdl.linkpm.sdk.core.exception.HDLException;
|
import com.hdl.linkpm.sdk.core.interceptor.HDLSmartHeader;
|
import com.hdl.linkpm.sdk.core.response.HDLResponse;
|
import com.hdl.linkpm.sdk.utils.HDLExceptionSubmitUtils;
|
import com.hdl.photovoltaic.bean.HttpResponsePack;
|
import com.hdl.photovoltaic.config.AppConfigManage;
|
import com.hdl.photovoltaic.config.UserConfigManage;
|
import com.hdl.photovoltaic.listener.BaseSuccessFailureCallBeak;
|
import com.hdl.photovoltaic.listener.CloudCallBeak;
|
import com.hdl.photovoltaic.other.HdlLogLogic;
|
import com.hdl.photovoltaic.utils.Md5Utils;
|
|
import java.io.File;
|
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 io.reactivex.rxjava3.disposables.Disposable;
|
import io.reactivex.rxjava3.functions.Consumer;
|
import okhttp3.Call;
|
import okhttp3.Callback;
|
import okhttp3.FormBody;
|
import okhttp3.MediaType;
|
import okhttp3.OkHttpClient;
|
import okhttp3.Request;
|
import okhttp3.RequestBody;
|
import okhttp3.Response;
|
import okhttp3.ResponseBody;
|
|
public class HttpClient {
|
|
private static volatile HttpClient sHttpClient;
|
|
private static final boolean isAddToMemory=false;
|
|
public static synchronized HttpClient getInstance() {
|
if (sHttpClient == null) {
|
synchronized (HttpClient.class) {
|
if (sHttpClient == null) {
|
sHttpClient = new HttpClient();
|
}
|
}
|
|
}
|
return sHttpClient;
|
}
|
|
/**
|
* 请求服务器
|
* 底层方法,引用库的方法
|
*
|
* @param api 请求接口
|
* @param body 请求参数(appKey,timestamp,sign这三个参数内部会自动添加))
|
* @param callBack 回调
|
* @return -
|
*/
|
private Disposable requestPost(String api, String body, CloudCallBeak<String> callBack) {
|
String requestUrl = HDLCloudUserApi.getRequestUrl(api);
|
HdlLogLogic.print("http->发送->" + requestUrl + "\r\n" + body, isAddToMemory);
|
return HxHttp.builder().url(requestUrl).raw(body).build().post().subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String str) {
|
if (callBack != null) {
|
callBack.onSuccess(str);
|
// System.out.println("http->回复->" + requestUrl + "\r\n" + gson.fromJson(str, JsonObject.class).toString());
|
HdlLogLogic.print("http->回复->" + requestUrl + "\r\n" + str, isAddToMemory);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, body, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
HdlLogLogic.print("http->回复->" + requestUrl + "\r\n" + "\"{code=\"" + e.getCode() + "," + "\"message=\"" + e.getMsg() + "}", isAddToMemory);
|
}
|
}
|
});
|
|
}
|
|
/**
|
* 请求服务器
|
* 底层方法,引用库的方法
|
*
|
* @param api 请求接口
|
* @param body 请求参数(appKey,timestamp,sign这三个参数内部会自动添加))
|
* @param callBack 回调
|
* @return -
|
*/
|
private Disposable requestFilePost(String api, File body, CloudCallBeak<String> callBack) {
|
|
|
String requestUrl = HDLCloudUserApi.getRequestUrl(api);
|
HdlLogLogic.print("http->发送->" + requestUrl + "\r\n" + body, isAddToMemory);
|
return HxHttp.builder().url(requestUrl).file(body).build().post().subscribeWith(new HDLResponse<String>() {
|
@Override
|
public void onResponse(String str) {
|
if (callBack != null) {
|
callBack.onSuccess(str);
|
// System.out.println("http->回复->" + requestUrl + "\r\n" + gson.fromJson(str, JsonObject.class).toString());
|
HdlLogLogic.print("http->回复->" + requestUrl + "\r\n" + str, isAddToMemory);
|
}
|
}
|
|
@Override
|
public void onFailure(HDLException e) {
|
HDLExceptionSubmitUtils.submit(requestUrl, body, e);
|
if (callBack != null) {
|
callBack.onFailure(e);
|
HdlLogLogic.print("http->回复->" + requestUrl + "\r\n" + "\"{code=\"" + e.getCode() + "," + "\"message=\"" + e.getMsg() + "}", isAddToMemory);
|
}
|
}
|
});
|
|
}
|
|
|
/**
|
* 下载文件
|
*
|
* @param callBack -
|
*/
|
public Disposable downLoadFile(String url, CloudCallBeak<ResponseBody> callBack) {
|
return HxHttp.builder()
|
.url(url)
|
.headers(HDLSmartHeader.IGNORE_SIGN_HEADER, 1)
|
.build()
|
.download()
|
.subscribe(new Consumer<ResponseBody>() {
|
@Override
|
public void accept(ResponseBody responseBody) throws Exception {
|
if (callBack != null) {
|
callBack.onSuccess(responseBody);
|
}
|
}
|
}, new Consumer<Throwable>() {
|
@Override
|
public void accept(Throwable throwable) throws Exception {
|
/**
|
* 网络请求失败
|
* 具体可以自己实现
|
*/
|
HDLExceptionSubmitUtils.submit(url, null, throwable);
|
if (callBack != null) {
|
callBack.onFailure(new HDLException(403, throwable.getMessage()));
|
}
|
}
|
});
|
}
|
|
|
/**
|
* 请求服务器
|
*
|
* @param api 请求接口
|
* @param body 请求参数(json)
|
* @param callBack 回调
|
*/
|
public Disposable requestHttp(String api, String body, CloudCallBeak<String> callBack) {
|
return requestPost(api, body, callBack);
|
}
|
|
/**
|
* 上传文件
|
*
|
* @param api 请求接口
|
* @param body 请求参数(json)
|
* @param callBack 回调
|
*/
|
public Disposable uploadingFile(String api, File body, CloudCallBeak<String> callBack) {
|
return requestFilePost(api, body, callBack);
|
}
|
|
|
/**
|
* 请求服务器的方法(已弃用)
|
*
|
* @param requestUrl 请求接口
|
* @param json 请求数据
|
* @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
|
* @param isExecute 是否是同步(true=同步,false=异步)
|
*/
|
@Deprecated
|
private void requestHttp(String requestUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
|
String fullUrl = AppConfigManage.getUserRegionUrl() + requestUrl;
|
this.requestHttpServer(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
|
}
|
|
/**
|
* 请求服务器的方法(已弃用)
|
* 目前只用在获取获取账号区域信息
|
*
|
* @param fullUrl 绝对地址(地址+接口)
|
* @param json 请求数据
|
* @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
|
* @param isExecute 是否是同步(true=同步,false=异步)
|
*/
|
@Deprecated
|
private void requestFullHttp(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
|
this.requestHttpServer(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
|
}
|
|
/**
|
* get方法请求
|
*
|
* @param url http地址
|
* @param cloudCallBeak 回调
|
*/
|
public void requestHttpGet(String url, CloudCallBeak<String> cloudCallBeak) {
|
this.requestHttpServer(url, cloudCallBeak);
|
}
|
|
|
/**
|
* 请求服务器的方法
|
*
|
* @param fullUrl 绝对请求地址
|
* @param json 请求数据
|
* @param isBasicService 是否是基础服务的接口(基础服务的接口需要 appKey,timestamp,sign这三个参数,当为true时,内部会自动添加)
|
* @param isExecute 是否是同步(true=同步,false=异步)
|
*/
|
private void requestHttpServer(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
HdlLogLogic.print("http->发送->" + fullUrl + "\r\n" + json, isAddToMemory);
|
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", UserConfigManage.getInstance().getHeaderPrefix() + UserConfigManage.getInstance().getToken()).post(requestBody).build();
|
if (isExecute) {
|
Response response = okHttpClient.newCall(request).execute();//同步
|
if (response.isSuccessful()) {
|
String s = Objects.requireNonNull(response.body()).string();
|
HttpResponsePack httpResponsePack = new Gson().fromJson(s, HttpResponsePack.class);
|
HdlLogLogic.print("http->回复->" + response.request().url() + "\r\n" + s, isAddToMemory);
|
baseSuccessCallBeak.onSuccess(httpResponsePack);
|
|
} else {
|
//throw new IOException("Unexpected code " + response);
|
baseSuccessCallBeak.onFailure(new HDLException(response.code(), response.message()));
|
}
|
} else {
|
|
Call call = okHttpClient.newCall(request);
|
call.enqueue(new Callback() {//异步
|
@Override
|
public void onFailure(@NonNull Call call, @NonNull IOException e) {
|
HdlLogLogic.print("http->回复->" + "\r\n" + e.getMessage(), isAddToMemory);
|
}
|
|
@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();
|
HttpResponsePack httpResponsePack = new Gson().fromJson(s, HttpResponsePack.class);
|
baseSuccessCallBeak.onSuccess(httpResponsePack);
|
HdlLogLogic.print("http->回复->" + "\r\n" + s, isAddToMemory);
|
} else {
|
baseSuccessCallBeak.onFailure(new HDLException(response.code(), response.message()));
|
}
|
}
|
});
|
}
|
} catch (Exception e) {
|
baseSuccessCallBeak.onFailure(new HDLException(-100, e.getMessage()));
|
HdlLogLogic.print("http->回复->" + "\r\n" + e.getMessage(), isAddToMemory);
|
}
|
|
}
|
}).start();
|
}
|
|
/**
|
* 请求服务器的方法
|
*
|
* @param url 绝对请求地址
|
*/
|
private void requestHttpServer(String url, CloudCallBeak<String> cloudCallBeak) {
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
OkHttpClient okHttpClient = new OkHttpClient();
|
final Request request = new Request.Builder().url(url).build();
|
try {
|
Response response = okHttpClient.newCall(request).execute();
|
String s = Objects.requireNonNull(response.body()).string();
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(s);
|
}
|
} catch (Exception e) {
|
if (cloudCallBeak != null) {
|
cloudCallBeak.onSuccess(e.getMessage());
|
}
|
|
}
|
}
|
}).start();
|
}
|
|
/**
|
* 添加sign字段
|
*/
|
private String getJson(String json) {
|
final String timestamp = String.valueOf(System.currentTimeMillis());
|
final String appKey = AppConfigManage.getAppKey();
|
final String appSecret = AppConfigManage.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 Md5Utils.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);
|
return firstChar != '{' && firstChar != '[';
|
}
|
}
|
