林武泰/新增定时任务-邮箱通知功能（收件人待改email 已TODO）

lab-admin/src/main/java/com/ruoyi/RuoYiApplication.java

@@ -3,6 +3,7 @@ package com.ruoyi;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 /**
  * 启动程序
@@ -10,6 +11,7 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  * @author ruoyi
  */
 @SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
+@EnableScheduling
 public class RuoYiApplication
 {
     public static void main(String[] args)

lab-admin/src/main/java/com/ruoyi/asset/schedule/task.java

@@ -0,0 +1,18 @@
+package com.ruoyi.asset.schedule;
+
+import com.ruoyi.asset.service.ITbAssetBorrowRecordService;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+public class task {
+    @Resource
+    private ITbAssetBorrowRecordService borrowRecordService;
+
+    @Scheduled(cron = "0 0 8 ? * *")
+    private void execute() {
+        borrowRecordService.informNotReturnUser();
+    }
+}

lab-admin/src/main/java/com/ruoyi/asset/service/ITbAssetBorrowRecordService.java

@@ -112,4 +112,9 @@ public interface ITbAssetBorrowRecordService extends IService<TbAssetBorrowRecor
      * @return 统计数量
      */
     AjaxResult countMeTbAssetBorrowRecord(Long status);
+
+    /**
+     * 通知未归还借用人
+     */
+    void informNotReturnUser();
 }

lab-admin/src/main/java/com/ruoyi/asset/service/impl/TbAssetBorrowRecordServiceImpl.java

@@ -1,8 +1,8 @@
 package com.ruoyi.asset.service.impl;
 
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.util.StrUtil;
@@ -15,13 +15,12 @@ import com.ruoyi.asset.domain.dto.TbBorrowRecordDTO;
 import com.ruoyi.asset.mapper.TbAssetMapper;
 import com.ruoyi.asset.mapper.TbAssetStatusRecordMapper;
 import com.ruoyi.asset.mapper.TbPlaceMapper;
+import com.ruoyi.asset.utils.EmailUtils;
 import com.ruoyi.common.core.domain.entity.SysUser;
 import com.ruoyi.common.utils.UserUtils;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.system.mapper.SysUserMapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ruoyi.asset.mapper.TbAssetBorrowRecordMapper;
@@ -39,8 +38,6 @@ import javax.annotation.Resource;
 @Service
 public class TbAssetBorrowRecordServiceImpl extends ServiceImpl<TbAssetBorrowRecordMapper, TbAssetBorrowRecord> implements ITbAssetBorrowRecordService
 {
-    private static final Logger log = LoggerFactory.getLogger(TbAssetBorrowRecordServiceImpl.class);
-
     @Autowired
     private TbAssetBorrowRecordMapper tbAssetBorrowRecordMapper;
 
@@ -272,4 +269,67 @@ public class TbAssetBorrowRecordServiceImpl extends ServiceImpl<TbAssetBorrowRec
         int count = count(borrowRecordQueryWrapper);
         return AjaxResult.success("查询成功", count);
     }
+
+    @Resource
+    private EmailUtils emailUtils;
+
+    @Override
+    public void informNotReturnUser() {
+        Date date = new Date();
+
+        long time = date.getTime();
+        long five = 5 * 24 * 60 * 60 * 1000;
+        long fiveDate = five + time;
+        Date toDate = new Date(fiveDate);
+
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String begin = dateFormat.format(date);
+        String end = dateFormat.format(toDate);
+
+        List<TbAssetBorrowRecord> borrowRecords = query().eq("isReturn", 0).ge("return_date", begin).le("return_date", end).list();
+        List<TbAssetBorrowRecord> borrowRecordList = borrowRecords.stream().filter(Objects::nonNull).collect(Collectors.toList());
+
+        if (borrowRecordList.isEmpty()) {
+            return;
+        }
+        Set<Long> userIdSet = new HashSet<>();
+
+        for (TbAssetBorrowRecord borrowRecord : borrowRecordList) {
+            userIdSet.add(borrowRecord.getUserId());
+        }
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        String nowDate = simpleDateFormat.format(date);
+
+        for (Long userId : userIdSet) {
+            SysUser sysUser = sysUserMapper.selectUserById(userId);
+            String email = sysUser.getEmail();
+            List<TbAssetBorrowRecord> collect = borrowRecordList.stream().filter(record -> record.getUserId().equals(userId)).collect(Collectors.toList());
+
+            String start = "<!DOCTYPE html>\r\n" +
+                    "<html>\r\n" +
+                    "<head>\r\n" +
+                    "<meta charset=\"UTF-8\">\r\n" +
+                    "<title>Insert title here</title>\r\n" +
+                    "</head>\r\n" +
+                    "<body>\r\n" +
+                    "<h3>"+ nowDate +"待归还设备提醒</h3>" +
+                    "<table border=\"1\">";
+            StringBuilder content = new StringBuilder("<tr><th style=\"font-size: 18px\">设备条形码</th><th style=\"font-size: 18px\">归还时间</th></tr>");
+            String end2 = "</table>" +
+                    "</body>\r\n" +
+                    "</html>";
+            for (TbAssetBorrowRecord borrowRecord : collect) {
+                String assetBarCode = borrowRecord.getAssetBarCode();
+                Date returnDate = borrowRecord.getReturnDate();
+                SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                String returnTime = simpleDateFormat1.format(returnDate);
+                content.append("<tr><td style=\"font-size: 18px\">").append(assetBarCode).append("</td>");
+                content.append("<td style=\"font-size: 18px\">").append(returnTime).append("</td></tr>");
+            }
+            String html = start + content + end2;
+
+            // TODO 邮箱记得更换回来
+            emailUtils.sendHtmlMail("2786794141@qq.com", "待归还设备提醒", html);
+        }
+    }
 }

lab-admin/src/main/java/com/ruoyi/asset/utils/EmailUtils.java

@@ -0,0 +1,103 @@
+package com.ruoyi.asset.utils;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.FileSystemResource;
+import org.springframework.mail.SimpleMailMessage;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import javax.mail.internet.MimeMessage;
+import java.io.File;
+
+@Component
+public class EmailUtils {
+    private final Logger logger = LoggerFactory.getLogger(EmailUtils.class);
+
+    @Resource
+    private JavaMailSender sender;
+
+    @Value("${spring.mail.username}")
+    private String fromMail;
+
+    /**
+     * 发送普通邮件
+     *
+     * @param toMail 收件人
+     * @param subject 标题
+     * @param content 邮件内容
+     */
+    public void sendSimpleEmail(String toMail, String subject, String content) {
+        SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
+        simpleMailMessage.setFrom(fromMail);
+        simpleMailMessage.setTo(toMail);
+        simpleMailMessage.setSubject(subject);
+        simpleMailMessage.setText(content);
+
+        try {
+            sender.send(simpleMailMessage);
+            logger.info("发送给:{}简单邮件已发送==》subject:{}", toMail, subject);
+        } catch (Exception e) {
+            logger.info("发送给:{}send mail error subject:{}", toMail, subject);
+            e.printStackTrace();
+        }
+
+    }
+
+    /**
+     * 发送带HTML格式邮件
+     *
+     * @param toMail 收件方
+     * @param subject 标题
+     * @param content 邮件内容
+     */
+    public void sendHtmlMail(String toMail, String subject, String content) {
+        // 封装数据
+        MimeMessage mimeMessage = sender.createMimeMessage();
+
+        try {
+            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage);
+            mimeMessageHelper.setTo(toMail);
+            mimeMessageHelper.setFrom(fromMail);
+            mimeMessageHelper.setText(content, true);
+            mimeMessageHelper.setSubject(subject);
+
+            // 发送邮件
+            sender.send(mimeMessage);
+            logger.info("发送给:{}html邮件已发送==》subject:{}", toMail, subject);
+        } catch (Exception e) {
+            logger.info("发送给:{}html send mail error subject:{}", toMail, subject);
+            e.printStackTrace();
+        }
+    }
+
+    public void sendFileMail(String toMail, String subject, String content, String filePath) {
+
+        // 编写发送的数据
+        MimeMessage mimeMessage = sender.createMimeMessage();
+        try {
+            MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage, true);
+            mimeMessageHelper.setFrom(fromMail);
+            mimeMessageHelper.setTo(toMail);
+            mimeMessageHelper.setSubject(subject);
+            mimeMessageHelper.setText(content, true);
+            // 添加文件数据
+            File file = new File(filePath);
+            // 获取文件数据
+            FileSystemResource fileSystemResource = new FileSystemResource(file);
+            // 获取文件名称
+            String fileName = file.getName();
+            // 添加数据
+            mimeMessageHelper.addAttachment(fileName, fileSystemResource);
+            // 发送邮件
+            sender.send(mimeMessage);
+            logger.info("发送给:{}带附件的邮件已发送", toMail);
+        } catch (Exception e) {
+            logger.info("发送给:{}带附件的邮件时发生异常", toMail);
+            e.printStackTrace();
+        }
+    }
+}

lab-admin/src/main/resources/application.yml

@@ -89,6 +89,16 @@ spring:
         max-active: 8
         # #连接池最大阻塞等待时间（使用负值表示没有限制）
         max-wait: -1ms
+  mail:
+    host: smtp.qq.com
+    username: 2130933887@qq.com
+    password: wcwoluyjkuvefcib
+    properties:
+      mail:
+        smtp: true
+      starttls:
+        enable: true
+        required: true
 
 # token配置
 token:

lab-common/pom.xml

@@ -139,6 +139,18 @@
             <version>3.4.3</version>
         </dependency>
 
+        <!--邮件服务-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-mail</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>commons-net</groupId>
+            <artifactId>commons-net</artifactId>
+            <version>3.3</version>
+        </dependency>
+
     </dependencies>
 
 </project>

lab-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java

@@ -3,6 +3,8 @@ package com.ruoyi.quartz.task;
 import org.springframework.stereotype.Component;
 import com.ruoyi.common.utils.StringUtils;
 
+import javax.annotation.Resource;
+
 /**
  * 定时任务调度测试
  * 
@@ -11,6 +13,7 @@ import com.ruoyi.common.utils.StringUtils;
 @Component("ryTask")
 public class RyTask
 {
+
     public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
     {
         System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));