193a82930e
自动结算结单前再校验俱乐部开关与 SettlementTime>=开启时间；关开关仍清 eligible。 Co-authored-by: Cursor <cursoragent@cursor.com>
62 lines
2.0 KiB
Python
62 lines
2.0 KiB
Python
"""
|
||
阿龙电竞 - Celery 定时任务主配置
|
||
|
||
业务约定（2026-07）：Beat 只跑两条
|
||
1) 资金冻结到期解冻
|
||
2) 可控订单自动结算
|
||
其余榜单/清零类任务保留代码但不进 beat_schedule，不会定时执行。
|
||
"""
|
||
import os
|
||
from celery import Celery
|
||
from celery.schedules import crontab
|
||
|
||
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'a_long_dianjing.settings')
|
||
|
||
app = Celery('a_long_dianjing')
|
||
app.config_from_object('django.conf:settings', namespace='CELERY')
|
||
|
||
# 仅自动发现仍可能被调用的任务模块；旧超时结算 orders.tasks 永不加载
|
||
app.autodiscover_tasks(['jituan.tasks', 'users.tasks', 'users.ranking_tasks', 'config.tasks'])
|
||
|
||
# ========== Beat：只保留这两个 ==========
|
||
app.conf.beat_schedule = {
|
||
# 资金冻结到期解冻（俱乐部未开冻结 / 无到期单 → 空跑）
|
||
'scan_fund_freeze_due': {
|
||
'task': 'jituan.tasks.scan_fund_freeze_due',
|
||
'schedule': crontab(minute='*/5'),
|
||
'options': {
|
||
'queue': 'periodic_tasks',
|
||
'priority': 4,
|
||
},
|
||
},
|
||
# 可控自动结算（俱乐部后台开关关 → 空跑；只处理 AutoSettleEligible 新单）
|
||
'scan_order_auto_settle_due': {
|
||
'task': 'jituan.tasks.scan_order_auto_settle_due',
|
||
'schedule': crontab(minute='*/5'),
|
||
'options': {
|
||
'queue': 'periodic_tasks',
|
||
'priority': 4,
|
||
},
|
||
},
|
||
}
|
||
|
||
app.conf.timezone = 'Asia/Shanghai'
|
||
app.conf.enable_utc = True
|
||
|
||
app.conf.task_routes = {
|
||
'jituan.tasks.*': {'queue': 'periodic_tasks'},
|
||
'users.tasks.*': {'queue': 'periodic_tasks'},
|
||
'config.tasks.*': {'queue': 'periodic_tasks'},
|
||
}
|
||
|
||
app.conf.accept_content = ['json']
|
||
app.conf.task_serializer = 'json'
|
||
app.conf.result_serializer = 'json'
|
||
app.conf.task_time_limit = 300
|
||
app.conf.task_soft_time_limit = 240
|
||
app.conf.worker_concurrency = 4
|
||
app.conf.worker_prefetch_multiplier = 1
|
||
app.conf.task_acks_late = True
|
||
app.conf.worker_disable_rate_limits = True
|
||
app.conf.result_expires = 3600
|