短剧业务概况支持拉群（暂时不用）

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

@@ -42,7 +42,7 @@
     </select>
     <select id="tmpTopMovie" resultType="java.util.Map">
         select  case ot1.movie_source when 2 then movie_name else concat('欢瑞自制-', movie_name) end as movie_name,
-        ot1.rk, ot1.end_amount,  ot2.cost_amount, ot2.real_cost_amount,
+        ot1.rk, ot1.share_end_amount, ot1.end_amount,  ot2.cost_amount, ot2.real_cost_amount,
         concat(round(if(ifnull(cost_amount,0)=0, 0, end_amount/cost_amount*100), 2), '%') AS water_roi,
         concat(round(if(ifnull(real_cost_amount,0)=0, 0, share_end_amount/real_cost_amount*100), 2), '%') AS real_roi
         FROM

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

@@ -107,7 +107,7 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
             JSONObject obj = new JSONObject();
             obj.put("rank", String.valueOf(movie.get("rk")));
             obj.put("movieName", String.valueOf(movie.get("movie_name")));
-            obj.put("endAmount", String.valueOf(movie.get("end_amount")));
+            obj.put("endAmount", String.valueOf(movie.get("share_end_amount")));
             obj.put("realROI", String.valueOf(movie.get("real_roi")));
             movieRankTable.add(obj);
         }
@@ -144,6 +144,13 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
         for (String userId : userIds) {
             sendToFeishu(token, template_variable, userId);
         }
+
+//        List<String> chatid = Arrays.asList(
+////                "oc_275f17aa4bf8fae649ef281a2b9250f6"
+//        );
+//        for (String chat : chatid) {
+//            sendToChatGroup(token, template_variable, chat);
+//        }
     }
 
     private void sendToFeishu(String token, JSONObject template_variable, String receive_id) {
@@ -172,4 +179,31 @@ public class DateReportsPushServiceImpl implements IDateReportsPushService {
             log.error("发送飞书消息失败", e);
         }
     }
+
+    private void sendToChatGroup(String token, JSONObject template_variable, String chatid) {
+        JSONObject content = new JSONObject();
+        JSONObject contentData = new JSONObject();
+        contentData.put("template_id",TEMPLATE_ID);
+        contentData.put("template_version_name", TEMPLATE_VERSION);
+        contentData.put("template_variable", template_variable);
+        content.put("type", "template");
+        content.put("data", contentData);
+
+        JSONObject request = new JSONObject();
+        request.put("receive_id", chatid);
+        request.put("msg_type", "interactive");
+        request.put("content", content.toJSONString());
+        //发送
+        try (CloseableHttpClient client = HttpClients.createDefault()){
+            HttpPost httpPost = new HttpPost("https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=chat_id");
+            httpPost.setHeader("Authorization", "Bearer "+token);
+            HttpEntity entity = new StringEntity(request.toJSONString(), "UTF-8");
+            httpPost.setEntity(entity);
+            httpPost.setHeader("Content-Type", "application/json; charset=utf-8");
+            CloseableHttpResponse respon = client.execute(httpPost);
+            System.out.println("发送结果: "+ EntityUtils.toString(respon.getEntity(), "UTF-8"));
+        }catch (IOException e){
+            log.error("发送飞书消息失败", e);
+        }
+    }
 }