From a59bbb7890e107a681f677765f2600e278c06a0d Mon Sep 17 00:00:00 2001
From: mac <user@users-MacBook-Pro.local>
Date: 星期一, 09 十月 2023 10:16:37 +0800
Subject: [PATCH] 2023年10月09日10:16:35

---
 app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java |   46 ++++++++++++++++++++++++++++++----------------
 1 files changed, 30 insertions(+), 16 deletions(-)

diff --git a/app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java b/app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java
index 850f6cb..eab83ff 100644
--- a/app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java
+++ b/app/src/main/java/com/hdl/photovoltaic/internet/HttpClient.java
@@ -9,6 +9,7 @@
 import com.google.gson.JsonObject;
 import com.google.gson.reflect.TypeToken;
 import com.hdl.hdlhttp.HxHttp;
+import com.hdl.hdlhttp.HxHttpBuilder;
 import com.hdl.hdlhttp.utils.GsonConvert;
 import com.hdl.linkpm.sdk.core.api.HDLCloudUserApi;
 import com.hdl.linkpm.sdk.core.exception.HDLException;
@@ -20,6 +21,7 @@
 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.HDLMD5Utils;
 
@@ -34,6 +36,7 @@
 import okhttp3.Call;
 import okhttp3.Callback;
 import okhttp3.FormBody;
+import okhttp3.Headers;
 import okhttp3.MediaType;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
@@ -61,22 +64,28 @@
      * 搴曞眰鏂规硶,寮曠敤搴撶殑鏂规硶
      *
      * @param api      璇锋眰鎺ュ彛
-     * @param body     璇锋眰鍙傛暟
+     * @param body     璇锋眰鍙傛暟(appKey,timestamp,sign杩欎笁涓弬鏁板唴閮ㄤ細鑷姩娣诲姞))
      * @param callBack 鍥炶皟
      * @return -
      */
-    private Disposable request(String api, String body, BaseSuccessFailureCallBeak callBack) {
+    private Disposable request(String api, String body, CloudCallBeak<String> callBack) {
+
+
         String requestUrl = HDLCloudUserApi.getRequestUrl(api);
+        Gson gson = new Gson();
+        System.out.println("鍙戦��->" + requestUrl + "\r\n" + body);
         return HxHttp.builder()
                 .url(requestUrl)
                 .raw(body)
                 .build()
                 .post()
-                .subscribeWith(new HDLResponse<HttpResponsePack>() {
+                .subscribeWith(new HDLResponse<String>() {
                     @Override
-                    public void onResponse(HttpResponsePack response) {
+                    public void onResponse(String str) {
                         if (callBack != null) {
-                            callBack.onSuccess(response);
+                            callBack.onSuccess(str);
+//                          System.out.println("鍥炲->" + requestUrl + "\r\n" + gson.fromJson(str, JsonObject.class).toString());
+                            System.out.println("鍥炲->" + requestUrl + "\r\n" + str);
                         }
                     }
 
@@ -85,11 +94,13 @@
                         HDLExceptionSubmitUtils.submit(requestUrl, body, e);
                         if (callBack != null) {
                             callBack.onFailure(e);
+                            System.out.println("鍥炲->" + requestUrl + "\r\n" + "\"{code=\"" + e.getCode() + "," + "\"message=\"" + e.getMsg() + "}");
                         }
                     }
                 });
 
     }
+
 
     /**
      * 璇锋眰鏈嶅姟鍣�
@@ -98,33 +109,36 @@
      * @param body     璇锋眰鍙傛暟(json)
      * @param callBack 鍥炶皟
      */
-    public Disposable requestHttp(String api, String body, BaseSuccessFailureCallBeak callBack) {
+    public Disposable requestHttp(String api, String body, CloudCallBeak<String> callBack) {
         return request(api, body, callBack);
     }
 
     /**
-     * 璇锋眰鏈嶅姟鍣ㄧ殑鏂规硶
+     * 璇锋眰鏈嶅姟鍣ㄧ殑鏂规硶(宸插純鐢�)
      *
      * @param requestUrl     璇锋眰鎺ュ彛
      * @param json           璇锋眰鏁版嵁
      * @param isBasicService 鏄惁鏄熀纭�鏈嶅姟鐨勬帴鍙�(鍩虹鏈嶅姟鐨勬帴鍙i渶瑕� appKey,timestamp,sign杩欎笁涓弬鏁�,褰撲负true鏃�,鍐呴儴浼氳嚜鍔ㄦ坊鍔�)
      * @param isExecute      鏄惁鏄悓姝�(true=鍚屾,false=寮傛)
      */
-    public void requestHttp(String requestUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
+    @Deprecated
+    private void requestHttp(String requestUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
         String fullUrl = AppConfigManage.getUserRegionUrl() + requestUrl;
-        this.requestHttps(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
+        this.requestHttpServer(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
     }
 
     /**
-     * 璇锋眰鏈嶅姟鍣ㄧ殑鏂规硶(鐩墠鍙敤鍦ㄨ幏鍙栬幏鍙栬处鍙峰尯鍩熶俊鎭�)
+     * 璇锋眰鏈嶅姟鍣ㄧ殑鏂规硶(宸插純鐢�)
+     * 鐩墠鍙敤鍦ㄨ幏鍙栬幏鍙栬处鍙峰尯鍩熶俊鎭�
      *
      * @param fullUrl        缁濆鍦板潃(鍦板潃+鎺ュ彛)
      * @param json           璇锋眰鏁版嵁
      * @param isBasicService 鏄惁鏄熀纭�鏈嶅姟鐨勬帴鍙�(鍩虹鏈嶅姟鐨勬帴鍙i渶瑕� 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);
+    @Deprecated
+    private void requestFullHttp(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
+        this.requestHttpServer(fullUrl, json, isBasicService, isExecute, baseSuccessCallBeak);
     }
 
     /**
@@ -135,7 +149,7 @@
      * @param isBasicService 鏄惁鏄熀纭�鏈嶅姟鐨勬帴鍙�(鍩虹鏈嶅姟鐨勬帴鍙i渶瑕� appKey,timestamp,sign杩欎笁涓弬鏁�,褰撲负true鏃�,鍐呴儴浼氳嚜鍔ㄦ坊鍔�)
      * @param isExecute      鏄惁鏄悓姝�(true=鍚屾,false=寮傛)
      */
-    private void requestHttps(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
+    private void requestHttpServer(String fullUrl, String json, boolean isBasicService, boolean isExecute, BaseSuccessFailureCallBeak baseSuccessCallBeak) {
         new Thread(new Runnable() {
             @Override
             public void run() {
@@ -158,7 +172,7 @@
 
                         } else {
                             //throw new IOException("Unexpected code " + response);
-                            baseSuccessCallBeak.onFailure(new Exception());
+                            baseSuccessCallBeak.onFailure(new HDLException(response.code(), response.message()));
                         }
                     } else {
 
@@ -178,13 +192,13 @@
                                     baseSuccessCallBeak.onSuccess(httpResponsePack);
                                     HdlLogLogic.print("http->鍥炲->", "\r\n" + s);
                                 } else {
-                                    baseSuccessCallBeak.onFailure(new Exception());
+                                    baseSuccessCallBeak.onFailure(new HDLException(response.code(), response.message()));
                                 }
                             }
                         });
                     }
                 } catch (Exception e) {
-                    baseSuccessCallBeak.onFailure(e);
+                    baseSuccessCallBeak.onFailure(new HDLException(-100, e.getMessage()));
                     HdlLogLogic.print("http->鍥炲->", "\r\n" + e.getMessage());
                 }
 

--
Gitblit v1.8.0