package com.ks.push.manager.rabbitmq.consumer;
|
|
import com.google.gson.Gson;
|
import com.ks.push.dto.BPushDeviceDataSet;
|
import com.ks.push.dto.mq.InvalidDeviceTokenInfo;
|
import com.ks.push.manager.BPushPlatformAppInfoManager;
|
import com.ks.push.manager.PushDeviceTokenManager;
|
import com.ks.push.manager.PushExcuteResultManager;
|
import com.ks.push.manager.rabbitmq.RabbitmqMsgConsumeUtil;
|
import com.ks.push.pojo.DO.BPushDeviceToken;
|
import com.ks.push.pojo.DO.BPushPlatformAppInfo;
|
import com.ks.push.pojo.DO.BPushTask;
|
import com.ks.push.pojo.DO.PushPlatform;
|
import com.ks.push.service.BPushTaskService;
|
import com.ks.push.utils.PushUtil;
|
import com.rabbitmq.client.Channel;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.StringUtil;
|
|
import javax.annotation.Resource;
|
import java.nio.charset.StandardCharsets;
|
import java.util.List;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description:
|
* @date 2024/9/26 13:47
|
*/
|
@Component
|
public class InvalidDeviceTokenListener {
|
|
static Logger logger = LoggerFactory.getLogger(InvalidDeviceTokenListener.class);
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
@Resource
|
private PushDeviceTokenManager pushDeviceTokenManager;
|
|
|
@RabbitListener(queues = {"bpush-xm","bpush-vivo","bpush-oppo","bpush-mz","bpush-jpush","bpush-huawei"}, ackMode = "MANUAL")
|
public void onMessage(Message message, Channel channel) throws Exception {
|
RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {
|
String result = new String(message.getBody(), StandardCharsets.UTF_8);
|
if (!StringUtil.isNullOrEmpty(result)) {
|
InvalidDeviceTokenInfo tokenInfo = new Gson().fromJson(result, InvalidDeviceTokenInfo.class);
|
List<BPushDeviceToken> tokenList = pushDeviceTokenManager.list(tokenInfo.getAppCode(), tokenInfo.getPushPlatform(), tokenInfo.getToken(), 1, 20);
|
if (tokenList != null) {
|
for (BPushDeviceToken token : tokenList) {
|
logger.info("清理无效token id-{}" + token.getId());
|
//删除
|
pushDeviceTokenManager.deleteByPrimaryKey(token.getId());
|
}
|
}
|
}
|
});
|
}
|
}
|
