diff --git a/src/main/java/com/xujie/sys/modules/oss/service/impl/SysOssServiceImpl.java b/src/main/java/com/xujie/sys/modules/oss/service/impl/SysOssServiceImpl.java index 9c1dbcdb..77d368ad 100644 --- a/src/main/java/com/xujie/sys/modules/oss/service/impl/SysOssServiceImpl.java +++ b/src/main/java/com/xujie/sys/modules/oss/service/impl/SysOssServiceImpl.java @@ -34,16 +34,31 @@ import com.aspose.words.Document; import com.aspose.cells.Workbook; +import com.xujie.sys.modules.ecss.mapper.CoDelMapper; +import com.xujie.sys.modules.ecss.data.EcssCoDelNotifyHeaderData; +import com.xujie.sys.modules.pms.mapper.QcMapper; +import com.xujie.sys.modules.pms.data.MailSendAddressData; +import com.xujie.sys.modules.pms.data.SendMailRecord; +import com.xujie.sys.modules.sys.entity.SysUserEntity; +import com.xujie.sys.common.utils.MailUtil; +import lombok.extern.slf4j.Slf4j; + import java.io.File; @Service("sysOssService") - +@Slf4j public class SysOssServiceImpl extends ServiceImpl implements SysOssService { @Autowired private SysOssDao sysOssDao; + @Autowired + private CoDelMapper coDelMapper; + + @Autowired + private QcMapper qcMapper; + @Override public PageUtils queryPage(Map params) { String fileName = (String)params.get("fileName"); @@ -124,6 +139,17 @@ public class SysOssServiceImpl extends ServiceImpl impl oss.setOrderReftype("询价文档"); this.save(oss); } + + // 如果是确认页面上传的文档（orderRef6=2），发送邮件给发货通知单创建人 + if ("2".equals(oss.getOrderRef6()) && StringUtils.isNotBlank(oss.getOrderRef1()) + && StringUtils.isNotBlank(oss.getOrderRef2())) { + try { + sendDocumentUploadNotification(oss); + } catch (Exception e) { + log.error("发送文档上传通知邮件失败: {}", e.getMessage(), e); + // 邮件发送失败不影响文件上传，只记录日志 + } + } } @Override @Transactional @@ -423,4 +449,90 @@ public class SysOssServiceImpl extends ServiceImpl impl document.save(pdfPath); System.out.println("Word 文件转换为 PDF 成功，保存路径：" + pdfPath); } + + /** + * 发送文档上传通知邮件给发货通知单创建人 + * + * @param oss 文件信息 + */ + private void sendDocumentUploadNotification(SysOssEntity oss) { + try { + // 查询发货通知单信息，获取创建人 + List headerList = coDelMapper.checkEcssCoDelNotifyHeaderByDelNo( + oss.getOrderRef1(), oss.getOrderRef2()); + + if (headerList == null || headerList.isEmpty()) { + log.warn("未找到发货通知单，site={}, delNo={}", oss.getOrderRef1(), oss.getOrderRef2()); + return; + } + + EcssCoDelNotifyHeaderData headerData = headerList.get(0); + + // 查询创建人邮箱 + SysUserEntity creator = coDelMapper.queryByUserName(headerData.getCreateBy()); + if (creator == null || StringUtils.isBlank(creator.getEmail())) { + log.warn("发货通知单创建人{}不存在或没有配置邮箱地址", headerData.getCreateBy()); + return; + } + + // 构建邮件内容 + String textHead = String.format("发货通知单 %s【发票：%s】- 仓库确认文档上传通知", + headerData.getDelNo(), headerData.getCmcInvoice()); + + StringBuilder emailContent = new StringBuilder(); + emailContent.append(""); + emailContent.append(""); + emailContent.append(""); + emailContent.append(""); + emailContent.append("

发货通知单仓库确认文档上传通知

"); + emailContent.append("

发货通知单号：").append(headerData.getDelNo()).append("

"); + emailContent.append("

发票号：").append(headerData.getCmcInvoice()).append("

"); + emailContent.append("

上传人：").append(oss.getCreatedBy()).append("

"); + emailContent.append("

上传时间：").append(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(oss.getCreateDate())).append("

"); + emailContent.append("

文件名称：").append(oss.getFileName()).append("

"); + + emailContent.append("

请登录系统查看详细信息。

"); + emailContent.append(""); + emailContent.append(""); + + // 发送邮件 + String[] mailAddress = new String[]{creator.getEmail()}; + sendMailUtil(textHead, emailContent.toString(), mailAddress, headerData); + + log.info("文档上传通知邮件已发送，收件人: {}, 发货通知单号: {}", creator.getEmail(), headerData.getDelNo()); + + } catch (Exception e) { + log.error("发送文档上传通知邮件失败: {}", e.getMessage(), e); + throw e; + } + } + + /** + * 发送邮件工具方法 + * + * @param textHead 邮件主题 + * @param text 邮件内容 + * @param mailAddress 收件人邮箱数组 + * @param data 发货通知单数据 + */ + private void sendMailUtil(String textHead, String text, String[] mailAddress, EcssCoDelNotifyHeaderData data) { + try { + MailSendAddressData mailSendData = qcMapper.getSendMailFromAddress(); + MailUtil.sendMail(textHead, text, mailAddress, mailSendData); + + // 保存邮件记录 + SendMailRecord mailRecord = new SendMailRecord(); + mailRecord.setSite(data.getSite()); + mailRecord.setBuNo(data.getBuNo()); + mailRecord.setDocumentNo(data.getDelNo()); + mailRecord.setSender(data.getCreateBy()); + mailRecord.setRecipient(Arrays.toString(mailAddress)); + mailRecord.setType("关务系统-文档上传"); + qcMapper.saveSendMailRecord(mailRecord); + + } catch (Exception e) { + log.error("邮件发送失败: {}", e.getMessage(), e); + throw e; + } + } }