新增pv&商户分润统计

app/common/repositories/finance/FinanceRepository.php

@@ -468,6 +468,7 @@ class FinanceRepository extends BaseRepository
         $query1 = clone $query;
         $query2 = clone $query;
         $query3 = clone $query;
+        $query4 = clone $query;
         $data['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
             ->field('ub.bill_id,ub.title,ub.number,ub.mark,ub.take_time,ub.commission_type,u.uid,u.phone,u.nickname,u.user_group,ub.order_sn,ub.take_time,ub.status,ub.create_time')
             ->order('ub.bill_id', 'desc')
@@ -489,7 +490,9 @@ class FinanceRepository extends BaseRepository
         $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '佣金奖励总额'];
         $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[1] ?? 0), 'name' => '已结算佣金'];
         $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[0] ?? 0), 'name' => '未结算佣金'];
-        $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(0), 'name' => '佣金转VR'];
+        $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[-1] ?? 0), 'name' => '已失效佣金'];
+        $transition_vr = Db::name('user_transition_vr')->where('type', 1)->sum('number');
+        $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($transition_vr), 'name' => '佣金转VR'];
         $user_extra_money = Db::name('user_extract')->where('status', 1)->sum('extract_price');
         $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现佣金'];
         $data['statistics'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现金额'];
@@ -510,6 +513,8 @@ class FinanceRepository extends BaseRepository
         $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[1] ?? 0), 'name' => '已结算养老金'];
         $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[0] ?? 0), 'name' => '未结算养老金'];
         $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[-1] ?? 0), 'name' => '已失效养老金'];
+        $gzc_number = $query4->where('ub.gzc', 1)->sum('ub.number');
+        $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($gzc_number ?? 0), 'name' => '已入账养老金'];
         return $data;
     }
 
@@ -793,7 +798,7 @@ class FinanceRepository extends BaseRepository
         $page = input('page');
         $limit = input('limit');
         $where = request()->params(['date']);
-        $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
+        $params = request()->params(['commission_type', 'type', 'uid', 'pm', 'phone','status']);
 
         if($params['status'] == 99){
             unset($params['status']);
@@ -820,6 +825,9 @@ class FinanceRepository extends BaseRepository
         })
         ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
             $query->where('type', $params['type']);
+        })        
+        ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
+            $query->where('uss.commission_type', $params['commission_type']);
         });
         $query1 = clone $query;
         $query2 = clone $query;
@@ -829,7 +837,7 @@ class FinanceRepository extends BaseRepository
         $query6 = clone $query;
         $query7 = clone $query;
         $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
-            ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
+            ->field('uss.id,uss.addtime,uss.commission_type,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
             ->page($page, $limit)
             ->order('uss.id', 'desc')
             ->select()
@@ -975,6 +983,130 @@ class FinanceRepository extends BaseRepository
 
 
 
+     /**
+     * PV统计
+     * @return mixed
+     */
+    public function pv_list($mer_id = 0)
+    {
+        $page = input('page');
+        $limit = input('limit');
+        $where = request()->params(['date']);
+        $params = request()->params([ 'uid', 'pm', 'phone','status']);
+
+        if($params['status'] == 99){
+            unset($params['status']);
+            $params['type'] = 2;
+        }
+
+        $date = [];
+        //商户ID
+        $query = Db::name('user_pv_log')
+        ->alias('uss')
+        ->leftJoin('user u', 'u.uid=uss.uid')
+        ->leftJoin('store_order o', 'o.order_id=uss.order_id')
+        ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
+            $query->where('uss.uid', $params['uid']);
+        })
+        ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
+            $query->where('uss.status', $params['status']);
+        })
+        ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
+            $query->whereLike('u.phone', '%' . $params['phone'] . '%');
+        });
+        // ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
+        //     $query->where('type', $params['type']);
+        // });
+        $query1 = clone $query;
+        $query2 = clone $query;
+        $query3 = clone $query;
+        $query4 = clone $query;
+        $query5 = clone $query;
+        $query6 = clone $query;
+        $query7 = clone $query;
+        $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
+            ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pv,o.order_sn,uss.status,uss.mark,u.score')
+            ->page($page, $limit)
+            ->order('uss.id', 'desc')
+            ->select()
+            ->each(function ($item) {
+                $item['mark'] = $item['mark'];
+                $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
+                return $item;
+            });
+        $date['count'] = $query->count();
+        $date['statistics']['all'] = decimal2($query1->sum('uss.pv'));//平台PV总数
+        $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('uss.pv'));//已结算PV总数
+        $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('uss.pv'));//未结算PV总数
+        $date['statistics']['lost'] = decimal2($query4->where('uss.status', 2)->sum('uss.pv'));//已失效PV总数
+        $date['statistics']['deduct'] = decimal2($query4->where('uss.status', 2)->sum('uss.pv'));//已结算红包总额
+        $date['statistics']['all_mp1'] = decimal2($query4->where('uss.status', 2)->sum('uss.pv'));//可分红PV数
+ 
+        return $date;
+    }
+
+
+
+
+    /**
+     * 商户分润统计
+     * @return mixed
+     */
+    public function fenrun_list($mer_id = 0)
+    {
+        $page = input('page');
+        $limit = input('limit');
+        $where = request()->params(['date']);
+        $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
+
+        if($params['status'] == 99){
+            unset($params['status']);
+            $params['type'] = 2;
+        }
+
+        $date = [];
+        //商户ID
+        $query = Db::name('user_sign_fenrun')
+        ->alias('uss')
+        ->leftJoin('user u', 'u.uid=uss.uid')
+        ->leftJoin('store_order o', 'o.order_id=uss.order_id')
+        ->leftJoin('merchant m', 'm.mer_id=o.mer_id')
+        ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
+            $query->where('uss.uid', $params['uid']);
+        })
+        ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
+            $query->where('uss.status', $params['status']);
+        })
+        ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
+            $query->whereLike('u.phone', '%' . $params['phone'] . '%');
+        });
+        $query1 = clone $query;
+        $query2 = clone $query;
+        $query3 = clone $query;
+        $query4 = clone $query;
+        $query5 = clone $query;
+        $query6 = clone $query;
+        $query7 = clone $query;
+        $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
+            ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,o.total_price,uss.status,uss.mark,u.score,m.mer_name')
+            ->page($page, $limit)
+            ->order('uss.id', 'desc')
+            ->select()
+            ->each(function ($item) {
+                $item['mark'] = $item['mark'];
+                $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
+                return $item;
+            });
+        $date['count'] = $query->count();
+        $date['statistics']['all'] = decimal2($query1->sum('number'));
+        $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));//已结算
+        $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));//未结算
+        $date['statistics']['lost'] = decimal2($query4->where('uss.status', 2)->sum('number'));//已失效
+ 
+        return $date;
+    }
+
+
 
     /**
      * 列表中的时间条件

app/controller/admin/finance/Finance.php

@@ -136,6 +136,41 @@ class Finance extends BaseController
 
 
 
+    /**
+     * PV统计
+     * @return mixed
+     */
+    public function pv_list(){
+        try {
+            $financeRepository = app()->make(FinanceRepository::class);
+            $date = $financeRepository->pv_list();
+            return app('json')->success($date);
+        } catch (\Exception $e) {
+            Db::name('log')->insert(['data' => 'PV统计错误：' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】']);
+            return app('json')->fail('PV统计失败' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】');
+        }
+    }
+
+
+
+
+    /**
+     * 商户分润统计
+     * @return mixed
+     */
+    public function fenrun_list(){
+        try {
+            $financeRepository = app()->make(FinanceRepository::class);
+            $date = $financeRepository->fenrun_list();
+            return app('json')->success($date);
+        } catch (\Exception $e) {
+            Db::name('log')->insert(['data' => '商户分润统计错误：' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】']);
+            return app('json')->fail('商户分润统计失败' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】');
+        }
+    }
+
+
+
 
     /**
      * 佣金统计

route/admin.php

@@ -865,6 +865,8 @@ Route::group(config('admin.api_admin_prefix') . '/', function () {
             Route::get('fugou_list', '/fugou_list');
             Route::get('hongbao_list', '/hongbao_list');
             Route::get('vr_list', '/vr_list');
+            Route::get('pv_list', '/pv_list');
+            Route::get('fenrun_list', '/fenrun_list');
             Route::get('day_bill/list', '/day_bill_list');
             Route::get('month_bill/list', '/month_bill_list');