clientinsertact.java

企业进销存管理系统

/**
 * 
 */
package action;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;

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.insertactform;
import actionform.logactform;

/**
 * @author mengdiexiang
 * 
 */
public class clientinsertact extends Action {

	public ActionForward execute(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response)
			throws IOException, ServletException {

		insertactform inserf = (insertactform) form;

		String clientid = inserf.getClientid();
		String clientname = inserf.getClientname();
		String address = inserf.getAddress();
		String linkname = inserf.getLinkname();
		String phone = inserf.getPhone();
		String bank = inserf.getBank();
		String accounts = inserf.getAccounts();

		HttpSession session=request.getSession(true);
		if(clientid==null||clientid.equals("")){
			return mapping.findForward("failure");
//			session.setAttribute("message", "客户编号不能为空");
//			session.setAttribute("link", "clientins.jsp");
//			return mapping.findForward("false");
		}
		if (clientname != null&&!clientname.equals("")) {
			byte p[];
			try {
				p = clientname.getBytes("8859_1");
				clientname = new String(p, 0, p.length, "UTF-8");
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}else{
			session.setAttribute("message", "客户名称不能为空");
			session.setAttribute("link", "clientins.jsp");
			return mapping.findForward("false");
		}
		if (address != null&&!address.equals("")) {
			byte p[];
			try {
				p = address.getBytes("8859_1");
				address = new String(p, 0, p.length, "UTF-8");
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}else{
			session.setAttribute("message", "客户地址不能为空");
			session.setAttribute("link", "clientins.jsp");
			return mapping.findForward("false");
		}
		if (linkname != null&&!linkname.equals("")) {
			byte p[];
			try {
				p = linkname.getBytes("8859_1");
				linkname = new String(p, 0, p.length, "UTF-8");
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}else{
			session.setAttribute("message", "客户联系人不能为空");
			session.setAttribute("link", "clientins.jsp");
			return mapping.findForward("false");
		}
		if (bank != null &&!bank.equals("")) {
			byte p[];
			try {
				p = bank.getBytes("8859_1");
				bank = new String(p, 0, p.length, "UTF-8");
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}else{
			session.setAttribute("message", "客户所在银行不能为空");
			session.setAttribute("link", "clientins.jsp");
			return mapping.findForward("false");
		}
		if(accounts==null||accounts.equals("")){
			session.setAttribute("message", "客户卡号不能为空");
			session.setAttribute("link", "clientins.jsp");
			return mapping.findForward("false");
		}
		
		try {
			System.out.println("ddddddddddd");
			Class.forName("oracle.jdbc.driver.OracleDriver");
			Connection conn = DriverManager
					.getConnection("jdbc:oracle:thin:scott/tiger@localhost:1521:database");
			String sql = "select *from client where clientid='"+clientid+"'";
			System.out.println(sql);
			
			PreparedStatement psmt = conn.prepareStatement(sql);
			ResultSet rs=psmt.executeQuery();
			if(rs.next()){
				session.setAttribute("message", "客户编号已存在");
				session.setAttribute("link", "clientins.jsp");
				return mapping.findForward("false");
			}else{
				try {
					System.out.println("ddddddddddd");
					Class.forName("oracle.jdbc.driver.OracleDriver");
					conn = DriverManager
							.getConnection("jdbc:oracle:thin:scott/tiger@localhost:1521:database");
					sql = "insert into client values ('" + clientid + "','"
							+ clientname + "','" + address + "','" + linkname + "','"
							+ phone + "','" + bank + "','" + accounts + "')";
					System.out.println(sql);
					
					psmt = conn.prepareStatement(sql);
					int res=psmt.executeUpdate();					
					
				} catch (ClassNotFoundException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return mapping.findForward("success");
	}
}