苍穹外卖--开发记录day09-10

苍穹外卖day09-10

首先第九天是实战日，要完成以下内容的开发：

用户端历史订单模块：

查询历史订单
查询订单详情
取消订单
再来一单

商家端订单管理模块：

订单搜索
各个状态的订单数量统计
查询订单详情
接单
拒单
取消订单
派送订单
完成订单

这里面基本上是增删改查，而且资料里有答案；我就不过多赘述了

直接进入第十天：

一：springtask

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

可以去网站生成cron表达式Cron - 在线Cron表达式生成器

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

自定义任务类：在项目中再建一个软件包，然后定义一个类，类上要加上compont注解将类交给容器管理，然后定义一个方法。里面完成定时任务的逻辑，方法上要加上@Scheduled注解，里面指定cron表达式；

@Component
@Slf4j
public class Mytask {@Scheduled(cron = "0/5 * * * * ?")public void task(){log.info("定时任务已触发：{}",new Date());}
}

二：订单状态定时处理

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

1：超时未支付：

@Scheduled(cron = "0 0/1 * * * ?")
public void PENDING_PAYMENTtask(){log.info("定时任务已触发：{}",new Date());LocalDateTime localDateTime = LocalDateTime.now().plusMinutes(-15);List<Orders>orders= orderMapper.select(Long.valueOf(Orders.PENDING_PAYMENT),localDateTime);for (Orders order : orders) {order.setStatus(Orders.CANCELLED);order.setCancelReason("超时未支付");order.setCancelTime(LocalDateTime.now());orderMapper.update(order);}
}

我们每分钟去检查有没有超时的，具体的超时时间就是：下单时间超过15分钟，也就是当前时间-下单时间》15分钟：

我们sql是这么写的：
@Select("select * from orders where status=#{status} and order_time<#{orderTime}")
List<Orders> select(Long status, LocalDateTime orderTime);
所以我们要传入的是当前时间减去谁5分钟，而localDateTime有方法可以直接减去，那么我们获取到了超时订单，就要遍历然后修改状态让超时订单取消，取消的话另外还要给取消原因和取消时间赋值；最后调用update修改就行了

2：派送中处理：

@Scheduled(cron = "0 0 1 * * ?")
public void  DELIVERY_IN_PROGRESStask(){LocalDateTime localDateTime = LocalDateTime.now().plusHours(-1);List<Orders> orders = orderMapper.select(Long.valueOf(Orders.DELIVERY_IN_PROGRESS), localDateTime);for (Orders order : orders) {order.setStatus(Orders.COMPLETED);orderMapper.update(order);}

我们每天的凌晨一点去检查有没有派送中的订单，这里我们还是用我们定义的那个mapper方法：查询的状态是配送中，并且下单时间是昨天，也就是当前时间减一小时；然后遍历集合修改状态就行了；

三：websocket

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

不同于http，http只能由客户端主动发送消息，不能由服务器发送，被称为请求响应；而websocket是双向传输，只要建立链接只会，双方可以互发消息；

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

具体步骤：1：导入websocket依赖坐标：

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

然后要导入服务端组件：

@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {//存放会话对象private static Map<String, Session> sessionMap = new HashMap();/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session, @PathParam("sid") String sid) {System.out.println("客户端：" + sid + "建立连接");sessionMap.put(sid, session);}/*** 收到客户端消息后调用的方法** @param message 客户端发送过来的消息*/@OnMessagepublic void onMessage(String message, @PathParam("sid") String sid) {System.out.println("收到来自客户端：" + sid + "的信息:" + message);}/*** 连接关闭调用的方法** @param sid*/@OnClosepublic 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();}}}}

@Component
@ServerEndpoint(“/ws/{sid}”)要有这两个注解，ServerEndpoint里是指定了建立连接的地址

还要导入一个配置类，用于注册websocket的组件

/*** WebSocket配置类，用于注册WebSocket的Bean*/
@Configuration
public class WebSocketConfiguration {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}

四：来单提醒

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

这里我们直接再用户支付成功后想管理端的前端发送消息，我们约定的消息是json格式的包含上述内容：

Map map=new HashMap<>();
map.put("type",1);
map.put("orderId",orders.getId());
map.put("content","订单号"+outTradeNo);
String jsonString = JSON.toJSONString(map);
webSocketServer.sendToAllClient(jsonString);

这里就是将我们要传入给前端的值存放在map中，然后将map转换为json格式；

五：客户催单

这里我们单独设置一个接口，因为是用户在点击催单后发送的请求，所以我们要单独设置接口：

controller：

@GetMapping("/reminder/{id}")
public Result reminder(@PathVariable Long id){Orders orders= orderService.reminder(id);return Result.success();
}

因为我们需要订单号所有我们还要去调用service

service：

@Override
public Orders reminder(Long id) {Orders orders = orderMapper.selectById(id);Map map=new HashMap<>();map.put("type",2);map.put("orderId",id);map.put("content","订单号"+orders.getNumber());String jsonString = JSON.toJSONString(map);webSocketServer.sendToAllClient(jsonString);return orders;
}

这里就是先查询信息，然后放入map中，再将map转成一个json字符串，然后再通过ws发送给前端；

总结

“orderId”,id);
map.put(“content”,“订单号”+orders.getNumber());
String jsonString = JSON.toJSONString(map);
webSocketServer.sendToAllClient(jsonString);
return orders;
}


> 这里就是先查询信息，然后放入map中，再将map转成一个json字符串，然后再通过ws发送给前端；# 总结今天学习了springtask的简单使用，用springtask来定义定时任务，然后学习了websocket的双向传输，了解了通过ws由服务器端向前端发送数据；完成了来单提醒，催单的功能；