飞书推送增加最近七天新投放剧目

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/ReportsAdPushMapper.java

@@ -65,4 +65,8 @@ public interface ReportsAdPushMapper {
     @DS("master")
     //三天内下架剧目列表
     List<JSONObject> publishDownMovieList();
+
+    @DS("master")
+    //七天内上架短剧项目列表
+    List<JSONObject> publishUpMovieList();
 }

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/ReportsAdPushMapper.xml

@@ -675,4 +675,18 @@
                  left join deepthink.dt_dictionary tb2 on cast(tb1.movie_source as char)=tb2.dict_key and tb2.select_key='movie_source'
         where tb1.publish_status=3 and publish_change_time >=DATE_SUB(NOW(), INTERVAL 3 DAY)
     </select>
+    <select id="publishUpMovieList" resultType="com.alibaba.fastjson.JSONObject">
+        select video_project_name, DATE_FORMAT(STR_TO_DATE(project_ad_date, '%Y%m%d'), '%Y-%m-%d') as project_ad_date,
+        <![CDATA[
+        case movie_project_source
+        when 1 then '<text_tag>自制</text_tag>'
+        when 2 then '<text_tag>引入</text_tag>'
+        end as movie_project_source
+        ]]>
+        from deepthink.all_moive
+        where project_ad_date >= DATE_SUB(CURRENT_DATE(), INTERVAL 6 DAY)
+        and movie_project_source in (1, 2)
+        group by  video_project_name, project_ad_date, movie_project_source
+        order by project_ad_date desc
+    </select>
 </mapper>

job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/DateReportsPushServiceImpl.java

@@ -34,7 +34,7 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
     @Autowired
     ReportsAdPushMapper reportsPushMapper;
 
-    private static final String TEMPLATE_VERSION = "1.0.22";
+    private static final String TEMPLATE_VERSION = "1.0.25";
     private static final String TEMPLATE_ID = "AAqRhJzMBoO0E";
 
     /**
@@ -85,10 +85,10 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
     public void preSend() {
         List<String> userIds = Arrays.asList(
                 "HR-00446" //zhaotx
-                ,"HR-00447" //yumeng
-                ,"HR-00433"  //xsq
-                ,"HR-00459" //angaoqi
-                ,"HR-00439" //huangpingkang
+//                ,"HR-00447" //yumeng
+//                ,"HR-00433"  //xsq
+//                ,"HR-00459" //angaoqi
+//                ,"HR-00439" //huangpingkang
         );
         List<String> chatid = Arrays.asList(
         );
@@ -218,7 +218,7 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
         template_variable.put("table_raw_array_2", movieRankTable);
         template_variable.put("deptRank", deptRank);
         template_variable.put("description", description);
-
+        template_variable.put("table_raw_array_3", reportsPushMapper.publishUpMovieList());
 
         for (String userId : userIds) {
             sendToFeishu(token, template_variable, userId);