package com.cloud.retrieve.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.model.common.Result;
|
import com.cloud.retrieve.service.AnalyDevService;
|
import com.cloud.retrieve.utils.EnumStr;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.MediaType;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.text.ParseException;
|
import java.util.Map;
|
|
/**
|
* 查看大图 查看视频
|
*/
|
@Slf4j
|
@Api(value = "EsDataBaseController",description = " 查看大图 查看视频")
|
@RestController
|
@RequestMapping("/data/api-r/dev")
|
public class DevInfoController {
|
|
@Autowired
|
private AnalyDevService analyDevService;
|
@Autowired
|
private EnumStr enumStr;
|
|
@ApiOperation(value = "getBigPic",notes =
|
"查看大图 {\"videoNum\":\"DS-2CD2T46WDA2-I20180622AACHC30488278\",\"picDate\":\"2019-02-12 06:59:52:505\"," +
|
"\"videoIp\":\"192.168.1.182\",\"indeviceid\":\"DSVAD010120181115\",\"imgKey\":\"DS-2CD2T46WDA2-I20180622AACHC30488278$2019-02-12-06-59-52_22803272\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("/getBigPic")
|
public Result getBigPic(@RequestBody Map reqMap, HttpServletRequest req) throws ParseException {
|
String videoNum = (String) reqMap.get("videoNum");
|
String picDate = (String) reqMap.get("picDate");
|
String videoIp = (String) reqMap.get("videoIp");
|
String imgKey = (String) reqMap.get("imgKey");
|
Object indeviceid = reqMap.get("indeviceid");
|
if (videoNum == null ||videoNum.isEmpty()|| picDate == null|| picDate.isEmpty()||
|
((videoIp == null|| videoIp.isEmpty() ))){
|
throw new RuntimeException("查看大图参数 videoNum:"+videoNum+"，picDate:"+picDate+
|
"，videoIp："+videoIp+"为空。");
|
}
|
log.info("查看大图参数videoNum:"+videoNum+"，picDate:"+picDate+
|
"，videoIp："+videoIp+"indeviceid："+indeviceid+"imgKey:"+imgKey);
|
JSONObject respView = analyDevService.getBigPic(videoNum,picDate,videoIp,indeviceid != null?indeviceid.toString():null,imgKey);
|
if ( respView.getString("img_url")!= null){
|
String file_path = respView.getString("img_url");
|
file_path = enumStr.getHttpImgUrl() +":"+enumStr.getHttpImgPort()+"/"+file_path; // 80 44280
|
log.info("查看大图;file_path:"+file_path);
|
respView.put("imgurl",file_path);
|
return Result.ok("查看大图成功。",respView);
|
}else {
|
return Result.error(new RuntimeException(respView.getString("error")));
|
}
|
}
|
|
@ApiOperation(value = "getVideoByCServer",notes =
|
"查看视频{\"videoNum\":\"DS-2CD2T46WDA2-I20180622AACHC30488278\",\"picDate\":\"2019-02-12 06:59:52:505\"," +
|
"\"videoIp\":\"192.168.1.182\",\"indeviceid\":\"DSVAD010120181115\",\"imgKey\":\"DS-2CD2T46WDA2-I20180622AACHC30488278$2019-02-12-06-59-52_22803272\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("/getVideoByCServer")
|
public Result getUploadRtnVideo(@RequestBody Map reqMap, HttpServletRequest req) throws ParseException {
|
String videoNum = (String) reqMap.get("videoNum");
|
String picDate = (String) reqMap.get("picDate");
|
String videoIp = (String) reqMap.get("videoIp");
|
String imgKey = (String) reqMap.get("imgKey");
|
String indeviceid = (String) reqMap.get("indeviceid");
|
if (videoNum == null ||videoNum.isEmpty()|| picDate == null|| picDate.isEmpty()||
|
((videoIp == null|| videoIp.isEmpty() )&&( indeviceid == null||indeviceid.isEmpty() ))){
|
throw new RuntimeException("查看视频参数 videoNum:"+videoNum+"，picDate:"+picDate+
|
"，videoIp："+videoIp+"indeviceid："+indeviceid+"为空。");
|
}
|
log.info("查看视频参数videoNum:"+videoNum+"，picDate:"+picDate+
|
"，videoIp："+videoIp+"indeviceid："+indeviceid);
|
JSONObject respView = analyDevService.getVideo(videoNum,picDate,videoIp,indeviceid,imgKey);
|
if ( respView.getString("file_path")!= null && respView.getString("file_path").contains("/cut")){
|
String file_path = respView.getString("file_path");
|
log.info("c返回数据："+file_path);
|
// String netPath = req.getScheme()+"://"+req.getServerName() /*"http://"+PropUtils.getProperty("cserver_web_host")*/ // req.getServerName()
|
// + respView.getString("filepath");; // nginxHttpPort
|
// respView.put("filepath",netPath);
|
// log.info("返回页面数据："+netPath);
|
// log.info("视频地址："+file_path);
|
return Result.ok("查看视频成功。",respView);
|
}else {
|
return Result.error(new RuntimeException(respView.getString("error")));
|
}
|
}
|
|
|
@ApiOperation(value = "getDevSnapshot",notes =
|
"获取实时流截图{\"devId\":\"DS-2CD2T46WDA2-I20180622AACHC30488278\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("/getDevSnapshot")
|
public Result getDevSnapshot(@RequestBody Map reqMap, HttpServletRequest req) throws ParseException {
|
String devId = (String) reqMap.get("devId");
|
if (StringUtils.isBlank(devId)){
|
throw new RuntimeException("获取实时流截图 devId:"+devId+"为空。");
|
}
|
log.info("获取实时流截图 devId:"+devId);
|
Result respView = analyDevService.getDevSnapshot(devId);
|
return respView;
|
}
|
}
|
