ordercontrolorservlet.java

手机销售网站

package com.j2meserver.ordercontrolor;

import java.io.*;
import java.sql.SQLException;
import javax.servlet.*;
import javax.servlet.http.*;
import com.wingtech.comm.DbProcess;
import com.wingtech.framework.util.ResultSetMap;
import com.wingtech.framework.util.Utilities;
//import com.wingtech.framework.util.exception.ApiException;
//import com.wingtech.framework.util.exception.BpException;

public class OrderControlorServlet extends HttpServlet {
	
	private static final long serialVersionUID = 1L;

	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws IOException, ServletException {
		response.setContentType("text/html; charset=windows-1252");

		String actionFlag = "";
		String strUserName = "";
		String strPassword = "";

		String strSql = null;
		String returnStr = "";
		DbProcess dp = null;

		try {
			dp = new DbProcess();
		} catch (SQLException ee) {
			ee.printStackTrace();
		}
		
		InputStream is = request.getInputStream();
		DataInputStream dis = new DataInputStream(is);
		
		actionFlag = dis.readUTF();

		System.out.println("actionFlag======="+actionFlag);

		if(actionFlag.equals("login") ){            //LOGIN  登陆的处理
	
			strUserName = dis.readUTF();
			strPassword = dis.readUTF();
			strSql = " SELECT * ";
			strSql += " FROM order.userinfo ";
			strSql += " WHERE username='"+strUserName+"' ";
			strSql += " AND password='"+strPassword+"' ";
			ResultSetMap rsm = dp.getResultSet(strSql);

			if (rsm.next()) {
				returnStr = "welcome";
				
			}else{
				System.out.println("login failed!");
			}
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			dos.writeUTF(returnStr);
	
			
		} else if(actionFlag.equals("Admain") ){     //管理员LOGIN  登陆的处理
	
			strUserName = dis.readUTF();
			strPassword = dis.readUTF();
			
			strSql = " SELECT * ";
			strSql += " FROM order.admain ";
			strSql += " WHERE username='"+strUserName+"' ";
			strSql += " AND password='"+strPassword+"' ";
			ResultSetMap rsm = dp.getResultSet(strSql);

			if (rsm.next()) {
				returnStr = "welcome";
				
			}else{
				System.out.println("login failed!");
			}
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			dos.writeUTF(returnStr);
	
			
		} else if(actionFlag.equals("Add")) {          //添加
			String strProName = dis.readUTF();
			String strProPrice = dis.readUTF();
			String strProNumber = dis.readUTF();
			String strProCompany = dis.readUTF();
			String strProPhone = dis.readUTF();
	
			strSql= "INSERT INTO order.product ("
		        + "name,"
				+ "price,"
				+ "number,"
				+ "company,"
		        + "tell " 
				+ ") VALUES ('"+ strProName +"','"+ strProPrice +"','"+ strProNumber +"'," +
				"'"+ strProCompany +"','"+ strProPhone +"')";
		
			dp.updRecord(strSql);
			
			String successflag = "1";				
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			dos.writeUTF(successflag);
			
		} else if(actionFlag.equals("Update")) {   //修改
			String strProName = dis.readUTF();
			
			strSql = " SELECT * ";
			strSql += " FROM order.product ";
			strSql += " WHERE name='"+strProName+"' ";
			
			ResultSetMap rsm = dp.getResultSet(strSql);

			if(rsm.next()){
				String successflag = "1";				
				DataOutputStream dos = new DataOutputStream(response.getOutputStream());
				dos.writeUTF(successflag);
				
			}else{
				String successflag = "0";				
				DataOutputStream dos = new DataOutputStream(response.getOutputStream());
				dos.writeUTF(successflag);
			}

		} else if(actionFlag.equals("UpdateList")) {   //修改  详细
			String strProName = dis.readUTF();
			String strProPrice = dis.readUTF();
			String strProNum = dis.readUTF();
			
			strSql = " UPDATE order.product  ";
			strSql += "SET price='"+ strProPrice +"',number='"+ strProNum +"' ";
			strSql += " WHERE name='"+strProName+"' ";
			
			dp.updRecord(strSql);
	
			String successflag = "1";				
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			dos.writeUTF(successflag);

		} else if(actionFlag.equals("Delete")) {   //删除
			String strProName = dis.readUTF();
			
			strSql = " DELETE ";
			strSql += " FROM order.product ";
			strSql += " WHERE name='"+strProName+"' ";
			
			dp.updRecord(strSql);

			String successflag = "1";				
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			dos.writeUTF(successflag);

		}else if(actionFlag.equals("Check")){     // 查询
	
			String strProName = dis.readUTF();
			
			strSql = " SELECT name,price,number ";
			strSql += " FROM order.product ";
			strSql += " WHERE name = '" + strProName + "' ";
			
			ResultSetMap rsmV = dp.getResultSet(strSql);
			
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			
			if (rsmV.next()) {				
				String ProName= Utilities.rtrim(Utilities.nvl(fDbDate(rsmV
					.getString("name"))));
				String ProPrice = Utilities.rtrim(Utilities.nvl(fDbDate(rsmV
						.getString("price"))));	
				String ProNum = Utilities.rtrim(Utilities.nvl(fDbDate(rsmV
						.getString("number"))));
				
				dos.writeUTF(ProName);
				dos.writeUTF(ProPrice);
				dos.writeUTF(ProNum);
			}
			
		} else if(actionFlag.equals("Order")){     // 订购
	
			String strProName = dis.readUTF();
			String Number = dis.readUTF();
			String Name = dis.readUTF();
			String Address = dis.readUTF();
			String Tell = dis.readUTF();
			
			strSql= "INSERT INTO order.orderthree ("
		        + "mobilename,"
				+ "number,"
		        + "username," 
		        + "address,"
		        + "phone "
				+ ") VALUES ('"+ strProName +"','"+ Number +"'," +
				"'"+ Name +"','"+ Address +"','"+ Tell +"')" ;
				
				dp.updRecord(strSql);
				
				String successflag = "1";				
				DataOutputStream dos = new DataOutputStream(response.getOutputStream());
				dos.writeUTF(successflag);
			
		} else if(actionFlag.equals("ProName")){   //显示 下拉菜单"产品型号" 

			String strProname = "";
			
			strSql = " SELECT DISTINCT name ";
			strSql += " FROM order.product";
	
			int i = 0;
			
			ResultSetMap rsm = dp.getResultSet(strSql);
			DataOutputStream dos = new DataOutputStream(response.getOutputStream());
			
			while(rsm.next()){	
				i ++;
				strProname = Utilities.rtrim(Utilities.nvl(fDbDate(rsm
						.getString("name"))));
			    
//			    System.out.println("strProname======="+strProname);

				dos.writeUTF(strProname);
				dos.writeInt(i);
				
			}
			
		}
		actionFlag = "";
	}

	public void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		doGet(request, response);
	}

	public void destroy() {
	}
	
	public static String fDbDate(String str) {
		if (str == null || "".equals(str)) {
			return " ";
		}
		return str;
	}
}