抢购

models/flashbuy/flashbuy.go

@@ -204,9 +204,17 @@ WHERE
 	return nil, nil
 }
 
-// Update
-
-// FlashBuy 抢购
-// func (m *FlashbuyDAO) FlashBuy() error {
+// GetCustomerFlashBuy 获取用户抢购信息
+func (m *FlashbuyDAO) GetCustomerFlashBuy(id, customerid string) ([]model.TaCustomerFlashBuy, error) {
+	var buys []model.TaCustomerFlashBuy
+	err := m.db.Where("flash_buy_id=?").And("customer_id=?").And("status>?", models.STATUS_DEL).Find(&buys)
+	return buys, err
+}
 
-// }
+// UpdateFlashBuyJoin 更新抢购参与人数
+func (m *FlashbuyDAO) UpdateFlashBuyJoin(id string) (int64, error) {
+	sql := `update ta_flash_buy set join_num = join_num + 1 where flash_buy_id=? and join_num < flash_buy_max_attendant`
+	result, err := m.db.Exec(sql, id)
+	rowCount, err := result.RowsAffected()
+	return rowCount, err
+}

service/flashbuy/flashbuy.go

@@ -2,11 +2,13 @@ package flashbuy
 
 import (
 	"errors"
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/flashbuy"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/verify"
 	"spaceofcheng/services/service"
 	"spaceofcheng/services/utils"
+	"time"
 )
 
 // FlashBuyServ 系统处理
@@ -135,3 +137,67 @@ func (s *FlashBuyServ) Verify(customerFlashBuyId string) error {
 	}
 	return nil
 }
+
+// FlashBuy 抢购
+func (s *FlashBuyServ) FlashBuy(id string) error {
+	flashbuy, err := s.dao.GetFlashBuyById(id)
+	if err != nil {
+		utils.LogError("获取抢购活动信息失败: " + err.Error())
+		return errors.New("获取抢购活动信息失败！")
+	}
+	if flashbuy.Status == models.STATUS_NORMAL {
+		return errors.New("抢购活动状态异常！")
+	}
+	if flashbuy.FlashBuyStatus == "" || time.Now().After(flashbuy.EndDate) {
+		return errors.New("活动已结束！")
+	}
+	if flashbuy.FlashBuyStatus == models.FLASH_BUY_INACTIVE {
+		return errors.New("活动已停用！")
+	}
+	if time.Now().Before(flashbuy.StartDate) {
+		return errors.New("活动还未开始！")
+	}
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	buys, err := s.dao.GetCustomerFlashBuy(id, customer.CustomerId)
+	if err != nil {
+		utils.LogError("获取客户抢购信息失败: " + err.Error())
+		return errors.New("获取客户抢购信息失败！")
+	}
+	if len(buys) > 0 {
+		return errors.New("您已参与过该活动！")
+	}
+	if flashbuy.JoinNum >= flashbuy.FlashBuyMaxAttendant {
+		err = s.dao.UpdateFlashBuy(flashbuy.FlashBuyId, models.FLASH_BUY_OVER)
+		if err != nil {
+			utils.LogError("更新状态失败: " + err.Error())
+		}
+		return errors.New("活动已结束！")
+	}
+	var customerFlashBuy model.TaCustomerFlashBuy
+	customerFlashBuy.FlashBuyId = flashbuy.FlashBuyId
+	customerFlashBuy.CustomerId = customer.CustomerId
+	customerFlashBuy.CaseId = flashbuy.CaseId
+	customerFlashBuy.OrgId = flashbuy.OrgId
+	if flashbuy.ValidateType == "" {
+		customerFlashBuy.ValidateStart = flashbuy.StartDate
+		customerFlashBuy.ValidateEnd = flashbuy.EndDate
+	} else {
+		customerFlashBuy.ValidateStart = time.Now().Local()
+		customerFlashBuy.ValidateEnd = time.Now().Local().AddDate(0, 0, flashbuy.ValidateDays)
+	}
+
+	num, err := s.dao.UpdateFlashBuyJoin(flashbuy.FlashBuyId)
+	if err != nil {
+		utils.LogError("抢购失败: " + err.Error())
+		return errors.New("抢购失败！")
+	}
+	if num < 1 {
+		err = s.dao.UpdateFlashBuy(flashbuy.FlashBuyId, models.FLASH_BUY_OVER)
+		if err != nil {
+			utils.LogError("更新状态失败: " + err.Error())
+		}
+		return errors.New("活动已结束！")
+	}
+
+	return nil
+}