src/config/config.local.ts

@@ -39,19 +39,10 @@ export default {
     },
      {
       id: '2',
-      wpApiUrl: 'http://t2-shop.local/',
-      consumerKey: 'ck_a369473a6451dbaec63d19cbfd74a074b2c5f742',
-      consumerSecret: 'cs_0946bbbeea1bfefff08a69e817ac62a48412df8c',
-      siteName: 'Local',
-      email: '444693295@qq.com',
-      emailPswd: 'lulin91.',
-    },
-    {
-      id: '3',
       wpApiUrl: 'http://t1-shop.local/',
       consumerKey: 'ck_a369473a6451dbaec63d19cbfd74a074b2c5f742',
       consumerSecret: 'cs_0946bbbeea1bfefff08a69e817ac62a48412df8c',
-      siteName: 'Local-test-2',
+      siteName: 'Local',
       email: '444693295@qq.com',
       emailPswd: 'lulin91.',
     },

src/controller/logistics.controller.ts

@@ -222,7 +222,7 @@ export class LogisticsController {
   }
 
   @ApiOkResponse()
-  @Post('/updateState/:shipmentId')
+  @Post('/updateState/:id')
   async updateShipmentState(
     @Param('shipmentId') shipmentId: number
   ) {
@@ -247,11 +247,11 @@ export class LogisticsController {
   }
 
   @ApiOkResponse()
-  @Post('/getOrderList')
+  @Post('/getTrackingNumber')
-  async getOrderList(@Query('number') number: string) {
+  async getTrackingNumber(@Query('number') number: string) {
     try {
       return successResponse(
-        await this.logisticsService.getOrderList(number)
+        await this.logisticsService.getTrackingNumber(number)
       );
     } catch (error) {
       return errorResponse(error?.message || '获取失败');
@@ -259,11 +259,11 @@ export class LogisticsController {
   }
 
   @ApiOkResponse()
-  @Post('/getListByOrderId')
+  @Post('/getListByTrackingId')
-  async getListByOrderId(@Query('id') orderId: number) {
+  async getListByTrackingId(@Query('shipment_id') shipment_id: number) {
     try {
       return successResponse(
-        await this.logisticsService.getListByOrderId(orderId)
+        await this.logisticsService.getListByTrackingId(shipment_id)
       );
     } catch (error) {
       return errorResponse(error?.message || '获取失败');

src/controller/order.controller.ts

@@ -68,12 +68,11 @@ export class OrderController {
   @Get('/getOrders')
   async getOrders(
     @Query()
-    param: QueryOrderDTO,
+    param: QueryOrderDTO
-    @User() user
   ) {
     try {
       const count = await this.orderService.getOrderStatus(param);
-      const data = await this.orderService.getOrders(param, user.id);
+      const data = await this.orderService.getOrders(param);
       return successResponse({
         ...data,
         count,

src/controller/user.controller.ts

@@ -12,15 +12,11 @@ export class UserController {
   @Inject()
   userService: UserService;
 
-  @Inject()
-  ctx;
-
   @ApiOkResponse({
     type: LoginRes,
   })
   @Post('/login')
   async login(@Body() body) {
-    this.ctx.logger.info('ip:', this.ctx.ip, '; path:', this.ctx.path, '; user:', body?.username);
     try {
       const result = await this.userService.login(body);
       return successResponse(result, '登录成功');

src/controller/webhook.controller.ts

@@ -75,7 +75,7 @@ export class WebhookController {
         switch (topic) {
           case 'product.created':
           case 'product.updated':
-            const site = await this.wpProductService.getSite(siteId);
+            const site = await this.wpProductService.geSite(siteId);
             // 变体更新
             if (body.type === 'variation') {
               const variation = await this.wpApiService.getVariation(

src/controller/wp_product.controller.ts

@@ -7,7 +7,6 @@ import {
   Query,
   Put,
   Body,
-  Config,
 } from '@midwayjs/core';
 import { WpProductService } from '../service/wp_product.service';
 import { errorResponse, successResponse } from '../utils/response.util';
@@ -20,21 +19,9 @@ import {
   UpdateWpProductDTO,
 } from '../dto/wp_product.dto';
 import { WPService } from '../service/wp.service';
-import { WpSite } from '../interface';
 
 @Controller('/wp_product')
 export class WpProductController {
-  @Inject()
-  wpService: WPService;
-
-  @Config('wpSite')
-  sites: WpSite[];
-
-  getSite(id: string): WpSite {
-    let idx = this.sites.findIndex(item => item.id === id);
-    return this.sites[idx];
-  }
-
   @Inject()
   private readonly wpProductService: WpProductService;
 
@@ -86,22 +73,6 @@ export class WpProductController {
     }
   }
 
-  @ApiOkResponse({
-    type: BooleanRes
-  })
-  @Post('/updateState/:id')
-  async updateWPProductState(
-    @Param('id') id: number,
-    @Body() body: any, // todo
-  ) {
-    try {
-      const res = await this.wpProductService.updateProductStatus(id, body?.status, body?.stock_status);
-      return successResponse(res);
-    } catch (error) {
-      return errorResponse(error.message);
-    }
-  }
-
   /**
    * 更新产品接口
    * @param productId 产品 ID
@@ -125,7 +96,7 @@ export class WpProductController {
       if (isDuplicate) {
         return errorResponse('SKU已存在');
       }
-      const site = await this.wpProductService.getSite(siteId);
+      const site = await this.wpProductService.geSite(siteId);
       const result = await this.wpApiService.updateProduct(
         site,
         productId,
@@ -165,7 +136,7 @@ export class WpProductController {
       if (isDuplicate) {
         return errorResponse('SKU已存在');
       }
-      const site = await this.wpProductService.getSite(siteId);
+      const site = await this.wpProductService.geSite(siteId);
       const result = await this.wpApiService.updateVariation(
         site,
         productId,

src/dto/order.dto.ts

@@ -90,10 +90,6 @@ export class QueryOrderSalesDTO {
   @Rule(RuleType.bool().default(false))
   isSource: boolean;
 
-  @ApiProperty()
-  @Rule(RuleType.bool().default(false))
-  exceptPackage: boolean;
-
   @ApiProperty({ example: '1', description: '页码' })
   @Rule(RuleType.number())
   current: number;

src/entity/order_item.entity.ts

@@ -37,7 +37,7 @@ export class OrderItem {
   externalOrderId: string; // WooCommerce 订单 ID
 
   @ApiProperty()
-  @Column({ nullable: true })
+  @Column()
   @Expose()
   externalOrderItemId: string; // WooCommerce 订单item ID
 

src/entity/order_item_original.entity.ts

@@ -22,7 +22,6 @@ export class OrderSaleOriginal {
   @ApiProperty()
   @ManyToOne(() => Order)
   @JoinColumn({ name: 'order_id' })
-  @Column({ name: 'order_id' })
   @Expose()
   orderId: number; // 订单 ID
 
@@ -32,7 +31,7 @@ export class OrderSaleOriginal {
   siteId: string; // 来源站点唯一标识
 
   @ApiProperty()
-  @Column({ nullable: true })
+  @Column()
   @Expose()
   externalOrderItemId: string; // WooCommerce 订单item ID
 

src/entity/wp_product.entity.ts

@@ -7,7 +7,7 @@ import {
   Entity,
 } from 'typeorm';
 import { ApiProperty } from '@midwayjs/swagger';
-import { ProductStatus, ProductStockStatus, ProductType } from '../enums/base.enum';
+import { ProductStatus, ProductType } from '../enums/base.enum';
 
 @Entity('wp_product')
 @Unique(['siteId', 'externalProductId']) // 确保产品的唯一性
@@ -56,15 +56,6 @@ export class WpProduct {
   @Column({ type: 'enum', enum: ProductStatus })
   status: ProductStatus;
 
-  @ApiProperty({ description: '上下架状态', enum: ProductStockStatus })
-  @Column({
-    name: 'stock_status',
-    type: 'enum',
-    enum: ProductStockStatus,
-    default: ProductStockStatus.INSTOCK
-  })
-  stockStatus: ProductStockStatus;
-
   @ApiProperty({ description: '常规价格', type: Number })
   @Column('decimal', { precision: 10, scale: 2, nullable: true })
   regular_price: number; // 常规价格

src/enums/base.enum.ts

@@ -9,12 +9,6 @@ export enum ProductStatus {
   INHERIT = 'inherit', // 继承状态
 }
 
-export enum ProductStockStatus {
-  INSTOCK = 'instock',
-  OUT_OF_STOCK = 'outofstock',
-  ON_BACK_ORDER = 'onbackorder',
-}
-
 export enum ProductType {
   SIMPLE = 'simple',
   VARIABLE = 'variable',

src/service/logistics.service.ts

@@ -85,7 +85,7 @@ export class LogisticsService {
   @Config('wpSite')
   sites: WpSite[];
 
-  getSite(id: string): WpSite {
+  geSite(id: string): WpSite {
     let idx = this.sites.findIndex(item => item.id === id);
     return this.sites[idx];
   }
@@ -129,7 +129,6 @@ export class LogisticsService {
   async updateShipmentState(shipment: Shipment) {
     try {
       const data = await this.uniExpressService.getOrderStatus(shipment.return_tracking_number);
-      console.log('updateShipmentState data:', data);
       shipment.state = data.data[0].state;
       if (shipment.state in [203, 215, 216, 230]) { // todo,写常数
         shipment.finished = true;
@@ -137,13 +136,12 @@ export class LogisticsService {
       this.shipmentModel.save(shipment);
       return shipment.state;
     } catch (error) {
-      throw error;
+      throw new Error(`更新运单状态失败 ${error.message}`);
-      // throw new Error(`更新运单状态失败 ${error.message}`);
     }
   }
 
   async updateShipmentStateById(id: number) {
-    const shipment: Shipment = await this.shipmentModel.findOneBy({ id: id });
+    const shipment:Shipment = await this.shipmentModel.findOneBy({ id : id });
     return this.updateShipmentState(shipment);
   }
 
@@ -220,7 +218,7 @@ export class LogisticsService {
 
   async getShipmentLabel(shipmentId) {
     try {
-      const shipment: Shipment = await this.shipmentModel.findOneBy({ id: shipmentId });
+      const shipment:Shipment = await this.shipmentModel.findOneBy({id: shipmentId});
       if (!shipment) {
         throw new Error('运单不存在');
       }
@@ -232,11 +230,11 @@ export class LogisticsService {
 
   async removeShipment(shipmentId: number) {
     try {
-      const shipment: Shipment = await this.shipmentModel.findOneBy({ id: shipmentId });
+      const shipment:Shipment = await this.shipmentModel.findOneBy({id: shipmentId});
       if (shipment.state !== '190') { // todo，写常数
         throw new Error('订单当前状态无法删除');
       }
-      const order: Order = await this.orderModel.findOneBy({ id: shipment.order_id });
+      const order:Order = await this.orderModel.findOneBy({id: shipment.order_id});
       const dataSource = this.dataSourceManager.getDataSource('default');
       let transactionError = undefined;
       await dataSource.transaction(async manager => {
@@ -263,7 +261,7 @@ export class LogisticsService {
 
       try {
         // 同步订单状态到woocommerce
-        const site = await this.getSite(order.siteId);
+        const site = await this.geSite(order.siteId);
         if (order.status === OrderStatus.COMPLETED) {
           await this.wpService.updateOrder(site, order.externalOrderId, {
             status: OrderStatus.PROCESSING,
@@ -288,7 +286,7 @@ export class LogisticsService {
 
   async getShipmentFee(data: ShipmentFeeBookDTO) {
     try {
-      const stock_point = await this.stockPointModel.findOneBy({ id: data.stockPointId });
+      const stock_point = await this.stockPointModel.findOneBy({ id: data.stockPointId});
       const reqBody = {
         ...convertKeysFromCamelToSnake(data),
         pickup_warehouse: stock_point.upStreamStockPointId,
@@ -320,7 +318,7 @@ export class LogisticsService {
 
     let resShipmentOrder;
     try {
-      const stock_point = await this.stockPointModel.findOneBy({ id: data.stockPointId });
+      const stock_point = await this.stockPointModel.findOneBy({ id: data.stockPointId});
       const reqBody = {
         sender: data.details.origin.contact_name,
         start_phone: data.details.origin.phone_number,
@@ -367,7 +365,7 @@ export class LogisticsService {
         const tracking_provider = 'UniUni'; // todo: id未确定，后写进常数
 
         // 同步物流信息到woocommerce
-        const site = await this.getSite(order.siteId);
+        const site = await this.geSite(order.siteId);
         const res = await this.wpService.createShipment(site, order.externalOrderId, {
           tracking_number: resShipmentOrder.data.tno,
           tracking_provider: tracking_provider,
@@ -410,12 +408,10 @@ export class LogisticsService {
       // 更新产品发货信息
       this.orderService.updateOrderSales(order.id, sales);
 
-      return {
+      return { data: {
-        data: {
         shipmentId
-        }
+      } };
-      };
+    } catch(error) {
-    } catch (error) {
       if (resShipmentOrder.status === 'SUCCESS') {
         await this.uniExpressService.deleteShipment(resShipmentOrder.data.tno);
       }
@@ -472,7 +468,7 @@ export class LogisticsService {
   }
 
   async getShipment(id: number) {
-    const orderShipments: OrderShipment[] = await this.orderShipmentModel.find({
+    const orderShipments:OrderShipment[] = await this.orderShipmentModel.find({
       where: { shipment_id: id },
     });
     if (!orderShipments || orderShipments.length === 0) return;
@@ -493,7 +489,7 @@ export class LogisticsService {
       const order = await this.orderModel.findOneBy({
         id: orderShipment.order_id,
       });
-      const site = this.getSite(order.siteId);
+      const site = this.geSite(order.siteId);
       await this.wpService.updateOrder(site, order.externalOrderId, {
         status: OrderStatus.COMPLETED,
       });
@@ -556,7 +552,7 @@ export class LogisticsService {
     });
   }
 
-  async getOrderList(number: string) {
+  async getTrackingNumber(number: string) {
     const orders = await this.orderModel.find({
       where: {
         externalOrderId: Like(`%${number}%`),
@@ -571,14 +567,56 @@ export class LogisticsService {
     }));
   }
 
-  async getListByOrderId(id: number) {
+  async getListByTrackingId(id: number) {
-    const item = await this.orderItem.find({ where: { orderId: id } });
+    const qb = `
-    const saleItem = await this.orderSaleModel.find({ where: { orderId: id } });
+      SELECT 
+        oi.name,
+        oi.quantity,
+        CASE 
+          WHEN oi.externalVariationId != 0 THEN v.constitution
+          ELSE p.constitution
+        END AS constitution
+      FROM order_item oi
+      LEFT JOIN wp_product p ON oi.siteId=p.siteId AND oi.externalProductId=p.externalProductId
+      LEFT JOIN variation v ON oi.siteId=v.siteId AND oi.externalVariationId=v.externalVariationId
+      WHERE oi.orderId=?
+    `;
+    const saleItem = await this.orderSaleModel.query(qb, [id]);
+    const allSkus = new Set<string>();
+    for (const item of saleItem) {
+      if (!item.constitution) continue;
+      try {
+        item.constitution.forEach(c => allSkus.add(c.sku));
+      } catch (e) {
+        console.warn('Invalid constitution JSON:', item.constitution);
+      }
+    }
+    console.log(allSkus);
+    const skuList = Array.from(allSkus);
+    let skuNameMap = new Map<string, string>();
 
-    return {
+    if (skuList.length > 0) {
-      item,
+      const placeholders = skuList.map(() => '?').join(', ');
-      saleItem
+      const productRows = await this.orderSaleModel.query(
-    };
+        `SELECT sku, name FROM product WHERE sku IN (${placeholders})`,
+        skuList
+      );
+      skuNameMap = new Map(productRows.map(p => [p.sku, p.name]));
+    }
+
+    for (const item of saleItem) {
+      if (!item.constitution) continue;
+      try {
+        item.constitution = item.constitution.map(c => ({
+          ...c,
+          name: skuNameMap.get(c.sku) || null,
+        }));
+      } catch (e) {
+        item.constitution = [];
+      }
+    }
+
+    return saleItem;
   }
 
   async getList(param: Record<string, any>) {

src/service/order.service.ts

@@ -45,9 +45,6 @@ export class OrderService {
   @InjectEntityModel(Order)
   orderModel: Repository<Order>;
 
-  @InjectEntityModel(User)
-  userModel: Repository<User>;
-
   @InjectEntityModel(OrderItem)
   orderItemModel: Repository<OrderItem>;
 
@@ -549,7 +546,7 @@ export class OrderService {
     current,
     pageSize,
     customer_email,
-  }, userId = undefined) {
+  }) {
     const parameters: any[] = [];
 
     // 基础查询
@@ -632,14 +629,6 @@ export class OrderService {
       totalQuery += ` AND o.date_created <= ?`;
       parameters.push(endDate);
     }
-    const user = await this.userModel.findOneBy({id: userId});
-    if (user?.permissions?.includes('order-10-days')) {
-      sqlQuery += ` AND o.date_created >= ?`;
-      totalQuery += ` AND o.date_created >= ?`;
-      const tenDaysAgo = new Date();
-      tenDaysAgo.setDate(tenDaysAgo.getDate() - 10);
-      parameters.push(tenDaysAgo.toISOString());
-    }
 
     // 处理 status 参数
     if (status) {
@@ -749,7 +738,7 @@ export class OrderService {
     return await query.getRawMany();
   }
 
-  async getOrderSales({ siteId, startDate, endDate, current, pageSize, name, exceptPackage }: QueryOrderSalesDTO) {
+  async getOrderSales({ siteId, startDate, endDate, current, pageSize, name }: QueryOrderSalesDTO) {
     const nameKeywords = name ? name.split(' ').filter(Boolean) : [];
     const offset = (current - 1) * pageSize;
 
@@ -796,16 +785,6 @@ export class OrderService {
       itemSql += ' AND os.siteId = ?';
       itemParams.push(siteId);
     }
-    if (exceptPackage) {
-      itemSql += `
-        AND os.orderId IN (
-          SELECT orderId 
-          FROM order_sale 
-          GROUP BY orderId 
-          HAVING COUNT(*) = 1
-        )
-      `;
-    }
     itemSql += nameCondition;
     itemSql += `
       GROUP BY os.productId, os.name
@@ -823,17 +802,17 @@ export class OrderService {
       const pcParams: any[] = [...productIds, startDate, endDate];
       if (siteId) pcParams.push(siteId);
 
-      let pcSql = `
+      const pcSql = `
         SELECT
           os.productId,
           SUM(CASE WHEN t.purchaseIndex = 1 THEN os.quantity ELSE 0 END) AS firstOrderYOONEBoxCount,
-          COUNT(DISTINCT CASE WHEN t.purchaseIndex = 1 THEN os.orderId END) AS firstOrderCount,
+          COUNT(CASE WHEN t.purchaseIndex = 1 THEN 1 END) AS firstOrderCount,
           SUM(CASE WHEN t.purchaseIndex = 2 THEN os.quantity ELSE 0 END) AS secondOrderYOONEBoxCount,
-          COUNT(DISTINCT CASE WHEN t.purchaseIndex = 2 THEN os.orderId END) AS secondOrderCount,
+          COUNT(CASE WHEN t.purchaseIndex = 2 THEN 1 END) AS secondOrderCount,
           SUM(CASE WHEN t.purchaseIndex = 3 THEN os.quantity ELSE 0 END) AS thirdOrderYOONEBoxCount,
-          COUNT(DISTINCT CASE WHEN t.purchaseIndex = 3 THEN os.orderId END) AS thirdOrderCount,
+          COUNT(CASE WHEN t.purchaseIndex = 3 THEN 1 END) AS thirdOrderCount,
           SUM(CASE WHEN t.purchaseIndex > 3 THEN os.quantity ELSE 0 END) AS moreThirdOrderYOONEBoxCount,
-          COUNT(DISTINCT CASE WHEN t.purchaseIndex > 3 THEN os.orderId END) AS moreThirdOrderCount
+          COUNT(CASE WHEN t.purchaseIndex > 3 THEN 1 END) AS moreThirdOrderCount
         FROM order_sale os
         INNER JOIN (
           SELECT o2.id AS orderId,
@@ -850,22 +829,9 @@ export class OrderService {
             WHERE date_paid BETWEEN ? AND ?
             ${siteId ? 'AND siteId = ?' : ''}
           )
-      `;
-      if (exceptPackage) {
-        pcSql += `
-          AND os.orderId IN (
-            SELECT orderId 
-            FROM order_sale 
-            GROUP BY orderId 
-            HAVING COUNT(*) = 1
-          )
-        `;
-      }
-      pcSql += `
         GROUP BY os.productId
       `;
 
-      console.log('------3.5-----', pcSql, pcParams, exceptPackage);
       const pcResults = await this.orderSaleModel.query(pcSql, pcParams);
 
       const pcMap = new Map<number, any>();
@@ -1320,8 +1286,7 @@ export class OrderService {
             productId: product.id,
             name: product.name,
             sku: sale.sku,
-            quantity: sale.quantity,
+            quantity: sale.quantity
-            // externalOrderItemId:
           });
         };
       }).catch(error => {

src/service/user.service.ts

@@ -70,7 +70,6 @@ export class UserService {
       id: user.id,
       deviceId,
       username: user.username,
-      isSuper: user.isSuper,
     });
 
     return {

src/service/wp.service.ts

@@ -4,7 +4,6 @@ import { WpSite } from '../interface';
 import { WpProduct } from '../entity/wp_product.entity';
 import { Variation } from '../entity/variation.entity';
 import { UpdateVariationDTO, UpdateWpProductDTO } from '../dto/wp_product.dto';
-import { ProductStatus, ProductStockStatus } from '../enums/base.enum';
 
 @Provide()
 export class WPService {
@@ -223,26 +222,6 @@ export class WPService {
     });
   }
 
-    /**
-   * 更新 WooCommerce 产品 上下架状态
-   * @param productId 产品 ID
-   * @param status 状态
-   * @param stock_status 上下架状态
-   */
-  async updateProductStatus(
-    site: WpSite,
-    productId: string,
-    status: ProductStatus,
-    stock_status: ProductStockStatus
-  ): Promise<Boolean> {
-    const res = await this.updateData(`/wc/v3/products/${productId}`, site, {
-      status,
-      stock_status,
-    });
-    console.log('res', res);
-    return res;
-  }
-
   /**
    * 更新 WooCommerce 产品变体
    * @param productId 产品 ID

src/service/wp_product.service.ts

@@ -11,7 +11,6 @@ import {
   UpdateWpProductDTO,
 } from '../dto/wp_product.dto';
 import { Product } from '../entity/product.entty';
-import { ProductStatus, ProductStockStatus } from '../enums/base.enum';
 
 @Provide()
 export class WpProductService {
@@ -27,7 +26,7 @@ export class WpProductService {
   @InjectEntityModel(Variation)
   variationModel: Repository<Variation>;
 
-  getSite(id: string): WpSite {
+  geSite(id: string): WpSite {
     let idx = this.sites.findIndex(item => item.id === id);
     return this.sites[idx];
   }
@@ -46,7 +45,7 @@ export class WpProductService {
   }
 
   async syncSite(siteId: string) {
-    const site = this.getSite(siteId);
+    const site = this.geSite(siteId);
     const products = await this.wpApiService.getProducts(site);
     for (const product of products) {
       const variations =
@@ -57,21 +56,6 @@ export class WpProductService {
     }
   }
 
-  // 控制产品上下架
-  async updateProductStatus(id: number, status: ProductStatus, stock_status: ProductStockStatus) {
-    const wpProduct = await this.wpProductModel.findOneBy({ id });
-    const site = await this.getSite(wpProduct.siteId);
-    wpProduct.status = status;
-    wpProduct.stockStatus = stock_status;
-    const res =  await this.wpApiService.updateProductStatus(site, wpProduct.externalProductId, status, stock_status);
-    if (res === true) {
-      this.wpProductModel.save(wpProduct);
-      return true;
-    } else {
-      return res;
-    }
-  }
-
   async findProduct(
     siteId: string,
     externalProductId: string

src/utils/object-transform.util.ts

@@ -1,36 +0,0 @@
-function camelToSnake(str: string): string {
-  return str.replace(/[A-Z]/g, letter => `_${letter.toLowerCase()}`);
-}
-
-function snakeToCamel(str: string): string {
-  return str.replace(/(_[\w])/g, (match) => 
-    match[1].toUpperCase()
-  );
-}
-
-export function convertKeysFromSnakeToCamel<T>(obj: T): T {
-  if (Array.isArray(obj)) {
-    return obj.map(convertKeysFromSnakeToCamel) as unknown as T;
-  } else if (obj !== null && typeof obj === 'object') {
-    return Object.keys(obj).reduce((acc, key) => {
-      const newKey = snakeToCamel(key);
-      acc[newKey] = convertKeysFromSnakeToCamel((obj as any)[key]);
-      return acc;
-    }, {} as any);
-  }
-  return obj;
-}
-
-
-export function convertKeysFromCamelToSnake<T>(obj: T): T {
-  if (Array.isArray(obj)) {
-    return obj.map(convertKeysFromCamelToSnake) as unknown as T;
-  } else if (obj !== null && typeof obj === 'object') {
-    return Object.keys(obj).reduce((acc, key) => {
-      const newKey = camelToSnake(key);
-      acc[newKey] = convertKeysFromCamelToSnake((obj as any)[key]);
-      return acc;
-    }, {} as any);
-  }
-  return obj;
-}