using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Runtime.Serialization.Formatters.Binary;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using commands;

public class InConnectUser
{
public TcpClient client { get; set; }
public BinaryReader br { get; set; }
public BinaryWriter bw { get; set; }

public Guid InUseID { get; set; }
public bool IfUserLogin=false;

public Entity.FeeRules obj_enFeeRules = new Entity.FeeRules();
public Entity.InUse obj_enInUse = new Entity.InUse();
public Entity.Computer obj_enComputer = new Entity.Computer();
public Entity.User obj_enUser = new Entity.User();

public InConnectUser(TcpClient client)
{
this.client = client;
NetworkStream networkstream = client.GetStream();
br = new BinaryReader(networkstream);
bw = new BinaryWriter(networkstream);
}
public void Close()
{
br.Close();
bw.Close();
client.Close();
}
}

//在线用户列表
private List<TcpHelper.InConnectUser> onlineUserList = new List<TcpHelper.InConnectUser>();
IPAddress localAddress;
private const int port = 51888;
private TcpListener myListener;

//开启服务器的按钮
private void button_StartServer_Click(object sender, EventArgs e)
{
myListener = new TcpListener(localAddress, port);
myListener.Start();
label_status.Text = "开启";

Thread myThread = new Thread(ListenClientConnect);
myThread.Start();
//timer1.Enabled = true;
button_StartServer.Visible = false;
button_StopServer.Visible = true;
}
//关闭服务器的按钮
private void button_StopServer_Click(object sender, EventArgs e)
{
label_status.Text = "关闭";
//关闭服务器，移除list的用户。
//for (int i = onlineUserList.Count - 1; i >= 0; i--)
//{
// RemoveOnlineUser(onlineUserList[i]);
//}
myListener.Stop();
button_StartServer.Visible = true;
button_StopServer.Visible = false;
}

/// <summary>
/// 监听连接
/// </summary>
private void ListenClientConnect()
{
TcpClient newClient = null;
while (true)
{
try
{
//停在此处监听连接，如果有新客户端连接就运行下去
newClient = myListener.AcceptTcpClient();
}
catch (Exception)
{

break;
}
InConnectUser user = new InConnectUser(newClient);
Thread threadReceive = new Thread(ReceiveData);
threadReceive.Start(user);
onlineUserList.Add(user);

}

}

/// <summary>
/// 收消息
/// </summary>
/// <param name="UserState"></param>
private void ReceiveData(object UserState)
{
InConnectUser user = (InConnectUser)UserState;
TcpClient client = user.client;
MessageInfo receiveObject;

while (true)
{
try
{
byte[] bytes = new byte[999];
//停在此处，networkstream流中有新数据则读出
int i = user.br.Read(bytes, 0, 999);
MemoryStream memory = new MemoryStream(bytes);
BinaryFormatter format = new BinaryFormatter();
receiveObject = (MessageInfo)format.Deserialize(memory);
}
catch (Exception)
{
return;
}
switch (receiveObject.CommandsTypes)
{
case CommandsTypes.RequestHowLong:
//这里是我处理各种命令的方法，和这个博客的主题无关，就不贴出来了。
//处理好之后，就在这个方法里面发送回应给对应的客户端，所以一定要有参数user
// ManagerHowLong(user);
break;
case CommandsTypes.RequestUserLogin:
// ManagerUserLogin(user, receiveObject);
break;
case CommandsTypes.RequestUserlogout:
// ManagerUserLogout(user);
break;
case CommandsTypes.RequestLogout:
//注意这里是return，本意是如果客户端的连接要关闭， 就用跳出循环
//但是我的是网吧管理，不考虑这种情况，所以就未做处理
return;
case CommandsTypes.RequestModPWD:
// ManagerModPWD(user, receiveObject);
break;
case CommandsTypes.RequestMachineLogin:
// ManagerMachineLogin(user, receiveObject);
break;

case CommandsTypes.RequestTalk:
// ManagerTalk(receiveObject);
break;

default:
break;
}

}

}

/// <summary>
/// 发消息
/// </summary>
/// <param name="user">发给谁</param>
/// <param name="userSend">发送内容</param>
private void SendToClient(TcpHelper.InConnectUser user, MessageInfo userSend)
{
try
{
MemoryStream memory = new MemoryStream();
BinaryFormatter format = new BinaryFormatter();
format.Serialize(memory, userSend);
byte[] bytes = memory.ToArray();

user.bw.Write(bytes);
user.bw.Flush();

}
catch (Exception)
{
//发送失败
}
}