package cn.iocoder.yudao.module.iot.core.enums;
|
|
import cn.hutool.core.util.ArrayUtil;
|
import cn.iocoder.yudao.framework.common.core.ArrayValuable;
|
import cn.iocoder.yudao.framework.common.util.collection.SetUtils;
|
import lombok.AllArgsConstructor;
|
import lombok.Getter;
|
|
import java.util.Arrays;
|
import java.util.Set;
|
|
/**
|
* IoT 设备消息的方法枚举
|
*
|
* @author haohao
|
*/
|
@Getter
|
@AllArgsConstructor
|
public enum IotDeviceMessageMethodEnum implements ArrayValuable<String> {
|
|
// ========== 设备状态 ==========
|
|
STATE_UPDATE("thing.state.update", "设备状态更新", true),
|
|
// TODO 芋艿：要不要加个 ping 消息；
|
|
// ========== 拓扑管理 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/manage-topological-relationships
|
|
TOPO_ADD("thing.topo.add", "添加拓扑关系", true),
|
TOPO_DELETE("thing.topo.delete", "删除拓扑关系", true),
|
TOPO_GET("thing.topo.get", "获取拓扑关系", true),
|
TOPO_CHANGE("thing.topo.change", "拓扑关系变更通知", false),
|
|
// ========== 设备注册 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/unique-certificate-per-product-verification
|
|
DEVICE_REGISTER("thing.auth.register", "设备动态注册", true),
|
SUB_DEVICE_REGISTER("thing.auth.register.sub", "子设备动态注册", true),
|
|
// ========== 设备属性 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/device-properties-events-and-services
|
|
PROPERTY_POST("thing.property.post", "属性上报", true),
|
PROPERTY_SET("thing.property.set", "属性设置", false),
|
|
PROPERTY_PACK_POST("thing.event.property.pack.post", "批量上报（属性 + 事件 + 子设备）", true), // 网关独有
|
|
// ========== 设备事件 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/device-properties-events-and-services
|
|
EVENT_POST("thing.event.post", "事件上报", true),
|
|
// ========== 设备服务调用 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/device-properties-events-and-services
|
|
SERVICE_INVOKE("thing.service.invoke", "服务调用", false),
|
|
// ========== 设备配置 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/remote-configuration-1
|
|
CONFIG_PUSH("thing.config.push", "配置推送", false),
|
|
// ========== OTA 固件 ==========
|
// 可参考：https://help.aliyun.com/zh/iot/user-guide/perform-ota-updates
|
|
OTA_UPGRADE("thing.ota.upgrade", "OTA 固件信息推送", false),
|
OTA_PROGRESS("thing.ota.progress", "OTA 升级进度上报", true),
|
|
;
|
|
public static final String[] ARRAYS = Arrays.stream(values()).map(IotDeviceMessageMethodEnum::getMethod)
|
.toArray(String[]::new);
|
|
/**
|
* 不进行 reply 回复的方法集合
|
*/
|
public static final Set<String> REPLY_DISABLED = SetUtils.asSet(
|
STATE_UPDATE.getMethod(),
|
OTA_PROGRESS.getMethod() // 参考阿里云，OTA 升级进度上报，不进行回复
|
);
|
|
private final String method;
|
|
private final String name;
|
|
private final Boolean upstream;
|
|
@Override
|
public String[] array() {
|
return ARRAYS;
|
}
|
|
public static IotDeviceMessageMethodEnum of(String method) {
|
return ArrayUtil.firstMatch(item -> item.getMethod().equals(method),
|
IotDeviceMessageMethodEnum.values());
|
}
|
|
public static boolean isReplyDisabled(String method) {
|
return REPLY_DISABLED.contains(method);
|
}
|
|
}
|
