管理后台 看板

app/api/controller/manage/Project.php

@@ -148,7 +148,7 @@ class Project extends BaseController
         ]);
 
         $list->each(function ($item) {
-            $item->done_num = ProjectPut::where(['user_id' => $item->user_id, 'complete_status' => 3])->count();;
+            $item->done_num = ProjectPut::where(['user_id' => $item->user_id, 'complete_status' => 3])->count();
             return $item;
         });
 

app/api/controller/manage/ShCourse.php

@@ -113,31 +113,31 @@ class ShCourse extends BaseController
     //添加课程
     public function createShCourse(Request $request)
     {
-        $vo = (new ShCourseValidate())->goCheck(['title', 'cate_id', 'thumb', 'teacher_id', 'thumb', 'detailthumb', 'content']);
+        $filed = ['title', 'cate_id', 'thumb', 'teacher_id', 'detailthumb', 'content','tag_ids','teacher_id','price'];
+        $vo = (new ShCourseValidate())->goCheck($filed);
         if ($vo !== true) {
             return $vo;
         }
-        $parm = $request->param();
-        $parm['sn'] = UtilService::generateCompactOrderNo($request->userId, 'K');
-        $parm['createtime'] = time();
-        $parm['user_id'] = $request->userId;
-        $result = ShCourseModel::create($parm);
+        $data = $request->only($filed);
+        $data['sn'] = UtilService::generateCompactOrderNo($request->userId, 'K');
+        $data['createtime'] = time();
+        $data['user_id'] = $request->userId;
+        $result = ShCourseModel::create($data);
         return $this->returnMsg('操作成功', 1, $result);
     }
 
     //修改课程
     public function editShCourse(Request $request)
     {
-        $vo = (new ShCourseValidate())->goCheck(['course_id', 'title', 'cate_id', 'thumb', 'teacher_id', 'thumb', 'detailthumb', 'content']);
+        $filed = ['course_id', 'title', 'cate_id', 'thumb', 'teacher_id', 'detailthumb', 'content','tag_ids','teacher_id','price'];
+        $vo = (new ShCourseValidate())->goCheck($filed);
         if ($vo !== true) {
             return $vo;
         }
+
         $parm = $request->param();
-        $udpatedata = $parm;
+        $udpatedata = $request->only($filed);
         unset($udpatedata['course_id']);
-        unset($udpatedata['thumbUrl']);
-        unset($udpatedata['detailThumbUrl']);
-
         $udpatedata['updatetime'] = time();
         $udpatedata['status'] = 0; //修改为待提交
         $result = ShCourseModel::where(['user_id' => $request->userId, 'id' => $parm['course_id']])->update($udpatedata);

app/api/controller/manage/ShCourseWork.php

@@ -46,6 +46,7 @@ class ShCourseWork extends BaseController
         if(isset($parm['course_id']) && $parm['course_id']){
             $map[] = ['course_id', '=', $parm['course_id']];
         }
+
         $page = $request->param('page', 1);
         $pageSize = $request->param('pageSize', 10);
         $list = ShCourseWorkModel::where($where)->where($map)

app/job/Jobtask.php

@@ -74,22 +74,26 @@ class Jobtask
             }
 
             //处理课时
-            $course_class_list = ShCourseClass::where('course_id', $data['course_id'])->select()->toArray();
-            if ($course_class_list) {
+//            $course_class_list = ShCourseClass::where('course_id', $data['course_id'])->without(['tvfile'])->select();
+            $course_class_list = Db::name('sh_course_class')->where('course_id', $data['course_id'])->select()->toArray();
 
+            if ($course_class_list) {
 //                CourseClass::where('course_id', $data['course_id'])->delete(); //删除课时
                 CourseClass::saveAll($course_class_list); //添加课时
             }
 
+
             //处理章节
-            $course_class_category = ShCourseClassCategory::where('course_id', $data['course_id'])->select()->toArray();
+//            $course_class_category = ShCourseClassCategory::where('course_id', $data['course_id'])->select()->toArray();
+            $course_class_category = Db::name('sh_course_class_category')->where('course_id', $data['course_id'])->select()->toArray();
             if ($course_class_category) {
 //                CourseClassCategory::where('course_id', $data['course_id'])->delete(); //删除章节
                 CourseClassCategory::saveAll($course_class_category); //添加章节
             }
 
             //处理作业
-            $course_work = ShCourseWork::where('course_id', $data['course_id'])->select()->toArray();
+//            $course_work = ShCourseWork::where('course_id', $data['course_id'])->select()->toArray();
+            $course_work = Db::name('sh_course_work')->where('course_id', $data['course_id'])->select()->toArray();
             if ($course_work) {
 //                CourseWork::where('course_id', $data['course_id'])->delete(); //删除作业
                 CourseWork::saveAll($course_work); //添加作业
@@ -150,14 +154,14 @@ class Jobtask
 
             //处理章节
             $course_class_category = Db::name('sh_course_class_category')->where('course_id', $data['course_id'])->select()->toArray();
-            if($course_class_category){
+            if ($course_class_category) {
                 Db::name('course_class_category')->where('course_id', $data['course_id'])->delete(); //删除章节
                 Db::name('course_class_category')->insertAll($course_class_category); //添加章节
             }
 
             //处理作业
             $course_work = Db::name('sh_course_work')->where('course_id', $data['course_id'])->select()->toArray();
-            if($course_work){
+            if ($course_work) {
                 Db::name('course_work')->where('course_id', $data['course_id'])->delete(); //删除作业
                 Db::name('course_work')->insertAll($course_work); //添加作业
             }

app/subscribe/course.php

@@ -25,6 +25,7 @@ class course
     public function onCourse($event)
     {
         Queue::push(Jobtask::class, $event); // 推送到队列的任务类及其数据参数
+//        $this->synccourse($event);
     }
 
     public function subscribe(Event $event)
@@ -34,4 +35,77 @@ class course
     }
 
 
+    public function synccourse($data)
+    {
+
+        if ($data['action'] == 'shstatus') {
+            //更新课程
+            $courseinfo = ShCourse::where('id', $data['course_id'])->find();
+            $is_cz = CourseModel::where('id', $data['course_id'])->count();
+            if ($is_cz > 0) {
+                unset($courseinfo['click']);
+                unset($courseinfo['tvclick']);
+                CourseModel::update($courseinfo);
+            } else {
+                CourseModel::create($courseinfo); //添加课程
+            }
+
+            //处理课时
+//            $course_class_list = ShCourseClass::where('course_id', $data['course_id'])->without(['tvfile'])->select();
+            $course_class_list = Db::name('sh_course_class')->where('course_id', $data['course_id'])->select()->toArray();
+
+            if ($course_class_list) {
+//                CourseClass::where('course_id', $data['course_id'])->delete(); //删除课时
+                CourseClass::saveAll($course_class_list); //添加课时
+            }
+
+
+            //处理章节
+//            $course_class_category = ShCourseClassCategory::where('course_id', $data['course_id'])->select()->toArray();
+            $course_class_category = Db::name('sh_course_class_category')->where('course_id', $data['course_id'])->select()->toArray();
+            if ($course_class_category) {
+//                CourseClassCategory::where('course_id', $data['course_id'])->delete(); //删除章节
+                CourseClassCategory::saveAll($course_class_category); //添加章节
+            }
+
+            //处理作业
+//            $course_work = ShCourseWork::where('course_id', $data['course_id'])->select()->toArray();
+            $course_work = Db::name('sh_course_work')->where('course_id', $data['course_id'])->select()->toArray();
+            if ($course_work) {
+//                CourseWork::where('course_id', $data['course_id'])->delete(); //删除作业
+                CourseWork::saveAll($course_work); //添加作业
+            }
+
+
+        } elseif ($data['action'] == 'shcourseupdate') {
+
+            //更新状态数据 删除，上下架
+            $courseinfo = Db::name('sh_course')->field('id,is_sell,is_del,is_hot,is_tj')->where('id', $data['course_id'])->find();
+            Db::name('course')->where('id', $data['course_id'])->update($courseinfo);
+            //处理课时
+            $course_class_list = Db::name('sh_course_class')->field('id,is_del,is_sell,sort')->where('course_id', $data['course_id'])->select()->toArray();
+            foreach ($course_class_list as $item) {
+                Db::name('course_class')->update($item);
+            }
+            //处理章节
+            $course_class_category = Db::name('sh_course_class_category')->field('id,is_del,sort')->where('course_id', $data['course_id'])->select()->toArray();
+
+            foreach ($course_class_category as $item) {
+                Db::name('course_class_category')->update($item);
+            }
+            //处理作业
+            $course_work = Db::name('sh_course_work')->field('id,is_del')->where('course_id', $data['course_id'])->select()->toArray();
+            foreach ($course_work as $item) {
+                Db::name('course_work')->update($item);
+            }
+
+        } elseif ($data['action'] == 'courseupdateclick') {
+            //更新销量阅读量
+            $courseinfo = CourseModel::field('id,click,tvclick')->where('id', $data['course_id'])->find();
+            ShCourse::update($courseinfo);
+        }
+
+
+    }
+
 }
\ No newline at end of file