From e94ea5ed58cdc153d0dc75ef18e66908e20e8c4b Mon Sep 17 00:00:00 2001 From: tikkhun Date: Mon, 17 Nov 2025 11:03:25 +0800 Subject: [PATCH] =?UTF-8?q?refactor(service):=20=E7=BB=9F=E4=B8=80?= =?UTF-8?q?=E5=B0=86wPService=E9=87=8D=E5=91=BD=E5=90=8D=E4=B8=BAwpService?= =?UTF-8?q?=E4=BB=A5=E7=AC=A6=E5=90=88=E5=91=BD=E5=90=8D=E8=A7=84=E8=8C=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/service/order.service.ts | 22 +++++++++++----------- src/service/subscription.service.ts | 4 ++-- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/src/service/order.service.ts b/src/service/order.service.ts index 3b1399e..9bdc1fd 100644 --- a/src/service/order.service.ts +++ b/src/service/order.service.ts @@ -38,7 +38,7 @@ export class OrderService { sites: WpSite[]; @Inject() - wPService: WPService; + wpService: WPService; @Inject() stockService: StockService; @@ -101,14 +101,14 @@ export class OrderService { customerModel: Repository; async syncOrders(siteId: string) { - const orders = await this.wPService.getOrders(siteId); // 调用 WooCommerce API 获取订单 + const orders = await this.wpService.getOrders(siteId); // 调用 WooCommerce API 获取订单 for (const order of orders) { await this.syncSingleOrder(siteId, order); } } async syncOrderById(siteId: string, orderId: string) { - const order = await this.wPService.getOrder(siteId, orderId); + const order = await this.wpService.getOrder(siteId, orderId); await this.syncSingleOrder(siteId, order, true); } // 订单状态切换表 @@ -131,7 +131,7 @@ export class OrderService { throw new Error(`更新订单信息,但失败,原因为 ${siteId} 的站点信息不存在`) } // 同步更新回 wordpress 的 order 状态 - await this.wPService.updateOrder(site, order.id, { status: order.status }); + await this.wpService.updateOrder(site, order.id, { status: order.status }); order.status = this.orderAutoNextStatusMap[originStatus]; } catch (error) { console.error('更新订单状态失败,原因为:', error) @@ -442,7 +442,7 @@ export class OrderService { refunds: Record[]; }) { for (const item of refunds) { - const refund = await this.wPService.getOrderRefund( + const refund = await this.wpService.getOrderRefund( siteId, externalOrderId, item.id @@ -1261,9 +1261,9 @@ export class OrderService { async cancelOrder(id: number) { const order = await this.orderModel.findOne({ where: { id } }); if (!order) throw new Error(`订单 ${id}不存在`); - const site = this.wPService.geSite(order.siteId); + const site = this.wpService.geSite(order.siteId); if (order.status !== OrderStatus.CANCEL) { - await this.wPService.updateOrder(site, order.externalOrderId, { + await this.wpService.updateOrder(site, order.externalOrderId, { status: OrderStatus.CANCEL, }); order.status = OrderStatus.CANCEL; @@ -1275,9 +1275,9 @@ export class OrderService { async refundOrder(id: number) { const order = await this.orderModel.findOne({ where: { id } }); if (!order) throw new Error(`订单 ${id}不存在`); - const site = this.wPService.geSite(order.siteId); + const site = this.wpService.geSite(order.siteId); if (order.status !== OrderStatus.REFUNDED) { - await this.wPService.updateOrder(site, order.externalOrderId, { + await this.wpService.updateOrder(site, order.externalOrderId, { status: OrderStatus.REFUNDED, }); order.status = OrderStatus.REFUNDED; @@ -1289,9 +1289,9 @@ export class OrderService { async completedOrder(id: number) { const order = await this.orderModel.findOne({ where: { id } }); if (!order) throw new Error(`订单 ${id}不存在`); - const site = this.wPService.geSite(order.siteId); + const site = this.wpService.geSite(order.siteId); if (order.status !== OrderStatus.COMPLETED) { - await this.wPService.updateOrder(site, order.externalOrderId, { + await this.wpService.updateOrder(site, order.externalOrderId, { status: OrderStatus.COMPLETED, }); order.status = OrderStatus.COMPLETED; diff --git a/src/service/subscription.service.ts b/src/service/subscription.service.ts index 2ec7597..5ae83b0 100644 --- a/src/service/subscription.service.ts +++ b/src/service/subscription.service.ts @@ -10,7 +10,7 @@ import { QuerySubscriptionDTO } from '../dto/subscription.dto'; @Provide() export class SubscriptionService { @Inject() - wPService: WPService; + wpService: WPService; @InjectEntityModel(Subscription) subscriptionModel: Repository; @@ -20,7 +20,7 @@ export class SubscriptionService { * - 从 WooCommerce 拉取订阅并逐条入库/更新 */ async syncSubscriptions(siteId: string) { - const subs = await this.wPService.getSubscriptions(siteId); + const subs = await this.wpService.getSubscriptions(siteId); for (const sub of subs) { await this.syncSingleSubscription(siteId, sub); }