|
|
@ -60,8 +60,8 @@ public class SendUtil {
|
|
|
|
List<SenderModel> senderModels = SenderUtil.getSender(ruleModel.getSenderId(), null);
|
|
|
|
List<SenderModel> senderModels = SenderUtil.getSender(ruleModel.getSenderId(), null);
|
|
|
|
for (SenderModel senderModel : senderModels
|
|
|
|
for (SenderModel senderModel : senderModels
|
|
|
|
) {
|
|
|
|
) {
|
|
|
|
LogUtil.addLog(new LogModel(smsVo.getMobile(), smsVo.getContent(), smsVo.getSimInfo(), ruleModel.getId()));
|
|
|
|
long logId = LogUtil.addLog(new LogModel(smsVo.getMobile(), smsVo.getContent(), smsVo.getSimInfo(), ruleModel.getId()));
|
|
|
|
SendUtil.senderSendMsgNoHandError(smsVo, senderModel);
|
|
|
|
SendUtil.senderSendMsgNoHandError(smsVo, senderModel, logId);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
@ -94,15 +94,15 @@ public class SendUtil {
|
|
|
|
|
|
|
|
|
|
|
|
for (SenderModel senderModel : senderModels
|
|
|
|
for (SenderModel senderModel : senderModels
|
|
|
|
) {
|
|
|
|
) {
|
|
|
|
SendUtil.senderSendMsg(handError, smsVo, senderModel);
|
|
|
|
SendUtil.senderSendMsg(handError, smsVo, senderModel, 0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static void senderSendMsgNoHandError(SmsVo smsVo, SenderModel senderModel) {
|
|
|
|
public static void senderSendMsgNoHandError(SmsVo smsVo, SenderModel senderModel, long logId) {
|
|
|
|
SendUtil.senderSendMsg(null, smsVo, senderModel);
|
|
|
|
SendUtil.senderSendMsg(null, smsVo, senderModel, logId);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static void senderSendMsg(Handler handError, SmsVo smsVo, SenderModel senderModel) {
|
|
|
|
public static void senderSendMsg(Handler handError, SmsVo smsVo, SenderModel senderModel, long logId) {
|
|
|
|
|
|
|
|
|
|
|
|
Log.i(TAG, "senderSendMsg smsVo:" + smsVo + "senderModel:" + senderModel);
|
|
|
|
Log.i(TAG, "senderSendMsg smsVo:" + smsVo + "senderModel:" + senderModel);
|
|
|
|
switch (senderModel.getType()) {
|
|
|
|
switch (senderModel.getType()) {
|
|
|
@ -112,8 +112,9 @@ 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(handError, dingDingSettingVo.getToken(), dingDingSettingVo.getSecret(), dingDingSettingVo.getAtMobils(), dingDingSettingVo.getAtAll(), smsVo.getSmsVoForSend());
|
|
|
|
SenderDingdingMsg.sendMsg(logId, handError, dingDingSettingVo.getToken(), dingDingSettingVo.getSecret(), dingDingSettingVo.getAtMobils(), dingDingSettingVo.getAtAll(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: dingding error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: dingding error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -126,9 +127,10 @@ 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(handError, emailSettingVo.getHost(), emailSettingVo.getPort(), emailSettingVo.getSsl(), emailSettingVo.getFromEmail(),
|
|
|
|
SenderMailMsg.sendEmail(logId, handError, emailSettingVo.getHost(), emailSettingVo.getPort(), emailSettingVo.getSsl(), emailSettingVo.getFromEmail(),
|
|
|
|
emailSettingVo.getPwd(), emailSettingVo.getToEmail(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
emailSettingVo.getPwd(), emailSettingVo.getToEmail(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderMailMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderMailMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -141,8 +143,9 @@ 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(handError, barkSettingVo.getServer(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderBarkMsg.sendMsg(logId, handError, barkSettingVo.getServer(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderBarkMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderBarkMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -155,8 +158,9 @@ 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(handError, webNotifySettingVo.getWebServer(), webNotifySettingVo.getSecret(), webNotifySettingVo.getMethod(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderWebNotifyMsg.sendMsg(logId, handError, webNotifySettingVo.getWebServer(), webNotifySettingVo.getSecret(), webNotifySettingVo.getMethod(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderWebNotifyMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderWebNotifyMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -169,8 +173,9 @@ 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(handError, qywxGroupRobotSettingVo.getWebHook(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderQyWxGroupRobotMsg.sendMsg(logId, handError, qywxGroupRobotSettingVo.getWebHook(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderQyWxGroupRobotMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderQyWxGroupRobotMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -183,8 +188,9 @@ 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(handError, qYWXAppSettingVo.getCorpID(), qYWXAppSettingVo.getAgentID(), qYWXAppSettingVo.getSecret(), qYWXAppSettingVo.getToUser(), smsVo.getSmsVoForSend(), false);
|
|
|
|
SenderQyWxAppMsg.sendMsg(logId, handError, qYWXAppSettingVo.getCorpID(), qYWXAppSettingVo.getAgentID(), qYWXAppSettingVo.getSecret(), qYWXAppSettingVo.getToUser(), smsVo.getSmsVoForSend(), false);
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: qywx_app error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: qywx_app error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -197,8 +203,9 @@ 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(handError, serverChanSettingVo.getSendKey(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderServerChanMsg.sendMsg(logId, handError, serverChanSettingVo.getSendKey(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderServerChanMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderServerChanMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -211,8 +218,9 @@ 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(handError, telegramSettingVo.getApiToken(), telegramSettingVo.getChatId(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderTelegramMsg.sendMsg(logId, handError, telegramSettingVo.getApiToken(), telegramSettingVo.getChatId(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderTelegramMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderTelegramMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -226,7 +234,9 @@ public class SendUtil {
|
|
|
|
if (smsSettingVo != null) {
|
|
|
|
if (smsSettingVo != null) {
|
|
|
|
//仅当无网络时启用
|
|
|
|
//仅当无网络时启用
|
|
|
|
if (true == smsSettingVo.getOnlyNoNetwork() && 0 != NetUtil.getNetWorkStatus()) {
|
|
|
|
if (true == smsSettingVo.getOnlyNoNetwork() && 0 != NetUtil.getNetWorkStatus()) {
|
|
|
|
Log.d(TAG, "仅当无网络时启用,当前网络状态:" + NetUtil.getNetWorkStatus());
|
|
|
|
String msg = "仅当无网络时启用,当前网络状态:" + NetUtil.getNetWorkStatus();
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, msg);
|
|
|
|
|
|
|
|
Log.d(TAG, msg);
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
try {
|
|
|
|
try {
|
|
|
@ -235,8 +245,9 @@ public class SendUtil {
|
|
|
|
simSlot = Integer.parseInt(smsVo.getSimInfo().substring(3, 4)) - 1;
|
|
|
|
simSlot = Integer.parseInt(smsVo.getSimInfo().substring(3, 4)) - 1;
|
|
|
|
Log.d(TAG, "simSlot = " + simSlot);
|
|
|
|
Log.d(TAG, "simSlot = " + simSlot);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
SenderSmsMsg.sendMsg(handError, simSlot, smsSettingVo.getMobiles(), smsSettingVo.getOnlyNoNetwork(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
SenderSmsMsg.sendMsg(logId, handError, simSlot, smsSettingVo.getMobiles(), smsSettingVo.getOnlyNoNetwork(), smsVo.getMobile(), smsVo.getSmsVoForSend());
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
LogUtil.updateLog(logId, 0, e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderSmsMsg error " + e.getMessage());
|
|
|
|
Log.e(TAG, "senderSendMsg: SenderSmsMsg error " + e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|