新用户楼宇筛选

dongjian-dashboard-back-dao/src/main/java/com/dongjian/dashboard/back/dao/ex/BasicBuildingMapperExt.java

@@ -13,5 +13,5 @@ public interface BasicBuildingMapperExt extends BasicBuildingMapper {
 
     List<BuildingPageVO> getListPage(BuildingSearchParams pageSearchParam);
 
-    List<Long> getBuildingIdListByCompanyId(@Param("companyId") Long companyId);
+    List<Long> getBuildingIdListByCompanyId(@Param("companyIdList") List<Long> companyIdList);
 }

dongjian-dashboard-back-dao/src/main/resources/mappers/ex/BasicBuildingMapperExt.xml

@@ -40,7 +40,9 @@
             building_id
         FROM
             basic_building
-        WHERE company_id = #{companyId} AND flag = 0
+        WHERE flag = 0
+        AND company_id IN <foreach collection="companyIdList" item="item" open="(" separator="," close=")">#{item}</foreach>
+
         ORDER BY building_id
     </select>
     

dongjian-dashboard-back-dao/src/main/resources/mappers/ex/DeviceInfoMapperExt.xml

@@ -39,6 +39,15 @@
     </sql>
 
     <sql id="deviceDataCommonWhere">
+        <if test="buildingId != null">
+            and basic_building.building_id = #{buildingId}
+        </if>
+        <if test="bindBuildingIdList != null">
+            and basic_building.building_id in
+            <foreach collection="bindBuildingIdList" item="item" open="(" separator="," close=")">
+                #{item}
+            </foreach>
+        </if>
         <if test="keyword != null and keyword != ''">
             and device_info.monitoring_point_name LIKE CONCAT('%',#{keyword},'%')
         </if>
@@ -112,9 +121,6 @@
         <include refid="deviceDataFromAndJoin"/>
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             <include refid="deviceDataCommonWhere"/>
         </where>
         <include refid="drrOrder"/>
@@ -131,9 +137,6 @@
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         left join dashboard_device_group_relation ddgr on ddgr.device_info_id = device_info.id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             and ddgr.device_group_id = #{deviceGroupId}
             <include refid="deviceDataCommonWhere"/>
         </where>
@@ -149,9 +152,6 @@
         <include refid="deviceDataFromAndJoin"/>
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             <include refid="deviceDataCommonWhere"/>
         </where>
         <include refid="drrOrder"/>
@@ -168,9 +168,6 @@
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         left join dashboard_device_group_relation ddgr on ddgr.device_info_id = device_info.id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             and ddgr.device_group_id = #{deviceGroupId}
             <include refid="deviceDataCommonWhere"/>
         </where>
@@ -228,9 +225,6 @@
         <include refid="deviceDataFromAndJoin"/>
         left join ba_status_statistics bss on bss.device_info_id = device_info.id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             <include refid="deviceDataCommonWhere"/>
         </where>
         <include refid="BaStatusOrder"/>
@@ -251,9 +245,6 @@
         left join dashboard_device_group_relation ddgr on ddgr.device_info_id = device_info.id
         left join ba_status_statistics bss on bss.device_info_id = device_info.id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             and ddgr.device_group_id = #{deviceGroupId}
             <include refid="deviceDataCommonWhere"/>
         </where>
@@ -343,9 +334,6 @@
         <where>
             and device_info.flag = 0 and basic_monitoring_asset.flag != 1
             and basic_space.flag != 1 and basic_floor.flag != 1 and basic_building.flag != 1
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             <include refid="deviceDataCommonWhere"/>
             <choose>
                 <when test="searchType == 1">
@@ -407,9 +395,6 @@
         <where>
             and device_info.flag = 0 and basic_monitoring_asset.flag != 1
             and basic_space.flag != 1 and basic_floor.flag != 1 and basic_building.flag != 1
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             and ddgr.device_group_id = #{deviceGroupId}
             <include refid="deviceDataCommonWhere"/>
             <choose>
@@ -438,9 +423,6 @@
         <include refid="deviceDataFromAndJoin"/>
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             <include refid="deviceDataCommonWhere"/>
         </where>
         <include refid="drrOrder"/>
@@ -457,9 +439,6 @@
         left join device_rawdata_realtime drr on drr.device_id = device_info.device_id
         left join dashboard_device_group_relation ddgr on ddgr.device_info_id = device_info.id
         <where>
-            <if test="buildingId != null">
-                and basic_building.building_id = #{buildingId}
-            </if>
             and ddgr.device_group_id = #{deviceGroupId}
             <include refid="deviceDataCommonWhere"/>
         </where>

dongjian-dashboard-back-model/src/main/java/com/dongjian/dashboard/back/dto/data/DataSearchParam.java

@@ -37,4 +37,7 @@ public class DataSearchParam extends BaseSearchParams {
 	@Schema(description = "关键词",example = "det")
 	private String keyword;
 
+	@Schema(description = "绑定的楼宇ID",example = "[]", hidden = true)
+	private List<Long> bindBuildingIdList;
+
 }

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/common/CommonOpt.java

@@ -256,10 +256,10 @@ public class CommonOpt {
 //			}
 //		}
 //	}
-	public List<Long> getBindBuildingIdList(Long userId, Long companyId) {
+	public List<Long> getBindBuildingIdList(Long userId, List<Long> companyIdList) {
 		Integer levelManager = basicUserMapperExt.checkLevelManager(userId);
 		if (levelManager > 0) {
-			return basicBuildingMapperExt.getBuildingIdListByCompanyId(companyId);
+			return basicBuildingMapperExt.getBuildingIdListByCompanyId(companyIdList);
 		} else {
 			List<Long> bindedBuildingList = levelMapperExt.getBoundBuilding(userId);
 			if (CollectionUtils.isEmpty(bindedBuildingList)) {

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataAccumulateServiceImpl.java

@@ -75,6 +75,8 @@ public class DeviceDataAccumulateServiceImpl implements DeviceDataAccumulateServ
 			pageSearchParam.setCompanyIdList(commonOpt.filterCompanyIds(companyId, pageSearchParam.getCompanyIds()));
 		}
 
+		pageSearchParam.setBindBuildingIdList(commonOpt.getBindBuildingIdList(pageSearchParam.getUserId(), pageSearchParam.getCompanyIdList()));
+
 		PageHelper.startPage(pageSearchParam.getPageNum() == null ? 1 : pageSearchParam.getPageNum(), pageSearchParam.getPageSize() == null ? 20 : pageSearchParam.getPageSize());
 		return new PageInfo<>(handleDeviceAccumulateData(pageSearchParam));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataAlarmServiceImpl.java

@@ -72,6 +72,8 @@ public class DeviceDataAlarmServiceImpl implements DeviceDataAlarmService {
 			pageSearchParam.setCompanyIdList(commonOpt.filterCompanyIds(companyId, pageSearchParam.getCompanyIds()));
 		}
 
+		pageSearchParam.setBindBuildingIdList(commonOpt.getBindBuildingIdList(pageSearchParam.getUserId(), pageSearchParam.getCompanyIdList()));
+
 		PageHelper.startPage(pageSearchParam.getPageNum() == null ? 1 : pageSearchParam.getPageNum(), pageSearchParam.getPageSize() == null ? 20 : pageSearchParam.getPageSize());
 		return new PageInfo<>(handleDeviceAlarmData(languageType, pageSearchParam));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataBaStatusServiceImpl.java

@@ -83,6 +83,8 @@ public class DeviceDataBaStatusServiceImpl implements DeviceDataBaStatusService
 			pageSearchParam.setCompanyIdList(commonOpt.filterCompanyIds(companyId, pageSearchParam.getCompanyIds()));
 		}
 
+		pageSearchParam.setBindBuildingIdList(commonOpt.getBindBuildingIdList(pageSearchParam.getUserId(), pageSearchParam.getCompanyIdList()));
+
 		PageHelper.startPage(pageSearchParam.getPageNum() == null ? 1 : pageSearchParam.getPageNum(), pageSearchParam.getPageSize() == null ? 20 : pageSearchParam.getPageSize());
 		return new PageInfo<>(handleDeviceBaStatusData(pageSearchParam));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataMeasureServiceImpl.java

@@ -86,6 +86,8 @@ public class DeviceDataMeasureServiceImpl implements DeviceDataMeasureService {
 			pageSearchParam.setCompanyIdList(commonOpt.filterCompanyIds(companyId, pageSearchParam.getCompanyIds()));
 		}
 
+		pageSearchParam.setBindBuildingIdList(commonOpt.getBindBuildingIdList(pageSearchParam.getUserId(), pageSearchParam.getCompanyIdList()));
+
 		PageHelper.startPage(pageSearchParam.getPageNum() == null ? 1 : pageSearchParam.getPageNum(), pageSearchParam.getPageSize() == null ? 20 : pageSearchParam.getPageSize());
 		return new PageInfo<>(handleDeviceMeasureData(pageSearchParam));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/DeviceDataTrendLogServiceImpl.java

@@ -71,6 +71,8 @@ public class DeviceDataTrendLogServiceImpl implements DeviceDataTrendLogService
 			pageSearchParam.setCompanyIdList(commonOpt.filterCompanyIds(companyId, pageSearchParam.getCompanyIds()));
 		}
 
+		pageSearchParam.setBindBuildingIdList(commonOpt.getBindBuildingIdList(pageSearchParam.getUserId(), pageSearchParam.getCompanyIdList()));
+
 		PageHelper.startPage(pageSearchParam.getPageNum() == null ? 1 : pageSearchParam.getPageNum(), pageSearchParam.getPageSize() == null ? 20 : pageSearchParam.getPageSize());
 		return new PageInfo<>(handleDeviceAccumulateData(pageSearchParam));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/FavoritedDeviceServiceImpl.java

@@ -98,10 +98,10 @@ public class FavoritedDeviceServiceImpl implements FavoritedDeviceService {
 		}
 
 		// 查询并构建 deviceId -> Data 映射
-		Map<String, DeviceAccumulateData> accumulateDataMap = buildAccumulateDataMap(companyId, accumulateDeviceIds);
-		Map<String, DeviceMeasureData> measureDataMap = buildMeasureDataMap(companyId, measureDeviceIds);
-		Map<String, DeviceBaStatusData> statusDataMap = buildStatusDataMap(companyId, statusDeviceIds);
-		Map<String, DeviceAlarmData> alarmDataMap = buildAlarmDataMap(companyId, languageType, alarmDeviceIds);
+		Map<String, DeviceAccumulateData> accumulateDataMap = buildAccumulateDataMap(userId, companyId, accumulateDeviceIds);
+		Map<String, DeviceMeasureData> measureDataMap = buildMeasureDataMap(userId, companyId, measureDeviceIds);
+		Map<String, DeviceBaStatusData> statusDataMap = buildStatusDataMap(userId, companyId, statusDeviceIds);
+		Map<String, DeviceAlarmData> alarmDataMap = buildAlarmDataMap(userId, companyId, languageType, alarmDeviceIds);
 
 		// 按收藏顺序生成结果
 		for (FavoritedDeviceVO vo : favoritedDeviceVOList) {
@@ -139,43 +139,47 @@ public class FavoritedDeviceServiceImpl implements FavoritedDeviceService {
 		return resultPageInfo;
 	}
 
-	private Map<String, DeviceAlarmData> buildAlarmDataMap(Long companyId, Integer languageType, List<String> deviceIds) {
+	private Map<String, DeviceAlarmData> buildAlarmDataMap(Long userId, Long companyId, Integer languageType, List<String> deviceIds) {
 		if (CollectionUtils.isEmpty(deviceIds)) return Collections.emptyMap();
 
 		AlarmDataSearchParam param = new AlarmDataSearchParam();
 		param.setDeviceIdList(deviceIds);
 		param.setCompanyIdList(List.of(companyId));
 		param.setSearchType(4);
+		param.setBindBuildingIdList(commonOpt.getBindBuildingIdList(userId, param.getCompanyIdList()));
 		return deviceDataAlarmService.handleDeviceAlarmData(languageType, param).stream()
 				.collect(Collectors.toMap(DeviceAlarmData::getDeviceId, Function.identity(), (existing, replacement) -> replacement));
 	}
 
-	private Map<String, DeviceAccumulateData> buildAccumulateDataMap(Long companyId, List<String> deviceIds) {
+	private Map<String, DeviceAccumulateData> buildAccumulateDataMap(Long userId, Long companyId, List<String> deviceIds) {
 		if (CollectionUtils.isEmpty(deviceIds)) return Collections.emptyMap();
 
 		AccumulateDataSearchParam param = new AccumulateDataSearchParam();
 		param.setDeviceIdList(deviceIds);
 		param.setCompanyIdList(List.of(companyId));
+		param.setBindBuildingIdList(commonOpt.getBindBuildingIdList(userId, param.getCompanyIdList()));
 		return deviceDataAccumulateService.handleDeviceAccumulateData(param).stream()
 				.collect(Collectors.toMap(DeviceAccumulateData::getDeviceId, Function.identity(), (existing, replacement) -> replacement));
 	}
 
-	private Map<String, DeviceMeasureData> buildMeasureDataMap(Long companyId, List<String> deviceIds) {
+	private Map<String, DeviceMeasureData> buildMeasureDataMap(Long userId, Long companyId, List<String> deviceIds) {
 		if (CollectionUtils.isEmpty(deviceIds)) return Collections.emptyMap();
 
 		MeasureDataSearchParam param = new MeasureDataSearchParam();
 		param.setDeviceIdList(deviceIds);
 		param.setCompanyIdList(List.of(companyId));
+		param.setBindBuildingIdList(commonOpt.getBindBuildingIdList(userId, param.getCompanyIdList()));
 		return deviceDataMeasureService.handleDeviceMeasureData(param).stream()
 				.collect(Collectors.toMap(DeviceMeasureData::getDeviceId, Function.identity(), (existing, replacement) -> replacement));
 	}
 
-	private Map<String, DeviceBaStatusData> buildStatusDataMap(Long companyId, List<String> deviceIds) {
+	private Map<String, DeviceBaStatusData> buildStatusDataMap(Long userId, Long companyId, List<String> deviceIds) {
 		if (CollectionUtils.isEmpty(deviceIds)) return Collections.emptyMap();
 
 		BaStatusDataSearchParam param = new BaStatusDataSearchParam();
 		param.setDeviceIdList(deviceIds);
 		param.setCompanyIdList(List.of(companyId));
+		param.setBindBuildingIdList(commonOpt.getBindBuildingIdList(userId, param.getCompanyIdList()));
 		return deviceDataBaStatusService.handleDeviceBaStatusData(param).stream()
 				.collect(Collectors.toMap(DeviceBaStatusData::getDeviceId, Function.identity(), (existing, replacement) -> replacement));
 	}

dongjian-dashboard-back-service/src/main/java/com/dongjian/dashboard/back/service/impl/OverviewServiceImpl.java

@@ -68,7 +68,7 @@ public class OverviewServiceImpl implements OverviewService {
 	public SimpleDataResponse<List<OverviewVO>> getOverviewInfo(Long userId, Long companyId, Integer languageType, Integer utcOffset) {
 		Map<String, Object> buildingMap = new HashMap<>();
 		buildingMap.put("companyId", companyId);
-		buildingMap.put("bindBuildingIdList", commonOpt.getBindBuildingIdList(userId, companyId));
+		buildingMap.put("bindBuildingIdList", commonOpt.getBindBuildingIdList(userId, List.of(companyId)));
 
 		List<OverviewVO> buildingInfoList = overviewInfoMapperExt.getBuildingInfo(buildingMap);
 
@@ -276,7 +276,7 @@ public class OverviewServiceImpl implements OverviewService {
 	public SimpleDataResponse<List<TreeMenusDTO>> getOverallBoundLevel(Long companyId, Long userId, Integer languageType) {
 		Map<String, Object> buildingMap = new HashMap<>();
 		buildingMap.put("companyId", companyId);
-		buildingMap.put("bindBuildingIdList", commonOpt.getBindBuildingIdList(userId, companyId));
+		buildingMap.put("bindBuildingIdList", commonOpt.getBindBuildingIdList(userId, List.of(companyId)));
 		List<BuildingPathDTO> selectBuildingFullPath = levelMapperExt.selectBuildingFullPath(buildingMap);
 
 		// 构建节点