mp_audio_manage/app/Libs/Helpers.php

<?php

use GuzzleHttp\Client;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;
use OSS\OssClient;
use OSS\Core\OssException;

use Tos\TosClient;
use Tos\Exception\TosClientException;
use Tos\Exception\TosServerException;
use Tos\Model\PutObjectInput;
// use Imagick;

/**
 * 截取字符串
 *
 * @param      $string
 * @param      $length
 * @param bool $append
 * @return array|string
 */
function sysSubStr($string, $length, $append = false)
{
    if (strlen($string) <= $length) {
        return $string;
    }

    $i          = 0;
    $stringLast = [];
    while ($i < $length) {
        $stringTMP = mb_substr($string, $i, 1);
        if (ord($stringTMP) >= 224) {
            $stringTMP = mb_substr($string, $i, 3);
            $i         += 3;
        } elseif (ord($stringTMP) >= 192) {
            $stringTMP = mb_substr($string, $i, 2);
            $i         += 2;
        } else {
            ++$i;
        }
        $stringLast[] = $stringTMP;
    }
    $stringLast = implode('', $stringLast);
    if ($append) {
        $stringLast .= '...';
    }
    return $stringLast;
}

/**
 * 自定义日志
 *
 * @param        $name
 * @param string $filename
 * @return \Illuminate\Log\Writer
 */
function myLog($name, $filename = '')
{
    if (!$filename) {
        $filename = $name;
    }
    $filename = $filename . '.log';
    $logger   = new Logger($name);
    $writer   = new \Illuminate\Log\Writer($logger);
    $writer->useDailyFiles(storage_path('logs/' . $filename));
    return $writer;
}

/**
 * 业务调试日志
 *
 * @return Logger
 */
function commonLog()
{
    $name     = 'common';
    $filename = $name . '.log';
    $logger   = new Logger($name);
    $logger->pushHandler(new StreamHandler(storage_path('logs/' . $filename), 'debug'));

    return $logger;
}

/**
 * @param $name
 * @return Logger
 */
function dLog($name)
{
    $filename = $name . '-' . date('Y-m-d') . '.log';
    $logger   = new Logger($name);
    $logger->pushHandler(new StreamHandler(storage_path('logs/' . $filename), 'debug'));

    return $logger;
}

/**
 * 获取对象或数组的属性值
 *
 * @param        $param
 * @param        $key
 * @param string $default
 * @return mixed|string
 */
function getProp($param, $key, $default = '')
{
    $result = $default;
    if (is_object($param) && isset($param->$key)) {
        $result = $param->$key;
    }

    if (is_array($param) && isset($param[$key])) {
        $result = $param[$key];
    }

    return $result;
}

/**
 * @param       $data
 * @param array $trans
 * @return array
 */
function assetData($data, $trans = []): array
{
    $result = [];
    if (empty($data)) {
        return $result;
    }

    if (empty($trans)) {
        return $data;
    }

    foreach ($trans as $tran) {
        [$originKey, $newKey, $conv, $default] = [$tran['o'], $tran['n'], $tran['conv'], $tran['default']];
        if (isset($data[$originKey])) {
            $result[$newKey] = $conv(getProp($data, $originKey, $default));
        }
    }

    return $result;
}

/**
 * 随机数
 *
 * @param int $num
 * @return string
 * @throws Exception
 */
function random($num = 16)
{
    $bytes = random_bytes($num);
    return bin2hex($bytes);
}

/**
 * 生成订单
 *
 * @param string $prefix 订单前缀
 * @return string
 */
function generateOrderSn($prefix = '')
{
    return $prefix . date('YmdHis') . getMillisecond() . rand(1000, 9999);
}

/**
 * 分页数据
 *
 * @param $data
 * @return array
 */
function getMeta($data)
{
    $currentPage = (int)$data->currentPage();
    $lastPage    = (int)$data->lastPage();
    return [
        'current_page'  => $currentPage,
        'next_page'     => $currentPage >= $lastPage ? $lastPage : ++$currentPage,
        'last_page'     => $lastPage,
        'per_page'      => (int)$data->perPage(),
        'total'         => (int)$data->total(),
        'is_end'        => !$data->hasMorePages(),
        'next_page_url' => (string)$data->nextPageUrl(),
        'prev_page_url' => (string)$data->previousPageUrl()
    ];
}

/**
 * 钉钉通知异常
 *
 * @param $message
 */
function sendNotice($message)
{
    $webHook = env('DD_WEB_HOOK');
    $data    = [
        'msgtype' => 'text',
        'text'    => [
            'content' => $message
        ],
        'at'      => [
            'isAll' => true
        ]
    ];

    // 异步发送
    $client = new GuzzleHttp\Client();
    $client->post($webHook, ['json' => $data]);
}

/**
 * 判断数据是合法的json数据
 *
 * @param $string
 * @return bool
 */
function is_json($string)
{
    json_decode($string);
    return (json_last_error() == JSON_ERROR_NONE);
}

/**
 * 获取ip地址
 *
 * @return mixed|string
 */
function getIpAddr()
{
    $ipaddress = '';
    if (isset($_SERVER['HTTP_CLIENT_IP']))
        $ipaddress = $_SERVER['HTTP_CLIENT_IP'];
    else if (isset($_SERVER['HTTP_X_FORWARDED_FOR']))
        $ipaddress = $_SERVER['HTTP_X_FORWARDED_FOR'];
    else if (isset($_SERVER['HTTP_X_FORWARDED']))
        $ipaddress = $_SERVER['HTTP_X_FORWARDED'];
    else if (isset($_SERVER['HTTP_FORWARDED_FOR']))
        $ipaddress = $_SERVER['HTTP_FORWARDED_FOR'];
    else if (isset($_SERVER['HTTP_FORWARDED']))
        $ipaddress = $_SERVER['HTTP_FORWARDED'];
    else if (isset($_SERVER['REMOTE_ADDR']))
        $ipaddress = $_SERVER['REMOTE_ADDR'];
    else
        $ipaddress = 'UNKNOWN';
    return $ipaddress;
}

/**
 * @param int $num
 * @return bool|string
 * @throws Exception
 */
function randStr($num = 5)
{
    $str = 'QWERTYUIOPASDFGHJKLZXCVBNM1234567890qwertyuiopasdfghjklzxcvbnm';
    return substr(str_shuffle($str), random_int(0, strlen($str) - 11), $num);
}

/**
 * 上传文件(火山云tos)
 *
 * @param $prefix   文件夹前缀
 * @param $file     文件二进制
 * @param $filename 文件名(不带后缀)
 * @return mixed
 */
function uploadFileByTos($prefix, $file, $filename='')
{
    if (!$filename) $filename = randStr(10) . '.' . $file->getClientOriginalExtension();
    else $filename = $filename . '.' . $file->getClientOriginalExtension();

    try {
        $client = new TosClient([
            'region'    => env('VOLC_REGION'),
            'endpoint'  => env('VOLC_END_POINT'),
            // 'ak'        => env('VOLC_AK'),
            // 'sk'        => env('VOLC_SK'),
            'ak'        => 'AKLTNDRjMzdiODkwMThhNDdhZThhOTI3MDg5MDkzYzExNTg',
            'sk'        => 'TXpOak4yWmxZemxrTVRVMU5EZzVNMkprT0dJMU9HSTBaR1kzWW1NMk5qaw==',
        ]);
        
        $stream = fopen($file->getRealPath(), 'r');

        $input = new PutObjectInput(env('VOLC_BUCKET'),  "$prefix/$filename", $stream);
        $output = $client->putObject($input);
        if ($output->getRequestId()) {
            return "https://".env('VOLC_BUCKET').'.'.env('VOLC_END_POINT')."/$prefix/$filename";
        }
    } catch (TosClientException $ex) {
        dLog('exception')->info('saveToTos', [$ex->getMessage()]);
    } catch (TosServerException $ex) {
        dLog('exception')->info('saveToTos', [$ex->getRequestId(), $ex->getStatusCode(), $ex->getErrorCode()]);
    }

    return '';
}

/**
 * 上传文件流(火山云tos)
 *
 * @param $prefix   文件夹前缀
 * @param $file     文件二进制
 * @param $filename 文件名(带后缀)
 * @return mixed
 */
function uploadStreamByTos($prefix, $stream, $filename)
{
    try {
        $client = new TosClient([
            'region'    => env('VOLC_REGION'),
            'endpoint'  => env('VOLC_END_POINT'),
            // 'ak'        => env('VOLC_AK'),
            // 'sk'        => env('VOLC_SK'),
            'ak'        => 'AKLTNDRjMzdiODkwMThhNDdhZThhOTI3MDg5MDkzYzExNTg',
            'sk'        => 'TXpOak4yWmxZemxrTVRVMU5EZzVNMkprT0dJMU9HSTBaR1kzWW1NMk5qaw==',
        ]);

        $input = new PutObjectInput(env('VOLC_BUCKET'),  "$prefix/$filename", $stream);
        $output = $client->putObject($input);
        if ($output->getRequestId()) {
            return "https://".env('VOLC_BUCKET').'.'.env('VOLC_END_POINT')."/$prefix/$filename";
        }
    } catch (TosClientException $ex) {
        dLog('exception')->info('saveToTos', [$ex->getMessage()]);
    } catch (TosServerException $ex) {
        dLog('exception')->info('saveToTos', [$ex->getRequestId(), $ex->getStatusCode(), $ex->getErrorCode()]);
    }

    return '';
}

// 从图片内容获取图片扩展名
function getExtFromContent(string $url): ?string {
    $imageInfo = @getimagesize($url);
    if ($imageInfo !== false) {
        // 返回MIME类型
        return mimeToExt($imageInfo['mime']);
        // 或者返回文件扩展名
        // return image_type_to_extension($imageInfo[2], false);
    }

    return null;
}

// 辅助 MIME 映射函数
function mimeToExt(string $mime): ?string {
    $map = [
        'audio/wav'                    => '.wav',
        'audio/x-ms-wma'               => '.wma',
        'video/x-ms-wmv'               => '.wmv',
        'video/mp4'                    => '.mp4',
        'audio/mpeg'                   => '.mp3',
        'audio/amr'                    => '.amr',
        'application/vnd.rn-realmedia' => '.rm',
        'audio/mid'                    => '.mid',
        'image/bmp'                    => '.bmp',
        'image/gif'                    => '.gif',
        'image/png'                    => '.png',
        'image/tiff'                   => '.tiff',
        'image/jpeg'                   => '.jpg',
        'application/pdf'              => '.pdf',
    ];
    return $map[$mime] ?? null;
}


/**
 * 上传文件(阿里云oss)
 *
 * @param $prefix   文件夹前缀
 * @param $file     文件二进制
 * @param $filename 文件名(不带后缀)
 * @return mixed
 */
function uploadFile($prefix, $file, $filename='')
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');

    if (!$filename) $filename = randStr(10) . '.' . $file->getClientOriginalExtension();
    else $filename = $filename . '.' . $file->getClientOriginalExtension();
    // 设置文件名称。
    $object = env('OSS_DIRECTORY') . '/' . $prefix . '/' . $filename;
    $provider = new \OSS\Credentials\StaticCredentialsProvider($accessKeyId, $accessKeySecret);

    try {
        $configs = [
            "provider" => $provider,
            "endpoint" => $endpoint,
            "signatureVersion" => 'v4',
            "region" => "cn-hangzhou"
        ];

        $ossClient = new OssClient($configs);
        $uploadRes = $ossClient->uploadFile($bucket, $object, $file->path());
    } catch (OssException $e) {
        dLog('exception')->info('saveImageToOss', [$e->getMessage()]);
        return '';
    }

    // 替换域名
    if (!isset($uploadRes['oss-request-url'])) return '';
    $url = str_ireplace('zw-ai.oss-cn-hangzhou.aliyuncs.com', 'cdn-zwai.ycsd.cn', $uploadRes['oss-request-url']);
    $url = urldecode($url);
    return str_ireplace('http://', 'https://', $url);
}

/**
 * 上传文件流(阿里云oss)
 *
 * @param $prefix   文件夹前缀
 * @param $file     文件二进制
 * @param $filename 文件名(带后缀)
 * @return mixed
 */
function uploadStreamToOss($prefix, $stream, $filename) {
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');

    // if (!$filename) $filename = randStr(10) . '.' . $file->getClientOriginalExtension();
    // 设置文件名称。
    $object = env('OSS_DIRECTORY') . '/' . $prefix . '/' . $filename;
    $provider = new \OSS\Credentials\StaticCredentialsProvider($accessKeyId, $accessKeySecret);

    try{
        $configs = [
            "provider" => $provider,
            "endpoint" => $endpoint,
            "signatureVersion" => 'v4',
            "region"=> "cn-hangzhou"
        ];

        $ossClient = new OssClient($configs);
        $uploadRes = $ossClient->putObject($bucket, $object, $stream);

    } catch (OssException $e) {
        dLog('exception')->info('saveImageToOss', [$e->getMessage()]);
        return '';
    }

    // 替换域名
    if (!isset($uploadRes['oss-request-url'])) return '';
    $url = str_ireplace('zw-ai.oss-cn-hangzhou.aliyuncs.com', 'cdn-zwai.ycsd.cn', $uploadRes['oss-request-url']);
    $url = urldecode($url);
    return str_ireplace('http://', 'https://', $url);
}

/**
 * 下载文件到本地
 *
 * @param $object
 * @param $localFile
 * @return string
 */
function downloadFile($object, $localFile)
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');

    try {
        $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
        $ossClient->getObject($bucket, $object, [
            OssClient::OSS_FILE_DOWNLOAD => $localFile
        ]);
    } catch (OssException $e) {
        printf($e->getMessage());
        return '';
    }
}

/**
 * 上传封面
 *
 * @param $file
 * @return string
 * @throws Exception
 */
function uploadCoverFile($file)
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');

    // 设置文件名称。
    $object = 'books/cover/' . randStr(10) . '.' . $file->getClientOriginalExtension();

    try {
        $ossClient      = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
        $ossImgBackData = $ossClient->uploadFile($bucket, $object, $file->path());
    } catch (OssException $e) {
        printf($e->getMessage());
        return '';
    }

    $urlArr = parse_url($ossImgBackData['oss-request-url']);
    return getProp($urlArr, 'path') ? 'http://' . $bucket . '.' . $endpoint . getProp($urlArr, 'path') : '';
}

function uploadAgreementFile($file)
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');

    $file_name = $file->getClientOriginalName();
    $file_name = str_replace('.' . $file->getClientOriginalExtension(), '', $file_name);

    // 设置文件名称。
    $object = 'books/contract/' . $file_name . '-' . date('YmdHi') . '.' . $file->getClientOriginalExtension();

    try {
        $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);

        $ossImgBackData = $ossClient->uploadFile($bucket, $object, $file);
    } catch (OssException $e) {
        printf($e->getMessage());
        return '';
    }

    $urlArr = parse_url($ossImgBackData['oss-request-url']);
    return getProp($urlArr, 'path') ? 'http://' . $bucket . '.' . $endpoint . urldecode(getProp($urlArr, 'path')) : '';
}

/**
 * 上传wap推荐图片
 *
 * @param $file
 * @param $filename
 * @return string
 * @throws Exception
 */
function uploadWapRecommendPic($file, $filename)
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET_YCSD');

    // 设置文件名称。
    $object = 'ycsd_web_3nd/images/homebanners/' . $filename . '.' . $file->getClientOriginalExtension();

    try {
        $ossClient      = new OssClient($accessKeyId, $accessKeySecret, $endpoint);
        $options        = array(
            OssClient::OSS_HEADERS => array(
                'Content-Type'        => 'image/jpeg',
                'Content-Disposition' => 'inline'
            ),
        );
        $ossImgBackData = $ossClient->uploadFile($bucket, $object, $file->path(), $options);
    } catch (OssException $e) {
        printf($e->getMessage());
        return '';
    }

    $urlArr = parse_url($ossImgBackData['oss-request-url']);
    return getProp($urlArr, 'path') ? 'http://' . $bucket . '.' . $endpoint . getProp($urlArr, 'path') : '';
}

/**
 * @param $path
 * @return Generator
 */
function readFileContent($path)
{
    if ($handle = fopen($path, 'r')) {
        while (!feof($handle)) {
            yield trim(fgets($handle));
        }
        fclose($handle);
    }
}

function exportFileCsv(array $headers, array $data, string $filename)
{
    header("Content-type:application/vnd.ms-excel");
    header("Content-Disposition:attachment;filename=" . $filename . ".csv");
    $headers = collect($headers)->map(function ($item) {
        return "\"" . mb_convert_encoding($item, "GBK", "UTF-8") . "\"";
    })->all();
    echo implode(",", $headers);
    echo "\r\n";
    foreach ($data as $item) {
        $rows = collect($item)->map(function ($row) {
            return "\"" . mb_convert_encoding(is_numeric($row) && strlen($row) > 12 ? "'" . $row : $row, "GBK", "UTF-8") . "\"";
        })->all();
        echo implode(",", $rows);
        echo "\r\n";
    }
    exit();
}

//function exportFileCsv(array $header, array $data, string $filename) {
//    header('Content-Encoding: UTF-8');
//    header("Content-type:application/vnd.ms-excel;charset=UTF-8");
//    header('Content-Disposition: attachment;filename="' . $filename . '.csv"');
//
//    //打开php标准输出流
//    $fp = fopen('php://output', 'a');
//
//    //添加BOM头，以UTF8编码导出CSV文件，如果文件头未添加BOM头，打开会出现乱码。
//    fwrite($fp, chr(0xEF).chr(0xBB).chr(0xBF));
//    //添加导出标题
//    fputcsv($fp, $header);
//
//    foreach ($data as $k => $item) {
//        fputcsv($fp, $item);
//        if ($k % 5000 == 0) {
//            //每1万条数据就刷新缓冲区
//            ob_flush();
//            flush();
//        }
//    }
//    exit();
//}

//function exportFileCsv(array $header, array $data, string $filename) {
//
//    header('Content-Type: application/vnd.ms-excel');
//    header('Content-Disposition: attachment;filename="'.$filename.'.csv"');
//    header('Cache-Control: max-age=0');
//
//    //打开PHP文件句柄,php://output 表示直接输出到浏览器
//    $fp = fopen('php://output', 'a');
//
//    //输出Excel列名信息
//    foreach ($header as $key => $value) {
//        //CSV的Excel支持GBK编码，一定要转换，否则乱码
//        $header[$key] = iconv('utf-8', 'gbk', $value);
//    }
//
//    //将数据通过fputcsv写到文件句柄
//    fputcsv($fp, $header);
//
//    //计数器
//    $num = 0;
//
//    //每隔$limit行，刷新一下输出buffer，不要太大，也不要太小
//    $limit = 10000;
//
//    //逐行取出数据，不浪费内存
//    $count = count($data);
//    for ($i = 0; $i < $count; $i++) {
//
//        $num++;
//
//        //刷新一下输出buffer，防止由于数据过多造成问题
//        if ($limit == $num) {
//            ob_flush();
//            flush();
//            $num = 0;
//        }
//
//        $row = $data[$i];
//        foreach ($row as $key => $value) {
//            $row[$key] = iconv('utf-8', 'gbk', $value);
//        }
//
//        fputcsv($fp, $row);
//    }
//    exit();
//}

// 获取除空格外的字数
function getSize(string $content)
{
    $content = preg_replace('/\s+/', '', $content);
    return mb_strlen($content, 'utf-8');
}

// 获取word字符数(不计空格)
function getChargeSize(string $content)
{
    //判断是否存在替换字符
    $is_replace_count = substr_count($content, "龘");
    try {
        //先将回车换行符做特殊处理
        $str = preg_replace('/(\r\n+|\s+|　+)/', "龘", $content);
        //处理英文字符数字，连续字母、数字、英文符号视为一个单词
        $str = preg_replace('/[a-z_A-Z0-9-\.!@#\$%\\\^&\*\)\(\+=\{\}\[\]\/",\'<>~`\?:;|]/', "m", $str);
        //合并字符m，连续字母、数字、英文符号视为一个单词
        $str = preg_replace('/m+/', "*", $str);
        //去掉回车换行符
        $str = preg_replace('/龘+/', "", $str);
        //返回字数
        return mb_strlen($str) + $is_replace_count;
    } catch (\Exception $e) {
        return 0;
    }
}

// 将阿拉伯数字转换成中文
function chineseNum($figure, $capital = false, $mode = true)
{
    if ($figure == '0') return '零';
    $numberChar = ['零', '一', '二', '三', '四', '五', '六', '七', '八', '九'];
    $unitChar   = ['', '十', '百', '千', '', '万', '亿', '兆', '京', '垓', '秭', '穣', '沟', '涧', '正', '载', '极', '恒河沙', '阿僧祇', '那由他', '不可思议', '无量大数'];
    if ($capital !== false) {
        $numberChar = ['零', '壹', '贰', '叁', '肆', '伍', '陆', '柒', '捌', '玖'];
        $unitChar   = ['', '拾', '佰', '仟', '', '万', '亿', '兆', '京', '垓', '秭', '穣', '沟', '涧', '正', '载', '极', '恒河沙', '阿僧祇', '那由他', '不可思议', '无量大数'];
    }

    $dec     = "点";
    $target  = '';
    $matches = [];

    if ($mode) {
        preg_match("/^0*(\d*)\.?(\d*)/", $figure, $matches);
    } else {
        preg_match("/(\d*)\.?(\d*)/", $figure, $matches);
    }

    list(, $number, $point) = $matches;

    if ($point) {
        $target = $dec . chineseNum($point, $capital, false);
    }

    if (!$number) {
        return $target;
    }

    $str = strrev($number);
    for ($i = 0; $i < strlen($str); $i++) {
        $out[$i] = $numberChar[$str[$i]];
        if ($mode === false) {
            continue;
        }
        $out[$i] .= $str[$i] != '0' ? $unitChar[$i % 4] : '';
        if ($i > 0 && $str[$i] + $str[$i - 1] == 0) {
            $out[$i] = '';
        }
        if ($i % 4 == 0) {
            $temp    = substr($str, $i, 4);
            $out[$i] = str_replace($numberChar[0], '', $out[$i]);
            if (strrev($temp) > 0) {
                $out[$i] .= $unitChar[4 + floor($i / 4)];
            } else {
                $out[$i] .= $numberChar[0];
            }
        }
    }

    $result = join('', array_reverse($out)) . $target;
    return mb_substr($result, 0, 2) == '一十' ? mb_substr($result, 1) : $result;
}


function addPrefix($str)
{
    if (!$str) return '';
    if (mb_substr($str, 0, 4) == 'http') return $str;
    if (mb_substr($str, 0, 5) == 'https') return $str;
    if (mb_substr($str, 0, 7) == '/books/') return 'http://zwcontent.oss-cn-hangzhou.aliyuncs.com' . $str;
    if (mb_substr($str, 0, 6) == '/card/') return 'http://zwcontent.oss-cn-hangzhou.aliyuncs.com' . $str;
    if (mb_substr($str, 0, 15) == 'uploader/idcard') return 'http://zwcontent.oss-cn-hangzhou.aliyuncs.com/' . $str;
    if (mb_substr($str, 0, 6) == '/cover') return 'https://cdn-newyc.ycsd.cn/ycsd_cover/covermiddle' . mb_substr($str, 6);
    if (mb_substr($str, 0, 8) == '/images/') return 'https://cdn-newyc.ycsd.cn/ycsd_cover' . $str;
}

/**
 * 章节内容排版
 *
 * @param $content
 * @return string
 */
function filterContent($content)
{
    if (!$content) return '';
    $content = str_replace(
        ['&nbsp;&nbsp;', '<br /><br />', '<br>', '<br />', '&nbsp;', '<p>', '</p>', '&ldquo;', '&rdquo;', '&hellip;', '&lsquo;', '&rsquo;', '&mdash;'],
        ['　', PHP_EOL, PHP_EOL, PHP_EOL, '　', '', PHP_EOL, '“', '”', '...', '‘', '’', '-'],
        $content);
    $content = preg_replace('/(\r\n)+/', PHP_EOL, $content);
    // 段落首字母前加两个中文空格
    $string = explode(PHP_EOL, $content);
    foreach ($string as $line => $text) {
        $string[$line] = str_replace(['　', "\r\n", "\r", "\n", ' '], '', $string[$line]);
        if (!$string[$line]) {
            unset($string[$line]);
        } else {
            $string[$line] = $string[$line] . PHP_EOL;
//            if (mb_substr($string[$line], 0, 1) == '　') {
//                $string[$line] = str_replace('　', '', $string[$line]);      // 去除多个空格
//                $string[$line] = '　　' . $string[$line].PHP_EOL;
//            }
//            if (mb_substr($string[$line], 0, 2) != '　　') {
//                $string[$line] = '　　' . $string[$line].PHP_EOL;
//            }
//            if (mb_substr($string[$line], 0, 2) == '　　' && str_replace('　', '', $string[$line])) {
//                $string[$line] .= PHP_EOL;
//            }
        }
    }
    $content = implode(PHP_EOL, $string);
    return $content;
}

/**
 * 书籍简介排版
 *
 * @param $content
 * @return string
 */
function filterContent2($content)
{
    if (!$content) return '';
    $content = str_replace(
        ['&nbsp;&nbsp;', '<br /><br />', '<br>', '<br />', '&nbsp;', '<p>', '</p>', '&ldquo;', '&rdquo;', '&hellip;', '&lsquo;', '&rsquo;', '&mdash;'],
        ['　', PHP_EOL, PHP_EOL, PHP_EOL, '　', '', PHP_EOL, '“', '”', '...', '‘', '’', '-'],
        $content);
    $content = preg_replace('/(\r\n)+/', PHP_EOL, $content);
    // 段落首字母前加两个中文空格
    $string  = explode(PHP_EOL, $content);
    $content = '';
    foreach ($string as $line => $text) {
        $string[$line] = str_replace(['　', "\r\n", "\r", "\n", ' ', '<br />'], '', $string[$line]);
        if (!$string[$line]) {
            unset($string[$line]);
        } else {
            $string[$line] = '　　' . $string[$line] . '<br />';
            $content       .= $string[$line];
        }
    }
    $content = trim($content, '<br />');
    return $content;
}

/**
 * 书籍简介排版-抖音版
 *
 * @param $content
 * @return string
 */
function filterIntro($content)
{
    if (!$content) return '';
    $content = str_replace(
        ['&nbsp;&nbsp;', '<br /><br />', '<br>', '<br />', '&nbsp;', '<p>', '</p>', '&ldquo;', '&rdquo;', '&hellip;', '&lsquo;', '&rsquo;', '&mdash;'],
        ['　', '　', '　', '　', '　', '', '　', '“', '”', '...', '‘', '’', '-'],
        $content);
    $content = preg_replace('/(\r\n)+/', PHP_EOL, $content);
    // 段落首字母前加两个中文空格
    $string  = explode(PHP_EOL, $content);
    $content = '';
    foreach ($string as $line => $text) {
        $string[$line] = str_replace(['　', "\r\n", "\r", "\n", ' ', '<br />'], '', $string[$line]);
        if (!$string[$line]) {
            unset($string[$line]);
        } else {
            $content .= $string[$line];
        }
    }
    $content = trim($content, '<br />');
    return $content;
}

function sensitiveStr($list, $string)
{
    $count         = 0;        //违规词的个数
    $sensitiveWord = '';       //违规词
    $stringAfter   = $string;  //替换后的内容

    $total       = count($list);
    $size        = 500;
    $last        = ceil($total / $size);
    $patternList = [];
    for ($page = 1; $page <= $last; $page++) {
        $arr    = array_slice($list, $size * ($page - 1), $size);
        $filter = [];
        foreach ($arr as $v) {
            if (preg_match('/[^a-zA-Z0-9\|\p{Han}\·]/u', $v)) continue;
            $filter[] = $v;

//            $a = preg_replace('/[^a-zA-Z0-9\|\p{Han}]/u', '', $v);
//            if ($a) $filter[] = $a;
        }
        $pattern = "/" . implode("|", $filter) . "/i"; //定义正则表达式

        if (preg_match_all($pattern, $string, $matches)) {          //匹配到了结果
            $patternList = array_merge($patternList, $matches[0]);  //匹配到的数组
        }
    }

    $sensitiveWord = '';
    if ($patternList) {
        $count = count($patternList);
//        $sensitiveWord = implode(',', $patternList); //敏感词数组转字符串
        $replaceArray = array_combine($patternList, array_fill(0, count($patternList), '*')); //把匹配到的数组进行合并，替换使用
        $stringAfter  = strtr($string, $replaceArray);                                        //结果替换

        // 将敏感词合并
        $return_pattern = [];
        foreach ($patternList as $v) {
            if (!isset($return_pattern[$v])) {
                $return_pattern[$v] = [
                    'word'  => $v,
                    'count' => 1,
                ];
            } else {
                $return_pattern[$v]['count'] += 1;
            }
        }

        foreach ($return_pattern as $v) {
            $sensitiveWord .= $v['word'] . ',';
        }

    }

    return [
        'count'           => $count,
        'sensitive_words' => trim($sensitiveWord, ','),
        'content'         => $stringAfter
    ];
}

/**
 * 转换时间格式
 *
 * @param        $date
 * @param string $format
 * @return false|string
 */
function transDate($date, $format = 'Y-m-d H:i:s')
{
    return strtotime($date) > 0 ? date($format, strtotime($date)) : '';
}

/**
 * 根据网段获取计算所有IP
 *
 * @param string $segment 网段 '139.217.0.1/24'
 * @return array [网络地址:139.217.0.1 广播地址:139.217.0.255  IP列表: ['139.217.0.2','139.217.0.3'……'139.217.0.254']]
 */
function getIpBySegment($segment)
{
    $segmentInfo  = explode("/", $segment);
    $beginIpArray = explode(".", $segmentInfo[0]);
    $mask         = intval($segmentInfo['1']);
    $endIp        = array();
    foreach ($beginIpArray as $ipKey => $item) {
        $beginFlag  = 8 * ($ipKey);    //0   8   16  24
        $endFlag    = 8 * ($ipKey + 1);//8   16  24  32
        $decbinItem = str_pad(decbin($item), 8, "0", STR_PAD_LEFT);
        $endIp[]    = $mask >= $endFlag ? $item : ($mask > $beginFlag ? bindec(str_pad(substr($decbinItem, 0, $mask - $beginFlag), 8, "1", STR_PAD_RIGHT)) : ($ipKey <= 2 ? pow(2, 8) - 1 : pow(2, 8) - 1));
    }
    $ipArray = array();
    for ($beginIp[0] = $beginIpArray[0]; $beginIp[0] <= $endIp[0]; $beginIp[0]++) {
        for ($beginIp[1] = $beginIpArray[1]; $beginIp[1] <= $endIp[1]; $beginIp[1]++) {
            for ($beginIp[2] = $beginIpArray[2]; $beginIp[2] <= $endIp[2]; $beginIp[2]++) {
                for ($beginIp[3] = $beginIpArray[3]; $beginIp[3] <= $endIp[3]; $beginIp[3]++) {
                    $ipArray[] = implode(".", $beginIp);
                }
            }
        }
    }
    $network_ip_addr   = $beginIpArray[0] . '.' . $beginIpArray[1] . '.' . $beginIpArray[2] . '.' . '0';      // 网络地址
    $broadcast_ip_addr = end($ipArray);                                                                       // 广播地址
    if ($ipArray[0] == $network_ip_addr) {          // 如果是网络地址则删掉
        unset($ipArray[0]);
    }

    $last = count($ipArray);
    unset($ipArray[$last]);

    return [$network_ip_addr, $broadcast_ip_addr, $ipArray];
}

/**
 * 在指定网段中分配子网段
 *
 * @param string $segment 指定网段
 * @param int    $ipNum 需要的IP数
 * @param array  $usedIpArray 不可用（已经使用）的IP，默认为空数组
 * @return bool|string 成功则返回分配的网段
 */
function allocateSegment($segment, $ipNum, $usedIpArray = [])
{
    $usedIpArray = empty($usedIpArray) ? [] : array_flip($usedIpArray);
    //计算需要多少个IP
    $i       = 0;
    $ipCount = pow(2, $i);
    while ($ipCount < $ipNum) {
        $i++;
        $ipCount = pow(2, $i);
    }
    $newMask = 32 - $i;
    //大网段的开始和结束IP
    $segmentInfo  = explode("/", $segment);       //['139.217.0.1',24]
    $beginIpArray = explode(".", $segmentInfo[0]);//[139,217,0,1]
    $mask         = intval($segmentInfo['1']);    //24
    if ($newMask < $mask) {
        return false;
    }
    $endIp = array();
    $step  = [];
    foreach ($beginIpArray as $ipKey => $item) {
        $beginFlag    = 8 * ($ipKey);    //0   8   16  24
        $endFlag      = 8 * ($ipKey + 1);//8   16  24  32
        $step[$ipKey] = $newMask > $endFlag ? 1 : ($endFlag - $newMask < 8 ? pow(2, $endFlag - $newMask) : pow(2, 8));
        $decbinItem   = str_pad(decbin($item), 8, "0", STR_PAD_LEFT);
        $endIp[]      = $mask >= $endFlag ? $item : ($mask > $beginFlag ? bindec(str_pad(substr($decbinItem, 0, $mask - $beginFlag), 8, "1", STR_PAD_RIGHT)) : ($ipKey <= 2 ? pow(2, 8) - 1 : pow(2, 8) - 1));
    }
    //遍历生成网段
    for ($beginIp[0] = $beginIpArray[0]; $beginIp[0] <= $endIp[0]; $beginIp[0] += $step[0]) {
        for ($beginIp[1] = $beginIpArray[1]; $beginIp[1] <= $endIp[1]; $beginIp[1] += $step[1]) {
            for ($beginIp[2] = $beginIpArray[2]; $beginIp[2] <= $endIp[2]; $beginIp[2] += $step[2]) {
                for ($beginIp[3] = $beginIpArray[3]; $beginIp[3] <= $endIp[3]; $beginIp[3] += $step[3]) {
                    $newSegment = implode('.', $beginIp) . '/' . $newMask;
                    //获取该网段所有的IP
                    $ipArray = getIpBySegment($newSegment);
                    $canUse  = true;
                    //判断该网段是否可用
                    if (!empty($usedIpArray)) {
                        foreach ($ipArray as $ip) {
                            if (isset($usedIpArray[$ip])) {
                                $canUse = false;
                                break;
                            }
                        }
                    }
                    if ($canUse) {
                        return $newSegment;
                    }
                }
            }
        }
    }
    return false;
}

function remove_xss($val)
{
    // remove all non-printable characters. CR(0a) and LF(0b) and TAB(9) are allowed
    // this prevents some character re-spacing such as <java\0script>
    // note that you have to handle splits with \n, \r, and \t later since they *are* allowed in some inputs
    $val = preg_replace('/([\x00-\x08,\x0b-\x0c,\x0e-\x19])/', '', $val);

    // straight replacements, the user should never need these since they're normal characters
    // this prevents like <IMG SRC=@avascript:alert('XSS')>
    $search = 'abcdefghijklmnopqrstuvwxyz';
    $search .= 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
    $search .= '1234567890!@#$%^&*()';
    $search .= '~`";:?+/={}[]-_|\'\\';
    for ($i = 0; $i < strlen($search); $i++) {
        // ;? matches the ;, which is optional
        // 0{0,7} matches any padded zeros, which are optional and go up to 8 chars

        // @ @ search for the hex values
        $val = preg_replace('/(&#[xX]0{0,8}' . dechex(ord($search[$i])) . ';?)/i', $search[$i], $val); // with a ;
        // @ @ 0{0,7} matches '0' zero to seven times
        $val = preg_replace('/(�{0,8}' . ord($search[$i]) . ';?)/', $search[$i], $val);                // with a ;
    }

    // now the only remaining whitespace attacks are \t, \n, and \r
    $ra1 = array('javascript', 'vbscript', 'expression', 'applet', 'meta', 'xml', 'blink', 'link', 'style', 'script', 'embed', 'object', 'iframe', 'frame', 'frameset', 'ilayer', 'layer', 'bgsound', 'title', 'base');
    $ra2 = array(
        'onabort', 'onactivate', 'onafterprint', 'onafterupdate', 'onbeforeactivate', 'onbeforecopy', 'onbeforecut', 'onbeforedeactivate', 'onbeforeeditfocus', 'onbeforepaste', 'onbeforeprint', 'onbeforeunload', 'onbeforeupdate', 'onblur', 'onbounce', 'oncellchange', 'onchange', 'onclick', 'oncontextmenu', 'oncontrolselect', 'oncopy', 'oncut', 'ondataavailable', 'ondatasetchanged', 'ondatasetcomplete', 'ondblclick', 'ondeactivate', 'ondrag', 'ondragend', 'ondragenter', 'ondragleave', 'ondragover', 'ondragstart', 'ondrop', 'onerror', 'onerrorupdate', 'onfilterchange', 'onfinish', 'onfocus', 'onfocusin', 'onfocusout', 'onhelp', 'onkeydown', 'onkeypress', 'onkeyup', 'onlayoutcomplete', 'onload', 'onlosecapture', 'onmousedown', 'onmouseenter', 'onmouseleave', 'onmousemove', 'onmouseout', 'onmouseover', 'onmouseup', 'onmousewheel', 'onmove', 'onmoveend', 'onmovestart', 'onpaste', 'onpropertychange', 'onreadystatechange', 'onreset', 'onresize', 'onresizeend', 'onresizestart', 'onrowenter', 'onrowexit', 'onrowsdelete', 'onrowsinserted', 'onscroll', 'onselect', 'onselectionchange', 'onselectstart', 'onstart', 'onstop', 'onsubmit', 'onunload'
    );
    $ra  = array_merge($ra1, $ra2);

    $found = true; // keep replacing as long as the previous round replaced something
    while ($found == true) {
        $val_before = $val;
        for ($i = 0; $i < sizeof($ra); $i++) {
            $pattern = '/';
            for ($j = 0; $j < strlen($ra[$i]); $j++) {
                if ($j > 0) {
                    $pattern .= '(';
                    $pattern .= '(&#[xX]0{0,8}([9ab]);)';
                    $pattern .= '|';
                    $pattern .= '|(�{0,8}([9|10|13]);)';
                    $pattern .= ')*';
                }
                $pattern .= $ra[$i][$j];
            }
            $pattern     .= '/i';
            $replacement = substr($ra[$i], 0, 2) . '<x>' . substr($ra[$i], 2); // add in <> to nerf the tag
            $val         = preg_replace($pattern, $replacement, $val);         // filter out the hex tags
            if ($val_before == $val) {
                // no replacements were made, so exit the loop
                $found = false;
            }
        }
    }
    return $val;
}

/**
 * 计算作者积分等级
 *
 * @param $score
 */
function calcAuthorLevel($score): int
{
    switch (true) {
        case $score <= 0:
            $level = 0;
            break;
        case $score <= 5000:
            $level = 1;
            break;
        case $score <= 50000:
            $level = 2;
            break;
        case $score <= 100000:
            $level = 3;
            break;
        case $score <= 300000:
            $level = 4;
            break;
        case $score <= 800000:
            $level = 5;
            break;
        case $score <= 1500000:
            $level = 6;
            break;
        case $score <= 2500000:
            $level = 7;
            break;
        case $score <= 5000000:
            $level = 8;
            break;
        case $score <= 10000000:
            $level = 9;
            break;
        default:
            $level = 10;
            break;
    }
    return $level;
}

/**
 * 运营数据（上传附件）
 *
 * @param $file
 * @return string
 * @throws Exception
 */
function uploadEnclosureFile($file)
{
    // 阿里云主账号
    $accessKeyId     = env('OSS_ACCESS_ID');
    $accessKeySecret = env('OSS_ACCESS_KEY');
    $endpoint        = env('OSS_END_POINT');
    $bucket          = env('OSS_BUCKET');
    // 设置文件名称。
    $object = 'books/enclosure/' . randStr(10) . '--' . $file->getClientOriginalName();
    try {
        $ossClient = new OssClient($accessKeyId, $accessKeySecret, $endpoint);

        $ossImgBackData = $ossClient->uploadFile($bucket, $object, $file->path());
    } catch (OssException $e) {
        printf($e->getMessage());
        return '';
    }

    $urlArr = parse_url($ossImgBackData['oss-request-url']);
    return getProp($urlArr, 'path') ? 'http://' . $bucket . '.' . $endpoint . getProp($urlArr, 'path') : '';
}

// 获取当前域名是http还是https
function getHttpType()
{
    return ((isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] == 'on') || (isset($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https')) ? 'https://' : 'http://';
}

// 根据id生成唯一邀请码
function enCodeId($user_id)
{
    $key  = 'XzeTdSPQc1uYHRBVWmUE6x94q25g3krfCGhb8FjtDZvMNKJpnayw7s';
    $num  = strlen($key);
    $code = ''; // 邀请码
    while ($user_id > 0) {                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                     // 转进制
        $mod     = $user_id % $num;                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                 // 求模
        $user_id = ($user_id - $mod) / $num;
        $code    = $key[$mod] . $code;
    }
    $code = str_pad($code, 6, 'A', STR_PAD_LEFT); // 不足用0补充

    return $code;

}

// 根据邀请码解密为id
function deCodeId($code)
{
    $key = 'XzeTdSPQc1uYHRBVWmUE6x94q25g3krfCGhb8FjtDZvMNKJpnayw7s';
    $num = strlen($key);
    if (strrpos($code, '0') !== false) $code = substr($code, strrpos($code, '0') + 1);
    $len     = strlen($code);
    $code    = strrev($code);
    $user_id = 0;
    for ($i = 0; $i < $len; $i++) {
        $user_id += strpos($key, $code[$i]) * pow($num, $i);
    }

    return $user_id;
}


/**
 * 将二维数组按其中的某个数组排序(此方法适用于将数据库数据按数组取出后自动按ID排序的情况 ps:即未按该数组排序)
 *
 * @param array  $array 二维数组
 * @param array  $sort 排序数组
 * @param string $field 排序字段(二维数组和排序数组相同的字段)
 * @return  array
 */
function sortByArray(array $array, array $sort, string $field): array
{
    $data = [];
    if (is_array($array) && is_array($sort)) {
        foreach ($sort as $v) {
            foreach ($array as $key => $val) {
                if ($v == $val[$field]) {
                    array_push($data, $array[$key]);
                }
            }
        }
    }
    return $data;
}

/**
 * 将二维数组按其中的字段排序(正序或倒序)
 *
 * @param array  $array 二维数组
 * @param string $field 排序字段
 * @param mixed  $type 排序方式(3倒序,4正序)
 * @return  array|mixed
 */
function sortByField(array $array, string $field, $type): array
{
    if (is_array($array)) {
        array_multisort(array_column($array, $field), $type, $array);
    }
    return $array;
}

// 生成用户邀请码
function setUserInviteCode($id)
{
    return \Vinkla\Hashids\Facades\Hashids::connection('invite')->encode($id);
}

// 解密用户邀请码
function decodeUserInviteCode($code)
{
    return \Vinkla\Hashids\Facades\Hashids::connection('invite')->decode($code);
}

function getMillisecond()
{
    list($microsecond, $time) = explode(' ', microtime());
    return (float)sprintf('%.0f', (floatval($microsecond) + floatval($time)) * 1000);
}


function get_client_ip($type = 0, $adv = false)
{
    $type = $type ? 1 : 0;
    static $ip = null;
    if (null !== $ip) {
        return $ip[$type];
    }

    if ($adv) {
        if (isset($_SERVER['HTTP_X_FORWARDED_FOR'])) {
            $arr = explode(',', $_SERVER['HTTP_X_FORWARDED_FOR']);
            $pos = array_search('unknown', $arr);
            if (false !== $pos) {
                unset($arr[$pos]);
            }

            $ip = trim($arr[0]);
        } elseif (isset($_SERVER['HTTP_CLIENT_IP'])) {
            $ip = $_SERVER['HTTP_CLIENT_IP'];
        } elseif (isset($_SERVER['REMOTE_ADDR'])) {
            $ip = $_SERVER['REMOTE_ADDR'];
        }
    } elseif (isset($_SERVER['REMOTE_ADDR'])) {
        $ip = $_SERVER['REMOTE_ADDR'];
    }
    // IP地址合法验证
    $long = sprintf("%u", ip2long($ip));
    $ip   = $long ? array($ip, $long) : array('0.0.0.0', 0);
    return $ip[$type];
}


/**
 * 获取真实IP
 */
function _getIp()
{
    if (getenv('HTTP_X_FORWARDED_FOR')) {
        $ip = getenv('HTTP_X_FORWARDED_FOR');
    } else if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
        $ip = getenv("HTTP_CLIENT_IP");
    else if (getenv("HTTP_X_FORWARD_FOR") && strcasecmp(getenv("HTTP_X_FORWARD_FOR"), "unknown"))
        $ip = getenv("HTTP_X_FORWARD_FOR");
    else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
        $ip = getenv("REMOTE_ADDR");
    else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown"))
        $ip = $_SERVER['REMOTE_ADDR'];
    else
        $ip = "unknown";
    return ($ip);
}

/**
 * 数组 转 对象
 *
 * @param array $arr 数组
 * @return object
 */
function array_to_object($arr)
{
    if (gettype($arr) != 'array') {
        return;
    }
    foreach ($arr as $k => $v) {
        if (gettype($v) == 'array' || getType($v) == 'object') {
            $arr[$k] = (object)array_to_object($v);
        }
    }
    return (object)$arr;
}

/**
 * 对象 转 数组
 *
 * @param object $obj 对象
 * @return array
 */
function object_to_array($obj)
{
    $obj = (array)$obj;
    foreach ($obj as $k => $v) {
        if (gettype($v) == 'resource') {
            return;
        }
        if (gettype($v) == 'object' || gettype($v) == 'array') {
            $obj[$k] = (array)object_to_array($v);
        }
    }
    return $obj;
}

/**
 * 检查是否为手机号码
 */
function _isPhone($number)
{
    return preg_match("/^1[34578][0-9]{9}$/", $number);
}


/**
 * 判断所传的参数是否缺少,如果缺少返回渠道的字段，正确返回0
 *
 * @param array $param
 * @param array $must
 * @return int|mixed
 */
function checkParam(array $param, array $must)
{
    foreach ($must as $item) {
        if (array_key_exists($item, $param) && $param[$item] != '') {

        } else {
            return $item;
        }
    }
    return 0;
}


/**
 * 对象 转 数组
 *
 * @param object $obj 对象
 * @return array
 */
function ignoreKeyInArray($targetArray, $delete_keys = [], $changes = [])
{
    $change_keys = array_keys($changes);
    foreach ($targetArray as $key => $value) {
        if (in_array($key, $delete_keys) && isset($targetArray[$key])) unset($targetArray[$key]);
        if (in_array($key, $change_keys) && isset($targetArray[$key])) $targetArray[$key] = $changes[$key];
        if (is_array($value)) ignoreKeyInArray($value, $delete_keys, $change_keys);
    }
    return $targetArray;
}

function itemTransform($trans, $data)
{
    if ($data) {
        return $trans->transform($data);
    } else {
        return [];
    }
}

function collectionTransform($trans, $data)
{
    $ret_data = [];
    if ($data) {
        foreach ($data as $item) {
            $ret_data[] = $trans->transform($item);
        }
    }
    return $ret_data;
}

function paginationTransform($trans, $paginator)
{
    $ret         = [];
    $ret['list'] = [];
    if ($paginator) {
        foreach ($paginator as $item) {
            $ret['list'][] = $trans->transform($item);
        }

        $ret['meta'] = [
            'total'         => (int)$paginator->total(),
            'per_page'      => (int)$paginator->perPage(),
            'current_page'  => (int)$paginator->currentPage(),
            'last_page'     => (int)$paginator->lastPage(),
            'next_page_url' => (string)$paginator->nextPageUrl(),
            'prev_page_url' => (string)$paginator->previousPageUrl()
        ];
    }
    return $ret;
}


/**
 * 加密site id
 */
function encodeDistributionChannelId($id)
{
    $encrypt_pool = [
    ];
    if (isset($encrypt_pool[$id])) {
        return $encrypt_pool[$id];
    }
    $hashids = new \Hashids\Hashids('', 16, 'abcdefghjklmnopqrstuvwxyz1234567890');
    return $hashids->encode($id);
}

/**
 * 解密密site id
 */
function decodeDistributionChannelId($code)
{
    $encrypt_pool = [
    ];
    if (isset($encrypt_pool[$code])) {
        return $encrypt_pool[$code];
    }
    $hashids = new \Hashids\Hashids('', 16, 'abcdefghjklmnopqrstuvwxyz1234567890');
    $res     = $hashids->decode($code);
    if ($res && isset($res[0])) {
        return $res[0];
    }
    return null;
}

//bid加密
function book_hash_encode($bid)
{
    return Vinkla\Hashids\Facades\Hashids::encode($bid);
}


function decodeBid($encode_bid)
{
    $bid = 0;
    try {
        $bid_arr = \Hashids::decode($encode_bid);
        if (isset($bid_arr[0])) {
            $bid = $bid_arr[0];
        }
    } catch (\Exception $e) {
        return null;
    }
    return $bid;
}


/**
 * 获取当前域名
 */
function _domain()
{
    return str_replace('https://', '', str_replace('http://', '', url('/')));
}

/**
 * 字符串转*
 *
 * @param        $str // 待转的字符串
 * @param        $start // 转*起始位置
 * @param int    $end // 转*结束位置
 * @param string $dot // 转换的字符(必须是单字符,默认是*)
 * @param string $charset // 编码方式
 * @param string $end_char // 特殊字符(碰到此字符则确定end位置)
 * @return string
 */
function trans_pass($str, $start, $end = 0, $dot = "*", $charset = "UTF-8", $end_char = '@'): string
{
    $len = mb_strlen($str, $charset);
    if ($start == 0 || $start > $len) {
        $start = 1;
    }

    if ($end != 0 && $end > $len) {
        $end = $len - 2;
    }

    if (strstr($str, $end_char)) {
        $end = $len - strrpos($str, $end_char);
    }
    $endStart = $len - $end;
    $top      = mb_substr($str, 0, $start, $charset);
    $bottom   = "";
    if ($endStart > 0) {
        $bottom = mb_substr($str, $endStart, $end, $charset);
    }

    $len -= mb_strlen($top, $charset);

    $len -= mb_strlen($bottom, $charset);

    $newStr = $top;

    for ($i = 0; $i < $len; $i++) {
        $newStr .= $dot;
    }
    $newStr .= $bottom;
    return $newStr;
}

/**
 * 格式化章节内容
 *
 * @param $content
 * @return false|string
 */
function formatContent($content)
{
    if (!$content) return '';
    $content = str_replace(
        ['&nbsp;&nbsp;', '<br /><br />', '<br>', '<br />', '&nbsp;', '<p>', '</p >', '&ldquo;', '&rdquo;', '&hellip;'],
        ['　', PHP_EOL, PHP_EOL, PHP_EOL, '　', '', PHP_EOL, '“', '”', '...'],
        $content);
    $content = str_replace(["&nbsp;", '&ldquo;', '&hellip;', '&rdquo;', '<p>'], '', $content);
    // 段落首字母前加两个中文空格
    $string = explode(PHP_EOL, $content);
    foreach ($string as $line => $text) {
        if (mb_substr($text, 0, 2) != '　　') $string[$line] = '　　' . $text;
    }
    $content = implode(PHP_EOL, $string);
    $content = mb_convert_encoding($content, 'UTF-8', 'UTF-8,GBK,GB2312');
    $content = iconv('UTF-8', 'UTF-8//IGNORE', $content);
    return $content;
}

/**
 * 筛选出有效的id集合
 *
 * @param array $ids
 * @return array
 */
function filterValidIds(array $ids): array
{
    // 传参
    if (empty($ids)) {
        return [];
    }

    $result = [];
    foreach ($ids as $id) {
        if (in_array($id, $result) || !is_numeric($id) || (int)$id < 1) {
            continue;
        }

        $result[] = (int)$id;
    }

    return $result;
}

function arrayToStr($map)
{
    $isMap = isArrMap($map);

    $result = "";
    if ($isMap) {
        $result = "map[";
    }

    $keyArr = array_keys($map);
    if ($isMap) {
        sort($keyArr);
    }

    $paramsArr = array();
    foreach ($keyArr as $k) {
        $v = $map[$k];
        if ($isMap) {
            if (is_array($v)) {
                $paramsArr[] = sprintf("%s:%s", $k, arrayToStr($v));
            } else {
                $paramsArr[] = sprintf("%s:%s", $k, trim(strval($v)));
            }
        } else {
            if (is_array($v)) {
                $paramsArr[] = arrayToStr($v);
            } else {
                $paramsArr[] = trim(strval($v));
            }
        }
    }

    $result = sprintf("%s%s", $result, join(" ", $paramsArr));
    if (!$isMap) {
        $result = sprintf("[%s]", $result);
    } else {
        $result = sprintf("%s]", $result);
    }

    return $result;
}

function isArrMap($map)
{
    foreach ($map as $k => $v) {
        if (is_string($k)) {
            return true;
        }
    }

    return false;
}

/**
 * 随机字符串
 *
 * @param $length
 * @return string
 */
function makeRandStr($length): string
{
    // 密码字符集，可任意添加你需要的字符
    $str = [
        'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h',
        'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's',
        't', 'u', 'v', 'w', 'x', 'y', 'z', 'A', 'B', 'C', 'D',
        'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O',
        'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z',
        '0', '1', '2', '3', '4', '5', '6', '7', '8', '9'
    ];
    // 在 $str 中随机取 $length 个数组元素键名
    $keys     = array_rand($str, $length);
    $password = '';
    for ($i = 0; $i < $length; $i++) {
        // 将 $length 个数组元素连接成字符串
        $password .= $str[$keys[$i]];
    }
    return $password;
}

/**
 * 导出数据为excel表格
 *
 * @param $data    一个二维数组,结构如同从数据库查出来的数组
 * @param $title   excel的第一行标题,一个数组,如果为空则没有标题
 * @param $filename 下载的文件名
 * @examlpe10
 */
function exportExcel($data = [], $title = [], $filename = 'report')
{
    ob_end_clean();
    ob_start();
    header("Content-type:application/octet-stream");
    header("Accept-Ranges:bytes");
    header("Content-type:application/vnd.ms-excel");
    header("Content-Disposition:attachment;filename=" . $filename . ".xls");
    header("Pragma: no-cache");
    header("Expires: 0");
    //导出xls 开始
    if (!empty($title)) {
        foreach ($title as $k => $v) {
            $title[$k] = iconv("UTF-8", "GB2312", $v);
        }
        $title = implode("\t", $title);
        echo "$title\n";
    }
    if (!empty($data)) {
        foreach ($data as $key => $val) {
            foreach ($val as $ck => $cv) {
                $data[$key][$ck] = iconv("UTF-8", "GB2312", $cv);
            }
            $data[$key] = implode("\t", $data[$key]);
        }
        echo implode("\n", $data);
    }
}


/**
 * 导出csv文件
 * @param string $name
 * @param array  $headers
 * @param array  $data
 * @return void
 */
function exportCsv(string $name, array $headers, array $data = [])
{
    header('Content-Description: File Transfer');
    header('Content-Type: application/csv');
    header("Content-Disposition: attachment; filename=".$name.".csv");
    header('Cache-Control: must-revalidate, post-check=0, pre-check=0');

    $handle = fopen('php://output', 'w');
    ob_clean();

    fputcsv($handle, $headers);
    if ($data) {
        foreach ($data as $row) {
            fputcsv($handle, $row);
        }
    }

    ob_flush();
    fclose($handle);
    die();
}

// 树状分类
function buildCategoryTree($categories, $pid = 0) {
    $tree = [];

    foreach ($categories as $category) {
        if ($category['pid'] == $pid) {
            $children = buildCategoryTree($categories, $category['category_id']);
            if ($children) {
                $category['children'] = $children;
            }
            $tree[] = $category;
        }
    }

    return $tree;
}

// 获取文件的md5值
function getFileContentMD5($filePath){
    //获取文件MD5的128位二进制数组
    $md5Bytes = md5_file($filePath,true);
    //计算文件的Content-MD5
    $contentMD5 = base64_encode($md5Bytes);
    return $contentMD5;
}

function getTextTokens($text) {
    // 方法1：按空格分词（西文较准）
    $words = preg_split('/\s+/', $text);
    $wordCount = count($words);
    
    // 方法2：按字符数估算（中文较准：1个汉字 ≈ 1.5-2 tokens）
    $charCount = mb_strlen($text);
    
    // 综合估算（根据语言调整权重）
    $tokenCount = $wordCount + $charCount * 0.5; // 示例公式
    
    // 更简单：直接按字符数 * 系数（中文推荐）
    // $tokenCount = $charCount * 1.8; // 经验系数
    
    return (int)ceil($tokenCount);
}

// 处理小说剧本文本
function handleScriptWords($text, $enable_emotion=1) {
    $text = preg_replace('/[\r\n]+/', PHP_EOL, $text);
    $text_arr = explode(PHP_EOL, $text);
    $roles = [];
    $words = [];
    $role_gender = [];
    // $sequence = 0;
    foreach ($text_arr as $line) {
        $line = trim($line);

        if ($enable_emotion) {
            $match_rule = '/^(.*?)\：(.*?)\{(.*?)\}$/';
            $count = 4;
        } else {
            $match_rule = '/^(.*?)\：(.*?)$/';
            $count = 3;
        }
        preg_match($match_rule, $line, $matches);
        
        if (count($matches) == $count) {
            $gender = '0';
            // 角色部分拆分
            preg_match('/^(.*?)\((.*?)\)$/', $matches[1], $matches2);
            if (count($matches2) == 3) {
                $role = $matches2[1];
                $gender_arr = ['男'=>'1', '女'=>'2'];
                $gender = isset($gender_arr[$matches2[2]]) ? $gender_arr[$matches2[2]] : '0';
            }else {
                $role = $matches[1];
            }
            if (!in_array($role, $roles)) {
                $roles[] = $role;   // 记录角色
                $role_gender[$role] = $gender;
            }
            $words[] = [
                'role'      => $role,
                'gender'    => $gender,
                'text'      => $matches[2],
                'emotion'   => $enable_emotion ? $matches[3] : '中性',
            ];
        }
    }

    $new_words = [];
    $tmp = '';
    $tmp_arr = [];
    $tmp_text = '';
    // 将words数组按照role和emotion合并相邻的text内容,不相邻则跳过合并
    foreach ($words as $word) {
        if(!$tmp) $tmp = $word['role'].'-'.$word['emotion'];
        if($tmp == $word['role'].'-'.$word['emotion']) {
            $tmp_text .= PHP_EOL.$word['text'];
            $tmp_arr = [
                'role'      => $word['role'],
                'gender'    => $word['gender'],
                'text'      => trim($tmp_text, PHP_EOL),
                'emotion'   => $word['emotion'],
            ];
        }else {
            // $sequence++;
            // $tmp_arr['sequence'] = $sequence;
            $new_words[] = $tmp_arr;
            $tmp = $word['role'].'-'.$word['emotion'];
            $tmp_text = $word['text'];
            $tmp_arr = [
                'role'      => $word['role'],
                'gender'    => $word['gender'],
                'text'      => trim($tmp_text, PHP_EOL),
                'emotion'   => $word['emotion'],
            ];
        }
    }
    if ($tmp_arr) {
        // $sequence++;
        // $tmp_arr['sequence'] = $sequence;
        $new_words[] = $tmp_arr;
    }

    return [
        'roles' => $roles,
        'role_gender' => $role_gender,
        'words' => $new_words,
    ];
}


/**
 * 处理剧本内容
 */
function handleScriptContent($originalContent) {
    // 定义原始内容
//     $originalContent = <<<'EOD'
//     ###故事梗概
// 内容梗概：少女许芸重生回到悲剧发生前一个月，她本是许家假千金，真千金徐清遥因在徐家遭受表哥卞大伟侵犯及养母徐母包庇而心怀怨恨，最终导致许芸被逼联姻、家暴惨死。重生后，许芸提前让身份归位，试图避开悲剧。但她发现一个因暗恋她而与系统交易、令她重生的“空气人”始终在暗中保护她，她却因系统惩罚永远无法看见、听见他。许芸在躲避卞大伟侵害、应对原生家庭矛盾的过程中，逐渐感知到“空气人”的存在与深情。她努力追寻他的身份，得知他是她曾资助的学霸程景。两人在“看不见”的困境中相互靠近，经历生死危机与误解分离后，最终冲破系统束缚，得以相见相守，共度余生。

// ###剧本亮点
// 亮点1：重生救赎与无形守护
// 开篇以许芸死亡回忆切入，画面阴郁沉重，转场重生瞬间光影骤亮。许芸躲避悲剧时，“空气人”多次在危急关头无形相助——如车祸前拉扯卫衣、对抗卞大伟时扭打空气、深夜喂水亲吻等。镜头以许芸主观视角呈现，观众只见她反应却不见施救者，营造悬疑与浪漫交织的张力，突出“被深爱却不自知”的宿命感。

// 亮点2：系统惩罚下的情感博弈
// 许芸与“空气人”程景因系统设定无法直接接触，却通过“血脚印”“消失的面条”“深夜触碰”等细节传递暧昧与温情。许芸大胆挑逗、程景克制回避，两人在“看不见”的局限中试探彼此心意，既有荒诞喜感，又充满情感拉扯的酸涩与甜蜜，颠覆传统恋爱叙事。

// 亮点3：身份谜团与校园暗恋
// 许芸通过重点班花名册、志愿填报等线索，拼凑程景身份。场景在校园、阁楼间切换，许芸努力“听不见”程景信息时的茫然与执着，与夏颜的八卦互动形成反差，逐步揭开“资助者与被资助者”的前缘。观众随许芸一起解谜，沉浸式体验暗恋回溯的感动。

// 亮点4：生死危机与真相爆发
// 卞大伟持刀复仇段落紧张激烈，程景为救许芸受重伤“显形”血迹，却因伤情自卑选择分手。许芸在法院外闻到皂角味、假意跳楼逼其现身，将情感推向高潮。最终阁楼相见，系统束缚破除，两人记忆补全，过往守护细节——浮现，情感爆发力十足。

// 亮点5：跨越苦难的终成眷属
// 结局以十年后怀孕收尾，画面温暖明亮。许芸与程景回顾重生与守护历程，对话温情而释然。悲剧循环被打破，强调“坚持与爱可冲破既定命运”的主题，给予观众情感治愈与希望感。

// ###人物关系
// 许芸与程景：重生前为资助者与被资助者，程景长期暗恋许芸；重生后程景化为“空气人”默默守护，许芸逐渐感知并主动靠近，最终成为恋人、夫妻。
// 许芸与徐清遥：被抱错的真假千金，徐清遥因遭遇迁怒许芸，重生后许芸主动归位身份避免冲突。
// 许芸与徐母、卞大伟：徐母重男轻女、包庇侄子；卞大伟是侵犯者加害者，对许芸屡次施暴。
// 许芸与夏颜：同学兼闺蜜，夏颜单恋程景，一度误导许芸，后和解。
// 程景与系统：交易关系，程景以“许芸永远看不见他”为代价换她重生。

// ###核心矛盾
// 1. 许芸与既定悲剧命运的矛盾：她需避开卞大伟侵害、徐母压迫及徐清遥怨恨，改变惨死结局。
// 2. 许芸与程景“不可见”的系统惩罚矛盾：两人相爱却无法直接接触、沟通，情感传递受阻。
// 3. 程景的自卑与守护矛盾：他因出身、伤势自觉不配，一度逃避，与许芸的坚定追求形成拉扯。
// 4. 许芸与原生家庭的矛盾：徐母的苛待、卞大伟的威胁，迫使她反抗、逃离。

// ###主体列表
// 许芸-重生者：18岁少女，原许家假千金，惨死后重生，决心改变命运，性格从乖顺转向果敢。
// 许芸-追寻者：感知程景存在后，主动探寻其身份，大胆表达爱意，坚韧执着。
// 程景/“空气人”/1号同学：学霸，父母早逝，受许芸资助长大，暗恋许芸至深，以系统交易换她重生，默默守护。
// 卞大伟：徐母侄子，混混，侵犯徐清遥未遂后多次企图伤害许芸，最终入狱。
// 徐母：许芸生母，重男轻女，包庇卞大伟，苛待女儿。
// 徐父：怯懦但逐渐觉醒，最终与徐母离婚支持女儿。
// 徐清遥：真千金，因遭遇怨恨许芸，重生后未直接报复。
// 夏颜：许芸同学，暗恋程景，曾误导许芸，后和解。
// 系统：无形存在，设定“许芸永远看不见程景”的惩罚。

// ###美术风格
// 基础画风风格词：现代写实略带奇幻色调
// 整体采用细腻写实风格，色彩随情绪与剧情变化。重生前回忆片段采用冷灰、暗蓝色调，氛围压抑；重生后日常场景以自然光、生活化色彩为主，突出真实感。程景作为“空气人”存在时，镜头多以许芸主观视角拍摄，画面中他“缺席”却留有痕迹（如血脚印、水面波动），辅以微妙光影与音效暗示其存在。两人情感互动时，色调转为暖黄、柔光，烘托暧昧与温情。危机场景如遇袭、跳楼等，采用快速剪辑、手持晃动镜头与对比色，强化紧张感。结局部分画面明亮温暖，象征新生与希望。

// ###场景列表
// 徐家馄饨店：老旧街边小店，锅炉、案板杂乱，象征许芸压抑的原生家庭。
// 网吧：烟雾缭绕，光线昏暗，许芸在此熬夜躲避悲剧。
// 街道/路口：日常街景，车祸救人处，程景首次“无形”相助。
// 程景阁楼：狭小但整洁，书桌、床、矮几，两人主要相处空间，充满私密与温情。
// 学校教室/走廊：重点班与普通班场景，许芸探寻程景身份的主要场所。
// 医院：程景受伤住院处，许芸因看不见而无助。
// 法院外台阶：卞大伟宣判后，许芸与徐母冲突，程景暗中出现。
// 平台/草坪：许芸假意跳楼逼程景现身之处。

// ###分集剧本
// ##分集02
// 分集名: 街头相遇
// 场景描述：街道 / 日 / 外
// 出场角色：许芸、程景（无形）、老奶奶
// 台词内容:
// 许芸：（内心独白，画外音）我重生了。回到悲剧发生前一个月。这一次，我绝不会再走上那条绝路。
// （许芸熬夜后恍惚过马路，汽车疾驰而来）
// 许芸：（惊愕瞪大眼）啊！
// （许芸被无形力量猛地向后拉扯，踉跄站稳）
// 老奶奶：（拄拐走近）这司机开车横冲直撞，要不是小姑娘你反应快，一定会被撞到。
// 许芸：（环顾四周，茫然）不是我自己躲的……
// （许芸急切在人群中寻找，风吹过她的发梢）
// 许芸：（低声，眼眶微红）是你吗？傻瓜……你看我惨死的时候，很痛吧。

// ##分集03
// 分集名: 重生
// 场景描述：街道 / 日 / 外
// 出场角色：许芸、程景（无形）、老奶奶
// 台词内容:
// 许芸：（内心独白，画外音）我重生了。回到悲剧发生前一个月。这一次，我绝不会再走上那条绝路。
// （许芸熬夜后恍惚过马路，汽车疾驰而来）
// 许芸：（惊愕瞪大眼）啊！
// （许芸被无形力量猛地向后拉扯，踉跄站稳）
// 老奶奶：（拄拐走近）这司机开车横冲直撞，要不是小姑娘你反应快，一定会被撞到。
// 许芸：（环顾四周，茫然）不是我自己躲的……
// （许芸急切在人群中寻找，风吹过她的发梢）
// 许芸：（低声，眼眶微红）是你吗？傻瓜……你看我惨死的时候，很痛吧。

// 场景描述：徐家馄饨店 / 日 / 内
// 出场角色：许芸、徐母、卞大伟
// 台词内容:
// 徐母：（挥舞扫帚打许芸）夜不归宿死哪儿去了？！
// 许芸：（躲闪）去许家让清遥给我补课了。
// 徐母：（扔下扫帚，指案板）去包馄饨！
// （许芸沉默洗手，余光瞥向锅炉后的卞大伟）
// 卞大伟：（阴沉盯着许芸，无声冷笑）
// 许芸：（内心独白）上辈子，就是他在今天毁了徐清遥。幸好，我躲过去了。

// ##分集04
// 分集名: 馄饨店
// 场景描述：徐家馄饨店 / 傍晚 / 内
// 出场角色：许芸、卞大伟、程景（无形）
// 台词内容:
// （许芸放学进门，卞大伟猛地拉住她）
// 卞大伟：今天姑姑不在，看谁还能救你！
// 许芸：（挣扎）放开我！
// （桌椅撞倒，许芸掏刀，卞大伟突然怪异地摔倒）
// 卞大伟：（朝空气怒吼）你他妈谁啊？！
// 许芸：（愣住，随即眼睛一亮）是你！
// （许芸趁机跑出，回头看见卞大伟与“空气”扭打）
// 许芸：（朝屋内喊）我们走！
// （许芸跑出，看到臭水沟溅起水花，地上出现血脚印）
// 许芸：（追上）你受伤了！
// （血脚印停住）
// 许芸：（固执）我要跟你在一起。

// 场景描述：程景阁楼 / 夜 / 内
// 出场角色：许芸、程景（无形）
// 台词内容:
// （许芸坐在床边，矮几上出现两碗面，她对面的面条自动减少）
// 许芸：（看着空气）你一直在看着我，对吧？
// （许芸眼泪滴落）
// 许芸：（哽咽）你太惨了……换我重生，你却连名字都不能让我知道。
// （许芸擦泪吃面）
// 许芸：我今晚住你这。
// （许芸洗澡后穿T恤躺下，关灯）
// 许芸：（黑暗中）试试看我能不能碰到你。
// （许芸伸手摸索，只触到空气）
// 许芸：（沮丧）睡觉了。
// EOD;
    
    // 使用更精确的正则表达式分割内容
    $parts = [];
        
    // 提取故事梗概（直到遇到下一个###标记）
    preg_match('/###故事梗概\s*\n(.*?)(?=\n###|$)/s', $originalContent, $summaryMatch);
    $parts['intro'] = isset($summaryMatch[1]) ? trim($summaryMatch[1]) : '';
        
    // 提取剧本亮点
    preg_match('/###剧本亮点\s*\n(.*?)(?=\n###|$)/s', $originalContent, $highlightsMatch);
    $parts['highlights'] = isset($highlightsMatch[1]) ? trim($highlightsMatch[1]) : '';
        
    // 提取人物关系
    preg_match('/###人物关系\s*\n(.*?)(?=\n###|$)/s', $originalContent, $relationsMatch);
    $parts['role_relationship'] = isset($relationsMatch[1]) ? trim($relationsMatch[1]) : '';
        
    // 提取核心矛盾
    preg_match('/###核心矛盾\s*\n(.*?)(?=\n###|$)/s', $originalContent, $contradictionsMatch);
    $parts['core_contradiction'] = isset($contradictionsMatch[1]) ? trim($contradictionsMatch[1]) : '';
        
    // 提取主体列表
    preg_match('/###主体列表\s*\n(.*?)(?=\n###|$)/s', $originalContent, $subjectsMatch);
    $parts['roles'] = isset($subjectsMatch[1]) ? trim($subjectsMatch[1]) : '';
        
    // 提取美术风格
    preg_match('/###美术风格\s*\n(.*?)(?=\n###|$)/s', $originalContent, $artStyleMatch);
    $parts['art_style'] = isset($artStyleMatch[1]) ? trim($artStyleMatch[1]) : '';
        
    // 提取场景列表
    preg_match('/###场景列表\s*\n(.*?)(?=\n###|$)/s', $originalContent, $scenesMatch);
    $parts['scenes'] = isset($scenesMatch[1]) ? trim($scenesMatch[1]) : '';
        
    // 提取分集剧本并按分集拆分
    preg_match('/###分集剧本\s*\n(.*)/s', $originalContent, $storyboardMatch);
    $fullScript = isset($storyboardMatch[1]) ? trim($storyboardMatch[1]) : '';
    
    // 使用正则表达式按分集拆分剧本
    $episodes = [];
    
    // 匹配所有分集标题、分集名和内容
    preg_match_all('/##分集(\d+)\s*\n分集名:\s*(.*?)\s*\n(.*?)(?=\n##分集|$)/s', $fullScript, $matches, PREG_SET_ORDER);
    
    // 遍历匹配结果，构建二维分集数组
    foreach ($matches as $match) {
        $episodeNumber = (int)trim($match[1]);
        $episodeName = trim($match[2]);
        $episodeContent = trim($match[3]);
        
        $episodes[] = [
            'episode_number' => $episodeNumber,
            'title' => $episodeName,
            'content' => $episodeContent
        ];
    }
    
    $parts['episodes'] = $episodes;
        
    return $parts;
}


/**
 * 远程图片压缩（尽可能保持原图 fidelity，压缩到不超过 maxBytes 字节）
 * 采用有损/无损组合策略：保留原始格式尽量不失真，若需要则通过尺寸缩放和质量调节来降低体积。
 *
 * @param string $url       远程图片 URL
 * @param int    $maxBytes  最大字节数，默认 2MB
 * @return string|null      返回压缩后的图片二进制数据，失败时返回 null
 */
function compressRemoteImageUrlToSize(string $url, int $maxBytes = 3 * 1024 * 1024): ?string
{
    // 1) 下载图片数据（使用 Guzzle 以避免 allow_url_fopen 依赖）
    try {
        $client = new Client(['timeout' => 30]);
        $response = $client->get($url, ['stream' => true]);
        if ($response->getStatusCode() !== 200) {
            return null;
        }
        $data = $response->getBody()->getContents();
    } catch (\Exception $e) {
        return null;
    }

    if (!$data) return null;

    // 2) 识别图片类型
    $imgInfo = @getimagesizefromstring($data);
    $mime    = $imgInfo['mime'] ?? '';
    if ($mime == 'image/jpeg') return null; // JPEG 不做有损压缩
    // 3) 载入图像对象
    $srcImg = @imagecreatefromstring($data);
    if (!$srcImg) {
        return null;
    }
    $origW = imagesx($srcImg);
    $origH = imagesy($srcImg);

    // 3.1) 内部渲染成不同格式的字符串
    $render = function($srcRes, string $mimeType, int $quality) {
        ob_start();
        switch (strtolower($mimeType)) {
            case 'image/jpeg':
            case 'image/jpg':
            case 'image/pjpeg':
                // 输出 JPEG
                imagejpeg($srcRes, null, $quality);
                break;
            case 'image/png':
                // 将 quality 映射到 PNG 的 compression level (0-9)
                $level = (int)round((100 - $quality) / 11.11);
                if ($level < 0) $level = 0;
                if ($level > 9) $level = 9;
                imagepng($srcRes, null, $level);
                break;
            case 'image/webp':
                if (function_exists('imagewebp')) {
                    imagewebp($srcRes, null, $quality);
                } else {
                    imagejpeg($srcRes, null, $quality);
                }
                break;
            default:
                imagejpeg($srcRes, null, $quality);
                break;
        }
        $out = ob_get_contents();
        ob_end_clean();
        return $out;
    };

    // 4) 尝试策略：尽量保留原图尺寸，逐步降维/降质量，直到 <= maxBytes
    $tryList = [];
    // 原始尺寸，尽量保留
    $tryList[] = ['scale'=>1.0, 'mime'=>$mime, 'quality'=>100];
    // 逐步缩小尺寸
    for ($s = 0.9; $s >= 0.2; $s -= 0.1) {
        $tryList[] = ['scale'=>$s, 'mime'=>$mime, 'quality'=>90];
    }
    // 一系列质量等级（用于 JPEG/WebP）
    $qualityLevels = [95, 90, 85, 75, 60, 50, 40, 30];
    foreach ($qualityLevels as $q) {
        $tryList[] = ['scale'=>1.0, 'mime'=>$mime, 'quality'=>$q];
    }

    $bestData = null;
    foreach ($tryList as $cand) {
        $scale  = isset($cand['scale']) ? (float)$cand['scale'] : 1.0;
        $mimeT  = $cand['mime'] ?? $mime;
        $quality = isset($cand['quality']) ? (int)$cand['quality'] : 90;

        $w = (int)round($origW * $scale);
        $h = (int)round($origH * $scale);
        $src = $srcImg;
        $tempImg = null;
        if ($scale < 1.0) {
            $tempImg = imagecreatetruecolor($w, $h);
            // 处理透明通道
            imagealphablending($tempImg, false);
            imagesavealpha($tempImg, true);
            if (in_array(strtolower($mime), ['image/png','image/webp'])) {
                $transparent = imagecolorallocatealpha($tempImg, 0, 0, 0, 127);
                imagefill($tempImg, 0, 0, $transparent);
            }
            // 确保 $srcImg 有效
            if (!$srcImg || (!is_resource($srcImg) && !($srcImg instanceof \GdImage))) {
                safeDestroyImage($tempImg);
                continue;
            }
            imagecopyresampled($tempImg, $srcImg, 0, 0, 0, 0, $w, $h, $origW, $origH);
            $src = $tempImg;
        }
        $imageBytes = $render($src, $mimeT, $quality);
        if ($tempImg !== null) {
            safeDestroyImage($tempImg);
        }
        if ($imageBytes !== false && strlen($imageBytes) <= $maxBytes) {
            $bestData = $imageBytes;
            break;
        }
    }
    // 5) 回退策略：若仍未达到要求，尝试更大幅度降解到一个合理的小尺寸 JPEG
    if ($bestData === null) {
        $tmpW = max(1, (int)round($origW * 0.5));
        $tmpH = max(1, (int)round($origH * 0.5));
        $tmpImg = imagecreatetruecolor($tmpW, $tmpH);
        imagealphablending($tmpImg, false);
        imagesavealpha($tmpImg, true);
        if (in_array(strtolower($mime), ['image/png','image/webp'])) {
            $transparent = imagecolorallocatealpha($tmpImg, 0, 0, 0, 127);
            imagefill($tmpImg, 0, 0, $transparent);
        }
        imagecopyresampled($tmpImg, $srcImg, 0, 0, 0, 0, $tmpW, $tmpH, $origW, $origH);
        ob_start();
        if (in_array(strtolower($mime), ['image/jpeg','image/jpg','image/pjpeg'])) {
            imagejpeg($tmpImg, null, 75);
        } elseif (strtolower($mime) === 'image/png') {
            imagepng($tmpImg, null, 6);
        } elseif (function_exists('imagewebp')) {
            imagewebp($tmpImg, null, 75);
        } else {
            imagejpeg($tmpImg, null, 75);
        }
        $tmpBytes = ob_get_contents();
        ob_end_clean();
        safeDestroyImage($tmpImg);
        if ($tmpBytes !== '' && strlen($tmpBytes) <= $maxBytes) {
            $bestData = $tmpBytes;
        }
    }

    // 6) 清理
    safeDestroyImage($srcImg);
    return $bestData;
}
/**
 * 安全销毁 GD 图像资源（兼容 PHP7.4+ 的资源管理）
 * 通过引用传递并在销毁后置空变量，避免未定义变量的问题
 *
 * @param resource|\GdImage|null &$img GD 图像资源或对象（PHP7.4 为 resource，PHP8.0+ 为 GdImage）
 */
function safeDestroyImage(&$img)
{
    if (is_resource($img) || (is_object($img) && $img instanceof \GdImage)) {
        @imagedestroy($img);
    }
    $img = null;
}

// /**
//  * 使用 Imagick 将远程图片压缩至不超过 maxBytes（默认3MB）内
//  * 目标：在尽量保留原始格式和质量的前提下进行压缩，避免内存暴涨
//  * 依赖：Imagick 扩展与 ImageMagick 库，下载使用 Guzzle 获取图片 blob
//  *
//  * @param string $url
//  * @param int    $maxBytes 最大字节数，默认 3*1024*1024
//  * @return string|null 经过压缩后的图片 blob，失败返回 null
//  */
// function compressRemoteImageUrlToSizeImagick(string $url, int $maxBytes = 3 * 1024 * 1024): ?string
// {
//     // 兼容性检查
//     if (!extension_loaded('imagick') || !class_exists('Imagick')) {
//         return null;
//     }

//     try {
//         $client = new Client(['timeout' => 30]);
//         // 使用流式下载，将数据写入临时文件，避免一次性加载到内存
//         $response = $client->get($url, ['stream' => true]);
//         if ($response->getStatusCode() !== 200) {
//             return null;
//         }

//         $body = $response->getBody();
//         $tmp  = tmpfile();
//         if ($tmp === false) {
//             return null;
//         }
//         stream_copy_to_stream($body, $tmp);
//         rewind($tmp);

//         $imagick = new Imagick();
//         $imagick->readImageFile($tmp);
//         $origW = $imagick->getImageWidth();
//         $origH = $imagick->getImageHeight();
//         $format = strtolower($imagick->getImageFormat());

//         // 尝试序列：尺寸缩放 + 质量调节
//         $scales   = [1.0, 0.9, 0.8, 0.6, 0.4, 0.25];
//         $qualities = [95, 90, 85, 75, 60, 40, 30, 20];
//         $bestBlob = null;

//         foreach ($scales as $scale) {
//             foreach ($qualities as $q) {
//                 $clone = clone $imagick;
//                 if ($scale < 1.0) {
//                     $w = (int)round($origW * $scale);
//                     $h = (int)round($origH * $scale);
//                     if ($w < 1 || $h < 1) {
//                         $clone->destroy();
//                         continue;
//                     }
//                     $clone->resizeImage($w, $h, Imagick::FILTER_LANCZOS, 1);
//                 }
//                 $clone->setImageFormat($format);
//                 $clone->setImageCompressionQuality($q);
//                 $blob = $clone->getImageBlob();
//                 $clone->destroy();
//                 if ($blob !== false && strlen($blob) <= $maxBytes) {
//                     $bestBlob = $blob;
//                     break 2;
//                 }
//             }
//         }

//         if ($bestBlob !== null) {
//             $imagick->destroy();
//             fclose($tmp);
//             return $bestBlob;
//         }

//         // 回退：尝试强制输出为当前格式的一个中等质量版本
//         $fallback = clone $imagick;
//         $fallback->setImageFormat($format);
//         $fallback->setImageCompressionQuality(75);
//         $blob = $fallback->getImageBlob();
//         $fallback->destroy();
//         $imagick->destroy();
//         fclose($tmp);
//         if ($blob !== false && strlen($blob) <= $maxBytes) {
//             return $blob;
//         }
//     } catch (\Exception $e) {
//         return null;
//     }

//     return null;
// }