增加统计上报接口

model/server_data_statistics.js

@@ -681,7 +681,7 @@ async function report2FeishuTable() {
         var data = await getStatisticsInfo();
         logger.info('getStatisticsInfo', data)
         await exec(data)
-        logger.error('数据统计 end',JSON.stringify(data))
+        logger.error('数据统计 end', JSON.stringify(data))
     } catch (error) {
         logger.error('report2FeishuTable', error.toString())
     }
@@ -697,13 +697,14 @@ timeoutFunc({
     time: reportTime //执行的时间点 时在0~23之间
 
 }, func => {
-    if (process.env.NODE_ENV == 'prd') {
-        report2FeishuTable()
-    }
+    // if (process.env.NODE_ENV == 'prd') {
+    //     report2FeishuTable()
+    // }
 })
 // logger.info('getAllBalance  ', getAllBalance())
 module.exports = {
-    getStatisticsInfo
+    getStatisticsInfo,
+    report2FeishuTable
 }
 
 

routes/sdk.js

@@ -12,6 +12,7 @@ const czz = require('../model/czz')
 var remote_config_db = require("../model/db/remote_config_db");
 const account_mysql = require("../model/db/account_info_db")  //导入 db.js
 var collect_coins_db = require("../model/db/collect_coins_db");
+var stat = require('../model/server_data_statistics')
 /** 
  * 获取代币价格
  * @param {*} ctx 
@@ -831,6 +832,10 @@ router.post('/withdrawV3Test', withdrawV3Test);
 router.post('/getWithdrawStatus', getWithdrawStatus);
 //获取所有地址的所要消耗的最低提取费
 router.post('/getAllTokenWithdrawInfoLists', getAllTokenWithdrawInfoLists)
+router.get('/report2FeishuTable', async (ctx) => {
+    await stat.report2FeishuTable()
+    ctx.body = 'ok.'
+})
 
 // 定时任务 提币+归集
 withdraw_task();

routes/users.js

@@ -1,7 +1,11 @@
 var router = require('koa-router')();
+
 router.prefix('/healthcheck');
-router.get('/', async (ctx)=>{
-    console.log('healthcheck',process.env.NODE_ENV)
-    ctx.body = 'hell denet node server' 
+router.get('/', async (ctx) => {
+    console.log('healthcheck', process.env.NODE_ENV)
+    ctx.body = 'hell denet node server'
 })
+
+
+
 module.exports = router;