<?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\common\enum\DistributionOrderGoodsEnum;
use app\common\enum\NoticeEnum;
use app\common\model\distribution\Distribution;
use app\common\model\distribution\DistributionLevel;
use app\common\server\ConfigServer;
use app\common\model\user\UserDistribution;
use app\common\model\user\User;
use app\common\model\distribution\DistributionMemberApply;
use app\common\model\distribution\DistributionOrderGoods;
use app\common\server\AreaServer;
use app\common\server\JsonServer;
use app\common\server\UrlServer;
use app\common\basics\Logic;
use app\common\logic\AccountLogLogic;
use app\common\model\AccountLog;
use think\Exception;
use think\facade\Db;
class DistributionLogic extends Logic
{
/**
* Notes: 根据后台设置返回当前生成用户的分销会员状态(设置了全员分销,新生成的用户即为分销会员)
* @author 段誉(2021/4/7 14:48)
* @return int
*/
public static function isDistributionMember()
{
$is_distribution = 0;
//分销会员申请--1,申请分销; 2-全员分销;
$distribution = ConfigServer::get('distribution', 'member_apply', 1);
if ($distribution == 2) {
$is_distribution = 1;
}
return $is_distribution;
}
/**
* Desc: 生成用户扩展表
* @param $user_id
* @return bool
* @throws \think\db\exception\DataNotFoundException
* @throws \think\db\exception\ModelNotFoundException
* @throws \think\exception\DbException
*/
public static function createUserDistribution($user_id)
{
$user_distribution = UserDistribution::where(['user_id' => $user_id])->find();
if ($user_distribution) {
return true;
}
$data = [
'user_id' => $user_id,
'distribution_order_num' => 0,
'distribution_money' => 0,
'fans' => 0,
'create_time' => time(),
];
UserDistribution::create($data);
return true;
}
/**
* 申请分销会员
*/
public static function apply($post)
{
$time = time();
$data = [
'user_id' => $post['user_id'],
'real_name' => $post['real_name'],
'mobile' => $post['mobile'],
'province' => $post['province'],
'city' => $post['city'],
'district' => $post['district'],
'reason' => $post['reason'],
'status' => 0, // 待审核
'create_time' => $time,
'update_time' => $time,
];
return DistributionMemberApply::create($data);
}
/**
* 最新分销申请详情
*/
public static function applyDetail($userId)
{
$result = DistributionMemberApply::field(['real_name','mobile','province', 'city', 'district', 'reason', 'denial_reason', 'status'])
->where('user_id', $userId)
->order('id', 'desc')
->findOrEmpty();
if ($result->isEmpty()) {
return [];
}
$result = $result->toArray();
$result['province'] = AreaServer::getAddress($result['province']);
$result['city'] = AreaServer::getAddress($result['city']);
$result['district'] = AreaServer::getAddress($result['district']);
switch ($result['status']) {
case 0:
$result['status_str'] = '已提交，等待客服审核...';
break;
case 1:
$result['status_str'] = '已审核通过';
break;
case 2:
$result['status_str'] = '审核失败，请重新提交审核';
break;
}
return $result;
}
/**
* 分销主页
*/
public static function index($userId)
{
// 自身及上级信息
$user_info = self::myLeader($userId);
// 粉丝数(一级/二级)
$fans = User::where([
['first_leader|second_leader', '=', $userId],
['del', '=', 0]
])->count();
//今天的预估收益(待返佣)
$today_earnings = DistributionOrderGoods::whereDay('create_time')
->where(['status' => 1, 'user_id' => $userId])
->sum('money');
//本月预估收益(待返佣)
$month_earnings = DistributionOrderGoods::whereMonth('create_time')
->where(['status' => 1, 'user_id' => $userId])
->sum('money');
//累计收益(已结算)
$history_earnings = DistributionOrderGoods::where(['status' => 2, 'user_id' => $userId])
->sum('money');
// 用户分销会员等级
$levelId = Distribution::where('user_id', $userId)->value('level_id');
$levelName = DistributionLevel::getLevelNameTwo($levelId);
$data = [
'user' => $user_info['user'],
'leader' => $user_info['leader'],
'fans' => $fans,
'able_withdrawal' => $user_info['user']['earnings'],//可提现佣金
'today_earnings' => round($today_earnings, 2),//今天预估收益
'month_earnings' => round($month_earnings, 2),//本月预估收益
'history_earnings' => round($history_earnings, 2),//累计收益
'level_name' => $levelName
];
return $data;
}
/***
* 获取自身及上级信息
*/
public static function myLeader($userId)
{
$field = 'nickname,avatar,is_distribution,mobile,first_leader,distribution_code,earnings';
$user = User::field($field)->where(['id' => $userId, 'del'=>0])->findOrEmpty();
$first_leader = User::field('nickname,mobile')
->where(['id' => $user['first_leader'], 'del'=>0])
->findOrEmpty();
$user['avatar'] = UrlServer::getFileUrl($user['avatar']);
return [
'user' => $user,
'leader' => $first_leader,
];
}
/**
* 填写邀请码
*/
public static function code($post)
{
try {
Db::startTrans();
$firstLeader = User::field(['id', 'first_leader', 'second_leader', 'third_leader', 'ancestor_relation','user_integral'])
->where(['distribution_code' => $post['code']])
->findOrEmpty();
if($firstLeader->isEmpty()) {
throw new \think\Exception('无效的邀请码');
}
// 上级
$first_leader_id = $firstLeader['id'];
// 上上级
$second_leader_id = $firstLeader['first_leader'];
// 上上上级
$third_leader_id = $firstLeader['second_leader'];
// 拼接关系链
$firstLeader['ancestor_relation'] = boolval($firstLeader['ancestor_relation']) ?? ''; // 清空null值及0
$my_ancestor_relation = $first_leader_id. ',' . $firstLeader['ancestor_relation'];
// 去除两端逗号
$my_ancestor_relation = trim($my_ancestor_relation, ',');
$user = User::findOrEmpty($post['user_id']);
// 旧关系链
if (!empty($user->ancestor_relation)) {
$old_ancestor_relation = $user->id . ',' .$user->ancestor_relation;
} else {
$old_ancestor_relation = $user->id;
}
$data = [
'first_leader' => $first_leader_id,
'second_leader' => $second_leader_id,
'third_leader' => $third_leader_id,
'ancestor_relation' => $my_ancestor_relation,
'update_time' => time()
];
// 更新当前用户的分销关系
User::where(['id' => $post['user_id']])->update($data);
//更新当前用户下级的分销关系
$data = [
'second_leader' => $first_leader_id,
'third_leader' => $second_leader_id,
'update_time' => time()
];
User::where(['first_leader' => $post['user_id']])->update($data);
//更新当前用户下下级的分销关系
$data = [
'third_leader' => $first_leader_id,
'update_time' => time()
];
User::where(['second_leader' => $post['user_id']])->update($data);
//更新当前用户所有后代的关系链
$posterityArr = User::field('id,ancestor_relation')
->whereFindInSet('ancestor_relation', $post['user_id'])
->select()
->toArray();
$updateData = [];
$replace_ancestor_relation = $post['user_id'] . ','. $my_ancestor_relation;
foreach($posterityArr as $item) {
$updateData[] = [
'id' => $item['id'],
'ancestor_relation' => trim(str_replace($old_ancestor_relation, $replace_ancestor_relation, $item['ancestor_relation']), ',')
];
}
// 批量更新
(new User())->saveAll($updateData);
//邀请会员赠送积分
$invited_award_integral = ConfigServer::get('marketing','invited_award_integral',0);
if($invited_award_integral > 0){
// 增加上级积分
$firstLeader->user_integral += (int)$invited_award_integral;
$firstLeader->save();
// 增加上级积分变动记录
AccountLogLogic::AccountRecord($firstLeader['id'],$invited_award_integral,1, AccountLog::invite_add_integral);
}
//通知用户
event('Notice', [
'scene' => NoticeEnum::INVITE_SUCCESS_NOTICE,
'params' => [
'user_id' => $first_leader_id,
'lower_id' => $post['user_id'],
'join_time' => date('Y-m-d H:i:s', time())
]
]);
Db::commit();
return true;
} catch (\Exception $e) {
Db::rollback();
self::$error = $e->getMessage();
return false;
}
}
/**
* 分销订单
*/
public static function order($get)
{
$where[] = ['d.user_id', '=', $get['user_id']];
if (isset($get['status']) && in_array($get['status'], [1,2,3])) {
$where[] = ['d.status', '=', $get['status']];
}
$field = 'd.create_time, d.money, d.goods_num, d.status, d.status as statusDesc, o.order_sn, og.total_pay_price as pay_price, g.image as goods_image, g.name as goods_name, gi.spec_value_str';
$count = DistributionOrderGoods::alias('d')
->where($where)
->count();
$lists = DistributionOrderGoods::alias('d')
->field($field)
->leftJoin('order_goods og', 'og.id = d.order_goods_id')
->leftJoin('order o', 'o.id = og.order_id')
->leftJoin('goods g', 'og.goods_id=g.id')
->leftJoin('goods_item gi', 'og.item_id=gi.id')
->where($where)
->order('d.create_time desc')
->page($get['page_no'], $get['page_size'])
->select()
->toArray();
foreach ($lists as &$item) {
$item['goods_image'] = empty($item['goods_image']) ? '' : UrlServer::getFileUrl($item['goods_image']);
}
$data = [
'list' => $lists,
'page' => $get['page_no'],
'size' => $get['page_size'],
'count' => $count,
'more' => is_more($count, $get['page_no'], $get['page_size'])
];
return $data;
}
/**
* 月度账单
*/
public static function monthBill($get)
{
$field = [
"FROM_UNIXTIME(d.create_time,'%Y年%m月') as date",
"FROM_UNIXTIME(d.create_time,'%Y') as year",
"FROM_UNIXTIME(d.create_time,'%m') as month",
'sum(d.money) as total_money',
'count(d.id) as order_num'
];
$count = DistributionOrderGoods::alias('d')
->field($field)
->leftJoin('order_goods g', 'g.id = d.order_goods_id')
->leftJoin('order o', 'o.id = g.order_id')
->where(['d.user_id' => $get['user_id']])
->where('d.status', 'in', [1, 2])
->group('date')
->count();
$lists = DistributionOrderGoods::alias('d')
->field($field)
->leftJoin('order_goods g', 'g.id = d.order_goods_id')
->leftJoin('order o', 'o.id = g.order_id')
->where(['d.user_id' => $get['user_id']])
->where('d.status', 'in', [1, 2])
->order('d.create_time desc')
->page($get['page_no'], $get['page_size'])
->group('date')
->select()
->toArray();
$data = [
'list' => $lists,
'page' => $get['page_no'],
'size' => $get['page_size'],
'count' => $count,
'more' => is_more($count, $get['page_no'], $get['page_size'])
];
return $data;
}
/**
* 月度明细
*/
public static function monthDetail($get)
{
$where[] = ['d.user_id', '=', $get['user_id']];
$monthStr = $get['year'] . '-' . str_pad($get['month'], 2, '0', STR_PAD_LEFT);
$field = 'd.create_time, d.money, d.goods_num, d.status, d.status as statusDesc, o.order_sn, og.total_pay_price as pay_price, g.image as goods_image, g.name as goods_name, gi.spec_value_str';
$count = DistributionOrderGoods::alias('d')
->where($where)
->whereMonth('d.create_time', $monthStr)
->count();
$lists = DistributionOrderGoods::alias('d')
->field($field)
->leftJoin('order_goods og', 'og.id = d.order_goods_id')
->leftJoin('order o', 'o.id = og.order_id')
->leftJoin('goods g', 'og.goods_id=g.id')
->leftJoin('goods_item gi', 'og.item_id=gi.id')
->where($where)
->whereMonth('d.create_time', $monthStr)
->order('d.create_time desc')
->page($get['page_no'], $get['page_size'])
->select()
->toArray();
$data = [
'list' => $lists,
'page' => $get['page_no'],
'size' => $get['page_size'],
'count' => $count,
'more' => is_more($count, $get['page_no'], $get['page_size'])
];
return $data;
}
/**
* Desc: 取消订单后更新分销订单为已失效
* @param $order_id
* @throws Exception
* @throws \think\exception\PDOException
*/
public static function setDistributionOrderFail($order_id)
{
//订单取消后更新分销订单为已失效状态
return Db::name('distribution_order_goods d')
->join('order_goods og', 'og.id = d.order_goods_id')
->join('order o', 'o.id = og.order_id')
->where('o.id', $order_id)
->update([
'd.status' => DistributionOrderGoodsEnum::STATUS_ERROR,
'd.update_time' => time(),
]);
}
/**
* @Notes: 分销佣金列表
* @Author: 张无忌
* @param $get
* @param $user_id
* @return bool|array
*/
public static function commission($get, $user_id)
{
try {
$where = [
['user_id', '=', $user_id],
['source_type', 'in', AccountLog::earnings_change]
];
$model = new AccountLog();
$count = $model->where($where)->count();
$lists = $model->field(['id,source_type,change_amount,change_type,create_time'])
->where($where)
->order('id', 'desc')
->page($get['page_no'] ?? 1, $get['page_size'] ?? 20)
->select();
foreach ($lists as &$item) {
$symbol = $item['change_type'] == 1 ? '+' : '-';
$item['change_amount'] = $symbol.$item['change_amount'];
}
return [
'list' => $lists,
'page' => $get['page_no']??1,
'size' => $get['page_size']??20,
'count' => $count,
'more' => is_more($count, $get['page_no']??1, $get['page_size']??20)
];
} catch (\Exception $e) {
static::$error = $e->getMessage();
return false;
}
}
public static function fixAncestorRelation()
{
try {
$userList = User::select()->toArray();
if (empty($userList)) {
throw new \Exception('没有用户，无需修复');
}
$updateEmptyData = [];
$updateData = [];
foreach($userList as $user) {
$my_ancestor_relation = self::myAncestorRelation($user);
$updateEmptyData[] = ['id' => $user['id'], 'ancestor_relation' => ''];
$updateData[] = ['id' => $user['id'], 'ancestor_relation' => $my_ancestor_relation];
}
// 先清除所有关系链
(new User())->saveAll($updateEmptyData);
// 重新设置关系链
(new User())->saveAll($updateData);
return true;
} catch (\Exception $e) {
self::$error = $e->getMessage();
return false;
}
}
public static function myAncestorRelation($user)
{
if (empty($user['first_leader'])) {
return '';
}
return trim(self::findAncestorRelation($user['first_leader']), ',');
}
public static function findAncestorRelation($id, $flag = true)
{
static $ancestor_relation = '';
if ($flag) {
$ancestor_relation = '';
}
$ancestor_relation .= $id . ',';
$user = User::findOrEmpty($id);
if (empty($user['first_leader'])) {
return $ancestor_relation;
}
return self::findAncestorRelation($user['first_leader'], false);
}
/**
* @notes 获取背景海报
* @return array|mixed|string|null
* @author cjhao
* @date 2021/11/29 11:35
*/
public static function getPoster()
{
$poster = ConfigServer::get('invite', 'poster', '/images/share/share_user_bg.png');
$poster = empty($poster) ? $poster : UrlServer::getFileUrl($poster);
return ['poster'=>$poster];
}
}