1025AM

controllers/flashbuy/flashbuy.go

@@ -8,8 +8,6 @@ import (
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/flashbuy"
 	"spaceofcheng/services/utils"
-
-	"github.com/astaxie/beego"
 )
 
 // CaseController 信息
@@ -77,17 +75,10 @@ func (c *FlashBuyController) GetFlashBuyById() {
 	if err != nil {
 		c.ResponseError(err)
 	}
-	userRaw := c.Context.Get("customer")
-	if userRaw == nil {
-		c.ResponseError(errors.New("系统内部错误"), http.StatusInternalServerError)
-	}
-
-	user := userRaw.(model.TaCustomer)
-	userinfo, err := c.dao.GetCustomerFlashBuyId(flashBuyId, user.CustomerId)
+	userinfo, err := c.dao.GetFlashByUser(flashBuyId)
 	if err != nil {
 		c.ResponseError(err)
 	}
-	beego.Error(userinfo)
 	c.ResponseJSON(map[string]interface{}{
 		"flashBuy": flashBuy,
 		"userInfo": userinfo,

service/flashbuy/flashbuy.go

@@ -62,6 +62,17 @@ func (s *FlashBuyServ) GetFlashBuyById(flashBuyId string) (*model.TaFlashBuy, er
 	}
 	return flashbuy, nil
 }
+
+// GetFlashByUser 获取用户的抢购信息
+func (s *FlashBuyServ) GetFlashByUser(id string) ([]model.TaCustomerFlashBuy, error) {
+	cst := s.ctx.Get("customer")
+	if cst == nil {
+		return nil, errors.New("系统内部错误")
+	}
+	flashbuys, err := s.dao.GetCustomerFlashBuy(id, cst.(model.TaCustomer).CustomerId)
+	return flashbuys, err
+}
+
 func (s *FlashBuyServ) SaveFlashBuy(flashbuy model.TaFlashBuy) (*model.TaFlashBuy, error) {
 	var newFlashBuy *model.TaFlashBuy
 	var err error