基于javaweb开发的餐厅点餐系统

package org.hotelAppTest.dao; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Set; import org.hotelTest.bean.DinnerTable; import org.hotelTest.bean.Food; import org.hotelTest.bean.Order; import org.hotelTest.bean.OrderDetail; import org.hotelTest.util.ConnectionFactory; import org.hotelTest.util.ConstantUtil; public class OrderDaoImpl implements OrderDao { @Override public void order(Order order, Map<Integer, Integer> shopCar, String userName) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { //①获取连接 connection = ConnectionFactory.getConnection(); //手动提交事务 connection.setAutoCommit(false); //②准备SQL String sql = "INSERT INTO tb_order(order_code,table_id,total_Price,order_date,create_userId) VALUES(?,?,?,NOW(),?)"; //③ 获取集装箱 preparedStatement = connection.prepareStatement(sql.toString(),Statement.RETURN_GENERATED_KEYS); //索引从1开始 preparedStatement.setString(1, order.getOrderCode()); preparedStatement.setInt(2, order.getTableId()); preparedStatement.setDouble(3, order.getTotalPrice()); preparedStatement.setString(4, userName); //④ 执行SQL语句,返回影响的行数 int result = preparedStatement.executeUpdate(); resultSet = preparedStatement.getGeneratedKeys(); //指针下移一位，因为将表头信息也查询出来了，而表头信息不需要封装 resultSet.next(); Integer orderId = resultSet.getInt(1); System.out.println("orderId:"+orderId); //int i = 100/0; //保存订单明细 String sqlItem = "INSERT INTO tb_order_detail(orderId,food_id,buyNum,discount) VALUES(?,?,?,?)"; preparedStatement = connection.prepareStatement(sqlItem); //获取购物车中所有的菜品id Set<Integer> foodIds = shopCar.keySet(); for (Integer foodId : foodIds) { //购买数量 Integer buyNum = shopCar.get(foodId); FoodDao foodDao = new FoodDaoImpl(); Food food = foodDao.findById(foodId); preparedStatement.setInt(1, orderId); preparedStatement.setInt(2, foodId); preparedStatement.setInt(3, buyNum); preparedStatement.setDouble(4, food.getDiscount()); preparedStatement.addBatch(); } //执行批处理 preparedStatement.executeBatch(); connection.commit(); } catch (SQLException e) { e.printStackTrace(); }finally { ConnectionFactory.close(connection,preparedStatement,resultSet ); } } /*通过餐桌的id查询未付款的订单*/ @Override public List<Order> findByTableId(int dinnerTableId) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { //①获取连接 connection = ConnectionFactory.getConnection(); //②准备SQL String sql = "SELECT * FROM tb_order WHERE disabled= 0 AND table_id = ? AND order_Status = 0"; //③ 获取集装箱 preparedStatement = connection.prepareStatement(sql.toString()); //索引从1开始 preparedStatement.setInt(1, dinnerTableId); //④ 执行SQL语句,返回影响的行数 resultSet = preparedStatement.executeQuery(); List<Order> orders = new ArrayList<>(); while (resultSet.next()) { Order order = new Order(); order.setId(resultSet.getInt("id")); order.setOrderCode(resultSet.getString("order_code")); order.setOrderDate(resultSet.getTimestamp("order_Date")); order.setOrderStatus(resultSet.getInt("order_Status")); order.setTableId(resultSet.getInt("table_id")); order.setTotalPrice(resultSet.getDouble("total_Price")); order.setPayDate(resultSet.getTimestamp("pay_date")); order.setDisabled(resultSet.getInt("disabled")); orders.add(order); } return orders; } catch (SQLException e) { e.printStackTrace(); }finally { ConnectionFactory.close(connection,preparedStatement,resultSet ); } return null; } @Override public List<OrderDetail> findByOrderId(Integer orderId) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { //①获取连接 connection = ConnectionFactory.getConnection(); //②准备SQL String sql = "SELECT tb_order_detail.`id` detailId,tb_order_detail.*,tb_food.* " + " FROM tb_order_detail " + " LEFT JOIN tb_food ON tb_food.`id`=tb_order_detail.`food_id`" + " WHERE tb_order_detail.orderId = ? "; //③ 获取集装箱 preparedStatement = connection.prepareStatement(sql.toString()); //索引从1开始 preparedStatement.setInt(1, orderId); //④ 执行SQL语句,返回影响的行数 resultSet = preparedStatement.executeQuery(); List<OrderDetail> orderDetails = new ArrayList<>(); while (resultSet.next()) { OrderDetail orderDetail = new OrderDetail(); orderDetail.setBuyNum(resultSet.getInt("buyNum")); orderDetail.setOrderId(resultSet.getInt("orderId")); orderDetail.setFoodId(resultSet.getInt("food_id")); orderDetail.setDiscount(resultSet.getDouble("discount")); Food food = new Food(); food.setFoodTypeId(resultSet.getInt("foodType_id")); food.setFoodName(resultSet.getString("food_name")); food.setImg(resultSet.getString("img")); food.setDiscount(resultSet.getDouble("discount")); food.setPrice(resultSet.getDouble("price")); food.setRemark(resultSet.getString("remark")); orderDetail.setFood(food); orderDetails.add(orderDetail); } return orderDetails; } catch (SQLException e) { e.printStackTrace(); }finally { ConnectionFactory.close(connection,preparedStatement,resultSet ); } return null; } @Override public Order findById(int id) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { //①获取连接 connection = ConnectionFactory.getConnection(); //②准备SQL String sql = "SELECT * FROM tb_order WHERE id = ?"; //③ 获取集装箱 preparedStatement = connection.prepareStatement(sql.toString()); //索引从1开始 preparedStatement.setInt(1, id); //④ 执行SQL语句,返回影响的行数 resultSet = preparedStatement.executeQuery(); while (resultSet.next()) { Order order = new Order(); order.setId(resultSet.getInt("id")); order.setOrderCode(resultSet.getString("order_code")); order.setOrderDate(resultSet.getTimestamp("order_Date")); order.setOrderStatus(resultSet.getInt("order_Status")); order.setTableId(resultSet.getInt("table_id")); order.setTotalPrice(resultSet.getDouble("total_Price")); order.setPayDate(resultSet.getTimestamp("pay_date")); order.setDisabled(resultSet.getInt("disabled")); return order; } } catch (SQLException e) { e.printStackTrace(); }finally { ConnectionFactory.close(connection,preparedStatement,resultSet ); } return null; } @Override public void pay(Order order) { Connection connection = null; PreparedStatement preparedStatement = null; ResultSet resultSet = null; try { //①获取连接 connection = ConnectionFactory.getConnection(); //设置收到提交 connection.setAutoCommit(false); //②准备SQL String sql = "UPDATE tb_order SET order_Status = ?,order_code = ?,table_id=?,total_Price=?,order_date=?,pay_date=now(),update_date=now(),disabled=? WHERE id = ?"; //③ 获取集装箱 preparedStatement = connection.prepareStateme