Compare commits
10 Commits
d4b267106e
...
f4a46bcf72
| Author | SHA1 | Date |
|---|---|---|
|
|
f4a46bcf72 | |
|
|
534cc3f2c7 | |
|
|
d8a3422015 | |
|
|
9d69af03b2 | |
|
|
1657b96694 | |
|
|
0a14a7c1ae | |
|
|
51b59ca176 | |
|
|
b879202d13 | |
|
|
d3d493f858 | |
|
|
96a3e5c76d |
|
|
@ -42,7 +42,8 @@ export class OrderController {
|
||||||
const result = await this.orderService.syncOrders(siteId, params);
|
const result = await this.orderService.syncOrders(siteId, params);
|
||||||
return successResponse(result);
|
return successResponse(result);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
return errorResponse(`同步失败,${error?.message || '未知错误'}`);
|
console.log(error);
|
||||||
|
return errorResponse('同步失败');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -133,7 +133,7 @@ export class OrderService {
|
||||||
async syncOrders(siteId: number, params: Record<string, any> = {}): Promise<SyncOperationResult> {
|
async syncOrders(siteId: number, params: Record<string, any> = {}): Promise<SyncOperationResult> {
|
||||||
// 调用 WooCommerce API 获取订单
|
// 调用 WooCommerce API 获取订单
|
||||||
const result = await (await this.siteApiService.getAdapter(siteId)).getAllOrders(params);
|
const result = await (await this.siteApiService.getAdapter(siteId)).getAllOrders(params);
|
||||||
this.logger.info('开始进入循环同步订单', result.length, '个订单')
|
|
||||||
// 初始化同步结果对象
|
// 初始化同步结果对象
|
||||||
const syncResult: SyncOperationResult = {
|
const syncResult: SyncOperationResult = {
|
||||||
total: result.length,
|
total: result.length,
|
||||||
|
|
@ -143,6 +143,7 @@ export class OrderService {
|
||||||
updated: 0,
|
updated: 0,
|
||||||
errors: []
|
errors: []
|
||||||
};
|
};
|
||||||
|
this.logger.info('开始进入循环同步订单', result.length, '个订单')
|
||||||
// 遍历每个订单进行同步
|
// 遍历每个订单进行同步
|
||||||
for (const order of result) {
|
for (const order of result) {
|
||||||
try {
|
try {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue