http请求修改

hazard-admin/src/main/java/com/ozs/web/core/util/CameraUtil.java

@@ -46,6 +46,7 @@ import com.jcraft.jsch.Session;
 import com.ozs.common.utils.HttpClientUtil;
 import com.ozs.service.entity.*;
 import com.ozs.service.service.*;
+import okhttp3.Response;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -545,19 +546,24 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
      * @return
      */
     public static String getRecordUrl(String cameraCode, String channel, Date startTm, Date endTm) {
-        String result = null;
-        log.info(bakUrl + "/gb28181/api/invite?id=" + cameraCode + "&channel=" + channel + "&startTime=" + startTm.getTime() / 1000 + "&endTime=" + endTm.getTime() / 1000);
-        String url = bakUrl + "/gb28181/api/invite?id=" + cameraCode + "&channel=" + channel + "&startTime=" + startTm.getTime() / 1000 + "&endTime=" + endTm.getTime() / 1000;
+        log.info(bakUrl + "/gb28181/api/invite?id=" + cameraCode + "&channel=" + channel + "&startTime=" + startTm.getTime()/1000 + "&endTime=" + endTm.getTime()/1000);
+        String url = bakUrl + "/gb28181/api/invite?id=" + cameraCode + "&channel=" + channel + "&startTime=" + startTm.getTime()/1000 + "&endTime=" + endTm.getTime()/1000;
         try {
-            result = HttpClientUtil.get(url);
-            log.info("-----getRecordUrl-----" + result);
-            if (result.equals("200")) {
-                String path = apiSummary(cameraCode + "/" + channel + "/" + startTm.getTime() / 1000 + "-" + endTm.getTime() / 1000);
-                if (StringUtils.isNotEmpty(path)) {
-                    return path;
-                } else {
-                    return "当前相机暂无回放视频";
+            Response response = HttpClientUtil.get(url);
+            if (response != null) {
+                log.info("-----getRecordUrl----code-" + response.code());
+                log.info("-----getRecordUrl----message--" + cameraCode + "---" + response.message());
+                log.info("-----getRecordUrl----body--" + cameraCode + "---" + response.body());
+                if (response.code() == 200) {
+                    String path = apiSummary(cameraCode + "/" + channel + "/" + startTm.getTime() / 1000 + "-" + endTm.getTime() / 1000);
+                    if (StringUtils.isNotEmpty(path)) {
+                        return path;
+                    } else {
+                        return "当前相机暂无回放视频";
+                    }
                 }
+            }else {
+                return "当前相机暂无回放视频";
             }
         } catch (Exception e) {
             log.info(e.getMessage());

hazard-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

@@ -27,6 +27,7 @@ import com.ozs.vo.ReqMsgAlarmVo;
 import com.ozs.vo.RespGeoHazardMonitorVo;
 import com.ozs.vo.RespMsgAlarmVo;
 import lombok.extern.slf4j.Slf4j;
+import okhttp3.Response;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -385,23 +386,29 @@ public class GeoHazardMonitorTokenController {
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
         }
-        String result;
         String url = bakUrl + "/gb28181/api/invite?id=" + cameraCode + "&channel=" + channel + "&startTime=" + seconds + "&endTime=" + second;
         try {
-            result = HttpClientUtil.get(url);
-            if ("200".equals(result)) {
-                String path = apiSummary(cameraCode + "/" + channel + "/" + seconds + "-" + second);
-                if (org.apache.commons.lang3.StringUtils.isNotEmpty(path)) {
-                    String codes = HttpUtils.sendGet(startRecording(cameraCode + "/" + channel + "/" + seconds + "-" + second));
-                    log.info("codes------>" + codes);
-                    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-                    // 使用SimpleDateFormat将Date对象格式化为指定样式的字符串
-                    String formattedDate = sdf.format(alarmDate);
-                    log.info("-----formattedDate-----------" + formattedDate);
-                    String records = getQueryRecords(cameraCode + "/" + channel + "/" + seconds + "-" + second, formattedDate, "mp4");
-                    log.info("-----records-----------" + records);
-                    return records;
+            Response response = HttpClientUtil.get(url);
+            if (response != null) {
+                log.info("-----alarmHistoryPlay----code--" + cameraCode + "---" + response.code());
+                log.info("-----alarmHistoryPlay----message--" + cameraCode + "---" + response.message());
+                log.info("-----alarmHistoryPlay----body--" + cameraCode + "---" + response.body());
+                if (200 == response.code()) {
+                    String path = apiSummary(cameraCode + "/" + channel + "/" + seconds + "-" + second);
+                    if (org.apache.commons.lang3.StringUtils.isNotEmpty(path)) {
+                        String codes = HttpUtils.sendGet(startRecording(cameraCode + "/" + channel + "/" + seconds + "-" + second));
+                        log.info("codes------>" + codes);
+                        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+                        // 使用SimpleDateFormat将Date对象格式化为指定样式的字符串
+                        String formattedDate = sdf.format(alarmDate);
+                        log.info("-----formattedDate-----------" + formattedDate);
+                        String records = getQueryRecords(cameraCode + "/" + channel + "/" + seconds + "-" + second, formattedDate, "mp4");
+                        log.info("-----records-----------" + records);
+                        return records;
+                    }
                 }
+            }else {
+                return null;
             }
         } catch (Exception e) {
             log.info(e.getMessage());