mirror of https://github.com/ZhongFuCheng3y/austin
3y
2 years ago
commit
cf8828502f
@ -0,0 +1,115 @@
|
||||
package com.java3y.austin.handler.receipt;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.date.DatePattern;
|
||||
import cn.hutool.core.date.DateUtil;
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.google.common.base.Throwables;
|
||||
import com.java3y.austin.common.constant.SendAccountConstant;
|
||||
import com.java3y.austin.common.dto.account.TencentSmsAccount;
|
||||
import com.java3y.austin.common.enums.SmsStatus;
|
||||
import com.java3y.austin.support.config.SupportThreadPoolConfig;
|
||||
import com.java3y.austin.support.dao.SmsRecordDao;
|
||||
import com.java3y.austin.support.domain.SmsRecord;
|
||||
import com.java3y.austin.support.utils.AccountUtils;
|
||||
import com.tencentcloudapi.common.Credential;
|
||||
import com.tencentcloudapi.common.exception.TencentCloudSDKException;
|
||||
import com.tencentcloudapi.common.profile.ClientProfile;
|
||||
import com.tencentcloudapi.common.profile.HttpProfile;
|
||||
import com.tencentcloudapi.sms.v20210111.SmsClient;
|
||||
import com.tencentcloudapi.sms.v20210111.models.*;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
|
||||
/**
|
||||
* 拉取短信回执信息
|
||||
*
|
||||
* @author 3y
|
||||
*/
|
||||
@Component
|
||||
@Slf4j
|
||||
public class TencentSmsReceipt {
|
||||
|
||||
|
||||
@Autowired
|
||||
private AccountUtils accountUtils;
|
||||
|
||||
@Autowired
|
||||
private SmsRecordDao smsRecordDao;
|
||||
|
||||
@PostConstruct
|
||||
private void init() {
|
||||
|
||||
// 获取腾讯云账号信息
|
||||
TencentSmsAccount account = accountUtils.getAccount(10, SendAccountConstant.SMS_ACCOUNT_KEY, SendAccountConstant.SMS_PREFIX, TencentSmsAccount.class);
|
||||
|
||||
SupportThreadPoolConfig.getPendingSingleThreadPool().execute(() -> {
|
||||
|
||||
while (true) {
|
||||
try {
|
||||
SmsClient client = getSmsClient(account);
|
||||
|
||||
// 每次拉取10条
|
||||
PullSmsSendStatusRequest req = new PullSmsSendStatusRequest();
|
||||
req.setLimit(10L);
|
||||
req.setSmsSdkAppId(account.getSmsSdkAppId());
|
||||
|
||||
PullSmsSendStatusResponse resp = client.PullSmsSendStatus(req);
|
||||
List<SmsRecord> smsRecordList = new ArrayList<>();
|
||||
if (resp != null && resp.getPullSmsSendStatusSet() != null && resp.getPullSmsSendStatusSet().length > 0) {
|
||||
log.debug("receipt sms:{}", JSON.toJSONString(resp.getPullSmsSendStatusSet()));
|
||||
for (PullSmsSendStatus pullSmsSendStatus : resp.getPullSmsSendStatusSet()) {
|
||||
SmsRecord smsRecord = SmsRecord.builder()
|
||||
.sendDate(Integer.valueOf(DateUtil.format(new Date(), DatePattern.PURE_DATE_PATTERN)))
|
||||
.messageTemplateId(0L)
|
||||
.phone(Long.valueOf(pullSmsSendStatus.getSubscriberNumber()))
|
||||
.supplierId(account.getSupplierId())
|
||||
.supplierName(account.getSupplierName())
|
||||
.msgContent("")
|
||||
.seriesId(pullSmsSendStatus.getSerialNo())
|
||||
.chargingNum(0)
|
||||
.status("SUCCESS".equals(pullSmsSendStatus.getReportStatus()) ? SmsStatus.RECEIVE_SUCCESS.getCode() : SmsStatus.RECEIVE_FAIL.getCode())
|
||||
.reportContent(pullSmsSendStatus.getDescription())
|
||||
.updated(Math.toIntExact(pullSmsSendStatus.getUserReceiveTime()))
|
||||
.created(Math.toIntExact(DateUtil.currentSeconds()))
|
||||
.build();
|
||||
smsRecordList.add(smsRecord);
|
||||
}
|
||||
}
|
||||
if (!CollUtil.isEmpty(smsRecordList)) {
|
||||
smsRecordDao.saveAll(smsRecordList);
|
||||
}
|
||||
Thread.sleep(200);
|
||||
} catch (Exception e) {
|
||||
log.error("TencentSmsReceipt#init fail!{}", Throwables.getStackTraceAsString(e));
|
||||
}
|
||||
}
|
||||
|
||||
});
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 构造smsClient
|
||||
* @param account
|
||||
* @return
|
||||
*/
|
||||
private SmsClient getSmsClient(TencentSmsAccount account) {
|
||||
Credential cred = new Credential(account.getSecretId(), account.getSecretKey());
|
||||
HttpProfile httpProfile = new HttpProfile();
|
||||
httpProfile.setEndpoint(account.getUrl());
|
||||
ClientProfile clientProfile = new ClientProfile();
|
||||
clientProfile.setHttpProfile(httpProfile);
|
||||
return new SmsClient(cred, account.getRegion(), clientProfile);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,67 @@
|
||||
package com.java3y.austin.web.vo.amis;
|
||||
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author 3y
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
public class SmsTimeLineVo {
|
||||
|
||||
/**
|
||||
* items
|
||||
*/
|
||||
private List<SmsTimeLineVo.ItemsVO> items;
|
||||
|
||||
/**
|
||||
* ItemsVO
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
public static class ItemsVO {
|
||||
/**
|
||||
* 业务ID
|
||||
*/
|
||||
private String businessId;
|
||||
/**
|
||||
* detail 发送内容
|
||||
*/
|
||||
private String content;
|
||||
|
||||
/**
|
||||
* 发送状态
|
||||
*/
|
||||
private String sendType;
|
||||
|
||||
/**
|
||||
* 回执状态
|
||||
*/
|
||||
private String receiveType;
|
||||
|
||||
/**
|
||||
* 回执报告
|
||||
*/
|
||||
private String receiveContent;
|
||||
|
||||
/**
|
||||
* 发送时间
|
||||
*/
|
||||
private String sendTime;
|
||||
|
||||
/**
|
||||
* 回执时间
|
||||
*/
|
||||
private String receiveTime;
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue