controller.java

一个航空管理系统的例子,可以查询航班,增加代理商等功能,大家需要的话可以看看的.

package com.tarena.abs.server;
import java.net.*;
import java.io.*;

import com.tarena.abs.dao.*;
import com.tarena.abs.model.*;

public class Controller {
	private Socket s;
	private ObjectInputStream ois;
	private ObjectOutputStream oos;
	private DAO dao;
	public Controller(Socket s){
		this.s=s;
	}
	public void handle() throws Exception {	
		ois=new ObjectInputStream(s.getInputStream());
		oos=new ObjectOutputStream(s.getOutputStream());
		while(true){
			Request req=(Request)ois.readObject();
			String type=req.getType();
			if(type.equals("login")){
				dao=new AgentDAOFromFile(new File("e:\\airline\\agent.txt"));
				loginHandle(req);
			}else if(type.equals("flightSearch")){
				//dao=new FlightDAOFromFile(new File("f:\\sd0703\\airline\\flight.dat"));
				flightSearchHandle();
			}else if(type.equals("order")){
				//dao=new FlightDAOFromFile(new File("f:\\sd0703\\airline\\flight.dat"));
				orderHandle();
			}else if(type.equals("quit")){
				quitHandle();
				break;
			}
		}
	}
	
	private void loginHandle(Request req){
		AgentDAO adao=(AgentDAO)dao;
		String userName=(String)req.getData("UserName");
		String passwd=(String)req.getData("Password");
		Object obj=adao.getAgent(userName,passwd);
		Agent user=(Agent)obj;
		try {
			Response res=new Response("login");
			res.setData(user);
			oos.writeObject(res);
			oos.flush();
			System.out.println("HAHAHA");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	private void flightSearchHandle(){
		
	}
	private void orderHandle(){
		
	}
	private void quitHandle(){
		
	}
	

}