/**
 * 
 */
package action;

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

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 actionform.searchactform;

/**
 * @author 石亨
 * 
 */

public class searchact extends Action {
	static String sql;

	static Connection conn;

	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws IOException, ServletException {
		searchactform myForm = (searchactform) form;
		// ........
		String sflag = request.getParameter("flag");
		String sstockid = request.getParameter("stockid");
		String sserveid = request.getParameter("serveid");
		String swareid = request.getParameter("wareid");
		String sstockdate = request.getParameter("stockdate");
		String sstockamount = request.getParameter("stockamount");
		String smoneysum = request.getParameter("moneysum");
		String soperator = request.getParameter("operator");
		String swarename = request.getParameter("warename");
		if (swarename != null) {
			swarename = new String(swarename.getBytes("ISO8859-1"));
		}
		String sunit = request.getParameter("unit");
		String srate = request.getParameter("rate");
		String sstorage = request.getParameter("storage");
		String ser = "";
		String waremessage = "";
		String rwar = "";
		String rsto = "";
		String warename="";
		String unit="";
		String rate="";
		HttpSession session=request.getSession(true);

		if (sflag != null && sflag.equals("ins")) {

			try {
				Class.forName("oracle.jdbc.driver.OracleDriver");
				conn = DriverManager
						.getConnection("jdbc:oracle:thin:scott/tiger@localhost:1521:database");
				sql = "select * from serveman where serveman.serveid='"
						+ sserveid + "'";
				System.out.println("sql=" + sql);
				PreparedStatement psmt = conn.prepareStatement(sql);
				int record = psmt.executeUpdate();
				ResultSet res = psmt.executeQuery();
				if (res.next()) {

					ser = res.getString("serveid");

				}
				sql = "select * from waremessage where wareid='" + swareid
						+ "'";
				PreparedStatement psmt1 = conn.prepareStatement(sql);
				ResultSet res1 = psmt1.executeQuery();
				if (res1.next()) {
					waremessage = res1.getString("wareid");
					 warename=res1.getString("warename");
					 unit=res1.getString("unit");
					 rate=res1.getString("rate");
				}
				sql = "select * from repertory where wareid='" + swareid + "'";
				PreparedStatement psmt2 = conn.prepareStatement(sql);
				ResultSet res2 = psmt2.executeQuery();
				if (res2.next()) {
					rwar = res2.getString("wareid");
					rsto = res2.getString("storage");

				}
				if (ser.equals("")) {
					// ////跳轉到供應商頁
					System.out.println("跳轉到供應商");
					session.setAttribute("message", "供應商不存在，點擊”返回“跳轉到添加供應商頁面");
					session.setAttribute("link", "Addserveman.jsp");
					return mapping.findForward("failure");
				} else {
					sql = "insert into stock values ('" + sstockid + "','"
							+ sserveid + "','" + swareid + "',to_date('"
							+ sstockdate + "','yyyy-mm-dd'),'" + sstockamount
							+ "','" + smoneysum + "','" + soperator + "')";
					System.out.println("spl=" + sql);
					PreparedStatement psmt3 = conn.prepareStatement(sql);
					ResultSet res3 = psmt3.executeQuery();

				}
				if (waremessage.equals("")) {
					// //跳轉到商品信息表
					System.out.println("商品信息表");
					session.setAttribute("message", "商品不存在，點擊”返回“跳轉到添加商品頁面");
					session.setAttribute("link", "insert.jsp");
					return mapping.findForward("failure");
				}
				if (rwar.equals("")) {
                       sql="insert into repertory values('"+waremessage+"','"+warename+"','"+unit+"','"+rate+"','"+sstockamount+"')";
                       System.out.println("spl=" + sql);
   					PreparedStatement psmt5 = conn.prepareStatement(sql);
   					ResultSet res5= psmt5.executeQuery();
					
				} else {
					System.out.println("1111111111");
					double tr = Double.parseDouble(sstockamount);
					System.out.println("222222222222");
					double tr1 = Double.parseDouble(rsto);
					double tr2 = tr + tr1;
					String tr3 = String.valueOf(tr2);
					System.out.println("13333333331");
					sql = "update repertory set storage='" + tr3
							+ "' where wareid='" + swareid + "'";
					System.out.println("spl=" + sql);
					PreparedStatement psmt4 = conn.prepareStatement(sql);
					ResultSet res4 = psmt4.executeQuery();

				}
				// else {
				// JOptionPane.showMessageDialog(null,"對不起，找不到相應的供應商");
				//				
				// }
				// System.out.println("insert sucessed " + record + " record");
			} catch (ClassNotFoundException e) {
				// TODO ?????? catch ??
				e.printStackTrace();
			} catch (SQLException e) {
				// TODO ?????? catch ??
				e.printStackTrace();
			}
			return mapping.findForward("true1");
		}

		return mapping.findForward("true1");

	}

}