1023PM

conf/log.conf

 [common]
-filename="E:\\GoProjects\\src\\spaceofcheng\\services\\log\\common.log"
+filename="E:\\GoProject\\src\\spaceofcheng\\services\\log\\common.log"
 # log level "emergency", "alert", "critical", "error", "warning", "notice", "info", "debug"
 level="debug"

controllers/card/card.go

 		pagesize = 10
 	}
 
-	list, total, err := c.serv.GetCardList(caseid, page, pagesize)
+	sendtype := c.GetString("sendtype")
+	usetype := c.GetString("usetype")
+
+	list, total, err := c.serv.GetCardList(caseid, sendtype, usetype, page, pagesize)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/luckdraw/luckdraw.go

 package luckdraw
 
 import (
+	"encoding/json"
 	"errors"
 	"net/http"
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/luckdraw"
 	"spaceofcheng/services/utils"
+
+	"github.com/astaxie/beego"
 )
 
 // LuckdrawController 应用
 
 // SaveLuckDraw 保存抽奖信息
 func (c *LuckDrawController) SaveLuckDraw() {
+	jsnStr := c.GetString("info")
+	if jsnStr == "" {
+		c.ResponseError(errors.New("未接收到保存内容"))
+	}
 	info := luckdrawModel.LuckDrawInfo{}
-	if err := c.ParseForm(&info); err != nil {
+	if err := json.Unmarshal([]byte(jsnStr), &info); err != nil {
+		utils.LogError("抽奖数据转换失败: " + err.Error())
 		c.ResponseError(err)
 	}
+	beego.Error(info)
 	newinfo, err := c.serv.SaveLuckDraw(&info)
 	if err != nil {
 		c.ResponseError(err)

models/constant.go

 	FLASH_VALIDATE_DAYS = "days"
 	FLASH_VALIDATE_DATE = "date"
 )
+
+const (
+	COUPONCARD_USETYPE_LUCKDRAW = "luckdraw"
+	COUPONCARD_USETYPE_SYS      = "sysactive"
+)

models/luckdraw/luckdraw.go

 		dao.And("name like '%" + name + "%'")
 	}
 	if status != "" {
-		dao.And("status=?", status)
+		query := `status=?`
+		switch status {
+		case strconv.Itoa(models.STATUS_NORMAL):
+			query = query + " and end_date>now()"
+			break
+		case strconv.Itoa(models.STATUS_EXPIRE):
+			query = "(" + query + " or end_date<=now())"
+		}
+		dao.And(query, status)
 	}
 	err := dao.Desc("create_date").Limit(pageSize, (page-1)*pageSize).Find(&luckdraws)
 	return luckdraws, err
 }
 
 // SaveLuckDrawDefault 保存内定信息
-func (m *LuckDrawDao) SaveLuckDrawDefault(defaults []model.TaPrizeDefault, luckdrawid string) error {
+func (m *LuckDrawDao) SaveLuckDrawDefault(defaults []model.TaPrizeDefault, prize model.TaLuckdrawPrize) 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
+			defaults[inx].LuckdrawId = prize.LuckdrawId
+			defaults[inx].PrizeId = prize.Id
 		}
 	}
 	_, err := m.db.Insert(defaults)
 		if prize.Id == "" {
 			prizes[inx].LuckdrawId = luckdraw.Id
 			prizes[inx].Id = utils.GetGUID()
+			prizes[inx].Remainder = prize.Stock
 			prizes[inx].Status = models.STATUS_NORMAL
 		}
 		if prize.PrizeType == models.PRIZE_TYPE_COUPONCARD {
-			m.SavePrizeDetail(prize.TaLuckdrawPrize)
+			err := m.SavePrizeDetail(prizes[inx].TaLuckdrawPrize)
+			if err != nil {
+				return err
+			}
 		}
-		saveprizes = append(saveprizes, prize.TaLuckdrawPrize)
+		saveprizes = append(saveprizes, prizes[inx].TaLuckdrawPrize)
 		// 保存内定信息
 		if luckdraw.IsInternalDefault == models.BOOL_TRUE {
-			err := m.SaveLuckDrawDefault(prize.Defaults, prizes[inx].Id)
+			err := m.SaveLuckDrawDefault(prize.Defaults, prizes[inx].TaLuckdrawPrize)
 			if err != nil {
 				return err
 			}
 				Status:  models.STATUS_NORMAL,
 			}
 			details = append(details, d)
+			i = i + 1
+		}
+		m.db.Insert(details)
+	} else {
+		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 {
+			return errors.New("卡券已被使用！不允许保存！")
+		}
+		var details []model.TaPrizeDetail
+		i := 0
+		for i < card.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)
+			i = i + 1
 		}
 		m.db.Insert(details)
 	}

service/card/card.go

 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/system"
 	"spaceofcheng/services/service"
+	"spaceofcheng/services/service/events"
 	"spaceofcheng/services/utils"
 	"strings"
 	"time"
 }
 
 // GetCardList 获取卡列表
-func (s *CardServ) GetCardList(caseID string, pagenavi ...int) ([]model.TaCouponCard, int64, error) {
+func (s *CardServ) GetCardList(caseID, sendtype, usetype string, pagenavi ...int) ([]model.TaCouponCard, int64, error) {
 	filters := []string{}
 	if caseID != "" {
 		if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
 			"case_id in ('" + strings.Join(caseIDs, "','") + "')",
 		}
 	}
+	if sendtype != "" {
+		filters = append(filters, "send_type='"+sendtype+"'")
+		if usetype != "" {
+			switch usetype {
+			case models.COUPONCARD_USETYPE_LUCKDRAW:
+				filters = append(filters, "card_id not in (select resource_id from sys_activity_action where active_type='"+events.ActGiveCoupon+"')")
+				break
+			case models.COUPONCARD_USETYPE_SYS:
+				filters = append(filters, "card_id not in (select coupon_card_id from ta_luckdraw_record where coupon_card_type='"+models.PRIZE_TYPE_CARD+"')")
+				break
+			}
+		}
+	}
 
 	limit := utils.GetPageNaviLimit(pagenavi...)
 	res, total, err := s.dao.GetCardList(filters, limit)