Commit 97810f23 authored by 邱阿朋's avatar 邱阿朋

refactor(import): 调整导入模块以简化代码结构

- 移除了 easy_storage.py 中未使用的 os 模块
- 在 return_goods.py 和 spa_search.py 中合并了 helper 模块的导入
- 删除了 src/helper 中的 rabbitmq 模块引用
parent fcd64832
No preview for this file type
No preview for this file type
No preview for this file type
No preview for this file type
# coding: utf-8 # coding: utf-8
import json import json
import os
from datetime import datetime from datetime import datetime
import requests import requests
......
...@@ -7,8 +7,7 @@ import pandas as pd ...@@ -7,8 +7,7 @@ import pandas as pd
from DrissionPage import ChromiumPage from DrissionPage import ChromiumPage
from DrissionPage.errors import ElementNotFoundError from DrissionPage.errors import ElementNotFoundError
from helper import helper, excel, file, domain, logger, api from helper import helper, excel, file, domain, logger, api, rabbitmq
from src.helper import rabbitmq
country = None country = None
shop_code = None shop_code = None
......
...@@ -10,8 +10,7 @@ from DrissionPage import ChromiumPage ...@@ -10,8 +10,7 @@ from DrissionPage import ChromiumPage
from DrissionPage.errors import ElementNotFoundError from DrissionPage.errors import ElementNotFoundError
from lxml import etree from lxml import etree
from helper import helper, excel, file, domain, logger, api from helper import helper, excel, file, domain, logger, api, rabbitmq
from src.helper import rabbitmq
country = None country = None
shop_code = None shop_code = None
...@@ -223,6 +222,7 @@ def main(): ...@@ -223,6 +222,7 @@ def main():
# 推送消息 # 推送消息
# push_data_queue(new_file_name) # push_data_queue(new_file_name)
def process_large_items(item_list, relation_data): def process_large_items(item_list, relation_data):
"""处理大数据列表 (item_list 长度 >= 10)""" """处理大数据列表 (item_list 长度 >= 10)"""
processed_items = [] processed_items = []
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment