开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 数据库编程 > 查看源码
op_buy.java~1~
资源名称：bookshop.zip　[点击查看]
上传用户：sxlinghang
上传日期：2022-07-20
资源大小：1405k
文件大小：17k
源码类别：

数据库编程

开发平台：

Java

op_buy.java~1~：源码内容
  1. package bookshop.run;
  3. /**
  4.  * <p>Title: </p>
  5.  * <p>Description: </p>
  6.  * <p>Copyright: Copyright (c) 2004</p>
  7.  * <p>Company: </p>
  8.  * @author not attributable
  9.  * @version 1.0
  10.  */
  12. import java.sql.*;
  13. import java.util.Vector;
  14. import bookshop.util.*;
  15. import bookshop.book.*;
  16. import javax.servlet.http.*;
  17. public class op_buy extends DataBase {
  19.     private javax.servlet.http.HttpServletRequest request; //建立页面请求
  20.     private HttpSession session; //页面的session;
  21.     private boolean sqlflag = true; //对接收到的数据是否正确
  22.     private Vector purchaselist; //显示图书列表向量数组
  23.     private Vector allorder; //订购单列表
  24.     private Vector order_list; //订单清单列表
  25.     private int booknumber = 0; //购书总数量
  26.     private float all_price = 0; //购书总价钱
  27.     private boolean isEmpty = false; //库中的书数量是否够购买的数
  28.     private int leaveBook = 0; //库存数量
  29.     private String orderId = ""; //用户订单号
  30.     private boolean isLogin = true; //用户是否登录！
  31.     private int page = 1; //显示的页码
  32.     private int pageSize = 15; //每页显示的订单数
  33.     private int pageCount = 0; //页面总数
  34.     private long recordCount = 0; //查询的记录总数
  36.     public op_buy() {
  37.       super();
  38.   }
  39.     public Vector getPurchaselist() {
  40.       return purchaselist;
  41.     }
  42.     public Vector getOrder_list() {
  43.       return order_list;
  44.     }
  45.     public Vector getAllorder() {
  46.       return allorder;
  47.     }
  48.     public boolean getSqlflag() {
  49.       return sqlflag;
  50.     }
  51.     public void setIsEmpty(boolean flag) {
  52.       isEmpty = flag;
  53.     }
  54.     public boolean getIsEmpty() {
  55.       return isEmpty;
  56.     }
  57.     public void setLeaveBook(int bknum) {
  58.       leaveBook = bknum;
  59.     }
  60.     public int getLeaveBook() {
  61.       return leaveBook;
  62.     }
  63.     public void setOrderId(String newId) {
  64.       orderId = newId;
  65.     }
  66.     public String getOrderId() {
  67.       return orderId;
  68.     }
  69.     public void setIsLogin(boolean flag) {
  70.       isLogin = flag;
  71.     }
  72.     public boolean getIsLogin() {
  73.       return isLogin;
  74.     }
  75.     public int getPage() { //显示的页码
  76.       return page;
  77.     }
  78.     public void setPage(int newpage) {
  79.       page = newpage;
  80.     }
  81.     public int getPageSize() { //每页显示的图书数
  82.       return pageSize;
  83.     }
  84.     public void setPageSize(int newpsize) {
  85.       pageSize = newpsize;
  86.     }
  87.     public int getPageCount() { //页面总数
  88.       return pageCount;
  89.     }
  90.     public void setPageCount(int newpcount) {
  91.       pageCount = newpcount;
  92.     }
  93.     public long getRecordCount() {
  94.       return recordCount;
  95.     }
  96.     public void setRecordCount(long newrcount) {
  97.       recordCount = newrcount;
  98.     }
  99.     public String getGbk(String str) {
  100.       try {
  101.         return new String(str.getBytes("ISO8859-1"));
  102.       }
  103.       catch (Exception e) {
  104.         return str;
  105.       }
  106.     }
  108.     public String getSql() {
  109.       sqlStr = "select id,classname from book order by id";
  110.       return sqlStr;
  111.     }
  112.     /**
  113.      * 往购物车中添加选购的图书
  114.      * @param newrequest
  115.      * @return
  116.      */
  117.     public boolean addnew(HttpServletRequest newrequest) {
  118.       request = newrequest;
  119.       String ID = request.getParameter("bookid");
  120.       String Amount = request.getParameter("amount");
  121.       long bookid = 0;
  122.       int amount = 0;
  123.       try {
  124.         bookid = Long.parseLong(ID);
  125.         amount = Integer.parseInt(Amount);
  126.       }
  127.       catch (Exception e) {
  128.         return false;
  129.       }
  130.       if (amount < 1)
  131.         return false;
  132.       session = request.getSession(false);
  133.       if (session == null) {
  134.         return false;
  135.       }
  136.       purchaselist = (Vector) session.getAttribute("shopcar");
  137.       sqlStr = "select leav_number from book where id=" + bookid;
  138.       try {
  139.         DataBase db = new DataBase();
  140.                   db.connect();
  141.                   stmt = db.conn.createStatement ();
  143.         rs = stmt.executeQuery(sqlStr);
  144.         if (rs.next()) {
  145.           if (amount > rs.getInt(1)) {
  146.             leaveBook = rs.getInt(1);
  147.             isEmpty = true;
  148.             return false;
  149.           }
  150.         }
  151.         rs.close();
  152.       }
  153.       catch (SQLException e) {
  154.         return false;
  155.       }
  157.       allorder iList = new allorder();
  158.       iList.setBookNo(bookid);
  159.       iList.setAmount(amount);
  160.       boolean match = false; //是否购买过该图书
  161.       if (purchaselist == null) { //第一次购买
  162.         purchaselist = new Vector();
  163.         purchaselist.addElement(iList);
  164.       }
  166.       else { // 不是第一次购买
  167.         for (int i = 0; i < purchaselist.size(); i++) {
  168.           allorder itList = (allorder) purchaselist.elementAt(i);
  169.           if (iList.getBookNo() == itList.getBookNo()) {
  170.             itList.setAmount(itList.getAmount() + iList.getAmount());
  171.             purchaselist.setElementAt(itList, i);
  172.             match = true;
  173.             break;
  174.           } //if name matches结束
  175.         } // for循环结束
  176.         if (!match)
  177.           purchaselist.addElement(iList);
  178.       }
  179.       session.setAttribute("shopcar", purchaselist);
  180.       return true;
  181.     }
  182.     /**
  183.      * 修改已经放进购物车的数据
  184.      * @param newrequest
  185.      * @return
  186.      */
  187.     public boolean modiShoper(HttpServletRequest newrequest) {
  188.       request = newrequest;
  189.       String ID = request.getParameter("bookid");
  190.       String Amount = request.getParameter("amount");
  191.       long bookid = 0;
  192.       int amount = 0;
  193.       try {
  194.         bookid = Long.parseLong(ID);
  195.         amount = Integer.parseInt(Amount);
  196.       }
  197.       catch (Exception e) {
  198.         return false;
  199.       }
  200.       if (amount < 1)
  201.         return false;
  202.       session = request.getSession(false);
  203.       if (session == null) {
  204.         return false;
  205.       }
  206.       purchaselist = (Vector) session.getAttribute("shopcar");
  207.       if (purchaselist == null) {
  208.         return false;
  209.       }
  210.       sqlStr = "select leav_number from book where id=" + bookid;
  211.       try {
  212.         DataBase db = new DataBase();
  213.                   db.connect();
  214.                   stmt = db.conn.createStatement ();
  216.         rs = stmt.executeQuery(sqlStr);
  217.         if (rs.next()) {
  218.           if (amount > rs.getInt(1)) {
  219.             leaveBook = rs.getInt(1);
  220.             isEmpty = true;
  221.             return false;
  222.           }
  223.         }
  224.         rs.close();
  225.       }
  226.       catch (SQLException e) {
  227.         return false;
  228.       }
  229.       for (int i = 0; i < purchaselist.size(); i++) {
  230.         allorder itList = (allorder) purchaselist.elementAt(i);
  231.         if (bookid == itList.getBookNo()) {
  232.           itList.setAmount(amount);
  233.           purchaselist.setElementAt(itList, i);
  234.           break;
  235.         } //if name matches结束
  236.       } // for循环结束
  237.       return true;
  238.     }
  239.     /**
  240.      *删除购物车中数据
  241.      * @param newrequest
  242.      * @return
  243.      */
  244.     public boolean delShoper(HttpServletRequest newrequest) {
  245.       request = newrequest;
  246.       String ID = request.getParameter("bookid");
  247.       long bookid = 0;
  248.       try {
  249.         bookid = Long.parseLong(ID);
  250.       }
  251.       catch (Exception e) {
  252.         return false;
  253.       }
  254.       session = request.getSession(false);
  255.       if (session == null) {
  256.         return false;
  257.       }
  258.       purchaselist = (Vector) session.getAttribute("shopcar");
  259.       if (purchaselist == null) {
  260.         return false;
  261.       }
  263.       for (int i = 0; i < purchaselist.size(); i++) {
  264.         allorder itList = (allorder) purchaselist.elementAt(i);
  265.         if (bookid == itList.getBookNo()) {
  266.           purchaselist.removeElementAt(i);
  267.           break;
  268.         } //if name matches结束
  269.       } // for循环结束
  270.       return true;
  271.     }
  272.     /**
  273.      * 提交购物车
  274.      * @param newrequest
  275.      * @return
  276.      * @throws java.lang.Exception
  277.      */
  278.     public boolean payout(HttpServletRequest newrequest) throws Exception {
  279.       request = newrequest;
  280.       session = request.getSession(false);
  281.     // System.out.print("f1");
  282.       if (session == null) {
  283.         return false;
  284.       }
  285.       String Userid = (String) session.getAttribute("userid"); //取得用户ID号
  286.       long userid = 0;
  287.       if (Userid == null || Userid.equals("")) {
  288.         isLogin = false;
  289.         return false;
  290.       }
  291.       else {
  292.         try {
  293.           userid = Long.parseLong(Userid);
  294.         }
  295.         catch (NumberFormatException e) {
  296.         //  System.out.print(e.getMessage());
  297.           return false;
  298.         }
  299.       }
  300.   System.out.println("f2");
  301.       purchaselist = (Vector) session.getAttribute("shopcar");
  302.       if (purchaselist == null || purchaselist.size() < 0) {
  303.         return false;
  304.       }
  305.       String Content = request.getParameter("content");
  306.       if (Content == null) {
  307.         Content = "";
  308.       }
  309.      //   System.out.print("f3");
  310.       Content = getGbk(Content);
  311.       String IP = request.getRemoteAddr();
  312.       String TotalPrice = request.getParameter("totalprice");
  314.   //System.out.println("f4");
  315.       sqlStr = "insert into orders (orderId,UserId,SubmitTime,ConsignmentTime,TotalPrice,content,IPAddress,IsPayoff,IsSales) values (";
  316.       orderId="000"+userid;
  317.       sqlStr = sqlStr  + orderId + ",'";
  318.       sqlStr = sqlStr + userid + "',now(),now()+7,'";
  319.       sqlStr = sqlStr + TotalPrice + "','";
  320.       sqlStr = sqlStr + dataFormat.toSql(Content) + "','";
  321.       sqlStr = sqlStr + IP + "',1,1)";
  322.     //  System.out.print(sqlStr);
  323.       try {
  324.         stmt.execute(sqlStr);
  325.         sqlStr = "select max(id) from orders where UserId = " + userid;
  326.         rs = stmt.executeQuery(sqlStr);
  327.         long indentid = 0;
  328.         while (rs.next()) {
  329.           indentid = rs.getLong(1);
  330.         }
  331.         rs.close();
  332.         for (int i = 0; i < purchaselist.size(); i++) {
  333.           allorder iList = (allorder) purchaselist.elementAt(i);
  334.           sqlStr =
  335.               "insert into allorder (orderId,BookNo,Amount) values (";
  336.           sqlStr = sqlStr + orderId + ",'";
  337.           sqlStr = sqlStr + iList.getBookNo() + "','";
  338.           sqlStr = sqlStr + iList.getAmount() + "')";
  339.           stmt.execute(sqlStr);
  340.           sqlStr = "update book set leav_number=leav_number - " +
  341.               iList.getAmount() + " where id = " + iList.getBookNo();
  342.           stmt.execute(sqlStr);
  343.         }
  344.         return true;
  345.       }
  346.       catch (SQLException e) {
  347.         System.out.print(e.getMessage());
  348.         return false;
  349.       }
  351.     }
  352.     /**
  353.      * 查询指定用户id的所有订单
  354.      * @param userid
  355.      * @return
  356.      */
  357.     public boolean getOrder(long userid) {
  358.       sqlStr = "select * from orders where userid = '" + userid +
  359.           "' order by id desc";
  360.       try {
  361.         DataBase db = new DataBase();
  362.                   db.connect();
  363.                   stmt = db.conn.createStatement ();
  365.         rs = stmt.executeQuery(sqlStr);
  366.         allorder = new Vector();
  367.         while (rs.next()) {
  368.           order ind = new order();
  369.           ind.setId(rs.getLong("id"));
  370.           ind.setOrderId(rs.getString("orderId"));
  371.           ind.setUserId(rs.getLong("userid"));
  372.           ind.setSubmitTime(rs.getString("submitTime"));
  373.           ind.setConsignmentTime(rs.getString("ConsignmentTime"));
  374.           ind.setTotalPrice(rs.getFloat("TotalPrice"));
  375.           ind.setContent(rs.getString("content"));
  376.           ind.setIPAddress(rs.getString("IpAddress"));
  377.           if (rs.getInt("IsPayoff") == 1)
  378.             ind.setIsPayoff(false);
  379.           else
  380.             ind.setIsPayoff(true);
  381.           if (rs.getInt("IsSales") == 1)
  382.             ind.setIsSales(false);
  383.           else
  384.             ind.setIsSales(true);
  385.           allorder.addElement(ind);
  386.         }
  387.         rs.close();
  388.         return true;
  389.       }
  390.       catch (SQLException e) {
  391.         return false;
  392.       }
  393.     }
  394.     /**
  395.      * 查询指定订单编号的订单
  396.      * @param iid
  397.      * @return
  398.      */
  399.     public boolean getSinggleOrder(long iid) {
  400.       sqlStr = "select * from orders where id = '" + iid +
  401.           "' order by id desc";
  402.       try {
  403.         DataBase db = new DataBase();
  404.                   db.connect();
  405.                   stmt = db.conn.createStatement ();
  407.         rs = stmt.executeQuery(sqlStr);
  408.         allorder = new Vector();
  409.         while (rs.next()) {
  410.           order ind = new order();
  411.           ind.setId(rs.getLong("id"));
  412.           ind.setOrderId(rs.getString("orderId"));
  413.           ind.setUserId(rs.getLong("userid"));
  414.           ind.setSubmitTime(rs.getString("submitTime"));
  415.           ind.setConsignmentTime(rs.getString("ConsignmentTime"));
  416.           ind.setTotalPrice(rs.getFloat("TotalPrice"));
  417.           ind.setContent(rs.getString("content"));
  418.           ind.setIPAddress(rs.getString("IpAddress"));
  419.           if (rs.getInt("IsPayoff") == 1)
  420.             ind.setIsPayoff(false);
  421.           else
  422.             ind.setIsPayoff(true);
  423.           if (rs.getInt("IsSales") == 1)
  424.             ind.setIsSales(false);
  425.           else
  426.             ind.setIsSales(true);
  427.           allorder.addElement(ind);
  428.         }
  429.         rs.close();
  430.         return true;
  431.       }
  432.       catch (SQLException e) {
  433.         return false;
  434.       }
  435.     }
  436.     /**
  437.      * 查询书店的所有订单数据
  438.      * @return
  439.      */
  440.     public boolean getOrder() {
  441.       sqlStr = "select count(*) from orders"; //取出记录数
  442.       int rscount = pageSize;
  443.       try {
  444.         DataBase db = new DataBase();
  445.                   db.connect();
  446.                   stmt = db.conn.createStatement ();
  448.         ResultSet rs1 = stmt.executeQuery(sqlStr);
  449.         if (rs1.next())
  450.           recordCount = rs1.getInt(1);
  451.         rs1.close();
  452.       }
  453.       catch (SQLException e) {
  454.         return false;
  455.       }
  456.       //设定有多少pageCount
  457.       if (recordCount < 1)
  458.         pageCount = 0;
  459.       else
  460.         pageCount = (int) (recordCount - 1) / pageSize + 1;
  461.         //检查查看的页面数是否在范围内
  462.       if (page < 1)
  463.         page = 1;
  464.       else if (page > pageCount)
  465.         page = pageCount;
  467.       rscount = (int) recordCount % pageSize; // 最后一页记录数
  469.       //sql为倒序取值
  470.       sqlStr = "select  * from orders ";
  471.       if (page == 1) {
  472.         sqlStr = sqlStr + " order by Id desc";
  473.       }
  474.       else {
  475.         sqlStr = sqlStr + " order by Id desc  limit "+(recordCount - pageSize * page) +","+ (recordCount - pageSize * (page - 1));
  477.       }
  479.       try {
  480.         DataBase db = new DataBase();
  481.                   db.connect();
  482.                   stmt = db.conn.createStatement ();
  484.         rs = stmt.executeQuery(sqlStr);
  485.         allorder = new Vector();
  486.         while (rs.next()) {
  487.           order ind = new order();
  488.           ind.setId(rs.getLong("id"));
  489.           ind.setOrderId(rs.getString("orderid"));
  490.           ind.setUserId(rs.getLong("userid"));
  491.           ind.setSubmitTime(rs.getString("submitTime"));
  492.           ind.setConsignmentTime(rs.getString("ConsignmentTime"));
  493.           ind.setTotalPrice(rs.getFloat("TotalPrice"));
  494.           ind.setContent(rs.getString("content"));
  495.           ind.setIPAddress(rs.getString("IpAddress"));
  496.           if (rs.getInt("IsPayoff") == 1)
  497.             ind.setIsPayoff(false);
  498.           else
  499.             ind.setIsPayoff(true);
  500.           if (rs.getInt("IsSales") == 1)
  501.             ind.setIsSales(false);
  502.           else
  503.             ind.setIsSales(true);
  504.           allorder.addElement(ind);
  505.         }
  506.         rs.close();
  507.         return true;
  508.       }
  509.       catch (SQLException e) {
  510.         System.out.println(e);
  511.         return false;
  512.       }
  513.     }
  514.     /**
  515.      * 获得订单列表
  516.      * @param nid
  517.      * @return
  518.      */
  519.     public boolean getAllorder(long nid) {
  520.       sqlStr = "select * from allorder where orderId = '" + nid + "'";
  521.       try {
  522.         DataBase db = new DataBase();
  523.                   db.connect();
  524.                   stmt = db.conn.createStatement ();
  526.         rs = stmt.executeQuery(sqlStr);
  527.         order_list = new Vector();
  528.         while (rs.next()) {
  529.           allorder identlist = new allorder();
  530.           identlist.setId(rs.getLong("id"));
  531.           identlist.setOrderId(rs.getLong("orderId"));
  532.           identlist.setBookNo(rs.getLong("BookNo"));
  533.           identlist.setAmount(rs.getInt("Amount"));
  534.           order_list.addElement(identlist);
  535.         }
  536.         rs.close();
  537.         return true;
  538.       }
  539.       catch (SQLException e) {
  540.         return false;
  541.       }
  542.     }
  543.     /**
  544.      * 修改订单，修改付款标志
  545.      * @param res
  546.      * @return
  547.      */
  548.     public boolean update(HttpServletRequest res) {
  549.       request = res;
  550.       int payoff = 1;
  551.       int sales = 1;
  552.       long orderId = 0;
  553.       try {
  554.         payoff = Integer.parseInt(request.getParameter("payoff"));
  555.         sales = Integer.parseInt(request.getParameter("sales"));
  556.         orderId = Long.parseLong(request.getParameter("orderId"));
  557.         sqlStr = "update orders set IsPayoff = '" + payoff + "',IsSales='" +
  558.             sales + "' where id =" + orderId;
  559.         DataBase db = new DataBase();
  560.                   db.connect();
  561.                   stmt = db.conn.createStatement ();
  562.         stmt.execute(sqlStr);
  563.         return true;
  564.       }
  565.       catch (Exception e) {
  566.         return false;
  567.       }
  568.     }
  569.     /**
  570.      * 删除订单
  571.      * @param id
  572.      * @return
  573.      */
  574.     public boolean delete(long id) {
  575.       try {
  576.         DataBase db = new DataBase();
  577.                   db.connect();
  578.                   stmt = db.conn.createStatement ();
  579.         sqlStr = "delete from allorder where orderId =" + id;
  580.         stmt.execute(sqlStr);
  581.         sqlStr = "delete from orders where id= " + id;
  582.         stmt.execute(sqlStr);
  583.         return true;
  584.       }
  585.       catch (SQLException e) {
  586.         return false;
  587.       }
  588.     }
  590.   }