diff --git a/emis-biz/src/main/java/com/xdadan/erp/emis/service/sms/AliyunSMSService.java b/emis-biz/src/main/java/com/xdadan/erp/emis/service/sms/AliyunSMSService.java index 1d78e342a..7d61eb05c 100644 --- a/emis-biz/src/main/java/com/xdadan/erp/emis/service/sms/AliyunSMSService.java +++ b/emis-biz/src/main/java/com/xdadan/erp/emis/service/sms/AliyunSMSService.java @@ -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; }