fm453/nocobase
1
0
Fork 0
mirror of https://gitee.com/nocobase/nocobase.git synced 2025-05-05 13:39:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add import and export log

Browse Source
This commit is contained in:
aaaaaajie 2025-04-24 18:46:24 +08:00
parent d0a7b49cad
commit dac08d94b7
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
packages/plugins/@nocobase/plugin-action-export/src/server/services/base-exporter.ts
View File

@ -94,7 +94,7 @@ abstract class BaseExporter<T extends ExportOptions = ExportOptions> extends Eve
)}`, )}`,
); );
} else { } else {
this.logger?.debug(`Query completed in ${executionTime}ms, fetched ${rows.length} records`); this.logger?.info(`Query completed in ${executionTime}ms, fetched ${rows.length} records`);
} }
this._batchQueryStartTime = null; this._batchQueryStartTime = null;
} }
@ -106,19 +106,23 @@ abstract class BaseExporter<T extends ExportOptions = ExportOptions> extends Eve
const diff = process.hrtime(startTime); const diff = process.hrtime(startTime);
const executionTime = (diff[0] * 1000 + diff[1] / 1000000).toFixed(2); const executionTime = (diff[0] * 1000 + diff[1] / 1000000).toFixed(2);
if (Number(executionTime) > 500) { if (Number(executionTime) > 500) {
this.logger?.debug(`HandleRow took too long, completed in ${executionTime}ms`); this.logger?.info(`HandleRow took too long, completed in ${executionTime}ms`);
} else {
this.logger?.info(`HandleRow completed, ${executionTime}ms`);
} }
} }
this.emit('progress', { this.emit('progress', {
total, total,
current: (current += rows.length), current: (current += rows.length),
}); });
const diff = process.hrtime(totalCountStartTime); const totalDiff = process.hrtime(totalCountStartTime);
const currentTotalCountTime = (diff[0] * 1000 + diff[1] / 1000000).toFixed(2); const elapsedSeconds = totalDiff[0] + totalDiff[1] / 1e9;
const estimatedTimeRemaining = (elapsedSeconds * (total - current)) / current;
this.logger?.info( this.logger?.info(
`Processed ${current}/${total} records (${Math.round( `Processed ${current}/${total} records (${Math.round((current / total) * 100)}%), ` +
(current / total) * 100, `elapsed time: ${elapsedSeconds.toFixed(2)}s, ` +
)}%), totalCountTime: ${currentTotalCountTime}ms`, `estimated remaining: ${estimatedTimeRemaining.toFixed(2)}s`,
); );
}, },
}; };