weizhiqiang1995/erp-pro
1
1
Fork 0
mirror of https://github.com/weizhiqiang1995/erp-pro.git synced 2025-02-28 17:33:25 +08:00
Code Issues Projects Releases Packages Wiki Activity

feat: 发送消息通知的任务修改

Browse source
This commit is contained in:
DESKTOP-ESU4BDD\WeiZhiQiang 2024-01-31 21:19:51 +08:00
parent ff2596f2ac
commit 9391b4a55f
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
skyeye-promote/skyeye-mq/src/main/java/com/skyeye/mq/job/impl/NoticeSendServiceImpl.java
View file

@ -3,6 +3,7 @@
******************************************************************************/ ******************************************************************************/
package com.skyeye.mq.job.impl; package com.skyeye.mq.job.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.skyeye.common.constans.MqConstants; import com.skyeye.common.constans.MqConstants;
import com.skyeye.common.util.MailUtil; import com.skyeye.common.util.MailUtil;
@ -46,9 +47,9 @@ public class NoticeSendServiceImpl implements RocketMQListener<String> {
List<Map<String, Object>> beans = JSONUtil.toList(email, null); List<Map<String, Object>> beans = JSONUtil.toList(email, null);
for (int i = 0; i < beans.size(); i++) { for (int i = 0; i < beans.size(); i++) {
Map<String, Object> bean = beans.get(i); Map<String, Object> bean = beans.get(i);
if (bean != null && !bean.isEmpty()) { if (CollectionUtil.isNotEmpty(bean)) {
// 邮件账号不为空，发送邮件 // 邮件账号不为空，发送邮件
new MailUtil().send(bean.get("userEmail").toString(), map.get("title").toString(), map.get("content").toString()); new MailUtil().send(bean.get("email").toString(), map.get("title").toString(), map.get("content").toString());
} }
} }
// 任务完成 // 任务完成