0823PM

conf/db.conf

@@ -5,7 +5,7 @@ db_type      = mysql
 con_protocol = tcp
 
 ; 数据库地址，可以使用IP
-db_addr      = localhost
+db_addr      = 192.168.0.122
 
 ; 端口
 db_port      = 3306

controllers/course/course.go

@@ -2,6 +2,7 @@ package course
 
 import (
 	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/course"
 )
 
@@ -17,3 +18,170 @@ type CourseController struct {
 func (c *CourseController) Constructor() {
 	c.dao = course.NewCourseServ(c.Context)
 }
+
+// GetCourseList 获取课程列表
+func (c *CourseController) GetCourseList() {
+	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")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+	courses, err := c.dao.GetCourseList(caseids, name, typeid, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(courses)
+}
+
+// GetCourseByID 获取课程明细
+func (c *CourseController) GetCourseByID() {
+	courseid := c.GetString(":courseid")
+	info, err := c.dao.GetCourseByID(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// SaveCourse 保存课程
+func (c *CourseController) SaveCourse() {
+	course := model.TaCourse{}
+	if err := c.ParseForm(&course); err != nil {
+		c.ResponseError(err)
+	}
+	tagids := c.GetString("tagids")
+	newinfo, err := c.dao.SaveCourse(course, tagids)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newinfo)
+}
+
+// DeleteCourse 删除课程
+func (c *CourseController) DeleteCourse() {
+	courseid := c.GetString(":courseid")
+	err := c.dao.DelCourse(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}
+
+// CoursePublic 课程发布
+func (c *CourseController) CoursePublic() {
+	courseid := c.GetString(":courseid")
+	err := c.dao.CoursePublic(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("操作成功！")
+}
+
+// CourseUnPublic 课程取消发布
+func (c *CourseController) CourseUnPublic() {
+	courseid := c.GetString(":courseid")
+	err := c.dao.CourseUnPublic(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("操作成功！")
+}
+
+// GetCourseImgs 获取课程图片
+func (c *CourseController) GetCourseImgs() {
+	courseid := c.GetString(":courseid")
+	imgs, err := c.dao.GetCourseImgs(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(imgs)
+}
+
+// SaveCourseImg 保存课程图片
+func (c *CourseController) SaveCourseImg() {
+	img := model.TaCourseImg{}
+	if err := c.ParseForm(&img); err != nil {
+		c.ResponseError(err)
+	}
+	newimg, err := c.dao.SaveCourseImg(img)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newimg)
+}
+
+// DelCourseImg 删除课程图片
+func (c *CourseController) DelCourseImg() {
+	courseid := c.GetString(":courseid")
+	err := c.dao.DelCourseImg(courseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("操作成功！")
+}
+
+// GetCourseSchedule 获取课程排期
+func (c *CourseController) GetCourseSchedule() {
+	name := c.GetString("name")
+	caseids := c.GetString("caseid")
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	date := c.GetString("date")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetCourseSchedule(name, caseids, date, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetDetails 获取所有排课
+func (c *CourseController) GetDetails() {
+	caseid := c.GetString("caseid")
+	date := c.GetString("date")
+	list, err := c.dao.GetDetails(caseid, date)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetDetailByID 获取单个排课信息
+func (c *CourseController) GetDetailByID() {
+	detailid := c.GetString(":detailid")
+	detail, err := c.dao.GetDetailByID(detailid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(detail)
+}
+
+// SaveDetail 保存排课信息
+func (c *CourseController) SaveDetail() {
+	detail := model.TaCourseDetail{}
+	if err := c.ParseForm(&detail); err != nil {
+		c.ResponseError(err)
+	}
+	newdetail, err := c.dao.SaveDetail(detail)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newdetail)
+}
+
+// DelCourseDetail 删除课程明细
+func (c *CourseController) DelCourseDetail() {
+	detailid := c.GetString(":detailid")
+	err := c.dao.DelCourseDetail(detailid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("删除成功！")
+}

models/course/course.go

@@ -5,6 +5,8 @@ import (
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
+	"strings"
+	"time"
 
 	"github.com/go-xorm/xorm"
 )
@@ -23,11 +25,304 @@ func NewCourseDAO(ctx *utils.Context) *CourseDAO {
 	}
 }
 
+const (
+	STATUS_UNPUBLISH = 0
+)
+
+// CourseInfo 课程
+type CourseInfo struct {
+	model.TaCourse `xorm:"extends"`
+	CourseType     string
+}
+
 // GetCourseList 获取课程列表
-func (m *CourseDAO) GetCourseList(caseids, name, typeid string, page, pageSize int) ([]model.TaCourse, error) {
+func (m *CourseDAO) GetCourseList(caseids, name, typeid string, page, pageSize int) ([]CourseInfo, error) {
+	var courses []CourseInfo
+	sql := `select a.*,b.location_name from ta_course a left join td_cms_image_location b on a.location_id = b.location_id where a.case_id in ('` +
+		strings.Replace(caseids, ",", "','", -1) + `') and a.status>` + strconv.Itoa(models.STATUS_DEL)
+
+	if name != "" {
+		sql += ` and a.course_name like '%` + name + `%'`
+	}
+
+	if typeid != "" {
+		sql += ` and a.location_id='` + typeid + `'`
+	}
+
+	sql += ` order by create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(page*pageSize)
+	err := m.db.Sql(sql).Find(&courses)
+	return courses, err
+}
+
+// GetCourseCount 获取课程总数
+func (m *CourseDAO) GetCourseCount(caseids, name, typeid string) (int, error) {
+	var course []model.TaCourse
+	dao := m.db.Where("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").And("status>" + strconv.Itoa(models.STATUS_DEL))
+
+	if name != "" {
+		dao.And("course_name like '%" + name + "%'")
+	}
+
+	if typeid != "" {
+		dao.And("location_id=?", typeid)
+	}
+	err := dao.Find(&course)
+	if err != nil {
+		return 0, err
+	}
+	if len(course) > 0 {
+		return len(course), nil
+	}
+	return 0, nil
+}
+
+// GetCourseByID 根据ID获取课程
+func (m *CourseDAO) GetCourseByID(courseid string) (*model.TaCourse, error) {
+	var course []model.TaCourse
+	err := m.db.Where("course_id=?", courseid).Find(&course)
+	if err != nil {
+		return nil, err
+	}
+	if len(course) > 0 {
+		return &course[0], nil
+	}
+	return nil, nil
+}
+
+// AddCourse 新增课程信息
+func (m *CourseDAO) AddCourse(course model.TaCourse) (*model.TaCourse, error) {
+	course.CourseId = utils.GetGUID()
+	course.CreateDate = time.Now()
+	course.Status = STATUS_UNPUBLISH
+	user := m.ctx.Get("user").(model.SysUser)
+	course.CreateUser = user.UserId
+	_, err := m.db.Insert(course)
+	return &course, err
+}
+
+// UpdateCourse 修改课程信息
+func (m *CourseDAO) UpdateCourse(course model.TaCourse) error {
+	var cols = []string{
+		"course_name",
+		"price",
+		"case_id",
+		"location_id",
+		"course_num",
+		"max_num",
+		"min_num",
+		"begin_date",
+		"end_date",
+		"course_img",
+		"course_desc",
+		"remark",
+		"is_select",
+	}
+	_, err := m.db.Cols(cols...).Where("course_id=?", course.CourseId).Update(course)
+	return err
+}
+
+// DelCourse 删除课程信息
+func (m *CourseDAO) DelCourse(courseid string) error {
+	var info = model.TaCourse{
+		CourseId: courseid,
+		Status:   models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("course_id=?", courseid).Update(info)
+	return err
+}
+
+// CoursePublic 课程发布
+func (m *CourseDAO) CoursePublic(courseid string) error {
+	var info = model.TaCourse{
+		CourseId: courseid,
+		Status:   models.STATUS_NORMAL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("course_id=?", courseid).Update(info)
+	return err
+}
+
+// CourseUnPublic 取消课程发布
+func (m *CourseDAO) CourseUnPublic(courseid string) error {
+	var info = model.TaCourse{
+		CourseId: courseid,
+		Status:   STATUS_UNPUBLISH,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("course_id=?", courseid).Update(info)
+	return err
+}
+
+// GetCourseImgs 获取课程图片
+func (m *CourseDAO) GetCourseImgs(courseid string) ([]model.TaCourseImg, error) {
+	var imgs []model.TaCourseImg
+	err := m.db.Where("course_id=?", courseid).Find(&imgs)
+	return imgs, err
+}
+
+// AddCourseImg 新增课程图片
+func (m *CourseDAO) AddCourseImg(courseimg model.TaCourseImg) (*model.TaCourseImg, error) {
+	courseimg.ImgId = utils.GetGUID()
+	_, err := m.db.Insert(courseimg)
+	return &courseimg, err
+}
+
+// UpdateCourseImg 修改课程图片
+func (m *CourseDAO) UpdateCourseImg(courseimg model.TaCourseImg) error {
+	var cols = []string{
+		"sort",
+	}
+	_, err := m.db.Cols(cols...).Where("img_id=?", courseimg.ImgId).Update(courseimg)
+	return err
+}
+
+// DelCourseImg 删除课程图片
+func (m *CourseDAO) DelCourseImg(imgid string) error {
+	sql := `delete from ta_course_img where img_id='` + imgid + `'`
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// CourseDetail 课程详情
+type CourseDetail struct {
+	model.TaCourse `xorm:"extends"`
+	CourseTags     []model.TaCourseTag
+	CourseImgs     []model.TaCourseImg
+	CourseDetail   []model.TaCourseDetail
+}
+
+// GetCourseInfo 获取课程详情
+func (m *CourseDAO) GetCourseInfo(courseid string) (*CourseDetail, error) {
+	var courses []CourseDetail
+	sql := `select * from ta_course where course_id='` + courseid + `'`
+	err := m.db.Sql(sql).Find(&courses)
+	if err != nil {
+		return nil, err
+	}
+	if len(courses) > 0 {
+		return &courses[0], nil
+	}
+	return nil, nil
+}
+
+// GetCourseDetail 获取课程明细
+func (m *CourseDAO) GetCourseDetail(courseid string) ([]model.TaCourseDetail, error) {
+	var details []model.TaCourseDetail
+	err := m.db.Where("course_id=?", courseid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&details)
+	return details, err
+}
+
+// GetDetails 获取所有的排课记录
+func (m *CourseDAO) GetDetails(caseid, date string) ([]model.TaCourseDetail, error) {
+	var details []model.TaCourseDetail
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("DATE_FORMAT(begin_date,'%Y-%m') = ?", date).Find(&details)
+	return details, err
+}
+
+// GetCourseSchedule 获取需要排课的记录
+func (m *CourseDAO) GetCourseSchedule(name, caseids, date string, page, pageSize int) ([]model.TaCourse, error) {
+	var courses []model.TaCourse
+	dao := m.db.Where("status=?", STATUS_UNPUBLISH).And("schedule_num<course_num").And(date + " BETWEEN begin_date and end_date")
+	if name != "" {
+		dao.And("course_name like '%" + name + "%'")
+	}
+	if caseids != "" {
+		dao.And("caseids in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
+	}
+	err := dao.OrderBy("create_date").Limit(pageSize, (page-1)*pageSize).Find(&courses)
+	return courses, err
+}
+
+// GetCourseScheduleCount 获取排课记录数
+func (m *CourseDAO) GetCourseScheduleCount(name, caseids, date string) (int, error) {
 	var courses []model.TaCourse
+	dao := m.db.Where("status=?", STATUS_UNPUBLISH).And("schedule_num<course_num").And(date + " BETWEEN begin_date and end_date")
+	if name != "" {
+		dao.And("course_name like '%" + name + "%'")
+	}
+	if caseids != "" {
+		dao.And("caseids in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
+	}
+	err := dao.Find(&courses)
+	return len(courses), err
+}
 
-	m.db.Where("status>" + strconv.Itoa(models.STATUS_DEL)).And("")
+// GetDetailByID 获取排课明细
+func (m *CourseDAO) GetDetailByID(detailid string) (*model.TaCourseDetail, error) {
+	var details []model.TaCourseDetail
+	err := m.db.Where("detail_id=?", detailid).And("status>" + strconv.Itoa(models.STATUS_DEL)).Find(&details)
+	if err != nil {
+		return nil, err
+	}
+	if len(details) > 0 {
+		return &details[0], nil
+	}
+	return nil, nil
+}
+
+// AddCourseDetail 新增明细
+func (m *CourseDAO) AddCourseDetail(detail model.TaCourseDetail) (*model.TaCourseDetail, error) {
+	detail.CreateDate = time.Now()
+	detail.Status = models.STATUS_NORMAL
+	detail.DetailId = utils.GetGUID()
+	_, err := m.db.Insert(detail)
+	return &detail, err
+}
+
+// UpdateCourseDetail 修改明细
+func (m *CourseDAO) UpdateCourseDetail(detail model.TaCourseDetail) error {
+	var cols = []string{
+		"detail_name",
+		"begin_date",
+		"end_date",
+	}
+	_, err := m.db.Cols(cols...).Where("detail_id=?", detail.DetailId).Update(detail)
+	return err
+}
+
+// DelCourseDetail 刪除明细
+func (m *CourseDAO) DelCourseDetail(detailid string) error {
+	var info = model.TaCourseDetail{
+		DetailId: detailid,
+		Status:   models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("detail_id=?", detailid).Update(info)
+	return err
+}
+
+// DelCourseTag 删除课程对应标签
+func (m *CourseDAO) DelCourseTag(courseid string) error {
+	sql := `delete from ta_course_tag where course_id='` + courseid + `'`
+	_, err := m.db.Exec(sql)
+	return err
+}
+
+// SaveCourseTag 保存课程对应标签
+func (m *CourseDAO) SaveCourseTag(coursetags []model.TaCourseTag) error {
+	_, err := m.db.Insert(coursetags)
+	return err
+}
+
+// GetCourseTag 获取课程对应标签
+func (m *CourseDAO) GetCourseTag(courseid string) ([]model.TaCourseTag, error) {
+	var coursetags []model.TaCourseTag
+	err := m.db.Where("course_id=?", courseid).Find(&coursetags)
+	return coursetags, err
+}
 
-	return courses, nil
+// CourseTagSave 保存课程对应标签
+func (m *CourseDAO) CourseTagSave(courseid, tagids string) error {
+	sql := `insert into ta_course_tag(course_id,tag_id) select '` + courseid + `',tag_id from td_course_tag where tag_id in ('` + strings.Replace(tagids, ",", "','", -1) + `') and status>` + strconv.Itoa(models.STATUS_DEL)
+	_, err := m.db.Exec(sql)
+	return err
 }

models/course/tag.go

@@ -5,7 +5,6 @@ import (
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
-	"strings"
 )
 
 // GetTagsList 获取标签列表
@@ -29,23 +28,9 @@ func (m *CourseDAO) GetTagsCount(orgid string) (int, error) {
 }
 
 // AddCourseTag 新增课程标签
-func (m *CourseDAO) AddCourseTag(tag *model.TdCourseTag) (*model.TdCourseTag, error) {
+func (m *CourseDAO) AddCourseTag(tag model.TdCourseTag) (*model.TdCourseTag, error) {
 	tag.TagId = utils.GetGUID()
 	tag.Status = models.STATUS_NORMAL
 	_, err := m.db.Insert(tag)
-	return tag, err
-}
-
-// DelCourseTag 删除课程对应标签
-func (m *CourseDAO) DelCourseTag(courseid string) error {
-	sql := `delete ta_course_tag where course_id='` + courseid + `'`
-	_, err := m.db.Exec(sql)
-	return err
-}
-
-// CourseTagSave 保存课程对应标签
-func (m *CourseDAO) CourseTagSave(courseid, tagids string) error {
-	sql := `insert into ta_course_tag(course_id,tag_id) select '` + courseid + `',tag_id from td_course_tag where tag_id in ('` + strings.Replace(tagids, ",", "','", -1) + `') and status>` + strconv.Itoa(models.STATUS_DEL)
-	_, err := m.db.Exec(sql)
-	return err
+	return &tag, err
 }

models/model/ta_course.go

@@ -5,23 +5,24 @@ import (
 )
 
 type TaCourse struct {
-	CourseId     string    `xorm:"not null pk VARCHAR(64)"`
-	CourseName   string    `xorm:"VARCHAR(50)"`
-	Price        float32   `xorm:"FLOAT(8,2)"`
-	OrgId        string    `xorm:"VARCHAR(64)"`
-	CaseId       string    `xorm:"VARCHAR(64)"`
-	LocationName string    `xorm:"VARCHAR(50)"`
-	CourseNum    int       `xorm:"INT(11)"`
-	ScheduleNum  int       `xorm:"INT(11)"`
-	MaxNum       int       `xorm:"INT(11)"`
-	MinNum       int       `xorm:"INT(11)"`
-	BeginDate    time.Time `xorm:"DATETIME"`
-	EndDate      time.Time `xorm:"DATETIME"`
-	CourseImg    string    `xorm:"TEXT"`
-	CourseDesc   string    `xorm:"VARCHAR(500)"`
-	Remark       string    `xorm:"TEXT"`
-	IsSelect     int       `xorm:"TINYINT(1)"`
-	Status       int       `xorm:"SMALLINT(6)"`
-	CreateDate   time.Time `xorm:"DATETIME"`
-	CreateUser   string    `xorm:"VARCHAR(64)"`
+	CourseId    string    `xorm:"not null pk VARCHAR(64)"`
+	CourseName  string    `xorm:"VARCHAR(50)"`
+	Price       float32   `xorm:"FLOAT(8,2)"`
+	OrgId       string    `xorm:"VARCHAR(64)"`
+	CaseId      string    `xorm:"VARCHAR(64)"`
+	LocationId  string    `xorm:"VARCHAR(64)"`
+	CourseNum   int       `xorm:"INT(11)"`
+	ScheduleNum int       `xorm:"INT(11)"`
+	MaxNum      int       `xorm:"INT(11)"`
+	MinNum      int       `xorm:"INT(11)"`
+	BeginDate   time.Time `xorm:"DATETIME"`
+	EndDate     time.Time `xorm:"DATETIME"`
+	CourseImg   string    `xorm:"TEXT"`
+	CourseDesc  string    `xorm:"VARCHAR(500)"`
+	Remark      string    `xorm:"TEXT"`
+	IsSelect    int       `xorm:"TINYINT(1)"`
+	Status      int       `xorm:"SMALLINT(6)"`
+	CreateDate  time.Time `xorm:"DATETIME"`
+	CreateUser  string    `xorm:"VARCHAR(64)"`
+	SignupNum   int       `xorm:"INT(11)"`
 }

routers/common.go

@@ -154,8 +154,26 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/rolemenu/:roleid", &system.RoleController{}, "put:SaveRoleMenus"),
 
 		// course 课程
-		beego.NSRouter("/course/taglist", &course.CourseController{}, "get:GetCourseTagsByPage"),
-		beego.NSRouter("/course/tag", &course.CourseController{}, "get:GetCourseTags"),
+		beego.NSRouter("/coursetag", &course.CourseController{}, "get:GetCourseTagsByPage"),
+		// beego.NSRouter("/coursetag", &course.CourseController{}, "get:GetCourseTags"),
+
+		beego.NSRouter("/course", &course.CourseController{}, "get:GetCourseList"),
+		beego.NSRouter("/course/:courseid", &course.CourseController{}, "get:GetCourseByID"),
+		beego.NSRouter("/course", &course.CourseController{}, "post:SaveCourse"),
+		beego.NSRouter("/course", &course.CourseController{}, "put:SaveCourse"),
+		beego.NSRouter("/course/:courseid", &course.CourseController{}, "delete:DeleteCourse"),
+		beego.NSRouter("/course/:courseid/public", &course.CourseController{}, "put:CoursePublic"),
+		beego.NSRouter("/course/:courseid/unpublic", &course.CourseController{}, "get:CourseUnPublic"),
+		beego.NSRouter("/courseimg/:courseid", &course.CourseController{}, "get:GetCourseImgs"),
+		beego.NSRouter("/courseimg", &course.CourseController{}, "post:SaveCourseImg"),
+		beego.NSRouter("/courseimg", &course.CourseController{}, "put:SaveCourseImg"),
+		beego.NSRouter("/courseimg/:courseid", &course.CourseController{}, "delete:DelCourseImg"),
+		beego.NSRouter("/schedule", &course.CourseController{}, "get:GetCourseSchedule"),
+		beego.NSRouter("/detail", &course.CourseController{}, "get:GetDetails"),
+		beego.NSRouter("/detail/:detailid", &course.CourseController{}, "get:GetDetailByID"),
+		beego.NSRouter("/detail", &course.CourseController{}, "post:SaveDetail"),
+		beego.NSRouter("/detail", &course.CourseController{}, "put:SaveDetail"),
+		beego.NSRouter("/detail/:detailid", &course.CourseController{}, "delete:DelCourseDetail"),
 
 		// 文件
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),

service/course/course.go

@@ -1,8 +1,14 @@
 package course
 
 import (
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/course"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
+	"strings"
+
+	"github.com/astaxie/beego"
 )
 
 // CourseServ 系统处理
@@ -18,3 +24,324 @@ func NewCourseServ(ctx *utils.Context) *CourseServ {
 		dao: course.NewCourseDAO(ctx),
 	}
 }
+
+// GetCourseList 获取课程列表
+func (s *CourseServ) GetCourseList(caseids, name, typeid string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	list, err := s.dao.GetCourseList(caseids, name, typeid, page, pageSize)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	total, err := s.dao.GetCourseCount(caseids, name, typeid)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetCourseByID 获取课程明细
+func (s *CourseServ) GetCourseByID(courseid string) (*course.CourseDetail, error) {
+	if courseid == "" {
+		return nil, utils.LogError("不存在课程信息！")
+	}
+	info, err := s.dao.GetCourseInfo(courseid)
+	if err != nil {
+		return nil, err
+	}
+	if info == nil {
+		return nil, utils.LogError("不存在课程信息！")
+	}
+	if info.Status == models.STATUS_DEL {
+		return nil, utils.LogError("课程已被删除！")
+	}
+
+	tags, err := s.dao.GetCourseTag(courseid)
+	if err != nil {
+		return nil, err
+	}
+	info.CourseTags = tags
+	details, err := s.dao.GetCourseDetail(courseid)
+	if err != nil {
+		return nil, err
+	}
+	info.CourseDetail = details
+	imgs, err := s.dao.GetCourseImgs(courseid)
+	if err != nil {
+		return nil, err
+	}
+	info.CourseImgs = imgs
+	return info, nil
+}
+
+// SaveCourse 保存课程信息
+func (s *CourseServ) SaveCourse(course model.TaCourse, tagids string) (*model.TaCourse, error) {
+	var newInfo *model.TaCourse
+	var err error
+	if course.CourseName == "" {
+		return nil, utils.LogError("课程名称不允许为空！")
+	}
+	if course.CourseImg == "" {
+		return nil, utils.LogError("课程主图不允许为空！")
+	}
+	if course.LocationId == "" {
+		return nil, utils.LogError("课程类型不允许为空！")
+	}
+	if course.CaseId == "" {
+		return nil, utils.LogError("课程案场不允许为空！")
+	}
+	if course.Price == 0 {
+		return nil, utils.LogError("课程价格不允许为0！")
+	}
+	if course.MinNum == 0 {
+		return nil, utils.LogError("最小开课人数不允许为0！")
+	}
+	if course.MaxNum == 0 {
+		return nil, utils.LogError("上课人数不允许为0！")
+	}
+	if course.MaxNum < course.MinNum {
+		return nil, utils.LogError("上课人数不允许小于最小开课人数！")
+	}
+	if course.CourseNum == 0 {
+		return nil, utils.LogError("课时数不允许为0！")
+	}
+	if course.BeginDate.IsZero() || course.EndDate.IsZero() {
+		return nil, utils.LogError("课程时间不允许为空！")
+	}
+	if course.EndDate.After(course.BeginDate) {
+		return nil, utils.LogError("截止时间必须大于开始时间！")
+	}
+	if tagids == "" {
+		return nil, utils.LogError("请选择课程标签！")
+	}
+	if course.CourseId == "" {
+		newInfo, err = s.dao.AddCourse(course)
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		err = s.dao.UpdateCourse(course)
+		if err != nil {
+			return nil, err
+		}
+		newInfo = &course
+		err = s.dao.DelCourseTag(course.CourseId)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	tags := strings.Split(tagids, ",")
+	var courseTags []model.TaCourseTag
+	for _, tag := range tags {
+		arr := strings.Split(tag, ":")
+		var tagid = ""
+		if len(arr) > 1 {
+			tagid = arr[1]
+		} else {
+			var taginfo = model.TdCourseTag{
+				TagName: arr[0],
+				OrgId:   course.OrgId,
+			}
+			newtag, err := s.dao.AddCourseTag(taginfo)
+			if err != nil {
+				return nil, err
+			}
+			tagid = newtag.TagId
+		}
+		var coursetag = model.TaCourseTag{
+			CourseId: course.CourseId,
+			TagId:    tagid,
+		}
+		courseTags = append(courseTags, coursetag)
+	}
+
+	if len(courseTags) > 0 {
+		err = s.dao.SaveCourseTag(courseTags)
+		return nil, err
+	}
+	return newInfo, nil
+}
+
+// DelCourse 刪除课程信息
+func (s *CourseServ) DelCourse(courseid string) error {
+	if courseid == "" {
+		return utils.LogError("没有对应的课程！")
+	}
+	err := s.dao.DelCourse(courseid)
+	return err
+}
+
+// CoursePublic 课程发布
+func (s *CourseServ) CoursePublic(courseid string) error {
+	if courseid == "" {
+		return utils.LogError("没有对应的课程！")
+	}
+	info, err := s.dao.GetCourseByID(courseid)
+	if err != nil {
+		return err
+	}
+	if info.Status != course.STATUS_UNPUBLISH {
+		return utils.LogError("当前课程状态异常！请刷新后重试！")
+	}
+	err = s.dao.CoursePublic(courseid)
+	return err
+}
+
+// CourseUnPublic 课程取消发布
+func (s *CourseServ) CourseUnPublic(courseid string) error {
+	if courseid == "" {
+		return utils.LogError("没有对应的课程！")
+	}
+	info, err := s.dao.GetCourseByID(courseid)
+	if err != nil {
+		return err
+	}
+	if info.Status != models.STATUS_NORMAL {
+		return utils.LogError("当前课程状态异常！请刷新后重试！")
+	}
+	err = s.dao.CourseUnPublic(courseid)
+	return err
+}
+
+// GetCourseImgs 获取课程图片
+func (s *CourseServ) GetCourseImgs(courseid string) ([]model.TaCourseImg, error) {
+	if courseid == "" {
+		return nil, utils.LogError("没有对应的课程！")
+	}
+	imgs, err := s.dao.GetCourseImgs(courseid)
+	return imgs, err
+}
+
+// SaveCourseImg 保存课程图片
+func (s *CourseServ) SaveCourseImg(img model.TaCourseImg) (*model.TaCourseImg, error) {
+	var newinfo *model.TaCourseImg
+	var err error
+	if img.ImgUrl == "" {
+		return nil, utils.LogError("请先上传图片！")
+	}
+	if img.ImgId == "" {
+		newinfo, err = s.dao.AddCourseImg(img)
+	} else {
+		newinfo = &img
+		err = s.dao.UpdateCourseImg(img)
+	}
+	return newinfo, err
+}
+
+// DelCourseImg 刪除课程图片
+func (s *CourseServ) DelCourseImg(imgid string) error {
+	if imgid == "" {
+		return utils.LogError("没有需要删除的内容！")
+	}
+	err := s.dao.DelCourseImg(imgid)
+	return err
+}
+
+// GetCourseSchedule 获取课程排期
+func (s *CourseServ) GetCourseSchedule(name, caseids, date string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	if date == "" {
+		return nil, utils.LogError("请先选择需要排课的日期！")
+	}
+	list, err := s.dao.GetCourseSchedule(name, caseids, date, page, pageSize)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	total, err := s.dao.GetCourseScheduleCount(name, caseids, date)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, err
+}
+
+// GetDetails 获取所有排课
+func (s *CourseServ) GetDetails(caseid, date string) ([]model.TaCourseDetail, error) {
+	if caseid == "" {
+		return nil, utils.LogError("请先选择案场！")
+	}
+	if date == "" {
+		return nil, utils.LogError("请选择需要查看的月份！")
+	}
+	details, err := s.dao.GetDetails(caseid, date)
+	return details, err
+}
+
+// GetDetailByID 获取单个排课信息
+func (s *CourseServ) GetDetailByID(detailid string) (*model.TaCourseDetail, error) {
+	if detailid == "" {
+		return nil, utils.LogError("没有对应的排课信息！")
+	}
+	detail, err := s.dao.GetDetailByID(detailid)
+	return detail, err
+}
+
+// SaveDetail 保存排课信息
+func (s *CourseServ) SaveDetail(detail model.TaCourseDetail) (*model.TaCourseDetail, error) {
+	var newinfo *model.TaCourseDetail
+	if detail.CourseId == "" {
+		return nil, utils.LogError("没有对应的课程信息！")
+	}
+	if detail.DetailName == "" {
+		return nil, utils.LogError("课程名称不能为空！")
+	}
+	if detail.BeginDate.IsZero() || detail.EndDate.IsZero() {
+		return nil, utils.LogError("课程时间不能为空！")
+	}
+	if detail.BeginDate.After(detail.EndDate) {
+		return nil, utils.LogError("课程截止时间必须大于开始时间！")
+	}
+	if detail.DetailId == "" {
+		course, err := s.dao.GetCourseByID(detail.CourseId)
+		if err != nil {
+			return nil, err
+		}
+		detail.OrgId = course.OrgId
+		detail.CaseId = course.CaseId
+		newinfo, err = s.dao.AddCourseDetail(detail)
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		err := s.dao.UpdateCourseDetail(detail)
+		if err != nil {
+			return nil, err
+		}
+		newinfo = &detail
+	}
+	return newinfo, nil
+}
+
+// DelCourseDetail 删除课程明细
+func (s *CourseServ) DelCourseDetail(detailid string) error {
+	if detailid == "" {
+		return utils.LogError("没有对应的排课信息！")
+	}
+	err := s.dao.DelCourseDetail(detailid)
+	return err
+}