【COS文件上传下载】

 		
            com.qcloud
            cos_api
            5.6.54
        

package com.example.completablefuture.controller;

import com.alibaba.excel.EasyExcel;
import com.alibaba.fastjson.JSON;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.OSSObject;

import com.example.completablefuture.config.CosConfig;
import com.example.completablefuture.config.OSSConfig;
import com.example.completablefuture.listener.CommonListen;
import com.example.completablefuture.model.DeliveryGoodExcel;
import com.qcloud.cos.COSClient;
import com.qcloud.cos.ClientConfig;
import com.qcloud.cos.auth.BasicCOSCredentials;
import com.qcloud.cos.auth.COSCredentials;
import com.qcloud.cos.http.HttpProtocol;
import com.qcloud.cos.model.*;
import com.qcloud.cos.region.Region;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import java.io.*;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;


@RestController
@RequestMapping("/excel/")
@Slf4j
public class ExcelController {

    @Autowired
    private CosConfig cosConfig;

    @PostMapping("/upload")
    public String upload(MultipartFile file) throws IOException {
        //读取COS 获取文件并解析操作数据库
        //获取相关配置
        String bucketName = cosConfig.getBucketname();
        String endpoint = cosConfig.getEndpoint();
        String endpointTemp = endpoint.substring(endpoint.indexOf(".") + 1);
        endpointTemp = endpointTemp.substring(0, endpointTemp.indexOf("."));
        String accessKeyId = cosConfig.getAccessKeyId();
        String accesskeySecret = cosConfig.getAccessKeySecret();
        COSCredentials cred = new BasicCOSCredentials(accessKeyId, accesskeySecret);
        Region region = new Region(endpointTemp);
        ClientConfig clientConfig = new ClientConfig(region);
        //创建客户端
        COSClient cosClient = new COSClient(cred, clientConfig);
        //获取原生文件名 xxx.cvs
        String originalFilename = file.getOriginalFilename();
        //JDK8的日期格式化
        LocalDateTime ldt = LocalDateTime.now();
        DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy/MM/dd");
        //拼装路径，cos上存储的路径
        String folder = dtf.format(ldt);
        //随机数
        String fileName = generateUUID();
        //.csv
        String extension = originalFilename.substring(originalFilename.lastIndexOf("."));
        //新文件名
        String newFileName = "excel/" + folder + "/" + fileName + extension;
        try {
            Objectmetadata objectmetadata = new Objectmetadata();
            //文件的大小
            objectmetadata.setContentLength(file.getSize());
            //文件的类型
            objectmetadata.setContentType(file.getContentType());
            PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, newFileName, file.getInputStream(), objectmetadata);
            PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
            log.info("newFileName:{}", newFileName);
            if (putObjectResult != null) {
                System.out.println(JSON.toJSONString(putObjectResult));
                String fileAccessUrl = "https://" + bucketName + "." + endpoint + "/" + newFileName;
                System.out.println(fileAccessUrl);
                return fileAccessUrl;
            }
        } finally {
            //cos关闭服务，不然会造成OOM
            cosClient.shutdown();
        }
        return null;
    }

    
    @RequestMapping("importExcel")
    @ResponseBody
    public void importExcel(String newFileName) {
        //读取COS 获取文件并解析操作数据库
        //获取相关配置
        String bucketName = cosConfig.getBucketname();
        String endpoint = cosConfig.getEndpoint();
        String endpointTemp = endpoint.substring(endpoint.indexOf(".") + 1);
        endpointTemp = endpointTemp.substring(0, endpointTemp.indexOf("."));
        String accessKeyId = cosConfig.getAccessKeyId();
        String accesskeySecret = cosConfig.getAccessKeySecret();
        COSCredentials cred = new BasicCOSCredentials(accessKeyId, accesskeySecret);
        Region region = new Region(endpointTemp);
        ClientConfig clientConfig = new ClientConfig(region);
        //创建客户端
        COSClient cosClient = new COSClient(cred, clientConfig);

        GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, newFileName);
        COSObject cosObject = cosClient.getObject(getObjectRequest);
        COSObjectInputStream cosObjectInput = cosObject.getObjectContent();
        try {
            List