1

13693261870

2024-11-13 2f55cebbad3dea187a5f91d16ec80a9677dab699

 src/main/java/com/yssh/service/EmailService.java

@@ -15,12 +15,6 @@
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 邮件服务类
 *
 * @author www
 * @date 2024-03-21
 */
@Service
public class EmailService {
    @Value("${email.userName}")
@@ -71,8 +65,13 @@
    @Value("${email.enable}")
    private Boolean enable;

    @Value("${email.debug}")
    private Boolean debug;

    @Resource
    private QxshMapper qxshMapper;

    private static boolean isBusy = false;

    private final static SimpleDateFormat YMDH = new SimpleDateFormat("yyyyMMddHH");

@@ -81,14 +80,13 @@
    protected final Logger logger = LoggerFactory.getLogger(this.getClass());

    public Session createSession() {
        // 创建一个配置文件，并保存
        Properties props = new Properties();

        // SMTP服务器连接信息：126—smtp.126.com，163—smtp.163.com，qq-smtp.qq.com"
        props.put("mail.smtp.host", smtpHost); // SMTP主机名
        props.put("mail.smtp.port", smtpPort); // 主机端口号：126—25，163—645，qq-587
        props.put("mail.smtp.auth", smtpAuth); // 是否需要用户认证
        props.put("mail.smtp.starttls.enale", smtpTls); // 启用TlS加密
        // 126—smtp.126.com，163—smtp.163.com，qq-smtp.qq.com"
        props.put("mail.smtp.host", smtpHost);
        props.put("mail.smtp.port", smtpPort);
        props.put("mail.smtp.auth", smtpAuth);
        props.put("mail.smtp.starttls.enale", smtpTls);

        Session session = Session.getInstance(props, new Authenticator() {
            @Override
@@ -97,8 +95,7 @@
            }
        });

        // 控制台打印调试信息
        session.setDebug(true);
        session.setDebug(debug);

        return session;
    }
@@ -109,10 +106,8 @@
                return null;
            }

            // 创建Session会话
            Session session = createSession();

            // 创建邮件对象
            MimeMessage message = new MimeMessage(session);
            message.setSubject(title);
            message.setText(text);
@@ -128,7 +123,6 @@
                message.setRecipients(Message.RecipientType.CC, ias);
            }

            // 发送
            Transport.send(message);

            return true;
@@ -138,9 +132,33 @@
        }
    }

    public int calcData() {
        List<String> list = new ArrayList<>();
    public Integer calcData() {
        try {
            if (isBusy) {
                return null;
            }

            isBusy = true;
            List<String> list = new ArrayList<>();
            calcCsvData(list);
            calcDbData(list);

            int size = list.size();
            if (size > 0) {
                String text = String.join("、", list.toArray(new String[list.size()])) + "，近" + hours + "小时内存在数据缺失。";
                send(title, text);
            }
            isBusy = false;

            return size;
        } catch (Exception ex) {
            logger.error(ex.getMessage(), ex);
            isBusy = false;
            return null;
        }
    }

    private void calcCsvData(List<String> list) {
        String[] strs = names.split(",");
        int count = countCsv(bigPath, hours);
        if (0 == count) {
@@ -154,7 +172,9 @@
        if (0 == count) {
            list.add(strs[2]);
        }
    }

    private void calcDbData(List<String> list) {
        Calendar calendar = getCalendar(0);
        Integer iEnd = Integer.parseInt(YMDH.format(calendar.getTime()));
        String sEnd = Y_M_D_H.format(calendar.getTime());
@@ -162,7 +182,8 @@
        Integer iStart = Integer.parseInt(YMDH.format(calendar.getTime()));
        String sStart = Y_M_D_H.format(calendar.getTime());

        count = qxshMapper.countGcsjByTime(iStart, iEnd);
        String[] strs = names.split(",");
        int count = qxshMapper.countGcsjByTime(iStart, iEnd);
        if (0 == count) {
            list.add(strs[3]);
        }
@@ -182,14 +203,6 @@
        if (0 == count) {
            list.add(strs[7]);
        }

        int size = list.size();
        if (size > 0) {
            String text = String.join("、", list.toArray(new String[list.size()])) + "，近" + hours + "小时内存在数据缺失。";
            send(title, text);
        }

        return size;
    }

    public int countCsv(String path, Integer hours) {