TaskController.php 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269
  1. <?php
  2. namespace App\Http\Controllers\API;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\API\Task\BatchCreateItemRules;
  5. use App\Http\Requests\API\Task\BatchCreateRequest;
  6. use App\Http\Requests\API\Task\CreateOrUpdateRequest;
  7. use App\Http\Resources\API\TaskDetailResource;
  8. use App\Http\Resources\API\TaskResource;
  9. use App\Models\CustomField;
  10. use App\Models\Enums\ActionObjectType;
  11. use App\Models\Enums\ObjectAction;
  12. use App\Models\NamingRule;
  13. use App\Models\Project;
  14. use App\Models\Requirement;
  15. use App\Models\Enums\TaskStatus;
  16. use App\Models\Task;
  17. use App\Repositories\ActionRepository;
  18. use App\Repositories\CustomFieldRepository;
  19. use App\Services\History\ModelChangeDetector;
  20. use Carbon\Carbon;
  21. use Illuminate\Http\Request;
  22. use Illuminate\Support\Facades\Auth;
  23. use Illuminate\Support\Facades\Validator;
  24. class TaskController extends Controller
  25. {
  26. /**
  27. * Display a listing of the resource.
  28. */
  29. public function index(Request $request)
  30. {
  31. $tasks = Task::query()
  32. ->where("parent_id", 0)
  33. ->with(['children', 'assignTo', 'createdBy'])
  34. ->filter($request->all())
  35. ->allowed()
  36. ->paginate();
  37. return TaskResource::collection($tasks);
  38. }
  39. /**
  40. * Store a newly created resource in storage.
  41. */
  42. public function store(CreateOrUpdateRequest $request, CustomFieldRepository $customFieldRepo)
  43. {
  44. $requirement = $request->has('requirement_id')
  45. ? Requirement::query()->findOrFail($request->get("requirement_id"))
  46. : null;
  47. $formData = [
  48. ...$request->all(),
  49. 'company_id' => Auth::user()->company_id,
  50. 'created_by' => Auth::id(),
  51. 'whitelist' => $request->whitelist ? sprintf(",%s,", implode(',', $request->whitelist)) : null,
  52. 'asset_id' => $requirement?->asset_id,
  53. 'requirement_group_id'=> $requirement?->requirement_group_id,
  54. ];
  55. if ($request->has("naming_rule_id") && $request->get("naming_rule_id") > 0) {
  56. $keys = $customFieldRepo->keysByGroup($request->get("naming_rule_id"));
  57. $formData['naming_rules'] = $request->only($keys);
  58. }
  59. $task = Task::create($formData);
  60. ActionRepository::createByTask($task, ObjectAction::CREATED);
  61. return $this->created();
  62. }
  63. /**
  64. * Display the specified resource.
  65. */
  66. public function show(string $id)
  67. {
  68. $task = Task::query()->allowed($id)->findOrFail($id);
  69. return new TaskDetailResource($task);
  70. }
  71. public function start(Request $request, string $id)
  72. {
  73. $task = Task::query()->allowed($id)->findOrFail($id);
  74. $task->status = TaskStatus::DOING->value;
  75. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  76. $task->save();
  77. ActionRepository::createByTask(
  78. $task,
  79. ObjectAction::STARTED,
  80. $request->get("comment"),
  81. objectChanges: $changes
  82. );
  83. return $this->noContent();
  84. }
  85. public function pause(Request $request, string $id)
  86. {
  87. $task = Task::query()->allowed($id)->findOrFail($id);
  88. $task->status = TaskStatus::PAUSE->value;
  89. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  90. $task->save();
  91. ActionRepository::createByTask(
  92. $task, ObjectAction::PAUSED, $request->get("comment"), objectChanges: $changes
  93. );
  94. return $this->noContent();
  95. }
  96. public function closed(Request $request, string $id)
  97. {
  98. $task = Task::query()->allowed($id)->findOrFail($id);
  99. $task->status = TaskStatus::CLOSED->value;
  100. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  101. $task->save();
  102. ActionRepository::createByTask(
  103. $task, ObjectAction::CLOSED, $request->get("comment"), objectChanges: $changes
  104. );
  105. return $this->noContent();
  106. }
  107. public function done(Request $request, string $id)
  108. {
  109. $task = Task::query()->allowed($id)->findOrFail($id);
  110. $task->fill([
  111. 'status' => TaskStatus::DONE->value,
  112. 'finished_by' => Auth::user()->id,
  113. 'finished_at' => Carbon::now(),
  114. ]);
  115. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  116. $task->save();
  117. ActionRepository::createByTask(
  118. $task, ObjectAction::DONE, $request->get("comment"), objectChanges: $changes
  119. );
  120. return $this->noContent();
  121. }
  122. public function cancel(Request $request, string $id)
  123. {
  124. $task = Task::query()->allowed($id)->findOrFail($id);
  125. $task->fill([
  126. 'status' => TaskStatus::CANCEL->value,
  127. 'finished_by' => Auth::user()->id,
  128. 'finished_at' => Carbon::now(),
  129. ]);
  130. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  131. $task->save();
  132. ActionRepository::createByTask(
  133. $task, ObjectAction::CANCELED, $request->get("comment"), objectChanges: $changes
  134. );
  135. return $this->noContent();
  136. }
  137. /**
  138. * Update the specified resource in storage.
  139. */
  140. public function update(CreateOrUpdateRequest $request, string $id, CustomFieldRepository $customFieldRepo)
  141. {
  142. $task = Task::query()->allowed($id)->findOrFail($id);
  143. $requirement = $request->has('requirement_id') && $task->requirement_id != $request->get('requirement_id')
  144. ? Requirement::query()->findOrFail($request->get("requirement_id"))
  145. : null;
  146. $formData = [...$request->all(),
  147. 'whitelist' => $request->whitelist ? sprintf(",%s,", implode(',', $request->whitelist)) : null,
  148. 'asset_id' => $requirement?->asset_id,
  149. ];
  150. if ($request->has("naming_rule_id") && $request->get("naming_rule_id") > 0) {
  151. $keys = $customFieldRepo->keysByGroup($request->get("naming_rule_id"));
  152. $formData['naming_rules'] = $request->only($keys);
  153. }
  154. $task->fill($formData);
  155. $changes = ModelChangeDetector::detector(ActionObjectType::TASK, $task);
  156. $task->save();
  157. ActionRepository::createByTask($task, ObjectAction::EDITED, objectChanges: $changes);
  158. return $this->noContent();
  159. }
  160. /**
  161. * Remove the specified resource from storage.
  162. */
  163. public function destroy(string $id)
  164. {
  165. $task = Task::query()->allowed($id)->findOrFail($id);
  166. $task->delete();
  167. ActionRepository::createByTask($task, ObjectAction::DELETED);
  168. return $this->noContent();
  169. }
  170. public function batchStore(BatchCreateRequest $request, CustomFieldRepository $customFieldRepo)
  171. {
  172. $project = Project::query()->allowed($request->project_id)->find($request->project_id);
  173. $parsedItems = [];
  174. $previousItem = [];
  175. foreach ($request->items as $index => $item) {
  176. if ($index == 0) {
  177. $newItem = $item;
  178. } else {
  179. $newItem = [];
  180. foreach ($item as $k => $v) {
  181. $newItem[$k] = $v == "ditto" ? data_get($previousItem, $k) : $v;
  182. }
  183. }
  184. $previousItem = $newItem;
  185. $parsedItems[] = $newItem;
  186. }
  187. $itemRules = new BatchCreateItemRules();
  188. foreach ($parsedItems as $index => $item) {
  189. $rules = $itemRules->rules($item);
  190. try {
  191. $validator = Validator::make($item, $rules);
  192. if ($validator->fails()) {
  193. return $this->badRequest(sprintf("line: %d, %s", $index + 1, $validator->errors()->first()));
  194. }
  195. } catch (\Exception $e) {
  196. return $this->badRequest(sprintf("line: %d, %s", $index + 1, $e->getMessage()));
  197. }
  198. }
  199. foreach ($parsedItems as $item) {
  200. $namingRuleId = data_get($item, "naming_rule_id", 0);
  201. if ($namingRuleId > 0) {
  202. $keys = $customFieldRepo->keysByGroup($namingRuleId);
  203. $item['naming_rules'] = collect($item)->only($keys)->toArray();
  204. }
  205. $task = Task::query()->create([
  206. ...$item,
  207. 'project_id' => $project->id,
  208. 'parent_id' => 0,
  209. 'company_id' => Auth::user()->company_id,
  210. 'created_by' => Auth::id(),
  211. ]);
  212. ActionRepository::createByTask($task, ObjectAction::CREATED);
  213. }
  214. return $this->noContent();
  215. }
  216. }