实例介绍
【实例简介】
【实例截图】
【核心代码】
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.IO;
using LumiSoft.Net;
using LumiSoft.Net.Log;
using LumiSoft.Net.Mime;
using LumiSoft.Net.MIME;
using LumiSoft.Net.Mail;
using LumiSoft.Net.POP3.Client;
using System.Text.RegularExpressions;
using System.Data.SqlClient;
using System.Data.OleDb;
using System.Diagnostics;
namespace 系统升级器
{
public partial class Form1 : Form
{
public string company, s_server, username, password, s_database;
public string conn_str;
public Form1()
{
InitializeComponent();
m_pTabMail_Messages.View = View.Details;
m_pTabMail_Messages.HideSelection = false;
m_pTabMail_Messages.FullRowSelect = true;
m_pTabMail_Messages.Columns.Add("发件人", 50);
m_pTabMail_Messages.Columns.Add("标题", 200);
m_pTabMail_Messages.Columns.Add("收件时间", 120);
m_pTabMail_Messages.Columns.Add("邮件大小", 100);
m_pTabMail_Messages.Columns.Add("排序码", 100);
m_pTabMail_Messages.Columns.Add("处理时间", 150);
m_pTabMail_Attachments.Anchor = AnchorStyles.Left | AnchorStyles.Right | AnchorStyles.Top;
m_pTabMail_Attachments.View = View.SmallIcon;
}
public void getini()
{
try
{
string[] strs = File.ReadAllLines(@"888.ini", Encoding.Default);
foreach (string ss in strs)
{
//me_1.Text = me_1.Text ss.ToString();
if (ss.IndexOf("company=") >= 0)
{
t_1.Text = ss.Substring(8);
}
if (ss.IndexOf("server=") >= 0)
{
t_2.Text = ss.Substring(7);
}
if (ss.IndexOf("mail=") >= 0)
{
t_3.Text = ss.Substring(5).Trim();
}
if (ss.IndexOf("pop=") >= 0)
{
t_5.Text = ss.Substring(4).Trim();
}
else
{
t_5.Text ="pop.126.com";
}
if (ss.IndexOf("mail_password=") >= 0)
{
t_4.Text = ss.Substring(5).Trim();
}
else
{
t_4.Text = "test123456";
}
}
}
catch (Exception x)
{
MessageBox.Show(x.Message);
}
string ls_company;
ls_company = t_1.Text.Trim();
password = t_4.Text.Trim();
switch (ls_company)
{
case "TEST":
username = "ttt123456";
s_database = "ttt";
break;
default:
if (t_3.Text.Trim() != "")
{
username = t_3.Text.Trim();
s_database = ls_company;
}
if (t_4.Text.Trim() != "")
{
password = t_4.Text.Trim();
}
break;
}
t_3.Text = username;
}
private void Form1_Load(object sender, EventArgs e)
{
getini();
}
public void GetEmails()
{
string ls_company;
DateTime rev_time;
ls_company = t_1.Text.Trim();
password = t_4.Text.Trim();
switch (ls_company)
{
case "TEST":
username = "ttt123456";
s_database = "ttt";
break;
default:
if (t_3.Text.Trim() != "")
{
username = t_3.Text.Trim();
s_database = ls_company;
}
break;
}
//需要首先设置这些信息
string pop3Server;
string ls_time;
int pop3Port;
bool pop3UseSsl;
string ls_from, ls_subject, ls_receive_time, ls_dealtime;
List<string> gotEmailIds;
List<Mime> result = new List<Mime>();
POP3_Client pop3 = new POP3_Client();
pop3Server = t_5.Text.Trim();
pop3Port = 110;
pop3UseSsl = false;
s_server = t_2.Text.Trim();
if (s_server == "")
{
s_server = ".";
}
//与Pop3服务器建立连接
try
{
pop3.Connect(pop3Server, pop3Port, pop3UseSsl);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "邮件服务器连接失败");
return;
}
//验证身份
try
{
pop3.Authenticate(username, password, false);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "用户名/密码错误");
return;
}
//pop3.Login(username, password);
try
{
//获取邮件信息列表
POP3_ClientMessageCollection infos = pop3.Messages;
foreach (POP3_ClientMessage message in infos)
{
Mail_Message mime = Mail_Message.ParseFromByte(message.HeaderToByte());
ListViewItem item = new ListViewItem();
if (mime.From != null)
{
item.Text = mime.From.ToString();
ls_from = mime.From.ToString().Trim();
}
else
{
item.Text = "<none>";
ls_from = "<none>";
}
if (string.IsNullOrEmpty(mime.Subject))
{
item.SubItems.Add("<none>");
ls_subject = "<none>";
}
else
{
item.SubItems.Add(mime.Subject);
ls_subject = mime.Subject.Trim();
}
item.SubItems.Add(mime.Date.ToString());
rev_time = mime.Date;
ls_time = rev_time.ToString("yyyy-MM-dd HH:mm:ss");
item.SubItems.Add(((decimal)(message.Size / (decimal)1000)).ToString("f2") " kb");
item.SubItems.Add(rev_time.Ticks.ToString());
ls_company = t_1.Text.Trim();
switch (ls_company)
{
case "HNZS":
conn_str = string.Format(@"User ID=sa;Data Source={0};Password=780223;Initial Catalog={1};", s_server, s_database);
break;
default:
conn_str = string.Format(@"User ID=sa;Data Source={0};Password=hnzw318OK!;Initial Catalog={1};", s_server, s_database);
break;
}
//是否已经处理过
string sql = string.Format(@" IF NOT EXISTS (SELECT * FROM syscolumns
WHERE id = object_id('MsgMailInfo') AND name = 't_addtime')
ALTER TABLE [MsgMailInfo] ADD [t_addtime] DATETIME DEFAULT getdate() NULL; ");
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, sql, new SqlParameter("@prodid", 24));
sql = string.Format(@" IF NOT EXISTS (SELECT * FROM syscolumns
WHERE id = object_id('MsgMailInfo') AND name = 't_revtime')
ALTER TABLE [MsgMailInfo] ADD [t_revtime] DATETIME NULL; ");
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, sql, null);
sql = string.Format(@" update msgmailinfo set t_revtime= case when charindex('上午',msg_date)>0 then convert(datetime,replace(msg_date,'上午','') )
when charindex('下午',msg_date)>0 then dateadd(hh,12,convert(datetime,replace(msg_date,'下午','')))
else convert(datetime,msg_date) end from msgmailinfo where msg_date is not null ");
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, sql, null);
sql = string.Format(@" select t_addtime from MsgMailInfo where Msg_Subject='{0}' and t_revtime='{1}' ", ls_subject, ls_time);
SqlDataReader dr;
dr = SqlHelper.ExecuteReader(conn_str, CommandType.Text, sql, null);
if (dr.Read())
{
item.SubItems.Add(dr[0].ToString());
}
else
{
item.SubItems.Add("未知");
}
item.Tag = message;
ls_subject = ls_subject.ToLower();
if (!(ls_subject.IndexOf("check_order") < 0 && ls_subject.IndexOf("notice") < 0 && ls_subject.IndexOf("sellprize") < 0 && ls_subject.IndexOf("backprize") < 0 && ls_subject.IndexOf("priceprize") < 0 && ls_subject.IndexOf("lowprize") < 0 && ls_subject.IndexOf("fun") < 0 && ls_subject.IndexOf("prise") < 0 && ls_subject.IndexOf("app") < 0 && ls_subject.IndexOf("营销提奖系统") < 0 && ls_subject.IndexOf("tjxt") < 0 && ls_subject.IndexOf("update") < 0 && ls_subject.IndexOf("comm") < 0))
{
m_pTabMail_Messages.Items.Add(item);
}
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "错误");
return;
}
//m_pTabMail_Messages.Sorting = SortOrder.None;
m_pTabMail_Messages.ListViewItemSorter = new ListViewItemComparer(4);
m_pTabMail_Messages.Sort();
}
private void button1_Click(object sender, EventArgs e)
{
button1.Enabled=false;
button2.Enabled = false;
button3.Enabled = false;
m_pTabMail_Messages.Clear();
m_pTabMail_Messages.Columns.Add("发件人", 50);
m_pTabMail_Messages.Columns.Add("标题", 200);
m_pTabMail_Messages.Columns.Add("收件时间", 120);
m_pTabMail_Messages.Columns.Add("邮件大小", 100);
m_pTabMail_Messages.Columns.Add("排序码", 100);
m_pTabMail_Messages.Columns.Add("处理时间", 150);
GetEmails();
button1.Enabled = true;
button2.Enabled = true;
button3.Enabled = true;
}
private void m_pTabMail_Messages_SelectedIndexChanged(object sender, EventArgs e)
{
if (m_pTabMail_Messages.SelectedItems.Count > 0)
{
m_pTabMail_Attachments.Items.Clear();
m_pTabMail_BodyText.Text = "";
POP3_ClientMessage message = (POP3_ClientMessage)m_pTabMail_Messages.SelectedItems[0].Tag;
Mail_Message mime = Mail_Message.ParseFromByte(message.MessageToByte());
foreach (MIME_Entity entity in mime.Attachments)
{
ListViewItem item = new ListViewItem();
if (entity.ContentDisposition != null && entity.ContentDisposition.Param_FileName != null)
{
item.Text = entity.ContentDisposition.Param_FileName;
}
else
{
item.Text = "untitled";
}
item.Tag = entity;
m_pTabMail_Attachments.Items.Add(item);
}
if (mime.BodyText != null)
{
m_pTabMail_BodyText.Text = mime.BodyText;
}
}
}
private void button2_Click(object sender, EventArgs e)
{
Process[] pp = Process.GetProcessesByName("XX系统");
if (pp.Length > 0)
{
MessageBox.Show("XX系统正在运行,为保证更新成功，请先关闭系统", "提示");
return;
}
m_pTabMail_Messages.Focus();
Application.DoEvents();
button2.Enabled = false;
button1.Enabled = false;
button3.Enabled = false;
deal_mail();
me_1.Text = "处理完毕！" "\r\n" me_1.Text;
button2.Enabled = true;
button1.Enabled = true;
button3.Enabled = true;
}
private void run_sql(string ls_body)
{
//分析并执行邮件正文
string ls_split;
string[] ls_sql;
string ss = (char)10 "GO";
me_1.Text = "正在分析sql【" ls_body.Substring(0, ls_body.Length > 80 ? 80 : ls_body.Length) "...】" "\r\n" me_1.Text; ;
ls_split = "##########";
ls_body = ls_body.Replace(ss, ls_split);
ss = (char)10 "go";
ls_body = ls_body.Replace(ss, ls_split);
ls_sql = Regex.Split(ls_body, ls_split, RegexOptions.IgnoreCase);
foreach (string ls in ls_sql)
{
if (ls.Trim().Length > 5)
{
//Return_cls rc1 = mail.ExecuteNonQuery(ls);
//ShowMs.Show(ls_body);
try
{
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, ls, null);
me_1.Text = "执行sql成功【" ls.Substring(0, ls.Length > 80 ? 80 : ls.Length) "...】" "\r\n" me_1.Text; ;
}
catch (Exception ex)
{
me_1.Text = "执行sql失败【" ex.Message "...】" "\r\n" me_1.Text; ;
}
}
}
}
private void deal_mail()
{
Application.DoEvents();
int ii;
DateTime ldt_revtime;
ii = 1;
string ls_subject, ls_body, ls_filename, ls_sql, ls_from, ls_receive_time;
foreach (ListViewItem item in m_pTabMail_Messages.Items)
{
me_1.Text = "正在处理第（" ii.ToString() "）封邮件【" item.SubItems[1].Text "】" "\r\n" me_1.Text;
ls_subject = item.SubItems[1].Text;
if (item.SubItems[5].Text == "未知")
{
ls_from = item.SubItems[0].Text;
ls_subject = item.SubItems[1].Text;
ls_receive_time = item.SubItems[2].Text;
m_pTabMail_Attachments.Items.Clear();
m_pTabMail_BodyText.Text = "";
POP3_ClientMessage message = (POP3_ClientMessage)item.Tag;
try
{
Mail_Message mime = Mail_Message.ParseFromByte(message.MessageToByte());
ldt_revtime = mime.Date;
//分析并执行邮件正文
if (mime.BodyText != null && mime.BodyText.Trim().Length > 10 && mime.Subject.Substring(0, 5) == "[sql]")
{
m_pTabMail_BodyText.Text = mime.BodyText;
ls_body = mime.BodyText;
run_sql(ls_body);
}
//下载附件
foreach (MIME_Entity entity in mime.Attachments)
{
ListViewItem item2 = new ListViewItem();
if (entity.ContentDisposition != null && entity.ContentDisposition.Param_FileName != null)
{
item2.Text = entity.ContentDisposition.Param_FileName;
ls_filename = entity.ContentDisposition.Param_FileName;
}
else
{
item2.Text = "untitled";
ls_filename = "untitled";
}
item2.Tag = entity;
me_1.Text = "正在保存附件【" ls_filename "】" "\r\n" me_1.Text;
try
{
File.WriteAllBytes(@"" ls_filename, ((MIME_b_SinglepartBase)entity.Body).Data);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "文件保存失败");
}
//如果后缀为sql,读取并执行
string ls_hz;
string ls_unzip_filename;
ls_hz = ls_filename.Substring(ls_filename.Length - 4, 4);
//ShowMs.Show(ls_hz);
if (ls_hz == ".sql")
{
me_1.Text = "正在读取sql脚本文件【" ls_filename "】" "\r\n" me_1.Text;
string sql;
StreamReader sr = new StreamReader(@"" ls_filename, System.Text.Encoding.Default);
sql = sr.ReadToEnd();
sr.Close();
run_sql(sql);
}
if (ls_hz == ".zip")
{
ls_unzip_filename = ls_filename.Substring(0, ls_filename.Length - 4);
me_1.Text = "解压缩文件【" ls_filename "】" "\r\n" me_1.Text;
Zip.DeCompressFile(ls_filename, ls_unzip_filename);
ls_sql = String.Format("delete from tbl_fileinfo where filename='{0}'", ls_unzip_filename);
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, ls_sql, null);
savefiletodb(ls_unzip_filename);
}
}
////更新处理标志
item.SubItems[5].Text = System.DateTime.Now.ToString();
ls_receive_time = item.SubItems[2].Text;
ls_sql = String.Format("insert msgmailinfo(Msg_FormName,Msg_Subject,t_revtime,Msg_Date) values('{0}','{1}','{2}','{3}')", ls_from, ls_subject, ldt_revtime.ToString("yyyy-MM-dd HH:mm:ss"), ldt_revtime.ToString("yyyy-MM-dd HH:mm:ss"));
SqlHelper.ExecuteNonQuery(conn_str, CommandType.Text, ls_sql, null);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "邮件读取错误");
}
}
else
{
me_1.Text = "【该邮件无需再次处理】" "\r\n" me_1.Text;
}
ii ;
}
}
private void savefiletodb(string fileName)
{
Application.DoEvents();
//保存客户端文件到数据库
//FileInfo fi = new FileInfo(fileName);
//FileStream fs = fi.OpenRead();
//byte[] bytes = new byte[fs.Length];
//fs.Read(bytes, 0, Convert.ToInt32(fs.Length));
string strConnection = string.Format(@"Provider=SQLOLEDB;Data Source={0};Initial Catalog={1};User ID=prise;Password=20110214;", s_server, s_database);
OleDbConnection DBConn;
OleDbCommand DBCommand;
try
{
DBConn = new OleDbConnection(strConnection);
DBConn.Open();
DBCommand = DBConn.CreateCommand();
FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read);
Byte[] b = new Byte[fs.Length];
fs.Read(b, 0, b.Length);
fs.Close();
DBCommand.CommandText = string.Format(@"insert tbl_fileinfo(version,[filename],filesize,filedata) values('2013','{0}',{1},?)", fileName, b.Length);
OleDbParameter prm = new OleDbParameter("@filedata", OleDbType.VarBinary, b.Length, ParameterDirection.Input, false, 0, 0, null, DataRowVersion.Current, b);
DBCommand.Parameters.Add(prm);
if (DBCommand.ExecuteNonQuery() == 1)
{
me_1.Text = "【文件(" fileName ")上传数据库成功】" "\r\n" me_1.Text;
}
else
{
MessageBox.Show("文件上传数据库失败1", "文件上传数据库失败");
}
DBConn.Close();
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "文件上传数据库失败");
}
}
private void button3_Click_2(object sender, EventArgs e)
{
this.Close();
}
private void t_1_TextChanged(object sender, EventArgs e)
{
if (t_1.Text == "ZIP")
{
button10.Visible = true;
}
}
private void label3_Click(object sender, EventArgs e)
{
}
private void button10_Click(object sender, EventArgs e)
{
Zip.CompressFile(@"start.pbd", @"start.pbd.zip");
Zip.CompressFile(@"comm.pbd", @"comm.pbd.zip");
Zip.CompressFile(@"jxc.pbd", @"jxc.pbd.zip");
Zip.CompressFile(@"parent.pbd", @"parent.pbd.zip");
Zip.CompressFile(@"sysbase.pbd", @"sysbase.pbd.zip");
Zip.CompressFile(@"run.exe", @"run.exe.zip");
Zip.CompressFile(@"TTF16.ocx", @"TTF16.ocx.zip");
}
}
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论