职务抽取改为微服务调用

src/main/java/com/zzsn/leaderbase/feign/api/UpdateRecognitionService.java

+package com.zzsn.leaderbase.feign.api;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
+
+/**
+ * 职务抽取服务
+ */
+@FeignClient(value = "Update-Recognition")
+public interface UpdateRecognitionService {
+
+    /**
+     * 职务抽取服务
+     * @param body 请求参数
+     * @author yanxin
+     * @date 2025/7/7
+     */
+    @PostMapping("/update_extraction/")
+    String updateExtraction(@RequestBody String body);
+}

src/main/java/com/zzsn/leaderbase/kafka/PersonOfJobChangeKafkaConsumer.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.zzsn.leaderbase.entity.CharacterExtractInfo;
+import com.zzsn.leaderbase.feign.api.UpdateRecognitionService;
 import com.zzsn.leaderbase.service.CharacterExtractInfoService;
 import com.zzsn.leaderbase.service.IGeneratorIdService;
 import com.zzsn.leaderbase.util.EsUtil;
@@ -36,6 +37,9 @@ public class PersonOfJobChangeKafkaConsumer {
     @Autowired
     IGeneratorIdService generatorIdService;
 
+    @Autowired(required = false)
+    UpdateRecognitionService updateRecognitionService;
+
     @Autowired
     private EsUtil esUtil;
 
@@ -70,9 +74,15 @@ public class PersonOfJobChangeKafkaConsumer {
         boolean flag = false;//diao接口成功标识
         while(true){
             try {
-                if(flag)
+                if(flag){
                     break;
-                String result = HttpUtil.doPost(relationEntityUrl, jsonObjectParam, 300000);
+                }
+                String result;
+                if(updateRecognitionService!=null){
+                    result = updateRecognitionService.updateExtraction(jsonObjectParam.toJSONString());
+                }else{
+                    result = HttpUtil.doPost(relationEntityUrl, jsonObjectParam, 300000);
+                }
                 log.info("职务变更抽取响应结果:{}", result);
                 Object objectResult = parseResult(result);
                 if (null != objectResult) {