package cn.verp.server;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Date;

import javax.swing.JOptionPane;

import cn.verp.model.DataPack;
import cn.verp.swing.LoginFm;
import cn.verp.swing.MainFm;

public class ClientConnectionService extends Thread {
	private Socket socket;
	
	private LoginFm loginSw;

	private MainFm mainSw;
	
	private ObjectInputStream ois;
	
	private ObjectOutputStream oos;
	
	public ClientConnectionService(LoginFm loginSw){
		this.loginSw = loginSw;
	}
	
	public DataPack receive() throws Exception{
		if (checkConnectionIsAction()) {
			Object obj = ois.readObject();
			if (obj != null) {
				DataPack dp = (DataPack) obj;
				return dp;
			}
		}
		return null;
	}
	
	private void sendMessage(DataPack dp) throws IOException{
		dp.put(DataPack.KEY_CLIENTUPTIME, new Date());
		this.oos.writeObject(dp);
		this.oos.flush();
		this.oos.reset();
	}

	// ���ӷ��������ɹ��췽������
	private void connect2Server(String hostAddress, int port) throws IOException {
		this.socket = new Socket(hostAddress, port);
	}

	// �û���¼����������˴����û���
	// ����true��ʾ��¼�ɹ�
	// ����false��ʾ��¼ʧ��
	public String login(DataPack dp) {
		String loginResult = null;
		try {
			// ���ӷ�����
			this.connect2Server(dp.getStr(DataPack.KEY_CLIENTIP), dp.getInt(DataPack.KEY_CLIENTPORT));
			this.oos = new ObjectOutputStream( this.socket.getOutputStream() );
			// ��������˷����û��ĵ�¼��Ϣ�����а����û���
			sendMessage(dp);
			this.ois = new ObjectInputStream( this.socket.getInputStream() );
			// ��ȡ�������˵���Ӧ����ж��û��Ƿ��¼�ɹ�
			DataPack rdp = receive(); 

			// ��¼�ɹ�
			if ("success".equals(rdp.getMsg())) {
				// ��������������
				this.mainSw = new MainFm("�û�-"+dp.get(DataPack.KEY_USERNAME),this);
				this.loginSw.setVisible(false);
				this.loginSw.dispose();
				loginResult = "200";
			}else if("failure".equals(rdp.getMsg())){
				loginResult = "�û����ѵ�¼";
			}
		} catch (Exception ex) {
			loginResult = ex.getMessage();
			if ("Connection refused: connect".equals(ex.getMessage())) {
				loginResult = "Զ�̷������Ӳ��ϣ�";
			}
		}

		return loginResult;
	}


	public void sendMessage(String message, int type) throws IOException {
		if (checkConnectionIsAction()) {
			DataPack dp = new DataPack(message, type);
			dp.put(DataPack.KEY_USERNAME, this.loginSw.getUsername().getText());
			sendMessage(dp);
		}
	}

	@Override
	public void run() {
		try {
			while (checkConnectionIsAction()) {
				DataPack rdp = receive();
				if (rdp.getMsg().equals("serverClosing")) {
					sendMessage("serverClosing", 4);
					close();
				}else if (rdp.getType() == 2) {
					this.mainSw.getJTextArea1().append(rdp.getMsg());
				}
			}
		} catch (Exception ex) {
			//ex.printStackTrace();
			JOptionPane.showMessageDialog(
					this.mainSw, "�������˳����쳣�����˳��������µ�¼��", "��Ϣ",
					JOptionPane.INFORMATION_MESSAGE);
		}
	}

	private void close() throws IOException {
		if (checkConnectionIsAction()) {
			this.ois.close();
			this.oos.close();
			this.socket.close();
		}
	}

	public boolean checkConnectionIsAction(){
		if (socket.isClosed()) {
			JOptionPane.showMessageDialog(
					this.mainSw, "�����ѶϿ������˳��������µ�¼��", "��Ϣ",
					JOptionPane.INFORMATION_MESSAGE);
			return false;
		}
		return true;
	}
}