package com.sinata.download.http;



import androidx.annotation.NonNull;

import com.sinata.download.utils.Logger;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.concurrent.TimeUnit;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;

/**
 * author：Created by zhaohaoting on 2019/6/25
 * email：526309416@qq.com
 * desc：
 */
public class DownLoadManager {

    private static OkHttpClient downLoadHttpClient;

    static {
        OkHttpClient.Builder downLoadHttpClientBuilder = new OkHttpClient.Builder();
        downLoadHttpClient = downLoadHttpClientBuilder.connectTimeout(3, TimeUnit.MINUTES)
                .readTimeout(3, TimeUnit.MINUTES).writeTimeout(3, TimeUnit.MINUTES).build();
    }

    /**
     * 下载文件
     *
     * @param url
     * @param filePath
     * @param listener
     */
    public static void downLoadFile(String url, final String filePath, final DownloadListener listener) {
        downLoadHttpClient.newCall(new Request.Builder().url(url).get().build()).enqueue(new Callback() {
            @Override
            public void onFailure(@NonNull Call call, @NonNull IOException e) {
                listener.onFail(e.getMessage());
            }

            @Override
            public void onResponse(@NonNull Call call, @NonNull Response response) {
                ResponseBody responseBody = response.body();
                if (responseBody == null) return;
                InputStream is = null;
                long currentLen = 0;
                byte[] buf = new byte[1024];
                int len = 0;
                FileOutputStream fos = null;
                try {
                    is = responseBody.byteStream();
                    File file = new File(filePath);
                    long length = responseBody.contentLength();
                    Logger.e("文件大小------------->", String.valueOf(length));
                    File parentFile = file.getParentFile();
                    if (!parentFile.exists()) {
                        boolean mkdirs = parentFile.mkdirs();
                    }
                    if (!file.exists()) {
                        boolean newFile = file.createNewFile();
                    } else {
                        if (file.length() == length) {//若本地存在当前下载文件，且文件大小一致（说明是同一个文件）则，无需再向磁盘写入
                            if (is != null) is.close();
                            listener.onProgress(100);
                            listener.onFinishDownload(true);
                            Logger.e("本地已有该文件------------->", "");
                            return;
                        }
                    }
                    listener.onStartDownload();
                    fos = new FileOutputStream(file);
                    while ((len = is.read(buf)) != -1) {
                        fos.write(buf, 0, len);
                        currentLen += len;
                        int progress = (int) (currentLen * 100 / length);
                        Logger.e("下载中------------->", String.valueOf(progress));
                        listener.onProgress(progress);
                    }
                    fos.flush();
                    //如果下载文件成功，第一个参数为文件的绝对路径
                    listener.onFinishDownload(false);
                } catch (Exception e) {
                    listener.onFail(e.getMessage());
                } finally {
                    try {
                        if (is != null) is.close();
                    } catch (Exception e) {
                    }
                    try {
                        if (fos != null) fos.close();
                    } catch (Exception e) {
                    }
                }
            }
        });
    }
}