CreatMtrldefExcutor.cs 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.SqlClient;
  4. using JLHHJSvr.BLL;
  5. using JLHHJSvr.Com;
  6. using JLHHJSvr.Com.Model;
  7. using JLHHJSvr.Helper;
  8. using LJLib.DAL.SQL;
  9. using LJLib.Net.SPI.Server;
  10. using Newtonsoft.Json.Linq;
  11. namespace JLHHJSvr.Excutor
  12. {
  13. internal sealed class CreatMtrldefExcutor : ExcutorBase<CreatMtrldefRequest, CreatMtrldefResponse>
  14. {
  15. Dictionary<string, object> replacements = new Dictionary<string, object>();
  16. protected override void ExcuteInternal(CreatMtrldefRequest request, object state, CreatMtrldefResponse rslt)
  17. {
  18. var tokendata = BllHelper.GetToken(request.token);
  19. if (tokendata == null)
  20. {
  21. rslt.ErrMsg = "会话已经中断,请重新登录";
  22. return;
  23. }
  24. if (request.mattressid <= 0)
  25. {
  26. rslt.ErrMsg = "床垫id参数为空!";
  27. return;
  28. }
  29. using (var con = new SqlConnection(GlobalVar.ConnectionString))
  30. using (var cmd = con.CreateCommand())
  31. {
  32. con.Open();
  33. var mattress = new u_mattress();
  34. if (DbSqlHelper.SelectOne(cmd, "u_mattress", "mattressid = @mattressid", new Dictionary<string, object>() { { "mattressid", request.mattressid } }, mattress, "erp_mtrlid,erp_mtrlcode, erp_mtrlname, erp_mtrlmode, erp_mtrltypeid, erp_mtrltype, erp_mtrlunit, erp_mtrlengname,nottax_factory_cost,dept_profitrate,dept_profitrate_rangli,commission,taxes,fob,extras_cost,mattresstypeid,erp_configcodetype") != 1)
  35. {
  36. rslt.ErrMsg = "床垫报价单匹配失败";
  37. return;
  38. }
  39. var interfaceList = new List<u_mattress_interface>();
  40. var selectStr = @"SELECT u_mattress_interface.mattressid
  41. ,printid
  42. ,itemname
  43. ,bj_pzname
  44. ,bj_namemx
  45. ,actual_size
  46. ,sb_craft
  47. ,actual_size_sb
  48. ,erp_pzid
  49. ,ss_rate
  50. ,ls_rate
  51. ,bj_inputtype
  52. ,u_configure_code.pzcode
  53. ,u_configure_code.name AS pzname
  54. FROM u_mattress_interface
  55. left outer join u_mattress on u_mattress.mattressid = u_mattress_interface.mattressid
  56. left outer join u_configure_code on u_configure_code.typeid = u_mattress.erp_configcodetype
  57. and u_mattress_interface.erp_pzid = u_configure_code.pzid";
  58. DbSqlHelper.SelectJoin(cmd, selectStr, "u_mattress_interface.mattressid = @mattressid AND u_mattress_interface.erp_pzid > 0 AND u_mattress_interface.bj_pzname <> '' ", new Dictionary<string, object>() { { "@mattressid", request.mattressid } }, "printid", "mattressid,printid,itemname,bj_pzname,bj_namemx,actual_size,sb_craft,actual_size_sb,erp_pzid,ss_rate,ls_rate,bj_inputtype,pzcode,pzname", 0, 0, interfaceList);
  59. var l1Helper = HelperBase.GetHelper<ERPHelper>(cmd);
  60. l1Helper.context = new HelperBase.Context() { tokendata = tokendata };
  61. l1Helper.CheckLogin();
  62. if (mattress.erp_mtrlid <= 0)
  63. {
  64. mattress = l1Helper.GetMattressMsg(mattress, interfaceList);
  65. var errMsg = l1Helper.SaveMtrldef(mattress, interfaceList);
  66. if (!string.IsNullOrEmpty(errMsg))
  67. {
  68. rslt.ErrMsg = errMsg;
  69. return;
  70. }
  71. }
  72. }
  73. }
  74. /// <summary>
  75. /// 保存物料清单请求参数,没有传入的参数按默认值
  76. /// </summary>
  77. private class SavePrdPfRequest
  78. {
  79. public string token { get; set; }
  80. /// <summary>
  81. /// 物料清单主表 mtrlid,pfcode,flag,affirmflag,Ifdft,inuse,wrkid
  82. /// </summary>
  83. public u_mtrl_pf mtrl_pf { get; set; }
  84. /// <summary>
  85. /// 物料清单明细表 mtrlid,pfcode,sonmtrlid,printid,wrkgrpid,sonpfcode,Sonscale,sonloss,sondecloss
  86. /// pfgroup,dscrp,pfgroupqty,pfklmode,azcode,promode
  87. /// </summary>
  88. public List<u_PrdPF> prdPfs { get; set; }
  89. }
  90. }
  91. }