|
|
@@ -0,0 +1,1260 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+
|
|
|
+namespace app\api\controller;
|
|
|
+
|
|
|
+use app\common\library\Common;
|
|
|
+use app\common\controller\Api;
|
|
|
+use app\common\library\WxPay;
|
|
|
+use EasyWeChat\Factory;
|
|
|
+use think\Db;
|
|
|
+use think\facade\Validate;
|
|
|
+use app\common\library\AliPay;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * @title 首页
|
|
|
+ * @controller Index
|
|
|
+ */
|
|
|
+class Index extends Api
|
|
|
+{
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 首页banner
|
|
|
+ * @desc 首页banner
|
|
|
+ * @url /api/Index/banner_list
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ */
|
|
|
+ public function banner_list(){
|
|
|
+ $type = input('type',1);
|
|
|
+ $list = Db::name('system_banner')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('type',$type)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->order('sort desc')
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 首页新闻动态/最新公告
|
|
|
+ * @desc 首页新闻动态/最新公告
|
|
|
+ * @url /api/Index/homeArticleList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:type type:int require:0 default:1 desc:1:新闻动态2：最新公告
|
|
|
+ */
|
|
|
+ public function homeArticleList(){
|
|
|
+ $type = input('type',1);
|
|
|
+ $is_all = input('is_all',1);
|
|
|
+ $list = Db::name('system_article')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('is_home',1)
|
|
|
+ ->order('id desc')
|
|
|
+ ->where('type',$type)
|
|
|
+ ->when($is_all,function ($query) use ($is_all){
|
|
|
+ if ($is_all==1){
|
|
|
+ $query->limit(3);
|
|
|
+ }
|
|
|
+ })
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 查看文章详情
|
|
|
+ * @desc 查看文章详情
|
|
|
+ * @url /api/Index/articleDetail
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:1 default: desc:文章ID
|
|
|
+ */
|
|
|
+ public function articleDetail(){
|
|
|
+ $id = input('id');
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $info = Db::name('system_article')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('is_home',1)
|
|
|
+ ->where('id',$id)
|
|
|
+ ->find();
|
|
|
+ Db::name('system_article')->where('id',$id)->setInc('click_number');
|
|
|
+ $this->success('成功',$info);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 提交评审信息
|
|
|
+ * @desc 提交评审信息
|
|
|
+ * @url /api/Index/submitReview
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:0 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:schooling type:string require:0 default:1 desc:学历
|
|
|
+ * @param name:name type:string require:0 default:1 desc:姓名
|
|
|
+ * @param name:phone type:string require:0 default:1 desc:手机号
|
|
|
+ * @param name:professional type:string require:0 default:1 desc:专业
|
|
|
+ * @param name:date_brith type:string require:0 default:1 desc:出生年月
|
|
|
+ */
|
|
|
+ public function submitReview(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ if (!$mid) $mid = 0;
|
|
|
+ $schooling = input('schooling');
|
|
|
+ $name = input('name');
|
|
|
+ $phone = input('phone');
|
|
|
+ $professional = input('professional');
|
|
|
+ $date_brith = input('date_brith');
|
|
|
+ if (!$schooling || !$name || !$phone || !$professional || !$date_brith) $this->error('参数错误');
|
|
|
+ $data = [
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'schooling'=>$schooling,
|
|
|
+ 'name'=>$name,
|
|
|
+ 'phone'=>$phone,
|
|
|
+ 'professional'=>$professional,
|
|
|
+ 'date_brith'=>$date_brith
|
|
|
+ ];
|
|
|
+ if (Db::name('system_review')->insert($data)){
|
|
|
+ $this->success('提交成功');
|
|
|
+ }
|
|
|
+ $this->error('提交失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 首页视频专区
|
|
|
+ * @desc 首页视频专区
|
|
|
+ * @url /api/Index/homeCourseList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ */
|
|
|
+ public function homeCourseList(){
|
|
|
+ $list = Db::name('system_course')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('is_home',1)
|
|
|
+ ->order('id desc')
|
|
|
+ ->where('type',1)
|
|
|
+ ->limit(4)
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v) {
|
|
|
+ $v['study_count'] = Db::name('system_course_order')->where('course_id',$v['id'])->where('status',1)->count();
|
|
|
+ $v['comments_count'] = Db::name('system_course_comments')->where('course_id',$v['id'])->where('is_del',1)->group('mid')->count();
|
|
|
+ }
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 岗位就业推荐
|
|
|
+ * @desc 岗位就业推荐
|
|
|
+ * @url /api/Index/jobreCommend
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ */
|
|
|
+ public function jobreCommend(){
|
|
|
+ $info = get_values('jobrecommend');
|
|
|
+ $list = explode(',',$info);
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 首页名师展示
|
|
|
+ * @desc 首页名师展示
|
|
|
+ * @url /api/Index/homeFamousTeacher
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ */
|
|
|
+ public function homeFamousTeacher(){
|
|
|
+ $list = Db::name('system_famous_teacher')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->order('id desc')
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 文章列表
|
|
|
+ * @desc 文章列表
|
|
|
+ * @url /api/Index/articleList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:type type:int require:0 default: desc:1:新闻2：通告
|
|
|
+ */
|
|
|
+ public function articleList(){
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $type = input('type',1);
|
|
|
+ if (!$type) $this->error('参数错误');
|
|
|
+ $where = [
|
|
|
+ 'type'=>$type,
|
|
|
+ 'is_del'=>1,
|
|
|
+ 'is_show'=>1
|
|
|
+ ];
|
|
|
+ $count = Db::name('system_article')
|
|
|
+ ->where($where)
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_article')
|
|
|
+ ->where($where)
|
|
|
+ ->order('id desc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程分类
|
|
|
+ * @desc 课程分类
|
|
|
+ * @url /api/Index/coursecate
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ */
|
|
|
+ public function coursecate(){
|
|
|
+ $list = Db::name('system_course_cate')
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->field('id,name')
|
|
|
+ ->order('id desc')
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程中心
|
|
|
+ * @desc 课程中心
|
|
|
+ * @url /api/Index/courselist
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:cate_id type:int require:0 default: desc:分类ID
|
|
|
+ * @param name:keywords type:string require:0 default: desc:关键词
|
|
|
+ */
|
|
|
+ public function courselist(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $cate_id = input('cate_id');
|
|
|
+ $keywords = input('keywords');
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $count = Db::name('system_course')
|
|
|
+ ->when($cate_id,function ($query) use ($cate_id){
|
|
|
+ $query->where('cate_id',$cate_id);
|
|
|
+ })
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('type',1)
|
|
|
+ ->when($keywords,function ($query) use ($keywords){
|
|
|
+ $query->whereLike('name','%'.$keywords.'%');
|
|
|
+ })
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course')
|
|
|
+ ->when($cate_id,function ($query) use ($cate_id){
|
|
|
+ $query->where('cate_id',$cate_id);
|
|
|
+ })
|
|
|
+ ->when($keywords,function ($query) use ($keywords){
|
|
|
+ $query->whereLike('name','%'.$keywords.'%');
|
|
|
+ })
|
|
|
+ ->where('type',1)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->order('id desc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v){
|
|
|
+ $v['period'] = Db::name('system_course_class')->where('course_id',$v['id'])->where('is_del',1)->where('is_show',1)->count();
|
|
|
+ $v['study_count'] = Db::name('system_course_order')->where('course_id',$v['id'])->where('status',1)->count();
|
|
|
+ $v['comments_count'] = Db::name('system_course_comments')->where('course_id',$v['id'])->where('is_del',1)->group('mid')->count();
|
|
|
+ if (!$mid){
|
|
|
+ $v['is_collection'] = 0;
|
|
|
+ }else{
|
|
|
+ $collection = Db::name('system_course_collection')->where('mid',$mid)->where('course_id',$v['id'])->count();
|
|
|
+ $v['is_collection'] = $collection > 0 ? 1 : 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程分类列表
|
|
|
+ * @desc 课程分类列表
|
|
|
+ * @url /api/Index/courseCateList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:is_home type:string require:0 default:1 desc:1：首页的分类2：其他页面
|
|
|
+ * @param name:cate_id type:int require:0 default: desc:分类ID(点击全部课程，一级分类ID)
|
|
|
+ */
|
|
|
+ public function courseCateList(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $is_home = input('is_home',1);
|
|
|
+ $cate_id = input('cate_id');
|
|
|
+ if ($cate_id){
|
|
|
+ $list = Db::name('system_course_cate')
|
|
|
+ ->where('id',$cate_id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('pid',0)
|
|
|
+ ->field('id,name,pid')
|
|
|
+ ->order('id desc')
|
|
|
+ ->find();
|
|
|
+ $list['children'] = Db::name('system_course_cate')
|
|
|
+ ->where('is_del', 1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('pid', $cate_id)
|
|
|
+ ->field('id,name,pid')
|
|
|
+ ->order('id desc')
|
|
|
+ ->select();
|
|
|
+ }else{
|
|
|
+ $list = Db::name('system_course_cate')
|
|
|
+ ->when($is_home,function ($query) use ($is_home){
|
|
|
+ if ($is_home==1){
|
|
|
+ $query->where('is_home',1);
|
|
|
+ }
|
|
|
+ })
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('pid',0)
|
|
|
+ ->field('id,name,pid')
|
|
|
+ ->order('id desc')
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v){
|
|
|
+ $v['children'] = Db::name('system_course_cate')
|
|
|
+ ->when($is_home,function ($query) use ($is_home){
|
|
|
+ if ($is_home==1){
|
|
|
+ $query->where('is_home',1);
|
|
|
+ }
|
|
|
+ })
|
|
|
+ ->where('is_del', 1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('pid', $v['id'])
|
|
|
+ ->field('id,name,pid')
|
|
|
+ ->order('id desc')
|
|
|
+ ->select();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 根据分类查课程列表
|
|
|
+ * @desc 根据分类查课程列表
|
|
|
+ * @url /api/Index/courselistByCate
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:cate_id type:int require:0 default: desc:分类ID（二级分类ID）
|
|
|
+ */
|
|
|
+ public function courselistByCate(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $cate_id = input('cate_id');
|
|
|
+ if (!$cate_id) $this->error('分类ID为空');
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $count = Db::name('system_course')
|
|
|
+ ->where('cate_two_id',$cate_id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('type',1)
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course')
|
|
|
+ ->where('cate_two_id',$cate_id)
|
|
|
+ ->where('type',1)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->order('id desc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v){
|
|
|
+ $v['period'] = Db::name('system_course_class')->where('course_id',$v['id'])->where('is_del',1)->where('is_show',1)->count();
|
|
|
+ $v['study_count'] = Db::name('system_course_order')->where('course_id',$v['id'])->where('status',1)->count();
|
|
|
+ $v['comments_count'] = Db::name('system_course_comments')->where('course_id',$v['id'])->where('is_del',1)->group('mid')->count();
|
|
|
+ if (!$mid){
|
|
|
+ $v['is_collection'] = 0;
|
|
|
+ }else{
|
|
|
+ $collection = Db::name('system_course_collection')->where('mid',$mid)->where('course_id',$v['id'])->count();
|
|
|
+ $v['is_collection'] = $collection > 0 ? 1 : 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程详情接口
|
|
|
+ * @desc 课程详情接口
|
|
|
+ * @url /api/Index/courseDetail
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default: desc:id
|
|
|
+ */
|
|
|
+ public function courseDetail(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $id = input('id');
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $info = Db::name('system_course')
|
|
|
+ ->where('id',$id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->find();
|
|
|
+ if (!$info) $this->error('课程不存在');
|
|
|
+ if (!$mid){
|
|
|
+ $info['is_collection'] = 0;
|
|
|
+ }else{
|
|
|
+ $collection = Db::name('system_course_collection')->where('mid',$mid)->where('course_id',$id)->count();
|
|
|
+ $info['is_collection'] = $collection > 0 ? 1 : 0;
|
|
|
+ }
|
|
|
+ $info['collection_count'] = Db::name('system_course_collection')->where('course_id',$id)->count();
|
|
|
+ $info['period'] = Db::name('system_course_class')
|
|
|
+ ->where('course_id',$id)->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->count();
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('course_id',$id)->where('status',1)->count();
|
|
|
+ $info['is_buy'] = $order > 0 ? 1 : 0;
|
|
|
+
|
|
|
+ $is_finish = Db::name('system_course_order')
|
|
|
+ ->where('mid',$mid)
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('status',1)
|
|
|
+ ->value('is_finish');
|
|
|
+
|
|
|
+ if (isset($is_finish) && $is_finish==1){
|
|
|
+ $info['study_class_count'] = $info['period'];
|
|
|
+ }else{
|
|
|
+ $info['study_class_count'] = Db::name('system_course_study_log')
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('mid',$mid)
|
|
|
+ ->where('is_accomplish',1)
|
|
|
+ ->group('class_id')
|
|
|
+ ->count();
|
|
|
+ }
|
|
|
+
|
|
|
+ $info['can_test'] = 1;
|
|
|
+ $info['can_test_time'] = 0;
|
|
|
+ //获取最新的未通过的记录
|
|
|
+ $log = Db::name('system_course_questions_log')
|
|
|
+ ->where('mid',$mid)
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('is_submint',1)
|
|
|
+ ->where('is_pass',0)
|
|
|
+ ->find();
|
|
|
+ if ($log){
|
|
|
+ $time = strtotime($log['end_at'])+(12*60*60);
|
|
|
+ if ($time>time()){
|
|
|
+ $info['can_test'] = 0;
|
|
|
+ }
|
|
|
+ $info['can_test_time'] = date('Y-m-d H:i:s');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ $questions_count = Db::name('system_course_questions')->where('course_id',$id)->where('is_del',1)->count();
|
|
|
+ $info['is_questions'] = $questions_count > 0 ? 1 : 0;
|
|
|
+
|
|
|
+ $pass = Db::name('system_course_questions_log')->where('mid',$mid)->where('course_id',$id)->where('is_pass',1)->count();
|
|
|
+ $info['pass_history'] = $pass > 0 ? 1 : 0;
|
|
|
+
|
|
|
+ Db::name('system_course')->where('id',$id)->setInc('click_number');
|
|
|
+
|
|
|
+ $this->success('成功',$info);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程目录接口
|
|
|
+ * @desc 课程目录接口
|
|
|
+ * @url /api/Index/courseClassList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:id type:int require:0 default: desc:课程ID
|
|
|
+ */
|
|
|
+ public function courseClassList(){
|
|
|
+ $id = input('id');
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $info = Db::name('system_course')
|
|
|
+ ->where('id',$id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->find();
|
|
|
+ if (!$info) $this->error('课程不存在');
|
|
|
+ $where = [
|
|
|
+ 'course_id'=>$id,
|
|
|
+ 'is_del'=>1,
|
|
|
+ 'is_show'=>1
|
|
|
+ ];
|
|
|
+ $count = Db::name('system_course_class')
|
|
|
+ ->where($where)
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course_class')
|
|
|
+ ->where($where)
|
|
|
+ ->order('id asc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->field('id,name,playtime')
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课时详情接口
|
|
|
+ * @desc 课时详情接口
|
|
|
+ * @url /api/Index/courseClassDetail
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default: desc:课程ID
|
|
|
+ * @param name:class_id type:int require:0 default: desc:课时ID
|
|
|
+ */
|
|
|
+ public function courseClassDetail(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $class_id = input('class_id');
|
|
|
+ if (!$id || !$class_id) $this->error('参数错误');
|
|
|
+ $class = $this->check_course_class($id,$class_id,$mid);
|
|
|
+ $now = Db::name('system_course_study_log')
|
|
|
+ ->where('mid',$mid)->where('course_id',$id)->where('class_id',$class_id)->where('is_accomplish',0)->value('now_time');
|
|
|
+ $class['nowtime'] = $now ? $now : 0;
|
|
|
+ $this->success('成功',$class);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 学员榜样
|
|
|
+ * @desc 学员榜样
|
|
|
+ * @url /api/Index/studentModel
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:0 default: desc:验证token
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default: desc:课程ID
|
|
|
+ */
|
|
|
+ public function studentModel(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $id = input('id');
|
|
|
+ if (!$mid) $mid = 0;
|
|
|
+ $count = Db::name('system_course_order')
|
|
|
+ ->where('status',1)
|
|
|
+ ->where('is_finish',1)
|
|
|
+ ->when($id,function ($query) use ($id){
|
|
|
+ $query->where('course_id',$id);
|
|
|
+ })
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course_order')
|
|
|
+ ->alias('a')->leftJoin('system_member b','a.mid=b.id')
|
|
|
+ ->where('a.status',1)
|
|
|
+ ->where('a.is_finish',1)
|
|
|
+ ->when($id,function ($query) use ($id){
|
|
|
+ $query->where('a.course_id',$id);
|
|
|
+ })
|
|
|
+ ->field('b.id,b.user_name,b.headimg')
|
|
|
+ ->order('a.id desc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 学员榜样
|
|
|
+ * @desc 学员榜样
|
|
|
+ * @url /api/Index/studentsDynamic
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:0 default: desc:验证token
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default: desc:课程ID
|
|
|
+ */
|
|
|
+ public function studentsDynamic(){
|
|
|
+ $mid = $this->check_user();
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $id = input('id');
|
|
|
+ if (!$mid) $mid = 0;
|
|
|
+ $count = Db::name('system_course_study_log')
|
|
|
+ ->when($id,function ($query) use ($id){
|
|
|
+ $query->where('course_id',$id);
|
|
|
+ })
|
|
|
+ ->group('mid')
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course_study_log')
|
|
|
+ ->alias('a')
|
|
|
+ ->leftJoin('system_member b','a.mid=b.id')
|
|
|
+ ->leftJoin('system_course c','a.course_id=c.id')
|
|
|
+ ->when($id,function ($query) use ($id){
|
|
|
+ $query->where('a.course_id',$id);
|
|
|
+ })
|
|
|
+ ->field('a.is_accomplish,b.id,b.user_name,b.headimg,c.name')
|
|
|
+ ->order('a.id desc')
|
|
|
+ ->group('mid')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 开始学习
|
|
|
+ * @desc 开始学习
|
|
|
+ * @url /api/Index/startStudy
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:1 default:1 desc:课程ID
|
|
|
+ * @param name:class_id type:int require:1 default:1 desc:课时ID
|
|
|
+ */
|
|
|
+ public function startStudy(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $class_id = input('class_id');
|
|
|
+ if (!$id || !$class_id) $this->error('参数错误');
|
|
|
+ $this->check_course_class($id,$class_id,$mid);
|
|
|
+ $data = [
|
|
|
+ 'course_id'=>$id,
|
|
|
+ 'class_id'=>$class_id,
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'start_at'=>date('Y-m-d H:i:s')
|
|
|
+ ];
|
|
|
+ if (Db::name('system_course_study_log')->insert($data)){
|
|
|
+ $this->success('成功');
|
|
|
+ }
|
|
|
+ $this->error('失败');
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 提交当前观看时间
|
|
|
+ * @desc 开始学习
|
|
|
+ * @url /api/Index/nowTime
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:1 default:1 desc:课程ID
|
|
|
+ * @param name:class_id type:int require:1 default:1 desc:课时ID
|
|
|
+ * @param name:now type:int require:1 default:1 desc:观看秒
|
|
|
+ */
|
|
|
+ public function nowTime(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $class_id = input('class_id');
|
|
|
+ $now = input('now');
|
|
|
+ if (!$id || !$class_id || !$now) $this->error('参数错误');
|
|
|
+ $this->check_course_class($id,$class_id,$mid);
|
|
|
+ $log = Db::name('system_course_study_log')->where('mid',$mid)
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('class_id',$class_id)
|
|
|
+ ->where('is_accomplish',0)->order('id desc')
|
|
|
+ ->limit(1)->find();
|
|
|
+ if ($log){
|
|
|
+ if (Db::name('system_course_study_log')->where('id',$log['id'])->update(['now_time'=>$now])){
|
|
|
+ $this->success('成功');
|
|
|
+ }
|
|
|
+ }
|
|
|
+ $this->error('失败');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课时学完
|
|
|
+ * @desc 课时学完
|
|
|
+ * @url /api/Index/endStudy
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:1 default:1 desc:课程ID
|
|
|
+ * @param name:class_id type:int require:1 default:1 desc:课时ID
|
|
|
+ */
|
|
|
+ public function endStudy(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $class_id = input('class_id');
|
|
|
+ if (!$id || !$class_id) $this->error('参数错误');
|
|
|
+ $this->check_course_class($id,$class_id,$mid);
|
|
|
+ $info = Db::name('system_course_study_log')
|
|
|
+ ->where('mid',$mid)
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('class_id',$class_id)
|
|
|
+ ->order('id desc')
|
|
|
+// ->where('is_accomplish',1)
|
|
|
+ ->limit(1)
|
|
|
+ ->find();
|
|
|
+ if ($info){
|
|
|
+ $data['end_at'] = date('Y-m-d H:i:s');
|
|
|
+ $data['is_accomplish'] = 1;
|
|
|
+ if (Db::name('system_course_study_log')->where('id',$info['id'])->update($data)){
|
|
|
+
|
|
|
+ //获取课时数量
|
|
|
+ $class_count = Db::name('system_course_class')
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->count();
|
|
|
+ //获取已学习完成数量
|
|
|
+ $finish_count = Db::name('system_course_study_log')
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('mid',$mid)
|
|
|
+ ->where('is_accomplish',1)
|
|
|
+ ->group('class_id')
|
|
|
+ ->count();
|
|
|
+ $date = [
|
|
|
+ 'class_count'=>$class_count,
|
|
|
+ 'study_class_count'=>$finish_count
|
|
|
+ ];
|
|
|
+ if ($finish_count>=$class_count){
|
|
|
+ $date['is_finish'] = 1;
|
|
|
+ }
|
|
|
+ Db::name('system_course_order')->where('mid',$mid)->where('status',1)->update($date);
|
|
|
+
|
|
|
+ $this->success('成功');
|
|
|
+ }
|
|
|
+ $this->error('失败');
|
|
|
+ }else{
|
|
|
+ $this->error('未找到学习记录');
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程提交评论
|
|
|
+ * @desc 课程提交评论
|
|
|
+ * @url /api/Index/submitComments
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:1 default:1 desc:课程ID
|
|
|
+ * @param name:class_id type:int require:1 default:1 desc:课时ID
|
|
|
+ * @param name:content type:sting require:1 default:1 desc:评论内容
|
|
|
+ */
|
|
|
+ public function submitComments(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $class_id = input('class_id');
|
|
|
+ $content = input('content');
|
|
|
+ if (!$id || !$class_id || !$content) $this->error('参数错误');
|
|
|
+ $course = Db::name('system_course')->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+ if ($course['is_free']==1){
|
|
|
+ //不免费，查看是否购买课程
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('course_id',$id)->where('status',1)->find();
|
|
|
+ if (!$order) $this->error('请先购买课程');
|
|
|
+ }
|
|
|
+ $class = Db::name('system_course_class')->where('id',$class_id)->where('is_del',1)->find();
|
|
|
+ if (!$class) $this->error('课时不存在');
|
|
|
+ if (!$class['is_show']) $this->error('课时已下架');
|
|
|
+ $data = [
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'course_id'=>$id,
|
|
|
+ 'class_id'=>$class_id,
|
|
|
+ 'content'=>$content
|
|
|
+ ];
|
|
|
+ if (Db::name('system_course_comments')->insert($data)){
|
|
|
+ $this->success('提交成功');
|
|
|
+ }
|
|
|
+ $this->error('提交失败');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程评论列表
|
|
|
+ * @desc 课程评论列表
|
|
|
+ * @url /api/Index/courseCommentsList
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:id type:int require:0 default: desc:课程ID
|
|
|
+ */
|
|
|
+ public function courseCommentsList(){
|
|
|
+ $id = input('id');
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $info = Db::name('system_course')
|
|
|
+ ->where('id',$id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->find();
|
|
|
+ if (!$info) $this->error('课程不存在');
|
|
|
+ $count = Db::name('system_course_comments')
|
|
|
+ ->where('course_id',$id)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course_comments')->alias('a')
|
|
|
+ ->leftJoin('system_member b','a.mid=b.id')
|
|
|
+ ->leftJoin('system_course_class c','a.class_id=c.id')
|
|
|
+ ->where('a.course_id',$id)
|
|
|
+ ->where('a.is_del',1)
|
|
|
+ ->order('a.id desc')
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->field('a.*,b.user_name,b.headimg,c.name')
|
|
|
+ ->select();
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 收藏课程/取消收藏课程
|
|
|
+ * @desc 收藏课程/取消收藏课程
|
|
|
+ * @url /api/Index/collectionCancelCourse
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default:1 desc:课程ID
|
|
|
+ * @param name:type type:string require:0 default:1 desc:1:收藏0：取消收藏
|
|
|
+ */
|
|
|
+ public function collectionCancelCourse(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ $type = input('type',1);
|
|
|
+ if (!$mid) $mid = 0;
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $coll = Db::name('system_course_collection')->where('course_id',$id)->where('mid',$mid)->find();
|
|
|
+ if ($type==1){
|
|
|
+ if ($coll) $this->error('课程已收藏过');
|
|
|
+ $data = [
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'course_id'=>$id
|
|
|
+ ];
|
|
|
+ if (Db::name('system_course_collection')->insert($data)){
|
|
|
+ $this->success('收藏成功');
|
|
|
+ }
|
|
|
+ $this->error('收藏失败');
|
|
|
+ }else{
|
|
|
+ if (!$coll) $this->error('课程未收藏');
|
|
|
+ if (Db::name('system_course_collection')->where('id',$coll['id'])->delete()){
|
|
|
+ $this->success('取消成功');
|
|
|
+ }
|
|
|
+ $this->error('取消失败');
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 课程下单
|
|
|
+ * @desc 课程下单
|
|
|
+ * @url /api/Index/createOrder
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default:1 desc:课程ID
|
|
|
+
|
|
|
+ */
|
|
|
+ public function createOrder(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $course = Db::name('system_course')->where('id',$id)->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+ if ($course['is_free']!=1) $this->error('课程免费，无需下单');
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('course_id',$id)->whereIn('status','0,1')->find();
|
|
|
+ if ($order) $this->error('课程已购买或已下单',['order_no'=>$order['order_no'],'id'=>$order['id']]);
|
|
|
+ $order_no = get_order_sn();
|
|
|
+ $data = [
|
|
|
+ 'order_no'=>$order_no,
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'course_id'=>$id,
|
|
|
+ 'pay_price'=>$course['price'],
|
|
|
+ 'course_info'=>json_encode($course,true),
|
|
|
+ //'status'=>1
|
|
|
+ ];
|
|
|
+ $id = Db::name('system_course_order')->insertGetId($data);
|
|
|
+ if ($id){
|
|
|
+ $this->success('下单成功',['order_no'=>$order_no,'id'=>$id]);
|
|
|
+ }
|
|
|
+ $this->error('下单失败');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 订单支付
|
|
|
+ * @desc 订单支付
|
|
|
+ * @url /api/Index/payOrder
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:order_no type:string require:1 default: desc:订单ID
|
|
|
+ * @param name:pay_type type:string require:1 default: desc:支付方式wx:微信zfb:支付宝
|
|
|
+ * @param name:from type:string require:0 default:1 desc:来源1：PC2:小程序
|
|
|
+ */
|
|
|
+ public function payOrder(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $order_no = input('order_no');
|
|
|
+ $id = input('id');
|
|
|
+ $pay_type = input('pay_type','wx');
|
|
|
+ $from = input('from',1);
|
|
|
+ if (!$order_no) $this->error('参数错误');
|
|
|
+
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('id',$id)->find();
|
|
|
+ if (!$order) $this->error('订单不存在');
|
|
|
+ if ($order['status']!=0) $this->error('订单已支付或已取消');
|
|
|
+
|
|
|
+ Db::name('system_course_order')->where('order_no',$order_no)->update(['pay_type'=>$pay_type,'update_at'=>date('Y-m-d H:i:s')]);
|
|
|
+
|
|
|
+ $order['pay_type'] = $pay_type;
|
|
|
+ $course = Db::name('system_course')->where('id',$order['course_id'])->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+
|
|
|
+ if ($pay_type=='wx' && $from==2){
|
|
|
+ $openid = Db::name('system_member')->where('id',$mid)->value('openid');
|
|
|
+ if (!$openid) $this->error('请先绑定小程序');
|
|
|
+ }
|
|
|
+
|
|
|
+ Db::startTrans();
|
|
|
+ $com = true;
|
|
|
+ try {
|
|
|
+ $order_nos = get_order_sn();
|
|
|
+ Db::name('system_course_order')->where('order_no',$order_no)->update(['order_no'=>$order_nos]);
|
|
|
+ switch ($order['pay_type']){
|
|
|
+ case 'wx':
|
|
|
+ $body = '订单号' . $order_nos;//支付说明
|
|
|
+ $notify_url = 'https://'.$_SERVER['SERVER_NAME'].'/index.php/api/pay/pay_order';//回调地址
|
|
|
+ $wx = new WxPay();//实例化微信torganizationid支付控制器
|
|
|
+ $config = $wx->retrunconfig();
|
|
|
+ $config['notify_url'] = $notify_url;
|
|
|
+ $app = Factory::payment($config);
|
|
|
+
|
|
|
+ $app->order->close($order_no);
|
|
|
+
|
|
|
+ $trade_type = $from==2 ? "JSAPI" : "NATIVE";
|
|
|
+ $out_trade_no = $order_nos;//订单号
|
|
|
+ $array = [
|
|
|
+ 'body' => $body,
|
|
|
+ 'out_trade_no' => $out_trade_no,
|
|
|
+ 'total_fee' => $order['pay_price']*100,
|
|
|
+ 'trade_type' => $trade_type, // JSAPI--JSAPI支付（或小程序支付）、NATIVE--Native支付、APP--app支付，MWEB--H5支付
|
|
|
+ ];
|
|
|
+ if ($from==2){
|
|
|
+ $array['openid'] = $openid;
|
|
|
+ }
|
|
|
+ $result = $app->order->unify($array);
|
|
|
+
|
|
|
+ if ($from==2){
|
|
|
+ if ($result['return_msg']=='OK'){
|
|
|
+ if ($result['result_code']=='FAIL'){
|
|
|
+ Db::rollback();
|
|
|
+ $com = false;
|
|
|
+ }else{
|
|
|
+ $order1 = $app->jssdk->bridgeConfig($result['prepay_id']);//执行二次签名返回参数
|
|
|
+ $retrun_data['order_no'] = $order_nos;
|
|
|
+ $retrun_data['pay'] = json_decode($order1,true);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ Db::rollback();
|
|
|
+ $com = false;
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ if ($result['return_msg']=='OK'){
|
|
|
+ $retrun_data['order_no'] = $order_nos;
|
|
|
+ $retrun_data['pay'] = $result['code_url'];
|
|
|
+ }else {
|
|
|
+ Db::rollback();
|
|
|
+ $com = false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ break;
|
|
|
+ case 'zfb':
|
|
|
+ $zfb = new AliPay();
|
|
|
+ $notify_url = 'http://'.$_SERVER['SERVER_NAME'].'/index.php/api/Pay/alipayOrderNotify';//回调地址
|
|
|
+ $returnUrl = 'http://'.$_SERVER['SERVER_NAME'].'/order';//返回地址
|
|
|
+
|
|
|
+ $result = $zfb->aliPay('购买课程',$order['pay_price'],$order_nos,$notify_url,$returnUrl);
|
|
|
+ $retrun_data['order_no'] = $order_nos;
|
|
|
+ $retrun_data['pay'] = $result;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ Db::commit();
|
|
|
+ }catch (\Exception $e){
|
|
|
+ $com = false;
|
|
|
+ Db::rollback();
|
|
|
+ }
|
|
|
+ if ($com){
|
|
|
+ Db::name('system_course')->where('id',$order['course_id'])->setInc('sales');
|
|
|
+ $this->success('成功',$retrun_data);
|
|
|
+ }
|
|
|
+ $this->error('失败');
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ //判断课程课时
|
|
|
+ public function check_course_class($id,$class_id,$mid){
|
|
|
+ $course = Db::name('system_course')->where('id',$id)->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+ if ($course['is_free']==1){
|
|
|
+ //不免费，查看是否购买课程
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('course_id',$id)->where('status',1)->find();
|
|
|
+ if (!$order) $this->error('请先购买课程');
|
|
|
+ }
|
|
|
+ $class = Db::name('system_course_class')->where('id',$class_id)->where('is_del',1)->find();
|
|
|
+ if (!$class) $this->error('课时不存在');
|
|
|
+ if (!$class['is_show']) $this->error('课时已下架');
|
|
|
+ return $class;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 积分商城分类
|
|
|
+ * @desc 积分商城分类
|
|
|
+ * @url /api/Index/courseIntegralCate
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ */
|
|
|
+ public function courseIntegralCate(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $list = Db::name('system_course_integral_cate')
|
|
|
+ ->where('status',1)
|
|
|
+ ->where('is_deleted',0)
|
|
|
+ ->where('pid',0)
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v){
|
|
|
+ $v['child'] = Db::name('system_course_integral_cate')
|
|
|
+ ->where('status',1)
|
|
|
+ ->where('is_deleted',0)
|
|
|
+ ->where('pid',$v['id'])
|
|
|
+ ->select();
|
|
|
+ }
|
|
|
+ $this->success('成功',$list);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 积分商城
|
|
|
+ * @desc 积分商城
|
|
|
+ * @url /api/Index/courseIntegrallist
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @param name:page type:int require:0 default:1 desc:
|
|
|
+ * @param name:limit type:int require:0 default:10 desc:
|
|
|
+ * @param name:cate_one_id type:int require:0 default: desc:一级分类ID
|
|
|
+ * @param name:cate_two_id type:int require:0 default: desc:二级分类ID
|
|
|
+ * @param name:order type:int require:0 default:1 desc:排序1：综合2：销量3：价格
|
|
|
+ * @param name:price_min type:string require:0 default: desc:价格区间最低价
|
|
|
+ * @param name:price_max type:string require:0 default: desc:价格区间最高价
|
|
|
+ */
|
|
|
+ public function courseIntegrallist(){
|
|
|
+ $cate_one_id = input('cate_one_id');
|
|
|
+ $cate_two_id = input('cate_two_id');
|
|
|
+ $order = input('order',1);
|
|
|
+ $price_min = input('price_min');
|
|
|
+ $price_max = input('price_max');
|
|
|
+ $Nowpage = input('page',1);
|
|
|
+ $limits = input("limit",10);
|
|
|
+ $count = Db::name('system_course')
|
|
|
+ ->when($cate_one_id,function ($query) use ($cate_one_id){
|
|
|
+ $query->where('integral_cate_id',$cate_one_id);
|
|
|
+ })
|
|
|
+ ->when($cate_two_id,function ($query) use ($cate_two_id){
|
|
|
+ $query->where('integral_two_cate_id',$cate_two_id);
|
|
|
+ })
|
|
|
+ ->when($price_min,function ($query) use ($price_min,$price_max){
|
|
|
+ $query ->whereBetween('price',[$price_min,$price_max]);
|
|
|
+ })
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->where('type',2)
|
|
|
+ ->count();
|
|
|
+ $list = Db::name('system_course')
|
|
|
+ ->when($cate_one_id,function ($query) use ($cate_one_id){
|
|
|
+ $query->where('integral_cate_id',$cate_one_id);
|
|
|
+ })
|
|
|
+ ->when($cate_two_id,function ($query) use ($cate_two_id){
|
|
|
+ $query->where('integral_two_cate_id',$cate_two_id);
|
|
|
+ })
|
|
|
+ ->when($price_min,function ($query) use ($price_min,$price_max){
|
|
|
+ $query ->whereBetween('price',[$price_min,$price_max]);
|
|
|
+ })
|
|
|
+ ->where('type',2)
|
|
|
+ ->where('is_del',1)
|
|
|
+ ->where('is_show',1)
|
|
|
+ ->when($order,function ($query) use ($order){
|
|
|
+ if ($order==1){
|
|
|
+ $query->order('id desc');
|
|
|
+ }elseif ($order==2){
|
|
|
+ $query->order('sales asc');
|
|
|
+ }elseif ($order==3){
|
|
|
+ $query->order('price asc');
|
|
|
+ }
|
|
|
+ })
|
|
|
+ ->page($Nowpage,$limits)
|
|
|
+ ->select();
|
|
|
+ foreach ($list as &$v){
|
|
|
+ $v['period'] = Db::name('system_course_class')->where('course_id',$v['id'])->where('is_del',1)->where('is_show',1)->count();
|
|
|
+ $v['study_count'] = Db::name('system_course_order')->where('course_id',$v['id'])->where('status',1)->count();
|
|
|
+ $v['comments_count'] = Db::name('system_course_comments')->where('course_id',$v['id'])->where('is_del',1)->group('mid')->count();
|
|
|
+ }
|
|
|
+ $this->success('成功',compact('count','list'));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 积分商城下单
|
|
|
+ * @desc 积分商城下单
|
|
|
+ * @url /api/Index/createIntergalOrder
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:id type:int require:0 default:1 desc:课程ID
|
|
|
+ */
|
|
|
+ public function createIntergalOrder(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $id = input('id');
|
|
|
+ if (!$id) $this->error('参数错误');
|
|
|
+ $course = Db::name('system_course')->where('id',$id)->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+ if ($course['is_free']!=1) $this->error('课程免费，无需下单');
|
|
|
+ $member_integral = Db::name('system_member')->where('id',$mid)->value('integral');
|
|
|
+ if ($course['price']>$member_integral) $this->error('积分不足，无法购买');
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('course_id',$id)->where('status','1')->find();
|
|
|
+ if ($order) $this->error('课程已购买过',['order_no'=>$order['order_no']]);
|
|
|
+ $order_no = get_order_sn();
|
|
|
+ $data = [
|
|
|
+ 'order_no'=>$order_no,
|
|
|
+ 'mid'=>$mid,
|
|
|
+ 'course_id'=>$id,
|
|
|
+ 'pay_type'=>'integral',
|
|
|
+ 'pay_price'=>$course['price'],
|
|
|
+ 'course_info'=>json_encode($course,true),
|
|
|
+ 'type'=>2
|
|
|
+ ];
|
|
|
+ if (Db::name('system_course_order')->insert($data)){
|
|
|
+ $this->success('下单成功',['order_no'=>$order_no]);
|
|
|
+ }
|
|
|
+ $this->error('下单失败');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @title 积分商城订单支付
|
|
|
+ * @desc 积分商城订单支付
|
|
|
+ * @url /api/Index/payIntegralOrder
|
|
|
+ * @method POST
|
|
|
+ * @tag 基础
|
|
|
+ *
|
|
|
+ * @header name:Authorization require:1 default: desc:验证token
|
|
|
+ *
|
|
|
+ * @param name:order_no type:string require:1 default: desc:订单ID
|
|
|
+ */
|
|
|
+ public function payIntegralOrder(){
|
|
|
+ $mid = $this->check_login();
|
|
|
+ $order_no = input('order_no');
|
|
|
+ if (!$order_no) $this->error('参数错误');
|
|
|
+
|
|
|
+ $order = Db::name('system_course_order')->where('mid',$mid)->where('order_no',$order_no)->find();
|
|
|
+ if (!$order) $this->error('订单不存在');
|
|
|
+ if ($order['status']!=0) $this->error('订单已支付或已取消');
|
|
|
+
|
|
|
+ $course = Db::name('system_course')->where('id',$order['course_id'])->where('is_del',1)->find();
|
|
|
+ if (!$course) $this->error('课程不存在');
|
|
|
+ if (!$course['is_show']) $this->error('课程已下架');
|
|
|
+ $member_integral = Db::name('system_member')->where('id',$mid)->value('integral');
|
|
|
+ if ($course['price']>$member_integral) $this->error('积分不足，无法购买');
|
|
|
+ Db::startTrans();
|
|
|
+ $com = true;
|
|
|
+ try {
|
|
|
+ $log = memberMoneyChange($order['pay_price'],1,$mid,'积分购买课程',0,$order['id']);
|
|
|
+ if (!$log){
|
|
|
+ $com = false;
|
|
|
+ Db::rollback();
|
|
|
+ }else{
|
|
|
+ Db::name('system_course_order')->where('order_no',$order_no)->update(
|
|
|
+ [
|
|
|
+ 'status'=>1,
|
|
|
+ 'pay_at'=>date('Y-m-d H:i:s')
|
|
|
+ ]
|
|
|
+ );
|
|
|
+ Db::commit();
|
|
|
+ }
|
|
|
+ }catch (\Exception $e){
|
|
|
+ $com = false;
|
|
|
+ Db::rollback();
|
|
|
+ }
|
|
|
+ if ($com){
|
|
|
+ Db::name('system_course')->where('id',$order['course_id'])->setInc('sales');
|
|
|
+ $this->success('支付成功');
|
|
|
+ }
|
|
|
+ $this->error('失败');
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
songxingwei