gym card

models/constant.go

@@ -107,3 +107,11 @@ const (
 	VERIFY_USED    = "used"
 	VERIFY_LATE    = "late"
 )
+
+// 游泳健身卡种类
+const (
+	GYM_CARD_ONCE    = "once"
+	GYM_CARD_MONTH   = "month"
+	GYM_CARD_QUARTER = "quarter"
+	GYM_CARD_YEAR    = "year"
+)

models/gymcard/gymcard.go

@@ -24,9 +24,36 @@ func NewGymcardDAO(ctx *utils.Context) *GymcardDAO {
 		db:  ctx.DB,
 	}
 }
-func (m *GymcardDAO) GetGymcard(caseid string, page, pageSize int) ([]model.TaGymCard, error) {
-	var gymcard []model.TaGymCard
-	sql := `select a.* from ta_gym_card a
+
+type CustomerGym struct {
+	model.TaCustomerGym `xorm:"extends"`
+	CardImageUrl        string
+	CardShareInfo       string
+	CardUseInstruction  string
+	CardUseRule         string
+}
+
+type Gymcard struct {
+	model.TaGymCard    `xorm:"extends"`
+	CardImageUrl       string
+	CardShareInfo      string
+	CardUseInstruction string
+	CardUseRule        string
+}
+
+// GetGymcard 根据案场id获取游泳健身卡列表
+func (m *GymcardDAO) GetGymcard(caseid string, page, pageSize int) ([]Gymcard, error) {
+	var gymcard []Gymcard
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_gym_card a
+	INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+	INNER JOIN ta_card_share c ON a.gym_card_id = c.gym_card_id
 	where a.case_id in('` + strings.Replace(caseid, ",", "','", -1) + `')
 	and  a.status > ` + strconv.Itoa(models.STATUS_DEL)
 	sql += ` order by a.create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
@@ -34,9 +61,41 @@ func (m *GymcardDAO) GetGymcard(caseid string, page, pageSize int) ([]model.TaGy
 	return gymcard, err
 }
 
-func (m *GymcardDAO) GetGymcardById(gymcardId string) (*model.TaGymCard, error) {
-	var gymcard []model.TaGymCard
-	err := m.db.Where("gym_card_id=?", gymcardId).And("status > ?", models.STATUS_DEL).Find(&gymcard)
+// GetGymcardCount 根据案场id获取游泳健身卡数量
+func (m *GymcardDAO) GetGymcardCount(caseid string) (int, error) {
+	var gymcard []Gymcard
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_gym_card a
+	INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+	INNER JOIN ta_card_share c ON a.gym_card_id = c.gym_card_id
+	where a.case_id in('` + strings.Replace(caseid, ",", "','", -1) + `')
+	and  a.status > ` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&gymcard)
+	return len(gymcard), err
+}
+
+// GetGymcardById 根据id获取游泳健身卡详情
+func (m *GymcardDAO) GetGymcardById(gymcardId string) (*Gymcard, error) {
+	var gymcard []Gymcard
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_gym_card a
+	INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+	INNER JOIN ta_card_share c ON a.gym_card_id = c.gym_card_id
+	where a.gym_card_id = '` + gymcardId + `'
+	and  a.status > ` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&gymcard)
 	if err != nil {
 		return nil, err
 	}
@@ -46,16 +105,43 @@ func (m *GymcardDAO) GetGymcardById(gymcardId string) (*model.TaGymCard, error)
 	return nil, nil
 }
 
-func (m *GymcardDAO) AddGymCard(gymcard model.TaGymCard) (*model.TaGymCard, error) {
+// AddGymcard 新增游泳健身卡
+func (m *GymcardDAO) AddGymcard(gymcard model.TaGymCard) (model.TaGymCard, error) {
 	gymcard.GymCardId = utils.GetGUID()
 	gymcard.SentCount = 0
 	gymcard.UsedCount = 0
 	gymcard.Status = models.STATUS_NORMAL
 	gymcard.CreateDate = time.Now()
 	_, err := m.db.Insert(gymcard)
-	return &gymcard, err
+	return gymcard, err
+}
+
+// AddGymcardImg 新增游泳健身卡图片
+func (m *GymcardDAO) AddGymcardImg(gymcardId, imgUrl string) error {
+	var cardImg model.TaCardImage
+	cardImg.CardImageId = utils.GetGUID()
+	cardImg.CardImageUrl = imgUrl
+	cardImg.GymCardId = gymcardId
+	cardImg.Sort = 1
+	cardImg.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(cardImg)
+	return err
+}
+
+// AddGymcardShare 新增游泳健身卡分享信息
+func (m *GymcardDAO) AddGymcardShare(gymcardId, cardShareInfo, cardUseRule, cardUseInstraction string) error {
+	var cardShare model.TaCardShare
+	cardShare.CardShareId = utils.GetGUID()
+	cardShare.GymCardId = gymcardId
+	cardShare.CardShareInfo = cardShareInfo
+	cardShare.CardUseInstruction = cardUseInstraction
+	cardShare.CardUseRule = cardUseRule
+	cardShare.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(cardShare)
+	return err
 }
 
+// DeleteGymcard 删除游泳健身卡
 func (m *GymcardDAO) DeleteGymcard(gymcardId string) error {
 	var gymcard = model.TaGymCard{
 		GymCardId: gymcardId,
@@ -68,6 +154,7 @@ func (m *GymcardDAO) DeleteGymcard(gymcardId string) error {
 	return err
 }
 
+// DeleteCardImg 删除健身卡图片
 func (m *GymcardDAO) DeleteCardImg(gymcardId string) error {
 	var cardImg = model.TaCardImage{
 		GymCardId: gymcardId,
@@ -80,3 +167,146 @@ func (m *GymcardDAO) DeleteCardImg(gymcardId string) error {
 	return err
 
 }
+
+// DeleteCardImg 删除健身卡分享信息
+func (m *GymcardDAO) DeleteCardShare(gymcardId string) error {
+	var cardShare = model.TaCardShare{
+		GymCardId: gymcardId,
+		Status:    models.STATUS_DEL,
+	}
+	var cols = []string{
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("gym_card_id = ?", cardShare.GymCardId).Update(cardShare)
+	return err
+}
+
+// EditGymcardImg 修改健身卡图片
+func (m *GymcardDAO) EditGymcardImg(gymcardId, imgUrl string) error {
+	var cardImg = model.TaCardImage{
+		GymCardId:    gymcardId,
+		CardImageUrl: imgUrl,
+	}
+	var cols = []string{
+		"img_url",
+	}
+	_, err := m.db.Cols(cols...).Where("gym_card_id = ?", cardImg.GymCardId).Update(cardImg)
+	return err
+}
+
+// EditGymcardShare 修改健身卡分享信息
+func (m *GymcardDAO) EditGymcardShare(gymcardId, cardShareInfo, cardUseRule, cardUseInstraction string) error {
+	var cardShare = model.TaCardShare{
+		GymCardId:          gymcardId,
+		CardShareInfo:      cardShareInfo,
+		CardUseRule:        cardUseRule,
+		CardUseInstruction: cardUseInstraction,
+	}
+	var cols = []string{
+		"card_share_info",
+		"card_use_rule",
+		"card_use_instruction",
+	}
+	_, err := m.db.Cols(cols...).Where("gym_card_id = ?", cardShare.GymCardId).Update(cardShare)
+	return err
+}
+
+// SendGymcardToCustomer 新增用户健身卡
+func (m *GymcardDAO) SendGymcardToCustomer(gymcard *model.TaGymCard, customerId string) (*model.TaCustomerGym, error) {
+	var customerGym model.TaCustomerGym
+	customerGym.CustomerGymId = utils.GetGUID()
+	customerGym.CaseId = gymcard.CaseId
+	customerGym.CustomerGymName = gymcard.GymCardName
+	customerGym.CustomerId = customerId
+	customerGym.EndDate = gymcard.EndDate
+	customerGym.GymCardId = gymcard.GymCardId
+	customerGym.GymType = gymcard.GymTypeId
+	customerGym.OrgId = gymcard.OrgId
+	customerGym.ReceiveDate = time.Now()
+	customerGym.StartDate = gymcard.StartDate
+	customerGym.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(customerGym)
+	return &customerGym, err
+}
+
+// UpdateCustomerGym 修改用户卡
+func (m *GymcardDAO) UpdateCustomerGym(customerGym model.TaCustomerGym) error {
+	var cols = []string{
+		"start_date",
+		"end_date",
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("customer_gym_id =?", customerGym.CustomerGymId).Update(customerGym)
+	return err
+}
+
+// AddGymcardUsage 新增用户健身卡使用记录
+func (m *GymcardDAO) AddGymcardUsage(customerGym model.TaCustomerGym) (*model.TaGymCardUsage, error) {
+	var gymcardUsage model.TaGymCardUsage
+	gymcardUsage.CustomerGymId = customerGym.CustomerGymId
+	gymcardUsage.GymCardUsageId = utils.GetGUID()
+	gymcardUsage.UseCaseId = customerGym.CaseId
+	gymcardUsage.UseDate = time.Now()
+	gymcardUsage.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(gymcardUsage)
+	return &gymcardUsage, err
+}
+
+// GetCustomerGymByCustomerId 通过用户id获取用户所有游泳健身卡
+func (m *GymcardDAO) GetCustomerGymByCustomerId(customerId string, page, pageSize int) ([]CustomerGym, error) {
+	var customerGym []CustomerGym
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_customer_gym a
+INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+INNER JOIN ta_card_share C oN a.gym_card_id = c.gym_card_id
+WHERE
+	a.customer_id = '` + customerId + `' and a.status >` + strconv.Itoa(models.STATUS_DEL)
+	sql += ` order by a.create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&customerGym)
+	return customerGym, err
+}
+
+// GetCustomerGymCountByCustomerId 通过用户id获取用户所有游泳健身卡数量
+func (m *GymcardDAO) GetCustomerGymCountByCustomerId(customerId string) (int, error) {
+	var customerGym []CustomerGym
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_customer_gym a
+INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+INNER JOIN ta_card_share C oN a.gym_card_id = c.gym_card_id
+WHERE
+	a.customer_id = '` + customerId + `' and a.status >` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&customerGym)
+	return len(customerGym), err
+
+}
+
+// GetCustomerGymById 根据id获取用户健身卡详情
+func (m *GymcardDAO) GetCustomerGymById(customerCardId string) (CustomerGym, error) {
+	var customerGym []CustomerGym
+	sql := `SELECT
+	a.*,
+	b.card_image_url,
+	c.card_share_info,
+	c.card_use_instruction,
+	c.card_use_rule
+FROM
+	ta_customer_gym a
+INNER JOIN ta_card_image b ON a.gym_card_id = b.gym_card_id
+INNER JOIN ta_card_share C oN a.gym_card_id = c.gym_card_id
+WHERE
+	a.customer_gym_id = '` + customerCardId + `' and a.status >` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&customerGym)
+	return customerGym[0], err
+}

models/model/ta_card_image.go

@@ -3,7 +3,6 @@ package model
 type TaCardImage struct {
 	CardImageId  string `xorm:"not null pk VARCHAR(64)"`
 	GymCardId    string `xorm:"VARCHAR(64)"`
-	CardId       string `xorm:"VARCHAR(64)"`
 	CardImageUrl string `xorm:"TEXT"`
 	Status       int    `xorm:"SMALLINT(6)"`
 	Sort         int    `xorm:"INT(11)"`

models/model/ta_card_share.go

@@ -3,7 +3,6 @@ package model
 type TaCardShare struct {
 	CardShareId        string `xorm:"not null pk VARCHAR(64)"`
 	GymCardId          string `xorm:"VARCHAR(64)"`
-	CardId             string `xorm:"VARCHAR(64)"`
 	CardShareInfo      string `xorm:"TEXT"`
 	CardUseRule        string `xorm:"TEXT"`
 	CardUseInstruction string `xorm:"TEXT"`

models/model/ta_customer_gym.go

@@ -13,7 +13,6 @@ type TaCustomerGym struct {
 	EndDate         time.Time `xorm:"DATETIME"`
 	Status          int       `xorm:"SMALLINT(6)"`
 	ReceiveDate     time.Time `xorm:"DATETIME"`
-	VerifyDate      time.Time `xorm:"DATETIME"`
 	GymType         string    `xorm:"VARCHAR(64)"`
 	CaseId          string    `xorm:"VARCHAR(64)"`
 	OrgId           string    `xorm:"VARCHAR(64)"`

models/model/ta_gym_card.go

@@ -5,24 +5,19 @@ import (
 )
 
 type TaGymCard struct {
-	GymCardId        string    `xorm:"not null pk VARCHAR(64)"`
-	GymTypeId        string    `xorm:"VARCHAR(64)"`
-	GymCardName      string    `xorm:"VARCHAR(128)"`
-	Price            float32   `xorm:"FLOAT(8,2)"`
-	VideoUrl         string    `xorm:"TEXT"`
-	CoverUrl         string    `xorm:"TEXT"`
-	SentType         int       `xorm:"comment('0案场 1渠道') SMALLINT(6)"`
-	StartDate        time.Time `xorm:"DATETIME"`
-	EndDate          time.Time `xorm:"DATETIME"`
-	ValidDays        int       `xorm:"INT(11)"`
-	ShareDescription string    `xorm:"VARCHAR(255)"`
-	RuleDescription  string    `xorm:"VARCHAR(255)"`
-	UseDescription   string    `xorm:"TEXT"`
-	TotalCount       int       `xorm:"INT(11)"`
-	SentCount        int       `xorm:"INT(11)"`
-	UsedCount        int       `xorm:"INT(11)"`
-	Status           int       `xorm:"comment('0未发布 1已发布 2已过期') SMALLINT(6)"`
-	CaseId           string    `xorm:"VARCHAR(64)"`
-	OrgId            string    `xorm:"VARCHAR(64)"`
-	CreateDate       time.Time `xorm:"DATETIME"`
+	GymCardId   string    `xorm:"not null pk VARCHAR(64)"`
+	GymTypeId   string    `xorm:"VARCHAR(64)"`
+	GymCardName string    `xorm:"VARCHAR(128)"`
+	Price       float32   `xorm:"FLOAT(8,2)"`
+	SentType    int       `xorm:"comment('0案场 1渠道') SMALLINT(6)"`
+	StartDate   time.Time `xorm:"DATETIME"`
+	EndDate     time.Time `xorm:"DATETIME"`
+	ValidDays   int       `xorm:"INT(11)"`
+	TotalCount  int       `xorm:"INT(11)"`
+	SentCount   int       `xorm:"INT(11)"`
+	UsedCount   int       `xorm:"INT(11)"`
+	Status      int       `xorm:"comment('0未发布 1已发布 2已过期') SMALLINT(6)"`
+	CaseId      string    `xorm:"VARCHAR(64)"`
+	OrgId       string    `xorm:"VARCHAR(64)"`
+	CreateDate  time.Time `xorm:"DATETIME"`
 }

models/verify/verify.go

@@ -28,11 +28,7 @@ type MyCourse struct {
 	CourseName                   string
 	DetailName                   string
 	LocationName                 string
-<<<<<<< HEAD
-	CostomerId                   string
-=======
 	CustomerId                   string
->>>>>>> 802c15c146846cf0ddc7fc7e0273f2683cea90f4
 }
 
 func (m *VerifyDAO) GetCustomerCourseDetailById(id string) (*model.TaCustomerCourseDetail, error) {
@@ -110,13 +106,8 @@ func (m *VerifyDAO) GetCustomerCourseListByTel(tel, caseid string, page, pageSiz
 	d.case_name,
 	b.course_name,
 	c.detail_name,
-<<<<<<< HEAD
-	f.location_name,
-	b.customer_id
-=======
 	b.customer_id,
 	f.location_name
->>>>>>> 802c15c146846cf0ddc7fc7e0273f2683cea90f4
 	FROM
 	ta_customer_course_detail a
 	INNER JOIN ta_customer_course b ON a.customer_course_id = b.customer_course_id

service/gymcard/gymcard.go

@@ -0,0 +1,110 @@
+package gymcard
+
+import (
+	"errors"
+	"spaceofcheng/services/models/gymcard"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+)
+
+// GymcardServ 系统处理
+type GymcardServ struct {
+	ctx *utils.Context
+	dao *gymcard.GymcardDAO
+}
+
+// NewGymcardServ 初始化
+func NewGymcardServ(ctx *utils.Context) *GymcardServ {
+	return &GymcardServ{
+		ctx: ctx,
+		dao: gymcard.NewGymcardDAO(ctx),
+	}
+}
+func (s *GymcardServ) GetGymcardList(caseid string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	gymcard, err := s.dao.GetGymcard(caseid, page, pageSize)
+	if err != nil {
+		utils.LogError("获取健身卡列表失败：" + err.Error())
+		return nil, errors.New("获取健身卡列表失败")
+	}
+	total, err := s.dao.GetGymcardCount(caseid)
+	if err != nil {
+		utils.LogError("获取健身卡列表失败：" + err.Error())
+		return nil, errors.New("获取健身卡列表失败")
+	}
+	return map[string]interface{}{
+		"list":     gymcard,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+func (s *GymcardServ) GetCustomerGymBycustomerId(customerId string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	customerGym, err := s.dao.GetCustomerGymByCustomerId(customerId, page, pageSize)
+	if err != nil {
+		utils.LogError("获取健身卡列表失败：" + err.Error())
+		return nil, errors.New("获取健身卡列表失败")
+	}
+	total, err := s.dao.GetCustomerGymCountByCustomerId(customerId)
+	if err != nil {
+		utils.LogError("获取健身卡列表失败：" + err.Error())
+		return nil, errors.New("获取健身卡列表失败")
+	}
+	return map[string]interface{}{
+		"list":     customerGym,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+func (s *GymcardServ) GetGymcardDetailByIdZ(gymcardId string) (*gymcard.Gymcard, error) {
+	gymcard, err := s.dao.GetGymcardById(gymcardId)
+	if err != nil {
+		utils.LogError("获取健身卡详情失败" + err.Error())
+		return nil, errors.New("获取健身卡详情失败")
+	}
+	return gymcard, nil
+}
+
+func (s *GymcardServ) SaveGymcard(newGym gymcard.Gymcard) (*gymcard.Gymcard, error) {
+	var newGymCard model.TaGymCard
+	var cardGym model.TaGymCard
+	var err error
+	if newGym.GymCardId == "" {
+		newGymCard = newGym.TaGymCard
+		cardGym, err = s.dao.AddGymcard(newGymCard)
+		err = s.dao.AddGymcardImg(newGym.GymCardId, newGym.CardImageUrl)
+		newGym.TaGymCard = cardGym
+		err = s.dao.AddGymcardShare(newGym.GymCardId, newGym.CardShareInfo, newGym.CardUseRule, newGym.CardUseInstruction)
+	} else {
+		err = s.dao.EditGymcardImg(newGym.GymCardId, newGym.CardImageUrl)
+		err = s.dao.EditGymcardShare(newGym.GymCardId, newGym.CardShareInfo, newGym.CardUseRule, newGym.CardUseInstruction)
+	}
+	if err != nil {
+		utils.LogError("保存健身卡信息失败" + err.Error())
+		return nil, errors.New("保存健身卡信息失败")
+	}
+	return &newGym, nil
+}
+
+func (s *GymcardServ) SendGymCardToUser(customerId, gymcardId string) (*model.TaCustomerGym, error) {
+	var customerGym *model.TaCustomerGym
+	gymCard, err := s.dao.GetGymcardById(gymcardId)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+	customerGym, err = s.dao.SendGymcardToCustomer(gymCard, customerId)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return nil, errors.New("发送游泳健身卡给客户失败")
+	}
+	return customerGym, nil
+
+}