0816AM

controllers/cases/case.go

+package cases
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/service/cases"
+)
+
+// CaseController 信息
+type CaseController struct {
+	dao *cases.CaseServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *CaseController) Constructor() {
+	c.dao = cases.NewCaseServ(c.Context)
+}

controllers/cases/tag.go

+package cases
+
+import "spaceofcheng/services/models/model"
+
+// GetTagList 获取标签列表
+func (c *CaseController) GetTagList() {
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseIDs := c.GetCaseIDs(cases)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+
+	list, err := c.dao.GetTagList(caseIDs, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetTagByID 根据ID获取标签信息
+func (c *CaseController) GetTagByID() {
+	tagid := c.GetString(":tagid")
+	info, err := c.dao.GetTagByID(tagid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}

models/cases/cases.go

+package cases
+
+import (
+	"spaceofcheng/services/utils"
+
+	"github.com/go-xorm/xorm"
+)
+
+// CaseDAO 当前数据库操作对象
+type CaseDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewCaseDAO New Inst
+func NewCaseDAO(ctx *utils.Context) *CaseDAO {
+	return &CaseDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}

models/cases/tag.go

+package cases
+
+import (
+	"jcjy/demo/models"
+	"spaceofcheng/services/models/model"
+	"strconv"
+	"strings"
+)
+
+// GetTagCount 获取标签总数
+func (m *CaseDAO) GetTagCount(caseids string) (int, error) {
+	var tags []model.SysTag
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").Find(&tags)
+	return len(tags), err
+}
+
+// TagInfo 标签
+type TagInfo struct {
+	model.TaCmsCase `xorm:"extends"`
+	CaseNames       string
+}
+
+// GetTagList 根据案场获取标签
+func (m *CaseDAO) GetTagList(caseids string, page int, pageSize int) ([]TagInfo, error) {
+	var tags []TagInfo
+	sql := `select tag.*,c.case_names from sys_tag tag inner join (
+	select b.tag_id,GROUP_CONCAT(a.case_name) case_names from sys_case a inner join sys_tag_case b on a.case_id=b.case_id and a.status= ` + strconv.Itoa(models.STATUS_NORMAL) + `
+	where b.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `') and b.tag_id not in (select tag_id from sys_tag_case where case_id not in ('` +
+		strings.Replace(caseids, ",", "','", -1) + `'))
+	group by b.tag_id ) c on tag.tag_id = c.tag_id`
+
+	err := m.db.Sql(sql).Find(tags)
+	return tags, err
+}
+
+// Tag 标签
+type Tag struct {
+	model.TaCmsCase `xorm:"extends"`
+	TagCases        []model.SysTagCase
+}
+
+// GetTagByID 根据ID获取标签
+func (m *CaseDAO) GetTagByID(tagid string) (*Tag, error) {
+	var tags []Tag
+	err := m.db.Table("sys_tag").Where("tag_id=?", tagid).Find(&tags)
+	if err != nil {
+		return nil, err
+	}
+	if len(tags) > 0 {
+		return &tags[0], err
+	}
+	return nil, nil
+}
+
+// GetTagCaseByTagID 根据标签ID获取标签对应案场
+func (m *CaseDAO) GetTagCaseByTagID(tagid string) ([]model.SysTagCase, error) {
+	var tagcase []model.SysTagCase
+	err := m.db.Where("tag_id=?", tagid).Find(&tagcase)
+	return tagcase, err
+}

service/cases/cases.go

+package cases
+
+import (
+	"spaceofcheng/services/models/cases"
+	"spaceofcheng/services/utils"
+)
+
+// CaseServ 系统处理
+type CaseServ struct {
+	ctx *utils.Context
+	dao *cases.CaseDAO
+}
+
+// NewCaseServ 初始化
+func NewCaseServ(ctx *utils.Context) *CaseServ {
+	return &CaseServ{
+		ctx: ctx,
+		dao: cases.NewCaseDAO(ctx),
+	}
+}

service/cases/tag.go

+package cases
+
+import (
+	"spaceofcheng/services/models/cases"
+	"spaceofcheng/services/service"
+)
+
+// GetTagList 获取tag列表
+func (s *CaseServ) GetTagList(caseids string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	tags, err := s.dao.GetTagList(caseids, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetTagCount(caseids)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     tags,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetTagByID 根据ID获取标签
+func (s *CaseServ) GetTagByID(tagid string) (*cases.Tag, error) {
+	tag, err := s.dao.GetTagByID(tagid)
+	if err != nil {
+		return nil, err
+	}
+	if tag != nil {
+		tagcases, err := s.dao.GetTagCaseByTagID(tagid)
+		if err != nil {
+			return nil, err
+		}
+		tag.TagCases = tagcases
+	}
+	return tag, err
+}