package com.hxzkoa.controller; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.FileWriter; import java.io.IOException; import java.io.OutputStream; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.Socket; import java.net.SocketException; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.Date; import java.util.List; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.httpclient.util.DateUtil; 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_bsbaowen; import com.hxzkoa.json.tb_forward_data; import com.hxzkoa.json.tb_map; import com.hxzkoa.json.tb_nav; import com.hxzkoa.json.tb_suanfa; import com.hxzkoa.json.tb_system; import com.hxzkoa.json.tb_tag; import com.hxzkoa.json.tb_user; import com.hxzkoa.json.tb_yuan_shi_bao_wen; import com.hxzkoa.services.MapService; import com.hxzkoa.services.SysSettingService; import com.hxzkoa.services.ZhwService; import com.hxzkoa.udp.Panduan; import com.hxzkoa.udp.Udp_Out; /*import com.hxzkoa.udp.Udp_Receive;*/ import com.hxzkoa.util.Config; import com.hxzkoa.util.DatabaseUtil; import com.hxzkoa.util.ExcelUtils; import com.hxzkoa.util.HttpUtil; import com.hxzkoa.util.ModifyConfig; import com.hxzkoa.util.PageUtil; import com.hxzkoa.util.RequestUtils; import net.sf.json.JSONObject; @Controller public class SysSettingController { @Autowired private SysSettingService sysSettingService; @Autowired private MapService mapService; @Autowired private ZhwService zhwService; @ResponseBody @RequestMapping(value = "/to_cs_start_.do", method = { RequestMethod.POST, RequestMethod.GET }) public void kaishi(HttpServletRequest request) { String leixing = request.getParameter("leixing"); String tagid = request.getParameter("tagid"); String xieyi = "BSTOCS1,START,"+leixing+","+tagid+",END"; Udp_Out.udp_to_cs(xieyi); } @ResponseBody @RequestMapping(value = "/baowenrefresh.do", method = { RequestMethod.POST, RequestMethod.GET }) public List shuaxin(HttpServletRequest request) { List baowen = sysSettingService.bsbaowen(); // 升序排序 // Collections.sort(baowen, new Comparator() { // @Override // public int compare(tb_bsbaowen h1, tb_bsbaowen h2) { // return h1.getReceive_time().compareTo(h2.getReceive_time()); // } // }); // Collections.reverse(baowen); return baowen; } @ResponseBody @RequestMapping(value = "/to_cs_stop.do", method = { RequestMethod.POST, RequestMethod.GET }) public void zanting(HttpServletRequest request) { String xieyi = "BSTOCS1,STOP,END"; Udp_Out.udp_to_cs(xieyi); } @ResponseBody @RequestMapping(value = "/to_cs_clean.do", method = { RequestMethod.POST, RequestMethod.GET }) public void qingkong(HttpServletRequest request) { String xieyi = "BSTOCS1,CLEAR,END"; Udp_Out.udp_to_cs(xieyi); } @ResponseBody @RequestMapping(value = "/to_cs_close.do", method = { RequestMethod.POST, RequestMethod.GET }) public void jieshu(HttpServletRequest request) { String xieyi = "BSTOCS1,CLOSE,END"; Udp_Out.udp_to_cs(xieyi); } @ResponseBody @RequestMapping(value = "/panduan.do", method = { RequestMethod.POST, RequestMethod.GET }) public boolean panduan(HttpServletRequest request) { String tagid = request.getParameter("tagid"); String rees = request.getParameter("rees"); boolean abb = Panduan.panduan(tagid, rees); // if (rees.startsWith("display")) { // String tagid1 = Dell_display.gettagid(rees); // abb = tagid1.equals(tagid); // } else if (rees.startsWith("$GNGGA")) { // String tagid2 = Dell_GNGGA.gettagid(rees); // abb = tagid2.equals(tagid); // } return abb; } @RequestMapping(value = "/message.do", method = { RequestMethod.POST, RequestMethod.GET }) public String message(HttpServletRequest request) { String toPage = "forward:/hxzk/sysSetting/message.jsp"; List labelList = sysSettingService.getLabel(); request.setAttribute("labelList", labelList); return toPage; } @RequestMapping(value = "/messageTransfer.do", method = { RequestMethod.POST, RequestMethod.GET }) public String messageTransfer(HttpServletRequest request) { String toPage = "forward:/hxzk/sysSetting/messageTransfer.jsp"; List messageTransferList = sysSettingService.getmessageTransfer(1); request.setAttribute("messageTransferList", messageTransferList); int curPage = 1; int count = sysSettingService.getmessageTransferCount(); int minPage = PageUtil.getMinPage(count); request.setAttribute("pageList", PageUtil.getPage(minPage)); request.setAttribute("curPage", curPage); return toPage; } @ResponseBody @RequestMapping(value = "/messageTransfer_search.do", method = { RequestMethod.POST, RequestMethod.GET }) public String messageTransfer_search(HttpServletRequest request) { String input = request.getParameter("input"); int curPage = 1; List pageList = new ArrayList(); List messageTransferList = sysSettingService.searchmessageTransfer(input); pageList.add(1); JSONObject json = new JSONObject(); json.put("dataList", messageTransferList); json.put("pageList", pageList); json.put("curPage", curPage); return json.toString(); } @ResponseBody @RequestMapping(value = "/messageTransfer_page.do", method = { RequestMethod.POST, RequestMethod.GET }) public String labelManagement_page(HttpServletRequest request) { String pageStr = request.getParameter("page"); String curPageStr = request.getParameter("curPage"); int count = sysSettingService.getmessageTransferCount(); int minPage = PageUtil.getMinPage(count); int curPage = Integer.parseInt(curPageStr); int page = 1; if ("pre".equals(pageStr)) { if (curPage > 1) { page = curPage - 1; } } else if ("next".equals(pageStr)) { if (curPage < minPage) { page = curPage + 1; } } else { page = Integer.parseInt(pageStr); } List messageTransferList = sysSettingService.getmessageTransfer(page); List pageList = PageUtil.getPage(PageUtil.getLocPage(page, curPage), page, minPage); JSONObject json = new JSONObject(); json.put("dataList", messageTransferList); json.put("pageList", pageList); json.put("curPage", page); return json.toString(); } @ResponseBody @RequestMapping(value = "/messageTransfer_delete.do", method = { RequestMethod.POST, RequestMethod.GET }) public void labelManagement_delete(HttpServletRequest request) { String checkValStr = request.getParameter("checkVal"); checkValStr = checkValStr.replaceAll("\"", ""); String[] checkVal = checkValStr.split(","); sysSettingService.messageTransfer_delete(checkVal); for (int i = 0; i userManagementList = sysSettingService.getuserManagement(1); request.setAttribute("userManagementList", userManagementList); int curPage = 1; int count = sysSettingService.getuserManagementCount(); int minPage = PageUtil.getMinPage(count); request.setAttribute("pageList", PageUtil.getPage(minPage)); request.setAttribute("curPage", curPage); return toPage; } @ResponseBody @RequestMapping(value = "/userManagementa.do", method = { RequestMethod.POST, RequestMethod.GET }) public JSONObject userManagementa(HttpServletRequest request) { List userManagementList = sysSettingService.getuserManagement2(); JSONObject json = new JSONObject(); json.put("dataList", userManagementList); return json; } @ResponseBody @RequestMapping(value = "/userManagement_search.do", method = { RequestMethod.POST, RequestMethod.GET }) public String userManagement_search(HttpServletRequest request) { String input = request.getParameter("input"); int curPage = 1; List pageList = new ArrayList(); List userManagementList = sysSettingService.searchuserManagement(input); pageList.add(1); JSONObject json = new JSONObject(); json.put("dataList", userManagementList); json.put("pageList", pageList); json.put("curPage", curPage); return json.toString(); } @ResponseBody @RequestMapping(value = "/userManagement_searcha.do", method = { RequestMethod.POST, RequestMethod.GET }) public JSONObject userManagement_searcha(HttpServletRequest request) { String input = request.getParameter("username"); List userManagementList = sysSettingService.searchuserManagement(input); JSONObject json = new JSONObject(); json.put("dataList", userManagementList); return json; } @ResponseBody @RequestMapping(value = "/userManagement_page.do", method = { RequestMethod.POST, RequestMethod.GET }) public String userManagement_page(HttpServletRequest request) { String pageStr = request.getParameter("page"); String curPageStr = request.getParameter("curPage"); int count = sysSettingService.getuserManagementCount(); int minPage = PageUtil.getMinPage(count); int curPage = Integer.parseInt(curPageStr); int page = 1; if ("pre".equals(pageStr)) { if (curPage > 1) { page = curPage - 1; } } else if ("next".equals(pageStr)) { if (curPage < minPage) { page = curPage + 1; } } else { page = Integer.parseInt(pageStr); } List userManagementList = sysSettingService.getuserManagement(page); List pageList = PageUtil.getPage(PageUtil.getLocPage(page, curPage), page, minPage); JSONObject json = new JSONObject(); json.put("dataList", userManagementList); json.put("pageList", pageList); json.put("curPage", page); return json.toString(); } // 对象转数组 public static List objectToArray(List userManagementList) { List reList = new ArrayList<>(); for (int i = 0; i < userManagementList.size(); i++) { List words = new ArrayList(); tb_user user = (tb_user) userManagementList.get(i); words.add(String.valueOf(user.getId())); words.add(user.getUsername()); words.add(user.getSuperuser()); words.add(user.getDeleteq()); words.add(user.getDeleteall()); words.add(user.getAlertq()); words.add(user.getJustlook()); words.add(user.getFenceq()); words.add(String.valueOf(user.getAddtime())); String[] array = words.toArray(new String[0]); reList.add(array); } return reList; } @ResponseBody @RequestMapping(value = "/userManagement_export.do", method = { RequestMethod.POST, RequestMethod.GET }) public String userManagement_export(HttpServletRequest request, HttpServletResponse response) { String toPage = "forward:/hxzk/sysSetting/userManagement.jsp"; List userManagementList = sysSettingService.getuserManagement(); String[] rowName = { "序号","用户","级别","删除","修改","全部删除","仅观看","新增","添加时间"}; List dataList = objectToArray(userManagementList); ExcelUtils excel = new ExcelUtils("用户管理", rowName, dataList); OutputStream out; try { String fileName = "Excel-" + String.valueOf(System.currentTimeMillis()).substring(4, 13) + ".xls"; String headStr = "attachment; filename=\"" + fileName + "\""; response.setContentType("APPLICATION/OCTET-STREAM"); response.setHeader("Content-Disposition", headStr); out = response.getOutputStream(); excel.export(out); out.flush(); out.close(); } catch (Exception e) { e.printStackTrace(); } return toPage; } @RequestMapping(value = "/replay.do", method = { RequestMethod.POST, RequestMethod.GET }) public String replay(HttpServletRequest request) { String toPage = "forward:/hxzk/sysSetting/replay.jsp"; List replayList = sysSettingService.getreplay(); request.setAttribute("replayList", replayList); return toPage; } @ResponseBody @RequestMapping(value = "/userManagement_delete.do", method = { RequestMethod.POST, RequestMethod.GET }) public void userManagement_delete(HttpServletRequest request) { String checkValStr = request.getParameter("checkVal"); checkValStr = checkValStr.replaceAll("\"", ""); String[] checkVal = checkValStr.split(","); sysSettingService.userManagement_delete(checkVal); } @ResponseBody @RequestMapping(value = "/userManagement_deletea.do", method = { RequestMethod.POST, RequestMethod.GET }) public int userManagement_deletea(HttpServletRequest request) { String checkValStr = request.getParameter("checkVal"); checkValStr = checkValStr.replaceAll("\"", ""); String[] checkVal = checkValStr.split(","); int aaa = sysSettingService.userManagement_deletea(checkVal); return aaa; } @ResponseBody @RequestMapping(value = "/userManagement_deleteAll.do", method = { RequestMethod.POST, RequestMethod.GET }) public void userManagement_deleteAll(HttpServletRequest request) { sysSettingService.userManagement_deleteAll(); } @ResponseBody @RequestMapping(value = "/userManagement_deleteAlla.do", method = { RequestMethod.POST, RequestMethod.GET }) public int userManagement_deleteAlla(HttpServletRequest request) { int aaa = sysSettingService.userManagement_deleteAlla(); return aaa; } @ResponseBody @RequestMapping(value = "/userManagement_adda.do", method = { RequestMethod.POST, RequestMethod.GET }) public int userManagement_adda(HttpServletRequest request) { tb_user user = new tb_user(); user.setUsername(request.getParameter("username")); user.setPassword(request.getParameter("password")); user.setSuperuser(request.getParameter("superuser")); user.setDeleteq(request.getParameter("deleteq")); user.setAlertq(request.getParameter("alertq")); user.setDeleteall(request.getParameter("deleteall")); user.setJustlook(request.getParameter("justlook")); int bb = sysSettingService.userManagement_add(user); return bb; } @ResponseBody @RequestMapping(value = "/userManagement_add.do", method = { RequestMethod.POST, RequestMethod.GET }) public void userManagement_add(HttpServletRequest request) { tb_user user = new tb_user(); user.setUsername(request.getParameter("username")); user.setPassword(request.getParameter("password")); user.setSuperuser(request.getParameter("superuser")); user.setDeleteq(request.getParameter("deleteq")); user.setAlertq(request.getParameter("alertq")); user.setDeleteall(request.getParameter("deleteall")); user.setJustlook(request.getParameter("justlook")); user.setFenceq(request.getParameter("insert")); sysSettingService.userManagement_add(user); } @ResponseBody @RequestMapping(value = "/userManagement_modifya.do", method = { RequestMethod.POST, RequestMethod.GET }) public int userManagement_modifya(HttpServletRequest request) { tb_user user = new tb_user(); user.setId(Integer.parseInt(request.getParameter("id"))); user.setUsername(request.getParameter("username")); user.setPassword(request.getParameter("password")); user.setSuperuser(request.getParameter("superuser")); user.setDeleteq(request.getParameter("deleteq")); user.setAlertq(request.getParameter("alertq")); user.setDeleteall(request.getParameter("deleteall")); user.setJustlook(request.getParameter("justlook")); int bb = sysSettingService.userManagement_modify(user); return bb; } @ResponseBody @RequestMapping(value = "/userManagement_modify.do", method = { RequestMethod.POST, RequestMethod.GET }) public void userManagement_modify(HttpServletRequest request) { tb_user user = new tb_user(); user.setId(Integer.parseInt(request.getParameter("id"))); user.setUsername(request.getParameter("username")); user.setPassword(request.getParameter("password")); user.setSuperuser(request.getParameter("superuser")); user.setDeleteq(request.getParameter("deleteq")); user.setAlertq(request.getParameter("alertq")); user.setDeleteall(request.getParameter("deleteall")); user.setJustlook(request.getParameter("justlook")); user.setFenceq(request.getParameter("insert")); sysSettingService.userManagement_modify(user); } @RequestMapping(value = "/sysSetting.do", method = { RequestMethod.POST, RequestMethod.GET }) public String sysSetting(HttpServletRequest request) { String toPage = "forward:hxzk/sysSetting/sysSetting.jsp"; List settingList = sysSettingService.getSetting(); List maplist = mapService.getMapManagement(); List navList = zhwService.getnav(); request.setAttribute("dataList", navList); request.setAttribute("settingList", settingList); request.setAttribute("maplist", maplist); return toPage; } @ResponseBody @RequestMapping(value = "/getSysSetting.do", method = { RequestMethod.POST, RequestMethod.GET }) public String getSysSetting(HttpServletRequest request) { JSONObject json = new JSONObject(); List settingList = sysSettingService.getSetting(); json.put("result", settingList.get(0)); return json.toString(); } @RequestMapping(value = "/sysSetting_modify.do", method = { RequestMethod.POST, RequestMethod.GET }) public void sysSetting_modify(HttpServletRequest request) { tb_system setting = new tb_system(); setting.setDataname(request.getParameter("dataname")); setting.setDatapass(request.getParameter("datapass")); setting.setGui_ji(request.getParameter("gui_ji")); setting.setBei_fen_di_zhi(request.getParameter("bei_fen_di_zhi")); setting.setData_time(request.getParameter("data_time")); setting.setTitle(request.getParameter("title")); setting.setUdpPort(request.getParameter("udpPort")); setting.setUdpAdress(request.getParameter("udpAdress")); setting.setOpenudp(request.getParameter("openudp")); setting.setKnow_tag_zu(request.getParameter("know_tag_zu")); setting.setWifi_mdel(request.getParameter("wifi_mdel")); setting.setTagZb(request.getParameter("tagZb")); setting.setDiskaoqing(request.getParameter("diskaoqing")); setting.setViewAnckid(request.getParameter("viewAnckid")); setting.setViewName(request.getParameter("viewName")); setting.setTunlDw(request.getParameter("tunlDw")); setting.setGuiji_sava(request.getParameter("guiji_sava")); setting.setViewPower(request.getParameter("viewPower")); setting.setViewTagid(request.getParameter("viewTagid")); setting.setViewAnckzb(request.getParameter("viewAnckzb")); setting.setOffView(request.getParameter("offView")); setting.setAnckicon(request.getParameter("anckicon")); setting.setGas_show(request.getParameter("gas_show")); // setting.setQuiet(request.getParameter("quiet")); setting.setReal_trak_time(request.getParameter("real_trak_time")); setting.setReal_trak_color(request.getParameter("real_trak_color")); setting.setYulan_map(request.getParameter("yulan_map_tu")); setting.setBaidu_j(request.getParameter("baidu_j")); setting.setBaidu_w(request.getParameter("baidu_w")); setting.setGas_open(request.getParameter("gas_open")); setting.setGas_port(request.getParameter("gas_port")); setting.setGas_hz(request.getParameter("gas_hz")); setting.setRssid(request.getParameter("rssid")); setting.setFence_show(request.getParameter("fence_show")); tb_nav nav = new tb_nav(); nav.setLabel(request.getParameter("label")); nav.setAchor(request.getParameter("achor")); nav.setGps(request.getParameter("gps")); nav.setFence(request.getParameter("fence")); nav.setWarning(request.getParameter("warning")); nav.setHistory(request.getParameter("history")); nav.setAttendance(request.getParameter("attendance")); nav.setBasiclnfo(request.getParameter("basiclnfo")); nav.setVideo(request.getParameter("video")); nav.setGas(request.getParameter("gas")); sysSettingService.sysSetting_modify(setting); zhwService.updatenav(nav); } @ResponseBody @RequestMapping(value = "/sysSetting_modifya.do", method = { RequestMethod.POST, RequestMethod.GET }) public String sysSetting_modifya(HttpServletRequest request) { tb_system setting = new tb_system(); setting.setUdpAdress(request.getParameter("ip")); setting.setBaoliu20(request.getParameter("port")); setting.setBaoliu13(request.getParameter("sxtime")); setting.setBaoliu14(request.getParameter("tagupp")); setting.setBaoliu15(request.getParameter("fenceupp")); setting.setReal_trak_time(request.getParameter("realtraktime")); setting.setFence_show(request.getParameter("fenceshow")); setting.setViewAnckid(request.getParameter("viewAnckid")); setting.setBaoliu16(request.getParameter("showtracks")); setting.setBaoliu17(request.getParameter("shownews")); setting.setYulan_map(request.getParameter("map")); String xieyi = "BSTOCS1,U1ALTERSYSTEM,"+setting.getUdpAdress()+","+setting.getBaoliu20()+","+setting.getBaoliu13()+","+setting.getBaoliu14()+","+setting.getBaoliu15()+","+setting.getReal_trak_time()+","+setting.getFence_show()+","+setting.getViewAnckid()+","+setting.getBaoliu16()+","+setting.getBaoliu17()+","+setting.getYulan_map()+",END"; Udp_Out.udp_to_cs(xieyi); int aaa = sysSettingService.sysSetting_modifya(setting); return ""+aaa; } @ResponseBody @RequestMapping(value = "/getSysSettinga.do", method = { RequestMethod.POST, RequestMethod.GET }) public JSONObject getSysSettinga(HttpServletRequest request) { JSONObject json = new JSONObject(); List settingList = sysSettingService.getSetting(); json.put("dataList", settingList); return json; } @RequestMapping(value = "/algorithmConfiguration.do", method = { RequestMethod.POST, RequestMethod.GET }) public String algorithmConfiguration(HttpServletRequest request) { String toPage = "forward:hxzk/sysSetting/algorithmConfiguration.jsp"; List layerList = sysSettingService.getLayer(); request.setAttribute("layerList", layerList); List groupList = sysSettingService.getGroup(); request.setAttribute("groupList", groupList); return toPage; } @ResponseBody @RequestMapping(value = "/algorithmConfiguration_search.do", method = { RequestMethod.POST, RequestMethod.GET }) public String algorithmConfiguration_search(HttpServletRequest request) throws IOException { JSONObject json = new JSONObject(); String input = request.getParameter("input"); String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); tb_suanfa suanfa = (tb_suanfa) JSONObject.toBean(JSONObject.fromObject(jsonString), tb_suanfa.class); input = suanfa.getAnchorid(); List anchorManagementList = sysSettingService.searchAlgorithmConfiguration(input); json.put("result", anchorManagementList.get(0)); return json.toString(); } @RequestMapping(value = "/algorithmConfiguration_modify.do", method = { RequestMethod.POST, RequestMethod.GET }) public void algorithmConfiguration_modify(HttpServletRequest request) { tb_suanfa suanfa = new tb_suanfa(); suanfa.setFloor(request.getParameter("floor")); suanfa.setZu(request.getParameter("zu")); suanfa.setSufa(request.getParameter("sufa")); suanfa.setAnchor_num(request.getParameter("anchor_num")); suanfa.setJieji(request.getParameter("jieji")); suanfa.setXinhao_qiangdu(request.getParameter("xinhao_qiangdu")); suanfa.setYouxiao_qu(request.getParameter("youxiao_qu")); suanfa.setWuxiao_qu(request.getParameter("wuxiao_qu")); suanfa.setCaiyang_guolv(request.getParameter("caiyang_guolv")); suanfa.setCaiyang_canshu(request.getParameter("caiyang_canshu")); suanfa.setKuansong_model(request.getParameter("kuansong_model")); suanfa.setPingmian_buju(request.getParameter("kuansong_model")); suanfa.setDunjiao(request.getParameter("kuansong_model")); suanfa.setBujuqu_youxiao(request.getParameter("kuansong_model")); suanfa.setBujuqu_youxian(request.getParameter("kuansong_model")); sysSettingService.algorithmConfiguration_modify(suanfa); } // 所有报文 @RequestMapping(value = "/getMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void doPost(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getMessagePath()); if (!file.exists()) { file.createNewFile(); } // FileWriter fw = new FileWriter(file, true); // 设置成true就是追加 // fw.write(result); // fw.write("\r\n"); // ; // fw.close(); FileOutputStream fos = new FileOutputStream(file,true); BufferedOutputStream bos = new BufferedOutputStream(fos); bos.write((result+"\r\n").getBytes()); bos.flush(); bos.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } // 清空文件内容 public void clearInfoForFile(String fileName) { File file = new File(fileName); try { if (!file.exists()) { file.createNewFile(); } FileWriter fileWriter = new FileWriter(file); fileWriter.write(""); fileWriter.flush(); fileWriter.close(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.allMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // 原始报文 @RequestMapping(value = "/yuanshiMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void yuanshiMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getYuanshiMessagePath()); if (!file.exists()) { file.createNewFile(); } FileOutputStream fos = new FileOutputStream(file,true); BufferedOutputStream bos = new BufferedOutputStream(fos); bos.write((result+"\r\n").getBytes()); bos.flush(); bos.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayYuanshiMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayYuanshiMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.yuanshiMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } @ResponseBody @RequestMapping(value = "/displayUDPMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayUDPMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.udpMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // TCP @ResponseBody @RequestMapping(value = "/displayTCPMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayTCPMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.tcpMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // 调试报文 @RequestMapping(value = "/debugMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void debugMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getDebugMessagePath()); if (!file.exists()) { file.createNewFile(); } FileWriter fw = new FileWriter(file,true); //设置成true就是追加 fw.write(result); fw.write("\r\n");; fw.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayDebugMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayDebugMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.debugMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // 注册报文 @RequestMapping(value = "/zhuceMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void zhuceMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getZhuceMessagePath()); if (!file.exists()) { file.createNewFile(); } FileWriter fw = new FileWriter(file,true); //设置成true就是追加 fw.write(result); fw.write("\r\n");; fw.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayZhuceMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayZhuceMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.zhuceMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // mysql报文 @RequestMapping(value = "/mysqlMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void mysqlMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getMysqlMessagePath()); if (!file.exists()) { file.createNewFile(); } FileWriter fw = new FileWriter(file,true); //设置成true就是追加 fw.write(result); fw.write("\r\n");; fw.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } // 数据库数 @ResponseBody @RequestMapping(value = "/displayMysqlMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayMysqlMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.mysqlMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // 气体报文 @RequestMapping(value = "/gasMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void gasMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getGasMessagePath()); if (!file.exists()) { file.createNewFile(); } FileWriter fw = new FileWriter(file,true); //设置成true就是追加 fw.write(result); fw.write("\r\n");; fw.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayGasMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayGasMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.gasMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } // HEX显示 @RequestMapping(value = "/HEXMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void HEXMessage(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print("result" + jsonString); JSONObject json_test = JSONObject.fromObject(jsonString); String result = json_test.getString("result"); try { File file = new File(request.getServletContext().getRealPath("/")+Config.getHEXMessagePath()); if (!file.exists()) { file.createNewFile(); } FileWriter fw = new FileWriter(file,true); //设置成true就是追加 fw.write(result); fw.write("\r\n");; fw.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } @ResponseBody @RequestMapping(value = "/displayHEXMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected List displayHEXMessage(HttpServletRequest request) { try { List tmp = new ArrayList(); /* * tmp.addAll(Udp_Receive.hexMessage); Udp_Receive.allMessage.clear(); * Udp_Receive.zhuceMessage.clear(); Udp_Receive.debugMessage.clear(); * Udp_Receive.mysqlMessage.clear(); Udp_Receive.hexMessage.clear(); * Udp_Receive.gasMessage.clear(); Udp_Receive.tcpMessage.clear(); * Udp_Receive.yuanshiMessage.clear(); Udp_Receive.udpMessage.clear(); */ return tmp; } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); return null; } } @ResponseBody @RequestMapping(value = "/startMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void startMessage(HttpServletRequest request) { String BaowenPath = Config.getBaowenConfig(); /* * Udp_Receive.allMessage.clear(); Udp_Receive.zhuceMessage.clear(); * Udp_Receive.debugMessage.clear(); Udp_Receive.mysqlMessage.clear(); * Udp_Receive.hexMessage.clear(); Udp_Receive.gasMessage.clear(); * Udp_Receive.tcpMessage.clear(); Udp_Receive.yuanshiMessage.clear(); * Udp_Receive.udpMessage.clear(); */ ModifyConfig.writeData(BaowenPath, "baowenSwitch", "1"); } @ResponseBody @RequestMapping(value = "/stopMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void stopMessage(HttpServletRequest request) { String BaowenPath = Config.getBaowenConfig(); /* * Udp_Receive.allMessage.clear(); Udp_Receive.zhuceMessage.clear(); * Udp_Receive.debugMessage.clear(); Udp_Receive.mysqlMessage.clear(); * Udp_Receive.hexMessage.clear(); Udp_Receive.gasMessage.clear(); * Udp_Receive.tcpMessage.clear(); Udp_Receive.yuanshiMessage.clear(); * Udp_Receive.udpMessage.clear(); */ ModifyConfig.writeData(BaowenPath, "baowenSwitch", "0"); } @RequestMapping(value = "/doMessageTransfer.do", method = { RequestMethod.POST, RequestMethod.GET }) public void doMessageTransfer(HttpServletRequest request) throws IOException, InterruptedException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); JSONObject jsonResult = JSONObject.fromObject(jsonString); String dataType = jsonResult.getString("dataType"); String result = jsonResult.getString("result"); String wifi_model = sysSettingService.getSetting().get(0).getWifi_mdel(); List messageTransferList = sysSettingService.getALLMessageTransfer(dataType); //System.out.print(messageTransferList); DatagramPacket packet = null; DatagramSocket socket = new DatagramSocket(); if (messageTransferList.size() > 0) { for (int i = 0; i < messageTransferList.size(); i++) { String ip = messageTransferList.get(i).getIp(); String port = messageTransferList.get(i).getPort(); String type = messageTransferList.get(i).getType(); if (type.equals("UDP")) { try { packet = new DatagramPacket(result.getBytes(), result.getBytes().length, InetAddress.getByName(ip), Integer.parseInt(port)); } catch (NumberFormatException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } try { socket.send(packet); //延时 Thread.sleep(100); } catch (IOException e) { e.printStackTrace(); } try { socket.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } // 保存UDP转发报文 try { String BaowenPath = Config.getBaowenConfig(); String baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch"); if (baowenStatus.equals("1")){ /* Udp_Receive.udpMessage.add("发:"+result); */ } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } else if (type.equals("TCP")) { // TCP // if(Systems.sys().getWifi_model().equals("1")) { if (wifi_model.equals("1")) { port = "8234"; } try { Socket sck=new Socket(ip,Integer.parseInt(port)); //2.传输内容 byte[] bstream=result.getBytes("GBK"); //转化为字节流 OutputStream os=sck.getOutputStream(); //输出流 os.write(bstream); //3.关闭连接 // Thread.sleep(1000); sck.close(); } catch (Exception e1) { // TODO Auto-generated catch block //e1.printStackTrace(); continue; } // 保存TCP转发报文 try { String BaowenPath = Config.getBaowenConfig(); String baowenStatus = ModifyConfig.readData(BaowenPath, "baowenSwitch"); if (baowenStatus.equals("1")){ /* Udp_Receive.udpMessage.add("发:"+result); */ } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } else if (type.equals("HTTP")) { // http/https String url = "http://" + ip + ":" + port; String str = "{\"result\":\"" + result + "\"}"; JSONObject json = JSONObject.fromObject(str); HttpUtil.doPost(url, json, "UTF-8"); } else if (type.equals("HTTPS")) { // http/https String url = "https://" + ip + ":" + port; String str = "{\"result\":\"" + result + "\"}"; JSONObject json = JSONObject.fromObject(str); HttpUtil.doPost(url, json, "UTF-8"); } } } } @ResponseBody @RequestMapping(value = "/saveMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void saveMessage(HttpServletRequest request) { String data = request.getParameter("data"); String[] lines = data.split("\\r?\\n"); System.out.println(data); int count = 1; for (String line : lines) { System.out.println("line " + count++ + " : " + line); tb_yuan_shi_bao_wen yuanshibaowen = new tb_yuan_shi_bao_wen(); String str1=line.substring(0, line.indexOf(":")); String str2=line.substring(str1.length()+1, line.length()); yuanshibaowen.setStr(str2); sysSettingService.baowen_add(yuanshibaowen); } } @ResponseBody @RequestMapping(value = "/sendMessage.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void sendMessage(HttpServletRequest request) throws SocketException, NumberFormatException, UnknownHostException { try { String ip = request.getParameter("ip"); String port = request.getParameter("port"); String content = request.getParameter("content"); DatagramPacket packet = null; DatagramSocket socket = null; InetAddress address = null; try { address = InetAddress.getByName(ip); } catch (UnknownHostException e) { e.printStackTrace(); } try { socket = new DatagramSocket(); } catch (SocketException e) { e.printStackTrace(); } try { packet = new DatagramPacket(content.getBytes(), content.getBytes().length, address, Integer.parseInt(port)); } catch (Exception e1) { // TODO Auto-generated catch block e1.printStackTrace(); } try { socket.send(packet); Thread.sleep(100); //System.out.print("udp发送成功"); } catch (IOException e) { e.printStackTrace(); } try { socket.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } @RequestMapping(value = "/startDebug.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void startDebug(HttpServletRequest request) { String filePath = Config.getBaowenConfig(); ModifyConfig.writeData(filePath, "debugSwitch", "1"); } @RequestMapping(value = "/stopDebug.do", method = { RequestMethod.POST, RequestMethod.GET }) protected void stopDebug(HttpServletRequest request) { String filePath = Config.getBaowenConfig(); ModifyConfig.writeData(filePath, "debugSwitch", "0"); } @ResponseBody @RequestMapping(value = "/sysSetting_bw.do", method = { RequestMethod.POST, RequestMethod.GET }) public String sysSetting_bw(HttpServletRequest request) { JSONObject json = new JSONObject(); List settingList = sysSettingService.getSetting(); json.put("result", settingList.get(0)); return json.toString(); } // @ResponseBody // @RequestMapping(value = "/backup.do", method = { RequestMethod.POST, RequestMethod.GET }) // public String backup(HttpServletRequest request) { // String name = DateUtil.formatDate(new Date(),"yyyyMMddHHmmss"); // String filePath = request.getServletContext().getRealPath("/")+"backup\\"; // File uploadDir = new File(filePath); // if(!uploadDir.exists()){//如果文件夹不存在 // uploadDir.mkdir();//创建文件夹 // } // String mysqlDumpPath = Config.getMysqlDumpPath(); // String database =sysSettingService.getSetting().get(0).getDataname(); // String password = sysSettingService.getSetting().get(0).getDatapass(); // String cmd = "cmd /c "+ mysqlDumpPath + " -uroot" + " -p" + password + " " + database + " > " // + filePath + database + "_" + name + ".sql"; // //System.out.print(cmd); // // //执行备份命令 // try { // Runtime.getRuntime().exec(cmd); // } catch (Exception ex) { // return ex.getMessage(); // } // return filePath; // } @ResponseBody @RequestMapping(value = "/backup.do", method = { RequestMethod.POST, RequestMethod.GET }) public String backup(HttpServletRequest request) { String name = DateUtil.formatDate(new Date(),"yyyyMMddHHmmss"); String savePath = "d:\\" + name + ".sql"; String host = Config.getMysqlHost(); String port = Config.getMysqlPort(); String database =sysSettingService.getSetting().get(0).getDataname(); String password = sysSettingService.getSetting().get(0).getDatapass(); String cmd ="mysqldump -h "+host+" -P "+ port+ " -uroot" + " -p" + password + " " + database; //System.out.print(cmd); return savePath; } @ResponseBody @RequestMapping(value = "/recovery.do", method = { RequestMethod.POST, RequestMethod.GET }) public String recovery(HttpServletRequest request) throws IOException { String fileName = request.getParameter("filename"); if (fileName != ""){ String recoverPath ="d:\\"+fileName; String database =sysSettingService.getSetting().get(0).getDataname(); String password = sysSettingService.getSetting().get(0).getDatapass(); String host = Config.getMysqlHost(); String port = Config.getMysqlPort(); String cmd = "mysql -h "+host+" -P "+port+ " -uroot" + " -p" + password + " " + database; //System.out.print(cmd); boolean b2 = new DatabaseUtil().recover(cmd, recoverPath); return String.valueOf(b2); } else { return "0"; } } @RequestMapping(value = "/systemDebug.do", method = { RequestMethod.POST, RequestMethod.GET }) public String systemDebug(HttpServletRequest request) { String toPage = "forward:/hxzk/sysSetting/systemDebug.jsp"; List labelList = sysSettingService.getLabel(); request.setAttribute("labelList", labelList); return toPage; } @ResponseBody @RequestMapping(value = "/shiyan.do", method = { RequestMethod.POST, RequestMethod.GET }) public void shiyan(HttpServletRequest request) throws IOException { String jsonString = RequestUtils.getRequestJsonString(request, Config.getCharset()); //System.out.print(jsonString); //System.out.print("执行了"); } }