Workflow.cs 25 KB

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