super/crawler-plugin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modified: amazon/price_match.py

Browse Source 
modified:   config.py
This commit is contained in:
铭坤
2026-05-07 11:14:15 +08:00
parent 8be12ca9bc
commit b0514c3e9a
2 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/amazon/price_match.py
View File

@@ -979,7 +979,7 @@ class PriceTask(TaskBase):
country_name = self.country_info.get(country_code, country_code) country_name = self.country_info.get(country_code, country_code)
info_mes = f"开始处理国家: {country_name} ({country_code}),需要跳过的asin {skip_asin}" info_mes = f"开始处理国家: {country_name} ({country_code}),需要跳过的asin {skip_asin}"
self.log(info_mes) self.log(info_mes)
show_notification(info_mes, "info") show_notification(f"开始处理国家:{country_name}", "info")
# 更新当前处理的国家 # 更新当前处理的国家
if task_id in runing_task: if task_id in runing_task:

27
app/config.py
View File

@@ -3,12 +3,11 @@ coze_token = "sat_12nW40INoJxArrDXbY4lSCoudbqkOYTcphC99BP2efWyzxmsk4q81WDX3ezWgq
workflow_id = "7608812635877900322" workflow_id = "7608812635877900322"
STITCH_WORKFLOW_ID = "7608813873483300907" STITCH_WORKFLOW_ID = "7608813873483300907"
import os import os
from dotenv import load_dotenv from dotenv import load_dotenv
from queue import Queue from queue import Queue
load_dotenv() load_dotenv()
_base_url = os.getenv("base_url","http://159.75.121.33:15124") _base_url = os.getenv("base_url","http://159.75.121.33:15124")
base_dir = os.path.dirname(os.path.abspath(__file__))
# MySQL 配置 # MySQL 配置
mysql_host = os.getenv("mysql_host") mysql_host = os.getenv("mysql_host")
@@ -16,11 +15,10 @@ mysql_user = os.getenv("mysql_user")
mysql_password = os.getenv("mysql_password","WTFrb5y6hNLz6hNy") mysql_password = os.getenv("mysql_password","WTFrb5y6hNLz6hNy")
mysql_database = os.getenv("mysql_database","aiimage") mysql_database = os.getenv("mysql_database","aiimage")
proxy_url = os.getenv("proxy_url") proxy_url = os.getenv("proxy_url")
proxy_mode = int(os.getenv("proxy_mode",1)) proxy_mode = int(os.getenv("proxy_mode",1))
_client_name = os.getenv("client_name", "").strip() client_name=os.getenv("client_name") + ".exe"
client_name = f"{_client_name}.exe" if _client_name else "client.exe" JAVA_API_BASE = os.getenv("java_api_base", "http://127.0.0.1:18080")
JAVA_API_BASE = os.getenv("java_api_base", "http://127.0.0.1:18080")
# 紫鸟浏览器配置 # 紫鸟浏览器配置
from urllib.parse import unquote from urllib.parse import unquote
@@ -51,8 +49,8 @@ os.environ['OSS_ACCESS_KEY_SECRET'] = accessKeySecret
os.environ['SECRET_KEY'] = "ddffc7c1d02121d9554d7b080b2511b6" os.environ['SECRET_KEY'] = "ddffc7c1d02121d9554d7b080b2511b6"
debug = os.getenv("debug", "false").strip().lower() in ("1", "true", "yes", "on") debug = True
version = "1.0.56" version = "1.0.13"
APP_UPDATE_URL = f"{_base_url}/api/version/latest" # 检测更新接口地址，返回 { "file_url": "...", "version": "x.x.x" } APP_UPDATE_URL = f"{_base_url}/api/version/latest" # 检测更新接口地址，返回 { "file_url": "...", "version": "x.x.x" }
os.environ['APP_VERSION'] = version os.environ['APP_VERSION'] = version
os.environ['APP_UPDATE_URL'] = APP_UPDATE_URL os.environ['APP_UPDATE_URL'] = APP_UPDATE_URL
@@ -61,6 +59,9 @@ os.environ['APP_UPDATE_URL'] = APP_UPDATE_URL
# 队列 # 队列
JSON_TASK_QUEUE = Queue() JSON_TASK_QUEUE = Queue()
base_dir = os.getcwd()
#删除品牌，正在执行中的任务 #删除品牌，正在执行中的任务
runing_task = { runing_task = {