|
|
@@ -1,20 +1,37 @@
|
|
|
package com.fjhx.service.impl;
|
|
|
|
|
|
+import cn.hutool.core.io.IoUtil;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.fjhx.dto.SendDto;
|
|
|
-import com.fjhx.entity.MailInfo;
|
|
|
-import com.fjhx.entity.Mailbox;
|
|
|
+import com.fjhx.entity.*;
|
|
|
import com.fjhx.mapper.MailInfoMapper;
|
|
|
-import com.fjhx.service.MailInfoService;
|
|
|
-import com.fjhx.service.MailboxService;
|
|
|
+import com.fjhx.service.*;
|
|
|
import com.fjhx.utils.EmailUtil;
|
|
|
+import com.fjhx.vo.MailDetailsVo;
|
|
|
+import com.sun.mail.imap.IMAPFolder;
|
|
|
+import com.sun.mail.imap.IMAPMessage;
|
|
|
+import com.sun.mail.imap.IMAPStore;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springblade.core.log.exception.ServiceException;
|
|
|
+import org.springblade.core.tool.api.R;
|
|
|
+import org.springblade.core.tool.utils.StringPool;
|
|
|
+import org.springblade.resource.entity.ObsUpload;
|
|
|
+import org.springblade.resource.feign.IObsClient;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
+import javax.mail.*;
|
|
|
+import javax.mail.internet.MimeUtility;
|
|
|
+import java.io.*;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Objects;
|
|
|
+
|
|
|
/**
|
|
|
* <p>
|
|
|
* 邮件主表 服务实现类
|
|
|
@@ -31,6 +48,117 @@ public class MailInfoServiceImpl extends ServiceImpl<MailInfoMapper, MailInfo> i
|
|
|
@Autowired
|
|
|
private MailboxService mailboxService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private MailInfoService mailInfoService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private MailAddressService mailAddressService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private MailMessageService mailMessageService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private MailAttachmentService mailAttachmentService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private IObsClient obsClient;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public MailDetailsVo getDetails(Long mailId) {
|
|
|
+ MailDetailsVo mailDetailsVo = new MailDetailsVo();
|
|
|
+
|
|
|
+ MailInfo mailInfo = mailInfoService.getById(mailId);
|
|
|
+ if (mailInfo == null) {
|
|
|
+ throw new ServiceException("没有找到邮件信息");
|
|
|
+ }
|
|
|
+
|
|
|
+ Integer messageSync = mailInfo.getMessageSync();
|
|
|
+ Integer addressSync = mailInfo.getAddressSync();
|
|
|
+ Integer attachmentSync = mailInfo.getAttachmentSync();
|
|
|
+
|
|
|
+ if (ObjectUtil.notEqual(messageSync, 1) || ObjectUtil.notEqual(addressSync, 1) || ObjectUtil.notEqual(attachmentSync, 1)) {
|
|
|
+
|
|
|
+ Mailbox mailbox = mailboxService.getById(mailInfo.getMailboxId());
|
|
|
+ IMAPStore imapStore = null;
|
|
|
+ IMAPFolder folder = null;
|
|
|
+
|
|
|
+ try {
|
|
|
+ imapStore = EmailUtil.getIMAPStore(mailbox.getMailHost(), mailbox.getMailboxName(), mailbox.getMailboxPwd());
|
|
|
+ folder = (IMAPFolder) imapStore.getFolder(mailInfo.getFolderName());
|
|
|
+ folder.open(Folder.READ_ONLY);
|
|
|
+ IMAPMessage message = (IMAPMessage) folder.getMessage(mailInfo.getMessageNumber());
|
|
|
+
|
|
|
+ // 同步地址
|
|
|
+ if (ObjectUtil.notEqual(addressSync, 1)) {
|
|
|
+ List<MailAddress> mailAddressList = EmailUtil.mailAddressList(message, mailId);
|
|
|
+ mailDetailsVo.setMailAddressList(mailAddressList);
|
|
|
+ new Thread(() -> {
|
|
|
+ mailAddressService.saveBatch(mailAddressList);
|
|
|
+ mailInfoService.update(Wrappers.<MailInfo>lambdaUpdate()
|
|
|
+ .eq(MailInfo::getId, mailId).set(MailInfo::getAddressSync, 1));
|
|
|
+ }).start();
|
|
|
+ }
|
|
|
+
|
|
|
+ // 附件正文
|
|
|
+ if (ObjectUtil.notEqual(messageSync, 1) || ObjectUtil.notEqual(attachmentSync, 1)) {
|
|
|
+ MailMessage mailMessage = new MailMessage();
|
|
|
+ mailMessage.setMailInfoId(mailId);
|
|
|
+
|
|
|
+ List<MailAttachment> mailAttachmentList = new ArrayList<>();
|
|
|
+
|
|
|
+ mailDetailsVo.setMessage(mailMessage);
|
|
|
+ mailDetailsVo.setMailAttachmentList(mailAttachmentList);
|
|
|
+
|
|
|
+ saveMessageAndAttachment(mailDetailsVo, message);
|
|
|
+
|
|
|
+ new Thread(() -> {
|
|
|
+ mailMessageService.save(mailMessage);
|
|
|
+ mailAttachmentService.saveBatch(mailAttachmentList);
|
|
|
+
|
|
|
+ mailInfoService.update(Wrappers.<MailInfo>lambdaUpdate().eq(MailInfo::getId, mailId)
|
|
|
+ .set(MailInfo::getMessageSync, 1).set(MailInfo::getAttachmentSync, 1));
|
|
|
+ }).start();
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("获取邮件出错", e);
|
|
|
+ throw new ServiceException("获取邮件出错");
|
|
|
+ } finally {
|
|
|
+ try {
|
|
|
+ if (imapStore != null) {
|
|
|
+ if (imapStore.isConnected()) {
|
|
|
+ imapStore.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (folder != null) {
|
|
|
+ if (folder.isOpen()) {
|
|
|
+ folder.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (MessagingException e) {
|
|
|
+ log.error("关闭链接失败", e);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (Objects.equals(addressSync, 1)) {
|
|
|
+ List<MailAddress> mailAddressList = mailAddressService.list(Wrappers.<MailAddress>lambdaQuery().eq(MailAddress::getMailInfoId, mailId));
|
|
|
+ mailDetailsVo.setMailAddressList(mailAddressList);
|
|
|
+ }
|
|
|
+ if (Objects.equals(messageSync, 1)) {
|
|
|
+ List<MailMessage> list = mailMessageService.list(Wrappers.<MailMessage>lambdaQuery().eq(MailMessage::getMailInfoId, mailId));
|
|
|
+ if (list.size() > 0)
|
|
|
+ mailDetailsVo.setMessage(list.get(0));
|
|
|
+ }
|
|
|
+ if (Objects.equals(attachmentSync, 1)) {
|
|
|
+ List<MailAttachment> list = mailAttachmentService.list(Wrappers.<MailAttachment>lambdaQuery().eq(MailAttachment::getMailInfoId, mailId));
|
|
|
+ mailDetailsVo.setMailAttachmentList(list);
|
|
|
+ }
|
|
|
+
|
|
|
+ return mailDetailsVo;
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public void send(SendDto dto) {
|
|
|
String mailboxId = dto.getMailboxId();
|
|
|
@@ -45,4 +173,164 @@ public class MailInfoServiceImpl extends ServiceImpl<MailInfoMapper, MailInfo> i
|
|
|
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 保存附件和正文
|
|
|
+ */
|
|
|
+ private void saveMessageAndAttachment(MailDetailsVo mailDetailsVo, Part part) throws MessagingException, IOException {
|
|
|
+ MailMessage message = mailDetailsVo.getMessage();
|
|
|
+ List<MailAttachment> mailAttachmentList = mailDetailsVo.getMailAttachmentList();
|
|
|
+
|
|
|
+ // 正文：文本格式
|
|
|
+ if (part.isMimeType("text/plain")) {
|
|
|
+ addPlain(part, message);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 正文：html格式
|
|
|
+ else if (part.isMimeType("text/html")) {
|
|
|
+ addHtml(part, message);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 大对象
|
|
|
+ else if (part.isMimeType("multipart/*")) {
|
|
|
+
|
|
|
+ // 复杂体邮件
|
|
|
+ Multipart multipart = (Multipart) part.getContent();
|
|
|
+
|
|
|
+ // 复杂体邮件包含多个邮件体
|
|
|
+ int partCount = multipart.getCount();
|
|
|
+
|
|
|
+ for (int i = 0; i < partCount; i++) {
|
|
|
+
|
|
|
+ // 获得复杂体邮件中其中一个邮件体
|
|
|
+ BodyPart bodyPart = multipart.getBodyPart(i);
|
|
|
+
|
|
|
+ // 某一个邮件体也有可能是由多个邮件体组成的复杂体
|
|
|
+ String disposition = bodyPart.getDisposition();
|
|
|
+
|
|
|
+ // 正文：html格式
|
|
|
+ if (bodyPart.isMimeType("text/html")) {
|
|
|
+ addHtml(bodyPart, message);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 正文：文本格式
|
|
|
+ if (bodyPart.isMimeType("text/plain")) {
|
|
|
+ addPlain(bodyPart, message);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 附件
|
|
|
+ else if (disposition != null && (disposition.equalsIgnoreCase(Part.ATTACHMENT) || disposition.equalsIgnoreCase(Part.INLINE))) {
|
|
|
+ addFile(bodyPart, mailAttachmentList, message.getMailInfoId());
|
|
|
+ }
|
|
|
+
|
|
|
+ // 大对象
|
|
|
+ else if (bodyPart.isMimeType("multipart/*")) {
|
|
|
+ saveMessageAndAttachment(mailDetailsVo, bodyPart);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 其他类型
|
|
|
+ else {
|
|
|
+ String contentType = bodyPart.getContentType();
|
|
|
+ if (contentType.contains("name") || contentType.contains("application")) {
|
|
|
+ addFile(bodyPart, mailAttachmentList, message.getMailInfoId());
|
|
|
+ } else {
|
|
|
+ log.error("未知文件格式：{} ，邮件id：{}，待解析", contentType, message.getMailInfoId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // rfc822
|
|
|
+ else if (part.isMimeType("message/rfc822")) {
|
|
|
+ saveMessageAndAttachment(mailDetailsVo, (Part) part.getContent());
|
|
|
+ }
|
|
|
+ // 未知格式
|
|
|
+ else {
|
|
|
+ log.error("未知文件格式：{} ，邮件id：{}，待解析", part.getContentType(), message.getMailInfoId());
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addFile(Part part, List<MailAttachment> mailAttachmentList, Long mailInfoId) throws MessagingException, IOException {
|
|
|
+ InputStream is = part.getInputStream();
|
|
|
+ String fileName = decodeText(part.getFileName());
|
|
|
+
|
|
|
+ String path = uploadFile(is, fileName);
|
|
|
+ MailAttachment mailAttachment = new MailAttachment();
|
|
|
+ mailAttachment.setName(fileName);
|
|
|
+ mailAttachment.setUrl(path);
|
|
|
+ mailAttachment.setMailInfoId(mailInfoId);
|
|
|
+ mailAttachmentList.add(mailAttachment);
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addHtml(Part part, MailMessage message) throws MessagingException, IOException {
|
|
|
+ Object content = part.getContent();
|
|
|
+ if (content != null) {
|
|
|
+ message.setContent(content.toString());
|
|
|
+ } else {
|
|
|
+ message.setContent(StringPool.EMPTY);
|
|
|
+ }
|
|
|
+ message.setMimeType("text/html");
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addPlain(Part part, MailMessage message) throws MessagingException, IOException {
|
|
|
+ Object content = part.getContent();
|
|
|
+ if (content != null) {
|
|
|
+ if (ObjectUtil.notEqual(message.getMimeType(), "text/html")) {
|
|
|
+ message.setContent(content.toString());
|
|
|
+ message.setMimeType("text/plain");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 文本解码
|
|
|
+ */
|
|
|
+ private String decodeText(String encodeText) throws UnsupportedEncodingException {
|
|
|
+ if (encodeText == null || StringPool.EMPTY.equals(encodeText)) {
|
|
|
+ return StringPool.EMPTY;
|
|
|
+ } else {
|
|
|
+ return MimeUtility.decodeText(encodeText);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 上传文件
|
|
|
+ */
|
|
|
+ private String uploadFile(InputStream is, String fileName) {
|
|
|
+
|
|
|
+ BufferedInputStream bis = new BufferedInputStream(is);
|
|
|
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
|
|
|
+ BufferedOutputStream bos = new BufferedOutputStream(baos);
|
|
|
+
|
|
|
+ try {
|
|
|
+ int len;
|
|
|
+
|
|
|
+ while ((len = bis.read()) != -1) {
|
|
|
+ bos.write(len);
|
|
|
+ bos.flush();
|
|
|
+ }
|
|
|
+
|
|
|
+ bos.write(is.read());
|
|
|
+
|
|
|
+ // 上次附件至华为云
|
|
|
+ ObsUpload obsUpload = new ObsUpload();
|
|
|
+ obsUpload.setFileName(fileName);
|
|
|
+ obsUpload.setBytes(baos.toByteArray());
|
|
|
+ R<JSONObject> jsonObjectR = obsClient.uploadHuaWei(obsUpload);
|
|
|
+ if (jsonObjectR.isSuccess()) {
|
|
|
+ JSONObject data = jsonObjectR.getData();
|
|
|
+ return data.getString("path");
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("上传文件出错", e);
|
|
|
+ throw new ServiceException("获取附件出现错误");
|
|
|
+ } finally {
|
|
|
+ IoUtil.close(bos);
|
|
|
+ IoUtil.close(baos);
|
|
|
+ IoUtil.close(bis);
|
|
|
+ IoUtil.close(is);
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
}
|
24282