用jmail收邮件

Biegral 2008/12/26 8:53:00 1845

  1. jmail.Message Msg=new jmail.Message(); 
  2.             jmail.POP3 jpop = new jmail.POP3(); 
  3.             jmail.Attachments atts; 
  4.             jmail.Attachment att; 
  5.              
  6.             //username为用户名,该方法通过用户名获取该用户的pop设置,即用户的POP用户名,密码,POP服务器地址以及端口号这四个参数,这四个参数是连接POP服务器的必用参数. 
  7.                 SqlDataReader dataReader = this.ExtGetSetting(Username); 
  8.                 if(dataReader.Read()) 
  9.                 { 
  10.                     if(dataReader["PopServer"].ToString()!=""&&dataReader["PopUsername"].ToString()!="") 
  11.                     { 
  12.                         //连接POP服务器 
  13.                         jpop.Connect(dataReader["PopUsername"].ToString(),dataReader["PopPassword"].ToString(),dataReader["PopServer"].ToString(),Int32.Parse(dataReader["PopPort"].ToString())); 
  14.                         //如果服务器上有邮件 
  15.                         if(jpop.Count> =1) 
  16.                         { 
  17.                          for(int i=1;i <=jpop.Count;i++) 
  18.                             { 
  19.                              
  20.                                 Msg = jpop.Messages[i]; 
  21.                                 atts=Msg.Attachments; 
  23.                              //取数据库中邮件信息中的最大发送时间,即最近接收到的一封邮件的时间 
  24.                                 Database dbase=new Database(); 
  25.                                 DataTable data=dbase.GetDataTable("select max(MailSendDate) as MailSenderDate from TabMailList where MailTypeFlag='1'"); 
  26.                                  
  27.                              //对服务器上的邮件的发送时间和数据库最近一封邮件的时间进行比较,如果大那么证明该邮件还未被收取,是一封新邮件,这样避免重复收取邮件入库 
  28.                                 if(Msg.Date> Convert.ToDateTime(data.Rows[0][0].ToString())) 
  30.                                 { 
  31.                                     //将这封新邮件的信息保存到数据库 
  32.                                     this.SaveExtMail(Msg,Username,dataReader["Email"].ToString(),jpop.GetMessageUID(i)); 
  33.                              
  34.                                     //获取附件上传到服务器并且将信息存入数据库 
  35.                                     if(atts.Count> =1) 
  36.                                     { 
  37.                                         for(int k=0;k <atts.Count;k++) 
  38.                                         { 
  40.                                             att=atts[k];//获得附件 
  42.                                             string attname=att.Name; 
  43.                                             try 
  44.                                             { 
  46.                                                 Random TempNameInt    = new Random();  
  47.                                                 string NewMailDirName  = TempNameInt.Next(100000000).ToString(); 
  48.                                                 Directory.CreateDirectory(System.Web.HttpContext.Current.Server.MapPath(".")+"//AttachFiles//"+Username+"//"+NewMailDirName); 
  49.                  
  50.                                                 string mailPath="//AttachFiles//"+Username+"//"+NewMailDirName+"//"+attname; 
  51.              
  52.                                                 att.SaveToFile(System.Web.HttpContext.Current.Server.MapPath(".")+mailPath);  
  53.                                                  
  54.                                                 //获取该封邮件在数据库的ID,以便和附件信息相对应,取邮件表中的最大ID即可  
  55.                                                 int mailID=this.GetMailID(); 
  56.                                                //将附件信息存入数据库 
  57.                                                 this.AttExtSend(mailID,attname,att.Size,mailPath,Msg.From); 
  58.                                             } 
  59.                                             catch(Exception ex) 
  60.                                             { 
  61.                                                 throw new Exception(ex.Message); 
  62.                                             } 
  63.                                          
  64.                                         } 
  65.                                     }                                         
  66.                                 }                             
  67.                             }                         
  68.                         }     
  70.                         //删除服务器上的邮件 
  71.                         //jpop.DeleteMessages(); 
  72.                         //断开连接     
  73.                         jpop.Disconnect(); 
  74.                     } 
  75.                  
  76.             } 
  77.         } 

  78. 邮件信息入库：

    1. public string SaveExtMail(jmail.Message JMsg, string Username, string Email) 
    2.         { 
    3.             Database data = new Database(); 
    4.             string MailID = null; 
    6.              
    7.             SqlParameter[] prams = { 
    8.    data.MakeInParam("@MailFolderType",  SqlDbType.Int, 20, 1),//? 
    9.    data.MakeInParam("@MailReceiverStr",  SqlDbType.VarChar, 300, Username),//! 
    10.    data.MakeInParam("@MailSendDate",  SqlDbType.DateTime, 20, DateTime.Parse(JMsg.Date.ToString())),//发送时间 
    11.    data.MakeInParam("@MailSendLevel",  SqlDbType.SmallInt,20, 1),//! 
    12.    data.MakeInParam("@MailSender",  SqlDbType.NVarChar, 100, JMsg.From.ToString()),//发送者地址 
    13.    data.MakeInParam("@MailReceiver",  SqlDbType.NVarChar, 100, Username),//接受者 
    14.    data.MakeInParam("@MailSubject",  SqlDbType.NVarChar, 150,subject),//邮件主题 
    15.    data.MakeInParam("@MailBody",  SqlDbType.Text , 300000,  ( JMsg.BodyText==null?"": body )),//邮件内容 
    16.    data.MakeInParam("@MailCcToAddr",  SqlDbType.NVarChar, 300,""),//? 
    17.    data.MakeInParam("@MailBccToAddr",  SqlDbType.NVarChar, 300, ""),//? 
    18.    data.MakeInParam("@MailReadFlag",  SqlDbType.Bit, 1, 0), 
    19.    data.MakeInParam("@MailTypeFlag",  SqlDbType.Bit, 1,1),//? 
    20.    data.MakeInParam("@MailClassID",  SqlDbType.Int, 1, 0), 
    21.    data.MakeInParam("@MailImportance",  SqlDbType.Int, 1, Convert.ToInt32(JMsg.Priority)),//优先级 
    22.    data.MakeOutParam("@MailID", SqlDbType.Int,20) //? 
    23.    }; 
    25.             try 
    26.             { 
    27.                 data.RunProc("SP_MailSend", prams); 
    28.                 MailID = prams[14].Value.ToString(); 
    29.                 if (MailID == string.Empty) 
    30.                     return null; 
    31.                 else 
    32.                     return MailID; 
    33.             } 
    34.             catch (Exception ex) 
    35.             { 
    37.                 Error.Log(ex.ToString()); 
    38.               } 
    41.         } 
    43.   

     

本文转载:CSDN博客

阅读排行

分类

归档