161 lines
6.9 KiB
PHP
161 lines
6.9 KiB
PHP
<?php
|
||
/**
|
||
* tpshop
|
||
* ============================================================================
|
||
* 版权所有 2015-2027 深圳搜豹网络科技有限公司，并保留所有权利。
|
||
* 网站地址: http://www.tp-shop.cn
|
||
* ----------------------------------------------------------------------------
|
||
* 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
|
||
* 不允许对程序代码以任何形式任何目的的再发布。
|
||
* 采用TP5助手函数可实现单字母函数M D U等,也可db::name方式,可双向兼容
|
||
* ============================================================================
|
||
* Author: dyr
|
||
* Date: 2017-12-04
|
||
*/
|
||
|
||
namespace app\common\logic;
|
||
|
||
use app\common\model\Users;
|
||
use app\common\util\TpshopException;
|
||
use think\Model;
|
||
use think\Db;
|
||
|
||
/**
|
||
* 用户类
|
||
* Class CatsLogic
|
||
* @package Home\Logic
|
||
*/
|
||
class User
|
||
{
|
||
private $user;
|
||
public $coupon = [];
|
||
|
||
public function setUserById($user_id)
|
||
{
|
||
$this->user = Users::get($user_id);
|
||
}
|
||
|
||
public function setUserByMobile($mobile)
|
||
{
|
||
$this->user = Users::get(['mobile' => $mobile]);
|
||
}
|
||
public function setUser($user){
|
||
$this->user = $user;
|
||
}
|
||
/**
|
||
* 绑定账号
|
||
*/
|
||
public function checkOauthBind()
|
||
{
|
||
if (empty($this->user)) {
|
||
throw new TpshopException('关联账号', 0, ['status' => 0, 'msg' => '账号不存在']);
|
||
}
|
||
$thirdOauth = session('third_oauth');
|
||
$thirdName = ['weixin' => '微信', 'qq' => 'QQ', 'alipay' => '支付宝', 'miniapp' => '微信小程序'];
|
||
$openid = $thirdOauth['openid']; //第三方返回唯一标识
|
||
$unionid = $thirdOauth['unionid']; //第三方返回唯一标识
|
||
$oauth = $thirdOauth['oauth']; //来源
|
||
$oauthCN = $platform = $thirdName[$oauth];
|
||
if ((empty($unionid) && empty($oauth)) || empty($openid)) {
|
||
throw new TpshopException('关联账号', 0, ['status' => 0, 'msg' => '第三方平台参数有误[openid:' . $openid . ' , unionid:' . $unionid . ', oauth:' . $oauth . ']']);
|
||
}
|
||
//1.判断一个账号绑定多个QQ
|
||
//2.判断一个QQ绑定多个账号
|
||
if ($unionid) {
|
||
//此oauth是否已经绑定过其他账号
|
||
$thirdUser = Db::name('oauth_users')->where(['unionid' => $unionid, 'oauth' => $oauth])->find();
|
||
if ($thirdUser && $this->user['user_id'] != $thirdUser['user_id']) {
|
||
throw new TpshopException('关联账号', 0, ['status' => 0, 'msg' => '此' . $oauthCN . '已绑定其它账号', 'result' => ['unionid' => $unionid]]);
|
||
}
|
||
|
||
//1.2此账号是否已经绑定过其他oauth
|
||
$thirdUser = Db::name('oauth_users')->where(['user_id' => $this->user['user_id'], 'oauth' => $oauth])->find();
|
||
if ($thirdUser && $thirdUser['unionid'] != $unionid) {
|
||
throw new TpshopException('关联账号', 0, ['status' => 0, 'msg' => '此账号已绑定其它' . $oauthCN . '账号', 'result' => ['unionid' => $unionid]]);
|
||
}
|
||
} else {
|
||
//2.1此oauth是否已经绑定过其他账号
|
||
$thirdUser = Db::name('oauth_users')->where(['openid' => $openid, 'oauth' => $oauth])->find();
|
||
if ($thirdUser) {
|
||
throw new TpshopException('关联账号', 0, ['status' => 0, 'msg' => '此' . $oauthCN . '已绑定其它账号', 'result' => ['openid' => $openid]]);
|
||
}
|
||
//2.2此账号是否已经绑定过其他oauth
|
||
$thirdUser = Db::name('oauth_users')->where(['user_id' => $this->user['user_id'], 'oauth' => $oauth])->find();
|
||
if ($thirdUser) {
|
||
throw new TpshopException('关联账号', 0, ['此账号已绑定其它' . $oauthCN . '账号']);
|
||
}
|
||
}
|
||
}
|
||
|
||
public function oauthBind()
|
||
{
|
||
$thirdOauth = session('third_oauth');
|
||
Db::name('oauth_users')->save(['oauth' => $thirdOauth['oauth'], 'openid' => $thirdOauth['openid'], 'user_id' => $this->user['user_id'], 'unionid' => $thirdOauth['unionid'], 'oauth_child' => $thirdOauth['oauth_child']]);
|
||
$ruser['token'] = md5(time() . mt_rand(1, 999999999));
|
||
$ruser['last_login'] = time();
|
||
$this->user->token = md5(time() . mt_rand(1, 999999999));
|
||
$this->user->last_login = time();
|
||
$this->user->save();
|
||
$user_array = $this->user->toArray();
|
||
$oauth_users = Db::name('oauth_users')->where(['user_id' => $this->user['user_id'], 'oauth' => 'weixin', 'oauth_child' => 'mp'])->find();
|
||
if ($oauth_users) {
|
||
$user_array['open_id'] = $oauth_users['open_id'];
|
||
}
|
||
session('user', $user_array);
|
||
}
|
||
|
||
public function doLeader()
|
||
{
|
||
$first_leader = cookie('first_leader'); //推荐人id
|
||
if ($first_leader) {
|
||
$this->user->first_leader = $first_leader;
|
||
$this->user->save();
|
||
$firstLeaderUser = Users::get(['user_id' => $first_leader]);
|
||
if ($firstLeaderUser) {
|
||
//他上线分销的下线人数要加1
|
||
$firstLeaderUser->underling_number = $firstLeaderUser->underling_number + 1;
|
||
$firstLeaderUser->save();
|
||
Db::name('users')->where(['user_id' => $firstLeaderUser['second_leader']])->setInc('underling_number');
|
||
Db::name('users')->where(['user_id' => $firstLeaderUser['third_leader']])->setInc('underling_number');
|
||
}
|
||
} else {
|
||
if ($this->user->first_leader != 0) {
|
||
$this->user->first_leader = 0;
|
||
$this->user->save();
|
||
}
|
||
}
|
||
}
|
||
|
||
public function refreshCookie()
|
||
{
|
||
setcookie('user_id', $this->user['user_id'], null, '/');
|
||
setcookie('is_distribut', $this->user['is_distribut'], null, '/');
|
||
$nick_name = empty($this->user['nickname']) ? $this->user['mobile'] : $this->user['nickname'];
|
||
setcookie('uname', urlencode($nick_name), null, '/');
|
||
setcookie('head_pic', urlencode($this->user['head_pic']), null, '/');
|
||
setcookie('cn', 0, time() - 3600, '/');
|
||
}
|
||
|
||
/**
|
||
* 更新用户等级
|
||
* @throws \think\Exception
|
||
*/
|
||
function updateUserLevel()
|
||
{
|
||
$total_amount = Db::name('order')->master()->where(['user_id' => $this->user['user_id'], 'pay_status' => 1, 'order_status' => ['NOTIN', [3, 5]]])->sum('order_amount+user_money');
|
||
$level_info = Db::name('user_level')->where(['amount' => ['elt', $total_amount]])->order('amount desc')->find();
|
||
// 客户没添加用户等级，上报没有累计消费的bug
|
||
if($level_info){
|
||
$update['level'] = $level_info['level_id'];
|
||
$update['discount'] = $level_info['discount'] / 100;
|
||
}
|
||
$update['total_amount'] = $total_amount;//更新累计修复额度
|
||
Db::name('users')->where("user_id", $this->user['user_id'])->save($update);
|
||
}
|
||
|
||
public function getUser()
|
||
{
|
||
return $this->user;
|
||
}
|
||
|
||
} |