package com.cloud.retrieve.controller;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.model.common.Result;
|
import com.cloud.retrieve.model.EsDataQueryParam;
|
import com.cloud.retrieve.service.EsDataService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
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 java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.Map;
|
|
@Slf4j
|
@RestController
|
@Api(value = "EsDataBaseController",description = "es数据查询")
|
@RequestMapping("/data/api-r/es")
|
public class EsDataController {
|
|
@Autowired
|
private EsDataService esDataService;
|
private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
|
|
@ApiOperation(value = "findEsData",notes = "查询es检索数据",httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("findEsData")
|
public Result findEsData(@RequestBody EsDataQueryParam esSearch){
|
// log.info(sdf.format(new Date())+"查询es检索数据前");
|
JSONObject allDataByMoreParams = esDataService.getAllDataByMoreParams(esSearch);
|
// log.info(sdf.format(new Date())+"查询es检索数据返回");
|
return Result.ok("查询es检索数据成功。",allDataByMoreParams);
|
}
|
|
@ApiOperation(value = "updateEsToAlarm",notes = "修改为已确认报警 {\"id\":\"dc6e4b7b-08ad-4ba2-b1f0-4bbc5ace7c43\",\"ack_alarm\":\"1\"}",httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("updateEsToAlarm")
|
public Result updateEsToAlarm(@RequestBody Map reqMap){
|
String dataId = (String) reqMap.get("id");
|
String ack_alarm = (String) reqMap.get("ack_alarm");
|
if (dataId == null || dataId.isEmpty() || ack_alarm == null || ack_alarm .isEmpty()){
|
throw new RuntimeException("dataId或ack_alarm 参数为空"+dataId+ack_alarm);
|
}
|
log.info(sdf.format(new Date())+"修改为已确认前");
|
JSONObject respupdate = esDataService.updateEsDataByEsId(dataId,ack_alarm);
|
log.info(sdf.format(new Date())+"修改为已确认后");
|
if (respupdate.getBoolean("success")){
|
return Result.ok("修改为已确认报警成功。",respupdate);
|
}else {
|
return Result.error(new RuntimeException("操作过于频繁，报警确认失败，请稍后再试。"));
|
}
|
}
|
|
@ApiOperation(value = "cameraRecord",notes = "地图某摄像机报警记录或抓拍分页数据 " +
|
"{\"videoReqNum\":\"d820807a-5b83-4321-9b43-e0129102a9ff\",\"page\":1,\"size\":6,\"personIsHub\":\"\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("cameraRecord")
|
public Result findEsAlarmDataByEquPage(@RequestBody Map reqMap){
|
Integer page = (Integer) reqMap.get("page");
|
Integer size = (Integer) reqMap.get("size");
|
String equId = (String) reqMap.get("videoReqNum");
|
String personIsHub = (String) reqMap.get("personIsHub"); //
|
if (page == null || size == null ){
|
page = 1;size = 8;
|
}
|
// log.info("某摄像机报警记录查询参数page:"+page+"size:"+size+"equId:"+equId);
|
JSONObject respupdate = esDataService.findEsPersonAlarmDataByEquPage(page,size,equId,personIsHub);
|
return Result.ok("设备记录查询成功。",respupdate);
|
}
|
|
@ApiOperation(value = "alarmRecord",notes = "地图全部报警记录分页数据 {\"page\":1,\"size\":8}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("alarmRecord")
|
public Result findEsAllAlarmDataByPage(@RequestBody Map reqMap) throws ParseException {
|
Integer page = (Integer) reqMap.get("page");
|
Integer size = (Integer) reqMap.get("size");
|
Date startDate = reqMap.get("startDate")== null?null:sdf.parse(reqMap.get("startDate").toString());
|
Date endDate = reqMap.get("endDate")== null?null:sdf.parse(reqMap.get("endDate").toString());
|
if (page == null || size == null ){
|
page = 1;size = 6;
|
}
|
log.info("某摄像机报警记录查询参数page:"+page+"size:"+size);
|
JSONObject respView = esDataService.findEsAllAlarmDataByPage(page,size,startDate,endDate);
|
return Result.ok("全部报警记录查询成功。",respView);
|
}
|
|
|
@ApiOperation(value = "personDetail",notes =
|
"单人报警记录详情{\"id\":\"d820807a-5b83-4321-9b43-e0129102a9ff\",\"personId\":\"psv\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("personDetail")
|
public Result findEsDataByPerson(@RequestBody Map reqMap){
|
String id = (String) reqMap.get("id");
|
String personId = (String) reqMap.get("personId");
|
if (id == null ||id.isEmpty()|| personId == null|| personId.isEmpty()){
|
throw new RuntimeException("数据id，人员personId:"+id+personId+"为空。");
|
}
|
log.info("单人报警记录详情查询参数id:"+id+"personId:"+personId);
|
JSONObject respView = esDataService.getPersonDetail(id,personId);
|
return Result.ok("全部报警记录查询成功。",respView);
|
}
|
|
@ApiOperation(value = "accompanyPerson",notes =
|
"随行人员查询 {\"videoReqNum\":\"reqNum\",\"picDate\":\"2019-01-03 12:12:12\",\"personId\":\"perId\",\"Id\":\"Id\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("accompanyPerson")
|
public Result accompanyPerson(@RequestBody Map reqMap) throws ParseException {
|
String videoReqNum = (String) reqMap.get("videoReqNum");
|
String picDate = (String) reqMap.get("picDate");
|
String personId = (String) reqMap.get("personId");
|
String id = (String) reqMap.get("Id");
|
if (videoReqNum == null ||videoReqNum.isEmpty()|| picDate == null|| picDate.isEmpty()||
|
((personId == null || personId.isEmpty())&&(id == null || id.isEmpty()))){
|
throw new RuntimeException("随行人员查询 videoReqNum，picDate:"+videoReqNum+picDate+"personId:"+personId+"为空。");
|
}
|
log.info("随行人员查询参数videoReqNum:"+videoReqNum+"picDate:"+picDate);
|
JSONObject respView = esDataService.getAccompanyPerson(videoReqNum,personId,picDate,id);
|
return Result.ok("随行人员记录查询成功。",respView);
|
}
|
|
@ApiOperation(value = "getPersonnLocus",notes =
|
"人员轨迹查询 {\"personId\":\"PSVAD010120181215175357774\"," +
|
"\"startDate\":\"2018-12-01\",\"endDate\":\"2018-12-31\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("getPersonnLocus")
|
public Result getPersonnLocus(@RequestBody Map reqMap) throws ParseException {
|
String personId = (String) reqMap.get("personId");
|
String startDate = (String) reqMap.get("startDate");
|
String endDate = (String) reqMap.get("endDate");
|
if (personId == null ||personId.isEmpty()|| startDate == null|| startDate.isEmpty()|| endDate == null|| endDate.isEmpty()){
|
throw new RuntimeException("人员轨迹查询参数 personId，startDate:"+personId+startDate+"endDate"+endDate+"为空。");
|
}
|
log.info("人员轨迹查询参数personId:"+personId+"startDate:"+startDate+startDate+"endDate:"+endDate);
|
JSONObject respView = esDataService.getPersonnLocus(personId,startDate,endDate);
|
return Result.ok("人员轨迹查询成功。",respView);
|
}
|
|
@ApiOperation(value = "getPersonnLocusByJni",notes =
|
"人员轨迹查询 {\"picId\":\"PSVAD010120181215175357.jpg\"}",
|
httpMethod = "POST",produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
|
@RequestMapping("getPersonnLocusByJni")
|
public Result getPersonnLocusByJni(@RequestBody Map reqMap) throws ParseException {
|
String picId = (String) reqMap.get("picId");
|
if (picId == null ||picId.isEmpty()){
|
throw new RuntimeException("人员轨迹查询参数 picId:"+picId+"为空。");
|
}
|
log.info("人员轨迹查询参数picId:"+picId);
|
JSONObject respView = esDataService.getPersonnLocusByRedis(picId);
|
return Result.ok("人员轨迹查询成功。",respView);
|
}
|
|
}
|
