SaveMattressBcpExcutor.cs 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  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.Com.Model;
  9. using JLHHJSvr.Helper;
  10. using JLHHJSvr.LJException;
  11. using JLHHJSvr.Tools;
  12. using LJLib.DAL.SQL;
  13. using LJLib.Net.SPI.Server;
  14. using LJLib.SQLEX;
  15. namespace JLHHJSvr.Excutor
  16. {
  17. internal sealed class SaveMattressBcpExcutor : ExcutorBase<SaveMattressBcpRequest, SaveMattressBcpResponse>
  18. {
  19. protected override void ExcuteInternal(SaveMattressBcpRequest request, object state, SaveMattressBcpResponse rslt)
  20. {
  21. var tokendata = BllHelper.GetToken(request.token);
  22. if (tokendata == null)
  23. {
  24. rslt.ErrMsg = "会话已经中断,请重新登录";
  25. return;
  26. }
  27. if (request.mattress == null)
  28. {
  29. rslt.ErrMsg = "缺少主表信息";
  30. return;
  31. }
  32. if(request.mattress.mxlist == null || !request.mattress.mxlist.Any())
  33. {
  34. rslt.ErrMsg = "缺少半成品明细";
  35. return;
  36. }
  37. using (var con = GlobalVar.ConnectionString.NewSqlConnection())
  38. using (var cmd = con.CreateCommand())
  39. {
  40. con.Open();
  41. // 初始化属性
  42. AutoInit.AutoInitS(cmd, request.mattress);
  43. using (cmd.Transaction = con.BeginTransaction())
  44. {
  45. try
  46. {
  47. var helper = HelperBase.GetHelper<MattressHelper>(cmd, new HelperBase.Context() { tokendata = tokendata });
  48. helper.SaveMattressBcp(request.mattress);
  49. cmd.Transaction.Commit();
  50. rslt.mattress = new u_semi_finished_product() { billid = request.mattress.billid, billcode = request.mattress.billcode };
  51. }
  52. catch (Exception e)
  53. {
  54. cmd.Transaction.Rollback();
  55. rslt.ErrMsg = e.ToString();
  56. }
  57. }
  58. }
  59. }
  60. }
  61. }