mini-starter/tcb-shop-demo/services/order/orderItem.js

import { model, getAll } from '../../services/_utils/model';
import { getSkuDetail } from '../sku/sku';
import { DATA_MODEL_KEY } from '../../config/model';
import { cloudbaseTemplateConfig } from '../../config/index';
import { ORDER_ITEM, createId } from '../cloudbaseMock/index';

const ORDER_ITEM_MODEL_KEY = DATA_MODEL_KEY.ORDER_ITEM;

export async function getOrderItem(id) {
  return (
    await model()[ORDER_ITEM_MODEL_KEY].get({
      filter: {
        where: {
          _id: {
            $eq: id,
          },
        },
      },
      select: {
        sku: {
          _id: true,
        },
        comment: {
          _id: true,
        },
      },
    })
  ).data;
}

export async function createOrderItem({ count, skuId, orderId }) {
  if (cloudbaseTemplateConfig.useMock) {
    ORDER_ITEM.push({
      _id: createId(),
      count,
      order: {
        _id: orderId,
      },
      sku: {
        _id: skuId,
      },
    });
    return;
  }
  return model()[ORDER_ITEM_MODEL_KEY].create({
    data: {
      count,
      sku: {
        _id: skuId,
      },
      order: {
        _id: orderId,
      },
    },
  });
}

export function getAllOrderItems() {
  return getAll({ name: ORDER_ITEM_MODEL_KEY });
}

/**
 *
 * @param {{orderId: String}} param0
 */
export async function getAllOrderItemsOfAnOrder({ orderId }) {
  if (cloudbaseTemplateConfig.useMock) {
    const orderItems = ORDER_ITEM.filter((orderItem) => orderItem.order._id === orderId);
    await Promise.all(
      orderItems.map(async (orderItem) => {
        const skuId = orderItem.sku._id;
        const sku = await getSkuDetail(skuId);
        orderItem.sku = sku;
      }),
    );
    return orderItems;
  }

  const orderItems = await getAll({
    name: ORDER_ITEM_MODEL_KEY,
    filter: {
      where: {
        order: {
          $eq: orderId,
        },
      },
    },
    select: {
      _id: true,
      count: true,
      sku: {
        _id: true,
      },
    },
  });
  const enhancedItems = await Promise.all(
    orderItems.map(async (orderItem) => {
      const skuId = orderItem.sku._id;
      const sku = await getSkuDetail(skuId);
      return {
        ...orderItem,
        sku: {
          ...sku,
          id: sku._id,                  // 确保有id字段
          cover_image: sku.image || '', // 统一使用cover_image字段
          imageUrl: sku.image || '',    // 同时保留imageUrl字段以兼容旧代码
          price: sku.price || 0,       // 确保price字段存在
          name: sku.name || ''         // 确保商品名称存在
        },
        count: orderItem.count || 1,   // 默认数量为1
        id: orderItem._id               // 确保有id字段
      };
    }),
  );
  return enhancedItems;
}