网站中接入手机验证码和定时任务（含源码）

没腿的鸟  金牌会员 | 2023-6-25 09:16:15 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 892|帖子 892|积分 2676

页面预览

绑定手机号


未绑定手机号


已绑定手机号


第01章-短信发送

1、云市场-短信API

1.1、开通三网106短信

在阿里云云市场搜索“短信”，一般都可用，选择一个即可，例如如下：点击“立即购买”开通
这里开通的是【短信验证码- 快速报备签名】

1.2、获取开发参数

登录云市场控制台，在已购买的服务中可以查看到所有购买成功的API商品情况，下图红框中的就是AppKey/AppSecret，AppCode的信息。

1.3、API方式使用云市场服务

将工具类放入service-yun微服务的utils包中：资料：资料>短信发送>工具类
参考如下例子，复制代码在test目录进行测试

2、发送短息

2.1、Controller

创建FrontSmsController
  1. package com.atguigu.syt.yun.controller.front;
  3. @Api(tags = "短信接口")
  4. @RestController
  5. @RequestMapping("/front/yun/sms")
  6. public class FrontSmsController {
  8.     @Resource
  9.     private SmsService smsService;
  11.     @Resource
  12.     private RedisTemplate redisTemplate;
  14.     @ApiOperation("发送短信")
  15.     @ApiImplicitParam(name = "phone",value = "手机号")
  16.     @PostMapping("/send/{phone}")
  17.     public Result send(@PathVariable String phone) {
  19.         //生成验证码
  20.         int minutes = 5; //验证码5分钟有效
  21.         String code = RandomUtil.getFourBitRandom();
  23.         //创建短信发送对象
  24.         SmsVo smsVo = new SmsVo();
  25.         smsVo.setPhone(phone);
  26.         smsVo.setTemplateCode("CST_qozfh101");
  27.         Map<String,Object> paramsMap = new HashMap<String, Object>(){{
  28.             put("code", code);
  29.             put("expire_at", 5);
  30.         }};
  31.         smsVo.setParam(paramsMap);
  33.         //发送短信
  34.         smsService.send(smsVo);
  36.         //验证码存入redis
  37.         redisTemplate.opsForValue().set("code:" + phone, code, minutes, TimeUnit.MINUTES);
  39.         return Result.ok().message("短信发送成功");
  40.     }
  41. }
复制代码
2.2、Service

接口：SmsService
  1. package com.atguigu.syt.yun.service;
  3. public interface SmsService {
  4.     /**
  5.      * 发送短信
  6.      * @param smsVo
  7.      */
  8.     void send(SmsVo smsVo);
  9. }
复制代码
实现：SmsServiceImpl
  1. package com.atguigu.syt.yun.service.impl;
  3. @Service
  4. @Slf4j
  5. public class SmsServiceImpl implements SmsService {
  7.     @Override
  8.     public void send(SmsVo smsVo) {
  10.         String host = "https://dfsns.market.alicloudapi.com";
  11.         String path = "/data/send_sms";
  12.         String method = "POST";
  13.         String appcode = "你的appcode";
  14.         Map<String, String> headers = new HashMap<>();
  15.         //最后在header中的格式(中间是英文空格)为Authorization:APPCODE 83359fd73fe94948385f570e3c139105
  16.         headers.put("Authorization", "APPCODE " + appcode);
  17.         //根据API的要求，定义相对应的Content-Type
  18.         headers.put("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");
  19.         Map<String, String> querys = new HashMap<>();
  20.         Map<String, String> bodys = new HashMap<>();
  22.         StringBuffer contentBuffer = new StringBuffer();
  23.         smsVo.getParam().entrySet().forEach( item -> {
  24.             contentBuffer.append(item.getKey()).append(":").append(item.getValue()).append(",");
  25.         });
  26.         String content = contentBuffer.substring(0, contentBuffer.length() - 1);
  28.         bodys.put("content", content);
  29.         bodys.put("phone_number", smsVo.getPhone());
  30.         bodys.put("template_id", smsVo.getTemplateCode());
  32.         try {
  33.             /**
  34.              * 重要提示如下:
  35.              * HttpUtils请从
  36.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/src/main/java/com/aliyun/api/gateway/demo/util/HttpUtils.java
  37.              * 下载
  38.              *
  39.              * 相应的依赖请参照
  40.              * https://github.com/aliyun/api-gateway-demo-sign-java/blob/master/pom.xml
  41.              */
  42.             HttpResponse response = HttpUtils.doPost(host, path, method, headers, querys, bodys);
  44.             //获取response的body
  45.             String data = EntityUtils.toString(response.getEntity());
  47.             HashMap<String, String> resultMap = JSONObject.parseObject(data, HashMap.class);
  48.             String status = resultMap.get("status");
  50.             if(!"OK".equals(status)){
  51.                 String reason = resultMap.get("reason");
  52.                 log.error("短信发送失败：status = " + status + ", reason = " + reason);
  53.                 throw new GuiguException(ResultCodeEnum.FAIL.getCode(), "短信发送失败");
  54.             }
  56.         } catch (Exception e) {
  57.             log.error(ExceptionUtils.getStackTrace(e));
  58.             throw new GuiguException(ResultCodeEnum.FAIL.getCode(), "短信发送失败");
  59.         }
  60.     }
  61. }
复制代码
3、绑定手机号

3.1、Controller

service-user微服务FrontUserInfoController中添加接口方法
  1. @ApiOperation("绑定手机号")
  2. @ApiImplicitParams({
  3.     @ApiImplicitParam(name = "phone",value = "手机号", required = true),
  4.     @ApiImplicitParam(name = "code",value = "验证码", required = true)})
  5. @PostMapping("/auth/bindPhone/{phone}/{code}")
  6. public Result bindPhone(@PathVariable String phone, @PathVariable String code, HttpServletRequest request, HttpServletResponse response) {
  8.     Long userId = authContextHolder.checkAuth(request, resposne);
  9.     userInfoService.bindPhone(userId, phone, code);
  10.     return Result.ok().message("绑定成功");
  11. }
复制代码
3.2、Service

接口：UserInfoService
  1. /**
  2.      * 绑定当前用户的手机号
  3.      * @param userId
  4.      * @param phone
  5.      * @param code
  6.      */
  7. void bindPhone(Long userId, String phone, String code);
复制代码
实现：UserInfoServiceImpl
  1. @Resource
  2. private RedisTemplate redisTemplate;
  4. @Override
  5. public void bindPhone(Long userId, String phone, String code) {
  7.     //校验参数
  8.     if(StringUtils.isEmpty(phone) || StringUtils.isEmpty(code)) {
  9.         throw new GuiguException(ResultCodeEnum.PARAM_ERROR);
  10.     }
  12.     //校验验证码
  13.     String phoneCode = (String)redisTemplate.opsForValue().get("code:" + phone);
  14.     if(!code.equals(phoneCode)) {
  15.         throw new GuiguException(ResultCodeEnum.CODE_ERROR);
  16.     }
  18.     //根据手机号查找会员
  19.     LambdaQueryWrapper<UserInfo> queryWrapper = new LambdaQueryWrapper<>();
  20.     //手机号没有被其他人绑定过
  21.     queryWrapper.eq(UserInfo::getPhone, phone).ne(UserInfo::getId, userId);
  22.     UserInfo userInfo = baseMapper.selectOne(queryWrapper);
  24.     //手机号已存在
  25.     if(userInfo != null) {
  26.         throw new GuiguException(ResultCodeEnum.REGISTER_MOBILE_ERROR);
  27.     }
  28.     //设置绑定手机号
  29.     userInfo = new UserInfo();
  30.     userInfo.setId(userId);
  31.     userInfo.setPhone(phone);
  32.     baseMapper.updateById(userInfo);
  33. }
复制代码
4、前端整合

4.1、api

创建sms.js
  1. import request from '~/utils/request'
  3. export default {
  5.   sendCode(phone) {
  6.     return request({
  7.       url: `/front/yun/sms/send/${phone}`,
  8.       method: `post`
  9.     })
  10.   }
  11. }
复制代码
在userInfo.js中添加方法
  1. bindPhone(phone, code) {
  2.     return request({
  3.         url: `/front/user/userInfo/auth/bindPhone/${phone}/${code}`,
  4.         method: `post`
  5.     })
  6. },
复制代码
4.2、页面组件

复制页面到项目pages目录中
资料：资料>手机号绑定页面
第02章-引入MQ

预约或取消预约成功后我们要 更新预约数 以及 发送短信提醒，为了实现用户下单和取消订单的快速响应，这部分逻辑我们就交给MQ完成。
1、引入RabbitMQ

1.1、安装RabbitMQ
  1. #拉取镜像
  2. docker pull rabbitmq:3.8-management
  3. #创建容器启动
  4. docker run -d --restart=always -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:3.8-management
复制代码
1.2、访问管理后台

http://192.168.100.101:15672
登录：guest / guest
1.3、创建rabbit-utils模块

在common模块中创建rabbit-utils模块
1.4、引入依赖

在rabbit-utils中引入依赖
  1. <dependencies>
  2.    
  3.     <dependency>
  4.         <groupId>org.springframework.boot</groupId>
  5.         <artifactId>spring-boot-starter-amqp</artifactId>
  6.     </dependency>
  7.     <dependency>
  8.         <groupId>org.projectlombok</groupId>
  9.         <artifactId>lombok</artifactId>
  10.     </dependency>
  11. </dependencies>
复制代码
1.5、创建RabbitService类

添加sendMessage方法
  1. package com.atguigu.syt.rabbit;
  3. @Service
  4. @Slf4j
  5. public class RabbitService {
  7.     @Resource
  8.     private RabbitTemplate rabbitTemplate;
  9.    
  10.     /**
  11.      *  发送消息
  12.      * @param exchange 交换机
  13.      * @param routingKey 路由
  14.      * @param message 消息
  15.      */
  16.     public boolean sendMessage(String exchange, String routingKey, Object message) {
  17.         log.info("发送消息...........");
  18.         rabbitTemplate.convertAndSend(exchange, routingKey, message);
  19.         return true;
  20.     }
  21. }
复制代码
1.6、配置MQ消息转换器
  1. package com.atguigu.syt.rabbit.config;
  3. @Configuration
  4. public class MQConfig {
  6.     @Bean
  7.     public MessageConverter messageConverter(){
  8.         //配置json字符串转换器，默认使用SimpleMessageConverter
  9.         return new Jackson2JsonMessageConverter();
  10.     }
  11. }
复制代码
1.7、添加常量类
  1. package com.atguigu.syt.rabbit.config;
  2. public class MQConst {
  4.     /**
  5.      * 预约/取消订单
  6.      */
  7.     public static final String EXCHANGE_DIRECT_ORDER = "exchange.direct.order";
  8.     public static final String ROUTING_ORDER = "routing.order";
  9.     public static final String QUEUE_ORDER  = "queue.order";
  11.     /**
  12.      * 短信
  13.      */
  14.     public static final String EXCHANGE_DIRECT_SMS = "exchange.direct.sms";
  15.     public static final String ROUTING_SMS = "routing.sms";
  16.     public static final String QUEUE_SMS  = "queue.sms";
  17. }
复制代码
2、service-yun中发送短信

2.1、引入依赖
  1. <dependency>
  2.     <groupId>com.atguigu</groupId>
  3.     <artifactId>rabbit-utils</artifactId>
  4.     <version>1.0</version>
  5. </dependency>
复制代码
2.2、添加MQ配置
  1. spring:
  2.   rabbitmq:
  3.     host: 192.168.100.101
  4.     port: 5672
  5.     username: guest
  6.     password: guest
复制代码
2.3、封装MQ监听器

在监听器中发送短信：
  1. package com.atguigu.syt.yun.receiver;
  3. @Component
  4. @Slf4j
  5. public class SmsReceiver {
  7.     @Resource
  8.     private SmsService smsService;
  10.     /**
  11.      * 监听MQ中的消息
  12.      * @param smsVo
  13.      */
  14.     @RabbitListener(bindings = @QueueBinding(
  15.             value = @Queue(value = MQConst.QUEUE_SMS, durable = "true"), //消息队列，并持久化
  16.             exchange = @Exchange(value = MQConst.EXCHANGE_DIRECT_SMS), //交换机
  17.             key = {MQConst.ROUTING_SMS} //路由
  18.     ))
  19.     public void receive(SmsVo smsVo){
  20.         log.info("SmsReceiver 监听器监听到消息......");
  21.         smsService.send(smsVo);
  22.     }
  23. }
复制代码
3、service-hosp中更新排班数量

3.1、引入依赖
  1. <dependency>
  2.     <groupId>com.atguigu</groupId>
  3.     <artifactId>rabbit-utils</artifactId>
  4.     <version>1.0</version>
  5. </dependency>
复制代码
3.2、添加MQ配置
  1. spring:
  2.   rabbitmq:
  3.     host: 192.168.100.101
  4.     port: 5672
  5.     username: guest
  6.     password: guest
复制代码
3.3、封装MQ监听器

在监听器中更新排班数量：
  1. package com.atguigu.syt.hosp.receiver;
  3. @Component
  4. @Slf4j
  5. public class HospReceiver {
  7.     @Resource
  8.     private ScheduleService scheduleService;
  10.     /**
  11.      * 监听MQ中的消息
  12.      * @param orderMqVo
  13.      */
  14.     @RabbitListener(bindings = @QueueBinding(
  15.             value = @Queue(value = MQConst.QUEUE_ORDER, durable = "true"), //消息队列，并持久化
  16.             exchange = @Exchange(value = MQConst.EXCHANGE_DIRECT_ORDER), //交换机
  17.             key = {MQConst.ROUTING_ORDER} //路由
  18.     ))
  19.     public void receive(OrderMqVo orderMqVo){
  20.         //修改排班信息
  21.         log.info("HospReceiver 监听器监听到消息......");
  22.         scheduleService.updateByOrderMqVo(orderMqVo);
  23.     }
  24. }
复制代码
接口：ScheduleService
  1. /**
  2.      * 更新排班数量
  3.      * @param orderMqVo
  4.      */
  5. void updateByOrderMqVo(OrderMqVo orderMqVo);
复制代码
实现：ScheduleServiceImpl
  1. @Override
  2. public void updateByOrderMqVo(OrderMqVo orderMqVo) {
  3.     //下单成功更新预约数
  4.     ObjectId objectId = new ObjectId(orderMqVo.getScheduleId());
  5.     //id是objectId
  6.     Schedule schedule = scheduleRepository.findById(objectId).get();
  7.     //id是string
  8.     //      Schedule schedule = scheduleRepository.findById(orderMqVo.getScheduleId()).get();
  9.     schedule.setReservedNumber(orderMqVo.getReservedNumber());
  10.     schedule.setAvailableNumber(orderMqVo.getAvailableNumber());
  12.     //主键一致就是更新
  13.     scheduleRepository.save(schedule);
  14. }
复制代码
4、完善service-orde订单接口

4.1、引入依赖
  1. <dependency>
  2.     <groupId>com.atguigu</groupId>
  3.     <artifactId>rabbit-utils</artifactId>
  4.     <version>1.0</version>
  5. </dependency>
复制代码
4.2、添加MQ配置
  1. spring:
  2.   rabbitmq:
  3.     host: 192.168.100.101
  4.     port: 5672
  5.     username: guest
  6.     password: guest
复制代码
4.3、修改下单方法

OrderInfoServiceImpl类：
  1. @Resource
  2. private RabbitService rabbitService;
复制代码
submitOrder方法中添加发送消息的业务逻辑：
  1. //使用这两个数据更新平台端的最新的排班数量
  2. Integer reservedNumber = data.getInteger("reservedNumber");
  3. Integer availableNumber = data.getInteger("availableNumber");
  5. //目的1：更新mongodb数据库中的排班数量
  6. //组装数据同步消息对象
  7. OrderMqVo orderMqVo = new OrderMqVo();
  8. orderMqVo.setAvailableNumber(availableNumber);
  9. orderMqVo.setReservedNumber(reservedNumber);
  10. orderMqVo.setScheduleId(scheduleId);
  11. //发消息
  12. rabbitService.sendMessage(MQConst.EXCHANGE_DIRECT_ORDER, MQConst.ROUTING_ORDER, orderMqVo);
  14. //目的2：给就诊人发短信
  15. //组装短信消息对象
  16. SmsVo smsVo = new SmsVo();
  17. smsVo.setPhone(orderInfo.getPatientPhone());
  18. //亲爱的用户：您已预约%{hosname}%{hosdepname}%{date}就诊
  19. //请您于%{time}至%{address}取号，
  20. //您的就诊号码是%{number}，请您及时就诊
  21. smsVo.setTemplateCode("和客服申请模板编号");
  22. Map<String,Object> paramsSms = new HashMap<String, Object>(){{
  23.     put("hosname", orderInfo.getHosname());
  24.     put("hosdepname", orderInfo.getDepname());
  25.     put("date", new DateTime(orderInfo.getReserveDate()).toString("yyyy-MM-dd"));
  26.     put("time", orderInfo.getFetchTime());
  27.     put("address", orderInfo.getFetchAddress());
  28.     put("number", orderInfo.getNumber());
  29. }};
  30. smsVo.setParam(paramsSms);
  31. //向MQ发消息
  32. rabbitService.sendMessage(MQConst.EXCHANGE_DIRECT_SMS, MQConst.ROUTING_SMS, smsVo);
复制代码
4.4、修改取消订单方法

cancelOrder方法中添加发送消息的业务逻辑：
  1. //获取返回数据
  2. JSONObject jsonObject = jsonResult.getJSONObject("data");
  3. Integer reservedNumber = jsonObject.getInteger("reservedNumber");
  4. Integer availableNumber = jsonObject.getInteger("availableNumber");
  6. //目的1：更新mongodb数据库中的排班数量
  7. //组装数据同步消息对象
  8. OrderMqVo orderMqVo = new OrderMqVo();
  9. orderMqVo.setAvailableNumber(availableNumber);
  10. orderMqVo.setReservedNumber(reservedNumber);
  11. orderMqVo.setScheduleId(orderInfo.getScheduleId());
  12. //发消息
  13. rabbitService.sendMessage(MQConst.EXCHANGE_DIRECT_ORDER, MQConst.ROUTING_ORDER, orderMqVo);
  15. //目的2：给就诊人发短信
  16. //组装短信消息对象
  17. SmsVo smsVo = new SmsVo();
  18. smsVo.setPhone(orderInfo.getPatientPhone());
  19. //亲爱的用户：您已取消%{hosname}%{hosdepname}%{date}就诊
  20. smsVo.setTemplateCode("和客服申请模板编号");
  21. Map<String,Object> paramsSms = new HashMap<String, Object>(){{
  22.     put("hosname", orderInfo.getHosname());
  23.     put("hosdepname", orderInfo.getDepname());
  24.     put("date", new DateTime(orderInfo.getReserveDate()).toString("yyyy-MM-dd"));
  25. }};
  26. smsVo.setParam(paramsSms);
  27. //向MQ发消息
  28. rabbitService.sendMessage(MQConst.EXCHANGE_DIRECT_SMS, MQConst.ROUTING_SMS, smsVo);
复制代码
5、就诊人提醒

5.1、添加定时任务

在service-order微服务中添加定时任务：创建ScheduledTask类
cron表达式参考：https://qqe2.com/cron
  1. package com.atguigu.syt.order.schedule;
  3. @Component
  4. @EnableScheduling  //开启定时任务
  5. @Slf4j
  6. public class ScheduledTask {
  7.     /**
  8.      * 测试
  9.      * (cron="秒 分 时 日 月 周")
  10.      * *：每隔一秒执行
  11.      * 0/3：从第0秒开始，每隔3秒执行一次
  12.      * 1-3: 从第1秒开始执行，到第3秒结束执行
  13.      * 1,2,3：第1、2、3秒执行
  14.      * ?：不指定，若指定日期，则不指定周，反之同理
  15.      */
  16.     @Scheduled(cron="0/3 * * * * ?")
  17.     public void task1() {
  18.         log.info("task1 执行");
  19.     }
  20. }
复制代码
5.2、添加就诊人提醒定时任务
  1. @Resource
  2. private OrderInfoService orderInfoService;
  4. @Scheduled(cron = "0 0 18 * * ?")
  5. public void patientAdviceTask(){
  7.     log.info("执行定时任务");
  8.     orderInfoService.patientAdvice();
  9. }
复制代码
5.3、Service

需求：就诊前一天晚六点向用户发送就医提醒短信
接口：OrderInfoService
  1. /**
  2.      * 就诊人提醒
  3.      */
  4. void patientAdvice();
复制代码
实现：OrderInfoServiceImpl
  1. @Override
  2. public void patientAdvice() {
  4.     //查询明天的预约信息
  5.     LambdaQueryWrapper<OrderInfo> queryWrapper = new LambdaQueryWrapper<>();
  7.     //明天
  8.     String tomorrow = new DateTime().plusDays(1).toString("yyyy-MM-dd");
  9.     queryWrapper.eq(OrderInfo::getReserveDate, tomorrow);
  10.     //未取消
  11.     queryWrapper.ne(OrderInfo::getOrderStatus, OrderStatusEnum.CANCLE.getStatus());
  12.     List<OrderInfo> orderInfoList = baseMapper.selectList(queryWrapper);
  14.     for (OrderInfo orderInfo : orderInfoList) {
  15.         //短信对象
  16.         SmsVo smsVo = new SmsVo();
  17.         smsVo.setPhone(orderInfo.getPatientPhone());
  18.         //就诊提醒：您已预约%{hosname}%{depname}的号源，就诊时间：%{date}，就诊人%{name}，请您合理安排出行时间
  19.         smsVo.setTemplateCode("和客服申请模板编号");
  20.         Map<String,Object> paramsSms = new HashMap<String, Object>(){{
  21.             put("hosname", orderInfo.getHosname());
  22.             put("hosdepname", orderInfo.getDepname());
  23.             put("date", new DateTime(orderInfo.getReserveDate()).toString("yyyy-MM-dd"));
  24.             put("name", orderInfo.getPatientName());
  25.         }};
  26.         smsVo.setParam(paramsSms);
  27.         //发消息
  28.         rabbitService.sendMessage(MQConst.EXCHANGE_DIRECT_SMS, MQConst.ROUTING_SMS, smsVo);
  29.     }
  30. }
复制代码
源码：https://gitee.com/dengyaojava/guigu-syt-parent

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

正序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

没腿的鸟

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表