Merge branch 'master' of http://git.ichunt.net/q578953158/go_sku_server

model/ly_sku.go

@@ -22,6 +22,7 @@ type LySku struct {
 	Mpq               int64         `json:"mpq"`
 	Multiple          int64         `json:"multiple"`
 	Stock             int64         `json:"stock"`
+	StockJd           int64         `json:"stock_jd"` //京东可售库存
 	HkDeliveryTime    string        `json:"hk_delivery_time"`
 	CnDeliveryTime    string        `json:"cn_delivery_time"`
 	LadderPriceResult interface{}   `json:"ladder_price"`

service/service_ly.go

@@ -313,7 +313,7 @@ func (ls *LyService) LyGoodsDetail(ctx context.Context, params RequestParams, go
 			sku.LadderPriceResult = []int{}
 		}
 
-		sku.Stock = ls.GetStock(sku)
+		sku.Stock, sku.StockJd = ls.GetStock(sku)
 
 		//判断是否可以购买
 		sku.IsBuy = ls.GetIsBuy(sku)

service/service_ly_common.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"encoding/json"
+	"github.com/gogf/gf/util/gconv"
 	"go_sku_server/model"
 	c "go_sku_server/pkg/common"
 	"go_sku_server/pkg/gredis"
@@ -259,26 +260,32 @@ func (ls *LyService) GetIsBuy(sku model.LySku) (isBuy int) {
 }
 
 // 获取库存
-func (ls *LyService) GetStock(sku model.LySku) (stock int64) {
+func (ls *LyService) GetStock(sku model.LySku) (stock_all, jd_stock int64) {
 	//过期修改库存为0
 	if sku.IsExpire == 1 && sku.SupplierId != 17 {
 		sku.Stock = 0
 	}
+	stock_all_t := sku.Stock
+	jd_stock_t := int64(0)
 	//这里还有一个逻辑
 	//如果是寄售的数据(source=12),获取的库存还要减去锁库的库存
 	if sku.Source == 12 || php2go.InArray(sku.Canal, []string{"L0018319", "L0013521", "L0018562", "L0017764", "L0003270", "L0012413", "L0013521"}) {
-		//获取锁库库存
+		//获取总锁库库存
 		redisCon := gredis.Conn("spu")
 		defer redisCon.Close()
 		stockStr, _ := redis.String(redisCon.Do("HGET", "sku_lock_stock", sku.GoodsId))
 		lockStock, _ := strconv.ParseInt(stockStr, 10, 64)
 		if sku.Stock < lockStock {
-			return 0
+			stock_all_t = 0
 		} else {
-			return sku.Stock - lockStock
+			stock_all_t = sku.Stock - lockStock
 		}
+		//获取京东库存
+		jdStockShiwuStr, _ := redis.String(redisCon.Do("HGET", "sku_jd_stock", sku.GoodsId))     // 京东单个sku实物总数量
+		jdStockLockStr, _ := redis.String(redisCon.Do("HGET", "sku_lock_stock_jd", sku.GoodsId)) //京东锁库数量
+		jd_stock_t = gconv.Int64(jdStockShiwuStr) - gconv.Int64(jdStockLockStr)
 	}
-	return sku.Stock
+	return stock_all_t, jd_stock_t
 }
 
 // 合并spu的信息

service/service_stock_info.go

-package service
-
-import (
-	"go_sku_server/model"
-	"go_sku_server/pkg/gredis"
-	"go_sku_server/pkg/logger"
-	"go_sku_server/pkg/mongo"
-	"go_sku_server/pkg/vars"
-	"time"
-
-	"github.com/gogf/gf/util/gconv"
-	"github.com/gomodule/redigo/redis"
-	"github.com/syyongx/php2go"
-	"gopkg.in/mgo.v2"
-	"gopkg.in/mgo.v2/bson"
-)
-
-// 在途库存服务
-type StockInfoService struct {
-}
-
-// 这个是老的在途库存,基本上就是Digikey用的
-func (ss *LyService) getStockInfo(supplierId, oldGoodsId int64) interface{} {
-	if !php2go.InArray(supplierId, vars.StockInfoSupplierIds) {
-		return nil
-	}
-	var stockInfo model.StockInfo
-	//去mongodb获取在途库存信息
-	mongodb := mongo.Conn("default")
-	defer func() {
-		mongodb.Close()
-	}()
-	//还要判断去哪个集合取值
-	collectionName := vars.StockInfoSupplierMap[supplierId]
-	type Goods struct {
-		StockInfo model.StockInfo `bson:"stock_info"`
-	}
-	var goods Goods
-	err := mongodb.DB("ichunt").C(collectionName).Find(bson.M{"goods_id": int(oldGoodsId)}).One(&goods)
-	if err != nil && err != mgo.ErrNotFound {
-		logger.Select("sku_query").Error(err.Error())
-	}
-
-	stockInfo = goods.StockInfo
-
-	if stockInfo.PeriodTime > 0 {
-		stockInfo.PeriodTimeFormat = time.Unix(int64(stockInfo.PeriodTime), 0).Format("2006-01-02")
-	}
-
-	if stockInfo.Stock != 0 || stockInfo.PeriodTime != 0 {
-		return stockInfo
-	}
-
-	return nil
-}
-
-// 获取新的在途库存
-func (ss *LyService) getOnwayStock(goodsId string) int {
-	redisConn := gredis.Conn("search_r")
-	defer func() {
-		redisConn.Close()
-	}()
-
-	onWayStockStr, _ := redis.String(redisConn.Do("HGET", "sku_onway_stock", goodsId))
-	if onWayStockStr == "" {
-		return 0
-	}
-
-	return gconv.Int(onWayStockStr)
-}
-
-// 获取新的在途库存
-func (ss *LyService) getLimitStock(goodsId string) (has bool, stock int) {
-	redisConn := gredis.Conn("search_r")
-	defer func() {
-		redisConn.Close()
-	}()
-
-	limitStockStr, _ := redis.String(redisConn.Do("HGET", "limit_stock", goodsId))
-	if limitStockStr == "" {
-		return false, 0
-	}
-
-	return true, gconv.Int(limitStockStr)
-}
+package service
+
+import (
+	"go_sku_server/model"
+	"go_sku_server/pkg/gredis"
+	"go_sku_server/pkg/logger"
+	"go_sku_server/pkg/mongo"
+	"go_sku_server/pkg/vars"
+	"time"
+
+	"github.com/gogf/gf/util/gconv"
+	"github.com/gomodule/redigo/redis"
+	"github.com/syyongx/php2go"
+	"gopkg.in/mgo.v2"
+	"gopkg.in/mgo.v2/bson"
+)
+
+// 在途库存服务
+type StockInfoService struct {
+}
+
+// 这个是老的在途库存,基本上就是Digikey用的
+func (ss *LyService) getStockInfo(supplierId, oldGoodsId int64) interface{} {
+	if !php2go.InArray(supplierId, vars.StockInfoSupplierIds) {
+		return nil
+	}
+	var stockInfo model.StockInfo
+	//去mongodb获取在途库存信息
+	mongodb := mongo.Conn("default")
+	defer func() {
+		mongodb.Close()
+	}()
+	//还要判断去哪个集合取值
+	collectionName := vars.StockInfoSupplierMap[supplierId]
+	type Goods struct {
+		StockInfo model.StockInfo `bson:"stock_info"`
+	}
+	var goods Goods
+	err := mongodb.DB("ichunt").C(collectionName).Find(bson.M{"goods_id": int(oldGoodsId)}).One(&goods)
+	if err != nil && err != mgo.ErrNotFound {
+		logger.Select("sku_query").Error(err.Error())
+	}
+
+	stockInfo = goods.StockInfo
+
+	if stockInfo.PeriodTime > 0 {
+		stockInfo.PeriodTimeFormat = time.Unix(int64(stockInfo.PeriodTime), 0).Format("2006-01-02")
+	}
+
+	if stockInfo.Stock != 0 || stockInfo.PeriodTime != 0 {
+		return stockInfo
+	}
+
+	return nil
+}
+
+// 获取新的在途库存
+func (ss *LyService) getOnwayStock(goodsId string) int {
+	redisConn := gredis.Conn("spu")
+	defer func() {
+		redisConn.Close()
+	}()
+
+	onWayStockStr, _ := redis.String(redisConn.Do("HGET", "sku_onway_stock", goodsId))
+	if onWayStockStr == "" {
+		return 0
+	}
+
+	return gconv.Int(onWayStockStr)
+}
+
+// 获取新的在途库存
+func (ss *LyService) getLimitStock(goodsId string) (has bool, stock int) {
+	redisConn := gredis.Conn("search_r")
+	defer func() {
+		redisConn.Close()
+	}()
+
+	limitStockStr, _ := redis.String(redisConn.Do("HGET", "limit_stock", goodsId))
+	if limitStockStr == "" {
+		return false, 0
+	}
+
+	return true, gconv.Int(limitStockStr)
+}