using System;
using System.Data;
using System.Text;
using System.Data.SqlClient;
using ZWL.DBUtility;//请先添加引用
namespace ZWL.BLL
{
///
/// 类ERPTalkInfo。
///
public class ERPTalkInfo
{
public ERPTalkInfo()
{ }
#region Model
private int _id;
private string _talkroomname;
private string _username;
private string _touser;
private DateTime? _timestr;
private string _contentstr;
///
///
///
public int ID
{
set { _id = value; }
get { return _id; }
}
///
/// 聊天室名称
///
public string TalkRoomName
{
set { _talkroomname = value; }
get { return _talkroomname; }
}
///
/// 发信息人
///
public string UserName
{
set { _username = value; }
get { return _username; }
}
///
/// 收信息人
///
public string ToUser
{
set { _touser = value; }
get { return _touser; }
}
///
/// 发布时间
///
public DateTime? TimeStr
{
set { _timestr = value; }
get { return _timestr; }
}
///
///
///
public string ContentStr
{
set { _contentstr = value; }
get { return _contentstr; }
}
#endregion Model
#region 成员方法
///
/// 是否存在该记录
///
public bool Exists(int ID)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select count(1) from ERPTalkInfo");
strSql.Append(" where ID=" + ID + " ");
SqlParameter[] parameters = {
new SqlParameter("@ID", SqlDbType.Int,4) };
parameters[0].Value = ID;
return DbHelperSQL.Exists(strSql.ToString(), parameters);
}
///
/// 增加一条数据
///
public int Add()
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into ERPTalkInfo(");
strSql.Append("TalkRoomName,UserName,ToUser,TimeStr,ContentStr)");
strSql.Append(" values (");
strSql.Append("@TalkRoomName,@UserName,@ToUser,@TimeStr,@ContentStr)");
strSql.Append(";select @@IDENTITY");
SqlParameter[] parameters = {
new SqlParameter("@TalkRoomName", SqlDbType.VarChar,500),
new SqlParameter("@UserName", SqlDbType.VarChar,50),
new SqlParameter("@ToUser", SqlDbType.VarChar,50),
new SqlParameter("@TimeStr", SqlDbType.DateTime),
new SqlParameter("@ContentStr", SqlDbType.VarChar,8000)};
parameters[0].Value = TalkRoomName;
parameters[1].Value = UserName;
parameters[2].Value = ToUser;
parameters[3].Value = TimeStr;
parameters[4].Value = ContentStr;
object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
if (obj == null)
{
return 1;
}
else
{
return Convert.ToInt32(obj);
}
}
///
/// 更新一条数据
///
public void Update()
{
StringBuilder strSql = new StringBuilder();
strSql.Append("update ERPTalkInfo set ");
strSql.Append("TalkRoomName=@TalkRoomName,");
strSql.Append("UserName=@UserName,");
strSql.Append("ToUser=@ToUser,");
strSql.Append("TimeStr=@TimeStr,");
strSql.Append("ContentStr=@ContentStr");
strSql.Append(" where ID=" + ID + " ");
SqlParameter[] parameters = {
new SqlParameter("@ID", SqlDbType.Int,4),
new SqlParameter("@TalkRoomName", SqlDbType.VarChar,500),
new SqlParameter("@UserName", SqlDbType.VarChar,50),
new SqlParameter("@ToUser", SqlDbType.VarChar,50),
new SqlParameter("@TimeStr", SqlDbType.DateTime),
new SqlParameter("@ContentStr", SqlDbType.VarChar,8000)};
parameters[0].Value = ID;
parameters[1].Value = TalkRoomName;
parameters[2].Value = UserName;
parameters[3].Value = ToUser;
parameters[4].Value = TimeStr;
parameters[5].Value = ContentStr;
DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
}
///
/// 删除一条数据
///
public void Delete(int ID)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete ERPTalkInfo ");
strSql.Append(" where ID=" + ID + " ");
SqlParameter[] parameters = {
new SqlParameter("@ID", SqlDbType.Int,4) };
parameters[0].Value = ID;
DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
}
///
/// 得到一个对象实体
///
public void GetModel(int ID)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select ID,TalkRoomName,UserName,ToUser,TimeStr,ContentStr ");
strSql.Append(" FROM ERPTalkInfo ");
strSql.Append(" where ID=" + ID + " ");
SqlParameter[] parameters = {
new SqlParameter("@ID", SqlDbType.Int,4) };
parameters[0].Value = ID;
DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
if (ds.Tables[0].Rows.Count > 0)
{
if (ds.Tables[0].Rows[0]["ID"].ToString() != "")
{
ID = int.Parse(ds.Tables[0].Rows[0]["ID"].ToString());
}
TalkRoomName = ds.Tables[0].Rows[0]["TalkRoomName"].ToString();
UserName = ds.Tables[0].Rows[0]["UserName"].ToString();
ToUser = ds.Tables[0].Rows[0]["ToUser"].ToString();
if (ds.Tables[0].Rows[0]["TimeStr"].ToString() != "")
{
TimeStr = DateTime.Parse(ds.Tables[0].Rows[0]["TimeStr"].ToString());
}
ContentStr = ds.Tables[0].Rows[0]["ContentStr"].ToString();
}
}
///
/// 获得数据列表
///
public DataSet GetList(string strWhere)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select [ID],[TalkRoomName],[UserName],[ToUser],[TimeStr],[ContentStr] ");
strSql.Append(" FROM ERPTalkInfo ");
if (strWhere.Trim() != "")
{
strSql.Append(" where " + strWhere);
}
return DbHelperSQL.Query(strSql.ToString());
}
#endregion 成员方法
}
}