飞书推送

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

@@ -185,7 +185,16 @@
     <select id="todayTopMovie" resultType="com.alibaba.fastjson.JSONObject" >
         select
         tb4.standard_movie_name as movie_name, tb4.movie_project_source, tb6.dict_name as movie_project_source_name,
-        group_concat(distinct case tb4.movie_source when 2 then '2' else '1' end) as movie_source,
+        case
+        when (DATEDIFF(STR_TO_DATE(tb1.stat_date, '%Y%m%d'), STR_TO_DATE(tb4.project_ad_date, '%Y%m%d')) + 1) between 1
+        and 3 then '新剧1阶'
+        when (DATEDIFF(STR_TO_DATE(tb1.stat_date, '%Y%m%d'), STR_TO_DATE(tb4.project_ad_date, '%Y%m%d')) + 1) between 4
+        and 7 then '新剧2阶'
+        when (DATEDIFF(STR_TO_DATE(tb1.stat_date, '%Y%m%d'), STR_TO_DATE(tb4.project_ad_date, '%Y%m%d')) + 1) between 8
+        and 15 then '次新剧'
+        when (DATEDIFF(STR_TO_DATE(tb1.stat_date, '%Y%m%d'), STR_TO_DATE(tb4.project_ad_date, '%Y%m%d')) + 1) >=15 then
+        '老剧'
+        else 999 end as project_ad_step,
         <include refid="endAmount"/>,
         <include refid="waterEndAmount"/>,
         <include refid="costAmount"/>,
@@ -196,8 +205,8 @@
         <include refid="shareIaaAmount3"/>,
         round(ifnull(sum(hour_cost_amount), 0), 2) as hour_cost_amount
         from
-        (select movie_id from application.media_ad_report_daily where stat_date=${date} and ma_appid in (select app_id from tidb.deepthink.mini_app_info where business_type not in (2,4,6))
-        union select movie_id from application.user_data_report_daily where stat_date=${date} and ma_appid in (select app_id from tidb.deepthink.mini_app_info where business_type not in (2,4,6))) tb1
+        (select ${date} as stat_date, movie_id from application.media_ad_report_daily where stat_date=${date} and ma_appid in (select app_id from tidb.deepthink.mini_app_info where business_type not in (2,4,6))
+        union select ${date} as stat_date, movie_id from application.user_data_report_daily where stat_date=${date} and ma_appid in (select app_id from tidb.deepthink.mini_app_info where business_type not in (2,4,6))) tb1
         left join
         (
         select movie_id, sum(iaa_cost_amount) as iaa_cost_amount, sum(iaa_real_cost_amount) as iaa_real_cost_amount,
@@ -223,7 +232,7 @@
         group by movie_id
         ) tb3 on tb1.movie_id=tb3.movie_id
         left join
-        (select moive_id, standard_movie_id, standard_movie_name, movie_source, movie_project_source from tidb.deepthink.all_moive
+        (select moive_id, standard_movie_id, standard_movie_name, movie_source, movie_project_source,project_ad_date from tidb.deepthink.all_moive
         ) tb4 on tb1.movie_id=tb4.moive_id
         left join
         (select movie_id, ifnull(sum(cost_amount), 0) as hour_cost_amount from application.media_ad_report_hourly
@@ -233,7 +242,7 @@
         (select dict_key, dict_name from tidb.deepthink.dt_dictionary where select_key='movie_project_source'
         ) tb6 on tb4.movie_project_source=tb6.dict_key
         where 1=1 and tb1.movie_id != '-9999'
-        group by tb4.standard_movie_name, tb4.movie_project_source, tb6.dict_name
+        group by 1,2,3,4
         order by end_amount desc
         limit 20
     </select>

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

@@ -32,7 +32,7 @@ public class ReportsAdPushServiceImpl implements IReportsAdPushService {
     public static final String APP_KEY = "OUlg7WTa6UWZItfTmJw2JdQvhVI4VcRj";
 
     public static final String TEMPLATE_ID = "AAqBGlVblKabY";
-    public static final String TEMPLATE_VERSION = "1.0.23";
+    public static final String TEMPLATE_VERSION = "1.0.24";
     @Autowired
     ReportsAdPushMapper reportsPushMapper;
 
@@ -139,7 +139,8 @@ public class ReportsAdPushServiceImpl implements IReportsAdPushService {
 //            obj.put("endAmount", m.get("water_end_amount"));
 //            obj.put("movieRealRoi", m.get("real_roi"));
             Double hourCostAmount = m.getDoubleValue("hour_cost_amount");
-            if (hourCostAmount >= 40000){
+            Double dayCostAmount = m.getDoubleValue("cost_amount");
+            if (hourCostAmount >= 30000 || dayCostAmount >=60000){
                 obj.put("movieName", "<font color='red'>"+m.getString("movie_name")+"(起量)</font>");
                 obj.put("hourCostAmount", "<font color='red'>"+hourCostAmount+"</font>");
             }else {
@@ -153,17 +154,11 @@ public class ReportsAdPushServiceImpl implements IReportsAdPushService {
             String iapAmount = String.valueOf(m.get("share_pay_amount"));
             obj.put("iaaRoi", iaaRoi+"\n"+iaaAmount);
             obj.put("iapRoi", iapRoi+"\n"+iapAmount);
-            String movieProjectSource = String.valueOf(m.get("movie_project_source"));
-            String movieProjectSourceName = String.valueOf(m.get("movie_project_source_name"));
-            JSONArray ms = new JSONArray();
-            if (!Check.isNull(movieProjectSource) && movieProjectSource.equals("1")){
-                ms.add(ImmutableMap.of("text", movieProjectSourceName, "color", "grey"));
-            }else if (!Check.isNull(movieProjectSource) && movieProjectSource.equals("2")){
-                ms.add(ImmutableMap.of("text", movieProjectSourceName, "color", "green"));
-            }else {
-                ms.add(ImmutableMap.of("text", movieProjectSourceName, "color", "blue"));
-            }
-            obj.put("movieProjectSource", ms);
+            String movieProjectSource = String.valueOf(m.get("movie_project_source_name"));
+            String projectAdStep = m.getString("project_ad_step");
+            String sb = "<text_tag color='blue'>" + movieProjectSource + "</text_tag>" +
+                    "<text_tag color='green'>" + projectAdStep + "</text_tag>";
+            obj.put("movieProjectSource", sb);
             object_list_2.add(obj);
         }
         template_variables.put("table_raw_array_1", object_list_2);