Просмотр исходного кода

feat(app): 增加连接池大小配置

refactor(rcs-number): 添加wasted字段

refactor(rcs-number): 添加wasted接口

refactor(rcs-number): 添加wasted方法

refactor(sys-config): 添加use_backup配置
xiongzhu 1 год назад
Родитель
Сommit
462401e857

+ 1 - 0
src/app.module.ts

@@ -54,6 +54,7 @@ import { PayOrderModule } from './pay-order/pay-order.module'
             imports: [ConfigModule],
             inject: [ConfigService],
             useFactory: (config: ConfigService) => ({
+                poolSize: 50,
                 type: 'mysql',
                 host: config.get<string>('TYPEORM_HOST'),
                 port: config.get<number>('TYPEORM_PORT'),

+ 4 - 0
src/rcs-number/entities/rcs-number.entity.ts

@@ -105,4 +105,8 @@ export class RcsNumber {
     @Column({ default: 0 })
     @Index()
     stockFlag: number
+
+    @Column({ default: false })
+    @Index()
+    wasted: boolean
 }

+ 5 - 0
src/rcs-number/rcs-number.controller.ts

@@ -46,6 +46,11 @@ export class RcsNumberController {
         return await this.rcsNumberService.configured(Number(id))
     }
 
+    @Post('/:id/wasted')
+    async wasted(@Param('id') id: string) {
+        return await this.rcsNumberService.configured(Number(id))
+    }
+
     @Put('/:id/stockFlag/:flag')
     async stockFlag(@Param('id') id: string, @Param('flag') flag: string) {
         return await this.rcsNumberService.updateStockFlag(Number(id), Number(flag))

+ 4 - 0
src/rcs-number/rcs-number.service.ts

@@ -238,6 +238,10 @@ export class RcsNumberService {
         await this.rcsNumberRepository.update(id, { configured: true })
     }
 
+    async wasted(id: number): Promise<void> {
+        await this.rcsNumberRepository.update(id, { wasted: true })
+    }
+
     getNumberService(source: RcsNumberSource): GetNumberService {
         switch (source) {
             case RcsNumberSource.mwze167:

+ 8 - 0
src/sys-config/sys-config.service.ts

@@ -103,6 +103,14 @@ export class SysConfigService implements OnModuleInit {
                 remark: '充值比'
             })
         }
+        if (!(await this.sysConfigRepository.findOneBy({ name: 'use_backup' }))) {
+            await this.sysConfigRepository.save({
+                name: 'use_backup',
+                value: 'true',
+                type: SysConfigType.Boolean,
+                remark: '使用备份'
+            })
+        }
     }
 
     async findAll(req: PageRequest<SysConfig>) {