From 1a8b730e71b267a43406f2b8f618380ee57598e3 Mon Sep 17 00:00:00 2001
From: Owen <595466820@qq.com>
Date: Wed, 5 Mar 2025 15:56:33 +0800
Subject: [PATCH] =?UTF-8?q?Fix:=E6=B9=96=E5=8D=97=E7=94=B5=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yudao/module/haoka/enums/ErrorCodeConstants.java |  3 +++
 .../onsaleproduct/OnSaleProductServiceImpl.java      | 12 +++++++++++-
 .../service/product/HaoKaProductServiceImpl.java     |  8 ++++++++
 .../SuperiorProductConfigServiceImpl.java            | 12 ++++++++++++
 4 files changed, 34 insertions(+), 1 deletion(-)

diff --git a/yudao-module-haoka/yudao-module-haoka-api/src/main/java/cn/iocoder/yudao/module/haoka/enums/ErrorCodeConstants.java b/yudao-module-haoka/yudao-module-haoka-api/src/main/java/cn/iocoder/yudao/module/haoka/enums/ErrorCodeConstants.java
index 4c266ee56b..67a3cf3633 100644
--- a/yudao-module-haoka/yudao-module-haoka-api/src/main/java/cn/iocoder/yudao/module/haoka/enums/ErrorCodeConstants.java
+++ b/yudao-module-haoka/yudao-module-haoka-api/src/main/java/cn/iocoder/yudao/module/haoka/enums/ErrorCodeConstants.java
@@ -50,4 +50,7 @@ public interface ErrorCodeConstants {
     ErrorCode ORDER_OPERATE_LOG_NOT_EXISTS = new ErrorCode(1_826_001_001, "订单操作日志不存在");
 
     ErrorCode ORDER_SYNC_LOG_NOT_EXISTS = new ErrorCode(1_827_001_001, "抓单记录不存在");
+
+
+    ErrorCode PRODUCT_EXITS = new ErrorCode(1_827_001_021, "产品已经存在");
 }
diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/onsaleproduct/OnSaleProductServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/onsaleproduct/OnSaleProductServiceImpl.java
index 129db89ed0..da71de8283 100644
--- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/onsaleproduct/OnSaleProductServiceImpl.java
+++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/onsaleproduct/OnSaleProductServiceImpl.java
@@ -36,7 +36,7 @@ import java.util.List;
 
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.invalidParamException;
-import static cn.iocoder.yudao.module.haoka.enums.ErrorCodeConstants.ON_SALE_PRODUCT_NOT_EXISTS;
+import static cn.iocoder.yudao.module.haoka.enums.ErrorCodeConstants.*;
 
 /**
  * 在售产品 Service 实现类
@@ -75,6 +75,16 @@ public class OnSaleProductServiceImpl extends ServiceImpl<OnSaleProductMapper,On
     public Long createOnSaleProduct(OnSaleProductSaveReqVO createReqVO) {
         // 插入
         OnSaleProductDO onSaleProduct = BeanUtils.toBean(createReqVO, OnSaleProductDO.class);
+
+        if ( createReqVO.getSku()!=null){
+            OnSaleProductDO onSaleProductDO =
+                    onSaleProductMapper.selectOne(new LambdaQueryWrapperX<OnSaleProductDO>().eq(OnSaleProductDO::getSku, createReqVO.getSku()));
+            if (onSaleProductDO!=null){
+                throw exception(PRODUCT_EXITS);
+            }
+        }
+
+
         onSaleProductMapper.insert(onSaleProduct);
         onSaleProduct.setId(SnowflakeId.generate());
 
diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/product/HaoKaProductServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/product/HaoKaProductServiceImpl.java
index 186dfa0612..84a47c87ca 100644
--- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/product/HaoKaProductServiceImpl.java
+++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/product/HaoKaProductServiceImpl.java
@@ -64,6 +64,14 @@ public class HaoKaProductServiceImpl extends ServiceImpl<HaoKaProductMapper, Hao
             bizNo = "{{#haoKaProduct.id}}",
             success = LogRecordConstants.HAOKA_PRODUCT_CREATE_SUCCESS)
     public Long createHaoKaProduct(HaoKaProductSaveReqVO createReqVO) {
+        if ( createReqVO.getSku()!=null){
+            HaoKaProductDO onSaleProductDO =
+                    haoKaProductMapper.selectOne(new LambdaQueryWrapperX<HaoKaProductDO>().eq(HaoKaProductDO::getSku, createReqVO.getSku()));
+            if (onSaleProductDO!=null){
+                throw exception(PRODUCT_EXITS);
+            }
+        }
+
         // 插入
         HaoKaProductDO haoKaProduct = BeanUtils.toBean(createReqVO, HaoKaProductDO.class);
         haoKaProduct.setId(SnowflakeId.generate());
diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/superiorproductconfig/SuperiorProductConfigServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/superiorproductconfig/SuperiorProductConfigServiceImpl.java
index a437d4056d..cba764ffc7 100644
--- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/superiorproductconfig/SuperiorProductConfigServiceImpl.java
+++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/superiorproductconfig/SuperiorProductConfigServiceImpl.java
@@ -1,5 +1,7 @@
 package cn.iocoder.yudao.module.haoka.service.superiorproductconfig;
 
+import cn.iocoder.yudao.framework.common.exception.ErrorCode;
+import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 import jakarta.annotation.Resource;
@@ -35,6 +37,16 @@ public class SuperiorProductConfigServiceImpl
 
     @Override
     public Long createSuperiorProductConfig(SuperiorProductConfigSaveReqVO createReqVO) {
+        Long haokaProductId = createReqVO.getHaokaProductId();
+        Long haokaSuperiorApiId = createReqVO.getHaokaSuperiorApiId();
+        if (haokaProductId!=null&& haokaSuperiorApiId!=null){
+            SuperiorProductConfigDO superiorProductConfigDO = superiorProductConfigMapper.selectOne(new LambdaQueryWrapperX<SuperiorProductConfigDO>()
+                    .eq(SuperiorProductConfigDO::getHaokaProductId, haokaProductId)
+                    .eq(SuperiorProductConfigDO::getHaokaSuperiorApiId, haokaSuperiorApiId));
+            if (superiorProductConfigDO!=null){
+                throw exception(new ErrorCode(10012,"配置已经存在"));
+            }
+        }
         // 插入
         SuperiorProductConfigDO superiorProductConfig = BeanUtils.toBean(createReqVO, SuperiorProductConfigDO.class);
         superiorProductConfigMapper.insert(superiorProductConfig);