物联消息指标推送逻辑修改调整

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

@@ -78,7 +78,7 @@ public class FireEquipmentFireAlarm implements Serializable {
 
     @ApiModelProperty(value = "报警状态")
     @TableField("status")
-    private Boolean status;
+    private Boolean status = true;
 
     @ApiModelProperty(value = "量测数据类型")
     @TableField("type")

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

 package com.yeejoin.equipmanage.common.entity;
 
 import java.math.BigDecimal;
+import java.util.Date;
 
 import com.baomidou.mybatisplus.annotation.FieldStrategy;
 import com.baomidou.mybatisplus.annotation.TableField;
@@ -78,6 +79,10 @@ public class CarProperty extends BaseEntity {
 	 */
 	@TableField(value = "emergency_level_describe")
 	private String emergencyLevelDescribe;
+	
+	@TableField("update_date")
+	@ApiModelProperty(value = "更新时间")
+	private Date updateDate;
 
 	@TableField(exist = false)
 	private String unitName;

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

@@ -41,7 +41,8 @@ public class EquipmentSpecificIndex extends BaseEntity {
 
     @ApiModelProperty(value = "装备名称（冗余字段）")
     @TableField("equipment_specific_name")
-    private String equipmentSpecialName;
+    private String equipmentSpecificName;
+//   equipmentSpecialName 
 
     @ApiModelProperty(value = "指标名称（冗余字段）")
     @TableField("equipment_index_name")
@@ -99,8 +100,8 @@ public class EquipmentSpecificIndex extends BaseEntity {
     @TableField(exist = false)
     private String indexName;
     
-    @TableField(exist = false)
-    private String equipmentSpecificName;
+//    @TableField(exist = false)
+//    private String equipmentSpecificName;
     
     @TableField(exist = false)
     private String equipmentSpecificIndexName;

amos-boot-module/amos-boot-module-api/amos-boot-module-equip-api/src/main/java/com/yeejoin/equipmanage/common/enums/TopicEnum.java

@@ -17,6 +17,7 @@ public enum TopicEnum {
     EQDQR("fasAlarmInsert", "今日消防警情-待确认"),
     EQYQR("fasAlarmConfirm", "今日消防警情-已确认"),
     EQZXDT("fasAlarmInsertOrUpdate", "最新动态-告警日志列表"),
+    CARZXDT("carIndexInsertOrUpdate", "最新动态-告警日志列表"),
     EQXXTJ("fasReportInsertOrUpdate", "设备信号消息统计列表"),
     ALARM_LOG_INSERT("alarm/log/insert","告警日志插入"),
     IOT_SYSTEM__AlARM("iot-system-alarm", "确警消息");

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

@@ -152,7 +152,7 @@ public class EquipmentDetailServiceImpl extends ServiceImpl<EquipmentDetailMappe
             List<EquipmentSpecificIndex> equipmentSpecificIndexs = equPropertyList.stream().map(p -> {
                 EquipmentSpecificIndex specificIndex = new EquipmentSpecificIndex();
                 Bean.copyExistPropertis(p, specificIndex);
-                specificIndex.setEquipmentSpecialName(equipmentDetail.getName());
+                specificIndex.setEquipmentSpecificName(equipmentDetail.getName());
                 specificIndex.setEquipmentSpecificId(equipmentSpecificId);
                 return specificIndex;
             }).collect(Collectors.toList());
@@ -165,7 +165,7 @@ public class EquipmentDetailServiceImpl extends ServiceImpl<EquipmentDetailMappe
             List<EquipmentSpecificIndex> equipmentSpecificIndexs = equPropertyList.stream().map(p -> {
                 EquipmentSpecificIndex specificIndex = new EquipmentSpecificIndex();
                 Bean.copyExistPropertis(p, specificIndex);
-                specificIndex.setEquipmentSpecialName(equipmentDetail.getName());
+                specificIndex.setEquipmentSpecificName(equipmentDetail.getName());
                 specificIndex.setEquipmentSpecificId(equipmentSpecificId);
                 specificIndex.setValue(p.getValue());
                 return specificIndex;

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

@@ -151,7 +151,7 @@ public class EquipmentIndexImpl extends ServiceImpl<EquipmentIndexMapper, Equipm
                     equipmentSpecificIndex.setEquipmentIndexId(equipmentIndex.getId());
                     equipmentSpecificIndex.setEquipmentIndexKey(equipmentIndex.getPerfQuotaDefinitionId());
                     equipmentSpecificIndex.setEquipmentIndexName(equipmentIndex.getPerfQuotaName());
-                    equipmentSpecificIndex.setEquipmentSpecialName(y.getName());
+                    equipmentSpecificIndex.setEquipmentSpecificName(y.getName());
                     if (bool.get()) {
                         equipmentSpecificIndex.setEmergencyLevelColor(signalClassify.getEmergencyLevelColor());
                         equipmentSpecificIndex.setIsAlarm(signalClassify.getIsAlarm());

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

@@ -1461,7 +1461,7 @@ public class EquipmentSpecificSerivceImpl extends ServiceImpl<EquipmentSpecificM
             equipmentSpecificIndex.setEquipmentIndexId(x.getEquipmentIndexId());
             equipmentSpecificIndex.setEquipmentSpecificId(specific.getId());
             EquipmentIndex index = iEquipmentIndexService.getById(x.getEquipmentIndexId());
-            equipmentSpecificIndex.setEquipmentSpecialName(equipName);
+            equipmentSpecificIndex.setEquipmentSpecificName(equipName);
             equipmentSpecificIndex.setEquipmentIndexName(index.getPerfQuotaName());
             equipmentSpecificIndex.setEquipmentIndexKey(index.getPerfQuotaDefinitionId());
             equipmentSpecificIndex.setEmergencyLevelColor(index.getEmergencyLevelColor());

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

@@ -876,16 +876,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 
     private EquipmentAlarmReportDay addEquipAlarmReportRecord(EquipmentSpecificIndex equipmentSpecificIndex) {
         EquipmentAlarmReportDay equipmentAlarmReportDay = new EquipmentAlarmReportDay();
-//        LambdaQueryWrapper<EquipmentSpecific> speWrapper = new LambdaQueryWrapper<>();
-//        EquipmentSpecific equipmentSpecific = iEquipmentSpecificSerivce.getOne(speWrapper.eq(BaseEntity::getId, equipmentSpecificIndex.getEquipmentSpecificId()));
-//        LambdaQueryWrapper<EquipmentDetail> speDetailWrapper = new LambdaQueryWrapper<>();
-//        EquipmentDetail detail = iEquipmentDetailService.getOne(speDetailWrapper.eq(BaseEntity::getId, equipmentSpecific.getEquipmentDetailId()));
         equipmentAlarmReportDay.setOrgCode(equipmentSpecificIndex.getOrgCode());
         equipmentAlarmReportDay.setReportDate(new Date());
+        equipmentAlarmReportDay.setUpdateDate(new Date());
         equipmentAlarmReportDay.setSystemIds(equipmentSpecificIndex.getSystemId());
         equipmentAlarmReportDay.setLastReportDate(new Date());
         equipmentAlarmReportDay.setEquipmentSpecificId(equipmentSpecificIndex.getEquipmentSpecificId());
-        equipmentAlarmReportDay.setEquipmentSpecificName(equipmentSpecificIndex.getEquipmentSpecialName());
+        equipmentAlarmReportDay.setEquipmentSpecificName(equipmentSpecificIndex.getEquipmentSpecificName());
         equipmentAlarmReportDay.setEquipmentDetailId(equipmentSpecificIndex.getEquipmentDetailId());
         equipmentAlarmReportDay.setEquipmentId(equipmentSpecificIndex.getEquipmentId());
         equipmentAlarmReportDay.setEquipmentCode(equipmentSpecificIndex.getEquipmentCode());
@@ -903,27 +900,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
     private EquipmentSpecificAlarmLog addEquipAlarmLogRecord(EquipmentSpecificAlarm equipmentSpecificAlarm) {
         EquipmentSpecificAlarmLog equipmentSpecificAlarmLog = new EquipmentSpecificAlarmLog();
         BeanUtils.copyProperties(equipmentSpecificAlarm, equipmentSpecificAlarmLog);
-//        equipmentSpecificAlarmLog.setOrgCode(equipmentSpecificAlarm.getOrgCode());
+        equipmentSpecificAlarmLog.setId(null);
         equipmentSpecificAlarmLog.setCreateDate(new Date());
-//        equipmentSpecificAlarmLog.setSystemIds(equipmentSpecificAlarm.getSystemIds());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificId(equipmentSpecificAlarm.getEquipmentSpecificId());
-//        equipmentSpecificAlarmLog.setIotCode(equipmentSpecificAlarm.getIotCode());
-//        equipmentSpecificAlarmLog.setSystemCodes(equipmentSpecificAlarm.getSystemCodes());
-//        equipmentSpecificAlarmLog.setEquipmentCode(equipmentSpecificAlarm.getEquipmentCode());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificName(equipmentSpecificAlarm.getEquipmentSpecificName());
-//        equipmentSpecificAlarmLog.setEquipmentDetailId(equipmentSpecificAlarm.getEquipmentDetailId());
-//        equipmentSpecificAlarmLog.setEquipmentId(equipmentSpecificAlarm.getEquipmentId());
-//        equipmentSpecificAlarmLog.setType(equipmentSpecificAlarm.getType());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificIndexValue(equipmentSpecificAlarm.getEquipmentSpecificIndexValue());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificIndexKey(equipmentSpecificAlarm.getEquipmentSpecificIndexKey());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificIndexName(equipmentSpecificAlarm.getEquipmentSpecificIndexName());
-//        equipmentSpecificAlarmLog.setEquipmentIndexId(equipmentSpecificAlarm.getEquipmentIndexId());
         equipmentSpecificAlarmLog.setEquipmentSpecificAlarmId(equipmentSpecificAlarm.getId());
-//        equipmentSpecificAlarmLog.setLocation(equipmentSpecificAlarm.getLocation());
-//        equipmentSpecificAlarmLog.setAlarmReason(equipmentSpecificAlarm.getAlamReason());
-//        equipmentSpecificAlarmLog.setEquipmentSpecificCode(equipmentSpecificAlarm.getEquipmentSpecificCode());
-//        equipmentSpecificAlarmLog.setBuildId(equipmentSpecificAlarm.getBuildId());
-//        equipmentSpecificAlarmLog.setStatus(equipmentSpecificAlarm.getStatus());
         boolean bool = equipmentSpecificAlarmLogService.save(equipmentSpecificAlarmLog);
         //  同步告警消息给平台
         if (amosSwitch && bool) {
@@ -1275,12 +1254,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 	  equipmentAlarmLogs.forEach(action->{
 		  FireEquipmentFireAlarm alarm = new FireEquipmentFireAlarm();
 		  BeanUtils.copyProperties(action, alarm);
-//		  alarm.setAlarmReason(action.getAlarmReason());
 		  alarm.setAliasname(action.getEquipmentSpecificIndexName());
-//		  alarm.setConfirmDate(action.getConfirmDate());
-//		  alarm.setConfirmType(action.getConfirmType());
-//		  alarm.setConfirmUser(action.getConfirmUser());
-//		  alarm.setCreateDate(action.getCreateDate());
 		  alarm.setEquipmentMeasurementId(action.getEquipmentIndexId().toString());
 		  alarm.setEquipmentMeasurementMRid(action.getEquipmentIndexId().toString());
 		  alarm.setFieldLabel(action.getEquipmentSpecificIndexKey());
@@ -1293,11 +1267,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 		  alarm.setMrid(action.getId().toString());
 		  alarm.setName(action.getEquipmentSpecificIndexName());
 		  alarm.setRecoveryDate(action.getUpdateDate());
-//		  alarm.setResolveResult(action.getResolveResult());
 		  alarm.setStationCode(ObjectUtils.isEmpty(stationInfo)?"":stationInfo.get("stationCode"));
 		  alarm.setStationName(ObjectUtils.isEmpty(stationInfo)?"":stationInfo.get("stationName"));
-//		  alarm.setType(action.getType());
-//		  alarm.setUpdateDate(action.getUpdateDate());
 		  alarm.setValue(action.getEquipmentSpecificIndexValue());
 		  alarmList.add(alarm);
 	  });
@@ -1417,6 +1388,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
       TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
           @Override
           public void afterCommit() {
+        	  mqttSendGateway.sendToMqtt(TopicEnum.EQZXDT.getTopic(), "");
         	  mqttSendGateway.sendToMqtt(TopicEnum.EQXXTJ.getTopic(), "");
               iEquipmentSpecificSerivce.integrationPageSysDataRefresh(topicEntity.getCode());
               iEquipmentSpecificSerivce.updateEquipmentSpecIndexRealtimeData(equipmentSpecificIndexList);
@@ -1490,19 +1462,33 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 	      }
 	      List<CarPropertyVo> carPropertyVos = new ArrayList<>();
 	      carProperties.forEach(carProperty->{
-	    	  CarProperty property = new CarProperty();
               if (iotDataVO.getKey().equals(carProperty.getNameKey())) {
-                  BeanUtils.copyProperties(carProperty, property);
-                  property.setValue(iotDataVO.getValue().toString());
+                  carProperty.setValue(iotDataVO.getValue().toString());
                   carPropertyVos.add(carPropertyToCarPropertyVo(carProperty));
-                  carIndexsList.add(property);
+                  carIndexsList.add(carProperty);
               }
 	      });
 	      
 	      boolean updateBatchById = carPropertyService.updateBatchById(carIndexsList);
 	      
 	      if(updateBatchById){
-	    	  List<CarIndexGisVo> list = createCarIndexGisVo(carIndexsList);
+	    	  carTransactionSynch(carProperties,carPropertyVos);
+	      }
+	  });
+  }
+  
+  /**
+   * 车辆数据推送及同步
+   * @param carProperties
+   * @param carPropertyVos
+   */
+  public void carTransactionSynch(List<CarProperty> carProperties, List<CarPropertyVo> carPropertyVos){
+	  //TODO 数字化换流站组态屏数据推送,需要在事务提交之后，否侧事务隔离查询不出数据
+      TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
+          @Override
+          public void afterCommit() {
+        	  List<CarIndexGisVo> list = createCarIndexGisVo(carProperties);
+	    	  mqttSendGateway.sendToMqtt(TopicEnum.CARZXDT.getTopic(), "");
 		      boolean flag = ifSendToGis(list);
 		      if (flag) {
 		          mqttSendGateway.sendToMqtt(carTopic, JSON.toJSONString(list));
@@ -1511,8 +1497,8 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
 		      if (syncSwitch) {
                   syncDataService.syncCreatedFireVehicleMeasurement(carPropertyVos);
               }
-	      }
-	  });
+          }
+      });
   }
   
   private CarPropertyVo carPropertyToCarPropertyVo(CarProperty property){
@@ -1532,14 +1518,26 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
   
   private List<CarIndexGisVo> createCarIndexGisVo(List<CarProperty> carProperties){
 	  List<CarIndexGisVo> list = new ArrayList<>();
-	  carProperties.forEach(action->{
+	  long id =0l;
+	  String iotCode = "";
+	  for(CarProperty action : carProperties){
 		  CarIndexGisVo v = new CarIndexGisVo();
+		  id = action.getCarId();
+		  iotCode = action.getIotCode();
 		  v.setId(action.getCarId());
 		  v.setIotCode(action.getIotCode());
 		  v.setNameKey(action.getEquipmentIndexKey());
-		  v.setValue(action.getValue());
+		  v.setValue(ObjectUtils.isEmpty(action.getValue())?"0":action.getValue());
 		  list.add(v);
-	  });
+	  }
+	 
+	  CarIndexGisVo time = new CarIndexGisVo();
+	  time.setId(id);
+	  time.setIotCode(iotCode);
+	  time.setNameKey(CarForGisEnum.SJ.getNameKey());
+	  time.setValue(String.valueOf(new Date().getTime()));
+	  list.add(time);
+	  
 	return list;
   }
   

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

@@ -466,7 +466,7 @@ public class StockServiceImpl extends ServiceImpl<StockMapper, Stock> implements
             equipmentSpecificIndex.setEquipmentIndexId(index.getId());
             equipmentSpecificIndex.setEquipmentSpecificId(equipmentSpecific.getId());
             equipmentSpecificIndex.setCreateDate(new Date());
-            equipmentSpecificIndex.setEquipmentSpecialName(equipmentDetail.getName());
+            equipmentSpecificIndex.setEquipmentSpecificName(equipmentDetail.getName());
             equipmentSpecificIndex.setEquipmentIndexName(index.getPerfQuotaName());
             equipmentSpecificIndex.setEquipmentIndexKey(index.getPerfQuotaDefinitionId());
             return equipmentSpecificIndex;

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

@@ -9,6 +9,8 @@
         wcp.remark AS remark,
         wcp.equipment_index_id AS equipmentIndexId,
         wei.name_key AS nameKey,
+        wei.name_key AS equipmentIndexKey,
+        wei.name as equipmentIndexName,
         wcp.is_alarm as isAlarm,
 		wcp.emergency_level_color as emergencyLevelColor,
 		wcp.emergency_level as emergencyLevel,