<?php
declare(strict_types=1);

namespace App\Http\Mail\lib\client;

use App\Http\Mail\lib\MailParse\Body;


/**
 * imap协议直连服务器无需 imap扩展
 * @time 2022/8/5 14:17
 * Class Imap
 * @package App\Mail\lib\socket
 */
class Imap {

    /**
     * @var resource
     */
    private $socket;

    /**
     * ssl://imap.qq.com:993
     * @var string
     */
    private $host;
    private $username;
    private $password;

    /**
     * 请求时增加的tag
     * @var int
     */
    private $tagNum = 0;

    /**
     * 标签名称
     * @var string
     */
    private $tagName    =   'A';

    /**
     * imap服务器设置id 邮箱邮件服务器是必须的
     * @var string[]
     */
    private $imapId = [
        'name'  =>  '测试本地 Client',
        'version'   =>  '1',
        'os'    =>  '测试本地',
        'os-version'    =>  '1.0'
    ];

    /**
     * 超时时间
     * @var int
     */
    private $timeout = 30;

    /**
     * 搜索字段，标题，邮件主题
     */
    const SEARCH_FILED_SUBJECT = 'SUBJECT';

    /**
     * 搜索字段，发件人
     */
    const SEARCH_FILED_FROM = 'FROM';

    /**
     * 搜索字段，收件人
     */
    const SEARCH_FILED_TO = 'TO';

//    const SEARCH_FILED_SUBJECT = 'RFC822.TEXT';


    /**
     * 邮件便签
     * @var string[]
     */
    public $flags = [
        'SEEN'      => '\\Seen', // 已读
        'DELETED'   => '\\Deleted', //删除
        'ANSWERED'  => '\\Answered',//已回复
        'DRAFT'     => '\\Draft',//草稿
        'FLAGGED'   => '\\Flagged',//星标
        'FORWARDED' => '$Forwarded',
        'MDNSENT'   => '$MDNSent',
        '*'         => '\\*',
    ];

    /**
     * 已读 标记
     */
    const FLAGS_SEEN = 'SEEN';

    /**
     * 删除 标记
     */
    const FLAGS_DELETED = 'DELETED';

    /**
     * 已回复 标记
     */
    const FLAGS_ANSWERED = 'ANSWERED';

    /**
     * 草稿 标记
     */
    const FLAGS_DRAFT = 'DRAFT';

    /**
     * 星标 标记
     */
    const FLAGS_FLAGGED = 'FLAGGED';

    /**
     * 添加邮件标签
     */
    const FLAGS_APPEND = '+';

    /**
     * 删除邮件标签
     */
    const FLAGS_REMOVE = '-';


    /**
     * 是否自动关闭
     * @var bool
     */
    private $auto_colse = true;

    /**
     * 调试模式
     * @var bool
     */
    private $debug = false;

    /**
     * 调试，记录日志的目录
     * @var string
     */
    private $debugWritePath = '';

    /**
     * 登录imap服务器
     * @param string $host ssl://imap.qq.com:993  imap.qq.com:143
     * @param string $username 邮箱地址 xxxxx@xx.com
     * @param string $password 密码，此密码非邮箱登录密码，是imap服务器单独设置的密码
     * @param bool $readOnly 是否以只读模式打开邮箱
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 11:06
     */
    public function login(string $host,string $username,string $password,bool $readOnly=false){
        $this->host =   $host;
        $this->username =   $username;
        $this->password =   $password;

        // 查看服务器所支持的功能列表
//        $this->request('CAPABILITY');

        // 设置id，必须在登录前，163是强制的
        $strId = '';
        foreach ($this->imapId as $k=>$str){
            if(!is_array($str)){
                $strId .= '"'.str_replace(['"',"'"],'',$k).'" "'.str_replace(['"',"'"],'',$str).'" ';
            }
        }
//        "name" "测试本地 Client" "version" "1" "os" "测试本地" "os-version" "1.0"
        $this->request('ID ('.trim($strId).')');// 这里就不处理命令返回的信箱了

        // 登录
        $result = $this->request("LOGIN {$username} {$password}");

        //解析登录数据每个服务商返回的登录结果不一样，很难兼容
        if($result[0] != 'ok'){
            throw new \Exception('IMAP Login Error:'.end($result[1]));
        }

        // 是否是只读模式
        // 只读模式不可操作邮箱任何内容，只可查看
        if($readOnly){
            $this->request('EXAMINE '.$username);
        }

        return true;
    }


    /**
     * 退出当前操作的邮箱
     * 一般情况不需要
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 10:46
     */
    public function loginOut():bool {
        return $this->request('LOGOUT')[0] == 'ok';
    }

    /**
     * @param resource $socket
     */
    public function setSocket($socket,$auto_colse=true): void
    {
        $this->socket = $socket;
        // 是否自动关闭
        $this->auto_colse = $auto_colse;
    }


    /**
     * 删除带有delete标签的邮件，删除的邮件不可恢复。
     * 类似清空
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 10:55
     */
    public function clearDelete():bool {
        return $this->request('EXPUNGE')[0] == 'ok';
    }

    /**
     * [
    [EXISTS] => 67 总邮件数
    [RECENT] => 1 最新的邮件
    [UIDVALIDITY] => 1
    [FLAGS] => Array 此文件夹可以操控的标签
    (
    [0] => \Answered 回复
    [1] => \Seen 已读
    [2] => \Deleted 删除
    [3] => \Draft 草稿
    [4] => \Flagged 星标
    )

    [PERMANENTFLAGS] => Array
    (
    [0] => \Answered
    [1] => \Seen
    [2] => \Deleted
    [3] => \Draft
    [4] => \Flagged
    )
    ]
     * 选择文件夹
     * @param string $folder
     * @return array
     * @throws \Exception
     * @author：dc
     * @time 2022/11/22 16:28
     */
    public function selectFolder($folder='INBOX'){

        // 选择文件夹
        $result = $this->request("SELECT \"{$folder}\"");
        if($result[0] != 'ok'){
            throw new \Exception('select folder error:'.end($result[1]));
        }

        $list = [];
        foreach ($result[1] as $item){
            $item = trim($item);
            // 总数量
            if(preg_match("/^\* (\d+) EXISTS$/i",$item,$m)){
                $list['EXISTS'] = $m[1];
            }
            // 最近的
            elseif (preg_match("/^\* (\d+) RECENT$/i",$item,$m)){
                $list['RECENT'] = $m[1];
            }
            // 未读
            elseif (preg_match("/^\*.*\[UNSEEN (\d+)\]/i",$item,$m)){
                $list['UNSEEN'] = $m[1];
            }
            // tag
            elseif (preg_match("/^\* FLAGS \((.*)\)$/i",$item,$m)){
                $list['FLAGS'] = explode(' ',$m[1]);
            }
            // 其他
            elseif (preg_match("/^\*.*\[(.*)\]/i",$item,$m)){
//               是否有(),有小扩号就是数组
//               * OK [PERMANENTFLAGS (\* \Answered \Flagged \Deleted \Draft \Seen)] Permanent flags
                if(preg_match("/\((.*)\)/i",$item,$m2)){
                    $em = explode(' ',$m[1]);
                    $list[$em[0]] = explode(' ',$m2[1]);
                }else{
                    $em = explode(' ',$m[1]);
                    $list[$em[0]] = $em[1];
                }
            }
        }

        return $list;
    }

    /**
     * 关闭当前打开的文件夹，
     * 使用selectFolder后才可以使用此函数
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 10:40
     */
    public function closeFolder():bool{
        return $this->request('CLOSE')['0'] == 'ok';
    }

    /**
     * 搜索邮件，如果要获得列表，需要配合fetch使用
     * @param array $criteria 搜索[key=>value,...]
     * @param bool $return_uid 是否返回uid，默认返回邮件编号
     * @return array 返回的是搜索出来的uid，每个文件夹下面uid是唯一的
     * @throws \Exception
     * @author：dc
     * @time 2022/11/24 15:46
     */
    public function search(array $criteria,$return_uid = false):array{
        // 命令，是否返回uid
        $cmd = ($return_uid ? 'UID ' : '').'SEARCH';

        foreach ($criteria as $k=>$v){
            $v  =   addslashes($v);
            $cmd .= " {$k} \"{$v}\"";
        }

        // 获取搜索到的 uid
        $result = $this->request($cmd);

        if($result[0] != 'ok'){
            throw new \Exception('search error:'.end($result[1]));
        }

        $uids = [];
        foreach ($result[1] as $item){
            // 匹配uid
            if(preg_match("/^\* SEARCH ([0-9\s]{1,})$/i",$item,$m)){
                $uids = array_merge($uids,explode(' ',$m[1]));
            }
        }

        return $uids;
    }


    /**
     * 设置标签,删除标签
     * @param string|int|array $data 邮件的编号或者uid
     * @param array $flag 标记属性 [Imap::FLAGS_SEEN,..]
     * @param string $mod 删除或者添加 Imap::FLAGS_APPEND|Imap::FLAGS_REMOVE
     * @param bool $is_uid 是否使用uid进行标记
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/24 16:58
     */
    public function flags($data,array $flag,string $mod = self::FLAGS_APPEND,bool $is_uid = false):bool {

        if(is_array($data)){
            $data = implode(',',$data);
        }

        // flags 标记
        foreach ($flag as $k=>$item){
            if(!isset($this->flags[$item])){
                unset($flag[$k]);
            }else{
                $flag[$k] = $this->flags[$item];
            }
        }

        // 是否是规定中的值
        if(!in_array($mod,[self::FLAGS_APPEND,self::FLAGS_REMOVE])){
            throw new \Exception('set flags error: mod');
        }

        // 请求标记
        $result = $this->request(($is_uid?'UID ':'')."STORE {$data} {$mod}FLAGS.SILENT (".implode(' ',$flag).")");

        return $result[0] == 'ok';
    }

    /**
     * 获取邮箱所有文件夹
     * @return array
     * @throws \Exception
     * @author：dc
     * @time 2022/11/24 17:20
     */
    public function getFolder():array {
        // 获取数据
        $result = $this->request('LIST "" *');

        $folder = [];
        foreach ($result[1] as $item){
            // 解析源数据
            if(preg_match('/^\* LIST \(([\\a-z\s]{0,})\) "(.*)" "(.*)"/Ui',$item,$m)){
                $folder[] = [
                    'parent'    =>  $m[2],
                    // 源文件夹名称，在进行 select的时候必须用未解析的文件夹名称
                    'folder'    =>  $m[3],
                    // 解析过的文件夹名称
                    'parseFolder'    =>  mb_convert_encoding($m[3], 'UTF-8', 'UTF7-IMAP'),
                    // 是否可选择
                    'isSelect'  =>  strpos($m[1],'NoSelect')===false,
                ];
            }
        }

        return $folder;
    }

    /**
     * 创建文件夹
     * $folder 目录 创建二级目录用/  a/b
     * @param string $folder
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/24 23:35
     */
    public function folderCreate(string $folder):bool {
        // 需要转码
        $folder = mb_convert_encoding($folder,'UTF7-IMAP','UTF-8');
//        A003 CREATE owatagusiam 顶级
//        A003 CREATE owatagusiam/owatagusiam2 有上下级关系的文件夹
        $res = $this->request('CREATE '.$folder);

        if ($res[0] == 'ok'){
            return true;
        }

        throw new \Exception('create folder error:'.end($res[1]));

    }

    /**
     * 修改文件夹名称
     * @param string $oldFolder 久文件夹名称
     * @param string $newFolder 新文件夹名称
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 10:24
     */
    public function folderRename(string $oldFolder, string $newFolder){
        // 需要转码
        $newFolder  =   mb_convert_encoding($newFolder,'UTF7-IMAP','UTF-8');
//        RENAME oldfolder newfolder
        $res = $this->request("RENAME {$oldFolder} {$newFolder}");

        if ($res[0] == 'ok'){
            return true;
        }

        throw new \Exception('rename folder error:'.end($res[1]));
    }

    /**
     * 删除文件夹
     * @param string $folder
     * @return bool
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 10:25
     */
    public function folderDelete(string $folder):bool{

//        A683 DELETE blurdybloop/test
        $res = $this->request('DELETE '.$folder);

        if ($res[0] == 'ok'){
            return true;
        }

        throw new \Exception('rename folder error:'.end($res[1]));

    }


    /**
     * 获取邮件头，并解析
     * @param $data
     * @param false $is_uid
     * @return array
     * @throws \Exception
     * @author：dc
     * @time 2022/11/23 14:25
     */
    public function fetchHeader($data,$is_uid = false){
        $result = $this->fetch($data,'header',$is_uid);
        // 解析header字段
        foreach ($result as $key=>$item){
            $result[$key]['HEADER.FIELDS'] = $this->parseHeader($item['HEADER.FIELDS']);
        }

        return $result;

    }

    /**
     * 解析header字段
     * @param $header
     * @return array
     * @author：dc
     * @time 2022/11/23 14:54
     */
    public function parseHeader($header){
        /****** 把数据中的 : 转换一下 *******/
        $header = explode("\n",$header);
        foreach ($header as $k=>$str){
            $first_str = '';
            if(substr_count($str,':') > 1){
                $str = explode(':',$str);
                $first_str = $str[0];
                if($first_str){
                    unset($str[0]);
                }
                $str = implode('_(_(_(_0_)_)_)_',$str);
                if($first_str) $str = $first_str.':'.$str;
            }
            $header[$k] = empty($first_str) ? $str : ltrim($str);
        }
        $header = implode("\n",$header);
        /******end*******/

        preg_match_all(
            "/^([^\r\n:]+)\s*[:]\s*([^\r\n:]+(?:[\r]?[\n][ \t][^\r\n]+)*)/m",
            $header,
            $matches,
            PREG_SET_ORDER
        );
        $headers = [];
        foreach($matches as $match){
            $match[2] = str_replace(['_(_(_(_0_)_)_)_'],[':'],$match[2]);
            if(strpos($match[2],'=?')!==false){
                $match2=iconv_mime_decode($match[2],ICONV_MIME_DECODE_CONTINUE_ON_ERROR,'utf-8');
                $match[2]   =   $match2;
            }

            if(isset($headers[$match[1]]) && is_array($headers[$match[1]])){
                $headers[$match[1]][]=$match[2];
            }elseif(isset($headers[$match[1]])){
                $headers[$match[1]]=array($headers[$match[1]],$match[2]);
            }else{
                $headers[$match[1]]=$match[2];
            }
        }
        return $headers;

    }


    /**
     * 获取邮件内容，包括附件
     * @param mixed $data 1，1:10,[1,2,3]
     * @param string $saveFilePath 保存附件的目录
     * @param bool $is_uid 是否是UID查询
     * @throws \Exception
     * @author：dc
     * @time 2022/11/23 17:01
     */
    public function fetchBody($data,$saveFilePath=__DIR__,$is_uid = false){
        // 取得body
        $result = $this->fetch($data,'body',$is_uid);
        foreach ($result as &$item){
            if (!empty($item['RFC822.TEXT'])){
                // 解析
                $item['RFC822.TEXT'] = (new Body($item['RFC822.TEXT'],$saveFilePath))->getItem();
            }
        }

        return $result;
    }



    /**
     * @param $data
     * @param false $is_uid
     * @return array
     * @throws \Exception
     * @author：dc
     * @time 2022/11/23 10:46
     */
    public function fetch($data,$header2Body='header',$is_uid = false):array{
        // string 必须是 0:99  开始:结束
        if(is_numeric($data)){
            $data = intval($data);
        }
        elseif(is_string($data)){
            if(!preg_match("/^\d+:\d+$/",$data)){
                $data = '';
            }
        }elseif (is_array($data)){
            foreach ($data as $k=>$v){
                if(!is_numeric($v)){
                    unset($data[$k]);
                }
            }
            $data = array_unique(array_values($data));
            $data = implode(',',$data);
        }

        if(empty($data)){
            throw new \Exception('fetch data error');
        }

        // (UID RFC822.SIZE RFC822.HEADER FLAGS INTERNALDATE BODYSTRUCTURE BODY.PEEK[HEADER.FIELDS (DATE FROM TO SUBJECT CONTENT-TYPE CC REPLY-TO LIST-POST DISPOSITION-NOTIFICATION-TO X-PRIORITY CONTENT-TRANSFER-ENCODING BCC IN-REPLY-TO MAIL-FOLLOWUP-TO MAIL-REPLY-TO MESSAGE-ID REFERENCES RESENT-BCC RETURN-PATH SENDER X-DRAFT-INFO)])
        // 指定字段 BODY.PEEK[HEADER.FIELDS (DATE FROM TO ...)]
        // 所有header字段 RFC822.HEADER
        // RFC822.TEXT 内容包括附件
        // body字段必须放最后
        if($header2Body=='header'){
//            BODY.peek必须放最后
            $filed = 'UID FLAGS INTERNALDATE RFC822.SIZE BODYSTRUCTURE BODY.PEEK[HEADER.FIELDS (DATE FROM TO SUBJECT CONTENT-TYPE CC REPLY-TO LIST-POST DISPOSITION-NOTIFICATION-TO X-PRIORITY CONTENT-TRANSFER-ENCODING BCC IN-REPLY-TO MAIL-FOLLOWUP-TO MAIL-REPLY-TO MESSAGE-ID REFERENCES RESENT-BCC RETURN-PATH SENDER X-DRAFT-INFO)]';
        }elseif($header2Body=='body'){
            $filed = 'RFC822.TEXT';
        }else{
            $filed = 'UID FLAGS INTERNALDATE';
        }

        // 读取数据
        $result = $this->request(($is_uid?'UID ':'')."FETCH {$data} ($filed)");

        if($result[0] != 'ok'){
            throw new \Exception('fetch error:'.end($result[1]));
        }

        // 开始解析数据
        $list = [];
        foreach ($result[1] as $item){
            $item = trim($item);
            // 匹配出id和数据
            if(preg_match("/\* (\d+) FETCH \(([\w\s\d\r\n\W]{1,})\)$/i",$item,$line)){
                $list[$line[1]] = $this->parseFetch($line[2]);
            }
        }

        // 返回结果
        return $list;

    }

    /**
     * 解析头部信息，只能解析固定字段的属性
     * @param string $line
     * @return array
     * @author：dc
     * @time 2022/11/22 18:06
     */
    public function parseFetch($line):array{
        $result = [];
        $line = ltrim($line);
        $header = explode(' ',$line);
        do{

            switch ($header[0]){
                case 'UID':{
                    $result['UID'] = $header[1];
                    array_splice($header,0,2);
                    break;
                }
                case 'FLAGS':{
                    // 标记，标签
                    $result['FLAGS'] = $this->pregFiled(
                        $header,
                        "/^\(([\\a-z\s]{0,})\)/Ui"
                    );
                    $result['FLAGS'] = $result['FLAGS'] ? explode(' ',$result['FLAGS']) : [];
                    break;
                }
                case 'INTERNALDATE':{
                    // 内部时间
                    $result['INTERNALDATE'] = $this->pregFiled(
                        $header,
                        "/^\"([\\a-z\d\s]{0,})\"/Ui"
                    );
                    break;
                }
                case 'RFC822.SIZE':{
                    $result['RFC822.SIZE'] = $header[1];
                    array_splice($header,0,2);
                    break;
                }
                case 'BODYSTRUCTURE':{
                    array_shift($header);
                    $result['BODYSTRUCTURE']    =   '';
                    $leftNum = $RightNum = 0;
                    foreach ($header as $key=>$str){
                        // 还有括号不对等的情况，无语了
                        if($str == 'BODY[HEADER.FIELDS'){
                            break;
                        }
                        // 找出现的次数
                        $leftNum += substr_count($str,'(');
                        $RightNum += substr_count($str,')');
                        // 拼接起来
                        $result['BODYSTRUCTURE'] .= ' '.$str;
                        unset($header[$key]);
                        // 说明找到结束了
                        if($leftNum===$RightNum){
                            break;
                        }
                    }
                    $header = array_values($header);
                    break;
                }
                // RFC822.TEXT不能和 BODY[HEADER.FIELDS 同时存在，否则解析失败
                case 'RFC822.TEXT':{
                    array_shift($header);
                    $result['RFC822.TEXT'] = implode(' ',$header);
                    $header = [];
                    break;
                }
                case 'RFC822.HEADER':{
                    array_shift($header);
                    $result['RFC822.HEADER'] = implode(' ',$header);
                    $header = [];
                    break;
                }
                case 'BODY[HEADER.FIELDS':{
                    // header
                    $header = implode(' ',$header);
                    preg_match("/^BODY\[HEADER.FIELDS.*\]/Ui",$header,$m);
                    // 结果,提出掉字段字符
                    $result['HEADER.FIELDS'] = ltrim(mb_substr($header,mb_strlen($m[0]),mb_strlen($header)));
                    $header = [];//表示结束了
                    break;
                }
                default:{
                    array_shift($header);
                    break;
                }
            }
        }while($header);

        return $result;
    }

    /**
     * 匹配字段中的值
     * @param $header
     * @param $preg
     * @return mixed|string
     * @author：dc
     * @time 2022/11/23 14:38
     */
    private function pregFiled(&$header,$preg){
        array_shift($header);
        // 组成字符串
        $header = implode(' ',$header);
        // 找flags,非贪婪模式
        if(preg_match($preg,$header,$m)){
            $header = mb_substr($header,mb_strlen($m[0]),mb_strlen($header));
        }
        // 打散成数组
        $header =   explode(' ',$header);

        return $m[1]??'';
    }

    /**
     * imap服务器设置的id
     * @param array|string $id
     * @author：dc
     * @time 2022/11/22 11:53
     */
    public function setImapId($id){
        if(is_array($id)){
            $this->imapId = array_merge($this->imapId,$id);
        }else{
            $this->imapId['name'] = $id;
        }
    }


    /**
     * 打开socket链接
     * @param int $timeout
     * @throws \Exception
     * @author：dc
     * @time 2022/11/22 14:13
     */
    private function socketOpen(int $timeout = 30){
        if(!is_resource($this->socket)){
            $this->timeout = $timeout ? : 30;
            // 链接服务器
            $this->socket = stream_socket_client($this->host, $errno, $error, $this->timeout);

            if($error){
                throw new \Exception("socket error: {$error}");
            }

            if (!$this->socket) {
                throw new \Exception("{$this->host} connection fail.");
            }

            stream_set_timeout($this->socket, $this->timeout);
        }else{
            // 是否超时，超时关闭
            $meta = stream_get_meta_data($this->socket);
            if (isset($meta['timed_out']) && $meta['timed_out'] !== false) {
                $this->socketClose();
                // 重新链接
                $this->socketOpen();
            }
        }
    }


    /**
     * 最后一次执行时候的tag
     * @return string
     * @author：dc
     * @time 2022/11/22 13:54
     */
    protected function getLastTag(){
        return sprintf('%s%d', $this->tagName, $this->tagNum);
    }

    /**
     * 获取下一次执行的tag
     * @return string
     * @author：dc
     * @time 2022/11/22 13:52
     */
    protected function getNextTag(){
        $this->tagNum   +=  1;
        return sprintf('%s%d', $this->tagName, $this->tagNum);
    }

    /**
     * 向服务器发送一个noop消息，表示什么也不做，
     * 只是用来保持通信，避免长久没有操作，丢失掉连接
     * @throws \Exception
     * @author：dc
     * @time 2022/11/25 11:15
     */
    public function noop():void {
        $this->request('NOOP');
    }

    /**
     * debug模式
     * @param bool $debug
     * @param string $logPath
     * @author：dc
     * @time 2022/12/6 11:10
     */
    public function debug($debug=true,$logPath=''){
        $this->debug = $debug;
        $this->debugWritePath = $logPath;
    }

    /**
     * 记录日志
     * @param string $message
     * @author：dc
     * @time 2022/12/6 11:13
     */
    private function log(string $message){
        if($this->debug){
            if(!is_dir($this->debugWritePath)){
                @mkdir($this->debugWritePath,0775,true);
            }
            @file_put_contents($this->debugWritePath.'/imap.log',date('Y-m-d H:i:s  ').$message.PHP_EOL,FILE_APPEND);
        }
    }

    /**
     * 获取数据集
     * @param $cmd
     * @return array
     * @throws \Exception
     * @author：dc
     * @time 2022/11/22 11:41
     */
    public function request($cmd){
        // 链接
        $this->socketOpen();

        $tag = $this->getNextTag();

        // 命令行必须要结束换行
        $cmd = trim($tag.' '.$cmd);

        // 记录日志
        $this->log($cmd);

        // 写入数据
        $r = fwrite($this->socket, $cmd."\r\n");
        if (!$r) {
            $this->socketClose();
            throw new \Exception("request error write");
        }

        // 读取数据
        $result =   []; // 返回数据
        $status = 'no'; // 状态
        $i = 1;
        while ($i) {
            $append = false;// 是否追加到上一个元素值里面
            // 这里不指定长度，读取一行
            $line = @fgets($this->socket);
            if ($line === false || !mb_strlen($line)) {
                $end = true;
            }else{


                // 是否有其他的固定串
                preg_match("/\{(\d+)\}\r\n$/",$line,$number);
                if($number[1]??0){
                    // 获取到固定字符串
                    $appendLine = fread($this->socket, intval($number[1]));
                    // 替换 {123}
                    $line   =   str_replace($number[0],$appendLine,$line);
                }

                // 记录日志
                $this->log($line);

                // 是否结束了,到了最后一行
                if(strpos($line,$tag.' ') === 0){
                    $end = true;
                    $status = strtolower(explode(' ',$line)[1]??'');
                    // 脚本异常
                    if($status == 'bad'){
                        throw new \Exception('request bad:'.$line);
                    }
                }else{
                    if(strpos($line,'* ') !==0 ){
                        $append = true;
                    }
                }

                // 结果数组
                if($append){
                    $result[$i-1] .= $line;
                }else{
                    $result[$i] = $line;
                    $i++;
                }

            }
            // 结束了
            if(!empty($end)){
                $i = false;
            }
        }

//        print_r($result);

        return [$status,$result];

    }

    /**
     * 是否读取结束
     * @return bool
     * @author：dc
     * @time 2022/11/22 14:14
     */
    protected function socketEof()
    {
        if (!is_resource($this->socket)) {
            return true;
        }

        // If a connection opened by fsockopen() wasn't closed
        // by the server, feof() will hang.
        $start = microtime(true);

        if (feof($this->socket) ||
            ($this->timeout && (microtime(true) - $start > $this->timeout))
        ) {
            $this->socketClose();
            return true;
        }

        return false;
    }

    /**
     * 关闭socket链接
     * @author：dc
     * @time 2022/11/22 10:45
     */
    protected function socketClose(){
        if(is_resource($this->socket)){
            fclose($this->socket);
        }
        $this->socket   =   false;
    }




    public function __construct()
    {
    }

    public function __destruct()
    {
        if($this->auto_colse){
            //        echo '关闭';
            // TODO: Implement __destruct() method.
            $this->socketClose();
        }

    }



}