我们一起去了解并探讨一下这个问题吧!如何实现自动批量发信息最近在项目中遇到了群发短信的需求。需求点包括：1.给符合条件的人群发优惠券短信2.并对发送短信做记录，成功或者失败。短信接口：api中有群发短信的接口，一组最大为200条。
如何实现自动批量发信息?最近在项目中遇到了群发短信的需求，下面我们就来说一说关于如何实现自动批量发信息?我们一起去了解并探讨一下这个问题吧!
如何实现自动批量发信息
最近在项目中遇到了群发短信的需求。
需求点包括：
1.给符合条件的人群发优惠券短信
2.并对发送短信做记录，成功或者失败。（SqlServer）
短信接口：
api中有群发短信的接口，一组最大为200条。
思路：
1.发送的手机集合放进一个队列
2.依次读取队列，放到待发送列表，当满足200（短信组个数可配置在web.config中）条时，调用接口发送，直到队列数据发完
3.发送结果放进已发送短信结果集合
4.把发送结果批量插入数据库
代码：
群发helper
/// <summary>/// 群发短信/// </summary>public class SmsGroupHelper{//每次发送短信数量private readonly static int SmsCount = Globals.SafeInt(Utils.GetAppSettingByKey("SmsCount"), 0);/// <summary>/// 群发短信/// </summary>/// <param name="content">短信内容</param>/// <param name="phones">手机号组</param>/// <returns></returns>public static SmsResult SendGroupSms(string content, List<string> phones){var phoneQueue = new Queue<string>();var unSendSmsList = new List<string>(); //待发送var sendedSmsList = new List<Sms>(); //已发送数量var sendFailed = new List<string>(); //发送失败数量var sendSuccess = new List<string>(); //发送成功数量var smsResult = new SmsResult();smsResult.ErrMsg = "无";try{//1.先发送短信 ，根据短信发送情况，保存数据库记录foreach (var phone in phones){phoneQueue.Enqueue(phone);}//是否发送短信var isSendFlag = false;while (true){if (phoneQueue.Count > 0){var phoneNum = phoneQueue.Dequeue();unSendSmsList.Add(phoneNum);//如果达到一个发送短信包数量if (unSendSmsList.Count == SmsCount){isSendFlag = true;}}else{//如果还有短信没发出去if (unSendSmsList.Count > 0){isSendFlag = true;}else{isSendFlag = false;break;}}if (isSendFlag){var phoneArr = unSendSmsList.ToArray();var resposeMsg = "";//发送短信短信接口var flag = SMSHelper.SendSms(content, phoneArr, out resposeMsg);var sendResult = "短信发送成功";if (flag){sendSuccess.AddRange(unSendSmsList);}else{sendResult = "短信发送失败";sendFailed.AddRange(unSendSmsList);}//记录总发送数量sendedSmsList.AddRange(unSendSmsList.Select(un =>new Sms{Phone = un,CreateTime = DateTime.Now,MessageStatus = sendResult,MessageRemarks = content}));//清空未发送列表unSendSmsList = new List<string>();isSendFlag = false;}}}catch (Exception ex){smsResult.ErrMsg = ex.Message;while (phoneQueue.Count > 0){var p = phoneQueue.Dequeue();sendFailed.Add(p);sendedSmsList.Add(new Sms(){Phone = p,CreateTime = DateTime.Now,MessageStatus = "短信发送失败",MessageRemarks = content});}}//批量插入短信结果到数据库DapperHelper.BulkInsert("SmsRecord", sendedSmsList);smsResult.Send = sendedSmsList.Count;smsResult.Success = sendSuccess.Count;smsResult.Failed = sendFailed.Count;return smsResult;}
批量插入数据
public class TableColumn{public string COLUMN_NAME { get; set; }public string DATA_TYPE { get; set; }}
#region Bulk批量插入public static Type MapCommonType(string dbtype){if (string.IsNullOrEmpty(dbtype)) return Type.Missing.GetType();dbtype = dbtype.ToLower();Type commonType = typeof(object);switch (dbtype){case "bigint": commonType = typeof(long); break;case "binary": commonType = typeof(byte[]); break;case "bit": commonType = typeof(bool); break;case "char": commonType = typeof(string); break;case "date": commonType = typeof(DateTime); break;case "datetime": commonType = typeof(DateTime); break;case "datetime2": commonType = typeof(DateTime); break;case "datetimeoffset": commonType = typeof(DateTimeOffset); break;case "decimal": commonType = typeof(decimal); break;case "float": commonType = typeof(double); break;case "image": commonType = typeof(byte[]); break;case "int": commonType = typeof(int); break;case "money": commonType = typeof(decimal); break;case "nchar": commonType = typeof(string); break;case "ntext": commonType = typeof(string); break;case "numeric": commonType = typeof(decimal); break;case "nvarchar": commonType = typeof(string); break;case "real": commonType = typeof(Single); break;case "smalldatetime": commonType = typeof(DateTime); break;case "smallint": commonType = typeof(short); break;case "smallmoney": commonType = typeof(decimal); break;case "sql_variant": commonType = typeof(object); break;case "sysname": commonType = typeof(object); break;case "text": commonType = typeof(string); break;case "time": commonType = typeof(TimeSpan); break;case "timestamp": commonType = typeof(byte[]); break;case "tinyint": commonType = typeof(byte); break;case "uniqueidentifier": commonType = typeof(Guid); break;case "varbinary": commonType = typeof(byte[]); break;case "varchar": commonType = typeof(string); break;case "xml": commonType = typeof(string); break;default: commonType = typeof(object); break;}return commonType;}//获取表结构public static List<TableColumn> GetTableColumns(string tableName){var columns =DapperHelper.GetList<TableColumn>(string.Format("select COLUMN_NAME,DATA_TYPE from INFORMATION_SCHEMA.COLUMNS t where t.TABLE_NAME = '{0}'",tableName), null);return columns;}/// <summary>/// 获取表数据/// </summary>/// <param name="tableName">数据表名称</param>/// <param name="lists">数据集合</param>/// <returns></returns>public static void BulkInsert<T>(string tableName, List<T> lists){var type = typeof (T);var fields = type.GetProperties();var columns = GetTableColumns(tableName);DataTable dt = new DataTable();foreach (var column in columns){dt.Columns.Add(new DataColumn(column.COLUMN_NAME, MapCommonType(column.DATA_TYPE)));}foreach (var l in lists){var row = dt.NewRow();foreach (var column in columns){var column1 = column;foreach (var field in fields.Where(field => String.Equals(column1.COLUMN_NAME, field.Name, StringComparison.CurrentCultureIgnoreCase))){row[column.COLUMN_NAME] = field.GetValue(l) ?? DBNull.Value;break;}}dt.Rows.Add(row);}BulkToDB(dt, tableName);}//批量插入数据public static void BulkToDB(DataTable dt, string tableName){SqlConnection con = DapperConnection.CreateCon(Temp_dbtype, Temp_dbConKey) as SqlConnection;SqlBulkCopy bulkCopy = new SqlBulkCopy(con);bulkCopy.DestinationTableName = tableName;bulkCopy.BatchSize = dt.Rows.Count;try{con.Open();if (dt != null && dt.Rows.Count != 0)bulkCopy.WriteToServer(dt);}catch (Exception ex){throw ex;}finally{con.Close();if (bulkCopy != null)bulkCopy.Close();}}#endregion
