package com.ld.igds.protocol.zldz.mq;

import com.ld.igds.io.constant.ProtocolEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

/**
 * 控制终端作为发布者发布信息，服务端作为订阅者订阅，通道定义为当前协议编码
 */
@Slf4j
@Component(PublisherControl.BEAN_ID)
public class PublisherControl {

    public static final String BEAN_ID = "zldz.redisPublisher";

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;


    /**
     * 正常返回信息获取
     *
     * @param reMessage
     */
    public void publishMessage(String reMessage) {
        redisTemplate.convertAndSend(ProtocolEnum.TCP_ZLDZ_GRAIN_V1.getCode(), reMessage);
        log.debug("-----------报文信息存入队列------{}", reMessage);
    }

    /**
     * 登录信息获取
     *
     * @param sessionKey
     */
    public void publishLoginMessage(String sessionKey) {
        redisTemplate.convertAndSend(ProtocolEnum.TCP_ZLDZ_GRAIN_V1.getCode() + "_LOGIN", sessionKey);
        log.debug("-----------登录信息存入队列------{}", sessionKey);
    }

}