package cn.iocoder.yudao.module.iot.service.ota;
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.module.iot.controller.admin.ota.vo.task.record.IotOtaTaskRecordPageReqVO;
|
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
|
import cn.iocoder.yudao.module.iot.dal.dataobject.device.IotDeviceDO;
|
import cn.iocoder.yudao.module.iot.dal.dataobject.ota.IotOtaFirmwareDO;
|
import cn.iocoder.yudao.module.iot.dal.dataobject.ota.IotOtaTaskRecordDO;
|
import jakarta.validation.Valid;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
/**
|
* IoT OTA 升级记录 Service 接口
|
*/
|
public interface IotOtaTaskRecordService {
|
|
/**
|
* 批量创建 OTA 升级记录
|
*
|
* @param devices 设备列表
|
* @param firmwareId 固件编号
|
* @param taskId 任务编号
|
*/
|
void createOtaTaskRecordList(List<IotDeviceDO> devices, Long firmwareId, Long taskId);
|
|
/**
|
* 获取 OTA 升级记录的状态统计
|
*
|
* @param firmwareId 固件编号
|
* @param taskId 任务编号
|
* @return 状态统计 Map，key 为状态码，value 为对应状态的升级记录数量
|
*/
|
Map<Integer, Long> getOtaTaskRecordStatusStatistics(Long firmwareId, Long taskId);
|
|
/**
|
* 获取 OTA 升级记录
|
*
|
* @param id 编号
|
* @return OTA 升级记录
|
*/
|
IotOtaTaskRecordDO getOtaTaskRecord(Long id);
|
|
/**
|
* 获取 OTA 升级记录分页
|
*
|
* @param pageReqVO 分页查询
|
* @return OTA 升级记录分页
|
*/
|
PageResult<IotOtaTaskRecordDO> getOtaTaskRecordPage(@Valid IotOtaTaskRecordPageReqVO pageReqVO);
|
|
/**
|
* 根据 OTA 任务编号，取消未结束的升级记录
|
*
|
* @param taskId 升级任务编号
|
*/
|
void cancelTaskRecordListByTaskId(Long taskId);
|
|
/**
|
* 根据设备编号和记录状态，获取 OTA 升级记录列表
|
*
|
* @param deviceIds 设备编号集合
|
* @param statuses 记录状态集合
|
* @return OTA 升级记录列表
|
*/
|
List<IotOtaTaskRecordDO> getOtaTaskRecordListByDeviceIdAndStatus(Set<Long> deviceIds, Set<Integer> statuses);
|
|
/**
|
* 根据记录状态，获取 OTA 升级记录列表
|
*
|
* @param status 升级记录状态
|
* @return 升级记录列表
|
*/
|
List<IotOtaTaskRecordDO> getOtaRecordListByStatus(Integer status);
|
|
/**
|
* 取消 OTA 升级记录
|
*
|
* @param id 记录编号
|
*/
|
void cancelOtaTaskRecord(Long id);
|
|
/**
|
* 推送 OTA 升级任务记录
|
*
|
* @param record 任务记录
|
* @param fireware 固件信息
|
* @param device 设备信息
|
* @return 是否推送成功
|
*/
|
boolean pushOtaTaskRecord(IotOtaTaskRecordDO record, IotOtaFirmwareDO fireware, IotDeviceDO device);
|
|
/**
|
* 更新 OTA 升级记录进度
|
*
|
* @param device 设备信息
|
* @param message 设备消息
|
*/
|
void updateOtaRecordProgress(IotDeviceDO device, IotDeviceMessage message);
|
|
}
|
