From fa55722dec5eb9a270c39212cabce97e9d95d7d0 Mon Sep 17 00:00:00 2001 From: wen <1455474577@qq.com> Date: Thu, 28 Oct 2021 18:09:02 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=9F=AD=E4=BF=A1=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E9=98=BF=E9=87=8C=E4=BA=91=E5=BB=B6=E8=BF=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../general/controller/XhpcSmsController.java | 4 +- .../general/service/XhpcSmsServiceImpl.java | 55 ++++++++++++++++--- 2 files changed, 48 insertions(+), 11 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 8b343e87..8de95283 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 @@ -65,7 +65,7 @@ public class XhpcSmsController extends BaseController { templateId = "SMS_226935795"; } else if (content.contains("设定的SOC")) { signatureName = "小华充电"; - templateId = "SMS_226826374"; + templateId = "SMS_227005968"; } } else { phone = paramMap.get("phone"); @@ -84,7 +84,7 @@ public class XhpcSmsController extends BaseController { templateId = "SMS_226935795"; } else if (content.contains("设定的SOC")) { signatureName = "小华充电"; - templateId = "SMS_226826374"; + templateId = "SMS_227005968"; } } xhpcSmsService.sendNotice(phone, signatureName, templateId, paramMap); 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 9cad7741..461a3b5d 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 @@ -2,7 +2,6 @@ package com.xhpc.general.service; import cn.hutool.json.JSONUtil; import com.aliyun.dysmsapi20170525.Client; -import com.aliyun.dysmsapi20170525.models.QuerySendDetailsRequest; import com.aliyun.dysmsapi20170525.models.SendSmsRequest; import com.aliyun.dysmsapi20170525.models.SendSmsResponse; import com.aliyun.dysmsapi20170525.models.SendSmsResponseBody; @@ -181,6 +180,7 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { * @throws Exception */ public Map aliyunSmsNotice(String phone, String signatureName, String templateId, Map paramMap) throws Exception { + //调用阿里云API发送请求 Client client = SmsUtil.createClient(accessKeyId, accessKeySecret); SendSmsRequest sendSmsRequest = new SendSmsRequest(); @@ -202,14 +202,18 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); String formatData = sdf.format(realDate); - //获取所发送的模板信息 - QuerySendDetailsRequest querySendDetailsRequest = new QuerySendDetailsRequest(); - querySendDetailsRequest.setPhoneNumber(phone); - querySendDetailsRequest.setBizId(bizId); - querySendDetailsRequest.setSendDate(formatData); - querySendDetailsRequest.setCurrentPage(1L); - querySendDetailsRequest.setPageSize(10L); - String templateContent = client.querySendDetails(querySendDetailsRequest).getBody().getSmsSendDetailDTOs().getSmsSendDetailDTO().get(0).getContent(); + //获取实际的模板内容 + 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(); @@ -223,5 +227,38 @@ public class XhpcSmsServiceImpl implements IXhpcSmsService { return valueParam; } + private String getTemplateContent(String templateId, Map paramMap) throws Exception { + + if (templateId == "SMS_227005968") { + String battery = paramMap.get("battery"); + String templateContent = "尊敬的用户，你的车辆已充电达至设定的SOC:" + battery + "%并停止充电，请您尽快将车辆挪走以方便他人使用充电桩，谢谢合作。"; + return templateContent; + } + if (templateId == "SMS_226935795") { + String money = paramMap.get("money"); + String templateContent = "尊敬的用户，你的账户余额小于" + money + "元,为不影响您的正常充电，请您尽快充值交费，谢谢。"; + return templateContent; + } + if (templateId == "SMS_226786374") { + String sumMoney = paramMap.get("sumMoney"); + String templateContent = "尊敬的用户，你的爱车已停止充电，请尽快挪车。总费用为：" + sumMoney + "元，充电费用明细，请查询小华充电小程序，谢谢。"; + return templateContent; + } + if (templateId == "SMS_227005968") { + String elec = paramMap.get("elec"); + String sumMoney = paramMap.get("sumMoney"); + String templateContent = "尊敬的用户，你的爱车已停止充电，请尽快挪车。电量为：" + elec + "，总费用为：" + sumMoney + "元，充电费用明细，请查询小华充电小程序，谢谢。"; + return templateContent; + } + if (templateId == "SMS_226786362") { + String code = paramMap.get("code"); + String templateContent = "您的验证码是：" + code + "，有效期为5分钟。如非本人操作，可不用理会。"; + return templateContent; + } + + throw new Exception("没有对应的模板id"); + + } + }