From 7b5a10306a20f4f7f54e12591b9cee8632818cc7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=9D=99?= Date: Sat, 15 Jan 2022 15:33:16 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E7=AE=A1=E7=90=86=E6=B4=A5?= =?UTF-8?q?=E8=B4=B4=E7=BB=93=E7=AE=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Dealer/ManageSubsidySettleCommand.php | 89 ++++++++++++------- app/Models/Dealer.php | 8 ++ ...15_115032_create_dealer_earnings_table.php | 2 +- 3 files changed, 65 insertions(+), 34 deletions(-) diff --git a/app/Console/Commands/Dealer/ManageSubsidySettleCommand.php b/app/Console/Commands/Dealer/ManageSubsidySettleCommand.php index 68ba5200..75f0821a 100644 --- a/app/Console/Commands/Dealer/ManageSubsidySettleCommand.php +++ b/app/Console/Commands/Dealer/ManageSubsidySettleCommand.php @@ -4,12 +4,12 @@ namespace App\Console\Commands\Dealer; use App\Enums\DealerEarningStatus; use App\Enums\DealerEarningType; +use App\Enums\DealerLvl; +use App\Models\Dealer; use App\Models\DealerEarning; -use App\Models\DealerManageSubsidyLog; use Illuminate\Console\Command; use Illuminate\Support\Carbon; use Illuminate\Support\Facades\Cache; -use Illuminate\Support\Facades\DB; class ManageSubsidySettleCommand extends Command { @@ -54,7 +54,7 @@ class ManageSubsidySettleCommand extends Command $endAt = $tz->copy()->setDay(19)->endOfDay(); } elseif ($tz->day >= 5) { $startAt = $tz->copy()->subMonthNoOverflow()->set('day', 20)->startOfDay(); - $endAt = $tz->copy()->set('day', 4)->endOfDay(); + $endAt = $tz->copy()->set('day', 24)->endOfDay(); } else { $startAt = $tz->copy()->subMonthNoOverflow()->setDay(5)->startOfDay(); $endAt = $startAt->copy()->subMonthNoOverflow()->setDay(19)->endOfDay(); @@ -81,7 +81,7 @@ class ManageSubsidySettleCommand extends Command $this->info("{$head}------------[结束]管理津贴结算------------".PHP_EOL); - Cache::put($this->cacheKey($startAt, $endAt), 1, 24*3600*22); + Cache::put($this->cacheKey($startAt, $endAt), 1, $endAt->tomorrow()); return 0; } @@ -91,45 +91,68 @@ class ManageSubsidySettleCommand extends Command * * @param \Illuminate\Support\Carbon $startAt * @param \Illuminate\Support\Carbon $endAt + * @param int $count * @return void */ - protected function settle(Carbon $startAt, Carbon $endAt): void + protected function settle(Carbon $startAt, Carbon $endAt, $count = 500): void { - $subsidies = DealerManageSubsidyLog::select('user_id', DB::raw('sum(total_amount) as total_amount')) - ->whereBetween('order_completed_at', [$startAt, $endAt]) - ->groupBy('user_id') - ->get(); - - // 手续费比例（百分比） - $time = now()->toDateTimeString(); $feeRate = app_settings('dealer.fee_rate'); - $data = []; - foreach ($subsidies as $key => $subsidy) { - if ($key > 0 && $key%500 === 0) { - DealerEarning::insert($data); + $lastId = Cache::get( + $key = $this->cacheKey($startAt, $endAt).':last_id' + ); - $data = []; - $time = now()->toDateTimeString(); + do { + $dealers = Dealer::where('lvl', '>=', DealerLvl::Contracted) + ->forPageAfterId($count, $lastId, 'id') + ->get(); + + $countDealers = $dealers->count(); + + if ($countDealers == 0) { + break; } - $fee = bcmul(bcdiv($feeRate, '100', 10), $subsidy->total_amount, 3); + $earnings = []; + $time = now()->toDateTimeString(); - $data[] = [ - 'user_id' => $subsidy->user_id, - 'total_amount' => $subsidy->total_amount, - 'fee' => $fee, - 'fee_rate' => $feeRate, - 'type' => DealerEarningType::ManageSubsidy, - 'start_at' => $startAt, - 'end_at' => $endAt, - 'status' => DealerEarningStatus::Pending, - 'created_at' => $time, - 'updated_at' => $time, - ]; - } + foreach ($dealers as $dealer) { + $totalAmount = $dealer->manageSubsidyLogs() + ->whereBetween('order_completed_at', [$startAt, $endAt]) + ->sum('total_amount'); - DealerEarning::insert($data); + if (bccomp($totalAmount, '0', 2) === 1) { + // 计算手续费 + $fee = bcmul($totalAmount, bcdiv($feeRate, '100', 10), 2); + + $earnings[] = [ + 'user_id' => $dealer->user_id, + 'total_amount' => $totalAmount, + 'fee' => $fee, + 'fee_rate' => $feeRate, + 'type' => DealerEarningType::ManageSubsidy, + 'start_at' => $startAt, + 'end_at' => $endAt, + 'lvl' => $dealer->lvl, + 'is_manager' => $dealer->is_manager, + 'status' => DealerEarningStatus::Pending, + 'description' => '管理津贴', + 'created_at' => $time, + 'updated_at' => $time, + ]; + } + + $lastId = $dealer->id; + } + + DealerEarning::insert($earnings); + + Cache::put($key, $lastId, $endAt); + + unset($dealers, $earnings); + } while ($countDealers == $count); + + Cache::forget($key); } /** diff --git a/app/Models/Dealer.php b/app/Models/Dealer.php index 514cd622..41e57b2a 100644 --- a/app/Models/Dealer.php +++ b/app/Models/Dealer.php @@ -36,6 +36,14 @@ class Dealer extends Model return $this->hasMany(DealerManagerSalesLog::class, 'user_id', 'user_id'); } + /** + * 属于此经销商的管理者津贴 + */ + public function manageSubsidyLogs() + { + return $this->hasMany(DealerManageSubsidyLog::class, 'user_id', 'user_id'); + } + public function getLvlTextAttribute() { return $this->lvl->text(); diff --git a/database/migrations/2022_01_15_115032_create_dealer_earnings_table.php b/database/migrations/2022_01_15_115032_create_dealer_earnings_table.php index 8068ccf7..accf32b4 100644 --- a/database/migrations/2022_01_15_115032_create_dealer_earnings_table.php +++ b/database/migrations/2022_01_15_115032_create_dealer_earnings_table.php @@ -26,7 +26,7 @@ class CreateDealerEarningsTable extends Migration $table->timestamp('completed_at')->nullable()->comment('完成时间'); $table->timestamps(); - $table->unique(['user_id', 'start_at', 'end_at']); + $table->unique(['user_id', 'type', 'start_at', 'end_at']); $table->index(['start_at', 'end_at']); $table->index('type'); });