mirror of
https://git.oceanpay.cc/danial/kami_itunes_third_api.git
synced 2025-12-18 22:58:26 +00:00
chore: 添加杂项
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
from loguru import logger
|
||||
|
||||
import sys
|
||||
|
||||
from loguru import logger
|
||||
|
||||
from src.database import redis_pool
|
||||
from src.database.mysql_db import engine
|
||||
from src.entities.queues import fifo_queue
|
||||
|
||||
@@ -30,10 +30,8 @@ def run_redeem_task(
|
||||
queue: Queue,
|
||||
reties=3,
|
||||
):
|
||||
logger.info("我被调用了")
|
||||
redis_conn = redis_pool.get_connection()
|
||||
redis_client = redis.Redis(connection_pool=redis_conn)
|
||||
logger.info("我被调用了")
|
||||
try:
|
||||
if reties <= 0:
|
||||
logger.error(f"调用次数已用完,请重新检查订单:{master_order}")
|
||||
@@ -48,7 +46,6 @@ def run_redeem_task(
|
||||
)
|
||||
return
|
||||
response_schema = None
|
||||
logger.info("我被调用了")
|
||||
redis_client.incrby(f"apple_account_{master_order.account}_count", 1)
|
||||
while True:
|
||||
response_schema_from_itunes = redis_client.get(
|
||||
@@ -72,7 +69,6 @@ def run_redeem_task(
|
||||
response_schema = apple_account_schema.login_schema
|
||||
break
|
||||
time.sleep(1)
|
||||
logger.info("我被调用了")
|
||||
itunes_service = ItunesService()
|
||||
# 设置登录标识
|
||||
if not response_schema_from_itunes:
|
||||
@@ -91,7 +87,6 @@ def run_redeem_task(
|
||||
account=master_order.account, password=master_order.password
|
||||
)
|
||||
)
|
||||
logger.info("我被调用了")
|
||||
if isinstance(response_schema, LoginFailureResponse):
|
||||
# 如果登录失败,保存一天的登录信息
|
||||
if not response_schema_from_itunes:
|
||||
|
||||
@@ -8,6 +8,7 @@ from typing import Any
|
||||
from urllib import parse
|
||||
|
||||
import requests
|
||||
from loguru import logger
|
||||
from requests.exceptions import ConnectionError
|
||||
from urllib3 import HTTPSConnectionPool
|
||||
|
||||
@@ -152,8 +153,8 @@ class SixClient:
|
||||
)
|
||||
response.Data = json.loads(decode_and_decompress(response.Data))
|
||||
if response.Data.get("msg") == "请重试":
|
||||
print("请重试", response.Data)
|
||||
time.sleep(2)
|
||||
logger.info(f"重试六月登录,{response}")
|
||||
time.sleep(1)
|
||||
return self.get_sign_sap_setup(reties - 1)
|
||||
response = AppleSixResponseModel[LoginSignatureModel].model_validate(
|
||||
response.model_dump()
|
||||
@@ -196,7 +197,7 @@ class SixClient:
|
||||
)
|
||||
response.Data = json.loads(decode_and_decompress(response.Data))
|
||||
if response.Data.get("msg") == "请重试":
|
||||
print("请重试 get_sign_sap_setup_cert", response.Data)
|
||||
logger.info(f"重试六月登录,{response}")
|
||||
time.sleep(2)
|
||||
return self.get_sign_sap_setup_cert(
|
||||
account, sign, sign_sap_setup, reties - 1
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
import uuid
|
||||
|
||||
from loguru import logger
|
||||
|
||||
from src.integrations.itunes.api import AppleClient
|
||||
from src.integrations.itunes.models.login import (
|
||||
ItunesSuccessLoginPlistData,
|
||||
@@ -39,8 +41,9 @@ class ItunesService:
|
||||
:param account:
|
||||
:return:
|
||||
"""
|
||||
|
||||
logger.info("我被调用了")
|
||||
sign_sap_from_june = self.june_client_service.get_sign_sap_setup()
|
||||
logger.info("我被调用了")
|
||||
sign_sap_setup_buffer = self.apple_client_service.query_sign_sap_setup(
|
||||
sign_sap_from_june.Data
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user