conflict

controllers/cases/case.go

@@ -0,0 +1,19 @@
+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

@@ -0,0 +1,27 @@
+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)
+}

controllers/goods/goods.go

@@ -2,7 +2,6 @@ package goods
 
 import (
 	"spaceofcheng/services/controllers"
-	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/goods"
 )
 
@@ -18,101 +17,3 @@ type GoodsController struct {
 func (c *GoodsController) Constructor() {
 	c.dao = goods.NewGoodsServ(c.Context)
 }
-
-// GetGoodsType 获取商品分类列表
-func (c *GoodsController) GetGoodsType() {
-	caseids := c.GetString("caseid")
-	if caseids == "" {
-		cases := c.Context.Get("cases").([]model.SysUserCase)
-		caseids = c.GetCaseIDs(cases)
-	}
-	page, _ := c.GetInt("page")
-	pageSize, _ := c.GetInt("pagesize")
-	goodstype, err := c.dao.GetGoodsType(caseids, page, pageSize)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(goodstype)
-}
-
-// GetGoodsTypeByID 根据ID获取商品分类
-func (c *GoodsController) GetGoodsTypeByID() {
-	typeid := c.GetString(":typeid")
-	goodsType, err := c.dao.GetGoodsTypeByID(typeid)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(goodsType)
-}
-
-// SaveGoodsType 保存商品分类
-func (c *GoodsController) SaveGoodsType() {
-	goodsType := model.TdGoodsType{}
-	if err := c.ParseForm(&goodsType); err != nil {
-		c.ResponseError(err)
-	}
-	newtype, err := c.dao.SaveGoodsType(goodsType)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(newtype)
-}
-
-// DelGoodsType 删除商品分类
-func (c *GoodsController) DelGoodsType() {
-	typeid := c.GetString(":typeid")
-	err := c.dao.DelGoodsType(typeid)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON("删除成功！")
-}
-
-// GetGoodsSpec 获取商品规格列表
-func (c *GoodsController) GetGoodsSpec() {
-	caseids := c.GetString("caseid")
-	if caseids == "" {
-		cases := c.Context.Get("cases").([]model.SysUserCase)
-		caseids = c.GetCaseIDs(cases)
-	}
-	page, _ := c.GetInt("page")
-	pageSize, _ := c.GetInt("pagesize")
-	goodsSpec, err := c.dao.GetGoodsSpec(caseids, page, pageSize)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(goodsSpec)
-}
-
-// GetGoodsSpecByID 根据ID获取商品分类
-func (c *GoodsController) GetGoodsSpecByID() {
-	specid := c.GetString(":specid")
-	goodsSpec, err := c.dao.GetGoodsSpecByID(specid)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(goodsSpec)
-}
-
-// SaveGoodsSpec 保存商品分类
-func (c *GoodsController) SaveGoodsSpec() {
-	goodsSpec := model.TdSpec{}
-	if err := c.ParseForm(&goodsSpec); err != nil {
-		c.ResponseError(err)
-	}
-	newSpec, err := c.dao.SaveGoodsSpec(goodsSpec)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON(newSpec)
-}
-
-// DelGoodsSpec 删除商品分类
-func (c *GoodsController) DelGoodsSpec() {
-	specid := c.GetString(":specid")
-	err := c.dao.DelGoodsSpec(specid)
-	if err != nil {
-		c.ResponseError(err)
-	}
-	c.ResponseJSON("删除成功！")
-}

controllers/goods/spec.go

@@ -0,0 +1,52 @@
+package goods
+
+import "spaceofcheng/services/models/model"
+
+// GetGoodsSpec 获取商品规格列表
+func (c *GoodsController) GetGoodsSpec() {
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	goodsSpec, err := c.dao.GetGoodsSpec(caseids, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsSpec)
+}
+
+// GetGoodsSpecByID 根据ID获取商品分类
+func (c *GoodsController) GetGoodsSpecByID() {
+	specid := c.GetString(":specid")
+	goodsSpec, err := c.dao.GetGoodsSpecByID(specid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsSpec)
+}
+
+// SaveGoodsSpec 保存商品分类
+func (c *GoodsController) SaveGoodsSpec() {
+	goodsSpec := model.TdSpec{}
+	if err := c.ParseForm(&goodsSpec); err != nil {
+		c.ResponseError(err)
+	}
+	newSpec, err := c.dao.SaveGoodsSpec(goodsSpec)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newSpec)
+}
+
+// DelGoodsSpec 删除商品分类
+func (c *GoodsController) DelGoodsSpec() {
+	specid := c.GetString(":specid")
+	err := c.dao.DelGoodsSpec(specid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/goods/type.go

@@ -0,0 +1,52 @@
+package goods
+
+import "spaceofcheng/services/models/model"
+
+// GetGoodsType 获取商品分类列表
+func (c *GoodsController) GetGoodsType() {
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	goodstype, err := c.dao.GetGoodsType(caseids, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodstype)
+}
+
+// GetGoodsTypeByID 根据ID获取商品分类
+func (c *GoodsController) GetGoodsTypeByID() {
+	typeid := c.GetString(":typeid")
+	goodsType, err := c.dao.GetGoodsTypeByID(typeid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(goodsType)
+}
+
+// SaveGoodsType 保存商品分类
+func (c *GoodsController) SaveGoodsType() {
+	goodsType := model.TdGoodsType{}
+	if err := c.ParseForm(&goodsType); err != nil {
+		c.ResponseError(err)
+	}
+	newtype, err := c.dao.SaveGoodsType(goodsType)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newtype)
+}
+
+// DelGoodsType 删除商品分类
+func (c *GoodsController) DelGoodsType() {
+	typeid := c.GetString(":typeid")
+	err := c.dao.DelGoodsType(typeid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/message/cmscase.go

@@ -0,0 +1,62 @@
+package message
+
+import "spaceofcheng/services/models/model"
+
+// GetCmsCase 获取项目列表
+func (c *MessageController) GetCmsCase() {
+	org := c.Context.Get("org").(model.SysOrg)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	name := c.GetString("name")
+	list, err := c.dao.GetCmsCasesList(name, org.OrgId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetCmsCaseList 项目列表
+func (c *MessageController) GetCmsCaseList() {
+	orgid := c.GetString("orgid")
+	list, err := c.dao.GetCmsCaseByOrg(orgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetCmsCaseByID 获取明细
+func (c *MessageController) GetCmsCaseByID() {
+	cmscaseid := c.GetString(":cmscaseid")
+	cmscase, err := c.dao.GetCmsCasesByID(cmscaseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(cmscase)
+}
+
+// SaveCmsCase 保存项目
+func (c *MessageController) SaveCmsCase() {
+	cmscase := model.TaCmsCase{}
+	if err := c.ParseForm(&cmscase); err != nil {
+		c.ResponseError(err)
+	}
+	courseids := c.GetString("courseids")
+	imgs := c.GetString("imgs")
+	detailimgs := c.GetString("detailimgs")
+	newInfo, err := c.dao.SaveCmsCase(cmscase, courseids, imgs, detailimgs)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newInfo)
+}
+
+// DelCmsCase 删除项目
+func (c *MessageController) DelCmsCase() {
+	cmscaseid := c.GetString(":cmscaseid")
+	err := c.dao.DelCmsCase(cmscaseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/message/image.go

@@ -0,0 +1,59 @@
+package message
+
+import "spaceofcheng/services/models/model"
+
+// GetImgList 获取轮播图列表
+func (c *MessageController) GetImgList() {
+	org := c.Context.Get("org").(model.SysOrg)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	imgs, err := c.dao.GetImgList(org.OrgId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(imgs)
+}
+
+// GetImgByLocation 根据位置获取轮播图信息
+func (c *MessageController) GetImgByLocation() {
+	loctionid := c.GetString("loctionid")
+	orgid := c.GetString("orgid")
+	imgs, err := c.dao.GetImgByLocation(loctionid, orgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(imgs)
+}
+
+// GetImgByID 根据id获取轮播图信息
+func (c *MessageController) GetImgByID() {
+	imgid := c.GetString(":imgid")
+	img, err := c.dao.GetImgByID(imgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(img)
+}
+
+// SaveImage 保存轮播图信息
+func (c *MessageController) SaveImage() {
+	img := model.TaCmsImages{}
+	if err := c.ParseForm(&img); err != nil {
+		c.ResponseError(err)
+	}
+	newInfo, err := c.dao.SaveImg(img)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newInfo)
+}
+
+// DelImg 删除轮播图信息
+func (c *MessageController) DelImg() {
+	imgid := c.GetString(":imgid")
+	err := c.dao.DelImg(imgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/message/location.go

@@ -13,6 +13,16 @@ func (c *MessageController) GetLocations() {
 	c.ResponseJSON(location)
 }
 
+// GetLocationById 根据id获取位置信息
+func (c *MessageController) GetLocationById() {
+	locationid := c.GetString(":locationid")
+	location, err := c.dao.GetLocationByID(locationid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(location)
+}
+
 // SaveLocation 保存位置信息
 func (c *MessageController) SaveLocation() {
 	location := model.TdCmsImageLocation{}

controllers/message/message.go

@@ -2,6 +2,7 @@ package message
 
 import (
 	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/message"
 )
 
@@ -17,3 +18,60 @@ type MessageController struct {
 func (c *MessageController) Constructor() {
 	c.dao = message.NewMessageServ(c.Context)
 }
+
+// GetCmsInfoList 获取消息列表
+func (c *MessageController) GetCmsInfoList() {
+	org := c.Context.Get("org").(model.SysOrg)
+	title := c.GetString("title")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	cmsInfos, err := c.dao.GetCmsInfoList(title, org.OrgId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(cmsInfos)
+}
+
+// GetCmsInfoByLocation 根据位置获取消息列表
+func (c *MessageController) GetCmsInfoByLocation() {
+	locationid := c.GetString("locationid")
+	orgid := c.GetString("orgid")
+	cmsinfos, err := c.dao.GetCmsInfoByLocation(locationid, orgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(cmsinfos)
+}
+
+// GetCmsInfoByID 根据id获取消息信息
+func (c *MessageController) GetCmsInfoByID() {
+	infoid := c.GetString(":infoid")
+	info, err := c.dao.GetCmsInfoByID(infoid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// SaveCmsInfo 保存消息信息
+func (c *MessageController) SaveCmsInfo() {
+	cmsinfo := model.TaCmsInfo{}
+	if err := c.ParseForm(&cmsinfo); err != nil {
+		c.ResponseError(err)
+	}
+	newInfo, err := c.dao.SaveCmsInfo(cmsinfo)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newInfo)
+}
+
+// DelCmsInfo 删除消息信息
+func (c *MessageController) DelCmsInfo() {
+	infoid := c.GetString(":infoid")
+	err := c.dao.DelCmsInfo(infoid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

controllers/message/news.go

@@ -0,0 +1,61 @@
+package message
+
+import "spaceofcheng/services/models/model"
+
+// GetNews 获取咨询列表
+func (c *MessageController) GetNews() {
+	org := c.Context.Get("org").(model.SysOrg)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	locationid := c.GetString("locationid")
+	news, err := c.dao.GetNewsList(locationid, org.OrgId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(news)
+}
+
+// GetNewsByID 获取咨询明细
+func (c *MessageController) GetNewsByID() {
+	newsid := c.GetString(":newsid")
+	news, err := c.dao.GetNewsByID(newsid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(news)
+}
+
+// GetNewsByLocation 根据位置获取咨询明细
+func (c *MessageController) GetNewsByLocation() {
+	locationid := c.GetString("locationid")
+	orgid := c.GetString("orgid")
+	news, err := c.dao.GetNewsByLocation(locationid, orgid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(news)
+}
+
+// SaveNews 保存咨询明细
+func (c *MessageController) SaveNews() {
+	news := model.TaCmsNews{}
+	if err := c.ParseForm(&news); err != nil {
+		c.ResponseError(err)
+	}
+	locationids := c.GetString("locationids")
+	newInfo, err := c.dao.SaveNews(news, locationids)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newInfo)
+}
+
+// DelNews 删除咨询明细
+func (c *MessageController) DelNews() {
+	newsid := c.GetString(":newsid")
+	err := c.dao.DelNews(newsid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

models/cases/cases.go

@@ -0,0 +1,21 @@
+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

@@ -0,0 +1,60 @@
+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
+}

models/constant.go

@@ -17,3 +17,8 @@ const (
 	ACCMAP_WECHAT = "wechat"
 	ACCMAP_MINI   = "mini"
 )
+
+const (
+	IMAGETYPE_COVER  = "cover"
+	IMAGETYPE_DETAIL = "detail"
+)

models/message/cmscase.go

@@ -0,0 +1,154 @@
+package message
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/go-xorm/builder"
+)
+
+// CmsCaseInfo 项目专题
+type CmsCaseInfo struct {
+	model.TaCmsCase `xorm:"extends"`
+	CaseName        string
+}
+
+// GetCmsCaseList 获取项目专题列表
+func (m *MessageDAO) GetCmsCaseList(name, caseids string, page int, pageSize int) ([]CmsCaseInfo, error) {
+	var cases []CmsCaseInfo
+	sql := `select a.*,b.case_name from ta_cms_case a inner join sys_case b on a.case_id = b.case_id 
+	where a.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `') and a.name like '%` + name + `%' and a.status > ` + strconv.Itoa(models.STATUS_DEL) + `
+	and b.status > ` + strconv.Itoa(models.STATUS_DEL) + `
+	order by create_date desc limit ` + strconv.Itoa(page*pageSize) + `, ` + strconv.Itoa((page+1)*pageSize)
+
+	err := m.db.Sql(sql).Find(&cases)
+	return cases, err
+}
+
+// GetCmsCaseByOrg 获取列表
+func (m *MessageDAO) GetCmsCaseByOrg(orgid string) ([]model.TaCmsCase, error) {
+	var cases []model.TaCmsCase
+	err := m.db.Where("org_id=?", orgid).Find(&cases)
+	return cases, err
+}
+
+// GetCmsCaseListCount 获取项目专题Count
+func (m *MessageDAO) GetCmsCaseListCount(name, caseids string) (int, error) {
+	var cases []CmsCaseInfo
+	sql := `select a.*,b.case_name from ta_cms_case a inner join sys_case b on a.case_id = b.case_id 
+	where a.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `') and a.name like '%` + name + `%' 
+	and a.status > ` + strconv.Itoa(models.STATUS_DEL) + ` and b.status > ` + strconv.Itoa(models.STATUS_DEL)
+
+	err := m.db.Sql(sql).Find(&cases)
+	if err != nil {
+		return 0, err
+	}
+	return len(cases), nil
+}
+
+// CmsCase 项目详情
+type CmsCase struct {
+	model.TaCmsCase `xorm:"extends"`
+	Courses         []model.TaCourse
+	CmsCaseImgs     []model.TaCmsCaseImage
+}
+
+// GetCmsCaseByID 获取项目专题详情
+func (m *MessageDAO) GetCmsCaseByID(cmscaseid string) (*CmsCase, error) {
+	var cases []CmsCase
+	err := m.db.Table("ta_cms_case").Where("cms_case_id=?", cmscaseid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&cases)
+	if err != nil {
+		return nil, err
+	}
+	if len(cases) > 0 {
+		return &cases[0], nil
+	}
+	return nil, nil
+}
+
+// GetCoursesByCmsCase 根据项目专题ID获取课程信息
+func (m *MessageDAO) GetCoursesByCmsCase(cmscaseid string) ([]model.TaCourse, error) {
+	var course []model.TaCourse
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).In("course_id", builder.Select("course_id").From("ta_cms_case_course").Where(builder.Eq{"cms_case_id": cmscaseid})).Find(&course)
+	return course, err
+}
+
+// GetCmsCaseImgs 根据项目专题ID获取课程图片
+func (m *MessageDAO) GetCmsCaseImgs(cmscaseid string) ([]model.TaCmsCaseImage, error) {
+	var imgs []model.TaCmsCaseImage
+	err := m.db.Where("cms_case_id=?", cmscaseid).And("status=?", models.STATUS_NORMAL).Find(&imgs)
+	return imgs, err
+}
+
+// GetCourseByCaseID 根据案场ID获取所有的课程信息
+func (m *MessageDAO) GetCourseByCaseID(caseid string) ([]model.TaCourse, error) {
+	var course []model.TaCourse
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("case_id=?", caseid).Find(&course)
+	return course, err
+}
+
+// AddCmsCase 新增项目专题
+func (m *MessageDAO) AddCmsCase(cmscase model.TaCmsCase) (*model.TaCmsCase, error) {
+	cmscase.CreateDate = time.Now()
+	cmscase.CmsCaseId = utils.GetGUID()
+	_, err := m.db.Insert(cmscase)
+	return &cmscase, err
+}
+
+// UpdateCmsCase 修改项目专题
+func (m *MessageDAO) UpdateCmsCase(cmscase model.TaCmsCase) error {
+	var col = []string{
+		"name",
+		"title",
+		"detail_content",
+		"is_all_course",
+		"status",
+		"sort",
+	}
+	_, err := m.db.Cols(col...).Where("cms_case_id=?", cmscase.CmsCaseId).Update(cmscase)
+	return err
+}
+
+// DelCmsCase 删除项目专题
+func (m *MessageDAO) DelCmsCase(cmscaseid string) error {
+	var cmscase = model.TaCmsCase{}
+	cmscase.Status = models.STATUS_DEL
+	cmscase.CmsCaseId = cmscaseid
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("cms_case_id=?", cmscase.CmsCaseId).Update(cmscase)
+	return err
+}
+
+// DelCmsCaseCourse 删除项目专题对应的课程
+func (m *MessageDAO) DelCmsCaseCourse(cmscaseid string) error {
+	sql := "delete from ta_cms_case_course where cms_case_id='" + cmscaseid + "'"
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// SaveCmsCaseCourse 保存项目对应的课程
+func (m *MessageDAO) SaveCmsCaseCourse(cmscaseid, courseids string) error {
+	sql := `insert into ta_cms_case_course(cms_case_id,course_id) select '` + cmscaseid + `', course_id from ta_course where course_id in ('` + strings.Replace(courseids, ",", "','", -1) + `') and status = ` + strconv.Itoa(models.STATUS_NORMAL)
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// DelCmsCaseImg 删除项目专题对应的图片
+func (m *MessageDAO) DelCmsCaseImg(cmscaseid string) error {
+	sql := "delete from ta_cms_case_image where cms_case_id='" + cmscaseid + "'"
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// SaveCmsCaseImg 保存项目专题对应的图片
+func (m *MessageDAO) SaveCmsCaseImg(img model.TaCmsCaseImage) error {
+	img.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(&img)
+	return err
+}

models/message/image.go

@@ -0,0 +1,81 @@
+package message
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"time"
+)
+
+// GetImgList 获取轮播图列表
+func (m *MessageDAO) GetImgList(orgid string, page int, pageSize int) ([]model.TaCmsImages, error) {
+	var imgs []model.TaCmsImages
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid).Limit(pageSize, page*pageSize).Desc("create_date").Find(&imgs)
+	return imgs, err
+}
+
+// GetImgListCount 获取轮播图count
+func (m *MessageDAO) GetImgListCount(orgid string) (int, error) {
+	var imgs []model.TaCmsImages
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid).Find(&imgs)
+	if err != nil {
+		return 0, err
+	}
+	return len(imgs), nil
+}
+
+// GetImgByLocation 根据位置获取轮播图信息
+func (m *MessageDAO) GetImgByLocation(orgid, locationid string) ([]model.TaCmsImages, error) {
+	var imgs []model.TaCmsImages
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid).And("location_id=?", locationid).Asc("sort").Find(&imgs)
+	return imgs, err
+}
+
+// GetImgByID 根据ID获取轮播图信息
+func (m *MessageDAO) GetImgByID(imgid string) (*model.TaCmsImages, error) {
+	var imgs []model.TaCmsImages
+
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("image_id=?", imgid).Find(&imgs)
+	if err != nil {
+		return nil, err
+	}
+	if len(imgs) > 0 {
+		return &imgs[0], nil
+	}
+	return nil, nil
+}
+
+// AddCmsImg 保存轮播图
+func (m *MessageDAO) AddCmsImg(info model.TaCmsImages) (*model.TaCmsImages, error) {
+	info.ImageId = utils.GetGUID()
+	info.Status = models.STATUS_NORMAL
+	info.CreateDate = time.Now()
+	_, err := m.db.Insert(&info)
+	return &info, err
+}
+
+// UpdateCmsImg 修改
+func (m *MessageDAO) UpdateCmsImg(img model.TaCmsImages) error {
+	var cols = []string{
+		"image_url",
+		"forward_type",
+		"foward_url",
+		"foward_resource_id",
+		"sort",
+	}
+	_, err := m.db.Cols(cols...).Where("image_id=?", img.ImageId).Update(img)
+	return err
+}
+
+// DelCmsImg 删除
+func (m *MessageDAO) DelCmsImg(imgid string) error {
+	var info = model.TaCmsImages{
+		ImageId: imgid,
+		Status:  models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("image_id=?", info.ImageId).Update(info)
+	return err
+}

models/message/message.go

@@ -1,7 +1,10 @@
 package message
 
 import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
+	"time"
 
 	"github.com/go-xorm/xorm"
 )
@@ -19,3 +22,81 @@ func NewMessageDAO(ctx *utils.Context) *MessageDAO {
 		db:  ctx.DB,
 	}
 }
+
+// GetCmsInfoList 获取消息列表
+func (m *MessageDAO) GetCmsInfoList(title, orgid string, page int, pageSize int) ([]model.TaCmsInfo, error) {
+	var cmsinfos []model.TaCmsInfo
+
+	dao := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid)
+	if title != "" {
+		dao.And("info_name like '%" + title + "%'")
+	}
+
+	err := dao.Limit(pageSize, page*pageSize).Desc("create_date").Find(&cmsinfos)
+	return cmsinfos, err
+}
+
+// GetCmsInfoListCount 消息列表
+func (m *MessageDAO) GetCmsInfoListCount(title, orgid string) (int, error) {
+	var cmsinfos []model.TaCmsInfo
+
+	dao := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid)
+	if title != "" {
+		dao.And("info_name like '%" + title + "%'")
+	}
+
+	err := dao.Find(&cmsinfos)
+	if err != nil {
+		return 0, err
+	}
+	return len(cmsinfos), nil
+}
+
+// GetCmsInfoByLocation 根据位置获取消息信息
+func (m *MessageDAO) GetCmsInfoByLocation(locationid, orgid string) ([]model.TaCmsInfo, error) {
+	var cmsinfos []model.TaCmsInfo
+
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid).And("location_id=?", locationid).Find(&cmsinfos)
+	return cmsinfos, err
+}
+
+// GetCmsInfoByID 获取单条消息记录
+func (m *MessageDAO) GetCmsInfoByID(id string) (*model.TaCmsInfo, error) {
+	var cmsinfos []model.TaCmsInfo
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("info_id=?", id).Find(&cmsinfos)
+	if err != nil {
+		return nil, err
+	}
+	return &cmsinfos[0], nil
+}
+
+// AddCmsInfo 新增消息记录
+func (m *MessageDAO) AddCmsInfo(cmsinfo model.TaCmsInfo) (*model.TaCmsInfo, error) {
+	cmsinfo.InfoId = utils.GetGUID()
+	cmsinfo.Status = models.STATUS_NORMAL
+	cmsinfo.CreateDate = time.Now()
+	_, err := m.db.Insert(&cmsinfo)
+	return &cmsinfo, err
+}
+
+// UpdateCmsInfo 修改
+func (m *MessageDAO) UpdateCmsInfo(cmsinfo model.TaCmsInfo) error {
+	var cols = []string{
+		"info_name",
+	}
+	_, err := m.db.Cols(cols...).Where("info_id=?", cmsinfo.InfoId).Update(cmsinfo)
+	return err
+}
+
+// DelCmsInfo 删除
+func (m *MessageDAO) DelCmsInfo(infoid string) error {
+	var info = model.TaCmsInfo{
+		InfoId: infoid,
+		Status: models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("info_id=?", info.InfoId).Update(info)
+	return err
+}

models/message/news.go

@@ -0,0 +1,134 @@
+package message
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/go-xorm/builder"
+)
+
+// CmsNewsInfo 咨询信息
+type CmsNewsInfo struct {
+	model.TaCmsNews `xorm:"extends"`
+	LocationNames   string
+	LocationIds     string
+}
+
+// GetNewsList 获取咨询列表
+func (m *MessageDAO) GetNewsList(locationid, orgid string, page int, pageSize int) ([]CmsNewsInfo, error) {
+	var news []CmsNewsInfo
+	sql := `select * from ta_cms_news new left join (
+		select b.news_id,GROUP_CONCAT(a.location_name) location_names,GROUP_CONCAT(a.location_id) location_ids 
+		from td_cms_image_location a inner join ta_cms_location b on a.location_id=b.location_id and a.status=` + strconv.Itoa(models.STATUS_NORMAL) +
+		` and b.org_id='` + orgid + `' group by b.news_id
+		) c on new.news_id = c.news_id and new.status>` + strconv.Itoa(models.STATUS_DEL) + ` and new.org_id='` + orgid + `'`
+
+	if locationid != "" {
+		sql += ` and new.news_id in (select news_id from ta_cms_location where location_id='` + locationid + `')`
+	}
+
+	sql = sql + " order by new.create_date desc limit " + strconv.Itoa(page*pageSize) + ", " + strconv.Itoa((page+1)*pageSize)
+
+	err := m.db.Sql(sql).Find(&news)
+	return news, err
+}
+
+// GetNewsListCount 获取咨询列表count
+func (m *MessageDAO) GetNewsListCount(locationid, orgid string) (int, error) {
+	var news []model.TaCmsNews
+	dao := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("org_id=?", orgid)
+	if locationid != "" {
+		dao.In("news_id", builder.Select("news_id").From("ta_cms_location").Where(builder.Eq{"location_id": locationid}))
+	}
+	err := dao.Find(&news)
+	if err != nil {
+		return 0, nil
+	}
+	return len(news), nil
+}
+
+// GetNewsByLocation 根据位置获取咨询信息
+func (m *MessageDAO) GetNewsByLocation(locationid, orgid string) ([]model.TaCmsNews, error) {
+	var news []model.TaCmsNews
+	err := m.db.Where("status=?", models.STATUS_NORMAL).And("org_id=?", orgid).In("news_id", builder.Select("news_id").From("ta_cms_location").Where(builder.Eq{"location_id": locationid})).Find(&news)
+	return news, err
+}
+
+// CmsNews 咨询详情
+type CmsNews struct {
+	model.TaCmsNews `xorm:"extends"`
+	NewsLocations   []model.TaCmsLocation
+}
+
+// GetNewsByID 获取咨询详情
+func (m *MessageDAO) GetNewsByID(newid string) (*CmsNews, error) {
+	var news []CmsNews
+	err := m.db.Where("news_id=?", newid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&news)
+	if err != nil {
+		return nil, err
+	}
+	if len(news) > 0 {
+		return &news[0], err
+	}
+	return nil, nil
+}
+
+// GetNewsLocationByID 根据咨询id获取咨询位置
+func (m *MessageDAO) GetNewsLocationByID(newsid string) ([]model.TaCmsLocation, error) {
+	var newslocation []model.TaCmsLocation
+	err := m.db.Where("news_id=?", newsid).Find(&newslocation)
+	return newslocation, err
+}
+
+// AddNews 新增咨询详细
+func (m *MessageDAO) AddNews(news model.TaCmsNews) (*model.TaCmsNews, error) {
+	news.NewsId = utils.GetGUID()
+	news.CreateDate = time.Now()
+	_, err := m.db.Insert(&news)
+	return &news, err
+}
+
+// DelNewsLocation 删除咨询与位置映射
+func (m *MessageDAO) DelNewsLocation(newsid string) error {
+	sql := "delete from ta_cms_location where news_id='" + newsid + "'"
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// SaveNewsLocation 保存咨询与位置映射
+func (m *MessageDAO) SaveNewsLocation(newsid, locationsid string) error {
+	sql := `insert into ta_cms_location(location_id,news_id) select '` + newsid + `', location_id from td_cms_image_location where location_id in ('` + strings.Replace(locationsid, ",", "','", -1) + `') and status = ` + strconv.Itoa(models.STATUS_NORMAL)
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// UpdateNews 编辑咨询详情
+func (m *MessageDAO) UpdateNews(news model.TaCmsNews) error {
+	var col = []string{
+		"image_url",
+		"forward_type",
+		"forward_url",
+		"forward_course_id",
+		"status",
+		"title",
+		"public_date",
+	}
+	_, err := m.db.Cols(col...).Where("news_id=?", news.NewsId).Update(news)
+	return err
+}
+
+// DelNews 删除咨询
+func (m *MessageDAO) DelNews(newsid string) error {
+	var news = model.TaCmsNews{}
+	news.Status = models.STATUS_DEL
+	news.NewsId = newsid
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("user_id=?", news.NewsId).Update(news)
+	return err
+}

models/model/ta_cms_case.go

@@ -7,6 +7,7 @@ import (
 type TaCmsCase struct {
 	CmsCaseId     string    `xorm:"not null pk VARCHAR(64)"`
 	CaseId        string    `xorm:"VARCHAR(64)"`
+	Name          string    `xorm:"VARCHAR(128)"`
 	Title         string    `xorm:"VARCHAR(128)"`
 	DetailContent string    `xorm:"TEXT"`
 	IsAllCourse   int       `xorm:"comment('是否显示全部课程 0否1是') SMALLINT(6)"`

models/model/ta_cms_case_course.go

@@ -1,7 +1,6 @@
 package model
 
 type TaCmsCaseCourse struct {
-	CaseCourseId string `xorm:"not null pk VARCHAR(64)"`
-	CmsCaseId    string `xorm:"VARCHAR(64)"`
-	CourseId     string `xorm:"VARCHAR(64)"`
+	CmsCaseId string `xorm:"not null pk VARCHAR(64)"`
+	CourseId  string `xorm:"not null pk VARCHAR(64)"`
 }

models/model/ta_cms_images.go

@@ -16,5 +16,5 @@ type TaCmsImages struct {
 	CaseId           string    `xorm:"VARCHAR(64)"`
 	OrgId            string    `xorm:"VARCHAR(64)"`
 	CreateUser       string    `xorm:"VARCHAR(64)"`
-	CreateTime       time.Time `xorm:"DATETIME"`
+	CreateDate       time.Time `xorm:"DATETIME"`
 }

models/model/ta_cms_location.go

@@ -1,8 +1,6 @@
 package model
 
 type TaCmsLocation struct {
-	Cmsloactionid string `xorm:"not null pk VARCHAR(64)"`
-	LocationId    string `xorm:"VARCHAR(64)"`
-	NewsId        string `xorm:"VARCHAR(64)"`
-	Status        int    `xorm:"SMALLINT(6)"`
+	LocationId string `xorm:"VARCHAR(64)"`
+	NewsId     string `xorm:"VARCHAR(64)"`
 }

models/model/ta_customer.go

@@ -9,7 +9,7 @@ type TaCustomer struct {
 	OrgId         string    `xorm:"VARCHAR(64)"`
 	CustomerName  string    `xorm:"VARCHAR(50)"`
 	Name          string    `xorm:"VARCHAR(50)"`
-	Tel           string    `xorm:"VARCHAR(100)"`
+	Phone         string    `xorm:"VARCHAR(100)"`
 	Sex           int       `xorm:"SMALLINT(6)"`
 	Headimgurl    string    `xorm:"TEXT"`
 	RecommendId   string    `xorm:"VARCHAR(64)"`

routers/common.go

@@ -3,6 +3,7 @@ package routers
 import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/goods"
+	"spaceofcheng/services/controllers/message"
 	"spaceofcheng/services/controllers/user"
 
 	"github.com/astaxie/beego"
@@ -30,6 +31,36 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/pwd/reset", &user.UserController{}, "put:ResetPassword"),
 		beego.NSRouter("/pwd/update", &user.UserController{}, "put:UpdatePassword"),
 
+		beego.NSRouter("/location", &message.MessageController{}, "get:GetLocations"),
+		beego.NSRouter("/location/:locationid", &message.MessageController{}, "get:GetLocationById"),
+		beego.NSRouter("/location", &message.MessageController{}, "post:SaveLocation"),
+		beego.NSRouter("/location", &message.MessageController{}, "put:SaveLocation"),
+		beego.NSRouter("/location/:locationid", &message.MessageController{}, "delete:DelLocation"),
+
+		beego.NSRouter("/cmsinfo", &message.MessageController{}, "get:GetCmsInfoList"),
+		beego.NSRouter("/cmsinfo/:infoid", &message.MessageController{}, "get:GetCmsInfoByID"),
+		beego.NSRouter("/cmsinfo", &message.MessageController{}, "post:SaveCmsInfo"),
+		beego.NSRouter("/cmsinfo", &message.MessageController{}, "put:SaveCmsInfo"),
+		beego.NSRouter("/cmsinfo/:infoid", &message.MessageController{}, "delete:DelCmsInfo"),
+
+		beego.NSRouter("/cmsimg", &message.MessageController{}, "get:GetImgList"),
+		beego.NSRouter("/cmsimg/:imgid", &message.MessageController{}, "get:GetImgByID"),
+		beego.NSRouter("/cmsimg", &message.MessageController{}, "post:SaveImage"),
+		beego.NSRouter("/cmsimg", &message.MessageController{}, "put:SaveImage"),
+		beego.NSRouter("/cmsimg/:imgid", &message.MessageController{}, "delete:DelImg"),
+
+		beego.NSRouter("/news", &message.MessageController{}, "get:GetNews"),
+		beego.NSRouter("/news/:newsid", &message.MessageController{}, "get:GetNewsByID"),
+		beego.NSRouter("/news", &message.MessageController{}, "post:SaveNews"),
+		beego.NSRouter("/news", &message.MessageController{}, "put:SaveNews"),
+		beego.NSRouter("/news/:newsid", &message.MessageController{}, "delete:DelNews"),
+
+		beego.NSRouter("/cmscase", &message.MessageController{}, "get:GetCmsCase"),
+		beego.NSRouter("/cmscase/:cmscaseid", &message.MessageController{}, "get:GetCmsCaseByID"),
+		beego.NSRouter("/cmscase", &message.MessageController{}, "post:SaveCmsCase"),
+		beego.NSRouter("/cmscase", &message.MessageController{}, "put:SaveCmsCase"),
+		beego.NSRouter("/cmscase/:cmscaseid", &message.MessageController{}, "delete:DelCmsCase"),
+
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
 	)
 }

routers/guest.go

@@ -1 +1,18 @@
 package routers
+
+import (
+	"spaceofcheng/services/controllers/message"
+
+	"github.com/astaxie/beego"
+)
+
+func getGuestRoutes() beego.LinkNamespace {
+	prefix := beego.AppConfig.String("api::guest")
+
+	return beego.NSNamespace(prefix,
+		beego.NSRouter("/cmsinfo", &message.MessageController{}, "get:GetCmsInfoByLocation"),
+		beego.NSRouter("/cmsimg", &message.MessageController{}, "get:GetImgByLocation"),
+		beego.NSRouter("/cmsnews", &message.MessageController{}, "get:GetNewsByLocation"),
+		beego.NSRouter("/cmscase", &message.MessageController{}, "get:GetCmsCaseList"),
+	)
+}

routers/router.go

@@ -22,6 +22,9 @@ func init() {
 
 		// 通用需要鉴权路由
 		getCommonRoutes(),
+
+		// 不需要鉴权的路由
+		getGuestRoutes(),
 	)
 
 	beego.AddNamespace(ns)

service/cases/cases.go

@@ -0,0 +1,20 @@
+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

@@ -0,0 +1,44 @@
+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
+}

service/message/cmscase.go

@@ -0,0 +1,127 @@
+package message
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/message"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+	"strings"
+)
+
+// GetCmsCasesList 获取项目列表
+func (s *MessageServ) GetCmsCasesList(name, orgid string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	infos, err := s.dao.GetCmsCaseList(name, orgid, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetCmsCaseListCount(name, orgid)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     infos,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetCmsCaseByOrg 获取项目列表
+func (s *MessageServ) GetCmsCaseByOrg(orgid string) ([]model.TaCmsCase, error) {
+	list, err := s.dao.GetCmsCaseByOrg(orgid)
+	return list, err
+}
+
+// GetCmsCasesByID 获取項目信息
+func (s *MessageServ) GetCmsCasesByID(cmscaseid string) (*message.CmsCase, error) {
+	var info = &message.CmsCase{}
+	var err error
+	info, err = s.dao.GetCmsCaseByID(cmscaseid)
+	if err != nil {
+		return nil, err
+	}
+	var course []model.TaCourse
+	if info.IsAllCourse == 1 {
+		course, err = s.dao.GetCourseByCaseID(info.CaseId)
+	} else {
+		course, err = s.dao.GetCoursesByCmsCase(info.CmsCaseId)
+	}
+	if err != nil {
+		return nil, err
+	}
+	info.Courses = course
+
+	imgs, err := s.dao.GetCmsCaseImgs(info.CmsCaseId)
+	if err != nil {
+		return nil, err
+	}
+	info.CmsCaseImgs = imgs
+	return info, nil
+}
+
+// SaveCmsCase 保存项目信息
+func (s *MessageServ) SaveCmsCase(cmscase model.TaCmsCase, courseids, imgs, detailimgs string) (*model.TaCmsCase, error) {
+	var newInfo *model.TaCmsCase
+	var err error
+	if cmscase.CmsCaseId == "" {
+		newInfo, err = s.dao.AddCmsCase(cmscase)
+	} else {
+		err = s.dao.UpdateCmsCase(cmscase)
+		newInfo = &cmscase
+	}
+	if err != nil {
+		return nil, err
+	}
+	err = s.dao.DelCmsCaseCourse(newInfo.CmsCaseId)
+	if err != nil {
+		return nil, err
+	}
+	if newInfo.IsAllCourse == 0 {
+		err = s.dao.SaveCmsCaseCourse(newInfo.CmsCaseId, courseids)
+		if err != nil {
+			return nil, err
+		}
+	}
+	err = s.dao.DelCmsCaseImg(newInfo.CmsCaseId)
+	if err != nil {
+		return nil, err
+	}
+
+	arrimg := strings.Split(imgs, ",")
+	for index, img := range arrimg {
+		CmsImg := model.TaCmsCaseImage{
+			ImageType:    models.IMAGETYPE_COVER,
+			Sort:         (index + 1),
+			CaseImageUrl: img,
+			CmsCaseId:    newInfo.CmsCaseId,
+		}
+		err = s.dao.SaveCmsCaseImg(CmsImg)
+		if err != nil {
+			return nil, err
+		}
+	}
+	arrdetailimg := strings.Split(detailimgs, ",")
+	for index, img := range arrdetailimg {
+		CmsImg := model.TaCmsCaseImage{
+			ImageType:    models.IMAGETYPE_DETAIL,
+			Sort:         (index + 1),
+			CaseImageUrl: img,
+			CmsCaseId:    newInfo.CmsCaseId,
+		}
+		err = s.dao.SaveCmsCaseImg(CmsImg)
+		if err != nil {
+			return nil, err
+		}
+	}
+	return newInfo, err
+}
+
+// DelCmsCase 刪除项目信息
+func (s *MessageServ) DelCmsCase(cmscaseid string) error {
+	err := s.dao.DelCmsCase(cmscaseid)
+	return err
+}

service/message/image.go

@@ -0,0 +1,56 @@
+package message
+
+import (
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+)
+
+// GetImgList 获取图片列表
+func (s *MessageServ) GetImgList(orgid string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	infos, err := s.dao.GetImgList(orgid, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetImgListCount(orgid)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     infos,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetImgByLocation 根据位置获取图片
+func (s *MessageServ) GetImgByLocation(locationid, orgid string) ([]model.TaCmsImages, error) {
+	imgs, err := s.dao.GetImgByLocation(locationid, orgid)
+	return imgs, err
+}
+
+// GetImgByID 获取单条图片信息
+func (s *MessageServ) GetImgByID(imgid string) (*model.TaCmsImages, error) {
+	img, err := s.dao.GetImgByID(imgid)
+	return img, err
+}
+
+// SaveImg 保存轮播图信息
+func (s *MessageServ) SaveImg(imginfo model.TaCmsImages) (*model.TaCmsImages, error) {
+	if imginfo.ImageId == "" {
+		newinfo, err := s.dao.AddCmsImg(imginfo)
+		return newinfo, err
+	}
+	err := s.dao.UpdateCmsImg(imginfo)
+	return &imginfo, err
+}
+
+// DelImg 删除轮播图
+func (s *MessageServ) DelImg(imgid string) error {
+	err := s.dao.DelCmsImg(imgid)
+	return err
+}

service/message/message.go

@@ -2,6 +2,8 @@ package message
 
 import (
 	"spaceofcheng/services/models/message"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 )
 
@@ -20,6 +22,51 @@ func NewMessageServ(ctx *utils.Context) *MessageServ {
 }
 
 // GetCmsInfoList 获取消息管理列表
-func (s *MessageServ) GetCmsInfoList() {
+func (s *MessageServ) GetCmsInfoList(title, orgid string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	infos, err := s.dao.GetCmsInfoList(title, orgid, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetCmsInfoListCount(title, orgid)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     infos,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetCmsInfoByLocation 根据位置ID获取消息列表
+func (s *MessageServ) GetCmsInfoByLocation(locationid, orgid string) ([]model.TaCmsInfo, error) {
+	infos, err := s.dao.GetCmsInfoByLocation(locationid, orgid)
+	return infos, err
+}
+
+// GetCmsInfoByID 获取单条消息信息
+func (s *MessageServ) GetCmsInfoByID(id string) (*model.TaCmsInfo, error) {
+	info, err := s.dao.GetCmsInfoByID(id)
+	return info, err
+}
+
+// SaveCmsInfo 保存消息信息
+func (s *MessageServ) SaveCmsInfo(cmsinfo model.TaCmsInfo) (*model.TaCmsInfo, error) {
+	if cmsinfo.InfoId == "" {
+		newcmsinfo, err := s.dao.AddCmsInfo(cmsinfo)
+		return newcmsinfo, err
+	}
+	err := s.dao.UpdateCmsInfo(cmsinfo)
+	return &cmsinfo, err
+}
 
+// DelCmsInfo 删除消息信息
+func (s *MessageServ) DelCmsInfo(infoid string) error {
+	err := s.dao.DelCmsInfo(infoid)
+	return err
 }

service/message/news.go

@@ -0,0 +1,79 @@
+package message
+
+import (
+	"spaceofcheng/services/models/message"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+)
+
+// GetNewsList 获取咨询列表
+func (s *MessageServ) GetNewsList(locationid, orgid string, page int, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	infos, err := s.dao.GetNewsList(locationid, orgid, page, pageSize)
+	if err != nil {
+		return nil, err
+	}
+	total, err := s.dao.GetNewsListCount(locationid, orgid)
+	if err != nil {
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     infos,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetNewsByLocation 根据位置id获取咨询信息
+func (s *MessageServ) GetNewsByLocation(locationid, orgid string) ([]model.TaCmsNews, error) {
+	news, err := s.dao.GetNewsByLocation(locationid, orgid)
+	return news, err
+}
+
+// GetNewsByID 获取咨询详情
+func (s *MessageServ) GetNewsByID(newsid string) (*message.CmsNews, error) {
+	info, err := s.dao.GetNewsByID(newsid)
+	if err != nil {
+		return nil, err
+	}
+	newslocation, err := s.dao.GetNewsLocationByID(newsid)
+	if err != nil {
+		return nil, err
+	}
+	info.NewsLocations = newslocation
+	return info, nil
+}
+
+// SaveNews 保存咨询信息
+func (s *MessageServ) SaveNews(news model.TaCmsNews, locationids string) (*model.TaCmsNews, error) {
+	var newInfo *model.TaCmsNews
+	var err error
+	if news.NewsId == "" {
+		newInfo, err = s.dao.AddNews(news)
+	} else {
+		err = s.dao.UpdateNews(news)
+		newInfo = &news
+	}
+	if err != nil {
+		return nil, err
+	}
+	err = s.dao.DelNewsLocation(newInfo.NewsId)
+	if err != nil {
+		return nil, err
+	}
+	err = s.dao.SaveNewsLocation(newInfo.NewsId, locationids)
+	if err != nil {
+		return nil, err
+	}
+	return newInfo, err
+}
+
+// DelNews 刪除咨询信息
+func (s *MessageServ) DelNews(newsid string) error {
+	err := s.dao.DelNews(newsid)
+	return err
+}