statistic

app/controller/k8s.js

-
-
 const Router = require('koa-router');
-
+const bodyParser = require('koa-bodyparser')
 const config = require('../../src');
+const { StatisticsLog } = require('../service/mongoService');
 
 const api = async function (ctx) {
   await ctx.pipe({
     uri: config.api.tke_api + ctx.url.replace('/k8s', ''),
   })
+  if (ctx.request.method === 'POST' && ctx.response.status === 200 && ctx.request.url.indexOf('/service') !== -1) {
+    const user = await ctx.redisGet(config.QA_TOKEN, ctx.request.header['x-token'])
+    const body = ctx.request.body
+    const data = {
+      namespace: body.namespace,
+      active: ctx.request.url.replace('/k8s/', '').replace('/', '_'),
+      microservice_name: body.serviceName,
+      user: user && user.cn,
+      user_mail: user && user.mail,
+      detail: body,
+    }
+    await StatisticsLog.saveLog(data);
+  }
 }
 const router = new Router();
+
 router
+  .use(bodyParser())
   .get('/*', api)
   .post('/*', api)
 module.exports = router

app/model/mongo/qa_api/ProConfig.js

@@ -42,7 +42,7 @@ const schema = new Schema({
 })
 
 schema.statics.getActiveProjectsHostName = function () {
-  return this.find({ des: { $ne: '海外' }, is_active: 1 }).select(['host_name', 'project_name', 'type']).lean().then((res) => {
+  return this.find({ des: { $ne: '海外' } }).select(['host_name', 'project_name', 'type']).lean().then((res) => {
     const reg = /^([\w-\.]+)\.[\w-]+\.[a-z]+$/
     // 转为对象形式
     const o = res.reduce((prev, next) => {