mirror of
https://github.com/crmeb/CRMEB.git
synced 2026-10-28 21:40:50 +00:00
d50837b663
移除佣金/提现控制器与前端页面，订单与用户链路去掉分销佣金逻辑，安装 SQL 与文档同步。 Co-authored-by: Cursor <cursoragent@cursor.com>
454 lines
17 KiB
PHP
454 lines
17 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
// +----------------------------------------------------------------------
|
||
// | Copyright (c) 2016~2026 https://www.crmeb.com All rights reserved.
|
||
// +----------------------------------------------------------------------
|
||
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
// +----------------------------------------------------------------------
|
||
// | Author: CRMEB Team <admin@crmeb.com>
|
||
// +----------------------------------------------------------------------
|
||
declare (strict_types=1);
|
||
|
||
namespace app\services\other;
|
||
|
||
use crmeb\basic\BaseService;
|
||
use app\dao\other\QrcodeDao;
|
||
use app\services\system\attachment\SystemAttachmentServices;
|
||
use crmeb\exceptions\AdminException;
|
||
|
||
use app\services\driver\upload\UploadService;
|
||
|
||
/**
|
||
*
|
||
* Class QrcodeServices
|
||
* @package app\services\other
|
||
* @method getQrcode($id, $type)
|
||
* @method scanQrcode($id, $type)
|
||
*/
|
||
class QrcodeServices extends BaseService
|
||
{
|
||
/**
|
||
* @var QrcodeDao
|
||
*/
|
||
protected $dao;
|
||
|
||
/**
|
||
* QrcodeServices constructor.
|
||
* @param QrcodeDao $dao
|
||
*/
|
||
public function __construct(QrcodeDao $dao)
|
||
{
|
||
$this->dao = $dao;
|
||
}
|
||
|
||
/**
|
||
* 获取临时二维码
|
||
* @param $type
|
||
* @param $id
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getTemporaryQrcode($type, $id)
|
||
{
|
||
$where['third_id'] = $id;
|
||
$where['third_type'] = $type;
|
||
$res = $this->dao->getOne($where);
|
||
if (!$res) {
|
||
$this->createTemporaryQrcode($id, $type);
|
||
$res = $this->getTemporaryQrcode($type, $id);
|
||
} else if (empty($res['expire_seconds']) || $res['expire_seconds'] < time()) {
|
||
$this->createTemporaryQrcode($id, $type, $res['id']);
|
||
$res = $this->getTemporaryQrcode($type, $id);
|
||
}
|
||
if (!$res['ticket']) throw new AdminException('临时二维码获取错误');
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 临时二维码生成
|
||
* @param $id
|
||
* @param $type
|
||
* @param string $qrcode_id
|
||
*/
|
||
public function createTemporaryQrcode($id, $type, $qrcode_id = '')
|
||
{
|
||
//通过事件代理获取微信公众号 qrcode 实例，避免 app 层直接引用 modules
|
||
// 多渠道同时注册 ChannelServiceProxy 时需取首个非 null 结果（勿用 [0]）
|
||
$qrcode = proxy_event_result(event('ChannelServiceProxy', [
|
||
'endpoint' => 'wechat_mp',
|
||
'service' => 'WechatService',
|
||
'action' => 'qrcodeService',
|
||
'args' => [],
|
||
]));
|
||
if (!$qrcode) {
|
||
throw new AdminException('微信公众号二维码服务不可用，请检查公众号配置与渠道插件');
|
||
}
|
||
$data = $qrcode->temporary($id, 30 * 24 * 3600)->toArray();
|
||
$data['qrcode_url'] = $data['url'];
|
||
$data['expire_seconds'] = $data['expire_seconds'] + time();
|
||
$data['url'] = $qrcode->url($data['ticket']);
|
||
$data['status'] = 1;
|
||
$data['third_id'] = $id;
|
||
$data['third_type'] = $type;
|
||
if ($qrcode_id) {
|
||
$this->dao->update($qrcode_id, $data);
|
||
} else {
|
||
$data['add_time'] = time();
|
||
$this->dao->save($data);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取永久二维码
|
||
* @param $type
|
||
* @param $id
|
||
* @return array|mixed|\think\Model
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\DbException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
*/
|
||
public function getForeverQrcode($type, $id)
|
||
{
|
||
$where['third_id'] = $id;
|
||
$where['third_type'] = $type;
|
||
$res = $this->dao->getOne($where);
|
||
if (!$res) {
|
||
$this->createForeverQrcode($id, $type);
|
||
$res = $this->getForeverQrcode($type, $id);
|
||
}
|
||
if (!$res['ticket']) throw new AdminException('永久二维码获取错误');
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 永久二维码生成
|
||
* @param $id
|
||
* @param $type
|
||
*/
|
||
public function createForeverQrcode($id, $type)
|
||
{
|
||
//通过事件代理获取微信公众号 qrcode 实例，避免 app 层直接引用 modules
|
||
// 多渠道同时注册 ChannelServiceProxy 时需取首个非 null 结果（勿用 [0]）
|
||
$qrcode = proxy_event_result(event('ChannelServiceProxy', [
|
||
'endpoint' => 'wechat_mp',
|
||
'service' => 'WechatService',
|
||
'action' => 'qrcodeService',
|
||
'args' => [],
|
||
]));
|
||
if (!$qrcode) {
|
||
throw new AdminException('微信公众号二维码服务不可用，请检查公众号配置与渠道插件');
|
||
}
|
||
$data = $qrcode->forever($id)->toArray();
|
||
$data['qrcode_url'] = $data['url'];
|
||
$data['url'] = $qrcode->url($data['ticket']);
|
||
$data['expire_seconds'] = 0;
|
||
$data['status'] = 1;
|
||
$data['third_id'] = $id;
|
||
$data['third_type'] = $type;
|
||
$data['add_time'] = time();
|
||
$this->dao->save($data);
|
||
}
|
||
|
||
/**
|
||
* 获取二维码完整路径，不存在则自动生成
|
||
* @param string $name 路径名
|
||
* @param string $link 需要生成二维码的跳转路径
|
||
* @param int $type https 1 = http , 0 = https
|
||
* @param bool $force 是否返回false
|
||
* @return bool|mixed|string
|
||
*/
|
||
public function getWechatQrcodePathAgent(string $name, string $link, bool $force = false)
|
||
{
|
||
/** @var SystemAttachmentServices $systemAttchment */
|
||
$systemAttchment = app()->make(SystemAttachmentServices::class);
|
||
try {
|
||
$imageInfo = $systemAttchment->getInfo(['real_name' => $name, 'module_type' => 2]);
|
||
$siteUrl = sys_config('site_url');
|
||
if (!$imageInfo) {
|
||
$codeUrl = PosterServices::setHttpType($siteUrl . $link, request()->isSsl() ? 0 : 1);//二维码链接
|
||
$imageInfo = PosterServices::getQRCodePath($codeUrl, $name);
|
||
if (is_string($imageInfo) && $force)
|
||
return false;
|
||
if (is_array($imageInfo)) {
|
||
$systemAttchment->attachmentAdd($imageInfo['name'], $imageInfo['size'], $imageInfo['type'], $imageInfo['dir'], $imageInfo['thumb_path'], 1, $imageInfo['image_type'], $imageInfo['time'], 2);
|
||
$url = $imageInfo['dir'];
|
||
} else {
|
||
$url = '';
|
||
$imageInfo = ['image_type' => 0];
|
||
}
|
||
} else $url = $imageInfo['att_dir'];
|
||
if ($imageInfo['image_type'] == 1 && $url) $url = $siteUrl . $url;
|
||
return $url;
|
||
} catch (\Throwable $e) {
|
||
if ($force)
|
||
return false;
|
||
else
|
||
return '';
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取二维码完整路径，不存在则自动生成
|
||
* @param string $name
|
||
* @param string $link
|
||
* @param bool $force
|
||
* @return bool|mixed|string
|
||
*/
|
||
public function getWechatQrcodePath(string $name, string $link, bool $force = false, bool $isSaveAttach = true)
|
||
{
|
||
/** @var SystemAttachmentServices $systemAttachmentService */
|
||
$systemAttachmentService = app()->make(SystemAttachmentServices::class);
|
||
try {
|
||
if (!$isSaveAttach) {
|
||
$imageInfo = "";
|
||
} else {
|
||
$imageInfo = $systemAttachmentService->getOne(['real_name' => $name, 'module_type' => 2]);
|
||
}
|
||
$siteUrl = sys_config('site_url');
|
||
if (!$imageInfo) {
|
||
$codeUrl = PosterServices::setHttpType($siteUrl . $link, request()->isSsl() ? 0 : 1);//二维码链接
|
||
$imageInfo = PosterServices::getQRCodePath($codeUrl, $name);
|
||
if (is_string($imageInfo) && $force)
|
||
return false;
|
||
if (is_array($imageInfo)) {
|
||
if ($isSaveAttach) {
|
||
$systemAttachmentService->save([
|
||
'name' => $imageInfo['name'],
|
||
'att_dir' => $imageInfo['dir'],
|
||
'satt_dir' => $imageInfo['thumb_path'],
|
||
'att_size' => $imageInfo['size'],
|
||
'att_type' => $imageInfo['type'],
|
||
'image_type' => $imageInfo['image_type'],
|
||
'module_type' => 2,
|
||
'time' => time(),
|
||
'pid' => 1,
|
||
'type' => 1
|
||
]);
|
||
}
|
||
$url = $imageInfo['dir'];
|
||
} else {
|
||
$url = '';
|
||
$imageInfo = ['image_type' => 0];
|
||
}
|
||
} else $url = $imageInfo['att_dir'];
|
||
if ($imageInfo['image_type'] == 1 && $url) $url = $siteUrl . $url;
|
||
return $url;
|
||
} catch (\Throwable $e) {
|
||
if ($force)
|
||
return false;
|
||
else
|
||
return '';
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取小程序分享二维码
|
||
* @param int $id
|
||
* @param int $uid
|
||
* @param int $type
|
||
* @param array $param
|
||
* @param bool $isSaveAttach
|
||
* @return false|mixed|string
|
||
*/
|
||
public function getRoutineQrcodePath(int $id, int $uid, int $type, array $param = [], bool $isSaveAttach = true)
|
||
{
|
||
$page = '';
|
||
$namePath = '';
|
||
$data = 'id=' . $id . '&pid=' . $uid;
|
||
switch ($type) {
|
||
case 0:
|
||
$page = 'pages/goods_details/index';
|
||
$namePath = $id . '_' . $uid . '_product.jpg';
|
||
break;
|
||
case 1:
|
||
$page = 'pages/activity/goods_combination_details/index';
|
||
$namePath = 'combination_' . $id . '_' . $uid . '.jpg';
|
||
break;
|
||
case 2:
|
||
$data = $data . '&time_id=' . $param['time_id'];
|
||
$page = 'pages/activity/goods_seckill_details/index';
|
||
$namePath = 'seckill_' . $id . '_' . $uid . '.jpg';
|
||
break;
|
||
case 3:
|
||
$page = 'pages/annex/offline_pay/index';
|
||
$namePath = 'routine_offline_scan.jpg';
|
||
break;
|
||
case 4:
|
||
$page = 'pages/annex/vip_active/index';
|
||
$namePath = 'routine_member_card.jpg';
|
||
break;
|
||
case 5:
|
||
$page = 'pages/annex/vip_paid/index';
|
||
$namePath = 'routine_pay_vip_code.jpg';
|
||
break;
|
||
case 6:
|
||
$page = 'pages/annex/special/index';
|
||
$namePath = $id . 'routine_index_code.jpg';
|
||
break;
|
||
case 7:
|
||
$page = 'pages/goods/receive_gift/index';
|
||
$namePath = 'gift_order_' . $id . '.jpg';
|
||
break;
|
||
}
|
||
if (!$page || !$namePath) {
|
||
return false;
|
||
}
|
||
return $this->createRoutineQrcode($data, $page, $namePath, $isSaveAttach);
|
||
}
|
||
|
||
/**
|
||
* 主题预览小程序码（scene 携带 theme_id，与移动端 pages/index/index、pages/annex/special/index 的 scene 解析一致）
|
||
* @param int $themeId
|
||
* @param string $pageType micro 时指向微页面预览页，其余指向首页
|
||
* @return false|mixed|string
|
||
*/
|
||
public function getThemeRoutineQrcodePath(int $themeId, string $pageType = 'home')
|
||
{
|
||
if ($pageType === 'micro') {
|
||
$page = 'pages/annex/special/index';
|
||
$namePath = 'theme_micro_' . $themeId . '_routine_index_code.jpg';
|
||
} else {
|
||
$page = 'pages/index/index';
|
||
$namePath = 'theme_' . $themeId . '_routine_index_code.jpg';
|
||
}
|
||
return $this->createRoutineQrcode('theme_id=' . $themeId, $page, $namePath, false);
|
||
}
|
||
|
||
/**
|
||
* 通过事件代理生成小程序码并上传，返回图片地址
|
||
* @param string $data scene 参数
|
||
* @param string $page 小程序页面路径
|
||
* @param string $namePath 上传文件名（同时作为附件缓存键）
|
||
* @param bool $isSaveAttach 是否按附件名缓存复用
|
||
* @return false|mixed|string
|
||
*/
|
||
protected function createRoutineQrcode(string $data, string $page, string $namePath, bool $isSaveAttach)
|
||
{
|
||
/** @var SystemAttachmentServices $systemAttachmentService */
|
||
$systemAttachmentService = app()->make(SystemAttachmentServices::class);
|
||
try {
|
||
if (!$isSaveAttach) {
|
||
$imageInfo = "";
|
||
} else {
|
||
$imageInfo = $systemAttachmentService->getOne(['real_name' => $namePath, 'module_type' => 2]);
|
||
}
|
||
$siteUrl = sys_config('site_url');
|
||
if (!$imageInfo) {
|
||
//通过事件代理获取小程序码，避免 app 层直接引用 modules
|
||
// 多渠道同时注册 ChannelServiceProxy 时需取首个非 null 结果（勿用 [0]）
|
||
$res = proxy_event_result(event('ChannelServiceProxy', [
|
||
'endpoint' => 'wechat_mini',
|
||
'service' => 'MiniProgramService',
|
||
'action' => 'appCodeUnlimitService',
|
||
'args' => [$data, $page, 280],
|
||
]));
|
||
if (!$res) return false;
|
||
$res = (string)$res;
|
||
if (strlen($res) < 100) return 'unpublished';
|
||
$upload = UploadService::init();
|
||
$res = $upload->to('routine/product')->validate()->setAuthThumb(false)->stream($res, $namePath);
|
||
if ($res === false) {
|
||
return false;
|
||
}
|
||
$imageInfo = $upload->getUploadInfo();
|
||
$imageInfo['image_type'] = upload_type();
|
||
if ($imageInfo['image_type'] == 1) $remoteImage = PosterServices::remoteImage($siteUrl . $imageInfo['dir']);
|
||
else $remoteImage = PosterServices::remoteImage($imageInfo['dir']);
|
||
if (!$remoteImage['status']) return false;
|
||
if ($isSaveAttach) {
|
||
$systemAttachmentService->save([
|
||
'name' => $imageInfo['name'],
|
||
'att_dir' => $imageInfo['dir'],
|
||
'satt_dir' => $imageInfo['thumb_path'],
|
||
'att_size' => $imageInfo['size'],
|
||
'att_type' => $imageInfo['type'],
|
||
'image_type' => $imageInfo['image_type'],
|
||
'module_type' => 2,
|
||
'time' => time(),
|
||
'pid' => 1,
|
||
'type' => 2
|
||
]);
|
||
}
|
||
$url = $imageInfo['dir'];
|
||
} else $url = $imageInfo['att_dir'];
|
||
if ($imageInfo['image_type'] == 1) $url = $siteUrl . $url;
|
||
return $url;
|
||
} catch (\Throwable $e) {
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* TODO 添加二维码 存在直接获取
|
||
* @param int $thirdId
|
||
* @param string $thirdType
|
||
* @param string $page
|
||
* @param string $qrCodeLink
|
||
* @return array|false|object|\PDOStatement|string|\think\Model
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function qrCodeForever($thirdId = 0, $thirdType = 'spread', $page = '', $qrCodeLink = '')
|
||
{
|
||
$qrcode = $this->dao->getOne(['third_id' => $thirdId, 'third_type' => $thirdType]);
|
||
if ($qrcode) {
|
||
return $qrcode;
|
||
}
|
||
return $this->setQrcodeForever($thirdId, $thirdType, $page, $qrCodeLink);
|
||
}
|
||
|
||
/**
|
||
* 添加二维码记录
|
||
* @param string $thirdType
|
||
* @param int $thirdId
|
||
* @return object
|
||
*/
|
||
public function setQrcodeForever($thirdId = 0, $thirdType = 'spread', $page = '', $qrCodeLink = '')
|
||
{
|
||
$data['third_type'] = $thirdType;
|
||
$data['third_id'] = $thirdId;
|
||
$data['status'] = 1;
|
||
$data['add_time'] = time();
|
||
$data['page'] = $page;
|
||
$data['url_time'] = '';
|
||
$data['qrcode_url'] = $qrCodeLink;
|
||
if (!$re = $this->dao->save($data)) {
|
||
throw new AdminException('二维码生成失败');
|
||
}
|
||
return $re;
|
||
}
|
||
|
||
/**
|
||
* 修改二维码地址
|
||
* @param int $id
|
||
* @param array $data
|
||
* @return bool
|
||
*/
|
||
public function setQrcodeFind($id = 0, $data = array())
|
||
{
|
||
if (!$id) return false;
|
||
if (!$this->dao->get((int)$id)) {
|
||
throw new AdminException('数据不存在');
|
||
}
|
||
if (!$re = $this->dao->update($id, $data, 'id')) {
|
||
throw new AdminException('修改失败');
|
||
}
|
||
return $re;
|
||
}
|
||
|
||
/**
|
||
* 检测是否存在
|
||
* @param int $thirdId
|
||
* @param string $thirdType
|
||
* @return bool
|
||
*/
|
||
public function qrCodeExist($thirdId = 0, $thirdType = 'spread')
|
||
{
|
||
return !!$this->dao->getCount(['third_id' => $thirdId, 'third_type' => $thirdType]);
|
||
}
|
||
}
|