下载1

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

@@ -15,6 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
import java.util.Map;
@@ -35,7 +37,7 @@ public class AnnounceController extends BaseController {
                      @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();
@@ -60,6 +62,16 @@ public class AnnounceController extends BaseController {
        return result;
    }
    @ApiOperation(value = "下载公告中的文件")
    @GetMapping("/download")
    public void download(@RequestParam(value = "uuid") String uuid, HttpServletRequest request, HttpServletResponse response) {
        try {
            mService.download(uuid, request, response);
        } catch (Exception e1) {
            e1.printStackTrace();
        }
    }
    @ApiOperation(value = "根据考试id获取公告列表")
    @GetMapping("/queryPage")
    public Result queryPage(int type, int curPage, int pageSize) {

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

@@ -8,8 +8,11 @@ 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.FileInfoEntity;
import com.css.oa.exam.util.upload.FileInfoRepository;
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;
@@ -22,6 +25,8 @@ import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.*;
@Slf4j
@@ -37,35 +42,49 @@ public class AnnounceService extends BaseService implements IAnnounceService {
        //上传文件
        if (obj.file != null) {
            Admin admin = Admin.getAdminByToken(token);
            UploadService.upload(obj.file, admin);
            new UploadService().upload(obj.file, admin);
        }
//        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);
        String id = UUIDGenerator.getUUID();
        obj.setUuid(id);
        Date newDate = new Date();
        obj.setPublish_time(newDate);
        obj.setCreate_time(newDate);
        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);
    }
    /*
    *  @param uuid = OP_XM_ENCLOSURE表主键
    */
    @Override
    public void download(String uuid, HttpServletRequest request, HttpServletResponse response) {
        Admin admin = Admin.getAdminByToken(token);
        new UploadService().download(admin, uuid, request, response);
    }
    @Override
    public void update(Announce newObj) {
        //上传文件
        if (newObj.file != null) {
            Admin admin = Admin.getAdminByToken(token);
            new UploadService().upload(newObj.file, admin);
        }
        Optional<Announce> byId = repository.findById(newObj.getUuid());
        Announce old = byId.get();
        CopyObjTool.copyProperties(old, newObj);
        repository.save(newObj);
    }
    @Override
@@ -105,14 +124,6 @@ public class AnnounceService extends BaseService implements IAnnounceService {
    }
    @Override
    public void update(Announce newTest) {
        Optional<Announce> byId = repository.findById(newTest.getUuid());
        Announce old = byId.get();
        CopyObjTool.copyProperties(old, newTest);
        repository.save(newTest);
    }
    @Override
    public void delete(List<String> ids) {
        //ids = ["0","2","3"]
        repository.deleteRealByIds(ids);

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

@@ -4,6 +4,8 @@ import com.css.oa.exam.announce.bean.AnnoQueryReq;
import com.css.oa.exam.announce.bean.SearchReq;
import com.css.oa.exam.announce.repository.Announce;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
import java.util.Map;
@@ -11,6 +13,8 @@ public interface IAnnounceService {
    void add(Announce test);
    void download(String uuid, HttpServletRequest request, HttpServletResponse response);
    Map queryPage(AnnoQueryReq req);
    void update(Announce newTest);

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

@@ -1,57 +0,0 @@
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/UploadService.java

@@ -1,28 +1,89 @@
package com.css.oa.exam.util.upload;
import com.css.oa.exam.admin.bean.Admin;
import com.css.oa.utils.UUIDGenerator;
import io.micrometer.core.instrument.util.StringUtils;
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.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.URLEncoder;
import java.util.*;
@Slf4j
public class UploadService {
    public static void upload(MultipartFile file, Admin admin) {
    public void upload(MultipartFile file, Admin admin) {
        //1,先上传
        JSONObject json = UploadUtil.upload(file, admin);
        //2,保存数据
        json.put("user_id", admin.my_unit_id);
        FileInfoUtil.getInstance().saveInfo(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);
    }
    @Autowired
    FileInfoRepository fileInfoRepository;
    public void download(Admin admin, String uuid, HttpServletRequest request, HttpServletResponse response) {
        try {
            response.reset();
            // 设置文件输出类型
            response.setContentType("multipart/form-data");
            // 文件名编码
            FileInfoEntity entity = fileInfoRepository.findOne(uuid);
            String fileName = entity.getFileName();
            response.setHeader("Content-Disposition", "attachment; fileName=" + transCharacter(request, fileName));
            UploadUtil.downloadListFolderFiles(admin,entity.getUuid(), entity.getUploadPath(), fileName, entity.getCipherKey(), response);
        } catch (Exception e) {
        }
    }
    private String transCharacter(HttpServletRequest request, String str) throws Exception {
        if (request.getHeader("USER-AGENT").toLowerCase().indexOf("msie") > 0) {
            return URLEncoder.encode(str, "UTF-8");
        } else if (request.getHeader("USER-AGENT").toLowerCase().indexOf("firefox") > 0) {
            return new String(str.getBytes("UTF-8"), "ISO8859-1");
        }
        return new String(str.getBytes("UTF-8"), "ISO8859-1");
    }
}

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

@@ -10,9 +10,11 @@ import org.apache.http.StatusLine;
import org.springframework.core.io.ClassPathResource;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.*;
@Slf4j
@@ -131,4 +133,48 @@ public class UploadUtil {
        }
        return result;
    }
    public static void downloadListFolderFiles(Admin admin,String uuid, String uploadPath, String fileName, String cipherKey, HttpServletResponse response) throws Exception {
        downloadParamsMap.put("k", uploadPath);
        downloadParamsMap.put("cipherKey", cipherKey);
        downloadParamsMap.put("srcName", fileName); //选填 可重定义文件名
//        UserContextModel user = UserContextModel.getCurrentUser();
//        if(user != null){
//            downloadParamsMap.put("userName",user.getUserName());
//        }
//        CoreUser user = coreUserService.findById(SessionUtil.getUserId());
        if (admin != null) {
            downloadParamsMap.put("userName", admin.name);
        }
        String serverPath = downloadParamsMap.get("serverPath") == null ? "" : downloadParamsMap.get("serverPath").toString();
        String fileServiceURL = downloadParamsMap.get("fileServiceURL") == null ? "" : downloadParamsMap.get("fileServiceURL").toString();
        Map<String, String> headMap = new HashMap<String, String>() {
            {
                put("Referer", fileServiceURL);
            }
        };
        OutputStream out = null;
        try {
            out = response.getOutputStream();
            Triple<StatusLine, Header[], String> triple = HttpClientUtil.getInstance().httpDownloadFile(
                    serverPath, out,
                    headMap, downloadParamsMap);
            log.debug(triple.getLeft().toString());
            log.debug(Arrays.asList(triple.getMiddle()).toString());
            Header[] headerArrs = triple.getMiddle();
            for (Header h : headerArrs) {
                if ("Content-Length".equals(h.getName())) {
                    // 设置输出长度
                    response.setHeader("Content-Length", String.valueOf(h.getValue()));
                }
            }
            out.flush();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            out.close();
        }
    }
}