问题修改

src/main/java/com/zzsn/leaderbase/config/QiyegaoguanExcutor.java

+package com.zzsn.leaderbase.config;
+
+import com.zzsn.leaderbase.entity.CharacterBasicInfo;
+import com.zzsn.leaderbase.entity.CharacterCorrelationEnterprise;
+import com.zzsn.leaderbase.service.CharacterBasicInfoService;
+import com.zzsn.leaderbase.service.CharacterCorrelationEnterpriseService;
+import com.zzsn.leaderbase.service.IGeneratorIdService;
+import com.zzsn.leaderbase.util.CharacterMergeStatus;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedReader;
+import java.io.FileReader;
+import java.io.IOException;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @Version 1.0
+ * @Author: ZhangJingKun
+ * @Date: 2024/4/7 11:18
+ * @Content:
+ */
+@Slf4j
+@Component
+public class QiyegaoguanExcutor implements CommandLineRunner {
+    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
+    private final Integer PERIOD=60*60*24*365;
+
+    //生成id
+    @Autowired
+    IGeneratorIdService generatorIdService;
+    @Autowired
+    CharacterMergeStatus characterMergeStatus;
+
+    @Autowired
+    CharacterBasicInfoService characterBasicInfoService;
+    @Autowired
+    CharacterCorrelationEnterpriseService characterCorrelationEnterpriseService;
+
+    @Value("${offset}")
+    private int offset;
+    @Value("${size}")
+    private int size;
+
+    @Override
+    public void run(String... args) {
+        scheduledExecutorService.scheduleAtFixedRate(()->{
+            run2();
+        },5,PERIOD, TimeUnit.SECONDS);
+    }
+
+
+    void run2(){
+        try (BufferedReader br = new BufferedReader(new FileReader("D:\\444.txt"))) {
+            String line;
+            while ((line = br.readLine()) != null) {
+                // 处理每行的逻辑
+                String id = line.replace("\"", "");
+                String uid = generatorIdService.getIdNo();
+
+                CharacterBasicInfo characterBasicInfo = new CharacterBasicInfo();
+                characterBasicInfo.setId(id);
+                characterBasicInfo.setUid(uid);
+                characterBasicInfoService.updateById(characterBasicInfo);
+
+                //人物企业信息
+                CharacterCorrelationEnterprise characterCorrelationEnterprise = new CharacterCorrelationEnterprise();
+                characterCorrelationEnterprise.setId(id);
+                characterCorrelationEnterprise.setUid(uid);
+                characterCorrelationEnterpriseService.updateById(characterCorrelationEnterprise);
+                System.out.println("id:" + id);
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+}

src/main/java/com/zzsn/leaderbase/entity/CharacterCorrelationEnterprise.java

+package com.zzsn.leaderbase.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName("character_correlation_enterprise")
+public class CharacterCorrelationEnterprise {
+
+  //主键
+  private String id;
+  //关联人物id
+  private String uid;
+  //企业信用代码
+  private String socialCreditCode;
+  //企业名称
+  private String ename;
+  //职位	股东、法人、董事长等
+  private String position;
+  //薪资
+  private String salary;
+  //持股数
+  private String shareNum;
+  //持股比例
+  private String shareRatio;
+  //最终受益股份
+  private String benefitShare;
+  //本届任期
+  private String currentTerm;
+  //创建人
+  private String createBy;
+  //创建时间
+  @TableField(fill = FieldFill.INSERT)
+  @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+  @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+  private Date createTime;
+  //更新人
+  private String updateBy;
+  //更新时间
+  @TableField(fill = FieldFill.INSERT)
+  @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
+  @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+  private Date updateTime;
+  //启停状态  1启 0停
+  private long status;
+}

src/main/java/com/zzsn/leaderbase/mapper/CharacterCorrelationEnterpriseMapper.java

+package com.zzsn.leaderbase.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zzsn.leaderbase.entity.CharacterCorrelationEnterprise;
+
+/**
+ * @Version 1.0
+ * @Author: ZhangJingKun
+ * @Date: 2024/4/7 11:05
+ * @Content:
+ */
+public interface CharacterCorrelationEnterpriseMapper extends BaseMapper<CharacterCorrelationEnterprise> {
+}

src/main/java/com/zzsn/leaderbase/service/CharacterCorrelationEnterpriseService.java

+package com.zzsn.leaderbase.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.zzsn.leaderbase.entity.CharacterCorrelationEnterprise;
+
+/**
+ * @Version 1.0
+ * @Author: ZhangJingKun
+ * @Date: 2024/4/7 11:03
+ * @Content:
+ */
+public interface CharacterCorrelationEnterpriseService extends IService<CharacterCorrelationEnterprise> {
+}

src/main/java/com/zzsn/leaderbase/service/DealLeaderDataService.java

@@ -77,13 +77,18 @@ public class DealLeaderDataService {
                     Map<String, List<InfoExtractionParam>> map = new HashMap<>();
                     map.put("data_list", Collections.singletonList(record));
                     jsonObjectParam.put("data", map);
-                    log.info("request");
-                    String result = HttpUtil.doPost(relationEntityUrl, jsonObjectParam, 40000);
-                    log.info("response:{}", result);
-                    Object objectResult = parseResult(result);
                     JSONArray dataResultList = null;
-                    if (null != objectResult) {
-                        dataResultList = (JSONArray) JSONArray.parse(objectResult.toString());
+                    try {
+                        log.info("request");
+                        String result = HttpUtil.doPost(relationEntityUrl, jsonObjectParam, 40000);
+                        log.info("response:{}", result);
+                        Object objectResult = parseResult(result);
+                        if (null != objectResult) {
+                            dataResultList = (JSONArray) JSONArray.parse(objectResult.toString());
+                        }
+                    }catch (Exception e){
+                        log.error("资讯解析失败");
+                        log.error("异常：{}",e.getMessage());
                     }
                     if (dataResultList != null) {
                         for (Object dataResultObject : dataResultList) {
@@ -110,7 +115,7 @@ public class DealLeaderDataService {
                                                 .company(temp.get("curWorkPlace") != null ? temp.get("curWorkPlace").toString() : "")
                                                 .name(temp.get("person") != null ? temp.get("person").toString() : "")
                                                 .articleId(dataResult.get("id") != null ? dataResult.get("id").toString() : "")
-                                                .articleIndex(dataResult.get("id") != null ? idIndexMap.get("id") : "")
+                                                .articleIndex(dataResult.get("id") != null ? idIndexMap.get(dataResult.get("id")) : "")
                                                 .checkStatus(0L)
                                                 .createTime(new Date())
                                                 .build());

src/main/java/com/zzsn/leaderbase/service/impl/CharacterCorrelationEnterpriseServiceImpl.java

+package com.zzsn.leaderbase.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zzsn.leaderbase.entity.CharacterCorrelationEnterprise;
+import com.zzsn.leaderbase.mapper.CharacterCorrelationEnterpriseMapper;
+import com.zzsn.leaderbase.service.CharacterCorrelationEnterpriseService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Version 1.0
+ * @Author: ZhangJingKun
+ * @Date: 2024/4/7 11:04
+ * @Content:
+ */
+@Service
+public class CharacterCorrelationEnterpriseServiceImpl extends ServiceImpl<CharacterCorrelationEnterpriseMapper, CharacterCorrelationEnterprise> implements CharacterCorrelationEnterpriseService {
+}

src/main/java/com/zzsn/leaderbase/service/impl/CharacterInfoServiceImpl.java

@@ -113,10 +113,10 @@ public class CharacterInfoServiceImpl implements CharacterInfoService {
             BeanUtils.copyProperties(characterVo, characterChangeInfo);
             characterChangeInfoList.add(characterChangeInfo);
 
-            CharacterBasicInfoHistory characterBasicInfoHistory = new CharacterBasicInfoHistory();
-            BeanUtils.copyProperties(characterBasicInfo, characterBasicInfoHistory);
-            characterBasicInfoHistory.setId(null);
-            characterBasicInfoHistoryList.add(characterBasicInfoHistory);
+//            CharacterBasicInfoHistory characterBasicInfoHistory = new CharacterBasicInfoHistory();
+//            BeanUtils.copyProperties(characterBasicInfo, characterBasicInfoHistory);
+//            characterBasicInfoHistory.setId(null);
+//            characterBasicInfoHistoryList.add(characterBasicInfoHistory);
         }
 
         characterBasicInfoService.saveBatch(characterBasicInfoList);