文件上传

oa-app/src/main/java/com/css/oa/exam/announce/controller/AnnounceController.java

@@ -8,9 +8,12 @@ import com.css.oa.exam.announce.service.AnnounceService;
import com.css.oa.utils.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.cxf.jaxrs.ext.multipart.Multipart;
import org.apache.cxf.jaxrs.ext.multipart.MultipartBody;
import org.apache.http.util.TextUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
import java.util.Map;
@@ -25,12 +28,29 @@ public class AnnounceController extends BaseController {
    @ApiOperation(value = "增加公告接口")
    @PostMapping("/add")
    public Result add(@RequestBody Announce announce) {
    public Result add(@RequestParam(value = "file") MultipartFile file,
                      @RequestParam(value = "title") String title,
                      @RequestParam(value = "author") String author,
                      @RequestParam(value = "publisher") String publisher,
                      @RequestParam(value = "content") String content,
                      @RequestParam(value = "is_top") int is_top,
                      @RequestParam(value = "type") int type
                      ) {
        Result<Map> result;
        try {
            Announce announce = new Announce();
            announce.file = file;
            announce.title = title;
            announce.author = author;
            announce.publisher = publisher;
            announce.content = content;
            announce.is_top = is_top;
            announce.type = type;
            if (announce.type == 0) {
                return setErr("type公告类型为必选类型");
            }
            String token = getToken();
            mService.setToken(token);
            mService.add(announce);
            result = setResult();
        } catch (Exception e) {

oa-app/src/main/java/com/css/oa/exam/announce/repository/Announce.java

@@ -2,6 +2,7 @@ package com.css.oa.exam.announce.repository;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import org.springframework.web.multipart.MultipartFile;
import javax.persistence.*;
import java.io.Serializable;
@@ -46,6 +47,9 @@ public class Announce implements Serializable {
    @Column(name = "FILE_PATH")
    public String file_path;
    @Transient
    public MultipartFile file;
//    // - - - - - - - - - - - - - - - - - - 下面是基础属性 - - - - - - - - - - - - - - - - - -
    @Column(name = "CREATE_TIME")

oa-app/src/main/java/com/css/oa/exam/announce/service/AnnounceService.java

@@ -1,5 +1,6 @@
package com.css.oa.exam.announce.service;
import com.css.oa.exam.admin.bean.Admin;
import com.css.oa.exam.announce.bean.AnnoType;
import com.css.oa.exam.announce.bean.SearchReq;
import com.css.oa.exam.base.BaseService;
@@ -7,8 +8,8 @@ import com.css.oa.exam.announce.bean.AnnoQueryReq;
import com.css.oa.exam.announce.repository.Announce;
import com.css.oa.exam.announce.repository.IAnnounceRepository;
import com.css.oa.exam.util.CopyObjTool;
import com.css.oa.exam.util.upload.UploadService;
import com.css.oa.utils.DateUtils;
import com.css.oa.utils.UUIDGenerator;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.util.TextUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -33,33 +34,38 @@ public class AnnounceService extends BaseService implements IAnnounceService {
    @Override
    public void add(Announce obj) {
        System.out.println("传入的obj => " + obj.toString());
        if (obj.getUuid() == null) {
            String id = UUIDGenerator.getUUID();
            obj.setUuid(id);
        //上传文件
        if (obj.file != null) {
            Admin admin = Admin.getAdminByToken(token);
            UploadService.upload(obj.file, admin);
        }
        Date newDate = new Date();
        if (obj.getPublish_time() == null) {
            obj.setPublish_time(newDate);
        }
        if (obj.getCreate_time() == null) {
            obj.setCreate_time(newDate);
        }
        if (obj.getUpdate_time() == null) {
            obj.setUpdate_time(newDate);
        }
        if (TextUtils.isEmpty(obj.getCreate_user()) || obj.getCreate_user().equalsIgnoreCase("null")) {
            obj.setCreate_user("系统");
        }
        if (TextUtils.isEmpty(obj.getUpdate_user()) || obj.getCreate_user().equalsIgnoreCase("null")) {
            obj.setUpdate_user("系统");
        }
        if (obj.getDel_flag() == null) {
            obj.setDel_flag("1");
        }
        if (obj.getRemark() == null) {
            obj.setRemark("系统默认的备注");
        }
        repository.save(obj);
//        if (obj.getUuid() == null) {
//            String id = UUIDGenerator.getUUID();
//            obj.setUuid(id);
//        }
//        Date newDate = new Date();
//        if (obj.getPublish_time() == null) {
//            obj.setPublish_time(newDate);
//        }
//        if (obj.getCreate_time() == null) {
//            obj.setCreate_time(newDate);
//        }
//        if (obj.getUpdate_time() == null) {
//            obj.setUpdate_time(newDate);
//        }
//        if (TextUtils.isEmpty(obj.getCreate_user()) || obj.getCreate_user().equalsIgnoreCase("null")) {
//            obj.setCreate_user("系统");
//        }
//        if (TextUtils.isEmpty(obj.getUpdate_user()) || obj.getCreate_user().equalsIgnoreCase("null")) {
//            obj.setUpdate_user("系统");
//        }
//        if (obj.getDel_flag() == null) {
//            obj.setDel_flag("1");
//        }
//        if (obj.getRemark() == null) {
//            obj.setRemark("系统默认的备注");
//        }
//        repository.save(obj);
    }
    @Override

oa-app/src/main/java/com/css/oa/exam/util/upload/Exceptions.java

@@ -0,0 +1,71 @@
/**
 * Copyright (c) 2005-2012 springside.org.cn
 */
package com.css.oa.exam.util.upload;
import javax.servlet.http.HttpServletRequest;
import java.io.PrintWriter;
import java.io.StringWriter;
/**
 * 关于异常的工具类.
 * @author calvin
 * @version 2013-01-15
 */
public class Exceptions {
	/**
	 * 将CheckedException转换为UncheckedException.
	 */
	public static RuntimeException unchecked(Exception e) {
		if (e instanceof RuntimeException) {
			return (RuntimeException) e;
		} else {
			return new RuntimeException(e);
		}
	}
	/**
	 * 将ErrorStack转化为String.
	 */
	public static String getStackTraceAsString(Throwable e) {
		if (e == null){
			return "";
		}
		StringWriter stringWriter = new StringWriter();
		e.printStackTrace(new PrintWriter(stringWriter));
		return stringWriter.toString();
	}
	/**
	 * 判断异常是否由某些底层的异常引起.
	 */
	public static boolean isCausedBy(Exception ex, Class<? extends Exception>... causeExceptionClasses) {
		Throwable cause = ex.getCause();
		while (cause != null) {
			for (Class<? extends Exception> causeClass : causeExceptionClasses) {
				if (causeClass.isInstance(cause)) {
					return true;
				}
			}
			cause = cause.getCause();
		}
		return false;
	}
	/**
	 * 在request中获取异常类
	 * @param request
	 * @return 
	 */
	public static Throwable getThrowable(HttpServletRequest request){
		Throwable ex = null;
		if (request.getAttribute("exception") != null) {
			ex = (Throwable) request.getAttribute("exception");
		} else if (request.getAttribute("javax.servlet.error.exception") != null) {
			ex = (Throwable) request.getAttribute("javax.servlet.error.exception");
		}
		return ex;
	}
	
}

oa-app/src/main/java/com/css/oa/exam/util/upload/FileInfoEntity.java

@@ -0,0 +1,73 @@
package com.css.oa.exam.util.upload;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.util.Date;
@Data
@Entity
@Table(name = "OP_XM_ENCLOSURE")
@JsonIgnoreProperties(value = {"hibernateLazyInitializer"})
public class FileInfoEntity {
    @Id
    @ApiModelProperty("主键ID")
    private String uuid;
    @ApiModelProperty("项目ID,具体业务ID，例如：公告ID,OP_SHENBAO_NEWS表主键")
    private String xmId;
    @ApiModelProperty("项目类型,具体业务类型，例如：1=公告附件 2=公告图片")
    private String xmType;
    @ApiModelProperty("上传系统")
    private String uploadSystem;
    @ApiModelProperty("上传时指定的文件类型")
    private String uploadType;
    @ApiModelProperty("sm3值")
    private String uploadSm;
    @ApiModelProperty("sm3路径")
    private String uploadPath;
    @ApiModelProperty("密钥串")
    private String cipherKey;
    @ApiModelProperty("附件名称")
    private String fileName;
    @ApiModelProperty("附件类型")
    private String fileType;
    @ApiModelProperty("附件大小")
    private String fileSize;
    @ApiModelProperty("创建时间")
    private Date createTime;
    @ApiModelProperty("更新时间")
    private Date updateTime;
    @ApiModelProperty("创建人")
    private String createUser;
    @ApiModelProperty("更新人")
    private String updateUser;
    @ApiModelProperty("是否生效,0=无效 1=有效")
    private Integer isValid;
    @ApiModelProperty("删除标记,0=未删除 1=删除")
    private Integer delFlag;
    @ApiModelProperty("备注")
    private String remark;
}

oa-app/src/main/java/com/css/oa/exam/util/upload/FileInfoRepository.java

@@ -0,0 +1,37 @@
package com.css.oa.exam.util.upload;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
@Repository
public interface FileInfoRepository extends JpaRepository<FileInfoEntity, String>, JpaSpecificationExecutor<FileInfoEntity> {
    /**
     * @brief 通过uuid获取FileInfoEntity
     * @detail 2021/4/21 17:51 zangtie 详细1 需求id#
     * @author zangtie
     * @since 2021/4/21 17:51
     * @param uuid OP_XM_ENCLOSURE表主键
     * @return com.css.oa.zcsb.repository.entity.FileInfoEntity
     */
    @Query("select f from FileInfoEntity f  where f.isValid = 1 and f.delFlag = 0 and f.uuid = ?1")
    FileInfoEntity findOne(String uuid);
    /**
     * @brief 通过uuid逻辑删除FileInfoEntity
     * @detail 2021/4/21 17:52 zangtie 详细1 需求id#
     * @author zangtie
     * @since 2021/4/21 17:52
     * @param uuid OP_XM_ENCLOSURE表主键
     * @return void
     */
    @Modifying
    @Transactional
    @Query("update FileInfoEntity set delFlag = 1 where uuid = ?1")
    void delete(String uuid);
}

oa-app/src/main/java/com/css/oa/exam/util/upload/FileInfoUtil.java

@@ -0,0 +1,57 @@
package com.css.oa.exam.util.upload;
import net.sf.json.JSONObject;
import com.css.oa.utils.UUIDGenerator;
import io.micrometer.core.instrument.util.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Date;
@Slf4j
public class FileInfoUtil {
    private static FileInfoUtil instance;
    public static FileInfoUtil getInstance() {
        if (instance == null) {
            instance = new FileInfoUtil();
        }
        return instance;
    }
    @Autowired
    FileInfoRepository fileInfoRepository;
    public void saveInfo(JSONObject json) {
        if (json.containsKey("result") && "false".equals(json.getString("result"))) {
            log.debug("上传文档报错：" + json.getString("message"));
            return;
        }
        FileInfoEntity entity = entity = new FileInfoEntity();
        entity.setUuid(UUIDGenerator.getUUID());
        entity.setUploadSystem(json.getString("srcSystem"));
        entity.setUploadType(json.getString("fileType"));
        entity.setUploadSm("sm3");
        entity.setUploadPath(json.getString("sm3Path"));
        entity.setCipherKey(json.getString("cipherKey"));
        String fileSrcName = json.getString("fileSrcName");
        if (fileSrcName.contains("-已加密.")) {
            fileSrcName = fileSrcName.replace("-已加密.", ".");
        }
        entity.setFileName(fileSrcName);
        entity.setFileType(json.getString("fileExt"));
        entity.setFileSize(json.getString("fileSize"));
        String xmType = json.getString("xmType");
        if (StringUtils.isNotEmpty(xmType)) {
            entity.setXmType(json.getString("xmType"));
        }
        entity.setCreateTime(new Date());
        entity.setCreateUser(json.getString("user_id"));
        entity.setDelFlag(0);
        entity.setIsValid(1);
        fileInfoRepository.save(entity);
    }
}

oa-app/src/main/java/com/css/oa/exam/util/upload/HttpClientUtil.java

@@ -0,0 +1,755 @@
package com.css.oa.exam.util.upload;
//import com.gxb.utils.Exceptions;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.tuple.ImmutableTriple;
import org.apache.commons.lang3.tuple.Triple;
import org.apache.http.*;
import org.apache.http.client.HttpRequestRetryHandler;
import org.apache.http.client.config.AuthSchemes;
import org.apache.http.client.config.CookieSpecs;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.apache.http.client.protocol.HttpClientContext;
import org.apache.http.config.Registry;
import org.apache.http.config.RegistryBuilder;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.routing.HttpRoute;
import org.apache.http.conn.socket.ConnectionSocketFactory;
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.InputStreamBody;
import org.apache.http.entity.mime.content.StringBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HttpContext;
import org.apache.http.ssl.SSLContexts;
import org.apache.http.ssl.TrustStrategy;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLException;
import javax.net.ssl.SSLHandshakeException;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.UnknownHostException;
import java.nio.charset.StandardCharsets;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.*;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
 * http请求工具类
 *
 * @author wangke
 * @date 2018/5/3 11:46
 */
public class HttpClientUtil {
    /**
     * 最大重试次数
     */
    public static int maxRetryTimes = 5;
    private static final int CONNECT_TIMEOUT = 4000;// 设置连接建立的超时时间为4s
    private static final int SOCKET_TIMEOUT = 300000;
    private static final int IDLE_TIMEOUT = 28000;
    private static final int MAX_CONN = 3000; // 最大连接数
    private static final int Max_PER_ROUTE = 1500;
    private static final int MAX_ROUTE = 2000;
    private static final String url = "http://fileback.miit.gov.cn";
    private final CloseableHttpClient httpClient; // 发送请求的客户端单例
    private static PoolingHttpClientConnectionManager manager; //连接池管理类
    private static ScheduledExecutorService monitorExecutor;
    private final static Object syncLock = new Object(); // 相当于线程锁,用于线程安全
    public static Logger log = LoggerFactory.getLogger(HttpClientUtil.class);
    public static void config(HttpRequestBase httpRequestBase) {
        httpRequestBase.setHeader("User-Agent", "Mozilla/5.0");
        httpRequestBase.setHeader("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
        httpRequestBase.setHeader("Accept-Language", "zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3");//"en-US,en;q=0.5");
        httpRequestBase.setHeader("Accept-Charset", "ISO-8859-1,utf-8,gbk,gb2312;q=0.7,*;q=0.7");
        // 配置请求的超时设置
        RequestConfig requestConfig = RequestConfig.custom().setCookieSpec(CookieSpecs.STANDARD_STRICT)
                .setExpectContinueEnabled(Boolean.TRUE).setTargetPreferredAuthSchemes(Arrays.asList(AuthSchemes.NTLM, AuthSchemes.DIGEST))
                .setProxyPreferredAuthSchemes(Arrays.asList(AuthSchemes.BASIC)).setConnectionRequestTimeout(CONNECT_TIMEOUT)
                .setSocketTimeout(SOCKET_TIMEOUT)
                .setConnectTimeout(CONNECT_TIMEOUT)
                .build();
        httpRequestBase.setConfig(requestConfig);
    }
    /**
     * 关闭连接池
     */
    public static void closeConnectionPool() {
        try {
            getInstance().httpClient.close();
            manager.close();
            monitorExecutor.shutdown();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    public CloseableHttpClient getHttpClient() {
        return httpClient;
    }
    private static final HttpClientUtil httpClientUtil = new HttpClientUtil();
    public static HttpClientUtil getInstance() {
        return httpClientUtil;
    }
    /**
     * 根据host和port构建httpclient实例
     *
     * @param host 要访问的域名
     * @param port 要访问的端口
     * @return
     */
    public static CloseableHttpClient createHttpClient(String host, int port) {
        ConnectionSocketFactory plainsf = PlainConnectionSocketFactory.getSocketFactory();
        SSLConnectionSocketFactory sslConnectionSocketFactory = null;
        try {
            final SSLContext sslContext = SSLContexts.custom().loadTrustMaterial(null, new TrustStrategy() {
                @Override
                public boolean isTrusted(X509Certificate[] x509Certificates, String authType) throws CertificateException {
                    return true;
                }
            }).build();
            sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslContext, new String[]{"TLSv1", "TLSv1.1", "TLSv1.2"}, null, NoopHostnameVerifier.INSTANCE);
            final Registry<ConnectionSocketFactory> registry = RegistryBuilder.<ConnectionSocketFactory>create()
                    .register("http", plainsf)
                    .register("https", sslConnectionSocketFactory)
                    .build();
            RequestConfig requestConfig = RequestConfig.custom().setConnectionRequestTimeout(CONNECT_TIMEOUT)
                    .setSocketTimeout(SOCKET_TIMEOUT)
                    .setConnectTimeout(CONNECT_TIMEOUT)
                    .build();
            manager = new PoolingHttpClientConnectionManager(registry);
            // 将最大连接数增加到200
            manager.setMaxTotal(MAX_CONN);
            // 将每个路由基础的连接增加到20
            manager.setDefaultMaxPerRoute(Max_PER_ROUTE);
            // 将目标主机的最大连接数增加到50
            HttpHost localhost = new HttpHost(host, port);
            manager.setMaxPerRoute(new HttpRoute(localhost), MAX_ROUTE);
            //请求重试处理
            HttpRequestRetryHandler httpRequestRetryHandler = new HttpRequestRetryHandler() {
                public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
                    if (executionCount >= maxRetryTimes) {// 如果已经重试了5次，就放弃
                        return false;
                    }
                    if (exception instanceof NoHttpResponseException) {// 如果服务器丢掉了连接，那么就重试
                        log.error("receive no response from server, retry");
                        return true;
                    }
                    if (exception instanceof SSLHandshakeException) {// 不要重试SSL握手异常
                        log.error("SSL hand shake exception");
                        return false;
                    }
                    if (exception instanceof InterruptedIOException) {// 超时
                        log.error("InterruptedIOException");
                        return false;
                    }
                    if (exception instanceof UnknownHostException) {// 目标服务器不可达
                        log.error("server host unknown");
                        return true;
                    }
                    if (exception instanceof ConnectTimeoutException) {// 连接被拒绝
                        log.error("Connection Time out");
                        return false;
                    }
                    if (exception instanceof SSLException) {// ssl握手异常
                        log.error("SSLException");
                        return false;
                    }
                    HttpClientContext clientContext = HttpClientContext.adapt(context);
                    HttpRequest request = clientContext.getRequest();
                    // 如果请求是幂等的，就再次尝试
                    return !(request instanceof HttpEntityEnclosingRequest);
                }
            };
            return HttpClients.custom()
                    .setConnectionManager(manager)
                    .setRetryHandler(httpRequestRetryHandler).setDefaultRequestConfig(requestConfig)
                    .build();
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (KeyStoreException e) {
            e.printStackTrace();
        } catch (KeyManagementException e) {
            e.printStackTrace();
        }
        return null;
    }
    private HttpClientUtil() {
//        System.setProperty("org.apache.commons.logging.Log", "org.apache.commons.logging.impl.SimpleLog");
//        System.setProperty("org.apache.commons.logging.simplelog.showdatetime", "true");
//        System.setProperty("org.apache.commons.logging.simplelog.log.org.apache.http.headers", "info");
//        System.setProperty("org.apache.commons.logging.simplelog.log.org.apache.http.wire", "info");
        String hostName = url;
        int port = 80;
        if (url.startsWith("http") || url.startsWith("HTTP"))
            hostName = url.split("/")[2];
        if (hostName.contains(":")) {
            String[] args = hostName.split(":");
            hostName = args[0];
            port = Integer.parseInt(args[1]);
        }
        //Security.insertProviderAt(new BouncyCastleProvider(), 1);
        httpClient = createHttpClient(hostName, port);
        if (monitorExecutor == null) {
            monitorExecutor = Executors.newScheduledThreadPool(1);
            monitorExecutor.scheduleAtFixedRate(new TimerTask() {
                @Override
                public void run() {
                    //关闭异常连接
                    manager.closeExpiredConnections();
                    //关闭5s空闲的连接
                    manager.closeIdleConnections(IDLE_TIMEOUT, TimeUnit.MILLISECONDS);
                    log.info("close expired and idle for over 5s connection");
                }
            }, 10000, 30000, TimeUnit.MILLISECONDS);
        }
    }
    /**
     * http get请求
     *
     * @param url
     * @return
     */
    public Triple<StatusLine, Header[], String> httpGet(String url, Map<String, String> headMap, Map<String, Object> parameterMap) {
        long startTime = System.currentTimeMillis();
        String responseContent = null;
        Header[] headers = null;
        StatusLine statusLine = null;
        try {
            if (!url.contains("?"))
                url += "?";
            else
                url += "&";
            if (parameterMap != null) {
                for (Map.Entry<String, Object> paramsMap : parameterMap.entrySet()) {
                    if (paramsMap.getKey() == null||paramsMap.getValue()==null)
                        continue;
                    else if (paramsMap.getValue() instanceof String) {
                        url += paramsMap.getKey() + "=" + paramsMap.getValue() + "&";
                    } else if (List.class.isAssignableFrom(paramsMap.getValue().getClass())) {
                        List list = (List) paramsMap.getValue();
                        for (int i = 0; i < list.size(); i++)
                            url += paramsMap.getKey() + "=" +  list.get(i).toString() + "&";
                    }
                }
            }
            if (url.endsWith("&"))
                url = url.substring(0, url.length() - 1);
            HttpGet request = new HttpGet(url);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    request.addHeader(e.getKey(), e.getValue());
                }
            }
            CloseableHttpResponse response = httpClient.execute(request);
            try {
                headers = response.getAllHeaders();
                statusLine = response.getStatusLine();
                HttpEntity entity = response.getEntity();
                responseContent = EntityUtils.toString(entity, "UTF-8");
                EntityUtils.consume(entity);
            } finally {
                response.close();
            }
        } catch (Exception e) {
            log.error(Exceptions.getStackTraceAsString(e));
        }
        log.debug(System.currentTimeMillis() - startTime + " ms httpGet spendTime");
        return new ImmutableTriple(statusLine, headers, responseContent);
    }
    /**
     * 将返回结果转化为String
     *
     * @param entity
     * @return
     * @throws Exception
     */
    private String getRespString(HttpEntity entity) throws Exception {
        if (entity == null) {
            return null;
        }
        StringBuffer strBuf = new StringBuffer();
        try (InputStream is = entity.getContent()) {
            byte[] buffer = new byte[4096];
            int r = 0;
            while ((r = is.read(buffer)) > 0) {
                strBuf.append(new String(buffer, 0, r, StandardCharsets.UTF_8));
            }
        }
        return strBuf.toString();
    }
    /**
     * http的post请求
     *
     * @param url
     * @param paramsMap
     * @return
     */
    public Triple<StatusLine, Header[], String> httpPost(String url, Map<String, Object> paramsMap,
                                                         Map<String, String> headMap) {
        String responseContent = null;
        Header[] headers = null;
        StatusLine statusLine = null;
        Long startTime = System.currentTimeMillis();
        try {
            HttpPost httpPost = new HttpPost(url);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    httpPost.addHeader(e.getKey(), e.getValue());
                }
            }
            if (paramsMap != null) {
                List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
                for (String key : paramsMap.keySet()) {
                    if (paramsMap.get(key) == null)
                        continue;
                    else if (paramsMap.get(key) instanceof String) {
                        String value = ((String) paramsMap.get(key));
                        nameValuePairList.add(new BasicNameValuePair(key, value));
                    } else if (List.class.isAssignableFrom(paramsMap.get(key).getClass())) {
                        List list = (List) paramsMap.get(key);
                        for (int i = 0; i < list.size(); i++)
                            nameValuePairList.add(new BasicNameValuePair(key, list.get(i).toString()));
                    }
                }
                UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
                formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
                httpPost.setEntity(formEntity);
                // request.setEntity(new ByteArrayEntity(body));
                // request.setEntity(new StringEntity(body, "utf-8"));
            }
            CloseableHttpResponse response = httpClient.execute(httpPost);
            try {
                headers = response.getAllHeaders();
                statusLine = response.getStatusLine();
                HttpEntity entity = response.getEntity();
                responseContent = EntityUtils.toString(entity, "UTF-8");
                EntityUtils.consume(entity);
            } finally {
                response.close();
            }
        } catch (Exception e) {
            log.error(Exceptions.getStackTraceAsString(e));
        }
        log.debug(System.currentTimeMillis() - startTime + " ms httpPost spendTime");
        return new ImmutableTriple(statusLine, headers, responseContent);
    }
    public Triple<StatusLine, Header[], String> httpPost(String url, String json,
                                                         Map<String, String> headMap) {
        String responseContent = null;
        Header[] headers = null;
        StatusLine statusLine = null;
        Long startTime = System.currentTimeMillis();
        try {
            HttpPost httpPost = new HttpPost(url);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    httpPost.addHeader(e.getKey(), e.getValue());
                }
            }
            httpPost.setHeader("Content-type", "application/json");
            if (StringUtils.isBlank(json)) {
                throw new RuntimeException("json串不能为空");
            }
            StringEntity requestEntity = new StringEntity(json, "utf-8");
            requestEntity.setContentEncoding("UTF-8");
            httpPost.setEntity(requestEntity);
            CloseableHttpResponse response = httpClient.execute(httpPost);
            try {
                headers = response.getAllHeaders();
                statusLine = response.getStatusLine();
                HttpEntity entity = response.getEntity();
                responseContent = EntityUtils.toString(entity, "UTF-8");
                EntityUtils.consume(entity);
            } finally {
                response.close();
            }
        } catch (Exception e) {
            log.error(Exceptions.getStackTraceAsString(e));
        }
        log.debug(System.currentTimeMillis() - startTime + " ms httpPost spendTime");
        return new ImmutableTriple(statusLine, headers, responseContent);
    }
    public Triple<StatusLine, Header[], String> uploadThenDownload(String serverUrl, InputStream fileInputStream, String fileName,
                                                                   String serverFieldName, Map<String, Object> params, Map<String, String> headMap, OutputStream out) throws Exception {
        Header[] headers = null;
        StatusLine statusLine = null;
        CloseableHttpResponse response = null;
        try {
            HttpPost httpPost = new HttpPost(serverUrl);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    httpPost.addHeader(e.getKey(), e.getValue());
                }
            }
            if (fileInputStream != null) {
                InputStreamBody streamBody = new InputStreamBody(fileInputStream, ContentType.APPLICATION_OCTET_STREAM, fileName);
                MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder
                        .create().setMode(HttpMultipartMode.RFC6532);
                multipartEntityBuilder.setCharset(Consts.UTF_8);
                // add the file params
                multipartEntityBuilder.addPart(serverFieldName, streamBody);
                // 设置上传的其他参数
                setUploadParams(multipartEntityBuilder, params);
                HttpEntity reqEntity = multipartEntityBuilder.build();
                httpPost.setEntity(reqEntity);
            } else {
                if (params != null) {
                    List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
                    for (String key : params.keySet()) {
                        if (params.get(key) == null)
                            continue;
                        else if (params.get(key) instanceof String) {
                            String value = params.get(key).toString();
                            nameValuePairList.add(new BasicNameValuePair(key, value));
                        }
                    }
                    UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
                    formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
                    httpPost.setEntity(formEntity);
                }
            }
            response = httpClient.execute(httpPost);
            headers = response.getAllHeaders();
            statusLine = response.getStatusLine();
            String contentDisposition = response.getFirstHeader("Content-Disposition") != null ? response.getFirstHeader("Content-Disposition").getValue() : "";
            if (!contentDisposition.equals(""))
                fileName = contentDisposition.substring(contentDisposition.indexOf("\"") + 1, contentDisposition.length() - 1);
            HttpEntity entity = response.getEntity();
            long contentLength = entity.getContentLength();
            log.debug(contentLength + " contentLength");
            InputStream in = entity.getContent();
            // 通过ioutil 对接输入输出流
            if(out!=null)
              IOUtils.copy(new BufferedInputStream(in), out);
            EntityUtils.consume(entity);
        } finally {
            if(out!=null)
              out.close();
            response.close();
        }
        return new ImmutableTriple(statusLine, headers, fileName);
    }
    /**
     * 设置上传文件时所附带的其他参数
     *
     * @param multipartEntityBuilder
     * @param params
     */
    private void setUploadParams(MultipartEntityBuilder multipartEntityBuilder,
                                 Map<String, Object> params) {
        if (params != null && params.size() > 0) {
            Set<String> keys = params.keySet();
            for (String key : keys) {
                multipartEntityBuilder
                        .addPart(key, new StringBody(params.get(key).toString(),
                                ContentType.create("text/plain", Consts.UTF_8)));
            }
        }
    }
    /**
     * 上传文件
     *
     * @param serverUrl       服务器地址
     * @param serverFieldName
     * @param params
     * @return
     * @throws Exception
     */
    public Triple<StatusLine, Header[], String> uploadFileImpl(String serverUrl, InputStream fileInputStream, String fileName,
                                                               String serverFieldName, Map<String, Object> params, Map<String, String> headMap)
            throws Exception {
        String respStr = null;
        Header[] headers = null;
        StatusLine statusLine = null;
        CloseableHttpResponse response = null;
        try {
            HttpPost httpPost = new HttpPost(serverUrl);
//            RequestConfig requestConfig = RequestConfig.custom().setProxy(new HttpHost("127.0.0.1", 8888)).build();
//            httpPost.setConfig(requestConfig);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    httpPost.addHeader(e.getKey(), e.getValue());
                }
            }
            InputStreamBody streamBody = new InputStreamBody(fileInputStream, ContentType.APPLICATION_OCTET_STREAM, fileName);
            //FileBody binFileBody = new FileBody(new File(localFilePath), ContentType.APPLICATION_OCTET_STREAM);
            MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder
                    .create().setMode(HttpMultipartMode.RFC6532);
            multipartEntityBuilder.setCharset(Consts.UTF_8);
            // add the file params
            multipartEntityBuilder.addPart(serverFieldName, streamBody);
            // 设置上传的其他参数
            setUploadParams(multipartEntityBuilder, params);
            HttpEntity reqEntity = multipartEntityBuilder.build();
            httpPost.setEntity(reqEntity);
            response = httpClient.execute(httpPost);
            headers = response.getAllHeaders();
            statusLine = response.getStatusLine();
            HttpEntity resEntity = response.getEntity();
            respStr = EntityUtils.toString(resEntity, "UTF-8");
            EntityUtils.consume(resEntity);
        } finally {
            if (response != null)
                response.close();
            if (fileInputStream != null)
                fileInputStream.close();
        }
        return new ImmutableTriple(statusLine, headers, respStr);
    }
    public Triple<StatusLine, Header[], String> httpDownloadFile(String url, String filePath,
                                                                 Map<String, String> headMap, Map<String, Object> parameterMap) throws FileNotFoundException {
        return httpDownloadFile(url, new FileOutputStream(filePath), headMap, parameterMap);
    }
    public Triple<StatusLine, Header[], String> httpDownloadFile(String url, OutputStream out,
                                                                 Map<String, String> headMap, Map<String, Object> parameterMap) {
        String fileName = "";
        Header[] headers = null;
        StatusLine statusLine = null;
        try {
            HttpPost request = new HttpPost(url);
            config(request);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    request.addHeader(e.getKey(), e.getValue());
                }
            }
            if (parameterMap != null) {
                List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
                for (String key : parameterMap.keySet()) {
                    if (parameterMap.get(key) == null)
                        continue;
                    else if (parameterMap.get(key) instanceof String) {
                        String value = ((String) parameterMap.get(key));
                        nameValuePairList.add(new BasicNameValuePair(key, value));
                    } else if (List.class.isAssignableFrom(parameterMap.get(key).getClass())) {
                        List list = (List) parameterMap.get(key);
                        for (int i = 0; i < list.size(); i++)
                            nameValuePairList.add(new BasicNameValuePair(key, list.get(i).toString()));
                    }
                }
                UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
                formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
                request.setEntity(formEntity);
            }
            CloseableHttpResponse response = httpClient.execute(request);
            try {
                headers = response.getAllHeaders();
                statusLine = response.getStatusLine();
                String contentDisposition = response.getFirstHeader("Content-Disposition") != null ? response.getFirstHeader("Content-Disposition").getValue() : "";
                if (!contentDisposition.equals(""))
                    fileName = contentDisposition.substring(contentDisposition.indexOf("\"") + 1, contentDisposition.length() - 1);
                //fileName=new String(fileName.getBytes("ISO-8859-1"));
                HttpEntity httpEntity = response.getEntity();
                long contentLength = httpEntity.getContentLength();
                log.debug(contentLength + " contentLength fileName: "+fileName);
                InputStream in = httpEntity.getContent();
                // 通过ioutil 对接输入输出流
                IOUtils.copy(new BufferedInputStream(in), out);
                EntityUtils.consume(httpEntity);
            } finally {
                out.close();
                response.close();
            }
        } catch (Exception e) {
            log.error(Exceptions.getStackTraceAsString(e));
        }
        return new ImmutableTriple(statusLine, headers, fileName);
    }
    public Triple<Header[],String, HttpEntity> httpDownloadFile(String url,
                                                                Map<String, String> headMap, Map<String, Object> parameterMap) {
        String fileName = "";
        Header[] headers = null;
        HttpEntity httpEntity = null;
        try {
            HttpPost request = new HttpPost(url);
            config(request);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    request.addHeader(e.getKey(), e.getValue());
                }
            }
            if (parameterMap != null) {
                List<NameValuePair> nameValuePairList = new ArrayList<NameValuePair>();
                for (String key : parameterMap.keySet()) {
                    if (parameterMap.get(key) == null)
                        continue;
                    else if (parameterMap.get(key) instanceof String) {
                        String value = ((String) parameterMap.get(key));
                        nameValuePairList.add(new BasicNameValuePair(key, value));
                    } else if (List.class.isAssignableFrom(parameterMap.get(key).getClass())) {
                        List list = (List) parameterMap.get(key);
                        for (int i = 0; i < list.size(); i++)
                            nameValuePairList.add(new BasicNameValuePair(key, list.get(i).toString()));
                    }
                }
                UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(nameValuePairList, "utf-8");
                formEntity.setContentType("application/x-www-form-urlencoded; charset=UTF-8");
                request.setEntity(formEntity);
            }
            CloseableHttpResponse response = httpClient.execute(request);
            headers = response.getAllHeaders();
            String contentDisposition = response.getFirstHeader("Content-Disposition") != null ? response.getFirstHeader("Content-Disposition").getValue() : "";
            if (!contentDisposition.equals(""))
                fileName = contentDisposition.substring(contentDisposition.indexOf("\"") + 1, contentDisposition.length() - 1);
            //if(fileNameIso8859)
            //  fileName=new String(fileName.getBytes("ISO-8859-1"));
            httpEntity = response.getEntity();
            long contentLength = httpEntity.getContentLength();
            log.debug(contentLength + " contentLength");
        } catch (Exception e) {
            log.error(Exceptions.getStackTraceAsString(e));
        }
        return new ImmutableTriple(headers, fileName, httpEntity);
    }
    public void httpDownloadFileBackToFront(String url, String userAgent, HttpServletResponse response,
                                            Map<String, String> headMap, Map<String, String> parameterMap) {
        OutputStream out = null;
        String fileName = "";
        try {
            if (!url.contains("?"))
                url += "?";
            else
                url += "&";
            if (parameterMap != null) {
                for (Map.Entry<String, String> e : parameterMap.entrySet()) {
                    url += e.getKey() + "=" + e.getValue() + "&";
                }
            }
            if (url.endsWith("&"))
                url = url.substring(0, url.length() - 1);
            HttpGet request = new HttpGet(url);
            config(request);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    request.addHeader(e.getKey(), e.getValue());
                }
            }
            CloseableHttpResponse response1 = httpClient.execute(request);
            try {
                log.debug(response1.getStatusLine().toString());
                fileName = response1.getFirstHeader("Content-Disposition").getValue().substring(response1.getFirstHeader("Content-Disposition").getValue().indexOf("\"") + 1, response1.getFirstHeader("Content-Disposition").getValue().length() - 1);
                //fileName=new String(fileName.getBytes("ISO-8859-1"));
                HttpEntity httpEntity = response1.getEntity();
                long contentLength = httpEntity.getContentLength();
                if (contentLength != 0l) {
                    response.setContentLength((int) contentLength);
                    response.addHeader("Content-Length", contentLength + "");
                }
                response.addHeader("Content-Disposition", "attachment;filename=\"" + fileName + "\"");
                InputStream in = httpEntity.getContent();
                // 通过ioutil 对接输入输出流
                out = response.getOutputStream();
                IOUtils.copy(new BufferedInputStream(in), out);
                EntityUtils.consume(httpEntity);
            } finally {
                out.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public void httpDownloadFileProgress(String url, String filePath,
                                         HttpClientDownLoadProgress progress, Map<String, String> headMap) {
        try {
            HttpGet request = new HttpGet(url);
            if (headMap != null) {
                for (Map.Entry<String, String> e : headMap.entrySet()) {
                    request.addHeader(e.getKey(), e.getValue());
                }
            }
            CloseableHttpResponse response1 = httpClient.execute(request);
            try {
                System.out.println(response1.getStatusLine());
                HttpEntity httpEntity = response1.getEntity();
                long contentLength = httpEntity.getContentLength();
                InputStream is = httpEntity.getContent();
                // 根据InputStream 下载文件
                FileOutputStream fos = new FileOutputStream(filePath);
                byte[] buffer = new byte[4096];
                int r = 0;
                long totalRead = 0;
                while ((r = is.read(buffer)) > 0) {
                    fos.write(buffer, 0, r);
                    totalRead += r;
                    if (progress != null) {// 回调进度
                        progress.onProgress((int) (totalRead * 100 / contentLength));
                    }
                }
                fos.flush();
                fos.close();
                EntityUtils.consume(httpEntity);
            } finally {
                response1.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public interface HttpClientDownLoadProgress {
        void onProgress(int progress);
    }
}

oa-app/src/main/java/com/css/oa/exam/util/upload/UploadService.java

@@ -0,0 +1,28 @@
package com.css.oa.exam.util.upload;
import com.css.oa.exam.admin.bean.Admin;
import lombok.extern.slf4j.Slf4j;
import net.sf.json.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.tuple.Triple;
import org.apache.http.Header;
import org.apache.http.StatusLine;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.multipart.MultipartFile;
import java.io.*;
import java.util.*;
@Slf4j
public class UploadService {
    public static void upload(MultipartFile file, Admin admin) {
        JSONObject json = UploadUtil.upload(file, admin);
        json.put("user_id", admin.my_unit_id);
        FileInfoUtil.getInstance().saveInfo(json);
    }
}

oa-app/src/main/java/com/css/oa/exam/util/upload/UploadUtil.java

@@ -0,0 +1,134 @@
package com.css.oa.exam.util.upload;
import com.css.oa.exam.admin.bean.Admin;
import lombok.extern.slf4j.Slf4j;
import net.sf.json.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.tuple.Triple;
import org.apache.http.Header;
import org.apache.http.StatusLine;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.*;
@Slf4j
public class UploadUtil {
    private static Map<String, Object> uploadParamsMap = new HashMap();
    private static Map<String, Object> downloadParamsMap = new HashMap<String, Object>();
    private static Map<String, Object> accessTokenParamsMap = new HashMap<String, Object>();
    private static Map<String, Object> decryptParamsMap = new HashMap<String, Object>();
    private static Map<String, Object> previewParamsMap = new HashMap<String, Object>();
    static {
        Properties props = new Properties();
        StringBuffer whiteList = new StringBuffer();
        try {
            //读取上传配置文件
            ClassPathResource classPathResource = new ClassPathResource("/fileUpload.properties");
            InputStream in = classPathResource.getInputStream();
            InputStreamReader ins = new InputStreamReader(in, "UTF-8");
            props.load(ins);
            in.close();
            ins.close();
        } catch (IOException e) {
            e.printStackTrace();
            //logger.info("读取配置文件 fileUpload.properties 失败，格式不正确！");
        }
        Iterator<Map.Entry<Object, Object>> it = props.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry<Object, Object> entry = it.next();
            String key = entry.getKey() == null ? "" : entry.getKey().toString();
            String value = entry.getValue() == null ? "" : entry.getValue().toString();
            if (StringUtils.isNotBlank(key)) {
                //获取上传参数
                if (key.startsWith("upload") && key.indexOf(".") != -1) {
                    String[] keys = key.split("\\.");
                    if (keys.length >= 2) {
                        uploadParamsMap.put(keys[1], value);
                    }
                }
                //获取下载参数
                if (key.startsWith("download") && key.indexOf(".") != -1) {
                    String[] keys = key.split("\\.");
                    if (keys.length >= 2) {
                        downloadParamsMap.put(keys[1], value);
                    }
                }
                //获取获取动态令牌的参数
                if (key.startsWith("accesstoken") && key.indexOf(".") != -1) {
                    String[] keys = key.split("\\.");
                    if (keys.length >= 2) {
                        accessTokenParamsMap.put(keys[1], value);
                    }
                }
                //获取解密的参数
                if (key.startsWith("decrypt") && key.indexOf(".") != -1) {
                    String[] keys = key.split("\\.");
                    if (keys.length >= 2) {
                        decryptParamsMap.put(keys[1], value);
                    }
                }
                // 转版DOCX/图片/文本文件获取PDF
                if (key.startsWith("preview") && key.indexOf(".") != -1) {
                    String[] keys = key.split("\\.");
                    if (keys.length >= 2) {
                        previewParamsMap.put(keys[1], value);
                    }
                }
            }
        }
    }
    public static JSONObject upload(MultipartFile file, Admin admin) {
        JSONObject json = null;
        try {
            String fileName = file.getOriginalFilename();
            InputStream in = file.getInputStream();
            Triple<StatusLine, Header[], String> triple = null;
            uploadParamsMap.put("userName", admin.name);
            try {
                triple = HttpClientUtil.getInstance().uploadFileImpl(uploadParamsMap.get("serverPath").toString(),
                        in, fileName, "file", uploadParamsMap, null); //按照流的方式上传文件名需要单独作为参数上传
            } catch (Exception e) {
                log.debug(Exceptions.getStackTraceAsString(e));
            }
            log.debug(triple.getLeft() + " statusLine");
            log.debug(Arrays.asList(triple.getMiddle()) + " Headers");
            log.debug(triple.getRight());
            if (isJSON(triple.getRight())) {
                json = JSONObject.fromObject(triple.getRight());
            } else {
                json = new JSONObject();
                json.put("result", "false");
                json.put("message", triple.getRight());
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return json;
    }
    private static Boolean isJSON(String str) {
        Boolean result = false;
        try {
            JSONObject json = JSONObject.fromObject(str);
            result = true;
        } catch (Exception e) {
            result = false;
        }
        return result;
    }
}

oa-app/src/main/resources/fileUpload.properties

@@ -0,0 +1,47 @@
upload.userId = -1
upload.srcSystem = 131452021
upload.token = MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDN-ZunAY9W94DxGz66PQFissaqjLMvyXkBNvCqmNqm1UokbOVpgEqyTzftR0pbMQOBsIV07IBIzlJuV5_ljVbnRSR7UIVrPm6atwpTfm5e5dTt88BmHHjQojQneEOIcZL9Avpvx488HuoNjNpOx2frydwHAHd5IynfVkczg1vfZQIDAQAB
upload.businessId =
upload.isTemp = 0
upload.isPublic = 1
upload.isValidate = 1
upload.anyoneDownload = 0
upload.fileType = GK
upload.isEncrypt = 1
upload.isStore = 0
upload.algorithm = SM4
upload.isHexKey = 1
upload.iv = 1234567812345678
upload.fileServiceURL = http://10.13.1.180
upload.serverPath = http://10.13.1.180/file/uploadDfsBackEnd
download.userId = -1
download.srcSystem = 131452021
download.token = MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDN-ZunAY9W94DxGz66PQFissaqjLMvyXkBNvCqmNqm1UokbOVpgEqyTzftR0pbMQOBsIV07IBIzlJuV5_ljVbnRSR7UIVrPm6atwpTfm5e5dTt88BmHHjQojQneEOIcZL9Avpvx488HuoNjNpOx2frydwHAHd5IynfVkczg1vfZQIDAQAB
download.fileType = GK
download.fileServiceURL = http://10.13.1.180
download.serverPath = http://10.13.1.180/file/downloadBackEnd
download.algorithm = SM4
download.isHexKey = 1
download.iv = 1234567812345678
accesstoken.userId = -1
accesstoken.srcSystem = 131452021
accesstoken.token = MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDN-ZunAY9W94DxGz66PQFissaqjLMvyXkBNvCqmNqm1UokbOVpgEqyTzftR0pbMQOBsIV07IBIzlJuV5_ljVbnRSR7UIVrPm6atwpTfm5e5dTt88BmHHjQojQneEOIcZL9Avpvx488HuoNjNpOx2frydwHAHd5IynfVkczg1vfZQIDAQAB
accesstoken.expireTime = 3600
accesstoken.notBeforeTime = 0
accesstoken.fileServiceURL = http://10.13.1.180
accesstoken.serverPath = http://10.13.1.180/file/getAccessToken
decrypt.userId = -1
decrypt.srcSystem = 131452021
decrypt.token = MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDN-ZunAY9W94DxGz66PQFissaqjLMvyXkBNvCqmNqm1UokbOVpgEqyTzftR0pbMQOBsIV07IBIzlJuV5_ljVbnRSR7UIVrPm6atwpTfm5e5dTt88BmHHjQojQneEOIcZL9Avpvx488HuoNjNpOx2frydwHAHd5IynfVkczg1vfZQIDAQAB
decrypt.noSsoUpload = 1
decrypt.isHexKey = 1
decrypt.iv = 1234567812345678
decrypt.algorithm = SM4
decrypt.isResponseFileEntity = 0
decrypt.fileType = GK
decrypt.isTemp = 0
decrypt.isPublic = 4
decrypt.businessId =
decrypt.isStore = 1
decrypt.fileServiceURL = http://10.13.1.180
decrypt.serverPath = http://10.13.1.180/file/decryptFile

oa-app/src/test/java/com/css/oa/supervision/waitexec/service/impl/MyTest.java

@@ -56,25 +56,32 @@ public class MyTest {
////        System.out.println("numberString => "+numberString);
//    }
    @Test
    public void a3() {
        String accessKeyId = "hellocode";
        String secureKey = "f53d3819d5e265984fc8911d36377280";
        long timestamp = 1619770939;//new Date().getTime();
        try {
            String signature = hmacsha1((accessKeyId + "\n" + timestamp).getBytes(), secureKey.getBytes());
            System.out.println(signature);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
//    @Test
//    public void a3() {
//        String accessKeyId = "hellocode";
//        String secureKey = "f53d3819d5e265984fc8911d36377280";
//
//        long timestamp = 1619770939;//new Date().getTime();
//        try {
//            String signature = hmacsha1((accessKeyId + "\n" + timestamp).getBytes(), secureKey.getBytes());
//            System.out.println(signature);
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//    private String hmacsha1(byte[] data, byte[] key) throws Exception {
//        SecretKeySpec signingKey = new SecretKeySpec(key, "HmacSHA1");
//        Mac mac = Mac.getInstance("HmacSHA1");
//        mac.init(signingKey);
//        byte[] rawHmac = mac.doFinal(data);
//        return org.apache.commons.codec.binary.Base64.encodeBase64String(rawHmac);
//    }
    private String hmacsha1(byte[] data, byte[] key) throws Exception {
        SecretKeySpec signingKey = new SecretKeySpec(key, "HmacSHA1");
        Mac mac = Mac.getInstance("HmacSHA1");
        mac.init(signingKey);
        byte[] rawHmac = mac.doFinal(data);
        return org.apache.commons.codec.binary.Base64.encodeBase64String(rawHmac);
    @Test
    public void a4() {
        String originalFilename = "logo.png";
        String[] filename = originalFilename.split("\\.");
        System.out.println(filename);
    }
}

pom.xml

@@ -160,7 +160,12 @@
            <version>1.7</version>
        </dependency>
        <!--网络请求的作用-->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpmime</artifactId>
            <version>4.5.9</version>
        </dependency>
        <dependency>
            <groupId>css.slw</groupId>