ActionVo.cs 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. using System.Data;
  2. using System.Data.SqlClient;
  3. using Business.FileFlow.Entity;
  4. using Common;
  5. namespace Business.FileFlow.Vo
  6. {
  7. public class ActionVo
  8. {
  9. /// <summary>
  10. /// 参数赋值
  11. /// </summary>
  12. /// <param name="action">实体类ActionEty</param>
  13. /// <returns>参数数组</returns>
  14. private SqlParameter[] SetPara(ActionEty action)
  15. {
  16. return new[]
  17. {
  18. new SqlParameter("@id", action.Id),
  19. new SqlParameter("@name", action.Name),
  20. new SqlParameter("@remark", action.Remark),
  21. new SqlParameter("@delflag", action.DelFlag),
  22. new SqlParameter("@addUserID", action.AddUserId),
  23. new SqlParameter("@addtime", action.AddTime),
  24. new SqlParameter("@updateUserID", action.UpdateUserId),
  25. new SqlParameter("@lastTime", action.LastTime),
  26. new SqlParameter( "@approveId",action.ApproveId)
  27. };
  28. }
  29. /// <summary>
  30. /// 新增action记录
  31. /// </summary>
  32. /// <param name="action">实体类ActionEty</param>
  33. /// <returns>成功返回空字符串,失败返回错误信息</returns>
  34. public string InsertAction(ActionEty action)
  35. {
  36. var sql =
  37. "insert into action(id,name,remark,delflag,addUserID,addtime,updateUserID,lastTime,approveId) values(@id,@name,@remark,@delflag,@addUserID,@addtime,@updateUserID,@lastTime,@approveId)";
  38. return SqlHelper.ExecSql(sql, SetPara(action));
  39. }
  40. /// <summary>
  41. /// 获取全部流程操作信息
  42. /// </summary>
  43. /// <param name="searchText">查询字段</param>
  44. /// <returns>数据表</returns>
  45. public DataTable AllAction(string searchText)
  46. {
  47. var sql =
  48. "select p.id,p.name,p.remark,sss.depid,p.approveId as pid,sss.username as approvename,p.lastTime,s.username as addusername ,ss.username as updateusername from action p left join SysUser s on s.userid=p.addUserID left join SysUser ss on ss.userid=p.updateUserID left join SysUser sss on sss.userid=p.approveId where p.delflag ='false' ";
  49. if (!string.IsNullOrEmpty(searchText))
  50. {
  51. //根据查询字段 进行查询
  52. sql +=
  53. string.Format(
  54. "and( p.name like '%{0}%' or p.remark like '%{0}%' or s.username like '%{0}%' or ss.username like '%{0}%' or sss.username like '%{0}%' )",
  55. searchText);
  56. }
  57. sql += " order by p.lastTime DESC";
  58. return SqlHelper.ExecSqlDateTable(sql);
  59. }
  60. /// <summary>
  61. /// 更新流程操作信息
  62. /// </summary>
  63. /// <param name="action">实体类ActionEty</param>
  64. /// <returns>成功返回空字符串,失败返回错误信息</returns>
  65. public string UpdateAction(ActionEty action)
  66. {
  67. var sq1 =
  68. "update action set name=@name,remark=@remark,lastTime=@lastTime,updateUserID=@updateUserID,approveId=@approveId where id=@id";
  69. return SqlHelper.ExecSql(sq1, SetPara(action));
  70. }
  71. /// <summary>
  72. /// 根据id删除流程操作信息
  73. /// </summary>
  74. /// <param name="id">流程操作id</param>
  75. /// <returns>成功返回空字符串,失败返回错误信息</returns>
  76. public string DelAction(string id)
  77. {
  78. var sql = "update action set delflag='true' where id in (" + id + ")";
  79. return SqlHelper.ExecSql(sql);
  80. }
  81. /// <summary>
  82. /// 根据userid 获取该用户可审批的操作 用','分割
  83. /// </summary>
  84. /// <param name="userid">用户ID</param>
  85. /// <returns>操作ID集合 用','分割</returns>
  86. public string MyActions(string userid)
  87. {
  88. string myactions = string.Empty;
  89. string sql = "select id from action where approveId=@approveId";
  90. foreach (DataRow row in SqlHelper.ExecSqlDateTable(sql, new SqlParameter("@approveId", userid)).Rows)
  91. {
  92. myactions += row["id"]+",";
  93. }
  94. return myactions.Equals(string.Empty) ? myactions : myactions.TrimEnd(',');
  95. }
  96. }
  97. }