admin
2021-02-01 c6c5a8ce0f42d46ea2fe0312c9eda67a49fd3917
src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java
@@ -3,8 +3,12 @@
import java.util.ArrayList;
import java.util.List;
import com.yeshi.buwan.dao.VideoResourceMapExtraInfoDao;
import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyiDao;
import com.yeshi.buwan.domain.VideoResource;
import com.yeshi.buwan.domain.VideoResourceMapExtraInfo;
import com.yeshi.buwan.dto.mq.VideoExtraInfoChangeMQMsg;
import com.yeshi.buwan.iqiyi.entity.VideoIqiyi;
import com.yeshi.buwan.util.mq.CMQManager;
import org.hibernate.HibernateException;
import org.hibernate.Query;
@@ -25,6 +29,10 @@
    @Autowired
    private ResourceVideoDao resourceVideoDao;
    @Resource
    private VideoResourceMapExtraInfoDao videoResourceMapExtraInfoDao;
    @SuppressWarnings("unchecked")
    public List<ResourceVideo> getResourceList(final List<VideoInfo> list) {
@@ -100,10 +108,16 @@
    @Transactional
    public void delete(String videoId, String resourceId) {
        ResourceVideo resourceVideo = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId + "");
        if (resourceVideo != null)
        if (resourceVideo != null) {
            resourceVideoDao.delete(resourceVideo);
        CMQManager.getInstance().addVideoResourceDeleteMsg(videoId);
        CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
            CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
        }
        VideoResourceMapExtraInfo extraInfo = new VideoResourceMapExtraInfo(videoId, Long.parseLong(resourceId));
        extraInfo = videoResourceMapExtraInfoDao.find(VideoResourceMapExtraInfo.class, extraInfo.getId());
        if (extraInfo != null) {
            videoResourceMapExtraInfoDao.delete(extraInfo);
        }
    }