TaskApi.php 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. <?php
  2. namespace App\Http\Api;
  3. use App\Models\Task;
  4. use App\Models\TaskRelation;
  5. use Illuminate\Support\Facades\App;
  6. use Illuminate\Support\Facades\Cache;
  7. use Illuminate\Support\Str;
  8. class TaskApi
  9. {
  10. public static function getById($id)
  11. {
  12. if (!$id) {
  13. return null;
  14. };
  15. $task = Task::where('id', $id)->first();
  16. if ($task) {
  17. return [
  18. 'id' => $id,
  19. 'title' => $task->title,
  20. 'description' => $task->description,
  21. ];
  22. } else {
  23. return null;
  24. }
  25. }
  26. public static function getListByIds($ids)
  27. {
  28. if (!$ids) {
  29. return null;
  30. };
  31. $tasks = Task::whereIn('id', $ids)->get();
  32. $output = array();
  33. foreach ($ids as $key => $id) {
  34. foreach ($tasks as $task) {
  35. if ($task->id === $id) {
  36. $output[] = [
  37. 'id' => $id,
  38. 'title' => $task->title,
  39. 'description' => $task->description,
  40. "executor" => UserApi::getByUuid($task->executor_id)
  41. ];
  42. continue;
  43. };
  44. }
  45. }
  46. return $output;
  47. }
  48. public static function setRelationTasks($taskId, $relationTasksId, $editor_id, $relation = 'pre')
  49. {
  50. if ($relation === 'pre') {
  51. $where = 'next_task_id';
  52. $task1 = 'task_id';
  53. $task2 = 'next_task_id';
  54. } else {
  55. $where = 'task_id';
  56. $task1 = 'next_task_id';
  57. $task2 = 'task_id';
  58. }
  59. TaskApi::removeTaskRelationRedisKey($taskId, $relation);
  60. $delete = TaskRelation::where($where, $taskId)
  61. ->delete();
  62. foreach ($relationTasksId as $key => $id) {
  63. if (Str::isUuid($taskId) && Str::isUuid($id)) {
  64. $data[] = [
  65. $task1 => $id,
  66. $task2 => $taskId,
  67. 'editor_id' => $editor_id,
  68. 'created_at' => now(),
  69. 'updated_at' => now(),
  70. ];
  71. }
  72. }
  73. if (isset($data)) {
  74. TaskRelation::insert($data);
  75. }
  76. TaskApi::removeTaskRelationRedisKey($taskId, $relation);
  77. }
  78. public static function getRelationTasks($taskId, $relation = 'pre')
  79. {
  80. $key = TaskApi::taskRelationRedisKey($taskId, $relation);
  81. //Log::debug('task redis key=' . $key . ' has=' . Cache::has($key));
  82. $data = Cache::remember($key, 24 * 3600, function () use ($taskId, $relation) {
  83. if ($relation === 'pre') {
  84. $where = 'next_task_id';
  85. $select = 'task_id';
  86. } else {
  87. $where = 'task_id';
  88. $select = 'next_task_id';
  89. }
  90. $tasks = TaskRelation::where($where, $taskId)
  91. ->select($select)->get();
  92. $tasksId = [];
  93. foreach ($tasks as $key => $task) {
  94. $tasksId[] = $task[$select];
  95. }
  96. return TaskApi::getListByIds($tasksId);
  97. });
  98. return $data;
  99. }
  100. public static function getNextTasks($taskId)
  101. {
  102. return TaskApi::getRelationTasks($taskId, 'next');
  103. }
  104. public static function getPreTasks($taskId)
  105. {
  106. return TaskApi::getRelationTasks($taskId, 'pre');
  107. }
  108. public static function removeTaskRelationRedisKey($taskId, $relation = 'pre')
  109. {
  110. //查询相关task
  111. $relations = TaskRelation::where('task_id', $taskId)
  112. ->orWhere('next_task_id', $taskId)
  113. ->select('task_id', 'next_task_id')->get();
  114. $relationsId = [];
  115. $relationsId[$taskId] = 1;
  116. foreach ($relations as $key => $value) {
  117. $relationsId[$value->task_id] = 1;
  118. $relationsId[$value->next_task_id] = 1;
  119. }
  120. foreach ($relationsId as $taskId => $value) {
  121. $key = TaskApi::taskRelationRedisKey($taskId, 'pre');
  122. Cache::forget($key);
  123. $key = TaskApi::taskRelationRedisKey($taskId, 'next');
  124. Cache::forget($key);
  125. }
  126. }
  127. public static function taskRelationRedisKey($taskId, $relation = 'pre')
  128. {
  129. return "task/relation/{$relation}/{$taskId}";
  130. }
  131. }