FS-IOT/code/VideoAccess-VCMP/api/app/lib/controllers/camera/index.js

'use strict';

async function getCameraProject (ctx, next) {
   try {
      const models = ctx.fs.dc.models;
      const { limit, page, orderBy, orderDirection, keyword, abilityId, type, venderId } = ctx.query
      const { userId, token } = ctx.fs.api

      let findOption = {
         attributes: { exclude: ['delete', 'recycleTime',] },
         where: {
            createUserId: userId,
            recycleTime: null,
            delete: false
         },
         order: [
            [orderBy || 'id', orderDirection || 'DESC']
         ],
         include: [{
            model: models.CameraAbility
         }, {
            model: models.CameraKind
         }]
      }
      if (limit) {
         findOption.limit = limit
      }
      if (page && limit) {
         findOption.offset = page * limit
      }
      if (keyword) {
         findOption.where.$or = [{
            name: { $like: `%${keyword}%` }
         }, {
            serialNo: { $like: `%${keyword}%` }
         }]
      }
      if (type) {
         findOption.where.type = type
      }
      if (abilityId) {
         findOption.where.abilityId = abilityId
      }
      if (venderId) {
         findOption.where.venderId = venderId
      }

      const cameraRes = await models.Camera.findAll(findOption)
      const total = await models.Camera.count({
         where: findOption.where
      })

      // 查在安心云绑定的数据
      const cameraIds = cameraRes.map(c => {
         return c.dataValues.id
      })
      const axbindCameraRes = await ctx.app.fs.axyRequest.get('vcmp/camera/project', { query: { token, cameraId: cameraIds.join(',') } })

      for (let { dataValues: camera } of cameraRes) {
         const corBindCamera = axbindCameraRes.find(b => b.cameraId == camera.id)
         if (corBindCamera) {
            camera.station = corBindCamera.stations
         } else {
            camera.station = []
         }
      }

      ctx.status = 200;
      ctx.body = {
         total: total,
         data: cameraRes
      }
   } catch (error) {
      ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
      ctx.status = 400;
      ctx.body = {}
   }
}

async function getCamera (ctx) {
   try {
      const { models } = ctx.fs.dc;
      const { cameraId } = ctx.query

      const cameraRes = await models.Camera.findAll({
         attributes: { exclude: ['delete', 'recycleTime',] },
         where: {
            id: { $in: cameraId.split(',') }
         },
         include: [{
            model: models.CameraAbility
         }, {
            model: models.CameraKind
         }, {
            model: models.Vender
         }]
      })

      ctx.status = 200;
      ctx.body = cameraRes
   } catch (error) {
      ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
      ctx.status = 400;
      ctx.body = {}
   }
}

async function banned (ctx) {
   try {
      const { models } = ctx.fs.dc;
      const data = ctx.request.body;

      // 向视频服务发送通知

      // 库记录
      await models.Camera.update({
         forbidden: data.forbidden
      }, {
         where: {
            id: data.cameraId
         }
      })

      ctx.status = 204;
   } catch (error) {
      ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
      ctx.status = 400;
      ctx.body = {}
   }
}

async function del (ctx) {
   try {
      const { models } = ctx.fs.dc;
      const { cameraId } = ctx.query
      const { token } = ctx.fs.api

      await models.cameraId.destroy({
         where: {
            id: cameraId
         }
      })

      await ctx.app.fs.axyRequest.delete('vcmp/camera/project', { query: { token, cameraId: cameraId.join(',') } })

      ctx.status = 204;
   } catch (error) {
      ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
      ctx.status = 400;
      ctx.body = {}
   }
}

module.exports = {
   getCameraProject,
   getCamera,
   banned,
   del,
};