# # TODO push the data of liexin to go_nplm_server.
# # 首先从234的redis中获取 supplier_id, brand_id的相关信息
# # 根据获取到的信息去sku数据库中筛选 符合条件的数据信息（包含spu_id）
# # 在redis中根据spu_id 获取到相关的分类信息等等。
# # 映射组装后推送到 go_nplm_server处理
# import json
#
# import pymysql
# import redis
#
# db = redis.Redis(host='192.168.1.235', port=6379, password='icDb29mLy2s', decode_responses=True)
# db_234 = redis.Redis(host='192.168.1.234', port=6379, password='icDb29mLy1s', decode_responses=True)
#
# def get_channel_info():
#     """return supplier_id 或者 brand_id 等等"""
#     data = {}
#     infos = db.hgetall('shop_distribution')
#     for key in infos:
#         info_value = json.loads(infos[key])
#         # 暂时只推京东数据
#         if info_value["shop_id"] != 1 or info_value["platform"] != 1:
#             continue
#         supplier_id_list = info_value["supplier_id_list"]
#         brand_id_list = info_value["brand_id_list"]
#         platform = info_value["platform"]
#         data["supplier_id_list"] = supplier_id_list
#         data["brand_id_list"] = brand_id_list
#         data["platform"] = platform
#     return data
#
# def period_get_data(db_name, table_name, condition) -> list:
#     """指定数据库 指定表中获取数据"""
#     db = pymysql.connect(host='192.168.1.238', port=3306, user='spu', password='spu', database=db_name)
#     supplier_ids = condition["supplier_id_list"]
#     sql = "select spu_id from " + table_name + " where supplier_id in %s"
#     cursor = db.cursor()
#     cursor.execute(sql, args=(supplier_ids,))
#     results = cursor.fetchall()
#     data = []
#     for i in range(len(results)):
#         data.append(results[i][0])
#     return data
#
# def get_class_from_rds(spu_id):
#     """根据spu_id 在redis中获取到对应的品牌和分类"""
#     infos = db_234.hget("spu", str(spu_id))
#     return json.loads(infos)
#
#
# if __name__ == '__main__':
#     condition = get_channel_info()
#     spu_ids = period_get_data("liexin_sku_0", "lie_sku_0", condition)
#     print(spu_ids)
#     infos = get_class_from_rds(spu_ids[0])
#     print(infos)