修改 mqtt 源数据存储
This commit is contained in:
@ -61,15 +61,8 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
|
|||||||
System.out.println("[SYSTEM] Status update: " + payload);
|
System.out.println("[SYSTEM] Status update: " + payload);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// 业务处理逻辑
|
emsMqttMessageService.insertMqttOriginalMessage(topic,payload);
|
||||||
EmsMqttMessage mqttMessage = new EmsMqttMessage();
|
|
||||||
mqttMessage.setMqttTopic(topic);
|
|
||||||
mqttMessage.setMqttMessage(payload);
|
|
||||||
mqttMessage.setCreateTime(new java.util.Date());
|
|
||||||
mqttMessage.setUpdateTime(new java.util.Date());
|
|
||||||
mqttMessage.setCreateBy("system");
|
|
||||||
mqttMessage.setUpdateBy("system");
|
|
||||||
emsMqttMessageService.insertEmsMqttMessage(mqttMessage);
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("Failed to process system status message: " + e.getMessage(), e);
|
log.error("Failed to process system status message: " + e.getMessage(), e);
|
||||||
}
|
}
|
||||||
@ -87,15 +80,7 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
|
|||||||
fXXDataProcessService.handleFxData(payload);
|
fXXDataProcessService.handleFxData(payload);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
emsMqttMessageService.insertMqttOriginalMessage(topic,payload);
|
||||||
EmsMqttMessage mqttMessage = new EmsMqttMessage();
|
|
||||||
mqttMessage.setMqttTopic(topic);
|
|
||||||
mqttMessage.setMqttMessage(payload);
|
|
||||||
mqttMessage.setCreateTime(new java.util.Date());
|
|
||||||
mqttMessage.setUpdateTime(new java.util.Date());
|
|
||||||
mqttMessage.setCreateBy("system");
|
|
||||||
mqttMessage.setUpdateBy("system");
|
|
||||||
emsMqttMessageService.insertEmsMqttMessage(mqttMessage);
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.error("Failed to process system status message: " + e.getMessage(), e);
|
log.error("Failed to process system status message: " + e.getMessage(), e);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -59,4 +59,13 @@ public interface IEmsMqttMessageService
|
|||||||
* @return 结果
|
* @return 结果
|
||||||
*/
|
*/
|
||||||
public int deleteEmsMqttMessageById(Long id);
|
public int deleteEmsMqttMessageById(Long id);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 新增【请填写功能名称】
|
||||||
|
*
|
||||||
|
* @param topic 【请填写功能名称】
|
||||||
|
* @param message 【请填写功能名称】
|
||||||
|
* @return 结果
|
||||||
|
*/
|
||||||
|
public int insertMqttOriginalMessage(String topic, String message);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -93,4 +93,17 @@ public class EmsMqttMessageServiceImpl implements IEmsMqttMessageService
|
|||||||
{
|
{
|
||||||
return emsMqttMessageMapper.deleteEmsMqttMessageById(id);
|
return emsMqttMessageMapper.deleteEmsMqttMessageById(id);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int insertMqttOriginalMessage(String topic, String message) {
|
||||||
|
EmsMqttMessage mqttMessage = new EmsMqttMessage();
|
||||||
|
mqttMessage.setMqttTopic(topic);
|
||||||
|
mqttMessage.setMqttMessage(message);
|
||||||
|
mqttMessage.setCreateTime(new java.util.Date());
|
||||||
|
mqttMessage.setUpdateTime(new java.util.Date());
|
||||||
|
mqttMessage.setCreateBy("system");
|
||||||
|
mqttMessage.setUpdateBy("system");
|
||||||
|
mqttMessage.setUpdateTime(DateUtils.getNowDate());
|
||||||
|
return emsMqttMessageMapper.updateEmsMqttMessage(mqttMessage);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user