:construction: 新建增删改查

api-v8/app/Http/Controllers/TaskController.php

@@ -3,8 +3,17 @@
 namespace App\Http\Controllers;
 
 use Illuminate\Http\Request;
+use Illuminate\Support\Str;
+use Illuminate\Support\Facades\Log;
+
+use App\Models\Task;
+use App\Models\TaskAssignee;
+use App\Models\Project;
+use App\Http\Resources\TaskResource;
+
 use App\Http\Api\AuthApi;
-use App\Http\Api\Mq;
+use App\Http\Api\StudioApi;
+
 
 class TaskController extends Controller
 {
@@ -13,10 +22,93 @@ class TaskController extends Controller
      *
      * @return \Illuminate\Http\Response
      */
-    public function index()
+    public function index(Request $request)
     {
         //
-        return $this->ok('ok');
+        $user = AuthApi::current($request);
+        if(!$user){
+            Log::error('notification auth failed {request}',['request'=>$request]);
+            return $this->error(__('auth.failed'),401,401);
+        }
+
+        switch ($request->get('view')) {
+            case 'all':
+                $table = Task::whereNotNull('owner_id');
+                break;
+            case 'studio':
+                $table = Task::where('owner_id',$user['user_uid']);
+                break;
+            case 'project':
+                $projects = Project::where('id',$request->get('project_id'))
+                                ->orWhereJsonContains('path',$request->get('project_id'))
+                                ->select('id')->get();
+                $table = Task::whereIn('project_id',$projects);
+                break;
+            default:
+                # code...
+                break;
+        }
+        if($request->has('executor_id_includes')){
+            $table = $table->whereIn('executor_id',
+                        explode(',',$request->get('executor_id_includes')));
+        }
+        if($request->has('executor_id_not-includes')){
+            $table = $table->whereNotIn('executor_id',
+                        explode(',',$request->get('executor_id_not-includes')));
+        }
+        if($request->has('assignees_id_includes')){
+            $table = $table->whereJsonContains('assignees_id',
+                        explode(',',$request->get('assignees_id_includes')));
+        }
+        if($request->has('assignees_id_not-includes')){
+            $table = $table->whereJsonDoesntContain('assignees_id',
+                        explode(',',$request->get('assignees_id_not-includes')));
+        }
+        if($request->get('sign_up_equals')==='true'){
+            $table = $table->whereNull('assignees_id')
+                        ->whereNull('executor_id');
+        }
+
+        if($request->has('participants_id_includes')){
+            $id = explode(',',$request->get('participants_id_includes'));
+            $tasks_id = TaskAssignee::whereIn('assignee_id',$id)->select('task_id')->get();
+            $table = $table->where(function ($query) use ($id,$tasks_id) {
+                $query->whereIn('executor_id',$id)
+                    ->orWhereIn('id',$tasks_id);
+            });
+        }
+
+        if($request->has('participants_id_not-includes')){
+            $id = explode(',',$request->get('participants_id_not-includes'));
+            $table = $table->where(function ($query) use ($id) {
+                $query->whereJsonDoesntContain('assignees_id',$id)
+                    ->whereNotIn('executor_id',$id);
+            });
+        }
+
+        if($request->has('keyword')){
+            $table = $table->where('title','like','%'.$request->get('keyword').'%');
+        }
+        if($request->has('status') && $request->get('status') !== 'all'){
+            $table = $table->whereIn('status',explode(',',$request->get('status')) );
+        }
+        $count = $table->count();
+
+        $table = $table->orderBy($request->get('order','created_at'),
+                                $request->get('dir','asc'));
+
+        $table = $table->skip($request->get("offset",0))
+                    ->take($request->get('limit',1000));
+
+        Log::debug('sql',['sql'=>$table->toSql()]);
+
+        $result = $table->get();
+
+        return $this->ok(
+            [
+            "rows" => TaskResource::collection($result),
+            "count" => $count,
+            ]);
     }
 
     /**
@@ -29,48 +121,188 @@ class TaskController extends Controller
     {
         //
         $user = AuthApi::current($request);
-        if(!$user || $user['user_uid'] !== 'ba5463f3-72d1-4410-858e-eadd10884713'){
+        if(!$user){
+            return $this->error(__('auth.failed'),401,401);
+        }
+        $studioId = StudioApi::getIdByName($request->get('studio_name'));
+
+        if(!$this->canEdit($user['user_uid'],$studioId)){
             return $this->error(__('auth.failed'),403,403);
         }
+        $new = Task::firstOrNew(
+            [
+                'id'=>$request->get('id')
+            ],
+            [
+                'owner_id'=>$studioId,
+                'project_id'=>$request->get('project_id'),
+            ],
+        );
+        if(Str::isUuid($request->get('id'))){
+            $new->id = $request->get('id');
+        }else{
+            $new->id =  Str::uuid();
+        }
+        $new->title = $request->get('title');
+        $new->editor_id = $user['user_uid'];
+        $new->parent_id = $request->get('parent_id');
+        //处理任务顺序
+        if($request->get('parent_id')){
+            $maxOrder = Task::where('parent_id',$request->get('parent_id'))
+                        ->max('order');
+        }else{
+            $maxOrder = Task::where('project_id',$request->get('project_id'))
+                        ->max('order');
+        }
+        if($maxOrder === null){
+            $new->order = 1;
+        }else{
+            $new->order = $maxOrder + 1;
+        }
+        $new->save();
 
-        Mq::publish('task',[
-            'name'=>$request->get('name'),
-            'param'=>$request->get('param'),
-        ]);
-        return $this->ok('ok');
+        return $this->ok(new TaskResource($new));
     }
 
     /**
      * Display the specified resource.
      *
-     * @param  int  $id
+     * @param  Task  $task
      * @return \Illuminate\Http\Response
      */
-    public function show($id)
+    public function show(Task $task)
     {
         //
+        return $this->ok(new TaskResource($task));
     }
 
     /**
      * Update the specified resource in storage.
      *
      * @param  \Illuminate\Http\Request  $request
-     * @param  int  $id
+     * @param  Task $task
      * @return \Illuminate\Http\Response
      */
-    public function update(Request $request, $id)
+    public function update(Request $request, Task $task)
     {
         //
+        $user = AuthApi::current($request);
+        if(!$user){
+            return $this->error(__('auth.failed'),401,401);
+        }
+        if(!$this->canEdit($user['user_uid'],$task->owner_id)){
+            return $this->error(__('auth.failed'),403,403);
+        }
+        if($request->has('title')){
+            $task->title = $request->get('title');
+        }
+        if($request->has('description')){
+            $task->description = $request->get('description');
+        }
+        if($request->has('assignees_id')){
+            $delete = TaskAssignee::where('task_id',$task->id)->delete();
+            $assigneesData = [];
+            foreach ($request->get('assignees_id') as $key => $id) {
+                $assigneesData[] = [
+                    'id' => Str::uuid(),
+                    'task_id' => $task->id,
+                    'assignee_id' => $id,
+                    'editor_id' => $user['user_uid'],
+                ];
+            }
+            TaskAssignee::insert($assigneesData);
+            //$task->assignees_id = json_encode($request->get('assignees_id'),JSON_UNESCAPED_UNICODE);
+        }
+        if($request->has('roles')){
+            $task->roles = json_encode($request->get('roles'),JSON_UNESCAPED_UNICODE);
+        }
+        if($request->has('executor_id')){
+            $task->executor_id = $request->get('executor_id');
+        }
+        if($request->has('executor_relation_task_id')){
+            $task->executor_relation_task_id = $request->get('executor_relation_task_id');
+        }
+        if($request->has('project_id')){
+            $task->project_id = $request->get('project_id');
+        }
+        if($request->has('pre_task_id')){
+            $task->pre_task_id = $request->get('pre_task_id');
+        }
+        if($request->has('next_task_id')){
+            $task->next_task_id = $request->get('next_task_id');
+        }
+        if($request->has('is_milestone')){
+            $task->is_milestone = $request->get('is_milestone');
+        }
+        if($request->has('order')){
+            $task->order = $request->get('order');
+        }
+        $relatedId = [];
+        if($request->has('status')){
+            switch ($request->get('status')) {
+                case 'publish':
+                    # code...
+                    break;
+                case 'running':
+                    $task->started_at = now();
+                    $task->executor_id = $user['user_uid'];
+                break;
+                case 'done':
+                    $task->finished_at = now();
+                    //开启相关任务
+                    $preTasks = Task::where('pre_task_id',$task->id)
+                                    ->where('status','pending')->select('id')->get();
+                    foreach ($preTasks as $key => $value) {
+                        $relatedId[] = $value->id;
+                    }
+                    if($task->next_task_id && Str::isUuid($task->next_task_id)){
+                        $nextTasks = Task::where('id',$task->next_task_id)
+                            ->where('status','pending')
+                            ->select('id')->get();
+                        foreach ($nextTasks as $key => $value) {
+                            $relatedId[] = $value->id;
+                        }
+                    }
+                    Task::whereIn('id',$relatedId)
+                            ->update(['status'=>'published']);
+                    break;
+                default:
+                    # code...
+                    break;
+            }
+            $task->status = $request->get('status');
+        }
+        $task->editor_id = $user['user_uid'];
+        $task->save();
+
+        return $this->ok(new TaskResource($task));
     }
 
     /**
      * Remove the specified resource from storage.
      *
-     * @param  int  $id
+     * @param  Task  $task
      * @return \Illuminate\Http\Response
      */
-    public function destroy($id)
+    public function destroy(Task  $task)
     {
         //
+        $user = AuthApi::current($request);
+        if(!$user){
+            return $this->error(__('auth.failed'),401,401);
+        }
+        if(!$this->canEdit($user['user_uid'],$task->owner)){
+            return $this->error(__('auth.failed'),403,403);
+        }
+        $task->delete();
+        if($task->trashed()){
+            return $this->ok('ok');
+        }else{
+            return $this->error('fail',500,500);
+        }
+    }
+
+    private function canEdit($user_uid,$owner_uid){
+        return $user_uid===$owner_uid;
     }
 }