diff --git a/.htaccess b/.htaccess
index dd7fb824..54df6e97 100644
--- a/.htaccess
+++ b/.htaccess
@@ -1,8 +1,7 @@
-Options +FollowSymlinks -Multiviews
-RewriteEngine on
-
-RewriteCond %{REQUEST_FILENAME} !-d
-RewriteCond %{REQUEST_FILENAME} !-f
-RewriteRule ^(.*)$ index.php?/$1 [QSA,PT,L]
+ Options +FollowSymlinks -Multiviews
+ RewriteEngine On
+ RewriteCond %{REQUEST_FILENAME} !-d
+ RewriteCond %{REQUEST_FILENAME} !-f
+ RewriteRule ^(.*)$ index.php/$1 [QSA,PT,L]
\ No newline at end of file
diff --git a/application/admin/controller/finance/UserExtract.php b/application/admin/controller/finance/UserExtract.php
index 91fce337..0fb1b66f 100644
--- a/application/admin/controller/finance/UserExtract.php
+++ b/application/admin/controller/finance/UserExtract.php
@@ -83,6 +83,10 @@ class UserExtract extends AuthController
{
if(!UserExtractModel::be(['id'=>$id,'status'=>0])) return JsonService::fail('操作记录不存在或状态错误!');
$fail_msg =$request->post();
+ $extract=UserExtractModel::get($id);
+ if(!$extract) return JsonService::fail('操作记录不存在!');
+ if($extract->status==1) return JsonService::fail('已经提现,错误操作');
+ if($extract->status==-1) return JsonService::fail('您的提现申请已被拒绝,请勿重复操作!');
$res = UserExtractModel::changeFail($id,$fail_msg['message']);
if($res){
return JsonService::successful('操作成功!');
@@ -95,6 +99,10 @@ class UserExtract extends AuthController
if(!UserExtractModel::be(['id'=>$id,'status'=>0]))
return JsonService::fail('操作记录不存在或状态错误!');
UserExtractModel::beginTrans();
+ $extract=UserExtractModel::get($id);
+ if(!$extract) return JsonService::fail('操作记录不存!');
+ if($extract->status==1) return JsonService::fail('您已提现,请勿重复提现!');
+ if($extract->status==-1) return JsonService::fail('您的提现申请已被拒绝!');
$res = UserExtractModel::changeSuccess($id);
if($res){
return JsonService::successful('操作成功!');
diff --git a/application/admin/controller/ump/StoreSeckill.php b/application/admin/controller/ump/StoreSeckill.php
index b1abcb17..5dfd45f8 100644
--- a/application/admin/controller/ump/StoreSeckill.php
+++ b/application/admin/controller/ump/StoreSeckill.php
@@ -60,7 +60,7 @@ class StoreSeckill extends AuthController
if(is_object($seckillList['list'])) $seckillList['list'] = $seckillList['list']->toArray();
$data = $seckillList['list']['data'];
foreach ($data as $k=>$v){
- $data[$k]['_stop_time'] = date('Y/m/d H:i:s',$v['stop_time']);
+ $data[$k]['_stop_time'] =$v['stop_time'] ? date('Y/m/d H:i:s',$v['stop_time']) : '';
}
return Json::successlayui(['count'=>$seckillList['list']['total'],'data'=>$data]);
}
@@ -103,6 +103,7 @@ class StoreSeckill extends AuthController
{
$data = Util::postMore([
'title',
+ 'product_id',
'info',
'unit_name',
['image',''],
@@ -159,6 +160,7 @@ class StoreSeckill extends AuthController
if(!$product) return Json::fail('数据不存在!');
$f = array();
$f[] = Form::input('title','产品标题',$product->getData('store_name'));
+ $f[] = Form::hidden('product_id',$id);
$f[] = Form::input('info','秒杀活动简介',$product->getData('store_info'))->type('textarea');
$f[] = Form::input('unit_name','单位',$product->getData('unit_name'))->placeholder('个、位');
$f[] = Form::dateTimeRange('section_time','活动时间');
@@ -170,7 +172,7 @@ class StoreSeckill extends AuthController
$f[] = Form::number('stock','库存',$product->getData('stock'))->min(0)->precision(0)->col(12);
$f[] = Form::number('sales','销量',$product->getData('sales'))->min(0)->precision(0)->col(12);
$f[] = Form::number('sort','排序',$product->getData('sort'))->col(12);
- $f[] = Form::number('num','单次购买产品个数')->precision(0)->col(12);
+ $f[] = Form::number('num','单次购买产品个数',1)->precision(0)->col(12);
$f[] = Form::number('give_integral','赠送积分',$product->getData('give_integral'))->min(0)->precision(0)->col(12);
$f[] = Form::number('postage','邮费',$product->getData('postage'))->min(0)->col(12);
$f[] = Form::radio('is_postage','是否包邮',$product->getData('is_postage'))->options([['label'=>'是','value'=>1],['label'=>'否','value'=>0]])->col(12);
diff --git a/application/admin/controller/user/User.php b/application/admin/controller/user/User.php
index b08f1c58..23194900 100644
--- a/application/admin/controller/user/User.php
+++ b/application/admin/controller/user/User.php
@@ -1 +1 @@
-assign('count_user',UserModel::getcount());
return $this->fetch();
}
/**
* 修改user表状态
*
* @return json
*/
public function set_status($status='',$uid=0,$is_echo=0){
if($is_echo==0) {
if ($status == '' || $uid == 0) return Json::fail('参数错误');
UserModel::where(['uid' => $uid])->update(['status' => $status]);
}else{
$uids=Util::postMore([
['uids',[]]
]);
UserModel::destrSyatus($uids['uids'],$status);
}
return Json::successful($status==0 ? '禁用成功':'解禁成功');
}
/**
* 获取user表
*
* @return json
*/
public function get_user_list(){
$where=Util::getMore([
['page',1],
['limit',20],
['nickname',''],
['status',''],
['pay_count',''],
['is_promoter',''],
['order',''],
['data',''],
['user_type',''],
['country',''],
['province',''],
['city',''],
['user_time_type',''],
['user_time',''],
['sex',''],
]);
return Json::successlayui(UserModel::getUserList($where));
}
/**
* 编辑模板消息
* @param $id
* @return mixed|\think\response\Json|void
*/
public function edit($uid)
{
if(!$uid) return $this->failed('数据不存在');
$user = UserModel::get($uid);
if(!$user) return Json::fail('数据不存在!');
$f = array();
$f[] = Form::input('uid','用户编号',$user->getData('uid'))->disabled(1);
$f[] = Form::input('nickname','用户姓名',$user->getData('nickname'));
$f[] = Form::radio('money_status','修改余额',1)->options([['value'=>1,'label'=>'增加'],['value'=>2,'label'=>'减少']])->col(12);
$f[] = Form::number('money','余额')->min(0)->col(12);
$f[] = Form::radio('integration_status','修改积分',1)->options([['value'=>1,'label'=>'增加'],['value'=>2,'label'=>'减少']])->col(12);
$f[] = Form::number('integration','积分')->min(0)->col(12);
$f[] = Form::radio('status','状态',$user->getData('status'))->options([['value'=>1,'label'=>'开启'],['value'=>0,'label'=>'锁定']]);
$f[] = Form::radio('is_promoter','推广员',$user->getData('is_promoter'))->options([['value'=>1,'label'=>'开启'],['value'=>0,'label'=>'关闭']]);
$form = Form::make_post_form('添加用户通知',$f,Url::build('update',array('id'=>$uid)));
$this->assign(compact('form'));
return $this->fetch('public/form-builder');
}
public function update(Request $request, $uid)
{
$data = Util::postMore([
['money_status',0],
['is_promoter',1],
['money',0],
['integration_status',0],
['integration',0],
['status',0],
],$request);
if(!$uid) return $this->failed('数据不存在');
$user = UserModel::get($uid);
if(!$user) return Json::fail('数据不存在!');
ModelBasic::beginTrans();
$res1 = false;
$res2 = false;
$edit = array();
if($data['money_status'] && $data['money']){//余额增加或者减少
if($data['money_status'] == 1){//增加
$edit['now_money'] = bcadd($user['now_money'],$data['money'],2);
$res1 = UserBill::income('系统增加余额',$user['uid'],'now_money','system_add',$data['money'],$this->adminId,$user['now_money'],'系统增加了'.floatval($data['money']).'余额');
try{
HookService::listen('admin_add_money',$user,$data['money'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}else if($data['money_status'] == 2){//减少
$edit['now_money'] = bcsub($user['now_money'],$data['money'],2);
$res1 = UserBill::expend('系统减少余额',$user['uid'],'now_money','system_sub',$data['money'],$this->adminId,$user['now_money'],'系统扣除了'.floatval($data['money']).'余额');
try{
HookService::listen('admin_sub_money',$user,$data['money'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}
}else{
$res1 = true;
}
if($data['integration_status'] && $data['integration']){//积分增加或者减少
if($data['integration_status'] == 1){//增加
$edit['integral'] = bcadd($user['integral'],$data['integration'],2);
$res2 = UserBill::income('系统增加积分',$user['uid'],'integral','system_add',$data['integration'],$this->adminId,$user['integral'],'系统增加了'.floatval($data['integration']).'积分');
try{
HookService::listen('admin_add_integral',$user,$data['integration'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}else if($data['integration_status'] == 2){//减少
$edit['integral'] = bcsub($user['integral'],$data['integration'],2);
$res2 = UserBill::expend('系统减少积分',$user['uid'],'integral','system_sub',$data['integration'],$this->adminId,$user['integral'],'系统扣除了'.floatval($data['integration']).'积分');
try{
HookService::listen('admin_sub_integral',$user,$data['integration'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}
}else{
$res2 = true;
}
$edit['status'] = $data['status'];
$edit['is_promoter'] = $data['is_promoter'];
if($edit) $res3 = UserModel::edit($edit,$uid);
else $res3 = true;
if($res1 && $res2 && $res3) $res =true;
else $res = false;
ModelBasic::checkTrans($res);
if($res) return Json::successful('修改成功!');
else return Json::fail('修改失败');
}
/**
* 用户图表
* @return mixed
*/
public function user_analysis(){
$where = Util::getMore([
['nickname',''],
['status',''],
['is_promoter',''],
['date',''],
['user_type',''],
['export',0]
],$this->request);
$user_count=UserModel::consume($where,'',true);
//头部信息
$header=[
[
'name'=>'新增用户',
'class'=>'fa-line-chart',
'value'=>$user_count,
'color'=>'red'
],
[
'name'=>'用户留存',
'class'=>'fa-area-chart',
'value'=>$this->gethreaderValue(UserModel::consume($where,'',true),$where).'%',
'color'=>'lazur'
],
[
'name'=>'新增用户总消费',
'class'=>'fa-bar-chart',
'value'=>'￥'.UserModel::consume($where),
'color'=>'navy'
],
[
'name'=>'用户活跃度',
'class'=>'fa-pie-chart',
'value'=>$this->gethreaderValue(UserModel::consume($where,'',true)).'%',
'color'=>'yellow'
],
];
$name=['新增用户','用户消费'];
$dates=$this->get_user_index($where,$name);
$user_index=['name'=>json_encode($name), 'date'=>json_encode($dates['time']), 'series'=>json_encode($dates['series'])];
//用户浏览分析
$view=StoreVisit::getVisit($where['date'],['','warning','info','danger']);
$view_v1=WechatMessage::getViweList($where['date'],['','warning','info','danger']);
$view=array_merge($view,$view_v1);
$view_v2=[];
foreach ($view as $val){
$view_v2['color'][]='#'.rand(100000,339899);
$view_v2['name'][]=$val['name'];
$view_v2['value'][]=$val['value'];
}
$view=$view_v2;
//消费会员排行用户分析
$user_null=UserModel::getUserSpend($where['date']);
//消费数据
$now_number=UserModel::getUserSpend($where['date'],true);
list($paren_number,$title)=UserModel::getPostNumber($where['date']);
if($paren_number==0) {
$rightTitle=[
'number'=>$now_number>0?$now_number:0,
'icon'=>'fa-level-up',
'title'=>$title
];
}else{
$number=(float)bcsub($now_number,$paren_number,4);
if($now_number==0){
$icon='fa-level-down';
}else{
$icon=$now_number>$paren_number?'fa-level-up':'fa-level-down';
}
$rightTitle=['number'=>$number, 'icon'=>$icon, 'title'=>$title];
}
unset($title,$paren_number,$now_number);
list($paren_user_count,$title)=UserModel::getPostNumber($where['date'],true,'add_time','');
if($paren_user_count==0){
$count=$user_count==0?0:$user_count;
$icon=$user_count==0?'fa-level-down':'fa-level-up';
}else{
$count=(float)bcsub($user_count,$paren_user_count,4);
$icon=$user_count<$paren_user_count?'fa-level-down':'fa-level-up';
}
$leftTitle=[
'count'=>$count,
'icon'=>$icon,
'title'=>$title
];
unset($count,$icon,$title);
$consume=[
'title'=>'消费金额为￥'.UserModel::consume($where),
'series'=>UserModel::consume($where,'xiaofei'),
'rightTitle'=>$rightTitle,
'leftTitle'=>$leftTitle,
];
$form=UserModel::consume($where,'form');
$grouping=UserModel::consume($where,'grouping');
$this->assign(compact('header','user_index','view','user_null','consume','form','grouping','where'));
return $this->fetch();
}
public function gethreaderValue($chart,$where=[]){
if($where){
switch($where['date']){
case null:case 'today':case 'week':case 'year':
if($where['date']==null){
$where['date']='month';
}
$sum_user=UserModel::whereTime('add_time',$where['date'])->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
break;
case 'quarter':
$quarter=UserModel::getMonth('n');
$quarter[0]=strtotime($quarter[0]);
$quarter[1]=strtotime($quarter[1]);
$sum_user=UserModel::where('add_time','between',$quarter)->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
default:
//自定义时间
$quarter=explode('-',$where['date']);
$quarter[0]=strtotime($quarter[0]);
$quarter[1]=strtotime($quarter[1]);
$sum_user=UserModel::where('add_time','between',$quarter)->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
break;
}
}else{
$num=UserModel::count();
$chart=$num!=0?bcdiv($chart,$num,5)*100:0;
return $chart;
}
}
public function get_user_index($where,$name){
switch ($where['date']){
case null:
$days = date("t",strtotime(date('Y-m',time())));
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=1;$i<=$days;$i++){
if(!in_array($i.'号',$times_list)){
array_push($times_list,$i.'号');
}
$time=$this->gettime(date("Y-m",time()).'-'.$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',$time)->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,$time);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'today':
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=0;$i<=24;$i++){
$strtitle=$i.'点';
if(!in_array($strtitle,$times_list)){
array_push($times_list,$strtitle);
}
$time=$this->gettime(date("Y-m-d ",time()).$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',$time)->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,$time);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case "week":
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=0;$i<=6;$i++){
if(!in_array('星期'.($i+1),$times_list)){
array_push($times_list,'星期'.($i+1));
}
$time=UserModel::getMonth('h',$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($time[0]),strtotime($time[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($time[0]),strtotime($time[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'year':
$dates=[];
$series=[];
$times_list=[];
$year=date('Y');
foreach ($name as $key=>$val){
for($i=1;$i<=12;$i++){
if(!in_array($i.'月',$times_list)){
array_push($times_list,$i.'月');
}
$t = strtotime($year.'-'.$i.'-01');
$arr= explode('/',date('Y-m-01',$t).'/'.date('Y-m-',$t).date('t',$t));
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($arr[0]),strtotime($arr[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($arr[0]),strtotime($arr[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'quarter':
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=1;$i<=4;$i++){
$arr=$this->gettime('quarter',$i);
if(!in_array(implode('--',$arr).'季度',$times_list)){
array_push($times_list,implode('--',$arr).'季度');
}
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($arr[0]),strtotime($arr[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($arr[0]),strtotime($arr[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
default:
$list=UserModel::consume($where,'default');
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $k=>$v){
foreach ($list as $val){
$date=$val['add_time'];
if(!in_array($date,$times_list)){
array_push($times_list,$date);
}
if($k==0){
$dates['data'][]=$val['num'];
}else if($k==1){
$dates['data'][]=UserBill::where(['uid'=>$val['uid'],'type'=>'pay_product'])->sum('number');
}
}
$dates['name']=$v;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
}
}
public function gettime($time='',$season=''){
if(!empty($time) && empty($season)){
$timestamp0 = strtotime($time);
$timestamp24 =strtotime($time)+86400;
return [$timestamp0,$timestamp24];
}else if(!empty($time) && !empty($season)){
$firstday=date('Y-m-01',mktime(0,0,0,($season - 1) *3 +1,1,date('Y')));
$lastday=date('Y-m-t',mktime(0,0,0,$season * 3,1,date('Y')));
return [$firstday,$lastday];
}
}
/**
* 会员等级首页
*/
public function group(){
return $this->fetch();
}
/**
* 会员详情
*/
public function see($uid=''){
$this->assign([
'uid'=>$uid,
'userinfo'=>UserModel::getUserDetailed($uid),
'is_layui'=>true,
'headerList'=>UserModel::getHeaderList($uid),
'count'=>UserModel::getCountInfo($uid),
]);
return $this->fetch();
}
/**
* 获取某用户的订单列表
*/
public function getOneorderList($uid,$page=1,$limit=20){
return Json::successful(StoreOrder::getOneorderList(compact('uid','page','limit')));
}
/**
* 获取某用户的积分列表
*/
public function getOneIntegralList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneIntegralList(compact('uid','page','limit')));
}
/**
* 获取某用户的积分列表
*/
public function getOneSignList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneSignList(compact('uid','page','limit')));
}
/**
* 获取某用户的持有优惠劵
*/
public function getOneCouponsList($uid,$page=1,$limit=20){
return Json::successful(StoreCouponUser::getOneCouponsList(compact('uid','page','limit')));
}
/**
* 获取某用户的余额变动记录
*/
public function getOneBalanceChangList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneBalanceChangList(compact('uid','page','limit')));
}
}
\ No newline at end of file
+assign('count_user',UserModel::getcount());
return $this->fetch();
}
/**
* 修改user表状态
*
* @return json
*/
public function set_status($status='',$uid=0,$is_echo=0){
if($is_echo==0) {
if ($status == '' || $uid == 0) return Json::fail('参数错误');
UserModel::where(['uid' => $uid])->update(['status' => $status]);
}else{
$uids=Util::postMore([
['uids',[]]
]);
UserModel::destrSyatus($uids['uids'],$status);
}
return Json::successful($status==0 ? '禁用成功':'解禁成功');
}
/**
* 获取user表
*
* @return json
*/
public function get_user_list(){
$where=Util::getMore([
['page',1],
['limit',20],
['nickname',''],
['status',''],
['pay_count',''],
['is_promoter',''],
['order',''],
['data',''],
['user_type',''],
['country',''],
['province',''],
['city',''],
['user_time_type',''],
['user_time',''],
['sex',''],
]);
return Json::successlayui(UserModel::getUserList($where));
}
/**
* 编辑模板消息
* @param $id
* @return mixed|\think\response\Json|void
*/
public function edit($uid)
{
if(!$uid) return $this->failed('数据不存在');
$user = UserModel::get($uid);
if(!$user) return Json::fail('数据不存在!');
$f = array();
$f[] = Form::input('uid','用户编号',$user->getData('uid'))->disabled(1);
$f[] = Form::input('nickname','用户姓名',$user->getData('nickname'));
$f[] = Form::radio('money_status','修改余额',1)->options([['value'=>1,'label'=>'增加'],['value'=>2,'label'=>'减少']])->col(12);
$f[] = Form::number('money','余额')->min(0)->col(12);
$f[] = Form::radio('integration_status','修改积分',1)->options([['value'=>1,'label'=>'增加'],['value'=>2,'label'=>'减少']])->col(12);
$f[] = Form::number('integration','积分')->min(0)->col(12);
$f[] = Form::radio('status','状态',$user->getData('status'))->options([['value'=>1,'label'=>'开启'],['value'=>0,'label'=>'锁定']]);
$f[] = Form::radio('is_promoter','推广员',$user->getData('is_promoter'))->options([['value'=>1,'label'=>'开启'],['value'=>0,'label'=>'关闭']]);
$form = Form::make_post_form('添加用户通知',$f,Url::build('update',array('id'=>$uid)));
$this->assign(compact('form'));
return $this->fetch('public/form-builder');
}
public function update(Request $request, $uid)
{
$data = Util::postMore([
['money_status',0],
['is_promoter',1],
['money',0],
['integration_status',0],
['integration',0],
['status',0],
],$request);
if(!$uid) return $this->failed('数据不存在');
$user = UserModel::get($uid);
if(!$user) return Json::fail('数据不存在!');
ModelBasic::beginTrans();
$res1 = false;
$res2 = false;
$edit = array();
if($data['money_status'] && $data['money']){//余额增加或者减少
if($data['money_status'] == 1){//增加
$edit['now_money'] = bcadd($user['now_money'],$data['money'],2);
$res1 = UserBill::income('系统增加余额',$user['uid'],'now_money','system_add',$data['money'],$this->adminId,$user['now_money'],'系统增加了'.floatval($data['money']).'余额');
try{
HookService::listen('admin_add_money',$user,$data['money'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}else if($data['money_status'] == 2){//减少
$edit['now_money'] = bcsub($user['now_money'],$data['money'],2);
$res1 = UserBill::expend('系统减少余额',$user['uid'],'now_money','system_sub',$data['money'],$this->adminId,$user['now_money'],'系统扣除了'.floatval($data['money']).'余额');
try{
HookService::listen('admin_sub_money',$user,$data['money'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}
}else{
$res1 = true;
}
if($data['integration_status'] && $data['integration']){//积分增加或者减少
if($data['integration_status'] == 1){//增加
$edit['integral'] = bcadd($user['integral'],$data['integration'],2);
$res2 = UserBill::income('系统增加积分',$user['uid'],'integral','system_add',$data['integration'],$this->adminId,$user['integral'],'系统增加了'.floatval($data['integration']).'积分');
try{
HookService::listen('admin_add_integral',$user,$data['integration'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}else if($data['integration_status'] == 2){//减少
$edit['integral'] = bcsub($user['integral'],$data['integration'],2);
$res2 = UserBill::expend('系统减少积分',$user['uid'],'integral','system_sub',$data['integration'],$this->adminId,$user['integral'],'系统扣除了'.floatval($data['integration']).'积分');
try{
HookService::listen('admin_sub_integral',$user,$data['integration'],false,UserBehavior::class);
}catch (\Exception $e){
ModelBasic::rollbackTrans();
return Json::fail($e->getMessage());
}
}
}else{
$res2 = true;
}
$edit['status'] = $data['status'];
$edit['is_promoter'] = $data['is_promoter'];
if($edit) $res3 = UserModel::edit($edit,$uid);
else $res3 = true;
if($res1 && $res2 && $res3) $res =true;
else $res = false;
ModelBasic::checkTrans($res);
if($res) return Json::successful('修改成功!');
else return Json::fail('修改失败');
}
/**
* 用户图表
* @return mixed
*/
public function user_analysis(){
$where = Util::getMore([
['nickname',''],
['status',''],
['is_promoter',''],
['date',''],
['user_type',''],
['export',0]
],$this->request);
$user_count=UserModel::consume($where,'',true);
//头部信息
$header=[
[
'name'=>'新增用户',
'class'=>'fa-line-chart',
'value'=>$user_count,
'color'=>'red'
],
[
'name'=>'用户留存',
'class'=>'fa-area-chart',
'value'=>$this->gethreaderValue(UserModel::consume($where,'',true),$where).'%',
'color'=>'lazur'
],
[
'name'=>'新增用户总消费',
'class'=>'fa-bar-chart',
'value'=>'￥'.UserModel::consume($where),
'color'=>'navy'
],
[
'name'=>'用户活跃度',
'class'=>'fa-pie-chart',
'value'=>$this->gethreaderValue(UserModel::consume($where,'',true)).'%',
'color'=>'yellow'
],
];
$name=['新增用户','用户消费'];
$dates=$this->get_user_index($where,$name);
$user_index=['name'=>json_encode($name), 'date'=>json_encode($dates['time']), 'series'=>json_encode($dates['series'])];
//用户浏览分析
$view=StoreVisit::getVisit($where['date'],['','warning','info','danger']);
$view_v1=WechatMessage::getViweList($where['date'],['','warning','info','danger']);
$view=array_merge($view,$view_v1);
$view_v2=[];
foreach ($view as $val){
$view_v2['color'][]='#'.rand(100000,339899);
$view_v2['name'][]=$val['name'];
$view_v2['value'][]=$val['value'];
}
$view=$view_v2;
//消费会员排行用户分析
$user_null=UserModel::getUserSpend($where['date']);
//消费数据
$now_number=UserModel::getUserSpend($where['date'],true);
list($paren_number,$title)=UserModel::getPostNumber($where['date']);
if($paren_number==0) {
$rightTitle=[
'number'=>$now_number>0?$now_number:0,
'icon'=>'fa-level-up',
'title'=>$title
];
}else{
$number=(float)bcsub($now_number,$paren_number,4);
if($now_number==0){
$icon='fa-level-down';
}else{
$icon=$now_number>$paren_number?'fa-level-up':'fa-level-down';
}
$rightTitle=['number'=>$number, 'icon'=>$icon, 'title'=>$title];
}
unset($title,$paren_number,$now_number);
list($paren_user_count,$title)=UserModel::getPostNumber($where['date'],true,'add_time','');
if($paren_user_count==0){
$count=$user_count==0?0:$user_count;
$icon=$user_count==0?'fa-level-down':'fa-level-up';
}else{
$count=(float)bcsub($user_count,$paren_user_count,4);
$icon=$user_count<$paren_user_count?'fa-level-down':'fa-level-up';
}
$leftTitle=[
'count'=>$count,
'icon'=>$icon,
'title'=>$title
];
unset($count,$icon,$title);
$consume=[
'title'=>'消费金额为￥'.UserModel::consume($where),
'series'=>UserModel::consume($where,'xiaofei'),
'rightTitle'=>$rightTitle,
'leftTitle'=>$leftTitle,
];
$form=UserModel::consume($where,'form');
$grouping=UserModel::consume($where,'grouping');
$this->assign(compact('header','user_index','view','user_null','consume','form','grouping','where'));
return $this->fetch();
}
public function gethreaderValue($chart,$where=[]){
if($where){
switch($where['date']){
case null:case 'today':case 'week':case 'year':
if($where['date']==null){
$where['date']='month';
}
$sum_user=UserModel::whereTime('add_time',$where['date'])->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
break;
case 'quarter':
$quarter=UserModel::getMonth('n');
$quarter[0]=strtotime($quarter[0]);
$quarter[1]=strtotime($quarter[1]);
$sum_user=UserModel::where('add_time','between',$quarter)->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
default:
//自定义时间
$quarter=explode('-',$where['date']);
$quarter[0]=strtotime($quarter[0]);
$quarter[1]=strtotime($quarter[1]);
$sum_user=UserModel::where('add_time','between',$quarter)->count();
if($sum_user==0) return 0;
$counts=bcdiv($chart,$sum_user,4)*100;
return $counts;
break;
}
}else{
$num=UserModel::count();
$chart=$num!=0?bcdiv($chart,$num,5)*100:0;
return $chart;
}
}
public function get_user_index($where,$name){
switch ($where['date']){
case null:
$days = date("t",strtotime(date('Y-m',time())));
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=1;$i<=$days;$i++){
if(!in_array($i.'号',$times_list)){
array_push($times_list,$i.'号');
}
$time=$this->gettime(date("Y-m",time()).'-'.$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',$time)->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,$time);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'today':
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=0;$i<=24;$i++){
$strtitle=$i.'点';
if(!in_array($strtitle,$times_list)){
array_push($times_list,$strtitle);
}
$time=$this->gettime(date("Y-m-d ",time()).$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',$time)->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,$time);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case "week":
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=0;$i<=6;$i++){
if(!in_array('星期'.($i+1),$times_list)){
array_push($times_list,'星期'.($i+1));
}
$time=UserModel::getMonth('h',$i);
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($time[0]),strtotime($time[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($time[0]),strtotime($time[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'year':
$dates=[];
$series=[];
$times_list=[];
$year=date('Y');
foreach ($name as $key=>$val){
for($i=1;$i<=12;$i++){
if(!in_array($i.'月',$times_list)){
array_push($times_list,$i.'月');
}
$t = strtotime($year.'-'.$i.'-01');
$arr= explode('/',date('Y-m-01',$t).'/'.date('Y-m-',$t).date('t',$t));
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($arr[0]),strtotime($arr[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($arr[0]),strtotime($arr[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
case 'quarter':
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $key=>$val){
for($i=1;$i<=4;$i++){
$arr=$this->gettime('quarter',$i);
if(!in_array(implode('--',$arr).'季度',$times_list)){
array_push($times_list,implode('--',$arr).'季度');
}
if($key==0){
$dates['data'][]=UserModel::where('add_time','between',[strtotime($arr[0]),strtotime($arr[1])])->count();
}else if($key==1){
$dates['data'][]=UserModel::consume(true,[strtotime($arr[0]),strtotime($arr[1])]);
}
}
$dates['name']=$val;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
default:
$list=UserModel::consume($where,'default');
$dates=[];
$series=[];
$times_list=[];
foreach ($name as $k=>$v){
foreach ($list as $val){
$date=$val['add_time'];
if(!in_array($date,$times_list)){
array_push($times_list,$date);
}
if($k==0){
$dates['data'][]=$val['num'];
}else if($k==1){
$dates['data'][]=UserBill::where(['uid'=>$val['uid'],'type'=>'pay_product'])->sum('number');
}
}
$dates['name']=$v;
$dates['type']='line';
$series[]=$dates;
unset($dates);
}
return ['time'=>$times_list,'series'=>$series];
}
}
public function gettime($time='',$season=''){
if(!empty($time) && empty($season)){
$timestamp0 = strtotime($time);
$timestamp24 =strtotime($time)+86400;
return [$timestamp0,$timestamp24];
}else if(!empty($time) && !empty($season)){
$firstday=date('Y-m-01',mktime(0,0,0,($season - 1) *3 +1,1,date('Y')));
$lastday=date('Y-m-t',mktime(0,0,0,$season * 3,1,date('Y')));
return [$firstday,$lastday];
}
}
/**
* 会员等级首页
*/
public function group(){
return $this->fetch();
}
/**
* 会员详情
*/
public function see($uid=''){
$this->assign([
'uid'=>$uid,
'userinfo'=>UserModel::getUserDetailed($uid),
'is_layui'=>true,
'headerList'=>UserModel::getHeaderList($uid),
'count'=>UserModel::getCountInfo($uid),
]);
return $this->fetch();
}
/*
* 获取某个用户的推广下线
* */
public function getSpreadList($uid,$page=1,$limit=20){
return Json::successful(UserModel::getSpreadList($uid,(int)$page,(int)$limit));
}
/**
* 获取某用户的订单列表
*/
public function getOneorderList($uid,$page=1,$limit=20){
return Json::successful(StoreOrder::getOneorderList(compact('uid','page','limit')));
}
/**
* 获取某用户的积分列表
*/
public function getOneIntegralList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneIntegralList(compact('uid','page','limit')));
}
/**
* 获取某用户的积分列表
*/
public function getOneSignList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneSignList(compact('uid','page','limit')));
}
/**
* 获取某用户的持有优惠劵
*/
public function getOneCouponsList($uid,$page=1,$limit=20){
return Json::successful(StoreCouponUser::getOneCouponsList(compact('uid','page','limit')));
}
/**
* 获取某用户的余额变动记录
*/
public function getOneBalanceChangList($uid,$page=1,$limit=20){
return Json::successful(UserBillAdmin::getOneBalanceChangList(compact('uid','page','limit')));
}
}
\ No newline at end of file
diff --git a/application/admin/model/user/User.php b/application/admin/model/user/User.php
index 24df1216..34819da9 100644
--- a/application/admin/model/user/User.php
+++ b/application/admin/model/user/User.php
@@ -1 +1 @@
-
* @day: 2017/11/11
*/
namespace app\admin\model\user;
use app\admin\model\order\StoreOrder;
use traits\ModelTrait;
use app\wap\model\user\UserBill;
use basic\ModelBasic;
use app\admin\model\wechat\WechatUser;
use app\admin\model\store\StoreCouponUser;
use app\admin\model\user\UserExtract;
/**
* 用户管理 model
* Class User
* @package app\admin\model\user
*/
class User extends ModelBasic
{
use ModelTrait;
/**
* @param $where
* @return array
*/
public static function systemPage($where){
$model = new self;
if($where['status'] != '') $model = $model->where('status',$where['status']);
if($where['is_promoter'] != '') $model = $model->where('is_promoter',$where['is_promoter']);
if(isset($where['user_type']) && $where['user_type'] != '') $model = $model->where('user_type',$where['user_type']);
if($where['nickname'] != '') $model = $model->where('nickname|uid','like',"%$where[nickname]%");
$model = $model->order('uid desc');
return self::page($model,function ($item){
if($item['spread_uid']){
$item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname');
}else{
$item['spread_uid_nickname'] = '无';
}
},$where);
}
/**
* 异步获取当前用户 信息
* @param $where
* @return array
*/
public static function getUserList($where){
if($where['order']!=''){
$model=self::order(self::setOrder($where['order']));
}else{
$model=self::order('u.uid desc');
}
if($where['user_time_type'] == 'visitno'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', ['>', strtotime($endTime)], ['<', strtotime($startTime)],'or');
}
if($where['user_time_type'] == 'visit'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', '>', strtotime($startTime));
$model = $model->where('u.last_time', '<', strtotime($endTime));
}
if($where['user_time_type'] == 'add_time'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.add_time', '>', strtotime($startTime));
$model = $model->where('u.add_time', '<', strtotime($endTime));
}
if($where['pay_count'] !== '') {
if($where['pay_count'] == '-1') $model = $model->where('pay_count',0);
else $model = $model->where('pay_count','>',$where['pay_count']);
}
if($where['country'] == 'domestic') $model = $model->where('w.country','EQ','中国');
else if($where['country'] == 'abroad') $model = $model->where('w.country','NEQ','中国');
// dump(self::setWherePage($model,$where,['w.province','w.city','u.status','u.is_promoter','u.user_type'],['u.nickname','u.uid']));
// dump($model);
// dump($where);
// exit();
$list = self::setWherePage($model,$where,['w.sex','w.province','w.city','u.status','u.is_promoter','u.user_type'],['u.nickname','u.uid'])
->alias('u')
->join('WechatUser w','u.uid=w.uid')
->field('u.*,w.country,w.province,w.city,w.sex,w.unionid,w.openid,w.routine_openid,w.groupid,w.tagid_list,w.subscribe,w.subscribe_time')
->page((int)$where['page'],(int)$where['limit'])
->select()
->each(function ($item){
$item['add_time']=date('Y-m-d H:i:s',$item['add_time']);
if($item['last_time']) $item['last_time'] = date('Y-m-d H:i:s',$item['last_time']);//最近一次访问日期
else $item['last_time'] = '无访问';//最近一次访问日期
// self::edit(['pay_count'=>StoreOrder::getUserCountPay($item['uid'])],$item['uid']);
$item['extract_count_price'] = UserExtract::getUserCountPrice($item['uid']);//累计提现
if($item['spread_uid']){
$item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname').'/'.$item['spread_uid'];
}else{
$item['spread_uid_nickname'] = '无';
}
if($item['user_type']=='wechat'){
$item['user_type']='微信类型';
}else if($item['user_type']=='routine'){
$item['user_type']='小程序类型';
}else $item['user_type']='其他类型';
if($item['sex'] == 1){
$item['sex']='男';
}else if($item['sex'] == 2){
$item['sex']='女';
}else $item['sex']='保密';
})->toArray();
// $model=self::getModelTime($where,$model,$where['time_visit'],'data',' - ');
if($where['user_time_type'] == 'visitno'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', ['>', strtotime($endTime)], ['<', strtotime($startTime)],'or');
}
if($where['user_time_type'] == 'visit'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', '>', strtotime($startTime));
$model = $model->where('u.last_time', '<', strtotime($endTime));
}
if($where['user_time_type'] == 'add_time'){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.add_time', '>', strtotime($startTime));
$model = $model->where('u.add_time', '<', strtotime($endTime));
}
if($where['pay_count'] !== '') $model = $model->where('pay_count','>',$where['pay_count']);
if($where['country'] == 'domestic') $model = $model->where('w.country','EQ','中国');
else if($where['country'] == 'abroad') $model = $model->where('w.country','NEQ','中国');
$count=self::setWherePage($model,$where,['w.sex','w.province','w.city','u.status','u.is_promoter','u.user_type'],['u.nickname','u.uid'])->alias('u')->join('WechatUser w','u.uid=w.uid')->count();
return ['count'=>$count,'data'=>$list];
}
/**
* 修改用户状态
* @param $uids 用户uid
* @param $status 修改状态
* @return array
*/
public static function destrSyatus($uids,$status){
if(empty($uids) && !is_array($uids)) return false;
if($status=='') return false;
self::beginTrans();
try{
$res=self::where('uid','in',$uids)->update(['status'=>$status]);
self::checkTrans($res);
return true;
}catch (\Exception $e){
self::rollbackTrans();
return Json::fail($e->getMessage());
}
}
/*
* 获取某季度,某年某年后的时间戳
*
* self::getMonth('n',1) 获取当前季度的上个季度的时间戳
* self::getMonth('n') 获取当前季度的时间戳
*/
public static function getMonth($time='',$ceil=0){
if(empty($time)){
$firstday = date("Y-m-01",time());
$lastday = date("Y-m-d",strtotime("$firstday +1 month -1 day"));
}else if($time=='n'){
if($ceil!=0)
$season = ceil(date('n') /3)-$ceil;
else
$season = ceil(date('n') /3);
$firstday=date('Y-m-01',mktime(0,0,0,($season - 1) *3 +1,1,date('Y')));
$lastday=date('Y-m-t',mktime(0,0,0,$season * 3,1,date('Y')));
}else if($time=='y'){
$firstday=date('Y-01-01');
$lastday=date('Y-12-31');
}else if($time=='h'){
$firstday = date('Y-m-d', strtotime('this week +'.$ceil.' day')) . ' 00:00:00';
$lastday = date('Y-m-d', strtotime('this week +'.($ceil+1).' day')) . ' 23:59:59';
}
return array($firstday,$lastday);
}
public static function getcount(){
return self::count();
}
/*
*获取用户某个时间段的消费信息
*
* reutrn Array || number
*/
public static function consume($where,$status='',$keep=''){
$model = new self;
$user_id=[];
if(is_array($where)){
if($where['is_promoter']!='') $model=$model->where('is_promoter',$where['is_promoter']);
if($where['status']!='') $model=$model->where('status',$where['status']);
switch ($where['date']){
case null:case 'today':case 'week':case 'year':
if($where['date']==null){
$where['date']='month';
}
if($keep){
$model=$model->whereTime('add_time',$where['date'])->whereTime('last_time',$where['date']);
}else{
$model=$model->whereTime('add_time',$where['date']);
}
break;
case 'quarter':
$quarter=self::getMonth('n');
$startTime=strtotime($quarter[0]);
$endTime=strtotime($quarter[1]);
if($keep){
$model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime)->where('last_time','>',$startTime)->where('last_time','<',$endTime);
}else{
$model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime);
}
break;
default:
//自定义时间
if(strstr($where['date'],'-')!==FALSE){
list($startTime,$endTime)=explode('-',$where['date']);
$model = $model->where('add_time','>',strtotime($startTime))->where('add_time','<',strtotime($endTime));
}else{
$model=$model->whereTime('add_time','month');
}
break;
}
}else{
if(is_array($status)){
$model=$model->where('add_time','>',$status[0])->where('add_time','<',$status[1]);
}
}
if($keep===true){
return $model->count();
}
if($status==='default'){
return $model->group('from_unixtime(add_time,\'%Y-%m-%d\')')->field('count(uid) num,from_unixtime(add_time,\'%Y-%m-%d\') add_time,uid')->select()->toArray();
}
if($status==='grouping'){
return $model->group('user_type')->field('user_type')->select()->toArray();
}
$uid=$model->field('uid')->select()->toArray();
foreach ($uid as $val){
$user_id[]=$val['uid'];
}
if(empty($user_id)){
$user_id=[0];
}
if($status==='xiaofei'){
$list=UserBill::where('uid','in',$user_id)
->group('type')
->field('sum(number) as top_number,title')
->select()
->toArray();
$series=[
'name'=>isset($list[0]['title'])?$list[0]['title']:'',
'type'=>'pie',
'radius'=> ['40%', '50%'],
'data'=>[]
];
foreach($list as $key=>$val){
$series['data'][$key]['value']=$val['top_number'];
$series['data'][$key]['name']=$val['title'];
}
return $series;
}else if($status==='form'){
$list=WechatUser::where('uid','in',$user_id)->group('city')->field('count(city) as top_city,city')->limit(0,10)->select()->toArray();
$count=self::getcount();
$option=[
'legend_date'=>[],
'series_date'=>[]
];
foreach($list as $key=>$val){
$num=$count!=0?(bcdiv($val['top_city'],$count,2))*100:0;
$t=['name'=>$num.'% '.(empty($val['city'])?'未知':$val['city']),'icon'=>'circle'];
$option['legend_date'][$key]=$t;
$option['series_date'][$key]=['value'=>$num,'name'=>$t['name']];
}
return $option;
}else{
$number=UserBill::where('uid','in',$user_id)->where('type','pay_product')->sum('number');
return $number;
}
}
/*
* 获取 用户某个时间段的钱数或者TOP20排行
*
* return Array || number
*/
public static function getUserSpend($date,$status=''){
$model=new self();
$model=$model->alias('A');
switch ($date){
case null:case 'today':case 'week':case 'year':
if($date==null) $date='month';
$model=$model->whereTime('A.add_time',$date);
break;
case 'quarter':
list($startTime,$endTime)=User::getMonth('n');
$model = $model->where('A.add_time','>',strtotime($startTime));
$model = $model->where('A.add_time','<',strtotime($endTime));
break;
default:
list($startTime,$endTime)=explode('-',$date);
$model = $model->where('A.add_time','>',strtotime($startTime));
$model = $model->where('A.add_time','<',strtotime($endTime));
break;
}
if($status===true){
return $model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
}
$list=$model->join('user_bill B','B.uid=A.uid')
->where('B.type','pay_product')
->where('B.pm',0)
->field('sum(B.number) as totel_number,A.nickname,A.avatar,A.now_money,A.uid,A.add_time')
->order('totel_number desc')
->limit(0,20)
->select()
->toArray();
if(!isset($list[0]['totel_number'])){
$list=[];
}
return $list;
}
/*
* 获取 相对于上月或者其他的数据
*
* return Array
*/
public static function getPostNumber($date,$status=false,$field='A.add_time',$t='消费'){
$model=new self();
if(!$status) $model=$model->alias('A');
switch ($date){
case null:case 'today':case 'week':case 'year':
if($date==null) {
$date='last month';
$title='相比上月用户'.$t.'增长';
}
if($date=='today') {
$date='yesterday';
$title='相比昨天用户'.$t.'增长';
}
if($date=='week') {
$date='last week';
$title='相比上周用户'.$t.'增长';
}
if($date=='year') {
$date='last year';
$title='相比去年用户'.$t.'增长';
}
$model=$model->whereTime($field,$date);
break;
case 'quarter':
$title='相比上季度用户'.$t.'增长';
list($startTime,$endTime)=User::getMonth('n',1);
$model = $model->where($field,'>',$startTime);
$model = $model->where($field,'<',$endTime);
break;
default:
list($startTime,$endTime)=explode('-',$date);
$title='相比'.$startTime.'-'.$endTime.'时间段用户'.$t.'增长';
$Time=strtotime($endTime)-strtotime($startTime);
$model = $model->where($field,'>',strtotime($startTime)+$Time);
$model = $model->where($field,'<',strtotime($endTime)+$Time);
break;
}
if($status){
return [$model->count(),$title];
}
$number=$model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
return [$number,$title];
}
//获取用户新增,头部信息
public static function getBadgeList($where){
$user_count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->count();
$user_count_old=self::getOldDate($where)->count();
$fenxiao=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->where('spread_uid','<>',0)->count();
$fenxiao_count=self::getOldDate($where)->where('spread_uid','neq',0)->count();
$newFemxiao_count=bcsub($fenxiao,$fenxiao_count,0);
$order_count=bcsub($user_count,$user_count_old,0);
return [
[
'name'=>'会员人数',
'field'=>'个',
'count'=>$user_count,
'content'=>'会员总人数',
'background_color'=>'layui-bg-blue',
'sum'=>self::count(),
'class'=>'fa fa-bar-chart',
],
[
'name'=>'会员增长',
'field'=>'个',
'count'=>$order_count,
'content'=>'会员增长率',
'background_color'=>'layui-bg-cyan',
'sum'=>$user_count_old ? bcdiv($order_count,$user_count_old,2)*100:0,
'class'=>'fa fa-line-chart',
],
[
'name'=>'分销人数',
'field'=>'个',
'count'=>$fenxiao,
'content'=>'分销总人数',
'background_color'=>'layui-bg-green',
'sum'=>self::where('spread_uid','neq',0)->count(),
'class'=>'fa fa-bar-chart',
],
[
'name'=>'分销增长',
'field'=>'个',
'count'=>$newFemxiao_count,
'content'=>'分销总人数',
'background_color'=>'layui-bg-orange',
'sum'=>$fenxiao_count ? bcdiv($newFemxiao_count,$fenxiao_count,2)*100:0,
'class'=>'fa fa-cube',
],
];
}
/*
* 获取会员增长曲线图和分布图
* $where 查询条件
* $limit 显示条数,是否有滚动条
*/
public static function getUserChartList($where,$limit=20){
$list=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])
->where('add_time','neq',0)
->field(['FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time','count(uid) as num'])
->order('_add_time asc')
->group('_add_time')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$Zoom='';
foreach ($list as $item){
$seriesdata[]=$item['num'];
$xdata[]=$item['_add_time'];
}
(count($xdata) > $limit) && $Zoom=$xdata[$limit-5];
//多次购物会员数量饼状图
$count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter'])->count();
$user_count=self::setWherePage(self::getModelTime($where,self::alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time'),$where,['is_promoter'])
->where('r.paid',1)->count('a.uid');
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0],
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1],
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('shop_data','shop_xdata','fenbu_data','fenbu_xdata','seriesdata','xdata','Zoom');
}
//获取$date的前一天或者其他的时间段
public static function getOldDate($where,$moedls=null){
$model=$moedls ===null ? self::setWherePage(new self(),$where,['is_promoter','status']) :$moedls;
switch ($where['data']){
case 'today':
$model=$model->whereTime('add_time','yesterday');
break;
case 'week':
$model=$model->whereTime('add_time','last week');
break;
case 'month':
$model=$model->whereTime('add_time','last month');
break;
case 'year':
$model=$model->whereTime('add_time','last year');
break;
case 'quarter':
$time=self::getMonth('n',1);
$model=$model->where('add_time','between',$time);
break;
}
return $model;
}
//获取用户属性和性别分布图
public static function getEchartsData($where){
$model=self::alias('a');
$data=self::getModelTime($where,$model,'a.add_time')
->join('wechat_user r','r.uid=a.uid')
->group('r.province')
->field('count(r.province) as count,province')
->order('count desc')
->limit(15)
->select();
if(count($data)) $data=$data->toArray();
$legdata=[];
$dataList=[];
foreach ($data as $value){
$value['province']=='' && $value['province']='未知省份';
$legdata[]=$value['province'];
$dataList[]=$value['count'];
}
$model=self::alias('a');
$sex=self::getModelTime($where,$model,'a.add_time')
->join('wechat_user r','r.uid=a.uid')
->group('r.sex')
->field('count(r.uid) as count,sex')
->order('count desc')
->select();
if(count($sex)) $sex=$sex->toArray();
$sexlegdata=['男','女','未知'];
$sexcount=self::getModelTime($where,new self())->count();
$sexList=[];
$color=['#FB7773','#81BCFE','#91F3FE'];
foreach ($sex as $key=>$item){
if($item['sex']==1){
$item_date['name']='男';
}else if($item['sex']==2){
$item_date['name']='女';
}else{
$item_date['name']='未知性别';
}
$item_date['value']=bcdiv($item['count'],$sexcount,2)*100;
$item_date['itemStyle']['color']=$color[$key];
$sexList[]=$item_date;
}
return compact('sexList','sexlegdata','legdata','dataList');
}
//获取佣金记录列表
public static function getCommissionList($where){
$list=self::setCommissionWhere($where)
->page((int)$where['page'],(int)$where['limit'])
->select();
count($list) && $list=$list->toArray();
foreach ($list as &$value){
$value['ex_price']=db('user_extract')->where(['uid'=>$value['uid']])->sum('extract_price');
$value['extract_price']=db('user_extract')->where(['uid'=>$value['uid'],'status'=>1])->sum('extract_price');
}
$count=self::setCommissionWhere($where)->count();
return ['data'=>$list,'count'=>$count];
}
//获取佣金记录列表的查询条件
public static function setCommissionWhere($where){
$models=self::setWherePage(self::alias('A'),$where,[],['A.nickname','A.uid'])
->join('user_bill B','B.uid=A.uid')
->group('A.uid')
->where(['B.category'=>'now_money','B.type'=>'brokerage'])
->field(['sum(B.number) as sum_number','A.nickname','A.uid','A.now_money']);
if($where['order']==''){
$models=$models->order('sum_number desc');
}else{
$models=$models->order($where['order']==1 ? 'sum_number desc':'sum_number asc');
}
if($where['price_max']!='' && $where['price_min']!=''){
$models=$models->where('now_money','between',[$where['price_max'],$where['price_min']]);
}
return $models;
}
//获取某人用户推广信息
public static function getUserinfo($uid){
$userinfo=self::where(['uid'=>$uid])->field(['nickname','spread_uid','now_money','add_time'])->find()->toArray();
$userinfo['number']=UserBill::where(['category'=>'now_money','type'=>'brokerage'])->sum('number');
$userinfo['spread_name']=$userinfo['spread_uid'] ? self::where(['uid'=>$userinfo['spread_uid']])->value('nickname') :'';
return $userinfo;
}
//获取某用户的详细信息
public static function getUserDetailed($uid){
$key_field=['real_name','phone','province','city','district','detail','post_code'];
$Address=($thisAddress=db('user_address')->where(['uid'=>$uid,'is_default'=>1])->field($key_field)->find()) ?
$thisAddress :
db('user_address')->where(['uid'=>$uid])->field($key_field)->find();
$UserInfo=self::get($uid);
return [
['col'=>12,'name'=>'默认收货地址','value'=>'邮编:'.$thisAddress['post_code'].' 收货人电话:'.$thisAddress['phone'].' 地址:'.$thisAddress['province'].' '.$thisAddress['city'].' '.$thisAddress['district'].' '.$thisAddress['detail']],
// ['name'=>'微信OpenID','value'=>WechatUser::where(['uid'=>$uid])->value('openid'),'col'=>8],
['name'=>'手机号码','value'=>$UserInfo['phone']],
// ['name'=>'ID','value'=>$uid],
['name'=>'姓名','value'=>''],
['name'=>'微信昵称','value'=>$UserInfo['nickname']],
['name'=>'邮箱','value'=>''],
['name'=>'生日','value'=>''],
['name'=>'积分','value'=>UserBill::where(['category'=>'integral','uid'=>$uid])->where('type','in',['sign','system_add'])->sum('number')],
['name'=>'上级推广人','value'=>$UserInfo['spread_uid'] ? self::where(['uid'=>$UserInfo['spread_uid']])->value('nickname'):''],
['name'=>'账户余额','value'=>$UserInfo['now_money']],
['name'=>'佣金总收入','value'=>UserBill::where(['category'=>'now_money','type'=>'brokerage','uid'=>$uid])->sum('number')],
['name'=>'提现总金额','value'=>db('user_extract')->where(['uid'=>$uid,'status'=>1])->sum('extract_price')],
];
}
//获取某用户的订单个数,消费明细
public static function getHeaderList($uid){
return [
[
'title'=>'总计订单',
'value'=>StoreOrder::where(['uid'=>$uid])->count(),
'key'=>'笔',
'class'=>'',
],
[
'title'=>'总消费金额',
'value'=>StoreOrder::where(['uid'=>$uid,'paid'=>1])->sum('total_price'),
'key'=>'元',
'class'=>'',
],
[
'title'=>'本月订单',
'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->count(),
'key'=>'笔',
'class'=>'',
],
[
'title'=>'本月消费金额',
'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->sum('total_price'),
'key'=>'元',
'class'=>'',
]
];
}
/*
* 获取 会员 订单个数,积分明细,优惠劵明细
*
* $uid 用户id;
*
* return array
*/
public static function getCountInfo($uid){
$order_count=StoreOrder::where(['uid'=>$uid])->count();
$integral_count=UserBill::where(['uid'=>$uid,'category'=>'integral'])->where('type','in',['deduction','system_add'])->count();
$sign_count=UserBill::where(['uid'=>$uid,'category'=>'integral','type'=>'sign'])->count();
$balanceChang_count=UserBill::where(['uid'=>$uid,'category'=>'now_money'])
->where('type','in',['system_add','pay_product','extract','pay_product_refund','system_sub'])
->count();
$coupon_count=StoreCouponUser::where(['uid'=>$uid])->count();
return compact('order_count','integral_count','sign_count','balanceChang_count','coupon_count');
}
/*
* 获取 会员业务的
* 购物会员统计
* 会员访问量
*
* 曲线图
*
* $where 查询条件
*
* return array
*/
public static function getUserBusinessChart($where,$limit=20){
//获取购物会员人数趋势图
$list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where(['r.paid'=>1,'a.is_promoter'=>0])
->where('a.add_time','neq',0)
->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$zoom='';
foreach ($list as $item){
$seriesdata[]=$item['count_user'];
$xdata[]=$item['_add_time'];
}
count($xdata) > $limit && $zoom=$xdata[$limit-5];
//会员访问量
$visit=self::getModelTime($where,self::alias('a')->join('store_visit t','t.uid=a.uid'),'t.add_time')
->where('a.is_promoter',0)
->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($visit) && $visit=$visit->toArray();
$visit_data=[];
$visit_xdata=[];
$visit_zoom='';
foreach ($visit as $item){
$visit_data[]=$item['count_user'];
$visit_xdata[]=$item['_add_time'];
}
count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
//多次购物会员数量饼状图
$count=self::getModelTime($where,self::where('is_promoter',0))->count();
$user_count=self::getModelTime($where,self::alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where('a.is_promoter',0)
->where('r.paid',1)
->group('a.uid')
->count();
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0],
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1],
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('seriesdata','xdata','zoom','visit_data','visit_xdata','visit_zoom','shop_data','shop_xdata');
}
/*
* 获取用户
* 积分排行
* 会员余额排行榜
* 分销商佣金总额排行榜
* 购物笔数排行榜
* 购物金额排行榜
* 分销商佣金提现排行榜
* 上月消费排行榜
* $limit 查询多少条
* return array
*/
public static function getUserTop10List($limit=10,$is_promoter=0){
//积分排行
$integral=self::where('status',1)
->where('is_promoter',$is_promoter)
->order('integral desc')
->field(['nickname','phone','integral','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
->limit($limit)
->select();
count($integral) && $integral=$integral->toArray();
//会员余额排行榜
$now_money=self::where('status',1)
->where('is_promoter',$is_promoter)
->order('now_money desc')
->field(['nickname','phone','now_money','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
->limit($limit)
->select();
count($now_money) && $now_money=$now_money->toArray();
//购物笔数排行榜
$shopcount=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->group('r.uid')
->field(['a.nickname','a.phone','count(r.uid) as sum_count','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
->order('sum_count desc')
->limit($limit)
->select();
count($shopcount) && $shopcount=$shopcount->toArray();
//购物金额排行榜
$order=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->group('r.uid')
->field(['a.nickname','a.phone','sum(r.pay_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','r.uid'])
->order('sum_price desc')
->limit($limit)
->select();
count($order) && $order=$order->toArray();
//上月消费排行
$lastorder=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->whereTime('r.pay_time','last month')
->group('r.uid')
->field(['a.nickname','a.phone','sum(r.pay_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','r.uid'])
->order('sum_price desc')
->limit($limit)
->select();
return compact('integral','now_money','shopcount','order','lastorder');
}
/*
* 获取 会员业务
* 会员总余额 会员总积分
* $where 查询条件
*
* return array
*/
public static function getUserBusinesHeade($where){
return [
[
'name'=>'会员总余额',
'field'=>'元',
'count'=>self::getModelTime($where,self::where('status',1))->sum('now_money'),
'background_color'=>'layui-bg-cyan',
'col'=>6,
],
[
'name'=>'会员总积分',
'field'=>'分',
'count'=>self::getModelTime($where,self::where('status',1))->sum('integral'),
'background_color'=>'layui-bg-cyan',
'col'=>6
]
];
}
/*
* 分销会员头部信息查询获取
*
* 分销商总佣金余额
* 分销商总提现佣金
* 本月分销商业务佣金
* 本月分销商佣金提现金额
* 上月分销商业务佣金
* 上月分销商佣金提现金额
* $where array 时间条件
*
* return array
*/
public static function getDistributionBadgeList($where){
return [
[
'name'=>'分销商总佣金',
'field'=>'元',
'count'=>self::getModelTime($where,UserBill::where('category','now_money')->where('type','brokerage'))->where('uid','in',function($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'分销商总佣金余额',
'field'=>'元',
'count'=>self::getModelTime($where,self::where('status',1)->where('is_promoter',1))->sum('now_money'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'分销商总提现佣金',
'field'=>'元',
'count'=>self::getModelTime($where,UserExtract::where('status',1))->sum('extract_price'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'本月分销商业务佣金',
'field'=>'元',
'count'=>self::getModelTime(['data'=>'month'],UserBill::where('category','now_money')->where('type','brokerage'))
->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'本月分销商佣金提现金额',
'field'=>'元',
'count'=>self::getModelTime(['data'=>'month'],UserExtract::where('status',1))
->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->field('uid');
})->sum('extract_price'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
[
'name'=>'上月分销商业务佣金',
'field'=>'元',
'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->where('type','brokerage'))->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
[
'name'=>'上月分销商佣金提现金额',
'field'=>'元',
'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->where('type','brokerage'))->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
];
}
/*
* 分销会员
* 分销数量 饼状图
* 分销商会员访问量 曲线
* 获取购物会员人数趋势图 曲线
* 多次购物分销会员数量 饼状图
* $where array 条件
* $limit int n条数据后出拖动条
* return array
*/
public static function getUserDistributionChart($where,$limit=20){
//分销数量
$fenbu_user=self::getModelTime($where,new self)->field(['count(uid) as num'])->group('is_promoter')->select();
count($fenbu_user) && $fenbu_user=$fenbu_user->toArray();
$sum_user=0;
$fenbu_data=[];
$fenbu_xdata=['分销商','非分销商'];
$color=['#81BCFE','#91F3FE'];
foreach($fenbu_user as $item){
$sum_user+=$item['num'];
}
foreach ($fenbu_user as $key=>$item){
$value['value']=bcdiv($item['num'],$sum_user,2)*100;
$value['name']=isset($fenbu_xdata[$key]) ?$fenbu_xdata[$key].' %'.$value['value'] :'';
$value['itemStyle']['color']=$color[$key];
$fenbu_data[]=$value;
}
//分销商会员访问量
$visit=self::getModelTime($where,self::alias('a')->join('store_visit t','t.uid=a.uid'),'t.add_time')
->where('a.is_promoter',1)
->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($visit) && $visit=$visit->toArray();
$visit_data=[];
$visit_xdata=[];
$visit_zoom='';
foreach ($visit as $item){
$visit_data[]=$item['count_user'];
$visit_xdata[]=$item['_add_time'];
}
count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
//获取购物会员人数趋势图
$list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where(['r.paid'=>1,'a.is_promoter'=>1])
->where('a.add_time','neq',0)
->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$zoom='';
foreach ($list as $item){
$seriesdata[]=$item['count_user'];
$xdata[]=$item['_add_time'];
}
count($xdata) > $limit && $zoom=$xdata[$limit-5];
//多次购物分销会员数量饼状图
$count=self::getModelTime($where,self::where('is_promoter',1))->count();
$user_count=self::getModelTime($where,self::alias('a')
->join('store_order r','r.uid=a.uid'),'a.add_time')
->where('a.is_promoter',1)
->where('r.paid',1)
->group('a.uid')
->count();
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0].$user_count.'人',
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1].($count-$user_count).'人',
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('fenbu_data','fenbu_xdata','visit_data','visit_xdata','visit_zoom','seriesdata','xdata','zoom','shop_xdata','shop_data');
}
/*
* 分销商佣金提现排行榜
* 分销商佣金总额排行榜
* $limit 截取条数
* return array
*/
public static function getUserDistributionTop10List($limit){
//分销商佣金提现排行榜
$extract=self::alias('a')
->join('user_extract t','a.uid=t.uid')
->where(['t.status'=>1,'a.is_promoter'=>1])
->group('t.uid')
->field(['a.nickname','a.phone','sum(t.extract_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','t.uid'])
->order('sum_price desc')
->limit($limit)
->select();
count($extract) && $extract=$extract->toArray();
//分销商佣金总额排行榜
$commission=UserBill::alias('l')
->join('user a','l.uid=a.uid')
->where(['l.status'=>'1','l.category'=>'now_money','l.type'=>'brokerage','a.is_promoter'=>1])
->group('l.uid')
->field(['a.nickname','a.phone','sum(number) as sum_number','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
->order('sum_number desc')
->limit($limit)
->select();
count($commission) && $commission=$commission->toArray();
return compact('extract','commission');
}
}
\ No newline at end of file
+
* @day: 2017/11/11
*/
namespace app\admin\model\user;
use app\admin\model\order\StoreOrder;
use traits\ModelTrait;
use app\wap\model\user\UserBill;
use basic\ModelBasic;
use app\admin\model\wechat\WechatUser;
use app\admin\model\store\StoreCouponUser;
use app\admin\model\user\UserExtract;
/**
* 用户管理 model
* Class User
* @package app\admin\model\user
*/
class User extends ModelBasic
{
use ModelTrait;
/**
* @param $where
* @return array
*/
public static function systemPage($where){
$model = new self;
if($where['status'] != '') $model = $model->where('status',$where['status']);
if($where['is_promoter'] != '') $model = $model->where('is_promoter',$where['is_promoter']);
if(isset($where['user_type']) && $where['user_type'] != '') $model = $model->where('user_type',$where['user_type']);
if($where['nickname'] != '') $model = $model->where('nickname|uid','like',"%$where[nickname]%");
$model = $model->order('uid desc');
return self::page($model,function ($item){
if($item['spread_uid']){
$item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname');
}else{
$item['spread_uid_nickname'] = '无';
}
},$where);
}
/*
* 设置搜索条件
*
*/
public static function setWhere($where)
{
if($where['order']!=''){
$model=self::order(self::setOrder($where['order']));
}else{
$model=self::order('u.uid desc');
}
if($where['user_time_type'] == 'visitno' && $where['user_time'] != ''){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', ['>', strtotime($endTime)+24*3600], ['<', strtotime($startTime)],'or');
}
if($where['user_time_type'] == 'visit' && $where['user_time'] != ''){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.last_time', '>', strtotime($startTime));
$model = $model->where('u.last_time', '<', strtotime($endTime)+24*3600);
}
if($where['user_time_type'] == 'add_time' && $where['user_time'] != ''){
list($startTime, $endTime) = explode(' - ', $where['user_time']);
$model = $model->where('u.add_time', '>', strtotime($startTime));
$model = $model->where('u.add_time', '<', strtotime($endTime)+24*3600);
}
if($where['pay_count'] !== '') {
if($where['pay_count'] == '-1') $model = $model->where('pay_count',0);
else $model = $model->where('pay_count','>',$where['pay_count']);
}
if($where['user_type'] != ''){
if($where['user_type'] == 'routine') $model = $model->where('w.routine_openid','not null');
else if($where['user_type'] == 'wechat') $model = $model->where('w.openid','not null');
}
if($where['country'] != ''){
if($where['country'] == 'domestic') $model = $model->where('w.country','EQ','中国');
else if($where['country'] == 'abroad') $model = $model->where('w.country','NEQ','中国');
}
return $model;
}
/**
* 异步获取当前用户 信息
* @param $where
* @return array
*/
public static function getUserList($where){
$model = self::setWherePage(self::setWhere($where),$where,['w.sex','w.province','w.city','u.status','u.is_promoter'],['u.nickname','u.uid']);
$list = $model->alias('u')
->join('WechatUser w','u.uid=w.uid')
->field('u.*,w.country,w.province,w.city,w.sex,w.unionid,w.openid,w.routine_openid,w.groupid,w.tagid_list,w.subscribe,w.subscribe_time')
->page((int)$where['page'],(int)$where['limit'])
->select()
->each(function ($item){
$item['add_time']=date('Y-m-d H:i:s',$item['add_time']);
if($item['last_time']) $item['last_time'] = date('Y-m-d H:i:s',$item['last_time']);//最近一次访问日期
else $item['last_time'] = '无访问';//最近一次访问日期
self::edit(['pay_count'=>StoreOrder::getUserCountPay($item['uid'])],$item['uid']);
$item['extract_count_price'] = UserExtract::getUserCountPrice($item['uid']);//累计提现
if($item['spread_uid']){
$item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname').'/'.$item['spread_uid'];
}else{
$item['spread_uid_nickname'] = '无';
}
if($item['openid'] != '' && $item['routine_openid'] != ''){
$item['user_type']='公众号小程序类型';
}else if($item['openid'] == '' && $item['routine_openid'] != ''){
$item['user_type']='小程序类型';
}else if($item['openid'] != '' && $item['routine_openid'] == ''){
$item['user_type']='公众号类型';
}else $item['user_type']='其他类型';
if($item['sex'] == 1){
$item['sex']='男';
}else if($item['sex'] == 2){
$item['sex']='女';
}else $item['sex']='保密';
})->toArray();
$count=self::setWherePage(self::setWhere($where),$where,['w.sex','w.province','w.city','u.status','u.is_promoter'],['u.nickname','u.uid'])->alias('u')->join('WechatUser w','u.uid=w.uid')->count();
return ['count'=>$count,'data'=>$list];
}
/**
* 修改用户状态
* @param $uids 用户uid
* @param $status 修改状态
* @return array
*/
public static function destrSyatus($uids,$status){
if(empty($uids) && !is_array($uids)) return false;
if($status=='') return false;
self::beginTrans();
try{
$res=self::where('uid','in',$uids)->update(['status'=>$status]);
self::checkTrans($res);
return true;
}catch (\Exception $e){
self::rollbackTrans();
return Json::fail($e->getMessage());
}
}
/*
* 获取某季度,某年某年后的时间戳
*
* self::getMonth('n',1) 获取当前季度的上个季度的时间戳
* self::getMonth('n') 获取当前季度的时间戳
*/
public static function getMonth($time='',$ceil=0){
if(empty($time)){
$firstday = date("Y-m-01",time());
$lastday = date("Y-m-d",strtotime("$firstday +1 month -1 day"));
}else if($time=='n'){
if($ceil!=0)
$season = ceil(date('n') /3)-$ceil;
else
$season = ceil(date('n') /3);
$firstday=date('Y-m-01',mktime(0,0,0,($season - 1) *3 +1,1,date('Y')));
$lastday=date('Y-m-t',mktime(0,0,0,$season * 3,1,date('Y')));
}else if($time=='y'){
$firstday=date('Y-01-01');
$lastday=date('Y-12-31');
}else if($time=='h'){
$firstday = date('Y-m-d', strtotime('this week +'.$ceil.' day')) . ' 00:00:00';
$lastday = date('Y-m-d', strtotime('this week +'.($ceil+1).' day')) . ' 23:59:59';
}
return array($firstday,$lastday);
}
public static function getcount(){
return self::count();
}
/*
*获取用户某个时间段的消费信息
*
* reutrn Array || number
*/
public static function consume($where,$status='',$keep=''){
$model = new self;
$user_id=[];
if(is_array($where)){
if($where['is_promoter']!='') $model=$model->where('is_promoter',$where['is_promoter']);
if($where['status']!='') $model=$model->where('status',$where['status']);
switch ($where['date']){
case null:case 'today':case 'week':case 'year':
if($where['date']==null){
$where['date']='month';
}
if($keep){
$model=$model->whereTime('add_time',$where['date'])->whereTime('last_time',$where['date']);
}else{
$model=$model->whereTime('add_time',$where['date']);
}
break;
case 'quarter':
$quarter=self::getMonth('n');
$startTime=strtotime($quarter[0]);
$endTime=strtotime($quarter[1]);
if($keep){
$model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime)->where('last_time','>',$startTime)->where('last_time','<',$endTime);
}else{
$model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime);
}
break;
default:
//自定义时间
if(strstr($where['date'],'-')!==FALSE){
list($startTime,$endTime)=explode('-',$where['date']);
$model = $model->where('add_time','>',strtotime($startTime))->where('add_time','<',strtotime($endTime));
}else{
$model=$model->whereTime('add_time','month');
}
break;
}
}else{
if(is_array($status)){
$model=$model->where('add_time','>',$status[0])->where('add_time','<',$status[1]);
}
}
if($keep===true){
return $model->count();
}
if($status==='default'){
return $model->group('from_unixtime(add_time,\'%Y-%m-%d\')')->field('count(uid) num,from_unixtime(add_time,\'%Y-%m-%d\') add_time,uid')->select()->toArray();
}
if($status==='grouping'){
return $model->group('user_type')->field('user_type')->select()->toArray();
}
$uid=$model->field('uid')->select()->toArray();
foreach ($uid as $val){
$user_id[]=$val['uid'];
}
if(empty($user_id)){
$user_id=[0];
}
if($status==='xiaofei'){
$list=UserBill::where('uid','in',$user_id)
->group('type')
->field('sum(number) as top_number,title')
->select()
->toArray();
$series=[
'name'=>isset($list[0]['title'])?$list[0]['title']:'',
'type'=>'pie',
'radius'=> ['40%', '50%'],
'data'=>[]
];
foreach($list as $key=>$val){
$series['data'][$key]['value']=$val['top_number'];
$series['data'][$key]['name']=$val['title'];
}
return $series;
}else if($status==='form'){
$list=WechatUser::where('uid','in',$user_id)->group('city')->field('count(city) as top_city,city')->limit(0,10)->select()->toArray();
$count=self::getcount();
$option=[
'legend_date'=>[],
'series_date'=>[]
];
foreach($list as $key=>$val){
$num=$count!=0?(bcdiv($val['top_city'],$count,2))*100:0;
$t=['name'=>$num.'% '.(empty($val['city'])?'未知':$val['city']),'icon'=>'circle'];
$option['legend_date'][$key]=$t;
$option['series_date'][$key]=['value'=>$num,'name'=>$t['name']];
}
return $option;
}else{
$number=UserBill::where('uid','in',$user_id)->where('type','pay_product')->sum('number');
return $number;
}
}
/*
* 获取 用户某个时间段的钱数或者TOP20排行
*
* return Array || number
*/
public static function getUserSpend($date,$status=''){
$model=new self();
$model=$model->alias('A');
switch ($date){
case null:case 'today':case 'week':case 'year':
if($date==null) $date='month';
$model=$model->whereTime('A.add_time',$date);
break;
case 'quarter':
list($startTime,$endTime)=User::getMonth('n');
$model = $model->where('A.add_time','>',strtotime($startTime));
$model = $model->where('A.add_time','<',strtotime($endTime));
break;
default:
list($startTime,$endTime)=explode('-',$date);
$model = $model->where('A.add_time','>',strtotime($startTime));
$model = $model->where('A.add_time','<',strtotime($endTime));
break;
}
if($status===true){
return $model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
}
$list=$model->join('user_bill B','B.uid=A.uid')
->where('B.type','pay_product')
->where('B.pm',0)
->field('sum(B.number) as totel_number,A.nickname,A.avatar,A.now_money,A.uid,A.add_time')
->order('totel_number desc')
->limit(0,20)
->select()
->toArray();
if(!isset($list[0]['totel_number'])){
$list=[];
}
return $list;
}
/*
* 获取 相对于上月或者其他的数据
*
* return Array
*/
public static function getPostNumber($date,$status=false,$field='A.add_time',$t='消费'){
$model=new self();
if(!$status) $model=$model->alias('A');
switch ($date){
case null:case 'today':case 'week':case 'year':
if($date==null) {
$date='last month';
$title='相比上月用户'.$t.'增长';
}
if($date=='today') {
$date='yesterday';
$title='相比昨天用户'.$t.'增长';
}
if($date=='week') {
$date='last week';
$title='相比上周用户'.$t.'增长';
}
if($date=='year') {
$date='last year';
$title='相比去年用户'.$t.'增长';
}
$model=$model->whereTime($field,$date);
break;
case 'quarter':
$title='相比上季度用户'.$t.'增长';
list($startTime,$endTime)=User::getMonth('n',1);
$model = $model->where($field,'>',$startTime);
$model = $model->where($field,'<',$endTime);
break;
default:
list($startTime,$endTime)=explode('-',$date);
$title='相比'.$startTime.'-'.$endTime.'时间段用户'.$t.'增长';
$Time=strtotime($endTime)-strtotime($startTime);
$model = $model->where($field,'>',strtotime($startTime)+$Time);
$model = $model->where($field,'<',strtotime($endTime)+$Time);
break;
}
if($status){
return [$model->count(),$title];
}
$number=$model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
return [$number,$title];
}
//获取用户新增,头部信息
public static function getBadgeList($where){
$user_count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->count();
$user_count_old=self::getOldDate($where)->count();
$fenxiao=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->where('spread_uid','<>',0)->count();
$fenxiao_count=self::getOldDate($where)->where('spread_uid','neq',0)->count();
$newFemxiao_count=bcsub($fenxiao,$fenxiao_count,0);
$order_count=bcsub($user_count,$user_count_old,0);
return [
[
'name'=>'会员人数',
'field'=>'个',
'count'=>$user_count,
'content'=>'会员总人数',
'background_color'=>'layui-bg-blue',
'sum'=>self::count(),
'class'=>'fa fa-bar-chart',
],
[
'name'=>'会员增长',
'field'=>'个',
'count'=>$order_count,
'content'=>'会员增长率',
'background_color'=>'layui-bg-cyan',
'sum'=>$user_count_old ? bcdiv($order_count,$user_count_old,2)*100:0,
'class'=>'fa fa-line-chart',
],
[
'name'=>'分销人数',
'field'=>'个',
'count'=>$fenxiao,
'content'=>'分销总人数',
'background_color'=>'layui-bg-green',
'sum'=>self::where('spread_uid','neq',0)->count(),
'class'=>'fa fa-bar-chart',
],
[
'name'=>'分销增长',
'field'=>'个',
'count'=>$newFemxiao_count,
'content'=>'分销总人数',
'background_color'=>'layui-bg-orange',
'sum'=>$fenxiao_count ? bcdiv($newFemxiao_count,$fenxiao_count,2)*100:0,
'class'=>'fa fa-cube',
],
];
}
/*
* 获取会员增长曲线图和分布图
* $where 查询条件
* $limit 显示条数,是否有滚动条
*/
public static function getUserChartList($where,$limit=20){
$list=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])
->where('add_time','neq',0)
->field(['FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time','count(uid) as num'])
->order('_add_time asc')
->group('_add_time')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$Zoom='';
foreach ($list as $item){
$seriesdata[]=$item['num'];
$xdata[]=$item['_add_time'];
}
(count($xdata) > $limit) && $Zoom=$xdata[$limit-5];
//多次购物会员数量饼状图
$count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter'])->count();
$user_count=self::setWherePage(self::getModelTime($where,self::alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time'),$where,['is_promoter'])
->where('r.paid',1)->count('a.uid');
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0],
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1],
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('shop_data','shop_xdata','fenbu_data','fenbu_xdata','seriesdata','xdata','Zoom');
}
//获取$date的前一天或者其他的时间段
public static function getOldDate($where,$moedls=null){
$model=$moedls ===null ? self::setWherePage(new self(),$where,['is_promoter','status']) :$moedls;
switch ($where['data']){
case 'today':
$model=$model->whereTime('add_time','yesterday');
break;
case 'week':
$model=$model->whereTime('add_time','last week');
break;
case 'month':
$model=$model->whereTime('add_time','last month');
break;
case 'year':
$model=$model->whereTime('add_time','last year');
break;
case 'quarter':
$time=self::getMonth('n',1);
$model=$model->where('add_time','between',$time);
break;
}
return $model;
}
//获取用户属性和性别分布图
public static function getEchartsData($where){
$model=self::alias('a');
$data=self::getModelTime($where,$model,'a.add_time')
->join('wechat_user r','r.uid=a.uid')
->group('r.province')
->field('count(r.province) as count,province')
->order('count desc')
->limit(15)
->select();
if(count($data)) $data=$data->toArray();
$legdata=[];
$dataList=[];
foreach ($data as $value){
$value['province']=='' && $value['province']='未知省份';
$legdata[]=$value['province'];
$dataList[]=$value['count'];
}
$model=self::alias('a');
$sex=self::getModelTime($where,$model,'a.add_time')
->join('wechat_user r','r.uid=a.uid')
->group('r.sex')
->field('count(r.uid) as count,sex')
->order('count desc')
->select();
if(count($sex)) $sex=$sex->toArray();
$sexlegdata=['男','女','未知'];
$sexcount=self::getModelTime($where,new self())->count();
$sexList=[];
$color=['#FB7773','#81BCFE','#91F3FE'];
foreach ($sex as $key=>$item){
if($item['sex']==1){
$item_date['name']='男';
}else if($item['sex']==2){
$item_date['name']='女';
}else{
$item_date['name']='未知性别';
}
$item_date['value']=bcdiv($item['count'],$sexcount,2)*100;
$item_date['itemStyle']['color']=$color[$key];
$sexList[]=$item_date;
}
return compact('sexList','sexlegdata','legdata','dataList');
}
//获取佣金记录列表
public static function getCommissionList($where){
$list=self::setCommissionWhere($where)
->page((int)$where['page'],(int)$where['limit'])
->select();
count($list) && $list=$list->toArray();
foreach ($list as &$value){
$value['ex_price']=db('user_extract')->where(['uid'=>$value['uid']])->sum('extract_price');
$value['extract_price']=db('user_extract')->where(['uid'=>$value['uid'],'status'=>1])->sum('extract_price');
}
$count=self::setCommissionWhere($where)->count();
return ['data'=>$list,'count'=>$count];
}
//获取佣金记录列表的查询条件
public static function setCommissionWhere($where){
$models=self::setWherePage(self::alias('A'),$where,[],['A.nickname','A.uid'])
->join('user_bill B','B.uid=A.uid')
->group('A.uid')
->where(['B.category'=>'now_money','B.type'=>'brokerage'])
->field(['sum(B.number) as sum_number','A.nickname','A.uid','A.now_money']);
if($where['order']==''){
$models=$models->order('sum_number desc');
}else{
$models=$models->order($where['order']==1 ? 'sum_number desc':'sum_number asc');
}
if($where['price_max']!='' && $where['price_min']!=''){
$models=$models->where('now_money','between',[$where['price_max'],$where['price_min']]);
}
return $models;
}
//获取某人用户推广信息
public static function getUserinfo($uid){
$userinfo=self::where(['uid'=>$uid])->field(['nickname','spread_uid','now_money','add_time'])->find()->toArray();
$userinfo['number']=UserBill::where(['category'=>'now_money','type'=>'brokerage'])->sum('number');
$userinfo['spread_name']=$userinfo['spread_uid'] ? self::where(['uid'=>$userinfo['spread_uid']])->value('nickname') :'';
return $userinfo;
}
//获取某用户的详细信息
public static function getUserDetailed($uid){
$key_field=['real_name','phone','province','city','district','detail','post_code'];
$Address=($thisAddress=db('user_address')->where(['uid'=>$uid,'is_default'=>1])->field($key_field)->find()) ?
$thisAddress :
db('user_address')->where(['uid'=>$uid])->field($key_field)->find();
$UserInfo=self::get($uid);
return [
['col'=>12,'name'=>'默认收货地址','value'=>$thisAddress ? '收货人:'.$thisAddress['real_name'].'邮编:'.$thisAddress['post_code'].' 收货人电话:'.$thisAddress['phone'].' 地址:'.$thisAddress['province'].' '.$thisAddress['city'].' '.$thisAddress['district'].' '.$thisAddress['detail'] : ''],
// ['name'=>'微信OpenID','value'=>WechatUser::where(['uid'=>$uid])->value('openid'),'col'=>8],
['name'=>'手机号码','value'=>$UserInfo['phone']],
// ['name'=>'ID','value'=>$uid],
['name'=>'姓名','value'=>''],
['name'=>'微信昵称','value'=>$UserInfo['nickname']],
['name'=>'邮箱','value'=>''],
['name'=>'生日','value'=>''],
['name'=>'积分','value'=>UserBill::where(['category'=>'integral','uid'=>$uid])->where('type','in',['sign','system_add'])->sum('number')],
['name'=>'上级推广人','value'=>$UserInfo['spread_uid'] ? self::where(['uid'=>$UserInfo['spread_uid']])->value('nickname'):''],
['name'=>'账户余额','value'=>$UserInfo['now_money']],
['name'=>'佣金总收入','value'=>UserBill::where(['category'=>'now_money','type'=>'brokerage','uid'=>$uid])->sum('number')],
['name'=>'提现总金额','value'=>db('user_extract')->where(['uid'=>$uid,'status'=>1])->sum('extract_price')],
];
}
//获取某用户的订单个数,消费明细
public static function getHeaderList($uid){
return [
[
'title'=>'总计订单',
'value'=>StoreOrder::where(['uid'=>$uid])->count(),
'key'=>'笔',
'class'=>'',
],
[
'title'=>'总消费金额',
'value'=>StoreOrder::where(['uid'=>$uid,'paid'=>1])->sum('total_price'),
'key'=>'元',
'class'=>'',
],
[
'title'=>'本月订单',
'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->count(),
'key'=>'笔',
'class'=>'',
],
[
'title'=>'本月消费金额',
'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->sum('total_price'),
'key'=>'元',
'class'=>'',
]
];
}
/*
* 获取 会员 订单个数,积分明细,优惠劵明细
*
* $uid 用户id;
*
* return array
*/
public static function getCountInfo($uid){
$order_count=StoreOrder::where(['uid'=>$uid])->count();
$integral_count=UserBill::where(['uid'=>$uid,'category'=>'integral'])->where('type','in',['deduction','system_add'])->count();
$sign_count=UserBill::where(['uid'=>$uid,'category'=>'integral','type'=>'sign'])->count();
$balanceChang_count=UserBill::where(['uid'=>$uid,'category'=>'now_money'])
->where('type','in',['system_add','pay_product','extract','pay_product_refund','system_sub'])
->count();
$coupon_count=StoreCouponUser::where(['uid'=>$uid])->count();
$spread_count=self::where(['spread_uid'=>$uid])->count();
return compact('order_count','integral_count','sign_count','balanceChang_count','coupon_count','spread_count');
}
/*
* 获取 会员业务的
* 购物会员统计
* 会员访问量
*
* 曲线图
*
* $where 查询条件
*
* return array
*/
public static function getUserBusinessChart($where,$limit=20){
//获取购物会员人数趋势图
$list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where(['r.paid'=>1,'a.is_promoter'=>0])
->where('a.add_time','neq',0)
->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$zoom='';
foreach ($list as $item){
$seriesdata[]=$item['count_user'];
$xdata[]=$item['_add_time'];
}
count($xdata) > $limit && $zoom=$xdata[$limit-5];
//会员访问量
$visit=self::getModelTime($where,self::alias('a')->join('store_visit t','t.uid=a.uid'),'t.add_time')
->where('a.is_promoter',0)
->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($visit) && $visit=$visit->toArray();
$visit_data=[];
$visit_xdata=[];
$visit_zoom='';
foreach ($visit as $item){
$visit_data[]=$item['count_user'];
$visit_xdata[]=$item['_add_time'];
}
count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
//多次购物会员数量饼状图
$count=self::getModelTime($where,self::where('is_promoter',0))->count();
$user_count=self::getModelTime($where,self::alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where('a.is_promoter',0)
->where('r.paid',1)
->group('a.uid')
->count();
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0],
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1],
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('seriesdata','xdata','zoom','visit_data','visit_xdata','visit_zoom','shop_data','shop_xdata');
}
/*
* 获取用户
* 积分排行
* 会员余额排行榜
* 分销商佣金总额排行榜
* 购物笔数排行榜
* 购物金额排行榜
* 分销商佣金提现排行榜
* 上月消费排行榜
* $limit 查询多少条
* return array
*/
public static function getUserTop10List($limit=10,$is_promoter=0){
//积分排行
$integral=self::where('status',1)
->where('is_promoter',$is_promoter)
->order('integral desc')
->field(['nickname','phone','integral','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
->limit($limit)
->select();
count($integral) && $integral=$integral->toArray();
//会员余额排行榜
$now_money=self::where('status',1)
->where('is_promoter',$is_promoter)
->order('now_money desc')
->field(['nickname','phone','now_money','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
->limit($limit)
->select();
count($now_money) && $now_money=$now_money->toArray();
//购物笔数排行榜
$shopcount=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->group('r.uid')
->field(['a.nickname','a.phone','count(r.uid) as sum_count','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
->order('sum_count desc')
->limit($limit)
->select();
count($shopcount) && $shopcount=$shopcount->toArray();
//购物金额排行榜
$order=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->group('r.uid')
->field(['a.nickname','a.phone','sum(r.pay_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','r.uid'])
->order('sum_price desc')
->limit($limit)
->select();
count($order) && $order=$order->toArray();
//上月消费排行
$lastorder=self::alias('a')
->join('store_order r','r.uid=a.uid')
->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
->whereTime('r.pay_time','last month')
->group('r.uid')
->field(['a.nickname','a.phone','sum(r.pay_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','r.uid'])
->order('sum_price desc')
->limit($limit)
->select();
return compact('integral','now_money','shopcount','order','lastorder');
}
/*
* 获取 会员业务
* 会员总余额 会员总积分
* $where 查询条件
*
* return array
*/
public static function getUserBusinesHeade($where){
return [
[
'name'=>'会员总余额',
'field'=>'元',
'count'=>self::getModelTime($where,self::where('status',1))->sum('now_money'),
'background_color'=>'layui-bg-cyan',
'col'=>6,
],
[
'name'=>'会员总积分',
'field'=>'分',
'count'=>self::getModelTime($where,self::where('status',1))->sum('integral'),
'background_color'=>'layui-bg-cyan',
'col'=>6
]
];
}
/*
* 分销会员头部信息查询获取
*
* 分销商总佣金余额
* 分销商总提现佣金
* 本月分销商业务佣金
* 本月分销商佣金提现金额
* 上月分销商业务佣金
* 上月分销商佣金提现金额
* $where array 时间条件
*
* return array
*/
public static function getDistributionBadgeList($where){
return [
[
'name'=>'分销商总佣金',
'field'=>'元',
'count'=>self::getModelTime($where,UserBill::where('category','now_money')->where('type','brokerage'))->where('uid','in',function($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'分销商总佣金余额',
'field'=>'元',
'count'=>self::getModelTime($where,self::where('status',1)->where('is_promoter',1))->sum('now_money'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'分销商总提现佣金',
'field'=>'元',
'count'=>self::getModelTime($where,UserExtract::where('status',1))->sum('extract_price'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'本月分销商业务佣金',
'field'=>'元',
'count'=>self::getModelTime(['data'=>'month'],UserBill::where('category','now_money')->where('type','brokerage'))
->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>3,
],
[
'name'=>'本月分销商佣金提现金额',
'field'=>'元',
'count'=>self::getModelTime(['data'=>'month'],UserExtract::where('status',1))
->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->field('uid');
})->sum('extract_price'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
[
'name'=>'上月分销商业务佣金',
'field'=>'元',
'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->where('type','brokerage'))->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
[
'name'=>'上月分销商佣金提现金额',
'field'=>'元',
'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
$query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
})->where('type','brokerage'))->sum('number'),
'background_color'=>'layui-bg-cyan',
'col'=>4,
],
];
}
/*
* 分销会员
* 分销数量 饼状图
* 分销商会员访问量 曲线
* 获取购物会员人数趋势图 曲线
* 多次购物分销会员数量 饼状图
* $where array 条件
* $limit int n条数据后出拖动条
* return array
*/
public static function getUserDistributionChart($where,$limit=20){
//分销数量
$fenbu_user=self::getModelTime($where,new self)->field(['count(uid) as num'])->group('is_promoter')->select();
count($fenbu_user) && $fenbu_user=$fenbu_user->toArray();
$sum_user=0;
$fenbu_data=[];
$fenbu_xdata=['分销商','非分销商'];
$color=['#81BCFE','#91F3FE'];
foreach($fenbu_user as $item){
$sum_user+=$item['num'];
}
foreach ($fenbu_user as $key=>$item){
$value['value']=bcdiv($item['num'],$sum_user,2)*100;
$value['name']=isset($fenbu_xdata[$key]) ?$fenbu_xdata[$key].' %'.$value['value'] :'';
$value['itemStyle']['color']=$color[$key];
$fenbu_data[]=$value;
}
//分销商会员访问量
$visit=self::getModelTime($where,self::alias('a')->join('store_visit t','t.uid=a.uid'),'t.add_time')
->where('a.is_promoter',1)
->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($visit) && $visit=$visit->toArray();
$visit_data=[];
$visit_xdata=[];
$visit_zoom='';
foreach ($visit as $item){
$visit_data[]=$item['count_user'];
$visit_xdata[]=$item['_add_time'];
}
count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
//获取购物会员人数趋势图
$list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('store_order r','r.uid=a.uid'),'a.add_time')
->where(['r.paid'=>1,'a.is_promoter'=>1])
->where('a.add_time','neq',0)
->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
->group('_add_time')
->order('_add_time asc')
->select();
count($list) && $list=$list->toArray();
$seriesdata=[];
$xdata=[];
$zoom='';
foreach ($list as $item){
$seriesdata[]=$item['count_user'];
$xdata[]=$item['_add_time'];
}
count($xdata) > $limit && $zoom=$xdata[$limit-5];
//多次购物分销会员数量饼状图
$count=self::getModelTime($where,self::where('is_promoter',1))->count();
$user_count=self::getModelTime($where,self::alias('a')
->join('store_order r','r.uid=a.uid'),'a.add_time')
->where('a.is_promoter',1)
->where('r.paid',1)
->group('a.uid')
->count();
$shop_xdata=['多次购买数量占比','无购买数量占比'];
$shop_data=[];
$count >0 && $shop_data=[
[
'value'=>bcdiv($user_count,$count,2)*100,
'name'=>$shop_xdata[0].$user_count.'人',
'itemStyle'=>[
'color'=>'#D789FF',
]
],
[
'value'=>bcdiv($count-$user_count,$count,2)*100,
'name'=>$shop_xdata[1].($count-$user_count).'人',
'itemStyle'=>[
'color'=>'#7EF0FB',
]
]
];
return compact('fenbu_data','fenbu_xdata','visit_data','visit_xdata','visit_zoom','seriesdata','xdata','zoom','shop_xdata','shop_data');
}
/*
* 分销商佣金提现排行榜
* 分销商佣金总额排行榜
* $limit 截取条数
* return array
*/
public static function getUserDistributionTop10List($limit){
//分销商佣金提现排行榜
$extract=self::alias('a')
->join('user_extract t','a.uid=t.uid')
->where(['t.status'=>1,'a.is_promoter'=>1])
->group('t.uid')
->field(['a.nickname','a.phone','sum(t.extract_price) as sum_price','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time','t.uid'])
->order('sum_price desc')
->limit($limit)
->select();
count($extract) && $extract=$extract->toArray();
//分销商佣金总额排行榜
$commission=UserBill::alias('l')
->join('user a','l.uid=a.uid')
->where(['l.status'=>'1','l.category'=>'now_money','l.type'=>'brokerage','a.is_promoter'=>1])
->group('l.uid')
->field(['a.nickname','a.phone','sum(number) as sum_number','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
->order('sum_number desc')
->limit($limit)
->select();
count($commission) && $commission=$commission->toArray();
return compact('extract','commission');
}
public static function getSpreadList($uid,$page,$limit){
$list=self::where(['spread_uid'=>$uid])->field(['uid','nickname','now_money','integral','add_time'])
->order('uid desc')->page((int)$page,(int)$limit)->select();
count($list) && $list=$list->toArray();
foreach ($list as &$item){
$item['add_time']=date('Y-m-d H',$item['add_time']);
}
return $list;
}
}
\ No newline at end of file
diff --git a/application/admin/model/user/UserBill.php b/application/admin/model/user/UserBill.php
index 50ba732d..95298ca8 100644
--- a/application/admin/model/user/UserBill.php
+++ b/application/admin/model/user/UserBill.php
@@ -16,11 +16,17 @@ class UserBill extends ModelBasic
{
use ModelTrait;
+ protected $insert = ['add_time'];
+
+ protected function setAddTimeAttr()
+ {
+ return time();
+ }
+
public static function income($title,$uid,$category,$type,$number,$link_id = 0,$balance = 0,$mark = '',$status = 1){
$pm = 1;
return self::set(compact('title','uid','link_id','category','type','number','balance','mark','status','pm'));
}
-
//获取柱状图和饼状图数据
public static function getUserBillChart($where,$category='now_money',$type='brokerage',$pm=1,$zoom=15){
$model=self::getModelTime($where,new self());
diff --git a/application/admin/view/finance/user_extract/index.php b/application/admin/view/finance/user_extract/index.php
index ef1cbc56..edade717 100644
--- a/application/admin/view/finance/user_extract/index.php
+++ b/application/admin/view/finance/user_extract/index.php
@@ -169,115 +169,66 @@
-
-
{/block}
-
{block name="script"}
-
{/block}
diff --git a/application/admin/view/system/system_databackup/index.php b/application/admin/view/system/system_databackup/index.php
index f4229bd9..8c808804 100644
--- a/application/admin/view/system/system_databackup/index.php
+++ b/application/admin/view/system/system_databackup/index.php
@@ -10,7 +10,7 @@