tp5 Excel 批量导入

Posted 2020-10-22 ws1992

//引入Excel公共类

vendor("phpExcel.Classes.PHPExcel");
vendor(‘PHPExcel.Classes.PHPExcel.IOFactory.PHPExcel_IOFactory‘);
vendor(‘PHPExcel.Classes.PHPExcel.Reader.Excel5‘);
$objPHPExcel = new \PHPExcel();
$file = request()->file(‘filename‘);
$info = $file->validate([‘ext‘ => ‘xlsx,xls,csv‘])->move(ROOT_PATH . ‘public‘ . DS . ‘uploads/import‘);//上传验证后缀名,以及上传之后移动的地址
if($info){
 $exclePath = $info->getSaveName();  //获取文件名
 $file_name = ROOT_PATH . ‘public‘ . DS . ‘uploads/import‘ . DS . $exclePath;   //上传文件的地址
 $objReader =\PHPExcel_IOFactory::createReader(‘Excel5‘);
 $obj_PHPExcel =$objReader->load($file_name, $encode = ‘utf-8‘);  //加载文件内容,编码utf-8
 $excel_array=$obj_PHPExcel->getsheet(0)->toArray();   //转换为数组格式
 array_shift($excel_array);  //删除第一个数组(标题);
 $datas = [];
 $data_errors = [];

//处理Excel导入时数据为空的情况

 foreach($excel_array as $k=>$v) {
 if(!empty($v[0] || $v[1] || $v[2])){
 $excel_list[] = $v;
 }
    }
 $cn=count($excel_list);

//循环遍历，组装数据进行入库

 foreach ($excel_list as $k=>$v){
 if(!empty($v[0]) && !empty($v[1])){
 $wh[‘job_number‘] = $v[0];
 $wh[‘is_deleted‘] = ‘1‘;
 $res_info=db(‘member‘)->where($wh)->count();
 if($res_info ==0){
 $data=array(
 ‘job_number‘=>$v[0],
 ‘user_name‘=>$v[1],
 ‘department‘=>$v[2],
 ‘create_id‘ =>$admin_id,
 ‘create_time‘=>date(‘Y-m-d H:i:s‘),
 );
 $datas[] = $data;
 }
      }else{
 $error_data=array(
 ‘job_number‘=>$v[0],
 ‘user_name‘=>$v[1],
 ‘department‘=>$v[2],
 ‘create_id‘ =>$admin_id,
 ‘create_time‘=>date(‘Y-m-d H:i:s‘),
 );
 $data_errors[] = $error_data;
 }

    }
 $errors_data = count($data_errors);
 $repetition = $cn-$errors_data;
 $success=db(‘member‘)->insertAll($datas); //批量插入数据
 if($success){
 $cn_fail=count($data_errors);
 $content = "批量新增抽奖参与者名单记录：".json_encode($data);
 $this->writelog($admin_id,$content,‘4‘);//4出席成员
 $error=$cn-$success;
 $error_all = $error-$cn_fail;
 $data = array(
 ‘code‘=>1,
 ‘message‘=>"总{$cn}条，导入成功{$success}条，其中失败{$cn_fail}条,重复{$error_all}条",
 ‘result‘=>$data_errors,
 );
 return json($data);
 }
 return json([‘code‘=>1,‘message‘=>"总{$cn}条，导入成功0条，其中重复{$repetition}条,失败{$errors_data}条",‘result‘=>$data_errors]);
}else{
 // 上传失败获取错误信息
 return json([‘code‘=>2,‘message‘=>‘导入失败‘,‘result‘=>null]);
}