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

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

.net编程

开发平台：

C#

User.cs：源码内容
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using System.Configuration;
  5. using System.Data.SqlClient;
  6. using System.Data;
  7. using System.Collections;
  8. using com.etong.DBUtility;
  9. using com.etong.Inform;
  10. using com.etong.SqlDataConnect;
  11. using com.etong.BusinessRule.Zwf;
  12. using com.etong.Model;
  13. using System.Xml;
  14. namespace com.etong.user
  15. {
  16.     public class AllUser
  17.     {
  18.         //设置连接字符串
  19.         private SqlDataConnect.MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  20.         public AllUser()
  21.         {
  22.             //
  23.             // TODO: 在此处添加构造函数逻辑
  24.             //
  25.         }
  26.         /*************************************************************************************************************  
  27.                                              * Module： 用户登陆管理
  28.                                              * Desc： 检验、保存、查询
  29.                                              * Author：徐秀梅
  30.                                              * Date： 2007-03
  31.         **************************************************************************************************************/     
  32.         //根据用户ID返回RoleID
  33.         public ArrayList GetRoleID(int userid)
  34.         {
  35.             ArrayList list = new ArrayList();
  36.             string str = "select RoleID from Tb_Sys_UserRole where UserID="+userid;
  37.             DataSet ds = new DataSet();
  38.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "");
  39.             if (ds.Tables[0].Rows.Count > 0)
  40.             {
  41.                 for (int i = 0; i < ds.Tables[0].Rows.Count; i++)
  42.                 {
  43.                     list.Add(ds.Tables[0].Rows[i][0].ToString());
  44.                 }
  45.             }
  46.             return list; 
  47.         }
  48.         //根据用户名返回EmpID
  49.         public int GetEmpID(int UserID)
  50.         {
  52.             //MSDA.Open();
  53.             int EmpID=0;            
  54.             string str = "select EmpID from Tb_Sys_User where UserID=" + UserID;
  55.             DataSet ds = new DataSet();
  56.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "");
  57.             if (ds.Tables[0].Rows.Count>0)
  58.             {
  59.                 if (ds.Tables[0].Rows[0]["EmpID"].ToString() != "")
  60.                 {
  61.                     EmpID = Convert.ToInt32(ds.Tables[0].Rows[0]["EmpID"].ToString());
  62.                 }
  63.             }          
  64.             MSDA.Close();
  65.             return EmpID;
  66.         }
  68.         //检查用户名和密码（带三个参数）
  69.         public CheckUserInfo PCheckUser(int UserID, string UserPwd,string UserIP)
  70.         {
  71.             MSDA.Open();
  72.             //bool flag = false;
  73.             CheckUserInfo checkuserinfo = null;            
  74.             string str = "select IsIPBound,IPAddress,isLock from Tb_Sys_User where UserID=" + UserID + " and UserPwd='" + UserPwd + "'";
  75.             DataSet ds = new DataSet();
  76.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "");   
  77.             if (ds.Tables[0].Rows.Count> 0)
  78.             {
  79.                 if (Convert.ToInt16(ds.Tables[0].Rows[0]["isLock"].ToString()) == 1)
  80.                     return checkuserinfo;
  81.      
  82.                 if (Convert.ToInt16(ds.Tables[0].Rows[0]["IsIPBound"].ToString()) == 0)
  83.                 {
  84.                     checkuserinfo = GetCheckUserInfo(UserID);
  85.                 }
  86.                 else
  87.                 {
  88.                     if (Convert.ToInt16(ds.Tables[0].Rows[0]["IsIPBound"].ToString()) == 1)
  89.                     {
  90.                         if (ds.Tables[0].Rows[0]["IPAddress"].ToString() == UserIP)
  91.                         {
  92.                              checkuserinfo = GetCheckUserInfo(UserID);
  93.                              try
  94.                              {
  95.                                  checkuserinfo.UserID = Convert.ToInt32(ds.Tables[0].Rows[0]["UserID"]);
  96.                              }
  97.                              catch
  98.                              {
  99.                                  checkuserinfo.UserID = -1;
  100.                              }
  101.                         }
  102.                     }
  103.                 }
  104.             }
  105.             MSDA.Close();          
  106.             return checkuserinfo;
  107.         }
  108.         //检查用户名和密码（带两个参数）
  109.         public bool PCheckUser(int UserID, string UserPwd)
  110.         {
  111.             MSDA.Open();
  112.             bool flag=false;
  113.             string str="select * from Tb_Sys_User where UserID=" + UserID + " and UserPwd='" + UserPwd + "'";
  114.             SqlDataReader dr = MSDA.ExecuteReader(CommandType.Text, str, null);
  115.             if (dr.Read())
  116.             {
  117.                 flag = true;
  118.             }
  119.             MSDA.Close();
  120.             return flag;
  121.         }
  123.         //检查用户名和密码(返回用户名,部门,用户权限)
  124.         public CheckUserInfo GetCheckUserInfo(int UserID)
  125.         { 
  126.             CheckUserInfo checkuserinfo = null;           
  127.             int EmpID = GetEmpID(UserID);
  128.             string UserAccount = GetUserAccount(UserID);
  129.             MSDA.Open();
  130.             if (EmpID != 0||(EmpID==0&&UserAccount=="admin"))
  131.             {
  132.                 checkuserinfo = new CheckUserInfo();
  133.                 checkuserinfo.UserAccount = UserAccount;
  134.                 checkuserinfo.UserID = UserID;
  135.                 checkuserinfo.EmpID = EmpID;
  136.                 DataSet ds = new DataSet();           
  137.                 string str="select EmpName,PrimaryOrgID from Tb_Sys_Employee where EmpID="+ EmpID;
  138.                 ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "");
  139.                 if (ds.Tables[0].Rows.Count > 0)
  140.                 {
  141.                     checkuserinfo.EmpName = ds.Tables[0].Rows[0]["EmpName"].ToString();
  142.                     checkuserinfo.OrgID = Convert.ToInt32(ds.Tables[0].Rows[0]["PrimaryOrgID"]);
  143.                     str = "select OrgName from Tb_Sys_Organization where OrgID=" + checkuserinfo.OrgID;
  144.                     ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "orgname");
  145.                     if (ds.Tables["orgname"].Rows.Count > 0)
  146.                     {
  147.                         checkuserinfo.OrgName = ds.Tables["orgname"].Rows[0]["OrgName"].ToString();
  148.                     }                    
  149.                 }
  150.                 str = "select RoleID from Tb_Sys_User,Tb_Sys_UserRole where Tb_Sys_User.UserID=Tb_Sys_UserRole.UserID and EmpID=" + EmpID;
  151.                 ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "roleid");
  152.                 if (ds.Tables["roleid"].Rows.Count > 0)
  153.                 {
  154.                     if (ds.Tables["roleid"].Rows[0]["RoleID"].ToString() != "")
  155.                     {
  156.                         checkuserinfo.RoleID = Convert.ToInt32(ds.Tables["roleid"].Rows[0]["RoleID"].ToString());
  157.                     }
  158.                 }
  159.                 else
  160.                 {
  161.                     if (UserAccount != "admin")
  162.                     {
  163.                         checkuserinfo.RoleID = -1;
  164.                     }
  165.                 }
  166.             }
  167.             MSDA.Close();
  168.             return checkuserinfo;
  169.         }        
  170.         //根据用户名修改用户密码
  171.         public int PModifyPwd(int UserID, string OldPwd, string NewPwd)
  172.         {           
  173.             int i = -2;                                 
  174.             bool flag = PCheckUser(UserID, OldPwd);
  175.             MSDA.Open();
  176.             string str = "update Tb_Sys_User set UserPwd='" + NewPwd + "'where UserID=" + UserID ;
  177.             if (flag)
  178.             {
  179.                 i = MSDA.ExecuteNonQuery(CommandType.Text, str, null);
  180.                 if (i != -1)
  181.                 {
  182.                     i = 1;
  183.                 }
  184.             }
  185.             MSDA.Close();
  186.             return i;
  187.         }
  188.         //根据职工取UserID
  189.         public DataSet GetUserID(string Empname)
  190.         {
  191.             MSDA.Open();
  192.             string str = "select EmpID from tb_sys_Employee where EmpName='"+Empname+"'";
  193.             DataSet ds1 = null;
  194.             DataSet ds = new DataSet();          
  195.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "EmpID");
  196.             if (ds.Tables[0].Rows.Count > 0)
  197.             {
  198.                 int EmpID = Convert.ToInt32(ds.Tables["EmpID"].Rows[0]["EmpID"].ToString());
  199.                 str = "select UserID,UserAccount,OrgName from tb_sys_User a,tb_sys_Employee b,Tb_Sys_Organization c where a.EmpID=" 
  200.                     + EmpID+" and a.EmpID=b.EmpID and b.PrimaryOrgID=c.OrgID";
  201.                 ds1 = new DataSet();
  202.                 ds1 = MSDA.ExecuteDataset(CommandType.Text, str, null, ds1, "UserID");
  203.             }
  204.             MSDA.Close();
  205.             return ds1;                           
  206.         }
  207.         //根据用户名取UserID
  208.         public DataSet GetUserIDFAccount(string Account)
  209.         {
  210.             MSDA.Open();
  211.             DataSet ds = new DataSet();
  212.             string str = "";
  213.             if (Account != "admin")
  214.             {
  215.                 str = "select UserID,EmpName,OrgName from tb_sys_User a,tb_sys_Employee b,Tb_Sys_Organization c where a.UserAccount like '"
  216.                               + Account + "%'and a.EmpID=b.EmpID and b.PrimaryOrgID=c.OrgID";
  217.             }
  218.             else
  219.             {
  220.                 str = "select UserID from tb_sys_User where UserAccount='admin'";
  221.             }
  222.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "UserID");
  223.             MSDA.Close();
  224.             return ds;
  225.         }
  226.         //根据用户ID取用户名
  227.         public string GetUserAccount(int UserID)
  228.         {
  229.             DataSet ds = new DataSet();
  230.             string str = "select UserAccount from tb_sys_User where UserID=" + UserID;
  231.             ds = MSDA.ExecuteDataset(CommandType.Text, str, null, ds, "Account");
  232.             string UserAccount = ds.Tables["Account"].Rows[0]["UserAccount"].ToString();
  233.             MSDA.Close();
  234.             return UserAccount;
  235.         }
  236.     }
  237.     public class Audit
  238.     { 
  239.         private MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  240.         public Audit()
  241.         {
  242.             //
  243.             // TODO: 在此处添加构造函数逻辑
  244.             //
  245.         }
  246.         /*************************************************************************************************************  
  247.                                              * Module： 访问审核控制信息
  248.                                              * Desc： 添加、查询、删除
  249.                                              * Author：徐秀梅
  250.                                              * Date： 2007-04
  251.         **************************************************************************************************************/
  252.         /// <summary>
  253.         /// 保存访问信息
  254.         /// </summary>
  255.         /// <returns>返回一bool类型值</returns>
  256.         public bool AuditAdd(string ipaddress, string operation, DateTime editdate, string useraccount, 
  257.             DateTime accesstime,string serviceactionname, int callingresult, string callingmodule, int logcate,string empname,string orgname)
  258.         {
  259.             QueryParameterCollection Params = new QueryParameterCollection();
  260.             Params.Clear();
  261.             Params.Add("@ipaddress", ipaddress);            
  262.             Params.Add("@operation", operation);
  263.             Params.Add("@editdate", editdate);
  264.             Params.Add("@useraccount", useraccount);
  265.             Params.Add("@accesstime", accesstime);
  266.             Params.Add("@serviceactionname", serviceactionname);
  267.             Params.Add("@callingresult", callingresult);
  268.             Params.Add("@callingmodule", callingmodule);
  269.             Params.Add("@logcate", logcate);
  270.             Params.Add("@empname", empname);
  271.             Params.Add("@orgname", orgname);
  272.             string sql = "insert into Tb_Sys_Audit values (@ipaddress,'',@operation,@editdate,@useraccount,@accesstime,'localhost',@serviceactionname,'localhost',@callingresult,@callingmodule,@logcate,@empname,@orgname)";
  273.             MSDA.Open();
  275.             NewObj obj = new NewObj();
  276.             bool returnvalue = obj.insert(sql, Params, CommandType.Text);
  278.             MSDA.Close();
  279.             return returnvalue; 
  280.         }
  281.         /// <summary>
  282.         /// 删除访问信息
  283.         /// </summary>
  284.         public void AuditDelete(int auditid)
  285.         {
  286.             string sql = "delete from Tb_Sys_Audit where [AuditID]='" + auditid + "'";
  287.             MSDA.Open();
  288.             MSDA.ExecuteNonQuery(CommandType.Text, sql, null);
  289.             MSDA.Close();
  290.         }
  291.         /// <summary>
  292.         /// 查找指定或全部物资代码记录
  293.         /// </summary>
  294.         /// <param name="SearchTxt">查找内容</param>
  295.         /// <param name="i">查找关键字,例:1:IP地址；2:用户帐号；3:用户名称;4:组织机构;5:访问时间;非1,2,3,4,5且SearchTxt为空:查找全部</param>
  296.         public DataView AuditSearch(string SearchTxt, string i, DateTime StartTime, DateTime EndTime)
  297.         {
  298.             string sql = "select * from Tb_Sys_Audit";
  299.             if (i == "1" && SearchTxt != "")
  300.             {
  301.                 sql = sql + "  where [IPAddress]='" + SearchTxt + "'";
  302.             }
  303.             if (i == "2" && SearchTxt != "")
  304.             {
  305.                 sql = sql + " where [UserAccount]='" + SearchTxt + "'";
  306.             }
  307.             if (i == "3" && SearchTxt != "")
  308.             {
  309.                 sql = sql + " where [EmpName]='" + SearchTxt + "'";
  310.             }
  311.             if (i == "4" && SearchTxt != "")
  312.             {
  313.                 sql = sql + " where [OrgName]='" + SearchTxt + "'";
  314.             }
  315.             if (i=="5" && StartTime != null && EndTime != null)
  316.             {
  317.                 sql = sql + " where [AccessTime] between '" + StartTime + "'and '" + EndTime + "'";
  318.             }  
  319.             DataSet ds = new DataSet();
  320.             MSDA.Open();
  321.             NewObj newobject = new NewObj();
  323.             DataView dv = newobject.Search(sql, null, CommandType.Text).Tables[0].DefaultView;
  326.             MSDA.Close();
  327.             return dv;
  328.         }        
  329.     }
  330.     public class Notice
  331.     {
  332.         private MSSqlDataAccess MSDA = new MSSqlDataAccess(0);    
  333.         public Notice()
  334.         {
  335.             //
  336.             // TODO: 在此处添加构造函数逻辑
  337.             //
  338.         }
  339.         /*************************************************************************************************************  
  340.                                              * Module： 工作流公告管理
  341.                                              * Desc： 添加、更新、删除、查询记录
  342.                                              * Author：徐秀梅
  343.                                              * Date： 2007-04
  344.         **************************************************************************************************************/
  345.         /// <summary>
  346.         /// 添加工作流公告
  347.         /// </summary>
  348.         /// <returns>返回一bool类型值</returns>
  349.         public bool NoticeAdd(string noticetitle,string noticecontent,DateTime invaiddate,DateTime noticedate,int createuserid,int assroleid,int assuserid)
  350.         {
  351.             QueryParameterCollection Params = new QueryParameterCollection();
  352.             Params.Clear();
  353.             Params.Add("@noticetitle", noticetitle);
  354.             Params.Add("@noticecontent", noticecontent);
  355.             Params.Add("@invaiddate", invaiddate);
  356.             Params.Add("@noticedate", noticedate);
  357.             Params.Add("@createuserid", createuserid);
  359.             Params.Add("@assroleid", assroleid);
  360.             Params.Add("@assuserid", assuserid);
  362.             string sSQL = "insert into tb_Notice([NoticeTitle],[NoticeContent],[InvaidDate],[NoticeDate],[CreateUserID],[AssRoleID],[AssUserID]) values(" +
  363.                            "@noticetitle ,@noticecontent,@invaiddate,@noticedate,@createuserid,@assroleid,@assuserid)";
  364.             MSDA.Open();
  366.             NewObj newobject = new NewObj();
  367.             bool returnvalue = newobject.insert(sSQL, Params, CommandType.Text);
  369.             MSDA.Close();
  370.             return returnvalue;
  371.         }
  373.         /// <summary>
  374.         /// 更新工作流公告记录
  375.         /// </summary>
  376.         /// <returns>返回bool类型参数</returns>
  377.         public bool NoticeUpdate(int noticeid,string noticetitle, string noticecontent, DateTime invaiddate, int assroleid, int assuserid)
  378.         {
  379.             QueryParameterCollection Params = new QueryParameterCollection();
  380.             Params.Clear();
  381.             Params.Add("@noticeid", noticeid);
  382.             Params.Add("@noticetitle", noticetitle);
  383.             Params.Add("@noticecontent", noticecontent);
  384.             Params.Add("@invaiddate", invaiddate);
  385.             //Params.Add("@noticedate", noticedate);
  386.             //Params.Add("@createuserid", createuserid);
  388.             Params.Add("@assroleid", assroleid);
  389.             Params.Add("@assuserid", assuserid);
  391.             string sSQL = "update Tb_Notice Set NoticeTitle=@noticetitle,NoticeContent=@noticecontent,InvaidDate=@invaiddate,AssRoleID=@assroleid,AssUserID=@assuserid where NoticeID=@noticeid";
  392.             MSDA.Open();
  393.             NewObj newobject = new NewObj();
  394.             bool returnvalue = newobject.Update(sSQL, Params, CommandType.Text);
  395.             MSDA.Close();
  396.             return returnvalue;
  397.         }
  399.         /// <summary>
  400.         /// 删除工作流公告记录
  401.         /// </summary>
  402.         /// <param name="userid">公告ID</param>
  403.         public void NoticeDelete(int NoticeID)
  404.         {
  405.             string sSQL = "delete from Tb_Notice where [NoticeID]='" + NoticeID + "'";
  406.             MSDA.Open();
  407.             MSDA.ExecuteNonQuery(CommandType.Text, sSQL, null);
  408.             MSDA.Close();
  409.         }
  410.         public void NoticeDelete(int UserID,DateTime starttime,DateTime endtime)
  411.         {
  412.             string sSQL = "delete from Tb_Notice where [NoticeDate] between '" + starttime + "'and '"+endtime+"'";
  413.             if (UserID != 0)
  414.             {
  415.                 sSQL += " and [CreateUserID]=" + UserID;
  416.             }
  417.             MSDA.Open();
  418.             MSDA.ExecuteNonQuery(CommandType.Text, sSQL, null);
  419.             MSDA.Close();
  420.         }
  421.         /// <summary>
  422.         /// 查找工作流公告记录
  423.         /// </summary>      
  424.         public DataView NoticeSearch(int createuserid,int NoticeID)//查找可以修改删除的
  425.         {
  426.             SqlParameter[] paramters ={
  427.                 new SqlParameter ("@Param_UserID",SqlDbType.Int ,4),
  428.                 new SqlParameter ("@Param_NoticID",SqlDbType.Int ,4)
  429.             };
  430.             paramters[0].Value = createuserid;
  431.             paramters[1].Value = NoticeID;
  432.             MSDA.Open();
  433.             DataSet ds =SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetDataNotic", paramters);
  434.             DataView dv = ds.Tables[0].DefaultView;
  435.             MSDA.Close();
  436.             return dv; 
  437.         }
  438.         public DataSet NoticeSearch(DateTime start,DateTime end)//查找某时间段的记录
  439.         {
  440.             string sSQL = "select [NoticeID],[NoticeTitle],[NoticeContent],[InvaidDate],[NoticeDate],[CreateUserID],[AssRoleID],[AssUserID],[UserAccount] from Tb_Notice a,TB_Sys_User b where [NoticeDate] between '"+start+"' and '"+end+"' and a.CreateUserID=b.UserID";
  441.             DataSet ds = new DataSet();
  442.             MSDA.Open();
  443.             ds = MSDA.ExecuteDataset(CommandType.Text, sSQL, null, ds, "");
  444.             MSDA.Close();
  445.             return ds;          
  446.         }
  447.         public DataTable  NoticeSearch(int userid,DateTime invaiddate)//查找用户可以浏览的
  448.         {
  449.             string sSQL = "select [NoticeTitle],[NoticeContent],[NoticeDate],[CreateUserID] from Tb_Notice where "
  450.             +"AssRoleID in (select roleid from Tb_Sys_UserRole where userid = "+userid+") or AssUserID="+userid+" or AssUserID=-1 and InvaidDate>='" + invaiddate+"'";            
  451.             DataTable dt = new DataTable();           
  452.             MSDA.Open();
  453.             NewObj newobject = new NewObj();
  454.             dt = newobject.Search(sSQL, null, CommandType.Text).Tables[0];
  455.             MSDA.Close();
  456.             return dt;
  457.         }
  458.         /// <summary>
  459.         /// 根据角色查找职工记录
  460.         /// </summary>
  461.         public DataView GetUser(int RoleID)
  462.         {
  463.             string sSQL = "select b.userid,empname from tb_sys_employee a,tb_sys_user b,tb_sys_userrole c " +
  464.             "where a.empid=b.empid and b.userid=c.userid and c.roleid=" + RoleID;
  465.             DataSet ds = new DataSet();
  466.             MSDA.Open();
  467.             NewObj newobject = new NewObj();
  468.             DataView dv = newobject.Search(sSQL, null, CommandType.Text).Tables[0].DefaultView;
  469.             MSDA.Close();
  470.             return dv; 
  471.         }
  472.         /// <summary>
  473.         /// 根据用户ID查找职工姓名(EmpName)
  474.         /// </summary>
  475.         public string GetEmpName(int UserID)
  476.         {
  477.             string empname = "";
  478.             string sSQL = "select Empname from tb_sys_employee where empid = (select empid from tb_sys_user where userid=" + UserID+")";
  479.             MSDA.Open();
  480.             DataSet ds = new DataSet();
  481.             ds = MSDA.ExecuteDataset(CommandType.Text, sSQL, null, ds, "EmpName");
  482.             if (ds.Tables[0].Rows.Count > 0)
  483.             {
  484.                 empname = ds.Tables[0].Rows[0]["EmpName"].ToString();
  485.             }
  486.             MSDA.Close();
  487.             return empname;
  488.         }               
  489.     }
  490.     /*************************************************************************************************************  
  491.                                            * Module： 验收工作流项目状态查询                                       
  492.                                            * Author：徐秀梅
  493.                                            * Date： 2007-05
  494.       **************************************************************************************************************/
  495.     public class Status
  496.     {
  497.         private MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  498.         public Status()
  499.         {
  500.             //
  501.             // TODO: 在此处添加构造函数逻辑
  502.             //
  503.         }      
  504.         /// <summary>
  505.         /// 查询
  506.         /// </summary>
  507.         /// <returns>返回一dataview类型值</returns>
  508.         public DataView StatusSearch()
  509.         {            
  510.             MSDA.Open();
  511.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetStatusProject", null);
  512.             DataView dv = ds.Tables[0].DefaultView;
  513.             MSDA.Close();
  514.             return dv;                     
  515.         }
  516.         /// <summary>
  517.         /// 验收流程查询
  518.         /// </summary>
  519.         /// <returns>返回一dataview类型值</returns>
  520.         public DataView StatusSearch1()
  521.         {
  522.             MSDA.Open();
  523.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetStatusProject1", null);
  524.             DataView dv = ds.Tables[0].DefaultView;
  525.             MSDA.Close();
  526.             return dv;
  527.         }
  528.         /// <summary>
  529.         /// 废旧物质流程查询
  530.         /// </summary>
  531.         /// <returns>返回一dataview类型值</returns>
  532.         public DataView OldMatStatusSearch()
  533.         {
  534.             MSDA.Open();
  535.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetOldMatStatusProject", null);
  536.             DataView dv = ds.Tables[0].DefaultView;
  537.             MSDA.Close();
  538.             return dv;
  539.         }
  540.         /// <summary>
  541.         /// 查询Prj
  542.         /// </summary>
  543.         /// <returns>返回一dataset类型值</returns>
  544.         public DataSet AllStatusSearch(int PrjID)
  545.         {
  546.             MSDA.Open();
  547.             SqlParameter paramter = new SqlParameter("@PrjID", SqlDbType.Int, 4);
  548.             paramter.Value = PrjID;
  549.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetAllStatus", paramter); 
  550.             MSDA.Close();
  551.             return ds;
  552.         }
  553.         /// <summary>
  554.         /// 查询验收Prj
  555.         /// </summary>
  556.         /// <returns>返回一dataset类型值</returns>
  557.         public DataSet AllStatusSearch1(int PrjID)
  558.         {
  559.             MSDA.Open();
  560.             SqlParameter paramter = new SqlParameter("@PrjID", SqlDbType.Int, 4);
  561.             paramter.Value = PrjID;
  562.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_GetAllStatus1", paramter);
  563.             MSDA.Close();
  564.             return ds;
  565.         }
  566.         /// <summary>
  567.         /// 查询废旧物质Prj
  568.         /// </summary>
  569.         /// <returns>返回一dataset类型值</returns>
  570.         public DataSet OldMatAllStatusSearch(int PrjID)
  571.         {
  572.             MSDA.Open();
  573.             SqlParameter paramter = new SqlParameter("@PrjID", SqlDbType.Int, 4);
  574.             paramter.Value = PrjID;
  575.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.StoredProcedure, "P_OldMatGetAllStatus", paramter);
  576.             MSDA.Close();
  577.             return ds;
  578.         }
  579.         //项目查询根据状态和类型
  580.         public DataView PrjQuery(int type,int status)
  581.         {
  582.             DataView dv = new DataView();
  583.             string strSQL="";
  584.             MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  585.             if (status < -1)
  586.             {
  587.                 status = -212;            //没有数据
  588.             }
  589.             switch(type)
  590.             {
  591.                 case 1://项目施工流程
  592.                     strSQL = "select * from tb_construct";
  593.                     break;
  594.                 case 2://项目施工工程变更和调整
  595.                     strSQL = "select * from tb_PrjAlert";
  596.                     break;
  597.                 case 3://工程管理验收流程
  598.                     strSQL = "select * from tb_PrjCheck";
  599.                     break;
  600.                 case 4://废旧物资管理流程
  601.                     strSQL = "select * from tb_PrjOldMat";
  602.                     break;
  603.                 case 5://项目工程流程
  604.                     strSQL = "select * from tb_Project";
  605.                     break;
  606.             }
  607.             if (status != -1)
  608.             {
  609.                 strSQL = strSQL + " where Status=" + status;
  610.             }
  611.             try
  612.             {
  613.                 MSDA.Open();
  614.                 dv = MSDA.ExecuteDataView(CommandType.Text, strSQL, null);
  615.             }
  616.             catch (Exception ex)
  617.             {
  618.                 throw ex;
  619.             }
  620.             finally
  621.             {
  622.                 MSDA.Close();
  623.             }
  624.             return dv;
  625.         }
  627.         //项目查询依据项目代码
  628.         //public DataView PrjQureyData()
  629.         //{
  630.         //    DataView dv = new DataView();
  631.         //    string strSQL;
  632.         //    MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  633.         //    strSQL = "select * from tb_Project where ProjectID=" + this.m_pID;
  634.         //    try
  635.         //    {
  636.         //        MSDA.Open();
  637.         //        dv = MSDA.ExecuteDataView(CommandType.Text, strSQL, null);
  638.         //    }
  639.         //    catch (Exception ex)
  640.         //    {
  641.         //        throw ex;
  642.         //    }
  643.         //    finally
  644.         //    {
  645.         //        MSDA.Close();
  646.         //    }
  647.         //    return dv;
  648.         //}
  649.     }
  650.     /*==============================================================================================
  651.      *                               工程管理验收流程
  652.      * ==============================================================================================*/
  653.     public class PrjCheck
  654.     {
  655.         private SqlDataConnect.MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  656.         /// <summary>
  657.         /// 添加项目验收信息,返回"0"表示添加失败，否则成功
  658.         /// </summary>
  659.         /// <param name="prjcheckinfo"></param>
  660.         /// <returns></returns>
  661.         public int AddPrjCheck(PrjCheckInfo prjcheckinfo)
  662.         {
  663.             SqlParameter[] parameters ={ 
  664.                  new SqlParameter("@PrjChID",SqlDbType.Int,4),
  665.                  new SqlParameter("@PrjChName",SqlDbType.VarChar,200),
  666.                  new SqlParameter("@PrjChSort",SqlDbType.VarChar,2),
  667.                  new SqlParameter("@JcTransactor",SqlDbType.VarChar,30),
  668.                  new SqlParameter("@JcCKName",SqlDbType.VarChar,100),
  669.                  new SqlParameter("@JcRKName",SqlDbType.VarChar,100),
  670.                  new SqlParameter("@JcQDName",SqlDbType.VarChar,100),
  671.                  new SqlParameter("@JcHZName",SqlDbType.VarChar,100),
  672.                  new SqlParameter("@CwTransactor",SqlDbType.VarChar,30),
  673.                  new SqlParameter("@CwFName",SqlDbType.VarChar,100),
  674.                  new SqlParameter("@WzTransatctor",SqlDbType.VarChar,30),
  675.                  new SqlParameter("@WzFName",SqlDbType.VarChar,100),
  676.                  new SqlParameter("@ZgTransactor",SqlDbType.VarChar,30),
  677.                  new SqlParameter("@ZgZlFName",SqlDbType.VarChar,100),
  678.                  new SqlParameter("@ZgTzFName",SqlDbType.VarChar,100),
  679.                  new SqlParameter("@ZgHtFName",SqlDbType.VarChar,100),
  680.                  new SqlParameter("@ZgWzFName",SqlDbType.VarChar,100),
  681.                  new SqlParameter("@ZgQTFName",SqlDbType.VarChar,100),
  682.                  new SqlParameter("@GcglTransactor",SqlDbType.VarChar,30),
  683.                  new SqlParameter("@GcglFName",SqlDbType.VarChar,100),
  684.                  new SqlParameter("@GcglGdTransactor",SqlDbType.VarChar,30),
  685.                  new SqlParameter("@GcglGdContect",SqlDbType.VarChar,100),
  686.                  new SqlParameter("@ZgGdTransactor",SqlDbType.VarChar,30),
  687.                  new SqlParameter("@ZgGdContect",SqlDbType.VarChar,100),                 
  688.                  new SqlParameter("@status",SqlDbType.Int,4),
  689.                  new SqlParameter("@nf",SqlDbType.VarChar,4),
  690.                  new SqlParameter("@jd",SqlDbType.VarChar,1),
  691.                  new SqlParameter("@hz",SqlDbType.VarChar,1),
  692.              };
  694.             parameters[0].Direction = ParameterDirection.Output;
  695.             parameters[1].Value = prjcheckinfo.PrjChName;
  696.             parameters[2].Value = prjcheckinfo.PrjChSort;
  697.             parameters[3].Value = prjcheckinfo.JcTransactor;
  698.             parameters[4].Value = prjcheckinfo.JcCKName;
  699.             parameters[5].Value = prjcheckinfo.JcRKName;
  700.             parameters[6].Value = prjcheckinfo.JcQDName;
  701.             parameters[7].Value = prjcheckinfo.JcHZName;
  702.             parameters[8].Value = prjcheckinfo.CwTransactor;
  703.             parameters[9].Value = prjcheckinfo.CwFName;
  704.             parameters[10].Value = prjcheckinfo.WzTransatctor;
  705.             parameters[11].Value = prjcheckinfo.WzFName;
  706.             parameters[12].Value = prjcheckinfo.ZgTransactor;
  707.             parameters[13].Value = prjcheckinfo.ZgZlFName;
  708.             parameters[14].Value = prjcheckinfo.ZgTzFName;
  709.             parameters[15].Value = prjcheckinfo.ZgHtFName;
  710.             parameters[16].Value = prjcheckinfo.ZgWzFName;
  711.             parameters[17].Value = prjcheckinfo.ZgQTFName;
  712.             parameters[18].Value = prjcheckinfo.GcglTransactor;
  713.             parameters[19].Value = prjcheckinfo.GcglFName;
  714.             parameters[20].Value = prjcheckinfo.GcglGdTransactor;
  715.             parameters[21].Value = prjcheckinfo.GcglGdContect;
  716.             parameters[22].Value = prjcheckinfo.ZgGdTransactor;
  717.             parameters[23].Value = prjcheckinfo.ZgGdContect;
  718.             parameters[24].Value = prjcheckinfo.Status;
  719.             parameters[25].Value = prjcheckinfo.NF;
  720.             parameters[26].Value = prjcheckinfo.JD;
  721.             parameters[27].Value = prjcheckinfo.HZ;
  724.             SqlHelper.ExecuteScalar(SqlHelper.connectionString, CommandType.StoredProcedure, "p_Prjcheck_ADD", parameters);
  726.             return (int)parameters[0].Value;
  727.         }
  728.         public DataTable GetOpid(int ParentOrgID)
  729.         {
  730.             string strsqltext = "select * from [TB_Sys_OpRole] where [OpID]=" + ParentOrgID;
  731.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  732.         }
  733.         public string GetEmpType(int EmpID)
  734.         {
  735.             string strEmpType = "";
  736.             DataView dv = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, "select [EmpType] from [Tb_Sys_Employee] where [EmpID]=" + EmpID, null).DefaultView;
  737.             if (dv.Count > 0)
  738.             {
  739.                 strEmpType = dv[0]["EmpType"].ToString();
  740.             }
  741.             return strEmpType;
  742.         }
  743.         public DataTable GetParentStatus(int PrjID, int ActivityID)
  744.         {
  745.             string strsqltext = "select * from tb_wf_actins where wfinstanceid in" +
  746.                             "( select wfinstanceid from tb_wf_instance where prjid=" + PrjID + " and status=3) and activityid in " +
  747.                              "(select parentactid from tb_colony_user where activityid =" + ActivityID + ")";
  748.             return SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, strsqltext, null);
  749.         }
  750.         public bool UpDatePrjch(int PrjChID)
  751.         {
  752.             string sSQL = "update  tb_PrjCheck  Set status=2  where  PrjChID=" + PrjChID;
  753.             MSDA.Open();
  754.             NewObj newobject = new NewObj();
  755.             bool returnvalue = newobject.Update(sSQL, null, CommandType.Text);
  756.             MSDA.Close();
  757.             return returnvalue;
  758.         }
  759.         //符合要求的未汇总的所有文档
  760.         public DataView GetWord(int PrjChID)
  761.         {
  762.             string str = "select * from tb_PrjCheck where PrjChID=" + PrjChID + " and hz='1'";
  763.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.Text, str, null);
  764.             return ds.Tables[0].DefaultView;
  765.         }
  766.         //判断下级活动是否已经产生
  767.         public DataView GetActinsid(int PrjChID, int ActivityID)
  768.         {
  769.             //string str ="select * from tb_wf_actins where activityid=(select parentactid from tb_colony_user where activityid="+
  770.             //ActivityID + ") and wfinstanceid=" + WfInstanceID;
  771.             string str = "select * from tb_wf_actins where wfinstanceid in (select wfinstanceid from tb_wf_instance where prjid=" + PrjChID +
  772.                           "and status=3) and activityid in (select activityid from tb_colony_user where parentactid =" + ActivityID + ")";
  773.             DataSet ds = SqlHelper.ExecuteDataSet(SqlHelper.connectionString, CommandType.Text, str, null);
  774.             return ds.Tables[0].DefaultView;
  775.         }
  776.         //汇总后修改汇总状态
  777.         public int UpdateHZ(int PrjChID)
  778.         {
  779.             string str = "update tb_PrjCheck set hz='2' where PrjChID=" + PrjChID;
  780.             return SqlHelper.ExecuteNonQuery(SqlHelper.connectionString, CommandType.Text, str, null);
  781.         }
  782.         /// <summary>
  783.         /// 获取上级活动记录
  784.         /// </summary>
  785.         /// <param name="activityid">当前活动事例ID</param>
  786.         /// <returns></returns>
  787.         public DataView GetByActInsId(int ActInsID, int PrjChID)
  788.         {
  789.             string sSQL = "select AC1.ACtivityID PreviousActID,AC1.UserID PreviousUserID,AC1.RoleID PreviousRoleID  from tb_wf_actins AC1 where ActivityID in(select ParentActID from tb_Colony_User where  ActivityID " +
  790.                           " in(select AC.ActivityID from tb_wf_actins AC where AC.ActInsID='" + ActInsID + "')) and wfinstanceid in " +
  791.                           "(select wfinstanceid from tb_wf_instance where prjid=" + PrjChID + " and status=3)";
  792.             DataView dv = null;
  793.             try
  794.             {
  795.                 MSDA.Open();
  796.                 dv = SqlHelper.ExecuteDataTable(SqlHelper.connectionString, CommandType.Text, sSQL, null).DefaultView;
  797.                 MSDA.Close();
  798.             }
  799.             catch
  800.             {
  801.                 dv = null;
  802.             }
  803.             return dv;
  805.         }
  806.         /// <summary>
  807.         ///返回工程项目预算表（电子文档）
  808.         /// </summary>
  809.         /// <returns></returns>
  810.         public DataView GetSFileName(int activityid)
  811.         {
  812.             string sSQL = "select * from [tb_Sys_FileName]  where [FID]  in (select FID  from  tb_Colony_FileName1 where ActivityID=" + activityid + ")";
  813.             DataView dv = null;
  814.             MSDA.Open();
  815.             try
  816.             {
  817.                 NewObj newobject = new NewObj();
  818.                 dv = newobject.Search(sSQL, null, CommandType.Text).Tables[0].DefaultView;
  819.             }
  820.             catch (Exception ex)
  821.             {
  822.                 dv = null;
  823.                 throw ex;
  824.             }
  825.             finally
  826.             {
  827.                 MSDA.Close();
  828.             }
  829.             return dv;
  830.         }
  831.         //查询上级用户
  832.         public DataView GetUser(int ActID,int WFActInsID)
  833.         {
  834.             string sSQL = "select EmpName,UserID from tb_sys_employee a ,tb_sys_user b where a.empid=b.empid and a.empid in" +
  835.                         "(select empid from tb_sys_user where userid in" +
  836.                         "(select userid from tb_wf_actins where activityid in" +
  837.                         "(select parentactid from tb_colony_user where activityid in" +
  838.                         "(select activityid from tb_wf_actins where actinsid=" + ActID + ")) and wfinstanceid=" + WFActInsID + "))";
  839.             DataView dv = null;
  840.             MSDA.Open();
  841.             try
  842.             {
  843.                 NewObj newobject = new NewObj();
  844.                 dv = newobject.Search(sSQL, null, CommandType.Text).Tables[0].DefaultView;
  845.             }
  846.             catch (Exception ex)
  847.             {
  848.                 dv = null;
  849.                 throw ex;
  850.             }
  851.             finally
  852.             {
  853.                 MSDA.Close();
  854.             }
  855.             return dv;
  857.         }
  858.         //查找用户类型
  859.         public DataView GetEmptype(int UserID)
  860.         {
  861.             string sSQL = "select [EmpType] from [Tb_Sys_Employee] where [EmpID] in (select [EmpID] from tb_sys_user where userid=" + UserID + ")";
  862.             DataView dv = null;
  863.             MSDA.Open();
  864.             try
  865.             {
  866.                 NewObj newobject = new NewObj();
  867.                 dv = newobject.Search(sSQL, null, CommandType.Text).Tables[0].DefaultView;
  868.             }
  869.             catch (Exception ex)
  870.             {
  871.                 dv = null;
  872.                 throw ex;
  873.             }
  874.             finally
  875.             {
  876.                 MSDA.Close();
  877.             }
  878.             return dv;
  879.         }
  880.         //查找是否是回退活动
  881.         public DataView GetStatus(int ActID)
  882.         {
  883.             string sSQL = "select * from tb_wf_actins where ActInsID="+ActID;
  884.             DataView dv = null;
  885.             MSDA.Open();
  886.             try
  887.             {
  888.                 NewObj newobject = new NewObj();
  889.                 dv = newobject.Search(sSQL, null, CommandType.Text).Tables[0].DefaultView;
  890.             }
  891.             catch (Exception ex)
  892.             {
  893.                 dv = null;
  894.                 throw ex;
  895.             }
  896.             finally
  897.             {
  898.                 MSDA.Close();
  899.             }
  900.             return dv;
  901.         }
  902.     }
  903.      /*==============================================================================================
  904.      *                               工程管理验收流程状态
  905.      * ==============================================================================================*/
  906.     public class WFPrjCh
  907.     {
  908.         private SqlDataConnect.MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  909.         //说明-----全部的值为-1  tb_Project
  910.         private int prjchid;                      //PrjChID
  911.         private string prjchname;                //PrjChName
  912.         private int prjchsort;                  //PrjChSort
  913.         private int status;                  //Status
  914.        
  915.         //项目代码
  916.         public int PrjChID
  917.         {
  918.             set { prjchid = value; }
  919.             get { return prjchid; }
  920.         }
  921.         //项目名称
  922.         public string PrjChName
  923.         {
  924.             set { prjchname = value; }
  925.             get { return prjchname; }
  926.         }
  927.         //项目流水号
  928.         public int PrjChSort
  929.         {
  930.             set { prjchsort = value; }
  931.             get { return prjchsort; }
  932.         }
  933.         //项目编号
  934.         public int Status
  935.         {
  936.             set { status = value; }
  937.             get { return status; }
  938.         }
  939.         //项目查询根据状态和类型
  940.         public DataView PrjChQuery()
  941.         {
  942.             DataView dv = new DataView();
  943.             string strSQL;
  944.             MSSqlDataAccess MSDA = new MSSqlDataAccess(0);
  945.             if (this.prjchsort < -1 || this.prjchsort == 0)
  946.             {
  947.                 this.prjchsort = -212;              //没有数据
  948.             }
  949.             if (this.status < -1)
  950.             {
  951.                 this.status = -212;            //没有数据
  952.             }
  953.             strSQL = "select * from tb_PrjCheck";
  954.             if (this.prjchsort != -1)
  955.                 strSQL = strSQL + " where PrjChSort=" + this.prjchsort;
  956.             if (this.status != -1)
  957.             {
  958.                 if (this.prjchsort != -1)
  959.                     strSQL = strSQL + " and status=" + this.status;
  960.                 else
  961.                     strSQL = strSQL + " where status=" + this.status;
  962.             }
  963.             try
  964.             {
  965.                 MSDA.Open();
  966.                 dv = MSDA.ExecuteDataView(CommandType.Text, strSQL, null);
  967.             }
  968.             catch (Exception ex)
  969.             {
  970.                 throw ex;
  971.             }
  972.             finally
  973.             {
  974.                 MSDA.Close();
  975.             }
  976.             return dv;
  977.         }
  978.        
  979.     }
  980. }