//将订单信息封装成map集合，方便发送
Map<String, Object> orderMsgMapToQueue = new HashMap<>();
//父订单
orderMsgMapToQueue.put("ordersForm", JSON.toJSONString(ordersForm));
//子订单
orderMsgMapToQueue.put("orderItemListSize", orderItemListForm.size());
for (int i = 0; i < orderItemListForm.size(); i++) {
    orderMsgMapToQueue.put("orderItem"+i,JSON.toJSONString(orderItemListForm.get(i)));
}

//发送生成抢购订单的消息到消息队列，并在redis中添加此订单的记录
//0 正在生成
if(redisUtils.set("weddingshop:orders:"+ordersForm.getOid(),ordersForm)){
    //发送生成的 订单信息 到 消息队列
    rabbitTemplate.convertAndSend(OrderMQConstant.WEDDINGSHOP_SAVE_ORDER_EXCHANGE,
                                  OrderMQConstant.WEDDINGSHOP_SAVE_ORDER_ROUTING,
                                  orderMsgMapToQueue);
}

@Slf4j
@Component
//指定接听的 消息队列 名字
@RabbitListener(queues = OrderMQConstant.WEDDINGSHOP_SAVE_ORDER_QUEUE)
public class SeckillOrderSaveListener {

    @Autowired
    private RedisUtils redisUtils;

    @Autowired(required = false)
    private OrdersMapper ordersMapper;

    @Autowired(required = false)
    private OrderItemMapper orderItemMapper;

    @Autowired
    private OrdersService ordersService;

    /**
     * @author : huayu
     * @date   : 1/11/2022
     * @param  : [directMsgJson]
     * @return : void
     * @description : Direct 直连模式消费者One,消费信息
     */
    //指定消息队列中的消息，交给对应的方法处理
    @RabbitHandler
    public void saveSeckillOrder(Map<String,Object> orderMsgMapToQueue){

        //子订单消息
        if(orderMsgMapToQueue.get("orderItemListSize") != null){
            //插入子订单
            int orderItemListSize = Integer.parseInt(orderMsgMapToQueue.get("orderItemListSize").toString());
            for (int i = 0; i < orderItemListSize; i++) {
                OrderItem orderItem = JSON.parseObject(orderMsgMapToQueue.get("orderItem" + i).toString(), OrderItem.class);
                log.info("***** 秒杀抢购子订单：{}，开始入库 ******",orderItem);
                if(orderItemMapper.insert(orderItem) > 0){
                    log.info("***** 秒杀抢购子订单：{}，开始入库 成功 ******",orderItem);
                }
            }
        }


        //父订单消息
        if(orderMsgMapToQueue.get("ordersForm")!= null){
            Orders ordersForm = JSON.parseObject(orderMsgMapToQueue.get("ordersForm").toString(), Orders.class);
            log.info("***** 秒杀抢购父订单：{}，开始入库 ******",ordersForm);

            //TODO 将消息中的订单实体对象，调入业务接口，插入到数据库,和redis中
            //插入 父订单
            if(ordersMapper.insert(ordersForm)>0){
                log.info("***** 秒杀抢购父订单：{}，入库 成功 ******",ordersForm);
            }
        }


       //父订单 付款后 ，操作
        if(orderMsgMapToQueue.get("ordersPayOid") != null){
            // 父订单付款后 对 父订单 修改状态，用户增加积分 和 子订单 修改状态，生成物流单号
            String ordersPayOid = orderMsgMapToQueue.get("ordersPayOid").toString();
            log.info("------ 父订单：{},支付成功，对 父订单 修改状态，用户增加积分 和 子订单 修改状态，生成物流单号------",ordersPayOid);
             if(ordersService.paySuccessOrders(ordersPayOid)){
                 log.info("------ 父订单：{},入库成功，对 父订单 修改状态，用户增加积分 和 子订单 修改状态，生成物流单号------",ordersPayOid);
             }
        }

    }


}