增加分页

controllers/course/course.go

@@ -216,7 +216,10 @@ func (c *CourseController) GetCourseByLocation() {
 
 // GetCustomerCourse 获取用户课程信息
 func (c *CourseController) GetCustomerCourse() {
-	courses, err := c.serv.GetCustomerCourse()
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+
+	courses, err := c.serv.GetCustomerCourse(page, pageSize)
 	if err != nil {
 		c.ResponseError(err)
 	}

models/course/course.go

@@ -456,10 +456,10 @@ type CustomerCourse struct {
 }
 
 // GetCustomerCourse 获取我的课程信息
-func (m *CourseDAO) GetCustomerCourse(custID string) ([]CustomerCourse, error) {
+func (m *CourseDAO) GetCustomerCourse(custID string, page, pageSize int) ([]CustomerCourse, error) {
 	var courses []CustomerCourse
 	sql := `select * from ta_customer_course where status>` + strconv.Itoa(models.STATUS_DEL) + ` and customer_id='` + custID + `'`
-
+	sql += ` order by create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
 	err := m.db.Sql(sql).Find(&courses)
 	if err != nil {
 		return nil, err
@@ -474,6 +474,16 @@ func (m *CourseDAO) GetCustomerCourse(custID string) ([]CustomerCourse, error) {
 	return courses, nil
 }
 
+// GetCustomerCourseCount 获取我的课程总数
+func (m *CourseDAO) GetCustomerCourseCount(custID string) (int, error) {
+	var courses []model.TaCustomerCourse
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("customer_id=?", custID).Find(&courses)
+	if err != nil {
+		return 0, err
+	}
+	return len(courses), nil
+}
+
 // GetCustomerCourseDetail 获取我的课程明细
 func (m *CourseDAO) GetCustomerCourseDetail(customerCourseID string) ([]model.TaCustomerCourseDetail, error) {
 	var details []model.TaCustomerCourseDetail

models/goods/orders.go

@@ -203,3 +203,8 @@ func (m *GoodsDAO) GetOrdersByRecord(recordid string) ([]OrdersWithGoods, error)
 	}
 	return orderList, nil
 }
+
+// GetCustomerOrders 获取用户订单
+// func (m *GoodsDAO) GetCustomerOrders(custID string) ([]OrdersWithGoods, error) {
+
+// }

service/course/course.go

@@ -500,14 +500,31 @@ func (s *CourseServ) GetCourseByLocation(orgid, locationid string) ([]course.Cou
 }
 
 // GetCustomerCourse 获取用户的课程信息
-func (s *CourseServ) GetCustomerCourse() ([]course.CustomerCourse, error) {
+func (s *CourseServ) GetCustomerCourse(page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
 	cust := s.ctx.Get("customer").(model.TaCustomer)
-	courses, err := s.dao.GetCustomerCourse(cust.CustomerId)
+	list, err := s.dao.GetCustomerCourse(cust.CustomerId, page, pageSize)
 	if err != nil {
 		utils.LogError("获取课程信息失败: " + err.Error())
 		return nil, errors.New("获取课程信息失败")
 	}
-	return courses, nil
+	total, err := s.dao.GetCustomerCourseCount(cust.CustomerId)
+	if err != nil {
+		utils.LogError("获取课程信息失败: " + err.Error())
+		return nil, errors.New("获取课程信息失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
 }
 
 // GetCustomerCourseByID 获取我的课程明细