filter

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/repository/VideoRecommendStatus.java

@@ -1,27 +0,0 @@
-package com.tzld.piaoquan.recommend.server.repository;
-
-import lombok.Data;
-
-import javax.persistence.Entity;
-import javax.persistence.Id;
-import javax.persistence.Table;
-import java.io.Serializable;
-import java.util.Date;
-
-@Data
-@Entity
-@Table(name = "video_recommend_status")
-public class VideoRecommendStatus implements Serializable {
-    @Id
-    private Long id;
-
-    private Integer appType;
-
-    private Long videoId;
-
-    private Integer recommendStatus;
-
-    private Date createTime;
-
-    private Date updateTime;
-}

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/repository/WxVideoStatus.java

@@ -0,0 +1,47 @@
+package com.tzld.piaoquan.recommend.server.repository;
+
+import lombok.Data;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+@Entity
+@Table(name = "wx_video_status")
+public class WxVideoStatus implements Serializable {
+    @Id
+    private Long videoId;
+
+    private Long videoUid;
+
+    private Integer auditStatus;
+
+    private Integer appAuditStatus;
+
+    private String auditTranscationId;
+
+    private Integer chargeExamineStatus;
+
+    private Integer videoStatus;
+
+    private Integer examineStatus;
+
+    private Integer recommendStatus;
+
+    private Integer appRecommendStatus;
+
+    private Integer sensitiveStatus;
+
+    private Integer stageRecommendExamineStatus;
+
+    private Date videoGmtCreate;
+
+    private Long videoGmtCreateTimestamp;
+
+    private Integer originalStatus;
+
+    private Integer isReupload;
+}

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/repository/VideoRecommendStatusRepository.java → recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/repository/WxVideoStatusRepository.java

@@ -7,6 +7,6 @@ import java.util.Collection;
 import java.util.List;
 
 @Repository
-public interface VideoRecommendStatusRepository extends JpaRepository<VideoRecommendStatus, Long> {
-    List<VideoRecommendStatus> findAllByVideoIdIn(Collection<Long> videoIds);
+public interface WxVideoStatusRepository extends JpaRepository<WxVideoStatus, Long> {
+    List<WxVideoStatus> findAllByVideoIdIn(Collection<Long> videoIds);
 }

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/filter/strategy/RecommendStatusStrategy.java

@@ -1,8 +1,8 @@
 package com.tzld.piaoquan.recommend.server.service.filter.strategy;
 
 import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
-import com.tzld.piaoquan.recommend.server.repository.VideoRecommendStatus;
-import com.tzld.piaoquan.recommend.server.repository.VideoRecommendStatusRepository;
+import com.tzld.piaoquan.recommend.server.repository.WxVideoStatus;
+import com.tzld.piaoquan.recommend.server.repository.WxVideoStatusRepository;
 import com.tzld.piaoquan.recommend.server.service.filter.FilterParam;
 import com.tzld.piaoquan.recommend.server.service.filter.FilterStrategy;
 import org.apache.commons.collections4.CollectionUtils;
@@ -30,7 +30,7 @@ public class RecommendStatusStrategy implements FilterStrategy {
     private RedisTemplate<String, String> redisTemplate;
 
     @Autowired
-    private VideoRecommendStatusRepository videoRecommendStatusRepository;
+    private WxVideoStatusRepository wxVideoStatusRepository;
 
     private String keyFormat = "video:recommend:status:%s";
 
@@ -61,9 +61,9 @@ public class RecommendStatusStrategy implements FilterStrategy {
         }
 
         if (CollectionUtils.isNotEmpty(cacheMissVideoIds)) {
-            List<VideoRecommendStatus> status = videoRecommendStatusRepository.findAllByVideoIdIn(cacheMissVideoIds);
+            List<WxVideoStatus> status = wxVideoStatusRepository.findAllByVideoIdIn(cacheMissVideoIds);
             if (CollectionUtils.isNotEmpty(status)) {
-                for (VideoRecommendStatus v : status) {
+                for (WxVideoStatus v : status) {
                     recommendStatusMap.put(v.getVideoId(), v.getRecommendStatus());
 
                     // TODO 异步更新缓存