From ba01e230ef1b76461f7447c84388ac21a49990f5 Mon Sep 17 00:00:00 2001
From: baize <3533151373@qq.com>
Date: Tue, 2 Apr 2024 16:48:25 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cache/abs/AtomicSequenceCacheAbs.java     | 44 +++++++++-------
 .../product/cache/ProjectSkuStockCache.java   | 50 ++++++++++++++++++-
 2 files changed, 76 insertions(+), 18 deletions(-)

diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/AtomicSequenceCacheAbs.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/AtomicSequenceCacheAbs.java
index 57dfe0b..1747a30 100644
--- a/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/AtomicSequenceCacheAbs.java
+++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/cache/abs/AtomicSequenceCacheAbs.java
@@ -21,7 +21,7 @@ public abstract class AtomicSequenceCacheAbs<K> implements AtomicSequenceCache<K
      * @return 值
      */
     @Override
-    public Long get(K key) {
+    public Long get (K key) {
         return this.redisService.getCacheObject(encode(key));
     }
 
@@ -30,54 +30,64 @@ public abstract class AtomicSequenceCacheAbs<K> implements AtomicSequenceCache<K
      * @param key
      */
     @Override
-    public Long increment(K key) {
-        return this.increment(key,1L);
+    public Long increment (K key) {
+        return this.increment(key, 1L);
     }
 
     /**
+     * 自减
      *
-     自减
+     * @param key
      */
     @Override
-    public Long decrement(K key) {
-        return this.decrement(key,1L);
+    public Long decrement (K key) {
+        return this.decrement(key, 1L);
     }
 
     /**
      * 增加数值
+     *
      * @param key
      * @param number
      */
     @Override
-    public Long increment(K key, Long number) {
+    public Long increment (K key, Long number) {
         Long numberValue = redisService.getCacheObject(encode(key));
-        if (numberValue==null){
+        if (numberValue == null){
             Long data = getData(key);
-            data=data==null?0L:data;
+            data = data == null ? 0L : data;
             redisService.setCacheObject(encode(key), data);
         }
-        return redisService.increment(encode(key),number);
+        return redisService.increment(encode(key), number);
     }
 
+    /**
+     * 减少数值
+     *
+     * @param key
+     * @param number
+     */
     @Override
-    public Long decrement(K key, Long number) {
+    public Long decrement (K key, Long number) {
         Long numberValue = redisService.getCacheObject(encode(key));
-        if (numberValue==null){
+        if (numberValue == null){
             Long data = getData(key);
-            data=data==null?0L:data;
-            redisService.setCacheObject(encode(key),data);
+            data = data == null ? 0L : data;
+            redisService.setCacheObject(encode(key), data);
         }
-        return redisService.decrement(encode(key),number);
+        return redisService.decrement(encode(key), number);
     }
 
     /**
      * 编码
+     *
      * @param key ID
+     *
      * @return 键
      */
     @Override
-    public String encode(K key) {
-        return keyPre()+key;
+    public String encode (K key) {
+        return keyPre() + key;
     }
 
     public abstract Long getData(K key);
diff --git a/muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/ProjectSkuStockCache.java b/muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/ProjectSkuStockCache.java
index 3d57ea1..c24777c 100644
--- a/muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/ProjectSkuStockCache.java
+++ b/muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/ProjectSkuStockCache.java
@@ -1,10 +1,58 @@
 package com.muyu.product.cache;
 
+import com.muyu.cache.abs.AtomicSequenceCacheAbs;
+import com.muyu.common.core.text.Convert;
+import com.muyu.product.cache.datasource.ProjectSkuStockData;
+import com.muyu.product.cache.key.SkuStockKey;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
 /**
  * ProjectSkuStockCache
  *
  * @author DeKangLiu
  * on 2024/4/1
  */
-public class ProjectSkuStockCache {
+@Service
+public class ProjectSkuStockCache extends AtomicSequenceCacheAbs<SkuStockKey>{
+
+    @Autowired
+    private ProjectSkuStockData projectSkuStockData;
+
+    /**
+     * key前缀
+     * @return key前缀
+     */
+    @Override
+    public String keyPre() {
+        return "project:sku:stock:";
+    }
+
+    /**
+     * 编码
+     * @param skuStockKey ID
+     * @return 键
+     */
+    @Override
+    public String encode(SkuStockKey skuStockKey){
+        return keyPre()+skuStockKey.getProjectId()+":"+skuStockKey.getSku();
+    }
+    @Override
+    public Long getData(SkuStockKey key) {
+        return projectSkuStockData.getData(key);
+    }
+
+    /**
+     * 解码
+     * @param redisKey 数据库键
+     * @return ID
+     */
+    @Override
+    public SkuStockKey decode(String redisKey) {
+        String[] split = redisKey.replace(keyPre(), "").split(":");
+        return SkuStockKey.builder()
+                .projectId(Convert.toLong(split[0]))
+                .sku(split[1])
+                .build();
+    }
 }