苍穹外卖day10 | 您所在的位置:网站首页 › 啦啦外卖语音提醒 › 苍穹外卖day10 |
预期效果
对于超时没处理的需要定时程序处理。基于SpringTask实现。 来单提醒和客户催单。基于WebSocket实现。 周几通常不能和日一起指定。 cron表达式在线生成器 在线Cron表达式生成器 创建定时任务类 /** * 定义定时任务类 */ @Slf4j @Component public class MyTask { /** * 定时任务,每隔5秒触发一次 */ @Scheduled(cron = "0/5 * * * * ?") public void executeTask(){ log.info("定时任务开始执行:{}",new Date()); } }新建一个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 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 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 getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime); 订单状态定时处理——功能测试运行测试无误。 WebSocket——介绍
导入提供的代码资料。 导入坐标 org.springframework.boot spring-boot-starter-websocket 准备一个新的包创建如下的类与Controller相似,通过路径进行匹配。 /** * WebSocket服务 */ @Component @ServerEndpoint("/ws/{sid}") public class WebSocketServer { //存放会话对象 private static Map 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 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())); } }这里不该资料的源码的话连接不上,加上:8080之后直接请求到后端了,没有走nginx去。 使用上面的代码 在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); } 来单提醒——功能测试懒得模拟支付,就这样吧 客户催单——需求分析与设计![]() ![]() 成功催单 nginx下的\nginx-1.20.2\html\sky\js\app.d0aa4eb3.js文件 |
CopyRight 2018-2019 实验室设备网 版权所有 |