Selaa lähdekoodia

feat(rcs-number): 新增 cloud041 服务商支持

- 在 rcs-number.entity.ts 中添加 cloud041 作为新的 RcsNumberSource
- 在 rcs-number.service.ts 中实现 cloud041 的相关逻辑,包括初始化、余额查询等
- 更新 task.service.ts,增加 cloud041 的余额查询任务
wuyi 1 vuosi sitten
vanhempi
commit
7f91dcd36e

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

@@ -21,6 +21,7 @@ export enum RcsNumberSource {
     cloud033 = 'cloud033',
     cloud034 = 'cloud034',
     cloud037 = 'cloud037',
+    cloud041 = 'cloud041',
     xyz = 'xyz',
     hwyzm = 'hwyzm',
     cowboy = 'cowboy'

+ 13 - 5
src/rcs-number/rcs-number.service.ts

@@ -33,6 +33,7 @@ export class RcsNumberService {
     private cloud033: cloud214
     private cloud034: cloud214
     private cloud037: cloud214
+    private cloud041: cloud214
 
     constructor(
         @InjectRepository(RcsNumber)
@@ -59,6 +60,7 @@ export class RcsNumberService {
         this.cloud033 = new cloud214('100033', '1e40ca9795b1fc038db76512175d59b5', RcsNumberSource.cloud033)
         this.cloud034 = new cloud214('100034', 'ed7b3de69df3d6d9ddfaa7eb862272f5', RcsNumberSource.cloud034)
         this.cloud037 = new cloud214('100037', 'aaec6c21e54dc53b92e472df21a95bb7', RcsNumberSource.cloud037)
+        this.cloud041 = new cloud214('100041', '30e8538b0773820ade32df9e2307ffb7', RcsNumberSource.cloud041)
     }
 
     async findAll(req: PageRequest<RcsNumber>): Promise<Pagination<RcsNumber>> {
@@ -126,10 +128,10 @@ export class RcsNumberService {
             return (
                 (store ? storeNumberChannels.includes(channel.source.toString()) : true) &&
                 (channel.countryConfig.find(
-                    (config) =>
-                        config.countryCode.toLowerCase() === operatorConfig.country ||
-                        config.countryCode.toUpperCase() === operatorConfig.country
-                )?.enabled ||
+                        (config) =>
+                            config.countryCode.toLowerCase() === operatorConfig.country ||
+                            config.countryCode.toUpperCase() === operatorConfig.country
+                    )?.enabled ||
                     false)
             )
         })
@@ -164,6 +166,9 @@ export class RcsNumberService {
             case RcsNumberSource.cloud037:
                 numberService = this.cloud037
                 break
+            case RcsNumberSource.cloud041:
+                numberService = this.cloud041
+                break
             case RcsNumberSource.xyz:
                 numberService = this.xyz
                 break
@@ -273,6 +278,8 @@ export class RcsNumberService {
                 return this.cloud034
             case RcsNumberSource.cloud037:
                 return this.cloud037
+            case RcsNumberSource.cloud041:
+                return this.cloud041
             case RcsNumberSource.xyz:
                 return this.xyz
             case RcsNumberSource.hwyzm:
@@ -324,7 +331,8 @@ export class RcsNumberService {
                     }
                     await this.rcsNumberRepository.update(number.id, update)
                 }
-            } catch (e) {}
+            } catch (e) {
+            }
         })
     }
 

+ 14 - 0
src/task/task.service.ts

@@ -665,6 +665,7 @@ export class TaskService implements OnModuleInit {
             cloud033: 0,
             cloud034: 0,
             cloud037: 0,
+            cloud041: 0,
             xyz: 0,
             cowboy: 0
         }
@@ -769,6 +770,19 @@ export class TaskService implements OnModuleInit {
                         res.cloud037 = cloud037Res.data.data.integral
                     }
                 } catch (e) {}
+            })(),
+            (async () => {
+                try {
+                    const cloud041Res = await cloudInstance.get('userBalance', {
+                        params: {
+                            userid: '100041',
+                            token: '30e8538b0773820ade32df9e2307ffb7'
+                        }
+                    })
+                    if (cloud041Res.data.code === '1001') {
+                        res.cloud041 = cloud041Res.data.data.integral
+                    }
+                } catch (e) {}
             })()
         ])
         return res