727 lines
26 KiB
PHP
727 lines
26 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\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 app\common\server\WeChatServer;
|
||
use EasyWeChat\Factory;
|
||
use EasyWeChat\Kernel\Http\StreamResponse;
|
||
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 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' => $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());
|
||
}
|
||
}
|
||
} |