苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket)

这篇具有很好参考价值的文章主要介绍了苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

 预期效果

 苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 对于超时没处理的需要定时程序处理。基于SpringTask实现。

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

来单提醒和客户催单。基于WebSocket实现。

 苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 Spring Task

介绍

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

Cron表达式

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

周几通常不能和日一起指定。 

 cron表达式在线生成器

在线Cron表达式生成器

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

入门案例

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 创建定时任务类

/**
 * 定义定时任务类
 */
@Slf4j
@Component
public class MyTask {


    /**
     * 定时任务,每隔5秒触发一次
     */
    @Scheduled(cron = "0/5 * * * * ?")
    public void executeTask(){
        log.info("定时任务开始执行:{}",new Date());
    }
}

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

订单状态定时处理——需求分析与设计

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 

订单状态定时处理——代码开发

新建一个task包中一个类如下

/**
 * 定时任务类,定时处理订单状态
 */
@Component
@Slf4j
public class OrderTask {
    @Autowired
    private OrderMapper orderMapper;

    /**
     * 处理超时订单
     */
    @Scheduled(cron = "0 * * * * ? ")//每分钟触发一次
    public void processTimeoutOrder(){
        log.info("定时处理超时订单:{}",LocalDateTime.now());

        LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
        // select * from orders where status = ? and order_time < (当前时间-15分钟)
        List<Orders> list = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, time);

        if(list!=null&&list.size()>0){
            for (Orders orders : list) {
                orders.setStatus(Orders.CANCELLED);
                orders.setCancelReason("订单超时,自动取消");
                orders.setCancelTime(LocalDateTime.now()); //取消时间
                orderMapper.update(orders);
            }
        }
    }

    /**
     * 处理一直派送中的订单
     */
    @Scheduled(cron = "0 0 1 * * ?")//每天凌晨一点
    public void processDeliveryOrder(){
        log.info("定时处理派送中的订单:{}",LocalDateTime.now());
        LocalDateTime time = LocalDateTime.now().plusMinutes(-60);
        List<Orders> list = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, time);

        if(list!=null&&list.size()>0){
            for (Orders orders : list) {
                orders.setStatus(Orders.COMPLETED);
                orderMapper.update(orders);
            }
        }
    }
}

在OrderMapper中

    /**
     * 根据订单状态和下单时间查询订单
     * @param status
     * @param orderTime
     * @return
     */
    @Select("select * from orders where status = #{status} and order_time < #{orderTime}")
    List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);

订单状态定时处理——功能测试

运行测试无误。

WebSocket——介绍

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 

WebSocket——入门案例

导入提供的代码资料。

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 文章来源地址https://www.toymoban.com/news/detail-621905.html

<!DOCTYPE HTML>
<html>
<head>
    <meta charset="UTF-8">
    <title>WebSocket Demo</title>
</head>
<body>
    <input id="text" type="text" />
    <button onclick="send()">发送消息</button>
    <button onclick="closeWebSocket()">关闭连接</button>
    <div id="message">
    </div>
</body>
<script type="text/javascript">
    var websocket = null;
    var clientId = Math.random().toString(36).substr(2);

    //判断当前浏览器是否支持WebSocket
    if('WebSocket' in window){
        //连接WebSocket节点
        websocket = new WebSocket("ws://localhost:8080/ws/"+clientId);
    }
    else{
        alert('Not support websocket')
    }

    //连接发生错误的回调方法
    websocket.onerror = function(){
        setMessageInnerHTML("error");
    };

    //连接成功建立的回调方法
    websocket.onopen = function(){
        setMessageInnerHTML("连接成功");
    }

    //接收到消息的回调方法
    websocket.onmessage = function(event){
        setMessageInnerHTML(event.data);
    }

    //连接关闭的回调方法
    websocket.onclose = function(){
        setMessageInnerHTML("close");
    }

    //监听窗口关闭事件,当窗口关闭时,主动去关闭websocket连接,防止连接还没断开就关闭窗口,server端会抛异常。
    window.onbeforeunload = function(){
        websocket.close();
    }

    //将消息显示在网页上
    function setMessageInnerHTML(innerHTML){
        document.getElementById('message').innerHTML += innerHTML + '<br/>';
    }

    //发送消息
    function send(){
        var message = document.getElementById('text').value;
        websocket.send(message);
    }
	
	//关闭连接
    function closeWebSocket() {
        websocket.close();
    }
</script>
</html>

 导入坐标

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
        </dependency>

准备一个新的包创建如下的类

与Controller相似,通过路径进行匹配。

/**
 * WebSocket服务
 */
@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {

    //存放会话对象
    private static Map<String, Session> sessionMap = new HashMap();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session, @PathParam("sid") String sid) {
        System.out.println("客户端:" + sid + "建立连接");
        sessionMap.put(sid, session);
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, @PathParam("sid") String sid) {
        System.out.println("收到来自客户端:" + sid + "的信息:" + message);
    }

    /**
     * 连接关闭调用的方法
     *
     * @param sid
     */
    @OnClose
    public void onClose(@PathParam("sid") String sid) {
        System.out.println("连接断开:" + sid);
        sessionMap.remove(sid);
    }

    /**
     * 群发
     *
     * @param message
     */
    public void sendToAllClient(String message) {
        Collection<Session> sessions = sessionMap.values();
        for (Session session : sessions) {
            try {
                //服务器向客户端发送消息
                session.getBasicRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

准备一个配置类

/**
 * WebSocket配置类,用于注册WebSocket的Bean
 */
@Configuration
public class WebSocketConfiguration {

    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }

}

准备一个定时任务类

@Component
public class WebSocketTask {
    @Autowired
    private WebSocketServer webSocketServer;

    /**
     * 通过WebSocket每隔5秒向客户端发送消息
     */
    @Scheduled(cron = "0/5 * * * * ?")
    public void sendMessageToClient() {
        webSocketServer.sendToAllClient("这是来自服务端的消息:" + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));
    }
}

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 

 来单提醒——需求分析与设计

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

设计

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端 

 来单提醒——代码开发

这里不该资料的源码的话连接不上,加上:8080之后直接请求到后端了,没有走nginx去。

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 使用上面的代码

在OrderServiceImpl中

    @Autowired
    private WebSocketServer webSocketServer;
    /**
     * 支付成功,修改订单状态
     *
     * @param outTradeNo
     */
    public void paySuccess(String outTradeNo) {

        XX
        XX
        XX
        XX
        XX

        //通过webSocket向客户端浏览器推送消息 type orderId content
        Map map=new HashMap();
        map.put("type",1);//1表示来单提醒
        map.put("orderId",ordersDB.getId());
        map.put("content","订单号:"+outTradeNo);
        String json = JSON.toJSONString(map);
        webSocketServer.sendToAllClient(json);
    }

 来单提醒——功能测试

懒得模拟支付,就这样吧

客户催单——需求分析与设计

 设计

 接口设计

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

客户催单——代码开发

Controller中

    /**
     * 客户催单
     * @param id
     * @return
     */
    @GetMapping("/reminder/{id}")
    @ApiOperation("客户催单")
    public Result reminder(@PathVariable("id") Long id){
        orderService.reminder(id);
        return Result.success();
    }

Service中

    /**
     * 客户催单
     * @param id
     */
    @Override
    public void reminder(Long id) {
        // 根据id查询订单
        Orders ordersDB = orderMapper.getById(id);

        // 校验订单是否存在
        if (ordersDB == null ) {
            throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
        }

        Map map=new HashMap();
        map.put("type",2);//1.表示来单提醒,2表示客户催单
        map.put("orderId",id);
        map.put("content","订单号:"+ordersDB.getNumber());
        String json = JSON.toJSONString(map);
        webSocketServer.sendToAllClient(json);
    }

客户催单——功能测试

成功催单

苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket),SpringBoot,spring,websocket,java,网络协议,后端

 

 

到了这里,关于苍穹外卖day10——订单状态定时处理(Spring Task)、来单提醒和客户催单(WebSocket)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • itheima苍穹外卖项目学习笔记--Day9: 订单模块

    (1). 查询历史订单 在OrderController中,创建查询方法 在OrderServiceImpl中,创建分页查询方法,及其父类接口 在OrderMapper中,添加查询方法,并在映射文件中写入动态SQL语句 在OrderDetailMapper中,实现根据订单id查询订单明细 (2). 查询订单详细 在OrderController中,创建查询订单详细方

    2024年02月16日
    浏览(73)
  • 基于SpringBoot+WebSocket+Spring Task的前后端分离外卖项目-订单管理(十七)

    1.1 介绍 Spring Task 是Spring框架提供的任务调度工具,可以按照约定的时间自动执行某个代码逻辑。 定位 :定时任务框架 作用 :定时自动执行某段Java代码 应用场景: 1). 信用卡每月还款提醒 2). 银行贷款每月还款提醒 3). 火车票售票系统处理未支付订单 4). 入职纪念日为用户发

    2024年02月21日
    浏览(57)
  • Java项目-苍穹外卖-Day10-SpirngTask及WebSocket

    本章实现的业务功能 超时未支付订单自动取消,配送中订单商家忘点完成自动再固定时间检查且修改成完成状态 来单提醒功能 催单提醒功能 一般的话周几和第几日是不能同时出现的 因为比如 4月15日 周四 可能4月15日不是周四 可能冲突的 所以周和日一般只能有一个 现在有

    2024年02月09日
    浏览(43)
  • Spring Task 实现定时任务 以及 WebSocket 实现 订单提醒 (学习笔记)

    1.maven坐标 spring-context 2.启动类添加注解 @EnableScheduling 开启任务调度 3.自定义定时任务类 去设置网站设置要 进行得定时任务 cron表达式在线生成器:https://cron.qqe2.com/ 1.导入maven坐标 2.导入websocket组件 3.设置配置类 4.导入代码 前端测试代码

    2024年02月20日
    浏览(42)
  • 【学习日记2023.5.30】之 订单处理 订单状态定时处理_来单提醒_用户催单

    Spring Task 订单状态定时处理 WebSocket 来单提醒 客户催单 功能实现: 订单状态定时处理 、 来单提醒 和 客户催单 订单状态定时处理: 来单提醒: 客户催单: 10.1.1 介绍 Spring Task 是Spring框架提供的任务调度工具,可以按照约定的时间自动执行某个代码逻辑。 **定位:**定时任

    2024年02月07日
    浏览(37)
  • 苍穹外卖day11笔记

    今日首先介绍前端技术Apache ECharts,说明后端需要准备的数据,然后讲解具体统计功能的实现,包括营业额统计、用户统计、订单统计、销量排名。 ECharts是一款基于 Javascript 的数据可视化图表库。我们用它来展示图表数据。 步骤 1). 引入echarts.js 文件 2). 为 ECharts 准备一个设

    2024年02月13日
    浏览(45)
  • 基于Spring Task框架的定时任务处理

    1.1 介绍 Spring Task 是Spring框架提供的任务调度工具,可以按照约定的时间自动执行某个代码逻辑。 定位: 定时任务框架 作用: 定时自动执行某段Java代码 应用场景: 1). 信用卡每月还款提醒 2). 银行贷款每月还款提醒 3). 火车票售票系统处理未支付订单 强调: 只要是需要定时

    2024年01月23日
    浏览(42)
  • 黑马苍穹外卖学习Day12

    结果 Controller层 Service实现类

    2024年01月25日
    浏览(56)
  • 项目实战————苍穹外卖(DAY11)

    Apache ECharts 营业额统计 用户统计 订单统计 销量排名Top10 功能实现: 数据统计 数据统计效果图: 1.1 介绍 Apache ECharts 是一款基于 Javascript 的数据可视化图表库,提供直观,生动,可交互,可个性化定制的数据可视化图表。 官网地址:Apache ECharts 常见效果展示: 1). 柱形图

    2024年01月20日
    浏览(49)
  • 苍穹外卖day02项目日志

    参考产品原型,设计表和接口。 1.1.1设计表 看员工管理的产品原型: 有员工姓名、账号、手机号、账号状态、最后操作时间等。 注意,操作一栏不是字段,其中的启用禁用才是。 再看添加员工的原型:  可以发现还有性别和身份证号。 不要忘了旁边: 还有密码。 总结出了

    2024年02月14日
    浏览(73)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包