自营锁库扣数量

service/service_zy.go

@@ -185,8 +185,8 @@ func (qs *ZiyingService) ZyGoodsDetail(ctx context.Context, params RequestParams
 		A.Set("stock", 0)                         //默认库存为0
 		A.Set("stock", 0)                         //默认库存为0
 		dbStock := gjson.Get(info, "stock").Int() //当前db库存
 		dbStock := gjson.Get(info, "stock").Int() //当前db库存
 		if dbStock > 0 {
 		if dbStock > 0 {
-			lockStock := qs.skuLockNum(&redisConn, goodsId) //当前锁库库存
-			stockG := dbStock - lockStock                   //当前可购买库存
+			lockStock := SkuLockNum(goodsId) //当前锁库库存
+			stockG := dbStock - lockStock    //当前可购买库存
 			if stockG > 0 {
 			if stockG > 0 {
 				A.Set("actual_stock", dbStock) //锁定库存
 				A.Set("actual_stock", dbStock) //锁定库存
 				A.Set("stock", stockG)
 				A.Set("stock", stockG)

service/service_zy_common.go

@@ -4,6 +4,7 @@ import (
 	"go_sku_server/model"
 	"go_sku_server/model"
 	"go_sku_server/pkg/common"
 	"go_sku_server/pkg/common"
 	"go_sku_server/pkg/gredis"
 	"go_sku_server/pkg/gredis"
+	"strconv"
 
 
 	"github.com/gomodule/redigo/redis"
 	"github.com/gomodule/redigo/redis"
 	"github.com/iancoleman/orderedmap"
 	"github.com/iancoleman/orderedmap"
@@ -12,8 +13,21 @@ import (
 )
 )
 
 
 //自营公共函数类
 //自营公共函数类
+
+/*
+获取自营锁库数量
+*/
+func SkuLockNum(goodsId string) int64 {
+	//获取总锁库库存
+	redisCon := gredis.Conn("spu")
+	defer redisCon.Close()
+	stockStr, _ := redis.String(redisCon.Do("HGET", "sku_lock_stock", goodsId))
+	lockStock, _ := strconv.ParseInt(stockStr, 10, 64)
+	return lockStock
+}
+
 /*
 /*
- 计算单个sku总锁库数量
+计算单个sku总锁库数量-废弃
 */
 */
 func (qs *ZiyingService) skuLockNum(c *redis.Conn, goodsId string) int64 {
 func (qs *ZiyingService) skuLockNum(c *redis.Conn, goodsId string) int64 {
 	reply, err := redis.Values((*c).Do("hvals", "Self_StockLock"+goodsId))
 	reply, err := redis.Values((*c).Do("hvals", "Self_StockLock"+goodsId))