package com.cloud.device.controller;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.device.constants.Constants;
|
import com.cloud.device.model.Device;
|
import com.cloud.device.model.Dic;
|
import com.cloud.device.service.DeviceService;
|
import com.cloud.device.service.DicService;
|
import com.cloud.device.service.NodeService;
|
import com.cloud.device.vo.MenuTreeVo;
|
import com.cloud.model.common.Page;
|
import com.cloud.model.common.Result;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
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.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.text.ParseException;
|
import java.util.*;
|
|
@Slf4j
|
@Api(value = "DeviceController",description = "设备管理")
|
@RequestMapping(value = "/data/api-d/device")
|
@RestController
|
public class DeviceController {
|
|
@Autowired
|
private DeviceService deviceService;
|
@Autowired
|
private DicService dicService;
|
@Autowired
|
private NodeService nodeService;
|
|
@RequestMapping("/getDeviceType")
|
@ApiOperation(value = "获取设备类型", notes = "获取设备类型", httpMethod = "POST",produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
public Result getDeviceType(){
|
try {
|
Map<String, Object> map = new HashMap<>();
|
map.put("type", Dic.DIC_DEVICE_TYPE);
|
|
return Result.ok(Constants.RESULT_QUERY_OK, dicService.getDicByType(map));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@GetMapping("/getDeviceBrand")
|
@ApiOperation(value = "获取设备品牌", notes = "获取设备品牌", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
public Result getDeviceBrand(){
|
try {
|
Map<String, Object> map = new HashMap<>();
|
map.put("type", Dic.DIC_DEVICE_BRAND);
|
return Result.ok(Constants.RESULT_QUERY_OK, dicService.getDicByType(map));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@GetMapping("/getStatus")
|
@ApiOperation(value = "获取设备状态字典列表", notes = "获取设备状态字典列表", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
public Result getStatusList(){
|
try {
|
Map<String, Object> map = new HashMap<>();
|
map.put("type", Dic.DIC_DEVICE_STATUS);
|
return Result.ok(Constants.RESULT_QUERY_OK, dicService.getDicByType(map));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@GetMapping("/findPlatDeviceList")
|
@ApiOperation(value = "获取平台设备列表(分页)",notes = "获取平台设备列表(分页)",httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name ="param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "start", value = "起始页", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "length", value = "条数", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "orgId", value = "组织机构id", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name ="condition", value = "设备名称/设备id/设备位置", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "type", value = "类型(MENU或其它)", required = true, dataType = "String", paramType = "query")
|
})
|
public Page<Device> findPlatDeviceList(@RequestParam Map<String,Object> param){
|
return deviceService.findPlatDeviceList(param);
|
|
}
|
|
@GetMapping("/findAllPlatDeviceList")
|
@ApiOperation(value = "获取所有非集群监控设备列表(不分页)",notes = "获取所有非集群监控设备列表（不分页）",httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name ="param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "orgId", value = "组织机构id", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name ="condition", value = "设备名称/设备id/设备位置", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "type", value = "类型(MENU或其它)", required = true, dataType = "String", paramType = "query")
|
})
|
public Result findAllPlatDeviceList(@RequestParam Map<String,Object> param){
|
try {
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.findAllPlatDeviceList(param));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "通过区域查找设备", notes = "通过区域查找设备", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "condition", value = "设备名称/设备位置", required = false, dataType = "String", paramType = "query")
|
})
|
@GetMapping("/findByArea")
|
public Result findByArea(@RequestParam Map<String,Object> param){
|
try {
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.findByArea(param));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "通过区域查找设备", notes = "通过区域查找设备", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "condition", value = "设备名称/设备位置", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "orgId", value = "组织机构id", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "type", value = "类型(MENU或其它)", required = true, dataType = "String", paramType = "query")
|
})
|
@GetMapping("/findAllDeviceByArea")
|
public Result findAllDeviceByArea(@RequestParam Map<String, Object> param){
|
try {
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.findAllDeviceByArea(param));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@RequestMapping("/getDeviceById")
|
@ApiOperation(value = "通过id查找设备", notes = "通过id查找设备", httpMethod = "POST", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name="id",value = "设备id", required = true, dataType = "String",paramType = "query")
|
})
|
public Result getDeviceById(@RequestParam String id){
|
try {
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.selectById(id));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
|
}
|
|
@RequestMapping("/getNodeByDeviceId")
|
@ApiOperation(value = "根据摄像机id获取摄像机信息(节点信息)",notes = "根据摄像机id获取摄像机信息（节点信息）",
|
httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "deviceId", value = "摄像机id", required = true, dataType = "String", paramType = "query")
|
})
|
public Result getNodeByDeviceId(@RequestParam String deviceId){
|
try {
|
JSONObject jsonResult = new JSONObject();
|
Device device = deviceService.selectById(deviceId);
|
if(device !=null){
|
jsonResult.put("device", device);
|
if(StringUtils.isNotEmpty(device.getNodeId())){
|
jsonResult.put("node", nodeService.selectById(device.getNodeId()));
|
}
|
}
|
return Result.ok(Constants.RESULT_QUERY_OK, jsonResult);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@RequestMapping("/saveDevice")
|
@ApiOperation(value = "保存设备",notes = "保存设备",httpMethod = "POST", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "device", value = "设备实例", required = true, dataType = "Device", paramType = "body")
|
// @ApiImplicitParam(name = "orgId", value = "所属组织机构id", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "name", value="设备名称", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "type", value = "设备类型(摄像机或PAD或分析的字典值)", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "brand", value = "设备品牌", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "ip", value = "设备ip", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "port", value = "端口", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "username", value = "用户名", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "password", value = "密码", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "address", value = "位置", required = true, dataType = "String", paramType = "query")
|
})
|
public Result saveDevice(@RequestBody Device device){
|
try {
|
//查找此ip是否有重复的设备
|
Device existDevice = deviceService.findByIp(device.getIp());
|
if(existDevice !=null){
|
if(StringUtils.isEmpty(device.getId()) || (StringUtils.isNotEmpty(device.getId()) && !device.getId().equals(existDevice.getId()))){
|
return Result.custom("重复添加摄像机",500,false,"设备ip不允许重复");
|
}
|
}
|
|
|
return Result.ok(Constants.RESULT_SAVE_OK, deviceService.saveDevice(device));
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@GetMapping("/updateOrg")
|
@ApiOperation(value = "更新设备所属组织", notes = "更新设备所属组织", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "设备id",required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "orgId", value = "组织id", required = true, dataType = "Integer", paramType = "query")
|
})
|
public Result updateOrg(String id,Integer orgId){
|
try {
|
log.info("id:"+id+",orgId:"+orgId);
|
if(StringUtils.isNotEmpty(id) && orgId > 0)
|
return Result.ok(Constants.RESULT_SAVE_OK, deviceService.updateOrg(id, orgId));
|
else
|
return Result.custom("更新失败，参数不正确",401,false,"");
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@RequestMapping("/deleteDevice")
|
@ApiOperation(value = "删除设备", notes = "删除设备", httpMethod = "POST", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "id", value = "设备id", required = true, dataType = "String", paramType = "query")
|
})
|
public Result deleteDevice(@RequestParam String id){
|
try {
|
return Result.ok(Constants.RESULT_DELETE_OK, deviceService.deleteById(id));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value="获取设备组织机构树", notes = "获取设备组织机构",httpMethod = "GET",produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "name", value = "名称、模糊查询", required = false, dataType = "String", paramType = "query")
|
})
|
@RequestMapping("/getOrgDeviceTree")
|
private List<MenuTreeVo> getOrgDeviceTree(@RequestParam Map<String, Object> param){
|
try {
|
return deviceService.getOrgDeviceTree(param);
|
} catch (Exception e) {
|
e.printStackTrace();
|
return new ArrayList<>();
|
}
|
}
|
|
@ApiOperation(value = "地图中获取所有设备", notes = "地图中获取所有设备", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@GetMapping("/findAllDevices")
|
public Result findAllDevices(){
|
try {
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.findAllDevices());
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "更新设备经纬度", notes = "更新设备经纬度", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "id", value = "id", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "type", value = "类型", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "longitude", value = "经度", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "latitude", value = "纬度", required = true, dataType = "String", paramType = "query")
|
})
|
@GetMapping("/updatePosById")
|
public Result updatePosById(@RequestParam Map<String,Object> param){
|
try {
|
return Result.ok(Constants.RESULT_SAVE_OK, deviceService.updatePosById(param));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "更新节点公网ip和端口", notes = "更新节点公网ip和端口", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "param", value = "无用参数", required = false, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "id", value = "id", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "publicIp", value = "公网ip", required = true, dataType = "String", paramType = "query"),
|
@ApiImplicitParam(name = "publicPort", value = "公网端口", required = true, dataType = "String", paramType = "query")
|
})
|
@GetMapping("/updatePublicIpPort")
|
public Result updatePublicIpPort(@RequestParam Map<String,Object> param){
|
try {
|
return Result.ok(Constants.RESULT_SAVE_OK, deviceService.updatePublicIpPort(param));
|
} catch (Exception e) {
|
e.printStackTrace();
|
return Result.error(e);
|
}
|
}
|
|
@ApiOperation(value = "通过devId获取节点信息", notes = "通过devId获取节点信息", httpMethod = "GET", produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "devId", value = "devId",required = true,dataType = "String",paramType = "query")
|
})
|
@GetMapping("/getNodeByDevId")
|
public Result getNodeByDevId(@RequestParam String devId){
|
return Result.ok(Constants.RESULT_QUERY_OK, deviceService.getNodeByDevId(devId));
|
}
|
|
@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, IOException {
|
String devId = (String) reqMap.get("devId");
|
if (StringUtils.isBlank(devId)){
|
throw new RuntimeException("获取实时流截图 devId:"+devId+"为空。");
|
}
|
log.info("获取实时流截图 devId:"+devId);
|
JSONObject url = deviceService.getDevSnapshot(devId); // :80/dddd.jpg
|
return Result.ok("获取实时流截图成功。",url);
|
}
|
|
|
// @AuthNoneIgnore
|
// @ApiOperation(value = "测试设备连接", notes = "测试设备连接" ,httpMethod = "GET",produces = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
|
// @ApiImplicitParams({
|
// @ApiImplicitParam(name = "str_brand", value = "品牌",required = true,dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "str_ip", value = "ip", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "n_port", value = "端口", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "str_username", value = "用户名", required = true, dataType = "String", paramType = "query"),
|
// @ApiImplicitParam(name = "str_password", value = "密码", required = true, dataType = "String", paramType = "query")
|
// })
|
// public Result testDeviceConn(@RequestParam Map<String,Object> param){
|
//
|
// return Result.ok(Constants.RESULT_QUERY_OK, deviceService.testDeviceConn(param));
|
// }
|
|
}
|
