From ec94cb137707a4d28161c8f94715c96330519e77 Mon Sep 17 00:00:00 2001 From: "Mr.Li" Date: Thu, 6 Apr 2023 21:04:01 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=96=87=E4=BB=B6=E6=93=8D?= =?UTF-8?q?=E4=BD=9C=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- biz/export/excel_exporter.go | 4 ++-- cmd/cmd/export.go | 2 ++ 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/biz/export/excel_exporter.go b/biz/export/excel_exporter.go index a553adc..4ce9fae 100644 --- a/biz/export/excel_exporter.go +++ b/biz/export/excel_exporter.go @@ -31,7 +31,7 @@ func (ee *ExcelExporter) Export(sql, pk string) error { } ee.count = len(data.Data) //fmt.Printf("Excel Exporter.Excel, got %v data\n", len(data)) - ee.file.Open() + //ee.file.Open() ee.file.WriteTitle(data.Title) var last interface{} for _, val := range data.Data { @@ -43,7 +43,7 @@ func (ee *ExcelExporter) Export(sql, pk string) error { ee.last = row[getPkIndex(data.Title, pk)] } - ee.file.Close() + //ee.file.Close() return nil } diff --git a/cmd/cmd/export.go b/cmd/cmd/export.go index 3092265..4c7f389 100644 --- a/cmd/cmd/export.go +++ b/cmd/cmd/export.go @@ -58,6 +58,7 @@ func JobHandler(job config.Job, d export.DataFetcher, params map[string]interfac func TaskExport(d export.DataFetcher, t config.Task, params map[string]interface{}, f export.FileAdapter, batch int) error { //todo 最多分1000个批次进行处理 + f.Open() for i := 0; i < 1000; i++ { sql := t.GetSql(params) @@ -74,5 +75,6 @@ func TaskExport(d export.DataFetcher, t config.Task, params map[string]interface params["last"] = last time.Sleep(time.Microsecond * 30) } + f.Close() return nil }