cyf
119 lines
3.7 KiB
C#
119 lines
3.7 KiB
C#
/******************************
|
|
* 说明：上传Socket通讯
|
|
* 创建人：龚宇超
|
|
* 创建日期：2018-01-23
|
|
* 修改人：
|
|
* 修改日期：
|
|
* 修改备注：
|
|
* 版本：1.0.0.0
|
|
******************************/
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Lskj.SocketService;
|
|
|
|
namespace Lskj.SocketClient
|
|
{
|
|
/// <summary>
|
|
/// 上传Socket通讯协议
|
|
/// </summary>
|
|
class ClientUploadSocket : ClientBaseSocket
|
|
{
|
|
public ClientUploadSocket()
|
|
: base()
|
|
{
|
|
_protocolFlag = ProtocolFlag.Upload;
|
|
}
|
|
|
|
/// <summary>
|
|
/// <para>说明：上传</para>
|
|
/// <para>创建人：龚宇超</para>
|
|
/// <para>创建日期：2018-01-24 </para>
|
|
/// <para>修改人：</para>
|
|
/// <para>修改日期：</para>
|
|
/// <para>修改备注：</para>
|
|
/// <para>版本：1.0</para>
|
|
/// </summary>
|
|
/// <param name="dirName">目录</param>
|
|
/// <param name="fileName">文件</param>
|
|
/// <param name="fileSize">文件大小</param>
|
|
/// <returns><c>true</c> if XXXX, <c>false</c> otherwise.</returns>
|
|
public bool DoUpload(string dirName, string fileName, ref long fileSize)
|
|
{
|
|
bool bConnect = ReConnectAndLogin(); //检测连接是否还在，如果断开则重连并登录
|
|
if (!bConnect)
|
|
return bConnect;
|
|
try
|
|
{
|
|
_outgoingDataAssembler.Clear();
|
|
_outgoingDataAssembler.AddRequest();
|
|
_outgoingDataAssembler.AddCommand(ProtocolKey.Upload);
|
|
_outgoingDataAssembler.AddValue(ProtocolKey.DirName, dirName);
|
|
_outgoingDataAssembler.AddValue(ProtocolKey.FileName, fileName);
|
|
_outgoingDataAssembler.AddValue(ProtocolKey.FileSize, fileSize);
|
|
SendCommand();
|
|
bool bSuccess = RecvCommand();
|
|
if (bSuccess)
|
|
{
|
|
bSuccess = CheckErrorCode();
|
|
if (bSuccess)
|
|
{
|
|
bSuccess = _incomingDataParser.GetValue(ProtocolKey.FileSize, ref fileSize);
|
|
}
|
|
return bSuccess;
|
|
}
|
|
else
|
|
return false;
|
|
}
|
|
catch (Exception E)
|
|
{
|
|
//记录日志
|
|
_errorString = E.Message;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public bool DoData(byte[] buffer, int offset, int count)
|
|
{
|
|
try
|
|
{
|
|
_outgoingDataAssembler.Clear();
|
|
_outgoingDataAssembler.AddRequest();
|
|
_outgoingDataAssembler.AddCommand(ProtocolKey.Data);
|
|
SendCommand(buffer, offset, count);
|
|
return true;
|
|
}
|
|
catch (Exception E)
|
|
{
|
|
//记录日志
|
|
_errorString = E.Message;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public bool DoEof(Int64 fileSize)
|
|
{
|
|
try
|
|
{
|
|
_outgoingDataAssembler.Clear();
|
|
_outgoingDataAssembler.AddRequest();
|
|
_outgoingDataAssembler.AddCommand(ProtocolKey.Eof);
|
|
SendCommand();
|
|
bool bSuccess = RecvCommand();
|
|
if (bSuccess)
|
|
return CheckErrorCode();
|
|
else
|
|
return false;
|
|
}
|
|
catch (Exception E)
|
|
{
|
|
//记录日志
|
|
_errorString = E.Message;
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
}
|