Wangyanyixiang_branch
Lin 5 months ago
parent 22050ebd56
commit 06c2fd3d81

@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry including="**/*.java" kind="src" output="target/classes" path="src">
<attributes>
<attribute name="optional" value="true"/>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/jdk21">
<attributes>
<attribute name="module" value="true"/>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.jst.j2ee.internal.web.container"/>
<classpathentry kind="con" path="org.eclipse.jst.j2ee.internal.module.container"/>
<classpathentry kind="lib" path="D:/apache-tomcat-9.0.87-windows-x64/apache-tomcat-9.0.87/lib/jsp-api.jar"/>
<classpathentry kind="lib" path="D:/apache-tomcat-9.0.87-windows-x64/apache-tomcat-9.0.87/lib/servlet-api.jar"/>
<classpathentry kind="lib" path="D:/apache-tomcat-9.0.87-windows-x64/apache-tomcat-9.0.87/lib/tomcat-api.jar"/>
<classpathentry kind="lib" path="D:/college/SE2/jar_files/mysql-connector-java-8.0.16.jar"/>
<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
<attributes>
<attribute name="maven.pomderived" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="lib" path="D:/college/SE2/jar_files/json-20240303.jar"/>
<classpathentry kind="output" path="target/classes"/>
</classpath>

8
.idea/.gitignore vendored

@ -0,0 +1,8 @@
# Default ignored files
/shelf/
/workspace.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectRootManager" version="2" languageLevel="JDK_21" default="true" project-jdk-name="jdk21" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/classes" />
</component>
</project>

@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>air_ticket_book</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
<buildCommand>
<name>org.eclipse.jdt.core.javabuilder</name>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.wst.common.project.facet.core.builder</name>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.wst.validation.validationbuilder</name>
<arguments>
</arguments>
</buildCommand>
<buildCommand>
<name>org.eclipse.m2e.core.maven2Builder</name>
<arguments>
</arguments>
</buildCommand>
</buildSpec>
<natures>
<nature>org.eclipse.m2e.core.maven2Nature</nature>
<nature>org.eclipse.jem.workbench.JavaEMFNature</nature>
<nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
<nature>org.eclipse.wst.common.project.facet.core.nature</nature>
<nature>org.eclipse.jdt.core.javanature</nature>
<nature>org.eclipse.wst.jsdt.core.jsNature</nature>
</natures>
</projectDescription>

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<classpath>
<classpathentry excluding="**/bower_components/*|**/node_modules/*|**/*.min.js" kind="src" path="WebContent"/>
<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.JRE_CONTAINER"/>
<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.WebProject">
<attributes>
<attribute name="hide" value="true"/>
</attributes>
</classpathentry>
<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.baseBrowserLibrary"/>
<classpathentry kind="output" path=""/>
</classpath>

@ -0,0 +1,11 @@
eclipse.preferences.version=1
org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
org.eclipse.jdt.core.compiler.compliance=1.8
org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
org.eclipse.jdt.core.compiler.release=disabled
org.eclipse.jdt.core.compiler.source=1.8

@ -0,0 +1,4 @@
activeProfiles=
eclipse.preferences.version=1
resolveWorkspaceProjects=true
version=1

@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?><project-modules id="moduleCoreId" project-version="1.5.0">
<wb-module deploy-name="air_ticket_book">
<wb-resource deploy-path="/" source-path="/WebContent" tag="defaultRootSource"/>
<wb-resource deploy-path="/WEB-INF/classes" source-path="/src"/>
<property name="java-output-path" value="/air_ticket_book/build/classes"/>
<property name="context-root" value="air_ticket_book"/>
</wb-module>
</project-modules>

@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<faceted-project>
<fixed facet="jst.web"/>
<fixed facet="wst.jsdt.web"/>
<fixed facet="java"/>
<installed facet="java" version="1.8"/>
<installed facet="jst.web" version="3.0"/>
<installed facet="wst.jsdt.web" version="1.0"/>
</faceted-project>

@ -0,0 +1 @@
org.eclipse.wst.jsdt.launching.baseBrowserLibrary

@ -0,0 +1,2 @@
eclipse.preferences.version=1
org.eclipse.wst.ws.service.policy.projectEnabled=false

Binary file not shown.

Binary file not shown.

Binary file not shown.

@ -0,0 +1,19 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="https://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>air_ticket_book</groupId>
<artifactId>air_ticket_book</artifactId>
<version>0.0.1-SNAPSHOT</version>
<build>
<sourceDirectory>src</sourceDirectory>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>

@ -0,0 +1,93 @@
package javabean;
/********************
*@IDE eclipse
*@jdk 1.8.0_161
*********************/
import java.sql.*;
public class db_conn {
public Connection conn = null;
public ResultSet res = null;
public Statement st = null;
//数据库初始化连接
public db_conn() {
String URL="jdbc:mysql://localhost:3307/fly_ticket?useSSL=false&useUnicode=true&characterEncoding=UTF8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC"; //数据库名3306
String USER="root"; //数据库用户名
String PWD="123456"; //数据库密码
try{
Class.forName("com.mysql.cj.jdbc.Driver");
}catch(ClassNotFoundException e){
System.out.println("加载驱动失败");
System.out.println(e);
}
try{
conn = DriverManager.getConnection(URL,USER,PWD);
// System.out.println("success");
st=conn.createStatement();
}catch(SQLException e){
System.out.println("连接数据库失败");
System.out.println(e);
}
}
//向数据库中添加数据
public int executeInsert(String sql){
int num=0;
try{
num=st.executeUpdate(sql);
}
catch(SQLException e){
System.out.println("添加数据出错信息:"+e.getMessage());
}
return num;
}
//从数据库中查询数据
public ResultSet executeQuery(String sql){
res=null;
try{
res=st.executeQuery(sql);
}
catch(SQLException e){
System.out.print("查询出错信息:"+e.getMessage());
}
return res;
}
//更新数据
public int Update(String sql){
int num=0;
try{
num=st.executeUpdate(sql);
}catch(SQLException ex){
System.out.print("执行修改有错误:"+ex.getMessage());
}
return num;
}
//删除数据
public int executeDelete(String sql){
int num=0;
try{
num=st.executeUpdate(sql);
}
catch(SQLException e){
System.out.print("执行删除有错误:"+e.getMessage());
}
return num;
}
//关闭数据库连接
public void closeDB(){
try{
st.close();
conn.close();
}
catch(Exception e){
System.out.print("执行关闭Connection对象有错误:"+e.getMessage());
}
}
}

@ -0,0 +1,61 @@
package javabean;
public class flight { //航班类
private String f_n=null;//航班号
private String f_s_p=null;//起飞地点
private String f_a_p=null;//飞行终点
private String f_s_a=null;//起飞机场
private String f_a_a=null;//到达机场
private String f_s_t=null;//起飞时间
private String f_a_t=null;//到达时间
private String f_p=null;//票价
public String getF_n() {
return f_n;
}
public void setF_n(String f_n) {
this.f_n = f_n;
}
public String getF_s_p() {
return f_s_p;
}
public void setF_s_p(String f_s_p) {
this.f_s_p = f_s_p;
}
public String getF_a_p() {
return f_a_p;
}
public void setF_a_p(String f_a_p) {
this.f_a_p = f_a_p;
}
public String getF_s_a() {
return f_s_a;
}
public void setF_s_a(String f_s_a) {
this.f_s_a = f_s_a;
}
public String getF_a_a() {
return f_a_a;
}
public void setF_a_a(String f_a_a) {
this.f_a_a = f_a_a;
}
public String getF_s_t() {
return f_s_t;
}
public void setF_s_t(String f_s_t) {
this.f_s_t = f_s_t;
}
public String getF_a_t() {
return f_a_t;
}
public void setF_a_t(String f_a_t) {
this.f_a_t = f_a_t;
}
public String getF_p() {
return f_p;
}
public void setF_p(String f_p) {
this.f_p = f_p;
}
}

@ -0,0 +1,49 @@
package javabean;
import java.sql.ResultSet;
import java.sql.SQLException;
import javabean.db_conn;
//用户头像功能
public class get_img {
public String img;
public String user_id;
public String getUser_id() {
return user_id;
}
public void setUser_id(String user_id) {
this.user_id = user_id;
}
public String getImg() {
//System.out.println("函数被调用了");
db_conn conn=new db_conn();
String sql="select avatar_img from common_user where "
+ "user_name='"+getUser_id()+"'";
ResultSet res=conn.executeQuery(sql);
try {
if(res.next()) {
img=res.getString(1);
if(img==null) {
img="/air_ticket_book/index/images/photo.png";
}else {
img="/air_ticket_book/index/upload/"+img;
}
}
} catch (SQLException e) {
System.out.println("出错信息如下:"+e);
}
return img;
}
public void setImg(String img) {
this.img = img;
}
}

@ -0,0 +1,16 @@
package javabean;
import java.util.Calendar;
public class oDate {
public String get_date() {
String date=null;
Calendar cal=Calendar.getInstance();
int y=cal.get(Calendar.YEAR);
int m=cal.get(Calendar.MONTH)+1;
int d=cal.get(Calendar.DATE);
date=y+"-"+m+"-"+d;
return date;
}
}

@ -0,0 +1,48 @@
package javabean;
public class passenger { //顾客类
private String p_id=null;//身份证号
private String p_name=null;//姓名
private String p_tel=null;//电话
private String p_sex=null;//性别
private String p_work=null;//工作单位
private String p_pwd=null;//密码
public String get_p_id() {
return p_id;
}
public void set_p_id(String p_id) {
this.p_id = p_id;
}
public String get_p_name() {
return p_name;
}
public void set_p_name(String p_name) {
this.p_name = p_name;
}
public String get_p_tel() {
return p_tel;
}
public void set_p_tel(String p_tel) {
this.p_tel = p_tel;
}
public String get_p_sex() {
return p_sex;
}
public void set_p_sex(String p_sex) {
this.p_sex = p_sex;
}
public String get_p_work() {
return p_work;
}
public void set_p_work(String p_work) {
this.p_work = p_work;
}
public String get_p_pwd() {
return p_pwd;
}
public void set_p_pwd(String p_pwd) {
this.p_pwd = p_pwd;
}
}

@ -0,0 +1,56 @@
package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javabean.db_conn;
public class addFlight extends HttpServlet{
private static final long serialVersionUID = 1L;
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
//开始获取各种参数
req.setCharacterEncoding("utf-8");
String flight_id=req.getParameter("flight_id");
String start_place=req.getParameter("start_place");
String end_place=req.getParameter("end_place");
String start_airport=req.getParameter("start_airport");
String end_airport=req.getParameter("end_airport");
String take_off_time=req.getParameter("take_off_time");
String landing_time=req.getParameter("landing_time");
String price_str=req.getParameter("first_class_price");
Integer price=Integer.parseInt(price_str);
//参数获取结束
db_conn conn=new db_conn();
String sql="select * from flight where f_n='"+flight_id+"'";
ResultSet res=conn.executeQuery(sql);
try {
if(res.next()) {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out=resp.getWriter();
out.println("您输入的航班号重复了请选择其他航班号添加5s后返回");
resp.setHeader("refresh", "5;url=admin/flight_add.jsp");
}else {
sql="insert into flight values('"+flight_id+"','"+start_place+"','"+end_place+"','"+start_airport+"','"+end_airport+"','"+take_off_time+"','"+landing_time+"',"+price+")";
//Integer res=
conn.executeInsert(sql);
//System.out.println(res);
//System.out.println(sql);
resp.sendRedirect("admin/flight_list.jsp");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

@ -0,0 +1,61 @@
package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javabean.db_conn;
/**
* Servlet implementation class addticket
*/
@WebServlet("/addticket")
public class addticket extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
String ticket_id=req.getParameter("ticket_id");
String flight_id=req.getParameter("flight_id");
String date=req.getParameter("date");
String seat_id=req.getParameter("seat_id");
//参数获取结束
db_conn conn=new db_conn();
String sql="select * from ticket where t_id='"+flight_id+"'";
ResultSet res=conn.executeQuery(sql);
try {
if(res.next()) {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out=resp.getWriter();
out.println("您输入的机票号重复了请选择其他机票号添加5s后返回");
resp.setHeader("refresh", "5;url=admin/ticket_add.jsp");
}else {
sql="insert into ticket values('"+ticket_id+"','"+flight_id+"','"+date+"','"+seat_id+"','"+1+"','"+0+"','"+0+"',"+0+")";
//Integer res=
conn.executeInsert(sql);
//System.out.println(res);
//System.out.println(sql);
resp.sendRedirect("admin/ticket_information.jsp");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
resp.setContentType("text/html;charset=utf-8");
PrintWriter out=resp.getWriter();
out.println("您添加的机票出错了,可能是输入的航班号不存在,禁止添加机票座位");
resp.setHeader("refresh", "5;url=admin/ticket_add.jsp");
e.printStackTrace();
}
}
}

@ -0,0 +1,62 @@
package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;
public class check extends HttpServlet {
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out = resp.getWriter();
out.println("请使用默认方式提交数据,不要尝试非法操作");
}
public void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
resp.setContentType("text/html;charset=utf-8");
String id = null;
String password = null;
HttpSession session = req.getSession();
id = req.getParameter("id");
password = req.getParameter("password");
db_conn conn = new db_conn();
String sql = "select * from admin_user where user = '"+id+"'";
try {
ResultSet res = conn.executeQuery(sql);
if(res.next()) {
String pwd = res.getString(2);
//System.out.println(pwd+"hha");
if(password.equals(pwd)) {
session.setAttribute("admin_id", id);
resp.sendRedirect("frame");
}else {
System.out.println("密码错误"+res);
resp.sendRedirect("/air_ticket_book/admin/index.jsp");
}
}else {
System.out.println("账号错误");
resp.sendRedirect("/air_ticket_book/admin/index.jsp");
}
}catch(SQLException e) {
System.out.println("出现不可预见性错误,错误信息如下:"+e);
}
}
}

@ -0,0 +1,159 @@
package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;//导入连接数据库类
public class check_login_reg extends HttpServlet {
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out = resp.getWriter();
out.println("该程序不接受直接访问,请不要尝试非法操作");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}
public void doPost(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
String log_name = req.getParameter("log_name");
String tel=req.getParameter("reg_name");
String id=req.getParameter("reg_p_id");
String name=req.getParameter("reg_p_name");
String sex=req.getParameter("reg_p_sex");
String work=req.getParameter("reg_p_work");
String log_pwd = req.getParameter("log_pwd");
String reg_name = req.getParameter("reg_name");
String reg_pwd1 = req.getParameter("reg_pwd1");
String reg_pwd2 = req.getParameter("reg_pwd2");
if(log_name!=null&&log_pwd!=null&&reg_name==null&&reg_pwd1==null&&reg_pwd2==null) {
//调用登录方法处理登录
go_login(log_name, log_pwd, req, resp);
}
else if(log_name==null&&log_pwd==null&&reg_name!=null&&reg_pwd1!=null&&reg_pwd2!=null&&reg_pwd1.equals(reg_pwd2)) {
//调用注册方法处理注册
go_reg(id,name,tel,sex,work,reg_pwd1, req, resp);
}
else {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out = resp.getWriter();
out.println("请不要尝试非法操作");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}
}
protected void go_login(String name, String pwd, HttpServletRequest req, HttpServletResponse resp) {
//System.out.println("go_login被调用了");
db_conn conn = new db_conn();//创建数据库连接对象
//取出cookie验证是否有url如果有url则跳转到url如果没有则跳转到index.jsp
//目的是跳转到用户浏览的原页面,提高用户体验感
HttpSession session = req.getSession();
/*放弃cookie转向使用session解决登录后页面跳转的问题cookie貌似无法解决这个问题*/
String sql = "select * from p_inf where p_tel = '"+name+"'";
ResultSet res = conn.executeQuery(sql);
try {
if(res.next()) {
String p_pwd = res.getString(6);
if(pwd.equals(p_pwd)) {
session.setAttribute("user_id", name);
if(session.getAttribute("url")!=null) {
String url = session.getAttribute("url").toString();
try{
url="/air_ticket_book/index.jsp";
resp.sendRedirect(url);
}
catch (IOException e) {
System.out.println("出错信息如下:"+e);
}
}else {
try {
resp.sendRedirect("user_center");
}
catch (IOException e) {
System.out.println("出错信息如下:"+e);
}
}
}else {
//用户输入密码错误
try {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out = resp.getWriter();
out.println("密码错误,请重新登录");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}catch (IOException e) {
System.out.println("出错信息如下:"+e);
}
}
}else {
//用户账号错误
try {
resp.setContentType("text/html;charset=utf-8");
PrintWriter out = resp.getWriter();
out.println("账号错误,请重新登录");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}catch (IOException e) {
System.out.println("出错信息如下:"+e);
}
}
conn.closeDB();
}
catch (SQLException e) {
System.out.println("出错信息如下:"+e);
}
}
protected void go_reg(String id,String name, String tel,String sex,String work,String pwd1,HttpServletRequest req, HttpServletResponse resp) {
//System.out.println("注册方法被调用了");
resp.setContentType("text/html;charset=utf-8");
db_conn conn = new db_conn();//创建数据库连接对象
String sql = "select * from p_inf where p_tel = '"+tel+"'";
ResultSet res = conn.executeQuery(sql);
try {
PrintWriter out = resp.getWriter();
try {
if(res.next()) {
out.println("该手机号已有注册账号");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}else {
sql = "insert into p_inf (p_id,p_name,p_tel,p_sex,p_work,p_pwd) values('"+id+"','"+name+"','"+tel+"','"+sex+"','"+work+"','"+pwd1+"')";
int in_res = conn.executeInsert(sql);
//System.out.println(in_res);
if(in_res==1) {
out.println("注册成功2秒之后跳转到登录页面");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}else {
out.println("出错啦请联系开发人员进行修补bug");
resp.setHeader("refresh", "2;url=index/login_reg.jsp");
}
}
}catch (Exception e) {
System.out.print("错误信息如下:"+e);
}
}catch (IOException e) {
System.out.println("出错啦"+e);
}
conn.closeDB();
}
}

@ -0,0 +1,45 @@
package servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javabean.db_conn;
import javabean.oDate;
public class deal_message extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
resp.sendRedirect("default/message_board.jsp");
//用户非法的操作,直接忽略即可
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
//System.out.println("dopost被调用了");
req.setCharacterEncoding("utf-8");
oDate o_date=new oDate();
String user_name=null;
String user_message=null;
user_name=req.getParameter("name").toString();
user_message=req.getParameter("message").toString();
String getDate=o_date.get_date();
if(!user_name.equals("")&&!user_message.equals("")) {
//System.out.println("条件语句判断成功了");
db_conn conn = new db_conn();
String sql="insert into user_message (time,user_name,message_content) values('"+getDate+"','"+user_name+"','"+user_message+"')";
//System.out.println(sql);
int res=conn.executeInsert(sql);
System.out.println(res);
//resp.sendRedirect("default/message_board.jsp");
conn.closeDB();
}
resp.sendRedirect("default/message_board.jsp");
}
}

@ -0,0 +1,165 @@
/*package servlet;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;
public class deal_order extends HttpServlet{
private static final long serialVersionUID = 1L;
public deal_order()
{super();}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
HttpSession session = req.getSession();
String s=req.getParameter("date");//日期
System.out.println(s);//本人的ID
String tel=session.getAttribute("p_tel").toString();
System.out.println(tel);//本人的电话
String f;
f=session.getAttribute("f").toString();
System.out.println(f);
if(session.getAttribute("p_tel")!=null) {
db_conn conn=new db_conn();
String sql="select p_id from p_inf where p_tel='"+tel+"'";
ResultSet res2=conn.executeQuery(sql);
String p_id=null;
try {
while (res2.next()) {
p_id=res2.getString(1);}
System.out.println(p_id);//本人的ID
String sql1="select p_id2 from ptp where p_id='"+p_id+"'";
//System.out.println("订购成功");
String p_id2=null;
ResultSet res=conn.executeQuery(sql1);
while (res.next()) {
db_conn conn2=new db_conn();
p_id2=res.getString(1);
String sql2="Update ticket set t_b=0,p_id2='"+p_id+"',p_id= '"+p_id2+"',t_pay=0 where t_d='"+s+"'and f_n='"+f+"' and t_b=1 limit 1";
conn2.Update(sql2);
System.out.println("订购成功");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
conn.closeDB();
}
}
resp.sendRedirect("/air_ticket_book/user_center");
}
}*/
package servlet;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;
public class deal_order extends HttpServlet{
private static final long serialVersionUID = 1L;
public deal_order()
{super();}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
HttpSession session = req.getSession();
String s=req.getParameter("date");//日期
System.out.println(s);//日期
String tel=session.getAttribute("p_tel").toString();
System.out.println(tel);//本人的电话
String f;
f=session.getAttribute("f").toString();
System.out.println(f);//航班
if(session.getAttribute("p_tel")!=null) {
db_conn conn=new db_conn();
db_conn conn3=new db_conn();
String sql="select p_id from p_inf where p_tel='"+tel+"'";
ResultSet res2=conn.executeQuery(sql);
String p_id=null;
try {
while (res2.next()) {p_id=res2.getString(1);}//本人的ID
String sql1="select p_id2 from ptp where p_id='"+p_id+"'";
String p_id2=null;
ResultSet res=conn.executeQuery(sql1);
String sql3="SELECT count(*) from ticket where t_d='"+s+"'and f_n='"+f+"' and t_b=1 ";
ResultSet res3=conn3.executeQuery(sql3);
int a=0;
int b=0;
if(res3.first()) {
a=Integer.parseInt(res3.getString(1));
}
String sql4="SELECT count(*) from ptp where p_id='"+p_id+"'";
ResultSet res4=conn3.executeQuery(sql4);
if(res4.first()) {
b=Integer.parseInt(res4.getString(1));
}
if(a>=b) {
System.out.println(a);
System.out.println(b);
while (res.next()) {
db_conn conn2=new db_conn();
p_id2=res.getString(1);
System.out.println(p_id2);
String sql2="Update ticket set t_b=0,p_id2='"+p_id+"',p_id= '"+p_id2+"',t_pay=0 where t_d='"+s+"'and f_n='"+f+"' and t_b=1 limit 1";
conn2.Update(sql2);
System.out.println("订购成功");
}
resp.sendRedirect("/air_ticket_book/user_center");
}
else {
System.out.println("deal_order出错啦请联系开发人员进行修补bug");
resp.setHeader("refresh", "2;url=/air_ticket_book/default/error.jsp");
}
}
catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
conn.closeDB();
}
}
}}

@ -0,0 +1,31 @@
package servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javabean.db_conn;
@WebServlet("/del_ptp")
public class del_ptp extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String p_id2=req.getParameter("p_id2");
db_conn conn=new db_conn();
String sql="delete from ptp where p_id2='"+p_id2+"'";
conn.executeDelete(sql);
resp.setHeader("refresh", "2;url=/air_ticket_book/index/ptp_change_success.jsp");
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
resp.setHeader("refresh", "2;url=/air_ticket_book/index/ptp_change_success.jsp");
}
}

@ -0,0 +1,26 @@
package servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javabean.db_conn;
public class del_user_message extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
String sort=req.getParameter("class");
if(sort.equals("user")) {
String user_name=req.getParameter("id");
db_conn conn=new db_conn();
String sql="delete from p_inf where p_tel='"+user_name+"'";
conn.executeDelete(sql);
resp.sendRedirect("admin/user_list.jsp");
}
}
}

@ -0,0 +1,28 @@
package servlet;
import java.io.IOException;
import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
public class frame extends HttpServlet {
private static final long serialVersionUID = 1L;
public void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
HttpSession session = req.getSession();
if(session.getAttribute("admin_id") != null) {
RequestDispatcher rd=getServletContext().getRequestDispatcher("/admin/frame.jsp");
rd.forward(req, resp);
}else {
resp.sendRedirect("/air_ticket_book/admin/index.jsp");
}
}
}

@ -0,0 +1,106 @@
package servlet;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;
import javabean.passenger;
@WebServlet("/ptp")
public class ptp extends HttpServlet {
private static final long serialVersionUID = 1L;
public ptp() {
super();
}
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
//get提交为非法操作直接返回被session记忆的页面即可
HttpSession session = req.getSession();
String url=null;
if(session.getAttribute("url")!=null) {
url=session.getAttribute("url").toString();
}else {
url="index/user_center.jsp";
}
resp.sendRedirect(url);
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
String url=null;
url="index/user_center.jsp";
String tel2=req.getParameter("tel");
String name=req.getParameter("name");
System.out.println(name);//要关联的人
System.out.println(tel2);//要关联的人的电话
HttpSession session = req.getSession();
String tel=session.getAttribute("p_tel").toString();
System.out.println(tel);//主人的电话
String p_id=null,p_id2=null;
String sql=null;
if(name==""||tel2=="") {
System.out.print("请输入完整信息");
resp.sendRedirect(url);
}
else {
sql="select * from p_inf where p_name='"+name+"' and p_tel='"+tel2+"'";
db_conn conn=new db_conn();
ArrayList<passenger> plist = new ArrayList<passenger>();
ResultSet res=conn.executeQuery(sql);
try {
while (res.next()) {
passenger passenger_info1=new passenger();
passenger passenger_info2=new passenger();
passenger_info1.set_p_id(res.getString(1));
passenger_info2.set_p_id(res.getString(2));
plist.add(passenger_info1);
plist.add(passenger_info2);
}
if(plist.size()==0){
System.out.println("信息输入有误或对方未创建账号,请重新输入");
}else{
sql="select p_id from p_inf where p_tel='"+tel+"'";
ResultSet res2=conn.executeQuery(sql);
if(res2.next())
p_id=res2.getString(1);
sql="select p_id from p_inf where p_tel='"+tel2+"'";
ResultSet res3=conn.executeQuery(sql);
if(res3.next())
p_id2=res3.getString(1);
sql="insert into ptp (p_id,p_id2) values ('"+p_id+"','"+p_id2+"')";
conn.executeInsert(sql);
req.getRequestDispatcher("index/ptp_change_success.jsp").forward(req, resp);
}
// p.setF_n(res.getString(1));
// plist.add(flight_info);
req.setAttribute("plist", plist);
} catch (SQLException e) {
System.out.println("错误信息:"+e);
}finally {
conn.closeDB();
}
}
}
}

@ -0,0 +1,85 @@
package servlet;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import javabean.db_conn;
import javabean.flight;
public class search_fly extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
HttpSession session = req.getSession();
String url=null;
if(session.getAttribute("url")!=null) {
url=session.getAttribute("url").toString();
}else {
url="default/index.jsp";
}
resp.sendRedirect(url);
}
protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
req.setCharacterEncoding("utf-8");
String url=null;
url="default/index.jsp";
String departure=null;
String destination=null;
departure=req.getParameter("departure");
destination=req.getParameter("destination");
String sql=null;
if(departure==""&&destination=="") {
//如果始发地和目的地都为空则跳转回原页面
resp.sendRedirect(url);
}else if (departure!=""&&destination=="") {
sql="select * from flight where f_s_p='"+departure+"'";
}else if (departure==""&&destination!="") {
sql="select * from flight where f_a_p='"+destination+"'";
}else if (departure!=""&&destination!="") {
sql="select * from flight where f_s_p='"+departure+"' and f_a_p='"+destination+"'";
}
if(departure==""&&destination=="") {
}else {
db_conn conn=new db_conn();
ArrayList<flight> flightlist = new ArrayList<flight>();
ResultSet res=conn.executeQuery(sql);
try {
while (res.next()) {
flight flight_info=new flight();
flight_info.setF_n(res.getString(1));
flight_info.setF_s_p(res.getString(2));
flight_info.setF_a_p(res.getString(3));
flight_info.setF_s_a(res.getString(4));
flight_info.setF_a_a(res.getString(5));
flight_info.setF_s_t(res.getString(6));
flight_info.setF_a_t(res.getString(7));
flight_info.setF_p(res.getString(8));
flightlist.add(flight_info);
}
req.setAttribute("flightlist", flightlist);
} catch (SQLException e) {
System.out.println("错误信息:"+e);
}finally {
conn.closeDB();
}
req.getRequestDispatcher("default/search.jsp").forward(req, resp);
}
}
}

@ -0,0 +1,109 @@
package servlet;
import java.io.File;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Iterator;
import java.util.List;
import java.util.UUID;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import javabean.db_conn;
public class upload_file extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp)
throws ServletException, IOException {
//GET方式提交的数据基本都是非法操作不用处理直接返回edit_info页面就可以
resp.sendRedirect("/air_ticket_book/index/edit_info.jsp");
}
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
HttpSession session=request.getSession();
if(session.getAttribute("user_id")==null) {
response.sendRedirect("index/user_info.jsp");
}
else {
//request.setCharacterEncoding("utf-8");
boolean flag=ServletFileUpload.isMultipartContent(request);
if(flag) {
DiskFileItemFactory factory=new DiskFileItemFactory();
ServletFileUpload upload=new ServletFileUpload(factory);
try {
List<FileItem>fileList = upload.parseRequest(request);
Iterator<FileItem> myitor = fileList.iterator();
while(myitor.hasNext()) {
FileItem item=myitor.next();
if(item!=null) {
String filename=item.getName();
if(filename!=null) {
String path="index/upload";
String absolutepath=this.getServletContext().getRealPath(path);
//System.out.println("文件名"+filename);
File file = new File(filename);
//System.out.println("文件名为:"+file.getName());
String file_name=file.getName();
String ext=file_name.substring(file_name.lastIndexOf("."));
//System.out.println("文件扩展名为:"+ext);
String end_filename=UUID.randomUUID().toString()+ext;
//System.out.println("头像图片名称为:"+end_filename);
File uploadFile = new File(absolutepath, end_filename);
try {
if(uploadFile.exists()) {
uploadFile.delete();
}
item.write(uploadFile);
//System.out.println("上传成功");
//System.out.println("图片存储文件夹为:"+absolutepath);
//上传文件成功把文件名写入数据库
db_conn conn= new db_conn();
String sql="update common_user set avatar_img='"+end_filename+"' "
+ "where user_name='"+session.getAttribute("user_id")+"'";
int res=conn.Update(sql);
//System.out.println(res);
PrintWriter out=response.getWriter();
response.setContentType("text/html;charset=utf-8");
if(res!=0) {
response.sendRedirect("/air_ticket_book/index/user_info.jsp");
}else {
out.println("文件上传失败程序出现bug请联系开发人员修复bug");
response.setHeader("refresh", "2;url=/air_ticket_book/index/user_info.jsp");
}
}catch (Exception e) {
System.out.println("出错了1出错信息如下"+e);
}
}
}
}
} catch (FileUploadException e) {
System.out.println("出错了2出错信息如下"+e);
e.printStackTrace();
}
}
}
}
}

@ -0,0 +1,28 @@
package servlet;
import java.io.IOException;
import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
public class userCenter extends HttpServlet{
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
HttpSession session = req.getSession();
Object user_id = session.getAttribute("user_id");
if(user_id != null) {
RequestDispatcher rd = getServletContext().getRequestDispatcher("/index/user_center.jsp");
rd.forward(req, resp);
session.setAttribute("url", "/air_ticket_book/user_center");
}else {
resp.sendRedirect("index/login_reg.jsp");
}
}
}

@ -0,0 +1,4 @@
Manifest-Version: 1.0
Build-Jdk-Spec: 21
Created-By: Maven Integration for Eclipse

@ -0,0 +1,7 @@
#Generated by Maven Integration for Eclipse
#Fri Oct 04 17:12:19 CST 2024
artifactId=air_ticket_book
groupId=air_ticket_book
m2e.projectLocation=D\:\\college\\SE2\\air_ticket_book-master\\\u8F6F\u4EF6\u5DE5\u7A0B\u8BFE\u7A0B\u8BBE\u8BA1\\air_ticket_book
m2e.projectName=air_ticket_book
version=0.0.1-SNAPSHOT

@ -0,0 +1,19 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="https://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>air_ticket_book</groupId>
<artifactId>air_ticket_book</artifactId>
<version>0.0.1-SNAPSHOT</version>
<build>
<sourceDirectory>src</sourceDirectory>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>

Binary file not shown.
Loading…
Cancel
Save