开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > .net编程 > 查看源码
DAL.cs
资源名称：whpower2007-8-24.rar　[点击查看]
上传用户：tiancihang
上传日期：2014-03-12
资源大小：21387k
文件大小：56k
源码类别：

.net编程

开发平台：

C#

DAL.cs：源码内容
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using com.etong.IDAL;
  5. using com.etong.Model;
  6. using com.etong.DBUtility;
  7. using System.Data;
  8. using System.Data.SqlClient;
  9. using com.etong.SqlDataConnect;
  10. using com.etong.BusinessRule.Zwf;
  11. using System.Xml;
  12. using System.Collections;
  14. namespace com.etong.DAL
  15. {
  16.     #region 角色管理类
  17.     public class RoleManage:IRole
  18.     {
  19.         public void AddPermissionToRole(int permissionid, int roleid, int permissionType, string fromDate, string toDate)
  20.         {
  21.             string strSqlText = "Insert into Tb_Sys_RolePerm([RoleID],[PermissionID],[EditDate],[PermissionType],[FromDate],[ToDate])values(" + roleid + "," + permissionid + ",getDate()," + permissionType + ",'" + fromDate + "','" + toDate + "')";
  22.             try
  23.             {
  24.                 SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  25.             }
  26.             catch (Exception ex)
  27.             {
  28.                 throw new Exception(ex.Message);
  29.             }
  30.         }
  32.         public bool AddRole(RoleInfo roleinfo)
  33.         {
  34.             string strSqlText = "Insert into Tb_Sys_Role([RoleName],[RoleDesc],[OrdInal],[CreateRole],[UserRole])values('" + roleinfo.RoleName + "','" + roleinfo.RoleDesc + "'," + roleinfo.OrdInal + "," + roleinfo.CreateRole + "," + roleinfo.UserRole + ")";
  35.             try
  36.             {
  37.                 SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  38.                 return true;
  39.             }
  40.             catch
  41.             {
  42.                 return false;
  43.             }
  44.         }
  46.         public void AddRoleToUser(int roleid, int userid)
  47.         {
  48.             string strSqlText = "Insert into Tb_Sys_UserRole([UserID],[RoleID],[EditDate])values(" + userid + "," + roleid + ",getDate())";
  49.             try
  50.             {
  51.                 SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  52.             }
  53.             catch (Exception ex)
  54.             {
  55.                 throw new Exception(ex.Message);
  56.             }
  57.         }
  59.         public bool DeleteRole(int roleid)
  60.         {
  61.             string strSqlText = "select * from Tb_Sys_Role where [CreateRole]=" + roleid;
  63.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  64.             if (dt.Rows.Count > 0)
  65.             {
  66.                 return false;
  67.             }
  69.             strSqlText = "select * from [tb_Colony_User] where [RoleID]=" + roleid;
  70.             dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  71.             if (dt.Rows.Count > 0)
  72.             {
  73.                 return false;
  74.             }
  76.             strSqlText = "Delete from Tb_Sys_Role where RoleID=" + roleid;
  78.             try
  79.             {
  80.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  81.                 return true;
  82.             }
  83.             catch
  84.             {
  85.                 return false;
  86.             }
  87.         }
  89.         public void DeletePermissionInPermissionRole(int roleid)
  90.         {
  91.             string strSqlText = "Delete from Tb_Sys_RolePerm where RoleID=" + roleid;
  92.             try
  93.             {
  94.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  95.             }
  96.             catch (Exception ex) 
  97.             {
  98.                 throw new Exception(ex.Message);
  99.             }
  100.         }
  102.         public DataTable GetAllRoles()
  103.         {
  104.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select r.[roleid],r.[rolename],r.[roledesc],rr.[rolename] createrole from Tb_Sys_Role r inner join Tb_Sys_Role rr on r.[createrole]=rr.[roleid]", null);
  105.         }
  107.         public DataTable GetPermissionList()
  108.         {
  109.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select [PermID],[DisplayName] from Tb_Sys_Permission", null);
  110.         }
  112.         public DataTable GetPermissionList(int RoleID)
  113.         {
  114.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select p.PermID,p.DisplayName from Tb_Sys_RolePerm as rp,Tb_Sys_Permission as p where rp.PermissionID=p.PermID and rp.RoleID=" + RoleID, null);
  115.         }
  117.         public DataTable GetUserPerissionList(int userid, string sAccount, int rightType)
  118.         {
  119.             //string strSqlText = "select p.[PermID],p.[DisplayName],p.[DefaultPage] from Tb_Sys_Permission p where PermID in(select PermissionID from Tb_Sys_RolePerm where RoleID in (select RoleID from Tb_Sys_UserRole where UserID=" + userid + ")) and ParentresCode=" + rightType;
  120.            // return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  122.             string strSqlText;
  123.             if ((sAccount == "admin" || sAccount == "Admin") && rightType == 1)
  124.             {
  125.                 strSqlText = "select p.[PermID],p.[DisplayName],p.[DefaultPage] from Tb_Sys_Permission p where ParentresCode=" + rightType;
  126.             }
  127.             else
  128.                 strSqlText = "select p.[PermID],p.[DisplayName],p.[DefaultPage] from Tb_Sys_Permission p where PermID in(select PermissionID from Tb_Sys_RolePerm where RoleID in (select RoleID from Tb_Sys_UserRole where UserID=" + userid + ")) and ParentresCode=" + rightType;
  129.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  130.         }
  132.         public DataTable GetRoleByConditions(int roleType, string searchContent, bool isBlurSearch)
  133.         {
  134.             string strSqlText = "select r.[roleid],r.[rolename],r.[roledesc],rr.[rolename] createrole from Tb_Sys_Role r inner join Tb_Sys_Role rr on r.[createrole]=rr.[roleid] where ";
  135.             if (isBlurSearch)//模糊查询
  136.             {
  137.                 switch (roleType)
  138.                 {
  139.                     case 1://角色名称
  140.                         strSqlText = strSqlText + "r.[RoleName] like '%" + searchContent + "%'";
  141.                         goto Label_00B9;
  143.                     case 2://创建者
  144.                         strSqlText = strSqlText + "rr.[RoleName] like '%" + searchContent + "%'";
  145.                         goto Label_00B9;
  147.                     case 3://使用者
  148.                         strSqlText = strSqlText + "rrr.[RoleName] like '%" + searchContent + "%'";
  149.                         goto Label_00B9;
  150.                 }
  151.             }
  152.             else//精确查询
  153.             {
  154.                 switch (roleType)
  155.                 {
  156.                     case 1:
  157.                         strSqlText = strSqlText + "r.[RoleName] ='" + searchContent + "'";
  158.                         goto Label_00B9;
  160.                     case 2:
  161.                         strSqlText = strSqlText + "rr.[RoleName] ='" + searchContent + "'";
  162.                         goto Label_00B9;
  164.                     case 3:
  165.                         strSqlText = strSqlText + "rrr.[RoleName] ='" + searchContent + "'";
  166.                         goto Label_00B9;
  167.                 }
  168.             }
  169.         Label_00B9:
  170.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  171.         }
  173.         public DataTable GetRoleByID(int id)
  174.         {
  175.             string strSqlText = "select * from Tb_Sys_Role where RoleID=" + id;
  176.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  177.         }
  179.         public bool UpdateRole(RoleInfo roleinfo)
  180.         {
  181.             string strSqlText = "Update Tb_Sys_Role set RoleName='" + roleinfo.RoleName + "',RoleDesc='" + roleinfo.RoleDesc + "',OrdInal=" + roleinfo.OrdInal + ",CreateRole=" + roleinfo.CreateRole + ",UserRole=" + roleinfo.UserRole + "where RoleID=" + roleinfo.RoleID;
  182.             try
  183.             {
  184.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  185.                 return true;
  186.             }
  187.             catch
  188.             {
  189.                 return false;
  190.             }
  191.         }
  192.     }
  193.     #endregion
  195.     #region 工程项目实施类
  196.     public class ProjectImplment :IProjectImplement
  197.     {
  198.         /// <summary>
  199.         /// 获取工程项目列表
  200.         /// </summary>
  201.         /// <returns></returns>
  202.         public DataTable GetAllProjects()
  203.         {
  204.             string strSqlText = "select * from tb_Project where status=1";
  205.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strSqlText, null);
  206.         }
  208.         public DataTable GetProjectByID(int id)
  209.         {
  210.             string strsqltext = "select * from [tb_project] where [ProjectID]=" + id;
  211.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  212.         }
  213.         /// <summary>
  214.         /// 
  215.         /// </summary>
  216.         /// <param name="constructid"></param>
  217.         /// <returns></returns>
  218.         public DataTable GetConstructByID(int constructid)
  219.         {
  220.             string strsqltext = "select * from [tb_construct] where [ConID]=" + constructid;
  221.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  222.         }
  223.         /// <summary>
  224.         /// 
  225.         /// </summary>
  226.         /// <returns></returns>
  227.         public DataTable GetAllConstructs()
  228.         {
  229.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.StoredProcedure, "p_construct_getAll", null);
  230.         }
  232.         /// <summary>
  233.         /// 获取指定ID工程项目
  234.         /// </summary>
  235.         /// <param name="ProjectID"></param>
  236.         /// <param name="isGetlist">表示是否要得到明细纪录</param>
  237.         /// <returns></returns>
  238.         public DataSet GetProjectByID(int ProjectID, bool isGetlist)
  239.         {
  240.             SqlParameter[] parameters ={
  241.                 new SqlParameter("@projectid",SqlDbType.Int,4),
  242.                 new SqlParameter ("@isgetlist",SqlDbType.Bit,1)
  243.             };
  244.             parameters[0].Value = ProjectID;
  245.             parameters[1].Value = isGetlist;
  246.             
  247.             return SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "p_Project_GetByID", parameters);
  248.         }
  250.         /// <summary>
  251.         /// 添加客户信息,返回"0"表示添加成功
  252.         /// </summary>
  253.         /// <param name="clientinfo"></param>
  254.         public int AddClient(ClientInfo clientinfo)
  255.         {
  256.             SqlParameter[] parameters ={ 
  257.                 new SqlParameter ("@ClientWorkUnit",SqlDbType.VarChar ,14),
  258.                 new SqlParameter ("@MateWorkUnit",SqlDbType.VarChar ,14),
  259.                 new SqlParameter ("@Number",SqlDbType.VarChar ,20),
  260.                 new SqlParameter ("@ClientNote",SqlDbType .VarChar ,200),
  261.                 new SqlParameter ("@ClientResidence",SqlDbType.VarChar,200),
  262.                 new SqlParameter ("@ClientDegreeID",SqlDbType.Int,4),
  263.                 new SqlParameter ("@ClientBirthday",SqlDbType.NVarChar ,20),
  264.                 new SqlParameter ("@ClientHomeAddress",SqlDbType .VarChar ,200),
  265.                 new SqlParameter ("@ClientIDCard",SqlDbType .VarChar ,30),
  266.                 new SqlParameter ("@ClientMale",SqlDbType .Int ,4),
  267.                 new SqlParameter ("@ClientMarriage",SqlDbType .Int ,4),
  268.                 new SqlParameter ("@ClientName",SqlDbType .VarChar ,20),
  269.                 new SqlParameter ("@ClientTelNum",SqlDbType .VarChar, 100),
  270.                 new SqlParameter ("@Salary",SqlDbType.Decimal ,12),
  271.                 new SqlParameter ("@MateNote",SqlDbType .VarChar ,200),
  272.                 new SqlParameter ("@MateResidence",SqlDbType.VarChar ,200),
  273.                 new SqlParameter ("@MateBirthday",SqlDbType.NVarChar ,20),
  274.                 new SqlParameter ("@MateDegree",SqlDbType.Int ,4),
  275.                 new SqlParameter ("@MateHomeAddress",SqlDbType.VarChar ,200),
  276.                 new SqlParameter ("@MateIDCard",SqlDbType.VarChar ,30),
  277.                 new SqlParameter ("@MateMale",SqlDbType.Int,4),
  278.                 new SqlParameter ("@MateName",SqlDbType.VarChar,20),
  279.                 new SqlParameter ("@MateSalary",SqlDbType.Decimal ,12),
  280.                 new SqlParameter ("returnValue",SqlDbType.Int,4)
  281.             };
  283.             parameters[0].Value = clientinfo.ClientWorkUnit;
  284.             parameters[1].Value = clientinfo.MateWorkUnit;
  285.             parameters[2].Value = clientinfo.Number;
  286.             parameters[3].Value = clientinfo.ClientNote;
  287.             parameters[4].Value = clientinfo.ClientRedience;
  288.             parameters[5].Value = clientinfo.ClientDegreeID;
  289.             parameters[6].Value = clientinfo.ClientBirthday;
  290.             parameters[7].Value = clientinfo.HomeAddress;
  291.             parameters[8].Value = clientinfo.IdentityCard;
  292.             parameters[9].Value = clientinfo.ClientMale;
  293.             parameters[10].Value = clientinfo.ClientMarriage;
  294.             parameters[11].Value = clientinfo.ClientName;
  295.             parameters[12].Value = clientinfo.ClientTelNum;
  296.             parameters[13].Value = clientinfo.Salary;
  297.             parameters[14].Value = clientinfo.MateNote;
  298.             parameters[15].Value = clientinfo.MateRedience;
  299.             parameters[16].Value = clientinfo.MateBirthday;
  300.             parameters[17].Value = clientinfo.MateDegreeID;
  301.             parameters[18].Value = clientinfo.MateHomeAddress;
  302.             parameters[19].Value = clientinfo.MateIdentityCard;
  303.             parameters[20].Value = clientinfo.MateMale;
  304.             parameters[21].Value = clientinfo.MateName;
  305.             parameters[22].Value = clientinfo.Salary;
  306.             parameters[23].Direction = ParameterDirection.ReturnValue;
  307.             
  308.             SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.StoredProcedure, "p_WF_Client_ADD", parameters);
  309.             return (int)parameters[23].Value;
  310.         }
  312.         /// <summary>
  313.         /// 添加项目施工信息,返回"0"表示添加失败，否则成功
  314.         /// </summary>
  315.         /// <param name="constructinfo"></param>
  316.         /// <returns></returns>
  317.         public int AddConstruct(ConstructInfo constructinfo)
  318.         {
  319.              SqlParameter[] parameters ={ 
  320.                  new SqlParameter("@ConID",SqlDbType.Int,4),
  321.                  new SqlParameter("@ConName",SqlDbType.VarChar,200),
  322.                  new SqlParameter("@ConSort",SqlDbType.VarChar,2),
  323.                  new SqlParameter("@JcKgName",SqlDbType.VarChar,100),
  324.                  new SqlParameter("@JcWZTransactor",SqlDbType.VarChar,30),
  325.                  new SqlParameter("@JcWZFName",SqlDbType.VarChar,100),
  326.                  new SqlParameter("@WZTransactor",SqlDbType.VarChar,30),
  327.                  new SqlParameter("@WZFName",SqlDbType.VarChar,100),
  328.                  new SqlParameter("@JcZTransactor",SqlDbType.VarChar,30),
  329.                  new SqlParameter("@JcZFName",SqlDbType.VarChar,100),
  330.                  new SqlParameter("@ZgJdTransactor",SqlDbType.VarChar,30),
  331.                  new SqlParameter("@ZgJdIdea",SqlDbType.VarChar,200),
  332.                  new SqlParameter("@ZgXdTransactor",SqlDbType.VarChar,30),
  333.                  new SqlParameter("@ZgXdIdea",SqlDbType.VarChar,100),
  334.                  new SqlParameter("@JcSBTransactor",SqlDbType.VarChar,30),
  335.                  new SqlParameter("@JcSBFName",SqlDbType.VarChar,100),
  336.                  new SqlParameter("@ZgHzTransactor",SqlDbType.VarChar,30),
  337.                  new SqlParameter("@ZgHzFName",SqlDbType.VarChar,100),
  338.                  new SqlParameter("@GcglTransactor",SqlDbType.VarChar,30),
  339.                  new SqlParameter("@GcglFName",SqlDbType.VarChar,100),
  340.                  new SqlParameter("@JcSJTransactor",SqlDbType.VarChar,30),
  341.                  new SqlParameter("@JcSJFName",SqlDbType.VarChar,100),
  342.                  new SqlParameter("@WZFjTransactor",SqlDbType.VarChar,30),
  343.                  new SqlParameter("@WZFjFName",SqlDbType.VarChar,100),
  344.                  new SqlParameter("@Status",SqlDbType.Int,4),
  345.                  new  SqlParameter("@DocumentXml",SqlDbType.VarChar ,50)
  346.              };
  348.              parameters[0].Direction = ParameterDirection.Output;
  349.              parameters[1].Value = constructinfo.Conname;
  350.              parameters[2].Value = constructinfo.Consort;
  351.              parameters[3].Value = constructinfo.JcKgName;
  352.              parameters[4].Value = constructinfo.JcWZTransator;
  353.              parameters[5].Value = constructinfo.JcWZName;
  354.              parameters[6].Value = constructinfo.WzTransator;
  355.              parameters[7].Value = constructinfo.WzName;
  356.              parameters[8].Value = constructinfo.JcZTransator;
  357.              parameters[9].Value = constructinfo.JcZName;
  358.              parameters[10].Value = constructinfo.ZgJdTransator;
  359.              parameters[11].Value = constructinfo.ZgJdIdea;
  360.              parameters[12].Value = constructinfo.ZgXdTransator;
  361.              parameters[13].Value = constructinfo.ZgXdIdea;
  362.              parameters[14].Value = constructinfo.JcSBTransator;
  363.              parameters[15].Value = constructinfo.JcSBFName;
  364.              parameters[16].Value = constructinfo.ZgHzTransator;
  365.              parameters[17].Value = constructinfo.ZgHzFName;
  366.              parameters[18].Value = constructinfo.GcglTransator;
  367.              parameters[19].Value = constructinfo.GcglName;
  368.              parameters[20].Value = constructinfo.JcSJTranstor;
  369.              parameters[21].Value = constructinfo.JcSJFName;
  370.              parameters[22].Value = constructinfo.WZFjTransator;
  371.              parameters[23].Value = constructinfo.WZFjName;
  372.              parameters[24].Value = constructinfo.Status;
  373.              parameters[25].Value = constructinfo.DocumentXML;
  375.              SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.StoredProcedure, "p_Construct_ADD", parameters);
  377.              return (int)parameters[0].Value;
  378.         }
  380.         /// <summary>
  381.         /// 编辑项目施工信息,返回"0"表示更新成功
  382.         /// </summary>
  383.         /// <param name="constructinfo"></param>
  384.         /// <returns></returns>
  385.         //public int UpdateConstruct(ConstructInfo constructinfo)
  386.         //{
  387.         //    SqlParameter[] parameters ={ 
  388.         //         new SqlParameter("@ConID",SqlDbType.Int,4),
  389.         //         new SqlParameter("@PrjID",SqlDbType.Int,4),
  390.         //         new SqlParameter("@TaskSort",SqlDbType.Int,4),
  391.         //         new SqlParameter("@MatRej",SqlDbType.Int,4),
  392.         //         new SqlParameter("@Rej_ChargeMachine",SqlDbType.Decimal,14),
  393.         //         new SqlParameter("@Rej_ChargeManPower",SqlDbType.Decimal,14),
  394.         //         new SqlParameter("@Rej_ChargeOther",SqlDbType.Decimal,14),
  395.         //         new SqlParameter("@Rej_ChargeStuff",SqlDbType.Decimal,14),
  396.         //         new SqlParameter("@Rej_ChargeSum",SqlDbType.Decimal,15),
  397.         //         new SqlParameter("@Rej_TransactorIdea",SqlDbType.VarChar,800),
  398.         //         new SqlParameter("@Rej_TransactorSignature",SqlDbType.VarChar,20),
  399.         //         new SqlParameter("@Fg_TransactorIdea",SqlDbType.VarChar,200),
  400.         //         new SqlParameter("@Fg_TransactorSignature",SqlDbType.VarChar,20),
  401.         //         new SqlParameter("@Zjl_TransactorIdea",SqlDbType.VarChar,200),
  402.         //         new SqlParameter("@Zjl_TransactorSignature",SqlDbType.VarChar,20),
  403.         //         new SqlParameter("@Mat_Stock",SqlDbType.VarChar,200),
  404.         //         new SqlParameter("@Mat_Grant",SqlDbType.VarChar,200),
  405.         //         new SqlParameter("@Ent_AccountMon",SqlDbType.VarChar,200),
  406.         //         new SqlParameter("@Ent_AddAccount",SqlDbType.Decimal,14),
  407.         //         new SqlParameter("@Ent_Account",SqlDbType.Int,4),
  408.         //         new SqlParameter("@StartWorking",SqlDbType.Int,4),
  409.         //         new SqlParameter("@DrawMat",SqlDbType.Int,4),
  410.         //         new SqlParameter("@PlanFile",SqlDbType.VarChar,100),
  411.         //         new SqlParameter("@ClientInfo",SqlDbType.VarChar,20),
  412.         //         new SqlParameter("@FinishFile",SqlDbType.VarChar,100),
  413.         //         new SqlParameter("@Ys_Manager",SqlDbType.VarChar,20),
  414.         //         new SqlParameter("@YsW_Idea",SqlDbType.VarChar,200),
  415.         //         new SqlParameter("@YsW_Manager",SqlDbType.VarChar,20),
  416.         //         new SqlParameter("@PactFile",SqlDbType.VarChar,100),
  417.         //         new SqlParameter("@PactSq",SqlDbType.VarChar,20),
  418.         //         new SqlParameter("@PactSqIdea",SqlDbType.VarChar,200),
  419.         //         new SqlParameter("@ConStatus",SqlDbType.Int,4),
  420.         //         new SqlParameter("returnValue",SqlDbType.Int,4)
  421.         //     };
  423.         //    parameters[0].Value = constructinfo.ConstructID;
  424.         //    parameters[1].Value = constructinfo.ProjectID;
  425.         //    parameters[2].Value = constructinfo.TaskType;
  426.         //    parameters[3].Value = constructinfo.isChangeMaterial;
  427.         //    parameters[4].Value = constructinfo.Rej_ChargeMachine;
  428.         //    parameters[5].Value = constructinfo.Rej_ChargeManpower;
  429.         //    parameters[6].Value = constructinfo.Rej_ChargeOther;
  430.         //    parameters[7].Value = constructinfo.Rej_ChargeStuff;
  431.         //    parameters[8].Value = constructinfo.Rej_ChargeSum;
  432.         //    parameters[9].Value = constructinfo.Rej_TransactorIdea;
  433.         //    parameters[10].Value = constructinfo.Rej_TransactorSignature;
  434.         //    parameters[11].Value = constructinfo.Fg_TransactorIdea;
  435.         //    parameters[12].Value = constructinfo.Fg_TransactorSignature;
  436.         //    parameters[13].Value = constructinfo.Zjl_TransactorIdea;
  437.         //    parameters[14].Value = constructinfo.Zjl_TransactorSignature;
  438.         //    parameters[15].Value = constructinfo.MatStock;
  439.         //    parameters[16].Value = constructinfo.MatGrant;
  440.         //    parameters[17].Value = constructinfo.EntAccountMon;
  441.         //    parameters[18].Value = constructinfo.EntAddAccount;
  442.         //    parameters[19].Value = constructinfo.EntAccount;
  443.         //    parameters[20].Value = constructinfo.StartWorking;
  444.         //    parameters[21].Value = constructinfo.DrawMat;
  445.         //    parameters[22].Value = constructinfo.PlanFile;
  446.         //    parameters[23].Value = constructinfo.ClientInfo;
  447.         //    parameters[24].Value = constructinfo.FinishFile;
  448.         //    parameters[25].Value = constructinfo.Ys_Manager;
  449.         //    parameters[26].Value = constructinfo.Ysw_Idea;
  450.         //    parameters[27].Value = constructinfo.Ysw_Manager;
  451.         //    parameters[28].Value = constructinfo.PactFile;
  452.         //    parameters[29].Value = constructinfo.PactSq;
  453.         //    parameters[30].Value = constructinfo.PactSqIdea;
  454.         //    parameters[31].Value = constructinfo.ConStatus;
  455.         //    parameters[32].Direction = ParameterDirection.ReturnValue;
  457.         //    SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.StoredProcedure, "p_Construct_Update", parameters);
  458.         //    return (int)parameters[32].Value;
  459.         //}
  461.         //修改项目表里的纪录状态
  462.         public void ChangeStatus(int projectid, int statusValue)
  463.         {
  464.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, "update [tb_Project] set [Status]= " + statusValue + " where [ProjectID]=" + projectid, null);
  465.         }
  467.         //确定施工表里的施工类型
  468.         public void ConfirmConstructTaskType(int constructid, int tasktype)
  469.         {
  470.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, "update [tb_construct] set [TaskSort]= " + tasktype + " where [ConID]=" + constructid, null);
  471.         }
  473.         public int GetProjectID(int constructid)
  474.         {
  475.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select [PrjID] from [tb_construct] where [ConID]=" + constructid, null);
  476.             if (dt.Rows.Count > 0)
  477.             {
  478.                 return Convert.ToInt32(dt.Rows[0]["PrjID"].ToString());
  479.             }
  480.             else
  481.             {
  482.                 return -1;
  483.             }
  484.         }
  486.         public void UpdateTransactorSignature(int constructid,string TransactorSignature)
  487.         {
  488.             string strsqltext = "update [tb_construct] set [Rej_TransactorSignature]='" + TransactorSignature + "' where [ConID]=" + constructid;
  489.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  490.         }
  492.         //修改项目的资金情况(工程实施表与项目表同步修改)
  493.         public void UpdateMoney(int constructid, decimal chargemachine, decimal chargemanpower, decimal chargeother, decimal chargestuff, decimal chargesum, string changeman)
  494.         {
  496.             string strsqltext1 = "update [tb_construct] set [Rej_ChargeMachine]=" + chargemachine + ",[Rej_ChargeManPower]=" + chargemanpower + ",[Rej_ChargeOther]=" + chargeother + ",[Rej_ChargeStuff]=" + chargestuff + ",[Rej_ChargeSum]=" + chargesum + ",[Rej_TransactorSignature]=" + changeman + " where [ConID]=" + constructid;
  497.             int projectid = GetProjectID(constructid);
  498.             string strsqltext2 = "update [tb_Project] set [ChargeMachine]=" + chargemachine + ",[ChargeManPower]=" + chargemanpower + ",[ChargeOther]=" + chargeother + ",[ChargeStuff]=" + chargestuff + ",[ChargeSum]=" + chargesum + " where [ProjectID]=" + projectid;
  500.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext1, null);
  501.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext2, null);
  502.         }
  503.         //分管领导审核
  504.         public void UpdateFg_TransactorIdea(int constructid, string Fg_TransactorIdea, string Fg_TransactorSignature)
  505.         {
  506.             string strsqltext = "update [tb_construct] set [Fg_TransactorIdea]='" + Fg_TransactorIdea + "',[Fg_TransactorSignature]='" + Fg_TransactorSignature + "' where [ConID]=" + constructid;
  507.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  508.         }
  509.         //总经理审核
  510.         public void UpdateZjl_TransactorIdea(int constructid, string Zjl_TransactorIdea, string Zjl_TransactorSignature)
  511.         {
  512.             string strsqltext = "update [tb_construct] set [Zjl_TransactorIdea]='" + Zjl_TransactorIdea + "',[Zjl_TransactorSignature]='" + Zjl_TransactorSignature + "' where [ConID]=" + constructid;
  513.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  514.         }
  515.         //flag为1为物资部门采购情况2为物资发放情况
  516.         public void UpdateMaterialStock(int constructid, string content, int flag)
  517.         {
  518.             string strsqltext=null;
  519.             switch (flag)
  520.             {
  521.                 case 1:
  522.                     strsqltext = "update [tb_construct] set [Mat_Stock]='" + content + "' where [ConID]=" + constructid; break;
  523.                 case 2:
  524.                     strsqltext = "update [tb_construct] set [Mat_Grant]='" + content + "' where [ConID]=" + constructid; break;
  526.             }   
  527.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  528.         }
  530.         public void UpdateContactAuthorzationIdea(int coustructid, string PactSqIdea, string PactSq)
  531.         {
  532.             string strsqltext = "update [tb_construct] set [PactSqIdea]='" + PactSqIdea + "',[PactSq]='" + PactSq + "' where [ConID]=" + coustructid;
  533.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  534.         }
  536.         public void UpdatePlanFile(int constructid, string planfile)
  537.         {
  538.             string strsqltext = "update [tb_construct] set [PlanFile]='" + planfile + "'";
  539.             SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  540.         }
  542.         public  void UpdateFinishFile(int constructid, string finishfile)
  543.         {
  544.             string strsqltext = "update [tb_construct] set [FinishFile]='" + finishfile + "'";
  545.             SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  546.         }
  548.         public void UpdateProjectDocumentBack(int constructid, string clientinfo, string pactfile, string Ys_Manager, string YsW_Idea, string YsW_Manager)
  549.         {
  550.             string strsqltext = "update [tb_construct] set [ClientInfo]='" + clientinfo + "',[PactFile]='" + pactfile + "',[Ys_Manager]='" + Ys_Manager + "',[YsW_Idea]='" + YsW_Idea + "',[YsW_Manager]='" + YsW_Manager + "' where [ConID]=" + constructid;
  551.             SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  552.         }
  554.         public void  UpdateStartWorking(int constructid, string working, int startworking, int drawmat)
  555.         {
  556.             string strsqltext = "update [tb_construct] set [StartWorking]=" + startworking + ",[Working]='" + working + "',[DrawMat]='" + drawmat + "' where [ConID]=" + constructid;
  557.             SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  558.         }
  560.         public DataTable GetDepartmentByID(int id)
  561.         {
  562.             string strsqltext = "select * from [Tb_Sys_Organization] where [OrgID]=" + id;
  563.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  564.         }
  566.         public DataTable GetNextOperatorRole(int CurrOpId)
  567.         {
  568.             string strsqltext = "select * from [Tb_Sys_OpRole] where [OpID]=" + CurrOpId;
  569.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  570.         }
  572.         public static string getTaskSortForString(int constructid)
  573.         {
  574.             string sqlText = "select [TaskSort] from [tb_construct] where [ConID]=" + constructid;
  575.             string returnString = null;
  576.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, sqlText, null);
  577.             if (dt.Rows.Count > 0)
  578.             {
  579.                 switch (Convert.ToInt32 (dt .Rows [0]["TaskSort"].ToString ()))
  580.                 {
  581.                     case 1: returnString = "自营"; break;
  582.                     case 2: returnString = "半委托"; break;
  583.                     case 3: returnString = "全委托"; break;
  584.                     case 4: returnString = "外委"; break;
  585.                 }
  586.             }
  587.             return returnString;
  588.         }
  590.         public static string getMatRejForString(int constructid)
  591.         {
  592.             string sqlText = "select [MatRej] from [tb_construct] where [ConID]=" + constructid;
  593.             string returnString = null;
  594.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, sqlText, null);
  595.             if (dt.Rows.Count > 0)
  596.             {
  597.                 switch (Convert.ToInt32(dt.Rows[0]["MatRej"].ToString()))
  598.                 {
  599.                     case 5: returnString = "更改材料"; break;
  600.                     case 6: returnString = "不更改材料"; break;
  601.                 }
  602.             }
  603.             return returnString;
  604.         }
  606.         public static string GetEmpType(int EmpID)
  607.         {
  608.             string strEmpType = "";
  609.             DataView dv = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select [EmpType] from [Tb_Sys_Employee] where [EmpID]=" + EmpID, null).DefaultView;
  610.             if (dv.Count > 0)
  611.             {
  612.                 strEmpType = dv[0]["EmpType"].ToString();
  613.             }
  614.             return strEmpType;
  615.         }
  617.         public DataView GetStructureStatus()
  618.         {
  619.             DataView dv = null;
  620.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetStructureStatus", null);
  621.             if (dt != null)
  622.             {
  623.                 dv = dt.DefaultView;
  624.             }
  625.             return dv;
  626.         }
  628.         public DataView GetStructureAllStatus(int ConID)
  629.         {
  630.             DataView dv = null;
  631.             SqlParameter parameterConID = new SqlParameter("@ConID", SqlDbType.Int, 4);
  632.             parameterConID.Value = ConID;
  633.             DataTable dt = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetSturctureAllStatus", parameterConID);
  634.             if (dt != null)
  635.                 dv = dt.DefaultView;
  636.             return dv;
  637.         }
  638.     }
  639.     #endregion
  641.     #region 工作流操作类
  642.     public class WorkFolw
  643.     {
  644.         private MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  645.         private EtongZwf etongzwf = new EtongZwf();
  646.         /*=======================================================================================
  647.          * 
  648.          *                           获取工作流起始活动.
  649.          * 
  650.          *======================================================================================= */
  651.         public int ActivityIDGetByWFID(int WfId)
  652.         {
  653.             DataView dvActivity = etongzwf.GetActivityByWFID(WfId);
  654.             if (dvActivity.Count != 0)
  655.             {
  656.                 int activity = Convert.ToInt32(dvActivity[0][0].ToString().Trim());
  657.                 return activity;
  658.             }
  659.             else
  660.                 return 0;
  661.         }
  663.         /*=======================================================================================
  664.          * 
  665.          *                           提交到下一个角色用户申核.
  666.          * 
  667.          *======================================================================================= */
  668.         public string NextColonyRole(int actinsid, int WFInstanceID)
  669.         {
  670.             DataView dvActRole = etongzwf.ColonyUserGetByActId(actinsid);
  671.             if (dvActRole.Count > 0)
  672.             {
  673.                 int ActivityIDNext = Convert.ToInt32(dvActRole[0][0].ToString().Trim());
  674.                 int RoleID = Convert.ToInt32(dvActRole[0][2].ToString().Trim());
  676.                 WFActInsInfo wfactinsinfo = new WFActInsInfo(-1, ActivityIDNext, Convert.ToDateTime(DateTime.Now.ToShortDateString()), Convert.ToDateTime(DateTime.Now.ToShortDateString()),
  677.                                                                 0, Convert.ToDateTime(DateTime.Now.ToShortDateString()), WFInstanceID, "", -1, RoleID);
  679.                 int returnValue = etongzwf.WFActInsADD(wfactinsinfo);
  680.                 if (returnValue > 0)
  681.                 {
  682.                     DataView dvRoleName = etongzwf.RoleGetName(RoleID);
  683.                     if (dvActRole.Count != 0)
  684.                     {
  685.                         return dvRoleName[0][0].ToString();
  686.                     }
  687.                     else
  688.                     {
  689.                         return "-1";
  690.                     }
  691.                 }
  692.                 else
  693.                 {
  694.                     return "-1";
  695.                 }
  696.             }
  697.             else // 不存在上级活动，将 活动状态(Status) 改为 "完成"   注:Status状态(0、正常；1、完成；2、回退；3、回退并完成；4、作废)
  698.             {
  699.                 bool ReValueAIUpdata = false;
  700.                 ReValueAIUpdata = etongzwf.WFActInsUpdata(actinsid, 1);
  702.                 return "-2";
  703.             }
  704.         }
  708.         /*=======================================================================================
  709.          * 
  710.          *                           改变当前工作流活动实例状态.
  711.          * 
  712.          *======================================================================================= */
  713.         public bool WFActInsUpdata(int actinsid, int status, int userid)
  714.         {
  716.             QueryParameterCollection Params = new QueryParameterCollection();
  717.             Params.Clear();
  718.             Params.Add("@actinsid", actinsid);
  719.             Params.Add("@status", status);
  720.             Params.Add("@userid", userid);
  722.             string sSQL = "update [tb_WF_ActIns]  Set [Status]=@status,[UserID]=@userid where [ActInsID]=@actinsid";
  724.             MSDA.Open();
  725.             NewObj newobject = new NewObj();
  726.             bool returnvalue = newobject.Update(sSQL, Params, CommandType.Text);
  727.             MSDA.Close();
  730.             return returnvalue;
  731.         }
  734.         /*================================================================================================================
  735.          * 
  736.          *                          判断当前工作流活动实例状态(0、正常；1、完成(审核通过)；2、回退；3、回退并完成；4、作废)
  737.          * 
  738.          *=============================================================================================================== */
  739.         public static int GetCurrentActivityInstanceStatus(int actinsid)
  740.         {
  741.             string sql = "Select [Status] from [tb_WF_ActIns] where [ActInsID]=" + actinsid;
  742.             DataView dv = SqlServer.GetDataView(sql);
  743.             int tempStatus = 0;
  744.             if (dv.Count > 0)
  745.             {
  746.                 tempStatus = Convert.ToInt32(dv[0]["Status"].ToString());
  747.             }
  748.             return tempStatus;
  749.         }
  751.         /*================================================================================================================
  752.         * 
  753.         *                          找出部门的业务角色的类型(1 科技 2 生产 3 营销 99 未知)
  754.         * 
  755.         *=============================================================================================================== */
  757.         public static string GetOrgOpRoleType(int OpID)
  758.         {
  759.             string sql = "select [OrgDesc] from [Tb_Sys_OpRole] where [OpID]=" + OpID;
  760.             DataView dv = SqlServer.GetDataView(sql);
  761.             int type = -1;
  762.             if (dv.Count > 0)
  763.             {
  764.                 try
  765.                 {
  766.                     type = Convert.ToInt32(dv[0]["OrgDesc"].ToString().Trim());
  767.                 }
  768.                 catch
  769.                 {
  770.                     type = 99;
  771.                 }
  772.             }
  773.             return type.ToString();
  774.         }
  776.         public static string GetBlockReason(int acinstanceid)
  777.         {
  778.             string sql = "select [BlockReason] from [tb_WF_ActIns] where [ActInsID]=" + acinstanceid;
  779.             DataView dv = SqlServer.GetDataView(sql);
  780.             string s = "";
  781.             if (dv.Count > 0)
  782.             {
  783.                 s = dv[0]["BlockReason"].ToString();
  784.             }
  785.             return s;
  786.         }
  789.         public static bool ParentActivitysIsCompleted(int PrjID, int ActivityID)
  790.         {
  791.             int tempCount = 0;
  792.             string sql = "select * from tb_wf_actins where wfinstanceid in" +
  793.                             "(select wfinstanceid from tb_wf_instance where prjid=" + PrjID + " and status=2) and activityid in " +
  794.                              "(select parentactid from tb_colony_user where activityid =" + ActivityID + ")";
  796.             //return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  799.             DataView dv = SqlServer.GetDataView(sql);
  801.             if (dv.Count > 0)
  802.             {
  803.                 for (int i = 0; i < dv.Count; i++)
  804.                 {
  805.                     tempCount += Convert.ToInt32(dv[i]["Status"].ToString().Trim());
  806.                 }
  807.             }
  809.             return (tempCount == dv.Count) ? true : false;
  810.         }
  811.     }
  812.     #endregion
  814.     #region XML操作类
  815.     public class XML
  816.     {
  817.         private XmlDocument xmlDocument;
  818.         private XmlElement xmlElement;
  819.         private string xmlFileName;
  821.         public XML()
  822.         {
  823.         }
  824.         public XML(string xmlFileName)
  825.         {
  826.             this.xmlFileName = xmlFileName;
  827.             xmlDocument = new XmlDocument();
  828.             xmlDocument.Load(xmlFileName);
  829.         }
  831.         public bool CreateXMLDocument(string xmlFileName)
  832.         {
  833.             try
  834.             {
  835.                 string str = "<?xml  version="1.0"   encoding="utf-8"   ?><Documents></Documents>";
  836.                 xmlDocument = new XmlDocument();
  837.                 xmlDocument.LoadXml(str);
  838.                 xmlDocument.Save(xmlFileName);
  839.                 return true;
  840.             }
  841.             catch
  842.             {
  843.                 return false;
  844.             }
  845.         }
  847.         public bool AddXmlNode(DocumentNode documentNode)
  848.         {
  849.             try
  850.             {
  851.                 xmlDocument = new XmlDocument();
  852.                 xmlDocument.Load(xmlFileName);
  854.                 XmlNode root = xmlDocument.SelectSingleNode("Documents");
  855.                 xmlElement = xmlDocument.CreateElement("Document");
  857.                 XmlElement filenameNode = xmlDocument.CreateElement("FileName");
  858.                 filenameNode.InnerText = documentNode.FileName;
  859.                 xmlElement.AppendChild(filenameNode);
  861.                 XmlElement checkerNode = xmlDocument.CreateElement("Checker");
  862.                 checkerNode.InnerText = documentNode.Checker;
  863.                 xmlElement.AppendChild(checkerNode);
  865.                 XmlElement timeNode = xmlDocument.CreateElement("Time");
  866.                 timeNode.InnerText = documentNode.Time;
  867.                 xmlElement.AppendChild(timeNode);
  869.                 XmlElement typeNode = xmlDocument.CreateElement("Type");
  870.                 typeNode.InnerText = documentNode.Type;
  871.                 xmlElement.AppendChild(typeNode);
  873.                 root.AppendChild(xmlElement);
  875.                 xmlDocument.Save(this.xmlFileName);
  876.                 return true;
  877.             }
  879.             catch
  880.             {
  881.                 return false;
  882.             }
  883.         }
  885.        // public ArrayList ReadNode(string nodeName)
  886.         public ArrayList ReadNode(ArrayList nodesname, string RootNodesName)
  887.         {
  888.             /*ArrayList list = new ArrayList();
  889.             string s = "";
  890.             XmlNodeReader xNodeReader = new XmlNodeReader(xmlDocument);
  891.             while (xNodeReader.Read())
  892.             {
  893.                 switch (xNodeReader.NodeType)
  894.                 {
  895.                     case XmlNodeType.Element:
  896.                         s = xNodeReader.Name;
  897.                         break;
  898.                     case XmlNodeType.Text:
  899.                         if (s.Equals(nodeName))
  900.                             list.Add(xNodeReader.Value);
  901.                         break;
  902.                 }
  903.             }
  904.             return list;*/
  907.             ArrayList al = new ArrayList();
  908.             //XmlDocument XmlDoc = new XmlDocument();
  909.             //XmlDoc.Load(address);
  910.             XmlNodeList NodeList = xmlDocument.SelectSingleNode(RootNodesName).ChildNodes;
  911.             foreach (XmlNode Xn in NodeList)
  912.             {
  913.                 XmlElement Xe = (XmlElement)Xn;
  914.                 XmlNodeList NodeList1 = Xe.ChildNodes;
  915.                 //指定命名空间的属性Xe.GetAttribute("")
  916.                 string[] s = new string[nodesname.Count];
  917.                 foreach (XmlNode Xn1 in NodeList1)
  918.                 {
  919.                     XmlElement Xe1 = (XmlElement)Xn1;
  920.                     for (int k = 0; k < nodesname.Count; k++)
  921.                     {
  922.                         if (nodesname[k].ToString() == Xe1.Name)
  923.                         {
  924.                             s[k] = Xe1.InnerText;
  925.                             break;
  926.                         }
  927.                     }
  929.                 }
  930.                 al.Add(s);
  931.             }
  932.             return al;
  934.         }
  936.         public ArrayList ReadNode(string rootNode, string matchValue, bool isMatchValue)
  937.         {
  938.             /*ArrayList list = new ArrayList();
  939.             string s = "";
  940.             //XmlNodeReader xNodeReader = new XmlNodeReader(xmlDocument);
  941.             //while (xNodeReader.reRead())
  942.             //{
  943.             //    switch (xNodeReader.NodeType)
  944.             //    {
  945.             //        case XmlNodeType.Element:
  946.             //            s = xNodeReader.Name;
  947.             //            break;
  948.             //        case XmlNodeType.Text:
  949.             //            if (s.Equals(nodeName))
  950.             //                list.Add(xNodeReader.Value);
  951.             //            break;
  952.             //    }
  953.             //}
  954.             XmlNodeList nodeList = xmlDocument.SelectNodes(nodeName);
  955.             foreach (XmlNode node in nodeList)
  956.             {
  957.                 if (node.SelectSingleNode("Type").InnerText == matchValue)
  958.                 {
  959.                     list.Add(node.SelectSingleNode("FileName").InnerText);
  960.                 }
  961.             }
  962.             return list;*/
  964.             ArrayList al = new ArrayList();
  965.             // XmlDocument XmlDoc = new XmlDocument();
  966.             // XmlDoc.Load(this.m_Address);
  967.             XmlNodeList NodeList = xmlDocument.SelectSingleNode(rootNode).ChildNodes;
  968.             foreach (XmlNode Xn in NodeList)
  969.             {
  970.                 XmlElement Xe = (XmlElement)Xn;
  971.                 XmlNodeList NodeList1 = Xe.ChildNodes;
  972.                 string FName = "", EmpName = "", OpSort = "", sDate = "";
  973.                 foreach (XmlNode Xn1 in NodeList1)
  974.                 {
  975.                     XmlElement Xe1 = (XmlElement)Xn1;
  976.                     switch (Xe1.Name)
  977.                     {
  978.                         case "FileName":
  979.                             FName = Xe1.InnerText;
  980.                             break;
  981.                         case "Checker":
  982.                             EmpName = Xe1.InnerText;
  983.                             break;
  984.                         case "Type":
  985.                             OpSort = Xe1.InnerText;
  986.                             break;
  987.                         case "Time":
  988.                             sDate = Xe1.InnerText;
  989.                             break;
  990.                         default:
  991.                             break;
  992.                     }
  993.                 }
  994.                 if (isMatchValue == false)
  995.                 {
  996.                     DocumentNode EXml = new DocumentNode();
  997.                     EXml.FileName = FName;
  998.                     EXml.Checker = EmpName;
  999.                     EXml.Type = OpSort;
  1000.                     EXml.Time = sDate;
  1001.                     al.Add(EXml);
  1002.                 }
  1003.                 else
  1004.                 {
  1005.                     if (OpSort.Trim() == matchValue)
  1006.                     {
  1007.                         DocumentNode EXml = new DocumentNode();
  1008.                         EXml.FileName = FName;
  1009.                         EXml.Checker = EmpName;
  1010.                         EXml.Type = OpSort;
  1011.                         EXml.Time = sDate;
  1012.                         al.Add(EXml);
  1013.                     }
  1014.                 }
  1015.             }
  1016.             return al;
  1017.         }
  1018.     }
  1019.     #endregion
  1021.     #region 废旧物资管理流程类
  1022.     public class PrjOldMatManager
  1023.     {
  1024.         public PrjOldMatManager()
  1025.         { }
  1027.         public int AddPrjOldMat(PrjOldMatInfo prjOldMatInfo)
  1028.         {
  1029.             SqlParameter[] parameters ={
  1030.                  new SqlParameter("@MatID",SqlDbType.Int,4),
  1031.                  new SqlParameter("@ConID",SqlDbType.Int,4),
  1032.                  new SqlParameter("@ConSort",SqlDbType.Int,4),
  1033.                //  new SqlParameter("@MatName",SqlDbType.VarChar,100),
  1034.                  new SqlParameter("@MatSort",SqlDbType.Int,4),
  1035.                  new SqlParameter("@nf",SqlDbType.VarChar,4),
  1036.                  new SqlParameter("@jd",SqlDbType.VarChar,1),
  1037.                  new SqlParameter("@hz",SqlDbType.VarChar,1),
  1038.                  new SqlParameter("@JcTransactor",SqlDbType.VarChar,50),
  1039.                  new SqlParameter("@ZgTransactor",SqlDbType.VarChar ,50),
  1040.                  new SqlParameter("@ZgHZFName",SqlDbType.VarChar,100),
  1041.                  new SqlParameter("@ZGxFName",SqlDbType.VarChar,100),
  1042.                  new SqlParameter("@ZGdFName",SqlDbType.VarChar,100),
  1043.                  new SqlParameter("@WZjTransactor",SqlDbType.VarChar,50),
  1044.                  new SqlParameter("@WZjIdea",SqlDbType.VarChar,200),
  1045.                  new SqlParameter("@WZhTransactor",SqlDbType.VarChar,50),
  1046.                  new SqlParameter("@WZhFName",SqlDbType.VarChar,100),
  1047.                  new SqlParameter("@WZqTransactor",SqlDbType.VarChar,50),
  1048.                  new SqlParameter("@WZqFName",SqlDbType.VarChar,100),
  1049.                  new SqlParameter("@GcglTransactor",SqlDbType.VarChar,50),
  1050.                  new SqlParameter("@GcglIdea",SqlDbType.VarChar,200),
  1051.                  new SqlParameter("@GSldTansactor",SqlDbType.VarChar ,50),
  1052.                  new SqlParameter("@GSldIdea",SqlDbType.VarChar,200),
  1053.                  new SqlParameter("@WZfTransactor",SqlDbType.VarChar,50),
  1054.                  new SqlParameter("@WZfIdea",SqlDbType.VarChar,200),
  1055.                  new SqlParameter("@ZGgTransactor",SqlDbType.VarChar,50),
  1056.                  new SqlParameter("@ZGgIdea",SqlDbType.VarChar,200),
  1057.                  new SqlParameter("@status",SqlDbType.Int,4)
  1058.             };
  1060.             parameters[0].Direction = ParameterDirection.Output;
  1061.             parameters[1].Value = prjOldMatInfo.ConID;
  1062.             parameters[2].Value = prjOldMatInfo.ConSort;
  1063.            // parameters[3].Value = prjOldMatInfo.;
  1064.             parameters[3].Value = prjOldMatInfo.MatSort;
  1065.             parameters[4].Value = prjOldMatInfo.NF;
  1066.             parameters[5].Value = prjOldMatInfo.JD;
  1067.             parameters[6].Value = prjOldMatInfo.HZ;
  1068.             parameters[7].Value = prjOldMatInfo.JcTransactor;
  1069.             parameters[8].Value = prjOldMatInfo.ZgTransactor;
  1070.             parameters[9].Value = prjOldMatInfo.ZgHZFName;
  1071.             parameters[10].Value = prjOldMatInfo.ZGxFName;
  1072.             parameters[11].Value = prjOldMatInfo.ZGdFName;
  1073.             parameters[12].Value = prjOldMatInfo.WZjTransactor;
  1074.             parameters[13].Value = prjOldMatInfo.WZjIdea;
  1075.             parameters[14].Value = prjOldMatInfo.WZhTransactor;
  1076.             parameters[15].Value = prjOldMatInfo.WZhFName;
  1077.             parameters[16].Value = prjOldMatInfo.WZqTransactor;
  1078.             parameters[17].Value = prjOldMatInfo.WZqFName;
  1079.             parameters[18].Value = prjOldMatInfo.GcglTransactor;
  1080.             parameters[19].Value = prjOldMatInfo.GcglIdea;
  1081.             parameters[20].Value = prjOldMatInfo.GSldTansactor;
  1082.             parameters[21].Value = prjOldMatInfo.GSldIdea;
  1083.             parameters[22].Value = prjOldMatInfo.WZfTransactor;
  1084.             parameters[23].Value = prjOldMatInfo.WZfIdea;
  1085.             parameters[24].Value = prjOldMatInfo.ZGgTransactor;
  1086.             parameters[25].Value = prjOldMatInfo.ZGgIdea;
  1087.             parameters[26].Value = prjOldMatInfo.Status;
  1089.             try
  1090.             {
  1091.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.StoredProcedure, "p_PrjOldMat_add", parameters);
  1092.                 return (int)parameters[0].Value;
  1093.             }
  1094.             catch
  1095.             {
  1096.                 return -1;
  1097.             }
  1098.         }
  1100.         public int UpdateOldMatName(int matid, string matname)
  1101.         {
  1102.             SqlParameter [] parameters ={ 
  1103.                 new SqlParameter ("@MatID",SqlDbType .Int,4),
  1104.                 new SqlParameter ("@MatName",SqlDbType.VarChar ,100),
  1105.                 new SqlParameter ("@returnValue",SqlDbType.Int,4)
  1106.             };
  1108.             parameters[0].Value = matid;
  1109.             parameters[1].Value = matname;
  1110.             parameters[2].Direction = ParameterDirection.ReturnValue;
  1112.             SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.StoredProcedure, "p_MatName_update", parameters);
  1113.             return (int)parameters[2].Value;
  1114.         }
  1115.     }
  1116.     #endregion
  1118.     #region 废旧物资汇总类
  1119.     public class PrjOldMatHZManager
  1120.     {
  1121.         public PrjOldMatHZManager()
  1122.         { }
  1124.         public int AddPrjOldMatHZ(PrjOldMatHZInfo  prjOldMatHZInfo)
  1125.         {
  1126.             SqlParameter[] parameters ={
  1127.                  new SqlParameter("@MatHZID",SqlDbType.Int,4),
  1128.                  new SqlParameter("@HZ",SqlDbType.VarChar,1),
  1129.                  new SqlParameter("@nf",SqlDbType.VarChar,4),
  1130.                  new SqlParameter("@jd",SqlDbType.VarChar,1),
  1131.                  new SqlParameter("@MatHzName",SqlDbType.VarChar,100),
  1132.                  new SqlParameter("@HzFName",SqlDbType.VarChar,100),
  1133.                  new SqlParameter("@WzTransactor",SqlDbType.VarChar,30),
  1134.                  new SqlParameter("@GcglTransactor",SqlDbType.VarChar,20),
  1135.                  new SqlParameter("@GcglIdea",SqlDbType.VarChar,200),
  1136.                  new SqlParameter("@FgTransactor",SqlDbType.VarChar,20),
  1137.                  new SqlParameter("@FgIdea",SqlDbType.VarChar,200),
  1138.                  new SqlParameter("@JcoTransactor",SqlDbType.VarChar,20),
  1139.                  new SqlParameter("@JcoIdea",SqlDbType.VarChar,200),
  1140.                  new SqlParameter("@status",SqlDbType.Int,4),
  1141.             };
  1143.             parameters[0].Direction = ParameterDirection.Output;
  1144.             parameters[1].Value = prjOldMatHZInfo.HZ;
  1145.             parameters[2].Value = prjOldMatHZInfo.NF;
  1146.             parameters[3].Value = prjOldMatHZInfo.JD;
  1147.             parameters[4].Value = prjOldMatHZInfo.MatHZName;
  1148.             parameters[5].Value = prjOldMatHZInfo.HzFName;
  1149.             parameters[6].Value = prjOldMatHZInfo.WzTransactor;
  1150.             parameters[7].Value = prjOldMatHZInfo.GcglTransactor;
  1151.             parameters[8].Value = prjOldMatHZInfo.GcglIdea;
  1152.             parameters[9].Value = prjOldMatHZInfo.FgTransactor;
  1153.             parameters[10].Value = prjOldMatHZInfo.FgIdea;
  1154.             parameters[11].Value = prjOldMatHZInfo.JcoTransactor;
  1155.             parameters[12].Value = prjOldMatHZInfo.JcoIdea;
  1156.             parameters[13].Value = prjOldMatHZInfo.Status;
  1158.             try
  1159.             {
  1160.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.StoredProcedure, "p_PrjOldMatHZ_add", parameters);
  1161.                 return (int)parameters[0].Value;
  1162.             }
  1163.             catch
  1164.             {
  1165.                 return -1;
  1166.             }
  1167.         }
  1168.     }
  1169.     #endregion
  1171.     #region 废旧物资汇总类
  1172.     public class PrjAlertManager
  1173.     {
  1174.         public PrjAlertManager()
  1175.         { }
  1177.         public int AddPrjAlert(PrjAlertInfo prjAlertInfo)
  1178.         {
  1179.             SqlParameter[] parameters ={
  1180.                  new SqlParameter("@AlertID",SqlDbType.Int,4),
  1181.                  new SqlParameter("@ConID",SqlDbType.Int,4),
  1182.                  new SqlParameter("@ConSort",SqlDbType.VarChar,2),
  1183.                  new SqlParameter("@AlertName",SqlDbType.VarChar,100),
  1184.                  new SqlParameter("@BgFName",SqlDbType.VarChar,100),
  1185.                  new SqlParameter("@JcTransactor",SqlDbType.VarChar,30),
  1186.                  new SqlParameter("@JcFName",SqlDbType.VarChar,100),
  1187.                  new SqlParameter("@ZgTransactor",SqlDbType.VarChar,30),
  1188.                  new SqlParameter("@ZgFName",SqlDbType.VarChar,100),
  1189.                  new SqlParameter("@GcglTransactor",SqlDbType.VarChar,20),
  1190.                  new SqlParameter("@GcglIdea",SqlDbType.VarChar,200),
  1191.                  new SqlParameter("@FgTransactor",SqlDbType.VarChar,20),
  1192.                  new SqlParameter("@FgIdea",SqlDbType.VarChar,200),
  1193.                  new SqlParameter("@status",SqlDbType.Int,4),
  1194.             };
  1196.             parameters[0].Direction = ParameterDirection.Output;
  1197.             parameters[1].Value = prjAlertInfo.ConID;
  1198.             parameters[2].Value = prjAlertInfo.ConSort;
  1199.             parameters[3].Value = prjAlertInfo.AlertName;
  1200.             parameters[4].Value = prjAlertInfo.BgFName;
  1201.             parameters[5].Value = prjAlertInfo.Jctransactor;
  1202.             parameters[6].Value = prjAlertInfo.Jcfname;
  1203.             parameters[7].Value = prjAlertInfo.Zgtransactor;
  1204.             parameters[8].Value = prjAlertInfo.Zgfname;
  1205.             parameters[9].Value = prjAlertInfo.Gcgltransactor;
  1206.             parameters[10].Value = prjAlertInfo.Gcglidea;
  1207.             parameters[11].Value = prjAlertInfo.Fgtransactor;
  1208.             parameters[12].Value = prjAlertInfo.Fgidea;
  1209.             parameters[13].Value = prjAlertInfo.Status;
  1211.             try
  1212.             {
  1213.                 SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.StoredProcedure, "p_tb_PrjAlert_add", parameters);
  1214.                 return (int)parameters[0].Value;
  1215.             }
  1216.             catch
  1217.             {
  1218.                 return -1;
  1219.             }
  1220.         }
  1221.     }
  1222.     #endregion
  1223. }