564 lines
19 KiB
PHP
564 lines
19 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\common\logic\AccountLogLogic;
|
||
use app\common\model\{AccountLog, AfterSale, DistributionOrder, NoticeSetting, Order, User};
|
||
use app\common\server\{AreaServer, ConfigServer, UrlServer};
|
||
use think\Db;
|
||
use think\Exception;
|
||
use think\facade\Hook;
|
||
|
||
class DistributionLogic
|
||
{
|
||
/**
|
||
* 填写邀请码
|
||
* @param $code
|
||
* @param $my_id
|
||
* @return bool|string
|
||
*/
|
||
public static function code($code, $my_id)
|
||
{
|
||
try {
|
||
Db::startTrans();
|
||
|
||
$my_leader = Db::name('user')
|
||
->field(['id', 'first_leader', 'second_leader', 'third_leader', 'ancestor_relation'])
|
||
->where(['distribution_code' => $code])
|
||
->find();
|
||
|
||
//更新我的第一上级、第二上级、第三上级、关系链
|
||
$my_leader_id = $my_leader['id'];
|
||
$my_first_leader = $my_leader['first_leader'];
|
||
$my_third_leader = $my_leader['second_leader'];
|
||
$my_ancestor_relation = trim("{$my_leader_id},{$my_leader['ancestor_relation']}", ',');
|
||
$data = [
|
||
'first_leader' => $my_leader_id,
|
||
'second_leader' => $my_first_leader,
|
||
'third_leader' => $my_third_leader,
|
||
'ancestor_relation' => $my_ancestor_relation,
|
||
];
|
||
Db::name('user')
|
||
->where(['id' => $my_id])
|
||
->update($data);
|
||
|
||
//更新我向下一级的第二上级、第三上级
|
||
$data = [
|
||
'second_leader' => $my_leader_id,
|
||
'third_leader' => $my_first_leader,
|
||
];
|
||
Db::name('user')
|
||
->where(['first_leader' => $my_id])
|
||
->update($data);
|
||
|
||
//更新我向下二级的第三级
|
||
$data = [
|
||
'third_leader' => $my_leader_id,
|
||
];
|
||
Db::name('user')
|
||
->where(['second_leader' => $my_id])
|
||
->update($data);
|
||
|
||
|
||
//更新与我相关的所有关系链
|
||
Db::name('user')
|
||
->where("find_in_set({$my_id},ancestor_relation)")
|
||
->exp('ancestor_relation', "replace(ancestor_relation,'{$my_id}','" . trim("{$my_id},{$my_ancestor_relation}", ',') . "')")
|
||
->update();
|
||
|
||
//邀请会员赠送积分
|
||
$invited_award_integral = ConfigServer::get('marketing','invited_award_integral',0);
|
||
if($invited_award_integral > 0){
|
||
Db::name('user')->where(['id'=>$my_leader['id']])->setInc('user_integral',$invited_award_integral);
|
||
AccountLogLogic::AccountRecord($my_leader['id'],$invited_award_integral,1, AccountLog::invite_add_integral);
|
||
}
|
||
|
||
//消息通知
|
||
Hook::listen('notice', [
|
||
'user_id' => $my_leader_id,
|
||
'lower_id' => $my_id,
|
||
'scene' => NoticeSetting::INVITE_SUCCESS_NOTICE,
|
||
]);
|
||
|
||
Db::commit();
|
||
return true;
|
||
} catch (Exception $e) {
|
||
Db::rollback();
|
||
return $e->getMessage();
|
||
}
|
||
|
||
}
|
||
|
||
|
||
/**
|
||
* 填写申请记录
|
||
* @param $post
|
||
* @param $user_id
|
||
* @return bool|string
|
||
*/
|
||
public static function apple($post, $user_id)
|
||
{
|
||
try {
|
||
$time = time();
|
||
$data = [
|
||
'user_id' => $user_id,
|
||
'real_name' => $post['real_name'],
|
||
'province' => $post['province'],
|
||
'city' => $post['city'],
|
||
'district' => $post['district'],
|
||
'reason' => $post['reason'],
|
||
'create_time' => $time,
|
||
'update_time' => $time,
|
||
];
|
||
Db::name('distribution_member_apply')
|
||
->insert($data);
|
||
return true;
|
||
} catch (Exception $e) {
|
||
return $e->getMessage();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取最新申请详情
|
||
* @param $user_id
|
||
* @return array|\PDOStatement|string|\think\Model|null
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public static function appleDetail($user_id)
|
||
{
|
||
$result = Db::name('distribution_member_apply')
|
||
->field(['real_name', 'province', 'city', 'district', 'reason', 'status'])
|
||
->where('user_id', $user_id)
|
||
->order('id', 'desc')
|
||
->find();
|
||
|
||
if (empty($result)) {
|
||
return [];
|
||
}
|
||
|
||
$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;
|
||
}
|
||
|
||
/**
|
||
* 上级邀请人信息
|
||
* @param $user_id
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public static function myLeader($user_id)
|
||
{
|
||
|
||
$field = 'nickname,avatar,is_distribution,mobile,first_leader,distribution_code,earnings';
|
||
|
||
$user = Db::name('user')
|
||
->field($field)
|
||
->where(['id' => $user_id])
|
||
->find();
|
||
|
||
$first_leader = Db::name('user')
|
||
->field('nickname,mobile')
|
||
->where(['id' => $user['first_leader']])
|
||
->findOrEmpty();
|
||
|
||
$user['avatar'] = UrlServer::getFileUrl($user['avatar'], 'local');
|
||
return [
|
||
'user' => $user,
|
||
'leader' => $first_leader,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 分销推广主页信息
|
||
* @param $user_id
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public static function index($user_id)
|
||
{
|
||
$user_info = self::myLeader($user_id);//用户信息
|
||
$fans = Db::name('user')
|
||
->where('first_leader|second_leader', '=', $user_id)
|
||
->count();
|
||
|
||
//今天的预估收益
|
||
$today_earnings = Db::name('distribution_order_goods')
|
||
->whereTime('create_time', 'today')
|
||
->where(['status' => 1, 'user_id' => $user_id])
|
||
->sum('money');
|
||
|
||
//本月预估收益
|
||
$month_earnings = Db::name('distribution_order_goods')
|
||
->whereTime('create_time', 'month')
|
||
->where(['status' => 1, 'user_id' => $user_id])
|
||
->sum('money');
|
||
|
||
//累计收益
|
||
$history_earnings = Db::name('distribution_order_goods')
|
||
->where(['status' => 2, 'user_id' => $user_id])
|
||
->sum('money');
|
||
|
||
$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),//累计收益
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
|
||
//可提现佣金
|
||
public static function getAbleWithdrawal($user_id)
|
||
{
|
||
$after_sale_time = ConfigServer::get('after_sale', 'refund_days');
|
||
$time = time() - ($after_sale_time * 24 * 60 * 60);
|
||
|
||
//可提现佣金
|
||
$orders = Db::name('order o')
|
||
->field('o.id, d.money')
|
||
->join('order_goods g', 'o.id = g.order_id')
|
||
->join('distribution_order_goods d', 'd.order_goods_id = g.id')
|
||
->where('o.create_time', '<', $time)
|
||
->where('o.order_status', Order::STATUS_FINISH)
|
||
->where('d.user_id', $user_id)
|
||
->where('d.status', DistributionOrder::STATUS_WAIT_HANDLE)
|
||
->select();
|
||
|
||
$able_withdrawal = 0;
|
||
if (!$orders) {
|
||
return $able_withdrawal;
|
||
}
|
||
|
||
foreach ($orders as $order) {
|
||
$check = Db::name('after_sale')
|
||
->where(['order_id' => $order['id']])
|
||
->where('status', 'in', [AfterSale::STATUS_WAIT_REFUND, AfterSale::STATUS_SUCCESS_REFUND])
|
||
->find();
|
||
|
||
if ($check) {
|
||
continue;
|
||
}
|
||
$able_withdrawal += $order['money'];
|
||
}
|
||
return $able_withdrawal;
|
||
}
|
||
|
||
|
||
/**
|
||
* 分销订单列表(待返佣,已结算,已失效)
|
||
* @param $user_id
|
||
* @param $get
|
||
* @return array|\PDOStatement|string|\think\Collection
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public static function order($user_id, $get, $page, $size)
|
||
{
|
||
$where = [];
|
||
$where[] = ['d.user_id', '=', $user_id];
|
||
|
||
$status = $get['status'] ?? 0;
|
||
if ($status != 0) {
|
||
$where[] = ['d.status', '=', $status];
|
||
}
|
||
|
||
$field = 'o.order_sn, og.total_pay_price as pay_price, d.create_time, d.money, og.item_id, og.goods_num, d.status';
|
||
|
||
$count = Db::name('distribution_order_goods d')
|
||
->field($field)
|
||
->join('order_goods og', 'og.id = d.order_goods_id')
|
||
->join('order o', 'o.id = og.order_id')
|
||
->where($where)
|
||
->count();
|
||
|
||
$lists = Db::name('distribution_order_goods d')
|
||
->field($field)
|
||
->join('order_goods og', 'og.id = d.order_goods_id')
|
||
->join('order o', 'o.id = og.order_id')
|
||
->where($where)
|
||
->order('o.id desc')
|
||
->page($page, $size)
|
||
->select();
|
||
|
||
$item_ids = array_column($lists, 'item_id');
|
||
$goods = Db::name('goods_item i')
|
||
->join('goods g', 'i.goods_id = g.id')
|
||
->where('i.id', 'in', $item_ids)
|
||
->column('g.name, g.image, i.image as spec_image, i.spec_value_str', 'i.id');
|
||
|
||
foreach ($lists as &$item) {
|
||
$item_id = $item['item_id'];
|
||
if (!isset($goods[$item_id])) {
|
||
continue;
|
||
}
|
||
$info = $goods[$item_id];
|
||
$item['goods_name'] = $info['name'];
|
||
$item['spec_name'] = $info['spec_value_str'];
|
||
$item['image'] = UrlServer::getFileUrl(empty($info['spec_image']) ? $info['image'] : $info['spec_image']);
|
||
$item['status'] = DistributionOrder::getOrderStatus($item['status']);
|
||
$item['create_time'] = date('Y-m-d H:i:s', $item['create_time']);
|
||
}
|
||
|
||
$data = [
|
||
'list' => $lists,
|
||
'page' => $page,
|
||
'size' => $size,
|
||
'count' => $count,
|
||
'more' => is_more($count, $page, $size)
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
|
||
/**
|
||
* 月度账单
|
||
* @param $user_id
|
||
* @param $get
|
||
* @param $page
|
||
* @param $size
|
||
* @return array
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public static function getMonthBill($user_id, $page, $size)
|
||
{
|
||
$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(o.id) as order_num'
|
||
];
|
||
$count = Db::name('distribution_order_goods d')
|
||
->field($field)
|
||
->join('order_goods g', 'g.id = d.order_goods_id')
|
||
->join('order o', 'o.id = g.order_id')
|
||
->where(['d.user_id' => $user_id])
|
||
->where('d.status', 'in', [DistributionOrder::STATUS_WAIT_HANDLE, DistributionOrder::STATUS_SUCCESS])
|
||
->group('date')
|
||
->count();
|
||
|
||
$lists = Db::name('distribution_order_goods d')
|
||
->field($field)
|
||
->join('order_goods g', 'g.id = d.order_goods_id')
|
||
->join('order o', 'o.id = g.order_id')
|
||
->where(['d.user_id' => $user_id])
|
||
->where('d.status', 'in', [DistributionOrder::STATUS_WAIT_HANDLE, DistributionOrder::STATUS_SUCCESS])
|
||
->page($page, $size)
|
||
->group('date')
|
||
->select();
|
||
|
||
$data = [
|
||
'list' => $lists,
|
||
'page' => $page,
|
||
'size' => $size,
|
||
'count' => $count,
|
||
'more' => is_more($count, $page, $size)
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
public static function getMonth($get, $user_id, $page, $size)
|
||
{
|
||
$year = $get['year'] ?? date('Y');
|
||
$month = $get['month'] ?? date('m');
|
||
//指定月份
|
||
list($y, $m, $t) = explode('-', date("$year-$month-t"));
|
||
$time_range = [
|
||
mktime(0, 0, 0, $m, 1, $y),
|
||
mktime(23, 59, 59, $m, $t, $y)
|
||
];
|
||
|
||
$field = 'o.order_sn, o.id as order_id, g.total_pay_price as pay_price, d.create_time, d.money, g.item_id, g.goods_num, d.status';
|
||
|
||
|
||
$count = Db::name('distribution_order_goods')->alias('d')
|
||
->field($field)
|
||
->join('order_goods g', 'g.id = d.order_goods_id')
|
||
->join('order o', 'o.id = g.order_id')
|
||
->where(['d.user_id' => $user_id])
|
||
->where('d.status', 'in', [DistributionOrder::STATUS_WAIT_HANDLE, DistributionOrder::STATUS_SUCCESS])
|
||
->where('d.create_time', 'between time', $time_range)
|
||
->count();
|
||
|
||
$lists = Db::name('distribution_order_goods')->alias('d')
|
||
->field($field)
|
||
->join('order_goods g', 'g.id = d.order_goods_id')
|
||
->join('order o', 'o.id = g.order_id')
|
||
->where(['d.user_id' => $user_id])
|
||
->where('d.status', 'in', [DistributionOrder::STATUS_WAIT_HANDLE, DistributionOrder::STATUS_SUCCESS])
|
||
->where('d.create_time', 'between time', $time_range)
|
||
->page($page, $size)
|
||
->select();
|
||
|
||
|
||
$item_ids = array_column($lists, 'item_id');
|
||
$goods = Db::name('goods_item i')
|
||
->join('goods g', 'i.goods_id = g.id')
|
||
->where('i.id', 'in', $item_ids)
|
||
->column('g.name, g.image, i.image as spec_image, i.spec_value_str', 'i.id');
|
||
|
||
$total_money = 0;
|
||
$order_ids = [];
|
||
foreach ($lists as &$item) {
|
||
$item_id = $item['item_id'];
|
||
if (!isset($goods[$item_id])) {
|
||
continue;
|
||
}
|
||
$info = $goods[$item_id];
|
||
$item['goods_name'] = $info['name'];
|
||
$item['spec_name'] = $info['spec_value_str'];
|
||
$item['image'] = UrlServer::getFileUrl(empty($info['spec_image']) ? $info['image'] : $info['spec_image']);
|
||
$item['status'] = DistributionOrder::getOrderStatus($item['status']);
|
||
$item['create_time'] = date('Y-m-d H:i:s', $item['create_time']);
|
||
$total_money += $item['money'];
|
||
if (!in_array($item['order_id'], $order_ids)) {
|
||
array_push($order_ids, $item['order_id']);
|
||
}
|
||
}
|
||
|
||
$data = [
|
||
'year' => $year,
|
||
'month' => $month,
|
||
'total_money' => $total_money,
|
||
'total_order' => count($order_ids),
|
||
'list' => $lists,
|
||
'page' => $page,
|
||
'size' => $size,
|
||
'count' => $count,
|
||
'more' => is_more($count, $page, $size)
|
||
];
|
||
return $data;
|
||
|
||
}
|
||
|
||
/**
|
||
* 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 = Db::name('user_distribution')
|
||
->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(),
|
||
];
|
||
Db::name('user_distribution')->insert($data);
|
||
return true;
|
||
}
|
||
|
||
|
||
/**
|
||
* 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' => DistributionOrder::STATUS_ERROR,
|
||
'd.update_time' => time(),
|
||
]);
|
||
}
|
||
|
||
|
||
/**
|
||
* Notes: 发生售后后,更新分销订单为已失效
|
||
* @param $order_goods_id
|
||
* @author 段誉(2021/5/13 17:38)
|
||
* @return int|string
|
||
* @throws Exception
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function setFailByAfterSale($order_goods_id)
|
||
{
|
||
return Db::name('distribution_order_goods')
|
||
->where('order_goods_id', $order_goods_id)
|
||
->update([
|
||
'status' => DistributionOrder::STATUS_ERROR,
|
||
'update_time' => time(),
|
||
]);
|
||
}
|
||
|
||
|
||
/**
|
||
* 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;
|
||
}
|
||
|
||
|
||
} |