package com.hxzk.controller;
|
|
import com.github.pagehelper.PageInfo;
|
import com.hxzk.pojo.TbAchor;
|
import com.hxzk.pojo.TbSystemOperationLog;
|
import com.hxzk.pojo.TbTag;
|
import com.hxzk.pojo.TbWarning;
|
import com.hxzk.service.SystemLogService;
|
import com.hxzk.service.TagService;
|
import com.hxzk.service.WarningService;
|
import com.hxzk.udp.Udp_Out;
|
import com.hxzk.util.GetTime;
|
import com.hxzk.util.result;
|
import com.hxzk.util.resultutil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
@RestController
|
@RequestMapping("/")
|
public class WarningController {
|
@Autowired
|
WarningService warningService;
|
|
@Autowired
|
SystemLogService systemLogService;
|
//查询所有标签设备信息
|
@GetMapping("findwarning")
|
result<List<com.hxzk.deo.TbWarning>> findwarning(Integer page, Integer limit){
|
PageInfo<com.hxzk.deo.TbWarning> cz= warningService.findAll(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
@GetMapping("findwarningHouTai")
|
result<List<com.hxzk.deo.TbWarning>> findwarningHouTai(Integer page, Integer limit){
|
PageInfo<com.hxzk.deo.TbWarning> cz= warningService.findAllHouTai(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
@GetMapping("findwarningDaPing")
|
result<List<com.hxzk.deo.TbWarning>> findwarningDaPing(Integer page, Integer limit){
|
PageInfo<com.hxzk.deo.TbWarning> cz= warningService.findAllStatus(page, limit);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
//表格搜索
|
@GetMapping("findwarningSearch")
|
result<List<com.hxzk.deo.TbWarning>> findwarningSearch(Integer page, Integer limit,TbWarning warning){
|
PageInfo<com.hxzk.deo.TbWarning> cz= warningService.findwarningSearch(page, limit,warning);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
|
//表格搜索
|
@GetMapping("findwarningSearchHouTai")
|
result<List<com.hxzk.deo.TbWarning>> findwarningSearchHouTai(Integer page, Integer limit,TbWarning warning){
|
PageInfo<com.hxzk.deo.TbWarning> cz= warningService.findwarningSearchHouTai(page, limit,warning);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
//表格筛选
|
@GetMapping("findwarningScreen")
|
result<List<TbWarning>> findwarningScreen(Integer page, Integer limit, TbWarning warning, HttpServletRequest request){
|
String param0 = request.getParameter("param0");
|
String param1 = request.getParameter("param1");
|
String param2 = request.getParameter("param2");
|
String param3 = request.getParameter("param3");
|
if(param3 == null){
|
warning.setType(param0+param1+param2);
|
}else{
|
warning.setType(param0+param1+param2+param3);
|
}
|
PageInfo<TbWarning> cz= warningService.findwarningScreen(page, limit,warning);
|
return resultutil.returnSuccess(cz.getTotal(), cz.getList());
|
}
|
//单独处理告警
|
@PostMapping("DellWarning")
|
public void deletegaojing(TbWarning warning, String ids, HttpServletResponse response) throws IOException {
|
warning.setBaoliu4(GetTime.getTime());
|
warning.setStatus("已处理");
|
String[] ids1 = ids.split(",");
|
String[] ids2 = warning.getType().split(",");
|
String[] ids3 = warning.getObjectid().split(",");
|
for (int i =0; i < ids1.length;i++){
|
warning.setType(ids2[i]);
|
warning.setObjectid(ids3[i]);
|
warningService.ChuliWarning(warning,ids1[i]);
|
TbWarning warning1 = warningService.findtagidWarning(ids1[i]);
|
TbSystemOperationLog systemOperationLog = new TbSystemOperationLog();
|
systemOperationLog.setName(UserController.username);
|
systemOperationLog.setTime(gettime());
|
systemOperationLog.setContent("在后台处理了一条告警数据，该数据设备ID是："+ids3[i]+"，类型是："+ids2[i]);
|
systemLogService.insertSystem(systemOperationLog);
|
String xieyi = "BSTOCS1,DELLWARN," +warning1.getObjectid()+","+warning1.getType()+",END";
|
Udp_Out.udp_to_cs(xieyi);
|
}
|
response.sendRedirect("/hxzkuwb/HouTai/GaoJingHuiZong/GaoJingHuiZong.jsp");
|
}
|
|
//首页大屏单独处理告警
|
@PostMapping("DaPingDellWarning")
|
public void deletegaojing(TbWarning warning,String username) throws IOException {
|
TbWarning warning1 = warningService.findIdXiangXi(warning.getId());
|
warning.setBaoliu4(GetTime.getTime());
|
warning.setBaoliu3(username);
|
warning.setObjectid(warning1.getObjectid());
|
warning.setStatus("已处理");
|
String xieyi = "BSTOCS1,DELLWARN," +warning.getId()+","+warning.getType()+",END";
|
TbSystemOperationLog systemOperationLog = new TbSystemOperationLog();
|
systemOperationLog.setName(UserController.username);
|
systemOperationLog.setTime(gettime());
|
systemOperationLog.setContent("在大屏处理了一条告警数据，该数据设备ID是："+warning.getObjectid()+"，类型是："+warning.getType());
|
systemLogService.insertSystem(systemOperationLog);
|
Udp_Out.udp_to_cs(xieyi);
|
warningService.DaPingChuliWarning(warning);
|
}
|
@GetMapping("WarningCaoZuo")
|
public void WarningCaoZuo(TbWarning warning){
|
String xieyi = "BSTOCS1,DELLWARN," + warning.getObjectid() + ","+warning.getType()+",END";
|
TbSystemOperationLog systemOperationLog = new TbSystemOperationLog();
|
systemOperationLog.setName(UserController.username);
|
systemOperationLog.setTime(gettime());
|
systemOperationLog.setContent("在后台处理了一条告警数据，该数据设备ID是："+warning.getObjectid()+"，类型是："+warning.getType());
|
systemLogService.insertSystem(systemOperationLog);
|
Udp_Out.udp_to_cs(xieyi);
|
}
|
//全部处理告警
|
@PostMapping("WarningChuLiAll")
|
public void deleteALLgaojing(TbWarning warning,HttpServletResponse response) throws IOException {
|
String xieyi = "BSTOCS1,DELLWARNALL,"+warning.getType()+",END";
|
TbWarning warning1 = new TbWarning();
|
warning1.setStatus("已处理");
|
warning1.setType(warning.getType());
|
warning1.setBaoliu3(UserController.username);
|
warning1.setBaoliu4(gettime());
|
warning1.setBaoliu6(warning.getBaoliu6());
|
warning1.setBaoliu5(warning.getBaoliu5());
|
warningService.UpAllWarning(warning1);
|
TbSystemOperationLog systemOperationLog = new TbSystemOperationLog();
|
systemOperationLog.setName(UserController.username);
|
systemOperationLog.setTime(gettime());
|
systemOperationLog.setContent("成功把"+warning.getType()+"消息全部处理");
|
systemLogService.insertSystem(systemOperationLog);
|
Udp_Out.udp_to_cs(xieyi);
|
response.sendRedirect("/hxzkuwb/HouTai/GaoJingHuiZong/GaoJingHuiZong.jsp");
|
}
|
|
//大屏告警信息数据查询
|
@GetMapping("findDaPingGaojing")
|
public List<com.hxzk.deo.TbWarning> findDaPingGaoJing(){
|
return warningService.findDaPingGaoJing();
|
}
|
//大屏今日未处理总数
|
@GetMapping("findDapingWeiChuLiCount")
|
public Integer findDaPingWeiChuLiCount(){
|
return warningService.findDaPingWeiChuLiCount();
|
}
|
|
//根据ID获取详细信息
|
@GetMapping("findIdXiangXi")
|
public TbWarning findIdXiangXi(Integer id){
|
return warningService.findIdXiangXi(id);
|
}
|
|
public String gettime(){
|
Date now = new Date();
|
// 创建日期格式化对象，设置格式为 "yyyy-MM-dd HH:mm"
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
|
// 格式化日期对象，输出字符串结果
|
String formattedDate = sdf.format(now);
|
return formattedDate;
|
}
|
|
@GetMapping("findIDWarning")
|
public TbWarning findIdWarning(Integer id){
|
return warningService.findIdWarning(id);
|
}
|
|
|
@GetMapping("updateIDWarning")
|
public void updateIDWarning(Integer id){
|
warningService.updateIDWarning(id);
|
}
|
}
|
