upborrowaction.java

eclipse+struts+sqlserver 简单图书管理系统,内有文档

/*
 * Generated by MyEclipse Struts
 * Template path: templates/java/JavaClass.vtl
 */
package kignbi.dong.action;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

import kignbi.dong.Borrow;
import kignbi.dong.Constants;
import kignbi.dong.DB;
import kignbi.dong.form.UpBorrowForm;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionMessage;
import org.apache.struts.action.ActionMessages;

/** 
 * MyEclipse Struts
 * Creation date: 01-31-2008
 * `
 * XDoclet definition:
 * @struts.action path="/upBorrow" name="upBorrowForm" input="/admin/upborrow.jsp" scope="request" validate="true"
 * @struts.action-forward name="success" path="/admin/borrowlist.jsp"
 * @struts.action-forward name="false" path="/admin/upborrow.jsp"
 */
public class UpBorrowAction extends Action {
	/*
	 * Generated Methods
	 */

	/** 
	 * Method execute
	 * @param mapping
	 * @param form
	 * @param request
	 * @param response
	 * @return ActionForward
	 */
	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception{
		UpBorrowForm upBorrowForm = (UpBorrowForm) form;// TODO Auto-generated method stub
		String  id=upBorrowForm.getId();
		String bid=upBorrowForm.getBid();
		String uid=upBorrowForm.getUid();
		String dt_borrow=upBorrowForm.getDt_borrow();
		String remark=upBorrowForm.getRemark();
		int number=0+Integer.parseInt(upBorrowForm.getNumber());
		int not_num=0+Integer.parseInt(upBorrowForm.getNot_num());
		int days=0+Integer.parseInt(upBorrowForm.getDays());
		ActionMessages errors = new ActionMessages();
		String PageForward = "false";
		ServletContext context = servlet.getServletContext();
		DataSource dataSource = (DataSource) context.getAttribute(Constants.DATASOURCE_KEY);
		DB db = new DB(dataSource);
		String str="select * from borrow where not_num!=0";//获取全部有效借书
		String str1="update borrow set state=0 where not_num=0";//更新已全部还书的记录为无效借书
		
	    String sql="update borrow set not_num="+not_num+",dt_return=CONVERT(varchar(10) , getdate(), 120 ) ,remark='"+remark+" ',days=" +days
	    		+" where id='"+id+"'";
	    
        String p1="select bnumber from books where dbo.trim(bid)='"+bid+"'";//查询图书数量
	    ResultSet r1=db.OpenSql(p1);//有此书
	    if( r1.next()){
	    		    int a=r1.getInt("bnumber");
	    		    ResultSet aa=db.OpenSql("select not_num from borrow where id='"+id+"'" );
	    		    if(aa.next()){//有次记录
	    		    int aa_a=aa.getInt("not_num");
	    		    int c=a+aa_a-not_num;
	    		    int d=aa_a-not_num;
	    		    String sql3="update books set bnumber="+c+"where bid='"+bid+"'";
	    		    String sql2="insert into dayflow (uid,bid,ftype,fnum) values ('"+uid+"','"+bid+"','还',"+d+")";//写日志
	                int status=db.ExecSql(sql2);//还书
	                System.out.print("str:"+sql2+"\n");
	                int state=db.ExecSql(sql3);//插入流水记录
	               System.out.print("str:"+sql3+"\n");
	               int sta=db.ExecSql(sql);
	              if(sta>=1){//更新：还书成功
		    	     ResultSet rs=db.OpenSql(str); 
		    	     ArrayList res=new ArrayList();
	    	         int i=0;
	    	         while(rs.next()&i<10){
			    		i=i+1;
			    		Borrow borrow = new Borrow();
			    		borrow.setId(rs.getString("id"));
						borrow.setUid(rs.getString("uid"));
						borrow.setBid(rs.getString("bid"));
					    borrow.setDt_borrow(rs.getString("dt_borrow"));
						borrow.setDt_return(rs.getString("dt_return"));
			            borrow.setNumber(rs.getInt("number"));
			            borrow.setNot_num(rs.getInt("not_num"));
			            borrow.setDays(rs.getInt("days"));
			            borrow.setRemark(rs.getString("remark"));
			            res.add(borrow);
	    	         }
	    	         errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("up.borrow.success"));
    		         if (!errors.isEmpty()) {
    			       saveErrors(request, errors);
    		         }
			    	String count=Integer.toString(i);
			        request.setAttribute("count", count);
			        request.setAttribute("borrows",res);
			        PageForward="success";
	              }
	              else {
	    			     errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("up.borrow.failture"));
	    		         if (!errors.isEmpty()) {
	    			       saveErrors(request, errors);
	    		         }
	    		  }
	         }
	     else {
			  errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("up.borrow.notherecord"));
	         if (!errors.isEmpty()) {
		       saveErrors(request, errors);
		     }
	     }
	    }
	    else {
	    	 errors.add(ActionMessages.GLOBAL_MESSAGE, new ActionMessage("up.borrow.nothebook"));
	         if (!errors.isEmpty()) {
		       saveErrors(request, errors);
	    }
	  }     
	        db.ExecSql(str1);
	        db.close();
			return mapping.findForward(PageForward);
  }

}