From 9576d7fb687ce6dc2002839c66519ac47152979a Mon Sep 17 00:00:00 2001
From: DongZeLiang <2746733890@qq.com>
Date: Mon, 1 Apr 2024 20:38:44 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=9F=E5=AD=90=E5=BA=8F=E5=88=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/cache/AtomicSequenceCache.java     | 30 +++++++++
 .../cache/abs/AtomicSequenceCacheAbs.java     | 64 +++++++++++++++++++
 .../cache/impl/ProjectSkuDataImpl.java        |  5 +-
 3 files changed, 98 insertions(+), 1 deletion(-)
 create mode 100644 muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/AtomicSequenceCache.java
 create mode 100644 muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/AtomicSequenceCacheAbs.java

diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/AtomicSequenceCache.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/AtomicSequenceCache.java
new file mode 100644
index 0000000..8391bd7
--- /dev/null
+++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/AtomicSequenceCache.java
@@ -0,0 +1,30 @@
+package com.muyu.common.cache;
+
+import com.muyu.common.cache.decoration.DecorationKey;
+
+/**
+ * @author DongZl
+ * @description: 原子序列缓存基准
+ * @Date 2024-4-1 下午 08:07
+ */
+public interface AtomicSequenceCache<K> extends DecorationKey<K> {
+
+    /**
+     * 自增
+     */
+    public Long increment();
+    /**
+     * 自减
+     */
+    public Long decrement();
+
+    /**
+     * 增加数值
+     */
+    public Long increment(Long number);
+
+    /**
+     * 减少数值
+     */
+    public Long decrement(Long number);
+}
diff --git a/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/AtomicSequenceCacheAbs.java b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/AtomicSequenceCacheAbs.java
new file mode 100644
index 0000000..54b231b
--- /dev/null
+++ b/muyu-common/muyu-common-cache/src/main/java/com/muyu/common/cache/abs/AtomicSequenceCacheAbs.java
@@ -0,0 +1,64 @@
+package com.muyu.common.cache.abs;
+
+import com.muyu.common.cache.AtomicSequenceCache;
+import com.muyu.common.redis.service.RedisService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * @author DongZl
+ * @description: 原子序列缓存抽象类
+ * @Date 2024-4-1 下午 08:33
+ */
+public abstract class AtomicSequenceCacheAbs<K> implements AtomicSequenceCache<K> {
+
+    @Autowired
+    private RedisService redisService;
+
+    /**
+     * 自增
+     */
+    @Override
+    public Long increment () {
+        return null;
+    }
+
+    /**
+     * 自减
+     */
+    @Override
+    public Long decrement () {
+        return null;
+    }
+
+    /**
+     * 增加数值
+     *
+     * @param number
+     */
+    @Override
+    public Long increment (Long number) {
+        return null;
+    }
+
+    /**
+     * 减少数值
+     *
+     * @param number
+     */
+    @Override
+    public Long decrement (Long number) {
+        return null;
+    }
+
+    /**
+     * 编码
+     *
+     * @param key ID
+     *
+     * @return 键
+     */
+    @Override
+    public String encode (K key) {
+        return null;
+    }
+}
diff --git a/muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuDataImpl.java b/muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuDataImpl.java
index b604952..6b66484 100644
--- a/muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuDataImpl.java
+++ b/muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuDataImpl.java
@@ -45,6 +45,9 @@ public class ProjectSkuDataImpl implements ProjectSkuData {
      */
     @Override
     public ProjectSkuInfo getData (Long projectId, String projectSku) {
-        return null;
+        LambdaQueryWrapper<ProjectSkuInfo> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(ProjectSkuInfo::getProjectId, projectId);
+        queryWrapper.eq(ProjectSkuInfo::getSku, projectSku);
+        return projectSkuInfoService.getOne(queryWrapper);
     }
 }