验证头图、视频、附件id是否正确

core/src/qfw/manage/course.go

@@ -3,6 +3,7 @@ package manage
 import (
 	"encoding/json"
 	"fmt"
+	"io/ioutil"
 	"net/http"
 	"net/url"
 	"qfw/coreconfig"
@@ -530,6 +531,82 @@ func (this *CourseManage) CreateOnLineApi() {
 			courseDate == "" || endTime == "" {
 			return &FuncResult{false, errors.New("参数不完整"), nil}
 		}
+		if picUrl != "" {
+			//生成访问地址
+			resp, err := http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+picUrl+"&model=img")
+			defer resp.Body.Close()
+			if err != nil {
+				return &FuncResult{false, errors.New("视频地址生成错误"), nil}
+			}
+			bytes, err := ioutil.ReadAll(resp.Body)
+
+			if err != nil {
+				fmt.Println("ioutil.ReadAll err=",err)
+				return &FuncResult{false, errors.New("视频地址生成转换错误"), nil}
+			}
+			fmt.Println(string(bytes))
+			item := make(map[string]interface{})
+			err = json.Unmarshal(bytes, &item)
+			if err != nil {
+				fmt.Println(err)
+			} else {
+				if item["code"] == false{
+					msg := item["msg"]
+					return &FuncResult{false, errors.New(fmt.Sprintf("%s", msg)), nil}
+				}
+			}
+		}
+		if videoUrl != "" {
+			//生成访问地址
+			resp, err := http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+videoUrl+"&model=")
+			defer resp.Body.Close()
+			if err != nil {
+				return &FuncResult{false, errors.New("头图地址生成错误"), nil}
+			}
+			bytes, err := ioutil.ReadAll(resp.Body)
+
+			if err != nil {
+				fmt.Println("ioutil.ReadAll err=",err)
+				return &FuncResult{false, errors.New("头图地址生成转换错误"), nil}
+			}
+			fmt.Println(string(bytes))
+			item := make(map[string]interface{})
+			err = json.Unmarshal(bytes, &item)
+			if err != nil {
+				fmt.Println(err)
+			} else {
+				if item["code"] == false{
+					msg := item["msg"]
+					return &FuncResult{false, errors.New(fmt.Sprintf("%s", msg)), nil}
+				}
+			}
+		}
+		if fileUrl != "" {
+			//生成访问地址
+			resp, err := http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+fileUrl+"&model=file")
+			defer resp.Body.Close()
+			if err != nil {
+				return &FuncResult{false, errors.New("附件地址生成错误"), nil}
+			}
+			bytes, err := ioutil.ReadAll(resp.Body)
+
+			if err != nil {
+				fmt.Println("ioutil.ReadAll err=",err)
+				return &FuncResult{false, errors.New("附件地址生成转换错误"), nil}
+			}
+			fmt.Println(string(bytes))
+			item := make(map[string]interface{})
+			err = json.Unmarshal(bytes, &item)
+			if err != nil {
+				fmt.Println(err)
+			} else {
+				if item["code"] == false{
+					msg := item["msg"]
+					return &FuncResult{false, errors.New(fmt.Sprintf("%s", msg)), nil}
+				}
+			}
+		}
+
 		publishtime, err := time.ParseInLocation(qutil.Date_Full_Layout, s_publishtime, time.Local)
 		if err != nil {
 			//return &FuncResult{false, errors.New("发布时间异常"), nil}
@@ -584,14 +661,6 @@ func (this *CourseManage) CreateOnLineApi() {
 			if mongodb.Save("jy_course", mData) == "" {
 				return &FuncResult{false, errors.New("增加课程失败"), nil}
 			} else {
-				if fileUrl != "" {
-					//生成访问地址
-					http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+fileUrl+"&model=file")
-				}
-				if picUrl != "" {
-					//生成访问地址
-					http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+picUrl+"&model=img")
-				}
 				return &FuncResult{true, nil, nil}
 			}
 		} else if Dotype == "edit" {
@@ -617,14 +686,6 @@ func (this *CourseManage) CreateOnLineApi() {
 			if !updateFlag {
 				return &FuncResult{false, errors.New("修改课程失败"), nil}
 			} else {
-				if fileUrl != "" {
-					//生成访问地址
-					http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+fileUrl+"&model=file")
-				}
-				if picUrl != "" {
-					//生成访问地址
-					http.Get(coreconfig.SysConfig.SpdbGetUrl + "/course/fileInit?fileId="+picUrl+"&model=img")
-				}
 				return &FuncResult{true, nil, nil}
 			}
 		}