ProcessManager.cs 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  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. var ret = process.Process(input);
  50. data = ret.Data;
  51. code = ret.Code;
  52. if (code < 0)
  53. {
  54. //异常
  55. if (string.IsNullOrEmpty(data))
  56. {
  57. data = ret.ErrMsg;
  58. }
  59. break;
  60. }
  61. if (!string.IsNullOrEmpty(data))
  62. {
  63. input = JObject.Parse(data);
  64. }
  65. }
  66. JObject rtn = JObject.Parse(data);
  67. //返回值检测(兼容)
  68. if (!rtn.ContainsKey("errorCode"))
  69. {
  70. rtn = JsonHelper.setIrisReturnValue(code, "",rtn);
  71. Global.writeLog("异常返回值检测", data, rtn.ToString());
  72. }
  73. return rtn.ToString();
  74. }
  75. }
  76. }