wangfei1023

controllers/luckdraw/luckdraw.go

@@ -11,8 +11,6 @@ import (
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/luckdraw"
 	"spaceofcheng/services/utils"
-
-	"github.com/astaxie/beego"
 )
 
 // LuckdrawController 应用
@@ -104,7 +102,6 @@ func (c *LuckDrawController) SaveLuckDraw() {
 		utils.LogError("抽奖数据转换失败: " + err.Error())
 		c.ResponseError(err)
 	}
-	beego.Error(info)
 	newinfo, err := c.serv.SaveLuckDraw(&info)
 	if err != nil {
 		c.ResponseError(err)
@@ -131,7 +128,7 @@ func (c *LuckDrawController) GetUserByCode() {
 
 	user := userRaw.(model.TaCustomer)
 	luckdrawid := c.GetString(":id")
-	record, err := c.serv.GetUserLuckDrawByLuckDraw(user.CustomerId, luckdrawid)
+	record, err := c.serv.GetUserLuckDrawByLuckDraw(user, luckdrawid)
 	if err != nil {
 		utils.LogError("获取用户抽奖信息失败: " + err.Error())
 		c.ResponseError(errors.New("获取用户抽奖信息失败"))

models/constant.go

@@ -205,6 +205,7 @@ const (
 	NUMTYPE_REPART    = "repeat"
 	NUMTYPE_NOTREPART = "no_repeat"
 )
+
 const (
 	FLASH_BUY_ACTIVE   = "active"
 	FLASH_BUY_INACTIVE = "inactive"
@@ -226,3 +227,10 @@ const (
 	ActGiveCoupon = "giveCoupon"
 	ActGiveCard   = "giveCard"
 )
+
+// 抽奖次数间隔
+const (
+	INTERVAL_DAY   = "day"
+	INTERVAL_WEEK  = "week"
+	INTERVAL_MONTH = "month"
+)

models/luckdraw/luckdraw.go

@@ -329,7 +329,6 @@ func (m *LuckDrawDao) SavePrizeDetail(prize model.TaLuckdrawPrize) error {
 		var card model.TaCouponCard
 		_, err := m.db.Where("card_id=?", prize.CouponCardId).Get(&card)
 		if err != nil {
-			beego.Error(err)
 			return err
 		}
 		if card.UsedCount > 0 {
@@ -362,6 +361,19 @@ func (m *LuckDrawDao) UpdateLuckDraw(luckdraw model.TaLuckdraw, cols []string) e
 	return err
 }
 
+// UpdatePrizeDesc 更新奖品描述
+func (m *LuckDrawDao) UpdatePrizeDesc(prizes []PrizeWithDefaults) error {
+	for _, prize := range prizes {
+		_, err := m.db.Cols([]string{
+			"prize_desc",
+		}...).Where("id=?", prize.Id).Update(prize.TaLuckdrawPrize)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
 // GetLuckDraw 获取抽奖信息
 func (m *LuckDrawDao) GetLuckDraw(id string) (*LuckDraw, error) {
 	if id == "" {
@@ -388,13 +400,13 @@ func (m *LuckDrawDao) GetLuckDraw(id string) (*LuckDraw, error) {
 }
 
 // AddCustomerLuckDraw 保存用户抽奖配置信息
-func (m *LuckDrawDao) AddCustomerLuckDraw(custLuckDraw *model.TaLuckdrawCustomer) (*model.TaLuckdrawCustomer, error) {
+func (m *LuckDrawDao) AddCustomerLuckDraw(custLuckDraw model.TaLuckdrawCustomer) (*model.TaLuckdrawCustomer, error) {
 	custLuckDraw.LuckdrawCustomerId = utils.GetGUID()
 	custLuckDraw.CreateDate = time.Now()
 	custLuckDraw.ShareNum = 0
-	custLuckDraw.SurplusNum = 0
+	custLuckDraw.ShareSurplusNum = 0
 	_, err := m.db.Insert(custLuckDraw)
-	return custLuckDraw, err
+	return &custLuckDraw, err
 }
 
 // LuckDraw 抽奖
@@ -441,33 +453,18 @@ func (m *LuckDrawDao) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuck
 	// 抽奖次数判断
 	if cstluckdrawSet.SurplusNum <= 0 {
 		return nil, nil, nil, errors.New("您的抽奖次数已用完！")
+	} else {
+		// 抽奖次数库存修改
+		err := m.UpdateCstLuckdrawSurplus(cstluckdrawSet)
+		if err != nil {
+			return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
+		}
+		// 更新参与人数
+		err = m.UpdateLuckDrawJoinedNum(id)
+		if err != nil {
+			return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
+		}
 	}
-	// 	userluckdraws, err := m.GetUserRecordByLuckDraw(user.CustomerId, id)
-	// 	if err != nil {
-	// 		utils.LogError("获取用户抽奖信息失败:", err)
-	// 		return nil, nil, nil, errors.New("获取用户抽奖信息失败！")
-	// 	}
-
-	// 	if len(userluckdraws) >= luckdraw.LuckdrawNum {
-	// 		return nil, nil, nil, errors.New("您的抽奖次数已用完！")
-	// 	}
-
-	// 判断人数是否已超过限制
-	// if luckdraw.JoinNum > 0 {
-	// 	usernum, err := m.GetLuckDrawCustomerNum(luckdraw.Id)
-	// 	if err != nil {
-	// 		utils.LogError("获取抽奖人员信息失败:", err)
-	// 		return nil, nil, nil, errors.New("获取抽奖人员信息失败！")
-	// 	}
-	// 	if luckdraw.JoinNum <= usernum {
-	// 		err = m.UpdateLuckDrawEndDate(luckdraw.Id)
-	// 		if err != nil {
-	// 			utils.LogError("操作失败，请刷新后重试:", err)
-	// 			return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
-	// 		}
-	// 		return nil, nil, nil, errors.New("活动已结束！")
-	// 	}
-	// }
 
 	// 判断是否内置用户
 	defaultPrize, err := m.GetPrizeDefaultByUser(id, user)
@@ -581,6 +578,37 @@ func (m *LuckDrawDao) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuck
 	return prize, &detail, record, err
 }
 
+// UpdateCstLuckdrawSurplus 更新用户抽奖剩余次数
+func (m *LuckDrawDao) UpdateCstLuckdrawSurplus(cstLuckDraw *model.TaLuckdrawCustomer) error {
+	sql := `update ta_luckdraw_customer set share_surplus_num = (case when surplus_num > share_surplus_num then share_surplus_num else share_surplus_num - 1 end),
+	surplus_num = surplus_num - 1 where luckdraw_customer_id = ? and surplus_num>0`
+	res, err := m.db.Exec(sql, cstLuckDraw.LuckdrawCustomerId)
+	if err != nil {
+		return err
+	}
+	len, _ := res.RowsAffected()
+	if len < 1 {
+		return errors.New("您没有剩余次数！")
+	}
+	return nil
+}
+
+// UpdateLuckDrawJoinedNum 更新抽奖参与人数
+func (m *LuckDrawDao) UpdateLuckDrawJoinedNum(id string) error {
+	var records []model.TaLuckdrawRecord
+	sql := `select DISTINCT user_id from ta_luckdraw_record where luckdraw_id=?`
+	err := m.db.Sql(sql, id).Find(&records)
+	if err != nil {
+		return err
+	}
+	if len(records) > 0 {
+		sql = `update ta_luckdraw set joined_num=? where id=?`
+		_, err = m.db.Exec(sql, len(records), id)
+		return err
+	}
+	return nil
+}
+
 // PrizeWithDefault 默认奖品
 type PrizeWithDefault struct {
 	DefaultId             string
@@ -845,6 +873,37 @@ func (m *LuckDrawDao) GetUserRecordByLuckDraw(userid string, luckdrawid string)
 	return records, err
 }
 
+// GetUserLuckDrawSet 获取用户抽奖设置
+func (m *LuckDrawDao) GetUserLuckDrawSet(customer model.TaCustomer, luckdrawid string) (*model.TaLuckdrawCustomer, error) {
+	var cstluckdraw = model.TaLuckdrawCustomer{}
+	_, err := m.db.Where("customer_id=?").And("luckdraw_id=?", luckdrawid).Get(&cstluckdraw)
+	if err != nil {
+		return nil, err
+	}
+	if cstluckdraw.CustomerId != "" {
+		return &cstluckdraw, nil
+	}
+	// 插入
+	luckdraw, err := m.GetLuckDrawByID(luckdrawid)
+	if err != nil {
+		return nil, err
+	}
+	surplusNum := luckdraw.LuckdrawNum
+	isnew := 0
+	if customer.Phone == "" {
+		isnew = 1
+	}
+	if luckdraw.JoinType == models.JOINTYPE_NEWUSER && isnew != 1 {
+		surplusNum = 0
+	}
+	cstluckdraw.CustomerId = customer.CustomerId
+	cstluckdraw.IsNew = isnew
+	cstluckdraw.LuckdrawId = luckdrawid
+	cstluckdraw.SurplusNum = surplusNum
+	newinfo, err := m.AddCustomerLuckDraw(cstluckdraw)
+	return newinfo, err
+}
+
 // GetUserLuckDrawByLuckDraw 获取用户的抽奖信息
 func (m *LuckDrawDao) GetUserLuckDrawByLuckDraw(userid string, luckdrawid string) (*model.TaLuckdrawRecord, error) {
 	var records []model.TaLuckdrawRecord
@@ -942,7 +1001,7 @@ func (m *LuckDrawDao) GetLuckDrawShareData(from, to, luckID, caseID string) ([]m
 // UpdateShareNum 分享增加抽奖次数
 func (m *LuckDrawDao) UpdateShareNum(luckdraw *LuckDraw, from string) error {
 	num := strconv.Itoa(luckdraw.ShareAddNum)
-	sql := `update ta_luckdraw_customer set share_num=share_num+` + num + `,surplus_num = surplus_num+` + num + ` where luckdraw_id=? and customer_id=?`
+	sql := `update ta_luckdraw_customer set share_num=share_num+` + num + `,share_surplus_num = share_surplus_num +` + num + ` ,surplus_num = surplus_num+` + num + ` where luckdraw_id=? and customer_id=?`
 	_, err := m.db.Exec(sql, luckdraw.Id, from)
 	return err
 }

models/model/ta_luckdraw_customer.go

@@ -10,6 +10,7 @@ type TaLuckdrawCustomer struct {
 	CustomerId         string    `xorm:"VARCHAR(64)"`
 	IsNew              int       `xorm:"TINYINT(1)"`
 	ShareNum           int       `xorm:"INT(11)"`
+	ShareSurplusNum    int       `xorm:"INT(11)"`
 	SurplusNum         int       `xorm:"INT(11)"`
 	CreateDate         time.Time `xorm:"DATETIME"`
 }

routers/common.go

@@ -204,8 +204,8 @@ func getCommonRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("luckdraw/:luckdrawid", &luckdraw.LuckDrawController{}, "put:SaveLuckDraw"),
 		beego.NSRouter("luckdraw/:luckdrawid", &luckdraw.LuckDrawController{}, "delete:DelLuckDraw"),
 
-		beego.NSRouter("luckdraw/records/:luckdrawid", &luckdraw.LuckDrawController{}, "delete:GetLuckDrawRecordList"),
-		beego.NSRouter("luckdraw/share/:luckdrawid", &luckdraw.LuckDrawController{}, "delete:GetLuckDrawShareList"),
+		beego.NSRouter("luckdraw/records/:luckdrawid", &luckdraw.LuckDrawController{}, "get:GetLuckDrawRecordList"),
+		beego.NSRouter("luckdraw/share/:luckdrawid", &luckdraw.LuckDrawController{}, "get:GetLuckDrawShareList"),
 
 		// bodychecklist 体检列表
 		beego.NSRouter("bodychecklist", &bodychecklist.BodychecklistController{}, "get:GetBodyCheckList"),

service/luckdraw/luckdraw.go

@@ -166,6 +166,12 @@ func (s *LuckdrawServ) SaveLuckDraw(luckdraw *luckdraw.LuckDrawInfo) (*model.TaL
 				utils.LogError("更新抽奖信息失败: " + err.Error())
 				return nil, errors.New("更新抽奖信息失败")
 			}
+
+			err = s.dao.UpdatePrizeDesc(luckdraw.Prizes)
+			if err != nil {
+				utils.LogError("更新抽奖信息失败: " + err.Error())
+				return nil, errors.New("更新抽奖信息失败")
+			}
 			return &luckdraw.TaLuckdraw, nil
 		}
 		var cols = []string{
@@ -460,8 +466,15 @@ func (s *LuckdrawServ) GetUserRecordByLuckDraw(userid string, luckdrawid string)
 	return record, nil
 }
 
-func (s *LuckdrawServ) GetUserLuckDrawByLuckDraw(userid string, luckdrawid string) (*model.TaLuckdrawRecord, error) {
-	record, err := s.dao.GetUserLuckDrawByLuckDraw(userid, luckdrawid)
+// GetUserLuckDrawByLuckDraw 获取用户抽奖信息
+func (s *LuckdrawServ) GetUserLuckDrawByLuckDraw(user model.TaCustomer, luckdrawid string) (*model.TaLuckdrawRecord, error) {
+	// 获取用户抽奖设置信息
+	_, err := s.dao.GetUserLuckDrawSet(user, luckdrawid)
+	if err != nil {
+		utils.LogError("获取用户抽奖设置失败: " + err.Error())
+		return nil, errors.New("获取用户抽奖设置失败")
+	}
+	record, err := s.dao.GetUserLuckDrawByLuckDraw(user.CustomerId, luckdrawid)
 	if err != nil {
 		utils.LogError("获取用户的抽奖信息失败: " + err.Error())
 		return nil, errors.New("获取用户的抽奖信息失败")