关于中间类的建立

该类对上连接webservice的代理类，对下生成操作逻辑和数据库的连接和操作。界面设计时可直接用ObjectDataSource来连接操作就可以，增加可控性。便于程序的分层设计。

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Web;??? //要在类中引入
using System.Configuration;?? //要在类中引入
using ServiceProxy;

namespace WorkOA
{
??? public class FJ
??? {
??????? string _Url;
??????? string _KEY_B;
??????? DataTable _dt;
??????? public string Message;

??????? public FJ()
??????? {
??????????? if (HttpContext.Current.Session["S_FJ_Table"] == null)
??????????? {
???????????
??????????????? _dt = new DataTable();
??????????????? _dt.Columns.Add(new DataColumn("FJ_ID",typeof(Int32)));
??????????????? _dt.Columns["FJ_ID"].AutoIncrement = true;
??????????????? _dt.Columns["FJ_ID"].AutoIncrementSeed = 1;
??????????????? _dt.Columns["FJ_ID"].AutoIncrementStep = 1;? //加入自增字段帮助检索
??????????????? _dt.PrimaryKey = new DataColumn[] { _dt.Columns["FJ_ID"] };
??????????????? _dt.Columns.Add(new DataColumn("FJ_MNo",typeof(string)));
??????????????? _dt.Columns.Add(new DataColumn("FJ_MKinfoID",typeof(int)));
??????????????? _dt.Columns.Add(new DataColumn("FJ_ML",typeof(string)));
??????????????? _dt.Columns.Add(new DataColumn("FJ_FileName",typeof(string)));
??????????????? _dt.Columns.Add(new DataColumn("FJ_FileType",typeof(string)));
??????????????? _dt.Columns.Add(new DataColumn("FJ_OldName",typeof(string)));

??????????????? HttpContext.Current.Session["S_FJ_Table"] = _dt;
??????????? }
??????????? else
??????????????? _dt = (DataTable)HttpContext.Current.Session["S_FJ_Table"];
??????????? _Url = System.Configuration.ConfigurationManager.AppSettings["myhost.Service"];
??????????? _KEY_B = System.Configuration.ConfigurationManager.AppSettings["KEY_B"];
??????? }

??????? public DataTable DT
??????? {
??????????? get
??????????? {
??????????????? return _dt;
??????????? }
??????????? set
??????????? {
??????????????? _dt = value;
??????????? }
??????? }

??????? public void Clean_FJ_Table()
??????? {
??????????? if (HttpContext.Current.Session["S_FJ_Table"] != null)
??????????? {
??????????????? HttpContext.Current.Session["S_FJ_Table"] = null;
??????????? }
??????? }

??????? public DataTable Get_FJ_Table()
??????? {
??????????? //DT = (DataTable)HttpContext.Current.Session["S_FJ_Table"];
??????????? return _dt;
??????? }

??????? public void Add_FJ_Table(string FJ_MNo,int FJ_MKinfoID,string FJ_ML,string FJ_FileName,string FJ_FileType,string FJ_OldName)
??????? {
??????????? DataRow dr = _dt.NewRow();
??????????? dr["FJ_MNo"] = FJ_MNo;
??????????? dr["FJ_MKinfoID"] = FJ_MKinfoID;
??????????? dr["FJ_ML"] = FJ_ML;
??????????? dr["FJ_FileName"] = FJ_FileName;
??????????? dr["FJ_FileType"] = FJ_FileType;
??????????? dr["FJ_OldName"] = FJ_OldName;
??????????? _dt.Rows.Add(dr);

??????????? HttpContext.Current.Session["S_FJ_Table"] = _dt;?? //为什么不返回也可以保存数据？为什么自动更新Session变量了呢？
??????? }

??????? public void Del_FJ_Table(int FJ_ID)
??????? {
??????????? DataView dv = new DataView(_dt);
??????????? dv.Sort = "FJ_ID";
??????????? int i;
??????????? i = dv.Find(FJ_ID);
??????????? if (i >= 0)
??????????? {
??????????????? dv.Delete(i);
??????????? }
??????????? dv.Sort = null;
??????????? HttpContext.Current.Session["S_FJ_Table"] = _dt;
??????? }

??????? public void UP_FJ_Table(int FJ_ID,string FJ_MNo,string FJ_OldName)
??????? {
??????????? DataView dv = new DataView(_dt);
??????????? dv.Sort = "FJ_ID";
??????????? int i;
??????????? i = dv.Find(FJ_ID);
??????????? if (i >= 0)
??????????? {
??????????????? dv[i][1] = FJ_MNo;
??????????????? dv[i][2] = FJ_MKinfoID;
??????????????? dv[i]["FJ_ML"] = FJ_ML;
??????????????? dv[i]["FJ_FileName"] = FJ_FileName;
??????????????? dv[i]["FJ_FileType"] = FJ_FileType;
??????????????? dv[i]["FJ_OldName"] = FJ_OldName;
??????????? }
??????????? dv.Sort = null;
??????????? HttpContext.Current.Session["S_FJ_Table"] = _dt;
??????? }

??????? public DataTable Get_FJ(string FJ_MNo,int FJ_MKinfoID)
??????? {
??????????? DataTable PTable=new DataTable();
??????????? PTable.Columns.Add(new DataColumn("FJ_MNo",typeof(string)));
??????????? PTable.Columns.Add(new DataColumn("FJ_MKinfoID",typeof(int)));
??????????? DataRow dr = PTable.NewRow();
??????????? dr["FJ_MNo"]=FJ_MNo;
??????????? dr["FJ_MKinfoID"]=FJ_MKinfoID;
??????????? PTable.Rows.Add(dr);
??????????? PTable.TableName = "P_SYS_FJ_Get";
??????????? DataSet ds=new DataSet();
??????????? ds.Tables.Add(PTable);
??????????? ServiceProxy.Service myser = new ServiceProxy.Service(_Url);
??????????? return myser.ExeOperate(ds,"SYS_FJ_Get",_KEY_B).Tables["O_SYS_FJ_Get"];
??????? }

??????? public bool Del_FJ(int FJ_ID)
??????? {
??????????? DataTable PTable = new DataTable();
??????????? PTable.Columns.Add(new DataColumn("FJ_ID",typeof(int)));
??????????? DataRow dr = PTable.NewRow();
??????????? dr["FJ_ID"] = FJ_ID;
??????????? PTable.Rows.Add(dr);
??????????? PTable.TableName = "P_SYS_FJ_Del";
??????????? DataSet ds = new DataSet();
??????????? ds.Tables.Add(PTable);
??????????? ServiceProxy.Service myser = new ServiceProxy.Service(_Url);
??????????? ds = myser.ExeOperate(ds,"SYS_FJ_Del",_KEY_B);
??????????? return Convert.ToBoolean( ds.Tables[0].DefaultView[0][0]);

??????? }

??????? public bool Add_FJ()??????? {??????????? DataSet ds = new DataSet();??????????? _dt.TableName = "P_SYS_FJ_UP";? //要注意，不要忘了??????????? ds.Tables.Add(_dt);??????????? string m = _dt.DefaultView[0][1].ToString();??????????? ServiceProxy.Service myser = new ServiceProxy.Service(_Url);??????????? ds = myser.ExeOperate(ds,"SYS_FJ_UP",_KEY_B);??????????? Message = ds.Tables[0].DefaultView[0][1].ToString();??????????? return Convert.ToBoolean(ds.Tables[0].DefaultView[0][0]);??????? }??? }}