import com.alibaba.fastjson.JSONObject;

import com.qiniu.common.QiniuException;

import com.qiniu.common.Zone;

import com.qiniu.http.Response;

import com.qiniu.storage.Configuration;

import com.qiniu.storage.UploadManager;

import com.qiniu.util.Auth;

import org.springframework.web.multipart.MultipartFile;

import java.io.*;

import java.util.*;

public class HBYAppUtils {

    //设置好账号的ACCESS_KEY和SECRET_KEY

    String ACCESS_KEY = "yKD4YcCSflBrGuSzbt0nfN3b2S8DFb8SYDXBUrOZ";

    //这两个登录七牛 账号里面可以找到

    String SECRET_KEY = "s6R_cGNQwo-NrBy4_vennXPlhB2iOq7sUA46AV9y";

    //要上传的空间

    String bucketname = "ecloud-app-files";

    //对应要上传到七牛上 你的那个路径（自己建文件夹 注意设置公开）

    // 上传到七牛后保存的文件名

//    String key = "123.html";

    //上传文件的路径

//    String FilePath = "C:\\Users\\沐白\\Desktop\\肺炎疫情武汉加油.html";

    //本地要上传文件路径

　　/*

　　　　普通上传

　　　　multipartFile : form表单传过来的文件,

　　　　key: 文件名

　　*/

    public String  upload(MultipartFile multipartFile,String key) throws IOException{

        // 密钥配置

        Auth auth = Auth.create(ACCESS_KEY,SECRET_KEY);

        //创建上传对象

        Configuration configuration = new Configuration(Zone.zone0());

        UploadManager uploadManager = new UploadManager(configuration);

        String result = "";

        FileInputStream inputStream=(FileInputStream)multipartFile.getInputStream();

        byte[] uploadBytes = new byte[inputStream.available()];

        ByteArrayInputStream byteInputStream=new ByteArrayInputStream(uploadBytes);

        try {

            //调用put方法上传

            Response res = uploadManager.put(byteInputStream,key,auth.uploadToken(bucketname),null, null);

            //打印返回的信息

            result = key;

        } catch (QiniuException e) {

            e.printStackTrace();

            // 请求失败时打印的异常的信息

            result = "no";

        }

        return  result;

    }

//流获取输入的搜索关键字同行一行的语句

    public static ArrayList<String> isContainContent(String url, String keyWord) throws  Exception{

        File pathname = new File(url);

        ArrayList<String> jsonObjects = new ArrayList<>();

        JSONObject jsonObject = new JSONObject();

        boolean result = false;

        //行读取

        LineNumberReader lineReader = null;

        InputStreamReader read = new InputStreamReader(new FileInputStream(pathname), "gbk");

        lineReader = new LineNumberReader(read);

        String readLine = null;

        while((readLine =lineReader.readLine()) != null){

            //判断是否包含

            if(readLine.contains(keyWord)) {

//                result = true;

//                    jsonObject.put("lineWords",readLine);

//                    jsonObject.put("lineNumber", lineReader.getLineNumber());

                jsonObject.put("pathname",pathname);

                jsonObjects.add(readLine);

            }

        }

        //关闭流

        if(lineReader != null){

            try {

                lineReader.close();

            } catch (IOException e) {

                e.printStackTrace();

//                lineReader = null;

            }

        }

//        jsonObject.put("flag", result);

        return jsonObjects;

    }