org.springframework
spring-web
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/ALiOssProperties.java b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/ALiOssProperties.java
new file mode 100644
index 00000000..b2011bc1
--- /dev/null
+++ b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/ALiOssProperties.java
@@ -0,0 +1,36 @@
+package com.central.oss.properties;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * ali oss协议配置
+ *
+ * @author 杨彬鑫
+ * @date 2021/12/13
+ *
+ */
+@Setter
+@Getter
+public class ALiOssProperties {
+ /**
+ * 密钥key
+ */
+ private String accessKey;
+ /**
+ * 密钥密码
+ */
+ private String accessKeySecret;
+ /**
+ * 端点
+ */
+ private String endpoint;
+ /**
+ * bucket名称
+ */
+ private String bucketName;
+ /**
+ * bucket域名
+ */
+ private String bucketHost;
+}
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/FileServerProperties.java b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/FileServerProperties.java
index ac5a786d..e36b543c 100644
--- a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/FileServerProperties.java
+++ b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/properties/FileServerProperties.java
@@ -18,6 +18,7 @@ public class FileServerProperties {
public static final String PREFIX = "zlt.file-server";
public static final String TYPE_FDFS = "fastdfs";
public static final String TYPE_S3 = "s3";
+ public static final String TYPE_ALI_OSS = "alioss";
/**
* 为以下2个值，指定不同的自动化配置
@@ -35,4 +36,9 @@ public class FileServerProperties {
* fastDFS配置
*/
FdfsProperties fdfs = new FdfsProperties();
+
+ /**
+ * alibaba oss配置
+ */
+ ALiOssProperties aliOss = new ALiOssProperties();
}
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java
new file mode 100644
index 00000000..bdf7547c
--- /dev/null
+++ b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java
@@ -0,0 +1,80 @@
+package com.central.oss.template;
+
+import com.aliyun.oss.OSSClient;
+import com.aliyun.oss.common.auth.DefaultCredentialProvider;
+import com.central.oss.model.ObjectInfo;
+import com.central.oss.properties.ALiOssProperties;
+import com.central.oss.properties.FileServerProperties;
+import lombok.SneakyThrows;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.util.StringUtils;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.util.UUID;
+
+/**
+ * 阿里oss，文件上传
+ *
+ * @author 杨彬鑫
+ */
+@ConditionalOnClass(OSSClient.class)
+@ConditionalOnProperty(prefix = FileServerProperties.PREFIX, name = "type", havingValue = FileServerProperties.TYPE_ALI_OSS)
+public class AliOssTemplate implements InitializingBean {
+ private static final String FILE_SPLIT = ".";
+ private static final String PATH_SPLIT = "/";
+
+ @Resource
+ private ALiOssProperties fileProperties;
+
+ private OSSClient ossClient;
+
+ @Override
+ public void afterPropertiesSet(){
+ ossClient = new OSSClient(fileProperties.getEndpoint()
+ , new DefaultCredentialProvider(fileProperties.getAccessKey(), fileProperties.getAccessKeySecret())
+ , null);
+ }
+
+ /**
+ * 上传文件
+ * @param file 文件
+ * @param folder 子目录
+ * @return
+ * @throws IOException
+ */
+ @SneakyThrows
+ public ObjectInfo upload(MultipartFile file, String folder) {
+ // 文件名
+ String fileName = file.getOriginalFilename();
+ if (fileName.contains(FILE_SPLIT)) {
+ throw new IllegalArgumentException("缺少后缀名");
+ }
+
+ //获取文件的后缀名 .jpg
+ String newFileName = UUID.randomUUID().toString();
+ String suffix = fileName.substring(fileName.lastIndexOf("."));
+ String filePath = folder + "/" + newFileName + suffix;
+
+ // 桶名称，地址
+ ossClient.putObject(fileProperties.getBucketName(), filePath, file.getInputStream());
+
+ ObjectInfo info = new ObjectInfo();
+ info.setObjectPath(fileProperties.getBucketName() + PATH_SPLIT + filePath);
+ info.setObjectUrl(fileProperties.getBucketHost() + PATH_SPLIT + info.getObjectPath());
+ return info;
+ }
+
+ /**
+ * 删除对象
+ * @param objectPath 对象路径
+ */
+ public void delete(String objectPath) {
+ if (!StringUtils.isEmpty(objectPath)) {
+ ossClient.deleteObject(fileProperties.getBucketName(), objectPath);
+ }
+ }
+}
diff --git a/zlt-config/src/main/resources/application-dev.properties b/zlt-config/src/main/resources/application-dev.properties
index d6d323b0..c11026f7 100644
--- a/zlt-config/src/main/resources/application-dev.properties
+++ b/zlt-config/src/main/resources/application-dev.properties
@@ -15,7 +15,7 @@ zlt.elasticsearch.username=elasticsearch
zlt.elasticsearch.password=elasticsearch
##### sentinel配置
-zlt.sentinel.dashboard=192.168.28.130:6999
+zlt.sentinel.dashboard=localhost:6999
##### fastDFS配置
zlt.fdfs.web-url=192.168.28.130
@@ -27,6 +27,13 @@ zlt.s3.accessKeySecret=minioadmin
zlt.s3.endpoint=http://192.168.28.130:9000
zlt.s3.bucketName=test
+##### 阿里OSS配置
+zlt.alioss.accessKey=LTAI5tH7YyqGEBMebYtHuvJE
+zlt.alioss.accessKeySecret=WWcVwDpDcyrUVzcWhO7NCJupX1fC84
+zlt.alioss.endpoint=https://oss-cn-shenzhen.aliyuncs.com
+zlt.alioss.bucketName=ioath
+zlt.alioss.bucketHost=https://ioath.oss-cn-shenzhen.aliyuncs.com
+
##### 日志链路追踪
zlt.trace.enable=true
diff --git a/zlt-config/src/main/resources/application-prod.properties b/zlt-config/src/main/resources/application-prod.properties
index 5fe2ca3d..b48cf1c5 100644
--- a/zlt-config/src/main/resources/application-prod.properties
+++ b/zlt-config/src/main/resources/application-prod.properties
@@ -27,5 +27,12 @@ zlt.s3.accessKeySecret=minioadmin
zlt.s3.endpoint=http://192.168.28.130:9000
zlt.s3.bucketName=test
+##### 阿里OSS配置
+zlt.alioss.accessKey=LTAI5tH7YyqGEBMebYtHuvJE
+zlt.alioss.accessKeySecret=WWcVwDpDcyrUVzcWhO7NCJupX1fC84
+zlt.alioss.endpoint=https://oss-cn-shenzhen.aliyuncs.com
+zlt.alioss.bucketName=ioath
+zlt.alioss.bucketHost=https://ioath.oss-cn-shenzhen.aliyuncs.com
+
##### 日志链路追踪
zlt.trace.enable=true
\ No newline at end of file
diff --git a/zlt-config/src/main/resources/application-test.properties b/zlt-config/src/main/resources/application-test.properties
index ddf04395..8ae2dd92 100644
--- a/zlt-config/src/main/resources/application-test.properties
+++ b/zlt-config/src/main/resources/application-test.properties
@@ -27,5 +27,12 @@ zlt.s3.accessKeySecret=minioadmin
zlt.s3.endpoint=http://192.168.28.130:9000
zlt.s3.bucketName=test
+##### 阿里OSS配置
+zlt.alioss.accessKey=LTAI5tH7YyqGEBMebYtHuvJE
+zlt.alioss.accessKeySecret=WWcVwDpDcyrUVzcWhO7NCJupX1fC84
+zlt.alioss.endpoint=https://oss-cn-shenzhen.aliyuncs.com
+zlt.alioss.bucketName=ioath
+zlt.alioss.bucketHost=https://ioath.oss-cn-shenzhen.aliyuncs.com
+
##### 日志链路追踪
zlt.trace.enable=true
\ No newline at end of file
--
Gitee
From 27457d4c3cd3d8f7f0a472d8ceb0adef6b33c706 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=A8=E5=BD=AC=E9=91=AB?= <18235529318@163.com>
Date: Tue, 14 Dec 2021 00:50:48 +0800
Subject: [PATCH 3/5] =?UTF-8?q?=E8=A7=A3=E5=86=B3oss=E4=B8=8D=E8=83=BD?=
=?UTF-8?q?=E4=BD=BF=E7=94=A8=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../file/service/impl/AliOssService.java | 6 +--
.../zlt-oss-spring-boot-starter/pom.xml | 1 -
.../central/oss/config/OssAutoConfigure.java | 3 +-
.../central/oss/template/AliOssTemplate.java | 46 +++++++++----------
4 files changed, 24 insertions(+), 32 deletions(-)
diff --git a/zlt-business/file-center/src/main/java/com/central/file/service/impl/AliOssService.java b/zlt-business/file-center/src/main/java/com/central/file/service/impl/AliOssService.java
index 8fd39026..bc134799 100644
--- a/zlt-business/file-center/src/main/java/com/central/file/service/impl/AliOssService.java
+++ b/zlt-business/file-center/src/main/java/com/central/file/service/impl/AliOssService.java
@@ -3,15 +3,11 @@ package com.central.file.service.impl;
import com.central.oss.model.ObjectInfo;
import com.central.oss.properties.FileServerProperties;
import com.central.oss.template.AliOssTemplate;
-import com.central.oss.template.FdfsTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
-import java.io.IOException;
import java.io.OutputStream;
/**
@@ -22,7 +18,7 @@ import java.io.OutputStream;
@Service
@ConditionalOnProperty(prefix = FileServerProperties.PREFIX, name = "type", havingValue = FileServerProperties.TYPE_ALI_OSS)
public class AliOssService extends AbstractIFileService {
- @Autowired
+ @Resource
private AliOssTemplate aliOssTemplate;
@Override
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/pom.xml b/zlt-commons/zlt-oss-spring-boot-starter/pom.xml
index 9d38f616..f166ae9b 100644
--- a/zlt-commons/zlt-oss-spring-boot-starter/pom.xml
+++ b/zlt-commons/zlt-oss-spring-boot-starter/pom.xml
@@ -28,7 +28,6 @@
com.aliyun.oss
aliyun-sdk-oss
- true
org.springframework
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/config/OssAutoConfigure.java b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/config/OssAutoConfigure.java
index 725bc196..fdfdcaca 100644
--- a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/config/OssAutoConfigure.java
+++ b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/config/OssAutoConfigure.java
@@ -1,6 +1,7 @@
package com.central.oss.config;
import com.central.oss.properties.FileServerProperties;
+import com.central.oss.template.AliOssTemplate;
import com.central.oss.template.FdfsTemplate;
import com.central.oss.template.S3Template;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
@@ -14,7 +15,7 @@ import org.springframework.context.annotation.Import;
* Github: https://github.com/zlt2000
*/
@EnableConfigurationProperties(FileServerProperties.class)
-@Import({FdfsTemplate.class, S3Template.class})
+@Import({FdfsTemplate.class, S3Template.class, AliOssTemplate.class})
public class OssAutoConfigure {
}
diff --git a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java
index bdf7547c..e4a0774b 100644
--- a/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java
+++ b/zlt-commons/zlt-oss-spring-boot-starter/src/main/java/com/central/oss/template/AliOssTemplate.java
@@ -1,12 +1,12 @@
package com.central.oss.template;
-import com.aliyun.oss.OSSClient;
-import com.aliyun.oss.common.auth.DefaultCredentialProvider;
+import com.aliyun.oss.OSS;
+import com.aliyun.oss.OSSClientBuilder;
+import com.aliyun.oss.common.comm.ResponseMessage;
+import com.aliyun.oss.model.PutObjectResult;
import com.central.oss.model.ObjectInfo;
-import com.central.oss.properties.ALiOssProperties;
import com.central.oss.properties.FileServerProperties;
import lombok.SneakyThrows;
-import org.springframework.beans.factory.InitializingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.util.StringUtils;
@@ -21,27 +21,18 @@ import java.util.UUID;
*
* @author 杨彬鑫
*/
-@ConditionalOnClass(OSSClient.class)
+@ConditionalOnClass(OSS.class)
@ConditionalOnProperty(prefix = FileServerProperties.PREFIX, name = "type", havingValue = FileServerProperties.TYPE_ALI_OSS)
-public class AliOssTemplate implements InitializingBean {
- private static final String FILE_SPLIT = ".";
+public class AliOssTemplate {
private static final String PATH_SPLIT = "/";
@Resource
- private ALiOssProperties fileProperties;
-
- private OSSClient ossClient;
-
- @Override
- public void afterPropertiesSet(){
- ossClient = new OSSClient(fileProperties.getEndpoint()
- , new DefaultCredentialProvider(fileProperties.getAccessKey(), fileProperties.getAccessKeySecret())
- , null);
- }
+ private FileServerProperties fileProperties;
/**
* 上传文件
- * @param file 文件
+ *
+ * @param file 文件
* @param folder 子目录
* @return
* @throws IOException
@@ -50,31 +41,36 @@ public class AliOssTemplate implements InitializingBean {
public ObjectInfo upload(MultipartFile file, String folder) {
// 文件名
String fileName = file.getOriginalFilename();
- if (fileName.contains(FILE_SPLIT)) {
- throw new IllegalArgumentException("缺少后缀名");
- }
//获取文件的后缀名 .jpg
String newFileName = UUID.randomUUID().toString();
String suffix = fileName.substring(fileName.lastIndexOf("."));
String filePath = folder + "/" + newFileName + suffix;
+ OSS ossClient = new OSSClientBuilder().build(fileProperties.getAliOss().getEndpoint(), fileProperties.getAliOss().getAccessKey(), fileProperties.getAliOss().getAccessKeySecret());
+
// 桶名称，地址
- ossClient.putObject(fileProperties.getBucketName(), filePath, file.getInputStream());
+ PutObjectResult putObjectResult = ossClient.putObject(fileProperties.getAliOss().getBucketName(), filePath, file.getInputStream());
+ ResponseMessage response = putObjectResult.getResponse();
+
+ ossClient.shutdown();
ObjectInfo info = new ObjectInfo();
- info.setObjectPath(fileProperties.getBucketName() + PATH_SPLIT + filePath);
- info.setObjectUrl(fileProperties.getBucketHost() + PATH_SPLIT + info.getObjectPath());
+ info.setObjectPath(filePath);
+ info.setObjectUrl(fileProperties.getAliOss().getBucketHost() + PATH_SPLIT + info.getObjectPath());
return info;
}
/**
* 删除对象
+ *
* @param objectPath 对象路径
*/
public void delete(String objectPath) {
if (!StringUtils.isEmpty(objectPath)) {
- ossClient.deleteObject(fileProperties.getBucketName(), objectPath);
+ OSS ossClient = new OSSClientBuilder().build(fileProperties.getAliOss().getEndpoint(), fileProperties.getAliOss().getAccessKey(), fileProperties.getAliOss().getAccessKeySecret());
+
+ ossClient.deleteObject(fileProperties.getAliOss().getBucketName(), objectPath);
}
}
}
--
Gitee
From bceaa492107c0e8e02a4560885a82be6947f47ac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=A8=E5=BD=AC=E9=91=AB?= <18235529318@163.com>
Date: Wed, 15 Dec 2021 15:14:38 +0800
Subject: [PATCH 4/5] =?UTF-8?q?=E6=96=B0=E5=A2=9Esms-starter?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
pom.xml | 21 ++++
zlt-business/pom.xml | 1 +
zlt-business/third-center/pom.xml | 59 ++++++++++
.../main/java/com/central/ThirdCenterApp.java | 13 +++
.../third/controller/SmsController.java | 54 +++++++++
.../central/third/service/ISmsService.java | 38 +++++++
.../third/service/impl/AliSmsServiceImpl.java | 107 ++++++++++++++++++
.../src/main/resources/application.yml | 31 +++++
.../src/main/resources/bootstrap.yml | 6 +
zlt-commons/pom.xml | 1 +
.../zlt-sms-spring-boot-starter/pom.xml | 42 +++++++
.../central/sms/config/SmsAutoConfigure.java | 14 +++
.../sms/model/alisms/QuerySendInfoCo.java | 36 ++++++
.../sms/model/alisms/QuerySendInfoDto.java | 40 +++++++
.../sms/model/alisms/SendBatchSmsCo.java | 34 ++++++
.../central/sms/model/alisms/SendSmsCo.java | 35 ++++++
.../central/sms/model/alisms/SendSmsDto.java | 29 +++++
.../sms/properties/AliSmsProperties.java | 20 ++++
.../sms/properties/SmsServerProperties.java | 31 +++++
.../central/sms/template/AliSmsTemplate.java | 95 ++++++++++++++++
.../main/resources/META-INF/spring.factories | 2 +
.../main/resources/application-dev.properties | 5 +
.../main/resources/application-dev.properties | 4 +-
...JobInfoMapper.xml => IQuerySendInfoCo.xml} | 0
24 files changed, 716 insertions(+), 2 deletions(-)
create mode 100644 zlt-business/third-center/pom.xml
create mode 100644 zlt-business/third-center/src/main/java/com/central/ThirdCenterApp.java
create mode 100644 zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
create mode 100644 zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
create mode 100644 zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
create mode 100644 zlt-business/third-center/src/main/resources/application.yml
create mode 100644 zlt-business/third-center/src/main/resources/bootstrap.yml
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/pom.xml
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/config/SmsAutoConfigure.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoCo.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoDto.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendBatchSmsCo.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsCo.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsDto.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/AliSmsProperties.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/SmsServerProperties.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/template/AliSmsTemplate.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/resources/META-INF/spring.factories
rename zlt-job/job-admin/src/main/resources/mybatis-mapper/{XxlJobInfoMapper.xml => IQuerySendInfoCo.xml} (100%)
diff --git a/pom.xml b/pom.xml
index 3fc7a277..c62972f1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,6 +66,9 @@
hub.zlt.com:8080/microservices-platform
-Djava.security.egd=file:/dev/./urandom
-Xms128m -Xmx128m
+
+ 0.2.0
+ 2.0.8
@@ -440,6 +443,24 @@
pom
import
+
+
+
+ com.aliyun
+ tea-openapi
+ ${tea-openapi.version}
+
+
+ com.aliyun
+ dysmsapi20170525
+ ${dysmsapi20170525.version}
+
+
+ com.zlt
+ zlt-sms-spring-boot-starter
+ ${project.version}
+
+
diff --git a/zlt-business/pom.xml b/zlt-business/pom.xml
index b495fe22..019a654e 100644
--- a/zlt-business/pom.xml
+++ b/zlt-business/pom.xml
@@ -18,5 +18,6 @@
code-generator
search-center
+ third-center
\ No newline at end of file
diff --git a/zlt-business/third-center/pom.xml b/zlt-business/third-center/pom.xml
new file mode 100644
index 00000000..5db57065
--- /dev/null
+++ b/zlt-business/third-center/pom.xml
@@ -0,0 +1,59 @@
+
+
+
+ zlt-business
+ com.zlt
+ 5.1.0
+
+ 4.0.0
+ jar
+ third-center
+ 第三方组件集成
+
+
+
+
+ com.zlt
+ zlt-config
+
+
+ com.zlt
+ zlt-common-spring-boot-starter
+
+
+ com.zlt
+ zlt-db-spring-boot-starter
+
+
+ com.zlt
+ zlt-redis-spring-boot-starter
+
+
+
+
+ com.zlt
+ zlt-swagger2-spring-boot-starter
+
+
+
+ com.zlt
+ zlt-sms-spring-boot-starter
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ com.alibaba.cloud
+ spring-cloud-starter-alibaba-nacos-discovery
+
+
+
+ mysql
+ mysql-connector-java
+
+
+
\ No newline at end of file
diff --git a/zlt-business/third-center/src/main/java/com/central/ThirdCenterApp.java b/zlt-business/third-center/src/main/java/com/central/ThirdCenterApp.java
new file mode 100644
index 00000000..4df143e1
--- /dev/null
+++ b/zlt-business/third-center/src/main/java/com/central/ThirdCenterApp.java
@@ -0,0 +1,13 @@
+package com.central;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+@EnableDiscoveryClient
+@SpringBootApplication
+public class ThirdCenterApp {
+ public static void main(String[] args) {
+ SpringApplication.run(ThirdCenterApp.class, args);
+ }
+}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java b/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
new file mode 100644
index 00000000..e2969035
--- /dev/null
+++ b/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
@@ -0,0 +1,54 @@
+package com.central.third.controller;
+
+import cn.hutool.core.util.RandomUtil;
+import com.central.common.model.Result;
+import com.central.common.utils.JsonUtil;
+import com.central.third.service.ISmsService;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author 杨彬鑫
+ */
+@RestController
+public class SmsController {
+ @Resource
+ private ISmsService iSmsService;
+
+ @PostMapping("/send-sms")
+ public Result sendSms(@RequestBody Map map) {
+ // 生成验证码
+ String number = RandomUtil.randomNumbers(4);
+ HashMap params = new HashMap<>();
+ params.put("code", number);
+ map.put("TemplateParam", JsonUtil.toJSONString(params));
+ return iSmsService.sendSms(map);
+ }
+
+ @PostMapping("/send-batch-sms")
+ public Result sendBatchSms(@RequestBody Map map) {
+ List> list = new ArrayList<>();
+ for (int i = 0; i < 2; i++) {
+ // 生成验证码
+ String number = RandomUtil.randomNumbers(4);
+ HashMap params = new HashMap<>();
+ params.put("code", number);
+ list.add(params);
+ }
+
+ map.put("TemplateParamJson", JsonUtil.toJSONString(list));
+ return iSmsService.sendBatchSms(map);
+ }
+
+ @PostMapping("/query-send-info")
+ public Result QuerySendInfo(@RequestBody Map map) {
+ return iSmsService.QuerySendInfo(map);
+ }
+}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java b/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
new file mode 100644
index 00000000..c84e7688
--- /dev/null
+++ b/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
@@ -0,0 +1,38 @@
+package com.central.third.service;
+
+import com.central.common.model.Result;
+
+import java.util.Map;
+
+/**
+ * 短信业务接口
+ * @author 杨彬鑫
+ */
+public interface ISmsService {
+ /**
+ * 发送短信
+ * @param map
+ * @return
+ */
+ Result sendSms(Map map);
+
+ /**
+ * 批量发送短信
+ * @param map
+ * @return
+ */
+ Result sendBatchSms(Map map);
+
+ /**
+ * 查询短信详情
+ * @param map
+ * @return
+ */
+ Result QuerySendInfo(Map map);
+
+ /**
+ * 短信厂商
+ * @return
+ */
+ String SmsType();
+}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java b/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
new file mode 100644
index 00000000..84e0d6a0
--- /dev/null
+++ b/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
@@ -0,0 +1,107 @@
+package com.central.third.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.central.common.model.Result;
+import com.central.sms.model.alisms.QuerySendInfoCo;
+import com.central.sms.model.alisms.SendBatchSmsCo;
+import com.central.sms.model.alisms.SendSmsCo;
+import com.central.sms.properties.SmsServerProperties;
+import com.central.sms.template.AliSmsTemplate;
+import com.central.third.service.ISmsService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+/**
+ * 阿里短信，接口实现类
+ *
+ * @author 杨彬鑫
+ */
+@Service
+@ConditionalOnProperty(prefix = SmsServerProperties.PREFIX, name = "type", havingValue = "alisms")
+public class AliSmsServiceImpl implements ISmsService {
+
+ @Resource
+ private AliSmsTemplate aliSmsTemplate;
+
+ /**
+ * 发送短信
+ *
+ * @param map
+ * @return
+ */
+ @Override
+ public Result sendSms(Map map) {
+ SendSmsCo sendSmsCo = BeanUtil.mapToBean(map, SendSmsCo.class, true);
+
+ // 校验参数，非空
+ if (StringUtils.isEmpty(sendSmsCo.getPhoneNumbers())) {
+ return Result.failed("【PhoneNumbers】参数不能为空");
+ }
+ if (StringUtils.isEmpty(sendSmsCo.getSignName())) {
+ return Result.failed("【SignName】参数不能为空");
+ }
+ if (StringUtils.isEmpty(sendSmsCo.getTemplateCode())) {
+ return Result.failed("【TemplateCode】参数不能为空");
+ }
+
+ return aliSmsTemplate.sendSms(sendSmsCo);
+ }
+
+ @Override
+ public Result sendBatchSms(Map map) {
+ SendBatchSmsCo sendBatchSmsCo = BeanUtil.mapToBean(map, SendBatchSmsCo.class, true);
+ // 校验参数，非空
+ if (StringUtils.isEmpty(sendBatchSmsCo.getPhoneNumberJson())) {
+ return Result.failed("【PhoneNumberJson】参数不能为空");
+ }
+ if (StringUtils.isEmpty(sendBatchSmsCo.getSignNameJson())) {
+ return Result.failed("【SignNameJson】参数不能为空");
+ }
+ if (StringUtils.isEmpty(sendBatchSmsCo.getTemplateCode())) {
+ return Result.failed("【TemplateCode】参数不能为空");
+ }
+
+ return aliSmsTemplate.sendBatchSms(sendBatchSmsCo);
+ }
+
+ /**
+ * 查询短信详情
+ *
+ * @param map
+ * @return
+ */
+ @Override
+ public Result QuerySendInfo(Map map) {
+ QuerySendInfoCo querySendInfoCo = BeanUtil.mapToBean(map, QuerySendInfoCo.class, true);
+
+ // 校验参数，非空
+ if (StringUtils.isEmpty(querySendInfoCo.getPhoneNumber())) {
+ return Result.failed("【PhoneNumber】参数不能为空");
+ }
+ if (StringUtils.isEmpty(querySendInfoCo.getSendDate())) {
+ return Result.failed("【SendDate】参数不能为空");
+ }
+ if (querySendInfoCo.getPageSize() == null) {
+ querySendInfoCo.setPageSize(0L);
+ }
+ if (querySendInfoCo.getCurrentPage() == null) {
+ querySendInfoCo.setCurrentPage(10L);
+ }
+
+ return aliSmsTemplate.QuerySendInfo(querySendInfoCo);
+ }
+
+ /**
+ * 短信厂商
+ *
+ * @return
+ */
+ @Override
+ public String SmsType() {
+ return SmsServerProperties.TYPE_ALI_SMS;
+ }
+}
diff --git a/zlt-business/third-center/src/main/resources/application.yml b/zlt-business/third-center/src/main/resources/application.yml
new file mode 100644
index 00000000..23fb4cb9
--- /dev/null
+++ b/zlt-business/third-center/src/main/resources/application.yml
@@ -0,0 +1,31 @@
+spring:
+ datasource:
+ url: jdbc:mysql://${zlt.datasource.ip}:3306/third_center?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai
+ username: ${zlt.datasource.username}
+ password: ${zlt.datasource.password}
+ driver-class-name: com.mysql.cj.jdbc.Driver
+
+mybatis-plus:
+ mapper-locations: classpath:/mapper/*Mapper.xml
+ #实体扫描，多个package用逗号或者分号分隔
+ typeAliasesPackage: com.central.third.model
+ global-config:
+ db-config:
+ id-type: INPUT
+
+zlt:
+ sms-server:
+ type: alisms
+ alisms:
+ accessKeyId: ${zlt.alisms.accessKeyId}
+ accessKeySecret: ${zlt.alisms.accessKeySecret}
+ endpoint: ${zlt.alisms.endpoint}
+ swagger:
+ enabled: true
+ title: 文件中心
+ description: 文件中心接口文档
+ version: 1.0
+ base-package: com.central.third.controller
+ #多租户配置
+ tenant:
+ enable: true
\ No newline at end of file
diff --git a/zlt-business/third-center/src/main/resources/bootstrap.yml b/zlt-business/third-center/src/main/resources/bootstrap.yml
new file mode 100644
index 00000000..a3754aa6
--- /dev/null
+++ b/zlt-business/third-center/src/main/resources/bootstrap.yml
@@ -0,0 +1,6 @@
+server:
+ port: 5100
+
+spring:
+ application:
+ name: third-center
\ No newline at end of file
diff --git a/zlt-commons/pom.xml b/zlt-commons/pom.xml
index 7ef16f85..b10808fd 100644
--- a/zlt-commons/pom.xml
+++ b/zlt-commons/pom.xml
@@ -23,5 +23,6 @@
zlt-elasticsearch-spring-boot-starter
zlt-oss-spring-boot-starter
zlt-zookeeper-spring-boot-starter
+ zlt-sms-spring-boot-starter
\ No newline at end of file
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/pom.xml b/zlt-commons/zlt-sms-spring-boot-starter/pom.xml
new file mode 100644
index 00000000..7fe5fe06
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/pom.xml
@@ -0,0 +1,42 @@
+
+
+
+ zlt-commons
+ com.zlt
+ 5.1.0
+
+ 4.0.0
+ jar
+ zlt-sms-spring-boot-starter
+ 短信通用组件
+
+
+
+ org.springframework
+ spring-web
+
+
+
+ org.springframework.boot
+ spring-boot-configuration-processor
+ true
+
+
+
+ com.aliyun
+ tea-openapi
+ true
+
+
+ com.aliyun
+ dysmsapi20170525
+
+
+
+ com.zlt
+ zlt-common-core
+
+
+
\ No newline at end of file
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/config/SmsAutoConfigure.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/config/SmsAutoConfigure.java
new file mode 100644
index 00000000..2cc68526
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/config/SmsAutoConfigure.java
@@ -0,0 +1,14 @@
+package com.central.sms.config;
+
+import com.central.sms.properties.SmsServerProperties;
+import com.central.sms.template.AliSmsTemplate;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Import;
+
+/**
+ * @author 杨彬鑫
+ */
+@EnableConfigurationProperties(SmsServerProperties.class)
+@Import({AliSmsTemplate.class})
+public class SmsAutoConfigure {
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoCo.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoCo.java
new file mode 100644
index 00000000..a0b21888
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoCo.java
@@ -0,0 +1,36 @@
+package com.central.sms.model.alisms;
+
+import lombok.Data;
+
+/**
+ * 根据短信发送日期查看发送记录和短信内容，请求参数Co
+ * @author 杨彬鑫
+ */
+@Data
+public class QuerySendInfoCo {
+ /**
+ * 接收短信的手机号码。
+ */
+ private String PhoneNumber;
+ /**
+ * 发送回执ID，即发送流水号
+ */
+ private String BizId;
+ /**
+ * 短信发送日期，支持查询最近30天的记录。
+ *
+ * 注意：格式为yyyyMMdd，例如20181225。
+ */
+ private String SendDate;
+ /**
+ * 分页查看发送记录，指定每页显示的短信记录数量。
+ *
+ * 取值范围为1~50。
+ */
+ private Long PageSize;
+ /**
+ *
+ * 分页查看发送记录，指定发送记录的当前页码。
+ */
+ private Long CurrentPage;
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoDto.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoDto.java
new file mode 100644
index 00000000..e9ee1d4c
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/QuerySendInfoDto.java
@@ -0,0 +1,40 @@
+package com.central.sms.model.alisms;
+
+import com.aliyun.tea.NameInMap;
+import lombok.Data;
+
+/**
+ * 根据短信发送日期查看发送记录和短信内容，返回结果Dto
+ * @author 杨彬鑫
+ */
+@Data
+public class QuerySendInfoDto {
+ /**
+ * 请求状态码。
+ *
+ * 返回OK代表请求成功。
+ */
+ private String code;
+ /**
+ * 状态码的描述。
+ */
+ private String message;
+ /**
+ * 请求ID。
+ */
+ private String requestId;
+
+ private SmsSendDetailDto[] smsSendDetailDTOs;
+
+ @Data
+ class SmsSendDetailDto{
+ public String errCode;
+ public String templateCode;
+ public String outId;
+ public String receiveDate;
+ public String sendDate;
+ public String phoneNum;
+ public String content;
+ public Long sendStatus;
+ }
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendBatchSmsCo.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendBatchSmsCo.java
new file mode 100644
index 00000000..c1e3a87f
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendBatchSmsCo.java
@@ -0,0 +1,34 @@
+package com.central.sms.model.alisms;
+
+import lombok.Data;
+
+/**
+ * 批量发送短信，请求参数Co
+ * @author 杨彬鑫
+ */
+@Data
+public class SendBatchSmsCo {
+ /**
+ * 接收短信的手机号码，JSON数组格式。
+ */
+ private String PhoneNumberJson;
+ /**
+ * 短信签名名称，JSON数组格式。
+ *
+ * 注意：必须是已添加、并通过审核的短信签名；且短信签名的个数必须与手机号码的个数相同、内容一一对应。
+ */
+ private String SignNameJson;
+ /**
+ * 短信模板CODE。
+ */
+ private String TemplateCode;
+ /**
+ * 短信模板变量对应的实际值，JSON格式。
+ */
+ private String TemplateParamJson;
+ /**
+ * 上行短信扩展码，JSON数组格式。
+ */
+ private String SmsUpExtendCodeJson;
+
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsCo.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsCo.java
new file mode 100644
index 00000000..412328ce
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsCo.java
@@ -0,0 +1,35 @@
+package com.central.sms.model.alisms;
+
+import lombok.Data;
+
+/**
+ * 发送短信，请求参数Co
+ * @author 杨彬鑫
+ */
+@Data
+public class SendSmsCo {
+ /**
+ * 接收短信的手机号码
+ */
+ private String PhoneNumbers;
+ /**
+ * 短信签名名称
+ */
+ private String SignName;
+ /**
+ * 短信模板ID
+ */
+ private String TemplateCode;
+ /**
+ * 短信模板变量对应的实际值，JSON格式
+ */
+ private String TemplateParam;
+ /**
+ * 上行短信扩展码
+ */
+ private String SmsUpExtendCode;
+ /**
+ * 外部流水扩展字段
+ */
+ private String OutId;
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsDto.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsDto.java
new file mode 100644
index 00000000..3d4e849a
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/alisms/SendSmsDto.java
@@ -0,0 +1,29 @@
+package com.central.sms.model.alisms;
+
+import lombok.Data;
+
+/**
+ * 发送短信，返回结果Dto
+ * @author 杨彬鑫
+ */
+@Data
+public class SendSmsDto {
+ /**
+ * 请求状态码。
+ *
+ * 返回OK代表请求成功。
+ */
+ private String code;
+ /**
+ * 状态码的描述。
+ */
+ private String message;
+ /**
+ * 发送回执ID。
+ */
+ private String bizId;
+ /**
+ * 请求ID。
+ */
+ private String requestId;
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/AliSmsProperties.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/AliSmsProperties.java
new file mode 100644
index 00000000..e76bbf82
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/AliSmsProperties.java
@@ -0,0 +1,20 @@
+package com.central.sms.properties;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * @author 杨彬鑫
+ */
+@Getter
+@Setter
+public class AliSmsProperties {
+ private String accessKeyId;
+
+ private String accessKeySecret;
+
+ /**
+ * 访问的域名
+ */
+ private String endpoint;
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/SmsServerProperties.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/SmsServerProperties.java
new file mode 100644
index 00000000..8a6dd04c
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/SmsServerProperties.java
@@ -0,0 +1,31 @@
+package com.central.sms.properties;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+/**
+ * @author 杨彬鑫
+ * @date 2021/12/15
+ *
+ */
+@Setter
+@Getter
+@ConfigurationProperties(prefix = SmsServerProperties.PREFIX)
+public class SmsServerProperties {
+ public static final String PREFIX = "zlt.sms-server";
+ public static final String TYPE_ALI_SMS = "alisms";
+ public static final String TYPE_WYY_SMS = "wyysms";
+
+ /**
+ * 为以下2个值，指定不同的自动化配置
+ * alisms：阿里云短信
+ * wyysms：网易云短信
+ */
+ private String type;
+
+ /**
+ * 阿里云短信配置
+ */
+ AliSmsProperties alisms = new AliSmsProperties();
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/template/AliSmsTemplate.java b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/template/AliSmsTemplate.java
new file mode 100644
index 00000000..8e6eb73c
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/template/AliSmsTemplate.java
@@ -0,0 +1,95 @@
+package com.central.sms.template;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.aliyun.dysmsapi20170525.Client;
+import com.aliyun.dysmsapi20170525.models.*;
+import com.aliyun.teaopenapi.models.Config;
+import com.central.common.model.Result;
+import com.central.sms.model.alisms.*;
+import com.central.sms.properties.SmsServerProperties;
+import lombok.SneakyThrows;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+
+/**
+ * @author 杨彬鑫
+ */
+@ConditionalOnClass(Client.class)
+@ConditionalOnProperty(prefix = SmsServerProperties.PREFIX, name = "type", havingValue = "alisms")
+public class AliSmsTemplate implements InitializingBean {
+ private final String SUCCESS = "OK";
+
+ @Autowired
+ private SmsServerProperties smsServerProperties;
+
+ private Client client;
+
+ @Override
+ public void afterPropertiesSet() throws Exception {
+ Config config = new Config()
+ .setAccessKeyId(smsServerProperties.getAlisms().getAccessKeyId())
+ .setAccessKeySecret(smsServerProperties.getAlisms().getAccessKeySecret())
+ .setEndpoint(smsServerProperties.getAlisms().getEndpoint());
+ client = new Client(config);
+ }
+
+ /**
+ * 发送短信
+ *
+ * @param sendSmsCo
+ * @return
+ */
+ @SneakyThrows
+ public Result sendSms(SendSmsCo sendSmsCo) {// 请求参数
+ SendSmsRequest sendSmsRequest = SendSmsRequest.build(BeanUtil.beanToMap(sendSmsCo));
+
+ // 发送请求
+ SendSmsResponse sendSmsResponse = client.sendSms(sendSmsRequest);
+ // 获取响应
+ SendSmsResponseBody body = sendSmsResponse.getBody();
+ SendSmsDto sendSmsDto = BeanUtil.toBean(body, SendSmsDto.class);
+
+ return sendSmsDto.getCode().equals(SUCCESS) ? Result.succeed(sendSmsDto) : Result.failed(sendSmsDto, "发送失败");
+ }
+
+ /**
+ * 批量发送短信
+ *
+ * @param sendBatchSmsCo
+ * @return
+ */
+ @SneakyThrows
+ public Result sendBatchSms(SendBatchSmsCo sendBatchSmsCo) {
+ // 请求参数
+ SendBatchSmsRequest sendBatchSmsRequest = SendBatchSmsRequest.build(BeanUtil.beanToMap(sendBatchSmsCo));
+
+ // 发送请求
+ SendBatchSmsResponse sendBatchSmsResponse = client.sendBatchSms(sendBatchSmsRequest);
+ // 获取响应
+ SendBatchSmsResponseBody body = sendBatchSmsResponse.getBody();
+ SendSmsDto sendSmsDto = BeanUtil.toBean(body, SendSmsDto.class);
+
+ return sendSmsDto.getCode().equals(SUCCESS) ? Result.succeed(sendSmsDto) : Result.failed(sendSmsDto, "发送失败");
+ }
+
+ /**
+ * 根据短信发送日期查看发送记录和短信内容
+ *
+ * @param querySendInfoCo
+ * @return
+ */
+ @SneakyThrows
+ public Result QuerySendInfo(QuerySendInfoCo querySendInfoCo) {
+ // 请求参数
+ QuerySendDetailsRequest querySendDetailsRequest = QuerySendDetailsRequest.build(BeanUtil.beanToMap(querySendInfoCo));
+
+ // 发送请求
+ QuerySendDetailsResponse querySendDetailsResponse = client.querySendDetails(querySendDetailsRequest);
+ // 获取响应
+ QuerySendDetailsResponseBody body = querySendDetailsResponse.getBody();
+ QuerySendInfoDto querySendInfoDto = BeanUtil.toBean(body, QuerySendInfoDto.class);
+ return querySendInfoDto.getCode().equals(SUCCESS) ? Result.succeed(querySendInfoDto) : Result.failed(querySendInfoDto, "发送失败");
+ }
+}
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/src/main/resources/META-INF/spring.factories b/zlt-commons/zlt-sms-spring-boot-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 00000000..4912d27d
--- /dev/null
+++ b/zlt-commons/zlt-sms-spring-boot-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+com.central.sms.config.SmsAutoConfigure
\ No newline at end of file
diff --git a/zlt-config/src/main/resources/application-dev.properties b/zlt-config/src/main/resources/application-dev.properties
index c11026f7..6a30e364 100644
--- a/zlt-config/src/main/resources/application-dev.properties
+++ b/zlt-config/src/main/resources/application-dev.properties
@@ -34,6 +34,11 @@ zlt.alioss.endpoint=https://oss-cn-shenzhen.aliyuncs.com
zlt.alioss.bucketName=ioath
zlt.alioss.bucketHost=https://ioath.oss-cn-shenzhen.aliyuncs.com
+##### 阿里SMS配置
+zlt.alisms.accessKeyId=LTAI5tH7YyqGEBMebYtHuvJE
+zlt.alisms.accessKeySecret=WWcVwDpDcyrUVzcWhO7NCJupX1fC84
+zlt.alisms.endpoint=dysmsapi.aliyuncs.com
+
##### 日志链路追踪
zlt.trace.enable=true
diff --git a/zlt-job/job-admin/src/main/resources/application-dev.properties b/zlt-job/job-admin/src/main/resources/application-dev.properties
index bc97e7df..3af4c5a3 100644
--- a/zlt-job/job-admin/src/main/resources/application-dev.properties
+++ b/zlt-job/job-admin/src/main/resources/application-dev.properties
@@ -1,7 +1,7 @@
### xxl-job, datasource
-zlt.datasource.ip=192.168.28.131
+zlt.datasource.ip=39.103.222.107
zlt.datasource.username=root
-zlt.datasource.password=1q2w3e4r
+zlt.datasource.password=lilishop
spring.datasource.url=jdbc:mysql://${zlt.datasource.ip}:3306/xxl-job?Unicode=true&characterEncoding=UTF-8
spring.datasource.username=${zlt.datasource.username}
diff --git a/zlt-job/job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml b/zlt-job/job-admin/src/main/resources/mybatis-mapper/IQuerySendInfoCo.xml
similarity index 100%
rename from zlt-job/job-admin/src/main/resources/mybatis-mapper/XxlJobInfoMapper.xml
rename to zlt-job/job-admin/src/main/resources/mybatis-mapper/IQuerySendInfoCo.xml
--
Gitee
From 4a596b2dd00802562bd8df11f99982883ff8ee79 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=A8=E5=BD=AC=E9=91=AB?= <18235529318@163.com>
Date: Wed, 15 Dec 2021 17:36:23 +0800
Subject: [PATCH 5/5] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=BD=91=E6=98=93?=
=?UTF-8?q?=E4=BA=91=E9=AA=8C=E8=AF=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.idea/httpRequests/http-requests-log.http | 448 ++++++++++++++++++
.../third/controller/SmsController.java | 5 +
.../central/third/service/ISmsService.java | 7 +
.../third/service/impl/AliSmsServiceImpl.java | 5 +
.../third/service/impl/WyySmsServiceImpl.java | 58 +++
.../src/main/resources/application.yml | 5 +-
.../zlt-sms-spring-boot-starter/pom.xml | 4 +
.../central/sms/config/SmsAutoConfigure.java | 3 +-
.../central/sms/model/wyysms/SendSmsCo.java | 27 ++
.../central/sms/model/wyysms/SendSmsDto.java | 14 +
.../sms/model/wyysms/VerifyCodeCo.java | 14 +
.../sms/properties/SmsServerProperties.java | 5 +
.../sms/properties/WyySmsProperties.java | 13 +
.../central/sms/template/WyySmsTemplate.java | 130 +++++
.../central/sms/utils/CheckSumBuilder.java | 58 +++
15 files changed, 794 insertions(+), 2 deletions(-)
create mode 100644 .idea/httpRequests/http-requests-log.http
create mode 100644 zlt-business/third-center/src/main/java/com/central/third/service/impl/WyySmsServiceImpl.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/wyysms/SendSmsCo.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/wyysms/SendSmsDto.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/model/wyysms/VerifyCodeCo.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/properties/WyySmsProperties.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/template/WyySmsTemplate.java
create mode 100644 zlt-commons/zlt-sms-spring-boot-starter/src/main/java/com/central/sms/utils/CheckSumBuilder.java
diff --git a/.idea/httpRequests/http-requests-log.http b/.idea/httpRequests/http-requests-log.http
new file mode 100644
index 00000000..ec364106
--- /dev/null
+++ b/.idea/httpRequests/http-requests-log.http
@@ -0,0 +1,448 @@
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "412304",
+ "nonce": "1234456546"
+}
+
+<> 2021-12-15T053548.200.json
+
+###
+
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "nonce": "412304"
+}
+
+<> 2021-12-15T053531.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "nonce": "1234567",
+ "templateId": "19496093",
+ "mobile": "18235529318",
+ "codeLen": "6"
+}
+
+<> 2021-12-15T053523.200.json
+
+###
+
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "nonce": "1234456546"
+}
+
+<> 2021-12-15T053515.200.json
+
+###
+
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "none": "1234456546"
+}
+
+<> 2021-12-15T053506.200.json
+
+###
+
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "none": "1234456546"
+}
+
+<> 2021-12-15T053152.200.json
+
+###
+
+POST http://localhost:5100/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "none": "1234"
+}
+
+<> 2021-12-15T053005.200.json
+
+###
+
+POST http://localhost:5001/verify-code
+Content-Type: application/json
+
+{
+ "mobile": "18235529318",
+ "code": "813135",
+ "none": "1234"
+}
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "nonce": "1234567",
+ "templateId": "19496093",
+ "mobile": "18235529318",
+ "codeLen": "6"
+}
+
+<> 2021-12-15T051439.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "nonce": "1234567",
+ "templateId": "19496093",
+ "mobile": "18235529318",
+ "codeLen": "6"
+}
+
+<> 2021-12-15T051210.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "nonce": "1234567",
+ "templateId": "19496093",
+ "mobile": "18235529318",
+ "codeLen": "6"
+}
+
+<> 2021-12-15T051143.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "nonce": "1234567",
+ "templateId": "19496093",
+ "mobile": "18235529318",
+ "codeLen": "6"
+}
+
+<> 2021-12-15T050611.500.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumber": "13051156821",
+ "BizId": "505520539552195487^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T031222.200.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumber": "18235529318",
+ "BizId": "505520539552195487^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T031135.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "SMS_207890087"
+}
+
+<> 2021-12-15T031056.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890087\",\"SMS_207890087\"]"
+}
+
+<> 2021-12-15T031018.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890086\"]"
+}
+
+<> 2021-12-15T031009.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890087\"]",
+ "TemplateParamJson": "[\"SMS_207890087\",\"SMS_207890087\"]"
+}
+
+<> 2021-12-15T030951.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890087\"]",
+ "TemplateParamJson": "[\"SMS_207890086\",\"SMS_207890086\"]"
+}
+
+<> 2021-12-15T030941.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890087\"]",
+ "TemplateParamJson": "[\"SMS_207890086\",\"SMS_207890086\"]"
+}
+
+<> 2021-12-15T030926.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890087\"]",
+ "TemplateParamJson": "[\"SMS_207890086\",\"SMS_207890087\"]"
+}
+
+<> 2021-12-15T030841.200.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+Content-Type: application/json
+
+{
+ "PhoneNumberJson": "[\"18235529318\",\"13051156821\"]",
+ "SignNameJson": "[\"浅野科技\",\"浅野科技\"]",
+ "TemplateCode": "[\"SMS_207890086\",\"SMS_207890087\"]",
+ "TemplateParamJson": "[\"SMS_207890086\",\"SMS_207890087\"]"
+}
+
+<> 2021-12-15T030711.200.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumber": "18235529318",
+ "BizId": "453511539550599091^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T025459.200.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumber": "18235529318",
+ "BizId": "453511539550599091^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T025415.200.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumber": "18235529318",
+ "BizId": "453511539550599091^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T025222.500.json
+
+###
+
+POST http://localhost:5100/query-send-info
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "BizId": "453511539550599091^0",
+ "SendDate": "20211215"
+}
+
+<> 2021-12-15T025214.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T024426.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T023757.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T023719.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T023548.500.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T023452.500.json
+
+###
+
+POST http://localhost:5100/send-sms
+Content-Type: application/json
+
+{
+ "PhoneNumbers": "18235529318",
+ "SignName": "浅野科技",
+ "TemplateCode": "SMS_207890086"
+}
+
+<> 2021-12-15T022832.500.json
+
+###
+
+GET http://localhost:5100/query-send-info
+
+<> 2021-12-15T020628.200.json
+
+###
+
+POST http://localhost:5100/query-send-info
+
+<> 2021-12-15T020621.405.json
+
+###
+
+POST http://localhost:5100/send-batch-sms
+
+<> 2021-12-15T020608.200.json
+
+###
+
+POST http://localhost:5100/send-sms
+
+<> 2021-12-15T020600.200.json
+
+###
+
diff --git a/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java b/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
index e2969035..d6e12b69 100644
--- a/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
+++ b/zlt-business/third-center/src/main/java/com/central/third/controller/SmsController.java
@@ -51,4 +51,9 @@ public class SmsController {
public Result QuerySendInfo(@RequestBody Map map) {
return iSmsService.QuerySendInfo(map);
}
+
+ @PostMapping("/verify-code")
+ public Result VerifyCode(@RequestBody Map map){
+ return iSmsService.verifyCode(map);
+ }
}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java b/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
index c84e7688..9119d97e 100644
--- a/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
+++ b/zlt-business/third-center/src/main/java/com/central/third/service/ISmsService.java
@@ -35,4 +35,11 @@ public interface ISmsService {
* @return
*/
String SmsType();
+
+ /**
+ * 校验验证码
+ * @param map
+ * @return
+ */
+ Result verifyCode(Map map);
}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java b/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
index 84e0d6a0..dec66474 100644
--- a/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
+++ b/zlt-business/third-center/src/main/java/com/central/third/service/impl/AliSmsServiceImpl.java
@@ -104,4 +104,9 @@ public class AliSmsServiceImpl implements ISmsService {
public String SmsType() {
return SmsServerProperties.TYPE_ALI_SMS;
}
+
+ @Override
+ public Result verifyCode(Map map) {
+ return Result.failed("未开发");
+ }
}
diff --git a/zlt-business/third-center/src/main/java/com/central/third/service/impl/WyySmsServiceImpl.java b/zlt-business/third-center/src/main/java/com/central/third/service/impl/WyySmsServiceImpl.java
new file mode 100644
index 00000000..86ad7903
--- /dev/null
+++ b/zlt-business/third-center/src/main/java/com/central/third/service/impl/WyySmsServiceImpl.java
@@ -0,0 +1,58 @@
+package com.central.third.service.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.central.common.model.Result;
+import com.central.sms.model.wyysms.SendSmsCo;
+import com.central.sms.model.wyysms.VerifyCodeCo;
+import com.central.sms.properties.SmsServerProperties;
+import com.central.sms.template.WyySmsTemplate;
+import com.central.third.service.ISmsService;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+/**
+ * 网易云短信，业务实现类
+ * @author 杨彬鑫
+ */
+@Service
+@ConditionalOnProperty(prefix = SmsServerProperties.PREFIX,name = "type",havingValue = "wyysms")
+public class WyySmsServiceImpl implements ISmsService {
+ @Resource
+ private WyySmsTemplate wyySmsTemplate;
+
+ @Override
+ public Result sendSms(Map map) {
+ return wyySmsTemplate.sendSms(BeanUtil.mapToBean(map, SendSmsCo.class,true));
+ }
+
+ @Override
+ public Result sendBatchSms(Map map) {
+ return Result.failed("厂商暂不提供该方法");
+ }
+
+ @Override
+ public Result QuerySendInfo(Map map) {
+ return null;
+ }
+
+ @Override
+ public String SmsType() {
+ return SmsServerProperties.TYPE_WYY_SMS;
+ }
+
+ @Override
+ public Result verifyCode(Map map) {
+ VerifyCodeCo verifyCodeCo = BeanUtil.mapToBean(map, VerifyCodeCo.class, true);
+ if(StringUtils.isEmpty(verifyCodeCo.getMobile())){
+ return Result.failed("【Mobile】参数不能为空");
+ }
+ if(StringUtils.isEmpty(verifyCodeCo.getCode())){
+ return Result.failed("【Code】参数不能为空");
+ }
+ return wyySmsTemplate.verifyCode(verifyCodeCo);
+ }
+}
diff --git a/zlt-business/third-center/src/main/resources/application.yml b/zlt-business/third-center/src/main/resources/application.yml
index 23fb4cb9..4737f7b4 100644
--- a/zlt-business/third-center/src/main/resources/application.yml
+++ b/zlt-business/third-center/src/main/resources/application.yml
@@ -15,11 +15,14 @@ mybatis-plus:
zlt:
sms-server:
- type: alisms
+ type: wyysms
alisms:
accessKeyId: ${zlt.alisms.accessKeyId}
accessKeySecret: ${zlt.alisms.accessKeySecret}
endpoint: ${zlt.alisms.endpoint}
+ wyysms:
+ appKey: 6048288d66a2508d7c2c654f70f29a6d
+ appSecret: a626dde5c805
swagger:
enabled: true
title: 文件中心
diff --git a/zlt-commons/zlt-sms-spring-boot-starter/pom.xml b/zlt-commons/zlt-sms-spring-boot-starter/pom.xml
index 7fe5fe06..b024fc1b 100644
--- a/zlt-commons/zlt-sms-spring-boot-starter/pom.xml
+++ b/zlt-commons/zlt-sms-spring-boot-starter/pom.xml
@@ -38,5 +38,9 @@
com.zlt
zlt-common-core
+