package com.hxzkoa.controller;
|
|
import java.io.File;
|
import java.io.FileWriter;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.hibernate.dialect.function.VarArgsSQLFunction;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import com.hxzkoa.json.tb_achor;
|
import com.hxzkoa.json.tb_shebei;
|
import com.hxzkoa.json.tb_shishi;
|
import com.hxzkoa.json.tb_system;
|
import com.hxzkoa.json.tb_tag;
|
import com.hxzkoa.json.vo_kaoqin_p;
|
import com.hxzkoa.services.AnchorService;
|
import com.hxzkoa.services.AttendanceService;
|
import com.hxzkoa.services.LabelService;
|
import com.hxzkoa.services.SysSettingService;
|
import com.hxzkoa.services.WarningService;
|
/*import com.hxzkoa.udp.Udp_Receive;*/
|
import com.hxzkoa.util.Config;
|
import com.hxzkoa.util.HttpUtil;
|
import com.hxzkoa.util.ModifyConfig;
|
|
import net.sf.json.JSONObject;
|
|
@Controller
|
public class ShowController {
|
@Autowired
|
private AnchorService anchorService;
|
@Autowired
|
private LabelService labelService;
|
@Autowired
|
private AttendanceService attendanceService;
|
@Autowired
|
private WarningService warningService;
|
@Autowired
|
private SysSettingService sysSettingService;
|
|
/* Udp_Receive receive; */
|
|
// 清空文件内容
|
public void clearInfoForFile(String fileName) {
|
File file = new File(fileName);
|
try {
|
if (!file.exists()) {
|
file.createNewFile();
|
System.out.println("file"+file);
|
}
|
System.out.println("file"+file);
|
FileWriter fileWriter = new FileWriter(file);
|
fileWriter.write("");
|
fileWriter.flush();
|
fileWriter.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
@RequestMapping(value = "/show.do", method = { RequestMethod.POST, RequestMethod.GET })
|
public String show(HttpServletRequest request) {
|
// tb_system system = new tb_system();
|
// system.setUdpPort("8234");
|
// JSONObject jsonObject = JSONObject.fromObject(system);
|
// String postUrl = Config.getPostUrl();
|
// String url_setting_bw = postUrl + "getSysSetting.do";
|
// JSONObject re_tb_setting = HttpUtil.doPost(url_setting_bw, jsonObject.toString(), "UTF-8");
|
// tb_system re_setting = (tb_system) JSONObject.toBean(JSONObject.fromObject(re_tb_setting.get("result").toString()),
|
// tb_system.class);
|
// String port = re_setting.getUdpPort();
|
// // 开启报文接收
|
// try {
|
// receive = new Udp_Receive(port);
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// if (Config.getUdpRunning().equals("1")) {
|
// try {
|
// receive.startThread();
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// }
|
String toPage = "forward:/hxzk/index.jsp";
|
// 基站信息
|
List<tb_achor> anchorManagementList = anchorService.getAnchorManagementsi();
|
// List<tb_shebei> shebei = anchorService.getShebei();
|
/*
|
* List<tb_achor> reAnchorManagementList = new ArrayList<tb_achor>(); if
|
* (anchorManagementList.size()>5){ for (int i = 0; i < 5; i++) { String time
|
* =anchorManagementList.get(i).getGreateTime(); time = time.split(" ")[1];
|
* anchorManagementList.get(i).setGreateTime(time);
|
* reAnchorManagementList.add(anchorManagementList.get(i)); } } else { for (int
|
* i = 0; i < anchorManagementList.size(); i++) { String time
|
* =anchorManagementList.get(i).getGreateTime(); time = time.split(" ")[1];
|
* anchorManagementList.get(i).setGreateTime(time);
|
* reAnchorManagementList.add(anchorManagementList.get(i)); } }
|
*/
|
|
// 标签信息
|
List<tb_tag> labelManagementList = labelService.getLabelManagement(1);
|
List<tb_tag> reLabelManagementList = new ArrayList<tb_tag>();
|
if (labelManagementList.size()>6){
|
for (int i = 0; i < 6; i++) {
|
String time =labelManagementList.get(i).getAddtime();
|
time = time.split(" ")[1];
|
labelManagementList.get(i).setAddtime(time);
|
reLabelManagementList.add(labelManagementList.get(i));
|
}
|
} else {
|
for (int i = 0; i < labelManagementList.size(); i++) {
|
String time =labelManagementList.get(i).getAddtime();
|
time = time.split(" ")[1];
|
labelManagementList.get(i).setAddtime(time);
|
reLabelManagementList.add(labelManagementList.get(i));
|
}
|
}
|
|
// 实时考勤
|
List<vo_kaoqin_p> realAttendanceList = attendanceService.getRealAttendance(1);
|
List<vo_kaoqin_p> reRealAttendanceList = new ArrayList<vo_kaoqin_p>();
|
if (realAttendanceList.size()>4){
|
for (int i = 0; i < 4; i++) {
|
String time =realAttendanceList.get(i).getIntime();
|
time = time.split(" ")[1];
|
time = time.split("\\.")[0];
|
realAttendanceList.get(i).setIntime(time);
|
reRealAttendanceList.add(realAttendanceList.get(i));
|
}
|
} else {
|
for (int i = 0; i < realAttendanceList.size(); i++) {
|
String time =realAttendanceList.get(i).getIntime();
|
time = time.split(" ")[1];
|
time = time.split("\\.")[0];
|
realAttendanceList.get(i).setIntime(time);
|
reRealAttendanceList.add(realAttendanceList.get(i));
|
}
|
}
|
|
// 告警汇总
|
Map warningSummaryTypeMap = warningService.getWarningSummaryType();
|
List<String> reWarningSummary_k = new ArrayList<String>();
|
List<Integer> reWarningSummary_v = new ArrayList<Integer>();
|
Iterator<String> warningSummaryTypeIter = warningSummaryTypeMap.keySet().iterator();
|
while (warningSummaryTypeIter.hasNext()) {
|
String key = warningSummaryTypeIter.next();
|
reWarningSummary_k.add(key);
|
reWarningSummary_v.add((int) warningSummaryTypeMap.get(key));
|
}
|
// 现场工种
|
Map realAttendanceTypeMap = attendanceService.getRealAttendanceType();
|
List<String> realAttendance_k = new ArrayList<String>();
|
List<Integer> realAttendance_v = new ArrayList<Integer>();
|
Iterator<String> realAttendanceTypeIter = realAttendanceTypeMap.keySet().iterator();
|
while (realAttendanceTypeIter.hasNext()) {
|
String key = realAttendanceTypeIter.next();
|
realAttendance_k.add(key);
|
realAttendance_v.add((int) realAttendanceTypeMap.get(key));
|
}
|
// 统计数据
|
Map realtongjiTypeMap = attendanceService.getRealtongjiType();
|
List<String> realtongji_k = new ArrayList<String>();
|
List<Integer> realtongji_v = new ArrayList<Integer>();
|
Iterator<String> realtongjiTypeIter = realtongjiTypeMap.keySet().iterator();
|
while (realtongjiTypeIter.hasNext()) {
|
String key = realtongjiTypeIter.next();
|
realtongji_k.add(key);
|
realtongji_v.add((int) realtongjiTypeMap.get(key));
|
}
|
// 系统设置
|
List<tb_system> systemlist = sysSettingService.getSetting();
|
// 实时数据
|
// Map realshishiTypeMap = attendanceService.getRealshishiType();
|
// List<String> realshishi_k = new ArrayList<String>();
|
// List<Integer> realshishi_v = new ArrayList<Integer>();
|
// Iterator<String> realshishiTypeIter = realshishiTypeMap.keySet().iterator();
|
// while (realshishiTypeIter.hasNext()) {
|
// String key = realshishiTypeIter.next();
|
// realshishi_k.add(key);
|
// realshishi_v.add((int) realshishiTypeMap.get(key));
|
// }
|
// request.setAttribute("shebei", shebei);
|
request.setAttribute("anchorManagementList", anchorManagementList);
|
request.setAttribute("labelManagementList", reLabelManagementList);
|
request.setAttribute("realAttendanceList", reRealAttendanceList);
|
request.setAttribute("reWarningSummary_k", reWarningSummary_k);
|
request.setAttribute("reWarningSummary_v", reWarningSummary_v);
|
request.setAttribute("realAttendance_k", realAttendance_k);
|
request.setAttribute("realAttendance_v", realAttendance_v);
|
request.setAttribute("realtongji_k", realtongji_k);
|
request.setAttribute("realtongji_v", realtongji_v);
|
request.setAttribute("systemlist", systemlist);
|
// request.setAttribute("realshishi_k", realshishi_k);
|
// request.setAttribute("realshishi_v", realshishi_v);
|
|
//初始化配置文件
|
File file = new File(Config.getBaowenConfig());
|
if (!file.exists()){
|
try {
|
file.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
File file2 = new File(Config.getMapConfig());
|
if (!file2.exists()){
|
try {
|
file2.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
String filePath = Config.getBaowenConfig();
|
ModifyConfig.writeData(filePath, "baowenSwitch", "0");
|
System.out.print(filePath);
|
ModifyConfig.writeData(filePath, "debugSwitch", "0");
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getYuanshiMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getHEXMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getGasMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getTCPMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getUDPMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getZhuceMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getDebugMessagePath());
|
clearInfoForFile(request.getServletContext().getRealPath("/")+Config.getMessagePath());
|
return toPage;
|
}
|
|
|
@RequestMapping(value = "/setshow.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public List<tb_shishi> setshow(HttpServletRequest request) {
|
// 实时数据
|
List<tb_shishi> shishilist = attendanceService.getRealshishiType();
|
return shishilist;
|
}
|
|
@RequestMapping(value = "/setweizhi.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public String setweizhi(HttpServletRequest request) {
|
// 实时数据
|
List<tb_shishi> shishilist = attendanceService.getRealshishiType();
|
String weizhi = shishilist.get(0).getNum();
|
return weizhi;
|
}
|
|
@RequestMapping(value = "/setshebei.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public List<tb_shebei> setshebei(HttpServletRequest request) {
|
// 设备数据
|
List<tb_shebei> achorlist = anchorService.getjizhanshebei();
|
List<tb_shebei> taglist = anchorService.getbiaoqianshebei();
|
for(int i = 0;i <taglist.size();i++) {
|
achorlist.add(taglist.get(i));
|
}
|
return achorlist;
|
}
|
|
@RequestMapping(value = "/settongjishuju.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public List<Object> settongjishuju(HttpServletRequest request) {
|
List<Object> shishilist = attendanceService.gettongjishuju();
|
return shishilist;
|
}
|
|
@RequestMapping(value = "/setgongzhongnum.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public List<Integer> setgongzhongnum(){
|
List<Integer> gongzhongnum = attendanceService.getgongzhongnum();
|
return gongzhongnum;
|
}
|
|
@RequestMapping(value = "/setgaojingnum.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public List<Integer> setgaojingnum(){
|
List<Integer> gaojingnum = attendanceService.getgaojingnum();
|
return gaojingnum;
|
}
|
|
}
|
