vip卡

controllers/vipcard/vipcard.go

@@ -6,8 +6,8 @@ import (
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/vipcard"
-	"time"
 	"spaceofcheng/services/utils"
+	"time"
 )
 
 // CaseController 信息
@@ -91,10 +91,15 @@ func (c *VipcardController) UserCharge() {
 	if err != nil {
 		c.ResponseError(err)
 	}
-	err = c.dao.CustomerCharge(vipChild, createUser)
+	// 插入客户VIP卡
+	err = c.dao.SaveCustomerVip(vipChild, createUser)
 	if err != nil {
 		c.ResponseError(err)
 	}
+	// err = c.dao.CustomerCharge(vipChild, createUser)
+	// if err != nil {
+	// 	c.ResponseError(err)
+	// }
 	c.ResponseJSON("激活成功")
 
 }
@@ -109,9 +114,8 @@ func (c *VipcardController) GetVipByCode() {
 	c.ResponseJSON(vipChild)
 }
 
-
 // GetVipListExcel 导出VIP 列表
-func (c *VipcardController) GetVipListExcel(){
+func (c *VipcardController) GetVipListExcel() {
 
 	caseids := c.GetString("caseid")
 	if caseids == "" {
@@ -154,7 +158,7 @@ func (c *VipcardController) GetVipListExcel(){
 		statusToString := ""
 		if item.Status == 1 {
 			statusToString = "已激活"
-		}else{
+		} else {
 			statusToString = "未激活"
 		}
 
@@ -173,6 +177,11 @@ func (c *VipcardController) GetVipListExcel(){
 
 }
 
-
-
-
+// GetCustomerVips 获取客户vip卡
+func (c *VipcardController) GetCustomerVips() {
+	vips, err := c.dao.GetCustomerVips()
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(vips)
+}

models/model/ta_vip_card_child.go

@@ -18,4 +18,6 @@ type TaVipCardChild struct {
 	SalesName        string    `xorm:"VARCHAR(50)"`
 	BeginDate        time.Time `xorm:"DATETIME"`
 	EndDate          time.Time `xorm:"DATETIME"`
+	CaseId           string    `xorm:"VARCHAR(64)"`
+	OrgId            string    `xorm:"VARCHAR(64)"`
 }

models/vipcard/vipcard.go

@@ -199,3 +199,43 @@ WHERE
 	err := m.db.Sql(sql).Find(&vipcards)
 	return vipcards, err
 }
+
+// AddCustomerVip 保存客户Vip卡信息
+func (m *VipcardDAO) AddCustomerVip(customerVip model.TaCustomerVip) (*model.TaCustomerVip, error) {
+	customerVip.CreateDate = time.Now()
+	customerVip.CustomerVipId = utils.GetGUID()
+	customerVip.Status = models.STATUS_NORMAL
+	_, err := m.db.Insert(customerVip)
+	return &customerVip, err
+}
+
+// InsertCustomerVipChange 保存客户Vip卡变动
+func (m *VipcardDAO) InsertCustomerVipChange(change model.TaCustomerVipChange) error {
+	change.ChangeId = utils.GetGUID()
+	change.Status = models.STATUS_NORMAL
+	change.CreateDate = time.Now()
+	_, err := m.db.Insert(change)
+	return err
+}
+
+// CustomerVipWithChange 用户vip卡关联变更
+type CustomerVipWithChange struct {
+	model.TaCustomerVip `xorm:"extends"`
+	Changes             []model.TaCustomerVipChange
+}
+
+// GetCustomerVips 获取客户vip卡信息
+func (m *VipcardDAO) GetCustomerVips(customerid string) ([]CustomerVipWithChange, error) {
+	var vips []CustomerVipWithChange
+	sql := `select * from ta_customer_vip where customer_id=? and status>?`
+	err := m.db.Sql(sql, customerid, models.STATUS_DEL).Find(&vips)
+	if err != nil {
+		return nil, err
+	}
+	for inx, vip := range vips {
+		var changes []model.TaCustomerVipChange
+		m.db.Where("customer_vip_id=?", vip.CustomerVipId).And("status>?", models.STATUS_DEL).Find(&changes)
+		vips[inx].Changes = changes
+	}
+	return vips, nil
+}

routers/wechat.go

@@ -11,6 +11,7 @@ import (
 	"spaceofcheng/services/controllers/gymcard"
 	"spaceofcheng/services/controllers/luckdraw"
 	"spaceofcheng/services/controllers/user"
+	"spaceofcheng/services/controllers/vipcard"
 
 	"github.com/astaxie/beego"
 )
@@ -72,6 +73,9 @@ func getWechatRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/card/:id", &card.CardController{}, "post:ReceiveCard"),
 		beego.NSRouter("/channel/card/:id", &card.CardController{}, "post:ChannelReceiveCard"),
 
+		// vip卡
+		beego.NSRouter("/vip", &vipcard.VipcardController{}, "get:GetCustomerVips"),
+
 		// 体检
 		beego.NSRouter("/GetCheckByUser", &bodycheck.BodyCheckController{}, "get:GetCheckByUser"),
 

service/vipcard/vipcard.go

@@ -85,6 +85,10 @@ func (s *VipcardServ) AddVipCard(vipCard model.TaVipCard) (*model.TaVipCard, err
 		vipChild.VipCardId = vipcard.VipCardId
 		vipChild.VipCardChildCode = s.dao.GenerateChildCode()
 		vipChild.Amount = vipCard.CardAmount
+		vipChild.BeginDate = vipCard.BeginDate
+		vipChild.EndDate = vipCard.EndDate
+		vipChild.CaseId = vipCard.CaseId
+		vipChild.OrgId = vipCard.OrgId
 		_, err := s.dao.AddVipChildCard(vipChild)
 		if err != nil {
 			utils.LogError("创建VIP卡失败: " + err.Error())
@@ -103,6 +107,55 @@ func (s *VipcardServ) FindCustomerByTel(tel string) (*model.TaCustomer, error) {
 	return customer, err
 }
 
+// SaveCustomerVip 保存用户vip
+func (s *VipcardServ) SaveCustomerVip(vipchild *model.TaVipCardChild, createUser model.SysUser) error {
+	customer, err := s.cdao.GetCustomerByPhone(vipchild.CustomerTel)
+	if err != nil {
+		utils.LogError("激活失败: " + err.Error())
+		return errors.New("激活失败")
+	}
+	var customerVip = model.TaCustomerVip{
+		CustomerId:     customer.CustomerId,
+		VipCardId:      vipchild.VipCardId,
+		VipCardChildId: vipchild.VipCardChildId,
+		CustomerTel:    customer.Phone,
+		Amount:         vipchild.Amount,
+		BeginDate:      vipchild.BeginDate,
+		EndDate:        vipchild.EndDate,
+		Balance:        vipchild.Amount,
+		CaseId:         vipchild.CaseId,
+		OrgId:          vipchild.OrgId,
+		SalesId:        vipchild.SalesId,
+		SalesName:      vipchild.SalesName,
+	}
+	info, err := s.dao.AddCustomerVip(customerVip)
+	if err != nil {
+		utils.LogError("保存用户vip卡失败: " + err.Error())
+		return errors.New("激活失败")
+	}
+	// vip卡明细操作
+	var change = model.TaCustomerVipChange{
+		CustomerVipId: info.CustomerVipId,
+		CustomerId:    info.CustomerId,
+		OrgId:         info.OrgId,
+		CaseId:        info.CaseId,
+		ChangeType:    models.CONSUME_COINCHG,
+		ChangeSource:  models.ACCSOURCE_RECHARGE,
+		SourceId:      vipchild.VipCardChildId,
+		SourceName:    vipchild.VipCardChildCode,
+		Amount:        info.Amount,
+		FloatType:     models.ACCOUNT_INCOME,
+		CreateUser:    createUser.UserId,
+	}
+	err = s.dao.InsertCustomerVipChange(change)
+	if err != nil {
+		utils.LogError("保存用户vip卡明细信息失败: " + err.Error())
+		return errors.New("激活失败")
+	}
+
+	return err
+}
+
 // CustomerCharge 给用户充值
 func (s *VipcardServ) CustomerCharge(vipchild *model.TaVipCardChild, createUser model.SysUser) error {
 	customer, err := s.cdao.GetCustomerByPhone(vipchild.CustomerTel)
@@ -141,17 +194,26 @@ func (s *VipcardServ) CustomerCharge(vipchild *model.TaVipCardChild, createUser
 	return nil
 }
 
-
 // GetVipChildExcel 获取VIP卡列表
 func (s *VipcardServ) GetVipChildExcel(caseids, cardNo, sellerName, userName string) ([]vipcard.VipChild, error) {
-	
+
 	vipchild, err := s.dao.GetVipCardListExcel(caseids, cardNo, sellerName, userName)
 	if err != nil {
 		utils.LogError("获取VIP卡信息失败: " + err.Error())
 		return nil, errors.New("获取VIP卡信息失败")
 	}
-	
+
 	return vipchild, err
 }
 
+// GetCustomerVips 获取用户vip卡信息
+func (s *VipcardServ) GetCustomerVips() ([]vipcard.CustomerVipWithChange, error) {
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	vips, err := s.dao.GetCustomerVips(customer.CustomerId)
+	if err != nil {
+		utils.LogError("获取VIP卡信息失败: " + err.Error())
+		return nil, errors.New("获取VIP卡信息失败")
+	}
 
+	return vips, err
+}