From d8a60832479ad16c45e685a997b959762f8c4442 Mon Sep 17 00:00:00 2001 From: mkm <727897186@qq.com> Date: Wed, 3 Jan 2024 15:02:44 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../store/order/StoreOtherOrderRepository.php | 2 +- app/event.php | 1 + app/listener/paySuccessOrderOther.php | 137 ++++++++++++++++++ 3 files changed, 139 insertions(+), 1 deletion(-) create mode 100644 app/listener/paySuccessOrderOther.php diff --git a/app/common/repositories/store/order/StoreOtherOrderRepository.php b/app/common/repositories/store/order/StoreOtherOrderRepository.php index 214891b5..355c6a7b 100644 --- a/app/common/repositories/store/order/StoreOtherOrderRepository.php +++ b/app/common/repositories/store/order/StoreOtherOrderRepository.php @@ -240,7 +240,7 @@ class StoreOtherOrderRepository extends BaseRepository $_payPrice = bcsub($_payPrice, $_order_rate, 2); // 结算各镇 小组佣金 - event('order.paySuccessOrder', compact('order', '_order_rate')); + event('order.paySuccessOrderOther', compact('order', '_order_rate')); } if (!$presell) { diff --git a/app/event.php b/app/event.php index 30312949..039bcf71 100644 --- a/app/event.php +++ b/app/event.php @@ -66,6 +66,7 @@ return [ 'pay_success_meal' => [\crmeb\listens\pay\MealSuccessListen::class], // 'community_address'=>[\app\listener\CommunityAddress::class], 'order.paySuccessOrder'=>[\app\listener\paySuccessOrder::class], + 'order.paySuccessOrderOther'=>[\app\listener\paySuccessOrderOther::class], 'order.paySuccess'=>[\app\listener\paySuccess::class], 'pay_success_margin'=>[\app\listener\paySuccessMargin::class], 'order.sendGoodsCode'=>[\app\listener\SendGoodsCode::class], diff --git a/app/listener/paySuccessOrderOther.php b/app/listener/paySuccessOrderOther.php new file mode 100644 index 00000000..cf1539c0 --- /dev/null +++ b/app/listener/paySuccessOrderOther.php @@ -0,0 +1,137 @@ +event = $event; + $this->finance = []; + $this->index = 1; + Db::startTrans(); + try { + $financialRecordRepository = app()->make(FinancialRecordRepository::class); + $this->financeSn = $financialRecordRepository->getSn(); + $merchant = Merchant::find($event['order']['mer_id']); + + if (!$merchant || $merchant['street_id'] == 0) { + throw new \Exception('商户地址不存在', 200); + } + $this->streetId = $merchant['street_id']; + + $commission_rate = ($event['order']['commission_rate'] / 100); + //该笔订单平台总手续费 + $realPrice = bcsub((string)$event['order']['total_price'], (string)$event['order']['extension_one'], 2); + $realPrice = bcsub($realPrice, (string)$event['order']['extension_two'], 2); + $this->totalAmount = bcmul($realPrice, (string)$commission_rate, 2); + $this->remain = $this->totalAmount; + + // $typeTownServerId = Db::name('MerchantType')->where('type_code', Merchant::TypeCode['TypeTownServer'])->value('mer_type_id'); + // $typeVillageServerId = Db::name('MerchantType')->where('type_code', Merchant::TypeCode['TypeVillageServer'])->value('mer_type_id'); + // $typeTeamServerId = Db::name('MerchantType')->where('type_code', Merchant::TypeCode['TypeTeamServer'])->value('mer_type_id'); + + // //镇团队佣金 + // $this->calculate($typeTownServerId, 'commission_to_town_rate'); + // //村团队佣金 + // $this->calculate($typeVillageServerId, 'commission_to_village_rate'); + // //小组服务团队佣金 + // $this->calculate($typeTeamServerId, 'commission_to_service_team_rate'); + + if ($this->remain > 0) { + //平台佣金 + $this->finance[] = [ + 'order_id' => $this->event['order']['order_id'], + 'order_sn' => $this->event['order']['order_sn'], + 'user_info' => $this->event['order']->user->nickname, + 'user_id' => $this->event['order']['uid'], + 'financial_type' => 'commission_to_platform', + 'financial_pm' => 1, + 'type' => 1, + 'number' => $this->remain, + 'mer_id' => 0, + 'financial_record_sn' => $this->financeSn . $this->index + ]; + } + + if ($financialRecordRepository->insertAll($this->finance) === false) { + throw new \Exception('财务流水保存出错'); + } + Db::commit(); + } catch (\Exception $e) { + if ($e->getCode() == 200) { + Db::commit(); + } else { + Db::rollback(); + } + Log::error('订单分润出错', ['code' => $e->getCode(), 'message' => $e->getMessage(), 'trace' => $e->getTraceAsString()]); + DingTalk::exception($e, '订单分润出错'); + } + } + + public function calculate($type, $field) + { + $merId = Db::name('merchant')->where('type_id', $type) + ->where('street_id', $this->streetId) + ->where('status', 1) + ->where('mer_state', 1) + ->value('mer_id'); + $rate = systemConfig($field); + $typeName = Merchant::TypeMap[$type]; + if (empty($merId) || $rate <= 0) { + Log::info("订单分佣：没有 $typeName 或比例为0"); + return false; + } + $financialTypeMap = [ + 'commission_to_town_rate' => 'town', + 'commission_to_village_rate' => 'village', + 'commission_to_service_team_rate' => 'service_team', + 'commission_to_cloud_rate' => 'cloud_warehouse', + ]; + $amount = bcmul($this->totalAmount, (string)($rate / 100), 2); + if ($amount <= 0) { + Log::info("订单分佣：$typeName 佣金为0"); + return false; + } + $this->remain = bcsub($this->remain, $amount, 2); + $this->finance[] = [ + 'order_id' => $this->event['order']['order_id'], + 'order_sn' => $this->event['order']['order_sn'], + 'user_info' => $this->event['order']->user->nickname, + 'user_id' => $this->event['order']['uid'], + 'financial_type' => 'commission_to_' . $financialTypeMap[$field], + 'financial_pm' => 1, + 'type' => 1, + 'number' => $amount, + 'mer_id' => $merId, + 'financial_record_sn' => $this->financeSn . $this->index + ]; + $this->index++; + app()->make(MerchantRepository::class)->addLockMoney($merId, 'order', $this->event['order']['order_id'], (float)$amount); + return true; + } + +} \ No newline at end of file