📄 messagetouserservice.cs
字号:
//============================================================
// Producnt name: BoBoARTS.CodeMad
// Version: 1.0
// Coded by: Shen Bo (bo.shen@jb-aptech.com.cn)
// Auto generated at: 2008-9-18 16:23:26
// Dowload from:http://www.51aspx.com/CV/AccpOffice
//============================================================
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Office.Model;
namespace Office.DAL
{
public static partial class MessageToUserService
{
/// <summary>
///
/// </summary>
/// <param name="messageToUser"></param>
/// <returns></returns>
public static MessageToUser AddMessageToUser(MessageToUser messageToUser)
{
string sql =
"INSERT MessageToUser (MessageId, ToUserId, IfRead)" +
"VALUES (@MessageId, @ToUserId, @IfRead)";
sql += " ; SELECT @@IDENTITY";
try
{
SqlParameter[] para = new SqlParameter[]
{
new SqlParameter("@MessageId", messageToUser.MessageId), //FK
new SqlParameter("@ToUserId", messageToUser.ToUserId),
new SqlParameter("@IfRead", messageToUser.IfRead)
};
int newId = DBHelper.GetScalar(sql, para);
return GetMessageToUserById(newId);
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <param name="messageToUser"></param>
public static void DeleteMessageToUser(MessageToUser messageToUser)
{
DeleteMessageToUserById( messageToUser.Id );
}
/// <summary>
///
/// </summary>
/// <param name="id"></param>
public static void DeleteMessageToUserById(int id)
{
string sql = "DELETE MessageToUser WHERE Id = @Id";
try
{
SqlParameter[] para = new SqlParameter[]
{
new SqlParameter("@Id", id)
};
DBHelper.ExecuteCommand(sql, para);
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <returns></returns>
public static void DeleteMessageToUserByMessageId(int id)
{
string sql = "DELETE MessageToUser WHERE MessageId = @Id";
try
{
SqlParameter[] para = new SqlParameter[]
{
new SqlParameter("@Id", id)
};
DBHelper.ExecuteCommand(sql, para);
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <returns></returns>
public static Boolean DeleteMessageToUserMessageIds(String messageIds)
{
string sql = "DELETE MessageToUser WHERE MessageId in (" + messageIds + ")";
try
{
DBHelper.ExecuteCommand(sql);
return true;
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
return false;
}
/// <summary>
///
/// </summary>
/// <param name="messageToUser"></param>
public static void ModifyMessageToUser(MessageToUser messageToUser)
{
string sql =
"UPDATE MessageToUser " +
"SET " +
"MessageId = @MessageId, " + //FK
"ToUserId = @ToUserId, " +
"IfRead = @IfRead " +
"WHERE Id = @Id";
try
{
SqlParameter[] para = new SqlParameter[]
{
new SqlParameter("@Id", messageToUser.Id),
new SqlParameter("@MessageId", messageToUser.MessageId), //FK
new SqlParameter("@ToUserId", messageToUser.ToUserId),
new SqlParameter("@IfRead", messageToUser.IfRead)
};
DBHelper.ExecuteCommand(sql, para);
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <returns></returns>
public static IList<MessageToUser> GetAllMessage()
{
string sqlAll = "SELECT * FROM MessageToUser";
return GetMessageToUsersBySql( sqlAll );
}
/// <summary>
///
/// </summary>
/// <returns></returns>
public static IList<MessageToUser> GetAllMessageToUsers(string UserId)
{
string sqlAll = "SELECT * FROM MessageToUser where ToUserId='" + UserId + "'";
return GetMessageToUsersBySql(sqlAll);
}
/// <summary>
///
/// </summary>
/// <param name="id"></param>
/// <returns></returns>
public static MessageToUser GetMessageToUserById(int id)
{
string sql = "SELECT * FROM MessageToUser WHERE Id = @Id";
int messageId;
try
{
SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@Id", id));
if (reader.Read())
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = (int)reader["Id"];
messageToUser.ToUserId = (string)reader["ToUserId"];
messageToUser.IfRead = (int)reader["IfRead"];
messageId = (int)reader["MessageId"]; //FK
reader.Close();
//messageToUser.Message = MessageService.GetMessageByMessageId(messageId);
return messageToUser;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
public static MessageToUser GetMessageToUserByMessageId(int MessageId)
{
string sql = "SELECT * FROM MessageToUser WHERE MessageId = @MessageId";
try
{
SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@MessageId", MessageId));
if (reader.Read())
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = reader.GetInt32(0);
messageToUser.MessageId = reader.GetInt32(1);
messageToUser.ToUserId = reader.GetString(2);
messageToUser.IfRead = reader.GetInt32(3);
reader.Close();
return messageToUser;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <param name="safeSql"></param>
/// <returns></returns>
private static IList<MessageToUser> GetMessageToUsersBySql( string safeSql )
{
List<MessageToUser> list = new List<MessageToUser>();
try
{
DataTable table = DBHelper.GetDataSet( safeSql );
foreach (DataRow row in table.Rows)
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = (int)row["Id"];
messageToUser.ToUserId = (string)row["ToUserId"];
messageToUser.IfRead = (int)row["IfRead"];
messageToUser.MessageId = (int)row["MessageId"];
// messageToUser.Message = MessageService.GetMessageByMessageId((int)row["MessageId"]); //FK
list.Add(messageToUser);
}
return list;
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
/// <summary>
///
/// </summary>
/// <param name="sql"></param>
/// <param name="values"></param>
/// <returns></returns>
private static IList<MessageToUser> GetMessageToUsersBySql( string sql, params SqlParameter[] values )
{
List<MessageToUser> list = new List<MessageToUser>();
try
{
DataTable table = DBHelper.GetDataSet( sql, values );
foreach (DataRow row in table.Rows)
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = (int)row["Id"];
messageToUser.MessageId = (int)row["MessageId"];
messageToUser.ToUserId = (string)row["ToUserId"];
messageToUser.IfRead = (int)row["IfRead"];
list.Add(messageToUser);
}
return list;
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
public static List<MessageToUser> GetMessageToUser(int MessageId)
{
string sql = "SELECT * FROM MessageToUser WHERE MessageId = @MessageId";
List<MessageToUser> touser = new List<MessageToUser>();
try
{
SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@MessageId", MessageId));
if (reader.HasRows)
{
while (reader.Read())
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = reader.GetInt32(0);
messageToUser.MessageId = reader.GetInt32(1);
messageToUser.ToUserId = reader.GetString(2);
messageToUser.IfRead = reader.GetInt32(3);
touser.Add(messageToUser);
}
reader.Close();
return touser;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
public static List<MessageToUser> GetMessageToUser(string touserid)
{
string sql = "SELECT * FROM MessageToUser WHERE ToUserId = @Id";
List<MessageToUser> touser = new List<MessageToUser>();
try
{
SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@Id", touserid));
if (reader.HasRows)
{
while (reader.Read())
{
MessageToUser messageToUser = new MessageToUser();
messageToUser.Id = reader.GetInt32(0);
messageToUser.MessageId = reader.GetInt32(1);
messageToUser.ToUserId = reader.GetString(2);
messageToUser.IfRead = reader.GetInt32(3);
touser.Add(messageToUser);
}
reader.Close();
return touser;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -