完善根据IP屏蔽广告,创建会员实体

admin

2021-02-01 c6c5a8ce0f42d46ea2fe0312c9eda67a49fd3917

 src/main/java/com/yeshi/buwan/service/imp/ResourceVideoService.java

@@ -3,7 +3,13 @@
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;
import org.hibernate.Session;
@@ -14,12 +20,19 @@
import com.yeshi.buwan.dao.ResourceVideoDao;
import com.yeshi.buwan.domain.ResourceVideo;
import com.yeshi.buwan.domain.VideoInfo;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

@Service
public class ResourceVideoService {

    @Autowired
    private ResourceVideoDao resourceVideoDao;

    @Resource
    private VideoResourceMapExtraInfoDao videoResourceMapExtraInfoDao;


    @SuppressWarnings("unchecked")
    public List<ResourceVideo> getResourceList(final List<VideoInfo> list) {
@@ -53,6 +66,7 @@

    /**
     * 获取资源列表
     *
     * @param videoId
     * @return
     */
@@ -62,6 +76,19 @@
        return getResourceList(videoInfoList);
    }


    /**
     * 根据视频ID与ResourceId查询
     *
     * @param videoId
     * @param sourceId
     * @return
     */

    public long countByVideoIdAndResourceId(String videoId, long sourceId) {
        return resourceVideoDao.countByVideoIdAndResourceId(videoId, sourceId + "");
    }

    public void save(ResourceVideo resourceVideo) {
        resourceVideoDao.save(resourceVideo);
    }
@@ -69,16 +96,28 @@
    public void addVideoResource(String videoId, String resourceId) {
        ResourceVideo rv = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId);
        if (rv == null) {
            System.out.println(videoId + ":" + resourceId);
            rv = new ResourceVideo();
            rv.setResource(new VideoResource(resourceId + ""));
            rv.setVideo(new VideoInfo(videoId + ""));
            resourceVideoDao.save(rv);
            CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_ADD));
        }
    }

    @Transactional
    public void delete(String videoId, String resourceId) {
        ResourceVideo resourceVideo = resourceVideoDao.selectByVideoIdAndResourceId(videoId, resourceId + "");
        if (resourceVideo != null) {
            resourceVideoDao.delete(resourceVideo);
            CMQManager.getInstance().addVideoExtraInfoChanged(new VideoExtraInfoChangeMQMsg(VideoExtraInfoChangeMQMsg.TYPE_RESOURCE, videoId, VideoExtraInfoChangeMQMsg.ACTION_DELETE));
        }

    public void delete(ResourceVideo rv){
        resourceVideoDao.delete(rv);
        VideoResourceMapExtraInfo extraInfo = new VideoResourceMapExtraInfo(videoId, Long.parseLong(resourceId));
        extraInfo = videoResourceMapExtraInfoDao.find(VideoResourceMapExtraInfo.class, extraInfo.getId());
        if (extraInfo != null) {
            videoResourceMapExtraInfoDao.delete(extraInfo);
        }
    }