diff --git a/.htaccess b/.htaccess
deleted file mode 100644
index dd7fb8245..000000000
--- a/.htaccess
+++ /dev/null
@@ -1,8 +0,0 @@
-
+退款原因:{$item['refund_reason_wap']}
+HTML;
+ }else if($item['paid']==1 && $item['refund_status']==2){
+ $item['status_name']='已退款';
+ }
+ if($item['paid']==0 && $item['status']==0 && $item['refund_status']==0){
+ $item['_status']=1;
+ }else if($item['paid']==1 && $item['status']==0 && $item['refund_status']==0){
+ $item['_status']=2;
+ }else if($item['paid']==1 && $item['refund_status']==1){
+ $item['_status']=3;
+ }else if($item['paid']==1 && $item['status']==1 && $item['refund_status']==0){
+ $item['_status']=4;
+ }else if($item['paid']==1 && $item['status']==2 && $item['refund_status']==0){
+ $item['_status']=5;
+ }else if($item['paid']==1 && $item['status']==3 && $item['refund_status']==0){
+ $item['_status']=6;
+ }else if($item['paid']==1 && $item['refund_status']==2){
+ $item['_status']=7;
+ }
+ }
+ if(isset($where['excel']) && $where['excel']==1){
+ self::SaveExcel($data);
+ }
+ $count=self::getOrderWhere($where,self::alias('a')->join('user r','r.uid=a.uid','LEFT'),'a.','r')->count();
+ return compact('count','data');
+ }
+ /*
+ * 保存并下载excel
+ * $list array
+ * return
+ */
+ public static function SaveExcel($list){
+ $export = [];
+ foreach ($list as $index=>$item){
+ $_info = Db::name('store_order_cart_info')->where('oid',$item['id'])->column('cart_info');
+ $goodsName = [];
+ foreach ($_info as $k=>$v){
+ $v = json_decode($v,true);
+ $goodsName[] = implode(
+ [$v['productInfo']['store_name'],
+ isset($v['productInfo']['attrInfo']) ? '('.$v['productInfo']['attrInfo']['suk'].')' : '',
+ "[{$v['cart_num']} * {$v['truePrice']}]"
+ ],' ');
+ }
+ $item['cartInfo'] = $_info;
+ $export[] = [
+ $item['order_id'],$item['pay_type_name'],
+ $item['total_num'],$item['total_price'],$item['total_postage'],$item['pay_price'],$item['refund_price'],
+ $item['mark'],$item['remark'],
+ [$item['real_name'],$item['user_phone'],$item['user_address']],
+ $goodsName,
+ [$item['paid'] == 1? '已支付':'未支付','支付时间: '.($item['pay_time'] > 0 ? date('Y/md H:i',$item['pay_time']) : '暂无')]
+ ];
+ }
+ PHPExcelService::setExcelHeader(['订单号','支付方式','商品总数','商品总价','邮费','支付金额','退款金额','用户备注','管理员备注','收货人信息','商品信息','支付状态'])
+ ->setExcelTile('订单导出','订单信息'.time(),' 生成时间:'.date('Y-m-d H:i:s',time()))
+ ->setExcelContent($export)
+ ->ExcelSave();
+ }
+
/**
* @param $where
* @return array
*/
- public static function systemPage($where,$userid){
+ public static function systemPage($where,$userid=false){
$model = self::getOrderWhere($where,self::alias('a')->join('user r','r.uid=a.uid','LEFT'),'a.','r')->field('a.*,r.nickname');
if($where['order']){
$model = $model->order('a.'.$where['order']);
@@ -52,7 +219,7 @@ class StoreOrder extends ModelBasic
$payType = '其他支付';
}
- $_info = db('store_order_cart_info')->where('oid',$item['id'])->column('cart_info');
+ $_info = Db::name('store_order_cart_info')->where('oid',$item['id'])->column('cart_info');
$goodsName = [];
foreach ($_info as $k=>$v){
$v = json_decode($v,true);
@@ -80,37 +247,39 @@ class StoreOrder extends ModelBasic
->ExcelSave();
}
return self::page($model,function ($item){
- $item['nickname'] = WechatUser::where('uid',$item['uid'])->value('nickname');
- $_info = db('store_order_cart_info')->where('oid',$item['id'])->field('cart_info')->select();
+ $_info = Db::name('store_order_cart_info')->where('oid',$item['id'])->field('cart_info')->select();
foreach ($_info as $k=>$v){
$_info[$k]['cart_info'] = json_decode($v['cart_info'],true);
}
$item['_info'] = $_info;
if($item['pink_id'] && $item['combination_id']){
$pinkStatus = StorePink::where('order_id_key',$item['id'])->value('status');
- if($pinkStatus == 1){
- $item['pink_name'] = '[拼团订单]正在进行中';
- $item['color'] = '#f00';
- }else if($pinkStatus == 2){
- $item['pink_name'] = '[拼团订单]已完成';
- $item['color'] = '#00f';
- }else if($pinkStatus == 3){
- $item['pink_name'] = '[拼团订单]未完成';
- $item['color'] = '#f0f';
- }else{
- $item['pink_name'] = '[拼团订单]历史订单';
- $item['color'] = '#457856';
+ switch ($pinkStatus){
+ case 1:
+ $item['pink_name'] = '[拼团订单]正在进行中';
+ $item['color'] = '#f00';
+ break;
+ case 2:
+ $item['pink_name'] = '[拼团订单]已完成';
+ $item['color'] = '#00f';
+ break;
+ case 3:
+ $item['pink_name'] = '[拼团订单]未完成';
+ $item['color'] = '#f0f';
+ break;
+ default:
+ $item['pink_name'] = '[拼团订单]历史订单';
+ $item['color'] = '#457856';
+ break;
}
}else{
- if($item['seckill_id']){
- $item['pink_name'] = '[秒杀订单]';
- $item['color'] = '#32c5e9';
- }else{
- $item['pink_name'] = '[普通订单]';
- $item['color'] = '#895612';
- }
-
-
+ if($item['seckill_id']){
+ $item['pink_name'] = '[秒杀订单]';
+ $item['color'] = '#32c5e9';
+ }else{
+ $item['pink_name'] = '[普通订单]';
+ $item['color'] = '#895612';
+ }
}
},$where);
}
@@ -193,33 +362,114 @@ class StoreOrder extends ModelBasic
// $model = $model->where('combination_id',0);
if($where['status'] != '') $model = self::statusByWhere($where['status'],$model,$aler);
if($where['is_del'] != '' && $where['is_del'] != -1) $model = $model->where($aler.'is_del',$where['is_del']);
- if($where['combination_id'] =='普通订单'){
- $model = $model->where($aler.'combination_id',0)->where($aler.'seckill_id',0);
+ if(isset($where['combination_id'])){
+ if($where['combination_id'] =='普通订单'){
+ $model = $model->where($aler.'combination_id',0)->where($aler.'seckill_id',0);
+ }
+ if($where['combination_id'] =='拼团订单'){
+ $model = $model->where($aler.'combination_id',">",0)->where($aler.'pink_id',">",0);
+ }
+ if($where['combination_id'] =='秒杀订单'){
+ $model = $model->where($aler.'seckill_id',">",0);
+ }
}
- if($where['combination_id'] =='拼团订单'){
- $model = $model->where($aler.'combination_id',">",0)->where($aler.'pink_id',">",0);
- }
- if($where['combination_id'] =='秒杀订单'){
- $model = $model->where($aler.'seckill_id',">",0);
+ if(isset($where['type'])){
+ switch ($where['type']){
+ case 1:
+ $model = $model->where($aler.'combination_id',0)->where($aler.'seckill_id',0);
+ break;
+ case 2:
+ $model = $model->where($aler.'combination_id',">",0)->where($aler.'pink_id',">",0);
+ break;
+ case 3:
+ $model = $model->where($aler.'seckill_id',">",0);
+ break;
+ }
}
if($where['real_name'] != ''){
$model = $model->where($aler.'order_id|'.$aler.'real_name|'.$aler.'user_phone'.($join ? '|'.$join.'.nickname|'.$join.'.uid':''),'LIKE',"%$where[real_name]%");
}
if($where['data'] !== ''){
- list($startTime,$endTime) = explode(' - ',$where['data']);
- $model = $model->where($aler.'add_time','>',strtotime($startTime));
- $model = $model->where($aler.'add_time','<',strtotime($endTime));
+ $model = self::getModelTime($where,$model,$aler.'add_time');
}
return $model;
}
-
+ public static function getBadge($where){
+ $price=self::getOrderPrice($where);
+ return [
+ [
+ 'name'=>'订单数量',
+ 'field'=>'件',
+ 'count'=>$price['total_num'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'售出商品',
+ 'field'=>'件',
+ 'count'=>$price['total_num'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'订单金额',
+ 'field'=>'元',
+ 'count'=>$price['pay_price'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'退款金额',
+ 'field'=>'元',
+ 'count'=>$price['refund_price'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'微信支付金额',
+ 'field'=>'元',
+ 'count'=>$price['pay_price_wx'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'余额支付金额',
+ 'field'=>'元',
+ 'count'=>$price['pay_price_yue'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'线下支付金额',
+ 'field'=>'元',
+ 'count'=>$price['pay_price_offline'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'积分抵扣',
+ 'field'=>'分',
+ 'count'=>$price['use_integral'].'(抵扣金额:¥'.$price['deduction_price'].')',
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ],
+ [
+ 'name'=>'退回积分',
+ 'field'=>'元',
+ 'count'=>$price['back_integral'],
+ 'background_color'=>'layui-bg-blue',
+ 'col'=>2
+ ]
+ ];
+ }
/**
* 处理订单金额
* @param $where
* @return array
*/
public static function getOrderPrice($where){
+ $where['is_del'] = 0;//删除订单不统计
$model = new self;
$price = array();
$price['pay_price'] = 0;//支付金额
@@ -233,7 +483,7 @@ class StoreOrder extends ModelBasic
$price['deduction_price'] = 0;//抵扣金额
$price['total_num'] = 0; //商品总数
$model = self::getOrderWhere($where,$model);
- $list = $model->select()->toArray();
+ $list = $model->where('is_del',0)->select()->toArray();
foreach ($list as $v){
$price['total_num'] = bcadd($price['total_num'],$v['total_num'],0);
$price['pay_price'] = bcadd($price['pay_price'],$v['pay_price'],2);
@@ -274,7 +524,7 @@ class StoreOrder extends ModelBasic
$payType = '其他支付';
}
- $_info = db('store_order_cart_info')->where('oid',$item['id'])->column('cart_info');
+ $_info = Db::name('store_order_cart_info')->where('oid',$item['id'])->column('cart_info');
$goodsName = [];
foreach ($_info as $k=>$v){
$v = json_decode($v,true);
@@ -301,7 +551,7 @@ class StoreOrder extends ModelBasic
return self::page($model,function ($item){
$item['nickname'] = WechatUser::where('uid',$item['uid'])->value('nickname');
- $_info = db('store_order_cart_info')->where('oid',$item['id'])->field('cart_info')->select();
+ $_info = Db::name('store_order_cart_info')->where('oid',$item['id'])->field('cart_info')->select();
foreach ($_info as $k=>$v){
$_info[$k]['cart_info'] = json_decode($v['cart_info'],true);
}
@@ -631,28 +881,109 @@ class StoreOrder extends ModelBasic
]
];
}
- /*
- * 退款列表
- * $where array
- * return array
+
+ /**微信 订单发货
+ * @param $oid
+ * @param array $postageData
*/
-// public static function getRefundList($where){
-// $refundlist=self::setEchatWhere($where)->field([
-// 'order_id','total_price','coupon_price','deduction_price',
-// 'use_integral','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time','FROM_UNIXTIME(pay_time,"%Y-%m-%d") as pay_time','combination_id',
-// 'seckill_id','bargain_id','cost','status','cart_id','pay_price','refund_status'
-// ])->page((int)$where['page'],(int)$where['limit'])->select();
-// count($refundlist) && $refundlist=$refundlist->toArray();
-// foreach($refundlist as &$item){
-// $item['product']=StoreProduct::where('id','in',function ($quers) use($item){
-// $quers->name('store_cart')->where('id','in',json_decode($item['cart_id'],true))->field('product_id');
-// })->field(['store_name','cost','price','image'])->select()->toArray();
-// if($item['refund_status']==1) {
-// $item['_refund'] = '申请退款中';
-// }elseif ($item['refund_status']==2){
-// $item['_refund'] = '退款成功';
-// }
-// }
-// return $refundlist;
-// }
+ public static function orderPostageAfter($oid,$postageData = [])
+ {
+ $order = self::where('id',$oid)->find();
+ $openid = WechatUser::uidToOpenid($order['uid']);
+ $url = Url::build('wap/My/order',['uni'=>$order['order_id']],true,true);
+ $group = [
+ 'first'=>'亲,您的订单已发货,请注意查收',
+ 'remark'=>'点击查看订单详情'
+ ];
+ if($postageData['delivery_type'] == 'send'){//送货
+ $goodsName = StoreOrderCartInfo::getProductNameList($order['id']);
+ $group = array_merge($group,[
+ 'keyword1'=>$goodsName,
+ 'keyword2'=>$order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i',$order['pay_time']),
+ 'keyword3'=>$order['user_address'],
+ 'keyword4'=>$postageData['delivery_name'],
+ 'keyword5'=>$postageData['delivery_id']
+ ]);
+ WechatTemplateService::sendTemplate($openid,WechatTemplateService::ORDER_DELIVER_SUCCESS,$group,$url);
+
+ }else if($postageData['delivery_type'] == 'express'){//发货
+ $group = array_merge($group,[
+ 'keyword1'=>$order['order_id'],
+ 'keyword2'=>$postageData['delivery_name'],
+ 'keyword3'=>$postageData['delivery_id']
+ ]);
+ WechatTemplateService::sendTemplate($openid,WechatTemplateService::ORDER_POSTAGE_SUCCESS,$group,$url);
+ }
+ }
+ /**
+ * 小程序 订单发货提醒
+ * @param int $oid
+ * @param array $postageData
+ * @return bool
+ */
+ public static function sendOrderGoods($oid = 0,$postageData=array()){
+ if(!$oid || !$postageData) return true;
+ $order = self::where('id',$oid)->find();
+ $routine_openid = WechatUser::uidToRoutineOpenid($order['uid']);
+ if(!$routine_openid) return true;
+ if($postageData['delivery_type'] == 'send'){//送货
+ $data['keyword1']['value'] = $order['order_id'];
+ $data['keyword2']['value'] = $order['delivery_name'];
+ $data['keyword3']['value'] = $order['delivery_id'];
+ $data['keyword4']['value'] = date('Y-m-d H:i:s',time());
+ $data['keyword5']['value'] = '您的商品已经发货请注意查收';
+ $formId = RoutineFormId::getFormIdOne($order['uid']);
+ if($formId){
+ RoutineFormId::delFormIdOne($formId);
+ RoutineTemplateService::sendTemplate($routine_openid,
+ RoutineTemplateService::setTemplateId(RoutineTemplateService::ORDER_DELIVER_SUCCESS),
+ '',
+ $data,
+ $formId);
+ }
+ }else if($postageData['delivery_type'] == 'express'){//发货
+ $data['keyword1']['value'] = $order['order_id'];
+ $data['keyword2']['value'] = $order['delivery_name'];
+ $data['keyword3']['value'] = $order['delivery_id'];
+ $data['keyword4']['value'] = date('Y-m-d H:i:s',time());
+ $data['keyword5']['value'] = '您的商品已经发货请注意查收';
+ $formId = RoutineFormId::getFormIdOne($order['uid']);
+ if($formId){
+ RoutineFormId::delFormIdOne($formId);
+ RoutineTemplateService::sendTemplate($routine_openid,
+ RoutineTemplateService::setTemplateId(RoutineTemplateService::ORDER_POSTAGE_SUCCESS),
+ '',
+ $data,
+ $formId);
+ }
+ }
+ }
+
+
+ /**
+ * 获取订单总数
+ * @param int $uid
+ * @return int|string
+ */
+ public static function getOrderCount($uid = 0){
+ if(!$uid) return 0;
+ return self::where('uid',$uid)->where('paid',1)->where('refund_status',0)->where('status',2)->count();
+ }
+ /**
+ * 获取已支付的订单
+ * @param int $is_promoter
+ * @return int|string
+ */
+ public static function getOrderPayCount($is_promoter = 0){
+ return self::where('o.paid',1)->alias('o')->join('User u','u.uid=o.uid')->where('u.is_promoter',$is_promoter)->count();
+ }
+
+ /**
+ * 获取最后一个月已支付的订单
+ * @param int $is_promoter
+ * @return int|string
+ */
+ public static function getOrderPayMonthCount($is_promoter = 0){
+ return self::where('o.paid',1)->alias('o')->whereTime('o.pay_time','last month')->join('User u','u.uid=o.uid')->where('u.is_promoter',$is_promoter)->count();
+ }
}
\ No newline at end of file
diff --git a/application/admin/model/order/StoreOrderCartInfo.php b/application/admin/model/order/StoreOrderCartInfo.php
new file mode 100644
index 000000000..ef5e86a8a
--- /dev/null
+++ b/application/admin/model/order/StoreOrderCartInfo.php
@@ -0,0 +1,33 @@
+
+ * @day: 2017/12/26
+ */
+
+namespace app\admin\model\order;
+
+
+use basic\ModelBasic;
+use traits\ModelTrait;
+
+class StoreOrderCartInfo extends ModelBasic
+{
+ use ModelTrait;
+
+ /** 获取订单产品列表
+ * @param $oid
+ * @return array
+ */
+ public static function getProductNameList($oid)
+ {
+ $cartInfo = self::where('oid',$oid)->select();
+ $goodsName = [];
+ foreach ($cartInfo as $cart){
+ $suk = isset($cart['cart_info']['productInfo']['attrInfo']) ? '('.$cart['cart_info']['productInfo']['attrInfo']['suk'].')' : '';
+ $goodsName[] = $cart['cart_info']['productInfo']['store_name'].$suk;
+ }
+ return $goodsName;
+ }
+
+}
\ No newline at end of file
diff --git a/application/admin/model/record/StoreStatistics.php b/application/admin/model/record/StoreStatistics.php
index 10c04cda6..04fe9cd38 100644
--- a/application/admin/model/record/StoreStatistics.php
+++ b/application/admin/model/record/StoreStatistics.php
@@ -173,8 +173,8 @@ class StoreStatistics extends ModelBasic
{
$trans = self::alias('a')
->join('user b', 'a.uid=b.uid')
- ->join('store_order_cart_info c', 'a.id=c.oid')
- ->join('store_product d', 'c.product_id=d.id')
+ ->join('__STORE_ORDER_CART_INFO__ c', 'a.id=c.oid')
+ ->join('__STORE_PRODUCT__ d', 'c.product_id=d.id')
->field('b.nickname,a.pay_price,d.store_name')
->order('a.add_time DESC')
->limit('6')
@@ -200,6 +200,8 @@ class StoreStatistics extends ModelBasic
$cost=$info['cost'];//成本
$export[] = [$time,$price,$zhichu,$cost,$coupon,$deduction,$profit];
}
+// ExportService::exportCsv($export,'统计'.time(),['时间','营业额(元)','支出(元)','成本','优惠','积分抵扣','盈利(元)']);
+ dump($export);
PHPExcelService::setExcelHeader(['时间','营业额(元)','支出(元)','成本','优惠','积分抵扣','盈利(元)'])->setExcelTile('财务统计', '财务统计',date('Y-m-d H:i:s',time()))->setExcelContent($export)->ExcelSave();
}
}
diff --git a/application/admin/model/routine/RoutineFormId.php b/application/admin/model/routine/RoutineFormId.php
new file mode 100644
index 000000000..9a72b78c3
--- /dev/null
+++ b/application/admin/model/routine/RoutineFormId.php
@@ -0,0 +1,43 @@
+where('stop_time','LT',time())->delete();
+ }
+
+ /**
+ * 获取一个可以使用的formId
+ * @return bool|mixed
+ */
+ public static function getFormIdOne($uid = 0){
+ $formId = self::where('status',1)->where('stop_time','GT',time())->where('uid',$uid)->order('id asc')->find();
+ if($formId) return $formId['form_id'];
+ else return false;
+ }
+
+ /**
+ * 修改一个FormID为已使用
+ * @param string $formId
+ * @return $this|bool
+ */
+ public static function delFormIdOne($formId = ''){
+ if($formId == '') return true;
+ return self::where('form_id',$formId)->update(['status'=>2]);
+ }
+}
\ No newline at end of file
diff --git a/application/admin/model/store/StoreCategory.php b/application/admin/model/store/StoreCategory.php
index 4b16e1cf5..7a4e13e24 100644
--- a/application/admin/model/store/StoreCategory.php
+++ b/application/admin/model/store/StoreCategory.php
@@ -7,7 +7,6 @@
namespace app\admin\model\store;
-
use traits\ModelTrait;
use basic\ModelBasic;
use service\UtilService;
@@ -20,16 +19,39 @@ class StoreCategory extends ModelBasic
{
use ModelTrait;
+ /*
+ * 异步获取分类列表
+ * @param $where
+ * @return array
+ */
+ public static function CategoryList($where){
+ $data=($data=self::systemPage($where,true)->page((int)$where['page'],(int)$where['limit'])->select()) && count($data) ? $data->toArray() :[];
+ foreach ($data as &$item){
+ if($item['pid']){
+ $item['pid_name'] = self::where('id',$item['pid'])->value('cate_name');
+ }else{
+ $item['pid_name'] = '顶级';
+ }
+ }
+ $count=self::systemPage($where,true)->count();
+ return compact('count','data');
+ }
/**
* @param $where
* @return array
*/
- public static function systemPage($where){
+ public static function systemPage($where,$isAjax=false){
$model = new self;
if($where['pid'] != '') $model = $model->where('pid',$where['pid']);
else if($where['pid']=='' && $where['cate_name']=='') $model = $model->where('pid',0);
if($where['is_show'] != '') $model = $model->where('is_show',$where['is_show']);
if($where['cate_name'] != '') $model = $model->where('cate_name','LIKE',"%$where[cate_name]%");
+ if($isAjax===true){
+ if(isset($where['order']) && $where['order']!=''){
+ $model=$model->order(self::setOrder($where['order']));
+ }
+ return $model;
+ }
return self::page($model,function ($item){
if($item['pid']){
$item['pid_name'] = self::where('id',$item['pid'])->value('cate_name');
diff --git a/application/admin/model/store/StoreCouponUser.php b/application/admin/model/store/StoreCouponUser.php
index 4300f71ce..3e3a2a014 100644
--- a/application/admin/model/store/StoreCouponUser.php
+++ b/application/admin/model/store/StoreCouponUser.php
@@ -4,6 +4,7 @@ namespace app\admin\model\store;
use basic\ModelBasic;
use traits\ModelTrait;
+use think\Db;
class StoreCouponUser extends ModelBasic
{
@@ -38,7 +39,7 @@ class StoreCouponUser extends ModelBasic
$coupon['_msg'] = '可使用';
}
}
- $coupon['integral']=db('store_coupon')->where(['id'=>$coupon['cid']])->value('integral');
+ $coupon['integral']= Db::name('store_coupon')->where(['id'=>$coupon['cid']])->value('integral');
}
return $couponList;
}
@@ -53,7 +54,7 @@ class StoreCouponUser extends ModelBasic
[
'name'=>'总发放优惠券',
'field'=>'张',
- 'count'=>self::getModelTime($where,db('store_coupon_issue'))->where('status',1)->sum('total_count'),
+ 'count'=>self::getModelTime($where, Db::name('store_coupon_issue'))->where('status',1)->sum('total_count'),
'background_color'=>'layui-bg-blue',
'col'=>6,
],
@@ -69,7 +70,7 @@ class StoreCouponUser extends ModelBasic
//获取优惠劵图表
public static function getConponCurve($where,$limit=20){
//优惠劵发放记录
- $list=self::getModelTime($where,db('store_coupon_issue')
+ $list=self::getModelTime($where, Db::name('store_coupon_issue')
->where('status',1)
->field(['FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time','sum(total_count) as total_count'])->group('_add_time')->order('_add_time asc'))->select();
$date=[];
diff --git a/application/admin/model/store/StoreProduct.php b/application/admin/model/store/StoreProduct.php
index 36998f4d9..3723f30e2 100644
--- a/application/admin/model/store/StoreProduct.php
+++ b/application/admin/model/store/StoreProduct.php
@@ -15,6 +15,9 @@ use traits\ModelTrait;
use basic\ModelBasic;
use app\admin\model\store\StoreCategory as CategoryModel;
use app\admin\model\order\StoreOrder;
+use app\admin\model\ump\StoreSeckill as StoreSeckillModel;
+use app\admin\model\ump\StoreCombination as StoreCombinationModel;
+use app\admin\model\ump\StoreBargain as StoreBargainModel;
use app\admin\model\system\SystemConfig;
/**
@@ -26,6 +29,27 @@ class StoreProduct extends ModelBasic
{
use ModelTrait;
+ /**删除产品
+ * @param $id
+ */
+ public static function proDelete($id){
+ //删除产品
+ //删除属性
+ //删除秒杀
+ //删除拼团
+ //删除砍价
+ //删除拼团
+ $model=new self();
+ self::beginTrans();
+ $res0 = $model::del($id);
+ $res1 = StoreSeckillModel::where(['product_id'=>$id])->delete();
+ $res2 = StoreCombinationModel::where(['product_id'=>$id])->delete();
+ $res3 = StoreBargainModel::where(['product_id'=>$id])->delete();
+ //。。。。
+ $res = $res0 && $res1 && $res2 && $res3;
+ self::checkTrans($res);
+ return $res;
+ }
/**
* 获取连表查询条件
* @param $type
@@ -71,13 +95,7 @@ class StoreProduct extends ModelBasic
$model = $model->where('p.store_name|p.keyword|p.id','LIKE',"%$where[store_name]%");
}
if(isset($where['cate_id']) && trim($where['cate_id'])!=''){
- $cate=CategoryModel::where('id',$where['cate_id'])->find();
- if($cate['pid']==0){
- $arr=CategoryModel::where('pid',$cate['id'])->column('id');
- $model = $model->where('p.cate_id','in',$arr);
- }else{
- $model = $model->where('p.cate_id','LIKE',"%$where[cate_id]%");
- }
+ $model = $model->where('p.cate_id','LIKE',"%$where[cate_id]%");
}
if(isset($where['order']) && $where['order']!=''){
$model = $model->order(self::setOrder($where['order']));
@@ -249,7 +267,7 @@ class StoreProduct extends ModelBasic
*/
public static function getMaxList($where){
$classs=['layui-bg-red','layui-bg-orange','layui-bg-green','layui-bg-blue','layui-bg-cyan'];
- $model=StoreOrder::alias('a')->join('StoreOrderCartInfo c','a.id=c.oid')->join('store_product b','b.id=c.product_id');
+ $model=StoreOrder::alias('a')->join('StoreOrderCartInfo c','a.id=c.oid')->join('__STORE_PRODUCT__ b','b.id=c.product_id');
$list=self::getModelTime($where,$model,'a.add_time')->group('c.product_id')->order('p_count desc')->limit(10)
->field(['count(c.product_id) as p_count','b.store_name','sum(b.price) as sum_price'])->select();
if(count($list)) $list=$list->toArray();
@@ -274,7 +292,7 @@ class StoreProduct extends ModelBasic
//获取利润
public static function ProfityTop10($where){
$classs=['layui-bg-red','layui-bg-orange','layui-bg-green','layui-bg-blue','layui-bg-cyan'];
- $model=StoreOrder::alias('a')->join('StoreOrderCartInfo c','a.id=c.oid')->join('store_product b','b.id=c.product_id');
+ $model=StoreOrder::alias('a')->join('StoreOrderCartInfo c','a.id=c.oid')->join('__STORE_PRODUCT__ b','b.id=c.product_id');
$list=self::getModelTime($where,$model,'a.add_time')->group('c.product_id')->order('profity desc')->limit(10)
->field(['count(c.product_id) as p_count','b.store_name','sum(b.price) as sum_price','(b.price-b.cost) as profity'])
->select();
@@ -366,7 +384,7 @@ class StoreProduct extends ModelBasic
}else{
$time['data']=isset($where['data'])? $where['data']:'';
}
- $model=self::getModelTime($time,db('store_cart')->alias('a')->join('store_product b','a.product_id=b.id'),'a.add_time');
+ $model=self::getModelTime($time, Db::name('store_cart')->alias('a')->join('__STORE_PRODUCT__ b','a.product_id=b.id'),'a.add_time');
if(isset($where['title']) && $where['title']!=''){
$model=$model->where('b.store_name|b.id','like',"%$where[title]%");
}
@@ -386,7 +404,7 @@ class StoreProduct extends ModelBasic
->select();
$count=self::setWhere($where)->where('a.is_pay',1)->group('a.product_id')->count();
foreach ($data as &$item){
- $item['sum_price']=bcdiv($item['num_product'],$item['price'],2);
+ $item['sum_price']=bcmul($item['num_product'],$item['price'],2);
}
return compact('data','count');
}
@@ -477,7 +495,7 @@ class StoreProduct extends ModelBasic
[
'name'=>'点赞次数',
'field'=>'个',
- 'count'=>db('store_product_relation')->where('product_id',$id)->where('type','like')->count(),
+ 'count'=>Db::name('store_product_relation')->where('product_id',$id)->where('type','like')->count(),
'background_color'=>'layui-bg-blue',
],
[
diff --git a/application/admin/model/store/StoreProductAttr.php b/application/admin/model/store/StoreProductAttr.php
index d685496ba..910cb9451 100644
--- a/application/admin/model/store/StoreProductAttr.php
+++ b/application/admin/model/store/StoreProductAttr.php
@@ -77,7 +77,7 @@ class StoreProductAttr extends ModelBasic
];
}
foreach ($valueList as $k=>$value){
- ksort($value['detail'],SORT_STRING);
+ sort($value['detail'],SORT_STRING);
$suk = implode(',',$value['detail']);
$valueGroup[$suk] = [
'product_id'=>$productId,
diff --git a/application/admin/model/system/SystemAttachment.php b/application/admin/model/system/SystemAttachment.php
index aae35c070..fc16fd2ef 100644
--- a/application/admin/model/system/SystemAttachment.php
+++ b/application/admin/model/system/SystemAttachment.php
@@ -38,7 +38,7 @@ class SystemAttachment extends ModelBasic
$model = new self;
$where['pid'] = $id;
$model->where($where)->order('att_id desc');
- return $model->page($model,$where,'',30);
+ return $model->page($model,$where,'',24);
}
/**
* 获取单条信息
diff --git a/application/admin/model/system/SystemConfig.php b/application/admin/model/system/SystemConfig.php
index 93702e472..b1219d55d 100644
--- a/application/admin/model/system/SystemConfig.php
+++ b/application/admin/model/system/SystemConfig.php
@@ -1 +1 @@
-
* @day: 2017/11/02
*/
namespace app\admin\model\system;
use basic\ModelBasic;
use service\FormBuilder as Form;
use traits\ModelTrait;
class SystemConfig extends ModelBasic {
use ModelTrait;
/**
* 修改单个配置
* */
public static function setValue($menu,$value){
if(empty($menu) || !($config_one = self::get(['menu_name'=>$menu]))) return self::setErrorInfo('字段名称错误');
if($config_one['type'] == 'radio' || $config_one['type'] == 'checkbox'){
$parameter = array();
$option = array();
$parameter = explode(',',$config_one['parameter']);
foreach ($parameter as $k=>$v){
if(isset($v) && !empty($v)){
$option[$k] = explode('-',$v);
}
}
$value_arr = array();//选项的值
foreach ($option as $k=>$v){
foreach ($v as $kk=>$vv)
if(!$kk){
$value_arr[$k] = $vv;
}
}
$i = 0;//
if(is_array($value)){
foreach ($value as $value_v){
if(in_array($value_v,$value_arr)){
$i++;
}
}
if(count($value) != $i) return self::setErrorInfo('输入的值不属于选项中的参数');
}else{
if(in_array($value,$value_arr)){
$i++;
}
if(!$i) return self::setErrorInfo('输入的值不属于选项中的参数');
}
if($config_one['type'] == 'radio' && is_array($value)) return self::setErrorInfo('单选按钮的值是字符串不是数组');
}
$bool = self::edit(['value' => json_encode($value)],$menu,'menu_name');
return $bool;
}
/**
* 获取单个参数配置
* */
public static function getValue($menu){
if(empty($menu) || !($config_one = self::get(['menu_name'=>$menu]))) return false;
return json_decode($config_one['value'],true);
}
/**
* 获得多个参数
* @param $menus
* @return array
*/
public static function getMore($menus)
{
$menus = is_array($menus) ? implode(',',$menus) : $menus;
$list = self::where('menu_name','IN',$menus)->column('value','menu_name')?:[];
foreach ($list as $menu => $value){
$list[$menu] = json_decode($value,true);
}
return $list;
}
public static function getAllConfig()
{
$list = self::column('value','menu_name')?:[];
foreach ($list as $menu => $value){
$list[$menu] = json_decode($value,true);
}
return $list;
}
/**
* text 判断
* */
public static function valiDateTextRole($data){
if (!$data['width']) return self::setErrorInfo('请输入文本框的宽度');
if ($data['width'] <= 0) return self::setErrorInfo('请输入正确的文本框的宽度');
return true;
}
/**
* radio 和 checkbox规则的判断
* */
public static function valiDateRadioAndCheckbox($data){
$parameter = array();
$option = array();
$option_new = array();
$data['parameter'] = str_replace("\r\n","\n",$data['parameter']);//防止不兼容
$parameter = explode("\n",$data['parameter']);
if(count($parameter) < 2)return self::setErrorInfo('请输入正确格式的配置参数');
foreach ($parameter as $k=>$v){
if(isset($v) && !empty($v)){
$option[$k] = explode('=',$v);
}
}
if(count($option) < 2)return self::setErrorInfo('请输入正确格式的配置参数');
$bool = 1;
foreach ($option as $k=>$v){
$option_new[$k] = $option[$k][0];
foreach ($v as $kk=>$vv){
$vv_num = strlen($vv);
if(!$vv_num){
$bool = 0;
}
}
}
// dump($option);
if(!$bool)return self::setErrorInfo('请输入正确格式的配置参数');
$num1 = count($option_new);//提取该数组的数目
$arr2 = array_unique($option_new);//合并相同的元素
$num2 = count($arr2);//提取合并后数组个数
if($num1>$num2)return self::setErrorInfo('请输入正确格式的配置参数');
return true;
}
/**
* textarea 判断
* */
public static function valiDateTextareaRole($data){
if (!$data['width']) return self::setErrorInfo('请输入多行文本框的宽度');
if (!$data['high']) return self::setErrorInfo('请输入多行文本框的高度');
if ($data['width'] < 0) return self::setErrorInfo('请输入正确的多行文本框的宽度');
if ($data['high'] < 0) return self::setErrorInfo('请输入正确的多行文本框的宽度');
return true;
}
/**
* 获取一数据
* */
public static function getOneConfig($filed,$value){
$where[$filed] = $value;
return self::where($where)->find();
}
/**
* 获取配置分类
* */
public static function getAll($id){
$where['config_tab_id'] = $id;
$where['status'] = 1;
return self::where($where)->order('sort desc,id asc')->select();
}
/**
* 获取所有配置分类
* */
public static function getConfigTabAll($type=0){
$configAll = \app\admin\model\system\SystemConfigTab::getAll($type);
$config_tab = array();
foreach ($configAll as $k=>$v){
if(!$v['info']){
$config_tab[$k]['value'] = $v['id'];
$config_tab[$k]['label'] = $v['title'];
$config_tab[$k]['icon'] = $v['icon'];
$config_tab[$k]['type'] = $v['type'];
}
}
return $config_tab;
}
/**
* 选择类型
* */
public static function radiotype($type='text'){
return [
['value'=>'text','label'=>'文本框','disabled'=>1]
,['value'=>'textarea','label'=>'多行文本框','disabled'=>1]
,['value'=>'radio','label'=>'单选按钮','disabled'=>1]
,['value'=>'upload','label'=>'文件上传','disabled'=>1]
,['value'=>'checkbox','label'=>'多选按钮','disabled'=>1]
];
}
/**
* 文本框
* */
public static function createInputRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','text')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('width','文本框宽(%)',100);
$formbuider[] = Form::input('required','验证规则')->placeholder('多个请用,隔开例如:required:true,url:true');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 多行文本框
* */
public static function createTextAreaRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','textarea')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('value','默认值');
$formbuider[] = Form::number('width','文本框宽(%)',100);
$formbuider[] = Form::number('high','多行文本框高(%)',5);
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 单选按钮
* */
public static function createRadioRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','radio')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('parameter','配置参数')->placeholder("参数方式例如:\n1=男\n2=女\n3=保密");
$formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 文件上传
* */
public static function createUploadRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','upload')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::radio('upload_type','上传类型',1)->options([['value'=>1,'label'=>'单图'],['value'=>2,'label'=>'多图'],['value'=>3,'label'=>'文件']]);
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 多选框
* */
public static function createCheckboxRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','checkbox')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('parameter','配置参数')->placeholder("参数方式例如:\n1=白色\n2=红色\n3=黑色");
$formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 插入数据到数据库
* */
public static function set($data)
{
return self::create($data);
}
}
\ No newline at end of file
+
* @day: 2017/11/02
*/
namespace app\admin\model\system;
use basic\ModelBasic;
use service\FormBuilder as Form;
use traits\ModelTrait;
use \app\admin\model\system\SystemConfigTab;
class SystemConfig extends ModelBasic {
use ModelTrait;
/**
* 修改单个配置
* */
public static function setValue($menu,$value){
if(empty($menu) || !($config_one = self::get(['menu_name'=>$menu]))) return self::setErrorInfo('字段名称错误');
if($config_one['type'] == 'radio' || $config_one['type'] == 'checkbox'){
$parameter = array();
$option = array();
$parameter = explode(',',$config_one['parameter']);
foreach ($parameter as $k=>$v){
if(isset($v) && !empty($v)){
$option[$k] = explode('-',$v);
}
}
$value_arr = array();//选项的值
foreach ($option as $k=>$v){
foreach ($v as $kk=>$vv)
if(!$kk){
$value_arr[$k] = $vv;
}
}
$i = 0;//
if(is_array($value)){
foreach ($value as $value_v){
if(in_array($value_v,$value_arr)){
$i++;
}
}
if(count($value) != $i) return self::setErrorInfo('输入的值不属于选项中的参数');
}else{
if(in_array($value,$value_arr)){
$i++;
}
if(!$i) return self::setErrorInfo('输入的值不属于选项中的参数');
}
if($config_one['type'] == 'radio' && is_array($value)) return self::setErrorInfo('单选按钮的值是字符串不是数组');
}
$bool = self::edit(['value' => json_encode($value)],$menu,'menu_name');
return $bool;
}
/**
* 获取单个参数配置
* */
public static function getValue($menu){
if(empty($menu) || !($config_one = self::get(['menu_name'=>$menu]))) return false;
return json_decode($config_one['value'],true);
}
/**
* 获得多个参数
* @param $menus
* @return array
*/
public static function getMore($menus)
{
$menus = is_array($menus) ? implode(',',$menus) : $menus;
$list = self::where('menu_name','IN',$menus)->column('value','menu_name')?:[];
foreach ($list as $menu => $value){
$list[$menu] = json_decode($value,true);
}
return $list;
}
public static function getAllConfig()
{
$list = self::column('value','menu_name')?:[];
foreach ($list as $menu => $value){
$list[$menu] = json_decode($value,true);
}
return $list;
}
/**
* text 判断
* */
public static function valiDateTextRole($data){
if (!$data['width']) return self::setErrorInfo('请输入文本框的宽度');
if ($data['width'] <= 0) return self::setErrorInfo('请输入正确的文本框的宽度');
return true;
}
/**
* radio 和 checkbox规则的判断
* */
public static function valiDateRadioAndCheckbox($data){
$parameter = array();
$option = array();
$option_new = array();
$data['parameter'] = str_replace("\r\n","\n",$data['parameter']);//防止不兼容
$parameter = explode("\n",$data['parameter']);
if(count($parameter) < 2)return self::setErrorInfo('请输入正确格式的配置参数');
foreach ($parameter as $k=>$v){
if(isset($v) && !empty($v)){
$option[$k] = explode('=>',$v);
}
}
if(count($option) < 2)return self::setErrorInfo('请输入正确格式的配置参数');
$bool = 1;
foreach ($option as $k=>$v){
$option_new[$k] = $option[$k][0];
foreach ($v as $kk=>$vv){
$vv_num = strlen($vv);
if(!$vv_num){
$bool = 0;
}
}
}
// dump($option);
if(!$bool)return self::setErrorInfo('请输入正确格式的配置参数');
$num1 = count($option_new);//提取该数组的数目
$arr2 = array_unique($option_new);//合并相同的元素
$num2 = count($arr2);//提取合并后数组个数
if($num1>$num2)return self::setErrorInfo('请输入正确格式的配置参数');
return true;
}
/**
* textarea 判断
* */
public static function valiDateTextareaRole($data){
if (!$data['width']) return self::setErrorInfo('请输入多行文本框的宽度');
if (!$data['high']) return self::setErrorInfo('请输入多行文本框的高度');
if ($data['width'] < 0) return self::setErrorInfo('请输入正确的多行文本框的宽度');
if ($data['high'] < 0) return self::setErrorInfo('请输入正确的多行文本框的宽度');
return true;
}
/**
* 获取一数据
* */
public static function getOneConfig($filed,$value){
$where[$filed] = $value;
return self::where($where)->find();
}
/**
* 获取配置分类
* */
public static function getAll($id){
$where['config_tab_id'] = $id;
$where['status'] = 1;
return self::where($where)->order('sort desc,id asc')->select();
}
/**
* 获取所有配置分类
* */
public static function getConfigTabAll($type=0){
$configAll = SystemConfigTab::getAll($type);
$config_tab = array();
foreach ($configAll as $k=>$v){
if(!$v['info']){
$config_tab[$k]['value'] = $v['id'];
$config_tab[$k]['label'] = $v['title'];
$config_tab[$k]['icon'] = $v['icon'];
$config_tab[$k]['type'] = $v['type'];
}
}
return $config_tab;
}
/**
* 选择类型
* */
public static function radiotype($type='text'){
return [
['value'=>'text','label'=>'文本框','disabled'=>1]
,['value'=>'textarea','label'=>'多行文本框','disabled'=>1]
,['value'=>'radio','label'=>'单选按钮','disabled'=>1]
,['value'=>'upload','label'=>'文件上传','disabled'=>1]
,['value'=>'checkbox','label'=>'多选按钮','disabled'=>1]
];
}
/**
* 文本框
* */
public static function createInputRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','text')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('width','文本框宽(%)',100);
$formbuider[] = Form::input('required','验证规则')->placeholder('多个请用,隔开例如:required:true,url:true');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 多行文本框
* */
public static function createTextAreaRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','textarea')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('value','默认值');
$formbuider[] = Form::number('width','文本框宽(%)',100);
$formbuider[] = Form::number('high','多行文本框高(%)',5);
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 单选按钮
* */
public static function createRadioRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','radio')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('parameter','配置参数')->placeholder("参数方式例如:\n1=>男\n2=>女\n3=>保密");
$formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 文件上传
* */
public static function createUploadRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','upload')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::radio('upload_type','上传类型',1)->options([['value'=>1,'label'=>'单图'],['value'=>2,'label'=>'多图'],['value'=>3,'label'=>'文件']]);
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 多选框
* */
public static function createCheckboxRule($tab_id){
$formbuider = array();
$formbuider[] = Form::radio('type','类型','checkbox')->options(self::radiotype());
$formbuider[] = Form::select('config_tab_id','分类',$tab_id)->setOptions(SystemConfig::getConfigTabAll(-1));
$formbuider[] = Form::input('info','配置名称')->autofocus(1);
$formbuider[] = Form::input('menu_name','字段变量')->placeholder('例如:site_url');
$formbuider[] = Form::input('desc','配置简介');
$formbuider[] = Form::textarea('parameter','配置参数')->placeholder("参数方式例如:\n1=>白色\n2=>红色\n3=>黑色");
// $formbuider[] = Form::input('value','默认值');
$formbuider[] = Form::number('sort','排序');
$formbuider[] = Form::radio('status','状态',1)->options([['value'=>1,'label'=>'显示'],['value'=>2,'label'=>'隐藏']]);
return $formbuider;
}
/**
* 插入数据到数据库
* */
public static function set($data)
{
return self::create($data);
}
}
\ No newline at end of file
diff --git a/application/admin/model/system/SystemConfigTab.php b/application/admin/model/system/SystemConfigTab.php
index 04e61db3d..5c47e7609 100644
--- a/application/admin/model/system/SystemConfigTab.php
+++ b/application/admin/model/system/SystemConfigTab.php
@@ -1 +1 @@
-
* @day: 2017/11/02
*/
namespace app\admin\model\system;
use traits\ModelTrait;
use basic\ModelBasic;
use think\Db;
/**
* 配置分类model
*
* Class SystemConfigTab
* @package app\admin\model\system
*/
class SystemConfigTab extends ModelBasic {
use ModelTrait;
/**
* 获取单选按钮或者多选按钮的显示值
* */
public static function getRadioOrCheckboxValueInfo($menu_name,$value){
$parameter = array();
$option = array();
$config_one = \app\admin\model\system\SystemConfig::getOneConfig('menu_name',$menu_name);
// dump($config_one);
// exit();
// if(empty($menu) || !($config_one = self::get(['menu_name'=>$menu]))) return false;
$parameter = explode("\n",$config_one['parameter']);
foreach ($parameter as $k=>$v){
if(isset($v) && !empty($v)){
$option[$k] = explode('=',$v);
}
}
// $value = json_decode($value,true);
if(!is_array($value)){
$value = explode("\n",$value);
}
// dump($value);
// dump($option);
$value_arr = array();//选项的值
foreach ($option as $k=>$v){
foreach ($v as $kk=>$vv){
if(is_array($value)) {
if (in_array($v[0], $value)) {
$value_arr[$k] = $v[1];
}
}
break;
}
}
if(empty($value_arr)){
return '空';
}
return $value_arr;
// exit();
// if(is_array($value)){
// foreach ($value as $k=>$value_v){
// if(in_array($value_v,$value_arr)){
// $i[$k] = 1;
// }
// }
// if(count($value) != $i) return self::setErrorInfo('输入的值不属于选项中的参数');
// }else{
// if(in_array($value,$value_arr)){
// $i++;
// }
// if(!$i) return self::setErrorInfo('输入的值不属于选项中的参数');
// }
// if($config_one['type'] == 'radio' && is_array($value)) return self::setErrorInfo('单选按钮的值是字符串不是数组');
}
/**
* 插入数据到数据库
* */
public static function set($data)
{
return self::create($data);
}
/**
* 获取全部
* */
public static function getAll($type = 0){
$where['status'] = 1;
if($type>-1)$where['type'] = $type;
return Db::name('SystemConfigTab')->where($where)->select();
}
/**
* 获取配置分类
* */
public static function getSystemConfigTabPage($where = array())
{
$model = new self;
if($where['title'] != '') $model = $model->where('title','LIKE',"%$where[title]%");
if($where['status'] != '') $model = $model->where('status',$where['status']);
return self::page($model,$where);
}
public static function edit($data,$id,$field='id')
{
return self::update($data,[$field=>$id]);
}
/**
* 更新数据
* @access public
* @param array $data 数据数组
* @param array $where 更新条件
* @param array|true $field 允许字段
* @return $this
*/
public static function update($data = [], $where = [], $field = null)
{
$model = new static();
if (!empty($field)) {
$model->allowField($field);
}
$result = $model->isUpdate(true)->save($data, $where);
return $model;
}
}
\ No newline at end of file
+
* @day: 2017/11/02
*/
namespace app\admin\model\system;
use traits\ModelTrait;
use basic\ModelBasic;
use think\Db;
/**
* 配置分类model
*
* Class SystemConfigTab
* @package app\admin\model\system
*/
class SystemConfigTab extends ModelBasic {
use ModelTrait;
/**
* 获取单选按钮或者多选按钮的显示值
* */
public static function getRadioOrCheckboxValueInfo($menu_name,$value){
$parameter = array();
$option = array();
$config_one = SystemConfig::getOneConfig('menu_name',$menu_name);
$parameter = explode("\n",$config_one['parameter']);
foreach ($parameter as $k=>$v){
if(isset($v) && strlen($v)>0){
$data = explode('=>',$v);
$option[$data[0]] = $data[1];
}
}
$str = '';
if(is_array($value)){
foreach ($value as $v){
$str .= $option[$v].',';
}
}else{
$str .= !empty($value)?$option[$value]:$option[0];
}
return $str;
}
/**
* 插入数据到数据库
* */
public static function set($data)
{
return self::create($data);
}
/**
* 获取全部
* */
public static function getAll($type = 0){
$where['status'] = 1;
if($type>-1)$where['type'] = $type;
return Db::name('SystemConfigTab')->where($where)->select();
}
/**
* 获取配置分类
* */
public static function getSystemConfigTabPage($where = array())
{
$model = new self;
if($where['title'] != '') $model = $model->where('title','LIKE',"%$where[title]%");
if($where['status'] != '') $model = $model->where('status',$where['status']);
return self::page($model,$where);
}
public static function edit($data,$id,$field='id')
{
return self::update($data,[$field=>$id]);
}
/**
* 更新数据
* @access public
* @param array $data 数据数组
* @param array $where 更新条件
* @param array|true $field 允许字段
* @return $this
*/
public static function update($data = [], $where = [], $field = null)
{
$model = new static();
if (!empty($field)) {
$model->allowField($field);
}
$result = $model->isUpdate(true)->save($data, $where);
return $model;
}
}
\ No newline at end of file
diff --git a/application/admin/model/system/SystemGroupData.php b/application/admin/model/system/SystemGroupData.php
index d9c8b9e7b..285541cde 100644
--- a/application/admin/model/system/SystemGroupData.php
+++ b/application/admin/model/system/SystemGroupData.php
@@ -28,6 +28,7 @@ class SystemGroupData extends ModelBasic
$model = new self;
if($params['gid'] !== '') $model = $model->where('gid',$params['gid']);
if($params['status'] !== '') $model = $model->where('status',$params['status']);
+ $model = $model->order('sort desc,id ASC');
return self::page($model,function($item,$key){
$info = json_decode($item->value,true);
foreach ($info as $index => $value) {
diff --git a/application/admin/model/ump/StoreSeckill.php b/application/admin/model/ump/StoreSeckill.php
index f3c69d0d7..56c8a5f39 100644
--- a/application/admin/model/ump/StoreSeckill.php
+++ b/application/admin/model/ump/StoreSeckill.php
@@ -161,7 +161,7 @@ class StoreSeckill extends ModelBasic
*/
public static function getMaxList($where){
$classs=['layui-bg-red','layui-bg-orange','layui-bg-green','layui-bg-blue','layui-bg-cyan'];
- $model=StoreOrder::alias('a')->join('store_seckill b','b.id=a.seckill_id')->where('a.paid',1);
+ $model=StoreOrder::alias('a')->join('__STORE_SECKILL__ b','b.id=a.seckill_id')->where('a.paid',1);
$list=self::getModelTime($where,$model,'a.add_time')->group('a.seckill_id')->order('p_count desc')->limit(10)
->field(['count(a.seckill_id) as p_count','b.title as store_name','sum(b.price) as sum_price'])->select();
if(count($list)) $list=$list->toArray();
@@ -191,7 +191,7 @@ class StoreSeckill extends ModelBasic
*/
public static function ProfityTop10($where){
$classs=['layui-bg-red','layui-bg-orange','layui-bg-green','layui-bg-blue','layui-bg-cyan'];
- $model = StoreOrder::alias('a')->join('store_seckill b','b.id = a.seckill_id')->where('a.paid',1);
+ $model = StoreOrder::alias('a')->join('__STORE_SECKILL__ b','b.id = a.seckill_id')->where('a.paid',1);
$list=self::getModelTime($where,$model,'a.add_time')->group('a.seckill_id')->order('profity desc')->limit(10)
->field(['count(a.seckill_id) as p_count','b.title as store_name','sum(b.price) as sum_price','(b.price-b.cost) as profity'])
->select();
@@ -244,7 +244,7 @@ class StoreSeckill extends ModelBasic
* @return mixed
*/
public static function getBargainRefundList($where = array()){
- $model = StoreOrder::alias('a')->join('store_seckill b','b.id=a.seckill_id');
+ $model = StoreOrder::alias('a')->join('__STORE_SECKILL__ b','b.id=a.seckill_id');
$list = self::getModelTime($where,$model,'a.add_time')->where('a.refund_status','NEQ',0)->group('a.seckill_id')->order('count desc')->page((int)$where['page'],(int)$where['limit'])
->field(['count(a.seckill_id) as count','b.title as store_name','sum(b.price) as sum_price'])->select();
if(count($list)) $list=$list->toArray();
diff --git a/application/admin/model/user/User.php b/application/admin/model/user/User.php
index 24df12162..a752537c3 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;
use think\Db;
/**
* 用户管理 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::name('user_extract')->where(['uid'=>$value['uid']])->sum('extract_price');
$value['extract_price']= Db::name('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;
}
/**获取用户详细信息
* @param $uid
* @return array
*/
public static function getUserInfos($uid)
{
$userInfo = self::where('uid',$uid)->find();
if(!$userInfo) exception('读取用户信息失败!');
return $userInfo->toArray();
}
//获取某人用户推广信息
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::name('user_address')->where(['uid'=>$uid,'is_default'=>1])->field($key_field)->find()) ?
$thisAddress :
Db::name('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::name('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();
//购物笔数排行榜
$orderPayCount = StoreOrder::getOrderPayCount($is_promoter);
if($orderPayCount){
$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();
}else $shopcount = [];
count($shopcount) && $shopcount=$shopcount->toArray();
//购物金额排行榜
if($orderPayCount){
$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();
}else $order = [];
count($order) && $order=$order->toArray();
//上月消费排行
$orderPayCount = StoreOrder::getOrderPayMonthCount($is_promoter);
if($orderPayCount){
$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')
->where('r.pay_time','between',[strtotime(date('Y-m',strtotime('-1 month'))),strtotime(date('Y-m'))])
->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();
}else $lastorder = [];
count($lastorder) && $lastorder=$lastorder->toArray();
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/UserAddress.php b/application/admin/model/user/UserAddress.php
new file mode 100644
index 000000000..056ba2360
--- /dev/null
+++ b/application/admin/model/user/UserAddress.php
@@ -0,0 +1,51 @@
+
+ * @day: 2017/12/25
+ */
+
+namespace app\admin\model\user;
+
+
+use basic\ModelBasic;
+use traits\ModelTrait;
+
+class UserAddress extends ModelBasic
+{
+ use ModelTrait;
+
+ protected $insert = ['add_time'];
+
+ protected function setAddTimeAttr()
+ {
+ return time();
+ }
+
+ public static function setDefaultAddress($id,$uid)
+ {
+ self::beginTrans();
+ $res1 = self::where('uid',$uid)->update(['is_default'=>0]);
+ $res2 = self::where('id',$id)->where('uid',$uid)->update(['is_default'=>1]);
+ $res =$res1 !== false && $res2 !== false;
+ self::checkTrans($res);
+ return $res;
+ }
+
+ public static function userValidAddressWhere($model=null,$prefix = '')
+ {
+ if($prefix) $prefix .='.';
+ $model = self::getSelfModel($model);
+ return $model->where("{$prefix}is_del",0);
+ }
+
+ public static function getUserValidAddressList($uid,$field = '*')
+ {
+ return self::userValidAddressWhere()->where('uid',$uid)->order('add_time DESC')->field($field)->select()->toArray()?:[];
+ }
+
+ public static function getUserDefaultAddress($uid,$field = '*')
+ {
+ return self::userValidAddressWhere()->where('uid',$uid)->where('is_default',1)->field($field)->find();
+ }
+}
\ No newline at end of file
diff --git a/application/admin/model/user/UserBill.php b/application/admin/model/user/UserBill.php
index 50ba732da..c21435a55 100644
--- a/application/admin/model/user/UserBill.php
+++ b/application/admin/model/user/UserBill.php
@@ -5,7 +5,7 @@ namespace app\admin\model\user;
use traits\ModelTrait;
use basic\ModelBasic;
use app\admin\model\wechat\WechatUser;
-
+use think\Db;
/**
* 用户消费新增金额明细 model
* Class User
@@ -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());
@@ -95,7 +101,7 @@ class UserBill extends ModelBasic
$list=self::alias('a')->join('user r','a.uid=r.uid')
->where($datawhere)
->order('a.number desc')
- ->join('store_order o','o.id=a.link_id')
+ ->join('__STORE_ORDER__ o','o.id=a.link_id')
->field(['o.order_id','FROM_UNIXTIME(a.add_time,"%Y-%c-%d") as add_time','a.uid','o.uid as down_uid','r.nickname','r.avatar','r.spread_uid','r.level','a.number'])
->page((int)$where['page'],(int)$where['limit'])
->select();
@@ -105,7 +111,7 @@ class UserBill extends ModelBasic
//获取返佣用户总人数
public static function getFanCount(){
$datawhere=['a.category'=>'now_money','a.type'=>'brokerage','a.pm'=>1];
- return self::alias('a')->join('user r','a.uid=r.uid')->join('store_order o','o.id=a.link_id')->where($datawhere)->count();
+ return self::alias('a')->join('user r','a.uid=r.uid')->join('__STORE_ORDER__ o','o.id=a.link_id')->where($datawhere)->count();
}
//获取用户充值数据
public static function getEchartsRecharge($where,$limit=15){
@@ -139,7 +145,7 @@ class UserBill extends ModelBasic
count($list) && $list=$list->toArray();
$count=self::setOneWhere($where,$uid)->count();
foreach ($list as &$value){
- $value['order_id']=db('store_order')->where(['order_id'=>$value['link_id']])->value('order_id');
+ $value['order_id']=Db::name('store_order')->where(['order_id'=>$value['link_id']])->value('order_id');
}
return ['data'=>$list,'count'=>$count];
}
diff --git a/application/admin/model/user/UserNotice.php b/application/admin/model/user/UserNotice.php
index 4f3d61e5e..ac18c7f02 100644
--- a/application/admin/model/user/UserNotice.php
+++ b/application/admin/model/user/UserNotice.php
@@ -24,9 +24,23 @@ class UserNotice extends ModelBasic
/**
* @return array
*/
- public static function getList(){
+ public static function getList($where=[]){
$model = new self;
$model->order('id desc');
+ if(!empty($where)){
+ $data=($data=$model->page((int)$where['page'],(int)$where['limit'])->select()) && count($data) ? $data->toArray() : [];
+ foreach ($data as &$item){
+ if($item["uid"] != ''){
+ $uids = explode(",",$item["uid"]);
+ array_splice($uids,0,1);
+ array_splice($uids,count($uids)-1,1);
+ $item["uid"] = $uids;
+ }
+ $item['send_time']=date('Y-m-d H:i:s',$item['send_time']);
+ }
+ $count=self::count();
+ return compact('data','count');
+ }
return self::page($model,function($item,$key){
if($item["uid"] != ''){
$uids = explode(",",$item["uid"]);
@@ -46,7 +60,7 @@ class UserNotice extends ModelBasic
$model = new self;
if(isset($where['title']) && $where['title'] != '') $model = $model->where('title','LIKE',"%".$where['title']."%");
$model = $model->where('type',2);
- $model = $model->where('is_send',0);
+// $model = $model->where('is_send',0);
$model = $model->order('id desc');
return self::page($model,$where);
}
diff --git a/application/admin/model/wechat/WechatMessage.php b/application/admin/model/wechat/WechatMessage.php
index e30277313..7e1d152ee 100644
--- a/application/admin/model/wechat/WechatMessage.php
+++ b/application/admin/model/wechat/WechatMessage.php
@@ -33,9 +33,11 @@ class WechatMessage extends ModelBasic
'event_subscribe'=>'关注微信号',
'event_unsubscribe'=>'取消关注微信号',
'event_scan'=>'扫码',
+ 'event_templatesendjobfinish'=>'进入小程序',
'event_location'=>'获取位置',
'event_click'=>'点击微信菜单关键字',
'event_view'=>'点击微信菜单链接',
+ 'event_view_miniprogram'=>'点击微信菜单进入小程序',
'text'=>'收到文本消息',
'image'=>'收到图片消息',
'video'=>'收到视频消息',
diff --git a/application/admin/model/wechat/WechatReply.php b/application/admin/model/wechat/WechatReply.php
index 66ce3cf96..4a82d2c76 100644
--- a/application/admin/model/wechat/WechatReply.php
+++ b/application/admin/model/wechat/WechatReply.php
@@ -26,6 +26,15 @@ class WechatReply extends ModelBasic
public static $reply_type = ['text','image','news','voice'];
+ /**根据关键字查询一条
+ * @param $key
+ */
+ public static function getDataByKey($key){
+ $resdata = [];
+ $resdata = self::where('key',$key)->find();
+ $resdata['data'] = json_decode($resdata['data'],true);
+ return $resdata;
+ }
public function getUrlAttr($value,$data)
{
return $value == '' ? \think\Url::build('index/index/news',['id'=>$data['id']]) : $value;
@@ -194,4 +203,5 @@ class WechatReply extends ModelBasic
}
+
}
\ No newline at end of file
diff --git a/application/admin/model/wechat/WechatUser.php b/application/admin/model/wechat/WechatUser.php
index 998212501..fe16aff46 100644
--- a/application/admin/model/wechat/WechatUser.php
+++ b/application/admin/model/wechat/WechatUser.php
@@ -33,7 +33,7 @@ use service\SystemConfigService;
protected $insert = ['add_time'];
/**
- * 用uid获得openid
+ * 用uid获得 微信openid
* @param $uid
* @return mixed
*/
@@ -47,6 +47,21 @@ use service\SystemConfigService;
Cache::set($cacheName,$openid,0);
return $openid;
}
+ /**
+ * 用uid获得 小程序 openid
+ * @param $uid
+ * @return mixed
+ */
+ public static function uidToRoutineOpenid($uid,$update = false)
+ {
+ $cacheName = 'routine_openid'.$uid;
+ $openid = Cache::get($cacheName);
+ if($openid && !$update) return $openid;
+ $openid = self::where('uid',$uid)->value('routine_openid');
+ if(!$openid) exception('对应的routine_openid不存在!');
+ Cache::set($cacheName,$openid,0);
+ return $openid;
+ }
public static function setAddTimeAttr($value)
{
@@ -145,7 +160,7 @@ use service\SystemConfigService;
* @return array
*/
public static function agentSystemPage($where = array(),$isall=false){
- self::setWechatUserOrder();//设置 一级推荐人 二级推荐人 一级推荐人订单 二级推荐人订单 佣金
+// self::setWechatUserOrder();//设置 一级推荐人 二级推荐人 一级推荐人订单 二级推荐人订单 佣金
$model = new self;
if($isall==false) {
$status = (int)SystemConfigService::get('store_brokerage_statu');
@@ -155,7 +170,7 @@ use service\SystemConfigService;
}
}
}
- $model = $model->where('openid','NOT NULL');
+// $model = $model->where('openid','NOT NULL');
if($where['nickname'] !== '') $model = $model->where('nickname','LIKE',"%$where[nickname]%");
if($where['data'] !== ''){
list($startTime,$endTime) = explode(' - ',$where['data']);
@@ -203,7 +218,6 @@ use service\SystemConfigService;
$item['qr_code'] = QrcodeService::getForeverQrcode('spread',$item['uid']);
$item['extract_count_price'] = UserExtract::getUserCountPrice($item['uid']);//累计提现
$item['extract_count_num'] = UserExtract::getUserCountNum($item['uid']);//提现次数
-// $item['qr_code'] = '';
},$where);
}
diff --git a/application/admin/view/agent/agent_manage/stair.php b/application/admin/view/agent/agent_manage/stair.php
index 8214cf7c1..f96da913d 100644
--- a/application/admin/view/agent/agent_manage/stair.php
+++ b/application/admin/view/agent/agent_manage/stair.php
@@ -28,7 +28,7 @@
{$vo.add_time|date="Y-m-d H:i:s",###}