544 lines
20 KiB
PHP
544 lines
20 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | likeshop开源商城系统
|
||
// +----------------------------------------------------------------------
|
||
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
||
// | gitee下载：https://gitee.com/likeshop_gitee
|
||
// | github下载：https://github.com/likeshop-github
|
||
// | 访问官网：https://www.likeshop.cn
|
||
// | 访问社区：https://home.likeshop.cn
|
||
// | 访问手册：http://doc.likeshop.cn
|
||
// | 微信公众号：likeshop技术社区
|
||
// | likeshop系列产品在gitee、github等公开渠道开源版本可免费商用，未经许可不能去除前后端官方版权标识
|
||
// | likeshop系列产品收费版本务必购买商业授权，购买去版权授权后，方可去除前后端官方版权标识
|
||
// | 禁止对系统程序代码以任何目的，任何形式的再发布
|
||
// | likeshop团队版权所有并拥有最终解释权
|
||
// +----------------------------------------------------------------------
|
||
// | author: likeshop.cn.team
|
||
// +----------------------------------------------------------------------
|
||
namespace app\api\logic;
|
||
|
||
use app\api\model\User;
|
||
use app\common\logic\LogicBase;
|
||
use app\common\logic\NoticeLogic;
|
||
use app\common\model\AccountLog;
|
||
use app\common\model\AfterSale;
|
||
use app\common\model\Client_;
|
||
use app\common\model\DistributionOrder;
|
||
use app\common\model\Order;
|
||
use app\common\model\TeamFollow;
|
||
use app\common\model\UserAuth;
|
||
use app\common\server\ConfigServer;
|
||
use app\common\server\storage\Driver as StorageDriver;
|
||
use app\common\server\UrlServer;
|
||
use app\common\server\WeChatServer;
|
||
use EasyWeChat\Factory;
|
||
use EasyWeChat\Kernel\Exceptions\Exception;
|
||
use think\Db;
|
||
use app\common\logic\AccountLogLogic;
|
||
use think\facade\Cache;
|
||
|
||
class UserLogic extends LogicBase
|
||
{
|
||
public static function center($user_id)
|
||
{
|
||
$user = User::get($user_id);
|
||
//待支付
|
||
$user->wait_pay = Db::name('order')->where(['del' => 0, 'user_id' => $user_id, 'order_status' => Order::STATUS_WAIT_PAY, 'pay_status' => 0])->count();
|
||
//待发货
|
||
$user->wait_delivery = Db::name('order')->where(['del' => 0, 'user_id' => $user_id, 'order_status' => [Order::STATUS_WAIT_DELIVERY], 'pay_status' => 1])->count();
|
||
//待收货
|
||
$user->wait_take = Db::name('order')->where(['del' => 0, 'user_id' => $user_id, 'order_status' => [Order::STATUS_WAIT_RECEIVE], 'pay_status' => 1])->count();
|
||
//待评论
|
||
$user->wait_comment = Db::name('order o')
|
||
->join('order_goods og', 'o.id = og.order_id')
|
||
->where(['del' => 0, 'user_id' => $user_id, 'order_status' => Order::STATUS_FINISH, 'is_comment' => 0])
|
||
->count('og.id');
|
||
//售后中
|
||
$user->after_sale = Db::name('after_sale')
|
||
->where(['del' => 0, 'user_id' => $user_id])
|
||
->where('status', '<>', AfterSale::STATUS_SUCCESS_REFUND)
|
||
->count();
|
||
$user->coupon = Db::name('coupon_list')->where(['user_id' => $user_id, 'del' => 0, 'status' => 0])->count();
|
||
//分销开关
|
||
$user->distribution_setting = ConfigServer::get('distribution', 'is_open', 1);
|
||
//消息数量
|
||
$user->notice_num = NoticeLogic::unRead($user_id) ? 1 : 0;
|
||
//下个会员等级提示
|
||
$user_level = Db::name('user_level')
|
||
->where([
|
||
['growth_value', '>', $user->user_growth],
|
||
['del', '=', 0]
|
||
])->order('growth_value asc')
|
||
->find();
|
||
$user['next_level_tips'] = '';
|
||
if ($user_level) {
|
||
$diff_growth_value = intval($user_level['growth_value'] - $user['user_growth']);
|
||
$diff_growth_value > 0 && $user['next_level_tips'] = '距离升级还差' . $diff_growth_value;
|
||
}
|
||
// 是否设置支付密码
|
||
$user['hasPayPassword'] = $user['pay_password'] ? 1 : 0;
|
||
$user->visible(['id', 'nickname', 'sn', 'avatar', 'mobile', 'hasPayPassword', 'next_level_tips', 'user_money', 'total_order_amount', 'total_recharge_amount',
|
||
'coupon', 'user_integral', 'level', 'wait_pay', 'wait_take', 'wait_delivery',
|
||
'wait_comment', 'after_sale', 'distribution_setting', 'distribution_code', 'notice_num','is_new_user']);
|
||
|
||
return $user;
|
||
}
|
||
|
||
public static function accountLog($user_id, $source, $type, $page, $size)
|
||
{
|
||
$source_type = '';
|
||
$where[] = ['user_id', '=', $user_id];
|
||
switch ($source) {
|
||
case 1:
|
||
$source_type = AccountLog::money_change;
|
||
break;
|
||
case 2:
|
||
$source_type = AccountLog::integral_change;
|
||
break;
|
||
case 3:
|
||
$source_type = AccountLog::growth_change;
|
||
|
||
}
|
||
$where[] = ['source_type', 'in', $source_type];
|
||
if ($type) {
|
||
$where[] = ['change_type', '=', $type];
|
||
}
|
||
$accountLog = new AccountLog();
|
||
$count = $accountLog
|
||
->where($where)
|
||
->count();
|
||
$list = $accountLog
|
||
->where($where)
|
||
->page($page, $size)
|
||
->order('id desc')
|
||
->field('id,change_amount,source_type,change_type,create_time,remark')
|
||
->select();
|
||
$more = is_more($count, $page, $size); //是否有下一页
|
||
|
||
$data = [
|
||
'list' => $list,
|
||
'page_no' => $page,
|
||
'page_size' => $size,
|
||
'count' => $count,
|
||
'more' => $more
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
//获取用户信息
|
||
public static function getUserInfo($user_id)
|
||
{
|
||
$info = User::where(['id' => $user_id])
|
||
->field('id,sn,nickname,avatar,mobile,sex,create_time')
|
||
->find();
|
||
|
||
$info['create_time'] = date('Y-m-d H:i:s', $info['create_time']);
|
||
|
||
$info['oa_auth'] = UserAuth::where('user_id', $user_id)->where(Client_::oa)->value('id') ? 1: 0;
|
||
$info['mnp_auth'] = UserAuth::where('user_id', $user_id)->where(Client_::mnp)->value('id') ? 1: 0;
|
||
|
||
return $info;
|
||
}
|
||
|
||
//设置个人信息
|
||
public static function setUserInfo($user_id, $data)
|
||
{
|
||
$field = $data['field'];
|
||
$value = $data['value'];
|
||
$res = Db::name('user')
|
||
->where(['id' => $user_id])
|
||
->update([$field => $value]);
|
||
return $res;
|
||
}
|
||
|
||
|
||
//修改手机号
|
||
public static function changeMobile($user_id, $data)
|
||
{
|
||
$user = User::get($user_id);
|
||
$user->mobile = $data['new_mobile'];
|
||
$user->save();
|
||
return $user;
|
||
}
|
||
|
||
|
||
//获取微信手机号
|
||
public static function getMobileByMnp($post)
|
||
{
|
||
Db::startTrans();
|
||
try {
|
||
$config = WeChatServer::getMnpConfig();
|
||
$app = Factory::miniProgram($config);
|
||
$response = $app->auth->session($post['code']);
|
||
if (!isset($response['session_key'])) {
|
||
throw new Exception();
|
||
}
|
||
$response = $app->encryptor->decryptData($response['session_key'], $post['iv'], $post['encrypted_data']);
|
||
|
||
$isExist = User::where([
|
||
['mobile', '=', $response['phoneNumber']],
|
||
['id', '<>', $post['user_id']]
|
||
])->find();
|
||
|
||
if (!empty($isExist)) {
|
||
throw new Exception('手机号已被其他账号绑定');
|
||
}
|
||
|
||
User::where(['id' => $post['user_id']])->update(['mobile' => $response['phoneNumber']]);
|
||
Db::commit();
|
||
return self::dataSuccess('操作成功');
|
||
} catch (Exception $e) {
|
||
Db::rollback();
|
||
return self::dataError('失败:' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
|
||
//我的粉丝列表
|
||
public static function fans($user_id, $get, $page, $size)
|
||
{
|
||
$where = [];
|
||
if (isset($get['keyword']) && $get['keyword'] != '') {
|
||
$where[] = ['nickname|mobile', 'like', '%' . $get['keyword'] . '%'];
|
||
}
|
||
|
||
//查询条件
|
||
$type = $get['type'] ?? 'all';
|
||
switch ($type) {
|
||
case 'first':
|
||
$where[] = ['first_leader', '=', $user_id];
|
||
break;
|
||
case 'second':
|
||
$where[] = ['second_leader', '=', $user_id];
|
||
break;
|
||
default:
|
||
$where[] = ['first_leader|second_leader', '=', $user_id];
|
||
}
|
||
|
||
$field = 'u.id, avatar, nickname, mobile, u.create_time, order_num as fans_order,
|
||
order_amount as fans_money, fans as fans_team';
|
||
|
||
$count = Db::name('user u')
|
||
->field($field)
|
||
->leftJoin('user_distribution d', 'd.user_id = u.id')
|
||
->where($where)
|
||
->count();
|
||
|
||
$lists = Db::name('user u')
|
||
->field($field)
|
||
->leftJoin('user_distribution d', 'd.user_id = u.id')
|
||
->where($where)
|
||
->page($page, $size)
|
||
->order(self::fansListsSort($get))
|
||
->select();
|
||
|
||
foreach ($lists as &$item) {
|
||
$item['avatar'] = UrlServer::getFileUrl($item['avatar']);
|
||
$item['fans_team'] = $item['fans_team'] ?? 0;
|
||
$item['fans_order'] = $item['fans_order'] ?? 0;
|
||
$item['fans_money'] = $item['fans_money'] ?? 0;
|
||
$item['create_time'] = date('Y-m-d H:i:s', $item['create_time']);
|
||
unset($item['fans'], $item['distribution_order_num'], $item['distribution_money']);
|
||
}
|
||
|
||
$data = [
|
||
'list' => $lists,
|
||
'page' => $page,
|
||
'size' => $size,
|
||
'count' => $count,
|
||
'more' => is_more($count, $page, $size)
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
|
||
//粉丝列表排序
|
||
public static function fansListsSort($get)
|
||
{
|
||
if (isset($get['fans']) && $get['fans'] != '') {
|
||
return ['fans_team' => $get['fans'], 'u.id' => 'desc'];
|
||
}
|
||
|
||
if (isset($get['money']) && $get['money'] != '') {
|
||
return ['fans_money' => $get['money'], 'u.id' => 'desc'];
|
||
}
|
||
|
||
if (isset($get['order']) && $get['order'] != '') {
|
||
return ['fans_order' => $get['order'], 'u.id' => 'desc'];
|
||
}
|
||
|
||
return ['u.id' => 'desc'];
|
||
}
|
||
|
||
|
||
public static function myWallet($user_id)
|
||
{
|
||
$info = Db::name('user')
|
||
->where(['id' => $user_id])
|
||
->field('user_money,total_order_amount,total_recharge_amount,user_growth')
|
||
->find();
|
||
$info['open_racharge'] = ConfigServer::get('recharge', 'open_racharge', 0);
|
||
return $info;
|
||
|
||
|
||
}
|
||
|
||
public static function myTeam($user_id, $status, $page, $size)
|
||
{
|
||
$where = [
|
||
['follow_user_id', '=', (int)$user_id]
|
||
];
|
||
|
||
if ($status !== -1 and $status !== '-1') {
|
||
$where[] = ['f.status', '=', (int)$status];
|
||
}
|
||
|
||
$teamFollowModel = new TeamFollow();
|
||
$count = $teamFollowModel->where($where)->alias('f')->count();
|
||
$lists = $teamFollowModel->alias('f')
|
||
->field('g.name,g.image,gi.image as spec_image,gi.spec_value_str,gi.goods_id,og.goods_price,
|
||
o.total_amount,o.order_amount,o.total_num,o.pay_status,a.start_time,a.end_time,
|
||
tf.need,tf.found_time,tf.found_end_time,tf.team_end_time,f.follow_time,
|
||
f.id,f.order_id,f.type,f.status')
|
||
->where($where)
|
||
->order('id', 'desc')
|
||
->join('order o', 'o.id = f.order_id')
|
||
->join('order_goods og', 'og.order_id = o.id')
|
||
->join('goods g', 'g.id = og.goods_id')
|
||
->join('goods_item gi', 'gi.id = og.item_id')
|
||
->join('team_found tf', 'tf.id = f.found_id')
|
||
->join('team_activity a', 'a.team_id = f.team_id')
|
||
->page($page, $size)
|
||
->select();
|
||
|
||
$status_text = ['拼团中', '拼团成功', '拼团失败'];
|
||
foreach ($lists as &$item) {
|
||
$item['image'] = UrlServer::getFileUrl($item['image']);
|
||
$item['spec_image'] = $item['spec_image'] ? UrlServer::getFileUrl($item['spec_image']) : $item['image'];
|
||
$item['type_text'] = $item['type'] ? '团长' : '团员';
|
||
$item['status_text'] = $status_text[$item['status']];
|
||
$item['team_end_time'] = $item['team_end_time'] ? date('Y-m-d H:i:s', $item['team_end_time']) : '';
|
||
$item['follow_time'] = date('Y-m-d H:i:s', $item['follow_time']);
|
||
}
|
||
|
||
return [
|
||
'list' => $lists,
|
||
'page' => $page,
|
||
'size' => $size,
|
||
'count' => $count,
|
||
'more' => is_more($count, $page, $size)
|
||
];
|
||
}
|
||
|
||
|
||
//更新微信信息
|
||
public static function updateWechatInfo($user_id, $post)
|
||
{
|
||
Db::startTrans();
|
||
try {
|
||
$time = time();
|
||
$avatar_url = $post['avatar'];
|
||
$nickanme = $post['nickname'];
|
||
$sex = $post['sex'];
|
||
|
||
$config = [
|
||
'default' => ConfigServer::get('storage', 'default', 'local'),
|
||
'engine' => ConfigServer::get('storage_engine')
|
||
];
|
||
|
||
$avatar = ''; //头像路径
|
||
if ($config['default'] == 'local') {
|
||
$file_name = md5($user_id . $time . rand(10000, 99999)) . '.jpeg';
|
||
$avatar = download_file($avatar_url, 'uploads/user/avatar/', $file_name);
|
||
} else {
|
||
$avatar = 'uploads/user/avatar/' . md5($user_id . $time . rand(10000, 99999)) . '.jpeg';
|
||
$StorageDriver = new StorageDriver($config);
|
||
if (!$StorageDriver->fetch($avatar_url, $avatar)) {
|
||
throw new Exception('头像保存失败:' . $StorageDriver->getError());
|
||
}
|
||
}
|
||
|
||
$user = new User;
|
||
$user->save([
|
||
'nickname' => $nickanme,
|
||
'avatar' => $avatar,
|
||
'sex' => $sex
|
||
], ['id' => $user_id]);
|
||
|
||
Db::commit();
|
||
return true;
|
||
|
||
} catch (\Exception $e) {
|
||
Db::rollback();
|
||
return $e->getMessage();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 设置支付密码
|
||
*/
|
||
public static function setPassword($data)
|
||
{
|
||
return Db::name('user')->where('id', $data['user_id'])->update([
|
||
'pay_password' => $data['pay_password'],
|
||
'update_time' => time()
|
||
]);
|
||
}
|
||
|
||
/**
|
||
* 分销会员转账
|
||
*/
|
||
public static function transfer($data)
|
||
{
|
||
$lockKey = 'transfer_' . $data['user_id'];
|
||
if (Cache::get($lockKey)) {
|
||
self::$error = '操作频繁';
|
||
return false;
|
||
} else {
|
||
Cache::set($lockKey, $data['money'], 60);
|
||
}
|
||
|
||
Db::startTrans();
|
||
try {
|
||
$transferFrom = Db::name('user')->where('id', $data['user_id'])->find();
|
||
|
||
// 判断余额是否充足
|
||
if ($transferFrom['user_money'] < $data['money']) {
|
||
throw new \Exception('余额不足');
|
||
}
|
||
// 判断支付密码是否正确
|
||
if ($transferFrom['pay_password'] != md5(trim($data['pay_password']))) {
|
||
throw new \Exception('支付密码错误');
|
||
}
|
||
// 收款人是否存在
|
||
$transferTo = Db::name('user')->where('sn', $data['transferTo'])->find();
|
||
if (!$transferTo) {
|
||
$transferTo = Db::name('user')->where('mobile', $data['transferTo'])->find();
|
||
}
|
||
if (!$transferTo) {
|
||
throw new \Exception('收款用户不存在');
|
||
}
|
||
// 不能自己转账给自己
|
||
if ($transferFrom['id'] == $transferTo['id']) {
|
||
throw new \Exception('不能自己转账给自己');
|
||
}
|
||
|
||
// 生成转账记录
|
||
$transferId = Db::name('user_transfer')->insertGetId([
|
||
'transfer_sn' => createSn('user_transfer', 'transfer_sn'),
|
||
'transfer_from_id' => $transferFrom['id'],
|
||
'transfer_to_id' => $transferTo['id'],
|
||
'money' => $data['money'],
|
||
'create_time' => time()
|
||
]);
|
||
// 减 转账人 余额
|
||
Db::name('user')->where('id', $transferFrom['id'])->setDec('user_money', $data['money']);
|
||
// 记录 转账人 余额变动
|
||
AccountLogLogic::AccountRecord($transferFrom['id'], $data['money'], 2, AccountLog::user_transfer_dec_balance, '会员转账支出', $transferId);
|
||
// 加 收款人 余额
|
||
Db::name('user')->where('id', $transferTo['id'])->setInc('user_money', $data['money']);
|
||
// 记录 收款人 余额变动
|
||
AccountLogLogic::AccountRecord($transferTo['id'], $data['money'], 1, AccountLog::user_transfer_inc_balance, '会员转账收入', $transferId);
|
||
|
||
Db::commit();
|
||
|
||
return true;
|
||
} catch (\Exception $e) {
|
||
Db::rollback();
|
||
self::$error = $e->getMessage();
|
||
return false;
|
||
} finally {
|
||
Cache::rm($lockKey);
|
||
}
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* 转账记录
|
||
*/
|
||
public static function transferRecord($get)
|
||
{
|
||
switch ($get['type']) {
|
||
case 'all': // 全部(用户信息单独获取)
|
||
$list = Db::name('user_transfer')
|
||
->where('transfer_from_id', $get['user_id'])
|
||
->whereOr('transfer_to_id', $get['user_id'])
|
||
->page($get['page_no'], $get['page_size'])
|
||
->order('create_time', 'desc')
|
||
->select();
|
||
$count = Db::name('user_transfer')
|
||
->where('transfer_from_id', $get['user_id'])
|
||
->whereOr('transfer_to_id', $get['user_id'])
|
||
->count();
|
||
break;
|
||
case 'in': // 收入
|
||
$list = Db::name('user_transfer')->alias('ut')
|
||
->field('ut.*, u.nickname, u.avatar, u.sn')
|
||
->leftJoin('user u', 'ut.transfer_from_id = u.id') // 转账人信息
|
||
->where('ut.transfer_to_id', $get['user_id'])
|
||
->page($get['page_no'], $get['page_size'])
|
||
->order('ut.create_time', 'desc')
|
||
->select();
|
||
$count = Db::name('user_transfer')
|
||
->where('transfer_to_id', $get['user_id'])
|
||
->count();
|
||
break;
|
||
case 'out': // 支出
|
||
$list = Db::name('user_transfer')->alias('ut')
|
||
->field('ut.*, u.nickname, u.avatar, u.sn')
|
||
->leftJoin('user u', 'ut.transfer_to_id = u.id') // 收款人信息
|
||
->where('ut.transfer_from_id', $get['user_id'])
|
||
->page($get['page_no'], $get['page_size'])
|
||
->order('ut.create_time', 'desc')
|
||
->select();
|
||
$count = Db::name('user_transfer')
|
||
->where('transfer_from_id', $get['user_id'])
|
||
->count();
|
||
break;
|
||
}
|
||
|
||
// 全部(获取用户信息)
|
||
if ($get['type'] == 'all') {
|
||
foreach ($list as &$item) {
|
||
if ($item['transfer_from_id'] == $get['user_id']) {
|
||
// 自己为转账人，需获得收款人信息
|
||
$user = Db::name('user')->where('id', $item['transfer_to_id'])->find();
|
||
$item['nickname'] = $user['nickname'] ?? '';
|
||
$item['avatar'] = $user['avatar'] ?? '';
|
||
$item['sn'] = $user['sn'] ?? '';
|
||
} else if ($item['transfer_to_id'] == $get['user_id']) {
|
||
// 自己为收款人，需获得转款人信息
|
||
$user = Db::name('user')->where('id', $item['transfer_from_id'])->find();
|
||
$item['nickname'] = $user['nickname'] ?? '';
|
||
$item['avatar'] = $user['avatar'] ?? '';
|
||
$item['sn'] = $user['sn'] ?? '';
|
||
}
|
||
}
|
||
}
|
||
|
||
// 格式化数据
|
||
foreach ($list as &$item) {
|
||
$item['avatar'] = UrlServer::getFileUrl($item['avatar']);
|
||
$item['create_time'] = date('Y-m-d h:i:s', $item['create_time']);
|
||
if ($item['transfer_from_id'] == $get['user_id']) {
|
||
$item['type'] = 0;
|
||
$item['typeDesc'] = '支出';
|
||
} else {
|
||
$item['type'] = 1;
|
||
$item['typeDesc'] = '收入';
|
||
}
|
||
}
|
||
|
||
$result = [
|
||
'count' => $count,
|
||
'list' => $list,
|
||
'more' => is_more($count, $get['page_no'], $get['page_size']),
|
||
'page_no' => $get['page_no'],
|
||
'page_size' => $get['page_size']
|
||
];
|
||
return $result;
|
||
}
|
||
|
||
} |