充值日统计

app/Console/Commands/Statistic/OptimizerMonthCharge.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace App\Console\Commands\Statistic;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+
+class OptimizerMonthCharge extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'Statistic:OptimizerMonthCharge {--month= : 统计月份}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '优化师充值月统计';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle(): void
+    {
+        //tj_optimizer_month_charge
+        $month = $this->option('month');
+        $monthStart = $month. '-01';
+        $montEnd = date_sub(date_add(date_create($monthStart),
+            date_interval_create_from_date_string('1 month')),
+            date_interval_create_from_date_string('1 day'))->format('Y-m-d');
+
+        $result = DB::table('tj_optimizer_day_charge')
+            ->whereBetween('day_at', [$monthStart, $montEnd])
+            ->select(
+                'user_id', 'miniprogram_id','puser_id',
+                DB::raw("sum(pay_money) as pay_money"),
+                DB::raw("sum(common_pay_count) as common_pay_count"),
+                DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                DB::raw("sum(vip_pay_count) as vip_pay_count"),
+            )->groupBy(['user_id', 'puser_id','miniprogram_id'])
+            ->get();
+        $insertData = [];
+        $now = date('Y-m-d H:i:s');
+        foreach ($result as $item) {
+            $info = (array)$item;
+            $info['created_at'] = $info['updated_at'] = $now;
+            $info['month_at'] = $month;
+            $insertData[] = $info;
+        }
+
+        DB::table('tj_optimizer_month_charge')
+            ->insert($insertData);
+    }
+}

app/Console/Commands/Statistic/PromotionDayCharge.php

@@ -39,41 +39,45 @@ class PromotionDayCharge extends Command
             ->chunk(100, function ($items) use ($date, &$optimizerDayData){
                 $promotionData = [];
                 $now = date('Y-m-d H:i:s');
-                $promotions = DB::table('promotions')->whereIn('id', $items->pluck('promotion_id'))
-                    ->select('id', 'uid', 'miniprogram_id')
+                $promotions = DB::table('promotions')
+                    ->leftJoin('users', 'users.id', '=' , 'promotions.uid')
+                    ->whereIn('promotions.id', $items->pluck('promotion_id'))
+                    ->select('promotions.id', 'promotions.uid', 'promotions.miniprogram_id', 'users.pid as puid')
                     ->get()->keyBy('id');
                 foreach ($items as $item) {
+                    $promotion = $promotions->get($item->promotion_id);
+                    if(!$promotion) {
+                        myLog('PromotionDayCharge')->error('订单中有的推广id,但是推广信息表中没有', ['promotion_id' => $item->promotion_id]);
+                        continue;
+                    }
                     $promotionDayCharge = $this->promotionDayCharge($item->promotion_id, $date);
                     $newUserCharge = $this->newUserCharge($item->promotion_id, $date);
                     $chargeInfo = $this->getPromotionData($promotionDayCharge, $newUserCharge);
                     $promotionData[] = array_merge( $chargeInfo, [
-                        'promotion_id' => $item->promotion_id, 'date' => $date,
+                        'promotion_id' => $item->promotion_id, 'day_at' => $date,
                         'created_at' => $now, 'updated_at' => $now,
+                        'user_id' => $promotion->uid,'puser_id' => $promotion->puid,
+                        'miniprogram_id' => $promotion->miniprogram_id,
                     ]);
-                    $promotion = $promotions->get($item->promotion_id);
-                    if(!$promotion) {
-                        myLog('PromotionDayCharge')->error('订单中有的推广id,但是推广信息表中没有', ['promotion_id' => $item->promotion_id]);
-                        continue;
-                    }
+
                     $key = $promotion->uid . '-'. $promotion->miniprogram_id;
                     foreach ($chargeInfo as $k => $v) {
                         $optimizerDayData[$key][$k] = $optimizerDayData[$key][$k] ?? 0 + $v;
                         $optimizerDayData[$key]['user_id'] = $promotion->uid;
+                        $optimizerDayData[$key]['puser_id'] = $promotion->puid;
                         $optimizerDayData[$key]['miniprogram_id'] = $promotion->miniprogram_id;
-                        $optimizerDayData[$key]['date'] = $date;
+                        $optimizerDayData[$key]['day_at'] = $date;
                         $optimizerDayData[$key]['created_at'] = $now;
                         $optimizerDayData[$key]['updated_at'] = $now;
                     }
                 }
-//                DB::table('tj_promotion_day_charge')
-//                    ->insert($promotionData);
-                dump($promotionData);
+                DB::table('tj_promotion_day_charge')
+                    ->insert($promotionData);
             });
 
         foreach (collect($optimizerDayData)->chunk(100) as $items) {
-//            DB::table('tj_optimizer_day_charge')
-//                ->insert($items->values()->toArray());
-            dump($items->values());
+            DB::table('tj_optimizer_day_charge')
+                ->insert($items->values()->toArray());
         }
     }
 

modules/Statistic/Http/Controllers/ChargeTJController.php

@@ -0,0 +1,246 @@
+<?php
+
+namespace Modules\Statistic\Http\Controllers;
+
+use Catch\Base\CatchController;
+use Illuminate\Foundation\Validation\ValidatesRequests;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
+use Modules\User\Http\Controllers\UserTrait;
+
+class ChargeTJController extends CatchController
+{
+    use ValidatesRequests;
+    use UserTrait;
+
+    private function _sql(Request $request) {
+        $this->validate($request, [
+            'start_at' => 'nullable|date_format:Y-m-d',
+            'end_at' => 'nullable|date_format:Y-m-d|after_or_equal:start_at',
+            'user_id' => 'nullable|integer|min:1',
+            'miniprogram_id' => 'nullable|integer|min:1'
+        ]);
+
+        $startAt = $request->input('start_at');
+        $endAt = $request->input('end_at');
+        $userId = $request->input('user_id');
+        $miniprogramId = $request->input('miniprogram_id');
+        $roles = $this->listUserRoles();
+        if($roles->contains('company')) {
+            $puserId = $this->getLoginUserId();
+        } else {
+            $puserId = null;
+            $userId = $this->getLoginUserId();
+        }
+
+        return  DB::table('tj_optimizer_day_charge')
+            ->when($startAt, function ($query, $startAt){
+                return $query->where('day_at', '>=', $startAt);
+            })->when($endAt, function ($query, $endAt){
+                return $query->where('day_at', '<=', $endAt);
+            })->when($userId, function ($query, $userId){
+                return $query->whereIn('user_id', $userId);
+            })->when($miniprogramId, function ($query, $miniprogramId) {
+                return $query->where('miniprogram_id', $miniprogramId);
+            })->when($puserId, function ($query, $puserId){
+                return $query->where('puser_id', $puserId);
+            });
+    }
+
+    // 充值明细
+    public function list(Request $request) {
+
+        $sql = $this->_sql($request);
+        $isExport = $request->input('is_export', false);
+
+        if($isExport) {
+            $result =  $sql->get();
+        } else {
+            $result =  $sql->paginate($request->input('limit', 15));
+        }
+
+        $users = DB::table('users')
+            ->whereIn('id', $result->pluck('user_id'))
+            ->select('id', 'username')
+            ->get()->keyBy('id');
+        $miniprograms = DB::table('miniprogram')
+            ->whereIn('id', $result->pluck('miniprogram_id'))
+            ->select('id','name')
+            ->get()->keyBy('id');
+
+        foreach ($result as $item) {
+            $item->common_pay_money_per = $item->common_pay_uv ? bcdiv($item->common_pay_money, $item->common_pay_uv ,2 ) : 0;
+            $item->vip_pay_money_per = $item->vip_pay_uv ? bcdiv($item->vip_pay_money, $item->vip_pay_uv ,2 ) : 0;
+            $item->common_pay_rate = $item->common_pay_count ? bcdiv(100 * ($item->common_pay_count + $item->common_unpay_count), $item->common_pay_count ,2 ) . '%' : 0 .'%';
+            $item->vip_pay_rate = $item->vip_pay_count ? bcdiv(100 * ($item->vip_pay_count + $item->vip_unpay_count), $item->vip_pay_count ,2 ) . '%' : 0 .'%';
+            $item->username = $users->get($item->user_id)->username ?? '';
+            $item->miniprogram_name = $miniprograms->get($item->miniprogram_id)->name ?? '';
+        }
+
+        return $result;
+    }
+
+    // 充值明细中的累计
+    public function listTotalCharge(Request $request) {
+        $sql = $this->_sql($request);
+        $info =  $sql->select(
+            DB::raw("sum(pay_money) as sum_pay_money"),
+            DB::raw("sum(pay_count) as sum_pay_count"),
+        )->first();
+        if($info) {
+            return [
+                'sum_pay_money' => $info->sum_pay_money,
+                'sum_pay_count' => $info->sum_pay_count,
+            ];
+        } else {
+            return [
+                'sum_pay_money' => 0,
+                'sum_pay_count' => 0,
+            ];
+        }
+    }
+
+    // 今日充值
+    public function todayCharge(Request $request) {
+        $date = date('Y-m-d');
+        $userId = $this->getLoginUserId();
+        if($this->listUserRoles()->contains('company')) {
+            $info = DB::table('orders')
+                ->whereBetween('created_at', [$date, $date. ' 23:59:59'])
+                ->where('puser_id', $userId)
+                ->select(
+                    DB::raw("sum(if(status = 'unpaid', 0, price)) as pay_money"),
+                    DB::raw("sum(if(status <> 'unpaid' and order_type in ('coin', 'first_coin'), 1, 0)) as common_pay_count"),
+                    DB::raw("sum(if(status = 'unpaid' and order_type in ('coin', 'first_coin'), 1, 0)) as common_unpay_count"),
+                    DB::raw("sum(if(status <> 'unpaid' and order_type not in ('coin', 'first_coin'), 1, 0)) as vip_pay_count"),
+                    DB::raw("sum(if(status = 'unpaid' and order_type not in ('coin', 'first_coin'), 1, 0)) as vip_unpay_count"),
+                )->first();
+        } else {
+            $info = DB::table('orders')
+                ->whereBetween('created_at', [$date, $date. ' 23:59:59'])
+                ->where('user_id', $userId)
+                ->where('miniprogram_id', $request->input('miniprogram_id'))
+                ->select(
+                    DB::raw("sum(if(status = 'unpaid', 0, price)) as pay_money"),
+                    DB::raw("sum(if(status <> 'unpaid' and order_type in ('coin', 'first_coin'), 1, 0)) as common_pay_count"),
+                    DB::raw("sum(if(status = 'unpaid' and order_type in ('coin', 'first_coin'), 1, 0)) as common_unpay_count"),
+                    DB::raw("sum(if(status <> 'unpaid' and order_type not in ('coin', 'first_coin'), 1, 0)) as vip_pay_count"),
+                    DB::raw("sum(if(status = 'unpaid' and order_type not in ('coin', 'first_coin'), 1, 0)) as vip_unpay_count"),
+                )->first();
+        }
+
+        if($info) {
+            $info->company_pay_rate = $info->common_pay_count ? bcdiv(($info->common_pay_count + $info->common_unpay_count) * 100, $info->common_pay_count, 2) . '%' : '0%';
+            $info->vip_pay_rate = $info->vip_pay_count ? bcdiv(($info->vip_pay_count + $info->vip_unpay_count) * 100, $info->vip_pay_count, 2) . '%' : '0%';
+        }
+        return $info;
+    }
+    // 本月充值
+    public function currentMonthCharge(Request $request) {
+        $userId = $this->getLoginUserId();
+        if($this->listUserRoles()->contains('company')) {
+            $info = DB::table('tj_optimizer_day_charge')
+                ->whereBetween('day_at', [date('Y-m-01'), date('Y-m-d', strtotime('yesterday'))])
+                ->where('puser_id', $userId)
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        } else {
+            $info = DB::table('tj_optimizer_day_charge')
+                ->whereBetween('day_at', [date('Y-m-01'), date('Y-m-d', strtotime('yesterday'))])
+                ->where('user_id', $userId)
+                ->where('miniprogram_id', $request->input('miniprogram_id'))
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        }
+        if($info) {
+            $info->company_pay_rate = $info->common_pay_count ? bcdiv(($info->common_pay_count + $info->common_unpay_count) * 100, $info->common_pay_count, 2) . '%' : '0%';
+            $info->vip_pay_rate = $info->vip_pay_count ? bcdiv(($info->vip_pay_count + $info->vip_unpay_count) * 100, $info->vip_pay_count, 2) . '%' : '0%';
+        }
+        return $info;
+    }
+    // 上月充值
+    public function lastMonthCharge(Request $request) {
+        $userId = $this->getLoginUserId();
+        if($this->listUserRoles()->contains('company')) {
+            $info = DB::table('tj_optimizer_month_charge')
+                ->where('month_at', date('Y-m-d', strtotime(date('Y-m-01')) - 10))
+                ->where('puser_id', $userId)
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        } else {
+            $info = DB::table('tj_optimizer_month_charge')
+                ->where('month_at', date('Y-m-d', strtotime(date('Y-m-01')) - 10))
+                ->where('user_id', $userId)
+                ->where('miniprogram_id', $request->input('miniprogram_id'))
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        }
+        if($info) {
+            $info->company_pay_rate = $info->common_pay_count ? bcdiv(($info->common_pay_count + $info->common_unpay_count) * 100, $info->common_pay_count, 2) . '%' : '0%';
+            $info->vip_pay_rate = $info->vip_pay_count ? bcdiv(($info->vip_pay_count + $info->vip_unpay_count) * 100, $info->vip_pay_count, 2) . '%' : '0%';
+        }
+        return $info;
+    }
+    // 累计充值
+    public function totalCharge(Request $request) {
+        $userId = $this->getLoginUserId();
+        if($this->listUserRoles()->contains('company')) {
+            $info = DB::table('tj_optimizer_month_charge')
+                ->where('month_at','<=', date('Y-m-d', strtotime(date('Y-m-01')) - 10))
+                ->where('puser_id', $userId)
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        } else {
+            $info = DB::table('tj_optimizer_month_charge')
+                ->where('month_at', '<=',date('Y-m-d', strtotime(date('Y-m-01')) - 10))
+                ->where('user_id', $userId)
+                ->where('miniprogram_id', $request->input('miniprogram_id'))
+                ->select(
+                    DB::raw("sum(pay_money) as pay_money"),
+                    DB::raw("sum(common_pay_count) as common_pay_count"),
+                    DB::raw("sum(common_unpay_count) as common_unpay_count"),
+                    DB::raw("sum(vip_unpay_count) as vip_unpay_count"),
+                    DB::raw("sum(vip_pay_count) as vip_pay_count"),
+                )->first();
+        }
+
+        $currentMonthInfo = $this->currentMonthCharge($request);
+
+        $result = (object)[
+            'pay_money' => $info->pay_money ?? 0 + $currentMonthInfo->pay_money ?? 0,
+            'common_pay_count' => $info->common_pay_count ?? 0 + $currentMonthInfo->common_pay_count ?? 0,
+            'common_unpay_count' => $info->common_unpay_count ?? 0 + $currentMonthInfo->common_unpay_count ?? 0,
+            'vip_unpay_count' => $info->vip_unpay_count ?? 0 + $currentMonthInfo->vip_unpay_count ?? 0,
+            'vip_pay_count' => $info->vip_pay_count ?? 0 + $currentMonthInfo->vip_pay_count ?? 0,
+        ];
+        $result->company_pay_rate = $result->common_pay_count ? bcdiv(($result->common_pay_count + $result->common_unpay_count) * 100, $result->common_pay_count, 2) . '%' : '0%';
+        $result->vip_pay_rate = $result->vip_pay_count ? bcdiv(($result->vip_pay_count + $result->vip_unpay_count) * 100, $result->vip_pay_count, 2) . '%' : '0%';
+
+        return $result;
+    }
+}