OkHttpUtils 请求及解析需要Gson依赖 ResultCallback

野性酷女 2023-10-09 22:24 35阅读 0赞

import android.util.Log;
    
    import androidx.annotation.NonNull;
    
    import com.blankj.utilcode.util.ActivityUtils;
    import com.blankj.utilcode.util.FileUtils;
    import com.blankj.utilcode.util.GsonUtils;
    import com.google.gson.Gson;
    import com.google.gson.JsonSyntaxException;
    import com.google.gson.reflect.TypeToken; 
    
    import java.io.File;
    import java.io.FileOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.lang.reflect.Type;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
     
    import okhttp3.Call;
    import okhttp3.Callback;
    import okhttp3.FormBody;
    import okhttp3.HttpUrl;
    import okhttp3.MediaType;
    import okhttp3.MultipartBody;
    import okhttp3.OkHttpClient;
    import okhttp3.Request;
    import okhttp3.RequestBody;
    import okhttp3.Response;
    import okhttp3.ResponseBody;
    
    public class NetUtils {
        private static OkHttpClient client = new OkHttpClient();
        private static Gson gson = new Gson();
    
        public static <T> void getRequest(String url, Map<String, String> params, final Class<T> clazz, final OnResponseCallback<T> callback) {
            url = SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, Constants.HTTP_BASE_URL) + "/hbhw-boot" + url;
            HttpUrl.Builder urlBuilder = HttpUrl.parse(url).newBuilder();
            if (params != null) {
                for (Map.Entry<String, String> entry : params.entrySet()) {
                    urlBuilder.addQueryParameter(entry.getKey(), entry.getValue());
                }
            }
            Request request = new Request.Builder()
                    .url(urlBuilder.build())
                    .build();
            executeRequest(OtherUtils.getString(params), request, clazz, callback);
        }
    
        public static <T> void getRequest(String url, final Class<T> clazz, final OnResponseCallback<T> callback) {
            Request request = new Request.Builder()
                    .url(url)
                    .build();
            executeRequest(url, request, clazz, callback);
        }
    
        public static <T> void postRequest(String url, Map<String, String> params, final Class<T> clazz, final OnResponseCallback<T> callback) {
            FormBody.Builder formBodyBuilder = new FormBody.Builder();
            for (Map.Entry<String, String> entry : params.entrySet()) {
                formBodyBuilder.add(entry.getKey(), entry.getValue());
            }
            RequestBody requestBody = formBodyBuilder.build();
            Request request = new Request.Builder()
                    .url(url)
                    .post(requestBody)
                    .build();
            executeRequest(OtherUtils.getString(params), request, clazz, callback);
        }
    
        public static <T> void postRequest(String url, String json, final Class<T> clazz, final OnResponseCallback<T> callback) {
    
            MediaType JSON = MediaType.parse("application/json; charset=utf-8");
            RequestBody requestBody = RequestBody.create(JSON, json);
            Request request = new Request.Builder()
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + url)
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .post(requestBody)
                    .build();
            executeRequest(json, request, clazz, callback);
        }
    
        public static <T> void postRequest(IRequest iRequest, final Type type, final OnResponseCallback<T> callback) {
            MediaType JSON = MediaType.parse("application/json; charset=utf-8");
            RequestBody requestBody = RequestBody.create(JSON, iRequest.toJson());
            Request request = new Request.Builder()
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + iRequest.getApi())
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .post(requestBody)
                    .build();
            executeRequest(iRequest.toJson(), request, type, callback);
        }
    
        public static <T> void putRequest(IRequest iRequest, final Class<T> clazz, final OnResponseCallback<T> callback) {
            MediaType JSON = MediaType.parse("application/json; charset=utf-8");
            RequestBody requestBody = RequestBody.create(JSON, iRequest.toJson());
            Request request = new Request.Builder()
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + iRequest.getApi())
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .put(requestBody)
                    .build();
            executeRequest(iRequest.toJson(), request, clazz, callback);
        }
    
        public static <T> void getRequest(IRequest iRequest, final Type type, final OnResponseCallback<T> callback) {
            String urlParams = OtherUtils.jsonToUrlParams(iRequest.toJson());
            Request request = new Request.Builder()
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + iRequest.getApi() + "?" + urlParams)
                    .build();
            executeRequest(iRequest.toJson(), request, type, callback);
        }
    
        public static <T> void getRequestStr(IRequest iRequest, final OnResponseCallback<T> callback) {
            String urlParams = OtherUtils.jsonToUrlParams(iRequest.toJson());
            Request request = new Request.Builder()
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + iRequest.getApi() + "?" + urlParams)
                    .build();
            client.newCall(request).enqueue(new Callback() {
    
                @Override
                public void onFailure(Call call, IOException e) {
                    if (callback != null) {
                        callback.onFailure(e.getMessage());
                    }
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    String json = response.body().string();
                    Log.i("网络请求", "请求地址:  " + call.request().url());
                    Log.i("网络请求", "请求参数:  " + urlParams);
                    Log.i("网络请求", "响应数据:  " + json);
                    UIUtils.runOnUIThread(() -> {
                        callback.onSuccessStr(json);
                    });
                }
            });
        }
    
        public static <T> void delRequest(IRequest iRequest, final Type type, final OnResponseCallback<T> callback) {
            String urlParams = OtherUtils.jsonToUrlParams(iRequest.toJson());
            Request request = new Request.Builder()
                    .header("X-Access-Token", SpUtils.getStr(SpUtils.KEY_TOKEN, ""))
                    .url(SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, "") + iRequest.getApi() + "?" + urlParams)
                    .delete()
                    .build();
            executeRequest(iRequest.toJson(), request, type, callback);
        }
    
        private static <T> void executeRequest(String args, Request request, final Type type, final OnResponseCallback<T> callback) {
            client.newCall(request).enqueue(new Callback() {
    
                @Override
                public void onFailure(Call call, IOException e) {
                    if (callback != null) {
                        callback.onFailure(e.getMessage());
                    }
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    String json = response.body().string();
                    UIUtils.runOnUIThread(() -> {
                        BaseBean<T> baseBean = gson.fromJson(json, TypeToken.getParameterized(BaseBean.class, type).getType());
                        if (response.isSuccessful()) {
                            Log.i("网络请求", "请求地址:  " + call.request().url());
                            Log.i("网络请求", "请求参数:  " + args);
                            XLogUtil.i("网络请求", "响应数据:  " + json);
                            try {
    
                                if (baseBean != null) {
                                    if (baseBean.getCode() == 200) {
                                        if (callback != null) {
                                            callback.onSuccess(baseBean.getResult());
                                        }
                                    } else {
                                        if (callback != null) {
                                            callback.onFailure(baseBean.getMessage());
                                        }
                                    }
                                } else {
                                    if (callback != null) {
                                        callback.onFailure("解析失败");
                                    }
                                }
                            } catch (JsonSyntaxException e) {
                                if (callback != null) {
                                    callback.onFailure("解析异常");
                                }
                            }
                        } else {
                            if (callback != null) {
                                if (response.code() == 401) {
                                    SpUtils.remove(SpUtils.KEY_TOKEN);
                                    //Token失效 返回登录页
                                    ActivityUtils.finishAllActivities();
                                    ActivityUtils.startActivity(LoginActivity.class);
                                }
                                KLog.i("请求失败:  " + json);
                                callback.onFailure("请求失败: " + baseBean.getMessage());
                            }
                        }
                    });
                }
            });
        }
    
        public static Type getListType(@NonNull final Type type) {
            return TypeToken.getParameterized(List.class, type).getType();
        }
    
        public interface OnResponseCallback<T> {
            void onSuccess(T result);
    
            default void onSuccessStr(String result) {
            }
    
            void onFailure(String errorMsg);
        }
    
        public static void postFile(String url, String path, Map<String, String> args, Callback callback) {
            url = SpUtils.getStr(SpUtils.KEY_HTTP_BASE_URL, Constants.HTTP_BASE_URL) + "/hbhw-boot" + url;
            OkHttpClient client = new OkHttpClient();
            File file = new File(path);
            // 创建一个RequestBody，封装文件和文件类型
            RequestBody fileBody = RequestBody.create(MediaType.parse("application/octet-stream"), file);
            // 创建一个MultipartBody.Builder，设置请求类型为Multipart
            MultipartBody.Builder builder = new MultipartBody.Builder()
                    .setType(MultipartBody.FORM)
                    .addFormDataPart("file", file.getName(), fileBody); // 添加文件
            if (args != null) {
                for (String key : args.keySet()) {
                    builder.addFormDataPart(key, args.get(key));
                }
            }
    
            // 构建请求体
            RequestBody requestBody = builder.build();
    
            // 构建请求
            Request request = new Request.Builder()
                    .url(url)
                    .post(requestBody)
                    .build();
    
            // 发送请求
            // 发送异步请求
            client.newCall(request).enqueue(callback);
        }
    
        /**
         * 上传文件
         */
        public static void postFile(String path) {
            if (path == null) {
                return;
            }
            String fileName = FileUtils.getFileName(path);
    
            Map<String, String> args = new HashMap<>();
            args.put("eqId", DeviceInfoUtils.getDeviceId());
            args.put("XPoint", GdUtils.getInstance().getxPointLatitude());
            args.put("YPoint", GdUtils.getInstance().getyPointLongitude());
            args.put("objType", fileName.endsWith(".mp4") ? "0" : "1");
            NetUtils.postFile("/sys/hmtObjMinio/photoStoryUpload", path, args, new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                    e.printStackTrace();
                    Log.e("调试信息", "onFailure: ", e);
                    WsUtils.getInstance().send(new SendPostFileErr(fileName));
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    ResponseBody body = response.body();
                    if (body == null) {
                        WsUtils.getInstance().send(new SendPostFileErr(fileName));
                        return;
                    }
                    String string = body.string();
                    PostFileBen fileBen = GsonUtils.fromJson(string, PostFileBen.class);
                    if (fileBen.getStatus()) {
                        // 上传成功后需要删除本地视频
    //                        FileUtils.delete(path);
                        //告知ws发送文件成功
                        WsUtils.getInstance().send(new SendFileSuccess(fileName, fileBen.getData().getUrl()));
                        KLog.i("文件上传成功，服务器响应: " + string);
                    } else {
                        WsUtils.getInstance().send(new SendPostFileErr(fileName));
                        KLog.i("文件上传失败，服务器响应: " + string);
                    }
                }
            });
        }
    
        public interface DownloadListener {
            void onDownloadSuccess(File file);
    
            void onDownloadFailed(Exception e);
    
            default void onDownloading(int progress) {
    
            }
        }
    
        public static void downloadFile(String url, final String saveDir, final DownloadListener listener) {
            Request request = new Request.Builder().url(url).build();
            OkHttpClient okHttpClient = new OkHttpClient();
            okHttpClient.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                    if (listener != null) {
                        listener.onDownloadFailed(e);
                    }
                }
    
                @Override
                public void onResponse(Call call, Response response) throws IOException {
                    InputStream inputStream = null;
                    FileOutputStream fos = null;
                    try {
                        inputStream = response.body().byteStream();
                        long total = response.body().contentLength();
                        File file = new File(saveDir, getFileName(url));
                        fos = new FileOutputStream(file);
    
                        byte[] buffer = new byte[2048];
                        int len;
                        long sum = 0;
                        while ((len = inputStream.read(buffer)) != -1) {
                            fos.write(buffer, 0, len);
                            sum += len;
                            int progress = (int) (sum * 1.0f / total * 100);
                            // 下载中
                            listener.onDownloading(progress);
                        }
                        fos.flush();
    
                        if (listener != null) {
                            listener.onDownloadSuccess(file);
                        }
                    } catch (IOException e) {
                        if (listener != null) {
                            listener.onDownloadFailed(e);
                        }
                    } finally {
                        try {
                            if (inputStream != null) {
                                inputStream.close();
                            }
                            if (fos != null) {
                                fos.close();
                            }
                        } catch (IOException e) {
                            if (listener != null) {
                                listener.onDownloadFailed(e);
                            }
                        }
                    }
                }
            });
        }
    
        private static String getFileName(String url) {
            return url.substring(url.lastIndexOf("/") + 1);
        }
    
    }

import android.util.Log;
    
    import com.blankj.utilcode.util.LogUtils;
    import com.blankj.utilcode.util.ToastUtils;
    import com.google.gson.Gson;
    import com.google.gson.reflect.TypeToken;
    import com.zhy.http.okhttp.callback.Callback;
    
    import java.lang.reflect.Type;
    import java.net.SocketException;
    import java.net.SocketTimeoutException;
    
    import okhttp3.Call;
    import okhttp3.ResponseBody;
    
    /**
     * ================================================
     * 作    者：Mi
     * 版    本：1.0
     * 创建日期：2023年5月8日 16:44:44
     * 描    述：默认将返回的数据解析成需要的Bean,可以是 BaseBean，String，List，Map
     * 修订历史：
     * ================================================
     */
    public abstract class ResultCallback<T> extends Callback<BaseBean<T>> {
        public ResultCallback() {
    
        }
    
        @Override
        public BaseBean<T> parseNetworkResponse(okhttp3.Response response, int id) throws Exception {
            ResponseBody body = response.body();
            if (body != null) {
                try {
                    String string = body.string();
                    Log.i("调试信息", "return data:  " + string);
                    Gson gson = new Gson();
                    Type type = new TypeToken<BaseBean<T>>() {
                    }.getType();
                    BaseBean<T> apiResponse = gson.fromJson(string, type);
                    Log.i("调试信息", "parseNetworkResponse:  " + new Gson().toJson(apiResponse));
                    return apiResponse;
                } catch (Throwable throwable) {
                    LogUtils.e(throwable.getMessage());
                }
            }
            return null;
        }
    
        @Override
        public void onError(Call call, Exception e, int id) {
            //记录一下错误日志
    //        call.request().url()
            if (e instanceof SocketTimeoutException) {
                ToastUtils.showShort("请求超时");
            } else if (e instanceof SocketException) {
                ToastUtils.showShort("服务器异常");
            }
            onError(call, e);
            LogUtils.e(e);
        }
    
        @Override
        public void onResponse(BaseBean<T> response, int id) {
            LogUtils.e("响应成功");
            if (response == null) {
                LogUtils.e("解析后的数据为空");
                return;
            }
            // TODO: 2023/5/8 这里需要根据实际编写
            if (response.isStatus()) {
                onSuccess(response);
            } else {
                //提示一下
                onFailure(response);
            }
        }
    
        public abstract void onSuccess(BaseBean<T> data);
    
        public abstract void onError(Call call, Exception e);
    
        public void onFailure(BaseBean<T> response) {
            //这里可以提示一下,写个toast.
            ToastUtils.showShort(response.getMsg());
        }
    
    }

import java.io.Serializable;
    
    public class BaseBean<T> implements Serializable {
        private int code;
        private T data;
        private String msg;
        private boolean status;
        private String msg_code;
    
        public int getCode() {
            return code;
        }
    
        public void setCode(int code) {
            this.code = code;
        }
    
        public T getData() {
            return data;
        }
    
        public void setData(T data) {
            this.data = data;
        }
    
        public String getMsg() {
            return msg;
        }
    
        public void setMsg(String msg) {
            this.msg = msg;
        }
    
        public boolean isStatus() {
            return status;
        }
    
        public void setStatus(boolean status) {
            this.status = status;
        }
    
        public String getMsg_code() {
            return msg_code;
        }
    
        public void setMsg_code(String msg_code) {
            this.msg_code = msg_code;
        }
    }

import com.google.gson.annotations.SerializedName;
    
    public class Data {
        @SerializedName("con23fig")
        private String config;
        @SerializedName("notice_switch")
        private String noticch;
        @SerializedName("ai_broadcast")
        private String aiBroadcast;
        @SerializedName("model_switch")
    
        //get set省略
    }