src/config/config.local.ts

@@ -35,7 +35,7 @@ export default {
     {
       id: '-1',
       siteName: 'Admin',
-      email: '2469687281@qq.com',
+      email: '444693295@qq.com',
     },
     {
       id: '2',
@@ -43,7 +43,7 @@ export default {
       consumerKey: 'ck_a369473a6451dbaec63d19cbfd74a074b2c5f742',
       consumerSecret: 'cs_0946bbbeea1bfefff08a69e817ac62a48412df8c',
       siteName: 'Local',
-      email: '2469687281@qq.com',
+      email: '444693295@qq.com',
       emailPswd: 'lulin91.',
     },
     {
@@ -52,7 +52,7 @@ export default {
       consumerKey: 'ck_a369473a6451dbaec63d19cbfd74a074b2c5f742',
       consumerSecret: 'cs_0946bbbeea1bfefff08a69e817ac62a48412df8c',
       siteName: 'Local-test-2',
-      email: '2469687281@qq.com',
+      email: '444693295@qq.com',
       emailPswd: 'lulin91.',
     },
     // {

src/controller/webhook.controller.ts

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

src/dto/order.dto.ts

@@ -68,10 +68,6 @@ export class QueryOrderDTO {
   @Rule(RuleType.string().allow(''))
   customer_email: string;
 
-  @ApiProperty()
-  @Rule(RuleType.string().allow(''))
-  billing_phone: string;
-
   @ApiProperty()
   @Rule(RuleType.string().allow(null))
   keyword: string;
@@ -87,10 +83,6 @@ export class QueryOrderDTO {
   @ApiProperty({ type: 'enum', enum: ErpOrderStatus })
   @Rule(RuleType.string().valid(...Object.values(ErpOrderStatus)))
   status: ErpOrderStatus;
-
-  @ApiProperty()
-  @Rule(RuleType.string())
-  payment_method: string;
 }
 
 export class QueryOrderSalesDTO {

src/dto/stock.dto.ts

@@ -51,18 +51,6 @@ export class QueryStockRecordDTO {
   @ApiProperty()
   @Rule(RuleType.string())
   productName: string;
-
-  @ApiProperty()
-  @Rule(RuleType.string())
-  operationType: string;
-
-  @ApiProperty()
-  @Rule(RuleType.date())
-  startDate: Date;
-
-  @ApiProperty()
-  @Rule(RuleType.date())
-  endDate: Date;
 }
 export class QueryPurchaseOrderDTO {
   @ApiProperty({ example: '1', description: '页码' })

src/entity/order.entity.ts

@@ -243,16 +243,6 @@ export class Order {
   @Expose()
   utm_source: string;
 
-  @ApiProperty()
-  @Column({ default: '' })
-  @Expose()
-  is_exchange: string;
-
-  @ApiProperty()
-  @Column({ default: '' })
-  @Expose()
-  exchange_frequency: string;
-
   @ApiProperty({
     example: '2022-12-12 11:11:11',
     description: '创建时间',

src/entity/order_item_original.entity.ts

@@ -77,6 +77,3 @@ export class OrderSaleOriginal {
   @Expose()
   updatedAt?: Date;
 }
-
-
-

src/entity/order_items_original.entity.ts

@@ -1,113 +0,0 @@
-import { ApiProperty } from '@midwayjs/swagger';
-import { Exclude, Expose } from 'class-transformer';
-import {
-  Column,
-  CreateDateColumn,
-  Entity,
-  JoinColumn,
-  ManyToOne,
-  PrimaryGeneratedColumn,
-  UpdateDateColumn,
-} from 'typeorm';
-import { Order } from './order.entity';
-
-
-@Entity('order_item_original')
-@Exclude()
-export class OrderItemOriginal {
-  @ApiProperty()
-  @PrimaryGeneratedColumn()
-  @Expose()
-  id: number;
-
-  @ApiProperty()
-  @ManyToOne(() => Order)
-  @JoinColumn({ name: 'order_id' })
-  @Column({ name: 'order_id' })
-  @Expose()
-  orderId: number; // 订单 ID
-
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  name: string;
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  siteId: string; // 来源站点唯一标识
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  externalOrderId: string; // WooCommerce 订单 ID
-
-  @ApiProperty()
-  @Column({ nullable: true })
-  @Expose()
-  externalOrderItemId: string; // WooCommerce 订单item ID
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  externalProductId: string; // WooCommerce 产品 ID
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  externalVariationId: string; // WooCommerce 变体 ID
-
-  @ApiProperty()
-  @Column()
-  @Expose()
-  quantity: number;
-
-  @ApiProperty()
-  @Column('decimal', { precision: 10, scale: 2, nullable: true })
-  @Expose()
-  subtotal: number;
-
-  @ApiProperty()
-  @Column('decimal', { precision: 10, scale: 2, nullable: true })
-  @Expose()
-  subtotal_tax: number;
-
-  @ApiProperty()
-  @Column('decimal', { precision: 10, scale: 2, nullable: true })
-  @Expose()
-  total: number;
-
-  @ApiProperty()
-  @Column('decimal', { precision: 10, scale: 2, nullable: true })
-  @Expose()
-  total_tax: number;
-
-  @ApiProperty()
-  @Column({ nullable: true })
-  @Expose()
-  sku?: string;
-
-  @ApiProperty()
-  @Column('decimal', { precision: 10, scale: 2 })
-  @Expose()
-  price: number;
-
-  @ApiProperty({
-    example: '2022-12-12 11:11:11',
-    description: '创建时间',
-    required: true,
-  })
-  @CreateDateColumn()
-  @Expose()
-  createdAt: Date;
-
-  @ApiProperty({
-    example: '2022-12-12 11:11:11',
-    description: '更新时间',
-    required: true,
-  })
-  @UpdateDateColumn()
-  @Expose()
-  updatedAt: Date;
-}

src/entity/variation.entity.ts

@@ -80,10 +80,6 @@ export class Variation {
   @Column({ nullable: true, type: Boolean })
   on_sale: boolean; // 是否促销中
 
-  @ApiProperty({ description: '是否删除', type: Boolean })
-  @Column({ nullable: true, type: Boolean , default: false  })
-  on_delete: boolean; // 是否删除
-
   @Column({ type: 'json', nullable: true })
   attributes: Record<string, any>; // 变体的属性
 

src/entity/wp_product.entity.ts

@@ -77,11 +77,6 @@ export class WpProduct {
   @Column({ nullable: true, type: Boolean })
   on_sale: boolean; // 是否促销中
 
-  @ApiProperty({ description: '是否删除', type: Boolean })
-  @Column({ nullable: true, type: Boolean , default: false  })
-  on_delete: boolean; // 是否删除
-
-
   @ApiProperty({
     description: '产品类型',
     enum: ProductType,
@@ -89,7 +84,6 @@ export class WpProduct {
   @Column({ type: 'enum', enum: ProductType })
   type: ProductType;
 
-
   @Column({ type: 'json', nullable: true })
   metadata: Record<string, any>; // 产品的其他扩展字段
 

src/enums/base.enum.ts

@@ -54,17 +54,9 @@ export enum ErpOrderStatus {
   AFTER_SALE_PROCESSING = 'after_sale_pending', // 售后处理中
   PENDING_RESHIPMENT = 'pending_reshipment', // 待补发
   PENDING_REFUND = 'pending_refund', // 待退款
-
-  REFUND_REQUESTED = 'refund_requested', // 已申请退款
-  REFUND_APPROVED = 'refund_approved', // 退款申请已通过
-  REFUND_CANCELLED = 'refund_cancelled', // 已取消退款
 }
 
 export enum ShipmentType {
   CANADAPOST = 'canadapost',
   FREIGHTCOM = 'freightcom',
 }
-
-export enum staticValue {
-  STATIC_CAPTCHA = 'yoone2025!@YOONE0923'
-}

src/service/authCode.service.ts

@@ -2,7 +2,6 @@ import { Provide } from '@midwayjs/core';
 import { InjectEntityModel } from '@midwayjs/typeorm';
 import { Repository } from 'typeorm';
 import { AuthCode } from '../entity/auth_code';
-import { staticValue } from '../enums/base.enum';
 
 @Provide()
 export class AuthCodeService {
@@ -39,7 +38,7 @@ export class AuthCodeService {
       return false;
     }
 
-    if (staticValue.STATIC_CAPTCHA !== code&&record.code !== code) return false;
+    if (record.code !== code) return false;
 
     await this.authCodeModel.delete({ device_id: deviceId });
     return true;

src/service/order.service.ts

@@ -5,7 +5,6 @@ import { In, Like, Repository } from 'typeorm';
 import { InjectEntityModel, TypeORMDataSourceManager } from '@midwayjs/typeorm';
 import { plainToClass } from 'class-transformer';
 import { OrderItem } from '../entity/order_item.entity';
-import { OrderItemOriginal } from '../entity/order_items_original.entity';
 import { OrderSale } from '../entity/order_sale.entity';
 import { WpProduct } from '../entity/wp_product.entity';
 import { Product } from '../entity/product.entty';
@@ -52,9 +51,6 @@ export class OrderService {
   @InjectEntityModel(OrderItem)
   orderItemModel: Repository<OrderItem>;
 
-  @InjectEntityModel(OrderItem)
-  orderItemOriginalModel: Repository<OrderItemOriginal>;
-
   @InjectEntityModel(OrderSale)
   orderSaleModel: Repository<OrderSale>;
 
@@ -213,7 +209,6 @@ export class OrderService {
         el => el.key === '_wc_order_attribution_utm_source'
       )?.value || '';
     order.customer_email = order?.billing?.email || order?.shipping?.email;
- //   order.billing_phone = order?.billing?.phone || order?.shipping?.phone;
     const entity = plainToClass(Order, order);
     const existingOrder = await this.orderModel.findOne({
       where: { externalOrderId: order.externalOrderId, siteId: siteId },
@@ -327,28 +322,6 @@ export class OrderService {
     }
   }
 
-    async saveOrderItemsG(orderItem: OrderItem) {
-    const existingOrderItem = await this.orderItemModel.findOne({
-      where: {
-        externalOrderId: orderItem.externalOrderId,
-        siteId: orderItem.siteId,
-        externalOrderItemId: orderItem.externalOrderItemId,
-      },
-    });
-
-    if (
-      existingOrderItem &&
-      existingOrderItem.quantity === orderItem.quantity
-    ) {
-      return;
-    }
-    if (existingOrderItem) {
-      await this.orderItemModel.update(existingOrderItem.id, orderItem);
-    } else {
-      await this.orderItemModel.save(orderItem);
-    }
-  }
-
   async saveOrderSale(orderItem: OrderItem) {
     const currentOrderSale = await this.orderSaleModel.find({
       where: {
@@ -576,8 +549,6 @@ export class OrderService {
     current,
     pageSize,
     customer_email,
-    payment_method,
-    billing_phone,
   }, userId = undefined) {
     const parameters: any[] = [];
 
@@ -591,7 +562,6 @@ export class OrderService {
         o.total as total,
         o.date_created as date_created,
         o.customer_email as customer_email,
-      
         o.transaction_id as transaction_id,
         o.orderStatus as orderStatus,
         o.customer_ip_address as customer_ip_address,
@@ -601,7 +571,6 @@ export class OrderService {
         o.customer_note as customer_note,
         o.shipping as shipping,
         o.billing as billing,
-        o.payment_method as payment_method,
         cs.order_count as order_count,
         cs.total_spent as total_spent,
         COALESCE(
@@ -663,10 +632,6 @@ export class OrderService {
       totalQuery += ` AND o.date_created <= ?`;
       parameters.push(endDate);
     }
-    if (payment_method) {
-      sqlQuery += ` AND o.payment_method like "%${payment_method}%" `;
-      totalQuery += ` AND o.payment_method like "%${payment_method}%" `;
-    }
     const user = await this.userModel.findOneBy({id: userId});
     if (user?.permissions?.includes('order-10-days')) {
       sqlQuery += ` AND o.date_created >= ?`;
@@ -699,12 +664,6 @@ export class OrderService {
       parameters.push(`%${customer_email}%`);
     }
 
-    if (billing_phone) {
-      sqlQuery += ` AND o.billing_phone LIKE ?`;
-      totalQuery += ` AND o.billing_phone LIKE ?`;
-      parameters.push(`%${billing_phone}%`);
-    }
-
     // 关键字搜索
     if (keyword) {
       sqlQuery += `
@@ -749,7 +708,6 @@ export class OrderService {
     endDate,
     keyword,
     customer_email,
-    billing_phone,
   }) {
     const query = this.orderModel
       .createQueryBuilder('order')
@@ -1142,6 +1100,7 @@ export class OrderService {
     }
 
     // update order_sale_origin if not exist
+
     try {
       const order_sale_origin_count = await this.orderSaleOriginalModel.countBy({ orderId: id });
       if (order_sale_origin_count === 0) {
@@ -1151,15 +1110,6 @@ export class OrderService {
         });
       }
   
-       // update order_item_origin if not exist
-       const order_item_origin_count = await this.orderItemOriginalModel.countBy({ orderId: id });
-      if (order_item_origin_count === 0 && items.length!=0) {
-        items.forEach(async sale => {
-          const { id: saleId, ...saleData } = sale;
-          await this.orderItemOriginalModel.save(saleData);
-        });
-      }
-  
     } catch (error) {
       console.log('create order sale origin error: ', error.message);
     }
@@ -1272,9 +1222,8 @@ export class OrderService {
     await this.orderModel.save(order);
   }
 
-
   async createOrder(data: Record<string, any>) {
-    const { sales, total, billing, customer_email, billing_phone } = data;
+    const { sales, total, billing, customer_email } = data;
     const dataSource = this.dataSourceManager.getDataSource('default');
     const now = new Date();
     return dataSource.transaction(async manager => {
@@ -1293,7 +1242,6 @@ export class OrderService {
         date_paid: now,
         total,
         customer_email,
-        billing_phone,
         billing,
         shipping: billing,
       });
@@ -1376,9 +1324,6 @@ export class OrderService {
             // externalOrderItemId:
           });
         };
-
-        //await orderRepo.save();
-
       }).catch(error => {
         transactionError = error;
       });

src/service/stock.service.ts

@@ -1,5 +1,5 @@
 import { Provide } from '@midwayjs/core';
-import { Between, Like, Repository, LessThan, MoreThan } from 'typeorm';
+import { Between, Like, Repository } from 'typeorm';
 import { Stock } from '../entity/stock.entity';
 import { StockRecord } from '../entity/stock_record.entity';
 import { paginate } from '../utils/paginate.util';
@@ -350,18 +350,11 @@ export class StockService {
       stockPointId,
       productSku,
       productName,
-      operationType,
-      startDate,
-      endDate,
     } = query;
 
     const where: any = {};
     if (stockPointId) where.stockPointId = stockPointId;
     if (productSku) where.productSku = productSku;
-    if (operationType) where.operationType = operationType;
-    if (startDate) where.createdAt = MoreThan(startDate);
-    if (endDate) where.createdAt = LessThan(endDate);
-    if (startDate && endDate) where.createdAt = Between(startDate, endDate);
     const queryBuilder = this.stockRecordModel
       .createQueryBuilder('stock_record')
       .leftJoin(Product, 'product', 'product.sku = stock_record.productSku')

src/service/wp.service.ts

@@ -240,6 +240,7 @@ export class WPService {
       manage_stock: false, // 为true的时候，用quantity控制库存，为false时，直接用stock_status控制
       stock_status,
     });
+    console.log('res', res);
     return res;
   }
 

src/service/wp_product.service.ts

@@ -1,4 +1,3 @@
-import { Product } from './../entity/product.entty';
 import { Config, Inject, Provide } from '@midwayjs/core';
 import { WPService } from './wp.service';
 import { WpSite } from '../interface';
@@ -11,6 +10,7 @@ import {
   UpdateVariationDTO,
   UpdateWpProductDTO,
 } from '../dto/wp_product.dto';
+import { Product } from '../entity/product.entty';
 import { ProductStatus, ProductStockStatus } from '../enums/base.enum';
 
 @Provide()
@@ -47,45 +47,14 @@ export class WpProductService {
 
   async syncSite(siteId: string) {
     const site = this.getSite(siteId);
-    const externalProductIds = this.wpProductModel.createQueryBuilder('wp_product')
-    .select([
-       'wp_product.id ',
-        'wp_product.externalProductId ',
-      ])
-    .where('wp_product.siteId = :siteIds ', {
-        siteIds: siteId,
-      })
-       const rawResult = await externalProductIds.getRawMany();
-
-   const externalIds = rawResult.map(item => item.externalProductId);
-
-const excludeValues = [];
-
     const products = await this.wpApiService.getProducts(site);
     for (const product of products) {
-        excludeValues.push(String(product.id));
       const variations =
         product.type === 'variable'
           ? await this.wpApiService.getVariations(site, product.id)
           : [];
-     
       await this.syncProductAndVariations(site.id, product, variations);
     }
-
-    const filteredIds = externalIds.filter(id => !excludeValues.includes(id));
-    if(filteredIds.length!=0){
-     await this.variationModel.createQueryBuilder('variation')
-    .update()
-    .set({ on_delete: true }) 
-    .where(" variation.externalProductId in (:...filteredId) ",{filteredId:filteredIds})
-    .execute();
-
-    this.wpProductModel.createQueryBuilder('wp_product')
-    .update()
-    .set({ on_delete: true }) 
-    .where(" wp_product.externalProductId in (:...filteredId) ",{filteredId:filteredIds})
-    .execute();
-}
   }
 
   // 控制产品上下架
@@ -310,8 +279,6 @@ const excludeValues = [];
     if (status) {
       where.status = status;
     }
-     where.on_delete = false;
-    
     const products = await this.wpProductModel.find({
       where,
       skip: (current - 1) * pageSize,
@@ -358,7 +325,7 @@ const excludeValues = [];
         'product.name as product_name', // 关联查询返回 product.name
         'variation_product.name as variation_product_name', // 关联查询返回 variation 的产品 name
       ])
-      .where('wp_product.id IN (:...ids) AND wp_product.on_delete = false ', {
+      .where('wp_product.id IN (:...ids)', {
         ids: products.map(product => product.id),
       });
 
@@ -490,21 +457,7 @@ const excludeValues = [];
       where: { siteId, externalProductId: productId },
     });
     if (!product) throw new Error('未找到该商品');
-
+    await this.variationModel.delete({ siteId, externalProductId: productId });
-    await this.variationModel.createQueryBuilder('variation')
+    await this.wpProductModel.delete({ siteId, externalProductId: productId });
-    .update()
-    .set({ on_delete: true }) 
-    .where(" variation.externalProductId = :externalProductId ",{externalProductId:productId})
-    .execute();
-
-    const sums= await this.wpProductModel.createQueryBuilder('wp_product')
-    .update()
-    .set({ on_delete: true }) 
-    .where(" wp_product.externalProductId = :externalProductId ",{externalProductId:productId})
-    .execute();
-
-    console.log(sums);
-    //await this.variationModel.delete({ siteId, externalProductId: productId });
-    //await this.wpProductModel.delete({ siteId, externalProductId: productId });
   }
 }

tsconfig.json

@@ -16,9 +16,7 @@
     "forceConsistentCasingInFileNames": true,
     "typeRoots": ["./typings", "./node_modules/@types"],
     "outDir": "dist",
-    "rootDir": "src",
+    "rootDir": "src"
-    "inlineSources": true         // ✅ 把源码嵌入 map 文件，方便 VS Code 还原
- 
   },
   "exclude": ["*.js", "*.ts", "dist", "node_modules", "test"]
 }