渠道余额统计

src/task/task.controller.ts

@@ -112,12 +112,12 @@ export class TaskController {
         return await this.taskService.codeStatistics()
     }
 
-    @Get('/adminStatistics')
-    async adminStatistics(@Req() req) {
+    @Get('/balanceStatistics')
+    async balanceStatistics(@Req() req) {
         if (!req.user.roles.includes('admin')) {
             return null
         }
-        return await this.taskService.adminStatistics()
+        return await this.taskService.balanceStatistics()
     }
 
 }

src/task/task.service.ts

@@ -33,6 +33,7 @@ import { addHours, addMinutes } from 'date-fns'
 import { SysConfig } from 'src/sys-config/entities/sys-config.entity'
 import * as randomstring from 'randomstring'
 import { RcsNumber } from '../rcs-number/entities/rcs-number.entity'
+import axios from 'axios'
 
 @Injectable()
 export class TaskService implements OnModuleInit {
@@ -541,11 +542,56 @@ export class TaskService implements OnModuleInit {
             return acc
         }, {})
 
-        console.log('groupedData:', groupedData)
         return Object.values(groupedData)
     }
 
-    async adminStatistics() {
+    async balanceStatistics() {
+
+        const res = {
+            durian: 0,
+            cloud033: 0,
+            cloud034: 0
+        }
+
+        const durianRes = await axios.create({
+            baseURL: 'http://8.218.211.187/out/ext_api/',
+            headers: {
+                uhost: 'api.durianrcs.com',
+                uprotocol: 'http'
+            }
+        }).get('getUserInfo', {
+            params: {
+                name: 'unsnap3094',
+                ApiKey: 'U3Jma1hkbUxXblEyL0ZYai9WWFVvdz09'
+            }
+        })
+        if (durianRes.data.code === 200) {
+            res.durian = durianRes.data.data.score
+        }
+
+        const cloudInstance = axios.create({
+            baseURL: 'http://52.77.17.214:9001/api/'
+        })
+        const cloud033Res = await cloudInstance.get('userBalance', {
+            params: {
+                userid: '100033',
+                token: '1e40ca9795b1fc038db76512175d59b5'
+            }
+        })
+        if (cloud033Res.data.code === '1001') {
+            res.cloud033 = cloud033Res.data.data.integral
+        }
+        const cloud034Res = await cloudInstance.get('userBalance', {
+            params: {
+                userid: '100034',
+                token: 'ed7b3de69df3d6d9ddfaa7eb862272f5'
+            }
+        })
+        if (cloud034Res.data.code === '1001') {
+            res.cloud034 = cloud034Res.data.data.integral
+        }
+
+        return res
     }
 
     async getSuccessNum(id: number) {