基于Java开发的影院管理系统源码(课程作业).zip

package com.lzh.cinema.dao; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import com.lzh.cinema.bean.MoneyMsg; import com.lzh.cinema.bean.Msg; import com.lzh.cinema.entity.Movie; import com.lzh.cinema.entity.MovieList; import com.lzh.cinema.entity.MoviePrice; import com.lzh.cinema.entity.Ticket; import com.lzh.cinema.entity.User; import com.lzh.cinema.entity.UserQueryMovie; import com.lzh.cinema.property.UserQueryMovieProperty; import com.lzh.cinema.service.BuyService; import com.lzh.cinema.service.MovieListService; import com.lzh.cinema.util.JDBCUtil; import com.lzh.cinema.view.LoginController; import com.lzh.cinema.view.MyTicketController; import com.lzh.cinema.view.PayController; import com.lzh.cinema.view.UserQueryMovieController; public class BuyDao { private Connection con; private PreparedStatement stmt; /** * 影票 * @return seat_id */ public int GSeatT(){ try { Integer s = 0; con = JDBCUtil.getCon(); String sql = "SELECT * FROM seat WHERE seat_id=?"; //被调用的方法的局部中的预编译要再次声明一次 PreparedStatement stmt = con.prepareStatement(sql); stmt.setInt(1, MyTicketController.a); System.out.println("g----seat"); ResultSet rs = stmt.executeQuery(); while(rs.next()) { s= rs.getInt("seat_id"); } return s; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接异常gseat"); } finally{ JDBCUtil.close(stmt, con); } return 0; } /** * 购票 * @return */ public int GSeat(){ try { Integer s = 0; con = JDBCUtil.getCon(); String sql = "SELECT * FROM seat WHERE x=? AND y=? AND hall_id=?"; //被调用的方法的局部中的预编译要再次声明一次 PreparedStatement stmt = con.prepareStatement(sql); stmt.setInt(1, PayController.x); stmt.setInt(2, PayController.y); stmt.setInt(3, QHall()); System.out.println("g----seat"); ResultSet rs = stmt.executeQuery(); while(rs.next()) { s= rs.getInt("seat_id"); } return s; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接异常gseat"); } finally{ JDBCUtil.close(stmt, con); } return 0; } /** * 得到当前用户的用户id * @return user_id */ public int GUser(){ try { int u = 0; con = JDBCUtil.getCon(); String sql = "SELECT * FROM user WHERE user_name = ?"; PreparedStatement stmt = con.prepareStatement(sql); stmt.setString(1, LoginController.userName); ResultSet rs = stmt.executeQuery(); while(rs.next()) { u = 0 ; u = rs.getInt("user_id"); } return u; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接异常guser"); } finally{ JDBCUtil.close(stmt, con); } return 0; } /** * 通过user_id找出ticket_id * @return ticket_id */ public int GTicket(){ int u = 0; try { con = JDBCUtil.getCon(); String sql = "SELECT * FROM ticket WHERE user_name = ?"; PreparedStatement stmt = con.prepareStatement(sql); stmt.setString(1, LoginController.userName); ResultSet rs = stmt.executeQuery(); if(rs.next()) { u = rs.getInt("user_id"); } return u; } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接异常"); } finally { JDBCUtil.close(stmt, con); } return 0; } /** * 查询该用户的余额信息，并返回其余额数值 * @param user * @return MoneyMsg */ public MoneyMsg UMoneyQ(User user){ try { con = JDBCUtil.getCon(); String sql = "SELECT * FROM user WHERE user_name = ?"; PreparedStatement stmt = con.prepareStatement(sql); stmt.setString(1, LoginController.userName); ResultSet rs = stmt.executeQuery(); if(rs.next()){ //检查数据库中是否存在该用户名和密码 if(LoginController.userName.equals(rs.getString("user_name"))) { user.setMoney(rs.getDouble("user_money")); if(user.getMoney()>=0) { return new MoneyMsg(user.getMoney(),user); } else return new MoneyMsg(0.00,user); } } } catch (SQLException e) { // TODO Auto-generated catch block System.out.println("数据库连接异常umq"); e.printStackTrace(); } finally{ JDBCUtil.close(stmt, con); } return null; } /** * 更改用户的金额数 * @param user * @return 0则失败，1则成功更改 */ public int AddMoney(User user,Double m) { int judge=0; con = JDBCUtil.getCon(); String sql = "UPDATE user SET user_money=? WHERE user_name = ?"; try { PreparedStatement stmt = con.prepareStatement(sql); stmt.setDouble(1, m); stmt.setString(2, LoginController.userName); stmt.executeUpdate(); judge=1; System.out.println("添加成功"); } catch (SQLException e) { judge=0; System.out.println("添加失败"); e.printStackTrace(); } finally {JDBCUtil.close(stmt, con);} return judge; } /** * 查询用户选择的票是否已存在， * 已存在的话，判断其状态是否已被预定 * 有三种情况 * @param 无参 * @return Ticket */ public Ticket TicketExists(){ try { con = JDBCUtil.getCon(); //联合查询---ticket表和seat表，将查到的两张表的结果全部返回,对象的集合 String sql = "select ticket.ticket_id,ticket.seat_id,ticket.schedule_id,ticket.price,ticket.status,seat.hall_id,seat.x,seat.y from ticket,seat where ticket.seat_id=seat.seat_id"; stmt = con.prepareStatement(sql); ResultSet rs = stmt.executeQuery();// 返回一个结果集，n个对象 System.out.println("ticket1"); List <Ticket> list = new ArrayList<Ticket>(); Ticket ticket =null;//作为返回值，供service层判断 while (rs.next()) { ticket =new Ticket(); // /* * 每次新建成一个对象的地址 */ //ticket表 ticket.setTicket(rs.getInt("ticket_id"));//票的单号 ticket.setSeat(rs.getInt("seat_id"));//座位的单号 ticket.setSchedule(rs.getInt("schedule_id"));//电影播放的单号，排片序号 ticket.setPrice(rs.getDouble("price"));//票价 ticket.setStatus(rs.getInt("status"));//记录当前票的状态（是否已被预定） //seat表 ticket.setHall(rs.getInt("hall_id"));//记录票的播放厅 ticket.setX(rs.getInt("x"));//x，座位的横坐标 ticket.setY(rs.getInt("y"));//y，座位的纵坐标 list.add(ticket); } if(ticket==null) { return null; } Ticket t = null; for (int i = 0; i < list.size();i++) { t = list.get(i); /** * 一个个比较schedule,无则为无该票信息----3， * 有则根据status判断，0为可买--------------2 * 1为不可预订--------------------------------1 */ if(UserQueryMovieController.a==t.getSchedule()) //2和1 { if(PayController.x==t.getX()&&PayController.y==t.getY())//座位的比较,比较status { if(t.getStatus()==1) {return t;} else { return t; } } } else // 3的情况 { System.out.println(11231); return null;//返回的票对象为空 } } System.out.println("dao循环外----"+ticket.toString()); return ticket;//若查询到票的结果则返回票的集合 } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println("数据库连接异常"); } finally{ JDBCUtil.close(stmt, con); } return null;//数据库中不存在该票 } /** * 查询hall_id的值 （schedule表中根据schedule_id的值查询） * @return hall_id的值 */ public double QPrice(){ try { con = JDBCUtil.getCon(); double p =0.0; MoviePrice mp = new MoviePrice(); //两张表的有关price和schedule的所有数据 String sql = "select