|
@@ -1,7 +1,13 @@
|
|
# xlswriter+yield+websocket
|
|
# xlswriter+yield+websocket
|
|
这是一个基于xlswriter+yield高性能操作excel/csv的库,集成了websocket用于excel操作时的进度推送。
|
|
这是一个基于xlswriter+yield高性能操作excel/csv的库,集成了websocket用于excel操作时的进度推送。
|
|
本类继承自xlswriter扩展, 重新封装了一些常用的方法,同时保持基类的用法。
|
|
本类继承自xlswriter扩展, 重新封装了一些常用的方法,同时保持基类的用法。
|
|
-xlswriter文档<https://xlswriter-docs.viest.me/>
|
|
|
|
|
|
+xlswriter文档<https://xlswriter-docs.viest.me/>
|
|
|
|
+源码:https://github.com/yzh0325/xlswrite
|
|
|
|
+**为何要使用xlswriter操作excel?**
|
|
|
|
+由于内存原因,PHPExcel数据量`相对较大`的情况下无法正常工作,虽然可以通过`修改memory_limit`配置来解决内存问题,但完成工作的时间可能会更长;xlswriter是一个 PHP C 扩展,可以更高效的读写excel.
|
|
|
|
+**yield的作用是什么呢?**
|
|
|
|
+当需要导出大量数据的时候,性能瓶颈会在数据库查询和内存上面,这时候应该分段获取数据,将获取到的数据放入yield生成器,遍历生成器获取数据循环写入excel,这样就可以避免从数据库读取大量数据一次性加载到内存而消耗了大量的内存。使用yield分段获取大量数据,可以大大的节省内存,提高服务器性能。
|
|
|
|
+
|
|
# 目录
|
|
# 目录
|
|
* [功能特性](#功能特性)
|
|
* [功能特性](#功能特性)
|
|
* 安装
|
|
* 安装
|
|
@@ -11,20 +17,24 @@ xlswriter文档<https://xlswriter-docs.viest.me/>
|
|
* [examples](#examples)
|
|
* [examples](#examples)
|
|
* [excel导出](#excel导出)
|
|
* [excel导出](#excel导出)
|
|
* [导出excel快速上手](#导出excel快速上手)
|
|
* [导出excel快速上手](#导出excel快速上手)
|
|
|
|
+ * [excel导出的两种模式](#excel导出的两种模式)
|
|
* [下载excel文件](#下载excel文件)
|
|
* [下载excel文件](#下载excel文件)
|
|
- * [使用WebSocket推送excel处理进度](#使用WebSocket推送excel处理进度)
|
|
|
|
* [设置字段&表格头](#设置字段&表格头)
|
|
* [设置字段&表格头](#设置字段&表格头)
|
|
* [样式设置](#样式设置)
|
|
* [样式设置](#样式设置)
|
|
- * [合并单元格](#合并单元格)
|
|
|
|
- * [动态合并单元格](#动态合并单元格)
|
|
|
|
- * [通用合并demo](#通用合并demo)
|
|
|
|
- * [订单类型合并demo](#订单类型合并demo)
|
|
|
|
- * [单元格数据填充相关的方法](#单元格数据填充相关的方法)
|
|
|
|
|
|
+ * [批量数据插入](#批量数据插入)
|
|
|
|
+ * [单元格](#单元格)
|
|
|
|
+ * [插入文字](#插入文字)
|
|
|
|
+ * [插入链接](#插入链接)
|
|
|
|
+ * [插入超链接(insertText+insertUrl)](#插入超链接(insertText+insertUrl))
|
|
|
|
+ * [合并单元格](#合并单元格)
|
|
|
|
+ * [动态合并单元格](#动态合并单元格)
|
|
|
|
+ * [通用合并demo](#通用合并demo)
|
|
|
|
+ * [订单类型合并demo](#订单类型合并demo)
|
|
|
|
+ * [使用WebSocket推送excel处理进度](#使用WebSocket推送excel处理进度)
|
|
* [excel读取](#excel读取)
|
|
* [excel读取](#excel读取)
|
|
* [游标读取excel分段写入数据库](#游标读取excel分段写入数据库)
|
|
* [游标读取excel分段写入数据库](#游标读取excel分段写入数据库)
|
|
-
|
|
|
|
-
|
|
|
|
-## 功能特性
|
|
|
|
|
|
+
|
|
|
|
+# 功能特性
|
|
* 高性能读写百万级别的excel数据
|
|
* 高性能读写百万级别的excel数据
|
|
* 支持动态合并单元格
|
|
* 支持动态合并单元格
|
|
* 字段定义和过滤
|
|
* 字段定义和过滤
|
|
@@ -32,7 +42,7 @@ xlswriter文档<https://xlswriter-docs.viest.me/>
|
|
* 支持 Excel 2007+ xlsx 文件
|
|
* 支持 Excel 2007+ xlsx 文件
|
|
* 支持csv文件读写
|
|
* 支持csv文件读写
|
|
|
|
|
|
-## Installing
|
|
|
|
|
|
+# Installing
|
|
```
|
|
```
|
|
composer require yzh0325/xlswrite
|
|
composer require yzh0325/xlswrite
|
|
```
|
|
```
|
|
@@ -47,15 +57,9 @@ pecl install xlswriter
|
|
* 服务端采用swoole搭建,需要安装[swoole](https://wiki.swoole.com/#/environment)扩展 swoole>=4.4.*,需在cli模式下运行
|
|
* 服务端采用swoole搭建,需要安装[swoole](https://wiki.swoole.com/#/environment)扩展 swoole>=4.4.*,需在cli模式下运行
|
|
* 客户端采用textalk/websocket的client作为websocket客户端,可在php-fpm模式下运行
|
|
* 客户端采用textalk/websocket的client作为websocket客户端,可在php-fpm模式下运行
|
|
|
|
|
|
-## examples
|
|
|
|
-见 examples/
|
|
|
|
-* xlswrite_demo.html 前端demo
|
|
|
|
-* export_demo.php excel导出demo
|
|
|
|
-* import_demo.php excel导入demo
|
|
|
|
-
|
|
|
|
-## excel导出
|
|
|
|
|
|
+# excel导出
|
|
可根据创建的文件名后缀自动导出xlsx文件和csv文件
|
|
可根据创建的文件名后缀自动导出xlsx文件和csv文件
|
|
-### 导出excel快速上手
|
|
|
|
|
|
+## 导出excel快速上手
|
|
```
|
|
```
|
|
use Pxlswrite\Pxlswrite;
|
|
use Pxlswrite\Pxlswrite;
|
|
$fileObj = new Pxlswrite(['path' => __DIR__]);
|
|
$fileObj = new Pxlswrite(['path' => __DIR__]);
|
|
@@ -82,7 +86,41 @@ function generateData(){
|
|
}
|
|
}
|
|
}
|
|
}
|
|
```
|
|
```
|
|
-### 下载excel文件
|
|
|
|
|
|
+## excel导出的两种模式
|
|
|
|
+### 导出-固定内存模式
|
|
|
|
+最大内存使用量 = 最大一行的数据占用量
|
|
|
|
+当开启内存优化模式时,单元格将根据行落地磁盘,如果当前操作的行已落盘则无法进行任何修改(比如无法进行合并单元格操作,样式设置等),内存中只保留最新一行数据,所以内存优化模式最大内存占用等于数据最多一行的内存.
|
|
|
|
+
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+
|
|
|
|
+$fileObj->constMemory('tutorial01.xlsx');
|
|
|
|
+
|
|
|
|
+$fileObj
|
|
|
|
+ ->setRow('A1', 50, ['bold'=>true,'align'=>[Pxlswrite::FORMAT_ALIGN_CENTER,Pxlswrite::FORMAT_ALIGN_VERTICAL_CENTER]]) // 写入数据前设置行样式
|
|
|
|
+ ->header(['name', 'age'])
|
|
|
|
+ ->data([['viest', 21]])
|
|
|
|
+ ->output();
|
|
|
|
+```
|
|
|
|
+### 导出-普通模式
|
|
|
|
+导出速度更快,但内存开销比固定内存模式更大
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+
|
|
|
|
+$fileObj->fileName('tutorial01.xlsx');
|
|
|
|
+
|
|
|
|
+$fileObj
|
|
|
|
+ ->header(['name', 'age'])
|
|
|
|
+ ->data([['viest', 21]])
|
|
|
|
+ ->setRow('A1', 50, ['bold'=>true,'align'=>[Pxlswrite::FORMAT_ALIGN_CENTER,Pxlswrite::FORMAT_ALIGN_VERTICAL_CENTER]]) // 可以在写入数据后设置行样式
|
|
|
|
+ ->output();
|
|
|
|
+```
|
|
|
|
+
|
|
|
|
+## 下载excel文件
|
|
可以设置文件下载完成后是否自动删除原文件,download方法参数二默认值为true自动删除原文件。
|
|
可以设置文件下载完成后是否自动删除原文件,download方法参数二默认值为true自动删除原文件。
|
|
|
|
|
|
函数原型
|
|
函数原型
|
|
@@ -101,111 +139,7 @@ $fileObj->download($filePath);
|
|
//false 文件下载后不会自动删除原文件,true 默认值,下载后自动删除原文件
|
|
//false 文件下载后不会自动删除原文件,true 默认值,下载后自动删除原文件
|
|
//$fileObj->download($filePath,false);
|
|
//$fileObj->download($filePath,false);
|
|
```
|
|
```
|
|
-### 使用WebSocket推送excel处理进度
|
|
|
|
-实现过程:前端与websocket服务器先建立连接,连接建立好之后服务端会发送一条消息 {'status' => 'onopen', 'fd' => $request->fd},
|
|
|
|
-前端将fd保存起来,在请求处理excel接口时将fd参数传给后台,后台在推送进度消息时将fd参数封装到消息体里在发送给websocket服务器
|
|
|
|
-,websocket服务器根据fd参数在推送消息给指定的前端,这就完成了web前端、websocket服务器、应用后端之间的数据交互。
|
|
|
|
-
|
|
|
|
-* 前端首次连接时websocket服务器发送的消息体结构:['status' => 'onopen', 'fd' => 1]
|
|
|
|
-* 处理过程中websocket服务器发送的消息体结构:['status' => 'processing', 'process' => 100, 'fd'=>1]
|
|
|
|
-
|
|
|
|
-前端可根据status状态进行相应的处理,status = onopen 时保存fd,status = processing 时进行进度条渲染。
|
|
|
|
-
|
|
|
|
-配置:
|
|
|
|
- WebSocket服务端默认使用9502端口,可自行修改./src/WebSocket/WebsocketServer的 CONST PORT = 9502
|
|
|
|
-
|
|
|
|
-WebSocketClient使用:
|
|
|
|
-```
|
|
|
|
-use Pxlswrite\WebSocket\WebSocketClient;
|
|
|
|
-//ws://127.0.0.1:9502 服务端地址
|
|
|
|
-//$_GET['fd'] 前端传过来的 web端与websocket服务端连接的唯一标识客户端fd
|
|
|
|
-$pushHandle = new WebSocketClient('ws://127.0.0.1:9502', $_GET['fd']);
|
|
|
|
-//发送websocket消息
|
|
|
|
-$pushHandle->send(['status' => 'rocessing', 'process' => 100, 'fd'=>1]);
|
|
|
|
-```
|
|
|
|
-处理excel时自动发送消息(在推送信息失败时不会影响、终止代码的执行,会生成相应的日志文件,日志文件存放于实例化Pxlswrite所设置的路径下的log目录,日志文件按日期存放)
|
|
|
|
-```
|
|
|
|
-//通用数据设置 generateData回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
-setGeneralData('generateData', [], [], $pushHandle)
|
|
|
|
-//订单类型数据设置 generateOrderData回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
-setOrderData('generateOrderData',[],[],pushHandle)
|
|
|
|
-```
|
|
|
|
-示例
|
|
|
|
-
|
|
|
|
-1.开启websocket 服务端
|
|
|
|
-```
|
|
|
|
-php ./src/WebSocket/WebSocketServer.php
|
|
|
|
-```
|
|
|
|
-2.web前端实现demo
|
|
|
|
-
|
|
|
|
-```
|
|
|
|
-var layer = layui.layer, $ = layui.jquery, upload = layui.upload;
|
|
|
|
-var loading, fileLoading;
|
|
|
|
-var wsServer = 'ws://127.0.0.1:9502';
|
|
|
|
-var websocket = new WebSocket(wsServer);
|
|
|
|
-var fd = 0;//客户端socket id
|
|
|
|
-websocket.onopen = function (evt) {
|
|
|
|
- console.log("Connected to WebSocket server.");
|
|
|
|
-};
|
|
|
|
-websocket.onclose = function (evt) {
|
|
|
|
- console.log("Disconnected");
|
|
|
|
-};
|
|
|
|
-websocket.onmessage = function (evt) {
|
|
|
|
- var data = JSON.parse(evt.data);
|
|
|
|
- if (data.status == 'onopen') {
|
|
|
|
- fd = data.fd;
|
|
|
|
- } else {
|
|
|
|
- $('#process').text('已处理' + data.process + '条数据...');
|
|
|
|
- // console.log(data.process);
|
|
|
|
- }
|
|
|
|
- // console.log('Retrieved data from server: ' + data);
|
|
|
|
-};
|
|
|
|
-websocket.onerror = function (evt, e) {
|
|
|
|
- console.log('Error occured: ' + evt.data);
|
|
|
|
-};
|
|
|
|
-
|
|
|
|
-//导出excel
|
|
|
|
- function exporData() {
|
|
|
|
- loading = layer.load(2, {
|
|
|
|
- shade: [0.1, '#fff'],
|
|
|
|
- content: '正在到导出,请耐心等待...',
|
|
|
|
- id: 'process',
|
|
|
|
- success: function (layero) {
|
|
|
|
- layero.find('.layui-layer-content').css({
|
|
|
|
- 'padding-top': '40px',//图标与样式会重合,这样设置可以错开
|
|
|
|
- 'width': '200px',//文字显示的宽度
|
|
|
|
- 'text-indent': '-4rem',
|
|
|
|
- });
|
|
|
|
- }
|
|
|
|
- });
|
|
|
|
- //请求后台excel文件生成接口
|
|
|
|
- $.get('/export_demo.php', {fd: fd}, function (res) {
|
|
|
|
- if (res.code == 1) {
|
|
|
|
- layer.close(loading);
|
|
|
|
- layer.msg(res.msg, {time: '1000'}, function () {
|
|
|
|
- //请求后台下载地址
|
|
|
|
- window.location.href = res.url;
|
|
|
|
- });
|
|
|
|
- }
|
|
|
|
- }, 'json');
|
|
|
|
- }
|
|
|
|
-```
|
|
|
|
-3.后端处理excel 并调用 WebSocketClient 推送消息
|
|
|
|
-```
|
|
|
|
-use Pxlswrite\Pxlswrite;
|
|
|
|
-use Pxlswrite\WebSocket\WebSocketClient;
|
|
|
|
-$fileObj = new Pxlswrite(['path' => __DIR__]);
|
|
|
|
-//实例化WebSocketClient--需要推送进度才实例化
|
|
|
|
-$pushHandle = new WebSocketClient('ws://127.0.0.1:9502', $_GET['fd']);
|
|
|
|
-$filePath = $fileObj->fileName('123.xlsx','sheet1')
|
|
|
|
- ->field($field)//设置字段&表格头
|
|
|
|
- ->setGeneralData('generateData', [], [], $pushHandle)//设置数据 回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
- ->output();//输出excel文件到磁盘
|
|
|
|
-//ajax请求返回下载地址
|
|
|
|
-echo json_encode(['code' => 1, 'msg' => '导出完毕', 'url' => '/download.php?file=' . $filePath]);
|
|
|
|
-```
|
|
|
|
-
|
|
|
|
-### 设置字段&表格头
|
|
|
|
|
|
+## 设置字段&表格头
|
|
通过field()可以进行字段的定义&表格头的设置,使用header()定义的表格头会覆盖field()定义的表格头;
|
|
通过field()可以进行字段的定义&表格头的设置,使用header()定义的表格头会覆盖field()定义的表格头;
|
|
使用field()定义字段后在使用setGeneralData()和setOrderData()时会进行字段的过滤,设置了回调的方法还会调用字段的回调方法,进行字段的格式化处理等操作。**但并不推荐设置字段的回调,因为效率不高,可以在传入数据的时候就处理好字段的值**。**推荐使field()设置表格头,设置过field才支持动态单元格行合并。**
|
|
使用field()定义字段后在使用setGeneralData()和setOrderData()时会进行字段的过滤,设置了回调的方法还会调用字段的回调方法,进行字段的格式化处理等操作。**但并不推荐设置字段的回调,因为效率不高,可以在传入数据的时候就处理好字段的值**。**推荐使field()设置表格头,设置过field才支持动态单元格行合并。**
|
|
|
|
|
|
@@ -224,6 +158,7 @@ echo json_encode(['code' => 1, 'msg' => '导出完毕', 'url' => '/download.php?
|
|
function field($field)
|
|
function field($field)
|
|
```
|
|
```
|
|
示例
|
|
示例
|
|
|
|
+
|
|
```
|
|
```
|
|
use Pxlswrite\Pxlswrite;
|
|
use Pxlswrite\Pxlswrite;
|
|
//定义字段
|
|
//定义字段
|
|
@@ -232,15 +167,18 @@ $field = [
|
|
'year' => ['name' => '出生年份'],
|
|
'year' => ['name' => '出生年份'],
|
|
'age' => ['name' => '年龄','callback'=>'ageFormat']//callback 回调方法处理格式化值 可以是函数/对象方法
|
|
'age' => ['name' => '年龄','callback'=>'ageFormat']//callback 回调方法处理格式化值 可以是函数/对象方法
|
|
];
|
|
];
|
|
-$fileObj = new Pxlswrite(['path' => __DIR__ ]);
|
|
|
|
-$fileObj->fileName('1234.xlsx')
|
|
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads' ]);
|
|
|
|
+$fileObj->fileName('field.xlsx')
|
|
->field($field)//设置字段&表格头
|
|
->field($field)//设置字段&表格头
|
|
- ->data([
|
|
|
|
- ['Rent', 1999,0],
|
|
|
|
- ['Gas', 1996,0],
|
|
|
|
- ['Food', 1998,0],
|
|
|
|
- ['Gym', 1995,0],
|
|
|
|
- ])
|
|
|
|
|
|
+ ->setGeneralData(function(){
|
|
|
|
+ yield [
|
|
|
|
+ ['name'=>'Rent', 'year'=>1999,'age'=>0],
|
|
|
|
+ ['name'=>'Gas', 'year'=>1996,'age'=>0],
|
|
|
|
+ ['name'=>'Food', 'year'=>1998,'age'=>0],
|
|
|
|
+ ['name'=>'Gym', 'year'=>1995,'age'=>0],
|
|
|
|
+ ];
|
|
|
|
+ }
|
|
|
|
+ )
|
|
->output();//输出excel文件到磁盘
|
|
->output();//输出excel文件到磁盘
|
|
//格式化字段值
|
|
//格式化字段值
|
|
function ageFormat($v, $values)
|
|
function ageFormat($v, $values)
|
|
@@ -248,7 +186,8 @@ function ageFormat($v, $values)
|
|
return date('Y') - $values['year'];
|
|
return date('Y') - $values['year'];
|
|
}
|
|
}
|
|
```
|
|
```
|
|
-### 样式设置
|
|
|
|
|
|
+
|
|
|
|
+## 样式设置
|
|
|
|
|
|
支持的样式如下:
|
|
支持的样式如下:
|
|
```
|
|
```
|
|
@@ -368,26 +307,182 @@ $filePath = $fileObj->fileName('123.xlsx','sheet1')
|
|
```
|
|
```
|
|
注意:设置行与行/列与列样式 交集范围会覆盖;行样式优先于列样式;全局默认样式不会被覆盖,谨慎使用
|
|
注意:设置行与行/列与列样式 交集范围会覆盖;行样式优先于列样式;全局默认样式不会被覆盖,谨慎使用
|
|
|
|
|
|
-### 合并单元格
|
|
|
|
- 函数原型
|
|
|
|
|
|
+
|
|
|
|
+## 批量数据插入
|
|
|
|
+通过回调生成器方法,逐行插入数据(一般通用数据)
|
|
```
|
|
```
|
|
/**
|
|
/**
|
|
- * 合并单元格
|
|
|
|
- * @param string $scope 单元格范围
|
|
|
|
- * @param string $data data
|
|
|
|
- * @param resource|array $formatHandler 合并单元格的样式
|
|
|
|
|
|
+* @todo 设置一般数据 通过回调生成器逐行向表格插入数据,
|
|
|
|
+* 设置过field才支持动态单元格合并,
|
|
|
|
+* 可以根据指定的字段 通过值比较自动进行 行合并
|
|
|
|
+* @param callable $_generator 回调数据生成器方法 返回的数据格式是二维数组 如下字段名数量不限
|
|
|
|
+* [['id'=>1,'name'=>'张三','age'=>'18']]
|
|
|
|
+* @param array $_mergeColumn 需要合并的字段
|
|
|
|
+* @param array $_mergeColumnStyle 合并单元格的样式
|
|
|
|
+* @param int $_index 单元格行偏移量 合并单元格的起始位置
|
|
|
|
+* @param WebSocketClient|null $_pushHandle
|
|
|
|
+* @return Pxlswrite
|
|
|
|
+* @throws DataFormatException 数据格式错误
|
|
|
|
+*/
|
|
|
|
+function setGeneralData($_generator, array $_mergeColumn = [], array $_mergeColumnStyle = [], WebSocketClient $_pushHandle = null, $_index = 1)
|
|
|
|
+```
|
|
|
|
+通过回调生成器方法,逐行插入数据(订单类型数据)
|
|
|
|
+```
|
|
|
|
+/**
|
|
|
|
+* @todo 设置订单数据 根据数据可以合并指定的字段,需要遵循以下数据格式
|
|
|
|
+* @param callable $_generator 数据生成器方法 返回数据格式如下,字段数量名称不限,只支持一个item二维数组
|
|
|
|
+* [
|
|
|
|
+* [
|
|
|
|
+* 'order'=>'20200632555' ,
|
|
|
|
+* 'time'=>'2020-06-30 12:30:10',
|
|
|
|
+* 'username'=>'张三',
|
|
|
|
+* 'address'=>'成都',
|
|
|
|
+* 'phone'=>'17756891562',
|
|
|
|
+* 'item'=> [
|
|
|
|
+* [
|
|
|
|
+* 'itemnumer'=>'2020515',
|
|
|
|
+* 'productname'=>'商品1',
|
|
|
|
+* 'mark'=>'备注',
|
|
|
|
+* ],
|
|
|
|
+* ],
|
|
|
|
+* ]
|
|
|
|
+* ];
|
|
|
|
+* @param array $_mergeColumn 需要合并的字段
|
|
|
|
+* @param array $_mergeColumnStyle 合并单元格样式
|
|
|
|
+* @param WebSocketClient|null $_pushHandle WebSocketClient对象 用于推送进度
|
|
|
|
+* @param int $_index 单元格行偏移量 合并单元格的起始位置
|
|
|
|
+* @return $this
|
|
|
|
+* @throws DataFormatException 数据格式错误
|
|
|
|
+*/
|
|
|
|
+function setOrderData($_generator, array $_mergeColumn = [], array $_mergeColumnStyle = [], WebSocketClient $_pushHandle = null, $_index = 1)
|
|
|
|
+```
|
|
|
|
+逐行逐列插入数据,按单元格循环插入(可以区分文本插入和超链接插入,这种方式插入的数据,后面无法通过批量设置样式)
|
|
|
|
+```
|
|
|
|
+/**
|
|
|
|
+* 设置数据,逐行逐列插入数据,可以区分分本插入和超链接插入
|
|
|
|
+* @param $_data
|
|
|
|
+* @param int $_rowIndex 单元行索引(起始位置为0)
|
|
|
|
+* @param int $_coleIndex 单元列索引(起始位置为0)
|
|
|
|
+* @throws DataFormatException
|
|
|
|
+*/
|
|
|
|
+function setData($_data,$_rowIndex = 1,$_coleIndex = 0)
|
|
|
|
+```
|
|
|
|
+批量插入数据(setGeneralData和setOrderData都是基于它来实现的)
|
|
|
|
+```
|
|
|
|
+/**
|
|
|
|
+* @todo 设置表格数据
|
|
|
|
+* @param array $_data 二维索引数组
|
|
|
|
+* @return
|
|
|
|
+*/
|
|
|
|
+function data($_data)
|
|
|
|
+```
|
|
|
|
+
|
|
|
|
+## 单元格
|
|
|
|
+
|
|
|
|
+### 插入文字
|
|
|
|
+函数原型
|
|
|
|
+```
|
|
|
|
+ /**
|
|
|
|
+ * @param int $_row 行 从0开始
|
|
|
|
+ * @param int $_col 列 从0开始
|
|
|
|
+ * @param string $_data 数据
|
|
|
|
+ * @param string $_format 数据格式
|
|
|
|
+ * @param array $_formatHandler 单元格样式
|
|
* @return $this
|
|
* @return $this
|
|
* @throws DataFormatException
|
|
* @throws DataFormatException
|
|
*/
|
|
*/
|
|
-mergeCells($scope, $data, $formatHandler = null)
|
|
|
|
|
|
+ function insertText($_row, $_col, $_data, $_format = '', $_formatHandler=[])
|
|
```
|
|
```
|
|
- 示例
|
|
|
|
|
|
+示例
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+
|
|
|
|
+$fileObj->fileName("insertText.xlsx")
|
|
|
|
+ ->header(['name', 'money']);
|
|
|
|
+
|
|
|
|
+for ($index = 0; $index < 10; $index++) {
|
|
|
|
+ $fileObj->insertText($index+1, 0, 'viest');
|
|
|
|
+ $fileObj->insertText($index+1, 1, 10000, '#,##0'); // #,##0 为单元格数据样式
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+$fileObj->output();
|
|
|
|
+```
|
|
|
|
+**数字样式示例**
|
|
|
|
+更多样式请参考 Excel 微软文档
|
|
|
|
+```
|
|
|
|
+"0.000"
|
|
|
|
+"#,##0"
|
|
|
|
+"#,##0.00"
|
|
|
|
+"0.00"
|
|
|
|
+"0 \"dollar and\" .00 \"cents\""
|
|
|
|
+```
|
|
|
|
+### 插入链接
|
|
|
|
+函数原型
|
|
```
|
|
```
|
|
-$fileObj->fileName("test.xlsx")
|
|
|
|
- ->mergeCells('A1:C1', 'Merge cells')
|
|
|
|
- ->output();
|
|
|
|
|
|
+/**
|
|
|
|
+* 插入链接
|
|
|
|
+* @param int $_row 行 从0开始
|
|
|
|
+* @param int $_col 列 从0开始
|
|
|
|
+* @param string $_url 链接地址
|
|
|
|
+* @param array $_formatHandler 单元格样式
|
|
|
|
+* @return $this
|
|
|
|
+* @throws DataFormatException
|
|
|
|
+*/
|
|
|
|
+function insertUrl($_row,$_col,$_url, $_formatHandler = [])
|
|
|
|
+```
|
|
|
|
+示例
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+
|
|
|
|
+$fileObj->fileName("insertUrl.xlsx");
|
|
|
|
+
|
|
|
|
+$fileObj->insertUrl(1, 0, 'https://github.com', ['underline'=>Pxlswrite::UNDERLINE_SINGLE,'fontColor'=>Pxlswrite::COLOR_GREEN]);
|
|
|
|
+
|
|
|
|
+$fileObj->output();
|
|
```
|
|
```
|
|
-#### 动态合并单元格
|
|
|
|
|
|
+### 插入超链接(insertText+insertUrl)
|
|
|
|
+示例
|
|
|
|
+注意:insertUrl和insertText的顺序不能写反了
|
|
|
|
+insertText会覆盖insertUrl写入的文本内容,同时会保持insertUrl的超链接
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+
|
|
|
|
+$fileObj->fileName("insertUrl.xlsx");
|
|
|
|
+$fileObj->insertUrl(1, 0, 'https://github.com', ['underline'=>Pxlswrite::UNDERLINE_SINGLE,'fontColor'=>Pxlswrite::COLOR_GREEN]);
|
|
|
|
+$fileObj->insertText(1, 0, 'View');
|
|
|
|
+
|
|
|
|
+$fileObj->output();
|
|
|
|
+```
|
|
|
|
+### 合并单元格
|
|
|
|
+函数原型
|
|
|
|
+```
|
|
|
|
+ /**
|
|
|
|
+ * @todo 合并单元格
|
|
|
|
+ * @param string $_scope 单元格范围
|
|
|
|
+ * @param string $_data data
|
|
|
|
+ * @param resource|array $_formatHandler 合并单元格的样式
|
|
|
|
+ * @return $this
|
|
|
|
+ * @throws DataFormatException
|
|
|
|
+ */
|
|
|
|
+ function mergeCells($_scope, $_data, $_formatHandler = null)
|
|
|
|
+```
|
|
|
|
+示例
|
|
|
|
+```
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads']);
|
|
|
|
+$fileObj->fileName("mergeCells.xlsx")
|
|
|
|
+ ->mergeCells('A1:C1', 'Merge cells')
|
|
|
|
+ ->output();
|
|
|
|
+```
|
|
|
|
+更多单元格操作见[xlswriter](https://xlswriter-docs.viest.me/zh-cn/dan-yuan-ge)
|
|
|
|
+## 动态合并单元格
|
|
* 通用合并,根据数据的值比较 自动进行 行合并(调用方法时需要指定要自动合并的字段,才会根据字段值进行自动合并)
|
|
* 通用合并,根据数据的值比较 自动进行 行合并(调用方法时需要指定要自动合并的字段,才会根据字段值进行自动合并)
|
|
|
|
|
|
优点:数据层不需要怎么处理,将数据库查询出来的二维数组直接传入即可。
|
|
优点:数据层不需要怎么处理,将数据库查询出来的二维数组直接传入即可。
|
|
@@ -417,7 +512,7 @@ $data = [
|
|
```
|
|
```
|
|
字段数量,名称没有限制,只支持一个item(也可以叫其他名字)二维数组,item数组里面的个数没有限制。
|
|
字段数量,名称没有限制,只支持一个item(也可以叫其他名字)二维数组,item数组里面的个数没有限制。
|
|
**当数据字段的值能明显区分时推荐使用通用合并,当数据字段的值不能明显区分时(如:时间字段)推荐订单类型的合并**
|
|
**当数据字段的值能明显区分时推荐使用通用合并,当数据字段的值不能明显区分时(如:时间字段)推荐订单类型的合并**
|
|
-##### 通用合并demo
|
|
|
|
|
|
+### 通用合并demo
|
|
函数原型
|
|
函数原型
|
|
```
|
|
```
|
|
/**
|
|
/**
|
|
@@ -445,8 +540,8 @@ $field = [
|
|
'c2' => ['name' => 'year'],
|
|
'c2' => ['name' => 'year'],
|
|
'c3' => ['name' => 'kk'],
|
|
'c3' => ['name' => 'kk'],
|
|
];
|
|
];
|
|
-$fileObj = new Pxlswrite(['path' => __DIR__ ]);
|
|
|
|
-$filePath = $fileObj->fileName('123.xlsx');
|
|
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__ . '/uploads' ]);
|
|
|
|
+$filePath = $fileObj->fileName('general.xlsx')
|
|
->field($field)//设置字段&表格头
|
|
->field($field)//设置字段&表格头
|
|
->setGeneralData('generateData', ['c1', 'c2'], ['align' => [Pxlswrite::FORMAT_ALIGN_CENTER, Pxlswrite::FORMAT_ALIGN_VERTICAL_CENTER]])//设置数据 并自动合并单元格
|
|
->setGeneralData('generateData', ['c1', 'c2'], ['align' => [Pxlswrite::FORMAT_ALIGN_CENTER, Pxlswrite::FORMAT_ALIGN_VERTICAL_CENTER]])//设置数据 并自动合并单元格
|
|
->output();//输出excel文件到磁盘
|
|
->output();//输出excel文件到磁盘
|
|
@@ -454,12 +549,13 @@ $filePath = $fileObj->fileName('123.xlsx');
|
|
function generateData(){
|
|
function generateData(){
|
|
for($i=0;$i<10000;$i++){
|
|
for($i=0;$i<10000;$i++){
|
|
yield [
|
|
yield [
|
|
- ['id'=>$i,'c1'=>$i+1,'c2'=>$i+2,'c3'=>$i+3];
|
|
|
|
- ];
|
|
|
|
|
|
+ ['id'=>$i,'c1'=>$i+1,'c2'=>$i+2,'c3'=>$i+3],
|
|
|
|
+ ['id'=>$i,'c1'=>$i+1,'c2'=>$i+2,'c3'=>$i+3],
|
|
|
|
+ ];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
```
|
|
```
|
|
-##### 订单类型合并demo
|
|
|
|
|
|
+### 订单类型合并demo
|
|
函数原型
|
|
函数原型
|
|
```
|
|
```
|
|
/**
|
|
/**
|
|
@@ -540,78 +636,112 @@ function generateOrderData(){
|
|
}
|
|
}
|
|
}
|
|
}
|
|
```
|
|
```
|
|
-## 单元格数据填充相关的方法
|
|
|
|
-使用生成器,逐行插入数据(一般通用数据)
|
|
|
|
|
|
+## 使用WebSocket推送excel处理进度
|
|
|
|
+实现过程:前端与websocket服务器先建立连接,连接建立好之后服务端会发送一条消息 {'status' => 'onopen', 'fd' => $request->fd},
|
|
|
|
+前端将fd保存起来,在请求处理excel接口时将fd参数传给后台,后台在推送进度消息时将fd参数封装到消息体里在发送给websocket服务器
|
|
|
|
+,websocket服务器根据fd参数在推送消息给指定的前端,这就完成了web前端、websocket服务器、应用后端之间的数据交互。
|
|
|
|
+
|
|
|
|
+* 前端首次连接时websocket服务器发送的消息体结构:['status' => 'onopen', 'fd' => 1]
|
|
|
|
+* 处理过程中websocket服务器发送的消息体结构:['status' => 'processing', 'process' => 100, 'fd'=>1]
|
|
|
|
+
|
|
|
|
+前端可根据status状态进行相应的处理,status = onopen 时保存fd,status = processing 时进行进度条渲染。
|
|
|
|
+
|
|
|
|
+配置:
|
|
|
|
+ WebSocket服务端默认使用9502端口,可自行修改./src/WebSocket/WebsocketServer的 CONST PORT = 9502
|
|
|
|
+
|
|
|
|
+WebSocketClient使用:
|
|
```
|
|
```
|
|
-/**
|
|
|
|
-* @todo 设置一般数据 通过生成器逐行向表格插入数据,
|
|
|
|
-* 设置过field才支持动态单元格合并,
|
|
|
|
-* 可以根据指定的字段 通过值比较自动进行 行合并
|
|
|
|
-* @param callable $_generator 回调数据生成器方法 返回的数据格式是二维数组 如下字段名数量不限
|
|
|
|
-* [['id'=>1,'name'=>'张三','age'=>'18']]
|
|
|
|
-* @param array $_mergeColumn 需要合并的字段
|
|
|
|
-* @param array $_mergeColumnStyle 合并单元格的样式
|
|
|
|
-* @param int $_index 单元格行偏移量 合并单元格的起始位置
|
|
|
|
-* @param WebSocketClient|null $_pushHandle
|
|
|
|
-* @return Pxlswrite
|
|
|
|
-* @throws DataFormatException 数据格式错误
|
|
|
|
-*/
|
|
|
|
-function setGeneralData($_generator, array $_mergeColumn = [], array $_mergeColumnStyle = [], WebSocketClient $_pushHandle = null, $_index = 1)
|
|
|
|
|
|
+use Pxlswrite\WebSocket\WebSocketClient;
|
|
|
|
+//ws://127.0.0.1:9502 服务端地址
|
|
|
|
+//$_GET['fd'] 前端传过来的 web端与websocket服务端连接的唯一标识客户端fd
|
|
|
|
+$pushHandle = new WebSocketClient('ws://127.0.0.1:9502', $_GET['fd']);
|
|
|
|
+//发送websocket消息
|
|
|
|
+$pushHandle->send(['status' => 'rocessing', 'process' => 100, 'fd'=>1]);
|
|
```
|
|
```
|
|
-使用生成器,逐行插入数据(订单类型数据)
|
|
|
|
|
|
+处理excel时自动发送消息(在推送信息失败时不会影响、终止代码的执行,会生成相应的日志文件,日志文件存放于实例化Pxlswrite所设置的路径下的log目录,日志文件按日期存放)
|
|
```
|
|
```
|
|
-/**
|
|
|
|
-* @todo 设置订单数据 根据数据可以合并指定的字段,需要遵循以下数据格式
|
|
|
|
-* @param callable $_generator 数据生成器方法 返回数据格式如下,字段数量名称不限,只支持一个item二维数组
|
|
|
|
-* [
|
|
|
|
-* [
|
|
|
|
-* 'order'=>'20200632555' ,
|
|
|
|
-* 'time'=>'2020-06-30 12:30:10',
|
|
|
|
-* 'username'=>'张三',
|
|
|
|
-* 'address'=>'成都',
|
|
|
|
-* 'phone'=>'17756891562',
|
|
|
|
-* 'item'=> [
|
|
|
|
-* [
|
|
|
|
-* 'itemnumer'=>'2020515',
|
|
|
|
-* 'productname'=>'商品1',
|
|
|
|
-* 'mark'=>'备注',
|
|
|
|
-* ],
|
|
|
|
-* ],
|
|
|
|
-* ]
|
|
|
|
-* ];
|
|
|
|
-* @param array $_mergeColumn 需要合并的字段
|
|
|
|
-* @param array $_mergeColumnStyle 合并单元格样式
|
|
|
|
-* @param WebSocketClient|null $_pushHandle WebSocketClient对象 用于推送进度
|
|
|
|
-* @param int $_index 单元格行偏移量 合并单元格的起始位置
|
|
|
|
-* @return $this
|
|
|
|
-* @throws DataFormatException 数据格式错误
|
|
|
|
-*/
|
|
|
|
-function setOrderData($_generator, array $_mergeColumn = [], array $_mergeColumnStyle = [], WebSocketClient $_pushHandle = null, $_index = 1)
|
|
|
|
|
|
+//通用数据设置 generateData回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
+setGeneralData('generateData', [], [], $pushHandle)
|
|
|
|
+//订单类型数据设置 generateOrderData回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
+setOrderData('generateOrderData',[],[],pushHandle)
|
|
```
|
|
```
|
|
-逐行逐列插入数据,按单元格循环插入(可以区分文本插入和超链接插入,这种方式插入的数据,后面无法通过批量设置样式)
|
|
|
|
|
|
+示例
|
|
|
|
+
|
|
|
|
+1.开启websocket 服务端
|
|
```
|
|
```
|
|
-/**
|
|
|
|
-* 设置数据,逐行逐列插入数据,可以区分分本插入和超链接插入
|
|
|
|
-* @param $_data
|
|
|
|
-* @param int $_rowIndex 单元行索引(起始位置为0)
|
|
|
|
-* @param int $_coleIndex 单元列索引(起始位置为0)
|
|
|
|
-* @throws DataFormatException
|
|
|
|
-*/
|
|
|
|
-function setData($_data,$_rowIndex = 1,$_coleIndex = 0)
|
|
|
|
|
|
+php ./src/WebSocket/WebSocketServer.php
|
|
```
|
|
```
|
|
-批量插入数据(setGeneralData和setOrderData都是基于它来实现的)
|
|
|
|
|
|
+2.web前端实现demo
|
|
|
|
+
|
|
```
|
|
```
|
|
-/**
|
|
|
|
-* @todo 设置表格数据
|
|
|
|
-* @param array $_data 二维索引数组
|
|
|
|
-* @return
|
|
|
|
-*/
|
|
|
|
-function data($_data)
|
|
|
|
|
|
+var layer = layui.layer, $ = layui.jquery, upload = layui.upload;
|
|
|
|
+var loading, fileLoading;
|
|
|
|
+var wsServer = 'ws://127.0.0.1:9502';
|
|
|
|
+var websocket = new WebSocket(wsServer);
|
|
|
|
+var fd = 0;//客户端socket id
|
|
|
|
+websocket.onopen = function (evt) {
|
|
|
|
+ console.log("Connected to WebSocket server.");
|
|
|
|
+};
|
|
|
|
+websocket.onclose = function (evt) {
|
|
|
|
+ console.log("Disconnected");
|
|
|
|
+};
|
|
|
|
+websocket.onmessage = function (evt) {
|
|
|
|
+ var data = JSON.parse(evt.data);
|
|
|
|
+ if (data.status == 'onopen') {
|
|
|
|
+ fd = data.fd;
|
|
|
|
+ } else {
|
|
|
|
+ $('#process').text('已处理' + data.process + '条数据...');
|
|
|
|
+ // console.log(data.process);
|
|
|
|
+ }
|
|
|
|
+ // console.log('Retrieved data from server: ' + data);
|
|
|
|
+};
|
|
|
|
+websocket.onerror = function (evt, e) {
|
|
|
|
+ console.log('Error occured: ' + evt.data);
|
|
|
|
+};
|
|
|
|
+
|
|
|
|
+//导出excel
|
|
|
|
+ function exporData() {
|
|
|
|
+ loading = layer.load(2, {
|
|
|
|
+ shade: [0.1, '#fff'],
|
|
|
|
+ content: '正在到导出,请耐心等待...',
|
|
|
|
+ id: 'process',
|
|
|
|
+ success: function (layero) {
|
|
|
|
+ layero.find('.layui-layer-content').css({
|
|
|
|
+ 'padding-top': '40px',//图标与样式会重合,这样设置可以错开
|
|
|
|
+ 'width': '200px',//文字显示的宽度
|
|
|
|
+ 'text-indent': '-4rem',
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+ });
|
|
|
|
+ //请求后台excel文件生成接口
|
|
|
|
+ $.get('/export_demo.php', {fd: fd}, function (res) {
|
|
|
|
+ if (res.code == 1) {
|
|
|
|
+ layer.close(loading);
|
|
|
|
+ layer.msg(res.msg, {time: '1000'}, function () {
|
|
|
|
+ //请求后台下载地址
|
|
|
|
+ window.location.href = res.url;
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+ }, 'json');
|
|
|
|
+ }
|
|
|
|
+```
|
|
|
|
+3.后端处理excel 并调用 WebSocketClient 推送消息
|
|
```
|
|
```
|
|
-更多使用方法见[xlswriter](https://xlswriter-docs.viest.me/zh-cn/dan-yuan-ge)
|
|
|
|
-## excel读取
|
|
|
|
|
|
+use Pxlswrite\Pxlswrite;
|
|
|
|
+use Pxlswrite\WebSocket\WebSocketClient;
|
|
|
|
+$fileObj = new Pxlswrite(['path' => __DIR__]);
|
|
|
|
+//实例化WebSocketClient--需要推送进度才实例化
|
|
|
|
+$pushHandle = new WebSocketClient('ws://127.0.0.1:9502', $_GET['fd']);
|
|
|
|
+$filePath = $fileObj->fileName('123.xlsx','sheet1')
|
|
|
|
+ ->field($field)//设置字段&表格头
|
|
|
|
+ ->setGeneralData('generateData', [], [], $pushHandle)//设置数据 回调生成器方法获取数据,$pushHandle 用于推送,可选参数
|
|
|
|
+ ->output();//输出excel文件到磁盘
|
|
|
|
+//ajax请求返回下载地址
|
|
|
|
+echo json_encode(['code' => 1, 'msg' => '导出完毕', 'url' => '/download.php?file=' . $filePath]);
|
|
|
|
+```
|
|
|
|
+# excel读取
|
|
可读取xlsx文件和csv文件
|
|
可读取xlsx文件和csv文件
|
|
-### 游标读取excel分段写入数据库
|
|
|
|
|
|
+## 游标读取excel分段写入数据库
|
|
函数原型
|
|
函数原型
|
|
```
|
|
```
|
|
/**
|
|
/**
|
|
@@ -645,4 +775,9 @@ function insert_data($data)
|
|
$db->execute("insert into sheet2 (id,c1,c2,c3,c4) values " . $sql);
|
|
$db->execute("insert into sheet2 (id,c1,c2,c3,c4) values " . $sql);
|
|
}
|
|
}
|
|
```
|
|
```
|
|
-更多使用方法见 [xlswrite](https://xlswriter-docs.viest.me/zh-cn)
|
|
|
|
|
|
+更多使用方法见 [xlswrite](https://xlswriter-docs.viest.me/zh-cn)
|
|
|
|
+# examples
|
|
|
|
+见 examples/
|
|
|
|
+* xlswrite_demo.html 前端demo
|
|
|
|
+* export_demo.php excel导出demo
|
|
|
|
+* import_demo.php excel导入demo
|