Merge branch 'dev' of http://git.ycjcjy.com/SpaceOfCheng/services into dev

controllers/gymcard/gymcard.go

@@ -0,0 +1,114 @@
+package gymcard
+
+import (
+	"spaceofcheng/services/controllers"
+	gym "spaceofcheng/services/models/gymcard"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/gymcard"
+)
+
+// GymcardController 信息
+type GymcardController struct {
+	dao *gymcard.GymcardServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *GymcardController) Constructor() {
+	c.dao = gymcard.NewGymcardServ(c.Context)
+}
+
+// GetGymcardList 后台获取游泳健身卡列表
+func (c *GymcardController) GetGymcardList() {
+	caseIDs := c.GetString("caseid")
+	if caseIDs == "" {
+		cases := c.Context.Get("cases").([]model.SysUserCase)
+		caseIDs = c.GetCaseIDs(cases)
+	}
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetGymcardList(caseIDs, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetGymcardListByCustomerId 根据客户id获取C端客户所有的健身卡
+func (c *GymcardController) GetGymcardListByCustomerId() {
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetCustomerGymBycustomerId(page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetGymcardDetailbyId 根据游泳健身卡ID获取游泳健身卡详情
+func (c *GymcardController) GetGymcardDetailbyId() {
+	id := c.GetString("gymcardId")
+	gymcard, err := c.dao.GetGymcardDetailById(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(gymcard)
+}
+
+// GetCustomerGymDetailById 根据客户健身卡ID获取客户健身卡详情
+func (c *GymcardController) GetCustomerGymDetailById() {
+	id := c.GetString("customerGymId")
+	customerGym, err := c.dao.GetCustomerGymDetailById(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customerGym)
+}
+
+// GetCustomerGymByPhone 根据客户手机获取客户可用的游泳健身卡
+func (c *GymcardController) GetCustomerGymByPhone() {
+	phone := c.GetString("phone")
+	customerGym, err := c.dao.GetCustomerGymByPhone(phone)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customerGym)
+}
+
+// SaveGymcard 保存游泳健身卡
+func (c *GymcardController) SaveGymcard() {
+	gymCard := gym.Gymcard{}
+	if err := c.ParseForm(&gymCard); err != nil {
+		c.ResponseError(err)
+	}
+	newGymcard, err := c.dao.SaveGymcard(gymCard)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newGymcard)
+}
+
+// SendGymToCustomer 客户领卡
+func (c *GymcardController) SendGymToCustomer() {
+	gymcardId := c.GetString("gymcardId")
+	sysuserId := c.GetString("sysuserId")
+	customerGym, err := c.dao.SendGymCardToUser(gymcardId, sysuserId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customerGym)
+}
+
+// VerifyCustomerGymcard 核销客户健身卡
+func (c *GymcardController) VerifyCustomerGymcard() {
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseids := c.GetCaseIDs(cases)
+	customerGymId := c.GetString("customerGymId")
+	err := c.dao.UpdateCustomerGym(customerGymId, caseids)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("核销成功")
+}

models/gymcard/gymcard.go

@@ -180,6 +180,15 @@ func (m *GymcardDAO) DeleteCardShare(gymcardId string) error {
 	_, err := m.db.Cols(cols...).Where("gym_card_id = ?", cardShare.GymCardId).Update(cardShare)
 	return err
 }
+func (m *GymcardDAO) EditGymcard(gymcard *model.TaGymCard) error {
+	var cols = []string{
+		"sent_count",
+		"used_count",
+		"status",
+	}
+	_, err := m.db.Cols(cols...).Where("gym_card_id = ?", gymcard.GymCardId).Update(gymcard)
+	return err
+}
 
 // EditGymcardImg 修改健身卡图片
 func (m *GymcardDAO) EditGymcardImg(gymcardId, imgUrl string) error {
@@ -329,3 +338,12 @@ WHERE
 	err := m.db.Sql(sql).Find(&customerGym)
 	return customerGym[0], err
 }
+
+// AddGiveRecord 新增赠送记录
+func (m *GymcardDAO) AddGiveRecord(giveRecord *model.TaCouponGiveRecord) error {
+	giveRecord.CreateDate = time.Now()
+	giveRecord.RecId = utils.GetGUID()
+	giveRecord.GiftType = models.GIVE_GIFT_GYM
+	_, err := m.db.Insert(giveRecord)
+	return err
+}

models/model/ta_coupon_give_record.go

@@ -13,4 +13,5 @@ type TaCouponGiveRecord struct {
 	ToName     string    `xorm:"VARCHAR(255)"`
 	CreateDate time.Time `xorm:"DATETIME"`
 	Remark     string    `xorm:"VARCHAR(255)"`
+	CaseId     string    `xorm:"VARCHAR(64)"`
 }

service/gymcard/gymcard.go

@@ -3,6 +3,7 @@ package gymcard
 import (
 	"errors"
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/gymcard"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service"
@@ -12,17 +13,21 @@ import (
 
 // GymcardServ 系统处理
 type GymcardServ struct {
-	ctx *utils.Context
-	dao *gymcard.GymcardDAO
+	ctx  *utils.Context
+	dao  *gymcard.GymcardDAO
+	cdao *customer.CustomerDAO
 }
 
 // NewGymcardServ 初始化
 func NewGymcardServ(ctx *utils.Context) *GymcardServ {
 	return &GymcardServ{
-		ctx: ctx,
-		dao: gymcard.NewGymcardDAO(ctx),
+		ctx:  ctx,
+		dao:  gymcard.NewGymcardDAO(ctx),
+		cdao: customer.NewCustomerDAO(ctx),
 	}
 }
+
+// GetGymcardList 根据案场id获取健身卡列表
 func (s *GymcardServ) GetGymcardList(caseid string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
 		pageSize = service.PAGENUM
@@ -44,16 +49,19 @@ func (s *GymcardServ) GetGymcardList(caseid string, page, pageSize int) (map[str
 		"page":     page,
 	}, nil
 }
-func (s *GymcardServ) GetCustomerGymBycustomerId(customerId string, page, pageSize int) (map[string]interface{}, error) {
+
+// GetCustomerGymBycustomerId 根据客户id获取客户所有健身卡列表
+func (s *GymcardServ) GetCustomerGymBycustomerId(page, pageSize int) (map[string]interface{}, error) {
+	customer := s.ctx.Get("customer").(model.TaCustomer)
 	if pageSize == 0 {
 		pageSize = service.PAGENUM
 	}
-	customerGym, err := s.dao.GetCustomerGymByCustomerId(customerId, page, pageSize)
+	customerGym, err := s.dao.GetCustomerGymByCustomerId(customer.CustomerId, page, pageSize)
 	if err != nil {
 		utils.LogError("获取健身卡列表失败：" + err.Error())
 		return nil, errors.New("获取健身卡列表失败")
 	}
-	total, err := s.dao.GetCustomerGymCountByCustomerId(customerId)
+	total, err := s.dao.GetCustomerGymCountByCustomerId(customer.CustomerId)
 	if err != nil {
 		utils.LogError("获取健身卡列表失败：" + err.Error())
 		return nil, errors.New("获取健身卡列表失败")
@@ -65,7 +73,19 @@ func (s *GymcardServ) GetCustomerGymBycustomerId(customerId string, page, pageSi
 		"page":     page,
 	}, nil
 }
-func (s *GymcardServ) GetGymcardDetailByIdZ(gymcardId string) (*gymcard.Gymcard, error) {
+
+// GetCustomerGymByPhone 根据用户手机号获取用户健身卡列表
+func (s *GymcardServ) GetCustomerGymByPhone(phone string) ([]gymcard.CustomerGym, error) {
+	customerGym, err := s.dao.GetCustomerGymByPhone(phone)
+	if err != nil {
+		utils.LogError("获取健身卡列表失败：" + err.Error())
+		return nil, errors.New("获取健身卡列表失败")
+	}
+	return customerGym, nil
+}
+
+// GetGymcardDetailById 根据id获取健身卡详情
+func (s *GymcardServ) GetGymcardDetailById(gymcardId string) (*gymcard.Gymcard, error) {
 	gymcard, err := s.dao.GetGymcardById(gymcardId)
 	if err != nil {
 		utils.LogError("获取健身卡详情失败" + err.Error())
@@ -74,6 +94,17 @@ func (s *GymcardServ) GetGymcardDetailByIdZ(gymcardId string) (*gymcard.Gymcard,
 	return gymcard, nil
 }
 
+// GetCustomerGymDetailById 根据id获取客户健身卡详情
+func (s *GymcardServ) GetCustomerGymDetailById(customerGymId string) (*gymcard.CustomerGym, error) {
+	customerGym, err := s.dao.GetCustomerGymById(customerGymId)
+	if err != nil {
+		utils.LogError("获取健身卡详情失败" + err.Error())
+		return nil, errors.New("获取健身卡详情失败")
+	}
+	return &customerGym, err
+}
+
+// SaveGymcard 保存游泳健身卡
 func (s *GymcardServ) SaveGymcard(newGym gymcard.Gymcard) (*gymcard.Gymcard, error) {
 	var newGymCard model.TaGymCard
 	var cardGym model.TaGymCard
@@ -95,28 +126,59 @@ func (s *GymcardServ) SaveGymcard(newGym gymcard.Gymcard) (*gymcard.Gymcard, err
 	return &newGym, nil
 }
 
-func (s *GymcardServ) SendGymCardToUser(customerId, gymcardId string) (*model.TaCustomerGym, error) {
+// SendGymCardToUser 给客户发卡
+func (s *GymcardServ) SendGymCardToUser(gymcardId, sysuserId string) (*model.TaCustomerGym, error) {
 	var customerGym *model.TaCustomerGym
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	var sysuser *model.SysUser
+	var sendRecord *model.TaCouponGiveRecord
 	gymCard, err := s.dao.GetGymcardById(gymcardId)
 	if err != nil {
 		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
 		return nil, errors.New("发送游泳健身卡给客户失败")
 	}
-	customerGym, err = s.dao.SendGymcardToCustomer(&gymCard.TaGymCard, customerId)
+	gymCard.SentCount = gymCard.SentCount + 1
+	customerGym, err = s.dao.SendGymcardToCustomer(&gymCard.TaGymCard, customer.CustomerId)
 	if err != nil {
 		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
 		return nil, errors.New("发送游泳健身卡给客户失败")
 	}
+	sysuser, err = s.cdao.GetUserByID(sysuserId)
+	if err != nil {
+		utils.LogError("记录发健身卡记录失败" + err.Error())
+		return nil, errors.New("记录发健身卡记录失败")
+	}
+	sendRecord.FromId = sysuser.UserId
+	sendRecord.FromName = sysuser.RealName
+	sendRecord.GiftId = gymCard.GymCardId
+	sendRecord.GiftName = gymCard.GymCardName
+	sendRecord.ToId = customer.CustomerId
+	sendRecord.ToName = customer.CustomerName
+	err = s.dao.AddGiveRecord(sendRecord)
+	if err != nil {
+		utils.LogError("记录发健身卡记录失败" + err.Error())
+		return nil, errors.New("记录发健身卡记录失败")
+	}
+	err = s.dao.EditGymcard(&gymCard.TaGymCard)
+	if err != nil {
+		utils.LogError("记录发健身卡记录失败" + err.Error())
+		return nil, errors.New("记录发健身卡记录失败")
+	}
 	return customerGym, nil
 }
 
-func (s *GymcardServ) UpdateCustomerGym(customerGymId string) error {
+// UpdateCustomerGym 核销游泳健身卡
+func (s *GymcardServ) UpdateCustomerGym(customerGymId, caseid string) error {
 	var gymCard *gymcard.Gymcard
 	customerGym, err := s.dao.GetCustomerGymById(customerGymId)
 	if err != nil {
 		utils.LogError("核销游泳健身卡失败" + err.Error())
 		return errors.New("核销游泳健身卡失败")
 	}
+	if caseid != customerGym.CaseId {
+		utils.LogError("核销游泳健身卡失败")
+		return errors.New("您的健身卡不在本案场")
+	}
 	gymCard, err = s.dao.GetGymcardById(customerGym.GymCardId)
 	if err != nil {
 		utils.LogError("核销游泳健身卡失败" + err.Error())
@@ -151,6 +213,11 @@ func (s *GymcardServ) UpdateCustomerGym(customerGymId string) error {
 		utils.LogError("核销游泳健身卡失败" + err.Error())
 		return errors.New("核销游泳健身卡失败")
 	}
+	err = s.dao.EditGymcard(&gymCard.TaGymCard)
+	if err != nil {
+		utils.LogError("核销游泳健身卡失败" + err.Error())
+		return errors.New("核销游泳健身卡失败")
+	}
 	err = s.dao.AddGymcardUsage(customerGym.TaCustomerGym)
 	return err