| | |
| | | package com.ycl.controller.platformApi; |
| | | |
| | | import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
| | | import com.ycl.annotation.LogSave; |
| | | import com.ycl.api.CommonResult; |
| | | import com.ycl.dto.video.AlarmParam; |
| | | import com.ycl.enums.common.ResultCode; |
| | |
| | | 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; |
| | |
| | | import java.net.HttpURLConnection; |
| | | import java.net.URL; |
| | | import java.util.Base64; |
| | | import java.util.Dictionary; |
| | | import java.util.Hashtable; |
| | | |
| | | /** |
| | | * @author admin |
| | |
| | | @RequestMapping("/API") |
| | | public class AlarmController { |
| | | private IVideoAlarmReportService videoAlarmReportService; |
| | | |
| | | private static Dictionary<String, Integer> sessionDic = new Hashtable<>(); |
| | | |
| | | @Autowired |
| | | private VideoUtil videoUtil; |
| | |
| | | |
| | | @ApiOperation("视频报警推送API") |
| | | @PostMapping("/AlarmReport") |
| | | @LogSave(operationType = "报警管理", contain = "视频报警推送") |
| | | public CommonResult alarmReport(@RequestBody @Validated AlarmParam alarmParam) { |
| | | videoAlarmReportService.save(alarmParam); |
| | | return new CommonResult(ResultCode.SUCCESS.getCode(), ResultCode.SUCCESS.getMessage()); |
| | |
| | | @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) { |
| | | public byte[] getImages(HttpServletRequest request, HttpServletResponse response, |
| | | @RequestParam String fileUrl, @RequestParam(required = false) String OSSAccessKeyId, |
| | | @RequestParam(required = false) 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, String sessionId) { |
| | | int index = sessionDic.get(sessionId); |
| | | try { |
| | | if (sessionDic.get(sessionId) < 10) { |
| | | sessionDic.remove(sessionId); |
| | | fileUrl = fileUrl.replace("Expires","v"); |
| | | System.out.println("getImages获取图片地址:" + fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature); |
| | | URL url = new URL(fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature); |
| | | HttpURLConnection conn = (HttpURLConnection) url.openConnection(); |
| | | conn.setRequestMethod("GET"); |
| | | conn.setConnectTimeout(10 * 1000); |
| | | conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)"); |
| | | |
| | | System.out.println("getImages获取图片地址:" + fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature); |
| | | URL url = new URL(fileUrl + "&OSSAccessKeyId=" + OSSAccessKeyId + "&Signature=" + Signature); |
| | | HttpURLConnection conn = (HttpURLConnection) url.openConnection(); |
| | | conn.setRequestMethod("GET"); |
| | | conn.setConnectTimeout(10 * 1000); |
| | | conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)"); |
| | | InputStream inputStream = conn.getInputStream();// 通过输入流获取图片数据 |
| | | |
| | | InputStream inputStream = conn.getInputStream();// 通过输入流获取图片数据 |
| | | byte[] data = readInputStream(inputStream); |
| | | System.out.println("getImages获取图片成功"); |
| | | |
| | | |
| | | byte[] data = readInputStream(inputStream); |
| | | System.out.println("getImages获取图片成功"); |
| | | |
| | | |
| | | System.out.println("getImages -图片64"); |
| | | System.out.println(Base64.getEncoder().encodeToString(data)); |
| | | return data; |
| | | |
| | | return data; |
| | | } |
| | | } catch (Exception e) { |
| | | System.out.println("getImages获取图片失败:" + e.getMessage()); |
| | | // e.printStackTrace(); |
| | | index++; |
| | | sessionDic.put(sessionId, index); |
| | | System.out.println(index + "-getImages获取图片失败:" + e.getMessage()); |
| | | e.printStackTrace(); |
| | | getBytes(fileUrl, OSSAccessKeyId, Signature, sessionId); |
| | | |
| | | } |
| | | return null; |
| | | } |