-
Notifications
You must be signed in to change notification settings - Fork 996
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #45 from rememberber/develop
新增对阿里云短信的支持
- Loading branch information
Showing
15 changed files
with
467 additions
and
16 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
146 changes: 146 additions & 0 deletions
146
src/main/java/com/fangxuele/tool/wechat/push/logic/AliYunSmsMsgServiceThread.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,146 @@ | ||
| package com.fangxuele.tool.wechat.push.logic; | ||
|
|
||
| import com.aliyuncs.DefaultAcsClient; | ||
| import com.aliyuncs.IAcsClient; | ||
| import com.aliyuncs.dysmsapi.model.v20170525.SendSmsRequest; | ||
| import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse; | ||
| import com.aliyuncs.exceptions.ClientException; | ||
| import com.aliyuncs.profile.DefaultProfile; | ||
| import com.aliyuncs.profile.IClientProfile; | ||
| import com.fangxuele.tool.wechat.push.ui.Init; | ||
| import com.fangxuele.tool.wechat.push.ui.MainWindow; | ||
| import org.apache.commons.lang3.StringUtils; | ||
|
|
||
| import javax.swing.*; | ||
|
|
||
| /** | ||
| * 阿里云短信发送服务线程 | ||
| * Created by rememberber(https://github.com/rememberber) on 2018/3/16. | ||
| */ | ||
| public class AliYunSmsMsgServiceThread extends BaseMsgServiceThread { | ||
|
|
||
| /** | ||
| * 构造函数 | ||
| * | ||
| * @param pageFrom 起始页 | ||
| * @param pageTo 截止页 | ||
| * @param pageSize 页大小 | ||
| */ | ||
| public AliYunSmsMsgServiceThread(int pageFrom, int pageTo, int pageSize) { | ||
| super(pageFrom, pageTo, pageSize); | ||
| } | ||
|
|
||
| @Override | ||
| public void run() { | ||
|
|
||
| // 初始化当前线程 | ||
| initCurrentThread(); | ||
|
|
||
| String aliyunAccessKeyId = Init.configer.getAliyunAccessKeyId(); | ||
| String aliyunAccessKeySecret = Init.configer.getAliyunAccessKeySecret(); | ||
|
|
||
| if (StringUtils.isEmpty(aliyunAccessKeyId) || StringUtils.isEmpty(aliyunAccessKeySecret)) { | ||
| JOptionPane.showMessageDialog(MainWindow.mainWindow.getSettingPanel(), | ||
| "请先在设置中填写并保存阿里云短信相关配置！", "提示", | ||
| JOptionPane.INFORMATION_MESSAGE); | ||
| } | ||
|
|
||
| //初始化acsClient,暂不支持region化 | ||
| IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", aliyunAccessKeyId, aliyunAccessKeySecret); | ||
| try { | ||
| DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", "Dysmsapi", "dysmsapi.aliyuncs.com"); | ||
| } catch (ClientException e) { | ||
| logger.error(e); | ||
| PushManage.console(e.getMessage()); | ||
| } | ||
| IAcsClient acsClient = new DefaultAcsClient(profile); | ||
|
|
||
| // 组织模板消息 | ||
| SendSmsRequest sendSmsRequest; | ||
|
|
||
| SendSmsResponse response; | ||
|
|
||
| for (int i = 0; i < list.size(); i++) { | ||
| if (!PushData.running) { | ||
| // 停止 | ||
| PushData.increaseStopedThread(); | ||
| return; | ||
| } | ||
|
|
||
| // 本条消息所需的数据 | ||
| String[] msgData = list.get(i); | ||
| String telNum = msgData[0]; | ||
| try { | ||
| sendSmsRequest = PushManage.makeAliyunMessage(msgData); | ||
| sendSmsRequest.setPhoneNumbers(telNum); | ||
|
|
||
| // 空跑控制 | ||
| if (!MainWindow.mainWindow.getDryRunCheckBox().isSelected()) { | ||
| response = acsClient.getAcsResponse(sendSmsRequest); | ||
| if (response.getCode() != null && "OK".equals(response.getCode())) { | ||
| // 总发送成功+1 | ||
| PushData.increaseSuccess(); | ||
| MainWindow.mainWindow.getPushSuccessCount().setText(String.valueOf(PushData.successRecords)); | ||
|
|
||
| // 当前线程发送成功+1 | ||
| currentThreadSuccessCount++; | ||
| tableModel.setValueAt(currentThreadSuccessCount, tableRow, 2); | ||
|
|
||
| // 保存发送成功 | ||
| PushData.sendSuccessList.add(msgData); | ||
| } else { | ||
| // 总发送失败+1 | ||
| PushData.increaseFail(); | ||
| MainWindow.mainWindow.getPushFailCount().setText(String.valueOf(PushData.failRecords)); | ||
|
|
||
| // 保存发送失败 | ||
| PushData.sendFailList.add(msgData); | ||
|
|
||
| // 失败异常信息输出控制台 | ||
| PushManage.console(new StringBuffer().append("发送失败:").append(response.getMessage()).append(";ErrorCode:") | ||
| .append(response.getCode()).append(";telNum:").append(telNum).toString()); | ||
|
|
||
| // 当前线程发送失败+1 | ||
| currentThreadFailCount++; | ||
| tableModel.setValueAt(currentThreadFailCount, tableRow, 3); | ||
| } | ||
| } else { | ||
| // 总发送成功+1 | ||
| PushData.increaseSuccess(); | ||
| MainWindow.mainWindow.getPushSuccessCount().setText(String.valueOf(PushData.successRecords)); | ||
|
|
||
| // 当前线程发送成功+1 | ||
| currentThreadSuccessCount++; | ||
| tableModel.setValueAt(currentThreadSuccessCount, tableRow, 2); | ||
|
|
||
| // 保存发送成功 | ||
| PushData.sendSuccessList.add(msgData); | ||
| } | ||
|
|
||
| } catch (Exception e) { | ||
| // 总发送失败+1 | ||
| PushData.increaseFail(); | ||
| MainWindow.mainWindow.getPushFailCount().setText(String.valueOf(PushData.failRecords)); | ||
|
|
||
| // 保存发送失败 | ||
| PushData.sendFailList.add(msgData); | ||
|
|
||
| // 失败异常信息输出控制台 | ||
| PushManage.console(new StringBuffer().append("发送失败:").append(e.getMessage()).append(";telNum:").append(telNum).toString()); | ||
|
|
||
| // 当前线程发送失败+1 | ||
| currentThreadFailCount++; | ||
| tableModel.setValueAt(currentThreadFailCount, tableRow, 3); | ||
| } | ||
| // 当前线程进度条 | ||
| tableModel.setValueAt((int) ((double) (i + 1) / list.size() * 100), tableRow, 5); | ||
|
|
||
| // 总进度条 | ||
| MainWindow.mainWindow.getPushTotalProgressBar().setValue((int) (PushData.successRecords + PushData.failRecords)); | ||
| } | ||
|
|
||
| // 当前线程结束 | ||
| currentThreadFinish(); | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.