mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
mkm 2024-01-03 15:02:44 +08:00
parent 4cf5366fdc
commit d8a6083247
3 changed files with 139 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/common/repositories/store/order/StoreOtherOrderRepository.php
View File

@ -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) {

1
app/event.php
View File

@ -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],

137
app/listener/paySuccessOrderOther.php Normal file
View File

@ -0,0 +1,137 @@
<?php
declare (strict_types=1);
namespace app\listener;
use app\common\dao\store\order\StoreCartDao;
use app\common\dao\system\merchant\MerchantDao;
use app\common\model\system\merchant\Merchant;
use app\common\repositories\store\order\StoreOrderRepository;
use app\common\repositories\system\merchant\FinancialRecordRepository;
use app\common\repositories\system\merchant\MerchantRepository;
use crmeb\utils\DingTalk;
use think\facade\Db;
use think\facade\Log;
/**
* 支付后逻辑
*/
class paySuccessOrderOther
{
public $totalAmount;
public $event;
public $finance = [];
public $streetId;
public $financeSn;
public $index = 1;
public $remain;
public function handle($event)
{
Log::info('b到b支付后逻辑22323233');
$this->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;
}
}