修改方法

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

@@ -9,8 +9,13 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
+import java.util.logging.Logger;
 import java.util.stream.Collectors;
 
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.equipmanage.common.entity.*;
+import com.yeejoin.equipmanage.common.entity.publics.BaseEntity;
+import liquibase.pro.packaged.W;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -33,12 +38,6 @@ import com.yeejoin.equipmanage.common.datasync.entity.FireEquipmentDefectAlarm;
 import com.yeejoin.equipmanage.common.datasync.entity.FireEquipmentFaultAlarm;
 import com.yeejoin.equipmanage.common.datasync.entity.FireEquipmentFireAlarm;
 import com.yeejoin.equipmanage.common.dto.TemperatureAlarmDto;
-import com.yeejoin.equipmanage.common.entity.CarProperty;
-import com.yeejoin.equipmanage.common.entity.EquipmentAlarmReportDay;
-import com.yeejoin.equipmanage.common.entity.EquipmentSpecificAlarm;
-import com.yeejoin.equipmanage.common.entity.EquipmentSpecificAlarmLog;
-import com.yeejoin.equipmanage.common.entity.EquipmentSpecificIndex;
-import com.yeejoin.equipmanage.common.entity.FireFightingSystemEntity;
 import com.yeejoin.equipmanage.common.entity.vo.CarPropertyVo;
 import com.yeejoin.equipmanage.common.entity.vo.EquipmentIndexVO;
 import com.yeejoin.equipmanage.common.entity.vo.EquipmentSpecificVo;
@@ -466,6 +465,16 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 			}
 			model.setIsSendWeb(true);
 			model.setCategory(1);
+
+			//告警弹窗需要根据人员单位判断是否展示 后端返回单位Code 前端判断
+			LambdaQueryWrapper<EquipmentSpecific> wrapper = new LambdaQueryWrapper<>();
+			wrapper.eq(BaseEntity::getId,equipmentSpecificAlarmLog.getEquipmentSpecificId());
+			EquipmentSpecific equipmentSpecific = equipmentSpecificMapper.selectOne(wrapper);
+			if (!ValidationUtil.isEmpty(equipmentSpecific) && !ValidationUtil.isEmpty(equipmentSpecific.getBizOrgCode())){
+				Map<String, String> equipMap = new HashMap<>();
+				equipMap.put("bizOrgCode",equipmentSpecific.getBizOrgCode());
+				model.setExtras(equipMap);
+			}
 			model.setRelationId(String.valueOf(equipmentSpecificAlarmLog.getId()));
 			Token token = remoteSecurityService.getServerToken();
 			systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);