ApprovalFlowController.php 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. <?php
  2. namespace App\Http\Controllers\API;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\API\ApprovalFlow\CreateOrUpdateRequest;
  5. use App\Http\Resources\API\ApprovalFlowDetailResource;
  6. use App\Http\Resources\API\ApprovalFlowResource;
  7. use App\Models\ApprovalFlow;
  8. use App\Models\Enums\ApprovalFlowType;
  9. use App\Models\User;
  10. use Illuminate\Http\Request;
  11. use Illuminate\Support\Facades\Auth;
  12. class ApprovalFlowController extends Controller
  13. {
  14. public function index(Request $request)
  15. {
  16. $pageSize=$request->get('page_size') ?? 50;
  17. $approvalFlows = ApprovalFlow::query()->with(['createdBy'])
  18. ->when($request->type, fn($query) => $query->where("type", $request->type))
  19. ->orderByDesc("id")->paginate($pageSize);
  20. return ApprovalFlowResource::collection($approvalFlows);
  21. }
  22. public function store(CreateOrUpdateRequest $request)
  23. {
  24. if ($request->nodes){
  25. $nodes = $this->getNewApprovalNodes($request->nodes['childNode'],1);
  26. }
  27. // $nodes = $this->getApprovalNodes($request);
  28. $limitObject = $request->get("object_type")
  29. && $request->get("object_id")
  30. && in_array($request->get("type"), [ApprovalFlowType::TASK->value]);
  31. $exists = ApprovalFlow::query()->where("type", $request->type)
  32. ->where("company_id", Auth::user()->company_id)->where('name',$request->name)
  33. ->count();
  34. throw_validation_if($exists && !isset($request->nodes), "Please do not add repeatedly.");
  35. $approvalFlow = new ApprovalFlow();
  36. $approvalFlow->mergeFillable([
  37. 'company_id', 'type'
  38. ]);
  39. $approvalFlow->fill([
  40. ...$request->all(),
  41. 'object_id' => $limitObject ? $request->object_id : 0,
  42. 'company_id' => Auth::user()->company_id,
  43. 'created_by' => Auth::id(),
  44. ]);
  45. if (!$exists){
  46. $approvalFlow->save();
  47. }else{
  48. ApprovalFlow::query()->where("company_id", Auth::user()->company_id)->where('name',$request->name)->update([
  49. 'nodes'=>$nodes ??[],
  50. 'nodes_config'=>json_encode($request->nodes??[])
  51. ]);
  52. }
  53. return $this->noContent();
  54. }
  55. protected function getNewApprovalNodes($nodeList = array(),$level = 1){
  56. $users = $nodeList['nodeUserList'] ? array_column($nodeList['nodeUserList'],'targetId') : [];
  57. $node = ['name'=>$nodeList['nodeName'],'level'=>$level,'approval_mode'=>'1','approval_users'=>$users];
  58. $nodes[$level] = $node;
  59. if (is_array($nodeList['childNode'])){
  60. $node = $this->getNewApprovalNodes($nodeList['childNode'],$level+1);
  61. $nodes = $nodes + $node;
  62. }
  63. return $nodes;
  64. }
  65. protected function getApprovalNodes(Request $request)
  66. {
  67. $nodes = [];
  68. foreach ($request->nodes as $node) {
  69. $userCount = User::query()->whereIn("id", $node['approval_users'])->count();
  70. throw_validation_if($userCount != count($node['approval_users']), "The selected approver does not exist");
  71. $nodes[$node['level']] = collect($node)->only(['name', 'approval_users', 'approval_mode', 'level'])->toArray();
  72. }
  73. throw_validation_if(max(array_keys($nodes)) != count($nodes), "The level field is incorrect");
  74. return $nodes;
  75. }
  76. public function update(CreateOrUpdateRequest $request, string $id)
  77. {
  78. $approvalFlow = ApprovalFlow::query()->findOrFail($id);
  79. $nodes = $this->getApprovalNodes($request);
  80. $nodeIsChange = false;
  81. if (count($nodes) != count($approvalFlow->nodes)) {
  82. $nodeIsChange = true;
  83. } else {
  84. foreach ($approvalFlow->nodes as $node) {
  85. $oldNodeUsers = $node['approval_users'];
  86. $nowNodeUsers = $nodes[$node['level']]['approval_users'];
  87. sort($oldNodeUsers);
  88. sort($nowNodeUsers);
  89. if (implode(',', $oldNodeUsers) != implode(',', $nowNodeUsers)
  90. || $node['approval_mode'] != $nodes[$node['level']]['approval_mode']
  91. ) {
  92. $nodeIsChange = true;
  93. break;
  94. }
  95. }
  96. }
  97. if ($nodeIsChange) {
  98. $newApprovalFlow = new ApprovalFlow();
  99. $newApprovalFlow->mergeFillable([
  100. 'company_id', 'type',
  101. ]);
  102. $newApprovalFlow->fill([
  103. 'name' => $request->name,
  104. 'type' => $approvalFlow->type,
  105. 'object_type' => $approvalFlow->object_type,
  106. 'object_id' => $approvalFlow->object_id,
  107. 'company_id' => Auth::user()->company_id,
  108. 'created_by' => Auth::id(),
  109. 'nodes' => $nodes,
  110. ]);
  111. $newApprovalFlow->save();
  112. $approvalFlow->delete();
  113. return $this->noContent();
  114. } else {
  115. $approvalFlow->name = $request->name;
  116. $approvalFlow->nodes = $nodes;
  117. $approvalFlow->save();
  118. }
  119. //return new ApprovalFlowDetailResource($approvalFlow);
  120. return $this->noContent();
  121. }
  122. public function show(string $id)
  123. {
  124. $approvalFlow = ApprovalFlow::query()->findOrFail($id);
  125. return new ApprovalFlowDetailResource($approvalFlow);
  126. }
  127. public function destroy(string $id)
  128. {
  129. $approvalFlow = ApprovalFlow::query()->findOrFail($id);
  130. $approvalFlow->delete();
  131. return $this->noContent();
  132. }
  133. }