完成课程保存的整个过程（数据验证,文件认领等等）

src/common/libs/Utils.php

@@ -54,7 +54,7 @@ class Utils
         
         foreach ($errors as $k => $v) {
             foreach ($v as $msg) {
-                $msg[] = $msg;
+                $msgs[] = $msg;
             }
         }
         

src/common/models/AttachUploadForm.php

@@ -123,5 +123,49 @@ class AttachUploadForm extends Model
 		$key = self::SESS_PREFIX.$tmp;
 		return Yii::$app->session->remove($key);
 	}
+
+	/**
+	 * 认领并绑定指定内容下的所有附件
+	 *
+	 * @param string $tmp
+	 * @param string $bind 绑定归属
+	 * @return int 绑定附件数量
+	 */
+	public static function claimTmpAttachs($tmp, $bind)
+	{
+		$attachs = self::getTmpAttachs($tmp);
+		$count = self::claimAttachs($attachs, $bind);
+		$count > 0 && self::clearTmpAttachs($tmp);
+		return $count;
+	}
+
+	/**
+	 * 认领并绑定传入的附件数据
+	 *
+	 * @param $attachData
+	 * @return int
+	 */
+	protected static function claimAttachs($attachData, $bind)
+	{
+		$count = 0;
+
+		if ($attachData) {
+			foreach ($attachData as $uuid) {
+				$cl = UploadPools::claimFile($uuid);
+				if ($cl) {
+					Yii::$app->db->createCommand()->insert('upload_attachments', [
+							'bind' => $bind, 
+							'key' => $cl['key'], 
+							'filesize' => $cl['filesize'], 
+							'w' => $cl['w'], 
+							'h' => $cl['h']
+						])->execute();
+					++$count;
+				}
+			}
+		}
+
+		return $count;
+	}
 	
 }
\ No newline at end of file

src/common/models/Course.php

@@ -14,7 +14,6 @@ use yii\redis\ActiveRecord;
  * @property integer $user_id
  * @property integer $classed_id
  * @property string $name
- * @property array $teacher
  * @property integer $price
  * @property integer $free_time
  * @property string $intro
@@ -42,7 +41,7 @@ class Course extends \yii\db\ActiveRecord
 
         $this->name = strip_tags($this->name);
         $this->intro = HtmlPurifier::process($this->intro);
-        
+
         return true;
     }
 
@@ -70,12 +69,12 @@ class Course extends \yii\db\ActiveRecord
         return [
             [['name', 'preview_pic'], 'required'],
             ['name', 'string', 'length'=>[1,60]],
-            //['teacher', 'exist', 'targetAttribute'=>'teacher_id', 'targetClass'=>CourseTeacher::className(), 'allowArray'=>true],
-            ['user_id', 'integer'],
-            ['class_id', 'integer'],
+            [['user_id', 'class_id'], 'integer'],
+            ['intro', 'string'],
             ['price', 'integer', 'min'=>0, 'max'=>9999],
             ['free_time', 'integer', 'min'=>0, 'max'=>15],
             ['recommend', 'boolean'],
+            ['recommend', 'default', 'value'=>0],
             ['status', 'in', 'range'=>[0, 1, 2, 3]]
         ];
     }

src/common/models/UploadPools.php

@@ -47,7 +47,7 @@ class UploadPools extends ActiveRecord
 
 	public function validateSkey($attr, $params)
 	{
-		if (!preg_match('/^\w+:[\w\.\/]+$/', $this->$attr)) {
+		if (!preg_match('#^[\w\-]+\:[\w\-\./]+$#i', $this->$attr)) {
 			$this->addError($attr, "$attr format is not a validate skey.");
 		}
 	}
@@ -140,6 +140,7 @@ class UploadPools extends ActiveRecord
 	 */
 	protected static function claimFileConfirm($file)
 	{
+
 		if ($file && $file->status == self::STATUS_UNUSE) {
 			$file->status = self::STATUS_USED;
 			$file->save();

src/console/migrations/m161010_075253_upload_attachments_init.php

@@ -15,7 +15,6 @@ class m161010_075253_upload_attachments_init extends Migration
             'filesize' => $this->integer(10)->unsigned()->notNull(),
             'w' => $this->smallInteger(5)->unsigned()->defaultValue(0)->comment('图片宽'),
             'h' => $this->smallInteger(5)->unsigned()->defaultValue(0)->comment('图片高'),
-            '`status` tinyint(1) NOT NULL DEFAULT \'0\' COMMENT \'文件状态: 0未认领，1已认领，2已删除（弃用）\'',
             'upload_time' => $this->integer(10)->unsigned()->notNull()->comment('上传时间'),
             'PRIMARY KEY (`id`)',
             'KEY `bind` (`bind`)',

src/frontend/controllers/MyCourseController.php

@@ -46,27 +46,44 @@ class MyCourseController extends \yii\web\Controller
     
     public function actionSubmit()
     {
-        $course = new Course();
-        $courseware = new Courseware();
-        $courseTeacher = new CourseTeacher();
-        
         $request = Yii::$app->request;
 
         $userId = 1;
         $classId = 1;
 
+        //验证临时ID
+        $tmpId = $request->post('tmp');
+
+        if (!$tmpId || !preg_match('/^\w{20}$/i', $tmpId)) {
+            Utils::ajaxResponse(false, '参数错误');
+            return;
+        }
+
         //课程数据
         $courseData = [
             'user_id' => $userId,
             'classed_id' => $classId
         ];
 
-        foreach (['name', 'teacher', 'price', 'free_time', 'intro', 'preview_pic', 'recommend'] as $key) {
-            $courseData[$key] = $request->post($key);
+        foreach (['name', 'teacher', 'price', 'free_time', 'intro', 'preview'=>'preview_pic', 'recommend'] as $postKey => $key) {
+            is_int($postKey) && $postKey = $key;
+            $courseData[$key] = $request->post($postKey);
         }
 
+        $course = new Course();
         $course->load($courseData);
 
+        //检查预览图是否存在
+        $previewFile = UploadPools::getFileInfo($courseData['preview_pic']);
+
+        if ($previewFile) {
+            $course->preview_pic = $previewFile['key'];
+        } else {
+            Utils::ajaxResponse(false, '预览图不存在');
+            return;
+        }
+
+        //验证课程数据
         if (!$course->validate()) {
             Utils::ajaxResponse(false, join('<br>', Utils::fetchErrors($course->errors)));
             return;
@@ -78,7 +95,6 @@ class MyCourseController extends \yii\web\Controller
 
         //课件数据
         $vuid = $request->post('vuid');
-        $vuid = '2ade5751-8fae-11e6-a1b1-1242ac110005'; //测试uuid
         $cwData = [
             'user_id' => $userId,
             'course_id' => 0,
@@ -88,32 +104,86 @@ class MyCourseController extends \yii\web\Controller
             'format' => ''
         ];
 
-        $video = UploadPools::getFileInfo($vuid);
+        //处理视频信息
+        $videoFile = UploadPools::getFileInfo($vuid);
 
-
-        if ($video) {
-            $bucket = Yii::$app->qiniu->getStorageConfig($video['storage'], 'bucket');
-            $auth = Yii::$app->qiniu->getAuthInstance();
+        if ($videoFile) {
+            $qiniu = Yii::$app->qiniu;
+            $bucket = $qiniu->getStorageConfig($videoFile['storage'], 'bucket');
+            $auth = $qiniu->getAuthInstance();
             $bucketMgr = new BucketManager($auth);
 
-            list($ret, $err) = $bucketMgr->stat($bucket, $video['key']);
+            list($ret, $err) = $bucketMgr->stat($bucket, $videoFile['key']);
 
             if ($err !== null) {
-                echo $err->message();
+                Utils::ajaxResponse(false, $err->message());
+                return;
             } else {
-                print_r($ret);
+                $cwData['size'] = $ret['fsize'];
             }
-        }
 
-        return;
+            //读取视频信息
+            $avUrl = $videoFile['url'].'?avinfo';
+            $response = (new \GuzzleHttp\Client())->get($avUrl);
 
-        $courseware->load($cwData);
+            $avInfo = $response->getBody();
+
+            if ($avInfo) {
+                $avInfo = \GuzzleHttp\json_decode($avInfo, true);
+            } else {
+                Utils::ajaxResponse(false, '读取视频信息失败');
+                return;
+            }
+
+            //list($video, $audio) = $avInfo['streams'];
+            //$format = $avInfo['format'];
 
-        if ($courseware->validate()) {
-            echo 'Success';
+            $cwData['name'] = $videoFile['key'];
+            $cwData['time'] = round($avInfo['format']['duration']);
+            $cwData['format'] = pathinfo($videoFile['key'], PATHINFO_EXTENSION);
         } else {
-            print_r($courseware->errors);
+            Utils::ajaxResponse(false, '视频文件不存在');
+            return;
+        }
+
+        //验证课件数据
+        $courseware = new Courseware();
+        $courseware->load($cwData);
+        if (!$courseware->validate()) {
+            Utils::ajaxResponse(false, join('<br>', Utils::fetchErrors($courseware->errors)));
+            return;
         }
+
+        //保存课程数据
+        if (!$course->save()) {
+            Utils::ajaxResponse(false, '课程保存失败');
+            return;
+        }
+
+        //保存课件数据
+        $courseware->course_id = $course->id;
+        
+        if (!$courseware->save()) {
+            Utils::ajaxResponse(false, '课件保存失败');
+            return;
+        }
+        
+        //保存讲师与课程关联数据
+        foreach ($teacherIds as $teacherId) {
+            $ct = new CourseTeacher();
+            $ct->course_id = $course->id;
+            $ct->teacher_id = $teacherId;
+            $ct->save();
+        }
+
+        //认领文件
+        UploadPools::claimFile($vuid);
+        UploadPools::claimFile($courseData['preview_pic']);
+
+        //保存附件关联
+        AttachUploadForm::claimTmpAttachs($tmpId, 'course:'.$course->id);
+
+        Utils::ajaxResponse(true, '', ['course_id'=>$course->id]);
     }
 
     /**
@@ -146,9 +216,7 @@ class MyCourseController extends \yii\web\Controller
 
     public function actionTest()
     {
-        $data = AttachUploadForm::getTmpAttachs('dxQ9tE6XyKX2TD6bndgP');
-
-        var_dump($data);
+        print_r(UploadPools::claimFile('2ade5751-8fae-11e6-a1b1-1242ac110005'));
     }
 
 }

src/frontend/views/my-course/publish.php

@@ -77,7 +77,7 @@ AppAsset::addCss($this, '@web/assets/css/course_publish.css');
 		<div class="tit">课程属性</div>
 		<div class="checkbox">
 			<label>
-				<input type="checkbox" name="recommend">推荐课程
+				<input type="checkbox" name="recommend" value="1">推荐课程
 			</label>
 		</div>
 	</div>

src/frontend/web/js/my-course/publish.js

@@ -80,7 +80,7 @@ var vm = new Vue({
 		});
 		
 		this.$on("thumb-uploaded", function(name, data) {
-			self.previewKey = data.key;
+			self.previewKey = data.uuid;
 		});
 
 		var validator = $(form).validate({
@@ -141,8 +141,12 @@ var vm = new Vue({
 			submitHandler: function() {
 				var data = $(form).serialize();
 				$.post("/my-course/submit", data, function(t) {
-					alert(t);
-				});
+					if (t.status) {
+						alert("保存成功,请等待审核!");
+					} else {
+						alert(t.message);
+					}
+				}, "json");
 				return false;
 			}
 		});