From f95968f0465e2332eea578785822c51719e9e10f Mon Sep 17 00:00:00 2001
From: zqy <2522236926@qq.com>
Date: 星期四, 08 八月 2024 11:19:17 +0800
Subject: [PATCH] 修改直播,分享bug

---
 zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java |   25 ++++++++++++++++++++++++-
 1 files changed, 24 insertions(+), 1 deletions(-)

diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java
index 972349f..db59d66 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/LiveStreamingServiceImpl.java
@@ -17,6 +17,8 @@
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 @Slf4j
@@ -77,6 +79,9 @@
 //        List<LiveStreaming> dtoResult = markOwnData(familyId, beanRecords);
 
         HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords);
+
+
+
         return AjaxResult.success(data);
 
     }
@@ -92,8 +97,19 @@
         return list;
     }
 
+    private Date getEndTime1(LiveStreaming liveStreaming) throws ParseException{
+        System.out.println(liveStreaming.getStartTime());
+        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Calendar nowTime = Calendar.getInstance();
+        nowTime.setTime(liveStreaming.getStartTime());
+        nowTime.add(Calendar.MINUTE, liveStreaming.getDuration());
+        String currentTime = df.format(nowTime.getTime());
+        System.out.println("30鍒嗛挓鍚庣殑鏃堕棿" + currentTime);
+        return df.parse(currentTime);
+    }
+
     @Override
-    public AjaxResult addData(LiveStreaming liveStreaming) {
+    public AjaxResult addData(LiveStreaming liveStreaming) throws ParseException {
         LambdaQueryWrapper<LiveStreaming> lqw = uniqueCondition(liveStreaming);
         List<LiveStreaming> list = list(lqw);
 
@@ -103,6 +119,8 @@
         if (liveStreaming.getMaxPerson() > 120){
             throw new RuntimeException("鍙绾充汉鏁版殏鏃舵渶澶氫负120浜�");
         }
+
+        liveStreaming.setEndTime(getEndTime1(liveStreaming));
 
         if (save(liveStreaming)) {
             EsModel esModel = new EsModel();
@@ -114,7 +132,12 @@
             esModel.setBy1(liveStreaming.getTitle());
             esModel.setBy2(liveStreaming.getApplyPerson());
             esModel.setBy3(liveStreaming.getRoomId());
+            //鍙栧綋鍓嶇殑鏃跺垎-30
 
+
+
+            System.out.println(liveStreaming.getEndTime());
+//            esModel.setBy4(liveStreaming.getEndTime());
             //杩欓噷瀛樺偍鏌ヨ璇︽儏鐨勮矾寰�
             esModel.setBy5("/zLiveStreaming");
 //            esModel.setFid(familyId);

--
Gitblit v1.9.1