实例介绍
【实例简介】
【实例截图】
【核心代码】
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Text.RegularExpressions;
using System.IO;
using System.Threading;
using System.Runtime.InteropServices;
using System.Diagnostics;
using Microsoft.Win32;
using System.Net.Sockets;
using H31SQLLibrary;
using System.Data.Common;
namespace H31DHTMgr
{
///1=movie 2=MUSIC 3=book 4=exe 5=PICTURE 6=other
/// <summary>
/// 枚举下载数据类型
/// </summary>
public enum HASHTYPE
{
MOVIE = 1,
MUSIC = 2,
BOOK = 3,
EXE = 4,
PICTURE = 5,
OTHER = 6
}
//HASH数据结构体
public struct HASHITEM
{
public Int32 hashID; //ID
public string hashKey; //hash
public DateTime recvTime; //时间
public DateTime updateTime; //时间
public string recvIp; //IP
public Int32 recvPort; //端口
public string keyContent; //文件内容
public string keyWords; //分析关键词
public long recvTimes; //总共接收了多少次
public long fileCnt;
public long filetotalSize;
public int keyType; //类型 1=movie 2=MUSIC 3=book 4=exe 5=PICTURE 6=other
};
//HASH数据结构体
public struct HASHFILEITEM
{
public Int32 ID; //ID
public Int32 hashID; //ID
public DateTime recvTime; //时间
public String filename; //文件内容
public long filesize;
};
public partial class MainForm : Form
{
private bool recvthreadison = false; //读取事件线程
private bool isFirstTimeCheck = true; //是否是第一次加载了
private DateTime m_lastrecvtime; //上次处理读取的时间
private string m_localPath; //本地文件夹路径
private H31Down m_downLoad = new H31Down();
private string m_readFilename=""; //读取到哪个文件了
private long m_readPos = 0; //读取文件到些位置了，方便下一次直接读取
private long m_fileTotal_Len = 0; //文件总长度
private Dictionary<string, int> m_downOKList = new Dictionary<string, int>();//用来保存已经存储到数据库里面的HASH列表 表TYPE
private Dictionary<string, int> m_downBadList = new Dictionary<string, int>();//用来保存下载不成功的HASH列表
private Dictionary<string, long> m_fileOKList = new Dictionary<string, long>();//用来保存已经遍历过的文件列表
private long m_doWorkCnt = 0; //用来统计读取了多少行文件的问题
private int MAX_FILEDETAIL_COUNT = 100; //每次需要读取的最大行数
private StreamReader m_reader = null; //读取文件指针
private int m_nowTableID = 1; //目前种子文件表存储到哪个表了，每个表100万数据
private int m_nowTableCount = 0; //目前种子文件表里面有多少条数据,超过100万就要换表
private int MAX_PAGE_SHOW_COUN = 50; //查询每页显示的数据条数
public MainForm()
{
InitializeComponent();
}
#region 程序加载
private void MainForm_Load(object sender, EventArgs e)
{
//读取本地文件路径,初步化日志类
m_localPath = AppDomain.CurrentDomain.BaseDirectory;
string tmpFolder = Path.Combine(m_localPath, "Temp");
if (!Directory.Exists(tmpFolder))
{
Directory.CreateDirectory(tmpFolder);
}
H31Debug.LogFile = Path.Combine(Path.Combine(m_localPath, "Temp"), H31Debug.c_LogFile);
//连接数据库
bool dbok = H31SQL.ConnectToDBServer();
comboBox_Type.SelectedIndex = 0;
comboBox_OrderBy.SelectedIndex = 0;
comboBox_Lanague.SelectedIndex = 1;
//初始化显示查询表
m_data.DataSource = null;
m_data.Columns.Clear();
m_data.RowHeadersVisible = false;
m_data.BackgroundColor = Color.White;
m_data.Columns.Add("ID", "ID");
m_data.Columns.Add("HashID", "HashID");
m_data.Columns.Add("HashKey", "Hash");
m_data.Columns.Add("recvTime", "时间");
m_data.Columns.Add("keyContent", "keyContent");
m_data.Columns.Add("keyType", "keyType");
m_data.Columns.Add("recvTimes", "recvTimes");
m_data.Columns.Add("fileCnt", "fileCnt");
m_data.Columns.Add("filetotalSize", "filetotalSize");
m_data.Columns.Add("TableID", "DetailID");
m_data.Columns[0].Width = 15;
m_data.Columns[1].Width = 20;
m_data.Columns[2].Visible = false;
m_data.Columns[3].Width = 60;
m_data.Columns[4].Width = 300;
m_data.Columns[5].Width = 10;
m_data.Columns[6].Width = 30;
m_data.Columns[7].Width = 30;
m_data.Columns[8].Width = 40;
m_data.Columns[9].Width = 10;
}
#endregion
#region 搜索加载显示数据
/// <summary>
/// 搜索数据库显示出来 2013-07-16
/// </summary>
private void ButtonSearch_Click(object sender, EventArgs e)
{
try
{
//TorrentFile my = new TorrentFile("1.torrent");
m_data.Rows.Clear();
int selecttype = comboBox_Type.SelectedIndex 1;
int ordertype = comboBox_OrderBy.SelectedIndex 1;
string keyword = textBox_Search.Text;
if (keyword == "关键字")
keyword = "";
int searchindex = Convert.ToInt32(textBox_SearchIndex.Text);
int ishanzi = comboBox_Lanague.SelectedIndex;
DataSet ds = H31SQL.GetHashPageListFromDB(selecttype,ishanzi, keyword, ordertype,searchindex, MAX_PAGE_SHOW_COUN);
Application.DoEvents(); //让系统在百忙之中来响应其他事件
if (ds != null)
{
int cnt = ds.Tables[0].Rows.Count;
for (int i = cnt - 1; i >= 0; i--)
{
m_data.Rows.Add((cnt - i).ToString(), ds.Tables[0].Rows[i]["ID"].ToString(), ds.Tables[0].Rows[i]["hashKey"].ToString(), ds.Tables[0].Rows[i]["recvTime"].ToString(), ds.Tables[0].Rows[i]["keyContent"].ToString(),
ds.Tables[0].Rows[i]["keyType"].ToString(), ds.Tables[0].Rows[i]["recvTimes"].ToString(), ds.Tables[0].Rows[i]["fileCnt"].ToString(), FormatFileSize(Convert.ToDouble(ds.Tables[0].Rows[i]["filetotalSize"].ToString())), ds.Tables[0].Rows[i]["Detail"].ToString());
}
if (MAX_PAGE_SHOW_COUN > cnt)
Button_NEXTPAGE.Enabled = false;
else
Button_NEXTPAGE.Enabled = true;
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.StackTrace);
}
}
//向前一页查询
private void Button_PrePAGE_Click(object sender, EventArgs e)
{
try
{
int searchindex = Convert.ToInt32(textBox_SearchIndex.Text);
searchindex = searchindex - 1;
if (searchindex < 0)
searchindex = 0;
textBox_SearchIndex.Text = searchindex.ToString();
ButtonSearch_Click(null, null);
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.StackTrace);
}
}
//向后一页查询
private void Button_NEXTPAGE_Click(object sender, EventArgs e)
{
try
{
int searchindex = Convert.ToInt32(textBox_SearchIndex.Text);
searchindex = searchindex 1;
textBox_SearchIndex.Text = searchindex.ToString();
ButtonSearch_Click(null, null);
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.StackTrace);
}
}
/// <summary>
/// 选中一行,然后Tips显示文件列表内容
/// </summary>
private void m_data_MouseClick(object sender, MouseEventArgs e)
{
try
{
DataGridView.HitTestInfo hi;
hi = m_data.HitTest(e.X, e.Y);
if (hi.RowIndex >= 0)
{
this.toolTip1.Hide(this);
m_data.ClearSelection();
m_data.Rows[hi.RowIndex].Selected = true;
Point mousePos = PointToClient(MousePosition);//获取鼠标当前的位置
int hashid = Convert.ToInt32(m_data.Rows[hi.RowIndex].Cells["HashID"].Value.ToString());
int tableid = Convert.ToInt32(m_data.Rows[hi.RowIndex].Cells["TableID"].Value.ToString());
int ordertype = comboBox_OrderBy.SelectedIndex 1;
int ishanzi = comboBox_Lanague.SelectedIndex;
DataSet ds = H31SQL.GetHashFileDetail(tableid, hashid, ordertype*1000 10 ishanzi);
Application.DoEvents(); //让系统在百忙之中来响应其他事件
string tip = "";
if (ds != null)
{
int cnt = ds.Tables[0].Rows.Count;
for (int i = 0; i <cnt; i )
{
tip = tip ds.Tables[0].Rows[i]["filename"].ToString() "\t" FormatFileSize(Convert.ToDouble(ds.Tables[0].Rows[i]["filesize"].ToString())) "\r\n";
}
}
this.toolTip1.Show(tip, this, mousePos);//在指定位置显示提示工具
}
else
{
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.StackTrace);
}
}
/// <summary>
/// 复制磁链接到剪贴板中
/// </summary>
private void Button_Copy_Click(object sender, EventArgs e)
{
this.toolTip1.Hide(this);
if (m_data.SelectedRows.Count == 0)
{
MessageBox.Show("请先选择一行.");
return;
}
int rowindex=m_data.SelectedRows[0].Index;
string hashkey = "magnet:?xt=urn:btih:" m_data.Rows[rowindex].Cells["HashKey"].Value.ToString();
Clipboard.SetDataObject(hashkey);
}
/// <summary>
/// 下载BT种子文件
/// </summary>
private void Button_DownBT_Click(object sender, EventArgs e)
{
this.toolTip1.Hide(this);
if (m_data.SelectedRows.Count == 0)
{
MessageBox.Show("请先选择一行.");
return;
}
int rowindex = m_data.SelectedRows[0].Index;
string hashname = m_data.Rows[rowindex].Cells["HashKey"].Value.ToString();
int res = m_downLoad.DownLoadFileByHashToFile(hashname);
if (res == 1)
{
string temppath = m_localPath "\\Torrent\\" hashname.Substring(hashname.Length - 2, 2) "\\" hashname ".torrent";
//存在则打开
System.Diagnostics.Process.Start("explorer.exe", temppath);
}
else
{
MessageBox.Show("下载失败.");
}
}
//格式化显示文件大小G M K B
public String FormatFileSize(Double fileSize)
{
if (fileSize < 0)
{
throw new ArgumentOutOfRangeException("fileSize");
}
else if (fileSize >= 1024 * 1024 * 1024)
{
return string.Format("{0:########0.00} GB", ((Double)fileSize) / (1024 * 1024 * 1024));
}
else if (fileSize >= 1024 * 1024)
{
return string.Format("{0:####0.00} MB", ((Double)fileSize) / (1024 * 1024));
}
else if (fileSize >= 1024)
{
return string.Format("{0:####0.00} KB", ((Double)fileSize) / 1024);
}
else
{
return string.Format("{0} bytes", fileSize);
}
}
#endregion
#region 监控线程读取文件到数据库中
//读取配置文件
private int ReadSetting()
{
try
{
string file = Path.Combine(m_localPath,"Setting.txt");
if (File.Exists(file))
{
StreamReader reader = new StreamReader(file, Encoding.Default);
while (true)
{
string str1 = reader.ReadLine();
if (str1 == null) break;
string str2 = reader.ReadLine();
if (str2 == null) break;
long readPos = Convert.ToInt32(str2);
m_fileOKList[str1] = readPos;
}
}
string file1 = Path.Combine(m_localPath,"BadList.txt");
if (File.Exists(file1))
{
StreamReader reader = new StreamReader(file1, Encoding.Default);
Int32 ticktime = System.Environment.TickCount / 1000;
string str1 = reader.ReadLine();
while (str1 != null)
{
m_downBadList[str1] = ticktime;
str1 = reader.ReadLine();
}
reader.Close();
}
string file2 = Path.Combine(m_localPath,"OKList.txt");
if (File.Exists(file2))
{
StreamReader reader = new StreamReader(file2, Encoding.Default);
Int32 ticktime = System.Environment.TickCount / 1000;
string str1 = reader.ReadLine();
while (str1 != null)
{
m_downOKList[str1] = ticktime;
str1 = reader.ReadLine();
}
reader.Close();
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn("ReadSetting:" ex.StackTrace);
}
return 1;
}
//存储目前已经处理的配置文件
private int SaveSetting()
{
try
{
//存储读取的文件列表
if (m_readFilename.Length > 1 && m_readPos > 0)
m_fileOKList[m_readFilename] = m_readPos;
string file = Path.Combine(m_localPath,"Setting.txt");
StreamWriter writer = new StreamWriter(file);
foreach (string key in m_fileOKList.Keys)
{
writer.WriteLine(key);
writer.WriteLine(m_fileOKList[key].ToString());
}
writer.Close();
//存储不成功的HASH列表
string file1 = Path.Combine(m_localPath,"BadList.txt");
StreamWriter writer1 = new StreamWriter(file1);
foreach (string key in m_downBadList.Keys)
{
writer1.WriteLine(key);
}
writer1.Close();
//存储成功的HASH列表
string file2 = Path.Combine(m_localPath,"OKList.txt");
StreamWriter writer2 = new StreamWriter(file2);
foreach (string key in m_downOKList.Keys)
{
writer2.WriteLine(key);
}
writer2.Close();
}
catch (System.Exception ex)
{
H31Debug.PrintLn("SaveSetting:" ex.StackTrace);
}
return 1;
}
//取得种子文件列表存储的地方
private int GetDetailFileTableID()
{
if (m_nowTableCount > 1000000 || m_nowTableCount==0)
{
m_nowTableID=0;
for (int k = 0; k < 10; k )
{
int cnt1 = H31SQL.GetHashFileTableNumberCount(k 1);
if (cnt1 < 1000000)
{
m_nowTableID = k 1;
m_nowTableCount = cnt1;
break;
}
}
if (m_nowTableID == 0)
{
MessageBox.Show("10个种子文件表已经用完了，请手动创建!");
}
}
return 1;
}
/// <summary>
/// 开始停止读取 2013-06-16
/// </summary>
private void ButtonStart_Click(object sender, EventArgs e)
{
try
{
if (ButtonStart.Text == "开始")
{
//将文件夹由16个变成256个
MoveTorrentFileToSubDir(Path.Combine(m_localPath, "Torrent"));
MainStatusText.Text = string.Format("准备读取:{0}", DateTime.Now.ToString());
recvthreadison = false;
isFirstTimeCheck = true;
ReadSetting();
m_nowTableCount = 0;
m_nowTableID = 0;
GetDetailFileTableID();
RecvTimer.Start();
ButtonStart.Text = "停止";
}
else
{
ButtonStart.Text = "开始";
RecvTimer.Stop();
MainStatusText.Text = string.Format("已经停止读取:{0}", DateTime.Now.ToString());
recvthreadison = false;
SaveSetting();
m_downBadList.Clear();
if (m_reader != null)
{
m_reader.Close();
m_reader.Dispose();
m_reader = null;
}
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn("ButtonStart:" ex.StackTrace);
}
}
#endregion
#region 读取 2013-06-16
/// <summary>
/// 开始停止读取 2013-06-16
/// </summary>
private void RecvTimer_Tick(object sender, EventArgs e)
{
int counttime = 1 * 1;
int nowhour = DateTime.Now.Hour;
TimeSpan span = DateTime.Now - m_lastrecvtime;
if (span.TotalSeconds < counttime && isFirstTimeCheck == false)
return;
isFirstTimeCheck = false;
m_lastrecvtime = DateTime.Now;
if (recvthreadison) return;
recvthreadison = true;
MainStatusText.Text = string.Format("准备读取:{0}", DateTime.Now.ToString());
Thread inittreethread = new Thread(new ThreadStart(GetTheHashThreadData));
inittreethread.IsBackground = true;
inittreethread.Start();//线程开始
}
/// <summary>
/// 读取线程 2013-06-16
/// </summary>
private void GetTheHashThreadData()
{
Thread.Sleep(1000 * 1);
MethodInvoker Inthreaddown = new MethodInvoker(GetTheDataDelegate);
this.BeginInvoke(Inthreaddown);
Application.DoEvents(); //让系统在百忙之中来响应其他事件
}
/// <summary>
/// 读取线程主函数 2013-06-16
/// </summary>
private void GetTheDataDelegate()
{
if (recvthreadison)
{
//检测网络状态
if (!isConnected())
{
LogTheAction(0, 1, "网络不通,请等待.");
recvthreadison = false;
return;
}
try
{
MainStatusText.Text = string.Format("开始读取:{0}", DateTime.Now.ToString());
if (m_reader==null)
{
int res2=GetOneFileDataToMDB();
if (m_reader != null)
{
m_reader.Close();
m_reader.Dispose();
}
}
//定位到上次文件读取的地方
m_reader = new StreamReader(Path.Combine(m_localPath,m_readFilename), Encoding.Default);
long pos = m_reader.BaseStream.Seek(m_readPos, SeekOrigin.Begin);
Int32 ticktime1 = System.Environment.TickCount;
string[] strlist = new string[100];
string str1 = m_reader.ReadLine();
int i = 0;
while (i < 100 && str1 != null)
{
if (str1.Length > 1)
{
if (str1.Length == 40)
m_readPos = m_readPos str1.Length 1;
else
m_readPos = m_readPos str1.Length 4;
strlist[i] = str1;
i ;
}
str1 = m_reader.ReadLine();
}
m_reader.Close();
m_doWorkCnt = m_doWorkCnt i;
int value1=Convert.ToInt32(m_readPos / 100);
MainProgressBar.Value = value1 > MainProgressBar.Maximum ? MainProgressBar.Maximum : value1;
Int32 ticktime2 = System.Environment.TickCount;
if (m_doWorkCnt % 10000 == 0)
{
SaveSetting();
LogTheAction(0, 1, "存储到BadList" m_downBadList.Count.ToString() "个成功.");
}
if (i == 0)
{
LogTheAction(0, 1,m_readFilename "读取文件完成");
m_fileOKList[m_readFilename] = m_readPos;
int res2 = GetOneFileDataToMDB();
recvthreadison = false;
return;
}
//开始处理那么多条HASH
for (int k = 0; k < i&&recvthreadison; k )
{
HASHITEM item1 = new HASHITEM();
//通过正则表达式获取几种不同类型的HASH文件
int res11=GetHashLineContent(strlist[k], ref item1);
if(res11==1)
{
if (m_downBadList.ContainsKey(item1.hashKey))
continue;
Int32 ticktime3 = System.Environment.TickCount;
int detailTableid = 0;
int keytype = 0;
int ishanzi = 0;
bool findexist = false;
//先检查本地HASH列表里面是否有,没有就查询数据库里面是否有这一条，如果没有则需要插入，如果有，则需要直接更新次数和日志表
if (m_downOKList.ContainsKey(item1.hashKey))
{
if (m_downOKList[item1.hashKey] > 0)
{
findexist = true;
keytype = m_downOKList[item1.hashKey] / 1000;
detailTableid = m_downOKList[item1.hashKey] / 10 % 100;
ishanzi = m_downOKList[item1.hashKey] % 10;
}
}
if(findexist==false)
{
int res2 = H31SQL.CheckHashItemExist(item1.hashKey, ref keytype, ref detailTableid, ref ishanzi);
}
if (detailTableid > 0)
{
H31SQL.UpdateHashCount(keytype, item1, detailTableid, ishanzi);
m_downOKList[item1.hashKey] = keytype * 1000 detailTableid * 10 ishanzi;
Int32 ticktime4 = System.Environment.TickCount;
//LogTheAction(2, 2, ">>>>" item1.hashKey "更新到数据库" item1.keyType.ToString() "成功" keytype.ToString() "TIME:" (ticktime2 - ticktime1).ToString() "-" (ticktime4 - ticktime3).ToString());
}
else
{
Int32 ticktime4 = System.Environment.TickCount;
HASHFILEITEM[] filelist=null;
//首先去下载种子文件并进行读取
int res=GetDownAndReaHashDetail(item1.hashKey, ref item1, ref filelist);
if (res==0||(res==1&&item1.keyContent.Contains("�")))
continue;
Int32 ticktime5 = System.Environment.TickCount;
if (filelist!=null&&res == 1 &&filelist.Length <= MAX_FILEDETAIL_COUNT)
{
item1.keyWords = "";
ishanzi = ISChineseAndEnglist(item1.keyContent);
//插入新的一条HASH数据
int hashID = H31SQL.AddNewHash((HASHTYPE)item1.keyType, item1, m_nowTableID,ishanzi);
Int32 ticktime6 = System.Environment.TickCount;
if (hashID > 0)
{
m_downOKList[item1.hashKey] = item1.keyType * 1000 m_nowTableID*10 ishanzi;
int real_add = 0;
//插入文件列表
for (int m = 0; m < filelist.Length; m )
{
filelist[m].hashID = hashID;
filelist[m].recvTime = item1.recvTime;
//过滤一些没有用的介绍性文件
if (filelist[m].filesize == 0 || (filelist[m].filename).ToLower().Contains("Thumbs.db"))
continue;
int dotpos = filelist[m].filename.LastIndexOf('.');
string str2 = filelist[m].filename.Substring(dotpos 1, filelist[m].filename.Length - dotpos-1);
if (str2.ToLower() == "url")
continue;
string str3 = filelist[m].filename.Substring(filelist[m].filename.Length - 1, 1);
if (str3 == "_")
continue;
//如果是视频就直接不需要一些文件
if ((item1.keyType == (int)HASHTYPE.MOVIE||filelist.Length>30) && (str2.ToLower() == "mht" || str2.ToLower() == "html" || str2.ToLower() == "htm" || str2.ToLower() == "txt"))
continue;
//过滤文件名字中的网址
filelist[m].filename = GetOneGoodString(filelist[m].filename);
int resid = H31SQL.AddNewHashDetail(item1.keyType*1000 10 ishanzi, filelist[m], m_nowTableID);
real_add = real_add 1;
}
m_nowTableCount = m_nowTableCount real_add;
GetDetailFileTableID();
Int32 ticktime7 = System.Environment.TickCount;
LogTheAction(2, 1, ">>>>" item1.keyContent "插入数据库" (item1.keyType*1000 10 ishanzi).ToString() "成功" filelist.Length.ToString() "个文件 TIME:"
(ticktime2 - ticktime1).ToString() "-" (ticktime4 - ticktime3).ToString() "-" (ticktime5 - ticktime4).ToString() "-" (ticktime6 - ticktime5).ToString() "-" (ticktime7 - ticktime6).ToString());
}
}
}
Application.DoEvents(); //让系统在百忙之中来响应其他事件
}
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn("GetTheDataDelegate:" ex.StackTrace);
}
}
else
{
Thread.Sleep(100);
isFirstTimeCheck = true;
}
this.Text = "已经读取" m_readFilename ":" m_doWorkCnt.ToString() "行";
MainStatusText.Text = string.Format("读取完成:{0}", DateTime.Now.ToString());
recvthreadison = false;
}
/// <summary>
/// 正则表达式取出内容 2013-07-16
/// </summary>
private int GetHashLineContent(string hashline, ref HASHITEM item1)
{
//从http://torrage.com/sync下载的文件解析
if (hashline.Length < 50)
{
if (hashline.Length == 40)
{
item1.hashKey = hashline.Trim();
item1.recvTime = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
item1.recvIp = "127.0.0.1";
item1.recvPort = 8080;
return 1;
}
else
{
}
}
else
{
//自己定义的文件格式下载
string pattern = @"ash\[(.*)\] Time\#(.*)\# ip\:(.*)\:(.*)\.(.*)\#";
Match usermatch = Regex.Match(hashline, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count >= 4 && recvthreadison)
{
item1.hashKey = usermatch.Groups[1].Value.ToString();
item1.recvTime = Convert.ToDateTime(usermatch.Groups[2].Value.ToString());
item1.recvIp = usermatch.Groups[3].Value.ToString();
item1.recvPort = Convert.ToInt32(usermatch.Groups[4].Value.ToString());
return 1;
}
}
return 0;
}
/// <summary>
/// 下载种子文件并进行解析读取
/// </summary>
private int GetDownAndReaHashDetail(string hashname, ref HASHITEM item1, ref HASHFILEITEM[] filelist)
{
Int32 ticktime1 = System.Environment.TickCount;
try
{
int res1 = 0;
TorrentFile myFile = null;
if (checkBox_Torrent.Checked)
{
res1 = m_downLoad.DownLoadFileByHashToFile(hashname);
Application.DoEvents(); //让系统在百忙之中来响应其他事件
if (res1 == 1)
{
string filename = Path.Combine(Path.Combine(Path.Combine(m_localPath, "Torrent"), hashname.Substring(hashname.Length - 2, 2)),hashname ".torrent");
myFile = new TorrentFile(filename);
Int32 ticktime2 = System.Environment.TickCount;
if (myFile == null || myFile.TorrentName.Length == 0)
{
m_downBadList[hashname] = System.Environment.TickCount / 1000;
//解析不了的文件就直接备份
if (checkBox_Torrent.Checked)
{
File.Move(filename, Path.Combine(Path.Combine(m_localPath, "Torrent\\BAD"), hashname ".torrent"));
LogTheAction(1, 1, hashname "下载文件不对，删除" "-" (ticktime2 - ticktime1).ToString());
}
return 0;
}
}
}
else
{
//不用存储文件,直接在内存中操作
byte[] data = m_downLoad.DownLoadFileByHashToByte(hashname);
if (data != null)
res1 = 1;
myFile = new TorrentFile(data);
}
//如果解析成功就进行赋值返回
if (res1 == 1)
{
if (myFile == null || myFile.TorrentName.Length == 0 || myFile.TorrentFileInfo.Count == 0 || myFile.TorrentFileInfo.Count > MAX_FILEDETAIL_COUNT)
{
Int32 ticktime2 = System.Environment.TickCount;
LogTheAction(1, 2, hashname ">>下载成功,但使用失败." "-" (ticktime2 - ticktime1).ToString());
m_downBadList[hashname] = System.Environment.TickCount / 1000;
return 0;
}
else
{
//通过文件列表对文件是哪类进行分析判断
item1.keyType=(int)GetHashFileKeyType(ref myFile);
item1.fileCnt = myFile.TorrentFileInfo.Count;
item1.filetotalSize = myFile.TorrentPieceLength;
//提取正确的文件名字,过滤一些网址信息
item1.keyContent = GetOneGoodString(myFile.TorrentName);
filelist = new HASHFILEITEM[myFile.TorrentFileInfo.Count];
for (int m = 0; m < myFile.TorrentFileInfo.Count; m )
{
filelist[m].filename = myFile.TorrentFileInfo[m].Path;
filelist[m].filesize = myFile.TorrentFileInfo[m].Length;
}
Int32 ticktime2 = System.Environment.TickCount;
LogTheAction(1, 3, myFile.TorrentName ">>下载成功:" myFile.TorrentFileInfo.Count "-" (ticktime2 - ticktime1).ToString());
return 1;
}
}
else
{
Int32 ticktime2 = System.Environment.TickCount;
m_downBadList[hashname] = System.Environment.TickCount / 1000;
LogTheAction(1, 4, hashname ">>下载失败" "-" (ticktime2 - ticktime1).ToString());
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn("GetHashDetail:" ex.StackTrace);
}
return 0;
}
/// <summary>
/// 遍历该目录下所有文件,并返回一个文件名进行读取
/// </summary>
private int GetOneFileDataToMDB()
{
DirectoryInfo filedir = new DirectoryInfo(m_localPath);
foreach (FileInfo fileChild in filedir.GetFiles("*201*.txt"))
{
try
{
Application.DoEvents(); //让系统在百忙之中来响应其他事件
string fc = fileChild.ToString();
//如果是同一个文件，则需要检测是否读取完成
if (m_fileOKList.ContainsKey(fc))
{
System.IO.FileStream file1 = new System.IO.FileStream(Path.Combine(m_localPath,fc), System.IO.FileMode.Open);
long len=file1.Length;
file1.Close();
if (len > m_fileOKList[fc])
{
m_readFilename = fc;
m_readPos = m_fileOKList[fc];
m_fileTotal_Len = len;
MainProgressBar.Maximum = Convert.ToInt32(m_fileTotal_Len / 100);
MainProgressBar.Value = Convert.ToInt32(m_readPos / 100);
this.Text = "已经读取" m_readFilename ":" m_doWorkCnt.ToString() "行";
return 1;
}
}
else
{
m_doWorkCnt = 0;
m_readFilename = fc;
m_fileOKList[fc] = 0;
m_readPos = 0;
System.IO.FileStream file1 = new System.IO.FileStream(Path.Combine(m_localPath, fc), System.IO.FileMode.Open);
m_fileTotal_Len = file1.Length;
file1.Close();
MainProgressBar.Maximum = Convert.ToInt32(m_fileTotal_Len / 100);
MainProgressBar.Value = Convert.ToInt32(m_readPos / 100);
this.Text = "已经读取" m_readFilename ":" m_doWorkCnt.ToString() "行";
return 1;
}
}
catch (Exception ex)
{
H31Debug.PrintLn(ex.Message);
}
}
return 0;
}
/// <summary>
/// 去掉标题中的网址信息
/// </summary>
private string GetOneGoodString(string title)
{
//去掉标题中的网址信息
string res = title;
try
{
//过滤[www.*] [bbs.*]的文件名
string pattern = @"(\[|\@|\【|\s|\(|\{)(.*)([\w-] ://?|(www|bbs)[.])([^(\]|\@|\】|\)|\})]*)(\]|\@|\】|\)|\})";
Match usermatch = Regex.Match(title, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count > 1)
{
res = res.Replace(usermatch.Groups[0].Value.ToString(), " ");
res = res.Trim();
}
//过滤[*.com]等文件名
pattern = @"(\[|\@|\【|\s|\(|\{)(.*)\.(com|edu|gov|mil|net|org|biz|info|name|museum|us|ca|uk|cc|me|cm)([^(\]|\@|\】|\)|\}|\s)]*)(\]|\@|\】|\)|\}|\s)";
usermatch = Regex.Match(res, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count > 1)
{
res = res.Replace(usermatch.Groups[0].Value.ToString(), " ");
res = res.Trim();
}
//过滤www.*.com bbs.*.com文件名
pattern = @"(www|bbs)(.*)(com|edu|gov|mil|net|org|biz|info|name|museum|us|ca|uk|cc|me|cm)";
usermatch = Regex.Match(res, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count > 1)
{
res = res.Replace(usermatch.Groups[0].Value.ToString(), " ");
res = res.Trim();
}
//如果过滤错误只有后缀留下说明有错误,直接用原来的
if (res.Length <= 5 && res.Length<title.Length)
{
res = title;
}
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.Message);
res = title;
}
return res;
}
//判断是否是中文，如果是日文等，则存储到另外一个表中
private int ISChineseAndEnglist(string title)
{
try
{
string pattern = @"[\uac00-\ud7ff] ";//判断韩语
Match usermatch = Regex.Match(title, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count >= 1 && usermatch.Groups[0].Value.Length >= 1)
return 0;
pattern = @"[\u0800-\u4e00] ";//判断日语
usermatch = Regex.Match(title, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count >= 1 && usermatch.Groups[0].Value.Length >= 1)
return 0;
pattern = @"[\u4e00-\u9fa5] ";//判断汉字
usermatch = Regex.Match(title, pattern, RegexOptions.IgnoreCase);
if (usermatch.Groups.Count >= 1 && usermatch.Groups[0].Value.Length >= 1)
return 1;
//判断英文，数字
byte[] byte_len = System.Text.Encoding.Default.GetBytes(title);
if (byte_len.Length == title.Length)
return 1;
}
catch (System.Exception ex)
{
H31Debug.PrintLn(ex.Message);
}
return 0;
}
//移动种子文件到子文件夹下
private int MoveTorrentFileToSubDir(string pathname)
{
DirectoryInfo filedir = new DirectoryInfo(pathname);
foreach (DirectoryInfo NextFolder in filedir.GetDirectories())
{
if (NextFolder.Name.Length == 1)
{
foreach (FileInfo fileChild in NextFolder.GetFiles("*.torrent"))
{
try
{
Application.DoEvents(); //让系统在百忙之中来响应其他事件
string fc = fileChild.ToString();
int finddot = fc.IndexOf('.');
string hashname = fc.Substring(0, finddot);
string pathname1 = Path.Combine(pathname, hashname.Substring(hashname.Length - 2, 2).ToUpper());
if (!Directory.Exists(pathname1))
{
Directory.CreateDirectory(pathname1);
}
string filename1 = Path.Combine(fileChild.DirectoryName, fc);
string filename2 = Path.Combine(pathname1, fc);
File.Move(filename1, filename2);
}
catch (Exception ex)
{
H31Debug.PrintLn(ex.Message);
}
}
}
}
return 0;
}
#endregion
#region 检查文件类型
/// <summary>
/// 检测文件类型
/// </summary>
private HASHTYPE GetHashFileKeyType(ref TorrentFile myFile)
{
HASHTYPE type1 = HASHTYPE.OTHER;
List<HASHTYPE> typelist = new List<HASHTYPE>();
for (int m = 0; m < myFile.TorrentFileInfo.Count;m )
{
string str1 = myFile.TorrentFileInfo[m].Path;
//获取后缀名
int dotIndex = str1.LastIndexOf('.');
string extName = str1.Substring(dotIndex 1, str1.Length - dotIndex-1).ToUpper();
if (extName == "RMVB" || extName == "AVI" || extName == "RM" || extName == "OGM" || extName == "MP4" || extName == "MKV" || extName == "FLV" || extName == "MPEG" || extName == "WMA" || extName == "ASF" || extName == "WMV" || extName == "MOV" || extName == "DAT" || extName == "BDMV"
|| extName == "CLPI" || extName == "M2TS" || extName == "VOB" || extName == "VCD" || extName == "DSF" || extName == "MPG" || extName == "DIVX" || extName == "TS" || extName == "TP")
{
type1=HASHTYPE.MOVIE;
typelist.Add(type1);
break;
}
else if (extName == "MP3" || extName == "MID" || extName == "APE" || extName == "AAC" || extName == "WAV" || extName == "WMA" || extName == "VOC" || extName == "FLAC"|| extName == "M4A")
{
type1=HASHTYPE.MUSIC;
}
else if (extName == "CHM"||extName == "EPUB" || extName == "PDF" || extName == "DOC" || extName == "TXT" || extName == "DOCX"
|| extName == "PPT" || extName == "PPTX" || extName == "XLS" || extName == "XLSX" || extName == "PDG" || extName == "FB2" || extName == "CBZ")
{
type1=HASHTYPE.BOOK;
}
else if(extName=="EXE"||extName=="BIN"||extName=="COM"||extName=="BAT"||extName=="RAR"||extName=="ZIP"||extName=="7z"||extName=="ISO"
|| extName == "MSI" || extName == "TAR" || extName == "LZH" || extName == "TGZ" || extName == "OCX" || extName == "SFV" || extName == "MDF" || extName == "DMG")
{
type1=HASHTYPE.EXE;
}
else if(extName=="BMP"||extName=="GIF"||extName=="PNG"||extName=="JPG"||extName=="RAW"||extName=="TIF"||extName=="PSD")
{
type1=HASHTYPE.PICTURE;
}
else
{
type1=HASHTYPE.OTHER;
}
typelist.Add(type1);
}
if (typelist.Contains(HASHTYPE.MOVIE))
type1 = HASHTYPE.MOVIE;
else if (typelist.Contains(HASHTYPE.MUSIC))
type1 = HASHTYPE.MUSIC;
else if (typelist.Contains(HASHTYPE.BOOK))
type1 = HASHTYPE.BOOK;
else if (typelist.Contains(HASHTYPE.EXE))
type1 = HASHTYPE.EXE;
else if (typelist.Contains(HASHTYPE.PICTURE))
type1 = HASHTYPE.PICTURE;
else
type1 = HASHTYPE.OTHER;
return type1;
}
#endregion
#region 检查网络状态
//检测网络状态
[DllImport("wininet.dll")]
extern static bool InternetGetConnectedState(out int connectionDescription, int reservedValue);
/// <summary>
/// 检测网络状态
/// </summary>
private bool isConnected()
{
int I = 0;
bool state = InternetGetConnectedState(out I, 0);
return state;
}
#endregion
/// <summary>
/// 记录处理日志
/// </summary>
private void LogTheAction(int action, int No, string Logstr)
{
//如果大于1000行，则清空
if (MainLogText.Text.Length > 10 * 1000)
MainLogText.Text = "";
MainLogText.Text = Logstr "\r\n" action.ToString() ":" No.ToString() ":" MainLogText.Text;
}
#region 关于程序 2013-07-06
/// <summary>
/// 关于程序 2013-07-06
/// </summary>
private void ButtonAbout_Click(object sender, EventArgs e)
{
About a = new About();
a.ShowDialog();
}
#endregion
}
}
标签： C#
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论