From 784506fcecaac297d0dfc8dc4c8f4fe1d03e1d38 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Fri, 22 Aug 2025 15:15:32 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-4418)=20-=20=E5=90=8C=E6=AD=A5=20ES=20?=
 =?UTF-8?q?=E5=8A=A8=E4=BD=9C=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97=E8=AE=B0?=
 =?UTF-8?q?=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../es/service/aggregation/AggregateProcessInstanceService.java | 1 +
 .../workflow/es/service/impl/EsProcessInstanceServiceImpl.java  | 2 ++
 2 files changed, 3 insertions(+)

diff --git a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/aggregation/AggregateProcessInstanceService.java b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/aggregation/AggregateProcessInstanceService.java
index 2b57029f7..4f01f4ecd 100644
--- a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/aggregation/AggregateProcessInstanceService.java
+++ b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/aggregation/AggregateProcessInstanceService.java
@@ -86,6 +86,7 @@ public class AggregateProcessInstanceService {
             if (Objects.nonNull(function) && !StringUtils.hasText(initiator.getAssignerName()) && NumberUtil.isNumber(initiator.getPersonId())) {
                 fullAssigner = function.apply(Lists.newArrayList(initiator)).getOrDefault(Long.parseLong(initiator.getPersonId()), null);
             }
+            log.info("insert es check fullAssigner: {}", Objects.nonNull(fullAssigner));
             if (Objects.nonNull(fullAssigner)) {
                 fullAssigner.setAssignerName(StringUtils.hasText(initiator.getAssignerName()) ? initiator.getAssignerName() : "未知");
                 processInstanceDocument.setInitiatorName(fullAssigner.getAssignerName());
diff --git a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/impl/EsProcessInstanceServiceImpl.java b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/impl/EsProcessInstanceServiceImpl.java
index 9174cd333..0047759d7 100644
--- a/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/impl/EsProcessInstanceServiceImpl.java
+++ b/workflow-engine-elasticsearch/src/main/java/cn/axzo/workflow/es/service/impl/EsProcessInstanceServiceImpl.java
@@ -7,6 +7,7 @@ import cn.axzo.workflow.es.mapper.EsProcessInstanceMapper;
 import cn.axzo.workflow.es.model.ProcessInstanceDocument;
 import cn.axzo.workflow.es.model.ProcessTaskDocument;
 import cn.axzo.workflow.es.service.EsProcessInstanceService;
+import com.alibaba.fastjson.JSON;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.easyes.annotation.IndexName;
@@ -93,6 +94,7 @@ public class EsProcessInstanceServiceImpl implements EsProcessInstanceService {
      */
     @Override
     public Integer insert(String routing, ProcessInstanceDocument processInstanceDocument) {
+        log.info("insert es document: {}", JSON.toJSONString(processInstanceDocument));
         return esProcessInstanceMapper.insert(routing, processInstanceDocument);
     }