Merge pull request #1 from maxVaJp/merchant

feat(): 商户体系梳理

src/config/config.max.ts

@@ -9,14 +9,14 @@ export default {
     dataSource: {
       default: {
         type: 'mysql',
-        // host: '192.168.2.101',
-        // port: 6806,
-        // username: 'root',
-        // password: 'admin',
-        host: '127.0.0.1',
-        port: 3306,
-        username: 'va',
-        password: 'FHZ36dP527GacTty',
+        host: '192.168.2.101',
+        port: 6806,
+        username: 'root',
+        password: 'admin',
+        // host: '127.0.0.1',
+        // port: 3306,
+        // username: 'va',
+        // password: 'FHZ36dP527GacTty',
         database: 'va',
         // 自动建表 注意：线上部署的时候不要使用，有可能导致数据丢失
         synchronize: true,

src/modules/api/controller/customer.ts

@@ -11,6 +11,7 @@ import {
 import { IndividualEntity } from '../../payment/entity/individual';
 import { CustomerService } from '../service/customer';
 import {SunPayAdapter} from "../../payment/adapter/sunpay.adapter";
+import {IndividualService} from "../../payment/service/individual";
 
 /**
  * 客户管理
@@ -30,6 +31,12 @@ export class CustomerController extends BaseController {
   async createCustomer(@Body() params: IndividualEntity) {
     return this.ok(await this.customerService.createCustomer(params));
   }
+
+
+  @Post('/add-individual', { summary: '创建客户' })
+  async addIndividual(@Body() params: IndividualEntity) {
+    return this.ok(await this.customerService.addIndividual(params));
+  }
   // /**
   //  * 获取创建客户必填字段
   //  */

src/modules/api/service/customer.ts

@@ -50,4 +50,8 @@ export class CustomerService extends BaseService {
     return await this.businessService.update(params);
     // TODO 过滤sunpay返回
   }
+  async addIndividual(params) {
+    this.individualService.setIsOpenApi(true)
+    return await this.individualService.add(params);
+  }
 }

src/modules/payment/adapter/sunpay.adapter.ts

@@ -122,12 +122,14 @@ export class SunPayAdapter implements ChannelAdapter {
       // 检查响应
       if (response.data.code !== 200) {
         console.log(response.data);
+        // TODO 移除 SunPay API Error1
         throw new Error(`SunPay API Error1: ${response.data.msg}`);
       }
       return response.data;
     } catch (error) {
       console.log(error);
       if (axios.isAxiosError(error) && error.response) {
+        // TODO 移除 SunPay API Error2
         throw new Error(`SunPay API Error2: ${error.response.data.msg}`);
       }
       throw error;
@@ -337,6 +339,7 @@ export class SunPayAdapter implements ChannelAdapter {
         channel: 'SUNPAY',
       },
     });
+    console.log(340, customer);
     let res = null;
     if (customer) {
       params.customer_id = customer.customer_id;
@@ -404,7 +407,7 @@ export class SunPayAdapter implements ChannelAdapter {
   async payOutOrder(orderNo: string) {
     return this.request('GET', `/Fiat/PayOut/${orderNo}`);
   }
-  
+
   async cancelPayOut(orderNo: string) {
     return this.request('POST', `/Fiat/PayOut/${orderNo}/Cancel`);
   }

src/modules/payment/controller/admin/merchant.ts

@@ -1,8 +1,7 @@
 import { MerchantEntity } from './../../entity/merchant';
-import { Body, Get, Inject, Post, Provide } from '@midwayjs/decorator';
+import {Body, Get, Inject, Param, Post, Provide} from '@midwayjs/decorator';
 import { CoolController, BaseController } from '@cool-midway/core';
 import { MerchantService } from '../../service/merchant';
-import { Utils } from '../../../../comm/utils';
 
 @Provide()
 @CoolController({
@@ -25,5 +24,15 @@ import { Utils } from '../../../../comm/utils';
 })
 export class MerchantController extends BaseController {
   @Inject()
-  utils: Utils;
+  merchantService: MerchantService;
+
+  /**
+   * 生成 apiSecret
+   */
+  @Post('/secret', { summary: '生成 apiSecret' })
+  async createSecret(@Body() params: any) {
+    // console.log(34, params)
+    // return this.ok('');
+    return this.ok(await this.merchantService.createSecret(params));
+  }
 }

src/modules/payment/entity/business.ts

@@ -75,10 +75,17 @@ export class BusinessEntity extends BaseEntity {
   trading_country!: string;
   @Column({ comment: '拒绝原因', nullable: true })
   refused?: string;
-  @OneToOne(() => MerchantEntity, {
-    nullable: true, // 允许为空
-    onDelete: 'SET NULL',
-  })
+
+  @Column({ comment: '商户编号' })
+  merchantId!: string;
+
+  @Column({ comment: '用户编号' })
+  customer_id!: string;
+
+  // @OneToOne(() => MerchantEntity, {
+  //   nullable: true, // 允许为空
+  //   onDelete: 'SET NULL',
+  // })
   @JoinColumn()
   merchant?: MerchantEntity;
 }

src/modules/payment/entity/individual.ts

@@ -51,10 +51,19 @@ export class IndividualEntity extends BaseEntity {
   valid_time_end!: Date;
   @Column({ comment: '拒绝原因', nullable: true })
   refused?: string;
-  @OneToOne(() => MerchantEntity, {
-    nullable: true, // 允许为空
-    onDelete: 'SET NULL',
-  })
+
+  @Column({ comment: '商户编号' })
+  merchantId!: string;
+
+  @Column({ comment: '用户编号' })
+  customer_id!: string;
+  //
+  // @OneToOne(() => MerchantEntity, {
+  //   nullable: true, // 允许为空
+  //   onDelete: 'SET NULL',
+  // })
+  // @JoinColumn()
+  // merchant?: MerchantEntity;
   @JoinColumn()
   merchant?: MerchantEntity;
 }

src/modules/payment/service/business.ts

@@ -4,11 +4,15 @@ import { BaseService } from '@cool-midway/core';
 import { InjectEntityModel } from '@midwayjs/typeorm';
 import { Repository } from 'typeorm';
 import { PaymentService } from './payment';
+import {MerchantEntity} from "../entity/merchant";
 @Provide()
 export class BusinessService extends BaseService {
   @InjectEntityModel(BusinessEntity)
   businessEntity: Repository<BusinessEntity>;
 
+  @InjectEntityModel(MerchantEntity)
+  merchantEntity: Repository<MerchantEntity>;
+
   @Inject()
   paymentService: PaymentService;
   @Inject()
@@ -29,7 +33,7 @@ export class BusinessService extends BaseService {
    * @returns
    */
   async add(param) {
-    let merchantId = this.getMerchantId(param);
+    let merchantId = await this.getMerchantId(param);
     const custom = {
       ...param,
       out_user_id: merchantId,
@@ -39,12 +43,13 @@ export class BusinessService extends BaseService {
     let res = await this.paymentService
       .setChannel('SUNPAY')
       .setCustomerInfo(custom);
-    param.merchant = {
-      id: merchantId,
-    };
+    if (merchantId) {
+      param.merchantId = param?.mch_id || param?.mchId || merchantId
+    }
     await super.add({
       ...param,
       ...param.company,
+      customer_id: res.data.customer_id,
     });
     return res;
   }
@@ -70,14 +75,20 @@ export class BusinessService extends BaseService {
     this._isOpenApi = payload
   }
 
-  getMerchantId(params) {
+  async getMerchantId(params) {
     let merchantId;
     if (this._isOpenApi) {
       merchantId = params.out_user_id;
+    } else if (params?.mch_id || params?.mchId) {
+      // const  merchantInfo = await this.merchantEntity.findOneBy({
+      //   mchId: params?.mch_id || params?.mchId
+      // })
+      merchantId = params?.mch_id || params?.mchId
     } else {
       const { merchant } = this.ctx.admin;
-      merchantId = merchant.id;
+      merchantId = merchant.mchId;
     }
+
     return merchantId
   }
 

src/modules/payment/service/individual.ts

@@ -6,6 +6,7 @@ import { BaseService } from '@cool-midway/core';
 import { InjectEntityModel } from '@midwayjs/typeorm';
 import { Repository } from 'typeorm';
 import { PaymentService } from './payment';
+import {MerchantEntity} from "../entity/merchant";
 @Provide()
 export class IndividualService extends BaseService {
   @InjectEntityModel(IndividualEntity)
@@ -17,6 +18,9 @@ export class IndividualService extends BaseService {
   ctx;
   @InjectEntityModel(CustomerEntity)
   customerEntity: Repository<CustomerEntity>;
+
+  @InjectEntityModel(MerchantEntity)
+  merchantEntity: Repository<MerchantEntity>;
   @Config(ALL)
   config;
   @Init()
@@ -32,7 +36,7 @@ export class IndividualService extends BaseService {
    * @returns
    */
   async add(param) {
-    let merchantId = this.getMerchantId(param);
+    let merchantId = await this.getMerchantId(param);
     const custom = {
       ...param,
       out_user_id: merchantId,
@@ -42,12 +46,11 @@ export class IndividualService extends BaseService {
     let res = await this.paymentService
       .setChannel('SUNPAY')
       .setCustomerInfo(custom);
-    param.merchant = {
-      id: merchantId,
-    };
+    param.merchantId = merchantId
     await super.add({
       ...param,
       ...param.company,
+      customer_id: res.data.customer_id,
     });
     return res;
   }
@@ -69,13 +72,18 @@ export class IndividualService extends BaseService {
     this._isOpenApi = payload
   }
 
-  getMerchantId(params) {
+  async getMerchantId(params) {
     let merchantId;
     if (this._isOpenApi) {
       merchantId = params.out_user_id;
+    } else if (params?.mch_id || params?.mchId) {
+     // const  merchantInfo = await this.merchantEntity.findOneBy({
+     //    mchId: params?.mch_id
+     //  })
+      merchantId = params?.mch_id || params?.mchId
     } else {
       const { merchant } = this.ctx.admin;
-      merchantId = merchant.id;
+      merchantId = merchant.mchId;
     }
     return merchantId
   }

src/modules/payment/service/merchant.ts

@@ -112,4 +112,14 @@ export class MerchantService extends BaseService {
       .digest('hex')
       .toUpperCase();
   }
+
+
+  async createSecret(params: MerchantEntity) {
+    const merchant = await this.merchantEntity.findOneBy({
+      mchId: params.mchId
+    })
+    merchant.apiSecret = this.generateSignature(`${JSON.stringify(params)}`)
+    await this.merchantEntity.save(merchant)
+    return merchant
+  }
 }

src/modules/payment/service/payment.ts

@@ -47,18 +47,17 @@ export class PaymentService extends BaseService {
   }
   async setCustomerInfo(params: any) {
     const custom: any = {
-      out_user_id: params.merchantId,
+      out_user_id: params.out_user_id,
       webhook_url: params.webhook_url,
       customer_type: params.customer_type,
     };
     delete params.merchantId;
     delete params.webhook_url;
-    delete params.customer_type;
     custom[params.customer_type === 'COMPANY' ? 'company' : 'individual'] = {
       ...params,
     };
+    delete custom[params.customer_type === 'COMPANY' ? 'company' : 'individual'].customer_type;
     const adapter = this.getChannelAdapter(this.channel);
-
     return adapter.setCustomerInfo(custom);
   }
   async createWallet(param: any) {