作业终于做完了，好开心。。。。。。虽然这一周经历不是那么顺利，但是觉得还是收获了不少，有过想哭的冲动，代码不会写，事情办不好，各种发愁。空间里发小发了带父母出去游玩的照片，瞬间能量值不知道是被击退的多还是回返的多。不过今天终于补满能量值。下面我来分享一下我的运行结果。

下面我把我管理后台的代码粘贴一下

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  3.  
  4.  
  5. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  6. <html>
  7.     <head>
  8.         <title>top.jsp</title>
  9.         <style type="text/css">
  10. body {
  11.     text-align: center;
  12.     font-size: 38px;
  13. }
  15. * {
  16.     font-family: 华文楷体;
  17.     font-size: 18px;
  18.     color: #F0F ";
  19. }
  21. h1 {
  22.     text-align: center;
  23.     font-size: 38px;
  24. }
  25. </style>
  26.     </head>
  27.  
  28.     <body>
  29.         <h1 style="font-size: 38px;">
  30.             欢迎登录网上购物后台
  31.         </h1>
  32.  
  33.         <form action="<c:url value=\'/AdminServlet\'/>" method="post">
  34.             <input type="hidden" name="method" value="1">
  35.             用户名:
  36.             <input type="text" name="username" />
  37.             <br />
  38.             密 &nbsp; 码:
  39.             <input type="password" name="password" />
  40.             <br />
  41.             <input type="submit" value="登录">
  42.         </form>
  43.     </body>
  44. </html>

 

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  3. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  4. <html>
  5.     <head>
  6.         <title>list.jsp</title>
  7.         <style type="text/css">
  8. body {
  9.     text-align: center;
  10.     font-size: 38px;
  11. }
  13. * {
  14.     font-family: 华文楷体;
  15.     font-size: 18px;
  16.     color: #F0F ";
  17. }
  18. img{
  19.     width: 50px;
  20.     height: 30px;
  21.  
  22.  
  23. }
  24. h1 {
  25.     text-align: center;
  26.     font-size: 38px;
  27. }
  29. a:link {
  30.     color: #999;
  31.     text-decoration: none;
  32. }
  34. a:VISITED {
  35.     text-decoration: none;
  36.     color: #c60;
  37. }
  39. a:HOVER {
  40.     text-decoration: none;
  41.     color: #00F;
  42. }
  43. </style>
  44.  
  45.     </head>
  46.  
  47.     <body>
  48.         <h1 style="font-size: 38px;">
  49.             欢迎登录到网上购物后台系统
  50.         </h1>
  51.         <a style="font-size: 26px;"
  52.             href="<c:url value=\'/AdminServlet?method=2\'/>">查看商品</a>
  53.         <a style="font-size: 26px;" href="<c:url value=\'/admin/add.jsp\'/>">添加商品</a>
  54.         <a style="font-size: 26px;"
  55.             href="<c:url value=\'/AdminServlet?method=7\'/>">查看订单</a>
  56.         <a style="font-size: 26px;" href="<c:url value=\'/admin/login.jsp\'/>">退出系统</a>
  57.  
  58.         <table border="1" align="center" width="60%">
  59.             <tr>
  60.                 <th>
  61.                     商品名
  62.                 </th>
  63.                 <th>
  64.                     价格
  65.                 </th>
  66.                 <th>
  67.                     类型
  68.                 </th>
  69.                 <th>
  70.                     数量
  71.                 </th>
  72.                 <th>
  73.                     图片
  74.                 </th>
  75.                 <th>
  76.                     描述
  77.                 </th>
  78.                 <th>
  79.                     操作
  80.                 </th>
  81.  
  82.             </tr>
  83.             <c:forEach items="${pb.datas }" var="c">
  84.                 <tr>
  85.                     <td>
  86.                         ${c.name }
  87.                     </td>
  88.                     <td>
  89.                         ${c.price }
  90.                     </td>
  91.                     <td>
  92.                         ${c.category }
  93.                     </td>
  94.                     <td>
  95.                         ${c.pnum}
  96.                     </td>
  97.                     <td>
  98.                         <a href="<c:url value=\'/AdminServlet?method=9&id=${c.id }\'/>"><img  src="${c.imgurl }"/> </a>
  99.                     </td>
  100.                     <td>
  101.                         ${c.description }
  102.                     </td>
  103.  
  104.                     <td>
  105.                         <a href="<c:url value=\'/AdminServlet?method=4&id=${c.id }\'/>">编辑</a>
  106.                         <a href="<c:url value=\'/OrderServlet?method=4&id=${c.id }\'/>">删除</a>
  107.                     </td>
  108.                 </tr>
  109.             </c:forEach>
  110.         </table>
  111.         <br>
  112.         第${pb.pageCode }页/共${pb.totalPage }页
  113.         <a href="<c:url value=\'/AdminServlet?method=2\'/>">首页</a>
  114.         <c:if test="${pb.pageCode > 1}">
  115.             <a
  116.                 href="<c:url value=\'/AdminServlet?method=2&pageCode=${pb.pageCode-1}\'/>">上一页</a>
  117.         </c:if>
  118.         <%--页码列表 --%>
  119.         <c:set var="begin" value="1" />
  120.         <c:set var="end" value="10" />
  121.  
  122.         <!-- 定位begin和end -->
  123.         <c:choose>
  124.             <c:when test="${pb.totalPage <= 10}">
  125.                 <c:set var="begin" value="1" />
  126.                 <c:set var="end" value="${pb.totalPage}" />
  127.             </c:when>
  128.             <c:otherwise>
  129.                 <c:choose>
  130.                     <c:when test="${pb.pageCode-4 <= 1 }">
  131.                         <c:set var="begin" value="1" />
  132.                         <c:set var="end" value="10" />
  133.                     </c:when>
  134.                     <c:when test="${pb.pageCode+5 > pb.totalPage}">
  135.                         <c:set var="begin" value="${pb.totalPage-9}" />
  136.                         <c:set var="end" value="${pb.totalPage}" />
  137.                     </c:when>
  138.                     <c:otherwise>
  139.                         <c:set var="begin" value="${pb.pageCode-4}" />
  140.                         <c:set var="end" value="${pb.pageCode+5}" />
  141.                     </c:otherwise>
  142.                 </c:choose>
  143.             </c:otherwise>
  144.         </c:choose>
  145.         <c:forEach begin="${begin}" end="${end}" var="i">
  146.             <c:choose>
  147.                 <c:when test="${pb.pageCode == i}">${i}</c:when>
  148.                 <c:otherwise>
  149.                     <a href="<c:url value=\'/AdminServlet?method=2&pageCode=${i}\'/>">${i
  150.                         }</a>
  151.                 </c:otherwise>
  152.             </c:choose>
  153.         </c:forEach>
  154.  
  155.         <c:if test="${pb.pageCode < pb.totalPage}">
  156.             <a
  157.                 href="<c:url value=\'/AdminServlet?method=2&pageCode=${pb.pageCode+1}\'/>">下一页</a>
  158.         </c:if>
  159.         <a
  160.             href="<c:url value=\'/AdminServlet?method=2&pageCode=${pb.totalPage }\'/>">尾页</a>
  161.  
  162.     </body>
  163. </html>

 

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  3.  
  4.  
  5. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  6. <html>
  7.     <head>
  8.         <title>add.jsp</title>
  9.         <style type="text/css">
  10. body {
  11.     text-align: center;
  12.     font-size: 38px;
  13. }
  15. * {
  16.     font-family: 华文楷体;
  17.     font-size: 18px;
  18.     color: #F0F ";
  19. }
  21. h1 {
  22.     text-align: center;
  23.     font-size: 38px;
  24. }
  25. </style>
  26.  
  27.     </head>
  28.  
  29.     <body>
  30.  
  31.         <h1 style="font-size: 38px;">
  32.             添加商品
  33.         </h1>
  34.  
  35.         <form action="<c:url value=\'/AdminServlet\'/>" method="post">
  36.             <input type="hidden" name="method" value="3">
  37.             <table border="1" width="50%" align="center">
  38.                 <tr>
  39.                     <td>
  40.                         商品名
  41.                     </td>
  42.                     <td>
  43.                         <input type="text" name="name" id="name" onfocus="nameFocus()"
  44.                             onblur="nameBlur()" />
  45.                         <div id="nameId"></div>
  46.                     </td>
  47.                 </tr>
  48.                 <tr>
  49.                     <td>
  50.                         价格
  51.                     </td>
  52.                     <td>
  53.                         <input type="text" name="price" id="tel" onfocus="telFocus()"
  54.                             onblur="telBlur()" />
  55.                         <div id="telId"></div>
  56.                     </td>
  57.                 </tr>
  58.                 <tr>
  59.                     <td>
  60.                         类型
  61.                     </td>
  62.                     <td>
  63.                         <input type="text" name="category" id="address" />
  64.                     </td>
  65.                 </tr>
  66.                 <tr>
  67.                     <td>
  68.                         数量
  69.                     </td>
  70.                     <td>
  71.                         <input type="text" name="pnum" />
  72.                     </td>
  73.                 </tr>
  74.             
  75.                 <tr>
  76.                     <td>
  77.                         描述
  78.                     </td>
  79.                     <td>
  80.                         <input type="text" name="description" />
  81.                     </td>
  82.                 </tr>
  83.  
  84.  
  85.             </table>
  86.             <input style="margin-right: 200px;" type="submit" value="添加" />
  87.  
  88.         </form>
  89.     </body>
  90. </html>

 

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  3.  
  4.  
  5. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  6. <html>
  7.     <head>
  8.         <title>edit.jsp</title>
  9.     </head>
  10.  
  11.     <body style="text-align: center;">
  12.         <h3>
  13.             修改商品信息
  14.         </h3>
  15.         <form action="<c:url value=\'/AdminServlet\'/>" method="post">
  16.             <input type="hidden" name="method" value="5">
  17.             <input type="hidden" name="id" value="${product.id }">
  18.             <table border="1" width="50%" align="center">
  19.                 <tr>
  20.                     <td>
  21.                         商品名
  22.                     </td>
  23.                     <td>
  24.                         <input type="text" name="name" value="${product.name }" />
  25.                     </td>
  26.                 </tr>
  27.                 <tr>
  28.                     <td>
  29.                         价格
  30.                     </td>
  31.                     <td>
  32.                         <input type="text" name="price" value="${product.price }" />
  33.                     </td>
  34.                 </tr>
  35.                 <tr>
  36.                     <td>
  37.                         类型
  38.                     </td>
  39.                     <td>
  40.                         <input type="text" id="birthday" name="category"
  41.                             value="${product.category }" />
  42.                     </td>
  43.                 </tr>
  44.                 <tr>
  45.                     <td>
  46.                         数量
  47.                     </td>
  48.                     <td>
  49.                         <input type="text" name="pnum" value="${product.pnum }" />
  50.                     </td>
  51.                 </tr>
  52.  
  53.                 <tr>
  54.                     <td>
  55.                         描述
  56.                     </td>
  57.                     <td>
  58.                         <input type="text" name="description"
  59.                             value="${product.description }" />
  60.                     </td>
  61.                 </tr>
  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c"%>
  3. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  4. <html>
  5.     <head>
  6.         <title>list.jsp</title>
  7.     </head>
  8.  
  9.     <body>
  10.         <center>
  11.             <h1>
  12.                 查看所有订单
  13.             </h1>
  14.             <table border="2" width="80%">
  15.                 <tr align="left">
  16.                     <th>
  17.                         序号
  18.                     </th>
  19.                     <th>
  20.                         订单号
  21.                     </th>
  22.                     <th>
  23.                         订单金额
  24.                     </th>
  25.                     <th>
  26.                         时间
  27.                     </th>
  28.                     <th>
  29.                         状态
  30.                     </th>
  31.                     <th>
  32.                         买家详情
  33.                     </th>
  34.                     <th>
  35.                         物流信息
  36.                     </th>
  37.                     <th>
  38.                         交易状态
  39.                     </th>
  40.                     <th>
  41.                         操作
  42.                     </th>
  43.                 </tr>
  44.                 <c:forEach items="${allorderList}" var="order" varStatus="status">
  45.                     <tr>
  46.                         <td>
  47.                             ${status.count}
  48.                         </td>
  49.                         <td>
  50.                             ${order.id }
  51.                         </td>
  52.                         <td>
  53.                             ${order.totalMoney }
  54.                         </td>
  55.                         <td>
  56.                             ${order.ordertime}
  57.                         </td>
  58.                         <td>
  59.                             <c:if test="${order.paysate == 0 }">
  60.                             未支付
  61.                         </c:if>
  62.                             <c:if test="${order.paysate == 1 }">
  63.                             已支付
  64.                         </c:if>
  65.                         </td>
  66.                         <td>
  67.                             ${order.receiverName }
  68.                         </td>
  69.                         <td>
  70.                             <c:if test="${order.paysate == 0 }">
  71.                             未发货
  72.                         </c:if>
  73.                             <c:if test="${order.paysate == 1 }">
  74.                             已发货
  75.                         </c:if>
  76.                         </td>
  77.                         <td>
  78.                             交易中
  79.                         </td>
  80.                         <td>
  81.                             <a href="<c:url value=\'/OrderServlet?method=4&id=${order.id }\'/>">删除</a>
  82.                         </td>
  83.                     </tr>
  84.                     <c:set value="${total + entry.key.price*entry.value}" var="total" />
  85.                 </c:forEach>
  86.             </table>
  87.         </center>
  88.     </body>
  89. </html>

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  3. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  4. <html>
  5.     <head>
  6.         <title>updateorder.jsp</title>
  7.     </head>
  8.  
  9.     <body style="text-align: center;">
  10.         <h3>
  11.             修改订单信息
  12.         </h3>
  13.         <form action="<c:url value=\'/AdminServlet\'/>" method="post">
  14.             <input type="hidden" name="method" value="5">
  15.             <input type="hidden" name="id" value="${product.id }">
  16.             <table border="1" width="50%" align="center">
  17.                 <tr>
  18.                     <td>
  19.                         订单号
  20.                     </td>
  21.                     <td>
  22.                         ${order.id }
  23.                     </td>
  24.                 </tr>
  25.                 <tr>
  26.                     <td>
  27.                         买家姓名
  28.                     </td>
  29.                     <td>
  30.                         <input type="text" name="receiverName"
  31.                             value="${order.receiverName }" />
  32.                     </td>
  33.                 </tr>
  34.                 <tr>
  35.                     <td>
  36.                         收货地址
  37.                     </td>
  38.                     <td>
  39.                         <input type="text" id="birthday" name="receiverAddress"
  40.                             value="${order.receiverAddress }" />
  41.                     </td>
  42.                 </tr>
  43.                 <tr>
  44.                     <td>
  45.                         收获电话
  46.                     </td>
  47.                     <td>
  48.                         <input type="text" name="receiverPhone"
  49.                             value="${order.receiverPhone }" />
  50.                     </td>
  51.                 </tr>
  52.                 <tr>
  53.                     <td>
  54.                         物流信息
  55.                     </td>
  56.                     <td>
  57.                         在路上
  58.                     </td>
  59.                 </tr>
  60.                 <tr>
  61.                     <td>
  62.                         交易状态
  63.                     </td>
  64.                     <td>
  65.                         交易中
  66.                     </td>
  67.                 </tr>
  68.                 <tr>
  69.                     <td colspan="2" align="center">
  70.                         <input type="submit" value="更改" />
  71.                     </td>
  72.                 </tr>
  73.             </table>
  74.         </form>
  75.     </body>
  76. </html>

 

  1. <%@ page language="java"  import="java.util.*" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>
  4. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
  5.     "http://www.w3.org/TR/html4/loose.dtd">
  6. <html>
  7.     <head>
  8.         <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
  9.         <title>upload.jsp</title>
  10.     </head>
  11.     <body>
  12.         
  13.         <form method="post" action="/shopping/AdminServlet?method=8&id=${product.id }"
  14.             enctype="multipart/form-data">
  15.             选择一个文件:
  16.             <input type="file" name="imgurl"/>
  17.             <br />
  18.             <br />
  19.             <input type="submit" value="上传" />
  20.         </form>
  21.     </body>
  22. </html>

 

  1.  

 

  1.                 <tr>
  2.                     <td colspan="2" align="center">
  3.                         <input type="submit" value="更改" />
  4.                     </td>
  5.                 </tr>
  6.             </table>
  7.         </form>
  8.     </body>
  9. </html>
  1. package cn.edu.aynu.rjxy.servlet;
  3. import java.io.File;
  4. import java.io.IOException;
  5. import java.io.PrintWriter;
  6. import java.text.DateFormat;
  7. import java.text.SimpleDateFormat;
  8. import java.util.Date;
  9. import java.util.List;
  11. import javax.servlet.ServletException;
  12. import javax.servlet.http.HttpServlet;
  13. import javax.servlet.http.HttpServletRequest;
  14. import javax.servlet.http.HttpServletResponse;
  15. import javax.servlet.http.HttpSession;
  17. import org.apache.commons.fileupload.FileItem;
  18. import org.apache.commons.fileupload.disk.DiskFileItemFactory;
  19. import org.apache.commons.fileupload.servlet.ServletFileUpload;
  21. import cn.edu.aynu.rjxy.bean.Admin;
  22. import cn.edu.aynu.rjxy.bean.Order;
  23. import cn.edu.aynu.rjxy.bean.Page;
  24. import cn.edu.aynu.rjxy.bean.Product;
  25. import cn.edu.aynu.rjxy.service.AdminService;
  26. import cn.edu.aynu.rjxy.service.OrderService;
  27. import cn.edu.aynu.rjxy.service.ProductService;
  28. import cn.edu.aynu.rjxy.utils.CommonsUtils;
  30. public class AdminServlet extends HttpServlet {
  31.     private AdminService aService = new AdminService();
  32.     private ProductService ps = new ProductService();
  33.     private OrderService os = new OrderService();
  34.     private static final long serialVersionUID = 1L;
  35.     // 上传文件存储目录
  36.     private static final String UPLOAD_DIRECTORY = "img";
  37.     // 上传配置
  38.     private static final int MEMORY_THRESHOLD = 1024 * 1024 * 3; // 3MB
  39.     private static final int MAX_FILE_SIZE = 1024 * 1024 * 40; // 40MB
  40.     private static final int MAX_REQUEST_SIZE = 1024 * 1024 * 50; // 50MB
  41.  
  42.     public void doGet(HttpServletRequest request, HttpServletResponse response)
  43.             throws ServletException, IOException {
  45.         this.doPost(request, response);
  46.     }
  48.     public void doPost(HttpServletRequest request, HttpServletResponse response)
  49.             throws ServletException, IOException {
  50.         // 处理中文乱码
  51.         request.setCharacterEncoding("UTF-8");
  52.         response.setContentType("text/html;charset=UTF-8");
  53.         // 获取隐藏字段method的值，并把它转换为int型
  54.         int method = Integer.parseInt(request.getParameter("method"));
  56.         switch (method) {
  58.         case 1:
  59.             this.login(request, response);
  60.             break;
  61.         case 2:
  62.             this.query(request, response);
  63.             break;
  64.         case 3:
  65.             this.add(request, response);
  66.             break;
  67.         case 4:
  68.             this.loadForUpdate(request, response);
  69.             break;
  70.         case 5:
  71.             this.edit(request, response);
  72.             break;
  73.         case 6:
  74.             this.delete(request, response);
  75.             break;
  76.         case 7:
  77.             this.order(request, response);
  78.             break;
  79.         case 8:
  80.             this.uploadpicture(request, response);
  81.             break;
  82.         case 9:
  83.             this.uploadForpicture(request, response);
  84.             break;
  86.         }
  88.     }
  90.     // 管理员登录
  91.     public void login(HttpServletRequest request, HttpServletResponse response)
  92.             throws ServletException, IOException {
  93.         // 从请求中解析用户名和密码
  94.         String username = request.getParameter("username");
  95.         String password = request.getParameter("password");
  96.         // 执行加载业务
  97.         Admin a = aService.login(username, password);
  98.         if (a != null) {
  99.             HttpSession session = request.getSession();
  100.             session.setAttribute("userId", a.getId());
  101.             response.getWriter().print("登录成功" + a.getId());
  102.             // 通过请求转发将pb带到list.jsp上去
  103.             request.getRequestDispatcher("/admin/list.jsp").forward(request,
  104.                     response);
  105.         } else {
  106.             response.getWriter().print("登录失败，即将跳转到登录页面，请重新登录......");
  107.             response.setHeader("Refresh", "3;url=/shopping/admin/login.jsp");
  109.         }
  111.     }
  113.     // 管理员查看商品
  114.     public void query(HttpServletRequest request, HttpServletResponse response)
  115.             throws ServletException, IOException {
  117.         // 当前页有一个默认值为1
  118.         int pageCode = 1;
  119.         String s = request.getParameter("pageCode");
  120.         // 如果请求中存在pageCode参数
  121.         if (s != null && !s.trim().isEmpty()) {
  122.             pageCode = Integer.parseInt(s);
  123.         }
  124.         // 查询当前页的记录
  125.         Page pb = ps.queryByPage(pageCode);
  126.         // 将pb保存在request域中
  127.         request.setAttribute("pb", pb);
  128.         // 通过请求转发将pb带到list.jsp上去
  129.         request.getRequestDispatcher("/admin/list.jsp").forward(request,
  130.                 response);
  131.     }
  133.     // 管理员添加商品
  134.     public void add(HttpServletRequest request, HttpServletResponse response)
  135.             throws ServletException, IOException {
  137.         // 使用CommonUtils工具类将请求数据封装到bean中
  138.         Product p = CommonsUtils.toBean(request.getParameterMap(),
  139.                 Product.class);
  140.         // 使用UUID作为id属性的值
  141.         p.setId(CommonsUtils.uuid());
  142.         // p.setImgurl(uploadPath);
  143.         // 执行添加
  144.         ps.add(p);
  145.         // 输出添加成功提示
  146.         response.getWriter().print("添加成功");
  147.     }
  149.     // 加载商品为修改做准备
  150.     public void loadForUpdate(HttpServletRequest request,
  151.             HttpServletResponse response) throws ServletException, IOException {
  152.         // 从请求中获取客户的id
  153.         String id = request.getParameter("id");
  154.         // 执行加载业务
  155.         Product p = ps.findById(id);
  156.         // 将Customer对象c保存在request域中
  157.         request.setAttribute("product", p);
  158.         // t=通过请求转发将customer对象显示在list.jsp页面上
  159.         request.getRequestDispatcher("/admin/edit.jsp").forward(request,
  160.                 response);
  162.     }
  164.     // 管理员修改商品信息
  165.     public void edit(HttpServletRequest request, HttpServletResponse response)
  166.             throws ServletException, IOException {
  167.         // 使用CommonUtils工具类将请求数据封装到bean中
  168.         Product p = CommonsUtils.toBean(request.getParameterMap(),
  169.                 Product.class);
  170.         // 执行更改业务
  171.         ps.edit(p);
  172.         // 给客户端发送更改成功提示
  173.         response.getWriter().print("更改成功");
  175.     }
  177.     // 管理员删除商品
  178.     public void delete(HttpServletRequest request, HttpServletResponse response)
  179.             throws ServletException, IOException {
  180.         // 从请求中获取id
  181.         String id = request.getParameter("id");
  182.         // 执行删除
  183.         ps.delete(id);
  184.         // 给客户端发送删除成功提示
  185.         response.getWriter().print("删除成功");
  187.     }
  189.     // 管理员查看所有订单
  190.     public void order(HttpServletRequest request, HttpServletResponse response)
  191.             throws ServletException, IOException {
  193.         List<Order> list = os.findAllOrder();
  194.         request.setAttribute("allorderList", list);
  195.         request.getRequestDispatcher("/admin/orderproduct.jsp").forward(
  196.                 request, response);
  197.     }
  199.     // 为上传照片做准备
  200.     public void uploadForpicture(HttpServletRequest request,
  201.             HttpServletResponse response) throws ServletException, IOException {
  202.         String id = request.getParameter("id");
  203.         Product p = ps.findById(id);
  204.         System.out.println(id + "id");
  205.         ps.upload(p, id);
  206.         // 将Customer对象c保存在request域中
  207.         request.setAttribute("product", p);
  208.         // t=通过请求转发将customer对象显示在list.jsp页面上
  209.         request.getRequestDispatcher("/admin/upload.jsp").forward(request,
  210.                 response);
  211.     }
  213.     // 管理员上传照片
  214.     public void uploadpicture(HttpServletRequest request,
  215.             HttpServletResponse response) throws ServletException, IOException {
  216.         // 检测是否为多媒体上传
  217.         if (!ServletFileUpload.isMultipartContent(request)) {
  218.             // 如果不是则停止
  219.             PrintWriter writer = response.getWriter();
  220.             writer.println("Error: 表单必须包含 enctype=multipart/form-data");
  221.             writer.flush();
  222.             return;
  223.         }
  225.         // 配置上传参数
  226.         DiskFileItemFactory factory = new DiskFileItemFactory();
  227.         // 设置内存临界值 - 超过后将产生临时文件并存储于临时目录中
  228.         factory.setSizeThreshold(MEMORY_THRESHOLD);
  229.         // 设置临时存储目录
  230.         factory.setRepository(new File(System.getProperty("java.io.tmpdir")));
  232.         ServletFileUpload upload = new ServletFileUpload(factory);
  234.         // 设置最大文件上传值
  235.         upload.setFileSizeMax(MAX_FILE_SIZE);
  237.         // 设置最大请求值 (包含文件和表单数据)
  238.         upload.setSizeMax(MAX_REQUEST_SIZE);
  240.         // 构造临时路径来存储上传的文件
  241.         // 这个路径相对当前应用的目录
  242.         String uploadPath = getServletContext().getRealPath("")
  243.                 + File.separator + UPLOAD_DIRECTORY;
  244.         // 如果目录不存在则创建
  245.         File uploadDir = new File(uploadPath);
  246.         if (!uploadDir.exists()) {
  247.             uploadDir.mkdir();
  248.         }
  250.         try {
  251.             // 解析请求的内容提取文件数据
  252.             @SuppressWarnings("unchecked")
  253.             List<FileItem> formItems = upload.parseRequest(request);
  255.             if (formItems != null && formItems.size() > 0) {
  256.                 // 迭代表单数据
  257.                 for (FileItem item : formItems) {
  258.                     // 处理不在表单中的字段
  259.                     if (!item.isFormField()) {
  261.                         Date date = new Date();
  262.                         DateFormat format = new SimpleDateFormat(
  263.                                 "yyyy-MM-dd-HH-mm-ss");
  264.                         String time = format.format(date);
  265.                         String filePath = uploadPath + File.separator + time
  266.                                 + ".jpg";
  267.                         File storeFile = new File(filePath);
  268.                         // 使用CommonUtils工具类将请求数据封装到bean中
  269.                         Product p = CommonsUtils.toBean(request
  270.                                 .getParameterMap(), Product.class);
  271.                         String url = "/" + "shopping" + "/" + UPLOAD_DIRECTORY
  272.                                 + "/" + time + ".jpg";
  273.                         p.setImgurl(url);
  274.                         // 执行更改业务
  275.                         ps.upload(p, p.getId());
  277.                         // 在控制台输出文件的上传路径
  278.                          System.out.println(filePath);
  279.                         System.out.println("/" + "shopping" + "/"
  280.                                 + UPLOAD_DIRECTORY + "/" + time + ".jpg");
  281.                         // 保存文件到硬盘
  282.                         item.write(storeFile);
  283.                         request.setAttribute("message", "文件上传成功!");
  284.                     }
  285.                 }
  286.             }
  287.         } catch (Exception ex) {
  288.             request.setAttribute("message", "错误信息: " + ex.getMessage());
  289.         }
  290.         response.getWriter().print("上传成功,三秒后跳转到功能界面......");
  291.         response.setHeader("Refresh", "3;url=/shopping/admin/list.jsp");
  292.     }
  294. }

 

  1. package cn.edu.aynu.rjxy.servlet;
  3. import java.io.IOException;
  4. import java.util.ArrayList;
  5. import java.util.Date;
  6. import java.util.List;
  7. import java.util.Map;
  9. import javax.servlet.ServletException;
  10. import javax.servlet.http.HttpServlet;
  11. import javax.servlet.http.HttpServletRequest;
  12. import javax.servlet.http.HttpServletResponse;
  14. import cn.edu.aynu.rjxy.bean.Order;
  15. import cn.edu.aynu.rjxy.bean.OrderItem;
  16. import cn.edu.aynu.rjxy.bean.Product;
  17. import cn.edu.aynu.rjxy.bean.User;
  18. import cn.edu.aynu.rjxy.service.OrderService;
  19. import cn.edu.aynu.rjxy.utils.CommonsUtils;
  21. public class OrderServlet extends HttpServlet {
  22.     private OrderService orderService = new OrderService();
  24.     public void doGet(HttpServletRequest request, HttpServletResponse response)
  25.             throws ServletException, IOException {
  26.         this.doPost(request, response);
  28.     }
  30.     public void doPost(HttpServletRequest request, HttpServletResponse response)
  31.             throws ServletException, IOException {
  32.         // 处理中文乱码
  33.         request.setCharacterEncoding("UTF-8");
  34.         response.setContentType("text/html;charset=UTF-8");
  35.         // 获取隐藏字段method的值，并把它转换为int型
  36.         int method = Integer.parseInt(request.getParameter("method"));
  38.         switch (method) {
  39.         case 1:
  40.             this.addOrder(request, response);
  41.             break;
  42.         case 2:
  43.             this.findMyOrder(request, response);
  44.             break;
  45.         case 3:
  46.             this.findOrderItem(request, response);
  47.             break;
  48.         case 4:
  49.             this.delete(request, response);
  50.             break;
  52.         }
  54.     }
  56.     // 添加订单和订单项
  57.     public void addOrder(HttpServletRequest request,
  58.             HttpServletResponse response) throws ServletException, IOException {
  59.         /**
  60.          * 1、判断用户是否登录，如果未登录就重定向到login.jsp 2、使用工具类将订单表中的信息封装成order对象，补全剩余的字段
  61.          * 3、从session中获取购物车，遍历购物车，创建订单项，把它们加入list集合 4、添加订单和订单项
  62.          */
  63.         User user = (User) request.getSession().getAttribute("user");
  64.         if (user == null) {
  65.             response.sendRedirect("jsp/login.jsp");
  66.             return;
  67.         }
  68.         Order order = CommonsUtils.toBean(request.getParameterMap(),
  69.                 Order.class);
  70.         // 补全字段
  71.         order.setId(CommonsUtils.uuid());
  72.         order.setOrdertime(new Date());
  73.         order.setPaysate(0);
  74.         order.setUser_id(user.getId());
  75.         Map<Product, Integer> cart = (Map<Product, Integer>) request
  76.                 .getSession().getAttribute("cart");
  77.         List<OrderItem> list = new ArrayList<OrderItem>();
  78.         for (Product p : cart.keySet()) {
  79.             OrderItem orderItem = new OrderItem();
  80.             orderItem.setId(CommonsUtils.uuid());
  81.             orderItem.setOrder_id(order.getId());
  82.             orderItem.setProduct_id(p.getId());
  83.             orderItem.setBuynum(cart.get(p));
  84.             orderItem.setSubtotal(p.getPrice() * orderItem.getBuynum());
  85.             // 订单项加入list集合
  86.             list.add(orderItem);
  87.         }
  88.         order.setList(list);
  89.         // 添加订单和订单项
  90.         String result = orderService.addOrder(order);
  91.         request.setAttribute("orderResult", result);
  92.         response.getWriter().print("购买成功,三秒后跳转到商品界面......");
  93.         response.setHeader("Refresh", "3;url=/shopping/index.jsp");
  94.     }
  96.     // 查看我的订单
  97.     public void findMyOrder(HttpServletRequest request,
  98.             HttpServletResponse response) throws ServletException, IOException {
  99.         /**
  100.          * 1、用户已经登录，从session中获取用户信息，从用户信息中得到user_id 2、调用方法得到用户的订单的集合
  101.          * 3、通过请求转发将订单集合显示在myorder.jsp页面上
  102.          */
  103.         User user = (User) request.getSession().getAttribute("user");
  104.         String user_id = user.getId();
  105.         List<Order> list = orderService.findMyOrder(user_id);
  106.         request.setAttribute("myorderList", list);
  107.         request.getRequestDispatcher("/jsp/myorder.jsp").forward(request,
  108.                 response);
  110.     }
  112.     // 查看我的订单的详情
  113.     public void findOrderItem(HttpServletRequest request,
  114.             HttpServletResponse response) throws ServletException, IOException {
  115.         /**
  116.          * 1、从请求转发中获取订单的id 2、调用方法得到订单详情的集合 3、通过请求转发将订单详情在orderItem.jsp页面上显示
  117.          */
  118.         String order_id = request.getParameter("order_id");
  119.         System.out.println(order_id + "ssssss");
  120.         List<OrderItem> list = orderService.findOrderItem(order_id);
  121.         request.setAttribute("orderItemList", list);
  122.         request.getRequestDispatcher("/jsp/orderitem.jsp").forward(request,
  123.                 response);
  125.     }
  127.     public void delete(HttpServletRequest request, HttpServletResponse response)
  128.             throws ServletException, IOException {
  129.         // 从请求中获取id
  130.         String id = request.getParameter("id");
  131.         // 执行删除客户业务
  132.         orderService.delete(id);
  133.         // 给客户端发送删除成功提示
  134.         response.getWriter().print("删除成功,三秒后跳转到功能界面......");
  135.         response.setHeader("Refresh", "3;url=/shopping/admin/list.jsp");
  137.     }
  138. }

 

  1. package cn.edu.aynu.rjxy.servlet;
  3. import java.io.IOException;
  4. import java.util.HashMap;
  5. import java.util.Iterator;
  6. import java.util.List;
  7. import java.util.Map;
  9. import javax.servlet.ServletException;
  10. import javax.servlet.http.HttpServlet;
  11. import javax.servlet.http.HttpServletRequest;
  12. import javax.servlet.http.HttpServletResponse;
  13. import javax.servlet.http.HttpSession;
  15. import cn.edu.aynu.rjxy.bean.Product;
  16. import cn.edu.aynu.rjxy.service.ProductService;
  18. /**
  19.  * 调用ProductService的方法
  20.  * 
  21.  * @author Administrator
  22.  * 
  23.  */
  24. public class ProductServlet extends HttpServlet {
  25.     private ProductService ps = new ProductService();
  27.     public void doGet(HttpServletRequest request, HttpServletResponse response)
  28.             throws ServletException, IOException {
  29.         this.doPost(request, response);
  30.     }
  32.     public void doPost(HttpServletRequest request, HttpServletResponse response)
  33.             throws ServletException, IOException {
  34.         // 处理中文乱码
  35.         request.setCharacterEncoding("UTF-8");
  36.         response.setContentType("text/html;charset=UTF-8");
  37.         // 获取隐藏字段method的值，并把它转换为int型
  38.         int method = Integer.parseInt(request.getParameter("method"));
  40.         switch (method) {
  41.         case 1:
  42.             this.findAll(request, response);
  43.             break;
  44.         case 2:
  45.             this.addCart(request, response);
  46.             break;
  47.         }
  49.     }
  51.     // 处理查询所有商品的请求
  52.     public void findAll(HttpServletRequest request, HttpServletResponse response)
  53.             throws ServletException, IOException {
  54.         List<Product> list = ps.findAll();
  55.         request.setAttribute("listProduct", list);
  56.         // 通过请求转发将商品信息显示在product.jsp页面上
  57.         request.getRequestDispatcher("/jsp/product.jsp").forward(request,
  58.                 response);
  59.     }
  61.     // 处理添加购物车的请求
  62.     public void addCart(HttpServletRequest request, HttpServletResponse response)
  63.             throws ServletException, IOException {
  64.         // 获取商品的id
  65.         String id = request.getParameter("id");
  66.         // 得到商品
  67.         Product p = ps.findById(id);
  68.         // 购物车是保存在session中
  69.         HttpSession session = request.getSession();
  70.         // 从session中拿到购物车
  71.         Map<Product, Integer> cart = (Map<Product, Integer>) session
  72.                 .getAttribute("cart");
  73.         // 如果cart不存在，就创建购物车
  74.         if (cart == null) {
  75.             cart = new HashMap<Product, Integer>();
  76.         }
  77.         /**
  78.          * 遍历Map中的所有key也就是商品对象，如果发现有的商品的id和 即将加入购物车的id相同，就在原来的数量上＋1
  79.          */
  80.         Iterator<Product> it = cart.keySet().iterator();
  81.         boolean f = true;
  82.         while (it.hasNext()) {
  83.             Product pp = (Product) it.next();
  84.             if (pp.getId().equals(p.getId())) {
  85.                 cart.put(pp, cart.get(pp) + 1);
  86.                 f = false;
  87.             }
  88.         }
  89.         // 如果没有发现购物车原来相同的商品，就直接加入
  90.         if (f) {
  91.             cart.put(p, 1);
  92.         }
  93.         // 将cart放入session
  94.         session.setAttribute("cart", cart);
  95.         // 重定向
  96.         response.sendRedirect("jsp/cart.jsp");
  98.     }
  100. }
  1. package cn.edu.aynu.rjxy.servlet;
  3. import java.io.IOException;
  4. import java.io.PrintWriter;
  6. import javax.servlet.ServletException;
  7. import javax.servlet.http.HttpServlet;
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  11. import cn.edu.aynu.rjxy.bean.User;
  12. import cn.edu.aynu.rjxy.exception.UserException;
  13. import cn.edu.aynu.rjxy.service.UserService;
  14. import cn.edu.aynu.rjxy.utils.CommonsUtils;
  16. /**
  17.  * 调用UserService里面的方法
  18.  * 
  19.  * @author Administrator
  20.  * 
  21.  */
  22. public class UserServlet extends HttpServlet {
  24.     private UserService userService = new UserService();
  26.     public void doGet(HttpServletRequest request, HttpServletResponse response)
  27.             throws ServletException, IOException {
  28.         this.doPost(request, response);
  30.     }
  32.     public void doPost(HttpServletRequest request, HttpServletResponse response)
  33.             throws ServletException, IOException {
  34.         // 处理中文乱码
  35.         request.setCharacterEncoding("UTF-8");
  36.         response.setContentType("text/html;charset=UTF-8");
  37.         // 获取隐藏字段method的值，并把它转换为int型
  38.         int method = Integer.parseInt(request.getParameter("method"));
  40.         switch (method) {
  41.         case 1:
  42.             this.register(request, response);
  43.             break;
  44.         case 2:
  45.             this.login(request, response);
  46.             break;
  48.         }
  49.     }
  51.     public void register(HttpServletRequest request,
  52.             HttpServletResponse response) throws ServletException, IOException {
  53.         /**
  54.          * 1、将注册表单中的用户信息封装到user对象中 2、将获取的ＵＵＩＤ值作为ｕｓｅｒ对象的ｉｄ
  55.          * ３、注册，如果发生异常，就到register.jsp页面上显示：用户已存在 如果成功，显示注册成功，3秒后就跳转到index.jsp页面。
  56.          */
  57.         User user = CommonsUtils.toBean(request.getParameterMap(), User.class);
  58.         user.setId(CommonsUtils.uuid());
  59.         try {
  60.             userService.register(user);
  61.             request.setAttribute("msg", "注册成功");
  62.             request.getRequestDispatcher("/jsp/index.jsp").forward(request,
  63.                     response);
  64.         } catch (UserException e) {
  65.             request.setAttribute("msg", e.getMessage());
  66.             // 将用户在注册表单中输入的信息保存在request域中，请求转发的register.jsp，目的回显
  67.             request.setAttribute("user", user);
  68.             request.getRequestDispatcher("/jsp/register.jsp").forward(request,
  69.                     response);
  70.         }
  71.     }
  73.     public void login(HttpServletRequest request, HttpServletResponse response)
  74.             throws ServletException, IOException {
  75.         /**
  76.          * 1、将用户登录表单中的信息封装成User对象 2、登录，如果发生异常，就转发到login.jsp页面，显示：异常信息
  77.          * 如果成功，就将查询到的user对象u，存放到session域中 然后转发到shopping.jsp页面，显示：欢迎用户登录
  78.          */
  79.         User user = CommonsUtils.toBean(request.getParameterMap(), User.class);
  80.         System.out.println(user + "-------->");
  81.         try {
  82.             User u = userService.login(user);
  83.             System.out.println(u + ">>>>");
  84.             // 将u存放到session域中
  85.             request.getSession().setAttribute("user", u);
  86.             request.getRequestDispatcher("/jsp/index.jsp").forward(request,
  87.                     response);
  88.         } catch (UserException e) {
  89.             request.setAttribute("msg", e.getMessage());
  90.             request.setAttribute("user", user); // 回显
  91.             request.getRequestDispatcher("/jsp/login.jsp").forward(request,
  92.                     response);
  93.         }
  94.     }
  95. }

 

  1. package cn.edu.aynu.rjxy.service;
  3. import java.sql.SQLException;
  5. import cn.edu.aynu.rjxy.bean.Admin;
  6. import cn.edu.aynu.rjxy.dao.AdminDao;
  8. public class AdminService {
  9.     private AdminDao aDao = new AdminDao();
  11.     /**
  12.      * 根据用户名和密码查询用户
  13.      * 
  14.      * @param cid
  15.      */
  16.     public Admin login(String username, String password) {
  17.         try {
  18.             return aDao.findByCid(username, password);
  19.         } catch (SQLException e) {
  20.             throw new RuntimeException(e);
  21.         }
  22.     }
  23. }
  1. package cn.edu.aynu.rjxy.service;
  3. import java.sql.SQLException;
  4. import java.util.List;
  6. import cn.edu.aynu.rjxy.bean.Order;
  7. import cn.edu.aynu.rjxy.bean.OrderItem;
  8. import cn.edu.aynu.rjxy.dao.OrderDao;
  9. import cn.edu.aynu.rjxy.dao.OrderItemDao;
  10. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  12. /**
  13.  * 调用dao里面的方法
  14.  * 
  15.  * @author Administrator
  16.  * 
  17.  */
  18. public class OrderService {
  19.     private OrderDao orderDao = new OrderDao();
  20.     private OrderItemDao orderItemDao = new OrderItemDao();
  22.     // 添加订单和订单项
  23.     public String addOrder(Order order) {
  24.         try {
  25.             // 开启事物
  26.             JDBCUtils.startTransaction();
  27.             // 添加订单
  28.             orderDao.add(order);
  29.             // 获取订单项的集合
  30.             List<OrderItem> list = order.getList();
  31.             // 遍历订单项目，依次将它们插入orderitem表中
  32.             for (OrderItem orderItem : list) {
  33.                 // 添加订单项
  34.                 orderItemDao.addItem(orderItem);
  35.             }
  36.             // 提交事务
  37.             JDBCUtils.commit();
  38.             return "success";
  39.         } catch (Exception e) {
  40.             // 回滚事务
  41.             JDBCUtils.rollback();
  42.             e.printStackTrace();
  43.             return "fail";
  44.         }
  45.     }
  47.     // 查看所有的订单
  48.     public List<Order> findAllOrder() {
  49.         try {
  50.             return orderDao.findAllOrder();
  51.         } catch (SQLException e) {
  52.             throw new RuntimeException(e);
  53.         }
  54.     }
  56.     // 查看我的订单
  57.     public List<Order> findMyOrder(String user_id) {
  58.         try {
  59.             return orderDao.findOrderByUser_id(user_id);
  60.         } catch (SQLException e) {
  61.             throw new RuntimeException(e);
  62.         }
  63.     }
  65.     // 查看某个订单
  66.     public List<OrderItem> findOrderItem(String order_id) {
  67.         try {
  68.             return orderItemDao.findOrderItem(order_id);
  69.         } catch (SQLException e) {
  70.             throw new RuntimeException(e);
  71.         }
  72.     }
  74.     // 删除某个订单
  75.     public void delete(String id) {
  76.         try {
  77.             orderDao.deleteById(id);
  78.         } catch (SQLException e) {
  79.             throw new RuntimeException(e);
  80.         }
  81.     }
  82. }
  1. package cn.edu.aynu.rjxy.service;
  3. import java.sql.SQLException;
  4. import java.util.List;
  6. import cn.edu.aynu.rjxy.bean.Page;
  7. import cn.edu.aynu.rjxy.bean.Product;
  8. import cn.edu.aynu.rjxy.dao.ProductDao;
  10. /**
  11.  * 调用ProductDao的方法
  12.  * 
  13.  * @author Administrator
  14.  * 
  15.  */
  16. public class ProductService {
  17.     private ProductDao pDao = new ProductDao();
  19.     /**
  20.      * 添加商品
  21.      * 
  22.      * @param c
  23.      */
  24.     public void add(Product p) {
  25.         try {
  26.             pDao.insert(p);
  27.         } catch (SQLException e) {
  28.             throw new RuntimeException(e);
  29.         }
  30.     }
  31.     //上传照片
  32.     public  void upload(Product p,String id){
  33.         try {
  34.             pDao.insertURL(p, id);
  35.         } catch (SQLException e) {
  36.             throw new RuntimeException(e);
  37.         }
  38.     }
  39.     /**
  40.      * 删除客户业务
  41.      */
  42.     public void delete(String cid) {
  43.         try {
  44.             pDao.delete(cid);
  45.         } catch (SQLException e) {
  46.             throw new RuntimeException(e);
  47.         }
  48.     }
  50.     /**
  51.      * 编辑修改商品
  52.      * 
  53.      * @param c
  54.      */
  55.     public void edit(Product p) {
  56.         try {
  57.             pDao.update(p);
  58.         } catch (SQLException e) {
  59.             throw new RuntimeException(e);
  60.         }
  61.     }
  63.     // 查询所有商品
  64.     public List<Product> findAll() {
  65.         try {
  66.             return pDao.findAll();
  67.         } catch (SQLException e) {
  68.             throw new RuntimeException(e);
  69.         }
  70.     }
  72.     // 查看某一商品
  73.     public Product findById(String id) {
  74.         try {
  75.             return pDao.findProductById(id);
  76.         } catch (SQLException e) {
  77.             throw new RuntimeException(e);
  78.         }
  79.     }
  81.     /**
  82.      * 分页查询
  83.      * 
  84.      * @param pageCode
  85.      * @return
  86.      */
  87.     public Page queryByPage(int pageCode) {
  88.         try {
  89.             // 获取总记录数
  90.             int totalRecord = pDao.queryTotalRecord();
  91.             // 创建Page
  92.             Page pb = new Page(pageCode, totalRecord);
  93.             // 查询当前页的记录
  94.             List<Product> datas = pDao.queryByPage((pageCode - 1)
  95.                     * pb.getPageSize(), pb.getPageSize());
  96.             // 将datas封装到pb
  97.             pb.setDatas(datas);
  98.             return pb;
  99.         } catch (SQLException e) {
  100.             throw new RuntimeException(e);
  101.         }
  102.     }
  103. }
  1. package cn.edu.aynu.rjxy.service;
  3. import java.sql.SQLException;
  5. import cn.edu.aynu.rjxy.bean.User;
  6. import cn.edu.aynu.rjxy.dao.UserDao;
  7. import cn.edu.aynu.rjxy.exception.UserException;
  9. /**
  10.  * 调用dao层的方法
  11.  * 
  12.  * @author Administrator
  13.  * 
  14.  */
  15. public class UserService {
  16.     private UserDao userDao = new UserDao();
  18.     /**
  19.      * 用户注册 1、检测输入的用户名是否存在，如果存在抛出异常“用户已存在” 2、把输入的用户添加到数据库中的user表
  20.      * 
  21.      * @throws UserException
  22.      */
  23.     public void register(User user) throws UserException {
  24.         try {
  25.             // 检测用户是否存在
  26.             User u = userDao.findByUsername(user.getUsername());
  27.             // 如果存在抛出异常否则添加用户到user表
  28.             if (u != null) {
  29.                 throw new UserException("用户已经存在");
  30.             } else {
  31.                 userDao.add(user);
  32.             }
  33.         } catch (SQLException e) {
  34.             throw new RuntimeException(e);
  35.         }
  36.     }
  38.     /**
  39.      * 用户登录
  40.      * 
  41.      * @throws UserException
  42.      */
  43.     public User login(User user) throws UserException {
  44.         try {
  45.             // 根据用户名查询user表得到user对象u
  46.             User u = userDao.findByUsername(user.getUsername());
  47.             /**
  48.              * 如果u为null，说明用户不存在，抛出异常，显示用户不存在 否则说明用户存在，检测u对象中的密码和用户输入的面貌是否一致
  49.              * 如果一致，返回查询到的u否则抛出异常，显示密码错误
  50.              */
  51.             if (u == null) {
  52.                 throw new UserException("用户名不存在");
  53.             }
  54.             // 查询到的用户密码和用户名输入的密码不一致
  55.             if (!u.getPassword().equals(user.getPassword())) {
  56.                 throw new UserException("密码错误");
  57.             }
  58.             return u;
  59.         } catch (SQLException e) {
  60.             throw new RuntimeException(e);
  61.         }
  63.     }
  64. }
  1. package cn.edu.aynu.rjxy.dao;
  3. import java.sql.SQLException;
  5. import org.apache.commons.dbutils.QueryRunner;
  6. import org.apache.commons.dbutils.handlers.BeanHandler;
  8. import cn.edu.aynu.rjxy.bean.Admin;
  9. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  11. /**
  12.  * 对管理员表的操作
  13.  * 
  14.  * @author Administrator
  15.  * 
  16.  */
  17. public class AdminDao {
  18.     QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
  20.     /**
  21.      * 根据用户名和用户密码查询
  22.      * 
  23.      * @return
  24.      * @throws SQLException
  25.      */
  26.     public Admin findByCid(String username, String password)
  27.             throws SQLException {
  28.         String sql = "select * from admin where username=?&&password=?";
  29.         Admin admin = qr.query(sql, new BeanHandler<Admin>(Admin.class),
  30.                 username, password);
  31.         return admin;
  32.     }
  33. }
  1. package cn.edu.aynu.rjxy.dao;
  3. import java.sql.Connection;
  4. import java.sql.Date;
  5. import java.sql.SQLException;
  6. import java.util.List;
  8. import org.apache.commons.dbutils.QueryRunner;
  9. import org.apache.commons.dbutils.handlers.BeanListHandler;
  11. import cn.edu.aynu.rjxy.bean.Order;
  12. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  14. /**
  15.  * 对order1表的操作
  16.  * 
  17.  * @author Administrator
  18.  * 
  19.  */
  20. public class OrderDao {
  21.     private QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
  23.     // 添加订单到数据库表order1中
  24.     public void add(Order order) throws Exception {
  25.         Connection conn = JDBCUtils.getConnection();
  26.         String sql = "insert into order1 values(?,?,?,?,?,?,?,?)";
  27.         // 订单生成时间，由java.util.Date----->java.sql.Date
  28.         Date date = new Date(order.getOrdertime().getTime());
  29.         qr.update(conn, sql, order.getId(), order.getTotalMoney(), order
  30.                 .getReceiverAddress(), order.getReceiverName(), order
  31.                 .getReceiverPhone(), order.getPaysate(), date, order
  32.                 .getUser_id());
  34.     }
  36.     // 查看所有用户的订单
  37.     public List<Order> findAllOrder() throws SQLException {
  38.         String sql = "select * from order1";
  39.         return qr.query(sql, new BeanListHandler<Order>(Order.class));
  40.     }
  42.     // 根据user_id查看用户的订单
  43.     public List<Order> findOrderByUser_id(String user_id) throws SQLException {
  44.         String sql = "select * from order1 where user_id = ?";
  45.         return qr.query(sql, new BeanListHandler<Order>(Order.class), user_id);
  46.     }
  48.     // 根据user_id删除用户的订单
  49.     public void deleteById(String id) throws SQLException {
  50.         String sql = "delete from order1 where id=?";
  51.         qr.update(sql, id);
  52.     }
  53. }
  1. package cn.edu.aynu.rjxy.dao;
  3. import java.sql.Connection;
  4. import java.sql.SQLException;
  5. import java.util.List;
  7. import org.apache.commons.dbutils.QueryRunner;
  8. import org.apache.commons.dbutils.handlers.BeanListHandler;
  10. import cn.edu.aynu.rjxy.bean.OrderItem;
  11. import cn.edu.aynu.rjxy.bean.Product;
  12. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  14. /**
  15.  * 对orderItem表的操作
  16.  * 
  17.  * @author Administrator
  18.  * 
  19.  */
  20. public class OrderItemDao {
  21.     private QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
  23.     // 添加订单项到数据库表orderitem中
  24.     public void addItem(OrderItem orderItem) throws Exception {
  25.         Connection conn = JDBCUtils.getConnection();
  26.         String sql = "insert into orderitem values(?,?,?,?,?)";
  27.         qr.update(conn, sql, orderItem.getId(), orderItem.getOrder_id(),
  28.                 orderItem.getProduct_id(), orderItem.getBuynum(), orderItem
  29.                         .getSubtotal());
  30.     }
  32.     // 查询某一个订单的所有订单项
  33.     public List<OrderItem> findOrderItem(String order_id) throws SQLException {
  34.         // 查询某一订单所包含的订单项
  35.         String sql = "select * from orderitem where order_id = ?";
  36.         List<OrderItem> orderItemList = qr.query(sql,
  37.                 new BeanListHandler<OrderItem>(OrderItem.class), order_id);
  38.         // 查询某一订单所包含的订单项对应的商品信息
  39.         sql = "select p.id,p.name,p.price from product p,orderitem oi where p.id = oi.product_id  and  order_id = ?";
  40.         List<Product> productList = qr.query(sql, new BeanListHandler<Product>(
  41.                 Product.class), order_id);
  42.         // 将查询出来的商品作为订单项的属性进行添加
  43.         for (OrderItem oi : orderItemList) {
  44.             for (Product p : productList) {
  45.                 if (oi.getProduct_id().equals(p.getId())) {
  46.                     oi.setProduct(p);
  47.                 }
  48.             }
  49.         }
  50.         return orderItemList;
  51.     }
  52. }
  1. package cn.edu.aynu.rjxy.dao;
  3. import java.sql.SQLException;
  4. import java.util.List;
  6. import org.apache.commons.dbutils.QueryRunner;
  7. import org.apache.commons.dbutils.handlers.BeanHandler;
  8. import org.apache.commons.dbutils.handlers.BeanListHandler;
  9. import org.apache.commons.dbutils.handlers.ScalarHandler;
  11. import cn.edu.aynu.rjxy.bean.Product;
  12. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  14. /**
  15.  * 对product表进行增删改查
  16.  * 
  17.  * @author Administrator
  18.  * 
  19.  */
  20. public class ProductDao {
  21.     QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
  23.     /**
  24.      * 添加商品
  25.      * 
  26.      * @param c
  27.      * @throws SQLException
  28.      */
  29.     public void insert(Product p) throws SQLException {
  30.         String sql = "insert into product(id,name,price,category,pnum,description) values(?,?,?,?,?,?)";
  31.         qr.update(sql, p.getId(), p.getName(), p.getPrice(), p.getCategory(), p
  32.                 .getPnum(),  p.getDescription());
  33.     }
  34.     
  35.     public void insertURL(Product p,String id) throws SQLException {
  36.         String sql = "update product set imgurl = ? where id =?";
  37.         qr.update(sql, p.getImgurl(),id);
  38.     }
  40.     // 查询所有商品
  41.     public List<Product> findAll() throws SQLException {
  42.         String sql = "select * from product";
  43.         List<Product> list = qr.query(sql, new BeanListHandler<Product>(
  44.                 Product.class));
  45.         return list;
  46.     }
  48.     // 根据id查找商品
  49.     public Product findProductById(String id) throws SQLException {
  50.         String sql = "select * from product where id=?";
  51.         return qr.query(sql, new BeanHandler<Product>(Product.class), id);
  52.     }
  54.     /**
  55.      * 根据传过来的id，删除商品
  56.      * 
  57.      * @throws SQLException
  58.      * 
  59.      */
  60.     public void delete(String id) throws SQLException {
  61.         String sql = "delete from product where id=?";
  62.         qr.update(sql, id);
  63.     }
  65.     /**
  66.      * 修改商品属性
  67.      * 
  68.      * @throws SQLException
  69.      */
  70.     public void update(Product p) throws SQLException {
  71.         String sql = "update product set name=?,price=?,category=?,pnum=?,imgurl=?,description=? where id=?";
  72.         qr.update(sql, p.getName(), p.getPrice(), p.getCategory(), p.getPnum(),
  73.                 p.getImgurl(), p.getDescription(), p.getId());
  74.     }
  76.     /**
  77.      * 查询总记录数
  78.      * 
  79.      * @throws SQLException
  80.      * 
  81.      */
  82.     public int queryTotalRecord() throws SQLException {
  83.         String sql = "select count(*) from product";
  84.         Long num = qr.query(sql, new ScalarHandler<Long>());
  85.         return num.intValue();
  86.     }
  88.     /**
  89.      * 分页查询
  90.      * 
  91.      * @throws SQLException
  92.      * 
  93.      */
  94.     public List<Product> queryByPage(int recordStartIndex, int pageSize)
  95.             throws SQLException {
  96.         String sql = "select * from product limit ?,?";
  97.         List<Product> datas = qr.query(sql, new BeanListHandler<Product>(
  98.                 Product.class), recordStartIndex, pageSize);
  99.         return datas;
  100.     }
  101. }
  1. package cn.edu.aynu.rjxy.dao;
  3. import java.sql.SQLException;
  5. import org.apache.commons.dbutils.QueryRunner;
  6. import org.apache.commons.dbutils.handlers.BeanHandler;
  8. import cn.edu.aynu.rjxy.bean.User;
  9. import cn.edu.aynu.rjxy.utils.JDBCUtils;
  11. /**
  12.  * 对User表的操作
  13.  * 
  14.  * @author Administrator
  15.  * 
  16.  */
  17. public class UserDao {
  18.     QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
  20.     /**
  21.      * 添加用户到user表
  22.      * 
  23.      * @throws SQLException
  24.      */
  25.     public void add(User user) throws SQLException {
  26.         String sql = "insert into user(id,username,password) values(?,?,?)";
  27.         qr.update(sql, user.getId(), user.getUsername(), user.getPassword());
  28.     }
  30.     /**
  31.      * 通过用户名查找用户
  32.      * 
  33.      * @throws SQLException
  34.      */
  35.     public User findByUsername(String username) throws SQLException {
  36.         String sql = "select * from user where username = ?";
  37.         User user = qr.query(sql, new BeanHandler<User>(User.class), username);
  38.         return user;
  39.     }
  40. }

http://lijun0349-163-com.iteye.com/blog/2008680

http://blog.sina.com.cn/s/blog_ae96abfd0101p9bf.html

版权声明：本文为kangyaping原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/kangyaping/p/6165842.html