create

app/Http/Controllers/DiscussionCountController.php

@@ -0,0 +1,180 @@
+<?php
+
+namespace App\Http\Controllers;
+
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Log;
+use App\Models\Discussion;
+use App\Models\CourseMember;
+use App\Models\Course;
+use App\Models\Sentence;
+use App\Models\WbwBlock;
+use App\Models\Wbw;
+use App\Http\Api\AuthApi;
+use App\Http\Resources\DiscussionCountResource;
+
+
+class DiscussionCountController extends Controller
+{
+    /**
+     * Display a listing of the resource.
+     *
+     * @return \Illuminate\Http\Response
+     */
+    public function index()
+    {
+        //
+    }
+
+    /**
+     * 课程模式业务逻辑
+     * 标准答案channel:学生提问
+     * 学生channel: 老师批改作业
+     * 老师：
+     *   标准答案channel: 本期学生，老师（区分已经回复，未回复）
+     *   学生channel: 本期学生，老师
+     * 学生：
+     *   标准答案channel：我自己topic(区分已经回复，未回复)
+     *   学生自己channel: 我自己，本期老师
+     *
+     * 输入：
+     *   句子列表
+     *   courseId
+     * 返回数据
+     *  resId
+     *  type:'discussion':
+     *     my:number
+     *     myReplied:number
+     *     all:number
+     *     allReplied:number
+     * @param  \Illuminate\Http\Request  $request
+     * @return \Illuminate\Http\Response
+     */
+    public function store(Request $request)
+    {
+        /**
+         * 课程
+         * 1. 获取用户角色
+         * 2. 获取成员列表
+         * 3. 计算答案channel的结果
+         * 4. 计算作业channel的结果
+         */
+        $user = AuthApi::current($request);
+        if(!$user){
+            return $this->error('auth.failed',401,401);
+        }
+        //判断我的角色
+        $my = CourseMember::where('user_id',$user["user_uid"])
+                            ->where('is_current',true)
+                            ->where('course_id',$request->get('course_id'))
+                            ->first();
+        if(!$my){
+            return $this->error('auth.failed',403,403);
+        }
+        //获取全部成员列表
+        $allMembers = CourseMember::where('is_current',true)
+                            ->where('course_id',$request->get('course_id'))
+                            ->select('user_id')
+                            ->get();
+        //获取答案channel
+        $answerChannel = Course::where('id',$request->get('course_id'))
+                        ->value('channel_id');
+        $exerciseChannels = CourseMember::where('is_current',true)
+                                ->where('course_id',$request->get('course_id'))
+                                ->select('channel_id')
+                                ->get();
+        $channels = array();
+        if($answerChannel){
+            array_push($channels,$answerChannel);
+        }
+        $users = array();
+        if($my->role === 'student'){
+            //自己的channel + 答案
+            if($my->channel_id){
+                array_push($channels,$my->channel_id);
+            }
+        }else{
+            //找到全部学员channel + 答案
+            foreach ($exerciseChannels as $key => $value) {
+                array_push($channels,$value->channel_id);
+            }
+        }
+
+        //获取全部学员对应的资源列表
+        $querySentId = $request->get('sentences');
+        $resId = array();
+        //译文
+        $sentUid = Sentence::whereIns(['book_id','paragraph','word_start','word_end'],$querySentId)
+                        ->whereIn('channel_uid',$channels)
+                        ->select('uid')->get();
+        foreach ($sentUid as $key => $value) {
+            $resId[] = $value->uid;
+        }
+        //wbw
+        $wbwBlockParagraphs = [];
+        foreach ($querySentId as $key => $value) {
+            $wbwBlockParagraphs[] = [$value[0],$value[1]];
+        }
+        $wbwBlock = WbwBlock::whereIn('channel_uid',$channels)
+                            ->whereIns(['book_id','paragraph'],$wbwBlockParagraphs)
+                            ->select('uid')
+                            ->get();
+        if($wbwBlock){
+            //找到逐词解析数据
+            foreach ($querySentId as $key => $value) {
+                $wbwData = Wbw::whereIn('block_uid',$wbwBlock)
+                                ->whereBetween('wid',[$value[2],$value[3]])
+                                ->select('uid')
+                                ->get();
+                foreach ($wbwData as $key => $value) {
+                    $resId[] = $value->uid;
+                }
+            }
+        }
+        Log::debug('res id',['res'=>$resId,'members'=>$allMembers]);
+        //全部资源id获取完毕
+        $allDiscussions = Discussion::where('status','active')
+                            ->whereNull('parent')
+                            ->whereIn('res_id',$resId)
+                            ->whereIn('editor_uid',$allMembers)
+                            ->select(['id','res_id','type','editor_uid'])
+                            ->get();
+        $result = DiscussionCountResource::collection($allDiscussions);
+        Log::debug('response',['data'=>$result]);
+        return $this->ok($result);
+    }
+
+    /**
+     * Display the specified resource.
+     *
+     * @param  \App\Models\Discussion  $discussion
+     * @return \Illuminate\Http\Response
+     */
+    public function show(Discussion $discussion)
+    {
+        //
+    }
+
+    /**
+     * Update the specified resource in storage.
+     *
+     * @param  \Illuminate\Http\Request  $request
+     * @param  \App\Models\Discussion  $discussion
+     * @return \Illuminate\Http\Response
+     */
+    public function update(Request $request, Discussion $discussion)
+    {
+        //
+    }
+
+    /**
+     * Remove the specified resource from storage.
+     *
+     * @param  \App\Models\Discussion  $discussion
+     * @return \Illuminate\Http\Response
+     */
+    public function destroy(Discussion $discussion)
+    {
+        //
+    }
+}

app/Http/Resources/DiscussionCountResource.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Http\Resources;
+
+use Illuminate\Http\Resources\Json\JsonResource;
+
+class DiscussionCountResource extends JsonResource
+{
+    /**
+     * Transform the resource into an array.
+     *
+     * @param  \Illuminate\Http\Request  $request
+     * @return array|\Illuminate\Contracts\Support\Arrayable|\JsonSerializable
+     */
+    public function toArray($request)
+    {
+        return parent::toArray($request);
+    }
+}

tests/Feature/DiscussionCountTest.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Tests\Feature;
+
+use Illuminate\Foundation\Testing\RefreshDatabase;
+use Illuminate\Foundation\Testing\WithFaker;
+use Tests\TestCase;
+
+class DiscussionCountTest extends TestCase
+{
+    private $token = 'Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJuYmYiOjE2OTc3Mjg2ODUsImV4cCI6MTcyOTI2NDY4NSwidWlkIjoiYmE1NDYzZjMtNzJkMS00NDEwLTg1OGUtZWFkZDEwODg0NzEzIiwiaWQiOjR9.fiXhnY2LczZ9kKVHV0FfD3AJPZt-uqM5wrDe4EhToVexdd007ebPFYssZefmchfL0mx9nF0rgHSqjNhx4P0yDA';
+
+    /**
+     * A basic feature test example.
+     *
+     * @return void
+     */
+    public function test_example()
+    {
+        $response = $this->get('/');
+
+        $response->assertStatus(200);
+    }
+
+    public function test_store()
+    {
+        //testing store
+        $response = $this->withHeaders([
+            'Authorization' => $this->token,
+        ])->json('POST', '/api/v2/discussion-count',
+                    [
+                        'course_id'=>'b3145a94-e400-459d-9507-acbb05256e4e',
+                        'sentences'=>[[168,916,2,9]],
+                    ]);
+
+        $response->assertOk();
+    }
+}