|
@@ -472,7 +472,7 @@ def zc_main(log):
|
|
|
# 获取sold data - 遍历所有商户
|
|
# 获取sold data - 遍历所有商户
|
|
|
try:
|
|
try:
|
|
|
# 从 shop 表查询所有 merNo
|
|
# 从 shop 表查询所有 merNo
|
|
|
- mer_no_rows = sql_pool.select_all("SELECT shop_id FROM zc_shop_record WHERE sold_number != 0")
|
|
|
|
|
|
|
+ mer_no_rows = sql_pool.select_all("SELECT shop_id, shop_name FROM zc_shop_record WHERE sold_number != 0")
|
|
|
log.info(f"查询到 {len(mer_no_rows)} 个商户编号: {mer_no_rows}")
|
|
log.info(f"查询到 {len(mer_no_rows)} 个商户编号: {mer_no_rows}")
|
|
|
for shop_id, shop_name in mer_no_rows:
|
|
for shop_id, shop_name in mer_no_rows:
|
|
|
log.info(f"开始爬取商户 {shop_id}, {shop_name} 的商品数据")
|
|
log.info(f"开始爬取商户 {shop_id}, {shop_name} 的商品数据")
|