celery 每日分账 添加参数

apps/web/dealer/tasks.py

@@ -24,9 +24,8 @@ from apps.web.common.models import OperatorLog, DealerDoneReportRecord
 from apps.web.common.proxy import ClientRechargeModelProxy, ClientConsumeModelProxy
 from apps.web.common.transaction import WITHDRAW_PAY_TYPE
 from apps.web.common.transaction.pay import PayRecordPoller, PayManager
-from apps.web.constant import Const, RechargeRecordVia, USER_RECHARGE_TYPE, AppPlatformType
+from apps.web.constant import Const, RechargeRecordVia, AppPlatformType
 from apps.web.constant import DEALER_CONSUMPTION_AGG_KIND_TRANSLATION, MONTH_DATE_KEY
-from apps.web.core.exceptions import InsufficientFundsError
 from apps.web.core.helpers import ActionDeviceBuilder
 from apps.web.core.messages import SmsVendorCode
 from apps.web.core.messages.sms import SMSSender
@@ -42,9 +41,8 @@ from apps.web.dealer.withdraw import DealerWithdrawService
 from apps.web.device.models import DevStatusRecord, Device, Group, DeviceDict
 from apps.web.device.timescale import SignalManager
 from apps.web.helpers import get_wechat_manager_mp_proxy, get_platform_wallet_pay_gateway
-from apps.web.report.ledger import Ledger, LedgerConsumeOrder
-from apps.web.report.models import DealerReport, DealerDailyStat, \
-    DeviceDailyStat, GroupDailyStat, DealerMonthlyStat
+from apps.web.report.ledger import LedgerConsumeOrder
+from apps.web.report.models import DealerReport, DealerDailyStat, DeviceDailyStat, GroupDailyStat, DealerMonthlyStat
 from apps.web.report.models import GroupReport
 from apps.web.report.utils import cum_stats, translate_consumption
 from apps.web.user.models import ConsumeRecord, MyUser, RechargeRecord, Card

taskmanager/config.py

@@ -373,7 +373,8 @@ CELERYBEAT_SCHEDULE = {
         "options": {
             'queue': MY_CELERY_QUEUE,
             'routing_key': MY_CELERY_ROUTING_KEY
-        }
+        },
+        'args': (None, None)
     },