package com.yeshi.buwan.util.mq.rabbit.consumer;
|
|
import com.google.gson.Gson;
|
import com.rabbitmq.client.Channel;
|
import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyi2Dao;
|
import com.yeshi.buwan.dto.mq.UpdateResourceVideoMQMsg;
|
import com.yeshi.buwan.service.imp.ResourceVideoService;
|
import com.yeshi.buwan.service.inter.juhe.Iqiyi2Service;
|
import com.yeshi.buwan.util.RedisManager;
|
import com.yeshi.buwan.util.mq.rabbit.RabbitmqMsgConsumeUtil;
|
import com.yeshi.buwan.videos.iqiyi.IqiYiNewAPI;
|
import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum2;
|
import com.yeshi.buwan.videos.iqiyi.entity.VideoIqiyi2;
|
import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil2;
|
import net.sf.json.JSONObject;
|
import org.springframework.amqp.core.Message;
|
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;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description:
|
* @date 2024/9/26 13:47
|
*/
|
@Component
|
public class UpdateResourceVideoListener {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private VideoIqiyi2Dao videoIqiyi2Dao;
|
|
@Resource
|
private ResourceVideoService resourceVideoService;
|
@Resource
|
private Iqiyi2Service iqiyi2Service;
|
@Resource
|
private IqiyiUtil2 iqiyiUtil2;
|
|
|
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)) {
|
Gson gson = new Gson();
|
UpdateResourceVideoMQMsg videoMQMsg = null;
|
try {
|
videoMQMsg = gson.fromJson(result, UpdateResourceVideoMQMsg.class);
|
} catch (Exception e) {
|
JSONObject jsonObject = JSONObject.fromObject(result);
|
jsonObject.remove("date");
|
videoMQMsg = gson.fromJson(jsonObject.toString(), UpdateResourceVideoMQMsg.class);
|
}
|
if (videoMQMsg != null) {
|
try {
|
String key = "resourcevideo-update-" + com.yeshi.buwan.util.StringUtil.Md5(videoMQMsg.getResourceId() + "#" + videoMQMsg.getId());
|
//可以更新
|
if (com.yeshi.buwan.util.StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {
|
//12小时内不再更新
|
redisManager.cacheCommonString(key, "1", 60 * 60 * 12);
|
switch (videoMQMsg.getResourceId()) {
|
case IqiyiUtil2
|
.RESOURCE_ID:
|
//redis查询是否更新过
|
IqiyiAlbum2 iqiyiAlbum2 = IqiYiNewAPI.getAlbumOrVideoDetail(Long.parseLong(videoMQMsg.getId()));
|
if (iqiyiAlbum2 == null) {
|
VideoIqiyi2 videoIqiyi2 = videoIqiyi2Dao.selectByIqiyiId(Long.parseLong(videoMQMsg.getId()));
|
if (videoIqiyi2 != null) {
|
//下架
|
resourceVideoService.delete(videoIqiyi2.getVideoId() + "", videoMQMsg.getResourceId() + "");
|
}
|
//删除爱奇艺资源
|
iqiyi2Service.offlineIqiyiAlbum(Long.parseLong(videoMQMsg.getId()));
|
} else {
|
//保存
|
iqiyiUtil2.syncByAid(iqiyiAlbum2.getId(), false);
|
}
|
break;
|
}
|
|
}
|
} catch (Exception e) {
|
} finally {
|
}
|
}
|
}
|
});
|
}
|
}
|
