29605 【中心级】一张图全景监控>设备管理>物联统计，站端视角，监测信号和今日监测数据未根据所选换流站过滤

amos-boot-module/amos-boot-module-api/amos-boot-module-equip-api/src/main/java/com/yeejoin/equipmanage/common/entity/vo/EquipmentSpecificVo.java

@@ -44,4 +44,7 @@ public class EquipmentSpecificVo implements Serializable  {
 
     @ApiModelProperty(value = "装备分类code")
     private String ecode;
+
+    @ApiModelProperty
+    private String bizOrgCode;
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/SystemStatisticController.java

@@ -107,7 +107,7 @@ public class SystemStatisticController extends AbstractBaseController {
         // 获取当天结束时间（23点59分59秒）
         Date endOfDay = DateUtil.endOfDay(new Date());
         String endOfDayStr = DateUtil.formatDateTime(endOfDay);
-        ResponseModel<Map<String, Object>> mapResponseModel = iotFeign.queryIotDataNum(startOfDayStr, endOfDayStr);
+        ResponseModel<Map<String, Object>> mapResponseModel = iotFeign.queryIotDataNum(startOfDayStr, endOfDayStr, bizOrgCode);
         if (200 == mapResponseModel.getStatus() ) {
             Map<String, Object> result = mapResponseModel.getResult();
             Object totalNum = result.get("totalNum");

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/fegin/IotFeign.java

@@ -84,7 +84,8 @@ public interface IotFeign {
 
     @RequestMapping(value = "v1/livedata/queryIotDataNum", method = RequestMethod.GET, consumes = "application/json")
     ResponseModel<Map<String ,Object>> queryIotDataNum(@RequestParam("timeStart") String timeStart,
-                                                       @RequestParam("timeEnd") String timeEnd);
+                                                       @RequestParam("timeEnd") String timeEnd,
+                                                       @RequestParam(value = "bizOrgCode", required = false) String bizOrgCode);
 
     @RequestMapping(value = "v1/livedata/queryIotDataNumByIndex", method = RequestMethod.GET, consumes = "application/json")
     ResponseModel<Map<String ,Integer>> queryIotDataNumByIndex(@RequestParam(value = "timeStart") String timeStart,

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/MqttReceiveServiceImpl.java

@@ -399,11 +399,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
         }
         //给 iot服务 推送消息 插数据到 influxdb
         if (isSendIot) {
+            EquipmentSpecificVo equipmentSpecificVo = eqIotCodeList.get(0);
             JSONObject messageObj = JSON.parseObject(message);
             if (!messageObj.containsKey("traceId")) {
                 String traceId = System.currentTimeMillis() + "";
                 messageObj.put("traceId", traceId);
             }
+            messageObj.put("bizOrgCode", equipmentSpecificVo.getBizOrgCode());
             String messageTraceId = JSON.toJSONString(messageObj);
             mqttSendGateway.sendToMqtt("influxdb/" + topic.substring(0, endIndex), messageTraceId);
         }

amos-boot-system-equip/src/main/resources/mapper/EquipmentSpecificMapper.xml

@@ -211,7 +211,8 @@
 						`wes`.`system_id`
 					)) AS `code`,
                   wes.system_id systemId,
-         ( SELECT GROUP_CONCAT(fs.name) FROM f_fire_fighting_system fs WHERE `wes`.`system_id`  like  CONCAT("%",fs.id,'%') )  AS systemName
+         ( SELECT GROUP_CONCAT(fs.name) FROM f_fire_fighting_system fs WHERE `wes`.`system_id`  like  CONCAT("%",fs.id,'%') )  AS systemName,
+         biz_org_code as bizOrgCode
 
          FROM
 					wl_equipment_specific AS wes
@@ -224,7 +225,8 @@
                         'car' AS type,
                         wc.car_num AS `code`,
                          '' systemId,
-                         '' systemName
+                         '' systemName,
+                         biz_org_code as bizOrgCode
 					FROM
 						wl_car wc
 				 where TRIM(wc.iot_code) != '' AND wc.iot_code IS NOT NULL

amos-boot-system-equip/src/main/resources/mapper/FireFightingSystemMapper.xml

@@ -7021,7 +7021,18 @@
             *
         FROM
             (
-                (SELECT count( 1 ) AS indexNum FROM wl_equipment_specific_index a LEFT JOIN wl_equipment_index b ON a.equipment_index_id = b.id WHERE b.is_iot = 1) AS indexNum,
+                (SELECT count( 1 ) AS indexNum FROM wl_equipment_specific_index a LEFT JOIN wl_equipment_index b ON a.equipment_index_id = b.id WHERE b.is_iot = 1
+                and equipment_specific_id IN
+                   (SELECT
+                        id
+                    FROM
+                        wl_equipment_specific
+                    <where>
+                        <if test="bizOrgCode!=null and bizOrgCode!=''">
+                            AND biz_org_code LIKE CONCAT(#{bizOrgCode},'%')
+                        </if>
+                    </where>)
+                ) AS indexNum,
                 (SELECT count( 1 ) AS equipNum FROM wl_equipment_specific es LEFT JOIN wl_equipment e ON e.`code` = es.equipment_code WHERE e.is_iot = 1
                     <if test="bizOrgCode!=null and bizOrgCode!=''">
                         AND es.biz_org_code LIKE CONCAT(#{bizOrgCode},'%')