User.php 47 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2017/11/11
  6. */
  7. namespace app\admin\model\user;
  8. use app\admin\model\order\StoreOrder;
  9. use app\admin\model\system\SystemUserLevel;
  10. use traits\ModelTrait;
  11. use app\admin\model\user\UserBill;
  12. use basic\ModelBasic;
  13. use app\admin\model\wechat\WechatUser;
  14. use app\admin\model\store\StoreCouponUser;
  15. use app\admin\model\user\UserExtract;
  16. use app\core\util\SystemConfigService;
  17. use think\Db;
  18. /**
  19. * 用户管理 model
  20. * Class User
  21. * @package app\admin\model\user
  22. */
  23. class User extends ModelBasic
  24. {
  25. use ModelTrait;
  26. /**
  27. * @param $where
  28. * @return array
  29. */
  30. public static function systemPage($where){
  31. $model = new self;
  32. if($where['status'] != '') $model = $model->where('status',$where['status']);
  33. if($where['is_promoter'] != '') $model = $model->where('is_promoter',$where['is_promoter']);
  34. if(isset($where['user_type']) && $where['user_type'] != '') $model = $model->where('user_type',$where['user_type']);
  35. if($where['nickname'] != '') $model = $model->where('nickname|uid','like',"%$where[nickname]%");
  36. $model = $model->order('uid desc');
  37. return self::page($model,function ($item){
  38. if($item['spread_uid']){
  39. $item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname');
  40. }else{
  41. $item['spread_uid_nickname'] = '无';
  42. }
  43. },$where);
  44. }
  45. /*
  46. * 设置搜索条件
  47. *
  48. */
  49. public static function setWhere($where)
  50. {
  51. if($where['order']!=''){
  52. $model=self::order(self::setOrder($where['order']));
  53. }else{
  54. $model=self::order('u.uid desc');
  55. }
  56. if($where['user_time_type'] == 'visitno' && $where['user_time'] != ''){
  57. list($startTime, $endTime) = explode(' - ', $where['user_time']);
  58. $model = $model->where('u.last_time', ['>', strtotime($endTime)+24*3600], ['<', strtotime($startTime)],'or');
  59. }
  60. if($where['user_time_type'] == 'visit' && $where['user_time'] != ''){
  61. list($startTime, $endTime) = explode(' - ', $where['user_time']);
  62. $model = $model->where('u.last_time', '>', strtotime($startTime));
  63. $model = $model->where('u.last_time', '<', strtotime($endTime)+24*3600);
  64. }
  65. if($where['user_time_type'] == 'add_time' && $where['user_time'] != ''){
  66. list($startTime, $endTime) = explode(' - ', $where['user_time']);
  67. $model = $model->where('u.add_time', '>', strtotime($startTime));
  68. $model = $model->where('u.add_time', '<', strtotime($endTime)+24*3600);
  69. }
  70. if($where['pay_count'] !== '') {
  71. if($where['pay_count'] == '-1') $model = $model->where('pay_count',0);
  72. else $model = $model->where('pay_count','>',$where['pay_count']);
  73. }
  74. if($where['user_type'] != ''){
  75. if($where['user_type'] == 'routine') $model = $model->where('w.routine_openid','not null');
  76. else if($where['user_type'] == 'wechat') $model = $model->where('w.openid','not null');
  77. }
  78. if($where['country'] != ''){
  79. if($where['country'] == 'domestic') $model = $model->where('w.country','EQ','中国');
  80. else if($where['country'] == 'abroad') $model = $model->where('w.country','NEQ','中国');
  81. }
  82. return $model;
  83. }
  84. /**
  85. * 异步获取当前用户 信息
  86. * @param $where
  87. * @return array
  88. */
  89. public static function getUserList($where){
  90. $model = self::setWherePage(self::setWhere($where),$where,['w.sex','w.province','w.city','u.status','u.is_promoter'],['u.nickname','u.uid']);
  91. $list = $model->alias('u')
  92. ->join('WechatUser w','u.uid=w.uid')
  93. ->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')
  94. ->page((int)$where['page'],(int)$where['limit'])
  95. ->select()
  96. ->each(function ($item){
  97. $item['add_time']=date('Y-m-d H:i:s',$item['add_time']);
  98. if($item['last_time']) $item['last_time'] = date('Y-m-d H:i:s',$item['last_time']);//最近一次访问日期
  99. else $item['last_time'] = '无访问';//最近一次访问日期
  100. self::edit(['pay_count'=>StoreOrder::getUserCountPay($item['uid'])],$item['uid']);
  101. $item['extract_count_price'] = UserExtract::getUserCountPrice($item['uid']);//累计提现
  102. if($item['spread_uid']){
  103. $item['spread_uid_nickname'] = self::where('uid',$item['spread_uid'])->value('nickname').'/'.$item['spread_uid'];
  104. }else{
  105. $item['spread_uid_nickname'] = '无';
  106. }
  107. if($item['openid'] != '' && $item['routine_openid'] != ''){
  108. $item['user_type']='通用';
  109. }else if($item['openid'] == '' && $item['routine_openid'] != ''){
  110. $item['user_type']='小程序';
  111. }else if($item['openid'] != '' && $item['routine_openid'] == ''){
  112. $item['user_type']='公众号';
  113. }else $item['user_type']='其他';
  114. if($item['sex'] == 1){
  115. $item['sex']='男';
  116. }else if($item['sex'] == 2){
  117. $item['sex']='女';
  118. }else $item['sex']='保密';
  119. $item['vip_name']=false;
  120. $levelinfo=UserLevel::where(['uid'=>$item['uid'],'is_del'=>0])->order('grade desc')->field(['level_id','is_forever','valid_time'])->find();
  121. if($levelinfo){
  122. if($levelinfo['is_forever']) $item['vip_name']=SystemUserLevel::where('id',$levelinfo['level_id'])->value('name');
  123. else if(time() > $levelinfo['valid_time']) $item['vip_name']=SystemUserLevel::where('id',$levelinfo['level_id'])->value('name');
  124. }
  125. });//->toArray();
  126. $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();
  127. return ['count'=>$count,'data'=>$list];
  128. }
  129. /**
  130. * 修改用户状态
  131. * @param $uids 用户uid
  132. * @param $status 修改状态
  133. * @return array
  134. */
  135. public static function destrSyatus($uids,$status){
  136. if(empty($uids) && !is_array($uids)) return false;
  137. if($status=='') return false;
  138. self::beginTrans();
  139. try{
  140. $res=self::where('uid','in',$uids)->update(['status'=>$status]);
  141. self::checkTrans($res);
  142. return true;
  143. }catch (\Exception $e){
  144. self::rollbackTrans();
  145. return Json::fail($e->getMessage());
  146. }
  147. }
  148. /*
  149. * 获取某季度,某年某年后的时间戳
  150. *
  151. * self::getMonth('n',1) 获取当前季度的上个季度的时间戳
  152. * self::getMonth('n') 获取当前季度的时间戳
  153. */
  154. public static function getMonth($time='',$ceil=0){
  155. if(empty($time)){
  156. $firstday = date("Y-m-01",time());
  157. $lastday = date("Y-m-d",strtotime("$firstday +1 month -1 day"));
  158. }else if($time=='n'){
  159. if($ceil!=0)
  160. $season = ceil(date('n') /3)-$ceil;
  161. else
  162. $season = ceil(date('n') /3);
  163. $firstday=date('Y-m-01',mktime(0,0,0,($season - 1) *3 +1,1,date('Y')));
  164. $lastday=date('Y-m-t',mktime(0,0,0,$season * 3,1,date('Y')));
  165. }else if($time=='y'){
  166. $firstday=date('Y-01-01');
  167. $lastday=date('Y-12-31');
  168. }else if($time=='h'){
  169. $firstday = date('Y-m-d', strtotime('this week +'.$ceil.' day')) . ' 00:00:00';
  170. $lastday = date('Y-m-d', strtotime('this week +'.($ceil+1).' day')) . ' 23:59:59';
  171. }
  172. return array($firstday,$lastday);
  173. }
  174. public static function getcount(){
  175. return self::count();
  176. }
  177. /*
  178. *获取用户某个时间段的消费信息
  179. *
  180. * reutrn Array || number
  181. */
  182. public static function consume($where,$status='',$keep=''){
  183. $model = new self;
  184. $user_id=[];
  185. if(is_array($where)){
  186. if($where['is_promoter']!='') $model=$model->where('is_promoter',$where['is_promoter']);
  187. if($where['status']!='') $model=$model->where('status',$where['status']);
  188. switch ($where['date']){
  189. case null:case 'today':case 'week':case 'year':
  190. if($where['date']==null){
  191. $where['date']='month';
  192. }
  193. if($keep){
  194. $model=$model->whereTime('add_time',$where['date'])->whereTime('last_time',$where['date']);
  195. }else{
  196. $model=$model->whereTime('add_time',$where['date']);
  197. }
  198. break;
  199. case 'quarter':
  200. $quarter=self::getMonth('n');
  201. $startTime=strtotime($quarter[0]);
  202. $endTime=strtotime($quarter[1]);
  203. if($keep){
  204. $model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime)->where('last_time','>',$startTime)->where('last_time','<',$endTime);
  205. }else{
  206. $model = $model->where('add_time','>',$startTime)->where('add_time','<',$endTime);
  207. }
  208. break;
  209. default:
  210. //自定义时间
  211. if(strstr($where['date'],'-')!==FALSE){
  212. list($startTime,$endTime)=explode('-',$where['date']);
  213. $model = $model->where('add_time','>',strtotime($startTime))->where('add_time','<',strtotime($endTime));
  214. }else{
  215. $model=$model->whereTime('add_time','month');
  216. }
  217. break;
  218. }
  219. }else{
  220. if(is_array($status)){
  221. $model=$model->where('add_time','>',$status[0])->where('add_time','<',$status[1]);
  222. }
  223. }
  224. if($keep===true){
  225. return $model->count();
  226. }
  227. if($status==='default'){
  228. 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();
  229. }
  230. if($status==='grouping'){
  231. return $model->group('user_type')->field('user_type')->select()->toArray();
  232. }
  233. $uid=$model->field('uid')->select()->toArray();
  234. foreach ($uid as $val){
  235. $user_id[]=$val['uid'];
  236. }
  237. if(empty($user_id)){
  238. $user_id=[0];
  239. }
  240. if($status==='xiaofei'){
  241. $list=UserBill::where('uid','in',$user_id)
  242. ->group('type')
  243. ->field('sum(number) as top_number,title')
  244. ->select()
  245. ->toArray();
  246. $series=[
  247. 'name'=>isset($list[0]['title'])?$list[0]['title']:'',
  248. 'type'=>'pie',
  249. 'radius'=> ['40%', '50%'],
  250. 'data'=>[]
  251. ];
  252. foreach($list as $key=>$val){
  253. $series['data'][$key]['value']=$val['top_number'];
  254. $series['data'][$key]['name']=$val['title'];
  255. }
  256. return $series;
  257. }else if($status==='form'){
  258. $list=WechatUser::where('uid','in',$user_id)->group('city')->field('count(city) as top_city,city')->limit(0,10)->select()->toArray();
  259. $count=self::getcount();
  260. $option=[
  261. 'legend_date'=>[],
  262. 'series_date'=>[]
  263. ];
  264. foreach($list as $key=>$val){
  265. $num=$count!=0?(bcdiv($val['top_city'],$count,2))*100:0;
  266. $t=['name'=>$num.'% '.(empty($val['city'])?'未知':$val['city']),'icon'=>'circle'];
  267. $option['legend_date'][$key]=$t;
  268. $option['series_date'][$key]=['value'=>$num,'name'=>$t['name']];
  269. }
  270. return $option;
  271. }else{
  272. $number=UserBill::where('uid','in',$user_id)->where('type','pay_product')->sum('number');
  273. return $number;
  274. }
  275. }
  276. /*
  277. * 获取 用户某个时间段的钱数或者TOP20排行
  278. *
  279. * return Array || number
  280. */
  281. public static function getUserSpend($date,$status=''){
  282. $model=new self();
  283. $model=$model->alias('A');
  284. switch ($date){
  285. case null:case 'today':case 'week':case 'year':
  286. if($date==null) $date='month';
  287. $model=$model->whereTime('A.add_time',$date);
  288. break;
  289. case 'quarter':
  290. list($startTime,$endTime)=User::getMonth('n');
  291. $model = $model->where('A.add_time','>',strtotime($startTime));
  292. $model = $model->where('A.add_time','<',strtotime($endTime));
  293. break;
  294. default:
  295. list($startTime,$endTime)=explode('-',$date);
  296. $model = $model->where('A.add_time','>',strtotime($startTime));
  297. $model = $model->where('A.add_time','<',strtotime($endTime));
  298. break;
  299. }
  300. if($status===true){
  301. return $model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
  302. }
  303. $list=$model->join('user_bill B','B.uid=A.uid')
  304. ->where('B.type','pay_product')
  305. ->where('B.pm',0)
  306. ->field('sum(B.number) as totel_number,A.nickname,A.avatar,A.now_money,A.uid,A.add_time')
  307. ->order('totel_number desc')
  308. ->limit(0,20)
  309. ->select()
  310. ->toArray();
  311. if(!isset($list[0]['totel_number'])){
  312. $list=[];
  313. }
  314. return $list;
  315. }
  316. /*
  317. * 获取 相对于上月或者其他的数据
  318. *
  319. * return Array
  320. */
  321. public static function getPostNumber($date,$status=false,$field='A.add_time',$t='消费'){
  322. $model=new self();
  323. if(!$status) $model=$model->alias('A');
  324. switch ($date){
  325. case null:case 'today':case 'week':case 'year':
  326. if($date==null) {
  327. $date='last month';
  328. $title='相比上月用户'.$t.'增长';
  329. }
  330. if($date=='today') {
  331. $date='yesterday';
  332. $title='相比昨天用户'.$t.'增长';
  333. }
  334. if($date=='week') {
  335. $date='last week';
  336. $title='相比上周用户'.$t.'增长';
  337. }
  338. if($date=='year') {
  339. $date='last year';
  340. $title='相比去年用户'.$t.'增长';
  341. }
  342. $model=$model->whereTime($field,$date);
  343. break;
  344. case 'quarter':
  345. $title='相比上季度用户'.$t.'增长';
  346. list($startTime,$endTime)=User::getMonth('n',1);
  347. $model = $model->where($field,'>',$startTime);
  348. $model = $model->where($field,'<',$endTime);
  349. break;
  350. default:
  351. list($startTime,$endTime)=explode('-',$date);
  352. $title='相比'.$startTime.'-'.$endTime.'时间段用户'.$t.'增长';
  353. $Time=strtotime($endTime)-strtotime($startTime);
  354. $model = $model->where($field,'>',strtotime($startTime)+$Time);
  355. $model = $model->where($field,'<',strtotime($endTime)+$Time);
  356. break;
  357. }
  358. if($status){
  359. return [$model->count(),$title];
  360. }
  361. $number=$model->join('user_bill B','B.uid=A.uid')->where('B.type','pay_product')->where('B.pm',0)->sum('B.number');
  362. return [$number,$title];
  363. }
  364. //获取用户新增,头部信息
  365. public static function getBadgeList($where){
  366. $user_count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->count();
  367. $user_count_old=self::getOldDate($where)->count();
  368. $fenxiao=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])->where('spread_uid','<>',0)->count();
  369. $fenxiao_count=self::getOldDate($where)->where('spread_uid','neq',0)->count();
  370. $newFemxiao_count=bcsub($fenxiao,$fenxiao_count,0);
  371. $order_count=bcsub($user_count,$user_count_old,0);
  372. return [
  373. [
  374. 'name'=>'会员人数',
  375. 'field'=>'个',
  376. 'count'=>$user_count,
  377. 'content'=>'会员总人数',
  378. 'background_color'=>'layui-bg-blue',
  379. 'sum'=>self::count(),
  380. 'class'=>'fa fa-bar-chart',
  381. ],
  382. [
  383. 'name'=>'会员增长',
  384. 'field'=>'个',
  385. 'count'=>$order_count,
  386. 'content'=>'会员增长率',
  387. 'background_color'=>'layui-bg-cyan',
  388. 'sum'=>$user_count_old ? bcdiv($order_count,$user_count_old,2)*100:0,
  389. 'class'=>'fa fa-line-chart',
  390. ],
  391. [
  392. 'name'=>'分销人数',
  393. 'field'=>'个',
  394. 'count'=>$fenxiao,
  395. 'content'=>'分销总人数',
  396. 'background_color'=>'layui-bg-green',
  397. 'sum'=>self::where('spread_uid','neq',0)->count(),
  398. 'class'=>'fa fa-bar-chart',
  399. ],
  400. [
  401. 'name'=>'分销增长',
  402. 'field'=>'个',
  403. 'count'=>$newFemxiao_count,
  404. 'content'=>'分销总人数',
  405. 'background_color'=>'layui-bg-orange',
  406. 'sum'=>$fenxiao_count ? bcdiv($newFemxiao_count,$fenxiao_count,2)*100:0,
  407. 'class'=>'fa fa-cube',
  408. ],
  409. ];
  410. }
  411. /*
  412. * 获取会员增长曲线图和分布图
  413. * $where 查询条件
  414. * $limit 显示条数,是否有滚动条
  415. */
  416. public static function getUserChartList($where,$limit=20){
  417. $list=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter','status'])
  418. ->where('add_time','neq',0)
  419. ->field(['FROM_UNIXTIME(add_time,"%Y-%m-%d") as _add_time','count(uid) as num'])
  420. ->order('_add_time asc')
  421. ->group('_add_time')
  422. ->select();
  423. count($list) && $list=$list->toArray();
  424. $seriesdata=[];
  425. $xdata=[];
  426. $Zoom='';
  427. foreach ($list as $item){
  428. $seriesdata[]=$item['num'];
  429. $xdata[]=$item['_add_time'];
  430. }
  431. (count($xdata) > $limit) && $Zoom=$xdata[$limit-5];
  432. //多次购物会员数量饼状图
  433. $count=self::setWherePage(self::getModelTime($where,new self),$where,['is_promoter'])->count();
  434. $user_count=self::setWherePage(self::getModelTime($where,self::alias('a')->join('__STORE_ORDER__ r','r.uid=a.uid'),'a.add_time'),$where,['is_promoter'])
  435. ->where('r.paid',1)->count('a.uid');
  436. $shop_xdata=['多次购买数量占比','无购买数量占比'];
  437. $shop_data=[];
  438. $count >0 && $shop_data=[
  439. [
  440. 'value'=>bcdiv($user_count,$count,2)*100,
  441. 'name'=>$shop_xdata[0],
  442. 'itemStyle'=>[
  443. 'color'=>'#D789FF',
  444. ]
  445. ],
  446. [
  447. 'value'=>bcdiv($count-$user_count,$count,2)*100,
  448. 'name'=>$shop_xdata[1],
  449. 'itemStyle'=>[
  450. 'color'=>'#7EF0FB',
  451. ]
  452. ]
  453. ];
  454. return compact('shop_data','shop_xdata','fenbu_data','fenbu_xdata','seriesdata','xdata','Zoom');
  455. }
  456. //获取$date的前一天或者其他的时间段
  457. public static function getOldDate($where,$moedls=null){
  458. $model=$moedls ===null ? self::setWherePage(new self(),$where,['is_promoter','status']) :$moedls;
  459. switch ($where['data']){
  460. case 'today':
  461. $model=$model->whereTime('add_time','yesterday');
  462. break;
  463. case 'week':
  464. $model=$model->whereTime('add_time','last week');
  465. break;
  466. case 'month':
  467. $model=$model->whereTime('add_time','last month');
  468. break;
  469. case 'year':
  470. $model=$model->whereTime('add_time','last year');
  471. break;
  472. case 'quarter':
  473. $time=self::getMonth('n',1);
  474. $model=$model->where('add_time','between',$time);
  475. break;
  476. }
  477. return $model;
  478. }
  479. //获取用户属性和性别分布图
  480. public static function getEchartsData($where){
  481. $model=self::alias('a');
  482. $data=self::getModelTime($where,$model,'a.add_time')
  483. ->join('wechat_user r','r.uid=a.uid')
  484. ->group('r.province')
  485. ->field('count(r.province) as count,province')
  486. ->order('count desc')
  487. ->limit(15)
  488. ->select();
  489. if(count($data)) $data=$data->toArray();
  490. $legdata=[];
  491. $dataList=[];
  492. foreach ($data as $value){
  493. $value['province']=='' && $value['province']='未知省份';
  494. $legdata[]=$value['province'];
  495. $dataList[]=$value['count'];
  496. }
  497. $model=self::alias('a');
  498. $sex=self::getModelTime($where,$model,'a.add_time')
  499. ->join('wechat_user r','r.uid=a.uid')
  500. ->group('r.sex')
  501. ->field('count(r.uid) as count,sex')
  502. ->order('count desc')
  503. ->select();
  504. if(count($sex)) $sex=$sex->toArray();
  505. $sexlegdata=['男','女','未知'];
  506. $sexcount=self::getModelTime($where,new self())->count();
  507. $sexList=[];
  508. $color=['#FB7773','#81BCFE','#91F3FE'];
  509. foreach ($sex as $key=>$item){
  510. if($item['sex']==1){
  511. $item_date['name']='男';
  512. }else if($item['sex']==2){
  513. $item_date['name']='女';
  514. }else{
  515. $item_date['name']='未知性别';
  516. }
  517. $item_date['value']=bcdiv($item['count'],$sexcount,2)*100;
  518. $item_date['itemStyle']['color']=$color[$key];
  519. $sexList[]=$item_date;
  520. }
  521. return compact('sexList','sexlegdata','legdata','dataList');
  522. }
  523. //获取佣金记录列表
  524. public static function getCommissionList($where){
  525. $list=self::setCommissionWhere($where)
  526. ->page((int)$where['page'],(int)$where['limit'])
  527. ->select();
  528. count($list) && $list=$list->toArray();
  529. foreach ($list as &$value){
  530. $value['ex_price']= Db::name('user_extract')->where(['uid'=>$value['uid']])->sum('extract_price');
  531. $value['extract_price']= Db::name('user_extract')->where(['uid'=>$value['uid'],'status'=>1])->sum('extract_price');
  532. }
  533. $count=self::setCommissionWhere($where)->count();
  534. return ['data'=>$list,'count'=>$count];
  535. }
  536. //获取佣金记录列表的查询条件
  537. public static function setCommissionWhere($where){
  538. $models=self::setWherePage(self::alias('A'),$where,[],['A.nickname','A.uid'])
  539. ->join('user_bill B','B.uid=A.uid')
  540. ->group('A.uid')
  541. ->where(['B.category'=>'now_money','B.type'=>'brokerage'])
  542. ->field(['sum(B.number) as sum_number','A.nickname','A.uid','A.now_money']);
  543. if($where['order']==''){
  544. $models=$models->order('sum_number desc');
  545. }else{
  546. $models=$models->order($where['order']==1 ? 'sum_number desc':'sum_number asc');
  547. }
  548. if($where['price_max']!='' && $where['price_min']!=''){
  549. $models=$models->where('now_money','between',[$where['price_max'],$where['price_min']]);
  550. }
  551. return $models;
  552. }
  553. /**获取用户详细信息
  554. * @param $uid
  555. * @return array
  556. */
  557. public static function getUserInfos($uid)
  558. {
  559. $userInfo = self::where('uid',$uid)->find();
  560. if(!$userInfo) exception('读取用户信息失败!');
  561. return $userInfo->toArray();
  562. }
  563. //获取某人用户推广信息
  564. public static function getUserinfo($uid){
  565. $userinfo=self::where(['uid'=>$uid])->field(['nickname','spread_uid','now_money','add_time'])->find()->toArray();
  566. $userinfo['number']=UserBill::where(['category'=>'now_money','type'=>'brokerage'])->sum('number');
  567. $userinfo['spread_name']=$userinfo['spread_uid'] ? self::where(['uid'=>$userinfo['spread_uid']])->value('nickname') :'';
  568. return $userinfo;
  569. }
  570. //获取某用户的详细信息
  571. public static function getUserDetailed($uid){
  572. $key_field=['real_name','phone','province','city','district','detail','post_code'];
  573. $Address=($thisAddress= Db::name('user_address')->where(['uid'=>$uid,'is_default'=>1])->field($key_field)->find()) ?
  574. $thisAddress :
  575. Db::name('user_address')->where(['uid'=>$uid])->field($key_field)->find();
  576. $UserInfo=self::get($uid);
  577. return [
  578. ['col'=>12,'name'=>'默认收货地址','value'=>$thisAddress ? '收货人:'.$thisAddress['real_name'].'邮编:'.$thisAddress['post_code'].' 收货人电话:'.$thisAddress['phone'].' 地址:'.$thisAddress['province'].' '.$thisAddress['city'].' '.$thisAddress['district'].' '.$thisAddress['detail'] : ''],
  579. // ['name'=>'微信OpenID','value'=>WechatUser::where(['uid'=>$uid])->value('openid'),'col'=>8],
  580. ['name'=>'手机号码','value'=>$UserInfo['phone']],
  581. // ['name'=>'ID','value'=>$uid],
  582. ['name'=>'姓名','value'=>''],
  583. ['name'=>'微信昵称','value'=>$UserInfo['nickname']],
  584. ['name'=>'邮箱','value'=>''],
  585. ['name'=>'生日','value'=>''],
  586. ['name'=>'积分','value'=>$UserInfo['integral']],
  587. ['name'=>'上级推广人','value'=>$UserInfo['spread_uid'] ? self::where(['uid'=>$UserInfo['spread_uid']])->value('nickname'):''],
  588. ['name'=>'账户余额','value'=>$UserInfo['now_money']],
  589. ['name'=>'佣金总收入','value'=>UserBill::where(['category'=>'now_money','type'=>'brokerage','uid'=>$uid])->sum('number')],
  590. ['name'=>'提现总金额','value'=> Db::name('user_extract')->where(['uid'=>$uid,'status'=>1])->sum('extract_price')],
  591. ];
  592. }
  593. //获取某用户的订单个数,消费明细
  594. public static function getHeaderList($uid){
  595. return [
  596. [
  597. 'title'=>'总计订单',
  598. 'value'=>StoreOrder::where(['uid'=>$uid])->count(),
  599. 'key'=>'笔',
  600. 'class'=>'',
  601. ],
  602. [
  603. 'title'=>'总消费金额',
  604. 'value'=>StoreOrder::where(['uid'=>$uid,'paid'=>1])->sum('total_price'),
  605. 'key'=>'元',
  606. 'class'=>'',
  607. ],
  608. [
  609. 'title'=>'本月订单',
  610. 'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->count(),
  611. 'key'=>'笔',
  612. 'class'=>'',
  613. ],
  614. [
  615. 'title'=>'本月消费金额',
  616. 'value'=>StoreOrder::where(['uid'=>$uid])->whereTime('add_time','month')->sum('total_price'),
  617. 'key'=>'元',
  618. 'class'=>'',
  619. ]
  620. ];
  621. }
  622. /*
  623. * 获取 会员 订单个数,积分明细,优惠劵明细
  624. *
  625. * $uid 用户id;
  626. *
  627. * return array
  628. */
  629. public static function getCountInfo($uid){
  630. $order_count=StoreOrder::where(['uid'=>$uid])->count();
  631. $integral_count=UserBill::where(['uid'=>$uid,'category'=>'integral'])->where('type','in',['deduction','system_add'])->count();
  632. $sign_count=UserBill::where(['uid'=>$uid,'category'=>'integral','type'=>'sign'])->count();
  633. $balanceChang_count=UserBill::where(['uid'=>$uid,'category'=>'now_money'])
  634. ->where('type','in',['system_add','pay_product','extract','pay_product_refund','system_sub'])
  635. ->count();
  636. $coupon_count=StoreCouponUser::where(['uid'=>$uid])->count();
  637. $spread_count=self::where(['spread_uid'=>$uid])->count();
  638. return compact('order_count','integral_count','sign_count','balanceChang_count','coupon_count','spread_count');
  639. }
  640. /*
  641. * 获取 会员业务的
  642. * 购物会员统计
  643. * 会员访问量
  644. *
  645. * 曲线图
  646. *
  647. * $where 查询条件
  648. *
  649. * return array
  650. */
  651. public static function getUserBusinessChart($where,$limit=20){
  652. //获取购物会员人数趋势图
  653. $list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('__STORE_ORDER__ r','r.uid=a.uid'),'a.add_time')
  654. ->where(['r.paid'=>1,'a.is_promoter'=>0])
  655. ->where('a.add_time','neq',0)
  656. ->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
  657. ->group('_add_time')
  658. ->order('_add_time asc')
  659. ->select();
  660. count($list) && $list=$list->toArray();
  661. $seriesdata=[];
  662. $xdata=[];
  663. $zoom='';
  664. foreach ($list as $item){
  665. $seriesdata[]=$item['count_user'];
  666. $xdata[]=$item['_add_time'];
  667. }
  668. count($xdata) > $limit && $zoom=$xdata[$limit-5];
  669. //会员访问量
  670. $visit=self::getModelTime($where,self::alias('a')->join('__STORE_VISIT__ t','t.uid=a.uid'),'t.add_time')
  671. ->where('a.is_promoter',0)
  672. ->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
  673. ->group('_add_time')
  674. ->order('_add_time asc')
  675. ->select();
  676. count($visit) && $visit=$visit->toArray();
  677. $visit_data=[];
  678. $visit_xdata=[];
  679. $visit_zoom='';
  680. foreach ($visit as $item){
  681. $visit_data[]=$item['count_user'];
  682. $visit_xdata[]=$item['_add_time'];
  683. }
  684. count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
  685. //多次购物会员数量饼状图
  686. $count=self::getModelTime($where,self::where('is_promoter',0))->count();
  687. $user_count=self::getModelTime($where,self::alias('a')->join('__STORE_ORDER__ r','r.uid=a.uid'),'a.add_time')
  688. ->where('a.is_promoter',0)
  689. ->where('r.paid',1)
  690. ->group('a.uid')
  691. ->count();
  692. $shop_xdata=['多次购买数量占比','无购买数量占比'];
  693. $shop_data=[];
  694. $count >0 && $shop_data=[
  695. [
  696. 'value'=>bcdiv($user_count,$count,2)*100,
  697. 'name'=>$shop_xdata[0],
  698. 'itemStyle'=>[
  699. 'color'=>'#D789FF',
  700. ]
  701. ],
  702. [
  703. 'value'=>bcdiv($count-$user_count,$count,2)*100,
  704. 'name'=>$shop_xdata[1],
  705. 'itemStyle'=>[
  706. 'color'=>'#7EF0FB',
  707. ]
  708. ]
  709. ];
  710. return compact('seriesdata','xdata','zoom','visit_data','visit_xdata','visit_zoom','shop_data','shop_xdata');
  711. }
  712. /*
  713. * 获取用户
  714. * 积分排行
  715. * 会员余额排行榜
  716. * 分销商佣金总额排行榜
  717. * 购物笔数排行榜
  718. * 购物金额排行榜
  719. * 分销商佣金提现排行榜
  720. * 上月消费排行榜
  721. * $limit 查询多少条
  722. * return array
  723. */
  724. public static function getUserTop10List($limit=10,$is_promoter=0){
  725. //积分排行
  726. $integral=self::where('status',1)
  727. ->where('is_promoter',$is_promoter)
  728. ->order('integral desc')
  729. ->field(['nickname','phone','integral','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
  730. ->limit($limit)
  731. ->select();
  732. count($integral) && $integral=$integral->toArray();
  733. //会员余额排行榜
  734. $now_money=self::where('status',1)
  735. ->where('is_promoter',$is_promoter)
  736. ->order('now_money desc')
  737. ->field(['nickname','phone','now_money','FROM_UNIXTIME(add_time,"%Y-%m-%d") as add_time'])
  738. ->limit($limit)
  739. ->select();
  740. count($now_money) && $now_money=$now_money->toArray();
  741. //购物笔数排行榜
  742. $orderPayCount = StoreOrder::getOrderPayCount($is_promoter);
  743. if($orderPayCount){
  744. $shopcount=self::alias('a')
  745. ->join('__STORE_ORDER__ r','r.uid=a.uid')
  746. ->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
  747. ->group('r.uid')
  748. ->field(['a.nickname','a.phone','count(r.uid) as sum_count','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
  749. ->order('sum_count desc')
  750. ->limit($limit)
  751. ->select();
  752. }else $shopcount = [];
  753. count($shopcount) && $shopcount=$shopcount->toArray();
  754. //购物金额排行榜
  755. if($orderPayCount){
  756. $order=self::alias('a')
  757. ->join('__STORE_ORDER__ r','r.uid=a.uid')
  758. ->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
  759. ->group('r.uid')
  760. ->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'])
  761. ->order('sum_price desc')
  762. ->limit($limit)
  763. ->select();
  764. }else $order = [];
  765. count($order) && $order=$order->toArray();
  766. //上月消费排行
  767. $orderPayCount = StoreOrder::getOrderPayMonthCount($is_promoter);
  768. if($orderPayCount){
  769. $lastorder=self::alias('a')
  770. ->join('__STORE_ORDER__ r','r.uid=a.uid')
  771. ->where(['r.paid'=>1,'a.is_promoter'=>$is_promoter])
  772. // ->whereTime('r.pay_time','last month')
  773. ->where('r.pay_time','between',[strtotime(date('Y-m',strtotime('-1 month'))),strtotime(date('Y-m'))])
  774. ->group('r.uid')
  775. ->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'])
  776. ->order('sum_price desc')
  777. ->limit($limit)
  778. ->select();
  779. }else $lastorder = [];
  780. count($lastorder) && $lastorder=$lastorder->toArray();
  781. return compact('integral','now_money','shopcount','order','lastorder');
  782. }
  783. /*
  784. * 获取 会员业务
  785. * 会员总余额 会员总积分
  786. * $where 查询条件
  787. *
  788. * return array
  789. */
  790. public static function getUserBusinesHeade($where){
  791. return [
  792. [
  793. 'name'=>'会员总余额',
  794. 'field'=>'元',
  795. 'count'=>self::getModelTime($where,self::where('status',1))->sum('now_money'),
  796. 'background_color'=>'layui-bg-cyan',
  797. 'col'=>6,
  798. ],
  799. [
  800. 'name'=>'会员总积分',
  801. 'field'=>'分',
  802. 'count'=>self::getModelTime($where,self::where('status',1))->sum('integral'),
  803. 'background_color'=>'layui-bg-cyan',
  804. 'col'=>6
  805. ]
  806. ];
  807. }
  808. /*
  809. * 分销会员头部信息查询获取
  810. *
  811. * 分销商总佣金余额
  812. * 分销商总提现佣金
  813. * 本月分销商业务佣金
  814. * 本月分销商佣金提现金额
  815. * 上月分销商业务佣金
  816. * 上月分销商佣金提现金额
  817. * $where array 时间条件
  818. *
  819. * return array
  820. */
  821. public static function getDistributionBadgeList($where){
  822. return [
  823. [
  824. 'name'=>'分销商总佣金',
  825. 'field'=>'元',
  826. 'count'=>self::getModelTime($where,UserBill::where('category','now_money')->where('type','brokerage'))->where('uid','in',function($query){
  827. $query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
  828. })->sum('number'),
  829. 'background_color'=>'layui-bg-cyan',
  830. 'col'=>3,
  831. ],
  832. [
  833. 'name'=>'分销商总佣金余额',
  834. 'field'=>'元',
  835. 'count'=>self::getModelTime($where,self::where('status',1)->where('is_promoter',1))->sum('now_money'),
  836. 'background_color'=>'layui-bg-cyan',
  837. 'col'=>3,
  838. ],
  839. [
  840. 'name'=>'分销商总提现佣金',
  841. 'field'=>'元',
  842. 'count'=>self::getModelTime($where,UserExtract::where('status',1))->sum('extract_price'),
  843. 'background_color'=>'layui-bg-cyan',
  844. 'col'=>3,
  845. ],
  846. [
  847. 'name'=>'本月分销商业务佣金',
  848. 'field'=>'元',
  849. 'count'=>self::getModelTime(['data'=>'month'],UserBill::where('category','now_money')->where('type','brokerage'))
  850. ->where('uid','in',function ($query){
  851. $query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
  852. })->sum('number'),
  853. 'background_color'=>'layui-bg-cyan',
  854. 'col'=>3,
  855. ],
  856. [
  857. 'name'=>'本月分销商佣金提现金额',
  858. 'field'=>'元',
  859. 'count'=>self::getModelTime(['data'=>'month'],UserExtract::where('status',1))
  860. ->where('uid','in',function ($query){
  861. $query->name('user')->where('status',1)->where('is_promoter',1)->field('uid');
  862. })->sum('extract_price'),
  863. 'background_color'=>'layui-bg-cyan',
  864. 'col'=>4,
  865. ],
  866. [
  867. 'name'=>'上月分销商业务佣金',
  868. 'field'=>'元',
  869. 'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
  870. $query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
  871. })->where('type','brokerage'))->sum('number'),
  872. 'background_color'=>'layui-bg-cyan',
  873. 'col'=>4,
  874. ],
  875. [
  876. 'name'=>'上月分销商佣金提现金额',
  877. 'field'=>'元',
  878. 'count'=>self::getOldDate(['data'=>'year'],UserBill::where('category','now_money')->where('uid','in',function ($query){
  879. $query->name('user')->where('status',1)->where('is_promoter',1)->whereOr('spread_uid','neq',0)->field('uid');
  880. })->where('type','brokerage'))->sum('number'),
  881. 'background_color'=>'layui-bg-cyan',
  882. 'col'=>4,
  883. ],
  884. ];
  885. }
  886. /*
  887. * 分销会员
  888. * 分销数量 饼状图
  889. * 分销商会员访问量 曲线
  890. * 获取购物会员人数趋势图 曲线
  891. * 多次购物分销会员数量 饼状图
  892. * $where array 条件
  893. * $limit int n条数据后出拖动条
  894. * return array
  895. */
  896. public static function getUserDistributionChart($where,$limit=20){
  897. //分销数量
  898. $fenbu_user=self::getModelTime($where,new self)->field(['count(uid) as num'])->group('is_promoter')->select();
  899. count($fenbu_user) && $fenbu_user=$fenbu_user->toArray();
  900. $sum_user=0;
  901. $fenbu_data=[];
  902. $fenbu_xdata=['分销商','非分销商'];
  903. $color=['#81BCFE','#91F3FE'];
  904. foreach($fenbu_user as $item){
  905. $sum_user+=$item['num'];
  906. }
  907. foreach ($fenbu_user as $key=>$item){
  908. $value['value']=bcdiv($item['num'],$sum_user,2)*100;
  909. $value['name']=isset($fenbu_xdata[$key]) ?$fenbu_xdata[$key].' %'.$value['value'] :'';
  910. $value['itemStyle']['color']=$color[$key];
  911. $fenbu_data[]=$value;
  912. }
  913. //分销商会员访问量
  914. $visit=self::getModelTime($where,self::alias('a')->join('store_visit t','t.uid=a.uid'),'t.add_time')
  915. ->where('a.is_promoter',1)
  916. ->field(['FROM_UNIXTIME(t.add_time,"%Y-%m-%d") as _add_time','count(t.uid) as count_user'])
  917. ->group('_add_time')
  918. ->order('_add_time asc')
  919. ->select();
  920. // echo self::getLastSql();die;
  921. count($visit) && $visit=$visit->toArray();
  922. $visit_data=[];
  923. $visit_xdata=[];
  924. $visit_zoom='';
  925. foreach ($visit as $item){
  926. $visit_data[]=$item['count_user'];
  927. $visit_xdata[]=$item['_add_time'];
  928. }
  929. count($visit_xdata) > $limit && $visit_zoom=$visit_xdata[$limit-5];
  930. //获取购物会员人数趋势图
  931. $list=self::getModelTime($where,self::where('a.status',1)->alias('a')->join('__STORE_ORDER__ r','r.uid=a.uid'),'a.add_time')
  932. ->where(['r.paid'=>1,'a.is_promoter'=>1])
  933. ->where('a.add_time','neq',0)
  934. ->field(['FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as _add_time','count(r.uid) as count_user'])
  935. ->group('_add_time')
  936. ->order('_add_time asc')
  937. ->select();
  938. count($list) && $list=$list->toArray();
  939. $seriesdata=[];
  940. $xdata=[];
  941. $zoom='';
  942. foreach ($list as $item){
  943. $seriesdata[]=$item['count_user'];
  944. $xdata[]=$item['_add_time'];
  945. }
  946. count($xdata) > $limit && $zoom=$xdata[$limit-5];
  947. //多次购物分销会员数量饼状图
  948. $count=self::getModelTime($where,self::where('is_promoter',1))->count();
  949. $user_count=self::getModelTime($where,self::alias('a')
  950. ->join('__STORE_ORDER__ r','r.uid=a.uid'),'a.add_time')
  951. ->where('a.is_promoter',1)
  952. ->where('r.paid',1)
  953. ->group('a.uid')
  954. ->count();
  955. $shop_xdata=['多次购买数量占比','无购买数量占比'];
  956. $shop_data=[];
  957. $count >0 && $shop_data=[
  958. [
  959. 'value'=>bcdiv($user_count,$count,2)*100,
  960. 'name'=>$shop_xdata[0].$user_count.'人',
  961. 'itemStyle'=>[
  962. 'color'=>'#D789FF',
  963. ]
  964. ],
  965. [
  966. 'value'=>bcdiv($count-$user_count,$count,2)*100,
  967. 'name'=>$shop_xdata[1].($count-$user_count).'人',
  968. 'itemStyle'=>[
  969. 'color'=>'#7EF0FB',
  970. ]
  971. ]
  972. ];
  973. return compact('fenbu_data','fenbu_xdata','visit_data','visit_xdata','visit_zoom','seriesdata','xdata','zoom','shop_xdata','shop_data');
  974. }
  975. /*
  976. * 分销商佣金提现排行榜
  977. * 分销商佣金总额排行榜
  978. * $limit 截取条数
  979. * return array
  980. */
  981. public static function getUserDistributionTop10List($limit){
  982. //分销商佣金提现排行榜
  983. $extract=self::alias('a')
  984. ->join('user_extract t','a.uid=t.uid')
  985. ->where(['t.status'=>1,'a.is_promoter'=>1])
  986. ->group('t.uid')
  987. ->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'])
  988. ->order('sum_price desc')
  989. ->limit($limit)
  990. ->select();
  991. count($extract) && $extract=$extract->toArray();
  992. //分销商佣金总额排行榜
  993. $commission=UserBill::alias('l')
  994. ->join('user a','l.uid=a.uid')
  995. ->where(['l.status'=>'1','l.category'=>'now_money','l.type'=>'brokerage','a.is_promoter'=>1])
  996. ->group('l.uid')
  997. ->field(['a.nickname','a.phone','sum(number) as sum_number','FROM_UNIXTIME(a.add_time,"%Y-%m-%d") as add_time'])
  998. ->order('sum_number desc')
  999. ->limit($limit)
  1000. ->select();
  1001. count($commission) && $commission=$commission->toArray();
  1002. return compact('extract','commission');
  1003. }
  1004. public static function getSpreadList($uid,$page,$limit){
  1005. $list=self::where(['spread_uid'=>$uid])->field(['uid','nickname','now_money','integral','add_time'])
  1006. ->order('uid desc')->page((int)$page,(int)$limit)->select();
  1007. count($list) && $list=$list->toArray();
  1008. foreach ($list as &$item){
  1009. $item['add_time']=date('Y-m-d H',$item['add_time']);
  1010. }
  1011. return $list;
  1012. }
  1013. /**
  1014. * 一级分销
  1015. * @param $orderInfo
  1016. * @return bool
  1017. */
  1018. public static function backOrderBrokerage($orderInfo)
  1019. {
  1020. $userInfo = User::getUserInfo($orderInfo['uid']);
  1021. if(!$userInfo || !$userInfo['spread_uid']) return true;
  1022. $storeBrokerageStatu = SystemConfigService::get('store_brokerage_statu') ? : 1;//获取后台分销类型
  1023. if($storeBrokerageStatu == 1){
  1024. if(!User::be(['uid'=>$userInfo['spread_uid'],'is_promoter'=>1])) return true;
  1025. }
  1026. $brokerageRatio = (SystemConfigService::get('store_brokerage_ratio') ?: 0)/100;
  1027. if($brokerageRatio <= 0) return true;
  1028. $cost = isset($orderInfo['cost']) ? $orderInfo['cost'] : 0;//成本价
  1029. if($cost > $orderInfo['pay_price']) return true;//成本价大于支付价格时直接返回
  1030. $brokeragePrice = bcmul(bcsub($orderInfo['pay_price'],$cost,2),$brokerageRatio,2);
  1031. //返佣之后余额
  1032. $spNow_money = User::where(['uid'=>$userInfo['spread_uid']])->value('now_money');
  1033. $balance = bcadd($spNow_money,$brokeragePrice,2);
  1034. if($brokeragePrice <= 0) return true;
  1035. $mark = $userInfo['nickname'].'成功消费'.floatval($orderInfo['pay_price']).'元,奖励推广佣金'.floatval($brokeragePrice);
  1036. self::beginTrans();
  1037. $res1 = UserBill::income('获得推广佣金',$userInfo['spread_uid'],'now_money','brokerage',$brokeragePrice,$orderInfo['id'],$balance,$mark);
  1038. $res2 = self::bcInc($userInfo['spread_uid'],'now_money',$brokeragePrice,'uid');
  1039. $res = $res1 && $res2;
  1040. self::checkTrans($res);
  1041. if($res) self::backOrderBrokerageTwo($orderInfo);
  1042. return $res;
  1043. }
  1044. /**
  1045. * 二级推广
  1046. * @param $orderInfo
  1047. * @return bool
  1048. */
  1049. public static function backOrderBrokerageTwo($orderInfo){
  1050. $userInfo = User::getUserInfo($orderInfo['uid']);
  1051. $userInfoTwo = User::getUserInfo($userInfo['spread_uid']);
  1052. if(!$userInfoTwo || !$userInfoTwo['spread_uid']) return true;
  1053. $storeBrokerageStatu = SystemConfigService::get('store_brokerage_statu') ? : 1;//获取后台分销类型
  1054. if($storeBrokerageStatu == 1){
  1055. if(!User::be(['uid'=>$userInfoTwo['spread_uid'],'is_promoter'=>1])) return true;
  1056. }
  1057. $brokerageRatio = (SystemConfigService::get('store_brokerage_two') ?: 0)/100;
  1058. if($brokerageRatio <= 0) return true;
  1059. $cost = isset($orderInfo['cost']) ? $orderInfo['cost'] : 0;//成本价
  1060. if($cost > $orderInfo['pay_price']) return true;//成本价大于支付价格时直接返回
  1061. $brokeragePrice = bcmul(bcsub($orderInfo['pay_price'],$cost,2),$brokerageRatio,2);
  1062. //返佣之后余额
  1063. $spNow_money = User::where(['uid'=>$userInfo['spread_uid']])->value('now_money');
  1064. $balance = bcadd($spNow_money,$brokeragePrice,2);
  1065. if($brokeragePrice <= 0) return true;
  1066. $mark = '二级推广人'.$userInfo['nickname'].'成功消费'.floatval($orderInfo['pay_price']).'元,奖励推广佣金'.floatval($brokeragePrice);
  1067. self::beginTrans();
  1068. $res1 = UserBill::income('获得推广佣金',$userInfoTwo['spread_uid'],'now_money','brokerage',$brokeragePrice,$orderInfo['id'],$balance,$mark);
  1069. $res2 = self::bcInc($userInfoTwo['spread_uid'],'now_money',$brokeragePrice,'uid');
  1070. $res = $res1 && $res2;
  1071. self::checkTrans($res);
  1072. return $res;
  1073. }
  1074. }