0825PM

controllers/course/course.go

 	}
 	c.ResponseJSON("删除成功！")
 }
+
+// GetSelectCourseList 获取精选课程
+// func (c *CourseController) GetSelectCourseList() {
+// 	orgid := c.GetString("orgid")
+// 	courses, err := c.dao.GetSelectCourseList(orgid)
+// 	if err != nil {
+// 		c.ResponseError(err)
+// 	}
+// 	c.ResponseJSON(courses)
+// }
+
+// GetCourseByLocation 根据位置获取课程信息
+func (c *CourseController) GetCourseByLocation() {
+	locationid := c.GetString("locationid")
+	orgid := c.GetString("orgid")
+	if locationid == "selected" {
+		courses, err := c.dao.GetSelectCourseList(orgid)
+		if err != nil {
+			c.ResponseError(err)
+		}
+		c.ResponseJSON(courses)
+	}
+	courses, err := c.dao.GetCourseByLocation(orgid, locationid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(courses)
+}

controllers/message/image.go

 
 // GetImgByLocation 根据位置获取轮播图信息
 func (c *MessageController) GetImgByLocation() {
-	loctionid := c.GetString("loctionid")
+	loctionid := c.GetString("locationid")
 	orgid := c.GetString("orgid")
 	imgs, err := c.dao.GetImgByLocation(loctionid, orgid)
 	if err != nil {

controllers/message/location.go

 // GetLocations 获取位置列表
 func (c *MessageController) GetLocations() {
 	issys := c.GetString("issys")
-	org := c.Context.Get("org").(model.SysOrg)
-	location, err := c.dao.GetLocationList(issys, org.OrgId)
+	orgid := c.GetString("orgid")
+	if orgid == "" {
+		org := c.Context.Get("org").(model.SysOrg)
+		orgid = org.OrgId
+	}
+	location, err := c.dao.GetLocationList(issys, orgid)
 	if err != nil {
 		c.ResponseError(err)
 	}

models/course/course.go

 
 const (
 	STATUS_UNPUBLISH = 0
+	IS_SELECT        = 1
 )
 
 // CourseInfo 课程
 	CourseTags     []model.TaCourseTag
 	CourseImgs     []model.TaCourseImg
 	CourseDetail   []model.TaCourseDetail
+	CaseInfo       *model.SysCase
 }
 
 // GetCourseInfo 获取课程详情
 	_, err := m.db.Exec(sql)
 	return err
 }
+
+// GetCourseDetailCount 获取已排课数量
+func (m *CourseDAO) GetCourseDetailCount(courseid string) (int, error) {
+	var details []model.TaCourseDetail
+	err := m.db.Where("course_id=?", courseid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&details)
+	if err != nil {
+		return 0, err
+	}
+	return len(details), nil
+}
+
+// UpdateCourseScheduleNum 更新课程已排课数量
+func (m *CourseDAO) UpdateCourseScheduleNum(courseid string, num int) error {
+	var info = model.TaCourse{
+		CourseId:    courseid,
+		ScheduleNum: num,
+	}
+	var cols = []string{
+		"schedule_num",
+	}
+	_, err := m.db.Cols(cols...).Where("course_id=?", courseid).Update(info)
+	return err
+}
+
+// DeleteScheduleByCourse 删除排课记录
+func (m *CourseDAO) DeleteScheduleByCourse(courseid string) error {
+	sql := `update ta_course_detail set status=` + strconv.Itoa(models.STATUS_DEL) + ` where course_id='` + courseid + `'`
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// GetSelectCourseList 获取精选课程
+func (m *CourseDAO) GetSelectCourseList(orgid string) ([]CourseDetail, error) {
+	var courses []CourseDetail
+	sql := `select * from ta_course where is_select=` + strconv.Itoa(IS_SELECT) + ` and status=` + strconv.Itoa(models.STATUS_NORMAL) + ` and org_id='` + orgid + `'`
+	err := m.db.Sql(sql).Find(&courses)
+	return courses, err
+}
+
+// GetCourseByLocation 根据位置获取课程信息
+func (m *CourseDAO) GetCourseByLocation(orgid, locationid string) ([]CourseDetail, error) {
+	var courses []CourseDetail
+	sql := `select * from ta_course where status=` + strconv.Itoa(models.STATUS_NORMAL) + ` and org_id='` + orgid + `' and location_id ='` + locationid + `'`
+	err := m.db.Sql(sql).Find(&courses)
+	return courses, err
+}

models/course/order.go

+package course
+
+import (
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"strings"
+	"time"
+)
+
+// SaveCourseOrder 保存订单
+func (m *CourseDAO) SaveCourseOrder(order model.TaCourseOrders) (*model.TaCourseOrders, error) {
+	order.OrdersId = utils.GetGUID()
+	// 当前订单号的随机方式 = 时间 + 个人ID
+	order.OrdersNo = "Customer-" + time.Now().Local().Format("20060102150405") + "-" + strings.Join(utils.GUIID2IntString(order.CustomerId), "")
+	order.CreateDate = time.Now()
+	_, err := m.db.Insert(&order)
+	return &order, err
+}
+
+// GetOrderByID 根据id获取订单明细
+func (m *CourseDAO) GetOrderByID(ordersid string) (*model.TaCourseOrders, error) {
+	var orders []model.TaCourseOrders
+	err := m.db.Where("orders_id=?", ordersid).Find(&orders)
+	if err != nil {
+		return nil, err
+	}
+	if len(orders) > 0 {
+		return &orders[0], nil
+	}
+	return nil, nil
+}
+
+// SaveCourseOrderDetail 保存订单明细
+func (m *CourseDAO) SaveCourseOrderDetail() {
+
+}

models/message/cmscase.go

 }
 
 // GetCmsCaseByOrg 获取列表
-func (m *MessageDAO) GetCmsCaseByOrg(orgid string) ([]model.TaCmsCase, error) {
-	var cases []model.TaCmsCase
-	err := m.db.Where("org_id=?", orgid).Find(&cases)
-	beego.Error(cases)
+func (m *MessageDAO) GetCmsCaseByOrg(orgid string) ([]CmsCase, error) {
+	var cases []CmsCase
+	sql := `select * from ta_cms_case where org_id='` + orgid + `' and status=` + strconv.Itoa(models.STATUS_NORMAL)
+	err := m.db.Sql(sql).Find(&cases)
+	// err := m.db.Where("org_id=?", orgid).Find(&cases)
 	return cases, err
 }
 

models/message/image.go

 }
 
 // GetImgByLocation 根据位置获取轮播图信息
-func (m *MessageDAO) GetImgByLocation(orgid, locationid string) ([]model.TaCmsImages, error) {
+func (m *MessageDAO) GetImgByLocation(locationid, orgid string) ([]model.TaCmsImages, error) {
 	var imgs []model.TaCmsImages
 	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("org_id=?", orgid).And("location_id=?", locationid).Asc("sort").Find(&imgs)
 	return imgs, err

models/model/ta_course_orders.go

 	CaseId       string    `xorm:"VARCHAR(64)"`
 	CourseId     string    `xorm:"VARCHAR(64)"`
 	CourseName   string    `xorm:"VARCHAR(50)"`
-	LocationId   string    `xorm:"VARCHAR(64)"`
-	LocationName string    `xorm:"VARCHAR(50)"`
 	Price        string    `xorm:"DECIMAL(8,2)"`
 	CourseNum    int       `xorm:"INT(11)"`
 	JoinNum      int       `xorm:"INT(11)"`

models/model/ta_course_orders_detail.go

+package model
+
+import (
+	"time"
+)
+
+type TaCourseOrdersDetail struct {
+	OrdersDetailId string    `xorm:"not null pk VARCHAR(64)"`
+	OrdersId       string    `xorm:"not null VARCHAR(64)"`
+	CourseId       string    `xorm:"VARCHAR(64)"`
+	CourseDetailId string    `xorm:"VARCHAR(64)"`
+	BeginDate      time.Time `xorm:"DATETIME"`
+	EndDate        time.Time `xorm:"DATETIME"`
+}

routers/guest.go

 import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/cases"
+	"spaceofcheng/services/controllers/course"
 	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/message"
 	"spaceofcheng/services/controllers/user"
 		beego.NSRouter("/cms/info", &message.MessageController{}, "get:GetCmsInfoByLocation"),
 		beego.NSRouter("/cms/img", &message.MessageController{}, "get:GetImgByLocation"),
 		beego.NSRouter("/cms/news", &message.MessageController{}, "get:GetNewsByLocation"),
+		beego.NSRouter("/cms/case", &message.MessageController{}, "get:GetCmsCaseList"),
+		beego.NSRouter("/cms/location", &message.MessageController{}, "get:GetLocations"),
+		beego.NSRouter("/cms/course", &course.CourseController{}, "get:GetCourseByLocation"),
 
 		// 案场
 		beego.NSRouter("/case", &cases.CaseController{}, "get:GetOrgCases"),

service/course/course.go

 
 import (
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/cases"
 	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service"
 
 // CourseServ 系统处理
 type CourseServ struct {
-	ctx *utils.Context
-	dao *course.CourseDAO
+	ctx     *utils.Context
+	dao     *course.CourseDAO
+	casedao *cases.CaseDAO
 }
 
 // NewCourseServ 初始化
 func NewCourseServ(ctx *utils.Context) *CourseServ {
 	return &CourseServ{
-		ctx: ctx,
-		dao: course.NewCourseDAO(ctx),
+		ctx:     ctx,
+		dao:     course.NewCourseDAO(ctx),
+		casedao: cases.NewCaseDAO(ctx),
 	}
 }
 
 		return nil, err
 	}
 	info.CourseImgs = imgs
+	caseinfo, err := s.casedao.GetCaseByID(info.CaseId)
+	if err != nil {
+		return nil, err
+	}
+	info.CaseInfo = caseinfo
 	return info, nil
 }
 
 	if courseid == "" {
 		return utils.LogError("没有对应的课程！")
 	}
-	err := s.dao.DelCourse(courseid)
+	courseinfo, err := s.dao.GetCourseByID(courseid)
+	if err != nil {
+		return err
+	}
+	if courseinfo.Status != course.STATUS_UNPUBLISH {
+		return utils.LogError("课程状态异常！不允许删除！")
+	}
+	err = s.dao.DelCourse(courseid)
+	if err != nil {
+		return err
+	}
+	err = s.dao.DeleteScheduleByCourse(courseid)
 	return err
 }
 
 	if detail.BeginDate.After(detail.EndDate) {
 		return nil, utils.LogError("课程截止时间必须大于开始时间！")
 	}
+	courseinfo, err := s.dao.GetCourseByID(detail.CourseId)
+	if err != nil {
+		return nil, err
+	}
+	if courseinfo.Status != course.STATUS_UNPUBLISH {
+		return nil, utils.LogError("课程状态异常！不允许排课！请刷新后重试！")
+	}
 	if detail.DetailId == "" {
-		course, err := s.dao.GetCourseByID(detail.CourseId)
+		detail.OrgId = courseinfo.OrgId
+		detail.CaseId = courseinfo.CaseId
+		newinfo, err = s.dao.AddCourseDetail(detail)
 		if err != nil {
 			return nil, err
 		}
-		detail.OrgId = course.OrgId
-		detail.CaseId = course.CaseId
-		newinfo, err = s.dao.AddCourseDetail(detail)
+		num, err := s.dao.GetCourseDetailCount(courseinfo.CourseId)
+		if err != nil {
+			return nil, err
+		}
+		err = s.dao.UpdateCourseScheduleNum(courseinfo.CourseId, num)
 		if err != nil {
 			return nil, err
 		}
 	if detailid == "" {
 		return utils.LogError("没有对应的排课信息！")
 	}
-	err := s.dao.DelCourseDetail(detailid)
-	return err
+	detail, err := s.dao.GetDetailByID(detailid)
+	if err != nil {
+		return err
+	}
+	courseinfo, err := s.dao.GetCourseByID(detail.CourseId)
+	if err != nil {
+		return err
+	}
+	if courseinfo.Status != course.STATUS_UNPUBLISH {
+		return utils.LogError("课程状态异常！不允许删除！")
+	}
+	err = s.dao.DelCourseDetail(detailid)
+	if err != nil {
+		return err
+	}
+	num, err := s.dao.GetCourseDetailCount(courseinfo.CourseId)
+	if err != nil {
+		return err
+	}
+	err = s.dao.UpdateCourseScheduleNum(courseinfo.CourseId, num)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// GetCourseBySelect 获取精选课程
+func (s *CourseServ) GetSelectCourseList(orgid string) ([]course.CourseDetail, error) {
+	if orgid == "" {
+		return nil, utils.LogError("参数错误！")
+	}
+	list, err := s.dao.GetSelectCourseList(orgid)
+	if err != nil {
+		return nil, err
+	}
+	for i, v := range list {
+		caseinfo, err := s.casedao.GetCaseByID(v.CaseId)
+		if err != nil {
+			return nil, err
+		}
+		list[i].CaseInfo = caseinfo
+	}
+	return list, err
+}
+
+// GetCourseByLocation 根据位置获取课程
+func (s *CourseServ) GetCourseByLocation(orgid, locationid string) ([]course.CourseDetail, error) {
+	if orgid == "" || locationid == "" {
+		return nil, utils.LogError("参数错误！")
+	}
+	list, err := s.dao.GetCourseByLocation(orgid, locationid)
+	if err != nil {
+		return nil, err
+	}
+	for i, v := range list {
+		caseinfo, err := s.casedao.GetCaseByID(v.CaseId)
+		if err != nil {
+			return nil, err
+		}
+		list[i].CaseInfo = caseinfo
+	}
+	return list, err
 }

service/message/cmscase.go

 }
 
 // GetCmsCaseByOrg 获取项目列表
-func (s *MessageServ) GetCmsCaseByOrg(orgid string) ([]model.TaCmsCase, error) {
+func (s *MessageServ) GetCmsCaseByOrg(orgid string) ([]message.CmsCase, error) {
 	list, err := s.dao.GetCmsCaseByOrg(orgid)
+	if err != nil {
+		return nil, err
+	}
+	for i, c := range list {
+		imgs, err := s.dao.GetCmsCaseImgs(c.CmsCaseId)
+		if err != nil {
+			return nil, err
+		}
+		list[i].CmsCaseImgs = imgs
+	}
 	return list, err
 }