package com.basic.analy.utils;


//import org.csource.common.NameValuePair;
//import org.csource.fastdfs.*;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.multipart.MultipartFile;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
//
//@Configuration
//public class FastDFSUtil2 {
//
//    //fdfs_client 核心配置文件
//    public static String conf_filename="fdfs_client.conf";
//
//
//    public  String  upload(MultipartFile file) {	//上传文件
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            ClientGlobal.init(conf_filename);
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//
//            String ext_Name = file.getOriginalFilename().split("\\.")[1];
//
//            byte[] bytes = null;
//            try {
//                bytes = file.getBytes();
//            } catch (IOException e) {
//                e.printStackTrace();
//            }
//
//            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//            String fileIds[] = storageClient.upload_file(bytes, ext_Name, null);
//            return fileIds[0]+"/"+fileIds[1];
//        } catch (Exception e) {
//            e.printStackTrace();
//            return "error";
//        }
//
//    }
//
//    public  String  uploadByByte(byte[] bytes,String extName) {	//上传文件
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            ClientGlobal.init(conf_filename);
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//            StorageClient1 client = new StorageClient1(trackerServer, storageServer);
//
//            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//            String fileIds[] = storageClient.upload_file(bytes, extName, null);
//            return fileIds[0]+"/"+fileIds[1];
//        } catch (Exception e) {
//            e.printStackTrace();
//            return "error";
//        }
//
//    }
//
//
//    public static void download() {	//下载文件
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            String groupName = "group1";
//            String filePath = "/M00/00/18/wKgBtlvrelCAQCN2AAAlu9rpxmA717.jpg";
////            String filePath = "M00/00/00/ZGIW_lpujW-ADvpRAAblmT4ACuo125.png";
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//
//            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//            byte[] bytes = storageClient.download_file(groupName, filePath);
//
//            String storePath = "/Users/shenwei/Desktop/download.png";
//            OutputStream out = new FileOutputStream(storePath);
//            out.write(bytes);
//        } catch (Exception e) {
//            e.printStackTrace();
//        } finally{
//            try {
//                if(null!=storageServer) storageServer.close();
//                if(null!=trackerServer) trackerServer.close();
//            } catch (IOException e) {
//                // TODO Auto-generated catch block
//                e.printStackTrace();
//            }
//        }
//    }
//
//
//    public  void getFileInfo(){ //获取文件信息
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            String groupName = "group1";
//            String filePath = "M00/B6/ED/wKgBy1vYJrSAMlSiAACrc4GTmVg117.png";
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//
//            StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//            FileInfo file = storageClient.get_file_info(groupName, filePath);
//            System.out.println("ip--->"+file.getSourceIpAddr());
//            System.out.println("文件大小--->"+file.getFileSize());
//            System.out.println("文件上传时间--->"+file.getCreateTimestamp());
//            System.out.println(file.getCrc32());
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//
//    public  void getFileMate(){ //获取文件的原数据类型
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            String groupName = "group1";
//            String filePath = "M00/00/00/ZGIW_lpujW-ADvpRAAblmT4ACuo125.png";
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//
//            StorageClient storageClient = new StorageClient(trackerServer,
//                    storageServer);
//
//            //这个值是上传的时候指定的NameValuePair
//            NameValuePair nvps [] = storageClient.get_metadata(groupName, filePath);
//            if(null!=nvps && nvps.length>0){
//                for(NameValuePair nvp : nvps){
//                    System.out.println(nvp.getName() + ":" + nvp.getValue());
//                }
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//
//    public  void delete(){ //删除文件
//        TrackerServer trackerServer =null;
//        StorageServer storageServer = null;
//
//        try {
//            String groupName = "group1";
//            String filePath = "M00/00/00/ZGIW_lpujW-ADvpRAAblmT4ACuo125.png";
//            ClientGlobal.init(conf_filename);
//
//            TrackerClient tracker = new TrackerClient();
//            trackerServer = tracker.getConnection();
//
//            StorageClient storageClient = new StorageClient(trackerServer,
//                    storageServer);
//            int i = storageClient.delete_file(groupName, filePath);
//            System.out.println( i==0 ? "删除成功" : "删除失败:"+i);
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//    /**
//     * 根据图片的FastDFS地址获得数据的字节流
//     * @param strUrl 网络连接地址
//     * @return
//     */
//    public  byte[] getImageFromFDFS(String strUrl){
//        try {
//            URL url = new URL(strUrl);
//            System.out.println("url是："+strUrl);
//            HttpURLConnection conn = (HttpURLConnection)url.openConnection();
//            conn.setRequestMethod("GET");
//            conn.setConnectTimeout(5 * 1000);
//            InputStream inStream = conn.getInputStream();//获取从网络的输入流
//            byte[] btImg = new byte[inStream.available()];
//            inStream.read(btImg);         //从输入流中得到图片的二进制数据
//            return btImg;
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//        return null;
//    }
//
//    public static byte[] downloadFDFS(String group_name,String remote_filename) throws Exception {
//        // 向项目中添加jar包
//        // 创建一个配置文件配置tracker服务器地址
//        //加载配置文件
//        ClientGlobal.init("fdfs_client.conf");
//
//        //创建一个tracker客户端对象
//        TrackerClient trackerClient = new TrackerClient();
//
//        //使用trackerclient连接trackersever对象
//        TrackerServer trackerServer = trackerClient.getConnection();
//
//        //创建一个straged server对象
//        StorageServer storageServer = null;
//
//        //创建一个storage client 对象
//        StorageClient storageClient = new StorageClient(trackerServer, storageServer);
//
//
//        byte[] download_file = storageClient.download_file(group_name,remote_filename);
//        //upload_file 存储着访问路径
//        return download_file;
//    }
//}