在Discuz中，消息可以分為公用消息(管理后臺(tái) --> 其他 -->公共消息管理)如下：

另外還有批量短消息發(fā)送(用戶管理)：

復(fù)制代碼 代碼如下:

pmid:自遞增的id
msgfrom:發(fā)送者的用戶名，若為系統(tǒng)消息則為“系統(tǒng)”。
msgfromid:發(fā)送者的id
msgto:接收者的用戶名
msgtoid:接收者的id
folder: 0、收件箱,1、發(fā)件箱,2、草稿箱
new:是否是新消息，未讀，1；0已讀
subject:標(biāo)題
postdatetime:發(fā)送時(shí)間
message:消息內(nèi)容

復(fù)制代碼 代碼如下:

/// <summary>
/// 得到公共消息數(shù)量
/// </summary>
/// <returns>公共消息數(shù)量</returns>
public int GetAnnouncePrivateMessageCount()
{
return Utils.StrToInt(DbHelper.ExecuteScalar(CommandType.Text, "SELECT COUNT(pmid) FROM [" + BaseConfigs.GetTablePrefix + "pms] WHERE [msgtoid] = 0").ToString(), 0);
}


/// <summary>
/// 獲得指定用戶的短信息列表
/// </summary>
/// <param>每頁(yè)顯示短信息數(shù)</param>
/// <param>當(dāng)前要顯示的頁(yè)數(shù)</param>
/// <returns>短信息列表</returns>
public IDataReader GetAnnouncePrivateMessageList(int pagesize, int pageindex)
{
string sql = "";
if(pageindex <= 1)
{
sql = string.Format("SELECT TOP {0} * FROM [{1}pms] WHERE [msgtoid] = 0 ORDER BY [pmid] DESC", pagesize, BaseConfigs.GetTablePrefix);
}
else
{
sql = string.Format("SELECT TOP {0} * FROM [{1}pms] WHERE [msgtoid] = 0 AND [pmid] < (SELECT MIN([pmid]) FROM (SELECT TOP " + (pageindex - 1) * pagesize + " [pmid] FROM [{1}pms] WHERE [msgtoid] = 0 ORDER BY [pmid] DESC) AS tblTmp) ORDER BY [pmid] DESC", pagesize, BaseConfigs.GetTablePrefix);
}

IDataReader reader = DbHelper.ExecuteReader(CommandType.Text, sql);
return reader;
}

復(fù)制代碼 代碼如下:

PrivateMessageInfo privatemessageinfo = new PrivateMessageInfo();

string curdatetime = Utils.GetDateTime();
// 收件箱
privatemessageinfo.Message = config.Welcomemsgtxt;
privatemessageinfo.Subject = "歡迎您的加入! (請(qǐng)勿回復(fù)本信息)";
privatemessageinfo.Msgto = userinfo.Username;
privatemessageinfo.Msgtoid = uid;
privatemessageinfo.Msgfrom = PrivateMessages.SystemUserName;
privatemessageinfo.Msgfromid = 0;
privatemessageinfo.New = 1;
privatemessageinfo.Postdatetime = curdatetime;
privatemessageinfo.Folder = 0;
PrivateMessages.CreatePrivateMessage(privatemessageinfo, 0);

       執(zhí)行方法也是讓我感到奇怪，居然是：比如我選擇了乞丐，而乞丐這個(gè)等級(jí)有10萬(wàn)用戶，則取得這10W用戶的數(shù)據(jù)，一條條執(zhí)行插入。暴汗……這樣算法以及實(shí)現(xiàn)確實(shí)簡(jiǎn)單了很多，但會(huì)員一多，要經(jīng)常清理這些數(shù)據(jù)。這也是為什么我們看到discuz的論壇經(jīng)常一段時(shí)間需要清理短消息的原因。建議批量發(fā)送只對(duì)等級(jí)較高，數(shù)量較少的用戶使用。同時(shí)在使用過(guò)程中，不明白為什么在“批量短消息發(fā)送”中的“文件箱”有“收件箱”、“發(fā)件箱”、“草稿箱”3種，這里應(yīng)該只有“收件箱”比較合適，或者這里根本就不該出現(xiàn)這個(gè)“文件箱”。

批量發(fā)送的代碼如下：

復(fù)制代碼 代碼如下:

private void BatchSendSM_Click(object sender, EventArgs e)
{
#region 批量短消息發(fā)送

if (this.CheckCookie())
{
string groupidlist = Usergroups.GetSelectString(",");

if (groupidlist == "")
{
base.RegisterStartupScript( "", "<script>alert('請(qǐng)您先選取相關(guān)的用戶組,再點(diǎn)擊提交按鈕');</script>");
return;
}

int percount = 10; //每多少記錄為一次等待
int count = 0; //當(dāng)前記錄數(shù)
// GetUserNameListByGroupid為取得選中的用戶組的所有用戶的id和用戶名
foreach (DataRow dr in DatabaseProvider.GetInstance().GetUserNameListByGroupid(groupidlist).Rows)
{
DatabaseProvider.GetInstance().SendPMToUser(username.Replace("'", "''"), userid, dr["username"].ToString().Replace("'", "''"), Convert.ToInt32(dr["uid"].ToString()), int.Parse(folder.SelectedValue), subject.Text, Convert.ToDateTime(postdatetime.Text), message.Text);
if (count >= percount)
{
Thread.Sleep(3500);
count = 0;
}
count++;
}
base.RegisterStartupScript( "PAGE", "window.location.href='global_sendSMtogroup.aspx';");
}

#endregion
}

//SendPMToUser函數(shù)如下：
public void SendPMToUser(string msgfrom, int msgfromid, string msgto, int msgtoid, int folder, string subject, DateTime postdatetime, string message)
{
DbParameter[] parms =
{
DbHelper.MakeInParam("@msgfrom", (DbType)SqlDbType.NVarChar,50, msgfrom),
DbHelper.MakeInParam("@msgfromid", (DbType)SqlDbType.Int, 4, msgfromid),
DbHelper.MakeInParam("@msgto", (DbType)SqlDbType.NVarChar,50, msgto),
DbHelper.MakeInParam("@msgtoid", (DbType)SqlDbType.Int, 4, msgtoid),
DbHelper.MakeInParam("@folder", (DbType)SqlDbType.SmallInt, 2, folder),
DbHelper.MakeInParam("@subject", (DbType)SqlDbType.NVarChar,60, subject),
DbHelper.MakeInParam("@postdatetime", (DbType)SqlDbType.DateTime,8, postdatetime),
DbHelper.MakeInParam("@message",(DbType)SqlDbType.NText, 0,message)
};
string sql = "INSERT INTO [" + BaseConfigs.GetTablePrefix + "pms] (msgfrom,msgfromid,msgto,msgtoid,folder,new,subject,postdatetime,message) " +
"VALUES (@msgfrom,@msgfromid,@msgto,@msgtoid,@folder,1,@subject,@postdatetime,@message)";
DbHelper.ExecuteNonQuery(CommandType.Text, sql, parms);
sql = "UPDATE [" + BaseConfigs.GetTablePrefix + "users] SET [newpmcount]=[newpmcount]+1 WHERE [uid] =@msgtoid";
DbHelper.ExecuteNonQuery(CommandType.Text, sql, parms);
}