511 lines
17 KiB
Go
511 lines
17 KiB
Go
package controller
|
||
|
||
import (
|
||
"database/sql"
|
||
"errors"
|
||
"fmt"
|
||
"net/http"
|
||
"os"
|
||
"path/filepath"
|
||
"planA/modules/logs"
|
||
"planA/rep"
|
||
"planA/service"
|
||
"planA/tool"
|
||
_type "planA/type"
|
||
"planA/validator"
|
||
|
||
"github.com/go-redis/redis/v8"
|
||
)
|
||
|
||
// GetExportTask 导出任务列表
|
||
func GetExportTask(httpMsg http.ResponseWriter, data *http.Request) {
|
||
|
||
// 验证表单
|
||
dataVal, GetExportValidatorErr := validator.GetExportValidator(data)
|
||
if GetExportValidatorErr != nil {
|
||
tool.Error(httpMsg, GetExportValidatorErr.Error(), http.StatusInternalServerError)
|
||
return
|
||
}
|
||
page, size := tool.SetPage(dataVal.Page, dataVal.Size)
|
||
|
||
read := rep.CreateDbFactoryRead()
|
||
records, total, getTaskRecordsListErr := read.GetTaskExportList(page, size, "")
|
||
if getTaskRecordsListErr != nil {
|
||
errMsg := getTaskRecordsListErr.Error()
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
var dataTaskAll []map[string]interface{}
|
||
for _, v := range records {
|
||
complete, getExportFileProgressErr := service.GetExportFileProgress(v.TaskId)
|
||
if getExportFileProgressErr != nil {
|
||
errMsg := "获取任务进度失败: " + getExportFileProgressErr.Error()
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
continue
|
||
}
|
||
taskExportdata := map[string]interface{}{
|
||
"task_id": v.TaskId,
|
||
"shop_name": v.ShopName,
|
||
"status": v.Status,
|
||
"total": v.Total,
|
||
"file_url": v.FileUrl,
|
||
"complete_at": v.CompleteAt.Time,
|
||
"create_at": v.CreateAt,
|
||
"complete": complete,
|
||
}
|
||
dataTaskAll = append(dataTaskAll, taskExportdata)
|
||
}
|
||
dataRet := map[string]interface{}{
|
||
"page": page,
|
||
"size": size,
|
||
"total": total,
|
||
"list": dataTaskAll,
|
||
}
|
||
tool.Success(httpMsg, dataRet)
|
||
}
|
||
|
||
// GetExportTaskByUserId 导出任务列表-用户
|
||
func GetExportTaskByUserId(httpMsg http.ResponseWriter, data *http.Request) {
|
||
|
||
// 验证表单
|
||
dataVal, GetExportByUserIdValidatorErr := validator.GetExportByUserIdValidator(data)
|
||
if GetExportByUserIdValidatorErr != nil {
|
||
tool.Error(httpMsg, GetExportByUserIdValidatorErr.Error(), http.StatusInternalServerError)
|
||
return
|
||
}
|
||
page, size := tool.SetPage(dataVal.Page, dataVal.Size)
|
||
|
||
read := rep.CreateDbFactoryRead()
|
||
records, total, getTaskRecordsListErr := read.GetTaskExportList(page, size, dataVal.UserID)
|
||
if getTaskRecordsListErr != nil {
|
||
errMsg := getTaskRecordsListErr.Error()
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
dataTaskAll := []map[string]interface{}{}
|
||
for _, v := range records {
|
||
complete, getExportFileProgressErr := service.GetExportFileProgress(v.TaskId)
|
||
if errors.Is(getExportFileProgressErr, redis.Nil) {
|
||
complete = int(v.Total)
|
||
} else if getExportFileProgressErr != nil {
|
||
errMsg := "获取任务进度失败: " + getExportFileProgressErr.Error()
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
taskExportdata := map[string]interface{}{
|
||
"task_id": v.TaskId,
|
||
"shop_name": v.ShopName,
|
||
"status": v.Status,
|
||
"total": v.Total,
|
||
"file_url": v.FileUrl,
|
||
"complete_at": v.CompleteAt.Time,
|
||
"create_at": v.CreateAt,
|
||
"complete": complete,
|
||
}
|
||
dataTaskAll = append(dataTaskAll, taskExportdata)
|
||
}
|
||
dataRet := map[string]interface{}{
|
||
"page": page,
|
||
"size": size,
|
||
"total": total,
|
||
"list": dataTaskAll,
|
||
}
|
||
tool.Success(httpMsg, dataRet)
|
||
}
|
||
|
||
// ExportTaskDetail 根据任务 id导出任务详情
|
||
func ExportTaskDetail(httpMsg http.ResponseWriter, data *http.Request) {
|
||
|
||
// 验证表单
|
||
dataVal, GetExportDetailValidatorErr := validator.GetExportDetailValidator(data)
|
||
if GetExportDetailValidatorErr != nil {
|
||
tool.Error(httpMsg, GetExportDetailValidatorErr.Error(), http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
read := rep.CreateDbFactoryRead()
|
||
|
||
//查询是任务信息
|
||
taskRecord, getTaskRecordsByTaskIDErr := read.GetTaskRecordsByTaskId(dataVal.TaskID)
|
||
if getTaskRecordsByTaskIDErr != nil {
|
||
errMsg := fmt.Sprintf("获取任务信息失败 %v", getTaskRecordsByTaskIDErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
if taskRecord.IsExport == 1 {
|
||
errMsg := "任务已导出过，请在下载中心查看"
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
//获取任务详情总数
|
||
total, GetBodyOverCount := service.GetBodyOverCount(dataVal.TaskID)
|
||
if GetBodyOverCount != nil {
|
||
errMsg := fmt.Sprintf("获取任务详情总数失败 %v", GetBodyOverCount)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
mysqlWrite, sqliteWrite := rep.CreateDbFactoryWrite()
|
||
//查询导出任务是存在
|
||
taskExport, getTaskExportByTaskIdErr := read.GetTaskExportByTaskId(dataVal.TaskID)
|
||
if getTaskExportByTaskIdErr != nil {
|
||
errMsg := fmt.Sprintf("获取任务信息失败 %v", getTaskExportByTaskIdErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
if taskExport.Id == 0 {
|
||
//创建一条导出任务
|
||
var status int64
|
||
var fileUrl string
|
||
mysqlCreateTaskExportErr := mysqlWrite.CreateTaskExport(_type.TaskExportDTO{
|
||
UserId: taskRecord.UserId,
|
||
ShopId: taskRecord.ShopId,
|
||
TaskId: taskRecord.TaskId,
|
||
ShopName: taskRecord.ShopName,
|
||
FileUrl: fileUrl,
|
||
Status: status,
|
||
Total: total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if mysqlCreateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("写入任务信息失败 %v", mysqlCreateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteCreateTaskExportErr := sqliteWrite.CreateTaskExport(_type.TaskExportDTO{
|
||
UserId: taskRecord.UserId,
|
||
ShopId: taskRecord.ShopId,
|
||
TaskId: taskRecord.TaskId,
|
||
ShopName: taskRecord.ShopName,
|
||
FileUrl: fileUrl,
|
||
Status: status,
|
||
Total: total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if sqLiteCreateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("写入任务信息失败 %v", sqLiteCreateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
} else {
|
||
newTotal := taskExport.Total + total
|
||
// 如果数据存在 清空完成时间 并且 修改任务总数量
|
||
mysqlUpdateTaskExportErr := mysqlWrite.UpdateTaskExport(_type.TaskExportDTO{
|
||
Id: taskExport.Id,
|
||
UserId: taskExport.UserId,
|
||
ShopId: taskExport.ShopId,
|
||
TaskId: taskExport.TaskId,
|
||
ShopName: taskExport.ShopName,
|
||
FileUrl: taskExport.FileUrl,
|
||
Status: taskExport.Status,
|
||
Total: newTotal,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if mysqlUpdateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务信息失败 %v", mysqlUpdateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteUpdateTaskExportErr := sqliteWrite.UpdateTaskExport(_type.TaskExportDTO{
|
||
Id: taskExport.Id,
|
||
UserId: taskExport.UserId,
|
||
ShopId: taskExport.ShopId,
|
||
TaskId: taskExport.TaskId,
|
||
ShopName: taskExport.ShopName,
|
||
FileUrl: taskExport.FileUrl,
|
||
Status: taskExport.Status,
|
||
Total: newTotal,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if sqLiteUpdateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务信息失败 %v", sqLiteUpdateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
}
|
||
//修改任务导出状态
|
||
mysqlUpdateTaskRecordsErr := mysqlWrite.UpdateTaskRecords(_type.TaskRecordsDTO{
|
||
Id: taskRecord.Id,
|
||
UserId: taskRecord.UserId,
|
||
ShopId: taskRecord.ShopId,
|
||
TaskId: taskRecord.TaskId,
|
||
ShopName: taskRecord.ShopName,
|
||
IsExport: 1,
|
||
TaskType: taskRecord.TaskType,
|
||
})
|
||
if mysqlUpdateTaskRecordsErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务导出状态失败 %v", mysqlUpdateTaskRecordsErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteUpdateTaskRecordsErr := sqliteWrite.UpdateTaskRecords(_type.TaskRecordsDTO{
|
||
Id: taskRecord.Id,
|
||
UserId: taskRecord.UserId,
|
||
ShopId: taskRecord.ShopId,
|
||
TaskId: taskRecord.TaskId,
|
||
ShopName: taskRecord.ShopName,
|
||
IsExport: 1,
|
||
TaskType: taskRecord.TaskType,
|
||
})
|
||
if sqLiteUpdateTaskRecordsErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务导出状态失败 %v", sqLiteUpdateTaskRecordsErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
go ExportCSV(dataVal.TaskID, total, taskRecord.TaskType)
|
||
tool.Success(httpMsg, "")
|
||
}
|
||
|
||
// ExportTaskDetailByUserId 根据任务 id导出任务详情-用户
|
||
func ExportTaskDetailByUserId(httpMsg http.ResponseWriter, data *http.Request) {
|
||
|
||
// 验证表单
|
||
dataVal, GetExportDetailValidatorErr := validator.GetExportDetailByUserIdValidator(data)
|
||
if GetExportDetailValidatorErr != nil {
|
||
tool.Error(httpMsg, GetExportDetailValidatorErr.Error(), http.StatusInternalServerError)
|
||
return
|
||
}
|
||
read := rep.CreateDbFactoryRead()
|
||
|
||
//查询任务信息
|
||
task, getTaskRecordsByTaskIdErr := read.GetTaskRecordsByTaskId(dataVal.TaskID)
|
||
if getTaskRecordsByTaskIdErr != nil {
|
||
errMsg := fmt.Sprintf("获取任务信息失败 %v", getTaskRecordsByTaskIdErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
// 验证用户
|
||
if dataVal.UserID != fmt.Sprintf("%v", task.UserId) {
|
||
errMsg := "用户验证失败"
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
if task.IsExport == 1 {
|
||
errMsg := "任务已导出过，请在下载中心查看"
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
//获取任务详情总数
|
||
total, GetBodyOverCount := service.GetBodyOverCount(dataVal.TaskID)
|
||
if GetBodyOverCount != nil {
|
||
errMsg := fmt.Sprintf("获取任务详情总数失败 %v", GetBodyOverCount)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
mysqlWrite, sqliteWrite := rep.CreateDbFactoryWrite()
|
||
//查询导出任务是存在
|
||
taskExport, getTaskExportByTaskIdErr := read.GetTaskExportByTaskId(dataVal.TaskID)
|
||
if getTaskExportByTaskIdErr != nil {
|
||
errMsg := fmt.Sprintf("获取任务信息失败 %v", getTaskExportByTaskIdErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
if taskExport.Id == 0 {
|
||
//向导出任务表写入一条数据
|
||
mysqlCreateTaskExportErr := mysqlWrite.CreateTaskExport(_type.TaskExportDTO{
|
||
UserId: task.UserId,
|
||
ShopId: task.ShopId,
|
||
TaskId: dataVal.TaskID,
|
||
ShopName: task.ShopName,
|
||
FileUrl: "",
|
||
Status: 0,
|
||
Total: total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if mysqlCreateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("写入任务信息失败 %v", mysqlCreateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteCreateTaskExport := sqliteWrite.CreateTaskExport(_type.TaskExportDTO{
|
||
UserId: task.UserId,
|
||
ShopId: task.ShopId,
|
||
TaskId: dataVal.TaskID,
|
||
ShopName: task.ShopName,
|
||
FileUrl: "",
|
||
Status: 0,
|
||
Total: total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if sqLiteCreateTaskExport != nil {
|
||
errMsg := fmt.Sprintf("写入任务信息失败 %v", sqLiteCreateTaskExport)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
} else {
|
||
// 如果数据存在 清空完成时间 并且 修改任务总数量
|
||
mysqlUpdateTaskExportErr := mysqlWrite.UpdateTaskExport(_type.TaskExportDTO{
|
||
Id: taskExport.Id,
|
||
UserId: taskExport.UserId,
|
||
ShopId: taskExport.ShopId,
|
||
TaskId: taskExport.TaskId,
|
||
ShopName: taskExport.ShopName,
|
||
FileUrl: taskExport.FileUrl,
|
||
Status: taskExport.Status,
|
||
Total: taskExport.Total + total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if mysqlUpdateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务信息失败 %v", mysqlUpdateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteUpdateTaskExportErr := sqliteWrite.UpdateTaskExport(_type.TaskExportDTO{
|
||
Id: taskExport.Id,
|
||
UserId: taskExport.UserId,
|
||
ShopId: taskExport.ShopId,
|
||
TaskId: taskExport.TaskId,
|
||
ShopName: taskExport.ShopName,
|
||
FileUrl: taskExport.FileUrl,
|
||
Status: taskExport.Status,
|
||
Total: taskExport.Total + total,
|
||
CompleteAt: sql.NullTime{},
|
||
})
|
||
if sqLiteUpdateTaskExportErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务信息失败 %v", sqLiteUpdateTaskExportErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
}
|
||
|
||
//修改任务导出状态
|
||
mysqlUpdateTaskExportStatusErr := mysqlWrite.UpdateTaskExportStatus(dataVal.TaskID, 1, "")
|
||
if mysqlUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务导出状态失败 %v", mysqlUpdateTaskExportStatusErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
sqLiteUpdateTaskExportStatusErr := sqliteWrite.UpdateTaskExportStatus(dataVal.TaskID, 1, "")
|
||
if sqLiteUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("修改任务导出状态失败 %v", sqLiteUpdateTaskExportStatusErr)
|
||
tool.Error(httpMsg, errMsg, http.StatusInternalServerError)
|
||
return
|
||
}
|
||
|
||
go ExportCSV(dataVal.TaskID, total, task.TaskType)
|
||
tool.Success(httpMsg, "")
|
||
}
|
||
|
||
// ExportCSV 导出CSV
|
||
// taskId 任务id
|
||
// total 总数
|
||
// taskType 任务类型
|
||
// ExportCSV 导出CSV
|
||
// taskId 任务id
|
||
// total 总数
|
||
func ExportCSV(taskId string, total int64, taskType int64) {
|
||
// 定义每次获取的数量
|
||
batchSize := 1000
|
||
csvFileName := fmt.Sprintf("%v.csv", taskId)
|
||
|
||
// 定义导出目录
|
||
exportDir := "file/export"
|
||
// 检查并创建目录（如果不存在）
|
||
err := os.MkdirAll(exportDir, 0755)
|
||
if err != nil {
|
||
errMsg := fmt.Sprintf("创建目录失败: %v", err)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
return
|
||
}
|
||
|
||
// 拼接完整的文件路径
|
||
fullPath := filepath.Join(exportDir, csvFileName)
|
||
|
||
// 检查文件是否已存在
|
||
fileExists := false
|
||
if _, err := os.Stat(fullPath); err == nil {
|
||
fileExists = true
|
||
fmt.Printf("文件已存在: %s，将在末尾追加数据\n", fullPath)
|
||
} else if !os.IsNotExist(err) {
|
||
// 其他错误（如权限问题）
|
||
errMsg := fmt.Sprintf("检查文件状态失败: %v", err)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
return
|
||
}
|
||
|
||
// 初始化偏移量
|
||
page := 1
|
||
// 标记是否是第一次写入（用于写入CSV表头）
|
||
// 如果文件已存在，则不需要写入表头
|
||
isFirstWrite := !fileExists
|
||
|
||
mysqlWrite, sqliteWrite := rep.CreateDbFactoryWrite()
|
||
|
||
// 更新任务导出状态-导出中
|
||
mysqlUpdateTaskExportStatusErr := mysqlWrite.UpdateTaskExportStatus(taskId, 1, "")
|
||
if mysqlUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("更新任务导出状态失败: %v", mysqlUpdateTaskExportStatusErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
}
|
||
sqLiteUpdateTaskExportStatusErr := sqliteWrite.UpdateTaskExportStatus(taskId, 1, "")
|
||
if sqLiteUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("更新任务导出状态失败: %v", sqLiteUpdateTaskExportStatusErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
}
|
||
|
||
// 循环获取并写入数据
|
||
for {
|
||
// 每次获取 batchSize条数据
|
||
dataBatch, _, err := service.GetBodyOverDataByBatch(taskId, page, batchSize)
|
||
if err != nil {
|
||
errMsg := fmt.Sprintf("获取任务详情批次数据失败 page:%d, err:%v", page, err)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
return
|
||
}
|
||
fmt.Printf("数据长度: %v", len(dataBatch))
|
||
// 没有数据了，退出循环
|
||
if len(dataBatch) == 0 {
|
||
// 导出完成
|
||
mysqlUpdateTaskExportStatusErr = mysqlWrite.UpdateTaskExportStatus(taskId, 2, fullPath)
|
||
if mysqlUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("更新任务导出状态失败: %v", mysqlUpdateTaskExportStatusErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
}
|
||
sqLiteUpdateTaskExportStatusErr = sqliteWrite.UpdateTaskExportStatus(taskId, 2, fullPath)
|
||
if sqLiteUpdateTaskExportStatusErr != nil {
|
||
errMsg := fmt.Sprintf("更新任务导出状态失败: %v", sqLiteUpdateTaskExportStatusErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
}
|
||
|
||
// 清空body_over
|
||
clearBodyOverErr := service.ClearBodyOver(taskId)
|
||
if clearBodyOverErr != nil {
|
||
errMsg := fmt.Sprintf("清空body_over失败: %v", clearBodyOverErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
return
|
||
}
|
||
break
|
||
}
|
||
|
||
// 追加写入CSV文件
|
||
// 注意：AppendToCSV函数需要修改以支持文件存在时的追加模式
|
||
if writeErr := AppendToCSV(fullPath, dataBatch, isFirstWrite, taskId, taskType); writeErr != nil {
|
||
errMsg := fmt.Sprintf("写入CSV文件失败 page:%d, err:%v", page, writeErr)
|
||
fmt.Println(errMsg)
|
||
logs.LoggingMiddleware(logs.LOG_LEVEL_ERROR, errMsg)
|
||
return
|
||
}
|
||
|
||
// 第一次写入后标记为false（后续不再写表头）
|
||
if isFirstWrite {
|
||
isFirstWrite = false
|
||
}
|
||
|
||
// 更新偏移量
|
||
page++
|
||
}
|
||
}
|