0815PM

controllers/message/cmscase.go

@@ -0,0 +1,52 @@
+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)
+}
+
+// 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/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/constant.go

@@ -4,3 +4,8 @@ const (
 	STATUS_NORMAL = 1
 	STATUS_DEL    = -1
 )
+
+const (
+	IMAGETYPE_COVER  = "cover"
+	IMAGETYPE_DETAIL = "detail"
+)

models/message/cmscase.go

@@ -0,0 +1,147 @@
+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
+}
+
+// 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/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_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

@@ -49,6 +49,12 @@ func getCommonRoutes() beego.LinkNamespace {
 		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("/file", &controllers.BaseController{}, "post:FileUpload"),
 	)
 }

routers/guest.go

@@ -12,5 +12,6 @@ func getGuestRoutes() beego.LinkNamespace {
 	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"),
 	)
 }

service/message/cmscase.go

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