You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
155 lines
8.7 KiB
155 lines
8.7 KiB
<?php
|
|
|
|
namespace App\Admin\Repositories;
|
|
|
|
use App\Models\v3\Store as Model;
|
|
use Dcat\Admin\Grid\Model as GridModel;
|
|
use Dcat\Admin\Repositories\EloquentRepository;
|
|
use App\Models\StoreAccount as StoreAccountModel;
|
|
use App\Models\FinancialRecord0 as FinancialRecordModel0;
|
|
use App\Models\FinancialRecord1 as FinancialRecordModel1;
|
|
use App\Models\FinancialRecord2 as FinancialRecordModel2;
|
|
use App\Models\FinancialRecord3 as FinancialRecordModel3;
|
|
use App\Models\FinancialRecord4 as FinancialRecordModel4;
|
|
use Dcat\Admin\Layout\Row;
|
|
use Illuminate\Support\Facades\DB;
|
|
use App\Admin\Common\Type;
|
|
|
|
class StoreUserReport extends EloquentRepository
|
|
{
|
|
/**
|
|
* Model.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $eloquentClass = Model::class;
|
|
|
|
/**
|
|
* 获取统计列表数据
|
|
* 旧表流水数据未洗到新表，所以统计需要查询旧表和新表数据
|
|
*/
|
|
public function get(GridModel $model)
|
|
{
|
|
$this->setSort($model);
|
|
$this->setPaginate($model);
|
|
// 获取每页显示行数
|
|
$perPage = $model->getPerPage();
|
|
$startTime = $params['start_time'] ?? request()->input('start_time','');
|
|
$endTime = $params['end_time'] ?? request()->input('end_time','');
|
|
$marketId = $params['market_id'] ?? request()->input('market_id',0);
|
|
$storeId = $params['store_id'] ?? request()->input('store_id',[]);
|
|
$storeIds = $params['store_ids'] ?? request()->input('store_ids','');
|
|
|
|
/* 根据流水查询 2020-08-18 用全匹配文字方式查询新用户 旧表 */
|
|
$storeAccount = StoreAccountModel::join(Model::$tableName.' as store',StoreAccountModel::$tableName.'.store_id','store.id')
|
|
->select('store_id','store.name as store_name','store.market_id',DB::raw("count(distinct ".StoreAccountModel::$tableName.".id) as new_user_total"))
|
|
->whereRaw("note = '新用户下单成功，平台奖励'")
|
|
->groupBy('store_id');
|
|
|
|
/* 根据流水查询 2020-10-29 用类型字段查询新用户 新表 */
|
|
$financial0 = Model::select(Model::$tableName.'.id as store_id',Model::$tableName.'.name as store_name','market_id',DB::raw('count(distinct f0.id) as new_user_total'))
|
|
->join(FinancialRecordModel0::$tableName.' as f0',Model::$tableName.'.user_id','=','f0.user_id','left')
|
|
->whereRaw(Model::$tableName.'.user_id MOD 5 = 0')
|
|
->whereRaw('user_type ='.Type::USER_TYPE_STORE)
|
|
->whereRaw('source_type = '.Type::SOURCE_TYPE_ORDER)
|
|
->whereRaw('money_type = '.Type::MONEY_TYPE_STORE_PLAT_NEW_USER)
|
|
->whereRaw('f0.created_at > 1600444800')
|
|
->groupBy('store_id','store_name','market_id');
|
|
|
|
$financial1 = Model::select(Model::$tableName.'.id as store_id',Model::$tableName.'.name as store_name','market_id',DB::raw('count(distinct f1.id) as new_user_total'))
|
|
->join(FinancialRecordModel1::$tableName.' as f1',Model::$tableName.'.user_id','=','f1.user_id','left')
|
|
->whereRaw(Model::$tableName.'.user_id MOD 5 = 1')
|
|
->whereRaw('user_type ='.Type::USER_TYPE_STORE)
|
|
->whereRaw('source_type = '.Type::SOURCE_TYPE_ORDER)
|
|
->whereRaw('money_type = '.Type::MONEY_TYPE_STORE_PLAT_NEW_USER)
|
|
->whereRaw('f1.created_at > 1600444800')
|
|
->groupBy('store_id','store_name','market_id');
|
|
|
|
$financial2 = Model::select(Model::$tableName.'.id as store_id',Model::$tableName.'.name as store_name','market_id',DB::raw('count(distinct f2.id) as new_user_total'))
|
|
->join(FinancialRecordModel2::$tableName.' as f2',Model::$tableName.'.user_id','=','f2.user_id','left')
|
|
->whereRaw(Model::$tableName.'.user_id MOD 5 = 2')
|
|
->whereRaw('user_type ='.Type::USER_TYPE_STORE)
|
|
->whereRaw('source_type = '.Type::SOURCE_TYPE_ORDER)
|
|
->whereRaw('money_type = '.Type::MONEY_TYPE_STORE_PLAT_NEW_USER)
|
|
->whereRaw('f2.created_at > 1600444800')
|
|
->groupBy('store_id','store_name','market_id');
|
|
|
|
$financial3 = Model::select(Model::$tableName.'.id as store_id',Model::$tableName.'.name as store_name','market_id',DB::raw('count(distinct f3.id) as new_user_total'))
|
|
->join(FinancialRecordModel3::$tableName.' as f3',Model::$tableName.'.user_id','=','f3.user_id','left')
|
|
->whereRaw(Model::$tableName.'.user_id MOD 5 = 3')
|
|
->whereRaw('user_type ='.Type::USER_TYPE_STORE)
|
|
->whereRaw('source_type = '.Type::SOURCE_TYPE_ORDER)
|
|
->whereRaw('money_type = '.Type::MONEY_TYPE_STORE_PLAT_NEW_USER)
|
|
->whereRaw('f3.created_at > 1600444800')
|
|
->groupBy('store_id','store_name','market_id');
|
|
|
|
$financial4 = Model::select(Model::$tableName.'.id as store_id',Model::$tableName.'.name as store_name','market_id',DB::raw('count(distinct f4.id) as new_user_total'))
|
|
->join(FinancialRecordModel4::$tableName.' as f4',Model::$tableName.'.user_id','=','f4.user_id','left')
|
|
->whereRaw(Model::$tableName.'.user_id MOD 5 = 4')
|
|
->whereRaw('user_type ='.Type::USER_TYPE_STORE)
|
|
->whereRaw('source_type = '.Type::SOURCE_TYPE_ORDER)
|
|
->whereRaw('money_type = '.Type::MONEY_TYPE_STORE_PLAT_NEW_USER)
|
|
->whereRaw('f4.created_at > 1600444800')
|
|
->groupBy('store_id','store_name','market_id');
|
|
|
|
if($startTime){
|
|
$startTime = $startTime.' 00:00:00';
|
|
$storeAccount->whereRaw(StoreAccountModel::$tableName.".time >= '".$startTime."'");
|
|
$financial0->whereRaw('f0.created_at >='.strtotime($startTime));
|
|
$financial1->whereRaw('f1.created_at >='.strtotime($startTime));
|
|
$financial2->whereRaw('f2.created_at >='.strtotime($startTime));
|
|
$financial3->whereRaw('f3.created_at >='.strtotime($startTime));
|
|
$financial4->whereRaw('f4.created_at >='.strtotime($startTime));
|
|
}
|
|
if($endTime){
|
|
$endTime = $endTime.' 23:59:59';
|
|
$storeAccount->whereRaw(StoreAccountModel::$tableName.".time <='".$endTime."'");
|
|
$financial0->whereRaw('f0.created_at <='.strtotime($endTime));
|
|
$financial1->whereRaw('f1.created_at <='.strtotime($endTime));
|
|
$financial2->whereRaw('f2.created_at <='.strtotime($endTime));
|
|
$financial3->whereRaw('f3.created_at <='.strtotime($endTime));
|
|
$financial4->whereRaw('f4.created_at <='.strtotime($endTime));
|
|
}
|
|
if($marketId){
|
|
$storeAccount->whereRaw('store.market_id ='.$marketId);
|
|
$financial0->whereRaw(Model::$tableName.'.market_id ='.$marketId);
|
|
$financial1->whereRaw(Model::$tableName.'.market_id ='.$marketId);
|
|
$financial2->whereRaw(Model::$tableName.'.market_id ='.$marketId);
|
|
$financial3->whereRaw(Model::$tableName.'.market_id ='.$marketId);
|
|
$financial4->whereRaw(Model::$tableName.'.market_id ='.$marketId);
|
|
}
|
|
if($storeId){
|
|
$storeStr = implode(',',$storeId);
|
|
$storeAccount->whereRaw('store.id in('. $storeStr.')');
|
|
$financial0->whereRaw(Model::$tableName.'.id in('. $storeStr.')');
|
|
$financial1->whereRaw(Model::$tableName.'.id in('. $storeStr.')');
|
|
$financial2->whereRaw(Model::$tableName.'.id in('. $storeStr.')');
|
|
$financial3->whereRaw(Model::$tableName.'.id in('. $storeStr.')');
|
|
$financial4->whereRaw(Model::$tableName.'.id in('. $storeStr.')');
|
|
}
|
|
if($storeIds){
|
|
$storeIds = trim($storeIds,',');
|
|
$expression = "/^[,0-9]+$/u";
|
|
preg_match($expression,$storeIds,$matches);
|
|
$storeIds = $matches[0] ?? 0;
|
|
|
|
$storeAccount->whereRaw('store.id in('. $storeIds.')');
|
|
$financial0->whereRaw(Model::$tableName.'.id in('. $storeIds.')');
|
|
$financial1->whereRaw(Model::$tableName.'.id in('. $storeIds.')');
|
|
$financial2->whereRaw(Model::$tableName.'.id in('. $storeIds.')');
|
|
$financial3->whereRaw(Model::$tableName.'.id in('. $storeIds.')');
|
|
$financial4->whereRaw(Model::$tableName.'.id in('. $storeIds.')');
|
|
}
|
|
|
|
$unionAll = $storeAccount->union($financial0)->union($financial1)->union($financial2)->union($financial3)->union($financial4);
|
|
$query = DB::table(Db::raw("({$unionAll->toSql()}) as a1"))
|
|
->select('a1.store_id','a1.store_name','a1.market_id',DB::raw('SUM(a1.new_user_total) as new_total'))
|
|
->groupBy('market_id','store_id','store_name')
|
|
->orderBy('new_total','desc')->paginate($perPage);
|
|
|
|
$query = $query->toArray();
|
|
|
|
$query = $model->makePaginator($query['total'],$query['data']);
|
|
return $query;
|
|
}
|
|
}
|