NB_NetPump/coffee-system/src/main/java/com/coffee/bus/websocket/WebSocketConstant.java

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);
    }
}