增加我的课程

controllers/course/course.go

@@ -213,3 +213,12 @@ func (c *CourseController) GetCourseByLocation() {
 	}
 	c.ResponseJSON(courses)
 }
+
+// GetCustomerCourse 获取用户课程信息
+func (c *CourseController) GetCustomerCourse() {
+	courses, err := c.serv.GetCustomerCourse()
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(courses)
+}

models/course/course.go

@@ -448,3 +448,35 @@ func (m *CourseDAO) SaveCourseOfCustomer(course *model.TaCustomerCourse, details
 
 	return nil
 }
+
+// CustomerCourse 客户课程信息
+type CustomerCourse struct {
+	model.TaCustomerCourse `xorm:"extends"`
+	Details                []model.TaCustomerCourseDetail
+}
+
+// GetCustomerCourse 获取我的课程信息
+func (m *CourseDAO) GetCustomerCourse(custID string) ([]CustomerCourse, error) {
+	var courses []CustomerCourse
+	sql := `select * from ta_customer_course where status>` + strconv.Itoa(models.STATUS_DEL) + ` and customer_id='` + custID + `'`
+
+	err := m.db.Sql(sql).Find(&courses)
+	if err != nil {
+		return nil, err
+	}
+	for inx, course := range courses {
+		details, err := m.GetCustomerCourseDetail(course.CustomerCourseId)
+		if err != nil {
+			return nil, err
+		}
+		courses[inx].Details = details
+	}
+	return courses, nil
+}
+
+// GetCustomerCourseDetail 获取我的课程明细
+func (m *CourseDAO) GetCustomerCourseDetail(customerCourseID string) ([]model.TaCustomerCourseDetail, error) {
+	var details []model.TaCustomerCourseDetail
+	err := m.db.Where("customer_course_id=?", customerCourseID).And(`status>` + strconv.Itoa(models.STATUS_DEL)).Find(&details)
+	return details, err
+}

routers/wechat.go

@@ -18,5 +18,8 @@ func getWechatRoutes() beego.LinkNamespace {
 		// 下单
 		beego.NSRouter("/order/goods", &goods.GoodsController{}, "post:PostOrder"),
 		beego.NSRouter("/order/course", &course.CourseController{}, "post:PostOrder"),
+
+		// 课程
+		beego.NSRouter("/course/user", &course.CourseController{}, "get:PostOrder"),
 	)
 }

service/course/course.go

@@ -498,3 +498,14 @@ func (s *CourseServ) GetCourseByLocation(orgid, locationid string) ([]course.Cou
 	}
 	return list, err
 }
+
+// GetCustomerCourse 获取用户的课程信息
+func (s *CourseServ) GetCustomerCourse() ([]course.CustomerCourse, error) {
+	cust := s.ctx.Get("customer").(model.TaCustomer)
+	courses, err := s.dao.GetCustomerCourse(cust.CustomerId)
+	if err != nil {
+		utils.LogError("获取课程信息失败: " + err.Error())
+		return nil, errors.New("获取课程信息失败")
+	}
+	return courses, nil
+}