package cn.besteam.modules.medical.controller;
|
|
import cn.besteam.common.api.vo.Result;
|
import cn.besteam.common.aspect.annotation.AutoLog;
|
import cn.besteam.common.aspect.annotation.OpenApi;
|
import cn.besteam.common.constant.ErrorCode;
|
import cn.besteam.common.exception.BusinessException;
|
import cn.besteam.modules.medical.biz.MonitorDeviceApiNewService;
|
import cn.besteam.modules.medical.dto.MwDeviceAgentDeviceDTO;
|
import cn.besteam.modules.medical.dto.MwDeviceAgentDeviceSaveDTO;
|
import cn.besteam.modules.medical.entity.MwDeviceAgent;
|
import cn.besteam.modules.medical.entity.MwDeviceAgentDevice;
|
import cn.besteam.modules.medical.service.IMwDeviceAgentDeviceService;
|
import cn.besteam.modules.medical.service.IMwDeviceAgentService;
|
import cn.besteam.modules.medical.vo.MwDeviceAgentDeviceAddBatchVO;
|
import cn.besteam.modules.medical.vo.MwDeviceAgentDeviceExcelVO;
|
import cn.hutool.poi.excel.ExcelUtil;
|
import cn.hutool.poi.excel.ExcelWriter;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import io.swagger.annotations.*;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.ServletOutputStream;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.validation.constraints.Max;
|
import javax.validation.constraints.Min;
|
import javax.validation.constraints.NotNull;
|
import java.io.IOException;
|
import java.io.Serializable;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Title: Controller
|
* @Description: 设备代理商-设备
|
* @author： besteam
|
* @date： 2020-04-25
|
* @version： V1.0
|
*/
|
@RestController
|
@RequestMapping("/medical/mwDeviceAgentDevice")
|
@Slf4j
|
@Api(description = "设备代理商-设备")
|
public class MwDeviceAgentDeviceController {
|
|
@Autowired
|
private IMwDeviceAgentService mwDeviceAgentService;
|
|
@Autowired
|
private IMwDeviceAgentDeviceService mwDeviceAgentDeviceService;
|
/**
|
* 视频设备
|
*/
|
@Autowired
|
private MonitorDeviceApiNewService monitorDeviceApiNewService;
|
|
/**
|
* 分页列表查询
|
*
|
* @param name
|
* @param pageNo
|
* @param pageSize
|
* @return
|
*/
|
@GetMapping(value = "/list")
|
@ApiOperation(value = "获取设备代理商-设备数据列表", notes = "获取所有设备代理商-设备数据列表", produces = "application/json")
|
public Result<IPage<MwDeviceAgentDevice>> queryPageList(String name, @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
|
|
return Result.ok(mwDeviceAgentDeviceService.getDeviceList(name, pageNo, pageSize));
|
}
|
|
@PostMapping("/addBatch")
|
@ApiOperation(value = "批量添加设备", notes = "批量添加设备", produces = "application/json")
|
public Result<MwDeviceAgentDeviceAddBatchVO> addBatch(@RequestBody MwDeviceAgentDeviceSaveDTO dto) {
|
|
MwDeviceAgent mwDeviceAgent = mwDeviceAgentService.getById(dto.getDeviceAgentId());
|
if (mwDeviceAgent == null) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_AGENT_NOT_FOUND);
|
}
|
return Result.ok(mwDeviceAgentDeviceService.addBatch(dto.getDeviceAgentId(), dto.getSns()));
|
}
|
/**
|
* 编辑
|
*
|
* @param mwDeviceAgentDevice
|
* @return
|
*/
|
@PostMapping(value = "/edit")
|
@AutoLog(value = "编辑设备代理商-设备")
|
@ApiOperation(value = "编辑设备代理商-设备", notes = "编辑设备代理商-设备", produces = "application/json")
|
public Result<MwDeviceAgentDevice> edit(@RequestBody MwDeviceAgentDevice mwDeviceAgentDevice) {
|
|
Result<MwDeviceAgentDevice> result = new Result<MwDeviceAgentDevice>();
|
MwDeviceAgentDevice mwDeviceAgentDeviceEntity = mwDeviceAgentDeviceService.getById(mwDeviceAgentDevice.getId());
|
if (mwDeviceAgentDeviceEntity == null) {
|
result.error500("未找到对应实体");
|
} else {
|
boolean ok = mwDeviceAgentDeviceService.updateById(mwDeviceAgentDeviceEntity);
|
if (ok) {
|
result.success("修改成功!");
|
}
|
}
|
return result;
|
}
|
|
/**
|
* 通过id删除
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/delete")
|
@AutoLog(value = "删除设备代理商-设备")
|
@ApiOperation(value = "删除设备代理商-设备", notes = "删除设备代理商-设备", produces = "application/json")
|
public Result<Boolean> delete(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
Result<Boolean> result = new Result<Boolean>();
|
MwDeviceAgentDevice mwDeviceAgentDevice = mwDeviceAgentDeviceService.getById(dto.getId());
|
if (mwDeviceAgentDevice == null) {
|
result.error500("未找到对应实体");
|
} else {
|
boolean ok = mwDeviceAgentDeviceService.removeById(dto.getId());
|
if (ok) {
|
result.success("删除成功!");
|
}
|
}
|
return result;
|
}
|
|
/**
|
* 批量删除
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/deleteBatch")
|
@AutoLog(value = "批量删除设备代理商-设备")
|
@ApiOperation(value = "批量删除设备代理商-设备", notes = "批量删除设备代理商-设备", produces = "application/json")
|
public Result<Boolean> deleteBatch(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
Result<Boolean> result = new Result<Boolean>();
|
if (dto.getIds() == null || "".equals(dto.getIds().trim())) {
|
result.error500("参数不识别！");
|
} else {
|
this.mwDeviceAgentDeviceService.removeByIds(Arrays.asList(dto.getIds().split(",")));
|
result.success("删除成功!");
|
}
|
return result;
|
}
|
|
/**
|
* 移动
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/move")
|
@AutoLog(value = "移动设备代理商-设备")
|
@ApiOperation(value = "移动设备代理商-设备", notes = "移动设备代理商-设备", produces = "application/json")
|
public Result<Boolean> move(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
MwDeviceAgent mwDeviceAgent = mwDeviceAgentService.getById(dto.getDeviceAgentId());
|
if (mwDeviceAgent == null) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_AGENT_NOT_FOUND);
|
}
|
return Result.ok(mwDeviceAgentDeviceService.move(dto.getId(), dto.getDeviceAgentId()));
|
}
|
|
/**
|
* 批量移动
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/moveBatch")
|
@AutoLog(value = "批量移动设备代理商-设备")
|
@ApiOperation(value = "批量移动设备代理商-设备", notes = "批量移动设备代理商-设备", produces = "application/json")
|
public Result<Boolean> moveBatch(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
MwDeviceAgent mwDeviceAgent = mwDeviceAgentService.getById(dto.getDeviceAgentId());
|
if (mwDeviceAgent == null) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_AGENT_NOT_FOUND);
|
}
|
Result<Boolean> result = new Result<Boolean>();
|
if (dto.getIds() == null || "".equals(dto.getIds().trim()) || dto.getDeviceAgentId() == null) {
|
result.error500("参数不识别！");
|
} else {
|
this.mwDeviceAgentDeviceService.moveBatch(dto.getIds(), dto.getDeviceAgentId());
|
result.success("移动成功!");
|
}
|
return result;
|
}
|
|
/**
|
* 启用、禁用
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/updateStatus")
|
@AutoLog(value = "启用、禁用设备代理商-设备")
|
@ApiOperation(value = "启用、禁用设备代理商-设备", notes = "启用、禁用设备代理商-设备", produces = "application/json")
|
public Result<Boolean> updateState(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
return Result.ok(mwDeviceAgentDeviceService.updateStatus(dto.getId(), dto.getStatus()));
|
}
|
|
/**
|
* 批量启用、禁用
|
*
|
* @param dto
|
* @return
|
*/
|
@PostMapping(value = "/updateStatusBatch")
|
@AutoLog(value = "批量启用、禁用设备代理商-设备")
|
@ApiOperation(value = "批量启用、禁用设备代理商-设备", notes = "批量启用、禁用设备代理商-设备", produces = "application/json")
|
public Result<Boolean> updateStatusBatch(@RequestBody MwDeviceAgentDeviceDTO dto) {
|
|
Result<Boolean> result = new Result<Boolean>();
|
if (dto.getIds() == null || "".equals(dto.getIds().trim()) || dto.getStatus() == null) {
|
result.error500("参数不识别！");
|
} else {
|
this.mwDeviceAgentDeviceService.updateStatusBatch(dto.getIds(), dto.getStatus());
|
result.success("修改成功!");
|
}
|
return result;
|
}
|
|
@OpenApi
|
@GetMapping("/export")
|
@ApiOperation(value = "导出", notes = "导出")
|
public void export(HttpServletResponse response, Integer deviceAgentId) throws UnsupportedEncodingException {
|
|
List<MwDeviceAgentDeviceExcelVO> list = mwDeviceAgentDeviceService.getDeviceExcelList(deviceAgentId);
|
//
|
ExcelWriter excelWriter = ExcelUtil.getWriter(true);
|
excelWriter.renameSheet("硬件特征码导出");
|
excelWriter.setColumnWidth(0, 20);
|
excelWriter.setColumnWidth(1, 20);
|
excelWriter.setColumnWidth(2, 20);
|
excelWriter.setColumnWidth(3, 20);
|
excelWriter.addHeaderAlias("name", "厂商");
|
excelWriter.addHeaderAlias("sn", "特征码");
|
excelWriter.addHeaderAlias("statusStr", "状态");
|
excelWriter.addHeaderAlias("createTime", "创建时间");
|
excelWriter.write(list, true);
|
//
|
response.setContentType("application/octet-stream;charset=utf-8");
|
String fileName = "硬件特征码导出";
|
response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8") + ".xlsx");
|
// response.setHeader("Content-Disposition", "attachment;");
|
ServletOutputStream out = null;
|
try {
|
out = response.getOutputStream();
|
excelWriter.flush(out, true);
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
if (out != null) {
|
try {
|
out.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
excelWriter.close();
|
}
|
}
|
|
@GetMapping("/getDeviceValidateStatus")
|
@ApiOperation(value = "获取特征码校验开关", notes = "获取特征码校验开关")
|
public Result<Integer> getDeviceValidateStatus() {
|
|
return Result.ok(mwDeviceAgentDeviceService.getDeviceValidateStatus());
|
}
|
|
@PostMapping("/setDeviceValidateStatus")
|
@ApiOperation(value = "设置特征码校验开关", notes = "设置特征码校验开关")
|
public Result<Boolean> setDeviceValidateStatus(@RequestBody MwDeviceAgentDeviceValidateStatusDTO dto) {
|
|
return Result.ok(mwDeviceAgentDeviceService.setDeviceValidateStatus(dto.getStatus()));
|
}
|
|
@Data
|
@ApiModel
|
private static class MwDeviceAgentDeviceValidateStatusDTO implements Serializable {
|
|
@NotNull(message = "状态不能为空")
|
@Min(value = 0, message = "状态区间[0,1]")
|
@Max(value = 1, message = "状态区间[0,1]")
|
@ApiModelProperty("1启动0禁用")
|
private Integer status;
|
|
}
|
|
@GetMapping("/getToken")
|
@ApiOperation(value = "获取视频服务器token", notes = "获取视频服务器token")
|
public Result<String> getToken() {
|
return Result.ok(monitorDeviceApiNewService.getJSession(1));
|
}
|
|
@GetMapping("/getDeviceList")
|
@ApiOperation(value = "获取视频服务器设备列表", notes = "获取视频服务器设备列表")
|
public Result<List<String>> getDeviceList() {
|
return Result.ok(monitorDeviceApiNewService.getDeviceList());
|
}
|
|
@GetMapping("/getDeviceUrl")
|
@ApiOperation(value = "获取视频服务器设备播放路径", notes = "获取视频服务器设备播放路径")
|
public Result<Map<String,Object>> getDeviceUrl(String id,Integer channelNum) {
|
return Result.ok(monitorDeviceApiNewService.getDeviceUrl(id,channelNum));
|
}
|
|
@GetMapping("/getChannelList")
|
@ApiOperation(value = "查询设备通道列表（新）", notes = "查询设备通道列表（新）")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "serial", value = "设备编号", required = true, dataType = "String", format = "query")
|
})
|
public Result<List<Map<String,String>>> getChannelList(String serial) {
|
return Result.ok(monitorDeviceApiNewService.getChannelList(serial));
|
}
|
|
@GetMapping("/getPlaybackRecordlist")
|
@ApiOperation(value = "查询通道录像列表（新）", notes = "查询通道录像列表（新）")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "serial", value = "设备编号", required = true, dataType = "String", format = "query"),
|
@ApiImplicitParam(name = "channel", value = "通道号", required = true, dataType = "Integer", format = "query"),
|
@ApiImplicitParam(name = "starttime", value = "开始时间（格式：YYYY-MM-DDTHH:mm:ss 如：2023-04-25T08:00:00）", required = true, dataType = "String", format = "query"),
|
@ApiImplicitParam(name = "endtime", value = "结束时间（格式：YYYY-MM-DDTHH:mm:ss 如：2023-04-25T08:00:00）", required = false, dataType = "String", format = "query")
|
})
|
public Result<List<Map<String,String>>> getPlaybackRecordlist(String serial,Integer channel,String starttime,String endtime) {
|
return Result.ok(monitorDeviceApiNewService.getPlaybackRecordlist(serial,channel,starttime,endtime));
|
}
|
@GetMapping("/playbackStart")
|
@ApiOperation(value = "开始回放（新）", notes = "开始回放（新）")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "serial", value = "设备编号", required = true, dataType = "String", format = "query"),
|
@ApiImplicitParam(name = "channel", value = "通道号", required = true, dataType = "Integer", format = "query"),
|
@ApiImplicitParam(name = "starttime", value = "开始时间（格式：YYYY-MM-DDTHH:mm:ss 如：2023-04-25T08:00:00）", required = true, dataType = "String", format = "query"),
|
@ApiImplicitParam(name = "endtime", value = "结束时间（格式：YYYY-MM-DDTHH:mm:ss 如：2023-04-25T08:00:00）", required = false, dataType = "String", format = "query")
|
})
|
public Result<Map<String,Object>> playbackStart(String serial,Integer channel,String starttime,String endtime) {
|
return Result.ok(monitorDeviceApiNewService.playbackStart(serial,channel,starttime,endtime));
|
}
|
|
@GetMapping("/playbackStop")
|
@ApiOperation(value = "回放流停止（新）", notes = "回放流停止（新）")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "streamID", value = "流ID", required = true, dataType = "String", format = "query")
|
})
|
public Result<Map<String,Object>> playbackStop(String streamID) {
|
return Result.ok(monitorDeviceApiNewService.playbackStop(streamID));
|
}
|
|
}
|
