Преглед изворни кода

Merge branch 'dev' of http://git.xayunmei.com/SH-Arbitrate/Arbitrate-Backend into qtz5

qitz пре 2 година
родитељ
комит
ff175c98df

+ 1
- 1
ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/CaseApplicationServiceImpl.java Прегледај датотеку

3704
         // 查询最大房间号
3704
         // 查询最大房间号
3705
         Long maxRoomId = caseApplicationMapper.selectMaxRoomId();
3705
         Long maxRoomId = caseApplicationMapper.selectMaxRoomId();
3706
 
3706
 
3707
-        if (null == maxRoomId || maxRoomId > 4294967294L) {
3707
+        if (null == maxRoomId || maxRoomId > 4294967294L/2) {
3708
             return 1L;
3708
             return 1L;
3709
         } else {
3709
         } else {
3710
             return maxRoomId + 1;
3710
             return maxRoomId + 1;

+ 17
- 3
ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/VideoServiceImpl.java Прегледај датотеку

3
 import cn.hutool.core.collection.CollectionUtil;
3
 import cn.hutool.core.collection.CollectionUtil;
4
 import cn.hutool.core.util.StrUtil;
4
 import cn.hutool.core.util.StrUtil;
5
 import cn.hutool.http.HttpUtil;
5
 import cn.hutool.http.HttpUtil;
6
+import cn.hutool.json.JSONUtil;
6
 import com.alibaba.fastjson.JSON;
7
 import com.alibaba.fastjson.JSON;
7
 import com.alibaba.fastjson.JSONArray;
8
 import com.alibaba.fastjson.JSONArray;
8
 import com.alibaba.fastjson.JSONObject;
9
 import com.alibaba.fastjson.JSONObject;
118
             Integer eventType = jsonObject.getInteger("EventType"); // 事件类型
119
             Integer eventType = jsonObject.getInteger("EventType"); // 事件类型
119
             String eventInfo = jsonObject.getString("EventInfo"); // 事件信息
120
             String eventInfo = jsonObject.getString("EventInfo"); // 事件信息
120
             JSONObject jsonObject1 = (JSONObject) JSON.parse(eventInfo);
121
             JSONObject jsonObject1 = (JSONObject) JSON.parse(eventInfo);
121
-        String roomId = jsonObject1.getString("RoomId");
122
-        String taskId = jsonObject1.getString("TaskId"); // 任务ID
122
+           String roomId = jsonObject1.getString("RoomId");
123
+            String taskId = jsonObject1.getString("TaskId"); // 任务ID
123
             String payload = jsonObject1.getString("Payload"); // 根据不同事件类型定义不同
124
             String payload = jsonObject1.getString("Payload"); // 根据不同事件类型定义不同
124
             JSONObject jsonObject2 = (JSONObject) JSON.parse(payload);
125
             JSONObject jsonObject2 = (JSONObject) JSON.parse(payload);
125
             String tencentVod = jsonObject2.getString("TencentVod"); // 点播平台信息
126
             String tencentVod = jsonObject2.getString("TencentVod"); // 点播平台信息
134
                 String mediaId = jsonObject3.getString("MediaId");
135
                 String mediaId = jsonObject3.getString("MediaId");
135
                 // 建立相关的数据库用来存储音视频录制地址并和相关的业务ID绑定,用于后续下载
136
                 // 建立相关的数据库用来存储音视频录制地址并和相关的业务ID绑定,用于后续下载
136
                 try {
137
                 try {
137
-                    downloadImage(fileId,videoUrl,roomId);
138
+                    // 调解系统roomId>4294967294L/2
139
+                    if(StrUtil.isNotEmpty(roomId)) {
140
+                        if (Integer.getInteger(roomId) > 4294967294L / 2) {
141
+                            // 调用调解系统
142
+                            cn.hutool.json.JSONObject params = JSONUtil.createObj();
143
+                            params.set("roomId",roomId);
144
+                            params.set("fileId",fileId);
145
+                            params.set("videoUrl",videoUrl);
146
+                            HttpUtil.post("http://172.16.1.14:6001/video/videoRollBack",params.toJSONString(2));
147
+
148
+                        } else {
149
+                            downloadImage(fileId, videoUrl, roomId);
150
+                        }
151
+                    }
138
 
152
 
139
                 } catch (IOException e) {
153
                 } catch (IOException e) {
140
                     throw new RuntimeException(e);
154
                     throw new RuntimeException(e);