From 3a891072ba4fe43d9cb0eae0ef2e7af25470d508 Mon Sep 17 00:00:00 2001 From: "kuang.yifei@iwhalecloud.com" Date: Mon, 1 Aug 2022 15:51:49 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=B9=E8=81=94=E4=BA=91=E7=9F=AD=E4=BF=A1?= =?UTF-8?q?=E9=AA=8C=E8=AF=81=E7=A0=81=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../web/controller/tool/SMSController.java | 79 +++++++++++++++++++ .../java/com/ghy/web/pojo/vo/SmsRequest.java | 21 +++++ ghy-admin/src/main/resources/application.yaml | 6 ++ .../java/com/ghy/common/config/SmsConfig.java | 50 ++++++++++++ .../com/ghy/common/constant/SmsConstants.java | 18 +++++ .../com/ghy/common/utils/http/HttpUtils.java | 35 ++++++-- 6 files changed, 203 insertions(+), 6 deletions(-) create mode 100644 ghy-admin/src/main/java/com/ghy/web/controller/tool/SMSController.java create mode 100644 ghy-admin/src/main/java/com/ghy/web/pojo/vo/SmsRequest.java create mode 100644 ghy-common/src/main/java/com/ghy/common/config/SmsConfig.java create mode 100644 ghy-common/src/main/java/com/ghy/common/constant/SmsConstants.java diff --git a/ghy-admin/src/main/java/com/ghy/web/controller/tool/SMSController.java b/ghy-admin/src/main/java/com/ghy/web/controller/tool/SMSController.java new file mode 100644 index 00000000..e58bd363 --- /dev/null +++ b/ghy-admin/src/main/java/com/ghy/web/controller/tool/SMSController.java @@ -0,0 +1,79 @@ +package com.ghy.web.controller.tool; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.ghy.common.config.SmsConfig; +import com.ghy.common.constant.SmsConstants; +import com.ghy.common.core.domain.AjaxResult; +import com.ghy.common.utils.CacheUtils; +import com.ghy.common.utils.ExceptionUtil; +import com.ghy.common.utils.http.HttpUtils; +import com.ghy.common.utils.security.Md5Utils; +import com.ghy.web.pojo.vo.SmsRequest; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; + +import java.nio.charset.StandardCharsets; +import java.text.SimpleDateFormat; +import java.util.*; + +/** + * 容联云短信 + * @author clunt + */ +@Slf4j +@Controller +@RequestMapping("/tool/sms") +public class SMSController { + + private static final ThreadLocal timeFormat = ThreadLocal.withInitial(()->new SimpleDateFormat("yyyyMMddHHmmss")); + + @Autowired + private SmsConfig smsConfig; + + @PostMapping("/send") + @ResponseBody + public AjaxResult sendSms(@RequestBody SmsRequest request){ + try { + // 短信验证码 + String code = String.valueOf((int)((Math.random() * 9 + 1) * Math.pow(10,5))); + + // 拼接请求题 + List dataList = new ArrayList<>(); + dataList.add(code); + dataList.add("3"); + request.setAppId(smsConfig.getAppId()); + request.setTemplateId(SmsConstants.TEMPLATE_ID); + request.setDatas(dataList); + + String url = (smsConfig.getUrl() + SmsConstants.TEMPLATE_PATH).replace("{accountSid}", smsConfig.getAccount()); + String time = timeFormat.get().format(new Date()); + String sigParameter = Md5Utils.hash(smsConfig.getAccount() + smsConfig.getToken() + time).toUpperCase(); + String authorization = Base64.getEncoder().encodeToString((smsConfig.getAccount() + ":" + time).getBytes(StandardCharsets.UTF_8)); + url = url.replace("{SigParameter}", sigParameter); + Map headerMap = new HashMap<>(); + headerMap.put("Content-Type", "application/json;charset=utf-8"); + headerMap.put("Accept", "application/json;"); + headerMap.put("Authorization", authorization); + // 调用第三方短信服务 + String result = HttpUtils.sendPost(url, JSON.toJSONString(request), headerMap); + if("000000".equals(JSONObject.parseObject(result).getString("statusCode"))){ + // 将短信验证码放进系统内存 + CacheUtils.put(request.getTo(), code); + return AjaxResult.success("验证码发送成功!"); + }else { + return AjaxResult.error(result); + } + }catch (Exception e){ + e.printStackTrace(); + log.error(ExceptionUtil.getExceptionMessage(e)); + return AjaxResult.error(e.getMessage()); + } + } + +} diff --git a/ghy-admin/src/main/java/com/ghy/web/pojo/vo/SmsRequest.java b/ghy-admin/src/main/java/com/ghy/web/pojo/vo/SmsRequest.java new file mode 100644 index 00000000..382e3ee4 --- /dev/null +++ b/ghy-admin/src/main/java/com/ghy/web/pojo/vo/SmsRequest.java @@ -0,0 +1,21 @@ +package com.ghy.web.pojo.vo; + +import lombok.Data; + +import java.util.List; + +/** + * 容联短信请求体 + * @author clunt + */ +@Data +public class SmsRequest { + + private String to; + private String appId; + private String templateId; + private List datas; + private String subAppend; + private String reqId; + +} diff --git a/ghy-admin/src/main/resources/application.yaml b/ghy-admin/src/main/resources/application.yaml index 56cbc2e9..2681e883 100644 --- a/ghy-admin/src/main/resources/application.yaml +++ b/ghy-admin/src/main/resources/application.yaml @@ -130,3 +130,9 @@ jim: baidu: ak: 'ZQTgMW7W0GTuE7Ripb0HDp5TqRaOI6PZ' url: 'https://api.map.baidu.com/reverse_geocoding/v3/?ak=#AK#&output=json&coordtype=wgs84ll&location=' + +sms: + url: 'https://app.cloopen.com:8883' + account: '8a216da85f008800015f0eb223620557' + appId: '8a216da85f008800015f0eb224db055d' + token: '3cef1bc80d814637a236d93004e7ffa5' diff --git a/ghy-common/src/main/java/com/ghy/common/config/SmsConfig.java b/ghy-common/src/main/java/com/ghy/common/config/SmsConfig.java new file mode 100644 index 00000000..24633f4b --- /dev/null +++ b/ghy-common/src/main/java/com/ghy/common/config/SmsConfig.java @@ -0,0 +1,50 @@ +package com.ghy.common.config; + +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.stereotype.Component; + +/** + * 容联云短信配置 + * @author clunt + */ +@Component +@ConfigurationProperties(prefix = "sms") +public class SmsConfig { + + private String url; + private String account; + private String appId; + private String token; + + public String getUrl() { + return url; + } + + public void setUrl(String url) { + this.url = url; + } + + public String getAccount() { + return account; + } + + public void setAccount(String account) { + this.account = account; + } + + public String getAppId() { + return appId; + } + + public void setAppId(String appId) { + this.appId = appId; + } + + public String getToken() { + return token; + } + + public void setToken(String token) { + this.token = token; + } +} diff --git a/ghy-common/src/main/java/com/ghy/common/constant/SmsConstants.java b/ghy-common/src/main/java/com/ghy/common/constant/SmsConstants.java new file mode 100644 index 00000000..04516a92 --- /dev/null +++ b/ghy-common/src/main/java/com/ghy/common/constant/SmsConstants.java @@ -0,0 +1,18 @@ +package com.ghy.common.constant; + +/** + * 容联云短信配置 + * @author clunt + */ +public class SmsConstants { + + // 短信验证码通知模版 + public static final String TEMPLATE_ID = "216263"; + + // 短信模版发送地址 + public static final String TEMPLATE_URL = "https://app.cloopen.com:8883"; + + // 短信模版发送路径 + public static final String TEMPLATE_PATH = "/2013-12-26/Accounts/{accountSid}/SMS/TemplateSMS?sig={SigParameter}"; + +} diff --git a/ghy-common/src/main/java/com/ghy/common/utils/http/HttpUtils.java b/ghy-common/src/main/java/com/ghy/common/utils/http/HttpUtils.java index cde14c6a..fd8105fb 100644 --- a/ghy-common/src/main/java/com/ghy/common/utils/http/HttpUtils.java +++ b/ghy-common/src/main/java/com/ghy/common/utils/http/HttpUtils.java @@ -6,6 +6,8 @@ import java.net.SocketTimeoutException; import java.net.URL; import java.net.URLConnection; import java.security.cert.X509Certificate; +import java.util.HashMap; +import java.util.Map; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLContext; @@ -120,6 +122,19 @@ public class HttpUtils * @return 所代表远程资源的响应结果 */ public static String sendPost(String url, String param) + { + return sendPost(url, param, null); + } + + + /** + * 向指定 URL 发送POST方法的请求 + * + * @param url 发送请求的 URL + * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。 + * @return 所代表远程资源的响应结果 + */ + public static String sendPost(String url, String param, Map header) { PrintWriter out = null; BufferedReader in = null; @@ -135,6 +150,9 @@ public class HttpUtils conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); conn.setRequestProperty("Accept-Charset", "utf-8"); conn.setRequestProperty("contentType", "utf-8"); + if(header != null){ + header.forEach(conn::setRequestProperty); + } conn.setDoOutput(true); conn.setDoInput(true); out = new PrintWriter(conn.getOutputStream()); @@ -242,22 +260,27 @@ public class HttpUtils return result; } - public static String sendSSLPost(String url, String param) - { + public static String sendSSLPost(String url, String param){ + return sendSSLPost(url, param, null); + } + + public static String sendSSLPost(String url, String param, Map header){ StringBuilder result = new StringBuilder(); - String urlNameString = url + "?" + param; try { - log.info("sendSSLPost - {}", urlNameString); + log.info("sendSSLPost - {}", url); SSLContext sc = SSLContext.getInstance("SSL"); sc.init(null, new TrustManager[] { new TrustAnyTrustManager() }, new java.security.SecureRandom()); - URL console = new URL(urlNameString); + URL console = new URL(url); HttpsURLConnection conn = (HttpsURLConnection) console.openConnection(); conn.setRequestProperty("accept", "*/*"); conn.setRequestProperty("connection", "Keep-Alive"); conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); conn.setRequestProperty("Accept-Charset", "utf-8"); conn.setRequestProperty("contentType", "utf-8"); + if(header != null){ + header.forEach(conn::setRequestProperty); + } conn.setDoOutput(true); conn.setDoInput(true); @@ -271,7 +294,7 @@ public class HttpUtils { if (ret != null && !ret.trim().equals("")) { - result.append(new String(ret.getBytes("ISO-8859-1"), "utf-8")); + result.append(new String(ret.getBytes("utf-8"), "utf-8")); } } log.info("recv - {}", result);