package com.ots.project.monitor.job.task;
|
|
import cn.hutool.core.date.DateUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.ots.common.enums.SenderType;
|
import com.ots.common.enums.SendtaskStatus;
|
import com.ots.common.enums.SmsStatusEnum;
|
import com.ots.common.utils.bean.BeanUtils;
|
import com.ots.framework.web.service.ConfigService;
|
import com.ots.project.exam.domain.EntTestMember;
|
import com.ots.project.exam.domain.EntTestSendtask;
|
import com.ots.project.exam.domain.EntTestSendtaskMail;
|
import com.ots.project.exam.service.IEntTestSendtaskMailService;
|
import com.ots.project.exam.service.impl.EntTestMemberServiceImpl;
|
import com.ots.project.exam.service.impl.EntTestSendtaskServiceImpl;
|
import com.ots.project.tool.email.*;
|
import com.ots.project.tool.email.utils.BouncedUser;
|
import com.ots.project.tool.email.utils.DefaultConfigurer;
|
import com.ots.project.tool.email.utils.EmailUtil;
|
import com.ots.project.tool.sms.ResponseSms;
|
import com.ots.project.tool.sms.Returnsms;
|
import com.ots.project.tool.sms.ShortMessage;
|
import com.ots.project.tool.sms.Statusbox;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
import static com.ots.common.enums.SmsStatusEnum.*;
|
|
/**
|
* 邮件短信发送任务
|
*/
|
@Component("senderTask")
|
@Slf4j
|
public class SenderTask {
|
|
private static final String SMS_ZJCM = "SMS_ZJCM";
|
private static final String SMS_ZJCM_INTERNATIONAL = "SMS_ZJCM_INTERNATIONAL";
|
private static final String EMAIL_126 = "EMAIL_126";
|
@Autowired
|
EntTestSendtaskServiceImpl entTestSendtaskService;
|
@Autowired
|
EntTestMemberServiceImpl entTestMemberService;
|
@Autowired
|
ShortMessage shortMessage;
|
@Autowired
|
EmailMessage emailMessage;
|
@Autowired
|
IEntTestSendtaskMailService entTestSendtaskMailService;
|
|
@Autowired
|
private ConfigService configService;
|
|
public void senderTask(String type) {
|
EntTestSendtask testSendtask = new EntTestSendtask();
|
testSendtask.setStatus(SendtaskStatus.Untreated.getStatus());
|
testSendtask.setType(type);
|
List<EntTestSendtask> entTestSendtasks = entTestSendtaskService.selectEntTestSendtaskList(testSendtask);
|
if (SenderType.email.getType().equals(type)) {
|
//发送邮件
|
entTestSendtasks.stream().forEach(p -> sendEmail(p));
|
//邮件退信情况处理 异步
|
bounceStatusUpdate();
|
}
|
if (SenderType.sms.getType().equals(type)) {
|
//发送短信
|
entTestSendtasks.stream().forEach(p -> sendSms(p));
|
//短信下发状态跟进 异步
|
smsDeliveryStatus();
|
}
|
}
|
|
private void mailBounceInformationStorage(List<BouncedUser> bouncedUserList) {
|
try {
|
bouncedUserList.stream().forEach(user -> {
|
EntTestSendtaskMail mail = new EntTestSendtaskMail();
|
BeanUtils.copyProperties(user, mail);
|
mail.setCreateTime(new Date());
|
entTestSendtaskMailService.insertEntTestSendtaskMail(mail);
|
});
|
} catch (Exception e) {
|
log.error("记录退信信息失败：{}", e.getMessage(), e);
|
}
|
}
|
|
private void bounceStatusUpdate() {
|
String mailMode = configService.getKey("MailMode");
|
if (Objects.equals("RushMail", mailMode)) {
|
String rushMailRemoteUrl = configService.getKey("RushMailRemoteUrl");
|
SimpleMailSender sms = new SimpleMailSender();
|
RushMailResultCheck check = sms.mailResult(rushMailRemoteUrl + "mail/report", "rushmail", DateUtil.today());
|
if (Objects.nonNull(check.getData())) {
|
check.getData().stream().forEach(re -> {
|
String task_id = String.valueOf(re.get("task_id"));
|
String fail = String.valueOf(re.get("fail"));
|
String msg = String.valueOf(re.get("msg"));
|
String isOpen = String.valueOf(re.get("isOpen"));
|
if (!Objects.equals("0", fail)) {
|
EntTestSendtask entTestSendtask = new EntTestSendtask();
|
entTestSendtask.setRushtaskid(task_id);
|
List<EntTestSendtask> entTestSendtasks = entTestSendtaskService.selectEntTestSendtaskList(entTestSendtask);
|
if (Objects.nonNull(entTestSendtasks) && entTestSendtasks.size() > 0) {
|
EntTestSendtask task = entTestSendtasks.get(0);
|
if (Objects.equals("1", fail)) {
|
task.setStatus(invalid_address.getCode());
|
} else if (Objects.equals("2", fail)) {
|
task.setStatus(not_enough_space.getCode());
|
} else if (Objects.equals("3", fail)) {
|
task.setStatus(DISHONOR.getCode());
|
} else {
|
task.setStatus(SENDFAILD_3.getCode());
|
}
|
task.setMessage(msg);
|
entTestSendtaskService.updateEntTestSendtask(task);
|
}
|
}
|
if (Objects.equals("true", isOpen)) {
|
EntTestSendtask entTestSendtask = new EntTestSendtask();
|
entTestSendtask.setRushtaskid(task_id);
|
List<EntTestSendtask> entTestSendtasks = entTestSendtaskService.selectEntTestSendtaskList(entTestSendtask);
|
if (Objects.nonNull(entTestSendtasks) && entTestSendtasks.size() > 0) {
|
EntTestSendtask testSendtask = entTestSendtasks.get(0);
|
testSendtask.setStatus(ISOPEN.getCode());
|
testSendtask.setMessage(msg);
|
entTestSendtaskService.updateEntTestSendtask(testSendtask);
|
}
|
}
|
});
|
}
|
} else {
|
EmailUtil eu = new EmailUtil(EmailMessageImpl.userName, EmailMessageImpl.password);
|
List<BouncedUser> bouncedUserList = eu.receiveMail(DefaultConfigurer.getIMAP(), "imap");// imap收信
|
//邮件退信数据入库
|
mailBounceInformationStorage(bouncedUserList);
|
bouncedUserList.stream().forEach(user -> {
|
EntTestSendtask entTestSendtask = new EntTestSendtask();
|
String content = user.getContent();
|
String substring = content.substring(content.indexOf("收件人邮件地址（") + "收件人邮件地址（".length(), content.indexOf("）不存在，邮件无法送达"));
|
entTestSendtask.setAddressee(substring);
|
entTestSendtask.setSendExtendTime(user.getSentDateExtend());
|
entTestSendtask.setType("email");
|
List<EntTestSendtask> sendtasks = entTestSendtaskService.selectEntTestSendtaskList(entTestSendtask);
|
sendtasks.stream().forEach(obj -> {
|
obj.setStatus(RET_4.getCode());
|
obj.setMessage(user.getReason());
|
entTestSendtaskService.updateEntTestSendtask(obj);
|
});
|
});
|
}
|
}
|
|
public static void main(String[] args) {
|
String str = "12321231232131 nihaodfdfdl 收件人邮件地址（ljhua@bydq.com.cn）不存在，邮件无法送达。 ";
|
String substring = str.substring(str.indexOf("收件人邮件地址（") + "收件人邮件地址（".length(), str.indexOf("）不存在，邮件无法送达"));
|
System.out.println(substring);
|
}
|
|
private void smsDeliveryStatus() {
|
List<Statusbox> statusboxList = shortMessage.getReport();
|
if (Objects.isNull(statusboxList) || statusboxList.size() == 0) {
|
return;
|
}
|
System.out.println(JSON.toJSON(statusboxList));
|
for (int i = 0; i < statusboxList.size(); i++) {
|
Statusbox statusbox = statusboxList.get(i);
|
if (Objects.equals(statusbox.getStatus(), "20")) {
|
String taskid = statusbox.getTaskid();
|
EntTestSendtask entTestSendtask = new EntTestSendtask();
|
entTestSendtask.setTaskId(taskid);
|
List<EntTestSendtask> sendtasks = entTestSendtaskService.selectEntTestSendtaskList(entTestSendtask);
|
sendtasks.stream().forEach(obj -> {
|
obj.setStatus(RET_4.getCode());
|
obj.setMessage(statusbox.getErrorcode());
|
entTestSendtaskService.updateEntTestSendtask(obj);
|
});
|
}
|
}
|
}
|
|
/**
|
* 发邮件
|
*
|
* @param testSendtask
|
*/
|
public void sendEmail(EntTestSendtask testSendtask) {
|
if (Objects.equals(EMAIL_126, testSendtask.getPlatform())) {
|
RushMailResult result = emailMessage.sendEmail(testSendtask.getAddressee(), testSendtask.getTitle(), testSendtask.getContent());
|
if (result.isResult()) {
|
testSendtask.setStatus(SmsStatusEnum.issent_1.getCode());
|
testSendtask.setSendTime(new Date());
|
if (Objects.nonNull(result.getData()) && Objects.nonNull(result.getData().get("taskid"))) {
|
testSendtask.setRushtaskid(String.valueOf(result.getData().get("taskid")));
|
}
|
} else {
|
testSendtask.setStatus(SENDFAILD_3.getCode());
|
testSendtask.setMessage(result.getMessage());
|
}
|
} else {
|
testSendtask.setStatus(RET_4.getCode());
|
testSendtask.setMessage(testSendtask.getPlatform() + "邮箱平台未注册");
|
}
|
EntTestMember entTestMember = entTestMemberService.selectEntTestMemberById(testSendtask.getMemberId());
|
entTestMember.setEmailStatus(testSendtask.getStatus());
|
entTestMember.setEmailTime(new Date());
|
entTestMemberService.updateEntTestMember(entTestMember);
|
entTestSendtaskService.updateEntTestSendtask(testSendtask);
|
}
|
|
/**
|
* 发短信
|
*
|
* @param testSendtask
|
*/
|
public void sendSms(EntTestSendtask testSendtask) {
|
if (Objects.equals(SMS_ZJCM, testSendtask.getPlatform())) {
|
Returnsms returnsms = shortMessage.sendSms(Arrays.asList(testSendtask.getAddressee()), "【TAI测评】", testSendtask.getContent());
|
if (Objects.equals(Returnsms.RET_SUCCESS, returnsms.getReturnstatus())) {
|
log.debug("{}【短信发送成功！】", testSendtask.getAddressee());
|
testSendtask.setStatus(SmsStatusEnum.issent_1.getCode());
|
testSendtask.setNumber(Long.parseLong(returnsms.getSuccessCounts()));
|
testSendtask.setMessage("短信发送成功");
|
String taskId = returnsms.getTaskID();
|
if (Objects.nonNull(taskId)) {
|
testSendtask.setTaskId(taskId);
|
}
|
} else {
|
log.error("{}【短信发送失败！】: {}", testSendtask.getAddressee(), returnsms.getMessage());
|
testSendtask.setStatus(SENDFAILD_3.getCode());
|
testSendtask.setMessage(returnsms.getMessage());
|
}
|
} else if (Objects.equals(SMS_ZJCM_INTERNATIONAL, testSendtask.getPlatform())) {
|
ResponseSms responseSms = shortMessage.sendInternationalSms(Arrays.asList(testSendtask.getAddressee()), testSendtask.getContent());
|
if (Objects.equals(ResponseSms.Mterrcode.RET_000.getCode(), responseSms.getMterrcode())) {
|
log.debug("{}【国际短信发送成功！】", testSendtask.getAddressee());
|
testSendtask.setStatus(SmsStatusEnum.issent_1.getCode());
|
testSendtask.setNumber(new Long(1));
|
testSendtask.setMessage("国际短信发送成功");
|
} else {
|
log.error("{}【短信发送失败！】: {}", testSendtask.getAddressee(), responseSms.getMterrcode());
|
testSendtask.setStatus(SENDFAILD_3.getCode());
|
testSendtask.setMessage(responseSms.getMterrcode());
|
}
|
} else {
|
testSendtask.setStatus(RET_4.getCode());
|
testSendtask.setMessage(testSendtask.getPlatform() + "短信平台未注册");
|
}
|
EntTestMember entTestMember = entTestMemberService.selectEntTestMemberById(testSendtask.getMemberId());
|
entTestMember.setSmsStatus(testSendtask.getStatus());
|
entTestMember.setSmsTime(new Date());
|
entTestMemberService.updateEntTestMember(entTestMember);
|
entTestSendtaskService.updateEntTestSendtask(testSendtask);
|
}
|
}
|
