package com.basic.security.utils;

import android.content.ContextWrapper;

import com.basic.security.base.BaseApplication;

import org.csource.common.NameValuePair;
import org.csource.fastdfs.ClientGlobal;
import org.csource.fastdfs.StorageClient1;
import org.csource.fastdfs.StorageServer;
import org.csource.fastdfs.TrackerClient;
import org.csource.fastdfs.TrackerServer;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.util.Properties;

/**
 * FastDFS文件上传，下载处理类
 *
 * @author sjw
 */

public class FastDFSUtil {

    private static final String TAG = "FastDFSUtil";


    //type是   jpg   png txt 之类的字符串
    public static void testUpload(String filePath, String type) {

        try {
            /*
             * 上传测试
             */
            String fdfs_client_path = new ContextWrapper(BaseApplication.getApplication().activity).getFilesDir().getAbsolutePath() + "/fdfs_client.properties";
            ClientGlobal.init(fdfs_client_path);
            fdfs_client_path = filePath;
            byte[] by = getBytes(fdfs_client_path);
            String fileName = filePath.substring(filePath.lastIndexOf("/") + 1, filePath.length());
            String resultPath = uploadFile(by, fileName, type);
//            System.out.println(TAG + "上传后相对存储路径：" + resultPath);
//             System.out.println("访问路径："+PropertiesUtils.getInfo("fastdfs_url")+resultPath);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static String upLoadVisitorPic(byte[] data, long time) {

        try {
            String fast_dfs_client_path = new ContextWrapper(BaseApplication.getApplication().activity).getFilesDir().getAbsolutePath() + "/fdfs_client.properties";
            ClientGlobal.init(fast_dfs_client_path);
            String fileName = DateUtil.formatTime(time, "yyyy-MM-dd HH:mm:ss");
            return uploadFile(data, fileName, "jpg");
        } catch (Exception e) {
//            e.printStackTrace();
            System.out.println("FastDFSUtil.upLoadVisitorPic " + e.getMessage());
            return null;
        }
    }

    public static byte[] getBytes(String filePath) {
        byte[] buffer = null;
        try {
            File file = new File(filePath);
            FileInputStream fis = new FileInputStream(file);
            ByteArrayOutputStream bos = new ByteArrayOutputStream(1000);
            byte[] b = new byte[1000];
            int n;
            while ((n = fis.read(b)) != -1) {
                bos.write(b, 0, n);
            }
            fis.close();
            bos.close();
            buffer = bos.toByteArray();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return buffer;
    }

    /**
     * 文件上传
     *
     * @param pic  上传文件字节数组
     * @param name 文件名
     * @param ext  文件后缀名
     * @return FastDFS存储文件路径
     */
    public static String uploadFile(byte[] pic, String name, String ext) {
        String path = null;
        TrackerServer trackerServer = null;
        try {
//            System.out.println(TAG + "上传文件名:" + name);
//			if (!getInfo("file_type_list").contains(ext)
//					&& !getInfo("file_type_list").toUpperCase().contains(ext)) {
//				System.out.println("不支持" + ext + "类型文件上传!");
//				throw new RuntimeException("不支持" + ext + "类型文件上传!");
//			}
//            System.out.println(TAG + "上传文件类型: " + ext);

            if (pic.length / 1024 / 1024 > 10) {
//                System.out.println(TAG + "仅支持10MB以下文件上传!");
                throw new RuntimeException(TAG + "仅支持10MB以下文件上传!");
            }
//            System.out.println(TAG + "文件大小:" + pic.length / 1024 + "KB");

            String fdfs_client_path = new ContextWrapper(BaseApplication.getApplication().activity).getFilesDir().getAbsolutePath();

            ClientGlobal.init(fdfs_client_path + "/fdfs_client.properties");

            TrackerClient trackerClient = new TrackerClient();
            trackerServer = trackerClient.getConnection();

//            System.out.println(TAG + "tracker服务器连接成功! " + trackerServer.getInetSocketAddress());

            StorageServer storageServer = null;

            StorageClient1 storageClient1 = new StorageClient1(trackerServer, storageServer);

//            System.out.println(TAG + "启动FastDFS客户端.... ：" + storageClient1);

            NameValuePair[] meta_list = new NameValuePair[3];

            meta_list[0] = new NameValuePair("filename", name);

            meta_list[1] = new NameValuePair("fileext", ext);

            meta_list[2] = new NameValuePair("filesize", String.valueOf(pic.length));

            path = storageClient1.upload_file1(pic, ext, meta_list);

            if (null != path && !"".equals(path)) {
//                System.out.println(TAG + "文件上传成功!   " + path);
                return path;
            } else {
//                System.out.println(TAG + "文件上传失败！");
                throw new RuntimeException(TAG + "文件上传失败！");
            }
        } catch (Exception e) {
            e.printStackTrace();
//            System.out.println(TAG + "系统异常，文件上传失败！");
            throw new RuntimeException(TAG + "系统异常，文件上传失败！");
        } finally {
            if (trackerServer != null) {
                try {
                    trackerServer.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

    }

    /**
     * 文件下载 仅作为下载方式案例，项目中使用请参考cbs-dfs-demo
     *
     * @param fileUrl 文件上传后返回的存储路径,如：group3/M00/A1/64/CgIBSViAG6GAPLsAAATyXumgUaA302
     *                .jpg
     * @return 下载到本地的存储路径
     */
    @SuppressWarnings("unused")
    public static String downFile(String fileUrl) {
        if (null == fileUrl || "".equals(fileUrl)) {
//            System.out.println("下载文件源路径为空！");
            return null;
        }
        BufferedInputStream dis = null;
        BufferedOutputStream fos = null;
        String filePath = null;
        try {
            // 存储下载文件的路径,默认存储在当前用户所在目录下
            filePath = System.getProperty("user.home") + File.separator
                    + fileUrl.substring(fileUrl.lastIndexOf("/") + 1);
//            System.out.println("本地存储路径:" + filePath);
            File destFile = new File(filePath);
            if (!destFile.exists()) {
                destFile.createNewFile();
            }
            URL url = new URL(getInfo("http_head") + getInfo("fastdfs_vip")
                    + fileUrl);
//            System.out.println("文件源路径:" + url);
            dis = new BufferedInputStream(url.openStream());
            fos = new BufferedOutputStream(new FileOutputStream(destFile));
            byte[] buff = new byte[2048];
            int bytesRead;

            while (-1 != (bytesRead = dis.read(buff, 0, buff.length))) {
                fos.write(buff, 0, bytesRead);
            }
//            System.out.println("文件下载成功!");
        } catch (Exception e) {
//            System.out.println("文件下载出现未知异常!");
            return null;
        } finally {
            if (dis != null) {
                try {
                    dis.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (fos != null) {
                try {
                    fos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        return filePath;

    }

    public static String getInfo(String code) throws Exception {
        ClassLoader classLoader = FastDFSUtil.class.getClassLoader();
        InputStream is = classLoader
                .getResourceAsStream("config/fdfs_client.conf");

        if (is == null) {
            is = classLoader.getResourceAsStream("fdfs_client.properties");
        }
        Properties prop = new Properties();
        if (is != null) {
            prop.load(is);
            String property = prop.getProperty(code);
            return property;
        }
        return code;
    }

}