From 00617fc5f0536b6c3b40476089824568610bea19 Mon Sep 17 00:00:00 2001
From: fengyuan_yang <1976974459@qq.com>
Date: Mon, 17 Feb 2025 13:59:25 +0800
Subject: [PATCH] =?UTF-8?q?2025-02-17=20=E8=8E=B7=E5=8F=96=E7=89=A9?=
 =?UTF-8?q?=E6=96=99=E6=88=90=E6=9C=AC=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/part/mapper/PartInformationMapper.java  |  2 ++
 .../service/impl/PartInformationServiceImpl.java    |  8 +++++++-
 .../resources/mapper/part/PartInformationMapper.xml | 13 +++++++++++++
 3 files changed, 22 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/spring/modules/part/mapper/PartInformationMapper.java b/src/main/java/com/spring/modules/part/mapper/PartInformationMapper.java
index 33dc6a54..c3cdf45b 100644
--- a/src/main/java/com/spring/modules/part/mapper/PartInformationMapper.java
+++ b/src/main/java/com/spring/modules/part/mapper/PartInformationMapper.java
@@ -323,4 +323,6 @@ public interface PartInformationMapper extends BaseMapper<PartInformationEntity>
     void deleteRecipeComponentByPartNo(PartInformationVo data);
 
     void savePartSubPropertiesValues(List<PartSubPropertiesValueData> arrayList);
+
+    List<InventoryPartUnitCostSumEntity> getUnitValuesByPartNo(@Param("site") String site, @Param("partNo") String partNo, @Param("configurationId") String s);
 }
diff --git a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
index a98fe781..a7ccfee0 100644
--- a/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
+++ b/src/main/java/com/spring/modules/part/service/impl/PartInformationServiceImpl.java
@@ -3594,7 +3594,13 @@ public class PartInformationServiceImpl extends ServiceImpl<PartInformationMappe
                 ArrayList<InventoryPartUnitCostSumEntity> subList = new ArrayList<>();
                 InventoryPartUnitCostSumEntity unitCostSum = JSONObject.parseObject(getInventoryValueResponse.get("obj"), InventoryPartUnitCostSumEntity.class);
                 subList.add(unitCostSum);
-                partInformationMapper.syncUpdateUnitValue(subList);
+                // 查是否存在该物料的成本
+                List<InventoryPartUnitCostSumEntity> unitValues = partInformationMapper.getUnitValuesByPartNo(inData.getSite(), inData.getPartNo(), "*");
+                if (unitValues.isEmpty()) {
+                    partInformationMapper.syncSaveUnitValue(subList);
+                } else {
+                    partInformationMapper.syncUpdateUnitValue(subList);
+                }
             } else {
                 log.error("获取成本信息异常: " + getInventoryValueResponse.get("resultMsg"));
             }
diff --git a/src/main/resources/mapper/part/PartInformationMapper.xml b/src/main/resources/mapper/part/PartInformationMapper.xml
index c23b8d9a..a32cec46 100644
--- a/src/main/resources/mapper/part/PartInformationMapper.xml
+++ b/src/main/resources/mapper/part/PartInformationMapper.xml
@@ -2268,4 +2268,17 @@
             (#{item.site}, #{item.partNo}, #{item.codeNo}, #{item.subCodeSeqNo, jdbcType=FLOAT}, #{item.itemNo, jdbcType=FLOAT}, #{item.propertiesItemNo}, #{item.textValue}, #{item.numValue, jdbcType=FLOAT}, #{item.recordType})
         </foreach>
     </insert>
+
+    <select id="getUnitValuesByPartNo" resultType="InventoryPartUnitCostSumEntity">
+        select
+        site,
+        part_no,
+        configuration_id,
+        inventory_value,
+        lot_batch_no,
+        serial_no,
+        ifs_row_version
+        from inventory_part_unit_cost_sum
+        where site = #{site} and part_no = #{partNo} and configuration_id = #{configurationId}
+    </select>
 </mapper>