替换为Okhttp调用网络

修复BT订阅下载失败的问题

pom.xml

@@ -142,7 +142,18 @@
             <artifactId>dom4j</artifactId>
             <version>2.1.4</version>
         </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.12.0</version>
+        </dependency>
 
+        <!-- https://mvnrepository.com/artifact/com.squareup.retrofit2/retrofit -->
+        <dependency>
+            <groupId>com.squareup.retrofit2</groupId>
+            <artifactId>retrofit</artifactId>
+            <version>2.11.0</version>
+        </dependency>
     </dependencies>
 
     <build>
@@ -191,8 +202,8 @@
             <plugin>
                 <artifactId>maven-compiler-plugin</artifactId>
                 <configuration>
-                    <source>1.8</source>
-                    <target>1.8</target>
+                    <source>9</source>
+                    <target>9</target>
                     <compilerArguments>
                         <extdirs>${basedir}/libs</extdirs>
                     </compilerArguments>

src/main/java/com/yutou/nas/Controllers/BTDownloadController.java

@@ -30,7 +30,6 @@ public class BTDownloadController {
     @ResponseBody
     @RequestMapping("/bt/done.do")
     public String done(String path, String filename, String hash1, String hash2, String tid) {
-        Log.i("BTDownloadController.done", "path = " + path + ", filename = " + filename + ", hash1 = " + hash1 + ", hash2 = " + hash2 + ", tid = " + tid);
         //BTDownloadManager.done(path, filename, hash1, hash2, tid);
         try {
             String exec = ConfigTools.load(ConfigTools.CONFIG, "tiny.exec", String.class);

src/main/java/com/yutou/nas/NasApplication.java

@@ -12,7 +12,7 @@ import org.springframework.context.annotation.Import;
 @Import(DmhyRssDownloadManager.class)
 @SpringBootApplication
 public class NasApplication {
-    public static final String version = "1.4";
+    public static final String version = "1.4.2";
 
     public static void main(String[] args) {
         SpringApplication.run(NasApplication.class, args);

src/main/java/com/yutou/nas/okhttp/BaseBean.java

@@ -0,0 +1,6 @@
+package com.yutou.nas.okhttp;
+
+import java.io.Serializable;
+
+public class BaseBean implements Serializable {
+}

src/main/java/com/yutou/nas/okhttp/GetRequestParams.java

@@ -0,0 +1,25 @@
+package com.yutou.nas.okhttp;
+
+
+import okhttp3.HttpUrl;
+import okhttp3.Request;
+
+import java.util.HashMap;
+
+public class GetRequestParams implements IRequestParam {
+    /**
+     * 构建Request
+     *
+     * @param request
+     * @return
+     */
+    @Override
+    public Request getRequest(HashMap<String, String> map, Request request) {
+        //添加公共参数
+        HttpUrl.Builder builder = request.url().newBuilder();
+        for (String key : map.keySet()) {
+            builder.addQueryParameter(key, String.valueOf(map.get(key)));
+        }
+        return request.newBuilder().url(builder.build()).build();
+    }
+}

src/main/java/com/yutou/nas/okhttp/HttpBody.java

@@ -0,0 +1,14 @@
+package com.yutou.nas.okhttp;
+
+import lombok.Data;
+
+@Data
+public class HttpBody<T> {
+    private String msg;
+    private String status;
+    private int code;
+    private int retcode;
+    private T data;
+    private String src;
+
+}

src/main/java/com/yutou/nas/okhttp/HttpCallback.java

@@ -0,0 +1,33 @@
+package com.yutou.nas.okhttp;
+
+import okhttp3.Headers;
+import retrofit2.Call;
+import retrofit2.Callback;
+import retrofit2.Response;
+
+public abstract class HttpCallback<T> implements Callback<HttpBody<T>> {
+
+    public abstract void onResponse(Headers headers,int code, String status, T response, String rawResponse);
+
+    public abstract void onFailure(Throwable throwable);
+
+    @Override
+    public void onResponse(Call<HttpBody<T>> call, Response<HttpBody<T>> response) {
+        if (response.body() != null) {
+            onResponse(
+                    response.headers(),
+                    response.body().getRetcode(),
+                    response.body().getStatus(),
+                    response.body().getData(),
+                    response.body().getSrc()
+            );
+        } else {
+            onFailure(new NullPointerException("response body is null"));
+        }
+    }
+
+    @Override
+    public void onFailure(Call<HttpBody<T>> call, Throwable throwable) {
+        onFailure(throwable);
+    }
+}

src/main/java/com/yutou/nas/okhttp/HttpLoggingInterceptor.java

@@ -0,0 +1,209 @@
+package com.yutou.nas.okhttp;
+
+
+import com.yutou.nas.utils.Log;
+import okhttp3.*;
+import okhttp3.internal.http.HttpHeaders;
+import okio.Buffer;
+
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Logger;
+
+public class HttpLoggingInterceptor implements Interceptor {
+    private static final String TAG = "HttpLogging";
+
+    private static final Charset UTF8 = Charset.forName("UTF-8");
+
+    private volatile Level printLevel = Level.NONE;
+    private java.util.logging.Level colorLevel;
+    private Logger logger;
+
+    private static boolean prLog;
+
+    public static void setLog(boolean log) {
+        prLog = log;
+    }
+
+    public enum Level {
+        NONE,       //不打印log
+        BASIC,      //只打印 请求首行 和 响应首行
+        HEADERS,    //打印请求和响应的所有 Header
+        BODY        //所有数据全部打印
+    }
+
+    public HttpLoggingInterceptor(String tag) {
+        logger = Logger.getLogger(tag);
+        colorLevel = java.util.logging.Level.INFO;
+    }
+
+    public void setPrintLevel(Level level) {
+        if (printLevel == null)
+            throw new NullPointerException("printLevel == null. Use Level.NONE instead.");
+        printLevel = level;
+    }
+
+    public void setColorLevel(java.util.logging.Level level) {
+        colorLevel = level;
+    }
+
+    private void log(String message) {
+        //logger.log(colorLevel, message);
+        if (prLog) {
+            Log.i(TAG, message);
+        }
+        //Log.e(TAG,message);
+    }
+
+    @Override
+    public Response intercept(Chain chain) throws IOException {
+        Request request = chain.request();
+        if (request.body() != null && request.body().contentLength() == 0) {
+            request = chain.call().request();
+        }
+        if (printLevel == Level.NONE) {
+            return chain.proceed(request);
+        }
+
+        //请求日志拦截
+        logForRequest(request, chain.connection());
+
+        //执行请求，计算请求时间
+        long startNs = System.nanoTime();
+        Response response;
+        try {
+            response = chain.proceed(request);
+        } catch (Exception e) {
+            log("<-- HTTP FAILED: " + e);
+            throw e;
+        }
+        long tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs);
+
+        //响应日志拦截
+        return logForResponse(response, tookMs);
+    }
+
+    private void logForRequest(Request request, Connection connection) throws IOException {
+        boolean logBody = (printLevel == Level.BODY);
+        boolean logHeaders = (printLevel == Level.BODY || printLevel == Level.HEADERS);
+        RequestBody requestBody = request.body();
+        boolean hasRequestBody = requestBody != null;
+        Protocol protocol = connection != null ? connection.protocol() : Protocol.HTTP_1_1;
+
+        try {
+            String requestStartMessage = "--> " + request.method() + ' ' + request.url() + ' ' + protocol;
+            log(requestStartMessage);
+
+            if (logHeaders) {
+                if (hasRequestBody) {
+                    // Request body headers are only present when installed as a network interceptor. Force
+                    // them to be included (when available) so there values are known.
+                    if (requestBody.contentType() != null) {
+                        log("\tContent-Type: " + requestBody.contentType());
+                    }
+                    if (requestBody.contentLength() != -1) {
+                        log("\tContent-Length: " + requestBody.contentLength());
+                    }
+                }
+                Headers headers = request.headers();
+                for (int i = 0, count = headers.size(); i < count; i++) {
+                    String name = headers.name(i);
+                    // Skip headers from the request body as they are explicitly logged above.
+                    if (!"Content-Type".equalsIgnoreCase(name) && !"Content-Length".equalsIgnoreCase(name)) {
+                        log("\t" + name + ": " + headers.value(i));
+                    }
+                }
+
+                log(" ");
+                if (logBody && hasRequestBody) {
+                    if (isPlaintext(requestBody.contentType())) {
+                        bodyToString(request);
+                    } else {
+                        log("\tbody: maybe [binary body], omitted!");
+                    }
+                }
+            }
+        } catch (Exception e) {
+            logger.log(java.util.logging.Level.WARNING, e.getMessage(), e);
+        } finally {
+            log("--> END " + request.method());
+        }
+    }
+
+    private Response logForResponse(Response response, long tookMs) {
+        Response.Builder builder = response.newBuilder();
+        Response clone = builder.build();
+        ResponseBody responseBody = clone.body();
+        boolean logBody = (printLevel == Level.BODY);
+        boolean logHeaders = (printLevel == Level.BODY || printLevel == Level.HEADERS);
+
+        try {
+            log("<-- " + clone.code() + ' ' + clone.message() + ' ' + clone.request().url() + " (" + tookMs + "ms）");
+            if (logHeaders) {
+                Headers headers = clone.headers();
+                for (int i = 0, count = headers.size(); i < count; i++) {
+                    log("\t" + headers.name(i) + ": " + headers.value(i));
+                }
+                log(" ");
+                if (logBody && HttpHeaders.hasBody(clone)) {
+                    if (responseBody == null) return response;
+
+                    if (isPlaintext(responseBody.contentType())) {
+                        byte[] bytes = responseBody.byteStream().readAllBytes();
+                        MediaType contentType = responseBody.contentType();
+                        String body = new String(bytes, getCharset(contentType));
+                        log("\tbody:" + body);
+                        responseBody = ResponseBody.create(responseBody.contentType(), bytes);
+                        return response.newBuilder().body(responseBody).build();
+                    } else {
+                        log("\tbody: maybe [binary body], omitted!");
+                    }
+                }
+            }
+        } catch (Exception e) {
+            logger.log(java.util.logging.Level.WARNING, e.getMessage(), e);
+        } finally {
+            log("<-- END HTTP");
+        }
+        return response;
+    }
+
+    private static Charset getCharset(MediaType contentType) {
+        Charset charset = contentType != null ? contentType.charset(UTF8) : UTF8;
+        if (charset == null) charset = UTF8;
+        return charset;
+    }
+
+    /**
+     * Returns true if the body in question probably contains human readable text. Uses a small sample
+     * of code points to detect unicode control characters commonly used in binary file signatures.
+     */
+    private static boolean isPlaintext(MediaType mediaType) {
+        if (mediaType == null) return false;
+        if (mediaType.type() != null && mediaType.type().equals("text")) {
+            return true;
+        }
+        String subtype = mediaType.subtype();
+        if (subtype != null) {
+            subtype = subtype.toLowerCase();
+            if (subtype.contains("x-www-form-urlencoded") || subtype.contains("json") || subtype.contains("xml") || subtype.contains("html")) //
+                return true;
+        }
+        return false;
+    }
+
+    private void bodyToString(Request request) {
+        try {
+            Request copy = request.newBuilder().build();
+            RequestBody body = copy.body();
+            if (body == null) return;
+            Buffer buffer = new Buffer();
+            body.writeTo(buffer);
+            Charset charset = getCharset(body.contentType());
+            log("\tbody:" + buffer.readString(charset));
+        } catch (Exception e) {
+            logger.log(java.util.logging.Level.WARNING, e.getMessage(), e);
+        }
+    }
+}

src/main/java/com/yutou/nas/okhttp/IRequestParam.java

@@ -0,0 +1,9 @@
+package com.yutou.nas.okhttp;
+
+import okhttp3.Request;
+
+import java.util.HashMap;
+
+public interface IRequestParam {
+    Request getRequest(HashMap<String,String> map, Request request);
+}

src/main/java/com/yutou/nas/okhttp/ParamsContext.java

@@ -0,0 +1,31 @@
+package com.yutou.nas.okhttp;
+
+import okhttp3.Request;
+
+import java.util.HashMap;
+
+public class ParamsContext {
+    private IRequestParam iRequestParam;
+    private Request request;
+    private HashMap<String,String> map;
+
+    public ParamsContext(HashMap<String,String> map,Request request) {
+        if(map==null){
+            map=new HashMap<>();
+        }
+        this.map=map;
+        this.request = request;
+    }
+
+    public Request getInRequest() {
+        switch (request.method()) {
+            case "GET":
+                iRequestParam = new GetRequestParams();
+                break;
+            case "POST":
+                iRequestParam = new PostRequestParams();
+                break;
+        }
+        return iRequestParam.getRequest(map,request);
+    }
+}

src/main/java/com/yutou/nas/okhttp/PostRequestParams.java

@@ -0,0 +1,69 @@
+package com.yutou.nas.okhttp;
+
+
+import com.alibaba.fastjson2.JSONObject;
+import okhttp3.FormBody;
+import okhttp3.MediaType;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+
+import java.net.URLEncoder;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+public class PostRequestParams implements IRequestParam {
+    @Override
+    public Request getRequest(HashMap<String, String> map, Request request) {
+        if (request.body() instanceof FormBody) {
+            FormBody.Builder bodyBuilder = new FormBody.Builder();
+            FormBody formBody = (FormBody) request.body();
+
+            for (int i = 0; i < formBody.size(); i++) {
+                bodyBuilder.addEncoded(formBody.encodedName(i), formBody.encodedValue(i));
+            }
+            for (String key : map.keySet()) {
+                bodyBuilder.addEncoded(key, String.valueOf(map.get(key)));
+            }
+            formBody = bodyBuilder.build();
+            request = request.newBuilder().post(formBody).build();
+        } else if (request.body() != null) {
+            RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"),toUrlParams(map));
+            request = request.newBuilder().post(request.body())
+                    .post(requestBody).build();
+        }
+        return request;
+    }
+
+    public static String toUrlParams(JSONObject json) {
+        StringBuilder string = new StringBuilder();
+        Set<String> keys = json.keySet();
+        for (String key : keys) {
+            try {
+                string.append("&").append(key).append("=").append(URLEncoder.encode(json.getString(key), "UTF-8"));
+            } catch (Exception e) {
+                e.printStackTrace();
+                try {
+                    string.append("&").append(URLEncoder.encode(key,"UTF-8")).append("=");
+                    //    string += "&" + key + "=";
+                } catch (Exception e1) {
+                    string.append("&").append(key).append("=");
+                }
+            }
+        }
+
+        string = new StringBuilder(string.substring(1, string.length()).replaceAll(" ", ""));
+        return string.toString();
+    }
+
+    public static String toUrlParams(Map<String, String> map) {
+        if(map.isEmpty()){
+            return "";
+        }
+        StringBuilder builder = new StringBuilder();
+        for (String key : map.keySet()) {
+            builder.append(key).append("=").append(map.get(key)).append("&");
+        }
+        return builder.substring(0, builder.length() - 1);
+    }
+}

src/main/java/com/yutou/nas/okhttp/api/BaseApi.java

@@ -0,0 +1,101 @@
+package com.yutou.nas.okhttp.api;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.internal.bind.DateTypeAdapter;
+import com.yutou.nas.okhttp.HttpLoggingInterceptor;
+import com.yutou.nas.okhttp.ParamsContext;
+import com.yutou.nas.okhttp.converter.JsonCallAdapter;
+import com.yutou.nas.okhttp.converter.JsonConverterFactory;
+import okhttp3.Interceptor;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import retrofit2.CallAdapter;
+import retrofit2.Converter;
+import retrofit2.Retrofit;
+
+import java.io.IOException;
+import java.util.Date;
+import java.util.HashMap;
+
+public class BaseApi {
+    private String URL;
+    private HashMap<String, String> params;
+
+    public BaseApi(String URL) {
+        this.URL = URL;
+    }
+
+    public BaseApi setURL(String URL) {
+        this.URL = URL;
+        return this;
+    }
+
+    public BaseApi setParams(HashMap<String, String> params) {
+        this.params = params;
+        return this;
+    }
+
+    /**
+     * 创建一个接口方法
+     *
+     * @param okHttpClient okhttp客户端
+     * @param converterFactory 处理工厂类
+     * @param callAdapterFactory 请求适配器工厂
+     * @param baseUrl 基础地质
+     * @param service 接口
+     * @param <T> 接口泛型
+     * @return 接口
+     */
+    public <T> T create(OkHttpClient okHttpClient, Converter.Factory converterFactory, CallAdapter.Factory callAdapterFactory, String baseUrl, Class<T> service) {
+        Retrofit.Builder builder = new Retrofit.Builder()
+                //基础url
+                .baseUrl(baseUrl)
+                //客户端OKHttp
+                .client(okHttpClient);
+        //添加转换工厂
+        if (null != converterFactory) {
+            builder.addConverterFactory(converterFactory);
+        }
+        //添加请求工厂
+        if (null != callAdapterFactory) {
+            builder.addCallAdapterFactory(callAdapterFactory);
+        }
+        //创建retrofit对象
+        Retrofit retrofit = builder.build();
+
+        //返回创建的api
+        return retrofit.create(service);
+    }
+
+    public <T> T createApi(Class<T> apiClass) {
+        Gson gson = new GsonBuilder()
+                .registerTypeAdapter(Date.class, new DateTypeAdapter())
+                .create();
+        HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor("http");
+        loggingInterceptor.setPrintLevel(HttpLoggingInterceptor.Level.BODY);
+        OkHttpClient.Builder builder = new OkHttpClient()
+                .newBuilder()
+
+                .addInterceptor(initQuery())
+                .addInterceptor(loggingInterceptor);
+        return create(builder.build(),
+                JsonConverterFactory.create(gson),
+                JsonCallAdapter.create(),
+                URL,
+                apiClass);
+    }
+    public Interceptor initQuery() {
+        Interceptor addQueryParameterInterceptor = new Interceptor() {
+            @Override
+            public Response intercept(Chain chain) throws IOException {
+                Request request = chain.request();
+                //配置公共参数
+                request = new ParamsContext(params,request).getInRequest();
+                return chain.proceed(request);
+            }
+        };
+        return addQueryParameterInterceptor;
+    }
+}

src/main/java/com/yutou/nas/okhttp/api/ToolsNetApi.java

@@ -0,0 +1,14 @@
+package com.yutou.nas.okhttp.api;
+
+import com.yutou.nas.okhttp.BaseBean;
+import com.yutou.nas.okhttp.HttpBody;
+import retrofit2.Call;
+import retrofit2.http.Field;
+import retrofit2.http.FormUrlEncoded;
+import retrofit2.http.POST;
+
+public interface ToolsNetApi {
+    @FormUrlEncoded
+    @POST("/api/v2/torrents/add")
+    Call<HttpBody<BaseBean>> postDownloadBt(@Field("urls")String urls, @Field("savePath")String savePath);
+}

src/main/java/com/yutou/nas/okhttp/api/ToolsNetManager.java

@@ -0,0 +1,17 @@
+package com.yutou.nas.okhttp.api;
+
+import com.yutou.nas.utils.ConfigTools;
+
+public class ToolsNetManager extends BaseApi {
+    public ToolsNetManager(String URL) {
+        super(URL);
+    }
+
+    public static ToolsNetManager createQbit() {
+        return new ToolsNetManager(ConfigTools.load(ConfigTools.CONFIG, "Qbittorrent.Url", String.class));
+    }
+
+    public ToolsNetApi getToolsNetApi() {
+        return createApi(ToolsNetApi.class);
+    }
+}

src/main/java/com/yutou/nas/okhttp/converter/JsonCallAdapter.java

@@ -0,0 +1,19 @@
+package com.yutou.nas.okhttp.converter;
+
+import org.jetbrains.annotations.Nullable;
+import retrofit2.CallAdapter;
+import retrofit2.Retrofit;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Type;
+
+public class JsonCallAdapter extends CallAdapter.Factory{
+    public  static  JsonCallAdapter create(){
+        return new JsonCallAdapter();
+    }
+    @Nullable
+    @Override
+    public CallAdapter<?, ?> get(Type type, Annotation[] annotations, Retrofit retrofit) {
+        return null;
+    }
+}

src/main/java/com/yutou/nas/okhttp/converter/JsonConverterFactory.java

@@ -0,0 +1,40 @@
+package com.yutou.nas.okhttp.converter;
+
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.google.gson.reflect.TypeToken;
+import okhttp3.RequestBody;
+import okhttp3.ResponseBody;
+import org.jetbrains.annotations.Nullable;
+import retrofit2.Converter;
+import retrofit2.Retrofit;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Type;
+
+public class JsonConverterFactory extends Converter.Factory {
+    Gson gson;
+    public static JsonConverterFactory create(Gson gson) {
+        return new JsonConverterFactory(gson);
+    }
+
+    private JsonConverterFactory(Gson gson) {
+        this.gson = gson;
+    }
+
+    @Nullable
+    @Override
+    public Converter<?, RequestBody> requestBodyConverter(Type type, Annotation[] parameterAnnotations, Annotation[] methodAnnotations, Retrofit retrofit) {
+        // return super.requestBodyConverter(type, parameterAnnotations, methodAnnotations, retrofit);
+        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
+        return new JsonRequestBodyConverter<>(gson,adapter);
+    }
+
+    @Nullable
+    @Override
+    public Converter<ResponseBody, ?> responseBodyConverter(Type type, Annotation[] annotations, Retrofit retrofit) {
+        // return super.responseBodyConverter(type, annotations, retrofit);
+        TypeAdapter<?> adapter = gson.getAdapter(TypeToken.get(type));
+        return new JsonResponseBodyConverter<>(gson,adapter,type);
+    }
+}

src/main/java/com/yutou/nas/okhttp/converter/JsonRequestBodyConverter.java

@@ -0,0 +1,36 @@
+package com.yutou.nas.okhttp.converter;
+
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.google.gson.stream.JsonWriter;
+import okhttp3.MediaType;
+import okhttp3.RequestBody;
+import okio.Buffer;
+import org.jetbrains.annotations.Nullable;
+import retrofit2.Converter;
+
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.StandardCharsets;
+
+public class JsonRequestBodyConverter<T> implements Converter<T, RequestBody> {
+    Gson gson;
+    TypeAdapter<T> adapter;
+    public JsonRequestBodyConverter(Gson gson, TypeAdapter<T> adapter) {
+        this.gson=gson;
+        this.adapter=adapter;
+    }
+
+    @Nullable
+    @Override
+    public RequestBody convert(T value) throws IOException {
+        Buffer buffer = new Buffer();
+        Writer writer = new OutputStreamWriter(buffer.outputStream(), StandardCharsets.UTF_8);
+        JsonWriter jsonWriter = gson.newJsonWriter(writer);
+        adapter.write(jsonWriter, value);
+        jsonWriter.close();
+        byte[] bytes = buffer.readByteArray();
+        return RequestBody.create(MediaType.parse("application/json; charset=UTF-8"),bytes );
+    }
+}

src/main/java/com/yutou/nas/okhttp/converter/JsonResponseBodyConverter.java

@@ -0,0 +1,42 @@
+package com.yutou.nas.okhttp.converter;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.TypeAdapter;
+import com.yutou.nas.okhttp.HttpBody;
+import okhttp3.ResponseBody;
+import org.jetbrains.annotations.Nullable;
+import retrofit2.Converter;
+
+import java.io.IOException;
+import java.lang.reflect.Type;
+
+public class JsonResponseBodyConverter<T> implements Converter<ResponseBody, T> {
+    Gson gson;
+    TypeAdapter<?> adapter;
+    Type type;
+
+    public JsonResponseBodyConverter(Gson gson, TypeAdapter<?> adapter, Type type) {
+        this.gson = gson;
+        this.adapter = adapter;
+        this.type = type;
+    }
+
+    @Nullable
+    @Override
+    public T convert(ResponseBody responseBody) throws IOException {
+        String string = new String(responseBody.bytes());
+        responseBody.close();
+        HttpBody<T> body;
+        try {
+            body = JSONObject.parseObject(string, type);
+            body.setSrc(string);
+            return (T) body;
+        } catch (Exception e) {
+            body = new HttpBody();
+            body.setSrc(string);
+        }
+        return (T) body;
+
+    }
+}

src/main/java/com/yutou/nas/utils/BTDownloadManager.java

@@ -9,11 +9,18 @@ import com.acgist.snail.protocol.magnet.MagnetProtocol;
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
+import com.yutou.nas.okhttp.BaseBean;
+import com.yutou.nas.okhttp.HttpBody;
+import com.yutou.nas.okhttp.api.ToolsNetApi;
+import com.yutou.nas.okhttp.api.ToolsNetManager;
 import org.slf4j.LoggerFactory;
 import org.slf4j.event.Level;
+import retrofit2.Response;
 
 import java.io.File;
 import java.io.IOException;
+import java.net.URLEncoder;
+import java.nio.charset.Charset;
 import java.nio.charset.StandardCharsets;
 import java.util.concurrent.TimeUnit;
 
@@ -91,17 +98,9 @@ public class BTDownloadManager {
                     , "-c"
                     , exec});
             process.waitFor(120, TimeUnit.SECONDS);*/
-            JSONObject json = new JSONObject();
-            json.put("urls", url);
-            json.put("savepath", "anim/" + title);
 
-            String data="urls="+url+"&savepath=anim/"+title;
-            String post = HttpTools.http_post_form(
-                    ConfigTools.load(ConfigTools.CONFIG, "Qbittorrent.Url", String.class) + "/api/v2/torrents/add",
-                    data.getBytes(StandardCharsets.UTF_8),
-                    0,
-                    null
-            );
+            Response<HttpBody<BaseBean>> response = ToolsNetManager.createQbit().getToolsNetApi().postDownloadBt(url, "anim/" + title).execute();
+            String post = response.body().getSrc();
             Log.i("BT下载", post);
             return post.toLowerCase().contains("ok");
         } catch (Exception e) {

src/main/java/com/yutou/nas/utils/HttpTools.java

@@ -127,6 +127,7 @@ public class HttpTools {
             if (body == null) {
                 body = "".getBytes();
             }
+            Log.i("Http","url = "+url+" body = "+new String(body));
             connection.setDoOutput(true);
             connection.setDoInput(true);
             connection.addRequestProperty("User-Agent", getUa());
@@ -150,13 +151,14 @@ public class HttpTools {
                 str.append(tmp);
             }
             String finalStr = str.toString();
-
+            Log.i("Http","code = "+connection.getResponseCode()+" url = "+url+" body = "+new String(body));
             connection.disconnect();
             reader.close();
             return finalStr;
         } catch (Exception e) {
+            e.printStackTrace();
             if (index < HttpRequestIndex) {
-                return http_post(url, body, index + 1, headers);
+                return http_post_form(url, body, index + 1, headers);
             } else {
                 e.printStackTrace();
                 return null;