From 90599c1af35eb139710e1472d9c2acbab5a8eb07 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期二, 04 四月 2023 11:07:24 +0800
Subject: [PATCH] bug修改

---
 ycl-platform/src/main/java/com/ycl/controller/platformApi/AlarmController.java |   30 +++++++++++++++++++-----------
 1 files changed, 19 insertions(+), 11 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/controller/platformApi/AlarmController.java b/ycl-platform/src/main/java/com/ycl/controller/platformApi/AlarmController.java
index 276ce3a..5abc6b7 100644
--- a/ycl-platform/src/main/java/com/ycl/controller/platformApi/AlarmController.java
+++ b/ycl-platform/src/main/java/com/ycl/controller/platformApi/AlarmController.java
@@ -14,6 +14,7 @@
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
@@ -21,6 +22,8 @@
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.util.Base64;
+import java.util.Dictionary;
+import java.util.Hashtable;
 
 /**
  * @author admin
@@ -31,7 +34,7 @@
 public class AlarmController {
     private IVideoAlarmReportService videoAlarmReportService;
 
-    private static Integer index = 0;
+    private static Dictionary<String, Integer> sessionDic = new Hashtable<>();
 
     @Autowired
     private VideoUtil videoUtil;
@@ -68,17 +71,19 @@
     @GetMapping(value = "/img", produces = {MediaType.IMAGE_JPEG_VALUE, MediaType.IMAGE_PNG_VALUE})
 //    @GetMapping(value = "/img")
     @ResponseBody
-    public byte[] getImages(HttpServletResponse response, @RequestParam String fileUrl, @RequestParam String OSSAccessKeyId, @RequestParam String Signature) {
-
-        index = 0;
-        return getBytes(fileUrl, OSSAccessKeyId, Signature);
+    public byte[] getImages(HttpServletRequest request, HttpServletResponse response,
+                            @RequestParam String fileUrl, @RequestParam String OSSAccessKeyId, @RequestParam String Signature) {
+        String sessionId = request.getSession().getId();
+        sessionDic.put(sessionId, 0);
+        return getBytes(fileUrl, OSSAccessKeyId, Signature, sessionId);
 
     }
 
-    private byte[] getBytes(String fileUrl, String OSSAccessKeyId, String Signature) {
+    private byte[] getBytes(String fileUrl, String OSSAccessKeyId, String Signature, String sessionId) {
+        int index = sessionDic.get(sessionId);
         try {
-            if (index < 10) {
-                index++;
+            if (sessionDic.get(sessionId) < 10) {
+                sessionDic.remove(sessionId);
                 System.out.println("getImages鑾峰彇鍥剧墖鍦板潃锛�" + fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature);
                 URL url = new URL(fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature);
                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
@@ -94,9 +99,12 @@
                 return data;
             }
         } catch (Exception e) {
-            System.out.println(index + "getImages鑾峰彇鍥剧墖澶辫触锛�" + e.getMessage());
-            getBytes(fileUrl, OSSAccessKeyId, Signature);
-            // e.printStackTrace();
+            index++;
+            sessionDic.put(sessionId, index);
+            System.out.println(index + "-getImages鑾峰彇鍥剧墖澶辫触锛�" + e.getMessage());
+            e.printStackTrace();
+            getBytes(fileUrl, OSSAccessKeyId, Signature, sessionId);
+
         }
         return null;
     }

--
Gitblit v1.8.0