ToB企服应用市场:ToB评测及商务社交产业平台

标题: Java学习-第一部分-第三阶段-项目实战：满汉楼项目 [打印本页]

---

作者: 反转基因福娃    时间: 2022-9-25 01:28
标题: Java学习-第一部分-第三阶段-项目实战：满汉楼项目
满汉楼项目

笔记目录：(https://www.cnblogs.com/wenjie2000/p/16378441.html)
注意：笔记内容仅为实现该项目的基本后端功能，并不会实现可视化界面，效果都在控制台展示。
要完成的满汉楼项目说明
满汉楼项目功能多，界面复杂,涉及到复杂的awt和swing技术和事件编程，做如下调整:

• 去掉界面和事件处理(工作中使用很少)，使用控制台界面
  
• 完成满汉楼项目的登录、订座、点餐和结账、查看账单等功能。
  
• 提示:在实际工作中，独立完成项目新功能非常重要，这是锻炼编程能力和思想的重要途径
  

界面设计

用户登录

显示餐桌状态

预定

显示菜品

点餐

查看账单

结账

项目设计


准备工作

准备工具类Utility，提高开发效率，并搭建项目的整体结构
在实际开发中，公司都会提供相应的工具类和开发库,可以提高开发效率

• 了解Utility类的使用
  
• 测试Utility类
  

基本结构

在MySQL中创建表

1. #用户表
2. create table employee (
3.         id int primary key auto_increment, #自增
4.         empId varchar(50) not null default '',#员工号
5.         pwd char(32) not null default '',#密码md5
6.         name varchar(50) not null default '',#姓名
7.         job varchar(50) not null default '' #岗位
8. )charset=utf8;
10. insert into employee values(null, '6668612', md5('123456'), '张三丰', '经理');
11. insert into employee values(null, '6668622', md5('123456'),'小龙女', '服务员');
12. insert into employee values(null, '6668633', md5('123456'), '张无忌', '收银员');
13. insert into employee values(null, '666', md5('123456'), '老韩', '经理');
15. #餐桌表
16. create table diningTable (
17.         id int primary key auto_increment, #自增, 表示餐桌编号
18.         state varchar(20) not null default '',#餐桌的状态
19.         orderName varchar(50) not null default '',#预订人的名字
20.         orderTel varchar(20) not null default ''
21. )charset=utf8;
23. insert into diningTable values(null, '空','','');
25. #菜谱
26. create table menu (
27.         id int primary key auto_increment, #自增主键，作为菜谱编号(唯一)
28.         name varchar(50) not null default '',#菜品名称
29.         type varchar(50) not null default '', #菜品种类
30.         price double not null default 0#价格
31. )charset=utf8;
33. insert into menu values(null, '八宝饭', '主食类', 10);
34. insert into menu values(null, '叉烧包', '主食类', 20);
35. insert into menu values(null, '宫保鸡丁', '热菜类', 30);
36. insert into menu values(null, '山药拨鱼', '凉菜类', 14);
37. insert into menu values(null, '银丝卷', '甜食类', 9);
38. insert into menu values(null, '水煮鱼', '热菜类', 26);
39. insert into menu values(null, '甲鱼汤', '汤类', 100);
40. insert into menu values(null, '鸡蛋汤', '汤类', 16);
42. #账单流水, 考虑可以分开结账, 并考虑将来分别统计各个不同菜品的销售情况
43. create table bill (
44.         id int primary key auto_increment, #自增主键
45.         billId varchar(50) not null default '',#账单号可以按照自己规则生成 UUID
46.         menuId int not null default 0,#菜品的编号, 也可以使用外键
47.         nums SMALLINT not null default 0,#份数
48.         money double not null default 0, #金额
49.         diningTableId int not null default 0, #餐桌
50.         billDate datetime not null ,#订单日期
51.         state varchar(50) not null default '' # 状态 '未结账' , '已经结账', '挂单'
52. )charset=utf8;

复制代码

druid配置文件(需要根据自己情况进行配置)

1. #key=value
2. driverClassName=com.mysql.jdbc.Driver
3. url=jdbc:mysql://localhost:3306/db02?rewriteBatchedStatements=true
4. username=root
5. password=123456
6. #initial connection Size
7. initialSize=10
8. #min idle connecton size
9. minIdle=5
10. #max active connection size
11. maxActive=50
12. #max wait time (5000 mil seconds)
13. maxWait=5000

复制代码

BasicDAO(如果看过我上一节的笔记，就可以不需要再写一遍，直接拿来用)

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.utils.JDBCUtilsByDruid;
4. import org.apache.commons.dbutils.QueryRunner;
5. import org.apache.commons.dbutils.handlers.BeanHandler;
6. import org.apache.commons.dbutils.handlers.BeanListHandler;
7. import org.apache.commons.dbutils.handlers.ScalarHandler;
9. import java.sql.Connection;
10. import java.sql.SQLException;
11. import java.util.List;
14. /**
15. * 开发BasicDAO , 是其他DAO的父类
16. */
17. public class BasicDAO<T> { //泛型指定具体类型
19.     private QueryRunner qr =  new QueryRunner();
21.     //开发通用的dml方法, 针对任意的表
22.     public int update(String sql, Object... parameters) {
24.         Connection connection = null;
26.         try {
27.             connection = JDBCUtilsByDruid.getConnection();
28.             int update = qr.update(connection, sql, parameters);
29.             return  update;
30.         } catch (SQLException e) {
31.            throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
32.         } finally {
33.             JDBCUtilsByDruid.close(null, null, connection);
34.         }
35.     }
37.     //返回多个对象(即查询的结果是多行), 针对任意表
39.     /**
40.      *
41.      * @param sql sql 语句，可以有 ?
42.      * @param clazz 传入一个类的Class对象 比如 Actor.class
43.      * @param parameters 传入 ? 的具体的值，可以是多个
44.      * @return 根据Actor.class 返回对应的 ArrayList 集合
45.      */
46.     public List<T> queryMulti(String sql, Class<T> clazz, Object... parameters) {
48.         Connection connection = null;
49.         try {
50.             connection = JDBCUtilsByDruid.getConnection();
51.             return qr.query(connection, sql, new BeanListHandler<T>(clazz), parameters);
53.         } catch (SQLException e) {
54.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
55.         } finally {
56.             JDBCUtilsByDruid.close(null, null, connection);
57.         }
58.     }
60.     //查询单行结果 的通用方法
61.     public T querySingle(String sql, Class<T> clazz, Object... parameters) {
63.         Connection connection = null;
64.         try {
65.             connection = JDBCUtilsByDruid.getConnection();
66.             return  qr.query(connection, sql, new BeanHandler<T>(clazz), parameters);
68.         } catch (SQLException e) {
69.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
70.         } finally {
71.             JDBCUtilsByDruid.close(null, null, connection);
72.         }
73.     }
75.     //查询单行单列的方法,即返回单值的方法
77.     public Object queryScalar(String sql, Object... parameters) {
79.         Connection connection = null;
80.         try {
81.             connection = JDBCUtilsByDruid.getConnection();
82.             return  qr.query(connection, sql, new ScalarHandler(), parameters);
84.         } catch (SQLException e) {
85.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
86.         } finally {
87.             JDBCUtilsByDruid.close(null, null, connection);
88.         }
89.     }
90. }

复制代码

JDBCUtilsByDruid(基于druid数据库连接池的工具类)

1. package com.zwj.mhl.utils;
3. import com.alibaba.druid.pool.DruidDataSourceFactory;
5. import javax.sql.DataSource;
6. import java.io.FileInputStream;
7. import java.sql.Connection;
8. import java.sql.ResultSet;
9. import java.sql.SQLException;
10. import java.sql.Statement;
11. import java.util.Properties;
13. /**
14. * 基于druid数据库连接池的工具类
15. */
16. public class JDBCUtilsByDruid {
18.     private static DataSource ds;
20.     //在静态代码块完成 ds初始化
21.     static {
22.         Properties properties = new Properties();
23.         try {
24.             properties.load(new FileInputStream("src\\druid.properties"));
25.             ds = DruidDataSourceFactory.createDataSource(properties);
26.         } catch (Exception e) {
27.             e.printStackTrace();
28.         }
30.     }
32.     //编写getConnection方法
33.     public static Connection getConnection() throws SQLException {
34.         return ds.getConnection();
35.     }
37.     //关闭连接, 老师再次强调： 在数据库连接池技术中，close 不是真的断掉连接
38.     //而是把使用的Connection对象放回连接池
39.     public static void close(ResultSet resultSet, Statement statement, Connection connection) {
41.         try {
42.             if (resultSet != null) {
43.                 resultSet.close();
44.             }
45.             if (statement != null) {
46.                 statement.close();
47.             }
48.             if (connection != null) {
49.                 connection.close();
50.             }
51.         } catch (SQLException e) {
52.             throw new RuntimeException(e);
53.         }
54.     }
55. }

复制代码

Utility(辅助输入数据的工具类)

1. package com.zwj.mhl.utils;
4. /**
5.    工具类的作用:
6.    处理各种情况的用户输入，并且能够按照程序员的需求，得到用户的控制台输入。
7. */
9. import java.util.*;
11. public class Utility {
12.    //静态属性。。。
13.     private static Scanner scanner = new Scanner(System.in);
15.    
16.     /**
17.      * 功能：读取键盘输入的一个菜单选项，值：1——5的范围
18.      * @return 1——5
19.      */
20.    public static char readMenuSelection() {
21.         char c;
22.         for (; ; ) {
23.             String str = readKeyBoard(1, false);//包含一个字符的字符串
24.             c = str.charAt(0);//将字符串转换成字符char类型
25.             if (c != '1' && c != '2' &&
26.                 c != '3' && c != '4' && c != '5') {
27.                 System.out.print("选择错误，请重新输入：");
28.             } else break;
29.         }
30.         return c;
31.     }
33.    /**
34.     * 功能：读取键盘输入的一个字符
35.     * @return 一个字符
36.     */
37.     public static char readChar() {
38.         String str = readKeyBoard(1, false);//就是一个字符
39.         return str.charAt(0);
40.     }
41.     /**
42.      * 功能：读取键盘输入的一个字符，如果直接按回车，则返回指定的默认值；否则返回输入的那个字符
43.      * @param defaultValue 指定的默认值
44.      * @return 默认值或输入的字符
45.      */
46.    
47.     public static char readChar(char defaultValue) {
48.         String str = readKeyBoard(1, true);//要么是空字符串，要么是一个字符
49.         return (str.length() == 0) ? defaultValue : str.charAt(0);
50.     }
51.    
52.     /**
53.      * 功能：读取键盘输入的整型，长度小于2位
54.      * @return 整数
55.      */
56.     public static int readInt() {
57.         int n;
58.         for (; ; ) {
59.             String str = readKeyBoard(2, false);//一个整数，长度<=2位
60.             try {
61.                 n = Integer.parseInt(str);//将字符串转换成整数
62.                 break;
63.             } catch (NumberFormatException e) {
64.                 System.out.print("数字输入错误，请重新输入：");
65.             }
66.         }
67.         return n;
68.     }
69.     /**
70.      * 功能：读取键盘输入的 整数或默认值，如果直接回车，则返回默认值，否则返回输入的整数
71.      * @param defaultValue 指定的默认值
72.      * @return 整数或默认值
73.      */
74.     public static int readInt(int defaultValue) {
75.         int n;
76.         for (; ; ) {
77.             String str = readKeyBoard(10, true);
78.             if (str.equals("")) {
79.                 return defaultValue;
80.             }
81.          
82.          //异常处理...
83.             try {
84.                 n = Integer.parseInt(str);
85.                 break;
86.             } catch (NumberFormatException e) {
87.                 System.out.print("数字输入错误，请重新输入：");
88.             }
89.         }
90.         return n;
91.     }
93.     /**
94.      * 功能：读取键盘输入的指定长度的字符串
95.      * @param limit 限制的长度
96.      * @return 指定长度的字符串
97.      */
99.     public static String readString(int limit) {
100.         return readKeyBoard(limit, false);
101.     }
103.     /**
104.      * 功能：读取键盘输入的指定长度的字符串或默认值，如果直接回车，返回默认值，否则返回字符串
105.      * @param limit 限制的长度
106.      * @param defaultValue 指定的默认值
107.      * @return 指定长度的字符串
108.      */
109.    
110.     public static String readString(int limit, String defaultValue) {
111.         String str = readKeyBoard(limit, true);
112.         return str.equals("")? defaultValue : str;
113.     }
116.    /**
117.     * 功能：读取键盘输入的确认选项，Y或N
118.     * 将小的功能，封装到一个方法中.
119.     * @return Y或N
120.     */
121.     public static char readConfirmSelection() {
122.         System.out.println("请输入你的选择(Y/N)");
123.         char c;
124.         for (; ; ) {//无限循环
125.            //在这里，将接受到字符，转成了大写字母
126.            //y => Y n=>N
127.             String str = readKeyBoard(1, false).toUpperCase();
128.             c = str.charAt(0);
129.             if (c == 'Y' || c == 'N') {
130.                 break;
131.             } else {
132.                 System.out.print("选择错误，请重新输入：");
133.             }
134.         }
135.         return c;
136.     }
138.     /**
139.      * 功能： 读取一个字符串
140.      * @param limit 读取的长度
141.      * @param blankReturn 如果为true ,表示 可以读空字符串。
142.      *                   如果为false表示 不能读空字符串。
143.      *           
144.     * 如果输入为空，或者输入大于limit的长度，就会提示重新输入。
145.      * @return
146.      */
147.     private static String readKeyBoard(int limit, boolean blankReturn) {
148.         
149.       //定义了字符串
150.       String line = "";
152.       //scanner.hasNextLine() 判断有没有下一行
153.         while (scanner.hasNextLine()) {
154.             line = scanner.nextLine();//读取这一行
155.            
156.          //如果line.length=0, 即用户没有输入任何内容，直接回车
157.          if (line.length() == 0) {
158.                 if (blankReturn) return line;//如果blankReturn=true,可以返回空串
159.                 else continue; //如果blankReturn=false,不接受空串，必须输入内容
160.             }
162.          //如果用户输入的内容大于了 limit，就提示重写输入  
163.          //如果用户如的内容 >0 <= limit ,我就接受
164.             if (line.length() < 1 || line.length() > limit) {
165.                 System.out.print("输入长度（不能大于" + limit + "）错误，请重新输入：");
166.                 continue;
167.             }
168.             break;
169.         }
170.         return line;
171.     }
172. }

复制代码

代码实现

注意：建议看代码之前先根据上面的信息自己写

com.zwj.mhl

dao

BasicDAO

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.utils.JDBCUtilsByDruid;
4. import org.apache.commons.dbutils.QueryRunner;
5. import org.apache.commons.dbutils.handlers.BeanHandler;
6. import org.apache.commons.dbutils.handlers.BeanListHandler;
7. import org.apache.commons.dbutils.handlers.ScalarHandler;
9. import java.sql.Connection;
10. import java.sql.SQLException;
11. import java.util.List;
14. /**
15. * 开发BasicDAO , 是其他DAO的父类
16. */
17. public class BasicDAO<T> { //泛型指定具体类型
19.     private QueryRunner qr =  new QueryRunner();
21.     //开发通用的dml方法, 针对任意的表
22.     public int update(String sql, Object... parameters) {
24.         Connection connection = null;
26.         try {
27.             connection = JDBCUtilsByDruid.getConnection();
28.             int update = qr.update(connection, sql, parameters);
29.             return  update;
30.         } catch (SQLException e) {
31.            throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
32.         } finally {
33.             JDBCUtilsByDruid.close(null, null, connection);
34.         }
35.     }
37.     //返回多个对象(即查询的结果是多行), 针对任意表
39.     /**
40.      *
41.      * @param sql sql 语句，可以有 ?
42.      * @param clazz 传入一个类的Class对象 比如 Actor.class
43.      * @param parameters 传入 ? 的具体的值，可以是多个
44.      * @return 根据Actor.class 返回对应的 ArrayList 集合
45.      */
46.     public List<T> queryMulti(String sql, Class<T> clazz, Object... parameters) {
48.         Connection connection = null;
49.         try {
50.             connection = JDBCUtilsByDruid.getConnection();
51.             return qr.query(connection, sql, new BeanListHandler<T>(clazz), parameters);
53.         } catch (SQLException e) {
54.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
55.         } finally {
56.             JDBCUtilsByDruid.close(null, null, connection);
57.         }
58.     }
60.     //查询单行结果 的通用方法
61.     public T querySingle(String sql, Class<T> clazz, Object... parameters) {
63.         Connection connection = null;
64.         try {
65.             connection = JDBCUtilsByDruid.getConnection();
66.             return  qr.query(connection, sql, new BeanHandler<T>(clazz), parameters);
68.         } catch (SQLException e) {
69.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
70.         } finally {
71.             JDBCUtilsByDruid.close(null, null, connection);
72.         }
73.     }
75.     //查询单行单列的方法,即返回单值的方法
77.     public Object queryScalar(String sql, Object... parameters) {
79.         Connection connection = null;
80.         try {
81.             connection = JDBCUtilsByDruid.getConnection();
82.             return  qr.query(connection, sql, new ScalarHandler(), parameters);
84.         } catch (SQLException e) {
85.             throw  new RuntimeException(e); //将编译异常->运行异常 ,抛出
86.         } finally {
87.             JDBCUtilsByDruid.close(null, null, connection);
88.         }
89.     }
90. }

复制代码

BillDAO

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.domain.Bill;
5. public class BillDAO extends BasicDAO<Bill> {
6. }

复制代码

DiningTableDAO

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.domain.DiningTable;
5. public class DiningTableDAO extends BasicDAO<DiningTable> {
6.     //如果有特别的操作，可以写在 DiningTableDAO
7. }

复制代码

EmployeeDAO

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.domain.Employee;
5. public class EmployeeDAO extends BasicDAO<Employee> {
6.     //这里还可以写特有的操作.
7. }

复制代码

MenuDAO

1. package com.zwj.mhl.dao;
3. import com.zwj.mhl.domain.Menu;
5. public class MenuDAO extends BasicDAO<Menu> {
6. }

复制代码

MultiTableDAO

1. package com.zwj.mhl.dao;
4. import com.zwj.mhl.domain.MultiTableBean;
6. public class MultiTableDAO extends BasicDAO<MultiTableBean> {
7. }

复制代码

domain

Bill

1. package com.zwj.mhl.domain;
3. import java.util.Date;
5. /**
6. * Bill 是javabean 和 bill对应
7. * id int primary key auto_increment, #自增主键
8. *     billId varchar(50) not null default '',#账单号可以按照自己规则生成 UUID
9. *     menuId int not null default 0,#菜品的编号, 也可以使用外键
10. *     nums int not null default 0,#份数
11. *     money double not null default 0, #金额
12. *     diningTableId int not null default 0, #餐桌
13. *     billDate datetime not null ,#订单日期
14. *     state varchar(50) not null default '' # 状态 '未结账' , '已经结账', '挂单'
15. */
16. public class Bill {
17.     private Integer id;
18.     private String billId;
19.     private Integer menuId;
20.     private Integer nums;
21.     private Double money;
22.     private Integer diningTableId;
23.     private Date billDate;
24.     private String state;
26.     public Bill() {
27.     }
29.     public Bill(Integer id, String billId, Integer menuId, Integer nums, Double money, Integer diningTableId, Date billDate, String state) {
30.         this.id = id;
31.         this.billId = billId;
32.         this.menuId = menuId;
33.         this.nums = nums;
34.         this.money = money;
35.         this.diningTableId = diningTableId;
36.         this.billDate = billDate;
37.         this.state = state;
38.     }
40.     public Integer getId() {
41.         return id;
42.     }
44.     public void setId(Integer id) {
45.         this.id = id;
46.     }
48.     public String getBillId() {
49.         return billId;
50.     }
52.     public void setBillId(String billId) {
53.         this.billId = billId;
54.     }
56.     public Integer getMenuId() {
57.         return menuId;
58.     }
60.     public void setMenuId(Integer menuId) {
61.         this.menuId = menuId;
62.     }
64.     public Integer getNums() {
65.         return nums;
66.     }
68.     public void setNums(Integer nums) {
69.         this.nums = nums;
70.     }
72.     public Double getMoney() {
73.         return money;
74.     }
76.     public void setMoney(Double money) {
77.         this.money = money;
78.     }
80.     public Integer getDiningTableId() {
81.         return diningTableId;
82.     }
84.     public void setDiningTableId(Integer diningTableId) {
85.         this.diningTableId = diningTableId;
86.     }
88.     public Date getBillDate() {
89.         return billDate;
90.     }
92.     public void setBillDate(Date billDate) {
93.         this.billDate = billDate;
94.     }
96.     public String getState() {
97.         return state;
98.     }
100.     public void setState(String state) {
101.         this.state = state;
102.     }
104.     @Override
105.     public String toString() {
106.         return  id +
107.                 "\t\t" + menuId +
108.                 "\t\t\t" + nums +
109.                 "\t\t\t" + money +
110.                 "\t" + diningTableId +
111.                 "\t\t" + billDate +
112.                 "\t\t" + state ;
113.     }
114. }

复制代码

DiningTable

1. package com.zwj.mhl.domain;
3. /**
4. * 这是一个javabean 和 diningTable 表对应
5. *     id int primary key auto_increment, #自增, 表示餐桌编号
6. *     state varchar(20) not null default '',#餐桌的状态
7. *     orderName varchar(50) not null default '',#预订人的名字
8. *     orderTel varchar(20) not null default ''
9. */
10. public class DiningTable {
11.     private Integer id;
12.     private String state;
13.     private String orderName;
14.     private String orderTel;
16.     public DiningTable() {
17.     }
19.     public DiningTable(Integer id, String state, String orderName, String orderTel) {
20.         this.id = id;
21.         this.state = state;
22.         this.orderName = orderName;
23.         this.orderTel = orderTel;
24.     }
26.     public Integer getId() {
27.         return id;
28.     }
30.     public void setId(Integer id) {
31.         this.id = id;
32.     }
34.     public String getState() {
35.         return state;
36.     }
38.     public void setState(String state) {
39.         this.state = state;
40.     }
42.     public String getOrderName() {
43.         return orderName;
44.     }
46.     public void setOrderName(String orderName) {
47.         this.orderName = orderName;
48.     }
50.     public String getOrderTel() {
51.         return orderTel;
52.     }
54.     public void setOrderTel(String orderTel) {
55.         this.orderTel = orderTel;
56.     }
58.     @Override
59.     public String toString() {
60.         return id + "\t\t\t" + state;
61.     }
62. }

复制代码

Employee

1. package com.zwj.mhl.domain;
3. /**
4. * 这是一个javabean 和 employee对应
5. * id int primary key auto_increment, #自增
6. *     empId varchar(50) not null default '',#员工号
7. *     pwd char(32) not null default '',#密码md5
8. *     name varchar(50) not null default '',#姓名
9. *     job varchar(50) not null default '' #岗位
10. */
11. public class Employee {
12.     private Integer id;
13.     private String empId;
14.     private String pwd;
15.     private String name;
16.     private String job;
18.     public Employee() { //无参构造器，底层apache-dbutils反射需要
19.     }
21.     public Employee(Integer id, String empId, String pwd, String name, String job) {
22.         this.id = id;
23.         this.empId = empId;
24.         this.pwd = pwd;
25.         this.name = name;
26.         this.job = job;
27.     }
29.     public Integer getId() {
30.         return id;
31.     }
33.     public void setId(Integer id) {
34.         this.id = id;
35.     }
37.     public String getEmpId() {
38.         return empId;
39.     }
41.     public void setEmpId(String empId) {
42.         this.empId = empId;
43.     }
45.     public String getPwd() {
46.         return pwd;
47.     }
49.     public void setPwd(String pwd) {
50.         this.pwd = pwd;
51.     }
53.     public String getName() {
54.         return name;
55.     }
57.     public void setName(String name) {
58.         this.name = name;
59.     }
61.     public String getJob() {
62.         return job;
63.     }
65.     public void setJob(String job) {
66.         this.job = job;
67.     }
68. }

复制代码

Menu

1. package com.zwj.mhl.domain;
3. /**
4. * 该类(javabean)和 menu 表对应
5. * id int primary key auto_increment, #自增主键，作为菜谱编号(唯一)
6. * name varchar(50) not null default '',#菜品名称
7. * type varchar(50) not null default '', #菜品种类
8. * price double not null default 0#价格
9. */
10. public class Menu {
11.     private Integer id;
12.     private String name;
13.     private String type;
14.     private Double price;
16.     public Menu() {//无参构造器
17.     }
19.     public Menu(Integer id, String name, String type, Double price) {
20.         this.id = id;
21.         this.name = name;
22.         this.type = type;
23.         this.price = price;
24.     }
26.     public Integer getId() {
27.         return id;
28.     }
30.     public void setId(Integer id) {
31.         this.id = id;
32.     }
34.     public String getName() {
35.         return name;
36.     }
38.     public void setName(String name) {
39.         this.name = name;
40.     }
42.     public String getType() {
43.         return type;
44.     }
46.     public void setType(String type) {
47.         this.type = type;
48.     }
50.     public Double getPrice() {
51.         return price;
52.     }
54.     public void setPrice(Double price) {
55.         this.price = price;
56.     }
58.     @Override
59.     public String toString() {
60.         return id + "\t\t\t" + name + "\t\t" + type + "\t\t" + price;
61.     }
62. }

复制代码

MultiTableBean

1. package com.zwj.mhl.domain;
3. import java.util.Date;
5. /**
6. * 这是一个javabean 可以和多张表进行对应
7. */
8. public class MultiTableBean {
9.     private Integer id;
10.     private String billId;
11.     private Integer menuId;
12.     private Integer nums;
13.     private Double money;
14.     private Integer diningTableId;
15.     private Date billDate;
16.     private String state;
17.     //增加一个来自menu表的列 name
18.     //思考 这里的属性名是否一定要和表的列名保持一致.
19.     //答: 可以不一致，但是需要sql做相应的修改, 规范需要保持一致.
20.     private String name;
21.     //增加来自menu表的列 price
22.     private Double price;//默认值 null
24.     public MultiTableBean() {
25.         System.out.println("反射调用....");
26.     }
28. //    public MultiTableBean(Integer id, String billId, Integer menuId, Integer nums, Double money, Integer diningTableId, Date billDate, String state, String name, Double price) {
29. //        this.id = id;
30. //        this.billId = billId;
31. //        this.menuId = menuId;
32. //        this.nums = nums;
33. //        this.money = money;
34. //        this.diningTableId = diningTableId;
35. //        this.billDate = billDate;
36. //        this.state = state;
37. //        this.name = name;
38. //        this.price = price;
39. //    }
41.     //给price生成setter 和 getter
43.     public Double getPrice() {
44.         return price;
45.     }
47.     public void setPrice(Double price) {
48.         this.price = price;
49.     }
52.     //给name生成setter 和 getter
55.     public String getName() {
56.         return name;
57.     }
59.     public void setName(String name) {
60.         this.name = name;
61.     }
63.     public Integer getId() {
64.         return id;
65.     }
67.     public void setId(Integer id) {
68.         this.id = id;
69.     }
71.     public String getBillId() {
72.         return billId;
73.     }
75.     public void setBillId(String billId) {
76.         this.billId = billId;
77.     }
79.     public Integer getMenuId() {
80.         return menuId;
81.     }
83.     public void setMenuId(Integer menuId) {
84.         this.menuId = menuId;
85.     }
87.     public Integer getNums() {
88.         return nums;
89.     }
91.     public void setNums(Integer nums) {
92.         this.nums = nums;
93.     }
95.     public Double getMoney() {
96.         return money;
97.     }
99.     public void setMoney(Double money) {
100.         this.money = money;
101.     }
103.     public Integer getDiningTableId() {
104.         return diningTableId;
105.     }
107.     public void setDiningTableId(Integer diningTableId) {
108.         this.diningTableId = diningTableId;
109.     }
111.     public Date getBillDate() {
112.         return billDate;
113.     }
115.     public void setBillDate(Date billDate) {
116.         this.billDate = billDate;
117.     }
119.     public String getState() {
120.         return state;
121.     }
123.     public void setState(String state) {
124.         this.state = state;
125.     }
127.     @Override
128.     public String toString() {
129.         return  id +
130.                 "\t\t" + menuId +
131.                 "\t\t\t" + nums +
132.                 "\t\t\t" + money +
133.                 "\t" + diningTableId +
134.                 "\t\t" + billDate +
135.                 "\t\t" + state +
136.                 "\t\t" + name +
137.                 "\t\t" + price;
138.     }
139. }

复制代码

service

BillService

1. package com.zwj.mhl.service;
3. import com.zwj.mhl.dao.BillDAO;
4. import com.zwj.mhl.dao.MultiTableDAO;
5. import com.zwj.mhl.domain.Bill;
6. import com.zwj.mhl.domain.MultiTableBean;
8. import java.util.List;
9. import java.util.UUID;
11. /**
12. * 处理和账单相关的业务逻辑
13. */
14. public class BillService {
15.     //定义BillDAO属性
16.     private BillDAO billDAO = new BillDAO();
17.     //定义MenuService 属性
18.     private MenuService menuService = new MenuService();
19.     //定义DiningTableService属性
20.     private DiningTableService diningTableService = new DiningTableService();
22.     private MultiTableDAO multiTableDAO = new MultiTableDAO();
24.     //思考
25.     //编写点餐的方法
26.     //1. 生成账单
27.     //2. 需要更新对应餐桌的状态
28.     //3. 如果成功返回true, 否则返回false
29.     public boolean orderMenu(int menuId, int nums, int diningTableId) {
30.         //生成一个账单号,UUID
31.         String billID = UUID.randomUUID().toString();
33.         //将账单生成到bill表, 要求直接计算账单金额
34.         int update = billDAO.update("insert into bill values(null,?,?,?,?,?,now(),'未结账')",
35.                 billID, menuId, nums, menuService.getMenuById(menuId).getPrice() * nums, diningTableId);
37.         if (update <= 0) {
38.             return false;
39.         }
41.         //需要更新对应餐桌的状态
42.         return diningTableService.updateDiningTableState(diningTableId, "就餐中");
44.     }
46.     //返回所有的账单， 提供给View调用
47.     public List<Bill> list() {
48.         return billDAO.queryMulti("select * from bill", Bill.class);
49.     }
51.     //返回所有的账单并带有菜品名,价格， 提供给View调用
52.     public List<MultiTableBean> list2() {
53.         return multiTableDAO.queryMulti("SELECT bill.*, name,price " +
54.                 "FROM bill, menu " +
55.                 "WHERE bill.menuId = menu.id", MultiTableBean.class);
56.     }
59.     //查看某个餐桌是否有未结账的账单
60.     public boolean hasPayBillByDiningTableId(int diningTableId) {
62.         Bill bill =
63.                 billDAO.querySingle("SELECT * FROM bill WHERE diningTableId=? AND state = '未结账' LIMIT 0, 1", Bill.class, diningTableId);
64.         return bill != null;
65.     }
67.     //完成结账[如果餐桌存在，并且该餐桌有未结账的账单]
68.     //如果成功，返回true, 失败返回 false
69.     public boolean payBill(int diningTableId, String payMode) {
71.         //如果这里使用事务的话，需要用ThreadLocal来解决 , 框架中比如mybatis 提供了事务支持
72.         //1. 修改bill表
73.         int update = billDAO.update("update bill set state=? where diningTableId=? and state='未结账'", payMode, diningTableId);
75.         if(update <= 0) { //如果更新没有成功，则表示失败...
76.             return false;
77.         }
78.         //2. 修改diningTable表
79.         //注意：不要直接在这里操作，而应该调用DiningTableService 方法,完成更新，体现各司其职
81.         if(!diningTableService.updateDiningTableToFree(diningTableId, "空")) {
82.             return false;
83.         }
84.         return true;
86.     }
88. }

复制代码

EmployeeService

1. package com.zwj.mhl.service;
3. import com.zwj.mhl.dao.DiningTableDAO;
4. import com.zwj.mhl.domain.DiningTable;
6. import java.util.List;
8. public class DiningTableService { //业务层
9.     //定义一个DiningTableDAO对象
10.     private DiningTableDAO diningTableDAO = new DiningTableDAO();
12.     //返回所有餐桌的信息
13.     public List<DiningTable> list() {
15.         return diningTableDAO.queryMulti("select id, state from diningTable", DiningTable.class);
16.     }
18.     //根据id , 查询对应的餐桌DiningTable 对象
19.     //,如果返回null , 表示id编号对应的餐桌不存在
20.     public DiningTable getDiningTableById(int id) {
22.         //老韩小技巧：把sql语句放在查询分析器去测试一下.
23.         return diningTableDAO.querySingle("select * from diningTable where id = ?", DiningTable.class, id);
24.     }
26.     //如果餐桌可以预定，调用方法，对其状态进行更新(包括预定人的名字和电话)
27.     public boolean orderDiningTable(int id, String orderName, String orderTel) {
29.         int update =
30.                 diningTableDAO.update("update diningTable set state='已经预定', orderName=?, orderTel=? where id=?", orderName, orderTel, id);
32.         return  update > 0;
33.     }
35.     //需要提供一个更新 餐桌状态的方法
36.     public boolean updateDiningTableState(int id, String state) {
38.         int update = diningTableDAO.update("update diningTable set state=? where id=?", state, id);
39.         return update > 0;
40.     }
42.     //提供方法，将指定的餐桌设置为空闲状态
43.     public boolean updateDiningTableToFree(int id, String state) {
45.         int update = diningTableDAO.update("update diningTable set state=?,orderName='',orderTel='' where id=?", state, id);
46.         return update > 0;
47.     }
49. }

复制代码

MenuService

1. package com.zwj.mhl.service;
3. import com.zwj.mhl.dao.EmployeeDAO;
4. import com.zwj.mhl.domain.Employee;
6. /**
7. * 该类完成对employee表的各种操作(通过调用EmployeeDAO对象完成)
8. */
9. public class EmployeeService {
11.     //定义一个 EmployeeDAO 属性
12.     private EmployeeDAO employeeDAO = new EmployeeDAO();
14.     //方法，根据empId 和 pwd 返回一个Employee对象
15.     //如果查询不到，就返回null
16.     public Employee getEmployeeByIdAndPwd(String empId, String pwd) {
18.         return employeeDAO.querySingle("select * from employee where empId=? and pwd=md5(?)", Employee.class, empId, pwd);
20.     }
21. }

复制代码

utils

JDBCUtilsByDruid

1. package com.zwj.mhl.utils;
3. import com.alibaba.druid.pool.DruidDataSourceFactory;
5. import javax.sql.DataSource;
6. import java.io.FileInputStream;
7. import java.sql.Connection;
8. import java.sql.ResultSet;
9. import java.sql.SQLException;
10. import java.sql.Statement;
11. import java.util.Properties;
13. /**
14. * 基于druid数据库连接池的工具类
15. */
16. public class JDBCUtilsByDruid {
18.     private static DataSource ds;
20.     //在静态代码块完成 ds初始化
21.     static {
22.         Properties properties = new Properties();
23.         try {
24.             properties.load(new FileInputStream("src\\druid.properties"));
25.             ds = DruidDataSourceFactory.createDataSource(properties);
26.         } catch (Exception e) {
27.             e.printStackTrace();
28.         }
30.     }
32.     //编写getConnection方法
33.     public static Connection getConnection() throws SQLException {
34.         return ds.getConnection();
35.     }
37.     //关闭连接, 老师再次强调： 在数据库连接池技术中，close 不是真的断掉连接
38.     //而是把使用的Connection对象放回连接池
39.     public static void close(ResultSet resultSet, Statement statement, Connection connection) {
41.         try {
42.             if (resultSet != null) {
43.                 resultSet.close();
44.             }
45.             if (statement != null) {
46.                 statement.close();
47.             }
48.             if (connection != null) {
49.                 connection.close();
50.             }
51.         } catch (SQLException e) {
52.             throw new RuntimeException(e);
53.         }
54.     }
55. }

复制代码

Utility

1. package com.zwj.mhl.utils;
3. import com.alibaba.druid.pool.DruidDataSourceFactory;
5. import javax.sql.DataSource;
6. import java.io.FileInputStream;
7. import java.sql.Connection;
8. import java.sql.ResultSet;
9. import java.sql.SQLException;
10. import java.sql.Statement;
11. import java.util.Properties;
13. /**
14. * 基于druid数据库连接池的工具类
15. */
16. public class JDBCUtilsByDruid {
18.     private static DataSource ds;
20.     //在静态代码块完成 ds初始化
21.     static {
22.         Properties properties = new Properties();
23.         try {
24.             properties.load(new FileInputStream("src\\druid.properties"));
25.             ds = DruidDataSourceFactory.createDataSource(properties);
26.         } catch (Exception e) {
27.             e.printStackTrace();
28.         }
30.     }
32.     //编写getConnection方法
33.     public static Connection getConnection() throws SQLException {
34.         return ds.getConnection();
35.     }
37.     //关闭连接, 老师再次强调： 在数据库连接池技术中，close 不是真的断掉连接
38.     //而是把使用的Connection对象放回连接池
39.     public static void close(ResultSet resultSet, Statement statement, Connection connection) {
41.         try {
42.             if (resultSet != null) {
43.                 resultSet.close();
44.             }
45.             if (statement != null) {
46.                 statement.close();
47.             }
48.             if (connection != null) {
49.                 connection.close();
50.             }
51.         } catch (SQLException e) {
52.             throw new RuntimeException(e);
53.         }
54.     }
55. }

复制代码

view

MHLView

1. package com.zwj.mhl.utils;
4. /**
5.    工具类的作用:
6.    处理各种情况的用户输入，并且能够按照程序员的需求，得到用户的控制台输入。
7. */
9. import java.util.*;
10. /**
12.    
13. */
14. public class Utility {
15.    //静态属性。。。
16.     private static Scanner scanner = new Scanner(System.in);
18.    
19.     /**
20.      * 功能：读取键盘输入的一个菜单选项，值：1——5的范围
21.      * @return 1——5
22.      */
23.    public static char readMenuSelection() {
24.         char c;
25.         for (; ; ) {
26.             String str = readKeyBoard(1, false);//包含一个字符的字符串
27.             c = str.charAt(0);//将字符串转换成字符char类型
28.             if (c != '1' && c != '2' &&
29.                 c != '3' && c != '4' && c != '5') {
30.                 System.out.print("选择错误，请重新输入：");
31.             } else break;
32.         }
33.         return c;
34.     }
36.    /**
37.     * 功能：读取键盘输入的一个字符
38.     * @return 一个字符
39.     */
40.     public static char readChar() {
41.         String str = readKeyBoard(1, false);//就是一个字符
42.         return str.charAt(0);
43.     }
44.     /**
45.      * 功能：读取键盘输入的一个字符，如果直接按回车，则返回指定的默认值；否则返回输入的那个字符
46.      * @param defaultValue 指定的默认值
47.      * @return 默认值或输入的字符
48.      */
49.    
50.     public static char readChar(char defaultValue) {
51.         String str = readKeyBoard(1, true);//要么是空字符串，要么是一个字符
52.         return (str.length() == 0) ? defaultValue : str.charAt(0);
53.     }
54.    
55.     /**
56.      * 功能：读取键盘输入的整型，长度小于2位
57.      * @return 整数
58.      */
59.     public static int readInt() {
60.         int n;
61.         for (; ; ) {
62.             String str = readKeyBoard(2, false);//一个整数，长度<=2位
63.             try {
64.                 n = Integer.parseInt(str);//将字符串转换成整数
65.                 break;
66.             } catch (NumberFormatException e) {
67.                 System.out.print("数字输入错误，请重新输入：");
68.             }
69.         }
70.         return n;
71.     }
72.     /**
73.      * 功能：读取键盘输入的 整数或默认值，如果直接回车，则返回默认值，否则返回输入的整数
74.      * @param defaultValue 指定的默认值
75.      * @return 整数或默认值
76.      */
77.     public static int readInt(int defaultValue) {
78.         int n;
79.         for (; ; ) {
80.             String str = readKeyBoard(10, true);
81.             if (str.equals("")) {
82.                 return defaultValue;
83.             }
84.          
85.          //异常处理...
86.             try {
87.                 n = Integer.parseInt(str);
88.                 break;
89.             } catch (NumberFormatException e) {
90.                 System.out.print("数字输入错误，请重新输入：");
91.             }
92.         }
93.         return n;
94.     }
96.     /**
97.      * 功能：读取键盘输入的指定长度的字符串
98.      * @param limit 限制的长度
99.      * @return 指定长度的字符串
100.      */
102.     public static String readString(int limit) {
103.         return readKeyBoard(limit, false);
104.     }
106.     /**
107.      * 功能：读取键盘输入的指定长度的字符串或默认值，如果直接回车，返回默认值，否则返回字符串
108.      * @param limit 限制的长度
109.      * @param defaultValue 指定的默认值
110.      * @return 指定长度的字符串
111.      */
112.    
113.     public static String readString(int limit, String defaultValue) {
114.         String str = readKeyBoard(limit, true);
115.         return str.equals("")? defaultValue : str;
116.     }
119.    /**
120.     * 功能：读取键盘输入的确认选项，Y或N
121.     * 将小的功能，封装到一个方法中.
122.     * @return Y或N
123.     */
124.     public static char readConfirmSelection() {
125.         System.out.println("请输入你的选择(Y/N)");
126.         char c;
127.         for (; ; ) {//无限循环
128.            //在这里，将接受到字符，转成了大写字母
129.            //y => Y n=>N
130.             String str = readKeyBoard(1, false).toUpperCase();
131.             c = str.charAt(0);
132.             if (c == 'Y' || c == 'N') {
133.                 break;
134.             } else {
135.                 System.out.print("选择错误，请重新输入：");
136.             }
137.         }
138.         return c;
139.     }
141.     /**
142.      * 功能： 读取一个字符串
143.      * @param limit 读取的长度
144.      * @param blankReturn 如果为true ,表示 可以读空字符串。
145.      *                   如果为false表示 不能读空字符串。
146.      *           
147.     * 如果输入为空，或者输入大于limit的长度，就会提示重新输入。
148.      * @return
149.      */
150.     private static String readKeyBoard(int limit, boolean blankReturn) {
151.         
152.       //定义了字符串
153.       String line = "";
155.       //scanner.hasNextLine() 判断有没有下一行
156.         while (scanner.hasNextLine()) {
157.             line = scanner.nextLine();//读取这一行
158.            
159.          //如果line.length=0, 即用户没有输入任何内容，直接回车
160.          if (line.length() == 0) {
161.                 if (blankReturn) return line;//如果blankReturn=true,可以返回空串
162.                 else continue; //如果blankReturn=false,不接受空串，必须输入内容
163.             }
165.          //如果用户输入的内容大于了 limit，就提示重写输入  
166.          //如果用户如的内容 >0 <= limit ,我就接受
167.             if (line.length() < 1 || line.length() > limit) {
168.                 System.out.print("输入长度（不能大于" + limit + "）错误，请重新输入：");
169.                 continue;
170.             }
171.             break;
172.         }
174.         return line;
175.     }
176. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

---

欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)

Powered by Discuz! X3.4