摄像头若干接口

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

@@ -1,12 +1,10 @@
 'use strict';
 
-async function get (ctx, next) {
+async function getCameraProject (ctx, next) {
    try {
       const models = ctx.fs.dc.models;
       const { limit, page, orderBy, orderDirection } = ctx.query
-      const { userId } = ctx.fs.api
-
-      const aa = await ctx.app.fs.axyRequest.get('structures/types', { query: { token: 'b11b7e6d-032e-4e3e-8973-931c2c5ada5a' } })
+      const { userId, token } = ctx.fs.api
 
       let findOption = {
          attributes: { exclude: ['delete', 'recycleTime',] },
@@ -32,6 +30,55 @@ async function get (ctx, next) {
       }
 
       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
@@ -42,6 +89,55 @@ async function get (ctx, next) {
    }
 }
 
+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 = {
-   get,
+   getCameraProject,
+   getCamera,
+   banned,
+   del,
 };

code/VideoAccess-VCMP/api/app/lib/controllers/nvr/index.js

@@ -46,10 +46,12 @@ async function edit (ctx, next) {
 async function get (ctx) {
    const models = ctx.fs.dc.models;
    try {
+      const { userId, token } = ctx.fs.api
       const { limit, page, orderBy, orderDirection } = ctx.query
       let findOption = {
          attributes: { exclude: ['delete'] },
          where: {
+            createUserId: userId,
             delete: false,
          },
          order: [
@@ -64,7 +66,9 @@ async function get (ctx) {
       }
 
       const res = await models.Nvr.findAll(findOption)
-        const total = await models.Nvr.count()
+      const total = await models.Nvr.count({
+         where: findOption.where
+      })
 
       ctx.status = 200;
       ctx.body = {
@@ -79,18 +83,39 @@ async function get (ctx) {
 }
 
 async function del (ctx, next) {
+   const transaction = await ctx.fs.dc.orm.transaction();
    try {
       const models = ctx.fs.dc.models;
+      const { userId, token } = ctx.fs.api
       const { nvrId } = ctx.params
 
       await models.Nvr.destroy({
          where: {
             id: nvrId
+         },
+         transaction
+      })
+
+      const cameraRes = await models.Camera.findAll({
+         where: {
+            nvrId
          }
       })
 
+      const cameraIds = cameraRes.map(c => c.id)
+
+      await models.Camera.destroy({
+         where: {
+            nvrId,
+         }
+      })
+
+      await ctx.app.fs.axyRequest.delete('vcmp/camera/project', { query: { token, cameraId: cameraIds.join(',') } })
+
+      await transaction.commit();
       ctx.status = 204;
    } catch (error) {
+      await transaction.rollback();
       ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
       ctx.status = 400;
       ctx.body = {}

code/VideoAccess-VCMP/api/app/lib/middlewares/paasRequest.js

@@ -1,21 +0,0 @@
-'use strict';
-const request = require('../service/request')
-
-function factory (app, opts) {
-   if (opts.pssaRequest) {
-      try {
-         for (let r of opts.pssaRequest) {
-            if (r.name && r.root) {
-               app.fs[r.name] = new request(r.root)
-            } else {
-               throw 'opts.pssaRequest 参数错误！'
-            }
-         }
-      } catch (error) {
-         console.error(error)
-         process.exit(-1);
-      }
-   }
-}
-
-module.exports = factory;

code/VideoAccess-VCMP/api/app/lib/models/vender.js

@@ -29,6 +29,12 @@ module.exports = dc => {
     comment: "",
     indexes: []
   });
+  
+  const Camera = dc.models.Camera;
+  Camera.belongsTo(Vender, { foreignKey: 'venderId', targetKey: 'id' });
+  Vender.hasMany(Camera, { foreignKey: 'venderId', sourceKey: 'id' });
+
   dc.models.Vender = Vender;
+
   return Vender;
 };

code/VideoAccess-VCMP/api/app/lib/routes/camera/index.js

@@ -3,6 +3,15 @@
 const camera = require('../../controllers/camera');
 
 module.exports = function (app, router, opts) {
-   app.fs.api.logAttr['GET/camera'] = { content: '获取摄像头列表', visible: false };
-   router.get('/camera', camera.get);
+   app.fs.api.logAttr['GET/camera/project'] = { content: '获取摄像头列表及项目绑定信息', visible: false };
+   router.get('/camera/project', camera.getCameraProject);
+
+   app.fs.api.logAttr['GET/camera'] = { content: '获取摄像头信息', visible: false };
+   router.get('/camera', camera.getCamera);
+
+   app.fs.api.logAttr['PUT/camera/banned'] = { content: '禁用摄像头', visible: false };
+   router.put('/camera/banned', camera.banned);
+
+   app.fs.api.logAttr['DEL/camera'] = { content: '删除摄像头', visible: false };
+   router.delete('/camera', camera.del);
 };

code/VideoAccess-VCMP/api/app/lib/service/paasRequest.js

@@ -20,27 +20,27 @@ class paasRequest {
         };
     }
 
-    get = (url, { query, header = {} }) => {
+    get = (url, { query = {}, header = {} } = {}) => {
         return new Promise((resolve, reject) => {
             request.get(this.#buildUrl(url)).set(header).query(query).end(this.#resultHandler(resolve, reject));
         })
     }
 
-    post = (url, data, query) => {
+    post = (url, { data = {}, query = {}, header = {} } = {}) => {
         return new Promise((resolve, reject) => {
-            request.post(this.#buildUrl(url, this.root)).set(header).query(query).send(data).end(this.#resultHandler(resolve, reject));
+            request.post(this.#buildUrl(url)).set(header).query(query).send(data).end(this.#resultHandler(resolve, reject));
         })
     }
 
-    put = (url, data) => {
+    put = (url, { data = {}, header = {}, query = {}, } = {}) => {
         return new Promise((resolve, reject) => {
-            request.put(this.#buildUrl(url)).set(setHeader()).send(data).end(this.#resultHandler(resolve, reject));
+            request.put(this.#buildUrl(url)).set(header).query(query).send(data).end(this.#resultHandler(resolve, reject));
         })
     }
 
-    delete = (url) => {
+    delete = (url, { header = {} } = {}) => {
         return new Promise((resolve, reject) => {
-            request.delete(this.#buildUrl(url)).set(setHeader()).end(this.#resultHandler(resolve, reject));
+            request.delete(this.#buildUrl(url)).set(header).end(this.#resultHandler(resolve, reject));
         })
     }
 }