falcon.py 文件源码

def search_iphone():
    # ???????????????????????
    buyers_info = get_buyers_info()
    availability = r.get(current_config['IPHONE_MODELS_URL']).json()
    if availability['stores']:
        # ?????????????????
        for store, models in buyers_info.items():
            # ????????????????
            for model_number, buyers in models.items():
                # ????????????
                stock = availability['stores'][store][model_number]
                if stock['availability']['unlocked'] is True:
                    for buyer in buyers:
                        if cache.get(buyer['idcard']) is None:
                            buyer['store'] = store
                            with rabbit as mq:
                                mq.send_message(exchange_name='iphone', queue_name='buyers', messages=buyer)
                            # ???????????
                            msg = '[??] ??????????????{0}? ???{1}????{2}'.format(get_store_name(store),  get_model_name(model_number), datetime.now())
                            logging.info(msg)
                            logging.info('?????{}'.format(buyer))
                            logging.info('[??] ????????????????')
                            itchat.send(msg, toUserName=wechat_user_name)
                            # ????????????5???????
                            cache.set(key=buyer['idcard'], val='???', time=300)
        else:
            logging.info('[??] ????????')