From b5edf7381f1e62577dc039721b0a15eb7e9e0695 Mon Sep 17 00:00:00 2001 From: TinyAnts Date: Thu, 31 Mar 2022 14:27:07 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=AD=E4=BF=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/controller/IndexController.java | 37 +++--- like-common/pom.xml | 12 ++ .../com/hxkj/common/plugin/sms/SmsDriver.java | 76 ++++++++++++ .../hxkj/common/plugin/sms/engine/AliSms.java | 106 +++++++++++++++++ .../common/plugin/sms/engine/TencentSms.java | 109 ++++++++++++++++++ .../common/plugin/storage/StorageDriver.java | 19 ++- .../{Aliyun.java => AliyunStorage.java} | 10 +- .../engine/{Local.java => LocalStorage.java} | 6 +- .../{Qcloud.java => QcloudStorage.java} | 7 +- .../engine/{Qiniu.java => QiniuStorage.java} | 7 +- pom.xml | 14 +++ 11 files changed, 362 insertions(+), 41 deletions(-) create mode 100644 like-common/src/main/java/com/hxkj/common/plugin/sms/SmsDriver.java create mode 100644 like-common/src/main/java/com/hxkj/common/plugin/sms/engine/AliSms.java create mode 100644 like-common/src/main/java/com/hxkj/common/plugin/sms/engine/TencentSms.java rename like-common/src/main/java/com/hxkj/common/plugin/storage/engine/{Aliyun.java => AliyunStorage.java} (91%) rename like-common/src/main/java/com/hxkj/common/plugin/storage/engine/{Local.java => LocalStorage.java} (96%) rename like-common/src/main/java/com/hxkj/common/plugin/storage/engine/{Qcloud.java => QcloudStorage.java} (95%) rename like-common/src/main/java/com/hxkj/common/plugin/storage/engine/{Qiniu.java => QiniuStorage.java} (93%) diff --git a/like-admin/src/main/java/com/hxkj/admin/controller/IndexController.java b/like-admin/src/main/java/com/hxkj/admin/controller/IndexController.java index 9521292b..b73317a4 100644 --- a/like-admin/src/main/java/com/hxkj/admin/controller/IndexController.java +++ b/like-admin/src/main/java/com/hxkj/admin/controller/IndexController.java @@ -1,35 +1,32 @@ package com.hxkj.admin.controller; import com.hxkj.common.core.AjaxResult; -import com.hxkj.common.plugin.storage.StorageDriver; -import com.hxkj.common.plugin.storage.engine.Aliyun; -import com.hxkj.common.plugin.storage.engine.Qiniu; -import com.hxkj.common.utils.TimeUtil; -import org.springframework.web.bind.annotation.GetMapping; + +import com.hxkj.common.exception.OperateException; +import com.hxkj.common.plugin.sms.SmsDriver; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RestController; -import org.springframework.web.multipart.MultipartFile; -import org.springframework.web.multipart.MultipartRequest; -import javax.servlet.http.HttpServletRequest; +import java.util.LinkedHashMap; +import java.util.Map; + @RestController public class IndexController { @PostMapping("/aa") - public AjaxResult aa(HttpServletRequest request) { - MultipartFile multipartFile = ((MultipartRequest) request).getFile("file"); - if (multipartFile == null) { - return AjaxResult.failed("请选择上传文件"); + public AjaxResult aa() { + try { + Map params = new LinkedHashMap<>(); + (new SmsDriver()) + .setMobile("15627119239") + .setParam(params) + .sendSms(); + + return AjaxResult.success(); + } catch (OperateException e) { + return AjaxResult.failed(e.getMsg()); } - - -// Qiniu qiniu = new Qiniu(); -// qiniu.upload(multipartFile); - - new StorageDriver(); - - return AjaxResult.success(); } } diff --git a/like-common/pom.xml b/like-common/pom.xml index e6b008d7..ad6a7c4e 100644 --- a/like-common/pom.xml +++ b/like-common/pom.xml @@ -102,6 +102,18 @@ com.aliyun.oss aliyun-sdk-oss + + + com.tencentcloudapi + tencentcloud-sdk-java + ${tencentcloudapi.version} + + + + com.aliyun + aliyun-java-sdk-core + ${aliyun-java.version} + \ No newline at end of file diff --git a/like-common/src/main/java/com/hxkj/common/plugin/sms/SmsDriver.java b/like-common/src/main/java/com/hxkj/common/plugin/sms/SmsDriver.java new file mode 100644 index 00000000..0a6a9d0f --- /dev/null +++ b/like-common/src/main/java/com/hxkj/common/plugin/sms/SmsDriver.java @@ -0,0 +1,76 @@ +package com.hxkj.common.plugin.sms; + +import com.alibaba.fastjson.JSON; +import com.hxkj.common.plugin.sms.engine.AliSms; +import com.hxkj.common.plugin.sms.engine.TencentSms; +import com.hxkj.common.utils.ConfigUtil; + +import java.util.Map; + +public class SmsDriver { + + private String mobile; // 手机号码 + private String templateId; // 短信模板 + private String smsContent; // 短信内容 + private Map param; // 短信参数 + private final String engine; // 短信引擎 + private final Map config; // 短信配置 + + /** + * 构造方法 + */ + public SmsDriver() { + this.engine = ConfigUtil.get("sms", "default", "aliyun"); + this.config = ConfigUtil.getMap("sms", this.engine); + } + + /** + * 设置手机号 + * + * @author fzr + * @param mobile 手机号 + * @return SmsDriver + */ + public SmsDriver setMobile(String mobile) { + this.mobile = mobile; + return this; + } + + /** + * 设置参数 + * + * @author fzr + * @param param 参数 + * @return SmsDriver + */ + public SmsDriver setParam(Map param) { + this.param = param; + return this; + } + + /** + * 发送短信 + * + * @author fzr + */ + public void sendSms() { + String templateParam = JSON.toJSONString(param); + switch (this.engine) { + case "aliyun": + AliSms aliSms = new AliSms(this.config); + aliSms.setMobile(this.mobile) + .setTemplateId(this.templateId) + .setTemplateParams(templateParam) + .send(); + break; + case "tencent": + TencentSms tencentSms = new TencentSms(this.config); + tencentSms.setMobile(this.mobile) + .setTemplateId(this.templateId) + .setTemplateParams(templateParam.split(",")) + .send(); + break; + } + } + +} diff --git a/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/AliSms.java b/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/AliSms.java new file mode 100644 index 00000000..eb2b7907 --- /dev/null +++ b/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/AliSms.java @@ -0,0 +1,106 @@ +package com.hxkj.common.plugin.sms.engine; + +import com.alibaba.fastjson.JSONObject; +import com.aliyuncs.CommonRequest; +import com.aliyuncs.CommonResponse; +import com.aliyuncs.DefaultAcsClient; +import com.aliyuncs.IAcsClient; +import com.aliyuncs.http.MethodType; +import com.aliyuncs.profile.DefaultProfile; +import com.hxkj.common.exception.OperateException; + +import java.util.Map; + +/** + * 阿里云短信 + */ +public class AliSms { + + private String mobile; // 手机号码 + private String templateId; // 短信模板 + private String templateParams; // 短信参数 + private final Map config; // 短信配置 + + /** + * 构造方法 + * + * @author fzr + * @param config 短信配置 + */ + public AliSms(Map config) { + this.config = config; + } + + /** + * 设置手机号 + * + * @author fzr + * @param mobile 手机号码 + * @return AliSms + */ + public AliSms setMobile(String mobile) { + this.mobile = mobile; + return this; + } + + /** + * 设置模板id + * + * @author fzr + * @param templateId 模板id + * @return AliSms + */ + public AliSms setTemplateId(String templateId) { + this.templateId = templateId; + return this; + } + + /** + * 设置模板参数 + * + * @author fzr + * @param templateParams 模板参数 + * @return AliSms + */ + public AliSms setTemplateParams(String templateParams) { + this.templateParams = templateParams; + return this; + } + + /** + * 发送短信 + * + * @author fzr + * @return String + */ + public String send() { + DefaultProfile profile = DefaultProfile.getProfile("cn-hangzhou", this.config.get("app_key"), this.config.get("secret_key")); + IAcsClient client = new DefaultAcsClient(profile); + + CommonRequest request = new CommonRequest(); + request.setSysMethod(MethodType.POST); + request.setSysDomain("dysmsapi.aliyuncs.com"); + request.setSysVersion("2017-05-25"); + request.setSysAction("SendSms"); + request.putQueryParameter("PhoneNumbers", this.mobile); + request.putQueryParameter("SignName", this.config.get("sign")); + request.putQueryParameter("TemplateCode", this.templateId); + request.putQueryParameter("TemplateParam", this.templateParams); + try { + System.out.println("来来来来来"); + CommonResponse response = client.getCommonResponse(request); + System.out.println(response); + JSONObject res = JSONObject.parseObject(response.getData()); + + if (!res.get("Code").equals("OK") || !res.get("Message").equals("OK")) { + throw new OperateException(res.get("Message").toString()); + } + + return response.getData(); + } catch (Exception e) { + System.out.println(e.getMessage()); + throw new OperateException("短信发送异常：" + e.getMessage()); + } + } + +} diff --git a/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/TencentSms.java b/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/TencentSms.java new file mode 100644 index 00000000..efca6c30 --- /dev/null +++ b/like-common/src/main/java/com/hxkj/common/plugin/sms/engine/TencentSms.java @@ -0,0 +1,109 @@ +package com.hxkj.common.plugin.sms.engine; + +import com.alibaba.fastjson.JSONObject; +import com.hxkj.common.exception.OperateException; +import com.tencentcloudapi.common.Credential; +import com.tencentcloudapi.common.profile.ClientProfile; +import com.tencentcloudapi.common.profile.HttpProfile; +import com.tencentcloudapi.sms.v20210111.SmsClient; +import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest; +import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse; + +import java.util.Map; + +/** + * 腾讯短信驱 + */ +public class TencentSms { + + + private String mobile; + private String templateId; + private String[] templateParams; + private final Map config; + + public TencentSms(Map config) { + this.config = config; + } + + /** + * 设置手机号 + * @author fzr + * @param mobile 手机号码 + * @return AliSms + */ + public TencentSms setMobile(String mobile) { + this.mobile = mobile; + return this; + } + + /** + * 设置模板id + * @author fzr + * @param templateId 模板id + * @return AliSms + */ + public TencentSms setTemplateId(String templateId) { + this.templateId = templateId; + return this; + } + + /** + * 设置模板参数 + * @author fzr + * @param templateParams 模板参数 + * @return AliSms + */ + public TencentSms setTemplateParams(String[] templateParams) { + this.templateParams = templateParams; + return this; + } + + /** + * 发送短信 + * + * @param config 配置 + * @return String + */ + public String send() { + try { + /*认证对象*/ + Credential cred = new Credential(this.config.get("secret_id").toString(), config.get("secret_key").toString()); + HttpProfile httpProfile = new HttpProfile(); + httpProfile.setReqMethod("POST"); + httpProfile.setConnTimeout(60); + httpProfile.setEndpoint("sms.tencentcloudapi.com"); + + /*客户端配置*/ + ClientProfile clientProfile = new ClientProfile(); + clientProfile.setSignMethod("HmacSHA256"); + clientProfile.setHttpProfile(httpProfile); + + /*参数配置*/ + SmsClient client = new SmsClient(cred, "ap-guangzhou",clientProfile); + SendSmsRequest req = new SendSmsRequest(); + req.setSignName(config.get("sign").toString()); + req.setSmsSdkAppId(config.get("app_id").toString()); + req.setTemplateId(this.templateId); + + /*手机号码*/ + String[] phoneNumberSet = {"+86"+this.mobile}; + req.setPhoneNumberSet(phoneNumberSet); + + /*模板参数*/ + String[] templateParamSet = this.templateParams; + req.setTemplateParamSet(templateParamSet); + + /*发起请求*/ + SendSmsResponse res = client.SendSms(req); + if (!res.getSendStatusSet()[0].getCode().equals("Ok")) { + throw new Exception(res.getSendStatusSet()[0].getMessage()); + } + + return res.getSendStatusSet()[0].getMessage(); + } catch (Exception e) { + throw new OperateException("短信发送异常：" + e.getMessage()); + } + } + +} diff --git a/like-common/src/main/java/com/hxkj/common/plugin/storage/StorageDriver.java b/like-common/src/main/java/com/hxkj/common/plugin/storage/StorageDriver.java index 5a45a255..afc40f84 100644 --- a/like-common/src/main/java/com/hxkj/common/plugin/storage/StorageDriver.java +++ b/like-common/src/main/java/com/hxkj/common/plugin/storage/StorageDriver.java @@ -2,13 +2,12 @@ package com.hxkj.common.plugin.storage; import com.hxkj.common.config.GlobalConfig; import com.hxkj.common.exception.OperateException; -import com.hxkj.common.plugin.storage.engine.Aliyun; -import com.hxkj.common.plugin.storage.engine.Local; -import com.hxkj.common.plugin.storage.engine.Qcloud; -import com.hxkj.common.plugin.storage.engine.Qiniu; +import com.hxkj.common.plugin.storage.engine.AliyunStorage; +import com.hxkj.common.plugin.storage.engine.LocalStorage; +import com.hxkj.common.plugin.storage.engine.QcloudStorage; +import com.hxkj.common.plugin.storage.engine.QiniuStorage; import com.hxkj.common.utils.ConfigUtil; import com.hxkj.common.utils.TimeUtil; -import com.hxkj.common.utils.ToolsUtil; import com.hxkj.common.utils.UrlUtil; import org.springframework.web.multipart.MultipartFile; @@ -44,22 +43,22 @@ public class StorageDriver { */ public Map upload(MultipartFile multipartFile, String folder, Integer type) { this.checkFile(multipartFile, type); - String key = this.buildSaveName(multipartFile); + String key = this.buildSaveName(multipartFile); switch (this.engine) { case "local": - Local local = new Local(); + LocalStorage local = new LocalStorage(); local.upload(multipartFile, key, folder); break; case "qiniu": - Qiniu qiniu = new Qiniu(this.config); + QiniuStorage qiniu = new QiniuStorage(this.config); qiniu.upload(multipartFile, folder + "/" + key); break; case "aliyun": - Aliyun aliyun = new Aliyun(this.config); + AliyunStorage aliyun = new AliyunStorage(this.config); aliyun.upload(multipartFile, folder + "/" + key); break; case "qcloud": - Qcloud qcloud = new Qcloud(this.config); + QcloudStorage qcloud = new QcloudStorage(this.config); qcloud.upload(multipartFile, folder + "/" + key); break; } diff --git a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Aliyun.java b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/AliyunStorage.java similarity index 91% rename from like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Aliyun.java rename to like-common/src/main/java/com/hxkj/common/plugin/storage/engine/AliyunStorage.java index 88dce6f2..7073d58b 100644 --- a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Aliyun.java +++ b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/AliyunStorage.java @@ -1,19 +1,19 @@ package com.hxkj.common.plugin.storage.engine; -import com.aliyun.oss.ClientException; import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.OSSException; import com.aliyun.oss.model.PutObjectRequest; import com.hxkj.common.exception.OperateException; -import com.qiniu.util.Auth; import org.springframework.web.multipart.MultipartFile; import java.io.ByteArrayInputStream; -import java.io.IOException; import java.util.Map; -public class Aliyun { +/** + * 阿里云存储 + */ +public class AliyunStorage { /** * 存储配置 @@ -23,7 +23,7 @@ public class Aliyun { /** * 构造方法 */ - public Aliyun(Map config) { + public AliyunStorage(Map config) { this.config = config; } diff --git a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Local.java b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/LocalStorage.java similarity index 96% rename from like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Local.java rename to like-common/src/main/java/com/hxkj/common/plugin/storage/engine/LocalStorage.java index dea3aa27..5fc0aecd 100644 --- a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Local.java +++ b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/LocalStorage.java @@ -6,9 +6,11 @@ import com.hxkj.common.utils.YmlUtil; import org.springframework.web.multipart.MultipartFile; import java.io.File; -import java.io.IOException; -public class Local { +/** + * 本地存储 + */ +public class LocalStorage { /** * 本地上传 diff --git a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qcloud.java b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QcloudStorage.java similarity index 95% rename from like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qcloud.java rename to like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QcloudStorage.java index a3d28878..869b989f 100644 --- a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qcloud.java +++ b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QcloudStorage.java @@ -15,7 +15,10 @@ import org.springframework.web.multipart.MultipartFile; import java.io.*; import java.util.Map; -public class Qcloud { +/** + * 腾讯云存储 + */ +public class QcloudStorage { /** * 存储配置 @@ -25,7 +28,7 @@ public class Qcloud { /** * 构造方法 */ - public Qcloud(Map config) { + public QcloudStorage(Map config) { this.config = config; } diff --git a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qiniu.java b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QiniuStorage.java similarity index 93% rename from like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qiniu.java rename to like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QiniuStorage.java index b948e42a..cbb81dc9 100644 --- a/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/Qiniu.java +++ b/like-common/src/main/java/com/hxkj/common/plugin/storage/engine/QiniuStorage.java @@ -13,7 +13,10 @@ import org.springframework.web.multipart.MultipartFile; import java.io.IOException; import java.util.Map; -public class Qiniu { +/** + * 七牛云存储 + */ +public class QiniuStorage { /** * 存储配置 @@ -23,7 +26,7 @@ public class Qiniu { /** * 构造方法 */ - public Qiniu(Map config) { + public QiniuStorage(Map config) { this.config = config; } diff --git a/pom.xml b/pom.xml index 05dc36e7..b7c611e1 100644 --- a/pom.xml +++ b/pom.xml @@ -32,7 +32,9 @@ 2.9.0 7.9.5 5.6.54 + 3.1.411 3.10.2 + 4.5.16 @@ -112,6 +114,18 @@ aliyun-sdk-oss ${aliyun-oss.version} + + + com.tencentcloudapi + tencentcloud-sdk-java + ${tencentcloudapi.version} + + + + com.aliyun + aliyun-java-sdk-core + ${aliyun-java.version} +