package com.yeshi.buwan.util.mq.rabbit.consumer;
|
|
import com.google.gson.Gson;
|
import com.rabbitmq.client.Channel;
|
import com.yeshi.buwan.dto.mq.PPTVMQMsg;
|
import com.yeshi.buwan.service.inter.juhe.PPTVService;
|
import com.yeshi.buwan.util.StringUtil;
|
import com.yeshi.buwan.util.mq.rabbit.RabbitmqMsgConsumeUtil;
|
import com.yeshi.buwan.videos.pptv.entity.PPTVSeries;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.nio.charset.StandardCharsets;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description:
|
* @date 2024/9/26 13:47
|
*/
|
@Component
|
public class VideoUpdatePPTVListener {
|
private final static Logger logger = LoggerFactory.getLogger(VideoUpdatePPTVListener.class);
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
@Resource
|
private PPTVService pptvService;
|
|
public void onMessage(Message message, Channel channel) throws Exception {
|
RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {
|
String result = new String(message.getBody(), StandardCharsets.UTF_8);
|
//TODO 处理消息
|
if(!StringUtil.isNullOrEmpty(result)) {
|
PPTVMQMsg pptvmqMsg = new Gson().fromJson(result, PPTVMQMsg.class);
|
try {
|
switch (pptvmqMsg.getType()) {
|
case PPTVMQMsg.TYPE_ADD_OR_UPDATE:
|
PPTVSeries pptvSeries = pptvService.getSeriesDetail(pptvmqMsg.getInfoId());
|
if (pptvSeries != null) {
|
pptvService.addToVideoInfo(pptvSeries);
|
}
|
break;
|
|
case PPTVMQMsg.TYPE_DELETE:
|
pptvService.offLineSeries(pptvmqMsg.getInfoId());
|
break;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
logger.error("PPTV添加到视频出错：" + e.getMessage());
|
logger.error("infoId:" + pptvmqMsg.getInfoId());
|
}
|
|
}
|
});
|
}
|
}
|
