评论模块修改

controllers/article/article_controller.go

 	beego.Router("/api/article/deleteArticle",&ArticleManage{},"Get:DeleteArticles")
 	beego.Router("/api/acticle/send",&ArticleManage{},"Get:SendReplycontent")
 	beego.Router("/api/acticle/getReplyAllComents",&ArticleManage{},"Get:GetReplyAllComents")
+	beego.Router("/api/article/sendInformation",&ArticleManage{},"Get:GetSendInformation")
+	beego.Router("/api/article/spreadReplay",&ArticleManage{},"Get:GetSpreadReplay")
+	beego.Router("/api/article/clearRelyInfo",&ArticleManage{},"Delete:ClearReplyInfo")
+	beego.Router("/api/article/deleteReply",&ArticleManage{},"Delete:DeleteReply")
+	beego.Router("/api/article/spread",&ArticleManage{},"Get:GetSpreadInfo")
 }
 
 type ArticleManage struct {
 	    "total":total,
 	})
 }
+
+func  (this * ArticleManage) GetSendInformation()  {
+	artilcid, _ := this.GetInt64("artilcid")
+	fmt.Println("文章id",artilcid)
+	parentid, _ := this.GetInt64("parentid")
+	fmt.Println("父类id",parentid)
+	content := this.GetString("content")
+	fmt.Println("文章内容",content)
+	adminUserInfo := this.GetAdminUserInfo()
+	userOrgID := adminUserInfo.CurrentOrgId
+	org := adminUserInfo.Orgs[adminUserInfo.CurrentOrgId]
+	orgName := org.OrgName
+	orgLogo := org.OrgLogo
+	fmt.Println("logo",orgLogo)
+	comment := models.Comment{
+		Content: content,
+		ParentId: parentid,
+		ArticleId: artilcid,
+		Ctime: time.Now().Unix(),
+		CommentUserId:userOrgID,
+		Status:1,
+		CommentUserAvater: orgLogo,
+		CommentUserName:orgName,
+	}
+	err := article_service.AddComment(&comment)
+	fmt.Println("错误是什么",err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加回复内容失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"comment":comment,
+	})
+}
+
+func  (this * ArticleManage) GetSpreadReplay()  {
+	artilcid, _ := this.GetInt64("artilcid")
+	fmt.Println("文章id",artilcid)
+	parentid, _ := this.GetInt64("parentid")
+	fmt.Println("父类id",parentid)
+
+	comments, err := article_service.GetAllReplyFormId(artilcid, parentid)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "查询回复内容失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"comments":comments,
+	})
+}
+
+func (this * ArticleManage) ClearReplyInfo()  {
+	id, _ := this.GetInt64("id")
+	fmt.Println("id为",id)
+	err := article_service.ClearReplyInfo(id)
+	fmt.Println("错误为",err)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "删除回复成功")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this * ArticleManage) DeleteReply()  {
+	id, _ := this.GetInt64("id")
+	fmt.Println("id为",id)
+	err := article_service.DeleteReply(id)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "删除回复成功")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this * ArticleManage) GetSpreadInfo()  {
+	parentid, _ := this.GetInt64("parentid")
+	acticlid, _ := this.GetInt64("acticlid")
+	fmt.Println("父类id",parentid)
+	fmt.Println("文章id",acticlid)
+	comments, err := article_service.GetQueryReplyInfo(parentid, acticlid)
+	if err !=nil{
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "查询回复内容失败")
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"comments":comments,
+	})
+}

service/article_service/article_category_service.go

 func GetReplyAllComents(page int64,limit int64)(comment []*models.Comment,total int64,err error)  {
 	db := service.PatientReadDB().Table("sgj_patient_articles_comment as a").Where("a.status = 1")
 	offset := (page - 1) * limit
-	err = db.Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
+	err = db.Where("parent_id = ?",0).Count(&total).Order("a.ctime desc").Offset(offset).Limit(limit).
 		Select("a.id,a.article_id,a.comment_user_id,a.parent_id,a.content,a.ctime,a.status,a.star_num,a.comment_num,a.comment_id,a.comment_user_name,a.comment_user_avater,a.source,a.ttid,a.tuser_id,a.taid,a.tpid,a.tcid").Find(&comment).Error
 	fmt.Println("err是啥呢?",err)
 	if err != nil {
 	return
 }
 
+func GetAllReplyFormId(articleID int64, commentId int64)([]models.Comment, error)  {
+	var comments []models.Comment
+	errs := service.PatientReadDB().Model(&models.Comment{}).
+		Where("article_id = ? AND parent_id = ? AND status = ?", articleID, commentId, 1).
+		Find(&comments).Error
 
+	return comments, errs
+}
 
+func ClearReplyInfo(id int64)(error){
+	err := service.PatientWriteDB().Model(&models.Comment{}).Where("id = ?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return  err
+}
 
+func DeleteReply(id int64)(error){
+	err := service.PatientWriteDB().Model(&models.Comment{}).Where("id = ?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	 return  err
+	}
+func GetQueryReplyInfo(parentid int64,articleID int64)([]models.Comment,error)  {
+	var comments []models.Comment
+	errs := service.PatientWriteDB().Model(&models.Comment{}).
+		Where("article_id = ? AND parent_id = ? AND status = ?", articleID, parentid, 1).Find(&comments).Error
+		return  comments,errs
+}