From 77f99d897d6e9e53ca6ca7aae97a5781114bc177 Mon Sep 17 00:00:00 2001 From: wen <1455474577@qq.com> Date: Mon, 29 Nov 2021 18:28:26 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9F=AD=E4=BF=A1=E7=BB=9F=E8=AE=A1=EF=BC=8C?= =?UTF-8?q?=E5=86=99=E4=BA=86=E4=B8=89=E4=B8=AAMapper=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../general/controller/XhpcSmsController.java | 10 ++++- .../xhpc/general/mapper/XhpcSmsMapper.java | 33 ++++++++++++++- .../xhpc/general/service/IXhpcSmsService.java | 11 +++++ .../general/service/XhpcSmsServiceImpl.java | 42 +++++++++---------- .../main/resources/mapper/XhpcSmsMapper.xml | 27 +++++++++++- 5 files changed, 97 insertions(+), 26 deletions(-) diff --git a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/controller/XhpcSmsController.java b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/controller/XhpcSmsController.java index 5d09fe6f..948e30fe 100644 --- a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/controller/XhpcSmsController.java +++ b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/controller/XhpcSmsController.java @@ -25,7 +25,7 @@ public class XhpcSmsController extends BaseController { * 注册获取手机号验证码 */ @GetMapping(value = "/getLogonPhoneCode") - public AjaxResult getLogonPhoneCode(@RequestParam("phone") String phone) throws Exception { + public AjaxResult getLogonPhoneCode(@RequestParam("phone") String phone) { String signatureName = null; String templateId = null; @@ -75,4 +75,12 @@ public class XhpcSmsController extends BaseController { xhpcSmsService.sendNotice(phone, signatureName, templateId, paramMap); } + + @GetMapping(value = "/getAliyunShortMessageInfo") + public AjaxResult getAliyunShortMessageInfo() { + + Object messageInfo = xhpcSmsService.getAliyunShortMessageInfo(); + return AjaxResult.success(); + } + } diff --git a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/mapper/XhpcSmsMapper.java b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/mapper/XhpcSmsMapper.java index 2fe05bde..3cfc434b 100644 --- a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/mapper/XhpcSmsMapper.java +++ b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/mapper/XhpcSmsMapper.java @@ -14,6 +14,37 @@ public interface XhpcSmsMapper { int addXhpcSms(XhpcSms xhpcSms); + List> getList(@Param("status") Integer status, @Param("phone") String phone); + + /** + * 查询阿里云中发送失败的短信条数 + * + * @return 返回发送失败的条数 + * @author WH + * @date 2021/11/29 14:11 + * @since version-1.0 + */ + Long querySumOfFailMessage(); + + /** + * 查询阿里云中的发送成功的短信条数 + * + * @return 发送成功的短信的条数 + * @author WH + * @date 2021/11/29 + * @since version-1.0 + */ + Long querySumOfSuccessMessage(); + + /** + * 查询发送的短信的总记录数 + * + * @return 返回发送过的短信的总记录数 + * @author WH + * @date 2021/11/29 14:25 + * @since version-1.0 + */ + Long querySumOfMessage(); + - List> getList(@Param("status") Integer status,@Param("phone") String phone); } diff --git a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/IXhpcSmsService.java b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/IXhpcSmsService.java index 5f92e39f..9b6c2abd 100644 --- a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/IXhpcSmsService.java +++ b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/IXhpcSmsService.java @@ -46,4 +46,15 @@ public interface IXhpcSmsService { * @param paramMap 模板中的参数 */ void sendNotice(String phone, String signatureName, String templateId, Map paramMap); + + /** + * 获取阿里云短信服务信息 + * + * @return 一个装有阿里云短信信息的对象 + * @author WH + * @date 2021/11/29 10:31 + * @since version-1.0 + */ + Object getAliyunShortMessageInfo(); + } diff --git a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/XhpcSmsServiceImpl.java b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/XhpcSmsServiceImpl.java index 06d7e023..3466f71c 100644 --- a/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/XhpcSmsServiceImpl.java +++ b/xhpc-modules/xhpc-general/src/main/java/com/xhpc/general/service/XhpcSmsServiceImpl.java @@ -10,11 +10,11 @@ import com.xhpc.common.redis.service.RedisService; import com.xhpc.general.domain.XhpcSms; import com.xhpc.general.mapper.XhpcSmsMapper; import com.xhpc.general.util.sms.SmsUtil; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.annotation.PostConstruct; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.regex.Matcher; @@ -24,6 +24,7 @@ import java.util.regex.Pattern; * @author yuyang * @date 2021/7/30 18:50 */ +@Slf4j @Service public class XhpcSmsServiceImpl implements IXhpcSmsService { @@ -78,12 +79,20 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { //用户频繁调用的判断的Key String token = "token:" + phone; String cacheObject = REDIS.getCacheObject(token); + System.out.println("过了redis"); if (cacheObject != null) { return AjaxResult.error("1012", "操作过于频繁，请于1分钟后重试"); } //使用阿里云发送通知短信 - Map neededParam = aliyunSmsNotice(phone, signatureName, templateId, paramMap); + Map neededParam = null; + try { + neededParam = aliyunSmsNotice(phone, signatureName, templateId, paramMap); + } catch (Exception e) { + System.out.println(e.getMessage()); + throw new RuntimeException("阿里短信服务异常,neededParam为null"); + } + System.out.println("过了阿里云"); if (!"".equals(random) && random != null) { xhpcSms.setCode(random); @@ -155,6 +164,12 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { xhpcSmsMapper.addXhpcSms(xhpcSms); } + @Override + public Object getAliyunShortMessageInfo() { + //todo + return null; + } + public static void main(String[] args) { for (int i = 0; i < 50; i++) { @@ -191,39 +206,20 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { String templateParam = JSONUtil.toJsonStr(paramMap); sendSmsRequest.setTemplateParam(templateParam); SendSmsResponse sendSmsResponse = client.sendSms(sendSmsRequest); - //获取发送结果状态码 String statusCode = sendSmsResponse.getBody().getCode(); - //获取短信的Biz号 - //String bizId = sendSmsResponse.getBody().getBizId(); - //获取短信的发送日期，并将其转换为yyyyMMdd的格式 - //String date = sendSmsResponse.getHeaders().get("date"); - //Date realDate = new Date(date); - //SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); - //String formatData = sdf.format(realDate); - //获取实际的模板内容 String templateContent = getTemplateContent(templateId, paramMap); - -// //获取所发送的模板信息 -// QuerySendDetailsRequest querySendDetailsRequest = new QuerySendDetailsRequest(); -// querySendDetailsRequest.setPhoneNumber(phone); -// querySendDetailsRequest.setBizId(bizId); -// querySendDetailsRequest.setSendDate(formatData); -// querySendDetailsRequest.setCurrentPage(1L); -// querySendDetailsRequest.setPageSize(10L); -// Thread.sleep(400); -// String templateContent = client.querySendDetails(querySendDetailsRequest).getBody().getSmsSendDetailDTOs().getSmsSendDetailDTO().get(0).getContent(); - //获取阿里云的返回值json字符串 SendSmsResponseBody body = sendSmsResponse.getBody(); String jsonResult = JSONUtil.toJsonStr(body); - + System.out.println("阿里云返回值的json字符串=============》" + jsonResult); //存放后面需要使用的返回值 HashMap valueParam = new HashMap<>(); valueParam.put("statusCode", statusCode); valueParam.put("templateContent", templateContent); valueParam.put("jsonResult", jsonResult); + System.out.println(("valueParam的值===========》" + valueParam)); return valueParam; } diff --git a/xhpc-modules/xhpc-general/src/main/resources/mapper/XhpcSmsMapper.xml b/xhpc-modules/xhpc-general/src/main/resources/mapper/XhpcSmsMapper.xml index c703459c..a3e3902c 100644 --- a/xhpc-modules/xhpc-general/src/main/resources/mapper/XhpcSmsMapper.xml +++ b/xhpc-modules/xhpc-general/src/main/resources/mapper/XhpcSmsMapper.xml @@ -98,7 +98,7 @@ phone, content, status, - create_time as createTime + create_time as createTime from xhpc_sms where del_flag=0 @@ -108,4 +108,29 @@ and phone like concat('%',#{phone},'%') + + + + + + +