com_systemuserdd.asmx.cs

ASP.NET的一些开发实例,有论坛管理系统等

using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.Web;
using System.Web.Services;
using System.Data.SqlClient;
using System.IO;
using System.Xml;

namespace ERPWebService.BdStudio
{
	/// <summary>
	/// COM_SystemUserdd 的摘要说明。
	/// </summary>
	public class COM_SystemUserdd : System.Web.Services.WebService
	{
		protected sysbase.COM_BASE COM_BASE = new sysbase.COM_BASE();
		protected sysbase.COMSoft COMSoft = new sysbase.COMSoft();
		protected SqlConnection SqlConn;

		public COM_SystemUserdd()
		{
			//CODEGEN：该调用是 ASP.NET Web 服务设计器所必需的
			InitializeComponent();
		}

		#region Component Designer generated code
		
		//Web 服务设计器所必需的
		private IContainer components = null;
				
		/// <summary>
		/// 设计器支持所需的方法 - 不要使用代码编辑器修改
		/// 此方法的内容。
		/// </summary>
		private void InitializeComponent()
		{
			this.SqlConn = new SqlConnection((string)Application["db_connstring"]);
		}

		/// <summary>
		/// 清理所有正在使用的资源。
		/// </summary>
		protected override void Dispose( bool disposing )
		{
			if(disposing && components != null)
			{
				components.Dispose();
			}
			base.Dispose(disposing);		
		}
		
		#endregion

		[WebMethod]
		public DataSet DsMainListForAll(string[] FieldValue)
		{
			string[] str_FieldName = {"m_num"};
			string[] str_FieldType = {"string"};
			string str_SearchType = "like";
			DataSet ds = new DataSet();
			string str_Sql = string.Format("select * from system_userdd");
			string strWhere = this.COM_BASE.CreateSql(FieldValue,str_FieldName,str_SearchType,str_FieldType);
			if (strWhere.Trim() != string.Empty && strWhere != null )
			{
				str_Sql = string.Format(" {0} where {1} ",str_Sql,strWhere);
			}
			else if (strWhere.Trim() == string.Empty)
			{
				str_Sql = string.Format(" {0} ",str_Sql);
			}
			str_Sql+=" and isnull(t_up,'')=''";
			
			ds = this.COM_BASE.CreateDataSetFromSql(str_Sql);			
			return ds;
		}

		[WebMethod]
		public DataSet DsMainFieldListForAll(string TableNameId)
		{
			DataSet ds = new DataSet();
			string strSql = string.Format(" select * from system_userdd where t_up = '{0}'",TableNameId);
			ds = this.COM_BASE.CreateDataSetFromSql(strSql);
			return ds;
		}

		[WebMethod]
		public DataSet DsSelectSingleData(string[] str_FieldValue,string SearchType,ref string sReturn)
		{
			string[] str_FieldName = {"u_num"};
			string[] str_FieldType = {"string"};
			string str_SearchType = "=";
			DataSet ds = new DataSet();
			string str_Sql = string.Format("select * from system_userdd");
			string str_Sql1 = string.Format("select u_num from system_userdd order by u_num");
			switch (SearchType)
			{
				case "0":
					str_Sql = string.Format(" {0} where {1} ",str_Sql,this.COM_BASE.CreateSql(str_FieldValue,str_FieldName,str_SearchType,str_FieldType));
					ds = this.COM_BASE.CreateDataSetFromSql(str_Sql);
					foreach(DataRow row in ds.Tables[0].Rows)
					{
						str_Sql+=" or m_num='"+row["m_num"].ToString()+"'";
					}
					ds = this.COM_BASE.CreateDataSetFromSql(str_Sql);
					sReturn = string.Empty;
					break;
				case "1":
					DataSet dsPrev = this.COM_BASE.CreateDataSetFromSql(str_Sql1);
					string str_Prev = string.Empty;
					for (int i=0;i<dsPrev.Tables[0].Rows.Count;i++)
					{
						if (str_FieldValue[0] == dsPrev.Tables[0].Rows[i]["u_num"].ToString() && i > 0)
						{
							str_Prev = dsPrev.Tables[0].Rows[i-1]["u_num"].ToString();
							break;
						}
						else if (str_FieldValue[0] == dsPrev.Tables[0].Rows[i]["u_num"].ToString())
						{
							sReturn = "没有上一条!";
						}
					}
					string[] str_FieldValuePrev = {str_Prev};
					if( str_FieldValuePrev != null)
					{
						str_Sql = string.Format(" {0} where {1} ",str_Sql,this.COM_BASE.CreateSql(str_FieldValuePrev,str_FieldName,str_SearchType,str_FieldType));
						ds = this.COM_BASE.CreateDataSetFromSql(str_Sql);
					}					
					break;
				case "2":
					DataSet dsNext = this.COM_BASE.CreateDataSetFromSql(str_Sql1);
					string str_Next = string.Empty;
					for (int i=0;i<dsNext.Tables[0].Rows.Count;i++)
					{
						if (str_FieldValue[0] == dsNext.Tables[0].Rows[i]["u_num"].ToString() && (i+1) < dsNext.Tables[0].Rows.Count)
						{
							str_Next = dsNext.Tables[0].Rows[i+1]["u_num"].ToString();
							break;
						}
						else if (str_FieldValue[0] == dsNext.Tables[0].Rows[i]["u_num"].ToString())
						{
							sReturn = "没有下一条!";
						}

					}
					string[] str_FieldValueNext = {str_Next};
					if( str_FieldValueNext != null)
					{
						str_Sql = string.Format(" {0} where {1} ",str_Sql,this.COM_BASE.CreateSql(str_FieldValueNext,str_FieldName,str_SearchType,str_FieldType));
						ds = this.COM_BASE.CreateDataSetFromSql(str_Sql);
					}		
					break;
			}						
			return ds;
		}

		[WebMethod]
		public void InsertData(DataSet ds,string InsertType,ref string sReturn)
		{
			SqlCommand mySqlCommand = new SqlCommand();
			SqlTransaction myTrans;
			string SqlString = string.Empty;

			this.SqlConn.Open();//启动连接
			myTrans = this.SqlConn.BeginTransaction();//建立事务
			mySqlCommand.Connection = this.SqlConn;//建立sql命令连接
			mySqlCommand.Transaction = myTrans;//绑定事务

			if (ds.Tables[0].Rows.Count > 0)
			{
				string str_p_num = ds.Tables[0].Rows[0]["p_num"].ToString();
				string str_m_num = ds.Tables[0].Rows[0]["m_num"].ToString();
				string str_t_name = ds.Tables[0].Rows[0]["t_name"].ToString();
				string strsql = string.Format("select u_num from system_userdd where p_num = '{0}' and m_num = '{1}' and t_name = '{2}'",str_p_num,str_m_num,str_t_name);
				DataSet ds1 = this.COM_BASE.CreateDataSetFromSql(strsql);
				if (ds1.Tables[0].Rows.Count <=0)
				{
					/*foreach (DataRow dr in ds.Tables[1].Rows)
					{
						dr["t_up"] = str_t_name;
						dr["p_num"] = str_p_num;
						dr["m_num"] = str_m_num;
					}
					DataTable dt = new DataTable();
					foreach (DataRow dr0 in ds.Tables[0].Rows)
					{
						dt.Rows.Add(dr0);
					}
					foreach (DataRow dr1 in ds.Tables[1].Rows)
					{
						dt.Rows.Add(dr1);
					}*/
					
					string str_TableName = "system_userdd";
					string str_u_num = string.Empty;
					foreach(DataRow row in ds.Tables[0].Rows)
					{
						if(row[0].ToString()=="自动生成")
						{
							ds.Tables[0].Columns.Remove("u_num");
						}
					}

					int nErr;
	
					try
					{
						nErr= this.COM_BASE.InsertTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ds.Tables[0],ref SqlString);
					}
					catch (Exception e)
					{
						nErr = 1;
					}	
					//增加细节数据
					try
					{
						nErr= this.COM_BASE.InsertTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ds.Tables[1],ref SqlString);
					}
					catch (Exception e)
					{
						nErr = 1;
					}		

	
					if (nErr == 1)
					{
						sReturn = SqlString;// "增加失败";
					}
					else 
					{
						myTrans.Commit();
						this.SqlConn.Close();

						switch (InsertType)
						{
							case "0":
								sReturn = "增加成功";
								break;
							case "1":
								sReturn = "增加成功";
								break;
							case "2":
								string strSql = string.Format("select u_num from system_userdd ");
								str_u_num = this.COM_BASE.GetID(strSql);
								sReturn = str_u_num;
								break;
						}
				
					}
				}
				else
				{
					sReturn = "该界面已经存在！";
				}

			}			
		}

		[WebMethod]
		public void EditData(DataSet ds,string EditType,ref string sReturn)
		{
			SqlCommand mySqlCommand = new SqlCommand();
			SqlTransaction myTrans;
			string SqlString = string.Empty;

			this.SqlConn.Open();//启动连接
			myTrans = this.SqlConn.BeginTransaction();//建立事务
			mySqlCommand.Connection = this.SqlConn;//建立sql命令连接
			mySqlCommand.Transaction = myTrans;//绑定事务

			string str_p_num = ds.Tables[0].Rows[0]["p_num"].ToString();
			string str_m_num = ds.Tables[0].Rows[0]["m_num"].ToString();
			string str_t_name = ds.Tables[0].Rows[0]["t_name"].ToString();
			string strsql = string.Format("select u_num from system_userdd where p_num = '{0}' and m_num = '{1}' and t_name = '{2}'",str_p_num,str_m_num,str_t_name);
			string str_TableName = "system_userdd";
			string s_pk = "u_num";
			string str_u_num = string.Empty;
			int nErr;
			//更新界面点数据
			try
			{
				str_u_num = ds.Tables[0].Rows[0]["u_num"].ToString();
				nErr = this.COM_BASE.UpdateTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ds.Tables[0],ref SqlString,ref s_pk);
			}
			catch (Exception e)
			{
				nErr = 1;
			}		
			//先删除界面点历史字段数据
			if(nErr != 1)
			{
				SqlString = string.Format(" p_num = '{0}' and m_num = '{1}' and t_up = '{2}'",str_p_num,str_m_num,str_t_name);
				nErr = this.COM_BASE.DeleteTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ref SqlString);
			}

			//插入界面点字段数据
			//增加细节数据
			if(nErr != 1)
			{
				try
				{
					nErr= this.COM_BASE.InsertTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ds.Tables[1],ref SqlString);
				}
				catch (Exception e)
				{
					nErr = 1;
				}		
			}

			if (nErr == 1)
			{
				sReturn = SqlString;//"修改失败";
			}
			else 
			{
				switch (EditType)
				{
					case "0":
						sReturn = "修改成功";
						break;
					case "1":
						sReturn = "修改成功";
						break;
					case "2":
						sReturn = str_u_num;
						break;
				}
			}
			if(nErr!=1)
			{
				myTrans.Commit();//提交事务
				this.SqlConn.Close();//终止连接
			}
		}

		[WebMethod]
		public void DeleteData(string[] FieldValue,ref string sReturn)
		{
			string strsql = string.Empty;
			if (FieldValue.Length>0)
			{
				strsql = string.Format(" m_num = '{0}' and t_name = '{1}' or t_up = '{1}'",FieldValue[0],FieldValue[1]);
			}
			SqlCommand mySqlCommand = new SqlCommand();
			SqlTransaction myTrans;
			string SqlString = strsql;

			this.SqlConn.Open();//启动连接
			myTrans = this.SqlConn.BeginTransaction();//建立事务
			mySqlCommand.Connection = this.SqlConn;//建立sql命令连接
			mySqlCommand.Transaction = myTrans;//绑定事务

			string str_TableName = "system_userdd";
			int nErr = this.COM_BASE.DeleteTableBase(ref mySqlCommand,ref SqlConn,ref myTrans,str_TableName,ref SqlString);
			if (nErr == 1)
			{
				sReturn = "删除失败";
			}
			else
			{
				sReturn = "删除成功";
			}
			if(nErr!=1)
			{
				myTrans.Commit();//提交事务
				this.SqlConn.Close();//终止连接
			}
		}
	}
}