package com.zy.integration.iot.publish.impl;
|
|
import com.core.common.Cools;
|
import com.zy.integration.iot.client.IotMqttClient;
|
import com.zy.integration.iot.publish.IotPublishService;
|
import com.zy.iot.constant.IotConstants;
|
import com.zy.iot.entity.IotPublishRecord;
|
import com.zy.iot.service.IotPublishRecordService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
|
/**
|
* IoT 统一发布器。
|
* 这里只处理 MQTT 传输结果，业务成功与否由指令处理阶段决定。
|
*/
|
@Slf4j
|
@Service
|
public class IotPublishServiceImpl implements IotPublishService {
|
|
@Autowired
|
private IotPublishRecordService iotPublishRecordService;
|
@Autowired
|
private IotMqttClient iotMqttClient;
|
|
/**
|
* 立即发布指定记录；若网络发送失败，仅更新状态，后续由调度器重试。
|
*/
|
@Override
|
public void publishRecordNow(Long recordId) {
|
if (recordId == null) {
|
return;
|
}
|
IotPublishRecord record = iotPublishRecordService.selectById(recordId);
|
if (record == null || Cools.isEmpty(record.getPublishTopic()) || Cools.isEmpty(record.getPublishPayload())) {
|
return;
|
}
|
Date now = new Date();
|
try {
|
iotMqttClient.publish(record.getPublishTopic(), record.getPublishPayload());
|
record.setPublishStatus(IotConstants.PUBLISH_STATUS_SUCCESS);
|
record.setUpdateTime(now);
|
iotPublishRecordService.updateById(record);
|
} catch (Exception e) {
|
record.setPublishStatus(IotConstants.PUBLISH_STATUS_FAILURE);
|
record.setErrorMessage(truncate(e.getMessage(), 500));
|
record.setUpdateTime(now);
|
iotPublishRecordService.updateById(record);
|
log.error("publish iot message failed, recordId={}", recordId, e);
|
}
|
}
|
|
private String truncate(String message, int maxLength) {
|
if (message == null || message.length() <= maxLength) {
|
return message;
|
}
|
return message.substring(0, maxLength);
|
}
|
}
|
