|  | @@ -214,17 +214,17 @@ public class PushMessageStrategyV1 implements ReplyStrategyService {
 | 
	
		
			
				|  |  |                  if (CollectionUtils.isEmpty(bucketDataParam.getVideos())) {
 | 
	
		
			
				|  |  |                      return null;
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  | +                CgiReplyBucketDataExample cgiReplyBucketDataExample = new CgiReplyBucketDataExample();
 | 
	
		
			
				|  |  | +                cgiReplyBucketDataExample.createCriteria().andIsDeleteEqualTo(0).andStrategyEqualTo(key)
 | 
	
		
			
				|  |  | +                        .andGhIdEqualTo(bucketDataParam.getGhId()).andMiniVideoIdIn(bucketDataParam.getVideos());
 | 
	
		
			
				|  |  | +                long count = cgiReplyBucketDataMapper.countByExample(cgiReplyBucketDataExample);
 | 
	
		
			
				|  |  | +                if (count == bucketDataParam.getVideos().size()) {
 | 
	
		
			
				|  |  | +                    // 已经存在就不处理
 | 
	
		
			
				|  |  | +                    continue;
 | 
	
		
			
				|  |  | +                }
 | 
	
		
			
				|  |  |                  Map<Long, VideoDetail> videoDetailMap = TouLiuHttpClientService.getVideoDetailRequest(bucketDataParam.getVideos());
 | 
	
		
			
				|  |  |                  int sort = 1;
 | 
	
		
			
				|  |  |                  for (Long videoId : bucketDataParam.getVideos()) {
 | 
	
		
			
				|  |  | -                    CgiReplyBucketDataExample cgiReplyBucketDataExample = new CgiReplyBucketDataExample();
 | 
	
		
			
				|  |  | -                    cgiReplyBucketDataExample.createCriteria().andIsDeleteEqualTo(0).andStrategyEqualTo(key)
 | 
	
		
			
				|  |  | -                            .andGhIdEqualTo(bucketDataParam.getGhId()).andMiniVideoIdIn(bucketDataParam.getVideos());
 | 
	
		
			
				|  |  | -                    long count = cgiReplyBucketDataMapper.countByExample(cgiReplyBucketDataExample);
 | 
	
		
			
				|  |  | -                    if (count == bucketDataParam.getVideos().size()) {
 | 
	
		
			
				|  |  | -                        // 已经存在就不处理
 | 
	
		
			
				|  |  | -                        continue;
 | 
	
		
			
				|  |  | -                    }
 | 
	
		
			
				|  |  |                      CgiReplyBucketData cgiReplyBucketData = new CgiReplyBucketData();
 | 
	
		
			
				|  |  |                      cgiReplyBucketData.setStrategy(key);
 | 
	
		
			
				|  |  |                      cgiReplyBucketData.setSort(sort);
 |