|
@@ -352,9 +352,9 @@ class LedgerConsumeOrder(object):
|
|
|
logger.warning("[LedgerConsumeOrder] stats <{}> has been ledgered!".format(self._record))
|
|
|
return
|
|
|
|
|
|
- # if not self._record.ledger_enable:
|
|
|
- # logger.warning("[LedgerConsumeOrder] stats <{}> not allow ledger!".format(self._record))
|
|
|
- # return
|
|
|
+ if not self._record.ledger_enable:
|
|
|
+ logger.warning("[LedgerConsumeOrder] stats <{}> not allow ledger!".format(self._record))
|
|
|
+ return
|
|
|
|
|
|
# TODO 每日统计等等统计暂时不处理
|
|
|
|
|
@@ -465,3 +465,17 @@ class LedgerConsumeOrder(object):
|
|
|
source_key=self._source_key,
|
|
|
money=money
|
|
|
)
|
|
|
+
|
|
|
+
|
|
|
+class LedgerConsumeOrderRetry(LedgerConsumeOrder):
|
|
|
+
|
|
|
+ def _get_partition_map(self):
|
|
|
+ """
|
|
|
+ 重试的订单里面 分账单的partition就是之前的partition 不用也不能重新计算
|
|
|
+ """
|
|
|
+ return self._record.ledger.partition
|
|
|
+
|
|
|
+ def execute(self):
|
|
|
+ # 重置一下订单的 描述
|
|
|
+ self._record = self._record.set_description("")
|
|
|
+ super(LedgerConsumeOrderRetry, self).execute()
|