diff --git a/src/main/java/com/yem/em/task/GenerateReplaceRelationshipTaskEdit.java b/src/main/java/com/yem/em/task/GenerateReplaceRelationshipTaskEdit.java
index 4d7b2ee4..8a4aee7a 100644
--- a/src/main/java/com/yem/em/task/GenerateReplaceRelationshipTaskEdit.java
+++ b/src/main/java/com/yem/em/task/GenerateReplaceRelationshipTaskEdit.java
@@ -2,6 +2,7 @@ package com.yem.em.task;
 
 import com.yem.em.utils.AtlasUtils;
 import com.yem.wm.utils.AttachmentUtil;
+import com.yem.wm.utils.DynamicObjectUtil;
 import com.yem.wm.utils.YEM;
 import kd.bos.context.RequestContext;
 import kd.bos.dataentity.entity.DynamicObject;
@@ -22,6 +23,7 @@ import java.util.*;
 
 import static com.yem.em.task.MatchingPLMChangeUpdateTaskEdit.*;
 import static com.yem.em.utils.AtlasUtils.seelctDyn;
+import static com.yem.rf.utils.RFUtils.getBaseQFilter;
 
 /**
  * @Description: 1、如《PLM变更单》分录【替换关系】=【相互替换】【新替换旧】【互不替换】,分录【启用停用状态】=‘停用’，并且【替换件启用停用状态】=‘启用’，更新当前行【执行状态】为【完成】、【完成时间】默认当前时间，并生成替换关系，记录替换关系id以及行id
@@ -120,23 +122,37 @@ public class GenerateReplaceRelationshipTaskEdit extends AbstractTask {
         Map<Long, DynamicObject> successMap = new HashMap<>();
         DynamicObject bomChange = createBOMChange(plmObj, enabled);
         DynamicObjectCollection entry = bomChange.getDynamicObjectCollection("yem_entryentity");
+        String selectfields = DynamicObjectUtil.getSelectfields("yem_em_replace");
+        selectfields = DynamicObjectUtil.getEntrySelectfields(selectfields, "yem_em_replace", "yem_entryentity");
         if (!entry.isEmpty()) {
             DynamicObject replace = null;
             String billno = plmObj.getString("billno");
             String gybg_no = plmObj.getString("yem_gybg_no");
             if (entry.size() == 1) {
-                logger.info("生成替换关系：PLM单号：{}， PLM工艺变更单号：{}，父项编码：{}", billno, gybg_no, enabled.get(0).getString("yem_textfield"));
+                logger.info("生成替换关系：PLM单号：{}， PLM工艺变更单号：{}，父项编码：{}", billno, gybg_no, entry.get(0).getString("yem_parentno"));
                 logger.info("生成_当前替换关系：{}", entry.get(0).getString("yem_replace"));
                 replace = AtlasUtils.Addreplace(bomChange, entry.get(0), null, "yem_em_replace", "add", "PLM");
                 successMap.put(entry.get(0).getLong("id"), bomChange);
-            }
-            for (DynamicObject entryObject : entry) {
-                int idx = entry.indexOf(entryObject);
-                if (idx == 0) continue;
-                logger.info("更新替换关系：PLM单号：{}， PLM工艺变更单号：{}，父项编码：{}", billno, gybg_no, entryObject.getString("yem_textfield"));
-                logger.info("更新_替换关系：{}", entryObject.getString("yem_replace"));
-                replace = AtlasUtils.Addreplace(bomChange, entry.get(0), replace, "yem_em_replace", "update", "PLM");
-                successMap.put(entryObject.getLong("id"), bomChange);
+            } else {
+                for (DynamicObject entryObject : entry) {
+                    int idx = entry.indexOf(entryObject);
+                    if (idx == 0) {
+                        QFilter qFilter = new QFilter("status", "=", "C");
+                        qFilter.and("number", "=", bomChange.getString("number"));
+                        DynamicObject[] load = BusinessDataServiceHelper.load("yem_em_replace", selectfields, qFilter.toArray());
+                        if (load.length == 1) {
+                            replace = load[0];
+                            replace = AtlasUtils.Addreplace(bomChange, entry.get(0), replace, "yem_em_replace", "update", "PLM");
+                        } else {
+                            replace = AtlasUtils.Addreplace(bomChange, entry.get(0), null, "yem_em_replace", "add", "PLM");
+                        }
+                        continue;
+                    };
+                    logger.info("更新替换关系：PLM单号：{}， PLM工艺变更单号：{}，父项编码：{}", billno, gybg_no, entryObject.getString("yem_parentno"));
+                    logger.info("更新_替换关系：{}", entryObject.getString("yem_replace"));
+                    replace = AtlasUtils.Addreplace(bomChange, entry.get(0), replace, "yem_em_replace", "update", "PLM");
+                    successMap.put(entryObject.getLong("id"), bomChange);
+                }
             }
         }
         List<Long> list = new ArrayList<>();