优化log

app/controller/dbsync.js

@@ -47,7 +47,7 @@ const dbSync = async function (ctx) {
     not_delete_business_data: req.not_delete_business_data,
     use_cache: req.use_cache,
     domain,
-  })
+  })  
   ctx.body = ctx.ok({ location: res.location })
 }
 
@@ -97,6 +97,22 @@ const dbSyncTke = async function (ctx) {
     ctx.body = ctx.fail('获取mysql服务端口号失败')
     return
   }
+  // 数据库同步时新增行为记录
+  if (ctx.request.method === 'POST' && ctx.response.status === 200 ) {
+    const user = await ctx.redisGet(config.QA_TOKEN, ctx.request.header['x-token'])
+    if (user) {
+      const body = ctx.request.body
+      const data = {
+        namespace: body.namespace,
+        active: '同步' + body.mysqlName,
+        microservice_name: body.dbname,
+        user: user.cn,
+        user_mail: user.mail,
+        detail: body,
+      }
+      await StatisticsLog.saveLog(data);
+    }
+  }
 
   res = await jenkinsService.build_with_params('sync_database_schema', {
     depth: 1,

app/controller/k8s.js

@@ -19,7 +19,10 @@ const api = async function (ctx) {
         user_mail: user.mail,
         detail: body,
       }
-      await StatisticsLog.saveLog(data);
+      // 用户行为记录中过滤rabbitmq
+      if (!(data.active === 'service_details' && data.microservice_name === 'rabbitmq')) {
+        await StatisticsLog.saveLog(data);
+      }
     }
   }
 }