jsp之图书管理系统

package dao.library.com; import java.math.RoundingMode; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.text.DecimalFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import tool.library.com.MessageSolveTools; import entity.library.com.ManagerMessage; import entity.library.com.UserTicket; public class MessageDao { public static boolean isCanRenew(String borrowdate) { Date date = new Date(); int days=0; SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd"); try { Date date2=dateFormat.parse(borrowdate); // System.out.println(date.getDay()); // System.out.println(date2.getDay()); days = (int) ((date.getTime() - date2.getTime())/(24*3600*1000)); } catch (ParseException e) { // TODO Auto-generated catch block e.printStackTrace(); } if(days>23&&days<=30) { System.out.println("允许续借"); return true; } return false; } public static void update_state(String username,String bookname) { String str =null; Connection conn=null ; PreparedStatement stm=null; ResultSet rs = null; String str1 = null; String str3="0"; try { SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd");//更新时间和状态 str = dateFormat.format(new Date()); conn = DbUtils.getConnection(); System.out.println(bookname); String sql="update `bookinfo` SET `bookstate`=?,`borrowdate`=? WHERE `username`= ? and `bookname`= ?"; stm = conn.prepareStatement(sql); System.out.println("........."); System.out.println(str3+"........."); System.out.println(str+"........."); stm.setString(1,str3); stm.setString(2,str); stm.setString(3,username); stm.setString(4,bookname); int nums = stm.executeUpdate(); System.out.println(nums+"hahahh111111111");//执行成功后 还需要给用户发送借阅成功的消息 还需更新借书时间 /**此处发送消息**/ String sql2="select `message_success` from `user` where `username`=?";//获取原来的未处理的信息 stm = conn.prepareStatement(sql2); stm.setString(1, username); rs=stm.executeQuery(); if(rs.next()) { str1 = rs.getString(1); } String str2 = null; if(str1==null) { str2 ="您已成功借阅"+bookname+"!"; } else { str2 = str1 +"您已成功借阅"+bookname+"!"; } String sqlt="UPDATE `user` SET `message_success`=? WHERE `username`=? "; stm = conn.prepareStatement(sqlt); stm.setString(1, str2); stm.setString(2, username); int num = stm.executeUpdate(); /** 此处将馆藏的书减少一本 **/ //考虑到原子性问题 ：用户根据馆藏借书 若馆藏大于0便可点击借阅 //并将该书放于借阅信息中 此时若不更改馆藏 可能会影响其他用户的借阅 所以将对馆藏的操作 放于用户程序中 保证了原子性 } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.release(conn, stm, null); } } public static void delete_back(String username,String bookname)//此处应设置事务操作 { //boolean success=false; Connection conn=null ; PreparedStatement stm=null; ResultSet rs = null; String str1 = null; try { conn = DbUtils.getConnection(); String sql="DELETE FROM `bookinfo` WHERE `username`=? and `bookname`=?;"; stm = conn.prepareStatement(sql); stm.setString(1,username); stm.setString(2,bookname); stm.executeUpdate();//此处成功后需要给用户发送归还成功的消息，并且该书的馆藏+1,此处还应立即处理hasbook-1操作 /**此处处理**/ String sql2="select `message_success` from `user` where `username`=?";//获取原来的未处理的信息 stm = conn.prepareStatement(sql2); stm.setString(1, username); rs=stm.executeQuery(); if(rs.next()) { str1 = rs.getString(1); } String str2=null; if(str1!=null) str2 = str1 +"您已成功归还"+bookname+"!"; else str2="您已成功归还"+bookname+"!"; String sqlt="UPDATE `user` SET `message_success`=? WHERE `username`=? "; stm = conn.prepareStatement(sqlt); stm.setString(1, str2); stm.setString(2, username); int num = stm.executeUpdate(); /**此处为对馆藏的更新 借阅成功不更新考虑到其与用户的动作保持一致性 所以放到用户处处理 但是此处删除完借阅信息后 保证原子性 就必须将馆藏+1**/ String sql4="select `ammount` from `book` where `bookname`=?";//获取原来的未处理的信息 stm = conn.prepareStatement(sql4); stm.setString(1, bookname); rs=stm.executeQuery(); if(rs.next()) { str1 = rs.getString(1); str1=String.valueOf((Integer.valueOf(str1)+1)); } String sql3="UPDATE `book` SET `ammount`=? WHERE `bookname`=? "; stm = conn.prepareStatement(sql3); stm.setString(1, str1); stm.setString(2, bookname); int nums = stm.executeUpdate(); String sql6="select `hasbook` from `user` where `username`=?";//此处更新用户的hasbook stm = conn.prepareStatement(sql6); stm.setString(1, username); rs=stm.executeQuery(); if(rs.next()) { str1 = rs.getString(1); System.out.println("hasbook:"+str1); str1=String.valueOf((Integer.valueOf(str1)-1)); System.out.println("hasbook:"+str1); } String sql7="UPDATE `user` SET `hasbook`=? WHERE `username`=? "; stm = conn.prepareStatement(sql7); stm.setString(1, str1); stm.setString(2, username); int numst = stm.executeUpdate(); System.out.println(numst); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.release(conn, stm, null); } } public static void singlesendticket(String username,String bookname) { boolean bool=true ; UserTicket userticket = getUserTicket(username,bookname); Connection conn=null ; PreparedStatement stm=null; ResultSet rs = null; try { conn = DbUtils.getConnection(); String sqlt="UPDATE `user` SET `message_success`=? WHERE `username`=?"; System.out.println(username); System.out.println(bookname); System.out.println(userticket.getCheck()); if(1==1){ stm = conn.prepareStatement(sqlt); bool = false; TicketDao.sendSingleTicket(username); String str1="您未成功借阅/归还"+bookname+"请先处理完罚单，再进行借阅/归还!"; System.out.println("开始"); // System.out.println(str); System.out.println(str1); System.out.println(userticket.getUsername()); System.out.println(username); stm.setString(1, str1); stm.setString(2, userticket.getUsername()); int resNum = stm.executeUpdate(); System.out.println(resNum); if (resNum == 1){ bool = true; } } if(bool==false) { System.out.println("更新罚单失败！"); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.release(conn, stm, null); } } private static UserTicket getUserTicket(String username, String bookname) {//通过书名 账户 返回 一个对象 // TODO Auto-generated method stub UserTicket userticket = new UserTicket(); userticket.setUsername(username); userticket.setBookname(bookname); Connection conn=null ; PreparedStatement stm=null; ResultSet rs = null; try { conn = DbUtils.getConnection(); String sql="select * from `bookinfo` where `username`=? and `bookname`=?"; stm = conn.prepareStatement(sql); stm.setString(1, username); stm.setString(2, bookname); rs = stm.executeQuery(); if(rs.next()){ userticket.setCheck(rs.getString(4)); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ DbUtils.release(conn, stm, null); } return userticket; } public static Lis