新用户抢购

controllers/flashbuy/flashbuy.go

@@ -162,3 +162,41 @@ func (c *FlashBuyController) GetFlashModelList() {
 	}
 	c.ResponseJSON(model)
 }
+
+func (c *FlashBuyController) AddNewFlashBuyCustomer() {
+	cust := c.Context.Get("customer").(model.TaCustomer)
+	flashBuyId := c.GetString(":flashBuyId")
+	err := c.dao.AddNewFlashBuyCustomer(cust, flashBuyId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("添加成功")
+}
+
+func (c *FlashBuyController) UpdateFlashBuyCustomer() {
+	cust := c.Context.Get("customer").(model.TaCustomer)
+	flashBuyId := c.GetString(":flashBuyId")
+	err := c.dao.UpdateFlashBuyCustomer(cust.CustomerId, flashBuyId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("修改成功")
+}
+
+func (c *FlashBuyController) IsFlashBuyCustomer() {
+	cust := c.Context.Get("customer").(model.TaCustomer)
+	flashBuyId := c.GetString(":flashBuyId")
+	flag, err := c.dao.IsFlashBuyCustomer(cust.CustomerId, flashBuyId)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(flag)
+}
+
+func (c *FlashBuyController) IsNewCustomer() {
+	cust := c.Context.Get("customer").(model.TaCustomer)
+	if cust.Phone == "" {
+		c.ResponseError(errors.New("不是新用户"))
+	}
+	c.ResponseJSON("是新用户")
+}

models/flashbuy/flashbuy.go

@@ -291,3 +291,38 @@ func (m *FlashbuyDAO) GetFlashModelList() ([]model.TdFlashbuyModel, error) {
 	err := m.db.Sql(sql).Find(&model)
 	return model, err
 }
+
+func (m *FlashbuyDAO) AddNewFlashBuyCustomer(customer model.TaFlashBuyCustomer) error {
+	customer.CreateDate = time.Now()
+	customer.FlashBuyCustomerId = utils.GetGUID()
+	_, err := m.db.Insert(customer)
+	return err
+}
+
+func (m *FlashbuyDAO) UpdateFlashBuyCustomer(customerId, flashBuyId string) error {
+	var customer = model.TaFlashBuyCustomer{
+		CustomerId: customerId,
+		IsNew:      0,
+	}
+	var cols = []string{
+		"is_new",
+	}
+	_, err := m.db.Cols(cols...).Where("customer_id = ?", customer.CustomerId).And("flash_buy_id =?", flashBuyId).Update(customer)
+	return err
+}
+
+func (m *FlashbuyDAO) IsFlashBuyCustomer(customerId, flashBuyId string) (*model.TaFlashBuyCustomer, error) {
+	var customer []model.TaFlashBuyCustomer
+	sql := `SELECT
+	* 
+FROM
+	ta_flash_buy_customer 
+WHERE
+	customer_id = '` + customerId + `'
+	and flash_buy_id = '` + flashBuyId + `'`
+	err := m.db.Sql(sql).Find(&customer)
+	if len(customer) <= 0 {
+		return nil, err
+	}
+	return &customer[0], err
+}

models/model/ta_flash_buy_customer.go

@@ -0,0 +1,13 @@
+package model
+
+import (
+	"time"
+)
+
+type TaFlashBuyCustomer struct {
+	FlashBuyCustomerId string    `xorm:"not null VARCHAR(64)"`
+	FlashBuyId         string    `xorm:"VARCHAR(64)"`
+	CustomerId         string    `xorm:"VARCHAR(64)"`
+	IsNew              int       `xorm:"TINYINT(1)"`
+	CreateDate         time.Time `xorm:"DATETIME"`
+}

models/model/td_flashbuy_model.go

@@ -1,9 +1,10 @@
 package model
 
 type TdFlashbuyModel struct {
-	ModelId     string `xorm:"not null pk VARCHAR(64)"`
-	ModelName   string `xorm:"VARCHAR(64)"`
-	OrgId       string `xorm:"VARCHAR(64)"`
-	Status      int    `xorm:"SMALLINT(6)"`
-	ModelImgUrl string `xorm:"TEXT"`
+	ModelId          string `xorm:"not null pk VARCHAR(64)"`
+	ModelName        string `xorm:"VARCHAR(64)"`
+	OrgId            string `xorm:"VARCHAR(64)"`
+	Status           int    `xorm:"SMALLINT(6)"`
+	ModelImgUrl      string `xorm:"TEXT"`
+	ModelLargeImgUrl string `xorm:"TEXT"`
 }

routers/wechat.go

@@ -101,6 +101,10 @@ func getWechatRoutes(prefix string) beego.LinkNamespace {
 		beego.NSRouter("/flashbuy/customer", &flashbuy.FlashBuyController{}, "get:GetCustomerFlashBuyByCustomerId"),
 		beego.NSRouter("/flashbuy/customerFlash/:customerFlashBuyId", &flashbuy.FlashBuyController{}, "get:GetCustomerFlashBuyId"),
 		beego.NSRouter("/flashbuy/:id", &flashbuy.FlashBuyController{}, "post:FlashBuy"),
+		beego.NSRouter("/flashbuy/customer/:flashBuyId", &flashbuy.FlashBuyController{}, "post:AddNewFlashBuyCustomer"),
+		beego.NSRouter("/flashbuy/customer/:flashBuyId", &flashbuy.FlashBuyController{}, "put:UpdateFlashBuyCustomer"),
+		beego.NSRouter("/flashbuy/customer/:flashBuyId", &flashbuy.FlashBuyController{}, "get:IsFlashBuyCustomer"),
+		beego.NSRouter("/flashbuy/newcustomer", &flashbuy.FlashBuyController{}, "get:IsNewCustomer"),
 
 		// 客户备注
 		beego.NSRouter("/customerremark/record/:salesId/:customerId", &customerremark.CustomerRemarkController{}, "get:GetCustomerReceiveRecord"),

service/events/events.go

@@ -17,9 +17,10 @@ var EvtActions = map[string]tinyevent.Action{
 	// 测试
 	ActTest: tsAction,
 
-	// 赠送卡券
+	// 赠送券
 	ActGiveCoupon: giveCoupon,
 
+	// 赠送卡
 	ActGiveCard: giveCard,
 }
 

service/events/giveCard.go

@@ -12,7 +12,7 @@ import (
 )
 
 var giveCard = func(e tinyevent.Event) error {
-	utils.LogInfo("开始卡券赠送操作...")
+	utils.LogInfo("开始卡赠送操作...")
 
 	ctx := NewContext()
 	defer DestroyContext(ctx, false)

service/events/giveCoupon.go

@@ -14,7 +14,7 @@ import (
 // giveCoupon 赠送卡券
 // Event.Payload.customer  = model.TaCustomer
 var giveCoupon = func(e tinyevent.Event) error {
-	utils.LogInfo("开始卡券赠送操作...")
+	utils.LogInfo("开始券赠送操作...")
 
 	ctx := NewContext()
 	defer DestroyContext(ctx, false)

service/flashbuy/flashbuy.go

@@ -314,3 +314,41 @@ func (s *FlashBuyServ) GetFlashModelList() ([]model.TdFlashbuyModel, error) {
 	}
 	return model, nil
 }
+
+func (s *FlashBuyServ) AddNewFlashBuyCustomer(customer model.TaCustomer, flashBuyId string) error {
+	var flashBuyCustomer = model.TaFlashBuyCustomer{
+		FlashBuyId: flashBuyId,
+		CustomerId: customer.CustomerId,
+	}
+	if customer.Phone == "" {
+		flashBuyCustomer.IsNew = 1
+	} else {
+		flashBuyCustomer.IsNew = 0
+	}
+	err := s.dao.AddNewFlashBuyCustomer(flashBuyCustomer)
+	if err != nil {
+		utils.LogError("存储用户抢购记录失败: " + err.Error())
+		return errors.New("存储用户抢购记录失败")
+	}
+	return nil
+}
+func (s *FlashBuyServ) UpdateFlashBuyCustomer(customerId, flashBuyId string) error {
+	err := s.dao.UpdateFlashBuyCustomer(customerId, flashBuyId)
+	if err != nil {
+		utils.LogError("更新用户抢购记录失败: " + err.Error())
+		return errors.New("更新用户抢购记录失败")
+	}
+	return nil
+}
+
+func (s *FlashBuyServ) IsFlashBuyCustomer(customerId, flashBuyId string) (bool, error) {
+	flashBuyCustomer, err := s.dao.IsFlashBuyCustomer(customerId, flashBuyId)
+	if err != nil {
+		utils.LogError("判断是否参与失败: " + err.Error())
+		return false, errors.New("判断是否参与失败")
+	}
+	if flashBuyCustomer != nil || flashBuyCustomer.IsNew == 0 {
+		return false, errors.New("客户已参与本次抢购")
+	}
+	return true, nil
+}