SMBMS超市订单管理系统

可以绿你吗 · 发布于 2023-5-26 14:09:57

文章目录

MVC三层架构（代码整体以此分层编写）

整体的流程与代码编写思路

建议是从后往前写，便于调试与debug，先编写Dao层，主要负责与数据库交互，编写sql语句等。然后编写Servicce层，主要负责调用Dao层，再编写Servlet层，其也是主要调用Service和前端的一些数据交互，比如resquet和response等。
根本架构

项目搭建准备工作

1- 4

5 创建项目包构造

6-7

package com.tong.dao;import java.io.IOException;import java.io.InputStream;import java.sql.*;import java.util.Properties;/**
* 操作数据库的基类--静态类
* @author Administrator
*
*/publicclassBaseDao{static{//静态代码块,在类加载的时候执行init();}privatestatic String driver;privatestatic String url;privatestatic String user;privatestatic String password;//初始化连接参数,从配置文件里获得publicstaticvoidinit(){
Properties params=newProperties();
String configFile ="db.properties";
InputStream is=BaseDao.class.getClassLoader().getResourceAsStream(configFile);try{
params.load(is);}catch(IOException e){
e.printStackTrace();}
driver=params.getProperty("driver");
url=params.getProperty("url");
user=params.getProperty("user");
password=params.getProperty("password");}/**
* 获取数据库连接
* @return
*/publicstatic Connection getConnection(){
Connection connection = null;try{
Class.forName(driver);
connection = DriverManager.getConnection(url, user, password);}catch(Exception e){// TODO Auto-generated catch block
e.printStackTrace();}return connection;}/**
* 查询操作
* @param connection
* @param pstm
* @param rs
* @param sql
* @param params
* @return
*/publicstatic ResultSet execute(Connection connection,PreparedStatement pstm,ResultSet rs, String sql,Object[] params)throws Exception{
pstm = connection.prepareStatement(sql);//向sql中的占位符加载参数Object[] paramsfor(int i =0; i < params.length; i++){
pstm.setObject(i+1, params[i]);}
rs = pstm.executeQuery();return rs;}/**
* 更新操作
* @param connection
* @param pstm
* @param sql
* @param params
* @return
* @throws Exception
*/publicstaticintexecute(Connection connection,PreparedStatement pstm, String sql,Object[] params)throws Exception{int updateRows =0;
pstm = connection.prepareStatement(sql);for(int i =0; i < params.length; i++){
pstm.setObject(i+1, params[i]);}
updateRows = pstm.executeUpdate();return updateRows;}/**
* 释放资源
* @param connection
* @param pstm
* @param rs
* @return
*/publicstaticbooleancloseResource(Connection connection,PreparedStatement pstm,ResultSet rs){boolean flag =true;if(rs != null){try{
rs.close();
rs = null;//GC回收,假设rs.close();没关上，让其等于null，使垃圾回收器自动回收。}catch(SQLException e){// TODO Auto-generated catch block
e.printStackTrace();
flag =false;}}if(pstm != null){try{
pstm.close();
pstm = null;//GC回收}catch(SQLException e){// TODO Auto-generated catch block
e.printStackTrace();
flag =false;}}if(connection != null){try{
connection.close();
connection = null;//GC回收}catch(SQLException e){// TODO Auto-generated catch block
e.printStackTrace();
flag =false;}}return flag;}}

复制代码

8 导致静态资源

登录功能实现

1.编写前端页面

<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%><!DOCTYPE html><html><head lang="en"><meta charset="UTF-8"><title>系统登录 - 超市订单管理系统</title><link type="text/css" rel="stylesheet" href="${pageContext.request.contextPath }/css/style.css"/><script type="text/javascript">/* if(top.location!=self.location){
top.location=self.location;
} */</script></head><body class="login_bg"><section class="loginBox"><header class="loginHeader"><h1>超市订单管理系统</h1></header><section class="loginCont"><form class="loginForm" action="${pageContext.request.contextPath }/login.do" name="actionForm" id="actionForm" method="post"><div class="info">${error }</div><div class="inputbox"><label for="userCode">用户名：</label><input type="text"class="input-text" id="userCode" name="userCode" placeholder="请输入用户名" required/></div><div class="inputbox"><label for="userPassword">密码：</label><input type="password" id="userPassword" name="userPassword" placeholder="请输入密码" required/></div><div class="subBtn"><input type="submit" value="登录"/><input type="reset" value="重置"/></div></form></section></section></body></html>

复制代码

2.设置首页

<welcome-file-list><welcome-file>login.jsp</welcome-file></welcome-file-list>

复制代码

3.编写Dao层用户登录的接口

public User getLoginUser(Connection connection, String userCode)throws Exception;

复制代码

4.编写Dao接口实现类

public User getLoginUser(Connection connection, String userCode)throws Exception {// TODO Auto-generated method stub
PreparedStatement pstm = null;
ResultSet rs = null;
User user = null;if(null != connection){
String sql ="select * from smbms_user where userCode=?";
Object[] params ={userCode};
rs = BaseDao.execute(connection, pstm, rs, sql, params);if(rs.next()){
user =newUser();
user.setId(rs.getInt("id"));
user.setUserCode(rs.getString("userCode"));
user.setUserName(rs.getString("userName"));
user.setUserPassword(rs.getString("userPassword"));
user.setGender(rs.getInt("gender"));
user.setBirthday(rs.getDate("birthday"));
user.setPhone(rs.getString("phone"));
user.setAddress(rs.getString("address"));
user.setUserRole(rs.getInt("userRole"));
user.setCreatedBy(rs.getInt("createdBy"));
user.setCreationDate(rs.getTimestamp("creationDate"));
user.setModifyBy(rs.getInt("modifyBy"));
user.setModifyDate(rs.getTimestamp("modifyDate"));}//connection设成null不让其关闭，是因为后面业务层还需要数据库连接。
BaseDao.closeResource(null, pstm, rs);}return user;}

复制代码

5.业务层接口

publicinterfaceUserService{//用户登录public User login(String userCode, String userPassword);}

复制代码

6.业务层实现类

publicclassUserServiceImplimplementsUserService{private UserDao userDao;publicUserServiceImpl(){
userDao =newUserDaoImpl();}public User login(String userCode, String userPassword){// TODO Auto-generated method stub
Connection connection = null;
User user = null;try{
connection = BaseDao.getConnection();
user = userDao.getLoginUser(connection, userCode);}catch(Exception e){// TODO Auto-generated catch block
e.printStackTrace();}finally{
BaseDao.closeResource(connection, null, null);}//匹配密码if(null != user){if(!user.getUserPassword().equals(userPassword))
user = null;}return user;}}

复制代码

7.编写servlet

publicclassLoginServletextendsHttpServlet{//servlet:控制层，接收用户的恳求，调用业务层代码。@OverrideprotectedvoiddoGet(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {//从前端获取用户名和密码（接收用户的恳求）
String userCode = req.getParameter("userCode");
String userPassword = req.getParameter("userPassword");//接收恳求后需处置业务，业务是：和数据库中的数据停止对比，所以需调用业务层
UserServiceImpl userService =newUserServiceImpl();
User user = userService.login(userCode, userPassword);//这里已经把登录的人给查出来了if(user != null){//查有此人，可以登录//将用户的信息放入Session中
req.getSession().setAttribute(Constant.USER_SESSION , user);//跳转主页(跳转到另一个页面，地址变了，所以用重定向)
resp.sendRedirect("jsp/frame.jsp");}else{//查无此人，无法登录//转发会登录页面，顺带提示它，用户名或密码错误。（(跳转到本页面，只是在本页面加了些信息（用户名或密码错误），地址没变，所以用恳求转发)）
req.setAttribute("error","用户名或密码错误");//恳求可以携带数据
req.getRequestDispatcher("login.jsp").forward(req , resp);}}@OverrideprotectedvoiddoPost(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {doGet(req, resp);}}

复制代码

8.注册servlet

<servlet><servlet-name>LoginServlet</servlet-name><servlet-class>com.tong.servlet.user.LoginServlet</servlet-class></servlet><servlet-mapping><servlet-name>LoginServlet</servlet-name><url-pattern>/login.do</url-pattern></servlet-mapping>

复制代码

整体流程

前端一启动，执行login.jsp（设置成了首页），直接到web.xml中设置的login.do（servlet映射），调用对应的控制器servlet（LoginServlet），servlet中会调用业务（UserServiceImpl），然后业务会调用想用的Dao（UserDaoImpl）来获取数据。
登录功能优化

注销功能：

思路：移除session，返回登录界面；

publicclassLogoutServletextendsHttpServlet{@OverrideprotectedvoiddoGet(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {
req.getSession().removeAttribute(Constant.USER_SESSION);
resp.sendRedirect(req.getContextPath()+"/login.jsp");}@OverrideprotectedvoiddoPost(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {doGet(req, resp);}}

复制代码

注册

<servlet><servlet-name>LogoutServlet</servlet-name><servlet-class>com.tong.servlet.user.LogoutServlet</servlet-class></servlet><servlet-mapping><servlet-name>LogoutServlet</servlet-name><url-pattern>/jsp/logout.do</url-pattern></servlet-mapping>

复制代码

登陆拦截优化

为什么要登陆拦截优化

详细步骤

编写一个过滤器，并注册

publicclassSysFilterimplementsFilter{publicvoidinit(FilterConfig filterConfig)throws ServletException {}publicvoiddoFilter(ServletRequest req, ServletResponse resp, FilterChain chain)throws IOException, ServletException {
HttpServletRequest request =(HttpServletRequest) req;
HttpServletResponse response =(HttpServletResponse) resp;//过滤器，从session中获取用户
User user =(User) request.getSession().getAttribute(Constant.USER_SESSION);if(user == null){//session已经被移除，或者用户注销，或还没登录
response.sendRedirect("error.jsp");}else{
chain.doFilter(req , resp);}}publicvoiddestroy(){}}

复制代码

<filter><filter-name>SysFilter</filter-name><filter-class>com.tong.filter.SysFilter</filter-class></filter><filter-mapping><filter-name>SysFilter</filter-name><url-pattern>/jsp/*</url-pattern></filter-mapping>

复制代码

密码修改

密码修改，需要和数据库打交道，所以还需要走dao层、service层、servlet层这一条线。

1.导入前端素材

2.写项目，建议从下向上写

3.编写Dao层修改当前用户密码接口

//修改当前用户密码//增删改返回的都是int类型，查找返回对应的实体类；publicintupdatePwd(Connection connection,int id, String pwd)throws Exception;

复制代码

4.编写Dao接口实现类

publicintupdatePwd(Connection connection,int id, String pwd)throws Exception {// TODO Auto-generated method stubint flag =0;
PreparedStatement pstm = null;if(connection != null){
String sql ="update smbms_user set userPassword= ? where id = ?";
Object[] params ={pwd,id};
flag = BaseDao.execute(connection, pstm, sql, params);
BaseDao.closeResource(null, pstm, null);}return flag;}

复制代码

5.业务层接口

//根据userId修改密码publicbooleanupdatePwd(int id, String pwd);

复制代码

6.业务层接口实现类

publicclassUserServiceImplimplementsUserService{//引入Dao，以后spring会替代这一步private UserDao userDao;publicUserServiceImpl(){
userDao =newUserDaoImpl();}
。。。。（各个函数）
}

复制代码

publicbooleanupdatePwd(int id, String pwd){boolean flag =false;//使用标志位，判断密码是否修改胜利。
Connection connection = null;try{
connection = BaseDao.getConnection();if(userDao.updatePwd(connection,id,pwd)>0)
flag =true;}catch(Exception e){
e.printStackTrace();}finally{
BaseDao.closeResource(connection, null, null);}return flag;}

复制代码

7.servlet记得实现复用需要提取出方法

//实现servlet复用publicclassUserServletextendsHttpServlet{@OverrideprotectedvoiddoGet(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {
String method = req.getParameter("method");if(method.equals("savepwd")){this.updatePwd(req , resp);}}@OverrideprotectedvoiddoPost(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {doGet(req, resp);}publicvoidupdatePwd(HttpServletRequest req, HttpServletResponse resp)throws ServletException, IOException {//从session里拿Uer实体类
Object o = req.getSession().getAttribute(Constant.USER_SESSION);
String newPassword = req.getParameter("newPassword");boolean flag =false;if(o != null && newPassword != null && newPassword.length()!=0){//Uer实体类和新密码newPassword都拿到了，开端调用业务层
UserServiceImpl userService =newUserServiceImpl();
flag = userService.updatePwd(((User) o).getId(), newPassword);if(flag){
req.setAttribute("message","修改密码胜利，请退出，使用新密码登录");//密码修改胜利，当前session。因为密码变了，session的内容自然也变了，所以需要移除，又因为密码变了需要重新登录，所以session会重新创建
req.getSession().removeAttribute(Constant.USER_SESSION);}else{
req.setAttribute("message","密码修改失败");}}else{
req.setAttribute("message","新密码有问题");}
req.getRequestDispatcher("pwdmodify.jsp").forward(req , resp);}}

复制代码

优化密码修改使用Ajax

1.阿里巴巴的fastjson

<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.61</version></dependency>

复制代码

2.后台代码修改

publicvoidpwdModify(HttpServletRequest req, HttpServletResponse resp)throws IOException {//从Session中拿ID
Object o = req.getSession().getAttribute(Constant.USER_SESSION);
String oldpassword = req.getParameter("oldpassword");//万能的Map : 结果集
Map<String, String> resultMap =newHashMap<String, String>();if(null == o ){//session过期、失效
resultMap.put("result","sessionerror");}elseif(StringUtils.isNullOrEmpty(oldpassword)){//旧密码输入为空
resultMap.put("result","error");}else{
String sessionPwd =((User)o).getUserPassword();if(oldpassword.equals(sessionPwd)){
resultMap.put("result","true");}else{//旧密码输入不正确
resultMap.put("result","false");}}
resp.setContentType("application/json");
PrintWriter outPrintWriter = resp.getWriter();
outPrintWriter.write(JSONArray.toJSONString(resultMap));
outPrintWriter.flush();
outPrintWriter.close();}

复制代码

用户管理实现(查询)

思路

导入静态资源

1.导入分页的工具类

publicclassPageSupport{//当前页码-来自于用户输入privateint currentPageNo =1;//总数量（表）privateint totalCount =0;//页面容量privateint pageSize =0;//总页数-totalCount/pageSize（+1）privateint totalPageCount =1;publicintgetCurrentPageNo(){return currentPageNo;}publicvoidsetCurrentPageNo(int currentPageNo){if(currentPageNo >0){this.currentPageNo = currentPageNo;}}publicintgetTotalCount(){return totalCount;}publicvoidsetTotalCount(int totalCount){if(totalCount >0){this.totalCount = totalCount;//设置总页数this.setTotalPageCountByRs();}}publicintgetPageSize(){return pageSize;}publicvoidsetPageSize(int pageSize){if(pageSize >0){this.pageSize = pageSize;}}publicintgetTotalPageCount(){return totalPageCount;}publicvoidsetTotalPageCount(int totalPageCount){this.totalPageCount = totalPageCount;}publicvoidsetTotalPageCountByRs(){if(this.totalCount %this.pageSize ==0){this.totalPageCount =this.totalCount /this.pageSize;}elseif(this.totalCount %this.pageSize >0){this.totalPageCount =this.totalCount /this.pageSize +1;}else{this.totalPageCount =0;}}}

复制代码

2.导入用户列表页面

1.获取用户数量

1.UerDao接口

//通过条件查询-用户表记录数publicintgetUserCount(Connection connection, String userName,int userRole)throws Exception;

复制代码

2.UerDaoImpl【使用动态SQL】

//根据用户名或用户角色查询用户总数publicintgetUserCount(Connection connection, String userName,int userRole)throws Exception {// TODO Auto-generated method stub
PreparedStatement pstm = null;
ResultSet rs = null;int count =0;if(connection != null){//用StringBuffer是因为userName和userRole可能有也可能没有(也就是sql语句不确定，可变-->动态sql)，利用StringBuffer的可变性停止随时添加
StringBuffer sql =newStringBuffer();
sql.append("select count(1) as count from smbms_user u,smbms_role r where u.userRole = r.id");//用ArrayList也是因为应对userName和userRole有没有的情况，随时添加。// 假设直接用object[]={userName，userRole}的话，userName和userRole不一定谁有谁没有，这样在dao层的执行语句中给sql语句的占位符（？）复制时，可能参数对不上，使用ArrayList随时添加可以处置这个问题。
List<Object> list =newArrayList<Object>();if(!StringUtils.isNullOrEmpty(userName)){
sql.append(" and u.userName like ?");
list.add("%"+userName+"%");}if(userRole >0){
sql.append(" and u.userRole = ?");
list.add(userRole);}//把list转换成数组。//经过判断，userName和userRole谁存在谁不存在已经确定，list中保管了存在的参数，此时可以转换成数组Object[] params，供BaseDao.execute（）调用。
Object[] params = list.toArray();
System.out.println("sql ----> "+ sql.toString());
rs = BaseDao.execute(connection, pstm, rs, sql.toString(), params);if(rs.next()){
count = rs.getInt("count");//从结果集中获取最终的数量。}
BaseDao.closeResource(null, pstm, rs);}return count;}

复制代码

3.UerService接口

//根据条件查询用户表记录数publicintgetUserCount(String queryUserName,int queryUserRole);

复制代码

4.UeServiceImpl

publicintgetUserCount(String queryUserName,int queryUserRole){// TODO Auto-generated method stub
Connection connection = null;int count =0;
System.out.println("queryUserName ---- > "+ queryUserName);
System.out.println("queryUserRole ---- > "+ queryUserRole);try{
connection = BaseDao.getConnection();
count = userDao.getUserCount(connection, queryUserName,queryUserRole);}catch(Exception e){// TODO Auto-generated catch block
e.printStackTrace();}finally{
BaseDao.closeResource(connection, null, null);}return count;}

复制代码

2.获取用户列表

3.获取角色列表

为了构造明晰，将角色相关的代码单独放在一个包中，和pojo类对应，编写对应的dao和service

4.用户显示的servlet【这个servlet较为复杂】

至此效劳处置完了，编写最后的servlet，这个servlet程序主要包括以下5部分。

//重点、难点privatevoidquery(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {//查询用户列表//从前端获取数据
String queryUserName = request.getParameter("queryname");
String temp = request.getParameter("queryUserRole");
String pageIndex = request.getParameter("pageIndex");int queryUserRole =0;
UserService userService =newUserServiceImpl();
List<User> userList = null;//设置页面容量。// 第一次走这个恳求，一定是第一页，页面大小固定int pageSize = Constant.pageSize;//当前页码int currentPageNo =1;/**
* http://localhost:8090/SMBMS/userlist.do
* ----queryUserName --NULL
* http://localhost:8090/SMBMS/userlist.do?queryname=
* --queryUserName ---""
*/
System.out.println("queryUserName servlet--------"+queryUserName);
System.out.println("queryUserRole servlet--------"+queryUserRole);
System.out.println("query pageIndex--------- > "+ pageIndex);//判断这些恳求是否要处置if(queryUserName == null){
queryUserName ="";}if(temp != null &&!temp.equals("")){
queryUserRole = Integer.parseInt(temp);}if(pageIndex != null){try{
currentPageNo = Integer.valueOf(pageIndex);}catch(NumberFormatException e){
response.sendRedirect("error.jsp");}}//为了实现分页，需要计算出当前页面和总页面，页面大小...//总数量（表）int totalCount = userService.getUserCount(queryUserName,queryUserRole);//总页数
PageSupport pages=newPageSupport();
pages.setCurrentPageNo(currentPageNo);
pages.setPageSize(pageSize);
pages.setTotalCount(totalCount);int totalPageCount = pages.getTotalPageCount();//控制首页和尾页if(currentPageNo <1){
currentPageNo =1;}elseif(currentPageNo > totalPageCount){
currentPageNo = totalPageCount;}//获取用户列表展示
userList = userService.getUserList(queryUserName,queryUserRole,currentPageNo, pageSize);
request.setAttribute("userList", userList);
List<Role> roleList = null;
RoleService roleService =newRoleServiceImpl();
roleList = roleService.getRoleList();
request.setAttribute("roleList", roleList);
request.setAttribute("queryUserName", queryUserName);
request.setAttribute("queryUserRole", queryUserRole);
request.setAttribute("totalPageCount", totalPageCount);
request.setAttribute("totalCount", totalCount);
request.setAttribute("currentPageNo", currentPageNo);
request.getRequestDispatcher("userlist.jsp").forward(request, response);}

复制代码

用户管理实现(增删改)

publicbooleanadd(User user){// TODO Auto-generated method stubboolean flag =false;
Connection connection = null;try{
connection = BaseDao.getConnection();
connection.setAutoCommit(false);//开启JDBC事务管理int updateRows = userDao.add(connection,user);
connection.commit();if(updateRows >0){
flag =true;
System.out.println("add success!");}else{
System.out.println("add failed!");}}catch(Exception e){
e.printStackTrace();try{
System.out.println("rollback==================");//假设执行出错就回滚
connection.rollback();}catch(SQLException e1){// TODO Auto-generated catch block
e1.printStackTrace();}}finally{//在service层停止connection连接的关闭
BaseDao.closeResource(connection, null, null);}return flag;}

复制代码

供给商管理、订单管理

供给商管理、订单管理，和用户管理一样，也分查询和增删改两部分。施行方式也大致类似