<gh_stars>1-10
#!/usr/bin/env python3
# -*- coding:utf-8 -*-
# author: bigfoolliu


"""
监听订单队列, 消费订单队列

1. 只要有消息就读出，然后写入mysql订单历史；
2. 此时订单未完成，所以交易状态为未完成
"""

import pika
import time
import settings
from typing import NoReturn
from conn import rabbitmq_conn


def start_order_consume(goods_id: int) -> NoReturn:
    """
    消费订单队列
    :param goods_id:
    :return:
    """
    channel = rabbitmq_conn.channel()

    exchange = 'order.exchange'
    queue = 'order.queue'

    print('start_order_consume\n')

