From 65f3031a704cc210c9e29b43b6235daf62f9361e Mon Sep 17 00:00:00 2001
From: liyj <1617420630@qq.com>
Date: Wed, 24 Sep 2025 10:35:25 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E5=95=86=E5=93=81=E5=BA=93?=
 =?UTF-8?q?=E5=AD=98=E7=BB=99=E6=80=9D=E8=BF=85=E6=95=B0=E6=8D=AE=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/ShopOrderBaseServiceImpl.java  |  4 ++--
 .../service/impl/SyncThirdDataServiceImpl.java  | 17 +++++++++--------
 2 files changed, 11 insertions(+), 10 deletions(-)

diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java
index f356cce6..c6d359cd 100644
--- a/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java
+++ b/mall-shop/src/main/java/com/suisung/mall/shop/order/service/impl/ShopOrderBaseServiceImpl.java
@@ -4170,7 +4170,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl<ShopOrderBaseMappe
             if (ObjectUtil.equal(order_item_inventory_lock, 1001) || ObjectUtil.equal(order_item_inventory_lock, 1002)) {
                 Long item_id = order_item_row.getItem_id();
                 ShopProductItem shopProductItem = shopProductItemService.get(item_id);
-                if (shopProductItem != null && CheckUtil.isEmpty(shopProductItem.getItem_src_id())) {
+                if (shopProductItem != null && CheckUtil.isNotEmpty(shopProductItem.getItem_src_id())) {
                     shopProductItem.setItem_quantity_frozen(shopProductItem.getItem_quantity_frozen() - order_item_quantity);
                     if (!shopProductItemService.edit(shopProductItem)) {
                         throw new ApiException(String.format(I18nUtil._("释放: %s 冻结库存失败!"), order_item_row.getItem_id()));
@@ -7114,7 +7114,7 @@ public class ShopOrderBaseServiceImpl extends BaseServiceImpl<ShopOrderBaseMappe
 
                             // start 判断增加冻结库存
                             Integer _product_inventory_lock = Convert.toInt(_item.get("product_inventory_lock"));
-                            if (ObjectUtil.equal(_product_inventory_lock, 1001) && CheckUtil.isEmpty(item_src_id)) {
+                            if (ObjectUtil.equal(_product_inventory_lock, 1001) && CheckUtil.isNotEmpty(item_src_id)) {
                                 if (shopProductItemService.lockSkuStock(item_id, cart_quantity) <= 0) {
                                     throw new ApiException(String.format(I18nUtil._("更改: %s 冻结库存失败!"), item.get("item_id")));
                                 }
diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
index 43b5a06e..5bd32952 100644
--- a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
+++ b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncThirdDataServiceImpl.java
@@ -853,20 +853,21 @@ public class SyncThirdDataServiceImpl extends SyncBaseThirdSxAbstract implements
                     continue;
                 }
                 ShopProductItem spuItem = shopProductItems.get(0);
-                cn.hutool.json.JSONArray array_item_spec=  JSONUtil.parseArray(spuItem.getItem_spec());
-                if(array_item_spec.isEmpty()){
-                    continue;
-                }
-                cn.hutool.json.JSONObject item = (cn.hutool.json.JSONObject) ((cn.hutool.json.JSONObject) array_item_spec.get(0)).get("item");
-                String name = Convert.toStr(item.get("name"));
-                BigDecimal itemQuaryty = getBigDecimal(delta, name);
+                String key=RedisKey.STOREDATARELEASE+":"+spuItem.getStore_id();
                 Long  productId = spuItem.getProduct_id();
                 ShopProductBase productBase = shopProductBaseService.get(productId);
                 if(productBase==null){
                     continue;
                 }
                 String itemId=productBase.getProduct_number();
-                String key=RedisKey.STOREDATARELEASE+":"+productBase.getStore_id();
+                cn.hutool.json.JSONArray array_item_spec=  JSONUtil.parseArray(spuItem.getItem_spec());
+                if(array_item_spec.isEmpty()){
+                    redisTemplate.opsForHash().increment(key, spuItem.getItem_id(), delta.doubleValue());
+                    continue;
+                }
+                cn.hutool.json.JSONObject item = (cn.hutool.json.JSONObject) ((cn.hutool.json.JSONObject) array_item_spec.get(0)).get("item");
+                String name = Convert.toStr(item.get("name"));
+                BigDecimal itemQuaryty = getBigDecimal(delta, name);
                 // 使用 Redis 的 HINCRBY 保证原子性和高性能
                 redisTemplate.opsForHash().increment(key, itemId, itemQuaryty.doubleValue());
             } catch (Exception e) {