php 使用 生成器 yield关键字 处理 万级以上csv 文件，并重新导出

            class
             Qushu
{
    
            public
            function
             getDg(){
        
            set_time_limit(0);

        $file = request()->get(‘file‘);
        $path = ‘D:/path/‘.$file.‘.csv‘;

        $key = ‘********‘;

        $header = [‘订单‘,‘姓名‘,‘电话‘,‘地址‘,‘证件号‘,‘机构‘,‘社会代码‘,‘税务‘,‘测试‘,‘测试电话‘,‘得知‘,‘物品名称‘];

        $output = $this->csvSet("导出表名",$header);

        $data = $this->getCsv($path);

        $i = 0;
        foreach ($dataas$k=>$v)
        {
            if (!$v) break;

            $idcard = iconv(‘GBK‘,"UTF-8//TRANSLIT//IGNORE",$v[4]);
            // 根据条件判断是否要处理字段if (!empty($idcard) && strlen($idcard)>18){
                // 处理字段的code....$v[4] = ‘‘;
            }

            //输出csv内容
            fputcsv($output, array_values($v));

            $i++;
        }
        //关闭文件句柄fclose($output) or die("can‘t close php://output");
        exit;


    }

    /**
    *获取csv内容 使用 yield
    */publicfunction getCsv($fname)
    {

        $handle = fopen("$fname", ‘rb‘);

        while (feof($handle)===false) {
            # code...
            yield fgetcsv($handle);
        }

        fclose($handle);
    }

    /**设置csv*/publicfunction csvSet($name,$head)
    {
        try {
            //设置内存占用set_time_limit(0);
            ini_set(‘memory_limit‘, ‘512M‘);

            //为fputcsv()函数打开文件句柄$output = fopen(‘php://output‘, ‘w‘) or die("can‘t open php://output");

            //告诉浏览器这个是一个csv文件header("Content-Type: application/csv");
            header("Content-Disposition: attachment; filename=$name.csv");
            header(‘Cache-Control:must-revalidate,post-check=0,pre-check=0‘);
            header(‘Expires:0‘);
            header(‘Pragma:public‘);

            // 文件名转码$name = iconv(‘utf-8‘, ‘gbk‘, $name);

            //输出表头foreach ($headas$i => $v) {
                //CSV的Excel支持GBK编码，一定要转换，否则乱码$head[$i] = iconv(‘utf-8‘, ‘gbk‘, $v);

            }

            fputcsv($output, $head);

            return$output;
        }catch (Exception$e){

        }
    }
}