一. RabbitMQ延时消息-> 订单处理

1. 流程: 调用微信支付api-> 查看订单状态-> 未支付则调用关闭订单api-> 修改订单状态为已关闭order-> 回滚库存goods-> 已支付则做补偿操作(修改订单状态和记录日志)

2. 核心: 死信队列-> provider发送的消息不会被立刻消费-> 设定TTL后被consumer消费

3. 创建订单时, 发送延迟消息为订单号-> 系统在限定时间内取出消息-> 查询订单支付转态

4. 死信交换机

(1) 普通队列:队列: queue.ordertimeout(2) 死信交换机(Dead Letter Exchange): TTL到期: 队列长度满了; consumer拒收(requeue=false);name: exchange.ordertimeout type: fanout(类型必须为fanout)
(3) 绑定: Bindings-> To queue-> queue.ordertimeout
(4) 死信队列: Tell Time Live消息过期时间name: queue.ordercreatedurability: DurableAuto delete: NoArguments: x-message-ttl=10000  //消息的生存时间x-dead-letter-exchange=exchange.ordertiemout  //队列的死信交换机

5. 代码实现:

(1) 订单价单-> 发送延迟消息
(2) 消息内容: orderId
(3) 发送到MQ的延迟消息
(4) 订单服务监听消息
(5) 基于微信api-> 查询支付状态
(6) 已支付-> 数据补偿-> MySQL记录日志/订单转态已支付
(7) 未支付-> 基于微信api关闭订单-> MySQL修改订单状态-> 商品库存回滚

调用微信api查询订单/关闭订单 

(1) com.changgou.pay.controller//基于微信查询订单@GetMapping("/query/{orderId}")public Result queryOrder(@PathVariable("orderId")String orderId) {Map map = wxPayService.queryOrder(orderId);return new Result(true, StatusCode.OK, "查询订单成功", map);}//基于微信关闭订单@PutMapping("/close/{orderId}")public Result closeOrder(@PathVariable("orderId")String orderId){Map map = wxPayService.closeOrder(orderId);return new Result(true, StatusCode.OK, "关闭订单成功", map);}(2) com.changgou.pay.service.impl//基于微信查询订单@Overridepublic Map queryOrder(String orderId) {try {Map<String, String> map = new HashMap();map.put("out_trade_no", orderId);Map<String, String> resultMap = wxPay.orderQuery(map);return resultMap;} catch(Exception e) {e.printStackTrace();return null;}}//基于微信关闭订单@Overridepublic Map closeOrder(String orderId) {try {Map<String, String> map = new HashMap();map.put("out_trade_no",orderId);Map<String, String> resultMap = wxPay.closeOrder(map);return resultMap;} catch(Exception e) {e.printStackTrace();return null;}}

回滚库存: changgou_service_goods

(1)com.changgou.goods.dao
public interface SkuMapper extends Mapper<Sku> {//回滚 -> 增减库存并扣减销量@Update("update tb_sku set num=num+#{num},sale_num=sale_num-#{num} where id=#{skuId}")void resumeStockNum(@Param("skuId")String skuId, @Param("num")Integer num);
}(2)com.changgou.goods.service.impl//回滚库存@Override@Transactionalpublic void resumeStockNum(String skuId, Integer num) {skuMapper.resumeStockNum(skuId, num);}(3)com.changgou.goods.controller//回滚库存@RequestMapping("/resumeStockNum")public Result resumeStockNum(@RequestParam("skuId")String skuId, @RequestParam("num")Integer num) {skuService.resumeStockNum(skuId, num);return new Result(true, StatusCode.OK, "回滚库存成功");}(4)对外暴露接口, 给回滚操作调用
//回滚库存@RequestMapping("/sku/resumeStockNum")
public Result resumeStockNum(@RequestParam("skuId") String skuId, @RequestParam("num") Integer num);

消息发送和监听类:

(1) com.changgou.order.service.impl
//发送延迟消息
rabbitTemplate.convertAndSend("", "queue.ordercreate", orderId);(2) com.changgou.order.listener
@Component
public class OrderTimeOutListener {@Autowiredprivate OrderService orderService;@RabbitListener(queues = "queue.ordertimeout")public void receiveCloseOrderMessage(String message) {System.out.println("接收到关闭订单的消息");try {//调用业务层完成关闭订单操作orderService.closeOrder(message);} catch(Exception e) {e.printStackTrace();}}
}(3) com.changgou.order.service.impl@Autowiredprivate PayFeign payFeign;//关闭订单@Override@Transactionalpublic void closeOrder(String orderId) {/***1.根据订单id查询mysql订单信息, 判断订单是否存在, 判断订单的支付状态2. 基于微信查询订单信息2.1. 订单已支付, 则数据补偿2.2. 订单未支付, 则修改订单信息, 新增订单日志, 恢复库存, 基于微信关闭订单*/System.out.println("关闭订单业务开启:" + orderId);Order order = orderMapper.selectByPrimaryKey(orderId);if (order == null) {throw new RuntimeException("订单不存在");}if (!"0".equals(order.getPayStatus())) {System.out.println("当前订单不需要关闭");return;}System.out.println("关闭订单校验通过" + orderId);//基于微信获取订单信息Map wxQueryMap = (Map) payFeign.queryOrder(orderId).getData();System.out.println("查询微信支付的订单" + wxQueryMap);//如果订单已支付, 数据补偿if ("SUCCESS".equals(wxQueryMap.get("trade_state"))) {this.updatePayStatus(orderId, (String) wxQueryMap.get("transaction_id"));System.out.println("完成数据补偿");}//如果订单未支付, 则修改订单信息, 新增订单日志, 恢复库存, 基于微信关闭订单if ("NOTPAY".equals(wxQueryMap.get("trade_state"))) {System.out.println("执行关闭");order.setUpdateTime(new Date());order.setOrderStatus("4");orderMapper.updateByPrimaryKeySelective(order);//新增日志OrderLog orderLog = new OrderLog();orderLog.setId(idWorker.nextId() + "");orderLog.setOperater("system");orderLog.setOperateTime(new Date());orderLog.setOrderStatus("4");orderLog.setOrderId(order.getId());orderLogMapper.insert(orderLog);//恢复商品库存OrderItem _orderItem = new OrderItem();_orderItem.setOrderId(orderId);orderItemMapper.select(_orderItem);List<OrderItem> orderItemList = orderItemMapper.select(_orderItem);for (OrderItem orderItem : orderItemList) {skuFeign.resumeStockNum(orderItem.getSkuId(), orderItem.getNum());}//基于微信关闭订单payFeign.closeOrder(orderId);}}

二. 批量发货, 第三方物流系统

1.业务逻辑: 商家管理后台->发货列表页面-> 选择物流-> 物流第三方api选择单号-> 批量状态修改

(1)com.changgou.order.service.impl//批量修改订单状态@Override@Transactionalpublic void batchSend(List<Order> orders) {//内含三个循环, 回滚点保证数据回滚时三个阶段状态的保存(循环1订单数据存在 -> 循环2发货状态保存 -> 循环3已发货)//判断每个订单的运单号和物流公司值是否存在for (Order order : orders) {if (order.getId()==null){throw new RuntimeException("订单号不存在");}if (order.getShippingCode()==null||order.getShippingName()==null){throw  new RuntimeException("请输入订单号或物流公司名称");}}//进行订单状态的批量发货for (Order order : orders) {Order order1 = orderMapper.selectByPrimaryKey(order.getId());if (!"0".equals(order1.getConsignStatus())||!"1".equals(order1.getOrderStatus())){throw new RuntimeException("订单状态不合法");}}//修改订单的状态为已发货for (Order order : orders) {order.setOrderStatus("2");  //已发货order.setConsignStatus("1"); //已发货order.setConsignTime(new Date());order.setUpdateTime(new Date());orderMapper.updateByPrimaryKeySelective(order);//记录订单日志OrderLog orderLog = new OrderLog();orderLog.setId(idWorker.nextId()+"");orderLog.setOperateTime(new Date());orderLog.setOperater("admin");orderLog.setOrderStatus("2");order.setConsignStatus("1");orderLog.setOrderId(order.getId());orderLogMapper.insertSelective(orderLog);}}(2)com.changgou.order.controller
//批量修改订单状态@PutMapping("/batchSend")public Result batchSend(@RequestBody List<Order> orders) {orderService.batchSend(orders);return new Result(true, StatusCode.OK, "发货成功");}

2. 第三发物流平台对接: 快递鸟http://www.kdniao.com ; 菜鸟物流

        (1) 预约取件API

        (2) 即时查询API

三. Spring task自动收货功能/手动确认收货

1. 手动: 用户点击-> 

(1) com.changgou.order.service.impl //手动确认收货@Override@Transactionalpublic void confirmTask(String orderId, String operator) {Order order = orderMapper.selectByPrimaryKey(orderId);if (order==null){throw new RuntimeException("订单不存在");}if (!"1".equals(order.getConsignStatus())){throw new RuntimeException("订单未发货");}order.setConsignStatus("2");  //已送达order.setOrderStatus("3");  //已完成order.setUpdateTime(new Date());order.setEndTime(new Date());orderMapper.updateByPrimaryKeySelective(order);//记录订单日志OrderLog orderLog = new OrderLog();orderLog.setId(idWorker.nextId()+"");orderLog.setOperateTime(new Date());orderLog.setOperater(operator);orderLog.setOrderStatus("3");order.setConsignStatus("2");orderLog.setOrderId(order.getId());orderLogMapper.insertSelective(orderLog);}

2. 自动: 物流发货后->order_config表中字段take_tiem=9天-> 定时任务-> 自动修改订单状态

changgou_task服务定时任务发送消息

(1) tb_order_config表: 字段take_timeout 自动收货超时时间15天
(2) cron表达式: 设置定时任务 秒分时日月周年 *每个单位 -区间 /增量  ,多个值
(3) changgou_task服务-> 发送消息到MQ-> order服务接收消息
@SpringBootApplication
@EnableScheduling
public class TaskApplication {public static void main(String[] args) {SpringApplication.run(TaskApplication.class,args);}
}(4)com.changgou.config
@Configuration
public class RabbitMQConfig {public static final String ORDER_TACK="order_tack";@Beanpublic Queue queue(){return new Queue(ORDER_TACK);}
}(5)com.changgou.task
@Component
public class OrderTask {@Autowiredprivate RabbitTemplate rabbitTemplate;@Scheduled(cron = "0 0 0 * * ?")  //每天执行一次public void autoTake() {System.out.println(new Date());rabbitTemplate.convertAndSend("", RabbitMQConfig.ORDER_TACK, "-");}
}

order服务接收消息

(1) 添加队列: com.changgou.order.config
//自动确认订单
public static final String ORDER_TACK="order_tack";
//声明队列 - 自动确认
@Bean
public Queue ORDER_TACK(){return new Queue(ORDER_TACK);
}(2) com.changgou.order.listener
@Component
public class OrderTaskListener {@Autowiredprivate OrderService orderService;@RabbitListener(queues = RabbitMQConfig.ORDER_TACK)public void receiveOrderTaskMessage(String message){System.out.println("收到自动确认收货的消息");//调动业务层,完成自动收货实现orderService.autoTack();}
}(3) com.changgou.order.service.impl@Autowiredprivate OrderConfigMapper orderConfigMapper;//自动确认收货@Override@Transactionalpublic void autoTack() {/*** 1. 从配置表中获得 订单自动确认的时间点* 2. 得到当前时间节点向前数(订单自动确认的时间节点)天, 作为过期的时间节点* 3. 从订单表中获取相关符合条件的数据(发货时间小于过期时间, 收货状态未确认)* 4. 循环遍历, 执行确认收货*/       //测试, 当前数据库只有一个数据, 直接通过主键拿到对象OrderConfig orderConfig = orderConfigMapper.selectByPrimaryKey(1);//获取当前时间LocalDate now = LocalDate.now();LocalDate date = now.plusDays(-orderConfig.getTakeTimeout());//按条件查询获取订单列表Example example = new Example(Order.class);Example.Criteria criteria = example.createCriteria();criteria.andLessThan("consignTime", date);criteria.andEqualTo("orderStatus", "2");List<Order> orderList = orderMapper.selectByExample(example);//遍历列表for (Order order : orderList) {//调用上面的手动确认方法this.confirmTask(order.getId(), "system");}}