feat: 所有的流水信息都走webhook处理

src/modules/api/controller/open.ts

@@ -171,7 +171,7 @@ export class OpenApiController extends BaseController {
     const method = this.ctx.method;
     const path = this.ctx.path;
     const res = await this.easyPayAdapter.request(method, path, params);
-    this.easyOpenService.save_user_order(res, params, OrderType.ACQUIRING_PAYMENT);
+    // this.easyOpenService.save_user_order(res, params, OrderType.ACQUIRING_PAYMENT);
     return res;
   }
 
@@ -240,7 +240,7 @@ export class OpenApiController extends BaseController {
     // console.log(typeof params)
     // return `${method}, ${path}, ${params}`
     const res = await this.easyPayAdapter.request(method, path, params);
-    this.easyOpenService.save_user_order(res, params, OrderType.ACQUIRING_REFUND);
+    // this.easyOpenService.save_user_order(res, params, OrderType.ACQUIRING_REFUND);
     return res;
   }
   /**
@@ -419,7 +419,7 @@ export class OpenApiController extends BaseController {
     const res = await this.easyPayAdapter.request(method, path, params);
     console.log('Request Method:', method);
     console.log('Request Path:', path);
-    this.easyOpenService.save_user_order(res, params, OrderType.CURRENCY_EXCHANGE);
+    // this.easyOpenService.save_user_order(res, params, OrderType.CURRENCY_EXCHANGE);
     return res;
   }
 
@@ -469,7 +469,7 @@ export class OpenApiController extends BaseController {
     console.log('Request Method:', method);
     console.log('Request Path:', path);
     const res = await this.easyPayAdapter.request(method, path, params);
-    this.easyOpenService.save_user_order(res, params, OrderType.PAYMENT);
+    // this.easyOpenService.save_user_order(res, params, OrderType.PAYMENT);
     return res;
   }
 
@@ -556,7 +556,7 @@ export class OpenApiController extends BaseController {
     // console.log(typeof params)
     // return `${method}, ${path}, ${params}`
     const res = await this.easyPayAdapter.request(method, path, params);
-    this.easyOpenService.save_user_order(res, params, OrderType.TRANSFER);
+    // this.easyOpenService.save_user_order(res, params, OrderType.TRANSFER);
     return res;
   }
 

src/modules/api/service/open.ts

@@ -107,6 +107,7 @@ export class EasyOpenService extends BaseService {
         request_id: params?.payment?.request_id,
         order_id: orderInfo.id,
         order_type: type,
+        event_id: orderInfo.id,
         additional_info: {
           orderInfo,
           params,
@@ -185,7 +186,7 @@ export class EasyOpenService extends BaseService {
         // OrderType.ACQUIRING_REFUND !== type
         OrderType.PAYMENT === type
       ) {
-        await this.capturedTransferStream(openOrderObj, params, type);
+        // await this.capturedTransferStream(openOrderObj, params, type);
       }
 
       /* 更新相关订单信息 */