feat:fix bugs（DeviceId改deviceId）

api/app/lib/controllers/analysis/network.js

@@ -309,7 +309,7 @@ async function findDevicesCardStatus (ctx, next) {
       if (deviceIds && deviceIds.length) {
          const id = `(${deviceIds.map(id => `'${id}'`).join(',')})`
          rlst = await clickHouse.dataAlarm.query(`
-         SELECT cs.DeviceId,cs.Status,MAX(cs.Time) 
+         SELECT cs.DeviceId as deviceId,cs.Status as status,MAX(cs.Time) 
          FROM alarm.CardStatus cs 
          WHERE cs.DeviceId in ${id}
          GROUP BY cs.DeviceId,cs.Status`).toPromise()
@@ -421,7 +421,36 @@ async function findAlarmsDevice(ctx, next) {
        ctx.body = rslt;
    }
 }
-
+//查询智能
+async function createInvoke (ctx, next) {
+   let error = { name: 'CreateError', message: '命令下发失败' };
+   const data = ctx.request.body
+   let rslt = null, code = null, issuccess = false, text = null;
+   if (data) {
+       try {
+           const models = ctx.fs.dc.models;
+           let iotaThingId = data.thingId;
+           let structure = await models.Structure.findOne({ where: { iotaThingId } });
+           if (structure) {
+               const dataToIota = data;
+               let iotaResponse = await ctx.app.fs.iotRequest.post(`/capabilities/invoke`, dataToIota)
+               rslt = JSON.parse(iotaResponse)
+               error = null;
+           } else {
+               error = { name: 'NotFound', message: `不存在{iotaThingId=${iotaThingId}}的结构物` };
+           }
+       } catch (err) {
+           ctx.fs.logger.error(`path: ${ctx.path}, error: ${err}`);
+       }
+   }
+   if (error) {
+       ctx.status = 400;
+       ctx.body = error;
+   } else {
+       ctx.status = 200;
+       ctx.body = rslt;
+   }
+};
 
 
 
@@ -435,5 +464,6 @@ module.exports = {
    findAlarmsDevices,
    findDevicesCardStatus,
    getDevicesLlinkStatus,
-   findAlarmsDevice
+   findAlarmsDevice,
+   createInvoke
 }