| | |
|---|
| | | |
|---|
| | | import ai.djl.modality.Classifications; |
|---|
| | | import cn.hutool.core.bean.BeanUtil; |
|---|
| | | import cn.hutool.core.thread.ThreadUtil; |
|---|
| | | import com.alibaba.druid.support.json.JSONUtils; |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | |
|---|
| | | mqttMessage.setQos(0); |
|---|
| | | mqttMessage.setPayload(JSONObject.toJSONString(realTimeDataVo).getBytes()); |
|---|
| | | mqttUtil.getMqttClient().publish(MqttConstant.TENANT_UP_PREFIX_REALTIME_DATA,mqttMessage); |
|---|
| | | //处理故障信息 |
|---|
| | | dryRealTimeDataService.fitFultRecord(realTimeDataVo); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } catch (MqttException e) { |
|---|
