forked from yoone/API
1
0
Fork 0

refactor(service): 将 console.log 替换为 logger 并调整日志级别

使用 logger 替代 console.log 以统一日志管理
将批量导入结果的日志级别从 debug 调整为 info
This commit is contained in:
tikkhun 2026-01-29 17:57:07 +08:00
parent e94805c640
commit 6b782a9d6e
4 changed files with 4 additions and 11 deletions

View File

@ -996,7 +996,6 @@ export class ShopyyAdapter implements ISiteAdapter {
private async getProductBySku(sku: string): Promise<UnifiedProductDTO> {
// 使用Shopyy API的搜索功能通过sku查询产品
const response = await this.getAllProducts({ where: { sku } });
console.log('getProductBySku', response)
const product = response?.[0]
if (!product) {
throw new Error(`未找到sku为${sku}的产品`);

View File

@ -40,7 +40,6 @@ export class AreaController {
}));
return successResponse(countryList, '查询成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}
@ -54,7 +53,6 @@ export class AreaController {
const newArea = await this.areaService.createArea(area);
return successResponse(newArea, '创建成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}
@ -68,7 +66,6 @@ export class AreaController {
const updatedArea = await this.areaService.updateArea(id, area);
return successResponse(updatedArea, '更新成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}
@ -81,7 +78,6 @@ export class AreaController {
await this.areaService.deleteArea(id);
return successResponse(null, '删除成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}
@ -95,7 +91,6 @@ export class AreaController {
const { list, total } = await this.areaService.getAreaList(query);
return successResponse({ list, total }, '查询成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}
@ -111,7 +106,6 @@ export class AreaController {
}
return successResponse(area, '查询成功');
} catch (error) {
console.log(error);
return errorResponse(error?.message || error);
}
}

View File

@ -58,7 +58,6 @@ export class OrderController {
const result = await this.orderService.syncOrderById(siteId, orderId);
return successResponse(result);
} catch (error) {
console.log(error);
return errorResponse('同步失败');
}
}

View File

@ -2032,9 +2032,9 @@ export class ProductService {
// 将工作表转换为 JSON 数组
records = xlsx.utils.sheet_to_json(worksheet);
console.log('Parsed records count:', records.length);
this.logger.debug('Parsed records count:', records.length);
if (records.length > 0) {
console.log('First record keys:', Object.keys(records[0]));
this.logger.debug('First record keys:', Object.keys(records[0]));
}
return records;
} catch (e: any) {
@ -2048,6 +2048,7 @@ export class ProductService {
let updated = 0;
const errors: BatchErrorItem[] = [];
const records = await this.getRecordsFromTable(file);
this.logger.debug('Total records count:', records.length);
// 逐条处理记录
for (const rec of records) {
try {
@ -2076,7 +2077,7 @@ export class ProductService {
errors.push({ identifier: '' + rec.sku, error: `产品${rec?.sku}导入失败:${e?.message || String(e)}` });
}
}
this.logger.debug(`导入 ${records.length} 条记录,成功创建 ${created} 条,更新 ${updated} 条,失败 ${errors.length} 条,错误详情:${JSON.stringify(errors)}`);
this.logger.info(`导入 ${records.length} 条记录,成功创建 ${created} 条,更新 ${updated} 条,失败 ${errors.length} 条,错误详情:${JSON.stringify(errors)}`);
return { total: records.length, processed: records.length - errors.length, created, updated, errors };
}