m

app/GoodsSkus.php

@@ -22,5 +22,15 @@ class GoodsSkus extends Model
         $quantity = $sku_quantity - $w_num - $fx_num;
         return $quantity;
     }
+
+    public static function actualQuantityByRedis($sku_id){
+        //计算实际库存 -还未到卖家云的量
+        $sku_quantity = GoodsSkus::where('id', $sku_id)->pluck('quantity');
+        $redisKey = config('SKU_QUANTITY_TABLE');
+        $w_num = RedisModel::hGet($redisKey, $sku_id);
+        if(!$w_num) $w_num = 0;
+        $quantity = $sku_quantity - $w_num;
+        return $quantity;
+    }
    
 }

app/Http/Controllers/Admin/OrderController.php

@@ -840,6 +840,26 @@ class OrderController extends Controller
             }
             
             DB::commit();
+
+            // +++++ 新加预占库存到redis
+            $order_skus = OrderGoodsSkus::select(DB::raw('sum(num) as num, sku_id'))->where('order_id', $res)->where('is_del', 0)->groupBy('sku_id')->get();
+            $redis_table = config('SKU_QUANTITY_TABLE');
+            $sku_redis = array();
+            foreach($order_skus as $k=>$item){
+                #记录sku到redis
+                $sku_id = $item->sku_id;
+                $num = $item->num;
+                if(!isset($sku_redis[$sku_id])){
+                    $sku_redis[$sku_id] = $num;
+                }else{
+                    $sku_redis[$sku_id] += $num;
+                }
+            }
+            foreach($sku_redis as $key => $val){
+                $sku_redis_val = RedisModel::hGet($redis_table, $key);
+                $sku_up_val = $sku_redis_val>0 ? ($sku_redis_val + $val) : $val;
+                RedisModel::hSet($redis_table, $key, $sku_up_val);
+            }
         }catch (Exception $e){
             DB::rollback();
         }   

app/RedisModel.php

@@ -45,4 +45,20 @@ class RedisModel extends Model
         $redis = self::_init();
         return $redis->lpop( $key );
     }
+
+    public static function hSet( $table, $column, $value ){
+        $redis = self::_init();
+        return $redis->hSet( $table, $column, $value );
+    }
+
+    public static function hGet( $table, $column ){
+        $redis = self::_init();
+        return $redis->hGet( $table, $column );
+    }
+
+    public static function hDel( $table, $column ){
+        $redis = self::_init();
+        return $redis->hDel( $table, $column );
+    }
+
 }

config/constants.php

@@ -9,5 +9,7 @@ return [
     'ESHOP_CODE' => '100|hxas', //卖家云店铺code
     //'ESHOP_CODE' => '100|xyxd', //卖家云店铺code
     'WAREHOUSE_CODE' => '28416',//卖家云仓库编码
+    //未到卖家云的sku库存rediskey前缀
+    'SKU_QUANTITY_TABLE' => 'seafood.sku_wmj_quantity',
 
 ];