查询数据告警详情

api/app/lib/controllers/alarm/app.js

@@ -235,10 +235,12 @@ async function apiErrorList (ctx) {
       }
 
       if (errType) {
-         if (errType = 'element') {
+         if (errType == 'element') {
+            findOption.where.screenshot = { $ne: null }
+         } else if (errType == 'timeout') {
+
+         } else if (errType == 'apiError') {
             findOption.where.screenshot = null
-         } else {
-            findOption.where.statusCode = errType
          }
       }
       if (confirmState) {

api/app/lib/controllers/alarm/data.js

@@ -6,15 +6,16 @@ async function list (ctx) {
       const { clickHouse } = ctx.app.fs
       const { utils: { judgeSuper, anxinStrucIdRange } } = ctx.app.fs
       const { database: anxinyun } = clickHouse.anxinyun.opts.config
+      const { pepProjectId } = ctx.query
 
       const isSuper = judgeSuper(ctx)
       let anxinStrucIds = null
-      if (!isSuper) {
-         anxinStrucIds = await anxinStrucIdRange(ctx)
+      if (!isSuper || pepProjectId) {
+         anxinStrucIds = await anxinStrucIdRange({ ctx, pepProjectId })
       }
       const alarmRes = await clickHouse.dataAlarm.query(`
          SELECT 
-            AlarmId, SourceName, name
+            AlarmId, SourceName, name AS StructureName, StructureId
          FROM 
             alarms 
          LEFT JOIN ${anxinyun}.t_structure 
@@ -33,6 +34,28 @@ async function list (ctx) {
    }
 }
 
+async function detail (ctx) {
+   try {
+      const { models } = ctx.fs.dc;
+      const { clickHouse } = ctx.app.fs
+      const { alarmId } = ctx.query
+
+      const detailRes = await clickHouse.dataAlarm.query(`
+         SELECT * FROM alarm_details WHERE AlarmId = '${alarmId}' ORDER BY Time ASC
+      `).toPromise()
+
+      ctx.status = 200;
+      ctx.body = detailRes
+   } catch (error) {
+      ctx.fs.logger.error(`path: ${ctx.path}, error: error`);
+      ctx.status = 400;
+      ctx.body = {
+         message: typeof error == 'string' ? error : undefined
+      }
+   }
+}
+
 module.exports = {
-   list
+   list,
+   detail
 };

api/app/lib/routes/alarm/index.js

@@ -28,4 +28,7 @@ module.exports = function (app, router, opts) {
    // 数据告警
    app.fs.api.logAttr['GET/alarm/data/list'] = { content: '查询数据告警列表', visible: true };
    router.get('/alarm/data/list', dataAlarm.list);
+
+   app.fs.api.logAttr['GET/alarm/data/detail'] = { content: '查询数据告警详情', visible: true };
+   router.get('/alarm/data/detail', dataAlarm.detail);
 };

api/app/lib/utils/dataRange.js

@@ -14,15 +14,16 @@ module.exports = function (app, opts) {
       }
    }
 
-   async function anxinStrucIdRange (ctx) {
+   async function anxinStrucIdRange ({ ctx, pepProjectId }) {
       try {
          const { models } = ctx.fs.dc;
          const { userInfo = {} } = ctx.fs.api || {};
          const { correlationProject = [] } = userInfo
 
+         // TODO 这儿也许需要判断传进来的 pepProjectId 在不在当前用户的关注范围内
          const bindRes = await models.ProjectCorrelation.findAll({
             where: {
-               id: { $in: correlationProject },
+               id: { $in: pepProjectId ? [pepProjectId] : correlationProject },
                del: false
             }
          })