UserExtract.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: lianghuan
  5. * Date: 2018-03-03
  6. * Time: 16:47
  7. */
  8. namespace app\admin\model\user;
  9. use app\admin\model\user\User;
  10. use app\admin\model\user\UserBill;
  11. use app\admin\model\wechat\WechatUser;
  12. use think\Url;
  13. use traits\ModelTrait;
  14. use basic\ModelBasic;
  15. use service\WechatTemplateService;
  16. /**
  17. * 用户提现管理 model
  18. * Class User
  19. * @package app\admin\model\user
  20. */
  21. class UserExtract extends ModelBasic
  22. {
  23. use ModelTrait;
  24. /**
  25. * @param $where
  26. * @return array
  27. */
  28. public static function systemPage($where)
  29. {
  30. $model = new self;
  31. if($where['status'] != '') $model = $model->where('a.status',$where['status']);
  32. if($where['extract_type'] != '') $model = $model->where('a.extract_type',$where['extract_type']);
  33. if($where['nireid'] != '') $model = $model->where('a.real_name|a.id|b.nickname|a.bank_code|a.alipay_code','like',"%$where[nireid]%");
  34. $model = $model->alias('a');
  35. $model = $model->field('a.*,b.nickname');
  36. $model = $model->join('__USER__ b','b.uid=a.uid','LEFT');
  37. $model = $model->order('a.id desc');
  38. return self::page($model);
  39. }
  40. public static function changeFail($id,$fail_msg)
  41. {
  42. $fail_time = time();
  43. $data =self::get($id);
  44. $extract_number=$data['extract_price'];
  45. $mark='提现失败,退回佣金'.$extract_number.'元';
  46. $uid=$data['uid'];
  47. $status = -1;
  48. $User= User::find(['uid'=>$uid])->toArray();
  49. UserBill::income('提现失败',$uid,'now_money','extract',$extract_number,$id,$User['now_money'],$mark);
  50. User::bcInc($uid,'now_money',$extract_number,'uid');
  51. WechatTemplateService::sendTemplate(WechatUser::uidToOpenid($uid),WechatTemplateService::USER_BALANCE_CHANGE,[
  52. 'first'=> $mark,
  53. 'keyword1'=>'佣金提现',
  54. 'keyword2'=>date('Y-m-d H:i:s',time()),
  55. 'keyword3'=>$extract_number,
  56. 'remark'=>'错误原因:'.$fail_msg
  57. ],Url::build('wap/my/user_pro',[],true,true));
  58. return self::edit(compact('fail_time','fail_msg','status'),$id);
  59. }
  60. public static function changeSuccess($id)
  61. {
  62. $status = 1;
  63. $data =self::get($id);
  64. $extract_number=$data['extract_price'];
  65. $mark='成功提现佣金'.$extract_number.'元';
  66. $uid=$data['uid'];
  67. WechatTemplateService::sendTemplate(WechatUser::uidToOpenid($uid),WechatTemplateService::USER_BALANCE_CHANGE,[
  68. 'first'=> $mark,
  69. 'keyword1'=>'佣金提现',
  70. 'keyword2'=>date('Y-m-d H:i:s',time()),
  71. 'keyword3'=>$extract_number,
  72. 'remark'=>'点击查看我的佣金明细'
  73. ],Url::build('wap/my/user_pro',[],true,true));
  74. return self::edit(compact('status'),$id);
  75. }
  76. //测试数据
  77. public static function test(){
  78. $uids=User::order('uid desc')->limit(2,20)->field(['uid','nickname'])->select()->toArray();
  79. $type=['bank','alipay','weixin'];
  80. foreach ($uids as $item){
  81. $data=[
  82. 'uid'=>$item['uid'],
  83. 'real_name'=>$item['nickname'],
  84. 'extract_type'=>isset($type[rand(0,2)]) ? $type[rand(0,2)] :'alipay',
  85. 'bank_code'=>rand(1000000,999999999),
  86. 'bank_address'=>'中国',
  87. 'alipay_code'=>rand(1000,9999999),
  88. 'extract_price'=>rand(100,9999),
  89. 'mark'=>'测试数据',
  90. 'add_time'=>time(),
  91. 'status'=>1,
  92. 'wechat'=>rand(999,878788).$item['uid'],
  93. ];
  94. self::set($data);
  95. }
  96. }
  97. //获取头部提现信息
  98. public static function getExtractHead(){
  99. //本月提现人数
  100. $month=self::getModelTime(['data'=>'month'],self::where(['status'=>1]))->group('uid')->count();
  101. //本月提现笔数
  102. $new_month=self::getModelTime(['data'=>'month'],self::where(['status'=>1]))->distinct(true)->count();
  103. //上月提现人数
  104. $last_month=self::whereTime('add_time','last month')->where('status',1)->group('uid')->distinct(true)->count();
  105. //上月提现笔数
  106. $last_count=self::whereTime('add_time','last month')->where('status',1)->count();
  107. //本月提现金额
  108. $extract_price=self::getModelTime(['data'=>'month'],self::where(['status'=>1]))->sum('extract_price');
  109. //上月提现金额
  110. $last_extract_price=self::whereTime('add_time','last month')->where('status',1)->sum('extract_price');
  111. return [
  112. [
  113. 'name'=>'总提现人数',
  114. 'field'=>'个',
  115. 'count'=>self::where(['status'=>1])->group('uid')->count(),
  116. 'content'=>'',
  117. 'background_color'=>'layui-bg-blue',
  118. 'sum'=>'',
  119. 'class'=>'fa fa-bar-chart',
  120. ],
  121. [
  122. 'name'=>'总提现笔数',
  123. 'field'=>'笔',
  124. 'count'=>self::where(['status'=>1])->distinct(true)->count(),
  125. 'content'=>'',
  126. 'background_color'=>'layui-bg-cyan',
  127. 'sum'=>'',
  128. 'class'=>'fa fa-line-chart',
  129. ],
  130. [
  131. 'name'=>'本月提现人数',
  132. 'field'=>'人',
  133. 'count'=>$month,
  134. 'content'=>'',
  135. 'background_color'=>'layui-bg-orange',
  136. 'sum'=>'',
  137. 'class'=>'fa fa-line-chart',
  138. ],
  139. [
  140. 'name'=>'本月提现笔数',
  141. 'field'=>'笔',
  142. 'count'=>$new_month,
  143. 'content'=>'',
  144. 'background_color'=>'layui-bg-green',
  145. 'sum'=>'',
  146. 'class'=>'fa fa-line-chart',
  147. ],
  148. [
  149. 'name'=>'本月提现金额',
  150. 'field'=>'元',
  151. 'count'=>$extract_price,
  152. 'content'=>'提现总金额',
  153. 'background_color'=>'layui-bg-cyan',
  154. 'sum'=>self::where(['status'=>1])->sum('extract_price'),
  155. 'class'=>'fa fa-line-chart',
  156. ],
  157. [
  158. 'name'=>'上月提现人数',
  159. 'field'=>'个',
  160. 'count'=>$last_month,
  161. 'content'=>'环比增幅',
  162. 'background_color'=>'layui-bg-blue',
  163. 'sum'=>$last_month==0 ? '100%' :bcdiv($month,$last_month,2)*100,
  164. 'class'=>$last_month==0 ? 'fa fa-level-up':'fa fa-level-down',
  165. ],
  166. [
  167. 'name'=>'上月提现笔数',
  168. 'field'=>'笔',
  169. 'count'=>$last_count,
  170. 'content'=>'环比增幅',
  171. 'background_color'=>'layui-bg-black',
  172. 'sum'=>$last_count==0 ? '100%':bcdiv($new_month,$last_count,2)*100,
  173. 'class'=>$last_count==0 ? 'fa fa-level-up':'fa fa-level-down',
  174. ],
  175. [
  176. 'name'=>'上月提现金额',
  177. 'field'=>'元',
  178. 'count'=>$last_extract_price,
  179. 'content'=>'环比增幅',
  180. 'background_color'=>'layui-bg-gray',
  181. 'sum'=>$last_extract_price==0 ? '100%':bcdiv($extract_price,$last_extract_price,2)*100,
  182. 'class'=>$last_extract_price==0 ? 'fa fa-level-up':'fa fa-level-down',
  183. ],
  184. ];
  185. }
  186. //获取提现分布图和提现人数金额曲线图
  187. public static function getExtractList($where,$limit=15){
  188. $legdata=['提现人数','提现金额'];
  189. $list=self::getModelTime($where,self::where('status',1))
  190. ->field([
  191. 'FROM_UNIXTIME(add_time,"%Y-%c-%d") as un_time',
  192. 'count(uid) as count',
  193. 'sum(extract_price) as sum_price',
  194. ])->group('un_time')->order('un_time asc')->select();
  195. if(count($list)) $list=$list->toArray();
  196. $xdata=[];
  197. $itemList=[0=>[],1=>[]];
  198. $chatrList=[];
  199. $zoom='';
  200. foreach ($list as $value){
  201. $xdata[]=$value['un_time'];
  202. $itemList[0][]=$value['count'];
  203. $itemList[1][]=$value['sum_price'];
  204. }
  205. foreach ($legdata as $key=>$name){
  206. $item['name']=$name;
  207. $item['type']='line';
  208. $item['data']=$itemList[$key];
  209. $chatrList[]=$item;
  210. }
  211. unset($item,$name,$key);
  212. if(count($xdata)>$limit) $zoom=$xdata[$limit-5];
  213. //饼状图
  214. $cake=['支付宝','银行卡','微信'];
  215. $fenbulist=self::getModelTime($where,self::where('status',1))
  216. ->field(['count(uid) as count','extract_type'])->group('extract_type')->order('count asc')->select();
  217. if(count($fenbulist)) $fenbulist=$fenbulist->toArray();
  218. $sum_count=self::getModelTime($where,self::where('status',1))->count();
  219. $color=['#FB7773','#81BCFE','#91F3FE'];
  220. $fenbudata=[];
  221. foreach ($fenbulist as $key=>$item){
  222. if($item['extract_type']=='bank'){
  223. $item_date['name']='银行卡';
  224. }else if($item['extract_type']=='alipay'){
  225. $item_date['name']='支付宝';
  226. }else if($item['extract_type']=='weixin'){
  227. $item_date['name']='微信';
  228. }
  229. $item_date['value']=bcdiv($item['count'],$sum_count,2)*100;
  230. $item_date['itemStyle']['color']=$color[$key];
  231. $fenbudata[]=$item_date;
  232. }
  233. return compact('xdata','chatrList','legdata','zoom','cake','fenbudata');
  234. }
  235. /**
  236. * 获取用户累计提现金额
  237. * @param int $uid
  238. * @return int|mixed
  239. */
  240. public static function getUserCountPrice($uid = 0){
  241. if(!$uid) return 0;
  242. $price = self::where('uid',$uid)->where('status',1)->field('sum(extract_price) as price')->find()['price'];
  243. return $price ? $price : 0;
  244. }
  245. /**
  246. * 获取用户累计提现次数
  247. * @param int $uid
  248. * @return int|string
  249. */
  250. public static function getUserCountNum($uid = 0){
  251. if(!$uid) return 0;
  252. return self::where('uid',$uid)->count();
  253. }
  254. }