83 lines
3.4 KiB
C#
83 lines
3.4 KiB
C#
|
using Longbow;
|
|||
|
|
using Longbow.Caching;
|
|||
|
|
using Longbow.Caching.Configuration;
|
|||
|
|
using Longbow.ExceptionManagement;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.Data.Common;
|
|||
|
|
|
|||
|
|
namespace Bootstrap.DataAccess
|
|||
|
|
{
|
|||
|
|
public class NotificationHelper
|
|||
|
|
{
|
|||
|
|
internal const string RetrieveNotifyDataKey = "NotificationHelper-RetrieveNotifications";
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 新用户注册的通知的面板显示
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public static IEnumerable<Notification> RetrieveNotifications(string category = null)
|
|||
|
|
{
|
|||
|
|
return CacheManager.GetOrAdd(RetrieveNotifyDataKey, CacheSection.RetrieveIntervalByKey(RetrieveNotifyDataKey), key =>
|
|||
|
|
{
|
|||
|
|
string sql = "select * from Notifications where Category=@Category";
|
|||
|
|
List<Notification> notifications = new List<Notification>();
|
|||
|
|
DbCommand cmd = DBAccessManager.SqlDBAccess.CreateCommand(CommandType.Text, sql);
|
|||
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@Category", Convert.ToInt32(category), ParameterDirection.Input));
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
using (DbDataReader reader = DBAccessManager.SqlDBAccess.ExecuteReader(cmd))
|
|||
|
|
{
|
|||
|
|
while (reader.Read())
|
|||
|
|
{
|
|||
|
|
notifications.Add(new Notification()
|
|||
|
|
{
|
|||
|
|
ID = (int)reader[0],
|
|||
|
|
Category = (string)reader[1],
|
|||
|
|
Title = (string)reader[2],
|
|||
|
|
Content = (string)reader[3],
|
|||
|
|
RegisterTime = (DateTime)reader[4],
|
|||
|
|
ProcessTime = LgbConvert.ReadValue(reader[5], DateTime.MinValue),
|
|||
|
|
ProcessBy = LgbConvert.ReadValue(reader[6], string.Empty),
|
|||
|
|
ProcessResult = LgbConvert.ReadValue(reader[7], string.Empty),
|
|||
|
|
Status = (string)reader[8]
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex) { ExceptionManager.Publish(ex); }
|
|||
|
|
return notifications;
|
|||
|
|
|
|||
|
|
}, CacheSection.RetrieveDescByKey(RetrieveNotifyDataKey));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 点击某一行用户注册通知的处理成功操作
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public static bool ProcessRegisterUser(string id)
|
|||
|
|
{
|
|||
|
|
bool ret = false;
|
|||
|
|
if (string.IsNullOrEmpty(id)) return ret;
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
using (DbCommand cmd = DBAccessManager.SqlDBAccess.CreateCommand(CommandType.StoredProcedure, "Proc_ProcessRegisterUser"))
|
|||
|
|
{
|
|||
|
|
cmd.Parameters.Add(DBAccessManager.SqlDBAccess.CreateParameter("@id", Convert.ToInt32(id), ParameterDirection.Input));
|
|||
|
|
DBAccessManager.SqlDBAccess.ExecuteNonQuery(cmd);
|
|||
|
|
}
|
|||
|
|
CacheCleanUtility.ClearCache(notifyIds: id);
|
|||
|
|
ret = true;
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
ExceptionManager.Publish(ex);
|
|||
|
|
}
|
|||
|
|
return ret;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|