pcwastaction.java

很好的东东 本人随便做的 仅供学习之用

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

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
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 cangku.javabeans.CKSql;
import cangku.javabeans.DBConn;

/**
 * MyEclipse Struts Creation date: 09-10-2007
 * 
 * XDoclet definition:
 * 
 * @struts.action scope="request" validate="true"
 */
public class PcwastAction 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) {
		// TODO Auto-generated method stub
		Integer drugID = new Integer(request.getParameter("drugID"));
	    System.out.print("3333333333333");
	    Integer counts=new Integer(request.getParameter("counts"));
		Integer xincounts = new Integer(request.getParameter("hecounts"));  //现仓库清点药品的数量
		String reason = request.getParameter("reason");
		String beizhu = request.getParameter("context");
		int sunshuliang = counts.intValue() - xincounts.intValue(); // 药品损失的数量
		String target="error";
		if(sunshuliang<0){
			target="error";
			return mapping.findForward(target);
		}
		if(sunshuliang==0){
			target="success";
			request.setAttribute("sun","没有损失！！！");
			return mapping.findForward(target);
			
		}
		
       System.out.print("11111sunshuliang111111111"+sunshuliang+"sunshuliang");
		
		
		Integer warehouseid = new Integer((String) request.getSession()
				.getAttribute("wareID")); //
		Connection conn = null;
		conn = DBConn.getconn();
		PreparedStatement sta = null;

		// ckypkc="update storage set counts=? where drugID=?
		// and warehouseID=?"; 修改库存信息
		String ckypkc = CKSql.ckypkc; // 修改库存信息语句
		try {
			sta = conn.prepareStatement(ckypkc);
			sta.setInt(1, xincounts.intValue());
			sta.setInt(2, drugID.intValue());
			sta.setInt(3, warehouseid.intValue());

			if (0 != sta.executeUpdate()) { // 库存修改成功后，修改损益表的内容
				sta.close();
				System.out.print("22222222222222222");
				//ckpcbdrugid="select drugid,counts from drugwaste  where drugID=?"; //查询已损耗的药品ID
				String ckpcbdrugid = CKSql.ckpcbdrugid;
				sta = conn.prepareStatement(ckpcbdrugid);
				sta.setInt(1, drugID.intValue());
				ResultSet rs=sta.executeQuery();
				System.out.print("22222ResultSet222222");
				if(rs.next()){      //损耗表中已有损耗
					int shuliang=sunshuliang+rs.getInt("counts");
					// ckpcb="update drugwaste set
					// reason=?,comment=?,counts=? where drugID=?" ; //仓库盘存损益表进行修改
					String ckpcb = CKSql.ckpcb;
					sta = conn.prepareStatement(ckpcb);					
					sta.setString(1, reason);
					sta.setString(2, beizhu);
					sta.setInt(3, shuliang);
					sta.setInt(4, drugID.intValue());
					 if(0!=sta.executeUpdate()){
		                	target="success";
		                	request.setAttribute("sun","成功盘存！！！");
		                	System.out.print("1111122222333a");
		              }
					 sta.close();
				}
				else{
					//ckpcadd="insert into drugwaste(drugID,reason,comment,counts) values(?,?,?,?)";  //新增一条损失药品信息
					String ckpcadd = CKSql.ckpcadd;
					sta = conn.prepareStatement(ckpcadd);
					sta.setInt(1, drugID.intValue());
					sta.setString(2, reason);
					sta.setString(3, beizhu);
					sta.setInt(4, sunshuliang);
					if(0!=sta.executeUpdate()){
	                	target="success";
	                	request.setAttribute("sun","成功盘存！！！");
	                	System.out.print("1111122222333b");
	                }
					sta.close();
	                
				}
				
				
				
                
			}

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
            try {
                if ((!conn.isClosed()) && conn == null) {
                    conn.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }

        }

		return mapping.findForward(target);
	}
}