fuse/app/common.php

<?php
// 应用公共文件
use think\facade\Filesystem;
use think\facade\Config;
use app\model\AdminTokenModel;
use app\model\AdminModel;
use think\exception\ValidateException;
use app\model\CommonModel;

//返回响应数据
if (!function_exists('json_show')) {
    function json_show(int $code = 0, string $message = '请求成功', array $data = [])
    {
        return json(['code' => $code, 'message' => $message, 'data' => $data]);
    }
}

//获取加密后的密码
//@param $password string 密码
//@param $salt string 盐值
if (!function_exists('get_password')) {
    function get_password(string $password = '', string $salt = ''): string
    {
        return sha1($password . $salt);
    }
}

//获取token
//@param $admin_id int 运营账号表id
//@param $username string 账户
//@param $salt string 盐值
if (!function_exists('make_token')) {
    function make_token(int $admin_id = 0, string $username = '', string $salt = ''): string
    {
        $now = time();
        $str = $username . $salt . (string)$now;
        $token = base64_encode($str);
        AdminTokenModel::handleToken($admin_id, $token);
        return $token;
    }
}

//校验token
//@param $salt string 盐值
if (!function_exists('verify_token')) {
    function verify_token(string $token = '')
    {
        $has = AdminTokenModel::where(['token' => $token])->findOrEmpty();
        if ($has->isEmpty()) throw new ValidateException('token不存在');

        if (strtotime($has->expiretime) <= time()) throw new ValidateException('token已失效');

        $account = AdminModel::where(['id' => $has['adminid'], 'is_del' => CommonModel::$del_normal])->findOrEmpty();
        if ($account->isEmpty()) throw new ValidateException('未找到账户');

        if ($account->status != CommonModel::$status_normal) throw new ValidateException('账户已禁用');

        $token_str = base64_decode($token);

        $account_str = substr($token_str, 0, -10);
        if ($account_str == $account->username . $account->salt) {
            AdminTokenModel::where(['token' => $token])
                ->save(['expiretime' => date('Y-m-d H:i:s', time() + Config::get('common.expire'))]);
            return ['uid' => $account->id, 'uname' => $account->nickname, 'roleid' => $account->role_id];
        } else throw new ValidateException('账户token无效');

    }
}

//发送post的curl请求
if (!function_exists('curl_request')) {
    function curl_request(string $url = '', array $data = [], array $header = [])
    {
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 10.0; Windows NT 6.1; Trident/6.0)');
        curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);
        curl_setopt($curl, CURLOPT_AUTOREFERER, 1);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        if ($data) {
            curl_setopt($curl, CURLOPT_POST, 1);
            curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
        }
        curl_setopt($curl, CURLOPT_SAFE_UPLOAD, true);
        if (!$header) $header = [
            'uid:' . request()->development['id'],
            'nickname:' . request()->development['contactor'],
            'mobile:' . request()->development['mobile'],
//            'email:',
            'supplierNo:' . request()->development['supplierNo'],
            'supplierName:' . request()->development['supplierName']
        ];

        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);

        curl_setopt($curl, CURLOPT_TIMEOUT, 10);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        $data = curl_exec($curl);
        if (curl_errno($curl)) {
            return curl_error($curl);
        }
        curl_close($curl);
        return $data;

    }
}

//生成编码
//@param $str string 前缀
if (!function_exists('make_no')) {
    function make_no(string $str = ''): string
    {
        $date = date("ymdHis");
//        $year = date("Y")-2000;
        $msec = randomkeys(4);
        return $str . $msec . $date;
    }
}

//生成随机字符串
//@param $length int 长度，默认4
if (!function_exists('randomkeys')) {
    function randomkeys(int $length = 4): string
    {
        $returnStr = '';
        $pattern = 'abcdefghijklmnopqrstuvwxyz';//ABCDEFGHIJKLOMNOPQRSTUVWXYZ
        $min = 0;
        $max = strlen($pattern) - 1;

        for ($i = 0; $i < $length; $i++) {
            $returnStr .= $pattern[mt_rand($min, $max)]; //生成php随机数
        }
        return $returnStr;
    }
}


//上传图片
/**
 * @param $files
 * @return array
 */
if (!function_exists('upload_img')) {

    function upload_img($files): array
    {
        $savename = [];
        $files = !is_array($files) ? [$files] : $files;
        //验证
        validate([
            'imgFile' => [
                'fileSize' => 10240000,
                'fileExt' => 'jpg,jpeg,png,bmp,gif',
                'fileMime' => 'image/jpeg,image/png,image/gif'
            ]
        ])->check(['imgFile' => $files]);

        foreach ($files as $file) {
            $url = Filesystem::disk('public')
                ->putFile('topic/' . date("Ymd"), $file, function () use ($file) {
                    return str_replace('.' . $file->getOriginalExtension(), '', $file->getOriginalName() . "_" . date('YmdHis'));
                });
            $name = str_replace('.' . $file->getOriginalExtension(), '', $file->getOriginalName());
            $temp = ["url" => $url, "name" => $name];
            $savename[] = $temp;
        }

        return $savename;

    }
}

//导出文件成压缩包
if (!function_exists('excel_save')) {
    function excel_save($fileName = '', $headArr = [], $data = [])
    {
        $objPHPExcel = new PHPExcel();
        $objPHPExcel->getProperties();
        $keyA = 0; // 设置表头
        foreach ($headArr as $v) {
            $colum = PHPExcel_Cell::stringFromColumnIndex($keyA);
            $objPHPExcel->setActiveSheetIndex(0)->setCellValue($colum . '1', $v);
            $keyA += 1;
        }

        $column = 2;
        $objActSheet = $objPHPExcel->getActiveSheet();

        foreach ($data as $key => $rows) { // 行写入
            $span = 0;
            foreach ($rows as $keyName => $value) { // 列写入
                //判断数据是否有数组，如果有数组，转换成字符串

                if (is_array($value)) $value = implode("、", $value);

                $objActSheet->setCellValue(PHPExcel_Cell::stringFromColumnIndex($span) . $column, $value);
                $span++;
            }
            $column++;
        }
        //  var_dump($objActSheet->getActiveCell());
        $file = $fileName . ".xls";
        //$fileName .= "_" . date("Y_m_d", Request()->instance()->time()) . ".xls";
        //$fileName = iconv("utf-8", "gb2312", $fileName); // 重命名表
        $dir = root_path() . 'public/storage/report/' . date("YmdHis") . "/";
        if (!is_dir($dir)) mkdir($dir, 0777, true);


        PHPExcel_Settings::setCacheStorageMethod(PHPExcel_CachedObjectStorageFactory::cache_in_memory_serialized);
        $objPHPExcel->setActiveSheetIndex(0); // 设置活动单指数到第一个表,所以Excel打开这是第一个表
        $objWriter = \PHPExcel_IOFactory::createWriter($objPHPExcel, 'Excel2007');
        $objWriter->save($dir . $file); // 文件通过浏览器下载
        $url = $dir . $file;
        if (!file_exists($url)) throw new \think\Exception('文件生成失败');

        $saveDir = root_path() . "public/storage/zip/";
        if (!is_dir($saveDir)) mkdir($saveDir, 0777, true);

//        $datetime = date("YmdHis");
        $file_dir = $saveDir . $fileName . ".zip";
        # 5.1 文件打包，提示：使用本类，linux需开启zlib，windows需取消php_zip.dll前的注释
        $zip = new \ZipArchive ();
        # 5.2 文件不存在则生成一个新的文件 用CREATE打开文件会追加内容至zip
        if ($zip->open($file_dir, \ZipArchive::OVERWRITE) !== true && $zip->open($file_dir, \ZipArchive::CREATE) !== true) throw new \think\Exception('无法打开文件或者文件创建失败');

        # 5.3 批量写入压缩包
        $zip->addEmptyDir($fileName);
        // @$zip->addFile($v['file_path'], 'resume'.DIRECTORY_SEPARATOR.basename($headername));
        @$zip->addFile($url, $fileName . DIRECTORY_SEPARATOR . basename($url));
        # 5.4 关闭压缩包写入
        $zip->close();
        @del_dir($dir);
        # 6. 检查文件是否存在，并输出文件
        if (!file_exists($file_dir)) throw new \think\Exception('导出文件不存在');

        ob_clean();
        flush();
        header("Cache-Control: max-age=0");
        header("Content-Description: File Transfer");
        header('Content-disposition: attachment; filename=' . basename($file_dir)); # 处理文件名
        header("Content-Type: application/octet-stream");                           # 流文件输出
        header("Content-Transfer-Encoding: binary");                                # 告诉浏览器，这是二进制文件
//    header('Content-Length: ' . filesize($file_dir));                           # 告诉浏览器，文件大小
//    readfile($file_dir);                                                        # 输出文件
        $res = read_big_file($file_dir);
        foreach ($res as $val) {
            echo $val;
        }
        @ unlink($file_dir);
        exit();
    }
}

//读取大文件
if (!function_exists('read_big_file')) {
    function read_big_file(string $file = '')
    {
        $handle = fopen($file, 'rb');
        while (feof($handle) === false) {
            yield fgets($handle);
        }
        fclose($handle);
    }
}

//递归删除目录内的所有文件和本目录
if (!function_exists('del_dir')) {
    function del_dir($path)
    {
        //如果是目录则继续
        if (is_dir($path)) {
            //扫描一个文件夹内的所有文件夹和文件并返回数组
            $p = scandir($path);
            //如果 $p 中有两个以上的元素则说明当前 $path 不为空
            if (count($p) > 2) {
                foreach ($p as $val) {
                    //排除目录中的.和..
                    if ($val != "." && $val != "..") {
                        //如果是目录则递归子目录，继续操作
                        if (is_dir($path . $val)) {
                            //子目录中操作删除文件夹和文件
                            del_dir($path . $val . '/');
                        } else {
                            //如果是文件直接删除
                            unlink($path . $val);
                        }
                    }
                }
            }
        }
        //删除目录
        return rmdir($path);
    }
}


//根据省市区编码获取省市区名称
if (!function_exists('get_addr_name')) {
    function get_addr_name(string $addr_code = ''): string
    {
        $rs = \think\facade\Db::name('area')
            ->whereIn('code', $addr_code)
            ->column('name');
        return implode('', $rs);
    }
}