src/dto/order.dto.ts

@@ -98,10 +98,14 @@ export class QueryOrderDTO {
 }
 
 export class QueryOrderSalesDTO {
-  @ApiProperty({ description: '是否为原产品还是库存产品' })
+  @ApiProperty()
   @Rule(RuleType.bool().default(false))
   isSource: boolean;
 
+  @ApiProperty()
+  @Rule(RuleType.bool().default(false))
+  exceptPackage: boolean;
+
   @ApiProperty({ example: '1', description: '页码' })
   @Rule(RuleType.number())
   current: number;
@@ -110,31 +114,19 @@ export class QueryOrderSalesDTO {
   @Rule(RuleType.number())
   pageSize: number;
 
-  @ApiProperty({ description: '排序对象,格式如 { productName: "asc", sku: "desc" }',type: 'any', required: false })
+  @ApiProperty()
-  @Rule(RuleType.object().allow(null))
-  orderBy?: Record<string, 'asc' | 'desc'>;
-  // filter
-  @ApiProperty({ description: '是否排除套餐' })
-  @Rule(RuleType.bool().default(false))
-  exceptPackage: boolean;
-
-  @ApiProperty({ description: '站点ID' })
   @Rule(RuleType.number())
   siteId: number;
 
-  @ApiProperty({ description: '名称' })
+  @ApiProperty()
   @Rule(RuleType.string())
   name: string;
 
-  @ApiProperty({ description: 'SKU' })
+  @ApiProperty()
-  @Rule(RuleType.string())
-  sku: string;
-
-  @ApiProperty({ description: '开始日期' })
   @Rule(RuleType.date())
   startDate: Date;
 
-  @ApiProperty({ description: '结束日期' })
+  @ApiProperty()
   @Rule(RuleType.date())
   endDate: Date;
 }

src/entity/order.entity.ts

@@ -272,14 +272,6 @@ export class Order {
   @Expose()
   updatedAt: Date;
 
-  @ApiProperty({ type: 'json', nullable: true, description: '订单项列表' })
-  @Expose()
-  orderItems?: any[];
-
-  @ApiProperty({ type: 'json', nullable: true, description: '销售项列表' })
-  @Expose()
-  orderSales?: any[];
-
   // 在插入或更新前处理用户代理字符串
   @BeforeInsert()
   @BeforeUpdate()

src/entity/order_sale.entity.ts

@@ -75,7 +75,7 @@ export class OrderSale {
   @ApiProperty({ nullable: true })
   @Column({ type: 'int', nullable: true })
   @Expose()
-  size: number | null; // 其实是 strength
+  size: number | null;
 
   @ApiProperty()
   @Column({ default: false })
@@ -98,24 +98,24 @@ export class OrderSale {
   @Expose()
   updatedAt?: Date;
 
-  //  // === 自动计算逻辑 ===
+   // === 自动计算逻辑 ===
-  // @BeforeInsert()
+  @BeforeInsert()
-  // @BeforeUpdate()
+  @BeforeUpdate()
-  // setFlags() {
+  setFlags() {
-  //   if (!this.name) return;
+    if (!this.name) return;
-  //   const lower = this.name.toLowerCase();
+    const lower = this.name.toLowerCase();
-  //   this.isYoone = lower.includes('yoone');
+    this.isYoone = lower.includes('yoone');
-  //   this.isZex = lower.includes('zex');
+    this.isZex = lower.includes('zex');
-  //   this.isYooneNew = this.isYoone && lower.includes('new');
+    this.isYooneNew = this.isYoone && lower.includes('new');
-  //   let size: number | null = null;
+    let size: number | null = null;
-  //   const sizes = [3, 6, 9, 12, 15, 18];
+    const sizes = [3, 6, 9, 12, 15, 18];
-  //   for (const s of sizes) {
+    for (const s of sizes) {
-  //     if (lower.includes(s.toString())) {
+      if (lower.includes(s.toString())) {
-  //       size = s;
+        size = s;
-  //       break;
+        break;
-  //     }
+      }
-  //   }
+    }
-  //   this.size = size;
+    this.size = size;
-  // }
+  }
   
 }

src/service/order.service.ts

@@ -39,8 +39,6 @@ import * as path from 'path';
 import * as os from 'os';
 import { UnifiedOrderDTO } from '../dto/site-api.dto';
 import { CustomerService } from './customer.service';
-import { DictItem } from '../entity/dict_item.entity';
-import { ProductService } from './product.service';
 @Provide()
 export class OrderService {
 
@@ -112,8 +110,6 @@ export class OrderService {
 
   @Logger()
   logger; // 注入 Logger 实例
-  @Inject()
-  productService: ProductService;
   
   /**
    * 批量同步订单
@@ -282,11 +278,6 @@ export class OrderService {
       console.error('更新订单状态失败,原因为:', error)
     }
   }
-  async getOrderByExternalOrderId(siteId: number, externalOrderId: string) {
-    return await this.orderModel.findOne({
-      where: { externalOrderId: String(externalOrderId), siteId },
-    });
-  }
   /**
    * 同步单个订单
    * 流程说明:
@@ -310,7 +301,7 @@ export class OrderService {
    * @param order 订单数据
    * @param forceUpdate 是否强制更新
    */
-  async syncSingleOrder(siteId: number, order: UnifiedOrderDTO, forceUpdate = false) {
+  async syncSingleOrder(siteId: number, order: any, forceUpdate = false) {
     // 从订单数据中解构出各个子项
     let {
       line_items,
@@ -324,28 +315,47 @@ export class OrderService {
     // console.log('同步进单个订单', order)
     // 如果订单状态为 AUTO_DRAFT,则跳过处理
     if (order.status === OrderStatus.AUTO_DRAFT) {
-      this.logger.debug('订单状态为 AUTO_DRAFT,跳过处理', siteId, order.id)
       return;
     }
-    // 这里其实不用过滤不可编辑的行为，而是应在 save 中做判断
+    // 检查数据库中是否已存在该订单
-    // if(!order.is_editable && !forceUpdate){
+    const existingOrder = await this.orderModel.findOne({
-    //   this.logger.debug('订单不可编辑,跳过处理', siteId, order.id)
+      where: { externalOrderId: order.id, siteId: siteId },
-    //   return;
+    });
-    // }
+    // 自动更新订单状态(如果需要)
-    // 自动转换远程订单的状态(如果需要)
     await this.autoUpdateOrderStatus(siteId, order);
-    // 这里的 saveOrder 已经包括了创建订单和更新订单
+
-    let orderRecord: Order = await this.saveOrder(siteId, orderData);
+    if(existingOrder){
+        // 矫正数据库中的订单数据
+        const updateData: any = { status: order.status };
+        if (this.canUpdateErpStatus(existingOrder.orderStatus)) {
+          updateData.orderStatus = this.mapOrderStatus(order.status);
+        }
+        // 更新
+        await this.orderModel.update({ externalOrderId: order.id, siteId: siteId }, updateData);
+        // 更新 fulfillments 数据
+        await this.saveOrderFulfillments({
+          siteId,
+          orderId: existingOrder.id,
+          externalOrderId:order.id,
+          fulfillments: fulfillments,
+        });
+    }
+   const externalOrderId = order.id; 
    // 如果订单从未完成变为完成状态,则更新库存
     if (
-      orderRecord &&
+      existingOrder &&
-      orderRecord.orderStatus !== ErpOrderStatus.COMPLETED &&
+      existingOrder.orderStatus !== ErpOrderStatus.COMPLETED &&
       orderData.status === OrderStatus.COMPLETED
     ) {
-      await this.updateStock(orderRecord);
+      this.updateStock(existingOrder);
       // 不再直接返回,继续执行后续的更新操作
     }
-    const externalOrderId = String(order.id);
+    // 如果订单不可编辑且不强制更新,则跳过处理
+    if (existingOrder && !existingOrder.is_editable && !forceUpdate) {
+      return;
+    }
+    // 保存订单主数据
+    const orderRecord = await this.saveOrder(siteId, orderData);
     const orderId = orderRecord.id;
     // 保存订单项
     await this.saveOrderItems({
@@ -449,8 +459,7 @@ export class OrderService {
    * @param order 订单数据
    * @returns 保存后的订单实体
    */
-  // 这里 omit 是因为处理在外头了 其实 saveOrder 应该包括 savelineitems 等
+  async saveOrder(siteId: number, order: UnifiedOrderDTO): Promise<Order> {
-  async saveOrder(siteId: number, order: Omit<UnifiedOrderDTO, 'line_items'|'refunds'>): Promise<Order> {
     // 将外部订单ID转换为字符串
     const externalOrderId = String(order.id) 
     delete order.id
@@ -699,8 +708,6 @@ export class OrderService {
    * 
    * @param orderItem 订单项实体
    */
-  // TODO 这里存的是库存商品实际
-  // 所以叫做 orderInventoryItems 可能更合适
   async saveOrderSale(orderItem: OrderItem) {
     const currentOrderSale = await this.orderSaleModel.find({
       where: {
@@ -719,44 +726,46 @@ export class OrderService {
     });
 
     if (!product) return;
-    const componentDetails: { product: Product, quantity: number }[] = product.components?.length > 0 ? await Promise.all(product.components.map(async comp => {
-      return {
-        product: await this.productModel.findOne({
-          where: { sku: comp.sku },
-        }),
-        quantity: comp.quantity * orderItem.quantity,
-      }
-    })) : [{ product, quantity: orderItem.quantity }];
 
-    const orderSales: OrderSale[] = componentDetails.map(componentDetail => {
+    const orderSales: OrderSale[] = [];
-      const attrsObj = this.productService.getAttributesObject(product.attributes)
+
-      const orderSale = plainToClass(OrderSale, {
+    if (product.components && product.components.length > 0) {
+      for (const comp of product.components) {
+        const baseProduct = await this.productModel.findOne({
+          where: { sku: comp.sku },
+        });
+        if (baseProduct) {
+          const orderSaleItem: OrderSale = plainToClass(OrderSale, {
             orderId: orderItem.orderId,
             siteId: orderItem.siteId,
             externalOrderItemId: orderItem.externalOrderItemId,
-        productId: componentDetail.product.id,
+            productId: baseProduct.id,
-        name: componentDetail.product.name,
+            name: baseProduct.name,
-        quantity: componentDetail.quantity * orderItem.quantity,
+            quantity: comp.quantity * orderItem.quantity,
-        sku: componentDetail.product.sku,
+            sku: comp.sku,
-        isPackage: componentDetail.product.type === 'bundle',
+            isPackage: orderItem.name.toLowerCase().includes('package'),
-        isYoone: attrsObj?.['brand']?.name === 'yoone',
-        isZyn: attrsObj?.['brand']?.name === 'zyn',
-        isYooneNew: attrsObj?.['brand']?.name === 'yoone' && attrsObj?.['version']?.name === 'new',
-        size: this.extractNumberFromString(attrsObj?.['strength']?.name) || null,
           });
-      return orderSale
+          orderSales.push(orderSaleItem);
-    })
+        }
+      }
+    } else {
+      const orderSaleItem: OrderSale = plainToClass(OrderSale, {
+        orderId: orderItem.orderId,
+        siteId: orderItem.siteId,
+        externalOrderItemId: orderItem.externalOrderItemId,
+        productId: product.id,
+        name: product.name,
+        quantity: orderItem.quantity,
+        sku: product.sku,
+        isPackage: orderItem.name.toLowerCase().includes('package'),
+      });
+      orderSales.push(orderSaleItem);
+    }
 
     if (orderSales.length > 0) {
       await this.orderSaleModel.save(orderSales);
     }
   }
-  extractNumberFromString(str: string): number {
-    if (!str) return 0;
-
-    const num = parseInt(str, 10);
-    return isNaN(num) ? 0 : num;
-  }
 
   /**
    * 保存订单退款信息
@@ -1183,53 +1192,7 @@ export class OrderService {
             ) END
           ),
           JSON_ARRAY()
-        ) as fulfillments,
+        ) as fulfillments
-        (
-          SELECT COALESCE(
-            JSON_ARRAYAGG(
-              JSON_OBJECT(
-                'id', oi.id,
-                'name', oi.name,
-                'orderId', oi.orderId,
-                'siteId', oi.siteId,
-                'externalOrderId', oi.externalOrderId,
-                'externalOrderItemId', oi.externalOrderItemId,
-                'externalProductId', oi.externalProductId,
-                'externalVariationId', oi.externalVariationId,
-                'quantity', oi.quantity,
-                'subtotal', oi.subtotal,
-                'subtotal_tax', oi.subtotal_tax,
-                'total', oi.total,
-                'total_tax', oi.total_tax,
-                'sku', oi.sku,
-                'price', oi.price
-              )
-            ),
-            JSON_ARRAY()
-          )
-          FROM order_item oi
-          WHERE oi.orderId = o.id
-        ) AS orderItems,
-        (
-          SELECT COALESCE(
-            JSON_ARRAYAGG(
-              JSON_OBJECT(
-                'id', os.id,
-                'orderId', os.orderId,
-                'siteId', os.siteId,
-                'externalOrderItemId', os.externalOrderItemId,
-                'productId', os.productId,
-                'name', os.name,
-                'sku', os.sku,
-                'quantity', os.quantity,
-                'isPackage', os.isPackage
-              )
-            ),
-            JSON_ARRAY()
-          )
-          FROM order_sale os
-          WHERE os.orderId = o.id
-        ) AS orderSales
       FROM \`order\` o
       LEFT JOIN (
         SELECT
@@ -1463,7 +1426,7 @@ export class OrderService {
    * @param params 查询参数
    * @returns 销售统计和分页信息
    */
-  async getOrderSales({ siteId, startDate, endDate, current, pageSize, name, exceptPackage, orderBy }: QueryOrderSalesDTO) {
+  async getOrderSales({ siteId, startDate, endDate, current, pageSize, name, exceptPackage }: QueryOrderSalesDTO) {
     const nameKeywords = name ? name.split(' ').filter(Boolean) : [];
     const defaultStart = dayjs().subtract(30, 'day').startOf('day').format('YYYY-MM-DD HH:mm:ss');
     const defaultEnd = dayjs().endOf('day').format('YYYY-MM-DD HH:mm:ss');
@@ -1679,12 +1642,11 @@ export class OrderService {
    * @returns 订单项统计和分页信息
    */
   async getOrderItems({
-    current,
-    pageSize,
     siteId,
     startDate,
     endDate,
-    sku,
+    current,
+    pageSize,
     name,
   }: QueryOrderSalesDTO) {
     const nameKeywords = name ? name.split(' ').filter(Boolean) : [];

src/service/product.service.ts

@@ -1466,12 +1466,7 @@ export class ProductService {
       price: num(rec.price),
       promotionPrice: num(rec.promotionPrice),
       type: val(rec.type),
-      siteSkus: rec.siteSkus
+      siteSkus: rec.siteSkus ? String(rec.siteSkus).split(',').map(s => s.trim()).filter(Boolean) : undefined,
-        ? String(rec.siteSkus)
-            .split(/[;,]/)      // 支持英文分号或英文逗号分隔
-            .map(s => s.trim())
-            .filter(Boolean)
-        : undefined,
       category, // 添加分类字段
 
       attributes: attributes.length > 0 ? attributes : undefined,
@@ -1536,13 +1531,7 @@ export class ProductService {
 
     return dto;
   }
-  getAttributesObject(attributes:DictItem[]){
+
-    const obj:any = {}
-    attributes.forEach(attr=>{
-      obj[attr.dict.name] = attr
-    })
-    return obj
-  }
   // 将单个产品转换为 CSV 行数组
   transformProductToCsvRow(
     p: Product,