12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433 |
- <?php
- namespace app\api\controller;
- use addons\epay\library\Service;
- use app\api\controller\Common;
- use app\api\validate\user\Report;
- use app\common\model\UserPower;
- use app\common\service\TenimService;
- use outh\outh;
- use think\Db;
- use app\common\controller\RedisLeaderboard;
- use Redis;
- use GatewayClient\Gateway;
- use think\Exception;
- /**
- * 会员中心接口
- */
- class UserCenter extends Common
- {
- protected $noNeedLogin = ['shujuhuifu','getAnchorType','getRecharConfig','getExchangeConfig','getLevelExplain'];
- protected $noNeedRight = '*';
- public function _initialize()
- {
- parent::_initialize();
- $this->userModel = new \app\common\model\User();
- }
- /**
- * 获取当前用户信息
- */
- public function getMyUserInfo() {
- $this->success("获取成功!",$this->auth->getUserinfo());
- }
- /**
- * 获取个人信息
- */
- public function getUserInfo() {
- $user_id = $this->request->param("user_id");
- if (!$user_id) {
- $this->error(__('Invalid parameters'));
- }
- // 获取基本信息
- $where = [];
- $where["id"] = $user_id;
- $userInfo = $this->userModel->field("id,nickname,pre_nickname,image,mobile,avatar,pre_avatar,gender,money,age,u_id,level,jewel,
- age_id,constellation_id,province_id,city_id,desc,ipaddress,is_cool,is_manager,is_stealth,charm_level,wealth_level")->where($where)->find();
- $userInfo['nickname_status'] = $userInfo['avatar_status'] = 0;
- if (!empty($userInfo['pre_nickname']) && $userInfo['pre_nickname'] != $userInfo['nickname']) {
- $userInfo['nickname_status'] = 1;
- }
- if (!empty($userInfo['pre_avatar']) && $userInfo['pre_avatar'] != $userInfo['avatar']) {
- $userInfo['avatar_status'] = 1;
- }
- $userInfoA = $this->userModel->getAppendData($userInfo);
- $userInfo['age_text'] = $userInfoA['age_text'];
- $userInfo['constellation_text'] = $userInfoA['constellation_text'];
- $userInfo['province_text'] = $userInfoA['province_text'];
- $userInfo['city_text'] = $userInfoA['city_text'];
- $userInfo['friends_num'] = $userInfoA['friends_num'];
- $userInfo['look_num'] = $userInfoA['look_num'];
- // 获取技能信息
- $skillList = Model("ViewUserSkill")->getSkillInfo($user_id);
- $userInfo["skill"] = implode("/",$skillList);
- // 获取关注粉丝信息
- $followModel = new \app\common\model\ViewFollows();
- $fansModel = new \app\common\model\ViewFans();
- // 获取关注信息
- $where = [];
- $where["user_id"] = $user_id;
- $userCount = $followModel->where($where)->value("follows"); //该用户关注了几个人
- $userInfo["follows_count"] = $userCount?$userCount:0;
- $userInfo["follows"] = $userInfo["follows_count"];//前端字段使用不一致添加
- // 获取粉丝数
- $where = [];
- $where["user_id"] = $user_id;
- $fansCount = $fansModel->where($where)->value("fans"); //该用户的粉丝数
- $userInfo["fans_count"] = $fansCount?$fansCount:0;
- $userInfo["fans"] = $userInfo["fans_count"];//前端字段使用不一致添加
- // 获取贵族信息
- $nobleInfo = $this->userModel->getUserNobleInfo($user_id);
- // 查看者是否已关注
- $followid = \app\common\model\UserFansFollow::where(["fans_id"=>$this->auth->id,"user_id"=>$user_id])->value("id");
- $userInfo["is_follow"] = $followid>0?1:0;
- $userInfo = json_decode(json_encode($userInfo),true);
- $userInfo = array_merge($userInfo,$nobleInfo);
- // 获取用户在派对直播间情况信息
- $redis = new Redis();
- $redisconfig = config("redis");
- $redis->connect($redisconfig["host"], $redisconfig["port"]);
- if ($redisconfig['redis_pwd']) {
- $redis->auth($redisconfig['redis_pwd']);
- }
- if($redisconfig['redis_selectdb'] > 0){
- $redis->select($redisconfig['redis_selectdb']);
- }
- $livingUserPartyId = $redis->hGet("livingUser", $user_id);
- $userInfo['party_info'] = json([]);
- if ($livingUserPartyId) {
- $party = \app\common\model\Party::where('id',$livingUserPartyId)->field('id,room_type')->find();
- $userInfo['party_info'] = ['party_id' => $party['id'], 'room_type' => $party['room_type']];
- }
- $blackWhere['user_id'] = $this->auth->id;
- $blackList = model('UserBlacklist')->where($blackWhere)->select();
- $blackIds = !empty($blackList) ? array_column($blackList,'black_user_id') : [];
- $userInfo['is_black'] = in_array($user_id,$blackIds) ? 1 : 0;
- $memberinfo = Db::name('guild_member')->alias('m')->field('m.id as `member_id`,m.user_id,guild.name,guild.image,guild.member,guild.desc')->join('guild','m.guild_id = guild.id','LEFT')->where(['m.user_id'=>$user_id,'m.status'=>1])->find();
- if ($memberinfo) {
- $userInfo['memberinfo'] = $memberinfo;
- }
- //家族信息
- $guildField = 'g.id,g.g_id,g.user_id,g.party_id,g.name,g.image,g.desc,g.member,g.status';
- $guildWhere['gm.user_id'] = $user_id;
- $guildWhere['g.status'] = 1;
- $guildInfo = model('Guild')->alias('g')->field($guildField)
- ->join('guild_member gm','gm.guild_id = g.id','LEFT')
- ->where($guildWhere)->order('id desc')->find();
- $userInfo['guild_info'] = !empty($guildInfo) ? $guildInfo : [];
- $guildStatus = -2;
- if (!empty($guildInfo)) {
- $guildStatus = (int)$guildInfo['status'];
- }
- $userInfo['guild_status'] = $guildStatus;//家族状态:公会状态:0=待审核,1=正常,-1=已解散,-2无公会
- //动态
- //技能
- //礼物
- if (empty($this->auth->power)) {
- $power = UserPower::where(['user_id'=>$user_id])->find();
- } else {
- $power = $this->auth->power;
- }
- $userInfo['user_power'] = $power;
- //访客记录
- if ($this->auth->id != $user_id) {
- $visit_data = [
- 'user_id' => $this->auth->id,
- 'visit_user_id' => $user_id,
- ];
- $visit_check = Db::name('user_visitlist')->where($visit_data)->find();
- if(empty($visit_check)){
- $visit_data['updatetime'] = time();
- Db::name('user_visitlist')->insertGetId($visit_data);
- }else{
- Db::name('user_visitlist')->where('id',$visit_check['id'])->update(['updatetime'=>time()]);
- }
- }
- //贡献等级
- $charm_info = Db::name('user_config_charm')->where('level',$userInfo['charm_level'])->find();
- $userInfo['charm_image'] = localpath_to_netpath($charm_info['image']);
- $userInfo['charm_color'] = $charm_info['color'];
- //财富等级
- $wealth_info = Db::name('user_config_wealth')->where('level',$userInfo['wealth_level'])->find();
- $userInfo['wealth_image'] = localpath_to_netpath($wealth_info['image']);
- $userInfo['wealth_color'] = $wealth_info['color'];
- $this->success("获取成功!",$userInfo);
- }
- /**
- * 添加关注
- */
- public function addFollows() {
- $user_id = $this->request->request("user_id",0,"intval");// 被关注者ID
- $type = $this->request->request("type",1);// 类型:1=关注,2=取消关注
- if (!$user_id || $user_id<=0) {
- $this->error(__('Invalid parameters'));
- }
- if($type == 1) {
- if($user_id == $this->auth->id) {
- $this->error("不需要关注自己哦!");
- }
- $fansfollowModel = new \app\common\model\UserFansFollow();
- $data = [];
- $data["user_id"] = $user_id;
- $data["fans_id"] = $this->auth->id;
- if($fansfollowModel->where($data)->find()) {
- $this->error("你已经关注过ta啦!");
- }
- $data["createtime"] = time();
- $id = $fansfollowModel->insertGetId($data);
- //关注通知
- $msgdata = [
- 'user_id'=>$user_id,
- 'title' => '有人刚刚关注了你',
- 'content'=> '打开[消息][最新关注]即可查看',
- 'createtime' => time(),
- ];
- Db::name('message')->insertGetId($msgdata);
- if($id > 0) {
- // 增加任务进度 +exp
- \app\common\model\TaskLog::tofinish($this->auth->id,"ebxLwnXj3L",1);
- // 增加任务进度 +exp
- \app\common\model\TaskLog::tofinish($this->auth->id,"iA1QgRhL",1);
- // 增加任务进度 +exp
- \app\common\model\TaskLog::tofinish($this->auth->id,"ghopE4Ou",1);
- // 增加任务进度 +exp
- \app\common\model\TaskLog::tofinish($this->auth->id,"TryNGc1x",1);
- $this->success("关注成功!");
- } else {
- $this->error("网络错误,请稍后重试!");
- }
- } else {
- $fansfollowModel = new \app\common\model\UserFansFollow();
- $where = [];
- $where["user_id"] = $user_id;
- $where["fans_id"] = $this->auth->id;
- $fansfollowInfo = $fansfollowModel->where($where)->find();
- if(!$fansfollowInfo) {
- $this->error("关注信息获取失败!");
- }
- $res = $fansfollowModel->where($where)->delete();
- if($res > 0) {
- $this->success("取消成功!");
- } else {
- $this->error("网络错误,请稍后重试!");
- }
- }
- }
- /**
- * 是否关注
- */
- public function isFollows() {
- $user_id = $this->request->request("user_id",0,"intval");// 关注者ID
- if (!$user_id || $user_id<=0) {
- $this->error(__('Invalid parameters'));
- }
- $fansfollowModel = new \app\common\model\UserFansFollow();
- $where = [];
- $where["user_id"] = $user_id;
- $where["fans_id"] = $this->auth->id;
- $fansfollowInfo = $fansfollowModel->where($where)->find();
- $data = [];
- if($fansfollowInfo) {
- $data["is_show_follow"] = 0;
- } else {
- $data["is_show_follow"] = 1;
- }
- $this->success("获取成功!",$data);
- }
- /**
- * 获取关注人列表.派对信息
- */
- public function getFollowsLive() {
- $is_online = $this->request->request("is_online");// 是否在线:1=直播中,0=未开播
- $page = $this->request->request('page',1); // 分页
- $pageNum = $this->request->request('pageNum',10); // 分页
- // 分页搜索构建
- $pageStart = ($page-1)*$pageNum;
- $is_online == 1 || $is_online = 0;
- $fanfollowModel = new \app\common\model\UserFansFollow();
- $where = [];
- $where["a.fans_id"] = $this->auth->id;
- $where["p.room_type"] = 2;
- $where["p.is_online"] = $is_online;
- if($is_online == 1) {
- $field = "p.id as party_id,u.u_id,u.nickname,p.party_name,p.party_hot,p.party_logo,u.avatar,t.id as party_type";
- } else {
- $field = "p.id as party_id,a.user_id,u.avatar,u.gender,u.level,u.nickname,p.party_name,p.party_logo,t.id as party_type";
- }
- $list = $fanfollowModel->alias("a")
- ->field($field)
- ->join("hx_user u","u.id = a.user_id")
- ->join("hx_party p","p.user_id = a.user_id")
- ->join("hx_party_type t","t.id = p.party_type","left")
- ->limit($pageStart,$pageNum)
- ->where($where)->select();
- if($list) {
- foreach($list as $k => $v) {
- $mod = isset($v["party_type"])?intval($v["party_type"])%5:1;
- if(isset($v["type_name"]) && $v["type_name"]) {
- $type_name = $v["type_name"];
- } else {
- $type_name = "普通房";
- }
- $list[$k]["party_type"] = $type_name;
- $list[$k]["party_type_color"] = $mod == 0?5:$mod;
- }
- $this->success("获取成功!",$list);
- } else {
- $this->success("数据为空!",[]);
- }
- }
- /**
- * 获取关注列表
- * (个人中心模块)(消息-最新关注)
- */
- public function getFollowsUser() {
- $type = $this->request->request('type',1); // 1=关注,2=粉丝,3=好友
- $page = $this->request->request('page',1); // 分页
- $pageNum = $this->request->request('pageNum',10); // 分页
- // 分页搜索构建
- $pageStart = ($page-1)*$pageNum;
- $pageEnd = $pageStart + $pageNum;
- $fanfollowModel = new \app\common\model\UserFansFollow();
- // 获取关注列表
- $where = [];
- $where["a.fans_id"] = $this->auth->id;
- $followlist = $fanfollowModel->alias("a")
- ->field("a.id,a.user_id,a.createtime,u.avatar,u.nickname,u.level,u.gender,u.desc")
- ->join("hx_user u","u.id = a.user_id")
- // ->limit($pageStart,$pageNum)
- ->where($where)->order('a.id desc')->select();
- $followlist = list_domain_image($followlist,['avatar']);
- // 获取粉丝列表
- $where = [];
- $where["a.user_id"] = $this->auth->id;
- $fanslist = $fanfollowModel->alias("a")
- ->field("a.id,a.fans_id,a.createtime,u.avatar,u.nickname,u.level,u.gender,u.desc")
- ->join("hx_user u","u.id = a.fans_id")
- // ->limit($pageStart,$pageNum)
- ->where($where)->order('a.id desc')->select();
- $fanslist = list_domain_image($fanslist,['avatar']);
- // print_r(json_encode($followlist));exit;
- if($type == 1) {
- $ids = [];
- if($fanslist) {
- foreach($fanslist as $k => $v) {
- $ids[] = $v["fans_id"];
- }
- }
- if($followlist) {
- foreach($followlist as $k => $v) {
- $followlist[$k]['createtime_text'] = get_last_time($v['createtime']);
- $followlist[$k]["is_follow"] = 1;
- if(in_array($v["user_id"],$ids)) {
- $followlist[$k]["is_hu"] = 1;
- } else {
- $followlist[$k]["is_hu"] = 0;
- }
- }
- }
- $fansfollow = $followlist;
- } elseif($type == 2) {
- $ids = [];
- if($followlist) {
- foreach($followlist as $k => $v) {
- $ids[] = $v["user_id"];
- }
- }
- if($fanslist) {
- foreach($fanslist as $k => $v) {
- $fanslist[$k]['createtime_text'] = get_last_time($v['createtime']);
- if(in_array($v["fans_id"],$ids)) {
- $fanslist[$k]["is_hu"] = 1;
- $fanslist[$k]["is_follow"] = 1;
- } else {
- $fanslist[$k]["is_hu"] = 0;
- }
- }
- }
- $fansfollow = $fanslist;
- }else {
- $ids = [];
- if($followlist) {
- foreach($followlist as $k => $v) {
- $ids[] = $v["user_id"];
- }
- }
- if($fanslist) {
- foreach($fanslist as $k => $v) {
- $fanslist[$k]['createtime_text'] = get_last_time($v['createtime']);
- $fanslist[$k]["is_follow"] = 1;
- if(in_array($v["fans_id"],$ids)) {
- $fanslist[$k]["is_hu"] = 1;
- } else {
- unset($fanslist[$k]); //不是好友的 直接unset掉
- }
- }
- }
- $fansfollow = $fanslist;
- }
- if($fansfollow) {
- $data = [];
- foreach($fansfollow as $k => $v) {
- if($k >= $pageStart && $k < $pageEnd) {
- $data[] = $v;
- }
- }
- $this->success("获取成功!",$data);
- } else {
- $this->success("数据为空!",[]);
- }
- }
- /**
- * 获取最近访客
- * (消息)
- */
- public function getMyVisitList(){
- $list = Db::name('user_visitlist')->alias('uv')
- ->field('uv.user_id,uv.updatetime,user.id,user.nickname,user.avatar,user.gender,user.desc')
- ->join('user','uv.user_id = user.id','LEFT')
- ->where('uv.visit_user_id',$this->auth->id) //被访问者
- ->order('uv.id desc')->autopage()->select();
- $list = list_domain_image($list,['avatar']);
- if(!empty($list)){
- foreach($list as $key => &$val){
- //关注
- $val['is_follow'] = $this->is_follow($val['user_id'],$this->auth->id);
- }
- }
- $this->success(1,$list);
- }
- /**
- * 获取附近的人
- * (消息-同城)
- */
- public function getSamecityList(){
- if(!$this->auth->city_id){
- $this->success(1,[]);
- }
- $where = [
- 'status' => 'normal',
- 'city_id'=> $this->auth->city_id,
- ];
- //排除黑名单的
- $black_ids = Db::name('user_blacklist')->where('user_id',$this->auth->id)->column('black_user_id');
- if(!empty($black_ids)){
- $where['id'] = ['NOTIN',$black_ids];
- }
- $list = Db::name('user')->where($where)->where('id','neq',$this->auth->id)->field('id,nickname,avatar,gender,desc')->order('id desc')->autopage()->select();
- $list = list_domain_image($list,['avatar']);
- if(!empty($list)){
- foreach($list as $key => &$val){
- //关注
- $val['is_follow'] = $this->is_follow($val['id'],$this->auth->id);
- }
- }
- $this->success(1,$list);
- }
- //是否关注
- private function is_follow($user_id,$fans_id){
- $where = [
- 'user_id' => $user_id,
- 'fans_id' => $fans_id,
- ];
- $check = Db::name('user_fans_follow')->where($where)->find();
- if($check){
- return 1;
- }else{
- return 0;
- }
- }
- /**
- * 获取个人技能列表
- */
- public function getMySkillList() {
- $user_id = $this->request->request('user_id',0); // 用户ID
- $page = $this->request->request('page',1); // 分页
- $pageNum = $this->request->request('pageNum',10); // 分页
- if ($user_id == -1) {
- $user_id = $this->auth->id;
- } elseif($user_id>0) {
- $user_id = intval($user_id);
- } else {
- $this->error(__('Invalid parameters'));
- }
- // 分页搜索构建
- $pageStart = ($page-1)*$pageNum;
- $authModel = new \app\common\model\DispatchAuth();
- $where = [];
- $where["a.user_id"] = $user_id;
- $where["a.status"] = 1;
- $authskillList = $authModel->alias("a")
- ->field("a.id,ds.image,ds.name,a.voice,a.voice_time,a.price,a.is_main,ds.unit")
- ->join("hx_dispatch_skill ds","ds.id = a.skill_id")
- ->where($where)
- ->limit($pageStart,$pageNum)
- ->select();
- $this->success("获取成功!",$authskillList);
- }
- /**
- * 删除个人技能信息
- */
- public function delMySkillInfo() {
- $id = $this->request->request('id'); // 认证ID
- if (!$id) {
- $this->error(__('Invalid parameters'));
- }
- $authModel = new \app\common\model\DispatchAuth();
- $where = [];
- $where["id"] = $id;
- $where["user_id"] = $this->auth->id;
- $authInfo = $authModel->where($where)->find();
- if(!$authInfo) $this->error("技能认证未找到");
- // if($authInfo->is_main == 1) $this->error("请先取消主技能,再删除!");
- Db::startTrans();
- try{
- $res1 = $authInfo->delete();
- $res2 = \app\common\model\UserSkill::where(["user_id"=>$this->auth->id,"skill_id"=>$authInfo->skill_id])->delete();
- if($res1 && $res2) {
- Db::commit();
- $this->success("删除成功!");
- } else {
- $this->error("网络错误,请稍后重试!");
- }
- }catch (ValidateException $e) {
- Db::rollback();
- $this->error($e->getMessage());
- } catch (PDOException $e) {
- Db::rollback();
- $this->error($e->getMessage());
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- }
- /**
- * 修改个人技能信息
- */
- public function editMySkillInfo() {
- $price = $this->request->request('price'); // 价格
- $id = $this->request->request('id'); // 认证ID
- $is_main = $this->request->request('is_main'); // 是否设置为主技能
- if (!$id && !$price) {
- $this->error(__('Invalid parameters'));
- }
- $authModel = new \app\common\model\DispatchAuth();
- $where = [];
- $where["id"] = $id;
- if(!$authModel->where($where)->find()) $this->error("技能认证未找到");
- Db::startTrans();
- try{
- if($is_main == 1) {
- $where = [];
- $where["user_id"] = $this->auth->id;
- $authModel->update(["is_main"=>0],$where);
- }
- $where = [];
- $where["id"] = $id;
- $data = [];
- $data["price"] = $price;
- $data["is_main"] = $is_main;
- $res = $authModel->update($data,$where);
- $myAuthList = $authModel->where(["user_id"=>$this->auth->id,"is_main"=>1])->find();
- if(!$myAuthList) {
- $this->error("必须至少设置一个主技能");
- Db::rollback();
- }
- if($res) {
- Db::commit();
- $this->success("修改成功!",$data);
- } else {
- $this->error("网络错误,请稍后重试!");
- }
- }catch (ValidateException $e) {
- Db::rollback();
- $this->error($e->getMessage());
- } catch (PDOException $e) {
- Db::rollback();
- $this->error($e->getMessage());
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- }
- /**
- * 编辑个人信息(完善资料)
- */
- public function editUserInfo() {
- $avatar = $this->request->request('avatar'); // 头像
- $nickname = $this->request->request('nickname'); // 昵称
- $age = $this->request->request('age'); // 年龄
- $ageId = $this->request->request('age_id'); // 年龄段
- $gender = $this->request->request('gender'); // 性别 0=女,1=男
- $image = $this->request->request('image'); // 个人形象照
- $constellationId = $this->request->request('star_id'); //星座ID
- $provinceId = $this->request->request('province_id'); //省ID
- $cityId = $this->request->request('city_id'); //城市ID
- $desc = $this->request->request('desc'); //个性签名
- /*if (!$avatar && !$nickname && !$age && !$image && !in_array($gender,[0,1])) {
- $this->error(__('请输入要修改的信息'));
- }*/
- $where = [];
- $where["id"] = $this->auth->id;
- $data = [];
- $avatar && $data["avatar"] = $avatar;
- if($nickname){
- if (mb_strlen($nickname) > 30) {
- $this->error('用户昵称最多支持30个汉字或组合');
- }
- $data["nickname"] = $nickname;
- }
- $gender && $data["gender"] = $gender;
- $age && $data["age"] = $age;
- $image && $data["image"] = $image;
- $ageId && $data['age_id'] = $ageId;
- $constellationId && $data['constellation_id'] = $constellationId;
- $provinceId && $data['province_id'] = $provinceId;
- $cityId && $data['city_id'] = $cityId;
- $desc && $data['desc'] = $desc;
- $res = $this->userModel->update($data,$where);
- if($res) {
- $user = $this->userModel->where($where)->find();
- if (!empty($user['nickname']) && !empty($user['avatar']) && !empty($user['age_id']) && $user['has_info']==0) {
- $data['has_info'] = 1;
- $this->userModel->update($data,$where);
- }
- $this->success("修改成功!");
- } else {
- $this->error("网络错误,请稍后重试!");
- }
- }
- /**
- * 编辑个人信息(修改昵称和头像需要后台审核)
- */
- public function editUser() {
- $avatar = $this->request->request('avatar'); // 头像
- $nickname = $this->request->request('nickname'); // 昵称
- if (!$avatar && !$nickname) {
- $this->error(__('请输入要修改的信息'));
- }
- $data = [];
- if ($avatar && $avatar != $this->auth->avatar) {
- $data["pre_avatar"] = $avatar;
- }
- if($nickname && $nickname != $this->auth->nickname){
- if (mb_strlen($nickname) > 8) {
- $this->error('用户昵称最多支持8个汉字或组合');
- }
- $data["pre_nickname"] = $nickname;
- }
- if (!empty($data)) {
- $data['need_check'] = 1;
- $where["id"] = $this->auth->id;
- $res = $this->userModel->update($data,$where);
- if(!$res) {
- $this->error("网络错误,请稍后重试!");
- }
- }
- $this->success("修改成功!");
- }
- /**
- * 主播申请
- */
- public function anchorApply() {
- $type_id = $this->request->request('type_id',0); // 技能分类ID
- $party_type_id = $this->request->request('party_type_id'); //分类ID
- $desc = $this->request->request('desc'); // 申请备注
- if (!$party_type_id && !$desc) {
- $this->error(__('Invalid parameters'));
- }
- $useranchorModel = new \app\common\model\UserAnchor();
- $data = [];
- $data["user_id"] = $this->auth->id;
- $data["type_id"] = $type_id;
- $data["party_type_id"] = $party_type_id;
- if($useranchorModel->where($data)->find()) $this->error(__('您已申请过该类型的主播,请勿重复申请!'));
- $data["desc"] = $desc;
- $data["createtime"] = time();
- $res = $useranchorModel->insertGetId($data);
- if($res) {
- \app\common\model\User::update(["is_anchor"=>1],["id"=>$this->auth->id]);
- $vbot = new \addons\vbot\Vbot();
- $vbot->vbotSendMsg('Anchor_Application_Notice', [], []);
- $this->success("申请发送成功!");
- } else {
- $this->error("网络错误,请稍后重试");
- }
- }
- /**
- * 实名认证
- */
- public function authApply() {
- $realname = $this->request->request('realname'); // 真实姓名
- $idcard = $this->request->request('idcard'); // 身份证号
- $zimage = $this->request->request('zimage'); // 身份证正面照
- $fimage = $this->request->request('fimage'); // 身份证反面照
- if (!$realname && !$idcard && !$zimage && !$fimage) {
- $this->error(__('Invalid parameters'));
- }
- $userauthModel = new \app\common\model\UserAuth();
- $data = [];
- $data["user_id"] = $this->auth->id;
- //$data["idcard"] = $idcard;
- $userAuth = $userauthModel->where($data)->find();
- if (!empty($userAuth)) {
- if(in_array($userAuth['status'],[0,1])) $this->error('您已经申请过了,请勿重复操作!');
- }
-
- // 测试需要 开始
- $data["realname"] = $realname;
- $zimage && $data["zimage"] = $zimage;
- $fimage && $data["fimage"] = $fimage;
- $data["status"] = 1;
- if (!empty($userAuth)) {
- $data["updatetime"] = time();
- $authWhere['user_id'] = $this->auth->id;
- $res = $userauthModel->where($authWhere)->update($data);
- } else {
- $data["createtime"] = time();
- $res = $userauthModel->insertGetId($data);
- }
- if($res) {
- \app\common\model\User::update(["is_auth"=>2],["id"=>$this->auth->id]);
- $this->success("恭喜,实名认证成功!");
- } else {
- $this->error("网络错误,请稍后重试");
- }
- // 测试需要 结束
- // 实名认证验证
- $configInfo = config("auth");
- $outh = new outh($configInfo["api_url"],$configInfo["customer_code"],$configInfo["private_key"],$configInfo["key"]);
- $out_trade_no = date("YmdHis").rand(1000,9999);
- $ret = $outh->toVerify($out_trade_no,$realname,$idcard);
- if(isset($ret["code"])) {
- if($ret["code"] == "1008") {
- $this->error(__('身份证格式错误'));
- }
- if($ret["code"] == "1009") {
- $this->error(__('身份证格式错误'));
- }
- if($ret["code"] == "0001") {
- $this->error(__('姓名和身份证号不匹配!'));
- }
- if($ret["code"] == "0000") {
- $data["realname"] = $realname;
- $zimage && $data["zimage"] = $zimage;
- $fimage && $data["fimage"] = $fimage;
- $data["status"] = 1;
- $data["createtime"] = time();
- $res = $userauthModel->insertGetId($data);
- if($res) {
- \app\common\model\User::update(["is_auth"=>2],["id"=>$this->auth->id]);
- $this->success("恭喜,实名认证成功!");
- } else {
- $this->error("网络错误,请稍后重试");
- }
- }
- } else {
- $this->error("网络错误,请稍后重试");
- }
- }
- /**
- * 获取主播分类
- */
- public function getAnchorType() {
- $this->success("获取成功!",\app\common\model\UserAnchorType::select());
- }
- /**
- * 加入黑名单
- */
- public function addBlacklist() {
- Db::startTrans();
- try {
- $black_user_id = $this->request->request('black_user_id'); // 黑名单用户ID
- if (!$black_user_id) {
- throw new Exception(__('Invalid parameters'));
- }
- $userblacklistModel = new \app\common\model\UserBlacklist();
- $data = [];
- $data["user_id"] = $this->auth->id;
- $data["black_user_id"] = $black_user_id;
- if($userblacklistModel->where($data)->find()) $this->error(__('已在黑名单!'));
- $data["createtime"] = time();
- $res = $userblacklistModel->insertGetId($data);
- if(!$res) {
- throw new Exception("网络错误,请稍后重试");
- }
- //im加入黑名单
- $tenimService = new TenimService();
- $params = [
- 'user_id' => $this->auth->id,
- 'black_user_ids' => [(string)$black_user_id],
- ];
- $imResult = $tenimService->addBlack($params);
- if (!$imResult['status']) {
- throw new Exception($imResult['msg']);
- }
- Db::commit();
- $this->success("加入成功!");
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- }
- /**
- * 获取黑名单用户
- */
- public function getBlacklist() {
- $page = $this->request->request('page',1); // 分页
- $pageNum = $this->request->request('pageNum',10); // 分页
- // 分页搜索构建
- $pageStart = ($page-1)*$pageNum;
- $userblacklistModel = new \app\common\model\UserBlacklist();// ->limit($pageStart,$pageNum)
- $where = [];
- $where["a.user_id"] = $this->auth->id;
- $list = $userblacklistModel->alias("a")
- ->field("a.id,a.black_user_id,u.avatar,u.nickname,u.level,u.gender")
- ->join("hx_user u","u.id = a.black_user_id")
- ->where($where)
- ->limit($pageStart,$pageNum)
- ->select();
- if($list) {
- $this->success("获取成功!",$list);
- } else {
- $this->success("数据为空",[]);
- }
- }
- /**
- * 移除用户黑名单
- */
- public function removeUserBlack() {
- Db::startTrans();
- try {
- $id = $this->request->request('id'); // 黑名单ID
- $userId = $this->request->request('user_id'); // 用户ID
- if (!$id && !$userId) {
- throw new Exception(__('Invalid parameters'));
- }
- $userblacklistModel = new \app\common\model\UserBlacklist();
- $where = [];
- $id && $where["id"] = $id;
- if ($userId) {
- $where['user_id'] = $this->auth->id;
- $where['black_user_id'] = $userId;
- }
- $userBlack = $userblacklistModel->where($where)->find();
- if (empty($userBlack)) {
- throw new Exception('未找到黑名单信息');
- }
- $blackUserId = isset($userBlack['black_user_id']) ? $userBlack['black_user_id'] : 0;
- $res = false;
- if (!empty($userBlack)) {
- $res = $userblacklistModel->where($where)->delete();
- }
- if(!$res) {
- $this->error("网络错误,请稍后重试!");
- }
- //im加入黑名单
- if (!empty($blackUserId)) {
- $tenimService = new TenimService();
- $params = [
- 'user_id' => $this->auth->id,
- 'black_user_ids' => [(string)$blackUserId],
- ];
- $imResult = $tenimService->delBlack($params);
- if (!$imResult['status']) {
- throw new Exception($imResult['msg']);
- }
- }
- Db::commit();
- $this->success("移除成功!",$res);
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- }
- /**
- * 举报用户
- */
- /*public function addReport() {
- $ruser_id = $this->request->request('ruser_id'); // 被举报用户ID
- $content = $this->request->request('content'); // 举报内容
- $image = $this->request->request('image'); // 图片描述(多个用半角逗号隔开)
- if (!$ruser_id) {
- $this->error(__('Invalid parameters'));
- }
- $userreportModel = new \app\common\model\UserReport();
- $data = [];
- $data["user_id"] = $this->auth->id;
- $data["reportable_id"] = $ruser_id;
- $data['reportable_type'] = $this->getModelName('user');
- $data["content"] = $content;
- $data["image"] = $image;
- $data["createtime"] = time();
- $res = $userreportModel->insertGetId($data);
- if($res) {
- $this->success("举报成功!");
- } else {
- $this->error("网络错误,请稍后重试");
- }
- }*/
- /**
- * 举报
- */
- /*public function addReportNew() {
- $params = $this->request->param();
- $validate = new Report();
- $result = $validate->check($params);
- if (!$result) {
- $this->error($validate->getError());
- }
- $userreportModel = new \app\common\model\UserReport();
- $data = [];
- $data["user_id"] = $this->auth->id;
- $data["reportable_id"] = $params['reportable_id'];
- $data['reportable_type'] = $this->getModelName($params['reportable_type']);
- $data["content"] = $params['content'];
- $data["image"] = $params['image'];
- $data["createtime"] = time();
- $res = $userreportModel->insertGetId($data);
- if($res) {
- $this->success("举报成功!");
- } else {
- $this->error("网络错误,请稍后重试");
- }
- }*/
- /**
- * redis 数据恢复---非redis数据丢失请勿使用!!!!
- */
- public function shujuhuifu() {
- $key = $this->request->request("key");// 操作验证 123456
- if($key != 123456) {
- $this->error(__('Invalid parameters'));
- }
- $giftuserpartyModel = new \app\common\model\GiftUserParty();
- $redis = new Redis();
- $redisconfig = config("redis");
- $redis->connect($redisconfig["host"], $redisconfig["port"]);
- if ($redisconfig['redis_pwd']) {
- $redis->auth($redisconfig['redis_pwd']);
- }
- if($redisconfig['redis_selectdb'] > 0){
- $redis->select($redisconfig['redis_selectdb']);
- }
- // 获取本周第一天
- $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
- // 获取本月第一天
- $monthday = date("Ym01");
- $where = [];
- $where["createtime"] = ["gt",strtotime($weekday)];
- $list1 = $giftuserpartyModel->where($where)->select();
- foreach($list1 as $k => $v) {
- // 添加redis记录做财富排行榜周榜用
- $redis->zIncrBy("jewel_get_".$v["party_id"].":".$weekday,$v["value"],$v["user_to_id"]);
- // 添加redis记录做贡献排行榜周榜用
- $redis->zIncrBy("jewel_to_".$v["party_id"].":".$weekday,$v["value"],$v["user_id"]);
- }
- $where = [];
- $where["createtime"] = ["gt",strtotime(date("Y-m-01"))];
- $list2 = $giftuserpartyModel->where($where)->select();
- foreach($list2 as $k => $v) {
- // 添加redis记录做财富排行榜月榜用
- $redis->zIncrBy("jewel_get_".$v["party_id"].":".$monthday,$v["value"],$v["user_to_id"]);
- // 添加redis记录做贡献排行榜月榜用
- $redis->zIncrBy("jewel_to_".$v["party_id"].":".$monthday,$v["value"],$v["user_id"]);
- }
- $this->success("执行成功!");
- }
- /**
- * 获取用户钻石余额
- */
- public function getUserJewel() {
- $data = \app\common\model\User::field("Jewel,money")->where(["id"=>$this->auth->id])->find();
- return $this->success("获取成功!",$data);
- }
- /**
- * 获取用户等级说明
- */
- public function getLevelExplain() {
- $data = \app\common\model\UserLevelExplain::field("title,content")->select();
- return $this->success("获取成功!",$data);
- }
- /**
- * 获取用户等级信息
- */
- public function getUserLevelInfo() {
- $res = [];$exstart = 0;$exend = 0;
- $userModel = new \app\common\model\User();
- $userInfo = $userModel->field("id,nickname,avatar,level,empirical")->where(["id"=>$this->auth->id])->find();
- if(!$userInfo) {
- $this->error("用户信息获取失败!");
- }
- $res["avatar"] = $userInfo['avatar'];
- $res["nickname"] = $userInfo['nickname'];
- // 获取用户当前经验值对应等级
- $userconfigModel = new \app\common\model\UserLevelConfig();
- $where = [];
- $where["empirical"] = ["elt",$userInfo["empirical"]];
- $userexplainstart = $userconfigModel->where($where)->order("empirical","desc")->limit(1)->select();
- $where = [];
- $where["empirical"] = ["gt",$userInfo["empirical"]];
- $userexplainend = $userconfigModel->where($where)->order("empirical","asc")->limit(1)->select();
- if(!$userexplainstart && !$userexplainend) {
- $this->error("经验等级信息获取失败!");
- } elseif(!$userexplainstart && $userexplainend) {
- $res["level_start"] = 0;
- $res["level_end"] = $userexplainend[0]["level"];
- } elseif($userexplainstart && !$userexplainend) {
- $res["level_start"] = $userexplainstart[0]["level"];
- $res["level_end"] = $userexplainstart[0]["level"];
- } elseif($userexplainstart && $userexplainend) {
- $res["level_start"] = $userexplainstart[0]["level"];
- $res["level_end"] = $userexplainend[0]["level"];
- }
- $userexplainstart && $exstart = $userexplainstart[0]["empirical"];
- $userexplainend && $exend = $userexplainend[0]["empirical"];
- $r1 = $exend-$exstart; // 等级经验值差
- $r2 = $userInfo["empirical"]-$exstart; // 当前等级与最低等级经验值差
- $r3 = $exend-$userInfo["empirical"]; // 还需多少经验值升级
- if($r1 == 0) {
- $res["level_rate"] = 1;
- } elseif($r2 == 0) {
- $res["level_rate"] = 0;
- if($res["level_start"] == $res["level_end"]) {
- $res["level_rate"] = 1;
- }
- } else {
- $res["level_rate"] = intval(($r2/$r1)*100)/100;
- }
- $res["to_up_need"] = $r3>0?$r3:0;
- // // 满级
- // if($r3 == 0 && !$userexplainend) {
- // $res["level_rate"] = 1;
- // }
- $this->success("获取成功!",$res);
- }
- /**
- * 邀请
- * @return void
- */
- public function addInvite()
- {
- try {
- $inviteNo = $this->request->param('invite_no','');
- $userId = $this->auth->id;
- if (empty($inviteNo)) {
- throw new Exception('参数错误');
- }
- $where['invite_no'] = $inviteNo;
- $userField = 'id,invite_no,pre_userid';
- $user = model('User')->field($userField)->where($where)->find();
- if (empty($user)) {
- throw new Exception('无效的邀请码');
- }
- //判断邀请码用户不能是自己的下级
- if ($user['pre_userid'] == $userId) {
- throw new Exception('对方已被您邀请过');
- }
- $userInviteWhere['invite_user_id'] = $userId;
- $userInvite = model('UserInvite')->where($userInviteWhere)->find();
- if (!empty($userInvite)) {
- throw new Exception('您已经被邀请过');
- }
- $userInviteData = [
- 'user_id' => $user['id'],
- 'invite_user_id' => $userId,
- 'createtime' => time(),
- ];
- $userInviteRes = model('UserInvite')->insertGetId($userInviteData);
- if (!$userInviteRes) {
- throw new Exception('邀请失败');
- }
- $userUpWhere['id'] = $userId;
- $userUpdate = ['pre_userid'=>$user['id']];
- $userUpdateRes = model('User')->where($userUpWhere)->update($userUpdate);
- if (!$userUpdateRes) {
- throw new Exception('更新邀请人失败');
- }
- $this->success('邀请成功');
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
-
- /**
- * 邀请详情
- * @return void
- */
- public function inviteInfo()
- {
- try {
- $userId = $this->auth->id;
- $field = 'id,invite_no';
- $where['id'] = $userId;
- $user = model('User')->field($field)->where($where)->find();
- $inviteNo = isset($user['invite_no']) ? $user['invite_no'] : '';
- $todayNow = day_now();
- $todayStart = $todayNow[0];
- $todayEnd = $todayNow[1]+1;
- $userMoneyLogWhere['user_id'] = $userId;
- $userMoneyLogWhere['type'] = 103;
- $appendWhere['createtime'] = [['egt', $todayStart],['lt', $todayEnd],'and'];
- $todayMoney = model('UserMoneyLog')->where($userMoneyLogWhere)->where($appendWhere)->sum('value');
- $totalMoney = model('UserMoneyLog')->where($userMoneyLogWhere)->sum('value');
- //本周
- $weekNow = week_now();
- $userInviteWhere['user_id'] = $userId;
- $userInviteAppendWhere['createtime'] = [['egt', $weekNow[0]],['lt', $weekNow[1]+1],'and'];
- $userInviteModel = model('UserInvite');
- $weekNowNum = $userInviteModel->where($userInviteWhere)->where($userInviteAppendWhere)->count();
- //上周
- $lastWeek = last_week();
- $appendLastWhere['createtime'] = [['egt', $lastWeek[0]],['lt', $lastWeek[1]+1],'and'];
- $lastWeekNum = $userInviteModel->where($userInviteWhere)->where($appendLastWhere)->count();
- //全部
- $totalNum = $userInviteModel->where($userInviteWhere)->count();
- $inviteMoney = config('site.invite_money');
- $inviteRule = config('site.invite_rule');
- $result = [
- 'invite_money' => (int)$inviteMoney,
- 'invite_no' => $inviteNo,//邀请码
- 'today_money' => $todayMoney,//今日收益
- 'total_money' => $totalMoney,//总收益
- 'week_now_num' => $weekNowNum,//本周邀请数
- 'last_week_num' => $lastWeekNum,//上周邀请数
- 'total_num' => $totalNum,//总邀请数
- 'invite_rule' => $inviteRule,//规则说明
- ];
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
- /**
- * 邀请列表
- * @return void
- */
- public function inviteList()
- {
- try {
- $userId = $this->auth->id;
- $where['user_id'] = $userId;
- $userInvite = model('UserInvite')->where($where)->with(['user'=>function($uQuery){
- $uQuery->field('id,avatar,u_id,nickname');
- }])->autopage()->order('createtime desc')->select();
- $result = [];
- if (!empty($userInvite)) {
- foreach ($userInvite as $key => $value) {
- $user = isset($value['user']) ? $value['user'] : [];
- $temp = [
- 'user_id' => isset($user['id']) ? $user['id'] : 0,
- 'u_id' => isset($user['u_id']) ? $user['u_id'] : 0,
- 'avatar' => isset($user['avatar']) ? $user['avatar'] : 0,
- 'nickname' => isset($user['nickname']) ? $user['nickname'] : 0,
- 'create_time_text' => !empty($value['createtime']) ? date('Y-m-d', $value['createtime']) : '',
- ];
- $result[] = $temp;
- }
- }
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
-
- /**
- * 钻石兑换记录
- * @return void
- */
- public function exchangeList()
- {
- try {
- $field = 'id,sound_coin,createtime';
- $where['user_id'] = $this->auth->id;
- $result = model('UserExchangeLog')->field($field)->where($where)->autopage()->order('createtime desc')->select();
- if (!empty($result)) {
- foreach ($result as $key => &$value) {
- $value['jewel'] = '+'.$value['sound_coin'];
- $value['createtime'] = !empty($value['createtime']) ? date('Y-m-d H:i',$value['createtime']) : '';
- unset($value['sound_coin']);
- }
- }
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
- /**
- * 钻石充值记录
- * @return void
- */
- public function rechargeList()
- {
- try {
- $field = 'id,detail,mode,value,createtime';
- $where['user_id'] = $this->auth->id;
- $result = model('UserJewelLog')->field($field)->where($where)->autopage()->order('createtime desc')->select();
- if (!empty($result)) {
- foreach ($result as $key => &$value) {
- $value['value'] = $value['mode'].$value['value'];
- $value['createtime'] = !empty($value['createtime']) ? date('Y-m-d H:i',$value['createtime']) : '';
- }
- }
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
- /**
- * 提现配置列表
- * @return void
- */
- public function withdrawalConfigList()
- {
- try {
- $field = 'id,money,real_money';
- $result = model('WithdrawalConfig')->field($field)->autopage()->order('weigh asc')->select();
- if (!empty($result)) {
- //设置是否使用自定义
- $withdrawDefine = config('site.withdraw_define');
- if ($withdrawDefine == 1) {
- $fieldArr = [[
- 'id' => -1,
- 'money' => 0,
- 'real_money' => 0.00,
- ],];
- $result = array_merge($result,$fieldArr);
- }
- }
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
- /**
- * 提现
- * @return void
- */
- public function withdrawal()
- {
- Db::startTrans();
- try {
- $withdrawConfigId = $this->request->param('id',0);
- $money = $this->request->param('money',0.00);
- $type = $this->request->param('type',0);
- $userId = $this->auth->id;
- $isAnchor = $this->auth->is_anchor;
- $userMoney = $this->auth->money;
- if (empty($withdrawConfigId) && empty($money)) {
- throw new Exception('参数错误');
- }
- //只有主播可以提现
- if ($isAnchor != 2) {
- throw new Exception('您不是主播不允许提现');
- }
- if ($this->auth->power->withdraw == 1) {
- throw new Exception('您已被禁止提现');
- }
- //验证提现类型
- $withdrawTypeConfig = config('wallet.withdraw_type');
- $typeIds = array_keys($withdrawTypeConfig);
- if (!in_array($type,$typeIds)) {
- throw new Exception('未知的提现类型');
- }
- $typeStr = isset($withdrawTypeConfig[$type]) ? $withdrawTypeConfig[$type] : '';
- $withdrawRateConfig = config('site.withdrawRate');//用户获取的金额比例(需要/100)
- $withdrawRate = bcdiv($withdrawRateConfig,100,2);
- if (!empty($money)) {//自定义金额
- if ($money <= 0) {
- throw new Exception('金额有误');
- }
- $inputMoney = $money;
- $moneys = bcmul($money,$withdrawRate,2);
- $platformMoney = bcsub($money,$moneys,2);
- } else {//提现配置
- $where['id'] = $withdrawConfigId;
- $withdrawalConfig = model('WithdrawalConfig')->where($where)->find();
- if (empty($withdrawalConfig)) {
- throw new Exception('未知的配置信息');
- }
- $inputMoney = $withdrawalConfig['money'];
- $moneys = $withdrawalConfig['money'];
- $platformMoney = bcsub($moneys,$withdrawalConfig['real_money'],2);;
- }
- if ($moneys <= 0) {
- throw new Exception('申请金额异常');
- }
- //扣减余额 记录余额日志
- $walletRes = model('wallet')->lockChangeAccountRemain($userId, $inputMoney, '-', $userMoney, '申请提现', 104,'money');
- if (!$walletRes['status']) {
- throw new Exception($walletRes['msg']);
- }
- $account = $name = '';
- if ($type == 1) {//微信
- $account = '';
- $name = '';
- } elseif ($type == 2) {//支付宝
- $userAlipayWhere['user_id'] = $userId;
- $userAlipay = model('UserAlipay')->where($userAlipayWhere)->find();
- if (empty($userAlipay)) {
- throw new Exception('请绑定支付宝');
- }
- $account = $userAlipay['pay_no'];
- $name = $userAlipay['realname'];
- } elseif ($type == 3) {//银行
- $userBankWhere['user_id'] = $userId;
- $userBank = model('UserBank')->where($userBankWhere)->find();
- if (empty($userBank)) {
- throw new Exception('请绑定银行卡');
- }
- $account = $userBank['bank_no'];
- $name = $userBank['realname'];
- }
- $realMoney = bcsub($inputMoney,$platformMoney,2);
- if ($realMoney < 0.1) {
- throw new Exception('输入金额请大于0.1');
- }
- $data = [
- 'user_id' => $userId,//用户ID
- 'money' => $inputMoney,//金额
- 'handingfee' => $platformMoney,//手续费
- 'real_money' => $realMoney,//金额
- 'taxes' => 0.00,//税费
- 'type' => $typeStr,//类型
- 'account' => $account,//提现账户
- 'name' => $name,//真实姓名
- //'memo' => '',//备注
- 'orderid' => getMillisecond() . mt_rand(1, 1000),//订单号
- //'transactionid' => '',//流水号
- 'status' => 'created',//状态:created=申请中,successed=成功,rejected=已拒绝
- //'transfertime' => '',//转账时间
- 'createtime' => time(),//添加时间
- ];
- $withdrawRes = model('Withdraw')->insertGetId($data);
- if (!$withdrawRes) {
- throw new Exception('提现失败');
- }
- Db::commit();
- $vbot = new \addons\vbot\Vbot();
- $vbot->vbotSendMsg('Withdrawal_Application_Notice', [], [
- 'name' => $name,
- 'account' => $account,
- 'real_money' => $realMoney,
- 'type' => $typeStr,
- 'handingfee' => $platformMoney
- ]);
- $this->success('操作成功待审核');
- } catch (Exception $e) {
- Db::rollback();
- $this->error($e->getMessage());
- }
- }
- /**
- * 提现列表
- * @return void
- */
- public function withdrawalList()
- {
- try {
- $field = 'id,money,type,status,createtime,transfertime';
- $where=[];
- $where['user_id'] = $this->auth->id;
- //$where['status'] = 'successed';//状态:created=申请中,successed=成功,rejected=已拒绝
- $result = model('Withdraw')->field($field)->where($where)->autopage()->order('createtime desc')->select();
- if (!empty($result)) {
- foreach ($result as $key => &$value) {
- $value['money'] = '-'.$value['money'];
- $value['createtime'] = !empty($value['createtime']) ? date('Y-m-d H:i', $value['createtime']) : '';
- $value['transfertime'] = !empty($value['transfertime']) ? date('Y-m-d H:i', $value['transfertime']) : '';
- }
- }
- $this->success('获取成功',$result);
- } catch (Exception $e) {
- $this->error($e->getMessage());
- }
- }
- }
|