From 65cfaee2bd940ec8f355fad32cc64d395b6c277c Mon Sep 17 00:00:00 2001
From: kaede10 <sch_na@163.com>
Date: Mon, 18 Mar 2024 20:02:46 +0800
Subject: [PATCH] update insertRPMPkg()

---
 .../rpmpackage/RPMPackageServiceImpl.java          | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/easysoftware/application/rpmpackage/RPMPackageServiceImpl.java b/src/main/java/com/easysoftware/application/rpmpackage/RPMPackageServiceImpl.java
index 77ba886..287f86b 100644
--- a/src/main/java/com/easysoftware/application/rpmpackage/RPMPackageServiceImpl.java
+++ b/src/main/java/com/easysoftware/application/rpmpackage/RPMPackageServiceImpl.java
@@ -93,12 +93,12 @@ public class RPMPackageServiceImpl extends ServiceImpl<RPMPackageDOMapper, RPMPa
             return ResultUtil.fail(HttpStatus.BAD_REQUEST, MessageCode.EC0002);
         }
         // 数据库中是否已存在该包
-        RPMPackageUnique unique = new RPMPackageUnique();
-        BeanUtils.copyProperties(inputrPMPackage, unique);
-        boolean found = rPMPkgGateway.existRPM(unique);
-        if (found) {
-            return ResultUtil.fail(HttpStatus.BAD_REQUEST, MessageCode.EC0008);
-        }
+        // RPMPackageUnique unique = new RPMPackageUnique();
+        // BeanUtils.copyProperties(inputrPMPackage, unique);
+        // boolean found = rPMPkgGateway.existRPM(unique);
+        // if (found) {
+        //     return ResultUtil.fail(HttpStatus.BAD_REQUEST, MessageCode.EC0008);
+        // }
         RPMPackage rPMPkg = new RPMPackage();
         BeanUtils.copyProperties(inputrPMPackage, rPMPkg);
         // rPMPkg = addRPMPkgMaintainerInfo(rPMPkg);
@@ -107,7 +107,7 @@ public class RPMPackageServiceImpl extends ServiceImpl<RPMPackageDOMapper, RPMPa
 
         Map<String, Object> kafkaMsg = ObjectMapperUtil.jsonToMap(inputrPMPackage);
         kafkaMsg.put("table", "RPMPackage");
-        kafkaMsg.put("unique", ObjectMapperUtil.writeValueAsString(unique));
+        // kafkaMsg.put("unique", ObjectMapperUtil.writeValueAsString(unique));
         kafkaProducer.sendMess(topicAppVersion + "_rpm", UuidUtil.getUUID32(), ObjectMapperUtil.writeValueAsString(kafkaMsg));
 
         // boolean succeed = rPMPkgGateway.save(rPMPkg);
-- 
Gitee