SaveProfitrateExcutor.cs 3.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  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 SaveProfitrateExcutor : ExcutorBase<SaveProfitrateRequest, SaveProfitrateResponse>
  16. {
  17. protected override void ExcuteInternal(SaveProfitrateRequest request, object state, SaveProfitrateResponse rslt)
  18. {
  19. var tokendata = BllHelper.GetToken(request.token);
  20. if (tokendata == null)
  21. {
  22. rslt.ErrMsg = "会话已经中断,请重新登录";
  23. return;
  24. }
  25. if (!request.list.Any())
  26. {
  27. rslt.ErrMsg = "未提交工厂利润率信息";
  28. return;
  29. }
  30. foreach(var profitrate in request.list)
  31. {
  32. if (profitrate.profitrate < 0)
  33. {
  34. rslt.ErrMsg = "利润率有误,请检查!";
  35. return;
  36. }
  37. }
  38. using (var con = GlobalVar.ConnectionString.NewSqlConnection())
  39. using (var cmd = con.CreateCommand())
  40. {
  41. con.Open();
  42. var dtNow = DateTime.Now;
  43. using (cmd.Transaction = con.BeginTransaction())
  44. {
  45. try
  46. {
  47. foreach (var profitrate in request.list)
  48. {
  49. cmd.CommandText = @"SELECT COUNT(*) AS cnt
  50. FROM u_factory_profitrate
  51. WHERE u_factory_profitrate.deptid = @deptid
  52. AND u_factory_profitrate.bednettypeid_mattresstypeid = @typid
  53. AND u_factory_profitrate.bednet_or_mattress = @kind";
  54. cmd.Parameters.Clear();
  55. cmd.Parameters.AddWithValue("@deptid", profitrate.deptid);
  56. cmd.Parameters.AddWithValue("@typid", profitrate.bednettypeid_mattresstypeid);
  57. cmd.Parameters.AddWithValue("@kind", profitrate.bednet_or_mattress);
  58. var cnt = Convert.ToInt32(cmd.ExecuteScalar());
  59. if (cnt <= 0)
  60. {
  61. AutoInit.AutoInitS(cmd, profitrate);
  62. profitrate.createtime = dtNow;
  63. profitrate.createby = tokendata.username;
  64. var fields = "deptid,bednet_or_mattress,bednettypeid_mattresstypeid,createtime,profitrate,createby";
  65. DbSqlHelper.Insert(cmd, "u_factory_profitrate", null, profitrate, fields);
  66. }
  67. else
  68. {
  69. //修改
  70. var fields = "profitrate";
  71. DbSqlHelper.Update(cmd, "u_factory_profitrate", null, profitrate, "deptid,bednet_or_mattress,bednettypeid_mattresstypeid", fields);
  72. }
  73. }
  74. cmd.Transaction.Commit();
  75. }
  76. catch (Exception e)
  77. {
  78. cmd.Transaction.Rollback();
  79. rslt.ErrMsg = e.ToString();
  80. }
  81. }
  82. }
  83. }
  84. }
  85. }