采购：内贸资信获取审核人

 package com.lframework.xingyun.sc.procurement.impl.credit;
 
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
@@ -344,8 +346,46 @@ public class ProcurementDomesticCustomerCreditServiceImpl
         if (StringUtils.isBlank(id)) {
             return new DomesticReviewerDto();
         }
-        DomesticReviewerDto reviewer = getBaseMapper().getReviewerById(id);
-        return reviewer == null ? new DomesticReviewerDto() : reviewer;
+        DomesticReviewerDto reviewer = new DomesticReviewerDto();
+        reviewer.setId(id);
+
+        String defJson = getBaseMapper().getLatestFlowDefJson(id);
+        if (StringUtils.isBlank(defJson)) {
+            return reviewer;
+        }
+
+        JSONObject flowJson = JsonUtil.parseObj(defJson);
+        Object nodeListObj = flowJson.get("nodeList");
+        if (ObjectUtil.isNull(nodeListObj)) {
+            return reviewer;
+        }
+
+        JSONArray nodeList = JsonUtil.parseArray(nodeListObj);
+        for (Object nodeObj : nodeList) {
+            if (ObjectUtil.isNull(nodeObj)) {
+                continue;
+            }
+
+            JSONObject nodeJson = JsonUtil.parseObj(nodeObj);
+            String nodeCode = nodeJson.getStr("nodeCode");
+            if (StringUtils.isBlank(nodeCode)) {
+                continue;
+            }
+
+            String approverName = getFirstApproverName(nodeJson);
+            if (StringUtils.isBlank(approverName)) {
+                continue;
+            }
+
+            if (isProcurementOfficeNode(nodeCode)) {
+                reviewer.setProcurementOffice(approverName);
+            } else if ("domestic_customer_credit_gyglk".equals(nodeCode)) {
+                reviewer.setSupplyManagementSection(approverName);
+            } else if ("domestic_customer_credit_gybzg".equals(nodeCode)) {
+                reviewer.setSupplyDepartment(approverName);
+            }
+        }
+        return reviewer;
     }
 
     /**
@@ -417,6 +457,49 @@ public class ProcurementDomesticCustomerCreditServiceImpl
     }
 
     /**
+     * 获取节点首个审批人名称
+     *
+     * @param nodeJson 流程节点JSON
+     * @return 审批人名称
+     */
+    private String getFirstApproverName(JSONObject nodeJson) {
+        if (nodeJson == null) {
+            return null;
+        }
+
+        JSONObject extMap = nodeJson.getJSONObject("extMap");
+        if (extMap == null) {
+            return null;
+        }
+
+        Object handleInfosObj = extMap.get("handleInfos");
+        if (ObjectUtil.isNull(handleInfosObj)) {
+            return null;
+        }
+
+        JSONArray handleInfos = JsonUtil.parseArray(handleInfosObj);
+        if (handleInfos.isEmpty()) {
+            return null;
+        }
+
+        JSONObject firstHandleInfo = JsonUtil.parseObj(handleInfos.get(0));
+        return firstHandleInfo.getStr("createBy");
+    }
+
+    /**
+     * 判断是否为采购处主管节点
+     *
+     * @param nodeCode 节点编码
+     * @return 是否为采购处主管节点
+     */
+    private boolean isProcurementOfficeNode(String nodeCode) {
+        return "domestic_customer_credit_cgczg_1".equals(nodeCode)
+                || "domestic_customer_credit_cgczg_2".equals(nodeCode)
+                || "domestic_customer_credit_cgczg_3".equals(nodeCode)
+                || "domestic_customer_credit_cgczg_4".equals(nodeCode);
+    }
+
+    /**
      * 发送评审有效期提醒消息。
      *
      * @param customerCredit 内贸资信

@@ -26,7 +26,7 @@ public interface ProcurementDomesticCustomerCreditMapper extends BaseMapper<Proc
     ProcurementDomesticCustomerCredit findById(@Param("id") String id);
 
     /**
-     * 获取审核人
+     * 查询最新流程定义JSON
      */
-    DomesticReviewerDto getReviewerById(@Param("id") String id);
+    String getLatestFlowDefJson(@Param("id") String id);
 }

@@ -179,35 +179,11 @@
         WHERE tb.id = #{id}
     </select>
 
-    <select id="getReviewerById" resultType="com.lframework.xingyun.sc.procurement.dto.DomesticReviewerDto">
-        SELECT
-            business_id,
-            -- 1. 采购处主管 (动态获取)
-            JSON_UNQUOTE(
-                    JSON_EXTRACT(def_json, CONCAT(
-                            REPLACE(JSON_SEARCH(def_json, 'one', 'domestic_customer_credit_cgczg_%'), '.nodeCode', ''),
-                            '.extMap.handleInfos[0].createBy'
-                        ))
-                ) AS procurementOffice,
-
-            -- 2. 供应管理科主管 (domestic_customer_credit_gyglk)
-            JSON_UNQUOTE(
-                    JSON_EXTRACT(def_json, CONCAT(
-                            REPLACE(JSON_SEARCH(def_json, 'one', 'domestic_customer_credit_gyglk'), '.nodeCode', ''),
-                            '.extMap.handleInfos[0].createBy'
-                        ))
-                ) AS supplyManagementSection,
-
-            -- 3. 供应部主管 (domestic_customer_credit_gybzg)
-            JSON_UNQUOTE(
-                    JSON_EXTRACT(def_json, CONCAT(
-                            REPLACE(JSON_SEARCH(def_json, 'one', 'domestic_customer_credit_gybzg'), '.nodeCode', ''),
-                            '.extMap.handleInfos[0].createBy'
-                        ))
-                ) AS supplyDepartment
-
+    <select id="getLatestFlowDefJson" resultType="java.lang.String">
+        SELECT def_json
         FROM flow_instance
         WHERE business_id = #{id}
-        ORDER BY create_time DESC LIMIT 1
+        ORDER BY create_time DESC
+        LIMIT 1
     </select>
 </mapper>