Email/Program.cs

   1 using System;
   2 using System.Collections.Generic;
   3 using System.Linq;
   4 using System.Text;
   5 using PumpkinHouse.Utils;
   6 using Mail;
   7 using PumpkinHouseDatabase;
   8 using System.Net.Mail;
   9 using System.Threading;
  10
  11 namespace Email
  12 {
  13     class Program
  14     {
  15         private static void PrintHelp()
  16         {
  17             Console.WriteLine("usage: SendEmail.exe [/reset] [<邮件主题> <模板路径>]");
  18         }
  19
  20         private static void ResetRecords()
  21         {
  22             using (DataUtils utils = new DataUtils())
  23             {
  24                 foreach (var u in utils.FindAllUsers().ToList())
  25                 {
  26                     u.Email_Sent = 0;
  27                 }
  28                 utils.Commit();
  29             }
  30         }
  31
  32         private static void SendEmail(string subject, string template, bool test)
  33         {
  34             if (test)
  35             {
  36                 Console.WriteLine("Test Mode");
  37             }
  38             MailClient.LoadConfiguration("mail.config");
  39             // EmailHelper.SendActivityEmail(subject, "728635054@qq.com", template, new string[] { "测试邮件" });
  40             using (DataUtils utils = new DataUtils())
  41             {
  42                 bool start = true;
  43                 var result = utils.FindAllUsers().Where(u => u.Receive_Email == 1 && u.Email != "" && u.Email_Verified != 2 && u.Email_Sent != 1).ToList();
  44
  45                 foreach (var r in result)
  46                 {
  47                     //if (r.Email == "iujijvjn@126.com")
  48                     //{
  49                     //    //start = true;
  50                     //}
  51                     if (!start) { Console.WriteLine("\tskip"); continue; }
  52
  53                     bool retry;
  54                     do
  55                     {
  56                         retry = false;
  57                         try
  58                         {
  59                             SendEmail(subject, template, utils, r, test);
  60                         }
  61                         catch (Exception e)
  62                         {
  63                             Console.WriteLine(r.Email + "\t" + r.Nick_Name + "\t" + e.Message);
  64                             if (e.Message.Equals("Mailbox unavailable. The server response was: Connection frequency limited"))
  65                             {
  66                                 Thread.Sleep(1000 * 60 * 10); // 停止发送10分钟
  67                                 Console.WriteLine(r.Email + "\t" + r.Nick_Name + "\tRetrying");
  68                                 retry = true;
  69                             }
  70                         }
  71                     } while (retry);
  72                     if (!test)
  73                     {
  74                         Thread.Sleep(25000);
  75                     }
  76                 }
  77             }
  78         }
  79
  80         private static void SendEmail(string subject, string template, DataUtils utils, DB_User r, bool test)
  81         {
  82             if (r.Email == "raymanyoung@gmail.com" || !test)
  83             {
  84                 EmailHelper.SendActivityEmail(subject, r.Email, template, new string[] { r.Nick_Name });
  85                 r.Email_Sent = 1;
  86                 utils.Commit();
  87                 Console.WriteLine(r.Email + "\t" + r.Nick_Name + "\tSuccess");
  88             }
  89         }
  90
  91         static void Main(string[] args)
  92         {
  93             if (args.Length < 1 || args.Length > 3)
  94             {
  95                 PrintHelp();
  96                 return;
  97             }
  98
  99             DataUtils.ConnectionString = @"Server=localhost\SQLExpress;Database=MutouheziDatabase;Integrated Security=true"; //305906536
 100
 101             if (args.Length == 1)
 102             {
 103                 if (args[0].Equals("/reset", StringComparison.OrdinalIgnoreCase))
 104                 {
 105                     ResetRecords();
 106                     return;
 107                 }
 108                 else
 109                 {
 110                     PrintHelp();
 111                     return;
 112                 }
 113             }
 114
 115             if (args.Length == 3)
 116             {
 117                 if (args[2].Equals("/prod", StringComparison.OrdinalIgnoreCase))
 118                 {
 119                     SendEmail(args[0], args[1], false);
 120                 }
 121                 else
 122                 {
 123                     PrintHelp();
 124                     return;
 125                 }
 126             }
 127             if (args.Length == 2)
 128             {
 129                 SendEmail(args[0], args[1], true);
 130             }
 131
 132         }
 133     }
 134 }