From c9601c4abb00f18abc448fb9562f117f90128012 Mon Sep 17 00:00:00 2001
From: liyawei <llyywwaoao@163.com>
Date: Thu, 21 Jul 2022 17:52:20 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A4=E8=AF=81-=E5=8F=82=E6=95=B0=E9=A1=B9?=
 =?UTF-8?q?=E6=94=B6=E9=9B=86=E6=B8=85=E5=8D=95-=E5=8F=98=E6=9B=B4?=
 =?UTF-8?q?=EF=BC=9A=E5=AF=BC=E5=87=BA=E6=97=B6=E5=8F=91=E9=80=81=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ParamsCollectManifestEOServiceImpl.java   | 37 +++++++++++++++++++
 1 file changed, 37 insertions(+)

diff --git a/jero-boot/jero-boot-module-certification/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsCollectManifestEOServiceImpl.java b/jero-boot/jero-boot-module-certification/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsCollectManifestEOServiceImpl.java
index f0ea1ec22..424e1ffe3 100644
--- a/jero-boot/jero-boot-module-certification/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsCollectManifestEOServiceImpl.java
+++ b/jero-boot/jero-boot-module-certification/src/main/java/com/jero/modules/cert/collect/service/impl/ParamsCollectManifestEOServiceImpl.java
@@ -68,15 +68,18 @@ import org.aspectj.util.FileUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.mock.web.MockMultipartFile;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.*;
 import java.lang.reflect.Field;
+import java.lang.reflect.Modifier;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.nio.file.StandardOpenOption;
@@ -2108,6 +2111,40 @@ public class ParamsCollectManifestEOServiceImpl extends ServiceImpl<ParamsCollec
 				os.write(len);
 			}
 
+			// 将导出文件上传到cos上
+			String uploadFileName = fileOriName + ".zip";
+			InputStream uploadFileio = new FileInputStream(new File(fileNowPath+".zip"));
+			MultipartFile mFile = new MockMultipartFile(uploadFileName, uploadFileName, "text/plain", uploadFileio); // 用于上传
+			OSSFile ossFile = ossFileService.uploadLocalOfCos(mFile, "/manifest", "", CutEnum.CN.getValue()); // 上传导出的压缩包
+
+			// 系统向用户发消息
+			LoginUser currentUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); // 获取当前登录人
+			String msgTitle = "您导出的" + paramsCollectManifestVO.getExportName()  + "已经生成完毕";
+			String content = "您导出的" + paramsCollectManifestVO.getExportName()  + "已经生成完毕，请点击下载。";
+
+			String href = "<a href='/jero-boot/sys/common/downLoadFile?id=" + ossFile.getId() + "'" + " target='_blank'>下载</a>。";
+			String contentInfo = "您导出的" + paramsCollectManifestVO.getExportName()  + "已经生成完毕，请点击" + href;
+
+			SysAnnouncement sysAnnouncement = new SysAnnouncement();
+			sysAnnouncement.setDelFlag("0");
+			sysAnnouncement.setSendStatus("0");
+			sysAnnouncement.setSendTime(new Date());
+			sysAnnouncement.setMsgCategory(MessageTypeEnum.PUSH.getValue()); //消息类型：转发推送
+			sysAnnouncement.setInitiator(MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName()); // 发起人：系统
+			sysAnnouncement.setMsgType(CommonConstant.MSG_TYPE_UESR);//指定用户
+			sysAnnouncement.setTitile(msgTitle);
+			sysAnnouncement.setMsgContent(content);
+			sysAnnouncement.setMsgContentInfo(contentInfo);
+			sysAnnouncement.setUserIds(currentUser.getId()); // 发送给当前导出人
+			sysAnnouncementService.saveAnnouncement(sysAnnouncement);
+
+			JSONObject obj = new JSONObject();
+			obj.put(WebsocketConst.MSG_CMD, WebsocketConst.CMD_TOPIC);
+			obj.put(WebsocketConst.MSG_ID, currentUser.getId());
+			obj.put(WebsocketConst.MSG_TXT, contentInfo);
+			webSocket.sendMessage(obj.toJSONString());
+
+			uploadFileio.close();
 			os.flush();
 			os.close(); // 后开先关
 			fis.close(); // 先开后关