0915PM

controllers/coupon/coupon.go

@@ -78,7 +78,7 @@ func (c *CouponController) GetCouponByID() {
 		c.ResponseError(errors.New("未指定券"))
 	}
 
-	cp, err := c.serv.GetCouponByID(id)
+	cp, err := c.serv.GetCouponInfoByID(id)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/statistics/course.go

@@ -0,0 +1,45 @@
+package statistics
+
+import "spaceofcheng/services/models/model"
+
+// GetCourseOrdersStatistics 获取课程订单统计数据
+func (c *StatisticsController) GetCourseOrdersStatistics() {
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+	begindate := c.GetString("begindate")
+	enddate := c.GetString("enddate")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	ordersList, err := c.serv.GetCourseOrdersStatistics(typeid, caseids, name, begindate, enddate, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(ordersList)
+}
+
+// GetCourseStatistics 获取课程统计数据
+func (c *StatisticsController) GetCourseStatistics() {
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	ordersList, err := c.serv.GetCourseStatistics(typeid, caseids, name, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(ordersList)
+}

controllers/statistics/goods.go

@@ -0,0 +1,45 @@
+package statistics
+
+import "spaceofcheng/services/models/model"
+
+// GetGoodsStatistics 获取商品统计数据
+func (c *StatisticsController) GetGoodsStatistics() {
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	caseids := c.GetString("caseid")
+	name := c.GetString("name")
+	typeid := c.GetString("typeid")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	goodsList, err := c.serv.GetGoodsStatistics(caseids, typeid, name, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(goodsList)
+}
+
+// GetGoodsOrdersStatistics 获取商品订单统计数据
+func (c *StatisticsController) GetGoodsOrdersStatistics() {
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	caseids := c.GetString("caseid")
+	status := c.GetString("status")
+	usertype := c.GetString("usertype")
+	begindate := c.GetString("begindate")
+	enddate := c.GetString("enddate")
+
+	if caseids == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseids = c.GetCaseIDs(cases)
+	}
+	goodsList, err := c.serv.GetGoodsOrdersStatistics(status, usertype, caseids, begindate, enddate, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(goodsList)
+}

controllers/statistics/statistics.go

@@ -0,0 +1,19 @@
+package statistics
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/service/statistics"
+)
+
+// StatisticsController 商品
+type StatisticsController struct {
+	serv *statistics.StatisticsServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *StatisticsController) Constructor() {
+	c.serv = statistics.NewStatisticsServ(c.Context)
+}

log/common.log

@@ -441,3 +441,140 @@
 2018/09/15 15:48:32 [E] 用户没有设置默认案场
 2018/09/15 15:48:36 [E] 用户没有设置默认案场
 2018/09/15 15:48:36 [E] 用户没有设置默认案场
+2018/09/15 17:32:50 [E] 用户没有设置默认案场
+2018/09/15 17:32:50 [E] 用户没有设置默认案场
+2018/09/15 17:35:31 [E] 用户没有设置默认案场
+2018/09/15 17:35:31 [E] 用户没有设置默认案场
+2018/09/15 19:53:50 [E] 用户没有设置默认案场
+2018/09/15 19:58:02 [E] 用户没有设置默认案场
+2018/09/15 19:58:21 [E] 用户没有设置默认案场
+2018/09/15 19:59:28 [E] 用户没有设置默认案场
+2018/09/15 19:59:28 [E] 用户没有设置默认案场
+2018/09/15 20:00:27 [E] 用户没有设置默认案场
+2018/09/15 20:00:27 [E] 用户没有设置默认案场
+2018/09/15 20:05:23 [E] 用户没有设置默认案场
+2018/09/15 20:05:23 [E] 用户没有设置默认案场
+2018/09/15 20:05:34 [E] 用户没有设置默认案场
+2018/09/15 20:05:34 [E] 用户没有设置默认案场
+2018/09/15 20:06:38 [E] 用户没有设置默认案场
+2018/09/15 20:08:27 [E] 用户没有设置默认案场
+2018/09/15 20:09:25 [E] 用户没有设置默认案场
+2018/09/15 20:10:33 [E] 用户没有设置默认案场
+2018/09/15 20:10:36 [E] 用户没有设置默认案场
+2018/09/15 20:10:36 [E] 获取商品统计数据失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'lile '%111%' GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+			' at line 24
+2018/09/15 20:10:59 [E] 用户没有设置默认案场
+2018/09/15 20:10:59 [E] 获取商品统计数据失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'lile '%111%' GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+			' at line 24
+2018/09/15 20:14:41 [E] 用户没有设置默认案场
+2018/09/15 20:14:41 [E] 获取商品统计数据失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'lile '%111%' GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+			' at line 24
+2018/09/15 20:15:09 [E] 用户没有设置默认案场
+2018/09/15 20:15:09 [E] 获取商品统计数据失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'lile '%111%' GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+			' at line 24
+2018/09/15 20:16:08 [E] 用户没有设置默认案场
+2018/09/15 20:16:33 [E] 用户没有设置默认案场
+2018/09/15 20:16:33 [E] 用户没有设置默认案场
+2018/09/15 20:18:10 [E] 用户没有设置默认案场
+2018/09/15 20:18:11 [E] 用户没有设置默认案场
+2018/09/15 20:18:16 [E] 用户没有设置默认案场
+2018/09/15 20:18:16 [E] 用户没有设置默认案场
+2018/09/15 20:18:17 [E] 用户没有设置默认案场
+2018/09/15 20:19:05 [E] 用户没有设置默认案场
+2018/09/15 20:19:05 [E] 用户没有设置默认案场
+2018/09/15 20:19:12 [E] 用户没有设置默认案场
+2018/09/15 20:19:19 [E] 用户没有设置默认案场
+2018/09/15 20:19:19 [E] 创建VIP卡失败: Error 1054: Unknown column 'sales_id' in 'field list'
+2018/09/15 20:20:02 [E] 用户没有设置默认案场
+2018/09/15 20:21:40 [E] 用户没有设置默认案场
+2018/09/15 20:21:40 [E] 用户没有设置默认案场
+2018/09/15 20:21:40 [E] 用户没有设置默认案场
+2018/09/15 20:21:55 [E] 用户没有设置默认案场
+2018/09/15 20:21:55 [E] 用户没有设置默认案场
+2018/09/15 20:22:03 [E] 用户没有设置默认案场
+2018/09/15 20:22:23 [E] 用户没有设置默认案场
+2018/09/15 20:22:25 [E] 用户没有设置默认案场
+2018/09/15 20:22:30 [E] 用户没有设置默认案场
+2018/09/15 20:22:36 [E] 课程下单失败: Error 1366: Incorrect decimal value: '' for column 'coupon_amount' at row 1
+2018/09/15 20:22:36 [E] 课程下单失败: 下单失败, 请重试
+2018/09/15 20:23:41 [E] 用户没有设置默认案场
+2018/09/15 20:23:41 [E] 用户没有设置默认案场
+2018/09/15 20:23:42 [E] 用户没有设置默认案场
+2018/09/15 20:28:39 [E] 用户没有设置默认案场
+2018/09/15 20:28:39 [E] 用户没有设置默认案场
+2018/09/15 20:30:57 [E] 用户没有设置默认案场
+2018/09/15 20:30:57 [E] 用户没有设置默认案场
+2018/09/15 20:31:21 [E] 用户没有设置默认案场
+2018/09/15 20:31:21 [E] 用户没有设置默认案场
+2018/09/15 20:35:30 [E] 用户没有设置默认案场
+2018/09/15 20:36:12 [E] 用户没有设置默认案场
+2018/09/15 20:36:12 [E] 用户没有设置默认案场
+2018/09/15 20:45:17 [E] 用户没有设置默认案场
+2018/09/15 20:46:02 [E] 用户没有设置默认案场
+2018/09/15 20:46:28 [E] 用户没有设置默认案场
+2018/09/15 20:46:41 [E] 用户没有设置默认案场
+2018/09/15 20:46:41 [E] 用户没有设置默认案场
+2018/09/15 20:47:09 [E] 用户没有设置默认案场
+2018/09/15 20:47:09 [E] 用户没有设置默认案场
+2018/09/15 20:47:26 [E] 用户没有设置默认案场
+2018/09/15 20:47:29 [E] 用户没有设置默认案场
+2018/09/15 20:47:29 [E] 用户没有设置默认案场
+2018/09/15 20:47:50 [E] 用户没有设置默认案场
+2018/09/15 20:48:53 [E] 用户没有设置默认案场
+2018/09/15 20:54:06 [E] 用户没有设置默认案场
+2018/09/15 20:54:11 [E] 用户没有设置默认案场
+2018/09/15 20:54:16 [E] 用户没有设置默认案场
+2018/09/15 20:55:29 [E] 用户没有设置默认案场
+2018/09/15 20:56:43 [E] 用户没有设置默认案场
+2018/09/15 20:56:46 [E] 用户没有设置默认案场
+2018/09/15 20:57:08 [E] 用户没有设置默认案场
+2018/09/15 20:57:08 [E] 用户没有设置默认案场
+2018/09/15 20:57:14 [E] 用户没有设置默认案场
+2018/09/15 20:57:17 [E] 用户没有设置默认案场
+2018/09/15 20:57:24 [E] 用户没有设置默认案场
+2018/09/15 20:58:03 [E] 用户没有设置默认案场
+2018/09/15 20:58:42 [E] 用户没有设置默认案场
+2018/09/15 21:01:05 [E] 用户没有设置默认案场
+2018/09/15 21:03:14 [E] 用户没有设置默认案场
+2018/09/15 21:04:55 [E] 用户没有设置默认案场
+2018/09/15 21:05:20 [E] 用户没有设置默认案场
+2018/09/15 21:07:38 [E] 用户没有设置默认案场
+2018/09/15 21:08:00 [E] 用户没有设置默认案场
+2018/09/15 21:09:20 [E] 用户没有设置默认案场
+2018/09/15 21:09:35 [E] 用户没有设置默认案场
+2018/09/15 21:09:35 [E] 用户没有设置默认案场
+2018/09/15 21:09:58 [E] 用户没有设置默认案场
+2018/09/15 21:10:18 [E] 用户没有设置默认案场
+2018/09/15 21:10:18 [E] 用户没有设置默认案场
+2018/09/15 21:10:50 [E] 用户没有设置默认案场
+2018/09/15 21:11:12 [E] 用户没有设置默认案场
+2018/09/15 21:11:20 [E] 用户没有设置默认案场
+2018/09/15 21:12:04 [E] 用户没有设置默认案场
+2018/09/15 21:12:55 [E] 用户没有设置默认案场
+2018/09/15 21:13:03 [E] 用户没有设置默认案场
+2018/09/15 21:18:03 [E] 用户没有设置默认案场
+2018/09/15 21:18:03 [E] 用户没有设置默认案场
+2018/09/15 21:18:09 [E] 用户没有设置默认案场
+2018/09/15 21:18:09 [E] 用户没有设置默认案场
+2018/09/15 21:18:09 [E] 用户没有设置默认案场
+2018/09/15 21:18:49 [E] 用户没有设置默认案场
+2018/09/15 21:18:49 [E] 用户没有设置默认案场
+2018/09/15 21:18:50 [E] 用户没有设置默认案场
+2018/09/15 21:19:33 [E] 用户没有设置默认案场
+2018/09/15 21:19:33 [E] 用户没有设置默认案场
+2018/09/15 21:19:48 [E] 用户没有设置默认案场
+2018/09/15 21:19:48 [E] 用户没有设置默认案场
+2018/09/15 21:19:51 [E] 用户没有设置默认案场
+2018/09/15 21:40:12 [E] 用户没有设置默认案场

models/message/cmscase.go

@@ -98,7 +98,7 @@ func (m *MessageDAO) GetCmsCaseImgs(cmscaseid string) ([]model.TaCmsCaseImage, e
 // GetCourseByCaseID 根据案场ID获取所有的课程信息
 func (m *MessageDAO) GetCourseByCaseID(caseid string) ([]course.CourseDetail, error) {
 	var course []course.CourseDetail
-	sql := `select * from ta_course where status>` + strconv.Itoa(models.STATUS_DEL) + ` and case_id=?`
+	sql := `select * from ta_course where status = ` + strconv.Itoa(models.STATUS_NORMAL) + ` and case_id=?`
 	err := m.db.Sql(sql, caseid).Find(&course)
 	return course, err
 }

models/statistics/course.go

@@ -0,0 +1,220 @@
+package statistics
+
+import (
+	"strconv"
+	"strings"
+	"time"
+)
+
+// CourseOrdersStatistics 课程订单
+type CourseOrdersStatistics struct {
+	OrdersId     string
+	OrdersNo     string
+	CourseName   string
+	CaseName     string
+	LocationName string
+	BeginDate    time.Time
+	EndDate      time.Time
+	Name         string
+	CustomerName string
+	Phone        string
+	CreateDate   time.Time
+}
+
+// GetCourseOrdersStatistics 获取课程订单统计信息
+func (m *StatisticsDAO) GetCourseOrdersStatistics(typeid, caseids, name, begindate, enddate string, page, pageSize int) ([]CourseOrdersStatistics, error) {
+	var courseOrders []CourseOrdersStatistics
+	sql := `SELECT
+					a.orders_id,
+					a.orders_no,
+					c.course_name,
+					b.case_name,
+					d.location_name,
+					c.begin_date,
+					c.end_date,
+					e. NAME,
+					e.customer_name,
+					e.phone,
+					a.create_date
+				FROM
+					ta_course_orders a
+				INNER JOIN sys_case b ON a.case_id = b.case_id
+				INNER JOIN ta_course c ON a.course_id = c.course_id
+				INNER JOIN td_cms_image_location d ON c.location_id = d.location_id
+				INNER JOIN ta_customer e ON a.customer_id = e.customer_id 
+				Where c.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+	if typeid != "" {
+		sql = sql + ` and c.location_id = '` + typeid + `'`
+	}
+	if name != "" {
+		sql = sql + ` and c.course_name like '%` + name + `%'`
+	}
+	if begindate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') >= '` + begindate + `'`
+	}
+	if enddate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') <= '` + enddate + `'`
+	}
+	sql = sql + ` limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+
+	err := m.db.Sql(sql).Find(&courseOrders)
+	return courseOrders, err
+}
+
+// GetCourseOrdersStatisticsCount 获取课程订单统计数量
+func (m *StatisticsDAO) GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate string) (int, error) {
+	var courseOrders []CourseOrdersStatistics
+	sql := `SELECT
+					a.orders_id,
+					a.orders_no,
+					c.course_name,
+					b.case_name,
+					d.location_name,
+					c.begin_date,
+					c.end_date,
+					e. NAME,
+					e.customer_name,
+					e.phone,
+					a.create_date
+				FROM
+					ta_course_orders a
+				INNER JOIN sys_case b ON a.case_id = b.case_id
+				INNER JOIN ta_course c ON a.course_id = c.course_id
+				INNER JOIN td_cms_image_location d ON c.location_id = d.location_id
+				INNER JOIN ta_customer e ON a.customer_id = e.customer_id 
+				Where c.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+	if typeid != "" {
+		sql = sql + ` and c.location_id = '` + typeid + `'`
+	}
+	if name != "" {
+		sql = sql + ` and c.course_name like '%` + name + `%'`
+	}
+	if begindate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') >= '` + begindate + `'`
+	}
+	if enddate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') <= '` + enddate + `'`
+	}
+
+	err := m.db.Sql(sql).Find(&courseOrders)
+	return len(courseOrders), err
+}
+
+// CourseStatistics 课程统计数据
+type CourseStatistics struct {
+	CourseId     string
+	CaseName     string
+	CourseName   string
+	LocationName string
+	BeginDate    time.Time
+	EndDate      time.Time
+	Price        string
+	Total        int
+	JoinTotal    int
+}
+
+// GetCourseStatistics 获取课程统计信息
+func (m *StatisticsDAO) GetCourseStatistics(typeid, caseids, name string, page, pageSize int) ([]CourseStatistics, error) {
+	var courses []CourseStatistics
+	sql := `SELECT
+					a.course_id,
+					d.case_name,
+					a.course_name,
+					e.location_name,
+					a.begin_date,
+					a.end_date,
+					a.price,
+					b.total,
+					c.join_total
+				FROM
+					ta_course a
+				INNER JOIN sys_case d ON a.case_id = d.case_id
+				INNER JOIN td_cms_image_location e ON a.location_id = e.location_id
+				LEFT JOIN (
+					SELECT
+						course_id,
+						count(1) AS total
+					FROM
+						ta_customer_course
+					GROUP BY
+						course_id
+				) b ON a.course_id = b.course_id
+				LEFT JOIN (
+					SELECT
+						course_id,
+						count(1) AS join_total
+					FROM
+						ta_customer_course
+					WHERE
+						join_num > 0
+					GROUP BY
+						course_id
+				) c ON a.course_id = c.course_id SELECT
+					*
+				FROM
+					ta_customer_course
+				Where d.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+	if typeid != "" {
+		sql = sql + ` and e.location_id = '` + typeid + `'`
+	}
+	if name != "" {
+		sql = sql + ` and a.course_name like '%` + name + `%'`
+	}
+
+	sql = sql + ` limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+
+	err := m.db.Sql(sql).Find(&courses)
+	return courses, err
+}
+
+// GetCourseStatisticsCount 获取课程统计信息数量
+func (m *StatisticsDAO) GetCourseStatisticsCount(typeid, caseids, name string) (int, error) {
+	var courses []CourseStatistics
+	sql := `SELECT
+					a.course_id,
+					d.case_name,
+					a.course_name,
+					e.location_name,
+					a.begin_date,
+					a.end_date,
+					a.price,
+					b.total,
+					c.join_total
+				FROM
+					ta_course a
+				INNER JOIN sys_case d ON a.case_id = d.case_id
+				INNER JOIN td_cms_image_location e ON a.location_id = e.location_id
+				LEFT JOIN (
+					SELECT
+						course_id,
+						count(1) AS total
+					FROM
+						ta_customer_course
+					GROUP BY
+						course_id
+				) b ON a.course_id = b.course_id
+				LEFT JOIN (
+					SELECT
+						course_id,
+						count(1) AS join_total
+					FROM
+						ta_customer_course
+					WHERE
+						join_num > 0
+					GROUP BY
+						course_id
+				) c ON a.course_id = c.course_id SELECT
+					*
+				FROM
+					ta_customer_course
+				Where d.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+	if typeid != "" {
+		sql = sql + ` and e.location_id = '` + typeid + `'`
+	}
+	if name != "" {
+		sql = sql + ` and a.course_name like '%` + name + `%'`
+	}
+
+	err := m.db.Sql(sql).Find(&courses)
+	return len(courses), err
+}

models/statistics/goods.go

@@ -0,0 +1,216 @@
+package statistics
+
+import (
+	"spaceofcheng/services/models/model"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// GoodsStatistics 商品统计信息
+type GoodsStatistics struct {
+	CaseName    string
+	GoodsName   string
+	TypeName    string
+	Price       string
+	Total       int
+	FinishTotal int
+	Amount      string
+}
+
+// GetGoodsStatistics 获取商品统计信息
+func (m *StatisticsDAO) GetGoodsStatistics(caseids, typeid, name string, page, pageSize int) ([]GoodsStatistics, error) {
+	var goods []GoodsStatistics
+	sql := `SELECT
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+					b.price,
+					sum(a.number) AS total,
+					sum(
+						(
+							CASE
+							WHEN d.make_status = 'finished' THEN
+								1
+							ELSE
+								0
+							END
+						)
+					) AS finishtotal,
+					b.price * sum(a.number) AS amount
+				FROM
+					ta_goods_orders_detail a
+				INNER JOIN ta_goods b ON a.goods_id = b.goods_id
+				INNER JOIN td_goods_type c ON b.type_id = c.type_id
+				INNER JOIN ta_goods_orders d ON a.orders_id = d.orders_id
+				inner join sys_case e on b.case_id=e.case_id 
+				where e.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+
+	if typeid != "" {
+		sql = sql + ` and c.type_id='` + typeid + `'`
+	}
+
+	if name != "" {
+		sql = sql + ` and b.goods_name like '%` + name + `%'`
+	}
+	sql = sql + ` GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+					b.price limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&goods)
+	return goods, err
+}
+
+// GetGoodsStatisticsCount 获取总数
+func (m *StatisticsDAO) GetGoodsStatisticsCount(caseids, typeid, name string) (int, error) {
+	var goods []GoodsStatistics
+	sql := `SELECT
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+					b.price,
+					sum(a.number) AS total,
+					sum(
+						(
+							CASE
+							WHEN d.make_status = 'finished' THEN
+								1
+							ELSE
+								0
+							END
+						)
+					) AS finishtotal,
+					b.price * sum(a.number) AS amount
+				FROM
+					ta_goods_orders_detail a
+				INNER JOIN ta_goods b ON a.goods_id = b.goods_id
+				INNER JOIN td_goods_type c ON b.type_id = c.type_id
+				INNER JOIN ta_goods_orders d ON a.orders_id = d.orders_id
+				inner join sys_case e on b.case_id=e.case_id 
+				where e.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+
+	if typeid != "" {
+		sql = sql + ` and c.type_id='` + typeid + `'`
+	}
+
+	if name != "" {
+		sql = sql + ` and b.goods_name like '%` + name + `%'`
+	}
+	sql = sql + ` GROUP BY
+					e.case_name,
+					b.goods_name,
+					c.type_name,
+					b.price`
+	err := m.db.Sql(sql).Find(&goods)
+	return len(goods), err
+}
+
+// GoodsOrdersStatistics 商品订单统计信息
+type GoodsOrdersStatistics struct {
+	OrdersId     string
+	OrdersNo     string
+	CaseName     string
+	UserType     string
+	CreateDate   time.Time
+	Status       int
+	MakeStatus   string
+	AreaName     string
+	TableNo      string
+	CustomerName string
+	Phone        string
+	Name         string
+	Details      []model.TaGoodsOrdersDetail
+}
+
+// GetGoodsOrderStatistics 获取商品订单
+func (m *StatisticsDAO) GetGoodsOrderStatistics(status, usertype, caseids, begindate, enddate string, page, pageSize int) ([]GoodsOrdersStatistics, error) {
+	var orders []GoodsOrdersStatistics
+	sql := `SELECT
+						a.orders_id,
+						a.orders_no,
+						d.case_name,
+						a.user_type,
+						a.create_date,
+						a.status,
+						a.make_status,
+						a.area_name,
+						a.table_no,
+						c.customer_name,
+						c. NAME,
+						c.phone
+					FROM
+						ta_goods_orders a
+					INNER JOIN ta_customer b ON a.user_id = b.customer_id
+					INNER JOIN ta_customer c ON b.customer_id = c.customer_id
+					INNER JOIN sys_case d ON a.case_id = d.case_id
+					where d.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+
+	if usertype != "" {
+		sql = sql + ` and a.user_type='` + usertype + `'`
+	}
+	if begindate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') >= '` + begindate + `'`
+	}
+	if enddate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') <= '` + enddate + `'`
+	}
+	if status != "" {
+		sql = sql + ` and a.make_status='` + status + `'`
+	}
+	sql = sql + ` limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+
+	err := m.db.Sql(sql).Find(&orders)
+	if err != nil {
+		return nil, err
+	}
+	for inx, item := range orders {
+		var details []model.TaGoodsOrdersDetail
+		err := m.db.Where("orders_id=?", item.OrdersId).Find(&details)
+		if err != nil {
+			return nil, err
+		}
+		orders[inx].Details = details
+	}
+	return orders, err
+}
+
+// GetGoodsOrderStatisticsCount 获取商品订单Count
+func (m *StatisticsDAO) GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate string) (int, error) {
+	var orders []GoodsOrdersStatistics
+	sql := `SELECT
+						a.orders_id,
+						a.orders_no,
+						d.case_name,
+						a.user_type,
+						a.create_date,
+						a.status,
+						a.make_status,
+						a.area_name,
+						a.table_no,
+						c.customer_name,
+						c. NAME,
+						c.phone
+					FROM
+						ta_goods_orders a
+					INNER JOIN ta_customer b ON a.user_id = b.customer_id
+					INNER JOIN ta_customer c ON b.customer_id = c.customer_id
+					INNER JOIN sys_case d ON a.case_id = d.case_id
+					where d.case_id in ('` + strings.Replace(caseids, ",", "','", -1) + `')`
+
+	if usertype != "" {
+		sql = sql + ` and a.user_type='` + usertype + `'`
+	}
+	if begindate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') >= '` + begindate + `'`
+	}
+	if enddate != "" {
+		sql = sql + ` and DATE_FORMAT(a.create_date, '%Y-%m-%d') <= '` + enddate + `'`
+	}
+	if status != "" {
+		sql = sql + ` and a.make_status='` + status + `'`
+	}
+
+	err := m.db.Sql(sql).Find(&orders)
+	return len(orders), err
+}

routers/common.go

@@ -14,6 +14,7 @@ import (
 	"spaceofcheng/services/controllers/luckdrawlist"
 	"spaceofcheng/services/controllers/marketing"
 	"spaceofcheng/services/controllers/message"
+	"spaceofcheng/services/controllers/statistics"
 	"spaceofcheng/services/controllers/system"
 	"spaceofcheng/services/controllers/user"
 	"spaceofcheng/services/controllers/verify"
@@ -274,5 +275,11 @@ func getCommonRoutes() beego.LinkNamespace {
 
 		// websocket
 		beego.NSRouter("/websocket/:grps/:id", &controllers.BaseController{}, "get:Ws"),
+
+		// 统计类
+		beego.NSRouter("/statistics/goods", &statistics.StatisticsController{}, "get:GetGoodsStatistics"),
+		beego.NSRouter("/statistics/goodsorders", &statistics.StatisticsController{}, "get:GetGoodsOrdersStatistics"),
+		beego.NSRouter("/statistics/courseorders", &statistics.StatisticsController{}, "get:GetCourseOrdersStatistics"),
+		beego.NSRouter("/statistics/courses", &statistics.StatisticsController{}, "get:GetCourseStatistics"),
 	)
 }

service/coupon/coupon.go

@@ -338,6 +338,17 @@ func (s *CouponServ) GetCouponByID(cpID string) (*model.TaCoupon, error) {
 	return cp, nil
 }
 
+// GetCouponInfoByID 获取详情
+func (s *CouponServ) GetCouponInfoByID(cpID string) (*coupon.CouponInfo, error) {
+	cp, err := s.dao.GetCouponInfoByID(cpID)
+	if err != nil {
+		utils.LogError("获取优惠券失败: " + err.Error())
+		return nil, errors.New("校验优惠券失败")
+	}
+
+	return cp, nil
+}
+
 // GetCouponByIDWithCheck 获取优惠券
 func (s *CouponServ) GetCouponByIDWithCheck(cpID string) (*coupon.CouponInfo, error) {
 	cp, err := s.dao.GetCouponInfoByID(cpID)

service/course/order.go

@@ -131,6 +131,7 @@ func (s *CourseServ) Orders(
 		}
 	} else {
 		couseOrder.PayType = models.CONSUME_COINCHG
+		couseOrder.CouponAmount = "0.0"
 	}
 
 	couponAmount, _ := strconv.ParseFloat(couseOrder.CouponAmount, 64)

service/statistics/course.go

@@ -0,0 +1,71 @@
+package statistics
+
+import (
+	"errors"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+)
+
+// GetCourseOrdersStatistics 获取课程订单统计信息
+func (s *StatisticsServ) GetCourseOrdersStatistics(typeid, caseids, name, begindate, enddate string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	list, err := s.dao.GetCourseOrdersStatistics(typeid, caseids, name, begindate, enddate, page, pageSize)
+	if err != nil {
+		utils.LogError("获取课程订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程订单统计数据失败")
+	}
+	total, err := s.dao.GetCourseOrdersStatisticsCount(typeid, caseids, name, begindate, enddate)
+	if err != nil {
+		utils.LogError("获取课程订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程订单统计数据失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+// GetCourseStatistics 获取课程统计信息
+func (s *StatisticsServ) GetCourseStatistics(typeid, caseids, name string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	list, err := s.dao.GetCourseStatistics(typeid, caseids, name, page, pageSize)
+	if err != nil {
+		utils.LogError("获取课程统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程统计数据失败")
+	}
+	total, err := s.dao.GetCourseStatisticsCount(typeid, caseids, name)
+	if err != nil {
+		utils.LogError("获取课程统计数据失败: " + err.Error())
+		return nil, errors.New("获取课程统计数据失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}

service/statistics/goods.go

@@ -0,0 +1,71 @@
+package statistics
+
+import (
+	"errors"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+)
+
+// GetGoodsStatistics 获取商品统计信息
+func (s *StatisticsServ) GetGoodsStatistics(caseids, typeid, name string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	list, err := s.dao.GetGoodsStatistics(caseids, typeid, name, page, pageSize)
+	if err != nil {
+		utils.LogError("获取商品统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品统计数据失败")
+	}
+	total, err := s.dao.GetGoodsStatisticsCount(caseids, typeid, name)
+	if err != nil {
+		utils.LogError("获取商品统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品统计数据失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+// GetGoodsOrdersStatistics 获取商品订单统计信息
+func (s *StatisticsServ) GetGoodsOrdersStatistics(status, usertype, caseids, begindate, enddate string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+
+	if caseids == "" {
+		return nil, errors.New("请先选择案场信息")
+	}
+
+	list, err := s.dao.GetGoodsOrderStatistics(status, usertype, caseids, begindate, enddate, page, pageSize)
+	if err != nil {
+		utils.LogError("获取商品订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品订单统计数据失败")
+	}
+	total, err := s.dao.GetGoodsOrderStatisticsCount(status, usertype, caseids, begindate, enddate)
+	if err != nil {
+		utils.LogError("获取商品订单统计数据失败: " + err.Error())
+		return nil, errors.New("获取商品订单统计数据失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}