diff --git a/src/change_url/change_url.py b/src/change_url/change_url.py index 9c7223e..c2056f6 100644 --- a/src/change_url/change_url.py +++ b/src/change_url/change_url.py @@ -146,7 +146,7 @@ def update_agent_url(url_list, url_type): if "代理web" in context.replace(" ", "").lower(): try: with engine.connect() as connection: - update_stmt = sql_text("UPDATE sys_platform SET url = :url WHERE nickname = :url_type") + update_stmt = sql_text("UPDATE sys_platform SET url = :url,update_time=NOW() WHERE nickname = :url_type") connection.execute(update_stmt, {"url": url, "url_type": url_type}) connection.commit() logger.debug(f"{url_type}后台链接更新成功") diff --git a/src/core/Dockerfile b/src/core/Dockerfile index 2df51d2..ebbc676 100644 --- a/src/core/Dockerfile +++ b/src/core/Dockerfile @@ -25,7 +25,6 @@ ENV RABBITMQ_USER=bot ENV RABBITMQ_PASSWORD=xiaomi@123 ENV RABBITMQ_HOST=mq.stupidpz.com ENV RABBITMQ_PORT=5672 -ENV TELEGRAM_BOT_TOKEN= ENV TZ=Asia/Shanghai # 配置健康检查 diff --git a/src/core/login.py b/src/core/login.py index 1f39f03..5b57e0a 100644 --- a/src/core/login.py +++ b/src/core/login.py @@ -150,7 +150,7 @@ def handle_login_failure(account: Account): pass -def base64_api(uname='luffy230505', pwd='qwer12345', img='', typeid=20): +def base64_api(uname='luffy230505', pwd='XIAOmi123', img='', typeid=20): logger.info('Calling third part interfaces') data = { "username": uname, diff --git a/src/core/message_server.py b/src/core/message_server.py index dbd0e4e..92761a2 100644 --- a/src/core/message_server.py +++ b/src/core/message_server.py @@ -11,7 +11,6 @@ rabbitmq_user = os.getenv("RABBITMQ_USER", "bot") rabbitmq_password = os.getenv("RABBITMQ_PASSWORD", "xiaomi@123") rabbitmq_host = os.getenv("RABBITMQ_HOST", "mq.stupidpz.com") rabbitmq_port = int(os.getenv("RABBITMQ_PORT", 5672)) -telegram_bot_token = os.getenv("TELEGRAM_BOT_TOKEN") # 移除默认的日志处理器 logger.remove() @@ -66,7 +65,7 @@ async def _send_message_to_user(bot_token, target_id, message, rate_limiter, ses return else: logger.debug('消息发送失败,重试中...') - logger.error(await response.text()) + logger.error(f'{params},发送失败,返回值:{await response.text()}') except aiohttp.ClientError as e: logger.error(f'网络异常,重试中... 错误详情: {e}') await asyncio.sleep(10)