SaveDeptExcutor.cs 3.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.SqlClient;
  4. using System.Linq;
  5. using System.Text;
  6. using JLHHJSvr.BLL;
  7. using JLHHJSvr.Com;
  8. using JLHHJSvr.LJException;
  9. using JLHHJSvr.Tools;
  10. using LJLib.DAL.SQL;
  11. using LJLib.Net.SPI.Server;
  12. using LJLib.SQLEX;
  13. namespace JLHHJSvr.Excutor
  14. {
  15. internal sealed class SaveDeptExcutor : ExcutorBase<SaveDeptRequest, SaveDeptResponse>
  16. {
  17. protected override void ExcuteInternal(SaveDeptRequest request, object state, SaveDeptResponse rslt)
  18. {
  19. var tokendata = BllHelper.GetToken(request.token);
  20. if (tokendata == null)
  21. {
  22. rslt.ErrMsg = "会话已经中断,请重新登录";
  23. return;
  24. }
  25. if (request.dept == null)
  26. {
  27. rslt.ErrMsg = "未提交部门信息";
  28. return;
  29. }
  30. if (string.IsNullOrEmpty(request.dept.deptname))
  31. {
  32. rslt.ErrMsg = "请录入部门名称!";
  33. return;
  34. }
  35. if (request.dept.pricelistid == null || request.dept.pricelistid <= 0)
  36. {
  37. rslt.ErrMsg = "请选择价格表!";
  38. return;
  39. }
  40. using (var con = GlobalVar.ConnectionString.NewSqlConnection())
  41. using (var cmd = con.CreateCommand())
  42. {
  43. con.Open();
  44. // 初始化属性
  45. AutoInit.AutoInitS(cmd, request.dept);
  46. using (cmd.Transaction = con.BeginTransaction())
  47. {
  48. try
  49. {
  50. var dtNow = DateTime.Now;
  51. if (request.dept.deptid == null || request.dept.deptid <= 0)
  52. {
  53. cmd.CommandText = @"SELECT COUNT(deptname) AS cnt FROM u_dept WHERE deptname = @deptname";
  54. cmd.Parameters.Clear();
  55. cmd.Parameters.AddWithValue("@deptname", request.dept.deptname);
  56. var cnt = Convert.ToInt32(cmd.ExecuteScalar());
  57. if (cnt > 0)
  58. {
  59. throw new LJCommonException("存在重复部门名称,请检查!");
  60. }
  61. //新建
  62. request.dept.createtime = dtNow;
  63. request.dept.deptid = BllHelper.GetID(cmd, "u_dept");
  64. var fields = "deptid,deptname,profitrate,pricelistid,springtypeid,createtime,moneyrate,discount,flag,if_rate_auto,manage_amt,mtrltype,managerate,com_profitrate,dannum1_rate,dannum2_rate,dannum3_rate,dannum4_rate,taxes_rate";
  65. DbSqlHelper.Insert(cmd, "u_dept", null, request.dept, fields);
  66. }
  67. else
  68. {
  69. //修改
  70. request.dept.moddate = dtNow;
  71. request.dept.modemp = tokendata.username;
  72. var fields = "deptname,profitrate,pricelistid,springtypeid,moneyrate,discount,flag,if_rate_auto,manage_amt,mtrltype,moddate,modemp,managerate,com_profitrate,dannum1_rate,dannum2_rate,dannum3_rate,dannum4_rate,taxes_rate";
  73. DbSqlHelper.Update(cmd, "u_dept", null, request.dept, "deptid", fields);
  74. }
  75. cmd.Transaction.Commit();
  76. }
  77. catch (Exception e)
  78. {
  79. cmd.Transaction.Rollback();
  80. rslt.ErrMsg = e.ToString();
  81. }
  82. }
  83. }
  84. }
  85. }
  86. }