/** 版本信息模板在安装目录下,可自行修改。 * pro_base_device.cs * * 功 能: N/A * 类 名: pro_base_device * * Ver 变更日期 负责人 变更内容 * ─────────────────────────────────── * V0.01 2024/9/26 9:44:52 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 using System.Collections.Generic; namespace DataService.DAL { /// /// 数据访问类:pro_base_device /// public partial class pro_base_device { public pro_base_device() {} #region BasicMethod /// /// 是否存在该记录 /// public bool Exists(string id) { StringBuilder strSql=new StringBuilder(); strSql.Append("select count(1) from pro_base_device"); strSql.Append(" where id=@id "); MySqlParameter[] parameters = { new MySqlParameter("@id", MySqlDbType.VarChar,50) }; parameters[0].Value = id; return DbHelperMySQL.Exists(strSql.ToString(),parameters); } /// /// 增加一条数据 /// public bool Add(DataService.Model.pro_base_device model) { StringBuilder strSql=new StringBuilder(); strSql.Append("insert into pro_base_device("); strSql.Append("id,device_name,device_state,model,device_type,jcfs,wg,bcyxsc,yxzsc,yxl,yxzt,bjcxsc,gzlx,zdjl,create_time,r1,r2,r3)"); strSql.Append(" values ("); strSql.Append("@id,@device_name,@device_state,@model,@device_type,@jcfs,@wg,@bcyxsc,@yxzsc,@yxl,@yxzt,@bjcxsc,@gzlx,@zdjl,@create_time,@r1,@r2,@r3)"); MySqlParameter[] parameters = { new MySqlParameter("@id", MySqlDbType.VarChar,50), new MySqlParameter("@device_name", MySqlDbType.VarChar,255), new MySqlParameter("@device_state", MySqlDbType.VarChar,255), new MySqlParameter("@model", MySqlDbType.VarChar,255), new MySqlParameter("@device_type", MySqlDbType.VarChar,255), new MySqlParameter("@jcfs", MySqlDbType.VarChar,255), new MySqlParameter("@wg", MySqlDbType.VarChar,255), new MySqlParameter("@bcyxsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxzsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxl", MySqlDbType.VarChar,255), new MySqlParameter("@yxzt", MySqlDbType.VarChar,255), new MySqlParameter("@bjcxsc", MySqlDbType.VarChar,255), new MySqlParameter("@gzlx", MySqlDbType.VarChar,255), new MySqlParameter("@zdjl", MySqlDbType.VarChar,255), new MySqlParameter("@create_time", MySqlDbType.DateTime), new MySqlParameter("@r1", MySqlDbType.VarChar,255), new MySqlParameter("@r2", MySqlDbType.VarChar,255), new MySqlParameter("@r3", MySqlDbType.VarChar,255)}; parameters[0].Value = model.id; parameters[1].Value = model.device_name; parameters[2].Value = model.device_state; parameters[3].Value = model.model; parameters[4].Value = model.device_type; parameters[5].Value = model.jcfs; parameters[6].Value = model.wg; parameters[7].Value = model.bcyxsc; parameters[8].Value = model.yxzsc; parameters[9].Value = model.yxl; parameters[10].Value = model.yxzt; parameters[11].Value = model.bjcxsc; parameters[12].Value = model.gzlx; parameters[13].Value = model.zdjl; parameters[14].Value = model.create_time; parameters[15].Value = model.r1; parameters[16].Value = model.r2; parameters[17].Value = model.r3; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 更新一条数据 /// public bool Update(DataService.Model.pro_base_device model) { StringBuilder strSql=new StringBuilder(); strSql.Append("update pro_base_device set "); strSql.Append("device_name=@device_name,"); strSql.Append("device_state=@device_state,"); strSql.Append("model=@model,"); strSql.Append("device_type=@device_type,"); strSql.Append("jcfs=@jcfs,"); strSql.Append("wg=@wg,"); strSql.Append("bcyxsc=@bcyxsc,"); strSql.Append("yxzsc=@yxzsc,"); strSql.Append("yxl=@yxl,"); strSql.Append("yxzt=@yxzt,"); strSql.Append("bjcxsc=@bjcxsc,"); strSql.Append("gzlx=@gzlx,"); strSql.Append("zdjl=@zdjl,"); strSql.Append("create_time=@create_time,"); strSql.Append("r1=@r1,"); strSql.Append("r2=@r2,"); strSql.Append("r3=@r3"); strSql.Append(" where id=@id "); MySqlParameter[] parameters = { new MySqlParameter("@device_name", MySqlDbType.VarChar,255), new MySqlParameter("@device_state", MySqlDbType.VarChar,255), new MySqlParameter("@model", MySqlDbType.VarChar,255), new MySqlParameter("@device_type", MySqlDbType.VarChar,255), new MySqlParameter("@jcfs", MySqlDbType.VarChar,255), new MySqlParameter("@wg", MySqlDbType.VarChar,255), new MySqlParameter("@bcyxsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxzsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxl", MySqlDbType.VarChar,255), new MySqlParameter("@yxzt", MySqlDbType.VarChar,255), new MySqlParameter("@bjcxsc", MySqlDbType.VarChar,255), new MySqlParameter("@gzlx", MySqlDbType.VarChar,255), new MySqlParameter("@zdjl", MySqlDbType.VarChar,255), new MySqlParameter("@create_time", MySqlDbType.DateTime), new MySqlParameter("@r1", MySqlDbType.VarChar,255), new MySqlParameter("@r2", MySqlDbType.VarChar,255), new MySqlParameter("@r3", MySqlDbType.VarChar,255), new MySqlParameter("@id", MySqlDbType.VarChar,50)}; parameters[0].Value = model.device_name; parameters[1].Value = model.device_state; parameters[2].Value = model.model; parameters[3].Value = model.device_type; parameters[4].Value = model.jcfs; parameters[5].Value = model.wg; parameters[6].Value = model.bcyxsc; parameters[7].Value = model.yxzsc; parameters[8].Value = model.yxl; parameters[9].Value = model.yxzt; parameters[10].Value = model.bjcxsc; parameters[11].Value = model.gzlx; parameters[12].Value = model.zdjl; parameters[13].Value = model.create_time; parameters[14].Value = model.r1; parameters[15].Value = model.r2; parameters[16].Value = model.r3; parameters[17].Value = model.id; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(string id) { StringBuilder strSql=new StringBuilder(); strSql.Append("delete from pro_base_device "); strSql.Append(" where id=@id "); MySqlParameter[] parameters = { new MySqlParameter("@id", MySqlDbType.VarChar,50) }; parameters[0].Value = id; int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string idlist ) { StringBuilder strSql=new StringBuilder(); strSql.Append("delete from pro_base_device "); strSql.Append(" where id in ("+idlist + ") "); int rows=DbHelperMySQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public DataService.Model.pro_base_device GetModel(string id) { StringBuilder strSql=new StringBuilder(); strSql.Append("select id,device_name,device_state,model,device_type,jcfs,wg,bcyxsc,yxzsc,yxl,yxzt,bjcxsc,gzlx,zdjl,create_time,r1,r2,r3 from pro_base_device "); strSql.Append(" where id=@id "); MySqlParameter[] parameters = { new MySqlParameter("@id", MySqlDbType.VarChar,50) }; parameters[0].Value = id; DataService.Model.pro_base_device model=new DataService.Model.pro_base_device(); 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 DataService.Model.pro_base_device DataRowToModel(DataRow row) { DataService.Model.pro_base_device model=new DataService.Model.pro_base_device(); if (row != null) { if(row["id"]!=null) { model.id=row["id"].ToString(); } if(row["device_name"]!=null) { model.device_name=row["device_name"].ToString(); } if(row["device_state"]!=null) { model.device_state=row["device_state"].ToString(); } if(row["model"]!=null) { model.model=row["model"].ToString(); } if(row["device_type"]!=null) { model.device_type=row["device_type"].ToString(); } if(row["jcfs"]!=null) { model.jcfs=row["jcfs"].ToString(); } if(row["wg"]!=null) { model.wg=row["wg"].ToString(); } if(row["bcyxsc"]!=null) { model.bcyxsc=row["bcyxsc"].ToString(); } if(row["yxzsc"]!=null) { model.yxzsc=row["yxzsc"].ToString(); } if(row["yxl"]!=null) { model.yxl=row["yxl"].ToString(); } if(row["yxzt"]!=null) { model.yxzt=row["yxzt"].ToString(); } if(row["bjcxsc"]!=null) { model.bjcxsc=row["bjcxsc"].ToString(); } if(row["gzlx"]!=null) { model.gzlx=row["gzlx"].ToString(); } if(row["zdjl"]!=null) { model.zdjl=row["zdjl"].ToString(); } if(row["create_time"]!=null && row["create_time"].ToString()!="") { model.create_time=DateTime.Parse(row["create_time"].ToString()); } if(row["r1"]!=null) { model.r1=row["r1"].ToString(); } if(row["r2"]!=null) { model.r2=row["r2"].ToString(); } if(row["r3"]!=null) { model.r3=row["r3"].ToString(); } } return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql=new StringBuilder(); strSql.Append("select id,device_name,device_state,model,device_type,jcfs,wg,bcyxsc,yxzsc,yxl,yxzt,bjcxsc,gzlx,zdjl,create_time,r1,r2,r3 "); strSql.Append(" FROM pro_base_device "); 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 pro_base_device "); if(strWhere.Trim()!="") { strSql.Append(" where "+strWhere); } object obj = DbHelperMySQL.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.id desc"); } strSql.Append(")AS Row, T.* from pro_base_device 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 = "pro_base_device"; parameters[1].Value = "id"; 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 public int BatchAdd_Update(List list_Insert, string lang = "0") { List listCmd = new List(); if (true) { StringBuilder strSql = new StringBuilder(); strSql.AppendFormat("delete from pro_base_device where r1 ='{0}' ", lang); var cmd = new CommandInfo(); cmd.CommandText = strSql.ToString(); listCmd.Add(cmd); } foreach (var model in list_Insert) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into pro_base_device("); strSql.Append("id,device_name,device_state,model,device_type,jcfs,wg,bcyxsc,yxzsc,yxl,yxzt,bjcxsc,gzlx,zdjl,create_time,r1,r2,r3)"); strSql.Append(" values ("); strSql.Append("@id,@device_name,@device_state,@model,@device_type,@jcfs,@wg,@bcyxsc,@yxzsc,@yxl,@yxzt,@bjcxsc,@gzlx,@zdjl,@create_time,@r1,@r2,@r3)"); MySqlParameter[] parameters = { new MySqlParameter("@id", MySqlDbType.VarChar,50), new MySqlParameter("@device_name", MySqlDbType.VarChar,255), new MySqlParameter("@device_state", MySqlDbType.VarChar,255), new MySqlParameter("@model", MySqlDbType.VarChar,255), new MySqlParameter("@device_type", MySqlDbType.VarChar,255), new MySqlParameter("@jcfs", MySqlDbType.VarChar,255), new MySqlParameter("@wg", MySqlDbType.VarChar,255), new MySqlParameter("@bcyxsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxzsc", MySqlDbType.VarChar,255), new MySqlParameter("@yxl", MySqlDbType.VarChar,255), new MySqlParameter("@yxzt", MySqlDbType.VarChar,255), new MySqlParameter("@bjcxsc", MySqlDbType.VarChar,255), new MySqlParameter("@gzlx", MySqlDbType.VarChar,255), new MySqlParameter("@zdjl", MySqlDbType.VarChar,255), new MySqlParameter("@create_time", MySqlDbType.DateTime), new MySqlParameter("@r1", MySqlDbType.VarChar,255), new MySqlParameter("@r2", MySqlDbType.VarChar,255), new MySqlParameter("@r3", MySqlDbType.VarChar,255)}; parameters[0].Value = model.id; parameters[1].Value = model.device_name; parameters[2].Value = model.device_state; parameters[3].Value = model.model; parameters[4].Value = model.device_type; parameters[5].Value = model.jcfs; parameters[6].Value = model.wg; parameters[7].Value = model.bcyxsc; parameters[8].Value = model.yxzsc; parameters[9].Value = model.yxl; parameters[10].Value = model.yxzt; parameters[11].Value = model.bjcxsc; parameters[12].Value = model.gzlx; parameters[13].Value = model.zdjl; parameters[14].Value = model.create_time; parameters[15].Value = model.r1; parameters[16].Value = model.r2; parameters[17].Value = model.r3; var cmd = new CommandInfo(); cmd.CommandText = strSql.ToString(); cmd.Parameters = parameters; listCmd.Add(cmd); } int rows = DbHelperMySQL.ExecuteSqlTran(listCmd); return rows; } #endregion ExtensionMethod } }