aike/emis-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

md

Browse Source
This commit is contained in:
linfso 2024-07-28 17:46:18 +08:00
parent 9898044bb6
commit f8c027b3f8
1 changed files with 39 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
emis-biz/src/main/java/com/xdadan/erp/emis/service/sms/AliyunSMSService.java
View File

@ -24,14 +24,13 @@ public class AliyunSMSService {
*/
public int sendMessage(String signName,String phone, String templateCode,String tplParam) throws EmisBizError {
// String jsonParamStr=configService.selectConfigByKey("sys.aliyun.sms");
// JSONObject jObjAliyunParam=JSONObject.parseObject(jsonParamStr);
// String accessKeyId=jObjAliyunParam.getString("accessKeyId");
// String accessKeySecret=jObjAliyunParam.getString("accessKeySecret");
//
// return innerSendMessage(accessKeyId,accessKeySecret,signName,templateCode,phone,tplParam);
String jsonParamStr=configService.selectConfigByKey("sys.aliyun.sms");
JSONObject jObjAliyunParam=JSONObject.parseObject(jsonParamStr);
String accessKeyId=jObjAliyunParam.getString("accessKeyId");
String accessKeySecret=jObjAliyunParam.getString("accessKeySecret");
return innerSendMessage(accessKeyId,accessKeySecret,signName,templateCode,phone,tplParam);
return 1;
}
@ -42,42 +41,41 @@ public class AliyunSMSService {
* @return Client
* @throws Exception
*/
// public static Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
// com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
// .setAccessKeyId(accessKeyId)
// .setAccessKeySecret(accessKeySecret);
// // 访问的域名
// config.endpoint = "dysmsapi.aliyuncs.com";
// return new Client(config);
// return null;
// }
public static Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
.setAccessKeyId(accessKeyId)
.setAccessKeySecret(accessKeySecret);
// 访问的域名
config.endpoint = "dysmsapi.aliyuncs.com";
return new Client(config);
}
public static int innerSendMessage(String accessKeyId,String accessKeySecret,String signName,String templateCode, String phone, String tplParam) throws EmisBizError {
// try {
// Client client = createClient(accessKeyId, accessKeySecret);
// com.aliyun.dysmsapi20170525.models.SendSmsRequest sendSmsRequest = new com.aliyun.dysmsapi20170525.models.SendSmsRequest();
// sendSmsRequest.setPhoneNumbers(phone);
// sendSmsRequest.setSignName(signName);
// sendSmsRequest.setTemplateCode(templateCode);
//// sendSmsRequest.setTemplateParam("{\"code\":\""+param+"\"}");
// sendSmsRequest.setTemplateParam(tplParam);
// RuntimeOptions runtime = new RuntimeOptions();
// com.aliyun.dysmsapi20170525.models.SendSmsResponse response = client.sendSmsWithOptions(sendSmsRequest, runtime);
// String jsonStr= Common.toJSONString(TeaModel.buildMap(response));
//
// if(response.getStatusCode()==200) {
// if ("OK".equals(response.getBody().getCode())) {
// return 1;
// } else {
// throw new EmisBizError(EmisBizErrorType.FAIL,response.getBody().getMessage());
// }
// }else{
// throw new EmisBizError(EmisBizErrorType.FAIL,"短信渠道发送错误");
// }
// }catch (Exception e) {
// e.printStackTrace();
// throw new EmisBizError(EmisBizErrorType.FAIL,"短信渠道异常");
// }
try {
Client client = createClient(accessKeyId, accessKeySecret);
com.aliyun.dysmsapi20170525.models.SendSmsRequest sendSmsRequest = new com.aliyun.dysmsapi20170525.models.SendSmsRequest();
sendSmsRequest.setPhoneNumbers(phone);
sendSmsRequest.setSignName(signName);
sendSmsRequest.setTemplateCode(templateCode);
// sendSmsRequest.setTemplateParam("{\"code\":\""+param+"\"}");
sendSmsRequest.setTemplateParam(tplParam);
RuntimeOptions runtime = new RuntimeOptions();
com.aliyun.dysmsapi20170525.models.SendSmsResponse response = client.sendSmsWithOptions(sendSmsRequest, runtime);
String jsonStr= Common.toJSONString(TeaModel.buildMap(response));
if(response.getStatusCode()==200) {
if ("OK".equals(response.getBody().getCode())) {
return 1;
} else {
throw new EmisBizError(EmisBizErrorType.FAIL,response.getBody().getMessage());
}
}else{
throw new EmisBizError(EmisBizErrorType.FAIL,"短信渠道发送错误");
}
}catch (Exception e) {
e.printStackTrace();
throw new EmisBizError(EmisBizErrorType.FAIL,"短信渠道异常");
}
return 1;
}