package com.coffee.bus.websocket; import cn.hutool.core.util.StrUtil; /** * @author lifang * @version 1.0.0 * @ClassName WebSocketContants.java * @Description websocket订阅所用常量 * @createTime 2022年03月25日 14:25:00 */ public class WebSocketConstant { public static final String ALARM_COUNT="alarm-count"; public static final String DEVICE_INFO_DETAIL="device-info-detail"; public static final String DEVICE_STATE_COUNT="device-state-count"; /** * 主题格式为 device-info-detail:default:45789215623:医院id * alarm-count:default:电量不足:医院id * @param id * @param productName * @param param * @return */ public static String getTopic(String id,String productName,String param,String tenantId){ productName=StrUtil.isEmptyIfStr(productName)?"default":productName; tenantId=StrUtil.isNullOrUndefined(tenantId)?"*":tenantId; return id+"-"+productName+"-"+param+"-"+tenantId; } public static String getDeviceInfoDetailTopic(String productName,String param,String tenantId){ return getTopic(DEVICE_INFO_DETAIL,productName,param,tenantId); } }