2.1.0

controllers/card/card.go

@@ -266,3 +266,12 @@ func (c *CardController) GetCustomerCardByCustomerAndSale() {
 	}
 	c.ResponseJSON(cards)
 }
+
+func (c *CardController) GetSysCardList() {
+	caseid := c.GetString(":caseId")
+	cards, err := c.serv.GetSysCardList(caseid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(cards)
+}

controllers/flashbuy/flashbuy.go

@@ -35,9 +35,20 @@ func (c *FlashBuyController) GetFlashBuyList() {
 	c.ResponseJSON(list)
 }
 
+func (c *FlashBuyController) GetCustomerFlashBuyByCustomerId() {
+	customerId := c.GetString(":customerId")
+	page, _ := c.GetInt("page")
+	pageSize, _ := c.GetInt("pagesize")
+	list, err := c.dao.GetCustomerFlashBuyByCustomerId(customerId, page, pageSize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(list)
+}
+
 func (c *FlashBuyController) GetCustomerFlashBuyList() {
 	flashBuyId := c.GetString(":flashBuyId")
-	phone := c.GetString(":phone")
+	phone := c.GetString("phone")
 	page, _ := c.GetInt("page")
 	pageSize, _ := c.GetInt("pagesize")
 	list, err := c.dao.GetCustomerFlashBuyById(flashBuyId, phone, page, pageSize)
@@ -57,6 +68,15 @@ func (c *FlashBuyController) GetFlashBuyById() {
 	c.ResponseJSON(flashBuy)
 }
 
+func (c *FlashBuyController) GetCustomerFlashBuyId() {
+	flashBuyId := c.GetString(":customerFlashBuyId")
+	flashBuy, err := c.dao.GetCustomerFlashBuyId(flashBuyId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(flashBuy)
+}
+
 func (c *FlashBuyController) SaveFlashBuy() {
 	flashbuy := model.TaFlashBuy{}
 	if err := c.ParseForm(&flashbuy); err != nil {
@@ -80,7 +100,7 @@ func (c *FlashBuyController) DeleteFlashBuy() {
 
 func (c *FlashBuyController) UpdateFlashBuy() {
 	flashBuyId := c.GetString(":flashBuyId")
-	flashBuyStatus := c.GetString("flashBuyStatus")
+	flashBuyStatus := c.GetString(":flashBuyStatus")
 	err := c.dao.UpdateFlashBuy(flashBuyId, flashBuyStatus)
 	if err != nil {
 		c.ResponseError(err)
@@ -90,7 +110,9 @@ func (c *FlashBuyController) UpdateFlashBuy() {
 
 func (c *FlashBuyController) VerifyCustomerFlashBuyList() {
 	qrcode := c.GetString(":qrcode")
-	customerFlashBuy, err := c.dao.VerifyCustomerFlashBuyList(qrcode)
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseids := c.GetCaseIDs(cases)
+	customerFlashBuy, err := c.dao.VerifyCustomerFlashBuyList(qrcode, caseids)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/marketing/marketing.go

@@ -116,3 +116,13 @@ func (c *MarketingController) SetMarketingDisable() {
 	}
 	c.ResponseJSON("操作成功!")
 }
+
+func (c *MarketingController) GetUserCases() {
+	cases := c.Context.Get("cases").([]model.SysUserCase)
+	caseIDs := c.GetCaseIDs(cases)
+	sysCase, err := c.serv.GetUserCases(caseIDs)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(sysCase)
+}

models/card/card.go

@@ -528,3 +528,18 @@ func (m *CardDAO) SaveCardChannel(channelid, cardid string) error {
 	_, err := m.db.Insert(&cardChannel)
 	return err
 }
+
+func (m *CardDAO) GetSysCardList(caseid string) ([]model.TaCouponCard, error) {
+	var card []model.TaCouponCard
+	sql := `SELECT
+	* 
+FROM
+	ta_coupon_card 
+WHERE
+	send_type = '` + models.GIVE_TYPE_SYSTEM + `'
+	and case_id = '` + caseid + `'
+	and  a.status > ` + strconv.Itoa(models.STATUS_DEL)
+	err := m.db.Sql(sql).Find(&card)
+	return card, err
+
+}

models/flashbuy/flashbuy.go

@@ -35,6 +35,14 @@ type CustomerFlashBuy struct {
 	CustomerName             string
 	Phone                    string
 }
+type CustomerFlashResult struct {
+	model.TaCustomerFlashBuy `xorm:"extends"`
+	FlashBuyName             string
+}
+type CustomerFlashDetail struct {
+	model.TaCustomerFlashBuy `xorm:"extends"`
+	CustomerQrcode           string
+}
 
 func (m *FlashbuyDAO) GetFlashBuyList(caseid, flashBuyName, flashBuyStatus string, page, pageSize int) ([]FlashBuy, error) {
 	var flashBuy []FlashBuy
@@ -183,7 +191,7 @@ WHERE
 	return len(customerFlashBuy), err
 }
 
-func (m *FlashbuyDAO) GetCustomerFlashBuyByQr(customerFlashBuyId string) (*CustomerFlashBuy, error) {
+func (m *FlashbuyDAO) GetCustomerFlashBuyByQr(customerFlashBuyId, caseId string) (*CustomerFlashBuy, error) {
 	var customerFlashBuy []CustomerFlashBuy
 	sql := `SELECT
 	a.*,
@@ -195,7 +203,7 @@ FROM
 	INNER JOIN ta_customer b ON a.customer_id = b.customer_id
 	INNER JOIN sys_case c ON a.case_id = c.case_id 
 WHERE
-	a.customer_flash_buy_id ='` + customerFlashBuyId + `'`
+	a.customer_flash_buy_id ='` + customerFlashBuyId + `' and a.case_id = '` + caseId + `'`
 	sql += ` and a.validate_start <= now() and a.validate_end >= now()`
 	err := m.db.Sql(sql).Find(&customerFlashBuy)
 	if len(customerFlashBuy) > 0 {
@@ -204,6 +212,45 @@ WHERE
 	return nil, nil
 }
 
+func (m *FlashbuyDAO) GetCustomerFlashBuyByCustomerId(customerId string, page, pageSize int) ([]CustomerFlashResult, error) {
+	var customerResult []CustomerFlashResult
+	sql := `select a.*,b.flash_buy_name
+	 from ta_customer_flash_buy a 
+	 inner join ta_flash_buy b 
+	 on a.flash_buy_id = b.flash_buy_id
+	 where a.customer_id = '` + customerId + `'`
+	sql += ` order by a.validate_start desc  limit ` + strconv.Itoa(page-1) + `, ` + strconv.Itoa(pageSize)
+	err := m.db.Sql(sql).Find(&customerResult)
+	return customerResult, err
+
+}
+
+func (m *FlashbuyDAO) GetCustomerFlashBuyByCustomerIdCount(customerId string) (int, error) {
+	var customerResult []CustomerFlashResult
+	sql := `select a.*,b.flash_buy_name
+	 from ta_customer_flash_buy a 
+	 inner join ta_flash_buy b 
+	 on a.flash_buy_id = b.flash_buy_id
+	 where a.customer_id = '` + customerId + `'`
+	err := m.db.Sql(sql).Find(&customerResult)
+	return len(customerResult), err
+
+}
+
+func (m *FlashbuyDAO) GetCustomerFlashBuyId(customerFlashBuyId string) (*CustomerFlashDetail, error) {
+	var customerDetail CustomerFlashDetail
+	sql := `SELECT
+	a.*,
+	b.customer_qrcode 
+FROM
+	ta_customer_flash_buy a
+	INNER JOIN ta_customer_course_qrcode b ON a.customer_flash_buy_id = b.customer_course_id
+	WHERE a.customer_flash_buy_id = '` + customerFlashBuyId + `'`
+	err := m.db.Sql(sql).Find(&customerDetail)
+	return &customerDetail, err
+
+}
+
 // Update
 
 // FlashBuy 抢购

models/marketing/marketing.go

@@ -136,3 +136,14 @@ func (m *MarketingDAO) UpdateMarketing(activity model.SysActivity) error {
 	_, err := m.db.Cols(cols...).Where("action_id=?", activity.ActivityId).Update(activity)
 	return err
 }
+
+func (m *MarketingDAO) GetUserCases(caseid string) ([]model.SysCase, error) {
+	var cases []model.SysCase
+	sql := `SELECT
+	* 
+FROM
+	sys_case 
+WHERE case_id in ('` + strings.Replace(caseid, ",", "','", -1) + `')`
+	err := m.db.Sql(sql).Find(&cases)
+	return cases, err
+}

routers/common.go

@@ -277,6 +277,7 @@ func getCommonRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/card/:id", &card.CardController{}, "get:GetCardByIDForAdmin"),
 		beego.NSRouter("/card/:id", &card.CardController{}, "put:UpdateCard"),
 		beego.NSRouter("/card/:id/to/:users", &card.CardController{}, "post:GiveCard"),
+		beego.NSRouter("/card/:caseId", &card.CardController{}, "get:GetSysCardList"),
 		// 赠送记录
 		beego.NSRouter("/record", &card.RecordController{}, "get:GetRecordList"),
 
@@ -298,6 +299,7 @@ func getCommonRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/marketing/normal/:activityId", &marketing.MarketingController{}, "put:SetMarketingNormal"),
 		beego.NSRouter("/marketing/disable/:activityId", &marketing.MarketingController{}, "put:SetMarketingDisable"),
 		beego.NSRouter("/marketing/:activityId", &marketing.MarketingController{}, "delete:DelMarketing"),
+		beego.NSRouter("/marketing/case", &marketing.MarketingController{}, "get:GetUserCases"),
 
 		// websocket
 		beego.NSRouter("/websocket/:grps/:id", &controllers.BaseController{}, "get:Ws"),

routers/wechat.go

@@ -7,6 +7,7 @@ import (
 	"spaceofcheng/services/controllers/coupon"
 	"spaceofcheng/services/controllers/course"
 	"spaceofcheng/services/controllers/customer"
+	"spaceofcheng/services/controllers/flashbuy"
 	"spaceofcheng/services/controllers/goods"
 	"spaceofcheng/services/controllers/gymcard"
 	"spaceofcheng/services/controllers/luckdraw"
@@ -90,5 +91,10 @@ func getWechatRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/luckdraw/record", &luckdraw.LuckDrawController{}, "get:GetRecordByLuckDraw"),
 		beego.NSRouter("/user/luckdraw/record", &luckdraw.LuckDrawController{}, "get:GetUserLuckDraw"),
 		beego.NSRouter("/user/luckdraw/record/:id", &luckdraw.LuckDrawController{}, "get:GetRecordByID"),
+
+		// 抢购
+		beego.NSRouter("/flashbuy/:flashBuyId", &flashbuy.FlashBuyController{}, "get:GetFlashBuyById"),
+		beego.NSRouter("/flashbuy/:customerId", &flashbuy.FlashBuyController{}, "get:GetCustomerFlashBuyByCustomerId"),
+		beego.NSRouter("/flashbuy/:customerFlashBuyId", &flashbuy.FlashBuyController{}, "get:GetCustomerFlashBuyId"),
 	)
 }

service/card/card.go

@@ -392,6 +392,15 @@ func (s *CardServ) GetCustomerCardByID(id string) (*card.CustomerCardWithShare,
 	return card, nil
 }
 
+func (s *CardServ) GetSysCardList(caseid string) ([]model.TaCouponCard, error) {
+	cards, err := s.dao.GetSysCardList(caseid)
+	if err != nil {
+		utils.LogError("获取体验卡失败: " + err.Error())
+		return nil, errors.New("获取体验卡失败")
+	}
+	return cards, nil
+}
+
 // GetCaseUsableCard 获取案场可用卡
 func (s *CardServ) GetCaseUsableCard(page, pageSize int) (map[string]interface{}, error) {
 

service/events/constant.go

@@ -13,4 +13,5 @@ const (
 
 	// 送券
 	ActGiveCoupon = "giveCoupon"
+	ActGiveCard   = "giveCard"
 )

service/flashbuy/flashbuy.go

@@ -109,7 +109,7 @@ func (s *FlashBuyServ) GetCustomerFlashBuyById(flashBuyId, phone string, page, p
 	}, nil
 }
 
-func (s *FlashBuyServ) VerifyCustomerFlashBuyList(qrcode string) (*flashbuy.CustomerFlashBuy, error) {
+func (s *FlashBuyServ) VerifyCustomerFlashBuyList(qrcode, caseId string) (*flashbuy.CustomerFlashBuy, error) {
 	var err error
 	var customerFlashBuyId string
 	var customerVerify *flashbuy.CustomerFlashBuy
@@ -118,7 +118,7 @@ func (s *FlashBuyServ) VerifyCustomerFlashBuyList(qrcode string) (*flashbuy.Cust
 		utils.LogError("获取核销列表失败: " + err.Error())
 		return nil, errors.New("获取核销列表失败")
 	}
-	customerVerify, err = s.dao.GetCustomerFlashBuyByQr(customerFlashBuyId)
+	customerVerify, err = s.dao.GetCustomerFlashBuyByQr(customerFlashBuyId, caseId)
 	if err != nil {
 		utils.LogError("获取核销列表失败: " + err.Error())
 		return nil, errors.New("获取核销列表失败")
@@ -135,3 +135,34 @@ func (s *FlashBuyServ) Verify(customerFlashBuyId string) error {
 	}
 	return nil
 }
+
+func (s *FlashBuyServ) GetCustomerFlashBuyByCustomerId(customerId string, page, pageSize int) (map[string]interface{}, error) {
+	if pageSize == 0 {
+		pageSize = service.PAGENUM
+	}
+	flashbuys, err := s.dao.GetCustomerFlashBuyByCustomerId(customerId, page, pageSize)
+	if err != nil {
+		utils.LogError("获取抢购活动列表失败: " + err.Error())
+		return nil, errors.New("获取抢购活动列表失败")
+	}
+	total, err := s.dao.GetCustomerFlashBuyByCustomerIdCount(customerId)
+	if err != nil {
+		utils.LogError("获取抢购活动列表失败: " + err.Error())
+		return nil, errors.New("获取抢购活动列表失败")
+	}
+	return map[string]interface{}{
+		"list":     flashbuys,
+		"pageSize": pageSize,
+		"pagenum":  total,
+		"page":     page,
+	}, nil
+}
+
+func (s *FlashBuyServ) GetCustomerFlashBuyId(customerFlashBuyId string) (*flashbuy.CustomerFlashDetail, error) {
+	flashbuy, err := s.dao.GetCustomerFlashBuyId(customerFlashBuyId)
+	if err != nil {
+		utils.LogError("获取抢购活动信息失败: " + err.Error())
+		return nil, errors.New("获取抢购活动信息失败")
+	}
+	return flashbuy, nil
+}

service/marketing/marketing.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"errors"
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/card"
 	"spaceofcheng/services/models/coupon"
 	"spaceofcheng/services/models/marketing"
 	"spaceofcheng/services/models/model"
@@ -22,6 +23,7 @@ type MarketingServ struct {
 	wdao      *marketing.WorkDAO
 	userdao   *system.UserDAO
 	couponDAO *coupon.CouponDAO
+	cardDAO   *card.CardDAO
 }
 
 // NewMarketingServ 初始化
@@ -32,6 +34,7 @@ func NewMarketingServ(ctx *utils.Context) *MarketingServ {
 		wdao:      marketing.NewWorkDAO(ctx),
 		userdao:   system.NewUserDAO(ctx),
 		couponDAO: coupon.NewCouponDAO(ctx),
+		cardDAO:   card.NewCardDAO(ctx),
 	}
 }
 
@@ -225,3 +228,12 @@ func (s *MarketingServ) UpdateMarketing(activity model.SysActivity) error {
 	err := s.dao.UpdateMarketing(activity)
 	return err
 }
+
+func (s *MarketingServ) GetUserCases(caseId string) ([]model.SysCase, error) {
+	cases, err := s.dao.GetUserCases(caseId)
+	if err != nil {
+		utils.LogError("获取用户案场失败: " + err.Error())
+		return nil, errors.New("获取用户案场失败")
+	}
+	return cases, nil
+}