UserExtract.php 10 KB

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