| | |
|---|
| | | @Autowired |
|---|
| | | private MqttUtil mqttUtil; |
|---|
| | | |
|---|
| | | @Value(value = "${jeecg.mqtt.enable}") |
|---|
| | | private boolean mqttEnable; |
|---|
| | | |
|---|
| | | public String getTemporaryToken() { |
|---|
| | | if (token == null) { |
|---|
| | | RedisUtil redisUtil = SpringContextUtils.getBean(RedisUtil.class); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Result<?> fitFultRecord(RealTimeDataVo vo) { |
|---|
| | | public Result<?> fitFaultRecord(RealTimeDataVo vo) { |
|---|
| | | TenantContext.setTenant(vo.getTenantid()+""); |
|---|
| | | ThreadUtil.execute(() -> { |
|---|
| | | try { |
|---|
| | |
|---|
| | | |
|---|
| | | //处理结束后，将redis中实时数据发送至云服务器 |
|---|
| | | Map<Object, Object> toCloudFaultMap = redisUtil.hmget(MqttConstant.MQTT_REAL_FAULT); |
|---|
| | | if(!toCloudFaultMap.isEmpty()){ |
|---|
| | | if(mqttEnable && !toCloudFaultMap.isEmpty()){ |
|---|
| | | MqMessage< Map<Object, Object>> message = new MqMessage<>(); |
|---|
| | | message.setData(toCloudFaultMap); |
|---|
| | | message.setTentId(vo.getTenantid()+""); |
|---|
