src/adapter/shopyy.adapter.ts

@@ -996,6 +996,7 @@ 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}的产品`);
@@ -1125,6 +1126,7 @@ export class ShopyyAdapter implements ISiteAdapter {
   // ========== 产品变体映射方法 ==========
   mapPlatformToUnifiedVariation(variant: ShopyyVariant): UnifiedProductVariationDTO {
     // 映射变体
+    console.log('ivarianttem', variant)
     return {
       id: variant.id,
       name: variant.title || '',

src/controller/area.controller.ts

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

src/controller/order.controller.ts

@@ -42,7 +42,8 @@ export class OrderController {
       const result = await this.orderService.syncOrders(siteId, params);
       return successResponse(result);
     } catch (error) {
-      return errorResponse(`同步失败,${error?.message || '未知错误'}`);
+      console.log(error);
+      return errorResponse('同步失败');
     }
   }
 
@@ -58,6 +59,7 @@ export class OrderController {
       const result = await this.orderService.syncOrderById(siteId, orderId);
       return successResponse(result);
     } catch (error) {
+      console.log(error);
       return errorResponse('同步失败');
     }
   }

src/service/order.service.ts

@@ -133,7 +133,7 @@ export class OrderService {
   async syncOrders(siteId: number, params: Record<string, any> = {}): Promise<SyncOperationResult> {
     // 调用 WooCommerce API 获取订单
     const result = await (await this.siteApiService.getAdapter(siteId)).getAllOrders(params);
-    this.logger.info('开始进入循环同步订单', result.length, '个订单')
+
     // 初始化同步结果对象
     const syncResult: SyncOperationResult = {
       total: result.length,
@@ -143,6 +143,7 @@ export class OrderService {
       updated: 0,
       errors: []
     };
+    this.logger.info('开始进入循环同步订单', result.length, '个订单')
     // 遍历每个订单进行同步
     for (const order of result) {
       try {

src/service/product.service.ts

@@ -2032,9 +2032,9 @@ export class ProductService {
       // 将工作表转换为 JSON 数组
       records = xlsx.utils.sheet_to_json(worksheet);
 
-      this.logger.debug('Parsed records count:', records.length);
+      console.log('Parsed records count:', records.length);
       if (records.length > 0) {
-        this.logger.debug('First record keys:', Object.keys(records[0]));
+        console.log('First record keys:', Object.keys(records[0]));
       }
       return records;
     } catch (e: any) {
@@ -2048,7 +2048,6 @@ 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 {
@@ -2077,7 +2076,7 @@ export class ProductService {
         errors.push({ identifier: '' + rec.sku, error: `产品${rec?.sku}导入失败:${e?.message || String(e)}` });
       }
     }
-    this.logger.info(`导入 ${records.length} 条记录,成功创建 ${created} 条,更新 ${updated} 条,失败 ${errors.length} 条,错误详情:${JSON.stringify(errors)}`);
+    this.logger.debug(`导入 ${records.length} 条记录,成功创建 ${created} 条,更新 ${updated} 条,失败 ${errors.length} 条,错误详情:${JSON.stringify(errors)}`);
     return { total: records.length, processed: records.length - errors.length, created, updated, errors };
   }
 
@@ -2139,6 +2138,7 @@ export class ProductService {
 
     return product;
   }
+
   // 根据站点SKU查询产品
   async getProductBySiteSku(siteSku: string, site?: Site): Promise<Product> {
     // 使用查询构建器来正确查询关联表
@@ -2150,7 +2150,7 @@ export class ProductService {
       .leftJoinAndSelect('product.components', 'components')
       .leftJoinAndSelect('product.siteSkus', 'siteSku')
       .where('siteSku.sku LIKE :siteSku', { siteSku: `%${siteSku}%` })
-      .orWhere('product.sku = :siteSku', { siteSku })
+      .orWhere('product.sku = :siteSku', { siteSku });
 
     if (site) {
       queryBuilder.orWhere('product.sku = :processedSku', {