Workflow.cs 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834
  1. using Hotline.FlowEngine.Definitions;
  2. using Hotline.Orders;
  3. using Hotline.Settings;
  4. using Hotline.Share.Dtos;
  5. using Hotline.Share.Enums.FlowEngine;
  6. using Hotline.Share.Enums.Order;
  7. using Hotline.Share.Enums.Settings;
  8. using SqlSugar;
  9. using XF.Domain.Entities;
  10. using XF.Domain.Exceptions;
  11. using XF.Domain.Extensions;
  12. using XF.Domain.Repository;
  13. namespace Hotline.FlowEngine.Workflows;
  14. public partial class Workflow : CreationEntity
  15. {
  16. public string DefinitionId { get; set; }
  17. /// <summary>
  18. /// 流程类型
  19. /// </summary>
  20. public EFlowType FlowType { get; set; }
  21. /// <summary>
  22. /// 审核结果
  23. /// </summary>
  24. public EReviewResult ReviewResult { get; set; }
  25. #region 业务模块(冗余)
  26. public string? ModuleId { get; set; }
  27. public string? ModuleName { get; set; }
  28. public string? ModuleCode { get; set; }
  29. #endregion
  30. /// <summary>
  31. /// 流程标题
  32. /// </summary>
  33. public string Title { get; set; }
  34. /// <summary>
  35. /// 到期时间(期满时间)
  36. /// </summary>
  37. public DateTime ExpiredTime { get; set; }
  38. /// <summary>
  39. /// 即将超期时间
  40. /// </summary>
  41. public DateTime? NearlyExpiredTime { get; set; }
  42. #region 办理时限
  43. /// <summary>
  44. /// 办理时间限制(如:24小时、7个工作日)
  45. /// </summary>
  46. public string? TimeLimit { get; set; }
  47. public int? TimeLimitCount { get; set; }
  48. public ETimeType? TimeLimitUnit { get; set; } = ETimeType.WorkDay;
  49. #endregion
  50. /// <summary>
  51. /// end节点办理完成时间
  52. /// </summary>
  53. public DateTime? EndTime { get; set; }
  54. /// <summary>
  55. /// 流程状态
  56. /// </summary>
  57. public EWorkflowStatus Status { get; set; }
  58. #region 实际办理信息(节点,部门,意见)
  59. /// <summary>
  60. /// 实际办理节点code(会签状态此字段保存最外层会签发起节点code)
  61. /// </summary>
  62. public string? ActualHandleStepCode { get; set; }
  63. /// <summary>
  64. /// 实际办理节点名称(会签状态此字段保存最外层会签发起节点名称)
  65. /// </summary>
  66. public string? ActualHandleStepName { get; set; }
  67. /// <summary>
  68. /// 实际办理节点id
  69. /// </summary>
  70. public string? ActualHandleStepId { get; set; }
  71. /// <summary>
  72. /// 到达实际办理节点时间(stepBox创建时间)
  73. /// </summary>
  74. public DateTime? ActualHandleStepCreateTime { get; set; }
  75. /// <summary>
  76. /// 实际办理节点签收时间
  77. /// </summary>
  78. public DateTime? ActualHandleStepAcceptTime { get; set; }
  79. /// <summary>
  80. /// 实际办理时间
  81. /// </summary>
  82. public DateTime? ActualHandleTime { get; set; }
  83. /// <summary>
  84. /// 实际办理人id
  85. /// </summary>
  86. public string? ActualHandlerId { get; set; }
  87. /// <summary>
  88. /// 实际办理人名称
  89. /// </summary>
  90. public string? ActualHandlerName { get; set; }
  91. /// <summary>
  92. /// 实际办理部门名称
  93. /// </summary>
  94. public string? ActualHandleOrgName { get; set; }
  95. /// <summary>
  96. /// 实际办理部门编码
  97. /// </summary>
  98. public string? ActualHandleOrgCode { get; set; }
  99. /// <summary>
  100. /// 实际办理部门行政区划编码
  101. /// </summary>
  102. public string? ActualHandleOrgAreaCode { get; set; }
  103. /// <summary>
  104. /// 实际办理部门行政区划名称
  105. /// </summary>
  106. public string? ActualHandleOrgAreaName { get; set; }
  107. /// <summary>
  108. /// 实际办理意见(办理中...or 最终办理意见)
  109. /// </summary>
  110. [SugarColumn(Length = 2000)]
  111. public string ActualOpinion { get; set; } = "办理中...";
  112. /// <summary>
  113. /// 真实办理人姓名(手动填写)
  114. /// </summary>
  115. public string? RealHandlerName { get; set; }
  116. /// <summary>
  117. /// 真实办理人电话(手动填写)
  118. /// </summary>
  119. public string? RealHandlerPhone { get; set; }
  120. /// <summary>
  121. /// 沟通方式(手动填写)
  122. /// </summary>
  123. public ERealCommunicationMode? RealCommunicationMode { get; set; }
  124. /// <summary>
  125. /// 沟通时间(手动填写)
  126. /// </summary>
  127. public DateTime? RealCommunicationTime { get; set; }
  128. /// <summary>
  129. /// 沟通地点(手动填写)
  130. /// </summary>
  131. public string? RealCommunicationAddress { get; set; }
  132. /// <summary>
  133. /// 已与市民沟通
  134. /// </summary>
  135. public bool? RealIsContacted { get; set; }
  136. /// <summary>
  137. /// 已与市民现场沟通
  138. /// </summary>
  139. public bool? RealContactLocale { get; set; }
  140. #endregion
  141. #region 当前办理节点信息
  142. /// <summary>
  143. /// 当前办理节点code(非会签:当前被指派节点,会签:会签发起节点)
  144. /// </summary>
  145. public string? CurrentStepCode { get; set; }
  146. /// <summary>
  147. /// 当前节点名称
  148. /// </summary>
  149. public string? CurrentStepName { get; set; }
  150. /// <summary>
  151. /// 当前节点id
  152. /// </summary>
  153. public string? CurrentStepId { get; set; }
  154. /// <summary>
  155. /// 到达当前节点时间(stepBox创建时间)
  156. /// </summary>
  157. public DateTime? CurrentStepCreateTime { get; set; }
  158. /// <summary>
  159. /// 实际办理节点签收时间
  160. /// </summary>
  161. public DateTime? CurrentHandleStepAcceptTime { get; set; }
  162. /// <summary>
  163. /// 实际办理时间
  164. /// </summary>
  165. public DateTime? CurrentHandleTime { get; set; }
  166. /// <summary>
  167. /// 实际办理人id
  168. /// </summary>
  169. public string? CurrentHandlerId { get; set; }
  170. /// <summary>
  171. /// 实际办理人名称
  172. /// </summary>
  173. public string? CurrentHandlerName { get; set; }
  174. /// <summary>
  175. /// 实际办理部门名称
  176. /// </summary>
  177. public string? CurrentHandleOrgName { get; set; }
  178. /// <summary>
  179. /// 实际办理部门编码
  180. /// </summary>
  181. public string? CurrentHandleOrgCode { get; set; }
  182. /// <summary>
  183. /// 实际办理部门行政区划编码
  184. /// </summary>
  185. public string? CurrentHandleOrgAreaCode { get; set; }
  186. /// <summary>
  187. /// 实际办理部门行政区划名称
  188. /// </summary>
  189. public string? CurrentHandleOrgAreaName { get; set; }
  190. #endregion
  191. #region 会签
  192. /// <summary>
  193. /// 会签类型
  194. /// </summary>
  195. public ECounterSignType? CounterSignType { get; set; }
  196. /// <summary>
  197. /// 当前会签办理节点Id,嵌套会签为最外层会签办理节点Id
  198. /// </summary>
  199. public string? TopCountersignStepId { get; set; }
  200. /// <summary>
  201. /// 流程是否处于会签中
  202. /// </summary>
  203. public bool IsInCountersign { get; set; }
  204. #endregion
  205. // /// <summary>
  206. // /// 处理方式(直办、交办)
  207. // /// </summary>
  208. // public EProcessType ProcessType { get; set; } = EProcessType.Zhiban;
  209. //
  210. // /// <summary>
  211. // /// 交办时间(中心交部门办理时间)
  212. // /// </summary>
  213. // public DateTime? CenterToOrgTime { get; set; }
  214. // /// <summary>
  215. // /// 办结时长(分钟)
  216. // /// 办结时间-交办时间
  217. // /// </summary>
  218. // public double HandleDuration { get; set; }
  219. //
  220. // /// <summary>
  221. // /// 办结工作日时长
  222. // /// </summary>
  223. // public double HandleDurationWorkday { get; set; }
  224. /// <summary>
  225. /// 全流程时长(分钟)
  226. /// 归档时间-创建时间
  227. /// </summary>
  228. public double AllDuration { get; set; }
  229. /// <summary>
  230. /// 外部业务唯一标识
  231. /// </summary>
  232. public string ExternalId { get; set; }
  233. #region 当前办理对象
  234. /// <summary>
  235. /// 办理人id
  236. /// </summary>
  237. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  238. public List<HandlerGroupItem> HandlerUsers { get; set; } = new();
  239. /// <summary>
  240. /// 办理部门id
  241. /// </summary>
  242. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  243. public List<HandlerGroupItem> HandlerOrgs { get; set; } = new();
  244. #endregion
  245. #region 流经对象
  246. /// <summary>
  247. /// 流经部门
  248. /// </summary>
  249. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  250. public List<string> FlowedOrgIds { get; set; } = new();
  251. /// <summary>
  252. /// 流经办理人
  253. /// </summary>
  254. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  255. public List<string> FlowedUserIds { get; set; } = new();
  256. #endregion
  257. #region 会签实际办理对象
  258. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  259. public List<string>? CsActualHandleOrgIds { get; set; }
  260. [SugarColumn(ColumnDataType = "json", IsJson = true)]
  261. public List<string>? CsActualHandleUserIds { get; set; }
  262. #endregion
  263. #region 一级部门
  264. /// <summary>
  265. /// 一级部门code
  266. /// </summary>
  267. public string? OrgLevelOneCode { get; set; }
  268. /// <summary>
  269. /// 一级部门名称
  270. /// </summary>
  271. public string? OrgLevelOneName { get; set; }
  272. #endregion
  273. #region 受理人(开启流程的话务员)
  274. /// <summary>
  275. /// 受理人id
  276. /// </summary>
  277. public string? AcceptorId { get; set; }
  278. /// <summary>
  279. /// 受理人名称
  280. /// </summary>
  281. public string? AcceptorName { get; set; }
  282. /// <summary>
  283. /// 受理人工号
  284. /// </summary>
  285. public string? AcceptorStaffNo { get; set; }
  286. /// <summary>
  287. /// 受理人部门编码
  288. /// </summary>
  289. public string? AcceptorOrgId { get; set; }
  290. /// <summary>
  291. /// 受理人部门名称
  292. /// </summary>
  293. public string? AcceptorOrgName { get; set; }
  294. /// <summary>
  295. /// 受理人部门行政区划编码
  296. /// </summary>
  297. public string? AcceptorOrgAreaCode { get; set; }
  298. /// <summary>
  299. /// 受理人部门行政区划名称
  300. /// </summary>
  301. public string? AcceptorOrgAreaName { get; set; }
  302. #endregion
  303. }
  304. public partial class Workflow
  305. {
  306. [Navigate(NavigateType.OneToOne, nameof(DefinitionId))]
  307. public WorkflowDefinition WorkflowDefinition { get; set; }
  308. /// <summary>
  309. /// 补充信息
  310. /// </summary>
  311. [Navigate(NavigateType.OneToMany, nameof(WorkflowSupplement.WorkflowId))]
  312. public List<WorkflowSupplement> Supplements { get; set; }
  313. /// <summary>
  314. /// 会签
  315. /// </summary>
  316. [Navigate(NavigateType.OneToMany, nameof(WorkflowCountersign.WorkflowId))]
  317. public List<WorkflowCountersign> Countersigns { get; set; }
  318. /// <summary>
  319. /// 主节点,依据流转进度动态生成或删除
  320. /// </summary>
  321. //[SugarColumn(IsIgnore = true)]
  322. [Navigate(NavigateType.OneToMany, nameof(WorkflowStep.WorkflowId))]
  323. public List<WorkflowStep> Steps { get; set; }
  324. /// <summary>
  325. /// 流转记录
  326. /// </summary>
  327. [SugarColumn(IsIgnore = true)]
  328. public List<WorkflowTrace> Traces { get; set; } = new();
  329. #region Method
  330. /// <summary>
  331. /// 流程结束
  332. /// </summary>
  333. public void Complete(EReviewResult? reviewResult = EReviewResult.Unknown)
  334. {
  335. if (FlowType is EFlowType.Review && !reviewResult.HasValue)
  336. throw new UserFriendlyException("无审核结果");
  337. Status = EWorkflowStatus.Completed;
  338. EndTime = DateTime.Now;
  339. if (FlowType is EFlowType.Review && ReviewResult is EReviewResult.Unknown)
  340. ReviewResult = reviewResult.Value;
  341. SetAllDuration();
  342. UpdateActualOption();
  343. }
  344. public void Terminate(string opinion)
  345. {
  346. Status = EWorkflowStatus.Terminated;
  347. EndTime = DateTime.Now;
  348. ActualOpinion = opinion;
  349. }
  350. /// <summary>
  351. /// 更新实际办理节点、部门数据
  352. /// </summary>
  353. private void ActualHandle(
  354. WorkflowStep currentStep,
  355. string? actualHandlerId,
  356. string? actualHandlerName,
  357. string? actualHandleOrgCode,
  358. string? actualHandleOrgName,
  359. string? actualHandleOrgAreaCode,
  360. string? actualHandleOrgAreaName)
  361. {
  362. ActualHandleStepCode = currentStep.Code;
  363. ActualHandleStepName = currentStep.Name;
  364. ActualHandleStepId = currentStep.Id;
  365. ActualHandleStepCreateTime = currentStep.CreationTime;
  366. ActualHandleStepAcceptTime = currentStep.AcceptTime;
  367. ActualHandleTime = DateTime.Now;
  368. ActualHandlerId = actualHandlerId;
  369. ActualHandlerName = actualHandlerName;
  370. ActualHandleOrgCode = actualHandleOrgCode;
  371. ActualHandleOrgName = actualHandleOrgName;
  372. ActualHandleOrgAreaCode = actualHandleOrgAreaCode;
  373. ActualHandleOrgAreaName = actualHandleOrgAreaName;
  374. }
  375. /// <summary>
  376. /// 归档时为最终办理意见赋值
  377. /// </summary>
  378. public void UpdateActualOption()
  379. {
  380. if(FlowType is EFlowType.Review) return;
  381. var step = Steps.FirstOrDefault(d => d.Id == ActualHandleStepId);
  382. if (step is null)
  383. throw new UserFriendlyException($"未查询到对应实际办理子节点,workflowId: {Id}");
  384. ActualOpinion = step.Opinion;
  385. ActualHandleStepAcceptTime = step.AcceptTime;
  386. }
  387. /// <summary>
  388. /// 更新workflow中实际办理节点数据(节点,时间,部门)
  389. /// </summary>
  390. public void UpdateWorkflowActualHandleInfo(WorkflowStep currentStep,
  391. string actualHandlerId, string? actualHandlerName,
  392. string actualHandleOrgCode, string? actualHandleOrgName,
  393. string? actualHandleOrgAreaCode, string? actualHandleOrgAreaName,
  394. int currentHandlerOrgLevel)
  395. {
  396. /*
  397. a.会签中:记录顶级会签发起节点, 会签结束前不更新。会签结束后再发起会签才会记录下一次会签的顶级发起节点
  398. b.非会签中,记录当前节点
  399. */
  400. if (currentStep.IsInCountersign()) return;
  401. if (currentStep.StepType is EStepType.Summary or EStepType.End) return;
  402. ActualHandle(currentStep,
  403. actualHandlerId, actualHandlerName,
  404. actualHandleOrgCode, actualHandleOrgName,
  405. actualHandleOrgAreaCode, actualHandleOrgAreaName);
  406. //SetHandleDuration();
  407. //实际办理部门为一级部门时记录
  408. if (currentHandlerOrgLevel == 1)
  409. UpdateLevelOneOrg(actualHandleOrgCode, actualHandleOrgName);
  410. }
  411. /// <summary>
  412. /// 更新当前办理节点信息
  413. /// </summary>
  414. public void UpdateWorkflowCurrentStepInfo(
  415. bool isStartCountersign,
  416. string? handlerId,
  417. string? handlerName,
  418. string? handleOrgCode,
  419. string? handleOrgName,
  420. string? handleOrgAreaCode,
  421. string? handleOrgAreaName,
  422. WorkflowStep? currentStep = null,
  423. WorkflowStep? nextStep = null)
  424. {
  425. //非会签:指当前被指派节点,会签:会签发起节点
  426. if (IsInCountersign) return;
  427. if (isStartCountersign && currentStep is null)
  428. throw new UserFriendlyException("开启会签时,会签发起节点不能为空");
  429. if (!isStartCountersign && nextStep is null)
  430. throw new UserFriendlyException("未开启会签时,被指派节点不能为空");
  431. CurrentHandle(
  432. isStartCountersign ? currentStep : nextStep,
  433. handlerId,
  434. handlerName,
  435. handleOrgCode,
  436. handleOrgName,
  437. handleOrgAreaCode,
  438. handleOrgAreaName
  439. );
  440. }
  441. public void CurrentHandle(
  442. WorkflowStep step,
  443. string? handlerId,
  444. string? handlerName,
  445. string? handleOrgCode,
  446. string? handleOrgName,
  447. string? handleOrgAreaCode,
  448. string? handleOrgAreaName)
  449. {
  450. CurrentStepCode = step.Code;
  451. CurrentStepName = step.Name;
  452. CurrentStepId = step.Id;
  453. CurrentStepCreateTime = step.CreationTime;
  454. CurrentHandleStepAcceptTime = step.AcceptTime;
  455. CurrentHandleTime = DateTime.Now;
  456. CurrentHandlerId = handlerId;
  457. CurrentHandlerName = handlerName;
  458. CurrentHandleOrgCode = handleOrgCode;
  459. CurrentHandleOrgName = handleOrgName;
  460. CurrentHandleOrgAreaCode = handleOrgAreaCode;
  461. CurrentHandleOrgAreaName = handleOrgAreaName;
  462. }
  463. /// <summary>
  464. /// 检查会签是否结束
  465. /// </summary>
  466. public bool CheckIfCountersignOver()
  467. {
  468. return Countersigns.All(d => d.IsCompleted());
  469. }
  470. ///// <summary>
  471. ///// 流程是否处于会签中
  472. ///// </summary>
  473. ///// <returns></returns>
  474. //public bool IsInCountersign() => !string.IsNullOrEmpty(TopCountersignStepId);
  475. /// <summary>
  476. /// 开始会签
  477. /// </summary>
  478. public void StartCountersign(string startCsStepId, ECounterSignType counterSignType)
  479. {
  480. IsInCountersign = true;
  481. TopCountersignStepId = startCsStepId;
  482. CounterSignType = counterSignType;
  483. }
  484. /// <summary>
  485. /// 结束流程会签状态(保留topStepId创建节点时判断用,直到下次会签开启时更新)
  486. /// </summary>
  487. public void EndCountersign() => IsInCountersign = false;
  488. /// <summary>
  489. /// 重置最终办理意见
  490. /// </summary>
  491. public void ResetOption() => ActualOpinion = "办理中...";
  492. /// <summary>
  493. /// 状态设置为可流转
  494. /// </summary>
  495. public void SetStatusRunnable() => Status = EWorkflowStatus.Runnable;
  496. /// <summary>
  497. /// 重新设置办理人(删除当前待办人/部门),撤回/跳转场景,因当前办理人不是流程指定办理人
  498. /// </summary>
  499. /// <param name="assignType"></param>
  500. /// <param name="handlerObjects"></param>
  501. public void ResetHandlers(EFlowAssignType assignType, List<HandlerGroupItem> handlerObjects)
  502. {
  503. HandlerOrgs = new List<HandlerGroupItem>();
  504. HandlerUsers = new List<HandlerGroupItem>();
  505. SetHandlers(assignType, handlerObjects);
  506. }
  507. /// <summary>
  508. /// 更新当前办理人(待办人或部门),正常流转场景
  509. /// </summary>
  510. public void UpdateHandlers(string handlerId, string handlerOrg, EFlowAssignType assignType,
  511. List<HandlerGroupItem> handlerObjects, bool isCreateNewStep)
  512. {
  513. RemoveCurrentHandleGroup(handlerId, handlerOrg);
  514. if (isCreateNewStep)
  515. SetHandlers(assignType, handlerObjects);
  516. }
  517. private void SetHandlers(EFlowAssignType assignType, List<HandlerGroupItem> handlerObjects)
  518. {
  519. switch (assignType)
  520. {
  521. case EFlowAssignType.Org:
  522. HandlerOrgs.AddRange(handlerObjects);
  523. HandlerOrgs = HandlerOrgs.Distinct().ToList();
  524. break;
  525. case EFlowAssignType.User:
  526. HandlerUsers.AddRange(handlerObjects);
  527. HandlerUsers = HandlerUsers.Distinct().ToList();
  528. break;
  529. default:
  530. throw new ArgumentOutOfRangeException(nameof(assignType), assignType, null);
  531. }
  532. }
  533. /// <summary>
  534. /// 更新当前办理人(逐级退回场景)
  535. /// </summary>
  536. /// <param name="handlerId"></param>
  537. /// <param name="handlerOrg"></param>
  538. /// <param name="prevStep"></param>
  539. public void UpdatePreviousHandlers(string handlerId, string handlerOrg, WorkflowStep prevStep)
  540. {
  541. RemoveCurrentHandleGroup(handlerId, handlerOrg);
  542. var groupId = Guid.NewGuid().ToString();
  543. var handlerObjects = prevStep.Handlers.Select(d => new HandlerGroupItem
  544. {
  545. GroupId = groupId,
  546. Key = d.Key,
  547. Value = d.Value
  548. });
  549. switch (prevStep.HandlerType)
  550. {
  551. case EHandlerType.OrgLevel:
  552. case EHandlerType.OrgType:
  553. case EHandlerType.AssignedOrg:
  554. HandlerOrgs.AddRange(handlerObjects);
  555. HandlerOrgs = HandlerOrgs.Distinct().ToList();
  556. break;
  557. case EHandlerType.Role:
  558. case EHandlerType.AssignedUser:
  559. HandlerUsers.AddRange(handlerObjects);
  560. HandlerUsers = HandlerUsers.Distinct().ToList();
  561. break;
  562. default:
  563. throw new ArgumentOutOfRangeException();
  564. }
  565. }
  566. /// <summary>
  567. /// 当前用户是否可以办理该流程
  568. /// </summary>
  569. /// <returns></returns>
  570. public bool CanHandle(string userId, string orgCode) =>
  571. Status is EWorkflowStatus.Runnable &&
  572. (HandlerUsers.Any(d => d.Key == userId) || HandlerOrgs.Any(d => d.Key == orgCode));
  573. private void RemoveCurrentHandleGroup(string handlerId, string handlerOrg)
  574. {
  575. if (string.IsNullOrEmpty(handlerId) && string.IsNullOrEmpty(handlerOrg))
  576. throw new UserFriendlyException($"{nameof(RemoveCurrentHandleGroup)}, 办理对象参数为空");
  577. var orgItem = HandlerOrgs.FirstOrDefault(d => d.Key == handlerOrg);
  578. if (orgItem != null)
  579. {
  580. HandlerOrgs.RemoveAll(d => d.GroupId == orgItem.GroupId);
  581. }
  582. var userItem = HandlerUsers.FirstOrDefault(d => d.Key == handlerId);
  583. if (userItem != null)
  584. {
  585. HandlerUsers.RemoveAll(d => d.GroupId == userItem.GroupId);
  586. }
  587. }
  588. public void Assign(EFlowAssignType type, string handler)
  589. {
  590. handler = handler.ToLower();
  591. switch (type)
  592. {
  593. case EFlowAssignType.Org:
  594. var orgCodes = handler.GetHigherOrgCodes(true).ToList();
  595. FlowedOrgIds.AddRange(orgCodes);
  596. FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
  597. break;
  598. case EFlowAssignType.User:
  599. if (!FlowedUserIds.Exists(d => d == handler))
  600. FlowedUserIds.Add(handler);
  601. break;
  602. default:
  603. throw new ArgumentOutOfRangeException(nameof(type), type, null);
  604. }
  605. }
  606. public void Assign(EFlowAssignType type, IEnumerable<string> handlers)
  607. {
  608. handlers = handlers.Select(d => d.ToLower());
  609. switch (type)
  610. {
  611. case EFlowAssignType.Org:
  612. var orgCodes = handlers.SelectMany(d => d.GetHigherOrgCodes(true)).ToList();
  613. FlowedOrgIds.AddRange(orgCodes);
  614. FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
  615. break;
  616. case EFlowAssignType.User:
  617. FlowedUserIds.AddRange(handlers);
  618. FlowedUserIds = FlowedUserIds.Distinct().ToList();
  619. break;
  620. default:
  621. throw new ArgumentOutOfRangeException(nameof(type), type, null);
  622. }
  623. }
  624. /// <summary>
  625. /// 更新受理人信息
  626. /// </summary>
  627. public void UpdateAcceptor(string userId, string? userName, string? staffNo, string orgCode, string? orgName)
  628. {
  629. AcceptorId = userId;
  630. AcceptorName = userName;
  631. AcceptorStaffNo = staffNo;
  632. AcceptorOrgId = orgCode;
  633. AcceptorOrgName = orgName;
  634. }
  635. /// <summary>
  636. /// 更新一级部门信息(实际办理部门为一级部门时记录)
  637. /// </summary>
  638. public void UpdateLevelOneOrg(string orgId, string? orgName)
  639. {
  640. OrgLevelOneCode = orgId;
  641. OrgLevelOneName = orgName;
  642. }
  643. // public void CenterToOrg(DateTime expiredTime)
  644. // {
  645. // ProcessType = EProcessType.Jiaoban;
  646. // ExpiredTime = expiredTime;
  647. // CenterToOrgTime = DateTime.Now;
  648. // }
  649. //
  650. // public void OrgToCenter(DateTime expiredTime)
  651. // {
  652. // ProcessType = EProcessType.Zhiban;
  653. // ExpiredTime = expiredTime;
  654. // CenterToOrgTime = null;
  655. // }
  656. public void Redo()
  657. {
  658. ResetOption();
  659. Status = EWorkflowStatus.Runnable;
  660. }
  661. // public void SetHandleDuration()
  662. // {
  663. // if (!ActualHandleTime.HasValue)
  664. // throw new ArgumentNullException($"{ActualHandleTime} is null");
  665. // if (!CenterToOrgTime.HasValue)
  666. // throw new ArgumentNullException($"{CenterToOrgTime} is null");
  667. // HandleDuration = Math.Round((ActualHandleTime - CenterToOrgTime).Value.TotalMinutes);
  668. // }
  669. public void SetAllDuration()
  670. {
  671. if (!EndTime.HasValue)
  672. throw new ArgumentNullException($"{EndTime} is null");
  673. AllDuration = Math.Round((EndTime - CreationTime).Value.TotalMinutes);
  674. }
  675. public bool IsReviewPass() => FlowType == EFlowType.Review && ReviewResult == EReviewResult.Approval;
  676. public bool IsReviewType() => FlowType == EFlowType.Review;
  677. /// <summary>
  678. /// 查询实际办理节点
  679. /// </summary>
  680. /// <returns></returns>
  681. public WorkflowStep? GetActualStep() => Steps.FirstOrDefault(d => d.Id == ActualHandleStepId);
  682. public void AddCsActualHandler(string userId, string orgId)
  683. {
  684. CsActualHandleUserIds ??= new();
  685. if (CsActualHandleUserIds.All(d => d != userId))
  686. CsActualHandleUserIds.Add(userId);
  687. CsActualHandleOrgIds ??= new();
  688. if (CsActualHandleOrgIds.All(d => d != orgId))
  689. CsActualHandleOrgIds.Add(orgId);
  690. }
  691. #endregion
  692. }