营销活动

controllers/user/user.go

@@ -79,8 +79,8 @@ func (c *UserController) GetUserList() {
 func (c *UserController) GetUserTypes() {
 	// cases := c.Context.Get("cases").([]model.SysUserCase)
 	// caseIDs := c.GetCaseIDs(cases)
-	orgid := c.GetString(":org")
-	usertypes, err := c.dao.GetUserTypes(orgid)
+	org := c.Context.Get("org").(model.SysOrg)
+	usertypes, err := c.dao.GetUserTypes(org.OrgId)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/verify/verify.go

@@ -0,0 +1,95 @@
+package verify
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/verify"
+)
+
+// CaseController 信息
+type VerifyController struct {
+	dao *verify.VerifyServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *VerifyController) Constructor() {
+	c.dao = verify.NewVerifyServ(c.Context)
+}
+
+// GetCustomerCourseDetailListById 根据id获取我的课程详情
+func (c *VerifyController) GetCustomerCourseDetailListById() {
+	customerCourseId := c.GetString(":customerCourseId")
+	caseid := c.GetString("caseid")
+	if caseid == "" {
+		caseinfo := c.Context.Get("currentCase").(model.SysUserCase)
+		caseid = caseinfo.CaseId
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetCustomerCourseDetailById(customerCourseId, caseid, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+
+}
+
+// GetCustomerCourseDetailListBytel 根据手机号获取我的课程详情id
+func (c *VerifyController) GetCustomerCourseDetailListBytel() {
+	caseid := c.GetString("caseid")
+	if caseid == "" {
+		caseinfo := c.Context.Get("currentCase").(model.SysUserCase)
+		caseid = caseinfo.CaseId
+	}
+	tel := c.GetString(":tel")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetCustomerCourseDetailByTel(tel, caseid, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+
+}
+
+// VerifyCourse核销我的课程详情
+func (c *VerifyController) VerifyCourse() {
+	sysUser := c.Context.Get("user").(model.SysUser)
+	userId := sysUser.UserId
+	customerDetailId := c.GetString(":customerDetailId")
+	customerCourseDetail, err := c.dao.GetCustomerCourseDetailByDetailId(customerDetailId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	customerCourse, err := c.dao.GetCustomerCourseByDetailId(customerCourseDetail.CustomerDetailId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	if customerCourse.CourseObtaimType == "card" {
+		customerCard, err := c.dao.GetCustomerCardByDetailId(customerCourseDetail.CustomerDetailId)
+		if err != nil {
+			c.ResponseError(err)
+		}
+		if customerCard.VerifyStatus == "usable" {
+			customerCard.VerifyStatus = "used"
+			err := c.dao.UpdateCustomerCard(customerCard)
+			if err != nil {
+				c.ResponseError(err)
+			}
+		}
+	}
+	err = c.dao.UpdateCustomerCourse(customerCourse)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	err = c.dao.UpdateCustomerCourseDetail(customerCourseDetail, userId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("核销成功")
+
+}

models/course/course.go

@@ -224,36 +224,52 @@ func (m *CourseDAO) GetCourseDetail(courseid string) ([]model.TaCourseDetail, er
 	return details, err
 }
 
+// DetailInfo 排课记录
+type DetailInfo struct {
+	model.TaCourseDetail `xorm:"extends"`
+	CourseStatus         int
+	CourseName           string
+	CaseName             string
+	CaseAddress          string
+}
+
 // 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)
+func (m *CourseDAO) GetDetails(caseid, date string) ([]DetailInfo, error) {
+	var details []DetailInfo
+
+	sql := `select a.*,b.course_name,b.status as course_status,c.case_name,c.case_address from ta_course_detail a 
+	inner join ta_course b on a.course_id=b.course_id 
+	inner join sys_case c on a.case_id=c.case_id where a.status>` + strconv.Itoa(models.STATUS_DEL) + `
+	and b.status>` + strconv.Itoa(models.STATUS_DEL) + ` and a.case_id='` + caseid + `' and DATE_FORMAT(a.begin_date,'%Y-%m') = '` + date + `'`
+	err := m.db.Sql(sql).Find(&details)
+
+	// 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")
+	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) + "')")
+		dao.And("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
 	}
-	err := dao.OrderBy("create_date").Limit(pageSize, (page-1)*pageSize).Find(&courses)
+	err := dao.Desc("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")
+	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) + "')")
+		dao.And("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
 	}
 	err := dao.Find(&courses)
 	return len(courses), err

models/course/tag.go

@@ -5,6 +5,7 @@ import (
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
+	"time"
 )
 
 // GetTagsList 获取标签列表
@@ -31,6 +32,7 @@ func (m *CourseDAO) GetTagsCount(orgid string) (int, error) {
 func (m *CourseDAO) AddCourseTag(tag model.TdCourseTag) (*model.TdCourseTag, error) {
 	tag.TagId = utils.GetGUID()
 	tag.Status = models.STATUS_NORMAL
+	tag.CreateDate = time.Now()
 	_, err := m.db.Insert(tag)
 	return &tag, err
 }

models/model/ta_customer_card.go

@@ -11,9 +11,6 @@ type TaCustomerCard struct {
 	CustomerId       string    `xorm:"VARCHAR(64)"`
 	StartDate        time.Time `xorm:"DATETIME"`
 	EndDate          time.Time `xorm:"DATETIME"`
-	CourseNum        int       `xorm:"INT(11)"`
-	JoinNum          int       `xorm:"INT(11)"`
-	CardState        string    `xorm:"VARCHAR(64)"`
 	Status           int       `xorm:"SMALLINT(6)"`
 	ReceiveDate      time.Time `xorm:"DATETIME"`
 	VerifyDate       time.Time `xorm:"DATETIME"`

models/model/ta_customer_course.go

@@ -11,6 +11,7 @@ type TaCustomerCourse struct {
 	OrgId            string    `xorm:"VARCHAR(64)"`
 	CaseId           string    `xorm:"VARCHAR(64)"`
 	CourseName       string    `xorm:"VARCHAR(50)"`
+	LocationId       string    `xorm:"VARCHAR(64)"`
 	Price            string    `xorm:"DECIMAL(8,2)"`
 	CourseNum        int       `xorm:"INT(11)"`
 	JoinNum          int       `xorm:"INT(11)"`

models/verify/verify.go

@@ -1,11 +1,9 @@
 package verify
 
 import (
-	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
-	"time"
 
 	"github.com/go-xorm/xorm"
 )
@@ -24,267 +22,170 @@ func NewVerifyDAO(ctx *utils.Context) *VerifyDAO {
 	}
 }
 
-type verifyCourse struct {
-	targetId     string
-	caseId       string
-	caseName     string
-	locationName string
-	courseName   string
-	detailName   string
-	beginDate    time.Time
-	endDate      time.Time
-	courseType   string
+type MyCourse struct {
+	model.TaCustomerCourseDetail `xorm:"extends"`
+	CaseName                     string
+	CourseName                   string
+	DetailName                   string
+	LocationName                 string
 }
 
-func (m *VerifyDAO) GetExperienceCardVerifyList(customerCardId string, page, pageSize int) ([]verifyCourse, error) {
-	var course []verifyCourse
-	sql := `SELECT
-	a.target_id,
-	g.case_name,
-	c.card_id,
-	f.location_name,
-	e.course_name,
-	d.detail_name,
-	d.begin_date,
-	d.end_date,
-	'card' as courseType 
-FROM
-	ta_coupon_card_target a
-	INNER JOIN ta_coupon_card b ON a.card_id = b.card_id
-	INNER JOIN ta_customer_card c ON c.card_id = b.card_id
-	INNER JOIN ta_course_detail d ON d.detail_id = a.detail_id
-	INNER JOIN ta_course e ON d.course_id = e.course_id
-	INNER JOIN td_cms_image_location f ON e.location_id = f.location_id
-	INNER JOIN sys_case g ON g.case_id = c.case_id 
-WHERE
-	DATE_FORMAT( d.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW(), '%Y-%m-%d' )
-	AND c.customer_card_id = ` + customerCardId
-	sql = sql + " limit  " + strconv.Itoa((page-1)*pageSize) + ", " + strconv.Itoa(pageSize)
-	err := m.db.Sql(sql).Find(&course)
-	return course, err
+func (m *VerifyDAO) GetCustomerCourseDetailById(id string) (*model.TaCustomerCourseDetail, error) {
+	var customerCourseDerail []model.TaCustomerCourseDetail
+	err := m.db.Where("customer_detail_id =?", id).Find(&customerCourseDerail)
+	if err != nil {
+		return nil, err
+	}
+	if len(customerCourseDerail) > 0 {
+		return &customerCourseDerail[0], nil
+	}
+	return nil, nil
 }
 
-func (m *VerifyDAO) GetExperienceCardVerifyListCount(customerCardId string) (int, error) {
-	var course []verifyCourse
+// GetCustomerCourseList 根据我的课程id获取我的课程详情
+func (m *VerifyDAO) GetCustomerCourseList(customerCourseId, caseid string, page int, pageSize int) ([]MyCourse, error) {
+	var courseList []MyCourse
 	sql := `SELECT
-	a.target_id,
-	g.case_name,
-	c.card_id,
-	f.location_name,
-	e.course_name,
-	d.detail_name,
-	d.begin_date,
-	d.end_date,
-	'card' as courseType 
-FROM
-	ta_coupon_card_target a
-	INNER JOIN ta_coupon_card b ON a.card_id = b.card_id
-	INNER JOIN ta_customer_card c ON c.card_id = b.card_id
-	INNER JOIN ta_course_detail d ON d.detail_id = a.detail_id
-	INNER JOIN ta_course e ON d.course_id = e.course_id
-	INNER JOIN td_cms_image_location f ON e.location_id = f.location_id
-	INNER JOIN sys_case g ON g.case_id = c.case_id 
-WHERE
-	DATE_FORMAT( d.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW(), '%Y-%m-%d' )
-	AND c.customer_card_id = ` + customerCardId
-	err := m.db.Sql(sql).Find(&course)
-	return len(course), err
+	a.*,
+	d.case_name,
+	b.course_name,	
+	c.detail_name,
+	f.location_name
+	FROM
+	ta_customer_course_detail a
+	INNER JOIN ta_customer_course b ON a.customer_course_id = b.customer_course_id
+	INNER JOIN ta_course_detail c ON c.detail_id = a.detail_id
+	INNER JOIN sys_case d ON d.case_id = a.case_id
+	LEFT JOIN td_cms_image_location f on b.location_id=f.location_id
+	WHERE DATE_FORMAT(a.start_date,'%Y-%m-%d') = DATE_FORMAT(NOW(),'%Y-%m-%d')
+	AND a.customer_course_id = '` + customerCourseId + `'
+	and b.case_id = '` + caseid + `'`
+	sql = sql + " limit " + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&courseList)
+	return courseList, err
 }
 
-func (m *VerifyDAO) GetOrderCourseList(courseOrderId string, page, pageSize int) ([]verifyCourse, error) {
-	var course []verifyCourse
+// GetCustomerCourseListCount 根据我的课程id获取我的课程详情数量
+func (m *VerifyDAO) GetCustomerCourseListCount(customerCourseId, caseid string) (int, error) {
+	var courseList []MyCourse
 	sql := `SELECT
-	a.orders_detail_id AS target_id,
-	b.case_id,
-	f.case_name,
-	e.location_name,
-	c.course_name,
-	d.detail_name,
-	a.begin_date,
-	a.end_date,
-	'order' as courseType
-FROM
-	ta_course_orders_detail a
-	INNER JOIN ta_course_orders b ON a.orders_id = b.orders_id
-	INNER JOIN ta_course c ON b.course_id = c.course_id
-	INNER JOIN ta_course_detail d ON a.course_detail_id = d.detail_id
-	INNER JOIN td_cms_image_location e ON e.location_id = c.location_id
-	INNER JOIN sys_case f ON b.case_id = f.case_id 
-WHERE
-	DATE_FORMAT( a.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW( ), '%Y-%m-%d' )
-	AND b.orders_id = ` + courseOrderId
-	sql = sql + " limit  " + strconv.Itoa((page-1)*pageSize) + ", " + strconv.Itoa(pageSize)
-	err := m.db.Sql(sql).Find(&course)
-	return course, err
-
+	a.*,
+	d.case_name,
+	b.course_name,	
+	c.detail_name
+	FROM
+	ta_customer_course_detail a
+	INNER JOIN ta_customer_course b ON a.customer_course_id = b.customer_course_id
+	INNER JOIN ta_course_detail c ON c.detail_id = a.detail_id
+	INNER JOIN sys_case d ON d.case_id = a.case_id
+	WHERE DATE_FORMAT(a.start_date,'%Y-%m-%d') = DATE_FORMAT(NOW(),'%Y-%m-%d')
+	AND a.customer_course_id = '` + customerCourseId + `'
+	and b.case_id = '` + caseid + `'`
+	err := m.db.Sql(sql).Find(&courseList)
+	return len(courseList), err
 }
 
-func (m *VerifyDAO) GetOrderCourseListCount(courseOrderId string) (int, error) {
-	var course []verifyCourse
-	sql := `SELECT
-	a.orders_detail_id AS target_id,
-	b.case_id,
-	f.case_name,
-	e.location_name,
-	c.course_name,
-	d.detail_name,
-	a.begin_date,
-	a.end_date,
-	'order' as courseType
-FROM
-	ta_course_orders_detail a
-	INNER JOIN ta_course_orders b ON a.orders_id = b.orders_id
-	INNER JOIN ta_course c ON b.course_id = c.course_id
-	INNER JOIN ta_course_detail d ON a.course_detail_id = d.detail_id
-	INNER JOIN td_cms_image_location e ON e.location_id = c.location_id
-	INNER JOIN sys_case f ON b.case_id = f.case_id 
-WHERE
-	DATE_FORMAT( a.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW( ), '%Y-%m-%d' )
-	AND b.orders_id = ` + courseOrderId
-	err := m.db.Sql(sql).Find(&course)
-	return len(course), err
+// UpdateCustomerCourseDetail 更新我的课程详情
+func (m *VerifyDAO) UpdateCustomerCourseDetail(customerCourse *model.TaCustomerCourseDetail) error {
+	var cols = []string{
+		"verify_status",
+		"verify_date",
+		"verify_user",
+	}
+	_, err := m.db.Cols(cols...).Where("customer_detail_id=?", customerCourse.CustomerDetailId).Update(customerCourse)
+	return err
 }
 
-func (m *VerifyDAO) GetCourseListByTel(tel string, page, pageSize int) ([]verifyCourse, error) {
-	var course []verifyCourse
+// GetCustomerCourseListByTel 根据客户电话获取我的课程详情
+func (m *VerifyDAO) GetCustomerCourseListByTel(tel, caseid string, page, pageSize int) ([]MyCourse, error) {
+	var courseList []MyCourse
 	sql := `SELECT
-	a.target_id,
-	g.case_name,
-	c.card_id,
-	f.location_name,
-	e.course_name,
-	d.detail_name,
-	d.begin_date,
-	d.end_date,
-	'card' as courseType 
-FROM
-	ta_coupon_card_target a
-	INNER JOIN ta_coupon_card b ON a.card_id = b.card_id
-	INNER JOIN ta_customer_card c ON c.card_id = b.card_id
-	INNER JOIN ta_course_detail d ON d.detail_id = a.detail_id
-	INNER JOIN ta_course e ON d.course_id = e.course_id
-	INNER JOIN td_cms_image_location f ON e.location_id = f.location_id
-	INNER JOIN sys_case g ON g.case_id = c.case_id 
-	INNER JOIN ta_customer h ON c.customer_id = h.customer_id
-WHERE
-	DATE_FORMAT( d.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW(), '%Y-%m-%d' )
-	AND h.phone = ` + tel + `
-	union all
-	SELECT
-	a.orders_detail_id AS target_id,
-	b.case_id,
-	f.case_name,
-	e.location_name,
-	c.course_name,
-	d.detail_name,
-	a.begin_date,
-	a.end_date,
-	'order' as courseType
-FROM
-	ta_course_orders_detail a
-	INNER JOIN ta_course_orders b ON a.orders_id = b.orders_id
-	INNER JOIN ta_course c ON b.course_id = c.course_id
-	INNER JOIN ta_course_detail d ON a.course_detail_id = d.detail_id
-	INNER JOIN td_cms_image_location e ON e.location_id = c.location_id
-	INNER JOIN sys_case f ON b.case_id = f.case_id 
-	INNER JOIN ta_customer g ON b.customer_id = g.customer_id
-WHERE
-	DATE_FORMAT( a.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW( ), '%Y-%m-%d' )
-	AND g.phone = ` + tel
-	sql = sql + " limit  " + strconv.Itoa((page-1)*pageSize) + ", " + strconv.Itoa(pageSize)
-	err := m.db.Sql(sql).Find(&course)
-	return course, err
+	a.*,
+	d.case_name,
+	b.course_name,
+	c.detail_name
+	FROM
+	ta_customer_course_detail a
+	INNER JOIN ta_customer_course b ON a.customer_course_id = b.customer_course_id
+	INNER JOIN ta_course_detail c ON c.detail_id = a.detail_id
+	INNER JOIN sys_case d ON d.case_id = a.case_id
+	LEFT JOIN td_cms_image_location f on b.location_id=f.location_id
+	WHERE DATE_FORMAT(a.start_date,'%Y-%m-%d') = DATE_FORMAT(NOW(),'%Y-%m-%d')
+	AND e.phone = '` + tel + `'
+	and b.case_id='` + caseid + `'`
+	sql = sql + " limit " + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&courseList)
+	return courseList, err
 }
 
-func (m *VerifyDAO) GetCourseListByTelCount(tel string) (int, error) {
-	var course []verifyCourse
+// GetCustomerCourseListByTelCount 根据客户电话获取我的课程详情数量
+func (m *VerifyDAO) GetCustomerCourseListByTelCount(tel, caseid string) (int, error) {
+	var courseList []MyCourse
 	sql := `SELECT
-	a.target_id,
-	g.case_name,
-	c.card_id,
-	f.location_name,
-	e.course_name,
-	d.detail_name,
-	d.begin_date,
-	d.end_date,
-	'card' as courseType 
-FROM
-	ta_coupon_card_target a
-	INNER JOIN ta_coupon_card b ON a.card_id = b.card_id
-	INNER JOIN ta_customer_card c ON c.card_id = b.card_id
-	INNER JOIN ta_course_detail d ON d.detail_id = a.detail_id
-	INNER JOIN ta_course e ON d.course_id = e.course_id
-	INNER JOIN td_cms_image_location f ON e.location_id = f.location_id
-	INNER JOIN sys_case g ON g.case_id = c.case_id 
-	INNER JOIN ta_customer h ON c.customer_id = h.customer_id
-WHERE
-	DATE_FORMAT( d.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW(), '%Y-%m-%d' )
-	AND h.phone = ` + tel + `
-	union all
-	SELECT
-	a.orders_detail_id AS target_id,
-	b.case_id,
-	f.case_name,
-	e.location_name,
-	c.course_name,
-	d.detail_name,
-	a.begin_date,
-	a.end_date,
-	'order' as courseType
+	a.*,
+	d.case_name,
+	b.course_name,
+	c.detail_name
 FROM
-	ta_course_orders_detail a
-	INNER JOIN ta_course_orders b ON a.orders_id = b.orders_id
-	INNER JOIN ta_course c ON b.course_id = c.course_id
-	INNER JOIN ta_course_detail d ON a.course_detail_id = d.detail_id
-	INNER JOIN td_cms_image_location e ON e.location_id = c.location_id
-	INNER JOIN sys_case f ON b.case_id = f.case_id 
-	INNER JOIN ta_customer g ON b.customer_id = g.customer_id
-WHERE
-	DATE_FORMAT( a.begin_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW( ), '%Y-%m-%d' )
-	AND g.phone = ` + tel
-	err := m.db.Sql(sql).Find(&course)
-	return len(course), err
-}
-
-func (m *VerifyDAO) AddExperienceCardVerification(verify model.TaExperienceCardVerification) (*model.TaExperienceCardVerification, error) {
-	verify.ExperienceCardVerifyTime = time.Now()
-	verify.Status = models.STATUS_NORMAL
-	verify.ExperienceCardVerifyId = utils.GetGUID()
-	_, err := m.db.Insert(verify)
-	return &verify, err
+	ta_customer_course_detail a
+	INNER JOIN ta_customer_course b ON a.customer_course_id = b.customer_course_id
+	INNER JOIN ta_course_detail c ON c.detail_id = a.detail_id
+	INNER JOIN sys_case d ON d.case_id = a.case_id
+	INNER JOIN ta_customer e ON b.customer_id = e.customer_id
+	WHERE DATE_FORMAT(a.start_date,'%Y-%m-%d') = DATE_FORMAT(NOW(),'%Y-%m-%d')
+	AND e.phone = '` + tel + `'
+	and b.case_id='` + caseid + `'`
+	err := m.db.Sql(sql).Find(&courseList)
+	return len(courseList), err
 }
 
-func (m *VerifyDAO) updateExperienceCardTarget(verify model.TaCouponCardTarget) error {
+// UpdateCustomerCard 更新客户体验卡
+func (m *VerifyDAO) UpdateCustomerCard(customerCard *model.TaCustomerCard) error {
 	var cols = []string{
-		"card_state",
-	}
-	_, err := m.db.Cols(cols...).Where("target_id=?", verify.TargetId).Update(verify)
-	return err
-}
-
-func (m *VerifyDAO) updateCustomerExperienceCard(verify model.TaCustomerCard) error {
-	var cols = []string{
-		"card_state",
-		"join_num",
 		"verify_date",
+		"verify_status",
 	}
-	_, err := m.db.Cols(cols...).Where("customer_card_id=?", verify.CustomerCardId).Update(verify)
+	_, err := m.db.Cols(cols...).Where("customer_card_id=?", customerCard.CustomerCardId).Update(customerCard)
 	return err
 }
 
-func (m *VerifyDAO) updateCustomerOrderCourse(verify model.TaCourseOrders) error {
+// UpdateCustomerCourse 更新我的课程
+func (m *VerifyDAO) UpdateCustomerCourse(customerCourse *model.TaCustomerCourse) error {
 	var cols = []string{
 		"join_num",
+		"is_done",
 	}
-	_, err := m.db.Cols(cols...).Where("orders_id = ?", verify.OrdersId).Update(verify)
+	_, err := m.db.Cols(cols...).Where("customer_course_id=?", customerCourse.CustomerCourseId).Update(customerCourse)
 	return err
 }
 
-func (m *VerifyDAO) AddOrdersVerification(verify model.TaCourseVerifcation) (*model.TaCourseVerifcation, error) {
-	verify.CreateDate = time.Now()
-	verify.VerifcationId = utils.GetGUID()
-	verify.Status = models.STATUS_NORMAL
-	_, err := m.db.Insert(verify)
-	return &verify, err
+// GetCustomerCardByDetailId 根据我的课程详情ID查询用户体验卡
+func (m *VerifyDAO) GetCustomerCardByDetailId(detailId string) (*model.TaCustomerCard, error) {
+	var customerCard []model.TaCustomerCard
+	sql := `SELECT
+	a.* 
+FROM
+	ta_customer_card a
+	INNER JOIN ta_customer_course b ON a.customer_card_id = b.source_id 
+	
+	INNER JOIN ta_customer_course_detail c ON c.customer_course_id = b.customer_course_id
+WHERE  b.course_obtaim_type = 'card'
+and  c.customer_detail_id = '` + detailId + `'`
+	err := m.db.Sql(sql).Find(&customerCard)
+	return &customerCard[0], err
 
 }
+
+// GetCustomerCourseByDetailId 根据我的课程详情ID查询我的课程
+func (m *VerifyDAO) GetCustomerCourseByDetailId(detailId string) (*model.TaCustomerCourse, error) {
+	var customerCard []model.TaCustomerCourse
+	sql := `SELECT
+	a.* 
+FROM
+	ta_customer_course a
+	INNER JOIN ta_customer_course_detail b ON a.customer_course_id = b.customer_course_id 
+WHERE
+	b.customer_detail_id = '` + detailId + `'`
+	err := m.db.Sql(sql).Find(&customerCard)
+	return &customerCard[0], err
+}

routers/common.go

@@ -10,6 +10,7 @@ import (
 	"spaceofcheng/services/controllers/message"
 	"spaceofcheng/services/controllers/system"
 	"spaceofcheng/services/controllers/user"
+	"spaceofcheng/services/controllers/verify"
 	"spaceofcheng/services/controllers/vipcard"
 	"spaceofcheng/services/controllers/marketing"
 
@@ -152,6 +153,11 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/vipcard", &vipcard.VipcardController{}, "post:AddVipCard"),
 		beego.NSRouter("/vipcard/:vipCardChildCode", &vipcard.VipcardController{}, "put:UserCharge"),
 
+		// courseVerify 核销课程
+		beego.NSRouter("/verify/course/code/:customerCourseId", &verify.VerifyController{}, "get:GetCustomerCourseDetailListById"),
+		beego.NSRouter("/verify/course/tel/:tel", &verify.VerifyController{}, "get:GetCustomerCourseDetailListBytel"),
+		beego.NSRouter("/verify/course/:customerDetailId", &verify.VerifyController{}, "put:VerifyCourse"),
+
 		// role 角色
 		beego.NSRouter("/role", &system.RoleController{}, "get:GetRoleList"),
 		beego.NSRouter("/role/:roleid", &system.RoleController{}, "get:GetRoleByID"),
@@ -172,7 +178,7 @@ func getCommonRoutes() beego.LinkNamespace {
 		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("/course/:courseid/unpublic", &course.CourseController{}, "put:CourseUnPublic"),
 		beego.NSRouter("/courseimg/:courseid", &course.CourseController{}, "get:GetCourseImgs"),
 		beego.NSRouter("/courseimg", &course.CourseController{}, "post:SaveCourseImg"),
 		beego.NSRouter("/courseimg", &course.CourseController{}, "put:SaveCourseImg"),

service/course/course.go

@@ -1,446 +1,443 @@
-package course
-
-import (
-	"spaceofcheng/services/models"
-	"spaceofcheng/services/models/cases"
-	"spaceofcheng/services/models/course"
-	"spaceofcheng/services/models/customer"
-	"spaceofcheng/services/models/model"
-	"spaceofcheng/services/models/system"
-	"spaceofcheng/services/service"
-	"spaceofcheng/services/utils"
-	"strings"
-
-	"github.com/astaxie/beego"
-)
-
-// CourseServ 系统处理
-type CourseServ struct {
-	ctx     *utils.Context
-	dao     *course.CourseDAO
-	casedao *cases.CaseDAO
-	custDAO *customer.CustomerDAO
-	userDAO *system.UserDAO
-}
-
-// NewCourseServ 初始化
-func NewCourseServ(ctx *utils.Context) *CourseServ {
-	return &CourseServ{
-		ctx:     ctx,
-		dao:     course.NewCourseDAO(ctx),
-		casedao: cases.NewCaseDAO(ctx),
-		custDAO: customer.NewCustomerDAO(ctx),
-		userDAO: system.NewUserDAO(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
-	caseinfo, err := s.casedao.GetCaseByID(info.CaseId)
-	if err != nil {
-		return nil, err
-	}
-	info.CaseInfo = caseinfo
-	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 == "" || 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("没有对应的课程！")
-	}
-	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
-}
-
-// 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("课程截止时间必须大于开始时间！")
-	}
-	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 == "" {
-		detail.OrgId = courseinfo.OrgId
-		detail.CaseId = courseinfo.CaseId
-		newinfo, err = s.dao.AddCourseDetail(detail)
-		if err != nil {
-			return nil, err
-		}
-		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
-		}
-	} 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("没有对应的排课信息！")
-	}
-	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
-}
-
-
-
+package course
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/cases"
+	"spaceofcheng/services/models/course"
+	"spaceofcheng/services/models/customer"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/models/system"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+	"strings"
+
+	"github.com/astaxie/beego"
+)
+
+// CourseServ 系统处理
+type CourseServ struct {
+	ctx     *utils.Context
+	dao     *course.CourseDAO
+	casedao *cases.CaseDAO
+	custDAO *customer.CustomerDAO
+	userDAO *system.UserDAO
+}
+
+// NewCourseServ 初始化
+func NewCourseServ(ctx *utils.Context) *CourseServ {
+	return &CourseServ{
+		ctx:     ctx,
+		dao:     course.NewCourseDAO(ctx),
+		casedao: cases.NewCaseDAO(ctx),
+		custDAO: customer.NewCustomerDAO(ctx),
+		userDAO: system.NewUserDAO(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
+	caseinfo, err := s.casedao.GetCaseByID(info.CaseId)
+	if err != nil {
+		return nil, err
+	}
+	info.CaseInfo = caseinfo
+	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 == "" || 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: newInfo.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("没有对应的课程！")
+	}
+	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
+}
+
+// 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) ([]course.DetailInfo, 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("课程截止时间必须大于开始时间！")
+	}
+	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 == "" {
+		detail.OrgId = courseinfo.OrgId
+		detail.CaseId = courseinfo.CaseId
+		newinfo, err = s.dao.AddCourseDetail(detail)
+		if err != nil {
+			return nil, err
+		}
+		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
+		}
+	} 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("没有对应的排课信息！")
+	}
+	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/course/order.go

@@ -245,6 +245,7 @@ func (s *CourseServ) SaveOrder(order *model.TaCourseOrders, coupons []model.TaCo
 		OrgId:            order.OrgId,
 		CaseId:           order.CaseId,
 		CourseName:       course.CourseName,
+		LocationId:       course.LocationId,
 		Price:            course.Price,
 		CourseNum:        course.CourseNum,
 		JoinNum:          0,

service/verify/verify.go

@@ -0,0 +1,160 @@
+package verify
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/customer"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/models/verify"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+	"time"
+
+	"github.com/astaxie/beego"
+)
+
+// CaseServ 系统处理
+type VerifyServ struct {
+	ctx  *utils.Context
+	dao  *verify.VerifyDAO
+	cdao *customer.CustomerDAO
+}
+
+// NewVerifyServ 初始化
+func NewVerifyServ(ctx *utils.Context) *VerifyServ {
+	return &VerifyServ{
+		ctx: ctx,
+		dao: verify.NewVerifyDAO(ctx),
+	}
+}
+
+// GetCustomerCourseDetailById 根据ID获取当日可核销课程
+func (s *VerifyServ) GetCustomerCourseDetailById(id, caseid string, page, pageSize int) (map[string]interface{}, error) {
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseid); err != nil {
+		return nil, err
+	}
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	customerDetail, err := s.dao.GetCustomerCourseList(id, caseid, page, pageSize)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	customerId := customerDetail[0].CustomerId
+	total, err := s.dao.GetCustomerCourseListCount(id, caseid)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	customer, err := s.cdao.GetCustomerByID(customerId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	return map[string]interface{}{
+		"list":         customerDetail,
+		"pagesize":     pageSize,
+		"pagenum":      total,
+		"page":         page,
+		"customerInfo": customer,
+	}, err
+}
+
+// GetCustomerCourseDetailByTel根据电话号码获取当日可核销课程
+func (s *VerifyServ) GetCustomerCourseDetailByTel(tel, caseid string, page, pageSize int) (map[string]interface{}, error) {
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseid); err != nil {
+		return nil, err
+	}
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	customerDetail, err := s.dao.GetCustomerCourseListByTel(tel, caseid, page, pageSize)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	customerId := customerDetail[0].CustomerId
+	total, err := s.dao.GetCustomerCourseListByTelCount(tel, caseid)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	customer, err := s.cdao.GetCustomerByID(customerId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	return map[string]interface{}{
+		"list":         customerDetail,
+		"pagesize":     pageSize,
+		"pagenum":      total,
+		"page":         page,
+		"customerInfo": customer,
+	}, err
+
+}
+func (s *VerifyServ) GetCustomerCourseDetailByDetailId(id string) (*model.TaCustomerCourseDetail, error) {
+	customerDetail, err := s.dao.GetCustomerCourseDetailById(id)
+	return customerDetail, err
+}
+
+// UpdateCustomerCourseDetail更新我的课程详情
+func (s *VerifyServ) UpdateCustomerCourseDetail(customerDetail *model.TaCustomerCourseDetail, userid string) error {
+	var err error
+	customerDetail.VerifyDate = time.Now()
+	customerDetail.VerifyUser = userid
+	if time.Now().After(customerDetail.EndDate) {
+		customerDetail.VerifyStatus = "late"
+	} else {
+		customerDetail.VerifyStatus = "used"
+	}
+	err = s.dao.UpdateCustomerCourseDetail(customerDetail)
+	return err
+}
+
+// UpdateCustomerCard 更新我的体验卡
+func (s *VerifyServ) UpdateCustomerCard(customerCard *model.TaCustomerCard) error {
+	var err error
+	customerCard.VerifyDate = time.Now()
+	err = s.dao.UpdateCustomerCard(customerCard)
+	return err
+
+}
+
+// UpdateCustomerCourse 更新我的课程
+func (s *VerifyServ) UpdateCustomerCourse(customerCourse *model.TaCustomerCourse) error {
+	var err error
+	customerCourse.JoinNum = customerCourse.JoinNum + 1
+	if customerCourse.JoinNum >= customerCourse.CourseNum {
+		customerCourse.IsDone = models.BOOL_TRUE
+	}
+	err = s.dao.UpdateCustomerCourse(customerCourse)
+	return err
+
+}
+
+// GetCustomerCardByDetailId 根据我的课程详情id获取体验卡
+func (s *VerifyServ) GetCustomerCardByDetailId(detailId string) (*model.TaCustomerCard, error) {
+	customerCard, err := s.dao.GetCustomerCardByDetailId(detailId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	return customerCard, err
+}
+
+// GetCustomerCourseByDetailId 根据我的课程详情id获取我的课程
+func (s *VerifyServ) GetCustomerCourseByDetailId(detailId string) (*model.TaCustomerCourse, error) {
+	customerCourse, err := s.dao.GetCustomerCourseByDetailId(detailId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	return customerCourse, err
+}