|
|
|
@ -47,10 +47,6 @@ import java.text.SimpleDateFormat;
|
|
|
|
import java.util.Date;
|
|
|
|
import java.util.Date;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.Locale;
|
|
|
|
import java.util.Locale;
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import io.reactivex.rxjava3.core.Observable;
|
|
|
|
|
|
|
|
import io.reactivex.rxjava3.core.ObservableEmitter;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public class SendUtil {
|
|
|
|
public class SendUtil {
|
|
|
|
private static final String TAG = "SendUtil";
|
|
|
|
private static final String TAG = "SendUtil";
|
|
|
|
@ -174,40 +170,28 @@ public class SendUtil {
|
|
|
|
@SuppressWarnings("ResultOfMethodCallIgnored")
|
|
|
|
@SuppressWarnings("ResultOfMethodCallIgnored")
|
|
|
|
public static void senderSendMsgNoHandError(SmsVo smsVo, SenderModel senderModel, long logId, String smsTemplate, String regexReplace) {
|
|
|
|
public static void senderSendMsgNoHandError(SmsVo smsVo, SenderModel senderModel, long logId, String smsTemplate, String regexReplace) {
|
|
|
|
//网络请求+重试比较耗时，创建子线程处理
|
|
|
|
//网络请求+重试比较耗时，创建子线程处理
|
|
|
|
// new Thread(new Runnable() {
|
|
|
|
new Thread(() -> {
|
|
|
|
// @Override
|
|
|
|
try {
|
|
|
|
// public void run() {
|
|
|
|
//是否需要失败重试
|
|
|
|
//是否需要失败重试
|
|
|
|
int retryTimes = SettingUtil.getRetryTimes();
|
|
|
|
int retryTimes = SettingUtil.getRetryTimes();
|
|
|
|
if (retryTimes < 1) {
|
|
|
|
if (retryTimes < 1) {
|
|
|
|
SendUtil.senderSendMsg(null, null, smsVo, senderModel, logId, smsTemplate, regexReplace);
|
|
|
|
SendUtil.senderSendMsg(null, null, smsVo, senderModel, logId, smsTemplate, regexReplace);
|
|
|
|
} else {
|
|
|
|
return;
|
|
|
|
int delayTime = SettingUtil.getDelayTime();
|
|
|
|
}
|
|
|
|
RetryIntercepter retryInterceptor = new RetryIntercepter.Builder()
|
|
|
|
|
|
|
|
.executionCount(retryTimes)
|
|
|
|
try {
|
|
|
|
.retryInterval(delayTime)
|
|
|
|
int delayTime = SettingUtil.getDelayTime();
|
|
|
|
.logId(logId)
|
|
|
|
Observable
|
|
|
|
.build();
|
|
|
|
.create(emitter -> {
|
|
|
|
SendUtil.senderSendMsg(null, retryInterceptor, smsVo, senderModel, logId, smsTemplate, regexReplace);
|
|
|
|
Log.w(TAG, "RxJava 开始请求接口...");
|
|
|
|
}
|
|
|
|
SendUtil.senderSendMsg(null, emitter, smsVo, senderModel, logId, smsTemplate, regexReplace);
|
|
|
|
} catch (Exception e) {
|
|
|
|
})
|
|
|
|
Log.e(TAG, e.getMessage());
|
|
|
|
.retryWhen(attempts -> attempts.zipWith(Observable.range(1, retryTimes), (n, i) -> i).flatMap(i -> {
|
|
|
|
}
|
|
|
|
long delay = (long) i * delayTime;
|
|
|
|
}).start();
|
|
|
|
Log.w(TAG, "RxJava 请求接口异常，" + delay + "秒后重试");
|
|
|
|
|
|
|
|
return Observable.timer(delay, TimeUnit.SECONDS);
|
|
|
|
|
|
|
|
}).concatWith(Observable.error(new RuntimeException("请求接口失败，已重试 " + retryTimes + " 次"))))
|
|
|
|
|
|
|
|
.subscribe(
|
|
|
|
|
|
|
|
(i) -> System.out.println("onNext with " + i),
|
|
|
|
|
|
|
|
(error) -> System.out.println("OnError with " + error)
|
|
|
|
|
|
|
|
);
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
Log.e(TAG, e.getMessage());
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
// }).start();//启动线程
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static void senderSendMsg(Handler handError, ObservableEmitter<Object> emitter, SmsVo smsVo, SenderModel senderModel, long logId, String smsTemplate, String regexReplace) {
|
|
|
|
public static void senderSendMsg(Handler handError, RetryIntercepter retryInterceptor, SmsVo smsVo, SenderModel senderModel, long logId, String smsTemplate, String regexReplace) {
|
|
|
|
|
|
|
|
|
|
|
|
Log.i(TAG, "senderSendMsg smsVo:" + smsVo.toString() + "senderModel:" + senderModel.toString());
|
|
|
|
Log.i(TAG, "senderSendMsg smsVo:" + smsVo.toString() + "senderModel:" + senderModel.toString());
|
|
|
|
|
|
|
|
|
|
|
|
@ -224,7 +208,7 @@ public class SendUtil {
|
|
|
|
DingDingSettingVo dingDingSettingVo = JSON.parseObject(senderModel.getJsonSetting(), DingDingSettingVo.class);
|
|
|
|
DingDingSettingVo dingDingSettingVo = JSON.parseObject(senderModel.getJsonSetting(), DingDingSettingVo.class);
|
|
|
|
if (dingDingSettingVo != null) {
|
|
|
|
if (dingDingSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderDingdingMsg.sendMsg(logId, handError, emitter, dingDingSettingVo.getToken(), dingDingSettingVo.getSecret(), dingDingSettingVo.getAtMobiles(), dingDingSettingVo.getAtAll(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderDingdingMsg.sendMsg(logId, handError, retryInterceptor, dingDingSettingVo.getToken(), dingDingSettingVo.getSecret(), dingDingSettingVo.getAtMobiles(), dingDingSettingVo.getAtAll(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: dingding error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: dingding error " + e.getMessage());
|
|
|
|
@ -239,7 +223,7 @@ public class SendUtil {
|
|
|
|
EmailSettingVo emailSettingVo = JSON.parseObject(senderModel.getJsonSetting(), EmailSettingVo.class);
|
|
|
|
EmailSettingVo emailSettingVo = JSON.parseObject(senderModel.getJsonSetting(), EmailSettingVo.class);
|
|
|
|
if (emailSettingVo != null) {
|
|
|
|
if (emailSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderMailMsg.sendEmail(logId, handError, emitter, emailSettingVo.getProtocol(), emailSettingVo.getHost(), emailSettingVo.getPort(), emailSettingVo.getSsl(), emailSettingVo.getFromEmail(), emailSettingVo.getNickname(),
|
|
|
|
SenderMailMsg.sendEmail(logId, handError, emailSettingVo.getProtocol(), emailSettingVo.getHost(), emailSettingVo.getPort(), emailSettingVo.getSsl(), emailSettingVo.getFromEmail(), emailSettingVo.getNickname(),
|
|
|
|
emailSettingVo.getPwd(), emailSettingVo.getToEmail(), smsVo.getTitleForSend(emailSettingVo.getTitle(), regexReplace), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
emailSettingVo.getPwd(), emailSettingVo.getToEmail(), smsVo.getTitleForSend(emailSettingVo.getTitle(), regexReplace), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
@ -255,7 +239,7 @@ public class SendUtil {
|
|
|
|
BarkSettingVo barkSettingVo = JSON.parseObject(senderModel.getJsonSetting(), BarkSettingVo.class);
|
|
|
|
BarkSettingVo barkSettingVo = JSON.parseObject(senderModel.getJsonSetting(), BarkSettingVo.class);
|
|
|
|
if (barkSettingVo != null) {
|
|
|
|
if (barkSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderBarkMsg.sendMsg(logId, handError, emitter, barkSettingVo.getServer(), barkSettingVo.getIcon(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace), senderModel.getName());
|
|
|
|
SenderBarkMsg.sendMsg(logId, handError, retryInterceptor, barkSettingVo.getServer(), barkSettingVo.getIcon(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace), senderModel.getName());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderBarkMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderBarkMsg error " + e.getMessage());
|
|
|
|
@ -270,7 +254,7 @@ public class SendUtil {
|
|
|
|
WebNotifySettingVo webNotifySettingVo = JSON.parseObject(senderModel.getJsonSetting(), WebNotifySettingVo.class);
|
|
|
|
WebNotifySettingVo webNotifySettingVo = JSON.parseObject(senderModel.getJsonSetting(), WebNotifySettingVo.class);
|
|
|
|
if (webNotifySettingVo != null) {
|
|
|
|
if (webNotifySettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderWebNotifyMsg.sendMsg(logId, handError, emitter, webNotifySettingVo.getWebServer(), webNotifySettingVo.getWebParams(), webNotifySettingVo.getSecret(), webNotifySettingVo.getMethod(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderWebNotifyMsg.sendMsg(logId, handError, retryInterceptor, webNotifySettingVo.getWebServer(), webNotifySettingVo.getWebParams(), webNotifySettingVo.getSecret(), webNotifySettingVo.getMethod(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderWebNotifyMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderWebNotifyMsg error " + e.getMessage());
|
|
|
|
@ -285,7 +269,7 @@ public class SendUtil {
|
|
|
|
QYWXGroupRobotSettingVo qywxGroupRobotSettingVo = JSON.parseObject(senderModel.getJsonSetting(), QYWXGroupRobotSettingVo.class);
|
|
|
|
QYWXGroupRobotSettingVo qywxGroupRobotSettingVo = JSON.parseObject(senderModel.getJsonSetting(), QYWXGroupRobotSettingVo.class);
|
|
|
|
if (qywxGroupRobotSettingVo != null) {
|
|
|
|
if (qywxGroupRobotSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderQyWxGroupRobotMsg.sendMsg(logId, handError, emitter, qywxGroupRobotSettingVo.getWebHook(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderQyWxGroupRobotMsg.sendMsg(logId, handError, retryInterceptor, qywxGroupRobotSettingVo.getWebHook(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderQyWxGroupRobotMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderQyWxGroupRobotMsg error " + e.getMessage());
|
|
|
|
@ -300,7 +284,7 @@ public class SendUtil {
|
|
|
|
QYWXAppSettingVo qYWXAppSettingVo = JSON.parseObject(senderModel.getJsonSetting(), QYWXAppSettingVo.class);
|
|
|
|
QYWXAppSettingVo qYWXAppSettingVo = JSON.parseObject(senderModel.getJsonSetting(), QYWXAppSettingVo.class);
|
|
|
|
if (qYWXAppSettingVo != null) {
|
|
|
|
if (qYWXAppSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderQyWxAppMsg.sendMsg(logId, handError, emitter, senderModel, qYWXAppSettingVo, smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderQyWxAppMsg.sendMsg(logId, handError, retryInterceptor, senderModel, qYWXAppSettingVo, smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: qywx_app error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: qywx_app error " + e.getMessage());
|
|
|
|
@ -315,7 +299,7 @@ public class SendUtil {
|
|
|
|
ServerChanSettingVo serverChanSettingVo = JSON.parseObject(senderModel.getJsonSetting(), ServerChanSettingVo.class);
|
|
|
|
ServerChanSettingVo serverChanSettingVo = JSON.parseObject(senderModel.getJsonSetting(), ServerChanSettingVo.class);
|
|
|
|
if (serverChanSettingVo != null) {
|
|
|
|
if (serverChanSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderServerChanMsg.sendMsg(logId, handError, emitter, serverChanSettingVo.getSendKey(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderServerChanMsg.sendMsg(logId, handError, retryInterceptor, serverChanSettingVo.getSendKey(), smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderServerChanMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderServerChanMsg error " + e.getMessage());
|
|
|
|
@ -330,7 +314,7 @@ public class SendUtil {
|
|
|
|
TelegramSettingVo telegramSettingVo = JSON.parseObject(senderModel.getJsonSetting(), TelegramSettingVo.class);
|
|
|
|
TelegramSettingVo telegramSettingVo = JSON.parseObject(senderModel.getJsonSetting(), TelegramSettingVo.class);
|
|
|
|
if (telegramSettingVo != null) {
|
|
|
|
if (telegramSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderTelegramMsg.sendMsg(logId, handError, emitter, telegramSettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace), telegramSettingVo.getMethod());
|
|
|
|
SenderTelegramMsg.sendMsg(logId, handError, retryInterceptor, telegramSettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace), telegramSettingVo.getMethod());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderTelegramMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderTelegramMsg error " + e.getMessage());
|
|
|
|
@ -372,7 +356,7 @@ public class SendUtil {
|
|
|
|
FeiShuSettingVo feiShuSettingVo = JSON.parseObject(senderModel.getJsonSetting(), FeiShuSettingVo.class);
|
|
|
|
FeiShuSettingVo feiShuSettingVo = JSON.parseObject(senderModel.getJsonSetting(), FeiShuSettingVo.class);
|
|
|
|
if (feiShuSettingVo != null) {
|
|
|
|
if (feiShuSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderFeishuMsg.sendMsg(logId, handError, emitter, feiShuSettingVo.getWebhook(), feiShuSettingVo.getSecret(), smsVo.getMobile(), smsVo.getDate(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderFeishuMsg.sendMsg(logId, handError, retryInterceptor, feiShuSettingVo.getWebhook(), feiShuSettingVo.getSecret(), smsVo.getMobile(), smsVo.getDate(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: feishu error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: feishu error " + e.getMessage());
|
|
|
|
@ -387,7 +371,7 @@ public class SendUtil {
|
|
|
|
PushPlusSettingVo pushPlusSettingVo = JSON.parseObject(senderModel.getJsonSetting(), PushPlusSettingVo.class);
|
|
|
|
PushPlusSettingVo pushPlusSettingVo = JSON.parseObject(senderModel.getJsonSetting(), PushPlusSettingVo.class);
|
|
|
|
if (pushPlusSettingVo != null) {
|
|
|
|
if (pushPlusSettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderPushPlusMsg.sendMsg(logId, handError, emitter, pushPlusSettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderPushPlusMsg.sendMsg(logId, handError, retryInterceptor, pushPlusSettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: feishu error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: feishu error " + e.getMessage());
|
|
|
|
@ -402,7 +386,7 @@ public class SendUtil {
|
|
|
|
GotifySettingVo gotifySettingVo = JSON.parseObject(senderModel.getJsonSetting(), GotifySettingVo.class);
|
|
|
|
GotifySettingVo gotifySettingVo = JSON.parseObject(senderModel.getJsonSetting(), GotifySettingVo.class);
|
|
|
|
if (gotifySettingVo != null) {
|
|
|
|
if (gotifySettingVo != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
SenderGotifyMsg.sendMsg(logId, handError, emitter, gotifySettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
SenderGotifyMsg.sendMsg(logId, handError, retryInterceptor, gotifySettingVo, smsVo.getMobile(), smsVo.getSmsVoForSend(smsTemplate, regexReplace));
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: gotify error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: gotify error " + e.getMessage());
|
|
|
|
|
pppscn
3 years ago