mirror of
https://git.oceanpay.cc/danial/kami_itunes_third_api.git
synced 2025-12-18 21:19:19 +00:00
refactor(scripts): 重构主程序执行逻辑
- 修改 docker-entrypoint.sh,增加睡眠时间以减少资源占用 - 重命名 main.py 中的函数 run_task 为 run - 更新 scripts.py,使用 while 循环持续查询订单
This commit is contained in:
@@ -11,5 +11,5 @@ while true; do
|
|||||||
# 如果成功获取锁,则运行 Python 脚本
|
# 如果成功获取锁,则运行 Python 脚本
|
||||||
python -u main.py
|
python -u main.py
|
||||||
) 200>$LOCKFILE
|
) 200>$LOCKFILE
|
||||||
sleep 1
|
sleep 5
|
||||||
done
|
done
|
||||||
4
main.py
4
main.py
@@ -1,4 +1,4 @@
|
|||||||
from src.cmd.scripts import run_task
|
from src.cmd.scripts import run
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
run_task()
|
run()
|
||||||
|
|||||||
@@ -182,17 +182,20 @@ def run_task():
|
|||||||
# 注册信号处理程序
|
# 注册信号处理程序
|
||||||
has_been_console = False
|
has_been_console = False
|
||||||
master_node_service = MasterNodeService()
|
master_node_service = MasterNodeService()
|
||||||
# 1s获取两次订单
|
while True:
|
||||||
master_order = master_node_service.query_order()
|
master_node_service = MasterNodeService()
|
||||||
if master_order.orderNo != "":
|
# 1s获取两次订单
|
||||||
logger.info(f"当前订单:{master_order}")
|
master_order = master_node_service.query_order()
|
||||||
run_redeem_task(master_order, master_node_service)
|
if master_order.orderNo != "":
|
||||||
# 10分钟打印一次信息
|
logger.info(f"当前订单:{master_order}")
|
||||||
if datetime.now().second % 10 == 0 and not has_been_console:
|
run_redeem_task(master_order, master_node_service)
|
||||||
has_been_console = True
|
# 10分钟打印一次信息
|
||||||
print(f"{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\t暂时没有订单")
|
if datetime.now().second % 10 == 0 and not has_been_console:
|
||||||
if datetime.now().second % 10 != 0 and has_been_console:
|
has_been_console = True
|
||||||
has_been_console = False
|
print(f"{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}\t暂时没有订单")
|
||||||
|
if datetime.now().second % 10 != 0 and has_been_console:
|
||||||
|
has_been_console = False
|
||||||
|
# time.sleep(1)
|
||||||
|
|
||||||
def run():
|
def run():
|
||||||
# signal.signal(signal.SIGINT, signal_handler)
|
# signal.signal(signal.SIGINT, signal_handler)
|
||||||
|
|||||||
Reference in New Issue
Block a user