|
|
|
|
@ -10,6 +10,8 @@ import org.dromara.common.log.enums.BusinessType;
|
|
|
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
|
|
|
|
import org.dromara.ems.common.web.EmsBaseController;
|
|
|
|
|
import org.dromara.ems.record.domain.EmsRecordAlarmData;
|
|
|
|
|
import org.dromara.ems.record.domain.vo.AlarmHandleResultVo;
|
|
|
|
|
import org.dromara.ems.record.domain.vo.EmsRealtimeAlarmBatchResultVo;
|
|
|
|
|
import org.dromara.ems.record.domain.vo.EmsRecordAlarmDataSummaryVo;
|
|
|
|
|
import org.dromara.ems.record.service.IEmsRecordAlarmDataService;
|
|
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
@ -57,7 +59,7 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* 导出异常数据记录列表
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:export")
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.EXPORT)
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.EXPORT, remark = "导出了异常数据记录数据")
|
|
|
|
|
@PostMapping("/export")
|
|
|
|
|
public void export(HttpServletResponse response, EmsRecordAlarmData emsRecordAlarmData)
|
|
|
|
|
{
|
|
|
|
|
@ -79,7 +81,7 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* 新增异常数据记录
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:add")
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.INSERT)
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.INSERT, remark = "新增了异常数据记录【#emsRecordAlarmData.alarmTitle}】")
|
|
|
|
|
@PostMapping
|
|
|
|
|
public R<?> add(@RequestBody EmsRecordAlarmData emsRecordAlarmData)
|
|
|
|
|
{
|
|
|
|
|
@ -90,7 +92,7 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* 修改异常数据记录
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:edit")
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.UPDATE)
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.UPDATE, remark = "修改了异常数据记录【#emsRecordAlarmData.alarmTitle}】")
|
|
|
|
|
@PutMapping
|
|
|
|
|
public R<?> edit(@RequestBody EmsRecordAlarmData emsRecordAlarmData)
|
|
|
|
|
{
|
|
|
|
|
@ -101,7 +103,7 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* 删除异常数据记录
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:remove")
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.DELETE)
|
|
|
|
|
@Log(title = "异常数据记录", businessType = BusinessType.DELETE, remark = "删除了异常数据记录，ID：【#objIds}】")
|
|
|
|
|
@DeleteMapping("/{objIds}")
|
|
|
|
|
public R<?> remove(@PathVariable Long[] objIds)
|
|
|
|
|
{
|
|
|
|
|
@ -113,15 +115,21 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* @param objIds
|
|
|
|
|
* @return
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:edit")
|
|
|
|
|
@PostMapping("/handleExceptions/{objIds}")
|
|
|
|
|
public R<?> handleExceptions(@PathVariable Long[] objIds)
|
|
|
|
|
public R<AlarmHandleResultVo> handleExceptions(@PathVariable Long[] objIds)
|
|
|
|
|
{
|
|
|
|
|
return toAjax(emsRecordAlarmDataService.handleExceptionsAlarmData(objIds));
|
|
|
|
|
AlarmHandleResultVo result = emsRecordAlarmDataService.handleExceptionsAlarmData(objIds);
|
|
|
|
|
if (result.getUpdatedCount() <= 0 && result.getAlreadyHandledCount() <= 0) {
|
|
|
|
|
return R.fail("没有可回写的告警记录", result);
|
|
|
|
|
}
|
|
|
|
|
return success(result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 获取异常数据表总数（包含所有告警类型）
|
|
|
|
|
*/
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:list")
|
|
|
|
|
@GetMapping("/getAlarmDataTotalCount")
|
|
|
|
|
public int getAlarmDataTotalCount()
|
|
|
|
|
{
|
|
|
|
|
@ -135,18 +143,19 @@ public class EmsRecordAlarmDataController extends EmsBaseController
|
|
|
|
|
* @param alarmDataList 异常数据记录列表
|
|
|
|
|
* @return 结果
|
|
|
|
|
*/
|
|
|
|
|
@Log(title = "WebSocket告警数据", businessType = BusinessType.INSERT)
|
|
|
|
|
@SaCheckPermission("ems/record:recordAlarmData:add")
|
|
|
|
|
@Log(title = "WebSocket告警数据", businessType = BusinessType.INSERT, remark = "接收了WebSocket告警数据")
|
|
|
|
|
@PostMapping("/saveWebSocketAlarmData")
|
|
|
|
|
public R<?> saveWebSocketAlarmData(@RequestBody List<EmsRecordAlarmData> alarmDataList)
|
|
|
|
|
public R<EmsRealtimeAlarmBatchResultVo> saveWebSocketAlarmData(@RequestBody List<EmsRecordAlarmData> alarmDataList)
|
|
|
|
|
{
|
|
|
|
|
if (alarmDataList == null || alarmDataList.isEmpty()) {
|
|
|
|
|
return error("告警数据不能为空");
|
|
|
|
|
return R.fail("告警数据不能为空", new EmsRealtimeAlarmBatchResultVo());
|
|
|
|
|
}
|
|
|
|
|
int result = emsRecordAlarmDataService.saveWebSocketAlarmDataBatch(alarmDataList);
|
|
|
|
|
if (result > 0) {
|
|
|
|
|
return success("保存成功，共保存 " + result + " 条告警记录");
|
|
|
|
|
EmsRealtimeAlarmBatchResultVo result = emsRecordAlarmDataService.saveWebSocketAlarmDataBatch(alarmDataList);
|
|
|
|
|
if (result.getInsertedCount() > 0 || result.getDuplicateCount() > 0) {
|
|
|
|
|
return success(result);
|
|
|
|
|
}
|
|
|
|
|
return error("保存失败，没有新增任何记录");
|
|
|
|
|
return R.fail("保存失败，没有新增任何记录", result);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
