发布视频模块的开发

controllers/article/article_controller.go

@@ -15,12 +15,15 @@ import (
 
 func ArticleRouters() {
 
-	beego.Router("/api/acticle/createacticle",&ArticleManage{},"Get:CreateArticle")
+	beego.Router("/api/acticle/createacticle",&ArticleManage{},"Post:CreateArticle")
 	beego.Router("/api/acticle/getArticleType",&ArticleManage{},"Get:GetArticleType")
 	beego.Router("/api/acticle/getAllArticles",&ArticleManage{},"Get:GetAllArticles")
 	beego.Router("/api/article/addCategory",&ArticleManage{},"Post:AddCategory")
 	beego.Router("/api/acticle/getCategorys",&ArticleManage{},"Get:GetCategorys")
-	beego.Router("/api/acticle/edit",&ArticleManage{},"Put:EditCategorys")
+	beego.Router("/api/acticle/edit",&ArticleManage{},"Post:EditCategorys")
+	beego.Router("/api/acticle/delete",&ArticleManage{},"Delete:DeleteCategorys")
+	beego.Router("/api/acticle/addvido",&ArticleManage{},"Post:Addvido")
+	beego.Router("/api/acticle/savedraft",&ArticleManage{},"Post:SaveDraft")
 }
 
 type ArticleManage struct {
@@ -31,10 +34,40 @@ type ArticleManage struct {
 func (this *ArticleManage) CreateArticle(){
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := int64(adminUserInfo.CurrentOrgId)
-	actname := this.GetString("act_name")
-	actcontent := this.GetString("act_content")
-	orglogo := this.GetString("org_logo")
-	acttype, _ := this.GetInt64("act_type")
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	actname := dataBody["act_name"].(string)
+	if len(actname) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章标题不能为空")
+		return
+	}
+
+	actcontent := dataBody["act_content"].(string)
+	if len(actcontent) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "文章内容不能为空")
+		return
+	}
+
+	orglogo := dataBody["org_logo"].(string)
+	if len(orglogo) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "封面图片不能为空")
+		return
+	}
+
+	acttype := int64(dataBody["act_type"].(float64))
+	if  acttype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "分类号不能为空")
+		return
+	}
+
 	timenow := time.Now().Unix()
 	fmt.Println("姓名:",actname,"文章内容",actcontent,"图片",orglogo,"文章类型",acttype,userOrgID)
 	articles := models.Articles{
@@ -45,12 +78,17 @@ func (this *ArticleManage) CreateArticle(){
 				UserOrgId:userOrgID,
 				Ctime:timenow,
 				Status:1,
+				Type:1,
+				ArticleStatus:1,
 		}
-		err := article_service.AddAritcle(articles)
+		err = article_service.AddAritcle(articles)
 		if err !=nil{
 			this.ServeFailJsonSend(enums.ErrorCodeDataException, "插入文章失败")
 			return
 		}
+		this.ServeSuccessJSON(map[string]interface{}{
+		"articles":articles,
+		})
 }
 
 func (this *ArticleManage) GetArticleType(){
@@ -124,14 +162,14 @@ func (this *ArticleManage) AddCategory(){
 		return
 	}
 
-	content := dataBody["content"].(string)
+	content := dataBody["summary"].(string)
 	fmt.Println("content是谁?",content)
 	if len(content) == 0 {
     	this.ServeFailJsonSend(enums.ErrorCodeParamWrong,"内容不能为空")
     	return
 	}
 
-	sort := dataBody["sort"].(string)
+	sort := dataBody["order"].(string)
 	sors, _ := strconv.ParseInt(sort, 10, 64)
 	if sors  <=0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
@@ -189,7 +227,7 @@ func  (this *ArticleManage) GetCategorys()  {
 }
 
 func (this *ArticleManage) EditCategorys()  {
-	id, _ := this.GetInt64("MenuId", 0)
+	id, _ := this.GetInt64("id", 0)
 	fmt.Println("ID是多少",id)
 	if id <= 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
@@ -198,18 +236,18 @@ func (this *ArticleManage) EditCategorys()  {
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := adminUserInfo.CurrentOrgId
 	categorys, err := article_service.GetCategorysByID(userOrgID, id)
-	 fmt.Println("err是设么",err)
+	fmt.Println("categorys是?",categorys,err)
 	if err != nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
 		return
 	}
 	if categorys == nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（会员记录不存在）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（会员记录不存在）")
 		return
 	}
-
 	timenow := time.Now().Unix()
 
+
 	dataBody := make(map[string]interface{}, 0)
 	err = json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
 	if err != nil {
@@ -218,28 +256,25 @@ func (this *ArticleManage) EditCategorys()  {
 		return
 	}
 
-	name:= dataBody["Name"].(string)
+	name:= dataBody["name"].(string)
 	fmt.Println("name是谁?",name)
-	if len(name) == 0 {
-		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
-		return
-	}
 
-	content := dataBody["Summary"].(string)
+	content := dataBody["summary"].(string)
 	fmt.Println("content是谁?",content)
 	if len(content) == 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong,"内容不能为空")
 		return
 	}
 
-	sort := dataBody["Order"].(string)
-	sors, _ := strconv.ParseInt(sort, 10, 64)
-	if sors  <=0 {
+	sors :=int64(dataBody["order"].(float64))
+	//sors, _ := strconv.ParseInt(sort, 10, 64)
+	fmt.Println("sort0",sors)
+	if sors  <= 0 {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
 		return
 	}
-	fmt.Println("soert是谁？",sort)
-	fmt.Println("姓名:",name,"内容",content,"排序",sort)
+	fmt.Println("soert是谁？",sors)
+	fmt.Println("姓名:",name,"内容",content,"排序",sors)
 
 	category := models.ArticleCategory{
 		Name:    name,
@@ -249,14 +284,173 @@ func (this *ArticleManage) EditCategorys()  {
 		Status: 1,
 		Mtime: timenow,
 	}
-	err = article_service.EditCategory(category)
-	fmt.Println("err错误",err)
+	fmt.Println("category是?",category)
+	article_service.EditCategory(&category,userOrgID,id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"category":category,
+	})
+}
+
+func (this *ArticleManage) DeleteCategorys()  {
+	adminUserInfo := this.GetAdminUserInfo()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			this.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+	}
+
+	err = article_service.DeleteCategorys(adminUserInfo.CurrentOrgId, ids)
 	if err != nil {
-		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		this.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除分类失败:（"+err.Error()+"）")
 		return
 	}
-	fmt.Println(category)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *ArticleManage) Addvido(){
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	vidupload := dataBody["vio_upload"].(string)
+     if len(vidupload) == 0 {
+		 this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频不能为空")
+		 return
+	 }
+     fmt.Println("视频",vidupload)
+	vidname := dataBody["vid_name"].(string)
+	if len(vidname)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频标题不能为空")
+		return
+	}
+    fmt.Println("视频名称",vidname)
+	vidpic := dataBody["vid_pic"].(string)
+	if(vidpic == ""){
+		vidpic = vidupload + "?vframe/jpg/offset/1/w/300/h/200"
+	}
+	if len(vidpic)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频封面不能为空")
+		return
+	}
+    fmt.Println("视频图片",vidpic)
+	vidtype := int64(dataBody["vid_type"].(float64))
+	if vidtype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "所属分类不能为空")
+		return
+	}
+    fmt.Println("视频类型",vidtype)
+	fmt.Println("视频",vidupload,"视频标题",vidname,"视频封面",vidpic,"视频类型",vidtype)
+	timenow := time.Now().Unix()
+	articles := models.Articles{
+       UserOrgId:userOrgID,
+       Ctime:timenow,
+       Type:2,
+       VideoUrl:vidupload,
+       Title:vidname,
+       Imgs:vidpic,
+       ClassId:vidtype,
+       ArticleStatus:1,
+	}
+
+	err = article_service.AddVido(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加分类失败")
+		return
+	}
+
 	this.ServeSuccessJSON(map[string]interface{}{
-		"category":categorys,
+		"vido":articles,
+	})
+}
+
+func (this *ArticleManage) SaveDraft()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("视频发布是什么呢",err)
+
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	vidupload := dataBody["vio_upload"].(string)
+	if len(vidupload) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频不能为空")
+		return
+	}
+	fmt.Println("视频",vidupload)
+	vidname := dataBody["vid_name"].(string)
+	if len(vidname)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频标题不能为空")
+		return
+	}
+	fmt.Println("视频名称",vidname)
+	vidpic := dataBody["vid_pic"].(string)
+	if(vidpic == ""){
+		vidpic = vidupload + "?vframe/jpg/offset/1/w/300/h/200"
+	}
+	if len(vidpic)==0{
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "视频封面不能为空")
+		return
+	}
+	fmt.Println("视频图片",vidpic)
+	vidtype := int64(dataBody["vid_type"].(float64))
+	if vidtype <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "所属分类不能为空")
+		return
+	}
+	fmt.Println("视频类型",vidtype)
+	fmt.Println("视频",vidupload,"视频标题",vidname,"视频封面",vidpic,"视频类型",vidtype)
+	timenow := time.Now().Unix()
+	articles := models.Articles{
+		UserOrgId:userOrgID,
+		Ctime:timenow,
+		Type:2,
+		VideoUrl:vidupload,
+		Title:vidname,
+		Imgs:vidpic,
+		ClassId:vidtype,
+		ArticleStatus:2,
+	}
+
+	err = article_service.AddVido(articles)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加分类失败")
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"savedraft":articles,
 	})
 }

models/article_models.go

@@ -2,16 +2,16 @@ package models
 
 type ArticleCategory struct{
 	//对应数据库中的字段
-	MenuId    int64  `gorm:"column:id" `
-	Name      string `gorm:"column:name" `
-	Order     int64  `gorm:"column:order" `
-	Status    int64  `gorm:"column:status" `
-	Summary   string `gorm:"column:summary" `
-	Type      int64  `gorm:"column:type"`
-	Mtime     int64  `gorm:"column:mtime"`
-	Ctime     int64  `gorm:"column:ctime"`
-	UserOrgId int64  `gorm:"column:user_org_id"`
-	Num       int64  `gorm:"column:num" json:"num"`
+	IMenuId int64 `gorm:"column:id" json:"id" form:"id"`
+	Name string `gorm:"column:name" json:"name" form:"Name"`
+	Order int64 `gorm:"column:order" json:"order" form:"order"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	Summary string `gorm:"column:summary" json:"summary" form:"summary"`
+	Type int64 `gorm:"column:type" json:"type" form:"type"`
+	UserOrgId int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Mtime int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Ctime int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Num int64 `gorm:"column:num" json:"num" form:"num"`
 
 }
 

service/article_service/article_category_service.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"github.com/jinzhu/gorm"
 
+	"time"
 )
 
 func FindArticleCategoryType (userOrgId int64)(*[]models.ArticleCategory,error){
@@ -83,7 +84,20 @@ func GetCategorysByID(orgID int64,id int64)(categorys []*models.ArticleCategory,
 	return categorys,err
 }
 
-func EditCategory(category models.ArticleCategory)(err error)  {
-	err = service.PatientWriteDB().Save(&category).Error
-	return err
+func EditCategory(cat *models.ArticleCategory,orgID int64,id int64){
+	 service.PatientWriteDB().Model(cat).Where("user_org_id =? AND id =? AND status = ?", orgID, id, 1).Update(map[string]interface{}{"Name": cat.Name, "Summary": cat.Summary, "Order": cat.Order, "mtime": cat.Mtime})
+}
+
+func DeleteCategorys(orgID int64,ids[] int64)(err error){
+     if len(ids) ==1{
+      err =	service.PatientWriteDB().Model(&models.ArticleCategory{}).Where( "id=? and user_org_id = ?",ids[0],orgID).Update(map[string]interface{}{"Status":0,"mtime":time.Now().Unix()}).Error
+	 }else {
+	  err =	service.PatientWriteDB().Model(&models.ArticleCategory{}).Where("id IN (?) and user_org_id = ?",ids,orgID).Update(map[string]interface{}{"Status":0,"mtime":time.Now().Unix()}).Error
+	 }
+	 return
+}
+
+func AddVido(articles models.Articles) error  {
+	err := service.PatientWriteDB().Create(&articles).Error
+	return  err
 }