package com.hxzkoa.controller;
|
|
import java.io.File;
|
import java.io.FileWriter;
|
import java.io.IOException;
|
import java.lang.Thread.State;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import javax.servlet.ServletContext;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpSession;
|
|
//import org.apache.tomcat.jni.Thread;
|
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_system;
|
import com.hxzkoa.json.tb_user;
|
import com.hxzkoa.services.LoginService;
|
import com.hxzkoa.services.SysSettingService;
|
import com.hxzkoa.udp.Baowen_Receive;
|
import com.hxzkoa.udp.Dell_tag_reg_ms;
|
import com.hxzkoa.udp.Gas_Receive;
|
import com.hxzkoa.udp.Gps_Receive;
|
import com.hxzkoa.udp.Transfer_Receive;
|
/*import com.hxzkoa.udp.Udp_Receive;*/
|
import com.hxzkoa.udp.Yuanshi_Receive;
|
import com.hxzkoa.udp.Yuanshibaowen;
|
import com.hxzkoa.udp.Zhuce_Receive;
|
import com.hxzkoa.util.Config;
|
import com.hxzkoa.util.HttpUtil;
|
import com.hxzkoa.util.ModifyConfig;
|
|
import net.sf.json.JSONObject;
|
|
@Controller
|
public class LoginController {
|
@Autowired
|
private LoginService loginService;
|
|
/* Udp_Receive receive1; */
|
Gps_Receive receive2;
|
Transfer_Receive receive3;
|
Yuanshi_Receive receive4;
|
Gas_Receive receive5;
|
Zhuce_Receive receive6;
|
Baowen_Receive receive7;
|
Dell_tag_reg_ms thread1;
|
/**
|
* 登录控制
|
*
|
* @param username
|
* @param password
|
* @param request
|
* @return
|
*/
|
@RequestMapping(value = "/login.do", method = { RequestMethod.POST, RequestMethod.GET })
|
@ResponseBody
|
public String login(HttpServletRequest request) {
|
String username = request.getParameter("username");
|
String password = request.getParameter("password");
|
tb_user user = loginService.login(username);
|
String result = "0";
|
String db_password = user.getPassword();
|
if (password.equals(db_password)) {
|
HttpSession session = request.getSession();
|
ServletContext application = session.getServletContext();
|
application.setAttribute("username", user.getUsername());
|
application.setAttribute("password", user.getPassword());
|
application.setAttribute("superuser", user.getSuperuser());
|
application.setAttribute("deleteq", user.getDeleteq());
|
application.setAttribute("alertq", user.getAlertq());
|
application.setAttribute("deleteall", user.getDeleteall());
|
session.setAttribute("username", user.getUsername());
|
session.setAttribute("password", user.getPassword());
|
session.setAttribute("superuser", user.getSuperuser());
|
session.setAttribute("deleteq", user.getDeleteq());
|
session.setAttribute("alertq", user.getAlertq());
|
session.setAttribute("deleteall", user.getDeleteall());
|
result = "1";
|
String username2 = (String) application.getAttribute("username");
|
//System.out.print(username2);
|
|
// tb_system system = new tb_system();
|
// system.setUdpPort("8234");
|
// //System.out.print(system);
|
// JSONObject jsonObject = JSONObject.fromObject(system);
|
// String postUrl = Config.getPostUrl();
|
// String url_setting_bw = postUrl + "getSysSetting.do";
|
// //System.out.print(url_setting_bw);
|
// 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);
|
// //System.out.print(re_setting);
|
// String port = re_setting.getUdpPort();
|
// 开启报文接收
|
// try {
|
// receive1 = new Udp_Receive(port);
|
// receive2 = new Gps_Receive();
|
// receive3 = new Transfer_Receive();
|
// receive4 = new Yuanshi_Receive();
|
// receive5 = new Gas_Receive();
|
// receive6 = new Zhuce_Receive();
|
// receive7 = new Baowen_Receive();
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// if (Config.getUdpRunning().equals("1")) {
|
// try {
|
// receive1.startThread();
|
// receive2.startThread();
|
// receive3.startThread();
|
// receive4.startThread();
|
// receive5.startThread();
|
// receive6.startThread();
|
// receive7.startThread();
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// }
|
//
|
}
|
|
|
//初始化配置文件
|
/*
|
* Udp_Receive.allMessage = new ArrayList<String>(); Udp_Receive.zhuceMessage =
|
* new ArrayList<String>(); Udp_Receive.debugMessage = new ArrayList<String>();
|
* Udp_Receive.mysqlMessage = new ArrayList<String>(); Udp_Receive.hexMessage =
|
* new ArrayList<String>(); Udp_Receive.gasMessage = new ArrayList<String>();
|
* Udp_Receive.tcpMessage = new ArrayList<String>(); Udp_Receive.yuanshiMessage
|
* = new ArrayList<String>(); Udp_Receive.udpMessage = new ArrayList<String>();
|
*/
|
File fileBaowen = new File(Config.getBaowenConfig());
|
if (!fileBaowen.exists()){
|
try {
|
fileBaowen.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
File fileAnchor = new File(Config.getAnchorConfig());
|
if (!fileAnchor.exists()){
|
try {
|
fileAnchor.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
File fileMap = new File(Config.getMapConfig());
|
if (!fileMap.exists()){
|
try {
|
fileMap.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
File filePage = new File(Config.getPageConfig());
|
if (!filePage.exists()){
|
try {
|
filePage.createNewFile();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
|
String perPage = Config.getPageConfig();
|
ModifyConfig.writeData(perPage, "perPage", "10");
|
String BaowenPath = Config.getBaowenConfig();
|
ModifyConfig.writeData(BaowenPath, "baowenSwitch", "0");
|
ModifyConfig.writeData(BaowenPath, "debugSwitch", "0");
|
ModifyConfig.writeData(BaowenPath, "yuanshiMessage", "");
|
ModifyConfig.writeData(BaowenPath, "udpMessage", "3");
|
String data = ModifyConfig.readData(BaowenPath, "udpMessage");
|
ModifyConfig.writeData(BaowenPath, "tcpMessage", "");
|
ModifyConfig.writeData(BaowenPath, "gasMessage", "");
|
ModifyConfig.writeData(BaowenPath, "hexMessage", "");
|
ModifyConfig.writeData(BaowenPath, "mysqlMessage", "");
|
ModifyConfig.writeData(BaowenPath, "debugMessage", "");
|
ModifyConfig.writeData(BaowenPath, "zhuceMessage", "");
|
ModifyConfig.writeData(BaowenPath, "allMessage", "");
|
String MapPath = Config.getMapConfig();
|
ModifyConfig.writeData(MapPath, "map_now", "百度地图");
|
String AnchorPath = Config.getAnchorConfig();
|
ModifyConfig.writeData(AnchorPath, "shebeimoshi", "");
|
ModifyConfig.writeData(AnchorPath, "zhudongceju", "");
|
ModifyConfig.writeData(AnchorPath, "kaiqixintiao", "");
|
ModifyConfig.writeData(AnchorPath, "jizhanid", "");
|
ModifyConfig.writeData(AnchorPath, "fashegonglv", "");
|
ModifyConfig.writeData(AnchorPath, "wuchajiaozhun", "");
|
ModifyConfig.writeData(AnchorPath, "lvbocanshu", "");
|
ModifyConfig.writeData(AnchorPath, "tongxunxiaozu", "");
|
ModifyConfig.writeData(AnchorPath, "tongxunpinlv", "");
|
ModifyConfig.writeData(AnchorPath, "tongxunshangxian", "");
|
ModifyConfig.writeData(AnchorPath, "gujianbanben", "");
|
ModifyConfig.writeData(AnchorPath, "tongbujizhan", "");
|
ModifyConfig.writeData(AnchorPath, "tongbuleixing", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhanshuliang", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan1", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan2", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan3", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan4", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan5", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan6", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan7", "");
|
ModifyConfig.writeData(AnchorPath, "linjinjizhan8", "");
|
ModifyConfig.writeData(AnchorPath, "qiehuanjuli", "");
|
ModifyConfig.writeData(AnchorPath, "anchorid", "");
|
ModifyConfig.writeData(AnchorPath, "anchorip", "");
|
ModifyConfig.writeData(AnchorPath, "readpeizhi", "");
|
ModifyConfig.writeData(AnchorPath, "beice_anchor", "");
|
ModifyConfig.writeData(AnchorPath, "huceju", "");
|
return result;
|
}
|
|
@RequestMapping(value = "/logout.do", method = { RequestMethod.POST, RequestMethod.GET })
|
public String logout(HttpServletRequest request) throws Exception {
|
HttpSession session = request.getSession();
|
ServletContext application = session.getServletContext();
|
application.removeAttribute("username");
|
application.removeAttribute("password");
|
application.removeAttribute("superuser");
|
application.removeAttribute("deleteq");
|
application.removeAttribute("alertq");
|
application.removeAttribute("deleteall");
|
session.removeAttribute("username");
|
session.removeAttribute("password");
|
session.removeAttribute("superuser");
|
session.removeAttribute("deleteq");
|
session.removeAttribute("alertq");
|
session.removeAttribute("deleteall");
|
|
// 停止报文接收
|
if (Config.getUdpRunning().equals("1")) {
|
try {
|
// thread1.stopThread();
|
// receive7.stopThread();
|
// receive6.stopThread();
|
// receive5.stopThread();
|
// receive4.stopThread();
|
receive3.stopThread();
|
// receive2.stopThread();
|
/* receive1.stopThread(); */
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
return "redirect:/hxzk/login.jsp";
|
}
|
}
|
