ProcessManager.cs 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. using Newtonsoft.Json.Linq;
  2. using PTMedicalInsurance.Common;
  3. using PTMedicalInsurance.Helper;
  4. using PTMedicalInsurance.Variables;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Linq;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. namespace PTMedicalInsurance.Business
  11. {
  12. class ProcessManager
  13. {
  14. private List<AbstractProcess> Processes { get; set; }
  15. public ProcessManager()
  16. {
  17. Processes = new List<AbstractProcess>();
  18. }
  19. public ProcessManager(List<AbstractProcess> processes)
  20. {
  21. Processes = processes;
  22. }
  23. /// <summary>
  24. /// 增加单个处理流程
  25. /// </summary>
  26. /// <param name="process"></param>
  27. public ProcessManager Add(AbstractProcess process)
  28. {
  29. Processes.Add(process);
  30. return this;
  31. }
  32. /// <summary>
  33. /// 运行
  34. /// </summary>
  35. /// <param name="input"></param>
  36. /// <returns></returns>
  37. public string Run(JObject input)
  38. {
  39. JObject orginalInput = (JObject)input?.DeepClone();
  40. string data = "";
  41. int code = 0;
  42. // 按顺序执行业务
  43. foreach (var process in Processes)
  44. {
  45. if (process.UseOrginal) {
  46. process.OrginalInput = orginalInput;
  47. input = orginalInput; //原始参数
  48. }
  49. if (process.MergeOrginal)
  50. {
  51. //process.OrginalInput = orginalInput;
  52. input.Add("orginalInput", orginalInput); //原始参数
  53. }
  54. var ret = process.Process(input);
  55. data = ret.Data;
  56. code = ret.Code;
  57. if (code < 0)
  58. {
  59. //异常
  60. if (string.IsNullOrEmpty(data))
  61. {
  62. data = ret.ErrMsg;
  63. }
  64. break;
  65. }
  66. if (!string.IsNullOrEmpty(data))
  67. {
  68. input = JObject.Parse(data);
  69. }
  70. }
  71. JObject rtn = JObject.Parse(data);
  72. //返回值检测(兼容)
  73. if (!rtn.ContainsKey("errorCode"))
  74. {
  75. rtn = JsonHelper.setIrisReturnValue(code, "",rtn);
  76. Global.writeLog("异常返回值检测", data, rtn.ToString());
  77. }
  78. return rtn.ToString();
  79. }
  80. }
  81. }