文章目录
-
- 概要
- 整体架构流程
- 技术细节
- 小结
概要
来单提醒：
业务场景：在电商平台、外卖平台等应用场景中，当有新的订单产生时，系统需要及时通知相关人员处理新订单。
目的：确保订单能够得到快速响应，提高客户满意度和服务效率。
用户催单：
业务场景：在订单处理过程中，如果用户长时间未收到订单状态更新，可能会发起催单请求。
目的：提升用户体验，确保订单处理流程透明化，及时反馈订单进度。
这两种机制通常结合使用，共同保障订单处理的高效性和用户的满意度。
需求分析以及接口设计
设计：
通过VebSocket实现管理端页面和服务端保持长连接状态
当用户点击催单按钮后，调用VebSocket的相关API实现服务端向客户端推送消息
客户端浏览器解析服务端推送的消息，判断是来单提醒还是客户催单，进行相应的消息提示和语音播报
约定服务端发送给客户端浏览器的数据格式为JSON,字段包括：type,orderld,content
-type为消息类型，1为来单提醒2为客户催单
-orderld为订单id
-content为消息内容
技术细节
1.Controller层
/**
* 客户催单
* @param id
* @return
*/
@GetMapping("/reminder/{id}")
@ApiOperation("客户催单")
public Result reminder(@PathVariable Long id){
log.info("客户催单");
orderService.reminder(id);
return Result.success();
}2.Service层:
@Override
public void reminder(Long id) {
Orders ordersDB = orderMapper.getById(id);
if(ordersDB == null){
throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
}
HashMap<String, Object> map = new HashMap<>();
map.put("type",2);
map.put("orderId",id);
map.put("content","订单id:" + ordersDB.getNumber());
String json = JSON.toJSONString(map);
webSocketServer.sendToAllClient(json);
}public OrderSubmitVO orderSubmit(OrdersSubmitDTO ordersSubmitDTO) {
//1.排除异常(购物车为空,地址为空)
//向购物车表查询该用户的购物车,并判空
Long userId = BaseContext.getCurrentId();
ShoppingCart shoppingCart = new ShoppingCart();
shoppingCart.setUserId(userId);
List<ShoppingCart> shoppingCarts = shoppingCartMapper.selectByUserId(shoppingCart);
if (shoppingCarts == null || shoppingCarts.size() == 0) {
throw new ShoppingCartBusinessException(MessageConstant.SHOPPING_CART_IS_NULL);
}
//向地址表中查询该用户的地址信息,并判空
Long addressBookId = ordersSubmitDTO.getAddressBookId();
AddressBook addressBook = addressBookMapper.getById(addressBookId);
if (addressBook == null) {
throw new AddressBookBusinessException(MessageConstant.ADDRESS_BOOK_IS_NULL);
}
//2.向订单表插入1条数据
Orders orders = new Orders();
BeanUtils.copyProperties(ordersSubmitDTO, orders);
String address = addressBook.getProvinceName() + addressBook.getCityName() + addressBook.getDistrictName() + addressBook.getDetail();
orders.setAddress(address);
orders.setOrderTime(LocalDateTime.now());
orders.setConsignee(addressBook.getConsignee());
orders.setUserId(userId);
orders.setPayStatus(Orders.UN_PAID);
orders.setStatus(Orders.PENDING_PAYMENT);
orders.setNumber(String.valueOf(System.currentTimeMillis()));
orderMapper.insert(orders);
//3.向订单明细表插入n条数据
List<OrderDetail> orderDetails = new ArrayList<>();
shoppingCarts.forEach(cart -> {
OrderDetail orderDetail = new OrderDetail();
BeanUtils.copyProperties(cart, orderDetail);
orderDetail.setOrderId(orders.getId());
orderDetails.add(orderDetail);
});
orderDetailMapper.insertBatch(orderDetails);
//4.清空购物车
shoppingCartMapper.deleteByUserId(userId);
//由于微信支付没有商家证件,为了接下来的接口能顺利测试,则把订单统一改成已支付
orders.setStatus(Orders.PAID);
orderMapper.update(orders);
//利用websocket实现商家来单提醒
Map<String,Object> map = new HashMap<>();
map.put("type",1);
map.put("orderId",orders.getId());
map.put("content","订单号:" + orders.getNumber());
String json = JSON.toJSONString(map);
webSocketServer.sendToAllClient(json);
//5.返回VO对象
OrderSubmitVO orderSubmitVO = new OrderSubmitVO();
orderSubmitVO.setOrderNumber(orders.getNumber());
orderSubmitVO.setOrderAmount(orders.getAmount());
orderSubmitVO.setOrderTime(orders.getOrderTime());
orderSubmitVO.setId(orders.getId());
return orderSubmitVO;
}
效果展示
1.建立长连接
2.用户下单
3.收到来单提醒
