From ac918503bb5e8fad007348e7e39ba7275b75f334 Mon Sep 17 00:00:00 2001
From: p-honggang.li <p-honggang.li@pcitc.com>
Date: 星期一, 08 九月 2025 23:33:32 +0800
Subject: [PATCH] 修改取消订单,修改状态为已取消

---
 src/main/java/com/webmanage/service/impl/OrderInfoServiceImpl.java |  796 +++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 751 insertions(+), 45 deletions(-)

diff --git a/src/main/java/com/webmanage/service/impl/OrderInfoServiceImpl.java b/src/main/java/com/webmanage/service/impl/OrderInfoServiceImpl.java
index 7ec425c..9db84be 100644
--- a/src/main/java/com/webmanage/service/impl/OrderInfoServiceImpl.java
+++ b/src/main/java/com/webmanage/service/impl/OrderInfoServiceImpl.java
@@ -22,25 +22,39 @@
 import com.webmanage.mapper.OrderDetailMapper;
 import com.webmanage.mapper.OrderEvaluationMapper;
 import com.webmanage.mapper.OrderInfoMapper;
+import com.webmanage.mapper.ReportResultSubmissionMapper;
 import com.webmanage.service.OrderInfoService;
 import com.webmanage.service.OrderNoService;
 import com.webmanage.service.MinioService;
+import com.webmanage.config.WorkflowProperties;
 import com.webmanage.vo.OrderAttachmentVO;
 import com.webmanage.vo.OrderDetailItemVO;
 import com.webmanage.vo.OrderDetailVO;
 import com.webmanage.vo.OrderEvaluationVO;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.http.ResponseEntity;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.MediaType;
+import org.springframework.http.HttpHeaders;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.stream.Collectors;
+import java.util.Objects;
 
 /**
  * 璁㈠崟淇℃伅Service瀹炵幇绫�
@@ -67,8 +81,17 @@
     @Resource
     private MinioService minioService;
 
+    @Resource
+    private ReportResultSubmissionMapper reportResultSubmissionMapper;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @Autowired
+    private WorkflowProperties workflowProperties;
+
     @Override
-    public PageResult<OrderInfo> getBuyerOrderPage(OrderQueryDTO queryDTO) {
+    public PageResult<OrderDetailVO> getBuyerOrderPage(OrderQueryDTO queryDTO) {
         // 鍙傛暟鏍¢獙
         if (queryDTO.getUserId() == null) {
             throw new BusinessException("鐢ㄦ埛ID涓嶈兘涓虹┖");
@@ -88,10 +111,23 @@
             queryDTO.getCreateTimeEnd() != null ? queryDTO.getCreateTimeEnd().toString() : null,
             queryDTO.getOrderBy(), queryDTO.getOrderDirection()
         );
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
 
         // 鏋勫缓杩斿洖缁撴灉
-        return new PageResult<OrderInfo>(
-            result.getRecords(),
+        return new PageResult<OrderDetailVO>(
+            voList,
             result.getTotal(),
             queryDTO.getPageNum().longValue(),
             queryDTO.getPageSize().longValue(),
@@ -100,7 +136,7 @@
     }
 
     @Override
-    public PageResult<OrderInfo> getSellerOrderPage(OrderQueryDTO queryDTO) {
+    public PageResult<OrderDetailVO> getSellerOrderPage(OrderQueryDTO queryDTO) {
         // 鍙傛暟鏍¢獙
         if (queryDTO.getProviderId() == null) {
             throw new BusinessException("鎻愪緵鑰匢D涓嶈兘涓虹┖");
@@ -120,9 +156,23 @@
             queryDTO.getOrderBy(), queryDTO.getOrderDirection()
         );
 
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
+
         // 鏋勫缓杩斿洖缁撴灉
-        return new PageResult<OrderInfo>(
-            result.getRecords(),
+        return new PageResult<OrderDetailVO>(
+            voList,
             result.getTotal(),
             queryDTO.getPageNum().longValue(),
             queryDTO.getPageSize().longValue(),
@@ -131,9 +181,42 @@
     }
 
     @Override
-    public PageResult<OrderInfo> getPendingApprovalOrderPage(OrderQueryDTO queryDTO) {
+    public PageResult<OrderDetailVO> getPendingApprovalOrderPage(OrderQueryDTO queryDTO) {
         // 鍒涘缓鍒嗛〉瀵硅薄
         Page<OrderInfo> page = new Page<>(queryDTO.getPageNum(), queryDTO.getPageSize());
+
+        // 鍩轰簬workFlowType鏌ヨ娴佺▼瀹炰緥ID闆嗗悎
+        List<Object> workFlowsList = fetchWorkflowProcessInstanceIds(
+            queryDTO.getWorkFlowType(),
+            queryDTO.getUserId(),
+            queryDTO.getDepartmentId(),
+            queryDTO.getBusinessType(),
+            queryDTO.getPageNum(),
+            queryDTO.getPageSize()
+        );
+
+        // 濡傛灉娌℃湁浠讳綍娴佺▼ID锛岀洿鎺ヨ繑鍥炵┖鍒嗛〉
+        if (workFlowsList == null || workFlowsList.isEmpty()) {
+            return new PageResult<OrderDetailVO>(
+                java.util.Collections.emptyList(),
+                0L,
+                queryDTO.getPageNum().longValue(),
+                queryDTO.getPageSize().longValue(),
+                0L
+            );
+        }
+
+        List<String> workFlowIds = workFlowsList.stream()
+                 .filter(item -> item instanceof Map)
+                 .map(item -> (Map<?, ?>) item)
+                 .map(m -> m.get("processInstanceId"))
+                 .filter(Objects::nonNull)
+                 .map(Object::toString)
+                 .collect(Collectors.toList());
+
+        Map<String,String> workFlowIdAndTaskIdMap = workFlowsList.stream()
+                .filter(item -> item instanceof Map)
+                .map(item -> (Map<?, ?>) item).collect(Collectors.toMap(m -> m.get("processInstanceId").toString(), m -> m.get("taskId").toString(),(k1,k2) -> k2));
 
         // 鎵ц鍒嗛〉鏌ヨ
         IPage<OrderInfo> result = baseMapper.selectPendingApprovalOrderPage(
@@ -141,12 +224,252 @@
             queryDTO.getOrderId(),
             queryDTO.getApplyTimeStart() != null ? queryDTO.getApplyTimeStart().toString() : null,
             queryDTO.getApplyTimeEnd() != null ? queryDTO.getApplyTimeEnd().toString() : null,
-            queryDTO.getOrderBy(), queryDTO.getOrderDirection()
+            queryDTO.getOrderBy(), queryDTO.getOrderDirection(), workFlowIds
         );
 
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            vo.setTaskId(workFlowIdAndTaskIdMap.get(vo.getWorkflowId()));
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
+
         // 鏋勫缓杩斿洖缁撴灉
-        return new PageResult<OrderInfo>(
-            result.getRecords(),
+        return new PageResult<OrderDetailVO>(
+                voList,
+                result.getTotal(),
+                queryDTO.getPageNum().longValue(),
+                queryDTO.getPageSize().longValue(),
+                result.getPages()
+        );
+    }
+
+    @Override
+    public PageResult<OrderDetailVO> getPendingApprovalOrderPageWithProductConditions(OrderQueryDTO queryDTO) {
+        // 鏍规嵁浜у搧鏉′欢鏌ヨ浜у搧ID鍒楄〃
+        List<String> productIds = null;
+        if (StringUtils.hasText(queryDTO.getIndustryId()) || StringUtils.hasText(queryDTO.getUnitProjectId()) ||
+            StringUtils.hasText(queryDTO.getProductTypeId()) || StringUtils.hasText(queryDTO.getProductSubTypeId())) {
+            productIds = reportResultSubmissionMapper.selectProductIdsByConditions(
+                queryDTO.getIndustryId(), queryDTO.getUnitProjectId(), 
+                queryDTO.getProductTypeId(), queryDTO.getProductSubTypeId()
+            );
+            
+            // 濡傛灉娌℃湁鎵惧埌鍖归厤鐨勪骇鍝侊紝鐩存帴杩斿洖绌虹粨鏋�
+            if (CollectionUtils.isEmpty(productIds)) {
+                return new PageResult<OrderDetailVO>(
+                    java.util.Collections.emptyList(),
+                    0L,
+                    queryDTO.getPageNum().longValue(),
+                    queryDTO.getPageSize().longValue(),
+                    0L
+                );
+            }
+        }
+
+        // 鍒涘缓鍒嗛〉瀵硅薄
+        Page<OrderInfo> page = new Page<>(queryDTO.getPageNum(), queryDTO.getPageSize());
+
+        // 鎵ц鍒嗛〉鏌ヨ
+        // 鍩轰簬workFlowType鏌ヨ娴佺▼瀹炰緥ID闆嗗悎
+        List<?> workFlowList = fetchWorkflowProcessInstanceIds(
+            queryDTO.getWorkFlowType(),
+            queryDTO.getUserId(),
+            queryDTO.getDepartmentId(),
+            queryDTO.getBusinessType(),
+            queryDTO.getPageNum(),
+            queryDTO.getPageSize()
+        );
+        // 濡傛灉娌℃湁浠讳綍娴佺▼ID锛岀洿鎺ヨ繑鍥炵┖鍒嗛〉
+        if (workFlowList == null || workFlowList.isEmpty()) {
+            return new PageResult<OrderDetailVO>(
+                    java.util.Collections.emptyList(),
+                    0L,
+                    queryDTO.getPageNum().longValue(),
+                    queryDTO.getPageSize().longValue(),
+                    0L
+            );
+        }
+
+        List<String> workFlowIds = workFlowList.stream()
+                        .filter(item -> item instanceof Map)
+                        .map(item -> (Map<?, ?>) item)
+                        .map(m -> m.get("processInstanceId"))
+                        .filter(Objects::nonNull)
+                        .map(Object::toString)
+                        .collect(Collectors.toList());
+
+        Map<String,String> workFlowIdAndTaskIdMap = workFlowList.stream()
+                .filter(item -> item instanceof Map)
+                .map(item -> (Map<?, ?>) item).collect(Collectors.toMap(m -> m.get("processInstanceId").toString(), m -> m.get("taskId").toString(),(k1,k2) -> k2));
+
+
+        IPage<OrderInfo> result = baseMapper.selectPendingApprovalOrderPageWithProductConditions(
+            page, queryDTO.getOrderStatus(), queryDTO.getProductName(), queryDTO.getProviderName(),
+            queryDTO.getOrderId(),
+            queryDTO.getApplyTimeStart() != null ? queryDTO.getApplyTimeStart().toString() : null,
+            queryDTO.getApplyTimeEnd() != null ? queryDTO.getApplyTimeEnd().toString() : null,
+            queryDTO.getOrderBy(), queryDTO.getOrderDirection(), productIds, workFlowIds
+        );
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            vo.setTaskId(workFlowIdAndTaskIdMap.get(vo.getWorkflowId()));
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
+
+        // 鏋勫缓杩斿洖缁撴灉
+        return new PageResult<OrderDetailVO>(
+            voList,
+            result.getTotal(),
+            queryDTO.getPageNum().longValue(),
+            queryDTO.getPageSize().longValue(),
+            result.getPages()
+        );
+    }
+
+    @Override
+    public PageResult<OrderDetailVO> getBuyerOrderPageWithProductConditions(OrderQueryDTO queryDTO) {
+        // 鍙傛暟鏍¢獙
+        if (queryDTO.getUserId() == null) {
+            throw new BusinessException("鐢ㄦ埛ID涓嶈兘涓虹┖");
+        }
+
+        // 鏍规嵁浜у搧鏉′欢鏌ヨ浜у搧ID鍒楄〃
+        List<String> productIds = null;
+        if (StringUtils.hasText(queryDTO.getIndustryId()) || StringUtils.hasText(queryDTO.getUnitProjectId()) ||
+            StringUtils.hasText(queryDTO.getProductTypeId()) || StringUtils.hasText(queryDTO.getProductSubTypeId())) {
+            productIds = reportResultSubmissionMapper.selectProductIdsByConditions(
+                queryDTO.getIndustryId(), queryDTO.getUnitProjectId(), 
+                queryDTO.getProductTypeId(), queryDTO.getProductSubTypeId()
+            );
+            
+            // 濡傛灉娌℃湁鎵惧埌鍖归厤鐨勪骇鍝侊紝鐩存帴杩斿洖绌虹粨鏋�
+            if (CollectionUtils.isEmpty(productIds)) {
+                return new PageResult<OrderDetailVO>(
+                    java.util.Collections.emptyList(),
+                    0L,
+                    queryDTO.getPageNum().longValue(),
+                    queryDTO.getPageSize().longValue(),
+                    0L
+                );
+            }
+        }
+
+        // 鍒涘缓鍒嗛〉瀵硅薄
+        Page<OrderInfo> page = new Page<>(queryDTO.getPageNum(), queryDTO.getPageSize());
+
+        // 鎵ц鍒嗛〉鏌ヨ
+        IPage<OrderInfo> result = baseMapper.selectBuyerOrderPageWithProductConditions(
+            page, queryDTO.getUserId(), queryDTO.getUnitId(), queryDTO.getOrderStatus(),
+            queryDTO.getPaymentStatus(), queryDTO.getPaymentType(), queryDTO.getProductName(),
+            queryDTO.getProviderName(), queryDTO.getOrderId(), 
+            queryDTO.getApplyTimeStart() != null ? queryDTO.getApplyTimeStart().toString() : null,
+            queryDTO.getApplyTimeEnd() != null ? queryDTO.getApplyTimeEnd().toString() : null,
+            queryDTO.getCreateTimeStart() != null ? queryDTO.getCreateTimeStart().toString() : null,
+            queryDTO.getCreateTimeEnd() != null ? queryDTO.getCreateTimeEnd().toString() : null,
+            queryDTO.getOrderBy(), queryDTO.getOrderDirection(), productIds
+        );
+
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
+
+        // 鏋勫缓杩斿洖缁撴灉
+        return new PageResult<OrderDetailVO>(
+            voList,
+            result.getTotal(),
+            queryDTO.getPageNum().longValue(),
+            queryDTO.getPageSize().longValue(),
+            result.getPages()
+        );
+    }
+
+    @Override
+    public PageResult<OrderDetailVO> getSellerOrderPageWithProductConditions(OrderQueryDTO queryDTO) {
+        // 鍙傛暟鏍¢獙
+        if (queryDTO.getProviderId() == null) {
+            throw new BusinessException("鎻愪緵鑰匢D涓嶈兘涓虹┖");
+        }
+
+        // 鏍规嵁浜у搧鏉′欢鏌ヨ浜у搧ID鍒楄〃
+        List<String> productIds = null;
+        if (StringUtils.hasText(queryDTO.getIndustryId()) || StringUtils.hasText(queryDTO.getUnitProjectId()) ||
+            StringUtils.hasText(queryDTO.getProductTypeId()) || StringUtils.hasText(queryDTO.getProductSubTypeId())) {
+            productIds = reportResultSubmissionMapper.selectProductIdsByConditions(
+                queryDTO.getIndustryId(), queryDTO.getUnitProjectId(), 
+                queryDTO.getProductTypeId(), queryDTO.getProductSubTypeId()
+            );
+            
+            // 濡傛灉娌℃湁鎵惧埌鍖归厤鐨勪骇鍝侊紝鐩存帴杩斿洖绌虹粨鏋�
+            if (CollectionUtils.isEmpty(productIds)) {
+                return new PageResult<OrderDetailVO>(
+                    java.util.Collections.emptyList(),
+                    0L,
+                    queryDTO.getPageNum().longValue(),
+                    queryDTO.getPageSize().longValue(),
+                    0L
+                );
+            }
+        }
+
+        // 鍒涘缓鍒嗛〉瀵硅薄
+        Page<OrderInfo> page = new Page<>(queryDTO.getPageNum(), queryDTO.getPageSize());
+
+        // 鎵ц鍒嗛〉鏌ヨ
+        IPage<OrderInfo> result = baseMapper.selectSellerOrderPageWithProductConditions(
+            page, queryDTO.getProviderId(), queryDTO.getOrderStatus(), queryDTO.getPaymentStatus(),
+            queryDTO.getProductName(), queryDTO.getOrderId(),
+            queryDTO.getApplyTimeStart() != null ? queryDTO.getApplyTimeStart().toString() : null,
+            queryDTO.getApplyTimeEnd() != null ? queryDTO.getApplyTimeEnd().toString() : null,
+            queryDTO.getCreateTimeStart() != null ? queryDTO.getCreateTimeStart().toString() : null,
+            queryDTO.getCreateTimeEnd() != null ? queryDTO.getCreateTimeEnd().toString() : null,
+            queryDTO.getOrderBy(), queryDTO.getOrderDirection(), productIds
+        );
+
+        // 灏嗚鍗曚笌璇︽儏鑱旇〃灏佽鍒癡O
+        List<OrderDetailVO> voList = result.getRecords().stream().map(order -> {
+            OrderDetailVO vo = new OrderDetailVO();
+            BeanUtils.copyProperties(order, vo);
+            List<OrderDetail> details = orderDetailMapper.selectByOrderId(order.getOrderId());
+            List<OrderDetailItemVO> items = details.stream().map(d -> {
+                OrderDetailItemVO item = new OrderDetailItemVO();
+                BeanUtils.copyProperties(d, item);
+                return item;
+            }).collect(java.util.stream.Collectors.toList());
+            vo.setOrderDetails(items);
+            return vo;
+        }).collect(java.util.stream.Collectors.toList());
+
+        // 鏋勫缓杩斿洖缁撴灉
+        return new PageResult<OrderDetailVO>(
+            voList,
             result.getTotal(),
             queryDTO.getPageNum().longValue(),
             queryDTO.getPageSize().longValue(),
@@ -208,6 +531,34 @@
         }
         // 鐢熸垚璁㈠崟缂栧彿
         String orderId = orderNoService.generateOrderNo();
+        
+        // 鍏堣皟鐢ㄥ伐浣滄祦鎺ュ彛锛岃幏鍙栧伐浣滄祦ID
+        String workflowId = null;
+        String taskId = null;
+        try {
+            // 妫�鏌ユ槸鍚︽湁浠锋牸绫诲瀷涓�"鍗忚"鐨勬槑缁嗛」
+            boolean hasAgreementPrice = createOrderDTO.getItems().stream()
+                    .anyMatch(item -> "鍗忚".equals(item.getPriceType()));
+            
+            // 鏍规嵁鏄惁鍖呭惈鍗忚纭畾type鍊�
+            String type = hasAgreementPrice ? "trade_agreement" : "trade_point";
+            
+            // 璋冪敤鑾峰彇娴佺▼妯℃澘ID鐨勬帴鍙�
+            // String processTemplateId = getProcessTemplateId(type);
+            
+            if (createOrderDTO.getProcessdefId() != null) {
+                // 璋冪敤鍙戣捣宸ヤ綔娴佺殑鎺ュ彛
+                Map<String,Object> resMap = startWorkflowProcess(createOrderDTO.getProcessdefId(), createOrderDTO.getUserId(), type);
+                workflowId = resMap.get("processinstId").toString();
+                taskId = resMap.get("taskId").toString();
+            } else {
+                throw new BusinessException("娴佺▼瀹氫箟Id涓虹┖!");
+            }
+        } catch (Exception e) {
+            log.error("璋冪敤宸ヤ綔娴佹帴鍙eけ璐ワ紝璁㈠崟ID: {}", orderId, e);
+            // 宸ヤ綔娴佽皟鐢ㄥけ璐ワ紝鎶涘嚭寮傚父瑙﹀彂浜嬪姟鍥炴粴
+            throw new BusinessException("宸ヤ綔娴佽皟鐢ㄥけ璐�: " + e.getMessage());
+        }
 
         // 璁$畻鎬婚噾棰�
         BigDecimal totalAmount = BigDecimal.ZERO;
@@ -240,6 +591,9 @@
         orderInfo.setPaymentType(createOrderDTO.getPaymentType());
         orderInfo.setPaymentStatus("鏈敮浠�");
         orderInfo.setBuyerRemarks(createOrderDTO.getBuyerRemarks());
+        orderInfo.setIsEvaluate("鏈瘎浠�");
+        orderInfo.setWorkflowId(workflowId); // 璁剧疆宸ヤ綔娴両D
+        orderInfo.setTaskId(taskId);
         orderInfo.setCreatedAt(LocalDateTime.now());
         orderInfo.setUpdatedAt(LocalDateTime.now());
 
@@ -281,7 +635,7 @@
     @Transactional(rollbackFor = Exception.class)
     public Long uploadOrderAttachment(String orderId, String fileName, String originalName, 
                                     String fileType, Long fileSize, String fileUrl, 
-                                    String bucketName, String objectName, Long uploadUserId, 
+                                    String bucketName, String objectName, String uploadUserId,
                                     String uploadUserName, String attachmentType, String description) {
         // 鍙傛暟鏍¢獙
         if (!StringUtils.hasText(orderId)) {
@@ -323,7 +677,7 @@
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public boolean addOrderEvaluation(String orderId, Long evaluatorId, String evaluatorName, 
+    public boolean addOrderEvaluation(String orderId, String evaluatorId, String evaluatorName,
                                    String evaluatorType, String content, Integer rating, 
                                    Integer serviceRating, Integer qualityRating, Integer deliveryRating, 
                                    Boolean isAnonymous) {
@@ -602,6 +956,58 @@
             throw new BusinessException("鎻掑叆瀹℃壒璁板綍澶辫触");
         }
 
+        // 鏇存柊浜ゆ槗淇℃伅澶囨敞锛堝彧鏇存柊remarks锛屼笉鏇存柊璁㈠崟鐘舵�侊級
+        // 鍙洿鏂拌鍗曡鎯呭娉紝涓嶆洿鏂拌鍗曠姸鎬�
+        if(orderApprovalDTO.getOrderDetails() != null) {
+            for (UpdateOrderDetailDTO.UpdateOrderDetailItemDTO itemDTO : orderApprovalDTO.getOrderDetails()) {
+                if (itemDTO.getId() == null) {
+                    continue;
+                }
+
+                OrderDetail orderDetail = orderDetailMapper.selectById(itemDTO.getId());
+                if (orderDetail == null) {
+                    log.warn("璁㈠崟璇︽儏涓嶅瓨鍦紝ID: {}", itemDTO.getId());
+                    continue;
+                }
+
+                // 鏇存柊澶囨敞
+                orderDetail.setRemarks(itemDTO.getRemarks());
+                orderDetail.setUpdatedAt(LocalDateTime.now());
+
+                int detailUpdated = orderDetailMapper.updateById(orderDetail);
+                if (detailUpdated <= 0) {
+                    log.warn("鏇存柊璁㈠崟璇︽儏澶辫触锛孖D: {}", itemDTO.getId());
+                }
+            }
+        }
+
+        // 鏇存柊璁㈠崟鐘舵�侊紙閫氳繃 -> 涓嬩竴涓紱椹冲洖 -> 涓婁竴涓級
+        String currentStatus = orderInfo.getOrderStatus();
+        if (!StringUtils.hasText(currentStatus)) {
+            throw new BusinessException("璁㈠崟褰撳墠鐘舵�佷负绌�");
+        }
+        boolean isReject = orderApprovalDTO.getApprovalResult().contains("椹冲洖");
+        String targetStatus = isReject ? getPreviousOrderStatus(currentStatus) : getNextOrderStatus(currentStatus);
+        if (targetStatus == null) {
+            throw new BusinessException((isReject ? "宸叉槸鍒濆鐘舵�侊紝鏃犳硶鍥為��" : "宸叉槸鏈�缁堢姸鎬侊紝鏃犳硶缁х画娴佽浆"));
+        }
+        orderInfo.setOrderStatus(targetStatus);
+        orderInfo.setUpdatedAt(LocalDateTime.now());
+
+        int updated = this.baseMapper.updateById(orderInfo);
+        if (updated <= 0) {
+            throw new BusinessException("鏇存柊璁㈠崟鐘舵�佸け璐�");
+        }
+
+        log.info("璁㈠崟鐘舵�佹洿鏂版垚鍔燂紝璁㈠崟ID: {}, 浠� {} 鏇存柊涓� {}", orderInfo.getOrderId(), currentStatus, targetStatus);
+        // 鏍规嵁瀹℃壒缁撴灉璋冪敤鎻愪氦鎴栭┏鍥炴帴鍙�
+        String comment = orderApprovalDTO.getApprovalResult().contains("椹冲洖") ? "瀹℃牳椹冲洖" : "瀹℃牳閫氳繃";
+        if ("瀹℃牳椹冲洖".equals(comment)) {
+            rejectWorkflowTask(orderApprovalDTO.getTaskId(), String.valueOf(orderApprovalDTO.getApproverId()), comment);
+        } else {
+            completeWorkflowTask(orderApprovalDTO.getTaskId(), String.valueOf(orderApprovalDTO.getApproverId()), comment);
+        }
+
         log.info("瀹℃壒璁板綍娣诲姞鎴愬姛锛岃鍗旾D: {}, 瀹℃壒绫诲瀷: {}, 瀹℃壒缁撴灉: {}, 瀹℃壒浜�: {}, 瀹℃壒鎰忚: {}", 
                 orderApprovalDTO.getOrderId(),
                 orderApprovalDTO.getApprovalType(),
@@ -715,9 +1121,10 @@
     private String getNextOrderStatus(String currentStatus) {
         switch (currentStatus) {
             case "寰呬笂浼犳枃浠�":
-                return "寰呮巿鏉�";
+                return "寰呭鎵规巿鏉�";
+            case "寰呭鎵规巿鏉�":
             case "寰呮巿鏉�":
-                return "寰呬氦鏄撶‘璁�";
+                return  "寰呬氦鏄撶‘璁�";
             case "寰呬氦鏄撶‘璁�":
                 return "宸插畬鎴�";
             case "宸插畬鎴�":
@@ -738,7 +1145,7 @@
         switch (currentStatus) {
             case "寰呬笂浼犳枃浠�":
                 return null; // 鍒濆鐘舵��
-            case "寰呮巿鏉�":
+            case "寰呭鎵规巿鏉�":
                 return "寰呬笂浼犳枃浠�";
             case "寰呬氦鏄撶‘璁�":
                 return "寰呮巿鏉�";
@@ -893,46 +1300,50 @@
         try {
             // 1. 鍒犻櫎璁㈠崟闄勪欢锛堝寘鎷琈inIO鏂囦欢鍜屾暟鎹簱璁板綍锛�
             log.info("寮�濮嬪垹闄よ鍗曢檮浠讹紝璁㈠崟ID: {}", orderId);
-            List<OrderAttachment> attachments = orderAttachmentMapper.selectByOrderId(orderId);
-            for (OrderAttachment attachment : attachments) {
-                try {
-                    // 鍒犻櫎MinIO涓殑鏂囦欢
-                    if (StringUtils.hasText(attachment.getObjectName())) {
-                        log.info("鍒犻櫎MinIO鏂囦欢锛屽璞″悕绉�: {}", attachment.getObjectName());
-                        minioService.deleteFile(attachment.getObjectName());
-                    }
-                    // 鍒犻櫎鏁版嵁搴撹褰�
-                    orderAttachmentMapper.deleteById(attachment.getId());
-                    log.info("鍒犻櫎闄勪欢璁板綍鎴愬姛锛岄檮浠禝D: {}", attachment.getId());
-                } catch (Exception e) {
-                    log.error("鍒犻櫎闄勪欢澶辫触锛岄檮浠禝D: {}, 閿欒: {}", attachment.getId(), e.getMessage());
-                    // 缁х画鍒犻櫎鍏朵粬闄勪欢锛屼笉涓柇鏁翠釜娴佺▼
-                }
-            }
+//            List<OrderAttachment> attachments = orderAttachmentMapper.selectByOrderId(orderId);
+//            for (OrderAttachment attachment : attachments) {
+//                try {
+//                    // 鍒犻櫎MinIO涓殑鏂囦欢
+//                    if (StringUtils.hasText(attachment.getObjectName())) {
+//                        log.info("鍒犻櫎MinIO鏂囦欢锛屽璞″悕绉�: {}", attachment.getObjectName());
+//                        minioService.deleteFile(attachment.getObjectName());
+//                    }
+//                    // 鍒犻櫎鏁版嵁搴撹褰�
+//                    orderAttachmentMapper.deleteById(attachment.getId());
+//                    log.info("鍒犻櫎闄勪欢璁板綍鎴愬姛锛岄檮浠禝D: {}", attachment.getId());
+//                } catch (Exception e) {
+//                    log.error("鍒犻櫎闄勪欢澶辫触锛岄檮浠禝D: {}, 閿欒: {}", attachment.getId(), e.getMessage());
+//                    // 缁х画鍒犻櫎鍏朵粬闄勪欢锛屼笉涓柇鏁翠釜娴佺▼
+//                }
+//            }
 
             // 2. 閫昏緫鍒犻櫎璁㈠崟璇︽儏
-            log.info("寮�濮嬮�昏緫鍒犻櫎璁㈠崟璇︽儏锛岃鍗旾D: {}", orderId);
+            // log.info("寮�濮嬮�昏緫鍒犻櫎璁㈠崟璇︽儏锛岃鍗旾D: {}", orderId);
             // 鍏堟煡璇㈣鍗曡鎯呭垪琛紝鐒跺悗閫愪釜閫昏緫鍒犻櫎
-            List<OrderDetail> orderDetails = orderDetailMapper.selectByOrderId(orderId);
-            int detailDeleted = 0;
-            for (OrderDetail detail : orderDetails) {
-                int result = orderDetailMapper.deleteById(detail.getId());
-                if (result > 0) {
-                    detailDeleted++;
-                }
-            }
-            log.info("閫昏緫鍒犻櫎璁㈠崟璇︽儏瀹屾垚锛屽奖鍝嶈鏁�: {}", detailDeleted);
+//            List<OrderDetail> orderDetails = orderDetailMapper.selectByOrderId(orderId);
+//            int detailDeleted = 0;
+//            for (OrderDetail detail : orderDetails) {
+//                int result = orderDetailMapper.deleteById(detail.getId());
+//                if (result > 0) {
+//                    detailDeleted++;
+//                }
+//            }
+//            log.info("閫昏緫鍒犻櫎璁㈠崟璇︽儏瀹屾垚锛屽奖鍝嶈鏁�: {}", detailDeleted);
 
             // 3. 鍒犻櫎璁㈠崟淇℃伅锛堥�昏緫鍒犻櫎锛�
-            log.info("寮�濮嬪垹闄よ鍗曚俊鎭紝璁㈠崟ID: {}", orderId);
-            int orderDeleted = this.baseMapper.deleteById(orderId);
-            log.info("鍒犻櫎璁㈠崟淇℃伅瀹屾垚锛屽奖鍝嶈鏁�: {}", orderDeleted);
+//            log.info("寮�濮嬪垹闄よ鍗曚俊鎭紝璁㈠崟ID: {}", orderId);
+//            int orderDeleted = this.baseMapper.deleteById(orderId);
+//            log.info("鍒犻櫎璁㈠崟淇℃伅瀹屾垚锛屽奖鍝嶈鏁�: {}", orderDeleted);
+            // 鏇存柊璁㈠崟鐘舵�佷负宸插畬鎴�
+            orderInfo.setOrderStatus("宸插彇娑�");
+            orderInfo.setUpdatedAt(LocalDateTime.now());
+            int orderDeleted = this.baseMapper.updateById(orderInfo);
 
             if (orderDeleted > 0) {
                 log.info("璁㈠崟鍙栨秷鎴愬姛锛岃鍗旾D: {}", orderId);
                 return true;
             } else {
-                log.error("鍒犻櫎璁㈠崟淇℃伅澶辫触锛屽奖鍝嶈鏁颁负0锛岃鍗旾D: {}", orderId);
+                log.error("鏇存柊璁㈠崟淇℃伅澶辫触锛屽奖鍝嶈鏁颁负0锛岃鍗旾D: {}", orderId);
                 throw new BusinessException("鍒犻櫎璁㈠崟淇℃伅澶辫触");
             }
         } catch (Exception e) {
@@ -940,4 +1351,299 @@
             throw new BusinessException("鍙栨秷璁㈠崟澶辫触锛�" + e.getMessage());
         }
     }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean updateWorkflowId(String orderId, String workflowId) {
+        if (!StringUtils.hasText(orderId)) {
+            throw new BusinessException("璁㈠崟ID涓嶈兘涓虹┖");
+        }
+        if (!StringUtils.hasText(workflowId)) {
+            throw new BusinessException("宸ヤ綔娴両D涓嶈兘涓虹┖");
+        }
+
+        OrderInfo orderInfo = this.getById(orderId);
+        if (orderInfo == null) {
+            throw new BusinessException("璁㈠崟涓嶅瓨鍦�");
+        }
+
+        orderInfo.setWorkflowId(workflowId);
+        orderInfo.setUpdatedAt(LocalDateTime.now());
+        return this.updateById(orderInfo);
+    }
+
+    @Override
+    public boolean existsCompletedNotCancelledOrderByProductId(String productId) {
+        if (!StringUtils.hasText(productId)) {
+            throw new BusinessException("浜у搧ID涓嶈兘涓虹┖");
+        }
+        QueryWrapper<OrderInfo> wrapper = new QueryWrapper<>();
+        wrapper.eq("product_id", productId);
+        // 鏈彇娑堬細閫昏緫鏈垹闄�
+        wrapper.eq("deleted", 0);
+        // 瀹℃牳涓細鐘舵�佷笉涓� 宸插畬鎴� 鎴� 宸插彇娑�
+        wrapper.notIn("order_status", Arrays.asList("宸插畬鎴�", "宸插彇娑�"));
+        Long count = this.baseMapper.selectCount(wrapper);
+        return count != null && count > 0;
+    }
+
+    @Override
+    public boolean updateOrderIsEvaluate(String orderId) {
+        if (!StringUtils.hasText(orderId)) {
+            throw new BusinessException("璁㈠崟ID涓嶈兘涓虹┖");
+        }
+        OrderInfo orderInfo = this.getById(orderId);
+        if (orderInfo == null) {
+            throw new BusinessException("璁㈠崟涓嶅瓨鍦�");
+        }
+        orderInfo.setIsEvaluate("宸茶瘎浠�");
+        return this.updateById(orderInfo);
+    }
+
+    /**
+     * 鑾峰彇娴佺▼妯℃澘ID
+     * @param type 绫诲瀷鍙傛暟
+     * @return 娴佺▼妯℃澘ID
+     */
+    private String getProcessTemplateId(String type) {
+        try {
+            String url = workflowProperties.getApproval().getBaseUrl() + workflowProperties.getApproval().getTemplateRelationUrl();
+            
+            // 鏋勫缓璇锋眰鍙傛暟
+            Map<String, Object> params = new HashMap<>();
+            params.put("type", type);
+            params.put("unitId", workflowProperties.getApproval().getUnitId());
+            
+            // 鍙戦�丳OST璇锋眰
+            ResponseEntity<Map<String, Object>> response = restTemplate.exchange(
+                url, 
+                HttpMethod.POST, 
+                new HttpEntity<>(params), 
+                new ParameterizedTypeReference<Map<String, Object>>() {}
+            );
+            
+            if (response.getStatusCode().is2xxSuccessful() && response.getBody() != null) {
+                Map<String, Object> responseBody = response.getBody();
+                return (String) responseBody.get("processTemplateId");
+            } else {
+                log.warn("鑾峰彇娴佺▼妯℃澘ID澶辫触锛屽搷搴旂姸鎬�: {}", response.getStatusCode());
+                return null;
+            }
+        } catch (Exception e) {
+            log.error("璋冪敤鑾峰彇娴佺▼妯℃澘ID鎺ュ彛澶辫触", e);
+            throw new BusinessException("鑾峰彇娴佺▼妯℃澘ID澶辫触: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 鍚姩宸ヤ綔娴佹祦绋�
+     * @param processTemplateId 娴佺▼妯℃澘ID
+     * @param userId 鐢ㄦ埛ID
+     * @param businessKey 涓氬姟閿紙璁㈠崟ID锛�
+     * @return 娴佺▼瀹炰緥ID
+     */
+    private Map<String,Object> startWorkflowProcess(String processTemplateId, String userId, String businessKey) {
+        try {
+            String url = workflowProperties.getProcess().getBaseUrl() + workflowProperties.getProcess().getStartProcessUrl();
+            
+            // 鏋勫缓璇锋眰鍙傛暟
+            Map<String, Object> params = new HashMap<>();
+            params.put("processdefId", processTemplateId);
+            params.put("userid", userId);
+            params.put("businessKey", businessKey);
+            
+            // 鍙戦�丳OST璇锋眰
+            ResponseEntity<Map<String, Object>> response = restTemplate.exchange(
+                url, 
+                HttpMethod.POST, 
+                new HttpEntity<>(params), 
+                new ParameterizedTypeReference<Map<String, Object>>() {}
+            );
+            
+            if (response.getStatusCode().is2xxSuccessful() && response.getBody() != null) {
+                Object code = response.getBody().get("code");
+                boolean ok = (code instanceof Number && ((Number) code).intValue() == 200) || "200".equals(String.valueOf(code));
+                if (!ok) {
+                    throw new BusinessException("宸ヤ綔娴佸惎鍔ㄤ换鍔″け璐ワ紝杩斿洖鐮�: " + code);
+                }
+                Map<String, Object> data = (Map<String, Object>) response.getBody().get("data");
+                if (data == null) {
+                    throw new BusinessException("宸ヤ綔娴佸惎鍔ㄤ换鍔″け璐ワ紝杩斿洖鏁版嵁涓虹┖");
+                }
+                return  data;
+            } else {
+                throw new BusinessException("鍚姩宸ヤ綔娴佸け璐ワ紝鍝嶅簲鐘舵��:"+response.getStatusCode());
+            }
+        } catch (Exception e) {
+            log.error("璋冪敤鍚姩宸ヤ綔娴佹帴鍙eけ璐�", e);
+            throw new BusinessException("鍚姩宸ヤ綔娴佸け璐�: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 鎻愪氦娴佺▼浠诲姟
+     * @param taskId 浠诲姟ID锛堜娇鐢ㄨ鍗曠殑workflowId锛�
+     * @param userId 鐢ㄦ埛ID
+     * @param comment 瀹℃壒鎰忚锛堝锛氬鏍搁�氳繃锛�
+     */
+    private void completeWorkflowTask(String taskId, String userId, String comment) {
+        try {
+            String url = workflowProperties.getProcess().getBaseUrl() + workflowProperties.getProcess().getCompleteUrl();
+            Map<String, Object> params = new HashMap<>();
+            params.put("taskId", taskId);
+            params.put("userid", userId);
+            params.put("commponet", comment);
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            HttpEntity<Map<String, Object>> entity = new HttpEntity<>(params, headers);
+
+            ResponseEntity<Map<String, Object>> response = restTemplate.exchange(
+                url,
+                HttpMethod.POST,
+                entity,
+                new ParameterizedTypeReference<Map<String, Object>>() {}
+            );
+
+            if (response.getStatusCode().is2xxSuccessful() && response.getBody() != null) {
+                Object code = response.getBody().get("code");
+                boolean ok = (code instanceof Number && ((Number) code).intValue() == 200) || "200".equals(String.valueOf(code));
+                if (!ok) {
+                    throw new BusinessException("宸ヤ綔娴佸畬鎴愪换鍔″け璐ワ紝杩斿洖鐮�: " + code);
+                }
+                Map<?, ?> data = (Map<?, ?>) response.getBody().get("data");
+                if (data == null) {
+                    throw new BusinessException("宸ヤ綔娴佸畬鎴愪换鍔″け璐ワ紝杩斿洖鏁版嵁涓虹┖");
+                }
+                log.info("瀹屾垚宸ヤ綔娴佷换鍔℃垚鍔燂紝processinstId: {}", data.get("processinstId"));
+            } else {
+                throw new BusinessException("宸ヤ綔娴佸畬鎴愪换鍔℃帴鍙h皟鐢ㄥけ璐ワ紝HTTP鐘舵��: " + response.getStatusCode());
+            }
+        } catch (Exception e) {
+            log.error("鎻愪氦宸ヤ綔娴佸け璐�", e);
+            throw new BusinessException("鎻愪氦宸ヤ綔娴佸け璐�: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 椹冲洖娴佺▼浠诲姟
+     */
+    private void rejectWorkflowTask(String taskId, String userId, String comment) {
+        try {
+            String url = workflowProperties.getProcess().getBaseUrl() + workflowProperties.getProcess().getRejectUrl();
+            Map<String, Object> params = new HashMap<>();
+            params.put("taskId", taskId);
+            params.put("userid", userId);
+            params.put("commponet", comment);
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            HttpEntity<Map<String, Object>> entity = new HttpEntity<>(params, headers);
+
+            ResponseEntity<Map<String, Object>> response = restTemplate.exchange(
+                url,
+                HttpMethod.POST,
+                entity,
+                new ParameterizedTypeReference<Map<String, Object>>() {}
+            );
+
+            if (response.getStatusCode().is2xxSuccessful() && response.getBody() != null) {
+                Object code = response.getBody().get("code");
+                boolean ok = (code instanceof Number && ((Number) code).intValue() == 200) || "200".equals(String.valueOf(code));
+                if (!ok) {
+                    throw new BusinessException("宸ヤ綔娴侀┏鍥炰换鍔″け璐ワ紝杩斿洖鐮�: " + code);
+                }
+                Map<?, ?> data = (Map<?, ?>) response.getBody().get("data");
+                if (data == null) {
+                    throw new BusinessException("宸ヤ綔娴侀┏鍥炰换鍔″け璐ワ紝杩斿洖鏁版嵁涓虹┖");
+                }
+                log.info("椹冲洖宸ヤ綔娴佷换鍔℃垚鍔燂紝processinstId: {}", data.get("processinstId"));
+            } else {
+                throw new BusinessException("宸ヤ綔娴侀┏鍥炰换鍔℃帴鍙h皟鐢ㄥけ璐ワ紝HTTP鐘舵��: " + response.getStatusCode());
+            }
+        } catch (Exception e) {
+            log.error("椹冲洖宸ヤ綔娴佸け璐�", e);
+            throw new BusinessException("椹冲洖宸ヤ綔娴佸け璐�: " + e.getMessage());
+        }
+    }
+
+    /**
+     * 鎸夌収workFlowType鏌ヨ娴佺▼瀹炰緥ID闆嗗悎
+     * workFlowType: 0=浠e姙锛�1=宸插姙
+     */
+    private List<Object> fetchWorkflowProcessInstanceIds(Integer workFlowType, String userId, String depId,String businessKey,Integer pageIndex, Integer pageSize) {
+        try {
+            if (workFlowType == null) {
+                return java.util.Collections.emptyList();
+            }
+
+            String base = workflowProperties.getProcess().getBaseUrl();
+
+            Map<String, Object> params = new HashMap<>();
+            params.put("userid", userId);
+            params.put("businessKey", businessKey);
+            params.put("pageIndex", pageIndex != null ? pageIndex : 1);
+            params.put("pageSize", pageSize != null ? pageSize : 10);
+
+            String url;
+            if (workFlowType != null && workFlowType == 0) {
+                // 浠e姙
+                url = base + workflowProperties.getProcess().getFindTodoUrl();
+                params.put("depid", depId);
+            } else {
+                // 宸插姙
+                url = base + workflowProperties.getProcess().getFindDoneUrl();
+            }
+
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            HttpEntity<Map<String, Object>> entity = new HttpEntity<>(params, headers);
+
+            ResponseEntity<Map<String, Object>> response = restTemplate.exchange(
+                url,
+                HttpMethod.POST,
+                entity,
+                new ParameterizedTypeReference<Map<String, Object>>() {}
+            );
+
+            if (!response.getStatusCode().is2xxSuccessful() || response.getBody() == null) {
+                return java.util.Collections.emptyList();
+            }
+            Object dataObj = response.getBody().get("data");
+
+            if (workFlowType != null && workFlowType == 0) {
+                if (!(dataObj instanceof java.util.List)) {
+                    return java.util.Collections.emptyList();
+                }
+                java.util.List<Object> list = (java.util.List<Object>) dataObj;
+                return list;
+//                        list.stream()
+//                        .filter(item -> item instanceof Map)
+//                        .map(item -> (Map<?, ?>) item)
+//                        .map(m -> m.get("processInstanceId"))
+//                        .filter(Objects::nonNull)
+//                        .map(Object::toString)
+//                        .collect(Collectors.toList());
+            }else {
+                if (!(dataObj instanceof Map)) {
+                    return java.util.Collections.emptyList();
+                }
+                Map<?,?> map = (Map<?,?>) dataObj;
+                Object dataObj1 = ((Map<?, ?>) dataObj).get("list");
+                java.util.List<Object> list = (java.util.List<Object>) dataObj1;
+                return list;
+//                        list.stream()
+//                        .filter(item -> item instanceof Map)
+//                        .map(item -> (Map<?, ?>) item)
+//                        .map(m -> m.get("processInstanceId"))
+//                        .filter(Objects::nonNull)
+//                        .map(Object::toString)
+//                        .collect(Collectors.toList());
+            }
+
+        } catch (Exception e) {
+            log.error("鏌ヨ宸ヤ綔娴佸疄渚婭D澶辫触", e);
+            return java.util.Collections.emptyList();
+        }
+    }
 }

--
Gitblit v1.8.0