package com.qianwen.smartman.modules.sync.message.consumer;
|
|
import cn.hutool.json.JSONObject;
|
import java.util.Objects;
|
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
import org.apache.rocketmq.spring.core.RocketMQListener;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.smartman.modules.sync.constant.QyWechatConstant;
|
import com.qianwen.smartman.modules.sync.enums.SseEventEnum;
|
import com.qianwen.smartman.modules.sync.message.sse.SseEmitterServer;
|
import com.qianwen.smartman.modules.sync.util.CodeUtil;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 企业微信消息消费
|
*/
|
@RocketMQMessageListener(topic = QyWechatConstant.WECHAT_TOPIC, consumerGroup = QyWechatConstant.WECHAT_GROUP)
|
@Component
|
public class QyWechatSyncConsumer implements RocketMQListener<JSONObject> {
|
private static final Logger log = LoggerFactory.getLogger(QyWechatSyncConsumer.class);
|
private final SseEmitterServer sseEmitterServer;
|
|
public QyWechatSyncConsumer(final SseEmitterServer sseEmitterServer) {
|
this.sseEmitterServer = sseEmitterServer;
|
}
|
|
public void onMessage(JSONObject message) {
|
log.info("[企业微信二维码消息消费者].[收到延迟消息 message={}]", message);
|
if (Objects.isNull(message)) {
|
return;
|
}
|
String clientId = message.getStr("clientId");
|
Integer type = message.getInt("type");
|
Long empId = message.getLong("empId");
|
String cacheKey = type.equals(QyWechatConstant.QY_CODE_LOGIN_TYPE) ? CodeUtil.getLoginCodeCacheKey(clientId) : CodeUtil.getBindCodeCacheKey(clientId, empId);
|
if ((type.equals(QyWechatConstant.QY_CODE_LOGIN_TYPE) ? CodeUtil.verifyLoginCodeExpire(clientId) : CodeUtil.verifyBindCodeExpire(clientId, empId)).booleanValue()) {
|
return;
|
}
|
this.sseEmitterServer.sendMsg(clientId, Boolean.TRUE, Objects.equals(type, QyWechatConstant.QY_CODE_LOGIN_TYPE) ? SseEventEnum.LOGIN_CODE_EXPIRE_ID.getEventId() : SseEventEnum.BIND_CODE_EXPIRE_ID.getEventId());
|
CodeUtil.failureCode(cacheKey);
|
}
|
}
|
