CRMEB/crmeb/app/services/wechat/WechatQrcodeServices.php

<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2026 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
namespace app\services\wechat;


use app\dao\wechat\WechatQrcodeDao;
use app\services\BaseServices;
use app\services\other\QrcodeServices;
use app\services\system\attachment\SystemAttachmentServices;
use app\services\user\UserLabelRelationServices;
use app\services\user\UserLabelServices;
use app\services\user\UserServices;
use crmeb\exceptions\AdminException;
use app\services\other\UploadService;
use crmeb\services\app\WechatService;
use think\facade\Config;

/**
 * Class WechatQrcodeServices
 * @package app\services\wechat
 */
class WechatQrcodeServices extends BaseServices
{
    /**
     * WechatQrcodeServices constructor.
     * @param WechatQrcodeDao $dao
     */
    public function __construct(WechatQrcodeDao $dao)
    {
        $this->dao = $dao;
    }

    /**
     * 获取渠道码列表
     * @param $where
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function qrcodeList($where)
    {
        /** @var UserLabelServices $userLabel */
        $userLabel = app()->make(UserLabelServices::class);
        [$page, $limit] = $this->getPageValue();
        $list = $this->dao->getList($where, $page, $limit);
        foreach ($list as &$item) {
            $item['y_follow'] = $item['y_follow'] ?? 0;
            $item['stop'] = $item['end_time'] ? ($item['end_time'] > time() ? 1 : -1) : 0;
            $item['label_name'] = $userLabel->getColumn([['id', 'in', $item['label_id']]], 'label_name');
            $item['end_time'] = date('Y-m-d H:i:s', $item['end_time']);
            $item['add_time'] = date('Y-m-d H:i:s', $item['add_time']);
        }
        $count = $this->dao->count($where);
        return compact('list', 'count');
    }

    /**
     * 获取详情
     * @param $id
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function qrcodeInfo($id)
    {
        $info = $this->dao->get($id);
        if ($info) {
            $info = $info->toArray();
        } else {
            throw new AdminException('数据不存在');
        }
        /** @var UserServices $userService */
        $userService = app()->make(UserServices::class);
        $info['label_id'] = explode(',', $info['label_id']);
        foreach ($info['label_id'] as &$item) {
            $item = (int)$item;
        }
        /** @var UserLabelServices $userLabelServices */
        $userLabelServices = app()->make(UserLabelServices::class);
        $info['label_id'] = $userLabelServices->getLabelList(['ids' => $info['label_id']], ['id', 'label_name']);
        $info['time'] = $info['continue_time'];
        $info['content'] = json_decode($info['content'], true);
        $info['data'] = json_decode($info['data'], true);
        $info['avatar'] = $userService->value(['uid' => $info['uid']], 'avatar');
        return $info;
    }

    /**
     * 保存渠道码数据
     * @param $id
     * @param $data
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function saveQrcode($id, $data)
    {
        $data['label_id'] = implode(',', $data['label_id']);
        $data['add_time'] = time();
        $data['continue_time'] = $data['time'];
        $data['end_time'] = $data['time'] ? $data['add_time'] + ($data['time'] * 86400) : 0;
        /** @var WechatReplyServices $replyServices */
        $replyServices = app()->make(WechatReplyServices::class);
        $type = $data['type'];
        if ($data['type'] == 'url') $type = 'text';
        $content = $data['content'];
        if ($data['type'] == 'news') $content = $data['content']['list'] ?? [];
        $method = 'tidy' . ucfirst($type);
        $data['data'] = $replyServices->{$method}($content, 0);
        $data['content'] = json_encode($data['content']);
        $data['data'] = json_encode($data['data']);
        if ($id) {
            $info = $this->dao->get($id);
            if (!$info) throw new AdminException('数据不存在');
            if ($info['image'] == '') $data['image'] = $this->getChannelCode($id);
            $info = $this->dao->update($id, $data);
            if (!$info) throw new AdminException('保存失败');
        } else {
            $info = $this->dao->save($data);
            $image = $this->getChannelCode($info['id']);
            $info = $this->dao->update($info['id'], ['image' => $image]);
            if (!$info) throw new AdminException('保存失败');
        }
        return true;
    }

    /**
     * 生成渠道码
     * @param int $id
     * @return mixed|string
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getChannelCode($id = 0)
    {
        /** @var SystemAttachmentServices $systemAttachment */
        $systemAttachment = app()->make(SystemAttachmentServices::class);
        $name = 'wechatqrcode_' . $id . '.jpg';
        $siteUrl = sys_config('site_url', '');
        $imageInfo = $systemAttachment->getInfo(['name' => $name]);
        if (!$imageInfo) {
            /** @var QrcodeServices $qrCode */
            $qrCode = app()->make(QrcodeServices::class);
            //公众号
            $resCode = $qrCode->getForeverQrcode('wechatqrcode', $id);
            if ($resCode) {
                $res = ['res' => $resCode, 'id' => $resCode['id']];
            } else {
                $res = false;
            }
            if (!$res) throw new AdminException('二维码生成失败');
            $imageInfo = $this->downloadImage($resCode['url'], $name);
            $systemAttachment->attachmentAdd($name, $imageInfo['size'], $imageInfo['type'], $imageInfo['att_dir'], $imageInfo['att_dir'], 1, $imageInfo['image_type'], time(), 1);
        }
        return strpos($imageInfo['att_dir'], 'http') === false ? $siteUrl . $imageInfo['att_dir'] : $imageInfo['att_dir'];
    }

    /**
     * 下载图片
     * @param string $url
     * @param string $name
     * @param int $type
     * @param int $timeout
     * @param int $w
     * @param int $h
     * @return string
     */
    public function downloadImage($url = '', $name = '', $type = 0, $timeout = 30, $w = 0, $h = 0)
    {
        if (!strlen(trim($url))) return '';
        if (!strlen(trim($name))) {
            //TODO 获取要下载的文件名称
            $downloadImageInfo = $this->getImageExtname($url);
            $ext = $downloadImageInfo['ext_name'];
            $name = $downloadImageInfo['file_name'];
            if (!strlen(trim($name))) return '';
        } else {
            $ext = $this->getImageExtname($name)['ext_name'];
        }
        if (!in_array($ext, Config::get('upload.fileExt'))) {
            throw new AdminException('格式错误');
        }
        //TODO 获取远程文件所采用的方法
        if ($type) {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); //TODO 跳过证书检查
            if (stripos($url, "https://") !== FALSE) curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);  //TODO 从证书中检查SSL加密算法是否存在
            curl_setopt($ch, CURLOPT_HTTPHEADER, array('user-agent:' . $_SERVER['HTTP_USER_AGENT']));
            if (ini_get('open_basedir') == '' && ini_get('safe_mode' == 'Off')) curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);//TODO 是否采集301、302之后的页面
            $content = curl_exec($ch);
            curl_close($ch);
        } else {
            try {
                ob_start();
                readfile($url);
                $content = ob_get_contents();
                ob_end_clean();
            } catch (\Exception $e) {
                return $e->getMessage();
            }
        }
        $size = strlen(trim($content));
        if (!$content || $size <= 2) return '图片流获取失败';
        $upload_type = sys_config('upload_type', 1);
        $upload = UploadService::init();
        if ($upload->to('attach/spread/agent')->setAuthThumb(false)->stream($content, $name) === false) {
            return $upload->getError();
        }
        $imageInfo = $upload->getUploadInfo();
        $data['att_dir'] = $imageInfo['dir'];
        $data['name'] = $imageInfo['name'];
        $data['size'] = $imageInfo['size'];
        $data['type'] = $imageInfo['type'];
        $data['image_type'] = $upload_type;
        $data['is_exists'] = false;
        return $data;
    }

    /**
     * 获取即将要下载的图片扩展名
     * @param string $url
     * @param string $ex
     * @return array|string[]
     */
    public function getImageExtname($url = '', $ex = 'jpg')
    {
        $_empty = ['file_name' => '', 'ext_name' => $ex];
        if (!$url) return $_empty;
        if (strpos($url, '?')) {
            $_tarr = explode('?', $url);
            $url = trim($_tarr[0]);
        }
        $arr = explode('.', $url);
        if (!is_array($arr) || count($arr) <= 1) return $_empty;
        $ext_name = trim($arr[count($arr) - 1]);
        $ext_name = !$ext_name ? $ex : $ext_name;
        return ['file_name' => md5($url) . '.' . $ext_name, 'ext_name' => $ext_name];
    }

    /**
     * 扫码完成后方法
     * @param $qrcodeInfo
     * @param $userInfo
     * @param $spreadInfo
     * @param int $isFollow
     * @return mixed
     */
    public function wechatQrcodeRecord($qrcodeInfo, $userInfo, $spreadInfo, $isFollow = 1)
    {
        $response = $this->transaction(function () use ($qrcodeInfo, $userInfo, $spreadInfo, $isFollow) {

            //绑定用户标签
            /** @var UserLabelRelationServices $labelServices */
            $labelServices = app()->make(UserLabelRelationServices::class);
            foreach ($qrcodeInfo['label_id'] as $item) {
                $labelArr[] = [
                    'uid' => $userInfo['uid'],
                    'label_id' => $item['id'] ?? $item
                ];
            }
            $labelServices->saveAll($labelArr);

            //增加二维码扫码数量
            $this->dao->upFollowAndScan($qrcodeInfo['id'], $isFollow);

            //写入扫码记录
            /** @var WechatQrcodeRecordServices $recordServices */
            $recordServices = app()->make(WechatQrcodeRecordServices::class);
            $data['qid'] = $qrcodeInfo['id'];
            $data['uid'] = $userInfo['uid'];
            $data['is_follow'] = $isFollow;
            $data['add_time'] = time();
            $recordServices->save($data);

            //回复信息内容
            return $this->replyDataByMessage($qrcodeInfo['type'], $qrcodeInfo['data']);
        });
        return $response;
    }

    /**
     * 发送扫码之后的信息
     * @param $type
     * @param $data
     * @return array|\EasyWeChat\Message\Image|\EasyWeChat\Message\News|\EasyWeChat\Message\Text|\EasyWeChat\Message\Voice
     */
    public function replyDataByMessage($type, $data)
    {
        if ($type == 'text') {
            return WechatService::textMessage($data['content']);
        } else if ($type == 'image') {
            return WechatService::imageMessage($data['media_id']);
        } else if ($type == 'news') {
            $title = $data['title'] ?? '';
            $image = $data['image'] ?? '';
            $description = $data['synopsis'] ?? '';
            $url = $data['url'] ?? '';
            return WechatService::newsMessage($title, $description, $url, $image);
        } else if ($type == 'url') {
            $title = $data['content'];
            $image = sys_config('h5_avatar');
            $description = $data['content'];
            $url = $data['content'];
            return WechatService::newsMessage($title, $description, $url, $image);
        } else if ($type == 'voice') {
            return WechatService::voiceMessage($data['media_id']);
        }
    }
}