1022AMUpdateByWangf

conf/app.conf

@@ -12,6 +12,9 @@ qrcodePrefix = bodycheck_
 followText = 您正在使用悦琦设备进行体检~
 resultURL = http://spaceofcheng.ycjcjy.com/wechat/bodyCheck.html
 
+clientShareURL = http://spaceofcheng.ycjcjy.com/wechat/user.html
+defaultShareUserID = 1
+
 [cros]
 allowMode = dev
 allowCredentials = true

controllers/luckdraw/luckdraw.go

@@ -4,7 +4,9 @@ import (
 	"errors"
 	"net/http"
 	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/customer"
+	luckdrawModel "spaceofcheng/services/models/luckdraw"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/luckdraw"
 	"spaceofcheng/services/utils"
@@ -25,6 +27,92 @@ func (c *LuckDrawController) Constructor() {
 	c.custDAO = customer.NewCustomerDAO(c.Context)
 }
 
+// GetLuckDrawTpl 获取抽奖模板
+func (c *LuckDrawController) GetLuckDrawTpl() {
+	tpls, err := c.serv.GetLuckDrawTpl()
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(tpls)
+}
+
+// GetLuckDrawList 获取抽奖列表
+func (c *LuckDrawController) GetLuckDrawList() {
+	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")
+	name := c.GetString("name")
+	status := c.GetString("status")
+	list, err := c.serv.GetLuckDrawList(caseids, name, status, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetLuckDrawRecordList 获取抽奖记录列表
+func (c *LuckDrawController) GetLuckDrawRecordList() {
+	luckdrawid := c.GetString(":luckdrawid")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	tel := c.GetString("tel")
+	list, err := c.serv.GetLuckDrawRecordList(luckdrawid, tel, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetLuckDrawShareList 获取抽奖分享记录列表
+func (c *LuckDrawController) GetLuckDrawShareList() {
+	luckdrawid := c.GetString(":luckdrawid")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	tel := c.GetString("tel")
+	list, err := c.serv.GetLuckDrawShareList(luckdrawid, tel, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
+// GetLuckDrawByID 根据id获取抽奖信息
+func (c *LuckDrawController) GetLuckDrawByID() {
+	id := c.GetString(":luckdrawid")
+	luckdraw, err := c.serv.GetLuckDrawInfoByID(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(luckdraw)
+}
+
+// SaveLuckDraw 保存抽奖信息
+func (c *LuckDrawController) SaveLuckDraw() {
+	info := luckdrawModel.LuckDrawInfo{}
+	if err := c.ParseForm(&info); err != nil {
+		c.ResponseError(err)
+	}
+	newinfo, err := c.serv.SaveLuckDraw(&info)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(newinfo)
+}
+
+// DelLuckDraw 删除抽奖信息
+func (c *LuckDrawController) DelLuckDraw() {
+	luckdrawid := c.GetString(":luckdrawid")
+	err := c.serv.DelLuckDraw(luckdrawid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("操作成功！")
+}
+
 // GetUserByCode 根据code获取用户信息
 func (c *LuckDrawController) GetUserByCode() {
 	userRaw := c.Context.Get("customer")
@@ -249,5 +337,19 @@ func (c *LuckDrawController) SaveShareRecord() {
 		)
 	}
 
+	fromIsNew := c.GetString("isnew")
+
+	// 分享可以增加抽奖次数
+	if luckdraw.ShareType == models.SHARETYPE_NEWUSER && fromIsNew == "true" {
+		if err := c.serv.UpdateShareNum(luckdraw, fromID); err != nil {
+			utils.LogError("更新抽奖次数失败: " + err.Error())
+			c.ResponseData(
+				errIgnore,
+				"保存分享记录失败",
+				http.StatusBadRequest,
+			)
+		}
+	}
+
 	c.ResponseJSON("ok")
 }

models/constant.go

@@ -177,3 +177,30 @@ const (
 const (
 	ADMIN_ID = "1"
 )
+
+// 奖品类型
+const (
+	PRIZE_TYPE_COUPONCARD = "couponcard"
+	PRIZE_TYPE_THIRD      = "third"
+
+	PRIZE_TYPE_COUPON = "coupon"
+	PRIZE_TYPE_CARD   = "card"
+)
+
+// 参与类型设置
+const (
+	JOINTYPE_NEWUSER = "newuser"
+	JOINTYPE_NO      = "no"
+)
+
+// 抽奖分享设置
+const (
+	SHARETYPE_NEWUSER = "newuser"
+	SHARETYE_NO       = "no"
+)
+
+// 抽奖次数类型
+const (
+	NUMTYPE_REPART    = "repeat"
+	NUMTYPE_NOTREPART = "no_repeat"
+)

models/luckdraw/luckdraw.go

@@ -9,6 +9,7 @@ import (
 	"strings"
 	"time"
 
+	"github.com/astaxie/beego"
 	"github.com/go-xorm/xorm"
 )
 
@@ -30,16 +31,25 @@ func NewDAO(ctx *utils.Context) *LuckDrawDao {
 type LuckDraw struct {
 	model.TaLuckdraw `xorm:"extends"`
 	Prizes           []model.TaLuckdrawPrize
+	Imgs             []model.TaLuckdrawImg
 }
+
 type LuckInfo struct {
 	model.TaLuckdrawRecord `xorm:"extends"`
 	CustomerQrcode         string
 }
 
+// GetLuckDrawTpl 获取抽奖模板
+func (m *LuckDrawDao) GetLuckDrawTpl(orgid string) ([]model.TaLuckdrawTpl, error) {
+	var tpls []model.TaLuckdrawTpl
+	err := m.db.Where("org_id=?", orgid).And("status=?", models.STATUS_NORMAL).Find(&tpls)
+	return tpls, err
+}
+
 // GetLuckDrawList 获取抽奖列表
 func (m *LuckDrawDao) GetLuckDrawList(caseids, name, status string, page, pageSize int) ([]model.TaLuckdraw, error) {
 	var luckdraws []model.TaLuckdraw
-	dao := m.db.Where("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
+	dao := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("status<>?", models.STATUS_DEL)
 	if name != "" {
 		dao.And("name like '%" + name + "%'")
 	}
@@ -53,7 +63,7 @@ func (m *LuckDrawDao) GetLuckDrawList(caseids, name, status string, page, pageSi
 // GetLuckDrawCount 获取抽奖列表count
 func (m *LuckDrawDao) GetLuckDrawCount(caseids, name, status string) (int, error) {
 	var luckdraws []model.TaLuckdraw
-	dao := m.db.Where("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')")
+	dao := m.db.Where("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").And("status<>?", models.STATUS_DEL)
 	if name != "" {
 		dao.And("name like '%" + name + "%'")
 	}
@@ -64,6 +74,237 @@ func (m *LuckDrawDao) GetLuckDrawCount(caseids, name, status string) (int, error
 	return len(luckdraws), err
 }
 
+// RecordWithPhone 抽奖记录
+type RecordWithPhone struct {
+	model.TaLuckdrawRecord `xorm:"extends"`
+	CustomerName           string
+	Phone                  string
+}
+
+// GetLuckDrawRecordCount 获取抽奖记录count
+func (m *LuckDrawDao) GetLuckDrawRecordCount(id, tel string) (int, error) {
+	var records []RecordWithPhone
+	sql := `select a.*,b.customer_name,b.phone from ta_luckdraw_record a inner join ta_customer b on a.user_id=b.customer_id where a.luckdraw_id=?`
+	if tel != "" {
+		sql = sql + ` and b.phone=` + tel
+	}
+
+	err := m.db.Sql(sql).Find(&records)
+	return len(records), err
+}
+
+// GetLuckDrawRecord 获取抽奖记录信息
+func (m *LuckDrawDao) GetLuckDrawRecord(id, tel string, page, pageSize int) ([]RecordWithPhone, error) {
+	var records []RecordWithPhone
+	sql := `select a.*,b.customer_name,b.phone from ta_luckdraw_record a inner join ta_customer b on a.user_id=b.customer_id where a.luckdraw_id=?`
+	if tel != "" {
+		sql = sql + ` and b.phone=` + tel
+	}
+	sql = sql + ` ORDER BY a.create_date desc limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
+
+	err := m.db.Sql(sql).Find(&records)
+	return records, err
+}
+
+// GetLuckDrawShareCount 获取分享记录count
+func (m *LuckDrawDao) GetLuckDrawShareCount(id, tel string) (int, error) {
+	var shares []model.TaShareLuckyRecord
+	dao := m.db.Where("luckydraw_id=?", id)
+	if tel != "" {
+		dao.And("from_customer_tel=?", tel)
+	}
+
+	err := dao.Find(&shares)
+	return len(shares), err
+}
+
+// GetLuckDrawShare 获取分享记录信息
+func (m *LuckDrawDao) GetLuckDrawShare(id, tel string, page, pageSize int) ([]model.TaShareLuckyRecord, error) {
+	var shares []model.TaShareLuckyRecord
+	dao := m.db.Where("luckydraw_id=?", id)
+	if tel != "" {
+		dao.And("from_customer_tel=?", tel)
+	}
+
+	err := dao.Desc("create_date").Limit(pageSize, (page-1)*pageSize).Find(&shares)
+	return shares, err
+}
+
+// LuckDrawInfo 抽奖info
+type LuckDrawInfo struct {
+	model.TaLuckdraw `xorm:"extends"`
+	Prizes           []model.TaLuckdrawPrize
+	Imgs             []model.TaLuckdrawImg
+	Defaults         []model.TaPrizeDefault
+}
+
+// GetLuckDrawInfoByID 获取抽奖信息
+func (m *LuckDrawDao) GetLuckDrawInfoByID(id string) (*LuckDrawInfo, error) {
+	if id == "" {
+		return nil, errors.New("不存在抽奖信息！")
+	}
+	var luckdraw LuckDrawInfo
+	sql := `select * from ta_luckdraw where id= ?`
+	_, err := m.db.SQL(sql, id).Get(&luckdraw)
+	if err != nil {
+		return nil, err
+	}
+	if luckdraw.Id == "" {
+		return nil, nil
+	}
+	prizes, err := m.GetPrizes(id)
+	if err != nil {
+		utils.LogError("获取奖品信息失败：", err)
+		return nil, errors.New("获取奖品信息失败")
+	}
+	luckdraw.Prizes = prizes
+	imgs, err := m.GetLuckDrawImgs(id)
+	if err != nil {
+		utils.LogError("获取抽奖图片信息失败：", err)
+		return nil, errors.New("获取抽奖图片信息失败")
+	}
+	luckdraw.Imgs = imgs
+	defaults, err := m.GetLuckDrawDefault(id)
+	if err != nil {
+		utils.LogError("获取奖品内置信息失败：", err)
+		return nil, errors.New("获取奖品信息失败")
+	}
+	luckdraw.Defaults = defaults
+	return &luckdraw, err
+}
+
+// GetLuckDrawImgs 获取抽奖图片
+func (m *LuckDrawDao) GetLuckDrawImgs(luckdrawid string) ([]model.TaLuckdrawImg, error) {
+	var imgs []model.TaLuckdrawImg
+	err := m.db.Where("luckdraw_id=?", luckdrawid).Find(&imgs)
+	return imgs, err
+}
+
+// GetLuckDrawDefault 获取奖品默认信息
+func (m *LuckDrawDao) GetLuckDrawDefault(luckdrawid string) ([]model.TaPrizeDefault, error) {
+	var defaults []model.TaPrizeDefault
+	err := m.db.Where("luckdraw_id=?", luckdrawid).Find(&defaults)
+	return defaults, err
+}
+
+// InsertLuckdraw 新增抽奖信息
+func (m *LuckDrawDao) InsertLuckdraw(luckdraw model.TaLuckdraw) (*model.TaLuckdraw, error) {
+	luckdraw.Id = utils.GetGUID()
+	luckdraw.Status = models.STATUS_NORMAL
+	luckdraw.CreateDate = time.Now()
+
+	_, err := m.db.Insert(luckdraw)
+	return &luckdraw, err
+}
+
+// DelLuckDrawDefault 删除抽奖默认信息
+func (m *LuckDrawDao) DelLuckDrawDefault(luckdrawid string) error {
+	sql := `delete from ta_prize_default where luckdraw_id=?`
+	_, err := m.db.Exec(sql, luckdrawid)
+	return err
+}
+
+// DelLuckDrawImgs 删除抽奖图片信息
+func (m *LuckDrawDao) DelLuckDrawImgs(luckdrawid string) error {
+	sql := `delete from ta_luckdraw_img where luckdraw_id=?`
+	_, err := m.db.Exec(sql, luckdrawid)
+	return err
+}
+
+// DelLuckDrawPrize 删除奖品信息
+func (m *LuckDrawDao) DelLuckDrawPrize(luckdrawid string) error {
+	sql := `delete from ta_prize_detail where prize_id in (select id from ta_luckdraw_prize where luckdraw_id=?)`
+	_, err := m.db.Exec(sql, luckdrawid)
+	if err != nil {
+		return err
+	}
+	sql = `delete from ta_luckdraw_prize where luckdraw_id=?`
+	_, err = m.db.Exec(sql, luckdrawid)
+	return err
+}
+
+// SaveLuckDrawImgs 保存抽奖图片
+func (m *LuckDrawDao) SaveLuckDrawImgs(imgs []model.TaLuckdrawImg, luckdrawid string) error {
+	for inx, img := range imgs {
+		if img.ImgId == "" {
+			imgs[inx].ImgId = utils.GetGUID()
+			org := m.ctx.Get("org").(model.SysOrg)
+			imgs[inx].OrgId = org.OrgId
+			imgs[inx].Status = models.STATUS_NORMAL
+			imgs[inx].LuckdrawId = luckdrawid
+		}
+	}
+	_, err := m.db.Insert(imgs)
+	return err
+}
+
+// SaveLuckDrawDefault 保存内定信息
+func (m *LuckDrawDao) SaveLuckDrawDefault(defaults []model.TaPrizeDefault, luckdrawid string) error {
+	for inx, d := range defaults {
+		if d.DefaultId == "" {
+			defaults[inx].DefaultId = utils.GetGUID()
+			defaults[inx].Status = models.STATUS_NORMAL
+			defaults[inx].CreateDate = time.Now()
+			defaults[inx].LuckdrawId = luckdrawid
+		}
+	}
+	_, err := m.db.Insert(defaults)
+	return err
+}
+
+// SaveLuckDrawPrizes 保存奖品信息
+func (m *LuckDrawDao) SaveLuckDrawPrizes(prizes []model.TaLuckdrawPrize, luckdrawid string) error {
+	for inx, prize := range prizes {
+		if prize.Id == "" {
+			prizes[inx].LuckdrawId = luckdrawid
+			prizes[inx].Id = utils.GetGUID()
+			prizes[inx].Status = models.STATUS_NORMAL
+		}
+		if prize.PrizeType == models.PRIZE_TYPE_COUPONCARD {
+			m.SavePrizeDetail(prize)
+		}
+	}
+	_, err := m.db.Insert(prizes)
+	return err
+}
+
+// SavePrizeDetail 保存奖品明细
+func (m *LuckDrawDao) SavePrizeDetail(prize model.TaLuckdrawPrize) error {
+	if prize.CouponCardType == models.PRIZE_TYPE_COUPON {
+		var coupon model.TaCoupon
+		_, err := m.db.Where("coupon_id=?", prize.CouponCardId).Get(&coupon)
+		if err != nil {
+			return err
+		}
+		if coupon.UsedCount > 0 {
+			return errors.New("卡券已被使用！不允许保存！")
+		}
+		var details []model.TaPrizeDetail
+		i := 0
+		for i < coupon.TotalCount {
+			unix := time.Now().UnixNano()
+			random := utils.GetRand(5) + strconv.Itoa(int(unix))
+			url := `/` + prize.CouponCardId + `/` + beego.AppConfig.String("defaultShareUserID") + `/` + prize.CouponCardType + `/` + random + `/receive`
+			var d = model.TaPrizeDetail{
+				Id:      utils.GetGUID(),
+				PrizeId: prize.Id,
+				Url:     beego.AppConfig.String("clientShareURL") + url,
+				Status:  models.STATUS_NORMAL,
+			}
+			details = append(details, d)
+		}
+		m.db.Insert(details)
+	}
+
+	return nil
+}
+
+// UpdateLuckDraw 修改抽奖
+func (m *LuckDrawDao) UpdateLuckDraw(luckdraw model.TaLuckdraw, cols []string) error {
+	_, err := m.db.Cols(cols...).Where("id=?", luckdraw.Id).Update(luckdraw)
+	return err
+}
+
 // GetLuckDraw 获取抽奖信息
 func (m *LuckDrawDao) GetLuckDraw(id string) (*LuckDraw, error) {
 	if id == "" {
@@ -80,69 +321,139 @@ func (m *LuckDrawDao) GetLuckDraw(id string) (*LuckDraw, error) {
 		return nil, errors.New("获取奖品信息失败")
 	}
 	luckdraw.Prizes = prizes
+	imgs, err := m.GetLuckDrawImgs(id)
+	if err != nil {
+		utils.LogError("获取抽奖图片信息失败：", err)
+		return nil, errors.New("获取抽奖图片信息失败")
+	}
+	luckdraw.Imgs = imgs
 	return luckdraw, nil
 }
 
+// AddCustomerLuckDraw 保存用户抽奖配置信息
+func (m *LuckDrawDao) AddCustomerLuckDraw(custLuckDraw *model.TaLuckdrawCustomer) (*model.TaLuckdrawCustomer, error) {
+	custLuckDraw.LuckdrawCustomerId = utils.GetGUID()
+	custLuckDraw.CreateDate = time.Now()
+	custLuckDraw.ShareNum = 0
+	custLuckDraw.SurplusNum = 0
+	_, err := m.db.Insert(custLuckDraw)
+	return custLuckDraw, err
+}
+
 // LuckDraw 抽奖
 func (m *LuckDrawDao) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuckdrawPrize, *model.TaPrizeDetail, *model.TaLuckdrawRecord, error) {
 	luckdraw, err := m.GetLuckDrawByID(id)
 	if err != nil {
 		return nil, nil, nil, errors.New("获取抽奖信息失败！")
 	}
+	if luckdraw.Status == models.STATUS_READY || time.Now().Before(luckdraw.BeginDate) {
+		return nil, nil, nil, errors.New("活动还未开始！")
+	}
+	if luckdraw.Status == models.STATUS_EXPIRE || time.Now().After(luckdraw.EndDate) {
+		return nil, nil, nil, errors.New("活动已结束！")
+	}
 	if luckdraw.Status != models.STATUS_NORMAL {
 		return nil, nil, nil, errors.New("当前抽奖活动状态异常！")
 	}
-	if time.Now().Before(luckdraw.BeginDate) {
-		return nil, nil, nil, errors.New("活动还未开始！")
+	// 系统用户是否可以抽奖
+	if luckdraw.IsSysLuckdraw == models.BOOL_FALSE {
+		if user.Phone != "" {
+			sysuser, err := m.GetUserByTel(user.Phone)
+			if err != nil {
+				return nil, nil, nil, errors.New("获取信息失败！")
+			}
+			if sysuser != nil {
+				return nil, nil, nil, errors.New("内部人员不允许进行抽奖！")
+			}
+		}
 	}
-	if time.Now().After(luckdraw.EndDate) {
-		return nil, nil, nil, errors.New("活动已结束！")
+
+	// 判断当前用户是否为新用户
+	cstluckdrawSet, err := m.GetCustomerLuckDraw(id, user.CustomerId)
+	if err != nil {
+		utils.LogError("获取用户抽奖配置信息失败:", err)
+		return nil, nil, nil, errors.New("获取用户抽奖配置信息失败！")
 	}
-	// if user.Phone != "" {
-	// 	sysuser, err := m.GetUserByTel(user.Phone)
+
+	if luckdraw.JoinType == models.JOINTYPE_NEWUSER {
+		if cstluckdrawSet.IsNew == models.BOOL_FALSE {
+			return nil, nil, nil, errors.New("您不是新用户，不允许抽奖！")
+		}
+	}
+
+	// 抽奖次数判断
+	if cstluckdrawSet.SurplusNum <= 0 {
+		return nil, nil, nil, errors.New("您的抽奖次数已用完！")
+	}
+	// 	userluckdraws, err := m.GetUserRecordByLuckDraw(user.CustomerId, id)
 	// 	if err != nil {
-	// 		return nil, nil, errors.New("获取信息失败！")
+	// 		utils.LogError("获取用户抽奖信息失败:", err)
+	// 		return nil, nil, nil, errors.New("获取用户抽奖信息失败！")
 	// 	}
-	// 	if sysuser != nil {
-	// 		return 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("活动已结束！")
 	// 	}
 	// }
-	userluckdraws, err := m.GetUserRecordByLuckDraw(user.CustomerId, id)
-	if err != nil {
-		utils.LogError("获取用户抽奖信息失败:", err)
-		return nil, nil, nil, errors.New("获取用户抽奖信息失败！")
-	}
-	if len(userluckdraws) > 0 {
-		return nil, nil, nil, errors.New("您已参与过此次抽奖，不允许重复抽奖！")
-	}
-	prizes, err := m.GetPrizeStock(id)
+
+	// 判断是否内置用户
+	defaultPrize, err := m.GetPrizeDefaultByUser(id, user)
 	if err != nil {
-		utils.LogError("获取奖项失败:", err)
-		return nil, nil, nil, errors.New("获取奖项失败！")
+		utils.LogError("操作失败，请刷新后重试:", err)
+		return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
 	}
-	if len(prizes) == 0 {
-		err = m.UpdateLuckDrawEndDate(luckdraw.Id)
+
+	var prize = new(model.TaLuckdrawPrize)
+	if defaultPrize.Id != "" {
+		// 内置用户，直接中奖
+		prize = &defaultPrize.TaLuckdrawPrize
+	} else {
+		prizes, err := m.GetPrizeStock(id)
 		if err != nil {
-			utils.LogError("操作失败，请刷新后重试:", err)
-			return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
+			utils.LogError("获取奖项失败:", err)
+			return nil, nil, nil, errors.New("获取奖项失败！")
+		}
+		if len(prizes) == 0 {
+			err = m.UpdateLuckDrawEndDate(luckdraw.Id)
+			if err != nil {
+				utils.LogError("操作失败，请刷新后重试:", err)
+				return nil, nil, nil, errors.New("操作失败，请刷新后重试！")
+			}
+			return nil, nil, nil, errors.New("活动已结束！")
+		}
+
+		prize, err = m.GetWinning(prizes)
+		if err != nil {
+			utils.LogError("获取奖项失败:", err)
+			return nil, nil, nil, errors.New("获取奖项失败！")
 		}
-		return nil, nil, nil, errors.New("活动已结束！")
 	}
-	prize, err := m.GetWinning(prizes)
+
+	details, err := m.GetPrizeDetail(prize.Id)
 	if err != nil {
-		utils.LogError("获取奖项失败:", err)
-		return nil, nil, nil, errors.New("获取奖项失败！")
+		utils.LogError("获取奖项详情失败:", err)
+		return nil, nil, nil, errors.New("获取奖项详情失败！")
 	}
 
-	// details, err := m.GetPrizeDetail(prize.Id)
-	// if err != nil {
-	// 	utils.LogError("获取奖项详情失败:", err)
-	// 	return nil, nil, errors.New("获取奖项详情失败！")
-	// }
-
 	// 保存中奖记录
 	var record = &model.TaLuckdrawRecord{}
-	// record.Id = utils.GetGUID()
+	record.Id = utils.GetGUID()
 	record.OrgId = luckdraw.OrgId
 	record.CaseId = luckdraw.CaseId
 	record.PrizeId = prize.Id
@@ -159,23 +470,30 @@ func (m *LuckDrawDao) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuck
 		utils.LogError("保存中奖纪录失败：", err)
 		return nil, nil, nil, err
 	}
-	// var detail = model.TaPrizeDetail{}
-	// if len(details) > 0 {
-	// 	// 更新中奖纪录明细
-	// 	details[0].ReceiveId = newrecord.Id
-	// 	err = m.UpdatePrizeDetail(details[0])
-	// 	if err != nil {
-	// 		utils.LogError("更新中奖纪录明细失败:", err)
-	// 		return nil, nil, errors.New("操作失败！")
-	// 	}
-	// 	detail = details[0]
-	// 	// 奖项自动核销，走卡券核销流程
-	// 	err = m.PrizeWriteOff(newrecord.Id, user.CustomerId)
-	// 	if err != nil {
-	// 		utils.LogError("卡券核销失败:", err)
-	// 		return nil, nil, errors.New("操作失败！")
-	// 	}
-	// }
+	// 更新内置信息
+	err = m.UpdatePrizeDefault(defaultPrize.DefaultId, record.Id)
+	if err != nil {
+		utils.LogError("更新内置信息失败：", err)
+		return nil, nil, nil, err
+	}
+
+	var detail = model.TaPrizeDetail{}
+	if len(details) > 0 {
+		// 更新中奖纪录明细
+		details[0].ReceiveId = record.Id
+		err = m.UpdatePrizeDetail(details[0])
+		if err != nil {
+			utils.LogError("更新中奖纪录明细失败:", err)
+			return nil, nil, nil, errors.New("操作失败！")
+		}
+		detail = details[0]
+		// 奖项自动核销，走卡券核销流程
+		err = m.PrizeWriteOff(record.Id, user.CustomerId)
+		if err != nil {
+			utils.LogError("卡券核销失败:", err)
+			return nil, nil, nil, errors.New("操作失败！")
+		}
+	}
 	// 更新库存
 	if prize.IsReality == 1 {
 		prize.Remainder = prize.Remainder - 1
@@ -195,7 +513,48 @@ func (m *LuckDrawDao) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuck
 		}
 	}
 
-	return prize, nil, record, err
+	return prize, &detail, record, err
+}
+
+// PrizeWithDefault 默认奖品
+type PrizeWithDefault struct {
+	DefaultId             string
+	model.TaLuckdrawPrize `xorm:"extends"`
+}
+
+// GetPrizeDefaultByUser 获取默认用户
+func (m *LuckDrawDao) GetPrizeDefaultByUser(id string, customer *model.TaCustomer) (*PrizeWithDefault, error) {
+	var prize = PrizeWithDefault{}
+	sql := `select a.default_id,b.* from ta_prize_default a inner join ta_prize_default b on a.prize_id=b.id where a.luckdraw_id=? and a.tel=? and is_receive=?`
+	_, err := m.db.Sql(sql, id, customer.Phone, models.BOOL_FALSE).Get(prize)
+	return &prize, err
+}
+
+// UpdatePrizeDefault 更新系统内置信息
+func (m *LuckDrawDao) UpdatePrizeDefault(id, recordid string) error {
+	var prizeDefault = model.TaPrizeDefault{
+		DefaultId:   id,
+		ReceiveDate: time.Now(),
+		ReceiveId:   recordid,
+		IsReceive:   models.BOOL_TRUE,
+	}
+	cols := []string{
+		"receive_id",
+		"receive_date",
+		"is_receive",
+	}
+	_, err := m.db.Cols(cols...).Where("id=?", prizeDefault.DefaultId).Update(prizeDefault)
+	return err
+}
+
+// GetCustomerLuckDraw 获取用户抽奖设置
+func (m *LuckDrawDao) GetCustomerLuckDraw(luckdrawid, customerid string) (*model.TaLuckdrawCustomer, error) {
+	var customerluckdraw model.TaLuckdrawCustomer
+	_, err := m.db.Where("luckdraw_id=?", luckdrawid).And("customer_id=?", customerid).Get(&customerluckdraw)
+	if err != nil {
+		return nil, err
+	}
+	return &customerluckdraw, nil
 }
 
 // PrizeWriteOff 奖品核销
@@ -287,9 +646,11 @@ func (m *LuckDrawDao) UpdateLuckDrawEndDate(id string) error {
 	var luckdraw = model.TaLuckdraw{
 		Id:      id,
 		EndDate: time.Now(),
+		Status:  models.STATUS_EXPIRE,
 	}
 	cols := []string{
 		"end_date",
+		"status",
 	}
 	_, err := m.db.Cols(cols...).Where("id=?", id).Update(luckdraw)
 	return err
@@ -314,7 +675,12 @@ func (m *LuckDrawDao) UpdateStock(prize *model.TaLuckdrawPrize) error {
 // GetPrizeStock 判断奖项库存
 func (m *LuckDrawDao) GetPrizeStock(luckdrawid string) ([]model.TaLuckdrawPrize, error) {
 	var prizes []model.TaLuckdrawPrize
-	err := m.db.Where("luckdraw_id=?", luckdrawid).And("status=?", models.STATUS_NORMAL).And("(remainder>0 or is_reality=0)").Find(&prizes)
+	sql := `select a.remainder-(case when b.default_num is null then 0 else b.default_num end) as remainder,
+	a.* from ta_luckdraw_prize a 
+	left join (select prize_id,count(1) as default_num from ta_prize_default where luckdraw_id) b 
+	on a.id=b.prize_id where a.luckdraw_id=? and a.status=? and (a.remainder-(case when b.default_num is null then 0 else b.default_num end)>0 or is_reality=0)`
+	err := m.db.Sql(sql).Find(&prizes)
+	// err := m.db.Where("luckdraw_id=?", luckdrawid).And("status=?", models.STATUS_NORMAL).And("(remainder>0 or is_reality=0)").Find(&prizes)
 	return prizes, err
 }
 
@@ -329,7 +695,7 @@ func (m *LuckDrawDao) GetPrizeByID(id string) (model.TaLuckdrawPrize, error) {
 func (m *LuckDrawDao) SaveRecord(record model.TaLuckdrawRecord) (*model.TaLuckdrawRecord, error) {
 	record.CreateDate = time.Now()
 	record.Status = models.STATUS_READY
-	record.Id = utils.GetGUID()
+	// record.Id = utils.GetGUID()
 	_, err := m.db.Insert(&record)
 	return &record, err
 }
@@ -482,3 +848,19 @@ func (m *LuckDrawDao) GetLuckDrawShareData(from, to, luckID, caseID string) ([]m
 
 	return dts, nil
 }
+
+// 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=?`
+	_, err := m.db.Exec(sql, luckdraw.Id, from)
+	return err
+}
+
+// GetLuckDrawCustomerNum 获取抽奖人数
+func (m *LuckDrawDao) GetLuckDrawCustomerNum(luckdrawid string) (int, error) {
+	var records []model.TaLuckdrawRecord
+	sql := `select DISTINCT user_id from ta_luckdraw_record where luckdraw_id=?`
+	err := m.db.Sql(sql, luckdrawid).Find(&records)
+	return len(records), err
+}

models/model/ta_luckdraw.go

@@ -5,16 +5,27 @@ import (
 )
 
 type TaLuckdraw struct {
-	Id           string    `xorm:"not null pk VARCHAR(64)"`
-	Name         string    `xorm:"VARCHAR(50)"`
-	ThemeId      string    `xorm:"VARCHAR(64)"`
-	LuckdrawRule string    `xorm:"TEXT"`
-	BeginDate    time.Time `xorm:"DATETIME"`
-	EndDate      time.Time `xorm:"DATETIME"`
-	OrgId        string    `xorm:"VARCHAR(64)"`
-	CaseId       string    `xorm:"VARCHAR(64)"`
-	CreateDate   time.Time `xorm:"DATETIME"`
-	CreateUser   string    `xorm:"VARCHAR(64)"`
-	Remark       string    `xorm:"TEXT"`
-	Status       int       `xorm:"SMALLINT(6)"`
+	Id                string    `xorm:"not null pk VARCHAR(64)"`
+	Name              string    `xorm:"VARCHAR(50)"`
+	ThemeId           string    `xorm:"VARCHAR(64)"`
+	LuckdrawRule      string    `xorm:"TEXT"`
+	BeginDate         time.Time `xorm:"DATETIME"`
+	EndDate           time.Time `xorm:"DATETIME"`
+	OrgId             string    `xorm:"VARCHAR(64)"`
+	CaseId            string    `xorm:"VARCHAR(64)"`
+	CreateDate        time.Time `xorm:"DATETIME"`
+	CreateUser        string    `xorm:"VARCHAR(64)"`
+	Remark            string    `xorm:"TEXT"`
+	Status            int       `xorm:"SMALLINT(6)"`
+	TplId             string    `xorm:"VARCHAR(64)"`
+	JoinedNum         int       `xorm:"default 0 INT(11)"`
+	JoinNum           int       `xorm:"default 0 INT(11)"`
+	JoinType          string    `xorm:"VARCHAR(20)"`
+	NumType           string    `xorm:"VARCHAR(20)"`
+	NumInterval       string    `xorm:"VARCHAR(20)"`
+	LuckdrawNum       int       `xorm:"default 0 INT(11)"`
+	ShareType         string    `xorm:"VARCHAR(20)"`
+	ShareAddNum       int       `xorm:"SMALLINT(6)"`
+	IsSysLuckdraw     int       `xorm:"TINYINT(1)"`
+	IsInternalDefault int       `xorm:"TINYINT(1)"`
 }

models/model/td_luckdraw_img.go → models/model/ta_luckdraw_img.go

@@ -1,6 +1,6 @@
 package model
 
-type TdLuckdrawImg struct {
+type TaLuckdrawImg struct {
 	ImgId      string `xorm:"not null VARCHAR(64)"`
 	LuckdrawId string `xorm:"VARCHAR(64)"`
 	ImgUrl     string `xorm:"TEXT"`

models/model/ta_luckdraw_prize.go

@@ -18,4 +18,7 @@ type TaLuckdrawPrize struct {
 	IsReality         int       `xorm:"SMALLINT(6)"`
 	VerificationStart time.Time `xorm:"DATETIME"`
 	VerificationEnd   time.Time `xorm:"DATETIME"`
+	PrizeType         string    `xorm:"VARCHAR(20)"`
+	CouponCardType    string    `xorm:"VARCHAR(20)"`
+	CouponCardId      string    `xorm:"VARCHAR(64)"`
 }

models/model/ta_luckdraw_record.go

@@ -5,16 +5,19 @@ import (
 )
 
 type TaLuckdrawRecord struct {
-	Id           string    `xorm:"not null pk VARCHAR(64)"`
-	LuckdrawId   string    `xorm:"VARCHAR(64)"`
-	PrizeId      string    `xorm:"VARCHAR(64)"`
-	PrizeName    string    `xorm:"VARCHAR(50)"`
-	UserId       string    `xorm:"VARCHAR(64)"`
-	UserName     string    `xorm:"VARCHAR(50)"`
-	UserHeadImg  string    `xorm:"TEXT"`
-	CreateDate   time.Time `xorm:"DATETIME"`
-	Status       int       `xorm:"SMALLINT(6)"`
-	WriteoffDate time.Time `xorm:"DATETIME"`
-	OrgId        string    `xorm:"VARCHAR(64)"`
-	CaseId       string    `xorm:"VARCHAR(64)"`
+	Id             string    `xorm:"not null pk VARCHAR(64)"`
+	LuckdrawId     string    `xorm:"VARCHAR(64)"`
+	PrizeId        string    `xorm:"VARCHAR(64)"`
+	PrizeName      string    `xorm:"VARCHAR(50)"`
+	UserId         string    `xorm:"VARCHAR(64)"`
+	UserName       string    `xorm:"VARCHAR(50)"`
+	UserHeadImg    string    `xorm:"TEXT"`
+	CreateDate     time.Time `xorm:"DATETIME"`
+	Status         int       `xorm:"SMALLINT(6)"`
+	WriteoffDate   time.Time `xorm:"DATETIME"`
+	OrgId          string    `xorm:"VARCHAR(64)"`
+	CaseId         string    `xorm:"VARCHAR(64)"`
+	PrizeType      string    `xorm:"VARCHAR(20)"`
+	CouponCardType string    `xorm:"VARCHAR(20)"`
+	CouponCardId   string    `xorm:"VARCHAR(64)"`
 }

models/model/ta_vip_card_child.go

@@ -16,4 +16,6 @@ type TaVipCardChild struct {
 	Amount           string    `xorm:"DECIMAL(8,2)"`
 	SalesId          string    `xorm:"VARCHAR(64)"`
 	SalesName        string    `xorm:"VARCHAR(50)"`
+	BeginDate        time.Time `xorm:"DATETIME"`
+	EndDate          time.Time `xorm:"DATETIME"`
 }

routers/common.go

@@ -11,6 +11,7 @@ import (
 	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/goods"
 	"spaceofcheng/services/controllers/gymcard"
+	"spaceofcheng/services/controllers/luckdraw"
 	"spaceofcheng/services/controllers/luckdrawlist"
 	"spaceofcheng/services/controllers/marketing"
 	"spaceofcheng/services/controllers/message"
@@ -197,6 +198,16 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("luckdrawlist/verify/:luckdrawId", &luckdrawlist.LuckdrawlistController{}, "get:GetVerifyList"),
 		beego.NSRouter("luckdrawlist/verify/:luckdrawId", &luckdrawlist.LuckdrawlistController{}, "put:VerifyLuckdraw"),
 
+		beego.NSRouter("luckdrawtpl", &luckdraw.LuckDrawController{}, "get:GetLuckDrawTpl"),
+		beego.NSRouter("luckdraw", &luckdraw.LuckDrawController{}, "get:GetLuckDrawList"),
+		beego.NSRouter("luckdraw/:luckdrawid", &luckdraw.LuckDrawController{}, "get:GetLuckDrawByID"),
+		beego.NSRouter("luckdraw", &luckdraw.LuckDrawController{}, "post:SaveLuckDraw"),
+		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"),
+
 		// bodychecklist 体检列表
 		beego.NSRouter("bodychecklist", &bodychecklist.BodychecklistController{}, "get:GetBodyCheckList"),
 		// role 角色

service/luckdraw/luckdraw.go

@@ -6,6 +6,7 @@ import (
 	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/luckdraw"
 	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
 	"time"
 )
@@ -26,6 +27,277 @@ func NewLuckdrawServ(ctx *utils.Context) *LuckdrawServ {
 	}
 }
 
+// GetLuckDrawTpl 获取抽奖模板
+func (s *LuckdrawServ) GetLuckDrawTpl() ([]model.TaLuckdrawTpl, error) {
+	org := s.ctx.Get("org").(model.SysOrg)
+	tpls, err := s.dao.GetLuckDrawTpl(org.OrgId)
+	return tpls, err
+}
+
+// GetLuckDrawList 获取抽奖列表
+func (s *LuckdrawServ) GetLuckDrawList(caseids, name, status string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	list, err := s.dao.GetLuckDrawList(caseids, name, status, page, pageSize)
+	if err != nil {
+		utils.LogError("获取抽奖信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖信息失败")
+	}
+	total, err := s.dao.GetLuckDrawCount(caseids, name, status)
+	if err != nil {
+		utils.LogError("获取抽奖信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖信息失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+// GetLuckDrawRecordList 获取抽奖记录列表
+func (s *LuckdrawServ) GetLuckDrawRecordList(luckdrawid, tel string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	list, err := s.dao.GetLuckDrawRecord(luckdrawid, tel, page, pageSize)
+	if err != nil {
+		utils.LogError("获取抽奖记录信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖记录信息失败")
+	}
+	total, err := s.dao.GetLuckDrawRecordCount(luckdrawid, tel)
+	if err != nil {
+		utils.LogError("获取抽奖记录信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖记录信息失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+// GetLuckDrawShareList 获取抽奖分享记录列表
+func (s *LuckdrawServ) GetLuckDrawShareList(luckdrawid, tel string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	if page == 0 {
+		page = 1
+	}
+	list, err := s.dao.GetLuckDrawShare(luckdrawid, tel, page, pageSize)
+	if err != nil {
+		utils.LogError("获取抽奖分享记录信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖分享记录信息失败")
+	}
+	total, err := s.dao.GetLuckDrawShareCount(luckdrawid, tel)
+	if err != nil {
+		utils.LogError("获取抽奖分享记录信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖分享记录信息失败")
+	}
+
+	return map[string]interface{}{
+		"list":     list,
+		"pagesize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+// GetLuckDrawInfoByID 获取单个抽奖记录
+func (s *LuckdrawServ) GetLuckDrawInfoByID(luckdrawid string) (*luckdraw.LuckDrawInfo, error) {
+	info, err := s.dao.GetLuckDrawInfoByID(luckdrawid)
+	if err != nil {
+		utils.LogError("获取抽奖信息失败: " + err.Error())
+		return nil, errors.New("获取抽奖信息失败")
+	}
+	return info, nil
+}
+
+// SaveLuckDraw 保存抽奖信息
+func (s *LuckdrawServ) SaveLuckDraw(luckdraw *luckdraw.LuckDrawInfo) (*model.TaLuckdraw, error) {
+	if luckdraw.CaseId == "" {
+		return nil, utils.LogError("请选择所属案场！")
+	}
+	if luckdraw.Name == "" {
+		return nil, utils.LogError("请输入活动标题！")
+	}
+	if luckdraw.BeginDate.IsZero() || luckdraw.EndDate.IsZero() {
+		return nil, utils.LogError("请选择活动时间！")
+	}
+	if luckdraw.TplId == "" {
+		return nil, utils.LogError("请选择活动模板！")
+	}
+	if luckdraw.LuckdrawRule == "" {
+		return nil, utils.LogError("请填写规则说明！")
+	}
+	var newInfo *model.TaLuckdraw
+	var err error
+	if luckdraw.Id == "" {
+		org := s.ctx.Get("org").(model.SysOrg)
+		luckdraw.OrgId = org.OrgId
+		user := s.ctx.Get("user").(model.SysUser)
+		luckdraw.CreateUser = user.UserId
+		newInfo, err = s.dao.InsertLuckdraw(luckdraw.TaLuckdraw)
+		if err != nil {
+			utils.LogError("保存抽奖信息失败: " + err.Error())
+			return nil, errors.New("保存抽奖信息失败")
+		}
+	} else {
+		if luckdraw.JoinedNum > 0 {
+			var cols = []string{
+				"name",
+				"luckdraw_rule",
+				"remark",
+			}
+			err = s.dao.UpdateLuckDraw(luckdraw.TaLuckdraw, cols)
+			if err != nil {
+				utils.LogError("更新抽奖信息失败: " + err.Error())
+				return nil, errors.New("更新抽奖信息失败")
+			}
+			return &luckdraw.TaLuckdraw, nil
+		}
+		var cols = []string{
+			"name",
+			"tpl_id",
+			"luckdraw_rule",
+			"begin_date",
+			"end_date",
+			"case_id",
+			"remark",
+			"join_num",
+			"join_type",
+			"num_type",
+			"num_interval",
+			"luckdraw_num",
+			"share_type",
+			"share_add_num",
+			"is_sys_luckdraw",
+			"is_internal_default"}
+		err = s.dao.UpdateLuckDraw(luckdraw.TaLuckdraw, cols)
+		if err != nil {
+			utils.LogError("更新抽奖信息失败: " + err.Error())
+			return nil, errors.New("更新抽奖信息失败")
+		}
+		newInfo = &luckdraw.TaLuckdraw
+		// 删除奖品内定信息
+		err = s.dao.DelLuckDrawDefault(luckdraw.Id)
+		if err != nil {
+			utils.LogError("删除抽奖内定信息失败: " + err.Error())
+			return nil, errors.New("更新抽奖信息失败")
+		}
+		// 删除抽奖图片信息
+		err = s.dao.DelLuckDrawImgs(luckdraw.Id)
+		if err != nil {
+			utils.LogError("删除抽奖图片信息失败: " + err.Error())
+			return nil, errors.New("更新抽奖信息失败")
+		}
+		// 删除奖品信息
+		err = s.dao.DelLuckDrawPrize(luckdraw.Id)
+		if err != nil {
+			utils.LogError("删除奖品信息失败: " + err.Error())
+			return nil, errors.New("更新奖品信息失败")
+		}
+	}
+
+	// 保存抽奖图片信息
+	err = s.dao.SaveLuckDrawImgs(luckdraw.Imgs, newInfo.Id)
+	if err != nil {
+		utils.LogError("保存抽奖图片信息失败: " + err.Error())
+		return nil, errors.New("保存抽奖图片信息失败")
+	}
+	// 保存内定信息
+	if luckdraw.IsInternalDefault == models.BOOL_TRUE {
+		err = s.dao.SaveLuckDrawDefault(luckdraw.Defaults, newInfo.Id)
+		if err != nil {
+			utils.LogError("保存奖品内定信息失败: " + err.Error())
+			return nil, errors.New("保存奖品内定信息失败")
+		}
+	}
+	// 保存奖品信息
+	err = s.dao.SaveLuckDrawPrizes(luckdraw.Prizes, newInfo.Id)
+	if err != nil {
+		utils.LogError("保存奖品信息失败: " + err.Error())
+		return nil, errors.New("保存奖品信息失败")
+	}
+	return newInfo, nil
+}
+
+// OpenLuckDraw 启动游戏
+func (s *LuckdrawServ) OpenLuckDraw(id string) error {
+	ld, err := s.dao.GetLuckDrawByID(id)
+	if err != nil {
+		utils.LogError("获取游戏信息失败: " + err.Error())
+		return errors.New("获取游戏信息失败")
+	}
+	if ld.Status != models.STATUS_READY {
+		return errors.New("游戏状态异常，请刷新后重试！")
+	}
+	var luckdraw = model.TaLuckdraw{
+		Id:     id,
+		Status: models.STATUS_NORMAL,
+	}
+	err = s.dao.UpdateLuckDraw(luckdraw, []string{
+		"status",
+	})
+	return err
+}
+
+// StopLuckDraw 暂停游戏
+func (s *LuckdrawServ) StopLuckDraw(id string) error {
+	// 判断
+	ld, err := s.dao.GetLuckDrawByID(id)
+	if err != nil {
+		utils.LogError("获取游戏信息失败: " + err.Error())
+		return errors.New("获取游戏信息失败")
+	}
+	if ld.Status != models.STATUS_NORMAL {
+		return errors.New("游戏状态异常，请刷新后重试！")
+	}
+
+	var luckdraw = model.TaLuckdraw{
+		Id:     id,
+		Status: models.STATUS_READY,
+	}
+	err = s.dao.UpdateLuckDraw(luckdraw, []string{
+		"status",
+	})
+	return err
+}
+
+// DelLuckDraw 删除游戏
+func (s *LuckdrawServ) DelLuckDraw(id string) error {
+	// 判断
+	ld, err := s.dao.GetLuckDrawByID(id)
+	if err != nil {
+		utils.LogError("获取游戏信息失败: " + err.Error())
+		return errors.New("获取游戏信息失败")
+	}
+	if ld.Status != models.STATUS_NORMAL {
+		return errors.New("游戏状态异常，请刷新后重试！")
+	}
+	var luckdraw = model.TaLuckdraw{
+		Id:     id,
+		Status: models.STATUS_DEL,
+	}
+	err = s.dao.UpdateLuckDraw(luckdraw, []string{
+		"status",
+	})
+	return err
+}
+
+// GetLuckDraw 获取抽奖信息
 func (s *LuckdrawServ) GetLuckDraw(id string) (*luckdraw.LuckDraw, error) {
 	luck, err := s.dao.GetLuckDraw(id)
 	if err != nil {
@@ -34,6 +306,7 @@ func (s *LuckdrawServ) GetLuckDraw(id string) (*luckdraw.LuckDraw, error) {
 	return luck, nil
 }
 
+// LuckDraw 抽奖
 func (s *LuckdrawServ) LuckDraw(id string, user *model.TaCustomer) (*model.TaLuckdrawPrize, *model.TaPrizeDetail, error) {
 	prize, prizeDetail, recored, err := s.dao.LuckDraw(id, user)
 	if err != nil {
@@ -267,3 +540,9 @@ func (s *LuckdrawServ) GetLuckDrawShareData(luckID, from, to, caseID string) ([]
 	}
 	return share, nil
 }
+
+// UpdateShareNum 更新抽奖次数
+func (s *LuckdrawServ) UpdateShareNum(luckdraw *luckdraw.LuckDraw, fromid string) error {
+	err := s.dao.UpdateShareNum(luckdraw, fromid)
+	return err
+}

utils/rand.go

@@ -3,6 +3,8 @@ package utils
 import (
 	"math/rand"
 	"reflect"
+	"strconv"
+	"strings"
 	"time"
 )
 
@@ -30,6 +32,17 @@ func Shuffle(arr interface{}) interface{} {
 	return res.Interface()
 }
 
+// GetRand 获取随机数
+func GetRand(len int) string {
+	newSeed()
+	var r []string
+	for i := 0; i < len; i++ {
+		m := rnd.Intn(9)
+		r = append(r, strconv.Itoa(m))
+	}
+	return strings.Join(r, "")
+}
+
 // LuckyDraw 抽奖
 func LuckyDraw(pList []map[string]interface{}) interface{} {
 	// 奖池

utils/rand_test.go

@@ -0,0 +1,15 @@
+package utils_test
+
+import (
+	"spaceofcheng/services/utils"
+	"testing"
+)
+
+func TestGetRand(t *testing.T) {
+	res1 := utils.GetRand(6)
+	res2 := utils.GetRand(6)
+
+	if res1 == res2 {
+		t.Fatalf("TestGetRand error, %s, %s", res1, res2)
+	}
+}