/** 版本信息模板在安装目录下,可自行修改。 * device_data.cs * * 功 能: N/A * 类 名: device_data * * Ver 变更日期 负责人 变更内容 * ─────────────────────────────────── * V0.01 2024/1/4 16:13:39 N/A 初版 * * Copyright (c) 2012 Maticsoft Corporation. All rights reserved. *┌──────────────────────────────────┐ *│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ *│ 版权所有:动软卓越(北京)科技有限公司              │ *└──────────────────────────────────┘ */ using System; using System.Data; using System.Text; using MySql.Data.MySqlClient; using Maticsoft.DBUtility;//Please add references namespace DataServer.DAL { /// /// 数据访问类:device_data /// public partial class device_data { public device_data() {} #region BasicMethod /// /// 是否存在该记录 /// public bool Exists(string DeviceId) { StringBuilder strSql=new StringBuilder(); strSql.Append("select count(1) from device_data"); strSql.Append(" where DeviceId=@DeviceId "); MySqlParameter[] parameters = { new MySqlParameter("@DeviceId", MySqlDbType.VarChar,255) }; parameters[0].Value = DeviceId; return DbHelperMySQL.Exists(strSql.ToString(),parameters); } /// /// 增加一条数据 /// public bool Add(DataServer.Model.device_data model) { StringBuilder strSql=new StringBuilder(); strSql.Append("insert into device_data("); strSql.Append("DeviceId,DeviceNumber,FloorName,DeviceName,EH,P,Kvar,Ia,Ib,Ic,Ua,Ub,Uc,CreateTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5)"); strSql.Append(" values ("); strSql.Append("@DeviceId,@DeviceNumber,@FloorName,@DeviceName,@EH,@P,@Kvar,@Ia,@Ib,@Ic,@Ua,@Ub,@Uc,@CreateTime,@Reserve1,@Reserve2,@Reserve3,@Reserve4,@Reserve5)"); MySqlParameter[] parameters = { new MySqlParameter("@DeviceId", MySqlDbType.VarChar,255), new MySqlParameter("@DeviceNumber", MySqlDbType.VarChar,255), new MySqlParameter("@FloorName", MySqlDbType.VarChar,255), new MySqlParameter("@DeviceName", MySqlDbType.VarChar,255), new MySqlParameter("@EH", MySqlDbType.Float,255), new MySqlParameter("@P", MySqlDbType.Float,255), new MySqlParameter("@Kvar", MySqlDbType.Float,255), new MySqlParameter("@Ia", MySqlDbType.Float,255), new MySqlParameter("@Ib", MySqlDbType.Float,255), new MySqlParameter("@Ic", MySqlDbType.Float,255), new MySqlParameter("@Ua", MySqlDbType.Float,255), new MySqlParameter("@Ub", MySqlDbType.Float,255), new MySqlParameter("@Uc", MySqlDbType.Float,255), new MySqlParameter("@CreateTime", MySqlDbType.DateTime), new MySqlParameter("@Reserve1", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve2", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve3", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve4", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve5", MySqlDbType.VarChar,255)}; parameters[0].Value = model.DeviceId; parameters[1].Value = model.DeviceNumber; parameters[2].Value = model.FloorName; parameters[3].Value = model.DeviceName; parameters[4].Value = model.EH; parameters[5].Value = model.P; parameters[6].Value = model.Kvar; parameters[7].Value = model.Ia; parameters[8].Value = model.Ib; parameters[9].Value = model.Ic; parameters[10].Value = model.Ua; parameters[11].Value = model.Ub; parameters[12].Value = model.Uc; parameters[13].Value = model.CreateTime; parameters[14].Value = model.Reserve1; parameters[15].Value = model.Reserve2; parameters[16].Value = model.Reserve3; parameters[17].Value = model.Reserve4; parameters[18].Value = model.Reserve5; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 更新一条数据 /// public bool Update(DataServer.Model.device_data model) { StringBuilder strSql=new StringBuilder(); strSql.Append("update device_data set "); strSql.Append("DeviceNumber=@DeviceNumber,"); strSql.Append("FloorName=@FloorName,"); strSql.Append("DeviceName=@DeviceName,"); strSql.Append("EH=@EH,"); strSql.Append("P=@P,"); strSql.Append("Kvar=@Kvar,"); strSql.Append("Ia=@Ia,"); strSql.Append("Ib=@Ib,"); strSql.Append("Ic=@Ic,"); strSql.Append("Ua=@Ua,"); strSql.Append("Ub=@Ub,"); strSql.Append("Uc=@Uc,"); strSql.Append("CreateTime=@CreateTime,"); strSql.Append("Reserve1=@Reserve1,"); strSql.Append("Reserve2=@Reserve2,"); strSql.Append("Reserve3=@Reserve3,"); strSql.Append("Reserve4=@Reserve4,"); strSql.Append("Reserve5=@Reserve5"); strSql.Append(" where DeviceId=@DeviceId "); MySqlParameter[] parameters = { new MySqlParameter("@DeviceNumber", MySqlDbType.VarChar,255), new MySqlParameter("@FloorName", MySqlDbType.VarChar,255), new MySqlParameter("@DeviceName", MySqlDbType.VarChar,255), new MySqlParameter("@EH", MySqlDbType.Float,255), new MySqlParameter("@P", MySqlDbType.Float,255), new MySqlParameter("@Kvar", MySqlDbType.Float,255), new MySqlParameter("@Ia", MySqlDbType.Float,255), new MySqlParameter("@Ib", MySqlDbType.Float,255), new MySqlParameter("@Ic", MySqlDbType.Float,255), new MySqlParameter("@Ua", MySqlDbType.Float,255), new MySqlParameter("@Ub", MySqlDbType.Float,255), new MySqlParameter("@Uc", MySqlDbType.Float,255), new MySqlParameter("@CreateTime", MySqlDbType.DateTime), new MySqlParameter("@Reserve1", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve2", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve3", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve4", MySqlDbType.VarChar,255), new MySqlParameter("@Reserve5", MySqlDbType.VarChar,255), new MySqlParameter("@DeviceId", MySqlDbType.VarChar,255)}; parameters[0].Value = model.DeviceNumber; parameters[1].Value = model.FloorName; parameters[2].Value = model.DeviceName; parameters[3].Value = model.EH; parameters[4].Value = model.P; parameters[5].Value = model.Kvar; parameters[6].Value = model.Ia; parameters[7].Value = model.Ib; parameters[8].Value = model.Ic; parameters[9].Value = model.Ua; parameters[10].Value = model.Ub; parameters[11].Value = model.Uc; parameters[12].Value = model.CreateTime; parameters[13].Value = model.Reserve1; parameters[14].Value = model.Reserve2; parameters[15].Value = model.Reserve3; parameters[16].Value = model.Reserve4; parameters[17].Value = model.Reserve5; parameters[18].Value = model.DeviceId; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(string DeviceId) { StringBuilder strSql=new StringBuilder(); strSql.Append("delete from device_data "); strSql.Append(" where DeviceId=@DeviceId "); MySqlParameter[] parameters = { new MySqlParameter("@DeviceId", MySqlDbType.VarChar,255) }; parameters[0].Value = DeviceId; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string DeviceIdlist ) { StringBuilder strSql=new StringBuilder(); strSql.Append("delete from device_data "); strSql.Append(" where DeviceId in ("+DeviceIdlist + ") "); int rows=DbHelperMySQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public DataServer.Model.device_data GetModel(string DeviceId) { StringBuilder strSql=new StringBuilder(); strSql.Append("select DeviceId,DeviceNumber,FloorName,DeviceName,EH,P,Kvar,Ia,Ib,Ic,Ua,Ub,Uc,CreateTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 from device_data "); strSql.Append(" where DeviceId=@DeviceId "); MySqlParameter[] parameters = { new MySqlParameter("@DeviceId", MySqlDbType.VarChar,255) }; parameters[0].Value = DeviceId; DataServer.Model.device_data model=new DataServer.Model.device_data(); DataSet ds=DbHelperMySQL.Query(strSql.ToString(),parameters); if(ds.Tables[0].Rows.Count>0) { return DataRowToModel(ds.Tables[0].Rows[0]); } else { return null; } } /// /// 得到一个对象实体 /// public DataServer.Model.device_data DataRowToModel(DataRow row) { DataServer.Model.device_data model=new DataServer.Model.device_data(); if (row != null) { if(row["DeviceId"]!=null) { model.DeviceId=row["DeviceId"].ToString(); } if(row["DeviceNumber"]!=null) { model.DeviceNumber=row["DeviceNumber"].ToString(); } if(row["FloorName"]!=null) { model.FloorName=row["FloorName"].ToString(); } if(row["DeviceName"]!=null) { model.DeviceName=row["DeviceName"].ToString(); } if(row["EH"]!=null && row["EH"].ToString()!="") { model.EH=decimal.Parse(row["EH"].ToString()); } if(row["P"]!=null && row["P"].ToString()!="") { model.P=decimal.Parse(row["P"].ToString()); } if(row["Kvar"]!=null && row["Kvar"].ToString()!="") { model.Kvar=decimal.Parse(row["Kvar"].ToString()); } if(row["Ia"]!=null && row["Ia"].ToString()!="") { model.Ia=decimal.Parse(row["Ia"].ToString()); } if(row["Ib"]!=null && row["Ib"].ToString()!="") { model.Ib=decimal.Parse(row["Ib"].ToString()); } if(row["Ic"]!=null && row["Ic"].ToString()!="") { model.Ic=decimal.Parse(row["Ic"].ToString()); } if(row["Ua"]!=null && row["Ua"].ToString()!="") { model.Ua=decimal.Parse(row["Ua"].ToString()); } if(row["Ub"]!=null && row["Ub"].ToString()!="") { model.Ub=decimal.Parse(row["Ub"].ToString()); } if(row["Uc"]!=null && row["Uc"].ToString()!="") { model.Uc=decimal.Parse(row["Uc"].ToString()); } if(row["CreateTime"]!=null && row["CreateTime"].ToString()!="") { model.CreateTime=DateTime.Parse(row["CreateTime"].ToString()); } if(row["Reserve1"]!=null) { model.Reserve1=row["Reserve1"].ToString(); } if(row["Reserve2"]!=null) { model.Reserve2=row["Reserve2"].ToString(); } if(row["Reserve3"]!=null) { model.Reserve3=row["Reserve3"].ToString(); } if(row["Reserve4"]!=null) { model.Reserve4=row["Reserve4"].ToString(); } if(row["Reserve5"]!=null) { model.Reserve5=row["Reserve5"].ToString(); } } return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql=new StringBuilder(); strSql.Append("select DeviceId,DeviceNumber,FloorName,DeviceName,EH,P,Kvar,Ia,Ib,Ic,Ua,Ub,Uc,CreateTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 "); strSql.Append(" FROM device_data "); if(strWhere.Trim()!="") { strSql.Append(" where "+strWhere); } return DbHelperMySQL.Query(strSql.ToString()); } /// /// 获取记录总数 /// public int GetRecordCount(string strWhere) { StringBuilder strSql=new StringBuilder(); strSql.Append("select count(1) FROM device_data "); if(strWhere.Trim()!="") { strSql.Append(" where "+strWhere); } object obj = DbHelperSQL.GetSingle(strSql.ToString()); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 分页获取数据列表 /// public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) { StringBuilder strSql=new StringBuilder(); strSql.Append("SELECT * FROM ( "); strSql.Append(" SELECT ROW_NUMBER() OVER ("); if (!string.IsNullOrEmpty(orderby.Trim())) { strSql.Append("order by T." + orderby ); } else { strSql.Append("order by T.DeviceId desc"); } strSql.Append(")AS Row, T.* from device_data T "); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSql.Append(" WHERE " + strWhere); } strSql.Append(" ) TT"); strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex); return DbHelperMySQL.Query(strSql.ToString()); } /* /// /// 分页获取数据列表 /// public DataSet GetList(int PageSize,int PageIndex,string strWhere) { MySqlParameter[] parameters = { new MySqlParameter("@tblName", MySqlDbType.VarChar, 255), new MySqlParameter("@fldName", MySqlDbType.VarChar, 255), new MySqlParameter("@PageSize", MySqlDbType.Int32), new MySqlParameter("@PageIndex", MySqlDbType.Int32), new MySqlParameter("@IsReCount", MySqlDbType.Bit), new MySqlParameter("@OrderType", MySqlDbType.Bit), new MySqlParameter("@strWhere", MySqlDbType.VarChar,1000), }; parameters[0].Value = "device_data"; parameters[1].Value = "DeviceId"; parameters[2].Value = PageSize; parameters[3].Value = PageIndex; parameters[4].Value = 0; parameters[5].Value = 0; parameters[6].Value = strWhere; return DbHelperMySQL.RunProcedure("UP_GetRecordByPage",parameters,"ds"); }*/ #endregion BasicMethod #region ExtensionMethod #endregion ExtensionMethod } }