新增数据项

api-module/src/main/java/com/tzld/piaoquan/api/dao/mapper/contentplatform/ext/ContentPlatformPlanMapperExt.java

@@ -37,7 +37,8 @@ public interface ContentPlatformPlanMapperExt {
                                             @Param("dt") String dt,
                                             @Param("minScore") Double minScore,
                                             @Param("offset") int offset,
-                                            @Param("pageSize") Integer pageSize);
+                                            @Param("pageSize") Integer pageSize,
+                                            @Param("sort") String sort);
 
     void batchInsertContentPlatformVideo(@Param("records") List<ContentPlatformVideo> saveList);
 

api-module/src/main/java/com/tzld/piaoquan/api/job/ContentPlatformDatastatJob.java

@@ -669,6 +669,7 @@ public class ContentPlatformDatastatJob {
                     continue;
                 }
                 if (saveMap.containsKey(channel) && !out2Channels.contains(channel)) {
+
                     saveMap.remove(channel);
                 }
                 ContentPlatformQwDataStatReplyTotal item = saveMap.getOrDefault(channel, new ContentPlatformQwDataStatReplyTotal());

api-module/src/main/java/com/tzld/piaoquan/api/model/param/contentplatform/VideoContentListParam.java

@@ -12,4 +12,7 @@ public class VideoContentListParam extends PageParam {
 
     @ApiModelProperty(value = "品类")
     private String category;
+
+    @ApiModelProperty(value = "排序 0-平台推荐 1-行业裂变率 2-本渠道裂变率")
+    private Integer sort;
 }

api-module/src/main/java/com/tzld/piaoquan/api/model/vo/contentplatform/VideoContentItemVO.java

@@ -20,4 +20,10 @@ public class VideoContentItemVO {
 
     @ApiModelProperty(value = "传播效率")
     private Double score;
+
+    @ApiModelProperty(value = "行业裂变率")
+    private Double industryFissionRate;
+
+    @ApiModelProperty(value = "本渠道裂变率")
+    private Double channelFissionRate;
 }

api-module/src/main/java/com/tzld/piaoquan/api/service/contentplatform/impl/ContentPlatformApiServiceImpl.java

@@ -97,7 +97,7 @@ public class ContentPlatformApiServiceImpl implements ContentPlatformApiService
         if (count == 0) {
             return result;
         }
-        List<ContentPlatformVideo> videoList = planMapperExt.getVideoList(listParam, dt, videoMinScore, offset, param.getPageSize());
+        List<ContentPlatformVideo> videoList = planMapperExt.getVideoList(listParam, dt, videoMinScore, offset, param.getPageSize(), "score desc");
         List<VideoIdTitleVO> list = videoList.stream().map(video -> {
             VideoIdTitleVO vo = new VideoIdTitleVO();
             vo.setVideoId(video.getVideoId());

api-module/src/main/java/com/tzld/piaoquan/api/service/contentplatform/impl/ContentPlatformPlanServiceImpl.java

@@ -455,12 +455,26 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
         if (count == 0) {
             return result;
         }
-        List<ContentPlatformVideo> videoList = planMapperExt.getVideoList(param, dt, videoMinScore, offset, param.getPageSize());
+        String sort = getVideoContentListSort(param.getSort());
+        List<ContentPlatformVideo> videoList = planMapperExt.getVideoList(param, dt, videoMinScore, offset, param.getPageSize(), sort);
         List<VideoContentItemVO> list = buildVideoContentItemVOList(videoList);
         result.setObjs(list);
         return result;
     }
 
+    private String getVideoContentListSort(Integer sort) {
+        switch (sort) {
+            case 1:
+                return "score desc";
+            case 2:
+                return "score desc";
+            case 3:
+                return "score desc";
+            default:
+                return "score desc";
+        }
+    }
+
     private List<VideoContentItemVO> buildVideoContentItemVOList(List<ContentPlatformVideo> videoList) {
         if (CollectionUtils.isEmpty(videoList)) {
             return null;

api-module/src/main/resources/mapper/contentplatform/ext/ContentPlatformPlanMapperExt.xml

@@ -115,7 +115,7 @@
         <if test="param.category!= null and param.category!= ''">
             and category = #{param.category}
         </if>
-        order by score desc
+        order by ${sort}
         limit #{offset}, #{pageSize}
     </select>