package com.zhitan.web.controller.alarm;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.zhitan.alarm.domain.JkRealTimeAlarmList;
|
import com.zhitan.alarm.services.IRealtimeAlarmService;
|
import com.zhitan.common.core.controller.BaseController;
|
import com.zhitan.common.core.domain.AjaxResult;
|
import com.zhitan.common.core.page.TableDataInfo;
|
import com.zhitan.realtimedata.domain.TagValue;
|
import com.zhitan.realtimedata.service.RealtimeDatabaseService;
|
import io.swagger.annotations.Api;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.math.BigDecimal;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 报警监测 下 实时报警监测 Controller
|
*
|
* @author zhaowei
|
* @date 2020-02-12
|
*/
|
@Api("报警检测——实时报警检测")
|
@RestController
|
@RequestMapping("/energyAlarm/realTimeAlarm")
|
public class RealTimeAlarmController extends BaseController
|
{
|
@Autowired
|
private IRealtimeAlarmService iRealtimeAlarmService;
|
|
@Autowired
|
private RealtimeDatabaseService realtimeDatabaseService;
|
|
|
/**
|
* 实时报警 页面 根据 节点目录和 条件查询
|
*/
|
// @ApiOperation("实时报警查询")
|
@PreAuthorize("@ss.hasPermi('energyAlarm:realTimeAlarm:list')")
|
@GetMapping("/list")
|
public TableDataInfo list(JkRealTimeAlarmList jkRealTimeAlarmList, Long pageNum, Long pageSize)
|
{
|
Page<JkRealTimeAlarmList> list = iRealtimeAlarmService.selectRealtimeAlarmJkPage(jkRealTimeAlarmList,pageNum,pageSize);
|
return getDataTable(list);
|
}
|
|
/**
|
* 实时报警 组件 实时数据获取
|
*/
|
// @ApiOperation("实时报警查询")
|
@PreAuthorize("@ss.hasPermi('energyAlarm:realTimeAlarm:list')")
|
@GetMapping("/liveHistoryData/{code}/{minute}/{pointCount}")
|
public AjaxResult liveList(@PathVariable("code") String code,@PathVariable("minute") String minute,@PathVariable("pointCount") String pointCount)
|
{
|
int time = Integer.parseInt(minute);
|
int count = Integer.parseInt(pointCount);
|
Calendar c = Calendar.getInstance();
|
Date endTime= c.getTime();
|
c.add(Calendar.MINUTE, -time);
|
Date startTime = c.getTime();
|
List<TagValue> TagValuelist = realtimeDatabaseService.retrieve(code, startTime, endTime, count);
|
for(TagValue tagVal:TagValuelist)
|
{
|
if(ObjectUtils.isEmpty(tagVal)){
|
tagVal = new TagValue();
|
}
|
tagVal.setShowDataTime("HH:mm:ss");
|
if(ObjectUtils.isEmpty(tagVal.getValue())){
|
tagVal.setValue(0.00);
|
}else{
|
BigDecimal b = new BigDecimal(tagVal.getValue());
|
tagVal.setValue( b.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue());
|
}
|
|
}
|
// Collections.reverse(TagValuelist);
|
return AjaxResult.success(TagValuelist);
|
}
|
}
|
