package com.toa.abs.server;
import java.net.*;
import java.io.*;
import java.util.*;

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

public class Controller {
	private Socket s;
	private ObjectInputStream ois;
	private ObjectOutputStream oos;
	private SaleDAO saleDao;
	private FlightDAO flightDao;
	
	public Controller(Socket s){
		this.s=s;
		saleDao=ServerMainClass.saleDao;
	}
	public void handle() throws Exception {	
		ois=new ObjectInputStream(s.getInputStream());
		oos=new ObjectOutputStream(s.getOutputStream());
		while(true){
			Request req=(Request)ois.readObject();
			int type=req.getType();
			switch(type){
			case Request.LOGIN_REQ:loginHandle(req);break;
			case Request.GET_AIRPORT_LIST_REQ: getAirportHandle(req);break;
			//?????
			}
			
		}
	}
	
	private void loginHandle(Request req){
		String userName=(String)req.getData("UserName");
		String passwd=(String)req.getData("Password");
		Sales sale=saleDao.getSale(userName,passwd);
		
		try {
			Response res=new Response();
			res.addParameter("Sale",sale);
			oos.writeObject(res);
			oos.flush();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	private void getAirportHandle(Request req){
		
	}
	
	private void flightSearchHandle(Request req){
//		String fromAddr=(String)req.getData("fromAddr");
//		String toAddr=(String)req.getData("toAddr");
//		String date=(String)req.getData("date");
//		MyDate theDate=MyDate.getDateFromStr(date,"-");
//		HashSet hs=new HashSet();
//		try {
//			hs=(HashSet)(ServerMainClass.flightDao.getAllFlights(fromAddr,toAddr,theDate));
//			int i=hs.size();
//			oos.writeInt(i);
//			oos.flush();
//			for(Object obj:hs){
//				ois.read();
//				Flight f=(Flight)obj;
//				oos.writeObject(f);
//				oos.flush();
//			}
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//		//航班查詢模塊
	}
	private void orderHandle(){
//		try {
//			oos.write(1);
//			oos.flush();
//			Order od=(Order)ois.readObject();
//			Boolean success=flightDao.order(od);
//			if(success){
//				agentDao.removeAgent(od.getUser().getName());
//				agentDao.addAgent(od.getUser());
//			}
//			oos.writeObject(success);
//			oos.flush();
//		} catch (Exception e) {
//			e.printStackTrace();
//		}
//		//出票模塊
	}
	private void quitHandle(){
		//try {
		//	s.close();
		//} catch (IOException e) {
		//	e.printStackTrace();
		//}
	}
}