diff --git a/DataServer/BLL/gas_data.cs b/DataServer/BLL/gas_data.cs new file mode 100644 index 0000000..2f14e41 --- /dev/null +++ b/DataServer/BLL/gas_data.cs @@ -0,0 +1,179 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* gas_data.cs +* +* 功 能: N/A +* 类 名: gas_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:05:57 N/A 初版 +* +* Copyright (c) 2012 Maticsoft Corporation. All rights reserved. +*┌──────────────────────────────────┐ +*│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ +*│ 版权所有:动软卓越(北京)科技有限公司              │ +*└──────────────────────────────────┘ +*/ +using System; +using System.Data; +using System.Collections.Generic; +using Maticsoft.Common; +using DataServer.Model; +namespace DataServer.BLL +{ + /// + /// gas_data + /// + public partial class gas_data + { + private readonly DataServer.DAL.gas_data dal=new DataServer.DAL.gas_data(); + public gas_data() + {} + #region BasicMethod + /// + /// 是否存在该记录 + /// + public bool Exists(string GasId) + { + return dal.Exists(GasId); + } + + /// + /// 增加一条数据 + /// + public bool Add(DataServer.Model.gas_data model) + { + return dal.Add(model); + } + + /// + /// 更新一条数据 + /// + public bool Update(DataServer.Model.gas_data model) + { + return dal.Update(model); + } + + /// + /// 删除一条数据 + /// + public bool Delete(string GasId) + { + + return dal.Delete(GasId); + } + /// + /// 删除一条数据 + /// + public bool DeleteList(string GasIdlist ) + { + return dal.DeleteList(GasIdlist ); + } + + /// + /// 得到一个对象实体 + /// + public DataServer.Model.gas_data GetModel(string GasId) + { + + return dal.GetModel(GasId); + } + + /// + /// 得到一个对象实体,从缓存中 + /// + public DataServer.Model.gas_data GetModelByCache(string GasId) + { + + string CacheKey = "gas_dataModel-" + GasId; + object objModel = Maticsoft.Common.DataCache.GetCache(CacheKey); + if (objModel == null) + { + try + { + objModel = dal.GetModel(GasId); + if (objModel != null) + { + int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache"); + Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero); + } + } + catch{} + } + return (DataServer.Model.gas_data)objModel; + } + + /// + /// 获得数据列表 + /// + public DataSet GetList(string strWhere) + { + return dal.GetList(strWhere); + } + /// + /// 获得数据列表 + /// + public List GetModelList(string strWhere) + { + DataSet ds = dal.GetList(strWhere); + return DataTableToList(ds.Tables[0]); + } + /// + /// 获得数据列表 + /// + public List DataTableToList(DataTable dt) + { + List modelList = new List(); + int rowsCount = dt.Rows.Count; + if (rowsCount > 0) + { + DataServer.Model.gas_data model; + for (int n = 0; n < rowsCount; n++) + { + model = dal.DataRowToModel(dt.Rows[n]); + if (model != null) + { + modelList.Add(model); + } + } + } + return modelList; + } + + /// + /// 获得数据列表 + /// + public DataSet GetAllList() + { + return GetList(""); + } + + /// + /// 分页获取数据列表 + /// + public int GetRecordCount(string strWhere) + { + return dal.GetRecordCount(strWhere); + } + /// + /// 分页获取数据列表 + /// + public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) + { + return dal.GetListByPage( strWhere, orderby, startIndex, endIndex); + } + /// + /// 分页获取数据列表 + /// + //public DataSet GetList(int PageSize,int PageIndex,string strWhere) + //{ + //return dal.GetList(PageSize,PageIndex,strWhere); + //} + + #endregion BasicMethod + #region ExtensionMethod + + #endregion ExtensionMethod + } +} + diff --git a/DataServer/BLL/water_data.cs b/DataServer/BLL/water_data.cs new file mode 100644 index 0000000..5446d31 --- /dev/null +++ b/DataServer/BLL/water_data.cs @@ -0,0 +1,179 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* water_data.cs +* +* 功 能: N/A +* 类 名: water_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:04:57 N/A 初版 +* +* Copyright (c) 2012 Maticsoft Corporation. All rights reserved. +*┌──────────────────────────────────┐ +*│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ +*│ 版权所有:动软卓越(北京)科技有限公司              │ +*└──────────────────────────────────┘ +*/ +using System; +using System.Data; +using System.Collections.Generic; +using Maticsoft.Common; +using DataServer.Model; +namespace DataServer.BLL +{ + /// + /// water_data + /// + public partial class water_data + { + private readonly DataServer.DAL.water_data dal=new DataServer.DAL.water_data(); + public water_data() + {} + #region BasicMethod + /// + /// 是否存在该记录 + /// + public bool Exists(string WaterId) + { + return dal.Exists(WaterId); + } + + /// + /// 增加一条数据 + /// + public bool Add(DataServer.Model.water_data model) + { + return dal.Add(model); + } + + /// + /// 更新一条数据 + /// + public bool Update(DataServer.Model.water_data model) + { + return dal.Update(model); + } + + /// + /// 删除一条数据 + /// + public bool Delete(string WaterId) + { + + return dal.Delete(WaterId); + } + /// + /// 删除一条数据 + /// + public bool DeleteList(string WaterIdlist ) + { + return dal.DeleteList(WaterIdlist ); + } + + /// + /// 得到一个对象实体 + /// + public DataServer.Model.water_data GetModel(string WaterId) + { + + return dal.GetModel(WaterId); + } + + /// + /// 得到一个对象实体,从缓存中 + /// + public DataServer.Model.water_data GetModelByCache(string WaterId) + { + + string CacheKey = "water_dataModel-" + WaterId; + object objModel = Maticsoft.Common.DataCache.GetCache(CacheKey); + if (objModel == null) + { + try + { + objModel = dal.GetModel(WaterId); + if (objModel != null) + { + int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache"); + Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero); + } + } + catch{} + } + return (DataServer.Model.water_data)objModel; + } + + /// + /// 获得数据列表 + /// + public DataSet GetList(string strWhere) + { + return dal.GetList(strWhere); + } + /// + /// 获得数据列表 + /// + public List GetModelList(string strWhere) + { + DataSet ds = dal.GetList(strWhere); + return DataTableToList(ds.Tables[0]); + } + /// + /// 获得数据列表 + /// + public List DataTableToList(DataTable dt) + { + List modelList = new List(); + int rowsCount = dt.Rows.Count; + if (rowsCount > 0) + { + DataServer.Model.water_data model; + for (int n = 0; n < rowsCount; n++) + { + model = dal.DataRowToModel(dt.Rows[n]); + if (model != null) + { + modelList.Add(model); + } + } + } + return modelList; + } + + /// + /// 获得数据列表 + /// + public DataSet GetAllList() + { + return GetList(""); + } + + /// + /// 分页获取数据列表 + /// + public int GetRecordCount(string strWhere) + { + return dal.GetRecordCount(strWhere); + } + /// + /// 分页获取数据列表 + /// + public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex) + { + return dal.GetListByPage( strWhere, orderby, startIndex, endIndex); + } + /// + /// 分页获取数据列表 + /// + //public DataSet GetList(int PageSize,int PageIndex,string strWhere) + //{ + //return dal.GetList(PageSize,PageIndex,strWhere); + //} + + #endregion BasicMethod + #region ExtensionMethod + + #endregion ExtensionMethod + } +} + diff --git a/DataServer/DAL/gas_data.cs b/DataServer/DAL/gas_data.cs new file mode 100644 index 0000000..fb021d8 --- /dev/null +++ b/DataServer/DAL/gas_data.cs @@ -0,0 +1,364 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* gas_data.cs +* +* 功 能: N/A +* 类 名: gas_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:05:57 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 +{ + /// + /// 数据访问类:gas_data + /// + public partial class gas_data + { + public gas_data() + {} + #region BasicMethod + + /// + /// 是否存在该记录 + /// + public bool Exists(string GasId) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("select count(1) from gas_data"); + strSql.Append(" where GasId=@GasId "); + MySqlParameter[] parameters = { + new MySqlParameter("@GasId", MySqlDbType.VarChar,255) }; + parameters[0].Value = GasId; + + return DbHelperMySQL.Exists(strSql.ToString(),parameters); + } + + + /// + /// 增加一条数据 + /// + public bool Add(DataServer.Model.gas_data model) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("insert into gas_data("); + strSql.Append("GasId,GasNumber,GasName,GasConsumption,CreateTime,EntireTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5)"); + strSql.Append(" values ("); + strSql.Append("@GasId,@GasNumber,@GasName,@GasConsumption,@CreateTime,@EntireTime,@Reserve1,@Reserve2,@Reserve3,@Reserve4,@Reserve5)"); + MySqlParameter[] parameters = { + new MySqlParameter("@GasId", MySqlDbType.VarChar,255), + new MySqlParameter("@GasNumber", MySqlDbType.VarChar,255), + new MySqlParameter("@GasName", MySqlDbType.VarChar,255), + new MySqlParameter("@GasConsumption", MySqlDbType.VarChar,255), + new MySqlParameter("@CreateTime", MySqlDbType.DateTime), + new MySqlParameter("@EntireTime", 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.GasId; + parameters[1].Value = model.GasNumber; + parameters[2].Value = model.GasName; + parameters[3].Value = model.GasConsumption; + parameters[4].Value = model.CreateTime; + parameters[5].Value = model.EntireTime; + parameters[6].Value = model.Reserve1; + parameters[7].Value = model.Reserve2; + parameters[8].Value = model.Reserve3; + parameters[9].Value = model.Reserve4; + parameters[10].Value = model.Reserve5; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + /// + /// 更新一条数据 + /// + public bool Update(DataServer.Model.gas_data model) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("update gas_data set "); + strSql.Append("GasNumber=@GasNumber,"); + strSql.Append("GasName=@GasName,"); + strSql.Append("GasConsumption=@GasConsumption,"); + strSql.Append("CreateTime=@CreateTime,"); + strSql.Append("EntireTime=@EntireTime,"); + strSql.Append("Reserve1=@Reserve1,"); + strSql.Append("Reserve2=@Reserve2,"); + strSql.Append("Reserve3=@Reserve3,"); + strSql.Append("Reserve4=@Reserve4,"); + strSql.Append("Reserve5=@Reserve5"); + strSql.Append(" where GasId=@GasId "); + MySqlParameter[] parameters = { + new MySqlParameter("@GasNumber", MySqlDbType.VarChar,255), + new MySqlParameter("@GasName", MySqlDbType.VarChar,255), + new MySqlParameter("@GasConsumption", MySqlDbType.VarChar,255), + new MySqlParameter("@CreateTime", MySqlDbType.DateTime), + new MySqlParameter("@EntireTime", 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("@GasId", MySqlDbType.VarChar,255)}; + parameters[0].Value = model.GasNumber; + parameters[1].Value = model.GasName; + parameters[2].Value = model.GasConsumption; + parameters[3].Value = model.CreateTime; + parameters[4].Value = model.EntireTime; + parameters[5].Value = model.Reserve1; + parameters[6].Value = model.Reserve2; + parameters[7].Value = model.Reserve3; + parameters[8].Value = model.Reserve4; + parameters[9].Value = model.Reserve5; + parameters[10].Value = model.GasId; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + + /// + /// 删除一条数据 + /// + public bool Delete(string GasId) + { + + StringBuilder strSql=new StringBuilder(); + strSql.Append("delete from gas_data "); + strSql.Append(" where GasId=@GasId "); + MySqlParameter[] parameters = { + new MySqlParameter("@GasId", MySqlDbType.VarChar,255) }; + parameters[0].Value = GasId; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + /// + /// 批量删除数据 + /// + public bool DeleteList(string GasIdlist ) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("delete from gas_data "); + strSql.Append(" where GasId in ("+GasIdlist + ") "); + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString()); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + + + /// + /// 得到一个对象实体 + /// + public DataServer.Model.gas_data GetModel(string GasId) + { + + StringBuilder strSql=new StringBuilder(); + strSql.Append("select GasId,GasNumber,GasName,GasConsumption,CreateTime,EntireTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 from gas_data "); + strSql.Append(" where GasId=@GasId "); + MySqlParameter[] parameters = { + new MySqlParameter("@GasId", MySqlDbType.VarChar,255) }; + parameters[0].Value = GasId; + + DataServer.Model.gas_data model=new DataServer.Model.gas_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.gas_data DataRowToModel(DataRow row) + { + DataServer.Model.gas_data model=new DataServer.Model.gas_data(); + if (row != null) + { + if(row["GasId"]!=null) + { + model.GasId=row["GasId"].ToString(); + } + if(row["GasNumber"]!=null) + { + model.GasNumber=row["GasNumber"].ToString(); + } + if(row["GasName"]!=null) + { + model.GasName=row["GasName"].ToString(); + } + if(row["GasConsumption"]!=null) + { + model.GasConsumption=row["GasConsumption"].ToString(); + } + if(row["CreateTime"]!=null && row["CreateTime"].ToString()!="") + { + model.CreateTime=DateTime.Parse(row["CreateTime"].ToString()); + } + if(row["EntireTime"]!=null && row["EntireTime"].ToString()!="") + { + model.EntireTime=DateTime.Parse(row["EntireTime"].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 GasId,GasNumber,GasName,GasConsumption,CreateTime,EntireTime,Reserve1,Reserve2,Reserve3,Reserve4,Reserve5 "); + strSql.Append(" FROM gas_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 gas_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.GasId desc"); + } + strSql.Append(")AS Row, T.* from gas_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 = "gas_data"; + parameters[1].Value = "GasId"; + 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 + } +} + diff --git a/DataServer/DAL/water_data.cs b/DataServer/DAL/water_data.cs new file mode 100644 index 0000000..2df7139 --- /dev/null +++ b/DataServer/DAL/water_data.cs @@ -0,0 +1,364 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* water_data.cs +* +* 功 能: N/A +* 类 名: water_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:04:57 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 +{ + /// + /// 数据访问类:water_data + /// + public partial class water_data + { + public water_data() + {} + #region BasicMethod + + /// + /// 是否存在该记录 + /// + public bool Exists(string WaterId) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("select count(1) from water_data"); + strSql.Append(" where WaterId=@WaterId "); + MySqlParameter[] parameters = { + new MySqlParameter("@WaterId", MySqlDbType.VarChar,255) }; + parameters[0].Value = WaterId; + + return DbHelperMySQL.Exists(strSql.ToString(),parameters); + } + + + /// + /// 增加一条数据 + /// + public bool Add(DataServer.Model.water_data model) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("insert into water_data("); + strSql.Append("WaterId,WaterNumber,WaterName,WaterYield,CreateTime,EntireTime,Reserver1,Reserver2,Reserver3,Reserver4,Reserver5)"); + strSql.Append(" values ("); + strSql.Append("@WaterId,@WaterNumber,@WaterName,@WaterYield,@CreateTime,@EntireTime,@Reserver1,@Reserver2,@Reserver3,@Reserver4,@Reserver5)"); + MySqlParameter[] parameters = { + new MySqlParameter("@WaterId", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterNumber", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterName", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterYield", MySqlDbType.Float,255), + new MySqlParameter("@CreateTime", MySqlDbType.DateTime), + new MySqlParameter("@EntireTime", MySqlDbType.DateTime), + new MySqlParameter("@Reserver1", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver2", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver3", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver4", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver5", MySqlDbType.VarChar,255)}; + parameters[0].Value = model.WaterId; + parameters[1].Value = model.WaterNumber; + parameters[2].Value = model.WaterName; + parameters[3].Value = model.WaterYield; + parameters[4].Value = model.CreateTime; + parameters[5].Value = model.EntireTime; + parameters[6].Value = model.Reserver1; + parameters[7].Value = model.Reserver2; + parameters[8].Value = model.Reserver3; + parameters[9].Value = model.Reserver4; + parameters[10].Value = model.Reserver5; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + /// + /// 更新一条数据 + /// + public bool Update(DataServer.Model.water_data model) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("update water_data set "); + strSql.Append("WaterNumber=@WaterNumber,"); + strSql.Append("WaterName=@WaterName,"); + strSql.Append("WaterYield=@WaterYield,"); + strSql.Append("CreateTime=@CreateTime,"); + strSql.Append("EntireTime=@EntireTime,"); + strSql.Append("Reserver1=@Reserver1,"); + strSql.Append("Reserver2=@Reserver2,"); + strSql.Append("Reserver3=@Reserver3,"); + strSql.Append("Reserver4=@Reserver4,"); + strSql.Append("Reserver5=@Reserver5"); + strSql.Append(" where WaterId=@WaterId "); + MySqlParameter[] parameters = { + new MySqlParameter("@WaterNumber", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterName", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterYield", MySqlDbType.Float,255), + new MySqlParameter("@CreateTime", MySqlDbType.DateTime), + new MySqlParameter("@EntireTime", MySqlDbType.DateTime), + new MySqlParameter("@Reserver1", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver2", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver3", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver4", MySqlDbType.VarChar,255), + new MySqlParameter("@Reserver5", MySqlDbType.VarChar,255), + new MySqlParameter("@WaterId", MySqlDbType.VarChar,255)}; + parameters[0].Value = model.WaterNumber; + parameters[1].Value = model.WaterName; + parameters[2].Value = model.WaterYield; + parameters[3].Value = model.CreateTime; + parameters[4].Value = model.EntireTime; + parameters[5].Value = model.Reserver1; + parameters[6].Value = model.Reserver2; + parameters[7].Value = model.Reserver3; + parameters[8].Value = model.Reserver4; + parameters[9].Value = model.Reserver5; + parameters[10].Value = model.WaterId; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + + /// + /// 删除一条数据 + /// + public bool Delete(string WaterId) + { + + StringBuilder strSql=new StringBuilder(); + strSql.Append("delete from water_data "); + strSql.Append(" where WaterId=@WaterId "); + MySqlParameter[] parameters = { + new MySqlParameter("@WaterId", MySqlDbType.VarChar,255) }; + parameters[0].Value = WaterId; + + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + /// + /// 批量删除数据 + /// + public bool DeleteList(string WaterIdlist ) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("delete from water_data "); + strSql.Append(" where WaterId in ("+WaterIdlist + ") "); + int rows=DbHelperMySQL.ExecuteSql(strSql.ToString()); + if (rows > 0) + { + return true; + } + else + { + return false; + } + } + + + /// + /// 得到一个对象实体 + /// + public DataServer.Model.water_data GetModel(string WaterId) + { + + StringBuilder strSql=new StringBuilder(); + strSql.Append("select WaterId,WaterNumber,WaterName,WaterYield,CreateTime,EntireTime,Reserver1,Reserver2,Reserver3,Reserver4,Reserver5 from water_data "); + strSql.Append(" where WaterId=@WaterId "); + MySqlParameter[] parameters = { + new MySqlParameter("@WaterId", MySqlDbType.VarChar,255) }; + parameters[0].Value = WaterId; + + DataServer.Model.water_data model=new DataServer.Model.water_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.water_data DataRowToModel(DataRow row) + { + DataServer.Model.water_data model=new DataServer.Model.water_data(); + if (row != null) + { + if(row["WaterId"]!=null) + { + model.WaterId=row["WaterId"].ToString(); + } + if(row["WaterNumber"]!=null) + { + model.WaterNumber=row["WaterNumber"].ToString(); + } + if(row["WaterName"]!=null) + { + model.WaterName=row["WaterName"].ToString(); + } + if(row["WaterYield"]!=null && row["WaterYield"].ToString()!="") + { + model.WaterYield=decimal.Parse(row["WaterYield"].ToString()); + } + if(row["CreateTime"]!=null && row["CreateTime"].ToString()!="") + { + model.CreateTime=DateTime.Parse(row["CreateTime"].ToString()); + } + if(row["EntireTime"]!=null && row["EntireTime"].ToString()!="") + { + model.EntireTime=DateTime.Parse(row["EntireTime"].ToString()); + } + if(row["Reserver1"]!=null) + { + model.Reserver1=row["Reserver1"].ToString(); + } + if(row["Reserver2"]!=null) + { + model.Reserver2=row["Reserver2"].ToString(); + } + if(row["Reserver3"]!=null) + { + model.Reserver3=row["Reserver3"].ToString(); + } + if(row["Reserver4"]!=null) + { + model.Reserver4=row["Reserver4"].ToString(); + } + if(row["Reserver5"]!=null) + { + model.Reserver5=row["Reserver5"].ToString(); + } + } + return model; + } + + /// + /// 获得数据列表 + /// + public DataSet GetList(string strWhere) + { + StringBuilder strSql=new StringBuilder(); + strSql.Append("select WaterId,WaterNumber,WaterName,WaterYield,CreateTime,EntireTime,Reserver1,Reserver2,Reserver3,Reserver4,Reserver5 "); + strSql.Append(" FROM water_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 water_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.WaterId desc"); + } + strSql.Append(")AS Row, T.* from water_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 = "water_data"; + parameters[1].Value = "WaterId"; + 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 + } +} + diff --git a/DataServer/DataServer.csproj b/DataServer/DataServer.csproj index fa8efad..f2f2a85 100644 --- a/DataServer/DataServer.csproj +++ b/DataServer/DataServer.csproj @@ -85,17 +85,23 @@ + + + + + + diff --git a/DataServer/Model/gas_data.cs b/DataServer/Model/gas_data.cs new file mode 100644 index 0000000..a21ba3b --- /dev/null +++ b/DataServer/Model/gas_data.cs @@ -0,0 +1,132 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* gas_data.cs +* +* 功 能: N/A +* 类 名: gas_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:05:57 N/A 初版 +* +* Copyright (c) 2012 Maticsoft Corporation. All rights reserved. +*┌──────────────────────────────────┐ +*│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ +*│ 版权所有:动软卓越(北京)科技有限公司              │ +*└──────────────────────────────────┘ +*/ +using System; +namespace DataServer.Model +{ + /// + /// gas_data:实体类(属性说明自动提取数据库字段的描述信息) + /// + [Serializable] + public partial class gas_data + { + public gas_data() + {} + #region Model + private string _gasid; + private string _gasnumber; + private string _gasname; + private string _gasconsumption; + private DateTime? _createtime; + private DateTime? _entiretime; + private string _reserve1; + private string _reserve2; + private string _reserve3; + private string _reserve4; + private string _reserve5; + /// + /// + /// + public string GasId + { + set{ _gasid=value;} + get{return _gasid;} + } + /// + /// + /// + public string GasNumber + { + set{ _gasnumber=value;} + get{return _gasnumber;} + } + /// + /// + /// + public string GasName + { + set{ _gasname=value;} + get{return _gasname;} + } + /// + /// + /// + public string GasConsumption + { + set{ _gasconsumption=value;} + get{return _gasconsumption;} + } + /// + /// + /// + public DateTime? CreateTime + { + set{ _createtime=value;} + get{return _createtime;} + } + /// + /// + /// + public DateTime? EntireTime + { + set{ _entiretime=value;} + get{return _entiretime;} + } + /// + /// + /// + public string Reserve1 + { + set{ _reserve1=value;} + get{return _reserve1;} + } + /// + /// + /// + public string Reserve2 + { + set{ _reserve2=value;} + get{return _reserve2;} + } + /// + /// + /// + public string Reserve3 + { + set{ _reserve3=value;} + get{return _reserve3;} + } + /// + /// + /// + public string Reserve4 + { + set{ _reserve4=value;} + get{return _reserve4;} + } + /// + /// + /// + public string Reserve5 + { + set{ _reserve5=value;} + get{return _reserve5;} + } + #endregion Model + + } +} + diff --git a/DataServer/Model/water_data.cs b/DataServer/Model/water_data.cs new file mode 100644 index 0000000..001b7a9 --- /dev/null +++ b/DataServer/Model/water_data.cs @@ -0,0 +1,132 @@ +/** 版本信息模板在安装目录下,可自行修改。 +* water_data.cs +* +* 功 能: N/A +* 类 名: water_data +* +* Ver 变更日期 负责人 变更内容 +* ─────────────────────────────────── +* V0.01 2024/1/9 14:04:57 N/A 初版 +* +* Copyright (c) 2012 Maticsoft Corporation. All rights reserved. +*┌──────────────────────────────────┐ +*│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │ +*│ 版权所有:动软卓越(北京)科技有限公司              │ +*└──────────────────────────────────┘ +*/ +using System; +namespace DataServer.Model +{ + /// + /// water_data:实体类(属性说明自动提取数据库字段的描述信息) + /// + [Serializable] + public partial class water_data + { + public water_data() + {} + #region Model + private string _waterid; + private string _waternumber; + private string _watername; + private decimal? _wateryield; + private DateTime? _createtime; + private DateTime? _entiretime; + private string _reserver1; + private string _reserver2; + private string _reserver3; + private string _reserver4; + private string _reserver5; + /// + /// + /// + public string WaterId + { + set{ _waterid=value;} + get{return _waterid;} + } + /// + /// + /// + public string WaterNumber + { + set{ _waternumber=value;} + get{return _waternumber;} + } + /// + /// + /// + public string WaterName + { + set{ _watername=value;} + get{return _watername;} + } + /// + /// + /// + public decimal? WaterYield + { + set{ _wateryield=value;} + get{return _wateryield;} + } + /// + /// + /// + public DateTime? CreateTime + { + set{ _createtime=value;} + get{return _createtime;} + } + /// + /// + /// + public DateTime? EntireTime + { + set{ _entiretime=value;} + get{return _entiretime;} + } + /// + /// + /// + public string Reserver1 + { + set{ _reserver1=value;} + get{return _reserver1;} + } + /// + /// + /// + public string Reserver2 + { + set{ _reserver2=value;} + get{return _reserver2;} + } + /// + /// + /// + public string Reserver3 + { + set{ _reserver3=value;} + get{return _reserver3;} + } + /// + /// + /// + public string Reserver4 + { + set{ _reserver4=value;} + get{return _reserver4;} + } + /// + /// + /// + public string Reserver5 + { + set{ _reserver5=value;} + get{return _reserver5;} + } + #endregion Model + + } +} + diff --git a/DataServer/bin/Debug/DataServer.pdb b/DataServer/bin/Debug/DataServer.pdb index 0e82b21..3d9e39a 100644 Binary files a/DataServer/bin/Debug/DataServer.pdb and b/DataServer/bin/Debug/DataServer.pdb differ diff --git a/DataServer/obj/Debug/DataServer.csproj.CoreCompileInputs.cache b/DataServer/obj/Debug/DataServer.csproj.CoreCompileInputs.cache index 02f801d..7e6f407 100644 --- a/DataServer/obj/Debug/DataServer.csproj.CoreCompileInputs.cache +++ b/DataServer/obj/Debug/DataServer.csproj.CoreCompileInputs.cache @@ -1 +1 @@ -15bbb4e196dffff88387fbe73c0b6671cf6e1fc8 +8863b3d404b4c933530616b840a3e61667fd3b30 diff --git a/DataServer/obj/Debug/DataServer.dll b/DataServer/obj/Debug/DataServer.dll index 08273c7..eddf501 100644 Binary files a/DataServer/obj/Debug/DataServer.dll and b/DataServer/obj/Debug/DataServer.dll differ diff --git a/DataServer/obj/Debug/DataServer.pdb b/DataServer/obj/Debug/DataServer.pdb index 0e82b21..3d9e39a 100644 Binary files a/DataServer/obj/Debug/DataServer.pdb and b/DataServer/obj/Debug/DataServer.pdb differ diff --git a/DongYingAPI/bin/DataServer.dll b/DongYingAPI/bin/DataServer.dll index 08273c7..eddf501 100644 Binary files a/DongYingAPI/bin/DataServer.dll and b/DongYingAPI/bin/DataServer.dll differ diff --git a/DongYingAPI/bin/DataServer.pdb b/DongYingAPI/bin/DataServer.pdb index 0e82b21..3d9e39a 100644 Binary files a/DongYingAPI/bin/DataServer.pdb and b/DongYingAPI/bin/DataServer.pdb differ diff --git a/DongYingAPI/bin/DongYingAPI.dll b/DongYingAPI/bin/DongYingAPI.dll index 288c193..cab4b3e 100644 Binary files a/DongYingAPI/bin/DongYingAPI.dll and b/DongYingAPI/bin/DongYingAPI.dll differ diff --git a/DongYingAPI/bin/DongYingAPI.pdb b/DongYingAPI/bin/DongYingAPI.pdb index 91840b8..54bda42 100644 Binary files a/DongYingAPI/bin/DongYingAPI.pdb and b/DongYingAPI/bin/DongYingAPI.pdb differ diff --git a/DongYingAPI/obj/Debug/DongYingAPI.csproj.CoreCompileInputs.cache b/DongYingAPI/obj/Debug/DongYingAPI.csproj.CoreCompileInputs.cache index 804fae5..9a2aba1 100644 --- a/DongYingAPI/obj/Debug/DongYingAPI.csproj.CoreCompileInputs.cache +++ b/DongYingAPI/obj/Debug/DongYingAPI.csproj.CoreCompileInputs.cache @@ -1 +1 @@ -fb5b9c8b46a48a3d02864cb0cc1a38db724aeeb0 +b5fe90906b5d33e0c9d21d797b9d7334cf5a65e3 diff --git a/DongYingAPI/obj/Debug/DongYingAPI.dll b/DongYingAPI/obj/Debug/DongYingAPI.dll index 288c193..cab4b3e 100644 Binary files a/DongYingAPI/obj/Debug/DongYingAPI.dll and b/DongYingAPI/obj/Debug/DongYingAPI.dll differ diff --git a/DongYingAPI/obj/Debug/DongYingAPI.pdb b/DongYingAPI/obj/Debug/DongYingAPI.pdb index 91840b8..54bda42 100644 Binary files a/DongYingAPI/obj/Debug/DongYingAPI.pdb and b/DongYingAPI/obj/Debug/DongYingAPI.pdb differ