文章分类模块

controllers/article/article_controller.go

@@ -7,6 +7,10 @@ import (
 	"SCRM/service/article_service"
 	"SCRM/enums"
 	"SCRM/models"
+	"time"
+	"SCRM/utils"
+	"encoding/json"
+	"strconv"
 )
 
 func ArticleRouters() {
@@ -14,6 +18,9 @@ func ArticleRouters() {
 	beego.Router("/api/acticle/createacticle",&ArticleManage{},"Get: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")
 }
 
 type ArticleManage struct {
@@ -28,6 +35,7 @@ func (this *ArticleManage) CreateArticle(){
 	actcontent := this.GetString("act_content")
 	orglogo := this.GetString("org_logo")
 	acttype, _ := this.GetInt64("act_type")
+	timenow := time.Now().Unix()
 	fmt.Println("姓名:",actname,"文章内容",actcontent,"图片",orglogo,"文章类型",acttype,userOrgID)
 	articles := models.Articles{
 				Title: actname,
@@ -35,6 +43,8 @@ func (this *ArticleManage) CreateArticle(){
 				Imgs: orglogo,
 				ClassId: acttype,
 				UserOrgId:userOrgID,
+				Ctime:timenow,
+				Status:1,
 		}
 		err := article_service.AddAritcle(articles)
 		if err !=nil{
@@ -59,7 +69,7 @@ func (this *ArticleManage) GetArticleType(){
 }
 
 func (this *ArticleManage) GetAllArticles()  {
-	page, _ := this.GetInt("page", 1)
+	page, _ := this.GetInt64("page", 1)
 	limit, _ := this.GetInt64("limit", 10)
 	searchKey := this.GetString("search", "")
 	classId,_ := this.GetInt64("classid",0)
@@ -74,16 +84,179 @@ func (this *ArticleManage) GetAllArticles()  {
 	adminUserInfo := this.GetAdminUserInfo()
 	userOrgID := adminUserInfo.CurrentOrgId
 
-	articles, total, err := article_service.FindAllArticle(userOrgID, page,10, searchKey, classId)
+	articles, total, err := article_service.FindAllArticle(userOrgID, page,limit, searchKey, classId)
 	fmt.Println("文章内容是是么",articles)
+	fmt.Println("total",total)
+	fmt.Println("err",err)
 	if err !=nil{
 		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章列表失败")
 		return
 	}
+	category, err := article_service.FindCategoryList(userOrgID)
+	fmt.Println("category是傻",category,err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
 		"articles":articles,
 		"total":total,
+		"category":category,
+	})
+	return
+}
+
+func (this *ArticleManage) AddCategory(){
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
+	fmt.Println("err是什么呢",err)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	name:= dataBody["name"].(string)
+	fmt.Println("name是谁?",name)
+	if len(name) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
+		return
+	}
+
+	content := dataBody["content"].(string)
+	fmt.Println("content是谁?",content)
+	if len(content) == 0 {
+    	this.ServeFailJsonSend(enums.ErrorCodeParamWrong,"内容不能为空")
+    	return
+	}
+
+	sort := dataBody["sort"].(string)
+	sors, _ := strconv.ParseInt(sort, 10, 64)
+	if sors  <=0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
+		return
+	}
+	fmt.Println("soert是谁？",sort)
+	fmt.Println("姓名:",name,"内容",content,"排序",sort)
+	timenow := time.Now().Unix()
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	category := models.ArticleCategory{
+		Name:    name,
+		Summary: content,
+		Order:   sors,
+		UserOrgId:userOrgID,
+		Status: 1,
+		Ctime: timenow,
+	}
+   fmt.Println(category)
+	err = article_service.AddCategory(category)
+	fmt.Println(err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加分类失败")
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"category":category,
+	})
+}
+
+func  (this *ArticleManage) GetCategorys()  {
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	page, _ := this.GetInt64("page", 1)
+	limit, _ := this.GetInt64("limit", 10)
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	fmt.Println("机构ID",userOrgID)
+	categorys, total, err := article_service.GetCategorys(page, limit, userOrgID)
+	fmt.Println("hhe",categorys,total,err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取文章分类列表失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"category":categorys,
+		"total":total,
 	})
 	return
 }
 
+func (this *ArticleManage) EditCategorys()  {
+	id, _ := this.GetInt64("MenuId", 0)
+	fmt.Println("ID是多少",id)
+	if id <= 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	categorys, err := article_service.GetCategorysByID(userOrgID, id)
+	fmt.Println("err是设么",err)
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		return
+	}
+	if categorys == nil {
+		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 {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	name:= dataBody["Name"].(string)
+	fmt.Println("name是谁?",name)
+	if len(name) == 0 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
+		return
+	}
+
+	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 {
+		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "排序不能为空")
+		return
+	}
+	fmt.Println("soert是谁？",sort)
+	fmt.Println("姓名:",name,"内容",content,"排序",sort)
+
+	category := models.ArticleCategory{
+		Name:    name,
+		Summary: content,
+		Order:   sors,
+		UserOrgId:userOrgID,
+		Status: 1,
+		Mtime: timenow,
+	}
+	err = article_service.EditCategory(category)
+	fmt.Println("err错误",err)
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑类别失败：（"+err.Error()+"）")
+		return
+	}
+	fmt.Println(category)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"category":categorys,
+	})
+}

service/article_service/article_category_service.go

@@ -3,6 +3,9 @@ package article_service
 import (
 	"SCRM/models"
 	"SCRM/service"
+	"fmt"
+	"github.com/jinzhu/gorm"
+
 )
 
 func FindArticleCategoryType (userOrgId int64)(*[]models.ArticleCategory,error){
@@ -11,20 +14,25 @@ func FindArticleCategoryType (userOrgId int64)(*[]models.ArticleCategory,error){
 	return  cartegory,err
 }
 
+func FindCategoryList(orgID int64)(cate []*models.ArticleCategory,err error)  {
+	err = service.PatientReadDB().Model(&models.ArticleCategory{}).Where("user_org_id =? AND status =?", orgID, 1).Order("id asc").Find(&cate).Error
+	return
+}
+
 func AddAritcle(articles models.Articles) error {
 	err := service.PatientWriteDB().Create(&articles).Error
 	return  err
 }
 
-func FindAllArticle(orgID int64, page int, count int, searchKey string, classId int64) (articles *[]models.Articles,total int64, err error) {
-
+func FindAllArticle(orgID int64, page int64,limit int64, searchKey string, classId int64) (articles []*models.Articles,total int64, err error) {
+    fmt.Println("机构ID",orgID,"搜搜索",searchKey)
 	db := service.PatientReadDB().Table("sgj_patient_articles as a ").Where("a.status=1")
 	if(orgID>0){
-		db.Where("a.user_org_id = ?" ,orgID)
+	  db = db.Where("a.user_org_id=?" ,orgID)
 	}
 
 	if(classId>0){
-	  db = db.Joins("JOIN sgj_patient_articles_menu as s ON s.id = a.class_id AND s.status=1 AND user_org_id = ?")
+	  db = db.Joins("JOIN sgj_patient_articles_menu as s ON s.id = a.class_id AND s.status=1 AND user_org_id=?",orgID)
 	}
 
 	if len(searchKey) > 0 {
@@ -32,8 +40,50 @@ func FindAllArticle(orgID int64, page int, count int, searchKey string, classId
 		db = db.Where("a.title LIKE ?", searchKey)
 	}
 
-	//err = db.Select("a.id,a.title,a.summary,a.content,a.type,a.num,a.mtime,a.real_read_num,a.ctime,a.class_id,a.author,a.status,a.reason" +
-	//	"a.star_num,a.comment_num,a.user_org_id,a.article_status,a.imgs,a.video_url,a.source,a.category_id,a.ttid,a.ttype,a.toid").Count(&total).Find(&articles).Error
+	    offset := (page - 1) * limit
+		err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Preload("Comments", func(db *gorm.DB) *gorm.DB {
+			return  db.Where(" status = ?",1)
+		}).
+		Select("a.id, a.title, a.summary, a.content, a.type, a.num, a.mtime, a.real_read_num, a.ctime, a.class_id, a.author, a.status, a.reason,a.star_num, a.comment_num,a.user_org_id, a.article_status, a.imgs, a.video_url, a.source, a.category_id, a.ttid, a.ttype, a.toid").Find(&articles).Error
+		fmt.Println("err是啥呢?",err)
+		 	if err != nil {
+			return
+		}
+		return
+}
+
+func AddCategory(category models.ArticleCategory) error {
+	err := service.PatientWriteDB().Create(&category).Error
+	return err
+}
 
+func GetCategorys(page int64,limit int64,orgID int64) ( categorys []*models.ArticleCategory,total int64,err error) {
+	db := service.PatientReadDB().Table("sgj_patient_articles_menu as a").Where("a.status=1")
+	if(orgID > 0){
+		db = db.Where("a.user_org_id=?" ,orgID)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+		Select("a.id,a.name,a.order,a.status,a.summary,a.type,a.user_org_id,a.mtime,a.ctime,a.num").Find(&categorys).Error
+	if err != nil {
 		return
+	}
+	return
+}
+
+func GetCategorysByID(orgID int64,id int64)(categorys []*models.ArticleCategory,err error){
+	err = service.PatientReadDB().Where("user_org_id = ? AND id =? AND status =1", orgID, id).Find(&categorys).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return categorys,err
+}
+
+func EditCategory(category models.ArticleCategory)(err error)  {
+	err = service.PatientWriteDB().Save(&category).Error
+	return err
 }

service/article_service/models.go

@@ -0,0 +1,12 @@
+package article_service
+
+import (
+	"SCRM/models"
+)
+
+type Articles struct{
+
+	models.Articles
+	ArticleCategory []*models.ArticleCategory  `gorm:"foreignkey:class_id" json:"id"`
+ }
+