vip卡

controllers/vipcard/vipcard.go

@@ -0,0 +1,76 @@
+package vipcard
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/vipcard"
+	"time"
+)
+
+// CaseController 信息
+type VipcardController struct {
+	dao *vipcard.VipcardServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *VipcardController) Constructor() {
+	c.dao = vipcard.NewVipcardServ(c.Context)
+}
+
+// GetVipList 获取VIP卡列表
+func (c *VipcardController) GetVipList() {
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseId := c.GetCaseIDs(cases)
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetVipChild(caseId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// AddVipCard 新增VIP卡
+func (c *VipcardController) AddVipCard() {
+	vipcard := model.TaVipCard{}
+	if err := c.ParseForm(&vipcard); err != nil {
+		c.ResponseError(err)
+	}
+	newVipCard, err := c.dao.AddVipCard(vipcard)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newVipCard)
+
+}
+
+// userCharge 用户激活vip卡
+func (c *VipcardController) userCharge() {
+	vipCode := c.GetString(":vipCardChildCode")
+	tel := c.GetString(":tel")
+	vipChild, err := c.dao.GetVipChildByCode(vipCode)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	customer, err := c.dao.FindCustomerByTel(tel)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	vipChild.CustomerId = customer.CustomerId
+	vipChild.CustomerTel = tel
+	vipChild.ActiveDate = time.Now()
+	newVipChild, err := c.dao.UpdateVipChild(vipChild)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	err := c.dao.CustomerCharge(newVipChild)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("激活成功")
+
+}

models/channel/channel.go

@@ -33,7 +33,7 @@ type Channel struct {
 // GetChannelsCount 获取渠道总数
 func (m *ChannelDAO) GetChannelsCount(caseid string) (int, error) {
 	var channels []model.TaChannel
-	dao := m.db.Where("status >" + strconv.Itoa(models.STATUS_DEL)).And("case_id in ('" + strings.Replace(caseid, ",", "','", -1) + "')")
+	dao := m.db.Where("status > " + strconv.Itoa(models.STATUS_DEL)).And("case_id in ('" + strings.Replace(caseid, ",", "','", -1) + "')")
 	err := dao.Find(&channels)
 	return len(channels), err
 }

models/model/ta_vip_card.go

@@ -7,7 +7,7 @@ import (
 type TaVipCard struct {
 	VipCardId   string    `xorm:"not null pk VARCHAR(64)"`
 	VipCardName string    `xorm:"VARCHAR(64)"`
-	CardAmount  float32   `xorm:"FLOAT(8,2)"`
+	CardAmount  string    `xorm:"DECIMAL(8,2)"`
 	CreateDate  time.Time `xorm:"DATETIME"`
 	TotalCount  int       `xorm:"INT(11)"`
 	Status      int       `xorm:"SMALLINT(6)"`

models/model/ta_vip_card_child.go

@@ -13,4 +13,5 @@ type TaVipCardChild struct {
 	CustomerTel      string    `xorm:"DECIMAL(13)"`
 	CreateDate       time.Time `xorm:"DATETIME"`
 	ActiveDate       time.Time `xorm:"DATETIME"`
+	Amount           string    `xorm:"DECIMAL(8,2)"`
 }

models/vipcard/vipcard.go

@@ -47,6 +47,7 @@ FROM
 WHERE
 	vcc.status > 0 ` + strconv.Itoa(models.STATUS_DEL) +
 		`AND sc.case_id IN('` + strings.Replace(caseid, ",", "','", -1) + `') `
+	sql = sql + " order by vc.create_date desc limit " + strconv.Itoa((page-1)*pageSize) + ", " + strconv.Itoa(page*pageSize)
 	err := m.db.Sql(sql).Find(&vipcards)
 	return vipcards, err
 }
@@ -102,8 +103,21 @@ func (m *VipcardDAO) GetVipChildByCode(vipCode string) (*model.TaVipCardChild, e
 	return nil, nil
 }
 
+// GetVipCardById 根据id获取VIP卡
+func (m *VipcardDAO) GetVipCardById(id string) (*model.TaVipCard, error) {
+	var vipCard []model.TaVipCard
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("vip_card_id = ?", id).Find(&vipCard)
+	if err != nil {
+		return nil, err
+	}
+	if len(vipCard) > 0 {
+		return &vipCard[0], nil
+	}
+	return nil, nil
+}
+
 // UpdateVipChild 更新子卡
-func (m *VipcardDAO) UpdateVipChild(vipChild model.TaVipCardChild) error {
+func (m *VipcardDAO) UpdateVipChild(vipChild *model.TaVipCardChild) error {
 	vipChild.ActiveDate = time.Now()
 	var cols = []string{
 		"customer_id",

service/vipcard/vipcard.go

@@ -1,6 +1,8 @@
 package vipcard
 
 import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/vipcard"
 	"spaceofcheng/services/service"
@@ -11,18 +13,21 @@ import (
 
 // CaseServ 系统处理
 type VipcardServ struct {
-	ctx *utils.Context
-	dao *vipcard.VipcardDAO
+	ctx  *utils.Context
+	dao  *vipcard.VipcardDAO
+	cdao *customer.CustomerDAO
 }
 
 // NewVipcardServ 初始化
 func NewVipcardServ(ctx *utils.Context) *VipcardServ {
 	return &VipcardServ{
-		ctx: ctx,
-		dao: vipcard.NewVipcardDAO(ctx),
+		ctx:  ctx,
+		dao:  vipcard.NewVipcardDAO(ctx),
+		cdao: customer.NewCustomerDAO(ctx),
 	}
 }
 
+// GetVipChild 获取VIP卡列表
 func (s *VipcardServ) GetVipChild(caseid string, page, pageSize int) (map[string]interface{}, error) {
 	if pageSize == 0 {
 		pageSize = service.PAGENUM
@@ -48,17 +53,20 @@ func (s *VipcardServ) GetVipChild(caseid string, page, pageSize int) (map[string
 	}, err
 }
 
+// 根据code获取vip子卡
 func (s *VipcardServ) GetVipChildByCode(vipChildId string) (*model.TaVipCardChild, error) {
 	vipCardChild, err := s.dao.GetVipChildByCode(vipChildId)
 	return vipCardChild, err
 }
 
-func (s *VipcardServ) UpdateVipChild(vipChild model.TaVipCardChild) (*model.TaVipCardChild, error) {
+// UpdateVipChild 更新子卡
+func (s *VipcardServ) UpdateVipChild(vipChild *model.TaVipCardChild) (*model.TaVipCardChild, error) {
 	var err error
 	err = s.dao.UpdateVipChild(vipChild)
 	return &vipChild, err
 }
 
+// AddVipCard 新建VIP卡
 func (s *VipcardServ) AddVipCard(vipCard model.TaVipCard) (*model.TaVipCard, error) {
 	vipcard, err := s.dao.AddVipCard(vipCard)
 	if err != nil {
@@ -70,10 +78,46 @@ func (s *VipcardServ) AddVipCard(vipCard model.TaVipCard) (*model.TaVipCard, err
 		vipChild.VipCardChildCode = s.dao.GenerateChildCode()
 		_, err := s.dao.AddVipChildCard(vipChild)
 		if err != nil {
-			break
 			return nil, err
 		}
 
 	}
 	return nil, nil
 }
+
+func (s *VipcardServ) FindCustomerByTel(tel string) (*model.TaCustomer, error) {
+	customer, err := s.cdao.GetCustomerByPhone(tel)
+	if err != nil {
+		return nil, err
+	}
+	return customer, err
+}
+
+// CustomerCharge 给用户充值
+func (s *VipcardServ) CustomerCharge(vipchild model.TaVipCardChild, createUser model.SysUser) error {
+	customer, err := s.cdao.GetCustomerByPhone(vipchild.CustomerTel)
+	if err != nil {
+		return err
+	}
+	customerId := customer.CustomerId
+	account, err := s.cdao.GetAccountByCust(customerId)
+	if err != nil {
+		return err
+	}
+	vipcard, err := s.dao.GetVipCardById(vipchild.VipCardId)
+	if err != nil {
+		return err
+	}
+	var record model.TaAccountChange
+	record.CustomerId = customerId
+	record.Amount = vipcard.CardAmount
+	record.CaseId = vipcard.CaseId
+	record.CustomerName = customer.CustomerName
+	record.ChangeType = models.CONSUME_MONEYCHG
+	record.ChangeSource = models.ACCSOURCE_RECHARGE
+	record.CreateUser = createUser.UserId
+	record.FloatType = models.ACCOUNT_INCOME
+	record.AccountId = account.AccountId
+	return s.cdao.InsertAccountRecords(&record)
+
+}