// WffosSocketClientDlg.cpp : 实现文件
//
#include "stdafx.h"#include<iostream>
#include<fstream>
#include<string>
using namespace std;#include "WffosSocketClient.h"
#include "WffosSocketClientDlg.h"
#include "afxdialogex.h"#ifdef _DEBUG
#define new DEBUG_NEW
#endif// 用于应用程序“关于”菜单项的 CAboutDlg 对话框class CAboutDlg : public CDialogEx
{
public:CAboutDlg();// 对话框数据enum { IDD = IDD_ABOUTBOX };protected:virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持// 实现
protected:DECLARE_MESSAGE_MAP()
};CAboutDlg::CAboutDlg() : CDialogEx(CAboutDlg::IDD)
{
}void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{CDialogEx::DoDataExchange(pDX);
}BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
END_MESSAGE_MAP()// CWffosSocketClientDlg 对话框
CWffosSocketClientDlg::CWffosSocketClientDlg(CWnd* pParent /*=NULL*/): CDialogEx(CWffosSocketClientDlg::IDD, pParent)
{m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}void CWffosSocketClientDlg::DoDataExchange(CDataExchange* pDX)
{CDialogEx::DoDataExchange(pDX);//upLoadHis------------------------------/*:CWffosSocketClientDlg.hCButton    m_connect;CButton    m_disconnect;CButton    m_upLoad;CEdit    m_severIP;CEdit    m_talk;CListCtrl    m_talkList;*/DDX_Control(pDX, IDC_BUTTON1, m_connect);DDX_Control(pDX, IDC_BUTTON3, m_disconnect);DDX_Control(pDX, IDC_BUTTON2, m_upLoad);DDX_Control(pDX, IDC_BUTTON4, m_downLoad);DDX_Control(pDX, IDC_EDIT2, m_severIP);DDX_Control(pDX, IDC_EDIT3, m_talk);DDX_Control(pDX, IDC_EDIT1, m_talkD);DDX_Control(pDX, IDC_LIST1, m_talkList);DDX_Control(pDX, IDC_LIST2, m_talkListD);//e------------------------------
}BEGIN_MESSAGE_MAP(CWffosSocketClientDlg, CDialogEx)ON_WM_SYSCOMMAND()ON_WM_PAINT()ON_WM_QUERYDRAGICON()//s--------------------changedON_BN_CLICKED(IDC_BUTTON1, &CWffosSocketClientDlg::OnBnClickedConnect)ON_BN_CLICKED(IDC_BUTTON3, &CWffosSocketClientDlg::OnBnClickedDisconnect)ON_BN_CLICKED(IDC_BUTTON2, &CWffosSocketClientDlg::OnBnClickedUpLoad)ON_BN_CLICKED(IDC_BUTTON4, &CWffosSocketClientDlg::OnBnClickedDownLoad)//e-----------------------------
END_MESSAGE_MAP()// CWffosSocketClientDlg 消息处理程序

BOOL CWffosSocketClientDlg::OnInitDialog()
{CDialogEx::OnInitDialog();// 将“关于...”菜单项添加到系统菜单中。// IDM_ABOUTBOX 必须在系统命令范围内。ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);ASSERT(IDM_ABOUTBOX < 0xF000);CMenu* pSysMenu = GetSystemMenu(FALSE);if (pSysMenu != NULL){BOOL bNameValid;CString strAboutMenu;bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);ASSERT(bNameValid);if (!strAboutMenu.IsEmpty()){pSysMenu->AppendMenu(MF_SEPARATOR);pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);}}// 设置此对话框的图标。  当应用程序主窗口不是对话框时，框架将自动//  执行此操作SetIcon(m_hIcon, TRUE);            // 设置大图标SetIcon(m_hIcon, FALSE);        // 设置小图标// TODO:  在此添加额外的初始化代码//s------------------------------------------------------m_talk.SetLimitText(1024);m_talkD.SetLimitText(1024);m_talkD.SetWindowTextA("");//初始化下载输入框m_talkList.InsertColumn(0, "上传和下载信息");m_talkListD.InsertColumn(0, "可下载列表");m_talkList.SetColumnWidth(0, 435);m_talkListD.SetColumnWidth(0, 435);m_upLoad.EnableWindow(FALSE);m_downLoad.EnableWindow(FALSE);m_disconnect.EnableWindow(FALSE);m_severIP.SetWindowTextA("127.0.0.1");count = 0;//e-------------------------------------------------------return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}void CWffosSocketClientDlg::OnSysCommand(UINT nID, LPARAM lParam)
{if ((nID & 0xFFF0) == IDM_ABOUTBOX){CAboutDlg dlgAbout;dlgAbout.DoModal();}else{CDialogEx::OnSysCommand(nID, lParam);}
}// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。void CWffosSocketClientDlg::OnPaint()
{if (IsIconic()){CPaintDC dc(this); // 用于绘制的设备上下文
SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);// 使图标在工作区矩形中居中int cxIcon = GetSystemMetrics(SM_CXICON);int cyIcon = GetSystemMetrics(SM_CYICON);CRect rect;GetClientRect(&rect);int x = (rect.Width() - cxIcon + 1) / 2;int y = (rect.Height() - cyIcon + 1) / 2;// 绘制图标
        dc.DrawIcon(x, y, m_hIcon);}else{CDialogEx::OnPaint();}
}//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CWffosSocketClientDlg::OnQueryDragIcon()
{return static_cast<HCURSOR>(m_hIcon);
}//连接------------nameChanged
void CWffosSocketClientDlg::OnBnClickedConnect()
{// TODO:  在此添加控件通知处理程序代码/*:CWffosSocketClientDlg.hSOCKET clientSocket;sockaddr_in cliAdd;int count, cliFlag;*/m_talkD.SetWindowTextA("");//初始化下载输入框char ipAddr[35];m_severIP.GetWindowTextA(ipAddr, 30);//项目->常规->使用多字符集//以下三行确定套接字cliAdd.sin_addr.s_addr = inet_addr(ipAddr);//_WINSOCK_DEPRECATED_NO_WARNINGScliAdd.sin_family = AF_INET;cliAdd.sin_port = 5000;//创建套接字clientSocket = socket(AF_INET, SOCK_STREAM, 0);//三种套接字，SOCK_STREAM对应TCP/IPcliFlag = 1;//表示客户端准备完毕//启动线程AfxBeginThread(thread, 0);
}//断开------------nameChanged
void CWffosSocketClientDlg::OnBnClickedDisconnect()
{// TODO:  在此添加控件通知处理程序代码cliFlag = 0;closesocket(clientSocket);
}//上传-----------nameChanged
void CWffosSocketClientDlg::OnBnClickedUpLoad()
{// TODO:  在此添加控件通知处理程序代码char buff[1024];CSize size;size.cx = 0;size.cy = 30;m_talk.GetWindowTextA(buff, 1024);//获取输入的文件路径存于srcstring src = buff;ifstream in(src, ifstream::in);if (!in){m_talkList.InsertItem(count++, "上传不成功，无法打开输入文件");return;}for (unsigned int i = 0; i < src.size(); i++){if ('\\' == src[i])src[i] = '/';}string src1;src1.push_back(src[0]);for (unsigned int i = 1; i < src.size(); i++){if ('/' == src[i]){if ('/' != src[i - 1])src1.push_back(src[i]);}}unsigned int j = 0;for (unsigned int i = 0; i < src.size(); i++){if ('/' == src[i])j = i > j ? i : j;}string fName = src;fName.erase(0, j + 1);//去掉路径,保留文件名src = src1 + fName;send(clientSocket, ("#upld#" + src).c_str(), 1024, 0);//发送上传文件名//下面代码逐行上传string fLine;while (getline(in, fLine)){send(clientSocket, fLine.c_str(), 1024, 0);}send(clientSocket, "", 1024, 0);in.close();//必须有这一步
}//下载-----------nameChanged
void CWffosSocketClientDlg::OnBnClickedDownLoad()
{// TODO:  在此添加控件通知处理程序代码char buff[1024];CSize size;size.cx = 0;size.cy = 30;m_talkD.GetWindowTextA(buff, 1024);//获取输入的文件路径存于srcstring src = buff;src = "E:/myLibForYunPan/data/" + src;send(clientSocket, ("#dnld#" + src).c_str(), 1024, 0);//发送下载文件名
}//接收数据线程:
//当用户单击“连接”按钮以后
//程序进行相关设定
//最后调用了"AfxBeginThread(thread, 0);"启动了该线程
UINT thread(LPVOID v)
{char buff[1024];char array[25][30] ={ "155.245.160.151","155.245.160.152","155.245.160.153","155.245.160.154","155.245.160.155","155.245.160.156","155.245.160.157","155.245.160.158","155.245.160.159","155.245.160.160","155.245.160.161","155.245.160.162","155.245.160.163","155.245.160.164","155.245.160.165","155.245.160.166","155.245.160.167","155.245.160.168","155.245.160.169","155.245.160.170","155.245.160.171","155.245.160.172","155.245.160.173","155.245.160.174","155.245.160.175" };// 定义数组用来存放一些IP地址
    CSize size;size.cx = 0;size.cy = 30;int socSta = 1, addcount = 0;CWffosSocketClientDlg *dlg = (CWffosSocketClientDlg*)AfxGetApp()->GetMainWnd();//获得当前运行对话dlg->m_connect.EnableWindow(FALSE);dlg->m_disconnect.EnableWindow(TRUE);//连接到服务器while (connect(dlg->clientSocket, (sockaddr*)&(dlg->cliAdd), sizeof(dlg->cliAdd)) && dlg->cliFlag != 0){dlg->m_talk.SetWindowText("等待.....");//空循环for (int i = 0; i <= 65000; i++)for (int j = 0; j <= 200; j++);if (addcount == 25)addcount = 0;dlg->cliAdd.sin_addr.s_addr = inet_addr(array[addcount++]);}if (dlg->cliFlag == 1)//连接成功，则提示并允许上传下载
    {dlg->m_talkList.InsertItem(dlg->count++, "连接成功");dlg->m_upLoad.EnableWindow(TRUE);//允许上传数据dlg->m_downLoad.EnableWindow(TRUE);//允许下载数据dlg->m_talkListD.DeleteAllItems();dlg->SetForegroundWindow();}//连接建好以后，循环获得数据并显示while (socSta != SOCKET_ERROR && dlg->cliFlag != 0){socSta = recv(dlg->clientSocket, buff, 1024, 0);//调用recv函数接收数据dlg->SetForegroundWindow();if (socSta != SOCKET_ERROR && dlg->cliFlag != 0){string src = buff;string srcBegin = { buff[0], buff[1], buff[2], buff[3], buff[4], buff[5] };if ("#talk#" == srcBegin)//聊天消息
            {src.erase(0, 6);//去掉标记dlg->m_talkList.InsertItem(dlg->count++, src.c_str());dlg->m_talkList.Scroll(size);// Forces the control to scroll its client area by the specified amount.
            }if ("#okdl#" == srcBegin)//可下载文件名显示
            {src.erase(0, 6);//去掉标记dlg->m_talkListD.InsertItem(dlg->count++, src.c_str());}if ("#dnld#" == srcBegin){src.erase(0, 6);//去掉标记unsigned int j = 0;for (unsigned int i = 0; i < src.size(); i++){if ('/' == src[i])j = i > j ? i : j;}string fName = src;fName.erase(0, j + 1);//去掉路径,保留文件名string dest = "E:/myLibForYunPan/download/" + fName;//目的文件路径记为destofstream toDest(dest, ofstream::out);//先打开一次，没有就创建，有就清除内容
                toDest.close();string msg = src + "下载到E:/myLibForYunPan/download/" + fName;ofstream downLoadSrcToDestHis("E:/myLibForYunPan/downLoadSrcToDestHis.txt", ofstream::app);downLoadSrcToDestHis << msg << endl;//写入上传源和目的信息到"E:/myLibForYunPan/downLoadSrcToDestHis.txt"dlg->m_talkList.InsertItem(dlg->count++, msg.c_str());}if (("#talk#" != srcBegin) && ("#okdl#" != srcBegin) && ("#dnld#" != srcBegin)){string dest = "E:/myLibForYunPan/download/";char fName[1024];dlg->m_talkD.GetWindowTextA(fName, 1024);dest = dest + fName;ofstream toDest(dest, ofstream::app);toDest << src << endl;//下面代码复制传过来的src信息到dest
                toDest.close();}}    }//非上述情况，则发送断开命令并终止线程send(dlg->clientSocket, "Disconnected", 1024, 0);dlg->m_upLoad.EnableWindow(FALSE);dlg->m_downLoad.EnableWindow(FALSE);dlg->m_connect.EnableWindow(TRUE);dlg->m_disconnect.EnableWindow(FALSE);closesocket(dlg->clientSocket);AfxEndThread(0);//终止该线程return 0;
}

// WffosSocketSeverDlg.cpp : 实现文件
//

#include "stdafx.h"#include<iostream>
#include<fstream>
#include<string>
#include<Windows.h>
#include<stdio.h>
using namespace std;#include "WffosSocketSever.h"
#include "WffosSocketSeverDlg.h"
#include "afxdialogex.h"#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif// 用于应用程序“关于”菜单项的 CAboutDlg 对话框class CAboutDlg : public CDialogEx
{
public:CAboutDlg();// 对话框数据enum { IDD = IDD_ABOUTBOX };protected:virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持// 实现
protected:DECLARE_MESSAGE_MAP()
};CAboutDlg::CAboutDlg() : CDialogEx(CAboutDlg::IDD)
{
}void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{CDialogEx::DoDataExchange(pDX);
}BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
END_MESSAGE_MAP()// CWffosSocketSeverDlg 对话框
CWffosSocketSeverDlg::CWffosSocketSeverDlg(CWnd* pParent /*=NULL*/): CDialogEx(CWffosSocketSeverDlg::IDD, pParent)
{m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}void CWffosSocketSeverDlg::DoDataExchange(CDataExchange* pDX)
{CDialogEx::DoDataExchange(pDX);//s-------------------------------------/*:CWffosSocketSeverDlg.hCButton    m_delete;CListCtrl    m_talkList;CEdit    m_talk;*/DDX_Control(pDX, IDC_BUTTON2, m_delete);DDX_Control(pDX, IDC_EDIT1, m_talk);DDX_Control(pDX, IDC_LIST1, m_talkList);DDX_Control(pDX, IDC_LIST2, m_talkListD);
}BEGIN_MESSAGE_MAP(CWffosSocketSeverDlg, CDialogEx)ON_WM_SYSCOMMAND()ON_WM_PAINT()ON_WM_QUERYDRAGICON()ON_BN_CLICKED(IDC_BUTTON2, &CWffosSocketSeverDlg::OnBnClickedDelete)
END_MESSAGE_MAP()// CWffosSocketSeverDlg 消息处理程序

BOOL CWffosSocketSeverDlg::OnInitDialog()
{CDialogEx::OnInitDialog();// 将“关于...”菜单项添加到系统菜单中。// IDM_ABOUTBOX 必须在系统命令范围内。ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);ASSERT(IDM_ABOUTBOX < 0xF000);CMenu* pSysMenu = GetSystemMenu(FALSE);if (pSysMenu != NULL){BOOL bNameValid;CString strAboutMenu;bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);ASSERT(bNameValid);if (!strAboutMenu.IsEmpty()){pSysMenu->AppendMenu(MF_SEPARATOR);pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);}}// 设置此对话框的图标。  当应用程序主窗口不是对话框时，框架将自动//  执行此操作SetIcon(m_hIcon, TRUE);            // 设置大图标SetIcon(m_hIcon, FALSE);        // 设置小图标// TODO:  在此添加额外的初始化代码//s-----------------------------------------------count = 0;m_talkList.InsertColumn(0, "上传下载消息");m_talkList.SetColumnWidth(0, 435);m_talkListD.InsertColumn(0, "已上传列表");m_talkListD.SetColumnWidth(0, 435);m_talk.SetLimitText(1024);for (int i = 0; i<50; i++)msgsock[i] = NULL;//设定地址servAdd.sin_addr.s_addr = htonl(INADDR_ANY);servAdd.sin_family = AF_INET;servAdd.sin_port = 5000;//htons(5000);addlen = sizeof(servAdd);m_delete.EnableWindow(TRUE);//创建socketsock = socket(AF_INET, SOCK_STREAM, 0);//绑定if (bind(sock, (sockaddr*)&servAdd, addlen)){m_talk.SetWindowTextA("绑定错误");}else{//m_talkList.InsertItem(count++,inet_ntoa(servAdd.sin_addr));m_talk.SetWindowTextA("");//开始侦听    listen(sock, 5);//调用线程AfxBeginThread(&thread, 0);}talkListDRefsh();//e--------------------------------------------------return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}void CWffosSocketSeverDlg::OnSysCommand(UINT nID, LPARAM lParam)
{if ((nID & 0xFFF0) == IDM_ABOUTBOX){CAboutDlg dlgAbout;dlgAbout.DoModal();}else{CDialogEx::OnSysCommand(nID, lParam);}
}// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。void CWffosSocketSeverDlg::OnPaint()
{if (IsIconic()){CPaintDC dc(this); // 用于绘制的设备上下文
SendMessageA(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);// 使图标在工作区矩形中居中int cxIcon = GetSystemMetrics(SM_CXICON);int cyIcon = GetSystemMetrics(SM_CYICON);CRect rect;GetClientRect(&rect);int x = (rect.Width() - cxIcon + 1) / 2;int y = (rect.Height() - cyIcon + 1) / 2;// 绘制图标
        dc.DrawIcon(x, y, m_hIcon);}else{CDialogEx::OnPaint();}
}//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CWffosSocketSeverDlg::OnQueryDragIcon()
{return static_cast<HCURSOR>(m_hIcon);
}//删除
void CWffosSocketSeverDlg::OnBnClickedDelete()
{// TODO:  在此添加控件通知处理程序代码char buff[1024];CSize size;size.cx = 0;size.cy = 30;m_talk.GetWindowTextA(buff, 1024);//获取输入的文件路径存于buffstring src = buff;src = "E:/myLibForYunPan/data/" + src;ifstream in(src);if (!in){m_talkList.InsertItem(count++, "删除不成功，无法打开该文件");return;}in.close();//必须有这一步，不关闭无法删除if (DeleteFileA(src.c_str())){string BKFName = "BKupLoadDestHis.txt";BKFName = "E:/myLibForYunPan/" + BKFName;//备份文件路径BKFNamestring upLoadDestHisList;ifstream upLoadDestHis("E:/myLibForYunPan/upLoadDestHis.txt", ifstream::in);while (getline(upLoadDestHis, upLoadDestHisList)){string WriteBKFLine;ofstream WriteBKF(BKFName, ifstream::app);//新建备份文件if (upLoadDestHisList != src){WriteBKF << upLoadDestHisList << endl;//写备份文件
            }WriteBKF.close();}upLoadDestHis.close();string ReadBKFLine;ifstream ReadBKF(BKFName, ifstream::in);string WriteupLoadDestHisLine;ofstream WriteupLoadDestHis("E:/myLibForYunPan/upLoadDestHis.txt", ofstream::out);m_talkList.InsertItem(count++, src.c_str());while (getline(ReadBKF, ReadBKFLine)){WriteupLoadDestHis << ReadBKFLine << endl;//备份拷贝到原文件
        }WriteupLoadDestHis.close();ReadBKF.close();DeleteFileA(BKFName.c_str());//删除备份文件const string END = "已删除";string msg = src + END;m_talkList.InsertItem(count++, msg.c_str());//循环向所有客户发送信息for (int i = 0; i<50; i++){if (msgsock[i] != NULL)send(msgsock[i], ("#talk#" + msg).c_str(), 1024, 0);}talkListDRefsh();//有删除，刷新可删除列表
    }elsem_talkList.InsertItem(count++, "删除不成功");
}string dest;
bool upLoadFlag = TRUE;
bool downLoadFlag = TRUE;const string TALK = "#talk#";//对话消息用"#talk#"标记
const string UPLD = "#upld#";//上传文件路径用"#upld#"标记
const string DNLD = "#dnld#";//下载文件路径用"#dnld#"标记

UINT thread(LPVOID p)
{char buff[1024];CSize size;size.cx = 0;size.cy = 30;int s = 1, msgcount, loop = 1, flag = 0;CWffosSocketSeverDlg *dlg = (CWffosSocketSeverDlg*)AfxGetApp()->GetMainWnd();//获得客户端数量msgcount = dlg->getcount();if (msgcount == -1)loop = 0;if (loop){s = 1;dlg->msgsock[msgcount] = accept(dlg->sock, (sockaddr*)&(dlg->servAdd), &(dlg->addlen));if (dlg->msgsock[msgcount] == INVALID_SOCKET){dlg->m_talk.SetWindowTextA("Error accept");}else{//启动线程AfxBeginThread(thread, 0);dlg->SetForegroundWindow();dlg->m_talkList.InsertItem(dlg->count++, "连接成功");dlg->m_talkList.InsertItem(dlg->count++, inet_ntoa(dlg->servAdd.sin_addr));//_WINSOCK_DEPRECATED_NO_WARNINGSdlg->m_talkList.Scroll(size);dlg->m_delete.EnableWindow(TRUE);//下面代码显示客户端可下载列表string upLoadDestHisLine;ifstream upLoadDestHis("E:/myLibForYunPan/upLoadDestHis.txt", ifstream::in);while (getline(upLoadDestHis, upLoadDestHisLine)){send(dlg->msgsock[msgcount], ("#okdl#" + upLoadDestHisLine).c_str(), 1024, 0);}upLoadDestHis.close();while (s != SOCKET_ERROR){//循环接收数据s = recv(dlg->msgsock[msgcount], buff, 1024, 0);dlg->SetForegroundWindow();string src = buff;string srcBegin = { buff[0], buff[1], buff[2], buff[3], buff[4], buff[5] };if ("#talk#" == srcBegin)//对话消息用"#talk#"标记
                {src.erase(0, 6);//去掉标记dlg->m_talkList.InsertItem(dlg->count++, src.c_str());dlg->m_talkList.Scroll(size);// Forces the control to scroll its client area by the specified amount.
                }if ("#upld#" == srcBegin)//上传文件路径用"#upld#"标记
                {src.erase(0, 6);//去掉标记upLoadFlag = TRUE;//恢复默认//------------------------------------------------------------//下面代码检查是否上传过,服务器端是否删除对应文件，决定是否能上传unsigned int j = 0;for (unsigned int i = 0; i < src.size(); i++){if ('/' == src[i])j = i > j ? i : j;}string fName = src;fName.erase(0, j + 1);//去掉路径,保留文件名fName = "E:/myLibForYunPan/data/" + fName;//目的文件路径记为fNameifstream RupLoadDest(fName, ifstream::in);if (RupLoadDest){upLoadFlag = FALSE;//上传过，不能再上传
                    }RupLoadDest.close();if (FALSE == upLoadFlag){send(dlg->msgsock[msgcount], (TALK + "该文件上传过，不能再次上传").c_str(), 1024, 0);}//-----------------------------------------------------------if (TRUE == upLoadFlag)//未上传过
                    {ofstream WupLoadSrcHis("E:/myLibForYunPan/upLoadSrcHis.txt", ofstream::app);WupLoadSrcHis << src << endl;//写入上传的文件名到"E:/myLibForYunPan/upLoadSrcHis.txt"
                        WupLoadSrcHis.close();unsigned int j = 0;for (unsigned int i = 0; i < src.size(); i++){if ('/' == src[i])j = i > j ? i : j;}string fName = src;fName.erase(0, j + 1);//去掉路径,保留文件名dest = "E:/myLibForYunPan/data/" + fName;//目的文件路径记为dest
ofstream WupLoadDestHis("E:/myLibForYunPan/upLoadDestHis.txt", ofstream::app);WupLoadDestHis << dest << endl;//写入上传的文件名到"E:/myLibForYunPan/upLoadDestHis.txt"
                        WupLoadDestHis.close();const string TO = "上传至";string SrcToDestHis = src + TO + dest;//记录条ofstream WupLoadSrcToDestHis("E:/myLibForYunPan/upLoadSrcToDestHis.txt", ofstream::app);WupLoadSrcToDestHis << SrcToDestHis << endl;//写入上传源和目的信息到"E:/myLibForYunPan/upLoadSrcToDestHis.txt"
                        WupLoadSrcToDestHis.close();dlg->m_talkList.InsertItem(dlg->count++, SrcToDestHis.c_str());dlg->m_talkList.Scroll(size);// Forces the control to scroll its client area by the specified amount.
send(dlg->msgsock[msgcount], (TALK + SrcToDestHis).c_str(), 1024, 0);//向客户发送信息
                    }dlg->talkListDRefsh();//有新上传，刷新可删除列表
                }if ("#dnld#" == srcBegin)//下载文件路径用"#dnld#"标记
                {src.erase(0, 6);//去掉标记//下面代码检查是否可下载ifstream RdownLoadSrc(src, ifstream::in);if (!RdownLoadSrc){downLoadFlag = FALSE;//该文件不存在，不能下载send(dlg->msgsock[msgcount], (TALK + "该文件不存在，不能下载").c_str(), 1024, 0);//向客户端发送消息
                    }else{downLoadFlag = TRUE;//该文件存在，能下载send(dlg->msgsock[msgcount], ("#dnld#"+src).c_str(), 1024, 0);//向客户端发送消息string downLoadSrcLine;while (getline(RdownLoadSrc, downLoadSrcLine)){send(dlg->msgsock[msgcount], downLoadSrcLine.c_str(), 1024, 0);}}RdownLoadSrc.close();}if (("#talk#" != srcBegin) && ("#upld#" != srcBegin) && ("#dnld#" != srcBegin) && (TRUE == upLoadFlag)){ofstream toDest(dest, ofstream::app);toDest << src << endl;//下面代码复制传过来的src信息到dest
                    toDest.close();}elsecontinue;}send(dlg->msgsock[msgcount], "#talk#Disconnected", 1024, 0);dlg->m_talkList.InsertItem(dlg->count++, "Disconnected");dlg->m_talkList.Scroll(size);dlg->msgsock[msgcount] = NULL;for (int i = 0; i < 50; i++)if (dlg->msgsock[i] != NULL)flag = 1;if (flag != 1)dlg->m_delete.EnableWindow(FALSE);closesocket(dlg->msgsock[msgcount]);}//终止线程AfxEndThread(0);return 0;}
}//获得还没有使用的socket数组号
int CWffosSocketSeverDlg::getcount()
{for (int i = 0; i<50; i++){if (msgsock[i] == NULL)return i;}return -1;}void CWffosSocketSeverDlg::talkListDRefsh()
{m_talkListD.DeleteAllItems();string upLoadHistory;string upLoadedFile = "E:/myLibForYunPan/upLoadDestHis.txt";ifstream ifUpLoadedFile(upLoadedFile, ifstream::in);while (getline(ifUpLoadedFile, upLoadHistory)){CSize size;size.cx = 0;size.cy = 30;m_talkListD.InsertItem(count++, upLoadHistory.c_str());m_talkListD.Scroll(size);// Forces the control to scroll its client area by the specified amount.
    }
}void CWffosSocketSeverDlg::cliTalkListDRefsh()
{//下面代码显示客户端可下载列表string upLoadDestHisLine;ifstream upLoadDestHis("E:/myLibForYunPan/upLoadDestHis.txt", ifstream::in);while (getline(upLoadDestHis, upLoadDestHisLine)){ifstream RupLoadDest(upLoadDestHisLine, ifstream::in);if (RupLoadDest){for (int i = 0; i<50; i++){if (msgsock[i] != NULL)send(msgsock[i], ("#okdl#" + upLoadDestHisLine).c_str(), 1024, 0);}}RupLoadDest.close();}upLoadDestHis.close();
}