Java项目-苍穹外卖-Day10-SpirngTask及WebSocket

这篇具有很好参考价值的文章主要介绍了Java项目-苍穹外卖-Day10-SpirngTask及WebSocket。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

前言

本章实现的业务功能

超时未支付订单自动取消,配送中订单商家忘点完成自动再固定时间检查且修改成完成状态
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
来单提醒功能
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
催单提醒功能
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

SpringTask

介绍

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

SpringTask_corn表达式

一般的话周几和第几日是不能同时出现的
因为比如 4月15日 周四 可能4月15日不是周四 可能冲突的 所以周和日一般只能有一个
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
现在有这种生成表达式的网站
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
!其实还挺复杂的,建议看个视频稍微学一下怎么用这个网站

Spring_Task入门案例

使用springtask主要关注 1.cron表达式 2.内部处理逻辑
spring_Task挺小的一个框架,是没有自己的jar包的,集成在了spring_context这个包里面
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
自定义的定时任务类
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

订单状态定时处理

需求分析

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
合理一点,你派送中订单不能12点弄的,一般这个时候有很多是真的在派送中的

代码开发

com.sky.Task.OrderTask

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

    /**
     * 处理超时订单的方法,每分钟触发一次
     */
    @Scheduled(cron = "0 * * * * ?")//每分钟触发一次
    public void processTimeoutOrder(){
        log.info("定时处理超时订单:{}", LocalDateTime.now());
        //select * from orders where status = ? and order_time < (当前时间-15分钟)
        List<Orders> ordersList = orderMapper.
                getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, LocalDateTime.now().plusMinutes(-15));

        if(ordersList != null && ordersList.size() > 0){
            for (Orders orders : ordersList) {
                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());

        List<Orders> ordersList = orderMapper.
                getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, LocalDateTime.now().plusMinutes(-60));
        if(ordersList != null && ordersList.size() > 0){
            for (Orders orders : ordersList) {
                orders.setStatus(Orders.COMPLETED);
                orderMapper.update(orders);
            }
        }
    }
}

ordermapper

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

功能测试


这个运行然后看数据库
弄几个status为1(待支付)的订单然后等到它自动处理看看能不能取消
然后那个配送的可以改一下那个cron表达式不用真的等到1点

WebScoket

介绍

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

入门案例

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
com.sky.webscoket.WebSocketServer
前三个方法 1. 建立连接 2.进行通话 3.结束连接
最后一个是 服务端向客户端发送信息的方法需要自己调用 所以没有注解标识

package com.sky.webscoket;

/**
 * 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();
            }
        }
    }

}

给这个bean注册一下
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

弄个Task来模拟服务端发消息
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

然后自己运行一下看效果
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

来单提醒

需求分析

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

代码开发

修改OrderServiceImpl的代码
在PaySuccess下新增推送消息即可
新增的

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

完整的


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

        // 根据订单号查询订单
        Orders ordersDB = orderMapper.getByNumber(outTradeNo);

        // 根据订单id更新订单的状态、支付方式、支付状态、结账时间
        Orders orders = Orders.builder()
                .id(ordersDB.getId())
                .status(Orders.TO_BE_CONFIRMED)
                .payStatus(Orders.PAID)
                .checkoutTime(LocalDateTime.now())
                .build();

        orderMapper.update(orders);

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

    }

功能测试

这个略显难受
因为我们实际上没有实现微信支付接口
所以我们要更改一下逻辑的
小程序前端

if (res.code === 1) {
            wx.showModel({
              title: '提示',
              content: '支付成功',
              success:function(){
                uni.redirectTo({url: '/pages/success/index?orderId=' + _this.orderId });
              }
            })
          //  wx.requestPayment({
          //    nonceStr: res.data.nonceStr,
          //    package: res.data.packageStr,
          //    paySign: res.data.paySign,
          //    timeStamp: res.data.timeStamp,
          //    signType: res.data.signType,
          //    success:function(res){
          //      wx.showModal({
          //        title: '提示',
          //        content: '支付成功',
          //        success:function(){
          //          uni.redirectTo({url: '/pages/success/index?orderId=' + _this.orderId });
          //        }
          //      })
          //      console.log('支付成功!')
          //    }
          //  })

//  直接重新定向不用微信支付
//这里的代码移到前面

Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
OrderController
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python

OrderServiceImpl
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python
效果就会是你点击确定支付就会直接支付成功
且不会跳出那个支付成功的页面

客户催单

代码开发

controller

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

serviceimpl

    /**
     * 用户催单
     * @param id
     */
    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);

    }

功能测试

催单去个人中心的订单找
然后我这个没报语音(后来我换了edge浏览器就可以了)
Java项目-苍穹外卖-Day10-SpirngTask及WebSocket,项目记录,java,websocket,python文章来源地址https://www.toymoban.com/news/detail-702430.html

到了这里,关于Java项目-苍穹外卖-Day10-SpirngTask及WebSocket的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

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

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

相关文章

  • Java项目-苍穹外卖-Day11-Apache ECharts数据统计

    主要是以下四项的统计,以不同形式的图形进行展示 自己去网站上看一哈,我不太懂前端 com.sky.controller.admin.ReportController com.sky.service.impl.ReportServiceImpl.java orderMapper orderMapper.xml Reportcontroller ReportServiceImpl orderMapper.xml reportController ReportServiceImpl orderMapper.xml

    2024年02月09日
    浏览(45)
  • 项目实战————苍穹外卖(DAY11)

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

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

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

    2024年02月14日
    浏览(73)
  • 苍穹外卖项目解读(四) 微信小程序支付、定时任务、WebSocket

    HM新出springboot入门项目《苍穹外卖》,笔者打算写一个系列学习笔记,“苍穹外卖项目解读”,内容主要从HM课程,自己实践,以及踩坑填坑出发,以技术,经验为主,记录学习,也希望能给在学想学的小伙伴一个参考。 注:本文章是直接拿到项目的最终代码,然后从代码出发

    2024年02月07日
    浏览(36)
  • 苍穹外卖 Spring Task 来单提醒 催单Apache ECharts day10~11

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

    2024年02月14日
    浏览(43)
  • itheima苍穹外卖项目学习笔记--Day9: 订单模块

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

    2024年02月16日
    浏览(73)
  • itheima苍穹外卖项目学习笔记--Day1:项目介绍与开发环境搭建

    (1). 前端环境搭建 前端工程基于 nginx 运行 启动nginx:双击 nginx.exe 即可启动 nginx 服务,访问端口号为 80 (2). 后端环境搭建 后端工程基于 maven 进行项目构建,并且进行分模块开发 (3). 前后端联调 修改数据库中明文密码,改为MD5加密后的密文 修改Java代码,前端提交的密码进行

    2024年02月15日
    浏览(37)
  • itheima苍穹外卖项目学习笔记--Day7:缓存商品 / 购物车

    通过Redis来缓存菜品数据,减少数据库查询操作。 缓存逻辑分析: 每个分类下的菜品保存一份缓存数据 数据库中菜品数据有变更时清理缓存数据 修改用户端接口 DishController 的 list 方法,加入缓存处理逻辑 修改管理端接口 DishController 的相关方法,加入清理缓存的逻辑,需要

    2024年02月16日
    浏览(48)
  • 【java苍穹外卖项目实战三】nginx反向代理和负载均衡

    我们思考一个问题: 前端发送的请求,是如何请求到后端服务的? 前端请求地址:http://localhost/api/employee/login 后端接口地址:http://localhost:8080/admin/employee/login 很明显,两个地址不一致,那是如何请求到后端服务的呢? 1、nginx反向代理 nginx 反向代理 ,就是将前端发送的动态

    2024年02月21日
    浏览(49)
  • 《苍穹外卖》电商实战项目(java)知识点整理(P1~P65)【上】

    史上最完整的《苍穹外卖》项目实操笔记,跟视频的每一P对应,全系列10万字,涵盖详细步骤与问题的解决方案。如果你操作到某一步卡壳,参考这篇,相信会带给你极大启发。 《苍穹外卖》项目实操笔记【中】:P66~P122《苍穹外卖》项目实操笔记【中】 1. nginx反向代理好处

    2024年01月24日
    浏览(45)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包