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

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

数据库编程

开发平台：

Java

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