diff --git a/app/listener/AfterRefund.php b/app/listener/AfterRefund.php index b434e303..50424fcd 100644 --- a/app/listener/AfterRefund.php +++ b/app/listener/AfterRefund.php @@ -9,6 +9,7 @@ use app\common\model\system\merchant\FinancialRecord; use app\common\model\system\serve\ServeOrder; use app\common\repositories\system\merchant\FinancialRecordRepository; use app\common\repositories\system\merchant\MerchantRepository; +use think\facade\Log; /** * 订单退款之后,退佣金 @@ -20,8 +21,10 @@ class AfterRefund public function handle($event) { + Log::info('refundCommissionStart'); $this->refundOrder = $event['res']; $financialRecords = FinancialRecord::getInstance()->where('order_id', $this->refundOrder['order_id'])->select(); + Log::info('refundCommissionCount:' . count($financialRecords)); foreach ($financialRecords as $financialRecord) { if (in_array($financialRecord['financial_type'], ['commission_to_cloud_warehouse', 'commission_to_entry_merchant', 'commission_to_service_team', 'commission_to_village', 'commission_to_town', ])) { //佣金类型的退还佣金 @@ -29,6 +32,7 @@ class AfterRefund $this->saveFinanceRecord($financialRecord); } if ($financialRecord['financial_type'] == 'auto_margin') { + Log::info("refundMargin, mer_id: {$financialRecord['mer_id']}, money: {$financialRecord['number']}"); //佣金类型的扣除保证金 ServeOrder::getInstance()->where('store_order_id', $financialRecord['order_id'])->update(['is_del' => 1]); $merchant = app()->make(MerchantDao::class)->get($financialRecord['mer_id']); @@ -41,10 +45,12 @@ class AfterRefund $this->saveFinanceRecord($financialRecord); } } + Log::info('refundCommissionEnd'); } public function subMoney($financialRecord) { + Log::info("refundCommission, mer_id: {$financialRecord['mer_id']}, money: {$financialRecord['number']}"); /** @var MerchantRepository $merchantRepository */ $merchantRepository = app()->make(MerchantRepository::class); $merchantRepository->subLockMoney($financialRecord['mer_id'], 'order', $this->refundOrder['order_id'], (float)$financialRecord['number']);