提交水历史和气历史

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
+{
+	/// <summary>
+	/// gas_data
+	/// </summary>
+	public partial class gas_data
+	{
+		private readonly DataServer.DAL.gas_data dal=new DataServer.DAL.gas_data();
+		public gas_data()
+		{}
+		#region  BasicMethod
+		/// <summary>
+		/// 是否存在该记录
+		/// </summary>
+		public bool Exists(string GasId)
+		{
+			return dal.Exists(GasId);
+		}
+
+		/// <summary>
+		/// 增加一条数据
+		/// </summary>
+		public bool Add(DataServer.Model.gas_data model)
+		{
+			return dal.Add(model);
+		}
+
+		/// <summary>
+		/// 更新一条数据
+		/// </summary>
+		public bool Update(DataServer.Model.gas_data model)
+		{
+			return dal.Update(model);
+		}
+
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		public bool Delete(string GasId)
+		{
+			
+			return dal.Delete(GasId);
+		}
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		public bool DeleteList(string GasIdlist )
+		{
+			return dal.DeleteList(GasIdlist );
+		}
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		public DataServer.Model.gas_data GetModel(string GasId)
+		{
+			
+			return dal.GetModel(GasId);
+		}
+
+		/// <summary>
+		/// 得到一个对象实体，从缓存中
+		/// </summary>
+		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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public DataSet GetList(string strWhere)
+		{
+			return dal.GetList(strWhere);
+		}
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public List<DataServer.Model.gas_data> GetModelList(string strWhere)
+		{
+			DataSet ds = dal.GetList(strWhere);
+			return DataTableToList(ds.Tables[0]);
+		}
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public List<DataServer.Model.gas_data> DataTableToList(DataTable dt)
+		{
+			List<DataServer.Model.gas_data> modelList = new List<DataServer.Model.gas_data>();
+			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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public DataSet GetAllList()
+		{
+			return GetList("");
+		}
+
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public int GetRecordCount(string strWhere)
+		{
+			return dal.GetRecordCount(strWhere);
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+		{
+			return dal.GetListByPage( strWhere,  orderby,  startIndex,  endIndex);
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		//public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+		//{
+			//return dal.GetList(PageSize,PageIndex,strWhere);
+		//}
+
+		#endregion  BasicMethod
+		#region  ExtensionMethod
+
+		#endregion  ExtensionMethod
+	}
+}
+

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
+{
+	/// <summary>
+	/// water_data
+	/// </summary>
+	public partial class water_data
+	{
+		private readonly DataServer.DAL.water_data dal=new DataServer.DAL.water_data();
+		public water_data()
+		{}
+		#region  BasicMethod
+		/// <summary>
+		/// 是否存在该记录
+		/// </summary>
+		public bool Exists(string WaterId)
+		{
+			return dal.Exists(WaterId);
+		}
+
+		/// <summary>
+		/// 增加一条数据
+		/// </summary>
+		public bool Add(DataServer.Model.water_data model)
+		{
+			return dal.Add(model);
+		}
+
+		/// <summary>
+		/// 更新一条数据
+		/// </summary>
+		public bool Update(DataServer.Model.water_data model)
+		{
+			return dal.Update(model);
+		}
+
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		public bool Delete(string WaterId)
+		{
+			
+			return dal.Delete(WaterId);
+		}
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		public bool DeleteList(string WaterIdlist )
+		{
+			return dal.DeleteList(WaterIdlist );
+		}
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		public DataServer.Model.water_data GetModel(string WaterId)
+		{
+			
+			return dal.GetModel(WaterId);
+		}
+
+		/// <summary>
+		/// 得到一个对象实体，从缓存中
+		/// </summary>
+		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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public DataSet GetList(string strWhere)
+		{
+			return dal.GetList(strWhere);
+		}
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public List<DataServer.Model.water_data> GetModelList(string strWhere)
+		{
+			DataSet ds = dal.GetList(strWhere);
+			return DataTableToList(ds.Tables[0]);
+		}
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public List<DataServer.Model.water_data> DataTableToList(DataTable dt)
+		{
+			List<DataServer.Model.water_data> modelList = new List<DataServer.Model.water_data>();
+			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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		public DataSet GetAllList()
+		{
+			return GetList("");
+		}
+
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public int GetRecordCount(string strWhere)
+		{
+			return dal.GetRecordCount(strWhere);
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+		{
+			return dal.GetListByPage( strWhere,  orderby,  startIndex,  endIndex);
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		//public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+		//{
+			//return dal.GetList(PageSize,PageIndex,strWhere);
+		//}
+
+		#endregion  BasicMethod
+		#region  ExtensionMethod
+
+		#endregion  ExtensionMethod
+	}
+}
+

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
+{
+	/// <summary>
+	/// 数据访问类:gas_data
+	/// </summary>
+	public partial class gas_data
+	{
+		public gas_data()
+		{}
+		#region  BasicMethod
+
+		/// <summary>
+		/// 是否存在该记录
+		/// </summary>
+		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);
+		}
+
+
+		/// <summary>
+		/// 增加一条数据
+		/// </summary>
+		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;
+			}
+		}
+		/// <summary>
+		/// 更新一条数据
+		/// </summary>
+		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;
+			}
+		}
+
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		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;
+			}
+		}
+		/// <summary>
+		/// 批量删除数据
+		/// </summary>
+		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;
+			}
+		}
+
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		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;
+			}
+		}
+
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		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());
+		}
+
+		/// <summary>
+		/// 获取记录总数
+		/// </summary>
+		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);
+			}
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		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());
+		}
+
+		/*
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		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
+	}
+}
+

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
+{
+	/// <summary>
+	/// 数据访问类:water_data
+	/// </summary>
+	public partial class water_data
+	{
+		public water_data()
+		{}
+		#region  BasicMethod
+
+		/// <summary>
+		/// 是否存在该记录
+		/// </summary>
+		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);
+		}
+
+
+		/// <summary>
+		/// 增加一条数据
+		/// </summary>
+		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;
+			}
+		}
+		/// <summary>
+		/// 更新一条数据
+		/// </summary>
+		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;
+			}
+		}
+
+		/// <summary>
+		/// 删除一条数据
+		/// </summary>
+		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;
+			}
+		}
+		/// <summary>
+		/// 批量删除数据
+		/// </summary>
+		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;
+			}
+		}
+
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		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;
+			}
+		}
+
+
+		/// <summary>
+		/// 得到一个对象实体
+		/// </summary>
+		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;
+		}
+
+		/// <summary>
+		/// 获得数据列表
+		/// </summary>
+		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());
+		}
+
+		/// <summary>
+		/// 获取记录总数
+		/// </summary>
+		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);
+			}
+		}
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		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());
+		}
+
+		/*
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		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
+	}
+}
+

DataServer/DataServer.csproj

@@ -85,17 +85,23 @@
     <Compile Include="BLL\device_operation.cs" />
     <Compile Include="BLL\electricity_data.cs" />
     <Compile Include="BLL\electricity_price.cs" />
+    <Compile Include="BLL\gas_data.cs" />
+    <Compile Include="BLL\water_data.cs" />
     <Compile Include="DAL\device_data.cs" />
     <Compile Include="api\get_realtime_data.cs" />
     <Compile Include="DAL\device_info.cs" />
     <Compile Include="DAL\device_operation.cs" />
     <Compile Include="DAL\electricity_data.cs" />
     <Compile Include="DAL\electricity_price.cs" />
+    <Compile Include="DAL\gas_data.cs" />
+    <Compile Include="DAL\water_data.cs" />
     <Compile Include="Model\device_data.cs" />
     <Compile Include="Model\device_info.cs" />
     <Compile Include="Model\device_operation.cs" />
     <Compile Include="Model\electricity_data.cs" />
     <Compile Include="Model\electricity_price.cs" />
+    <Compile Include="Model\gas_data.cs" />
+    <Compile Include="Model\water_data.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>
   <ItemGroup />

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
+{
+	/// <summary>
+	/// gas_data:实体类(属性说明自动提取数据库字段的描述信息)
+	/// </summary>
+	[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;
+		/// <summary>
+		/// 
+		/// </summary>
+		public string GasId
+		{
+			set{ _gasid=value;}
+			get{return _gasid;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string GasNumber
+		{
+			set{ _gasnumber=value;}
+			get{return _gasnumber;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string GasName
+		{
+			set{ _gasname=value;}
+			get{return _gasname;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string GasConsumption
+		{
+			set{ _gasconsumption=value;}
+			get{return _gasconsumption;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public DateTime? CreateTime
+		{
+			set{ _createtime=value;}
+			get{return _createtime;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public DateTime? EntireTime
+		{
+			set{ _entiretime=value;}
+			get{return _entiretime;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserve1
+		{
+			set{ _reserve1=value;}
+			get{return _reserve1;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserve2
+		{
+			set{ _reserve2=value;}
+			get{return _reserve2;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserve3
+		{
+			set{ _reserve3=value;}
+			get{return _reserve3;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserve4
+		{
+			set{ _reserve4=value;}
+			get{return _reserve4;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserve5
+		{
+			set{ _reserve5=value;}
+			get{return _reserve5;}
+		}
+		#endregion Model
+
+	}
+}
+

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
+{
+	/// <summary>
+	/// water_data:实体类(属性说明自动提取数据库字段的描述信息)
+	/// </summary>
+	[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;
+		/// <summary>
+		/// 
+		/// </summary>
+		public string WaterId
+		{
+			set{ _waterid=value;}
+			get{return _waterid;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string WaterNumber
+		{
+			set{ _waternumber=value;}
+			get{return _waternumber;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string WaterName
+		{
+			set{ _watername=value;}
+			get{return _watername;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public decimal? WaterYield
+		{
+			set{ _wateryield=value;}
+			get{return _wateryield;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public DateTime? CreateTime
+		{
+			set{ _createtime=value;}
+			get{return _createtime;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public DateTime? EntireTime
+		{
+			set{ _entiretime=value;}
+			get{return _entiretime;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserver1
+		{
+			set{ _reserver1=value;}
+			get{return _reserver1;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserver2
+		{
+			set{ _reserver2=value;}
+			get{return _reserver2;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserver3
+		{
+			set{ _reserver3=value;}
+			get{return _reserver3;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserver4
+		{
+			set{ _reserver4=value;}
+			get{return _reserver4;}
+		}
+		/// <summary>
+		/// 
+		/// </summary>
+		public string Reserver5
+		{
+			set{ _reserver5=value;}
+			get{return _reserver5;}
+		}
+		#endregion Model
+
+	}
+}
+

DataServer/obj/Debug/DataServer.csproj.CoreCompileInputs.cache

@@ -1 +1 @@
-15bbb4e196dffff88387fbe73c0b6671cf6e1fc8
+8863b3d404b4c933530616b840a3e61667fd3b30

DongYingAPI/obj/Debug/DongYingAPI.csproj.CoreCompileInputs.cache

@@ -1 +1 @@
-fb5b9c8b46a48a3d02864cb0cc1a38db724aeeb0
+b5fe90906b5d33e0c9d21d797b9d7334cf5a65e3