diff --git a/app/api/logic/DistributionLogic.php b/app/api/logic/DistributionLogic.php deleted file mode 100644 index 3978e15f..00000000 --- a/app/api/logic/DistributionLogic.php +++ /dev/null @@ -1,727 +0,0 @@ - $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 wxCodeApply($post,$user_id) - { - Db::startTrans(); - try { - $result = DistributionMemberApply::where('user_id',$user_id)->find(); - if($result == null){ - $url = self::makeMpWechatQrcode($user_id); - $time = time(); - $data = [ - 'user_id' => $user_id, - 'real_name' => $post['real_name'], - 'mobile' => $post['mobile'], - 'province' => $post['province'], - 'city' => $post['city'], - 'district' => $post['district'], -// 'reason' => $post['reason'], - 'status' => 1, - 'create_time' => $time, - 'update_time' => $time, - ]; - DistributionMemberApply::create($data); - User::where("id",$user_id)->update(['url'=>$url['data']['qr_code']]); - $distribution = Distribution::where("user_id",$user_id)->find(); - $defaultLevelId = DistributionLevel::where('is_default', 1)->value('id'); - $data = [ - 'user_id' => $user_id, - 'level_id' => $defaultLevelId, - 'is_freeze' => 0, - 'remark' => '', - 'is_distribution' => 1, - 'distribution_time' => time() - ]; - if($distribution != null){ - Distribution::update($data,['user_id'=>$user_id]); - }else{ - Distribution::create($data); - } - } - Db::commit(); - return true; - } catch (\Exception $e) { - Db::rollback(); - static::$error = $e->getMessage(); - return false; - } - - } - /** - * 最新分销申请详情 - */ - 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 = 'url,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'] = $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 wxCode($post,$user_id) - { - try { - Db::startTrans(); - - $firstLeader = User::field(['id', 'first_leader', 'second_leader', 'third_leader', 'ancestor_relation','user_integral']) - ->where(['id' => $post['user_id']]) - ->findOrEmpty(); - if($firstLeader->isEmpty()) { - throw new \think\Exception('无效的二维码'); - } - $user = User::where(['id' => $user_id]) - ->find(); - if($user['first_leader'] != 0) { - throw new \think\Exception('已扫码'); - } - if($post['user_id'] == $user_id) { - throw new \think\Exception('无法扫自己的码'); - } - // 上级 - $first_leader_id = $firstLeader['id']; - $data = [ - 'first_leader' => $first_leader_id, - 'update_time' => time() - ]; - - // 更新当前用户的分销关系 - User::where(['id' => $post['user_id']])->update($data); - //通知用户 - 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]; - - } - // 生成分销推广二维码 - public static function makeMpWechatQrcode($user_id, string $type = 'url', array $extra = []) - { - try { - $width = 430; - // 'env_version' => 'trial', - $envVersion = 'develop'; -// $envVersion = 'release'; - $page = "pages/index/index"; - $save_dir = public_path() . 'uploads/wxqrcode/'; - // 确保目录存在 - if (!is_dir($save_dir)) { - mkdir($save_dir, 0755, true); - } - $file_name = time() . '.png'; - $config = WeChatServer::getMnpConfig(); - $app = Factory::miniProgram($config); - - $response = $app->app_code->getUnlimit('user_id='.$user_id, [ -// 'scene' => 'type=1', - 'page' => $page, - 'width' => $width, - 'auto_color' => false, - 'line_color' => ['r' => 0, 'g' => 0, 'b' => 0], - 'is_hyaline' => false, - 'env_version' => $envVersion, - 'check_path' => false, - ]); - - if(is_array($response) && 41030 === $response['errcode']){ - - //开启错误提示，小程序未发布和页面不存在，返回提示 - if (41030 === $response['errcode']) { - return '所传page页面不存在，或者小程序没有发布'; - } - return $response['errmsg']; - } - - $contents = $response->getBody()->getContents(); - switch ($type){ - case 'file': - if ($response instanceof StreamResponse) { - $file_name = $response->saveAs($save_dir, $file_name); - $contents = $save_dir . $file_name; - } - break; - case 'url': // 保存并返回完整URL - $full_path = $save_dir . $file_name; - file_put_contents($full_path, $contents); - // 生成完整的可访问URL（根据实际域名调整） - $contents = request()->domain() . '/uploads/wxqrcode/' . $file_name; - break; - case 'base64': - $mp_base64 = chunk_split(base64_encode($contents)); - $contents = 'data:image/png;base64,' . $mp_base64; - break; - } - return data_success('',['qr_code'=>$contents, 'extra' => $extra]); - - - } catch (\EasyWeChat\Kernel\Exceptions\Exception $e){ - return data_error($e->getMessage()); - } - } -} \ No newline at end of file