修改接受字段，修改企业年报关联字段

background-service/zksy-system/src/main/java/com/zksy/basicData/domain/XcrAnnualReportBaseInfo.java

@@ -375,7 +375,7 @@ private static final long serialVersionUID=1L;
             @ApiModelProperty("企业年报年份")
             @TableField("ENTCHEYEAR")
             @JsonProperty("ENTCHEYEAR")
-    private Long ENTCHEYEAR;
+    private String ENTCHEYEAR;
 
     /** 数据更新时间 */
             @JsonFormat(pattern = "yyyy-MM-dd")

data-service/src/main/java/com/zksy/data/domain/po/XcrAnnualReportBaseInfo.java

@@ -76,7 +76,7 @@ public class XcrAnnualReportBaseInfo extends BasePo implements Serializable {
 
     @TableField("EMPNUM")
     @JsonProperty("EMPNUM")
-    private Integer empnum;  // 从业人数
+    private Long empnum;  // 从业人数
 
     @TableField("EMPNUMDIS")
     @JsonProperty("EMPNUMDIS")
@@ -88,35 +88,35 @@ public class XcrAnnualReportBaseInfo extends BasePo implements Serializable {
 
     @TableField("COLGRANUM")
     @JsonProperty("COLGRANUM")
-    private Integer colgranum;  // 其中高校毕业生人数(经营者)
+    private Long colgranum;  // 其中高校毕业生人数(经营者)
 
     @TableField("COLEMPLNUM")
     @JsonProperty("COLEMPLNUM")
-    private Integer colemplnum;  // 其中高校毕业生人数(雇工)
+    private Long colemplnum;  // 其中高校毕业生人数(雇工)
 
     @TableField("RETSOLNUM")
     @JsonProperty("RETSOLNUM")
-    private Integer retsolnum;  // 其中退役士兵人数(经营者)
+    private Long retsolnum;  // 其中退役士兵人数(经营者)
 
     @TableField("RETEMPLNUM")
     @JsonProperty("RETEMPLNUM")
-    private Integer retemplnum;  // 其中退役士兵人数(雇工)
+    private Long retemplnum;  // 其中退役士兵人数(雇工)
 
     @TableField("DISPERNUM")
     @JsonProperty("DISPERNUM")
-    private Integer dispernum;  // 其中残疾人人数(经营者)
+    private Long dispernum;  // 其中残疾人人数(经营者)
 
     @TableField("DISEMPLNUM")
     @JsonProperty("DISEMPLNUM")
-    private Integer disemplnum;  // 其中残疾人人数(雇工)
+    private Long disemplnum;  // 其中残疾人人数(雇工)
 
     @TableField("UNENUM")
     @JsonProperty("UNENUM")
-    private Integer unenum;  // 其中失业人员再就业人数(经营者)
+    private Long unenum;  // 其中失业人员再就业人数(经营者)
 
     @TableField("UNEEMPLNUM")
     @JsonProperty("UNEEMPLNUM")
-    private Integer uneemplnum;  // 其中失业人员再就业人数(雇工)
+    private Long uneemplnum;  // 其中失业人员再就业人数(雇工)
 
     @TableField("DEPENDENTENTNAME")
     @JsonProperty("DEPENDENTENTNAME")
@@ -188,7 +188,7 @@ public class XcrAnnualReportBaseInfo extends BasePo implements Serializable {
 
     @TableField("NUMPARM")
     @JsonProperty("NUMPARM")
-    private Integer numparm;  // 党员（预备党员）人数
+    private Long numparm;  // 党员（预备党员）人数
 
     @TableField("PARINS")
     @JsonProperty("PARINS")
@@ -213,7 +213,7 @@ public class XcrAnnualReportBaseInfo extends BasePo implements Serializable {
 
     @TableField("ENTCHEYEAR")
     @JsonProperty("ENTCHEYEAR")
-    private Integer entcheyear;  // 企业年报年份
+    private String entcheyear;  // 企业年报年份
 
     @TableField("S_EXT_DATATIME")
     @JsonProperty("S_EXT_DATATIME")

data-service/src/main/java/com/zksy/data/service/impl/XcrEnterpriseAnnualReportShareholderServiceImpl.java

@@ -18,6 +18,7 @@ import org.springframework.transaction.support.TransactionTemplate;
 
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 /**
@@ -48,13 +49,14 @@ public class XcrEnterpriseAnnualReportShareholderServiceImpl extends ServiceImpl
         // 将股东信息转换为实体类对象
         List<XcrEnterpriseAnnualReportShareholder> toDatabaseList = BeanUtil.copyToList(baseinfoAll.getData(), XcrEnterpriseAnnualReportShareholder.class);
 
-        // 创建一个映射，将 uniscid 映射到年报基本信息对象
+        // 创建一个映射，将处理过的 ENTCHEYEAR 映射到年报基本信息对象
         Map<String, AnBaseinfo> annualReportMap = annualReportAll.getData().stream()
-                .collect(Collectors.toMap(AnBaseinfo::getAncheid, info -> info));
+                .collect(Collectors.toMap(info -> getProcessedEntcheyear(info.getEntcheyear()), Function.identity()));
 
         // 设置 uniCode 属性
         toDatabaseList.forEach(q -> {
-            AnBaseinfo annualReport = annualReportMap.get(q.getAncheid());
+            String processedEntcheyear = getProcessedEntcheyear(q.getEntcheyear());
+            AnBaseinfo annualReport = annualReportMap.get(processedEntcheyear);
             if (annualReport != null) {
                 q.setUniCode(annualReport.getUniscid());
             }
@@ -70,6 +72,17 @@ public class XcrEnterpriseAnnualReportShareholderServiceImpl extends ServiceImpl
             return null;
         });
     }
+    // 辅助方法：处理 ENTCHEYEAR 字段，返回下划线前的数据
+    private String getProcessedEntcheyear(String entcheyear) {
+        if (entcheyear == null || entcheyear.isEmpty()) {
+            return "";
+        }
+        int underscoreIndex = entcheyear.indexOf('_');
+        if (underscoreIndex > -1) {
+            return entcheyear.substring(0, underscoreIndex);
+        }
+        return entcheyear; // 如果没有下划线，则直接返回原字符串
+    }
 }
 
 

xh-api/src/main/java/com/zksy/api/dto/tableData/AnBaseinfo.java

@@ -106,7 +106,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("ASSGRODIS")
-    private String assgrodiss;
+    private String assgrodis;
 
     
     @JsonProperty("LIAGRO")
@@ -114,7 +114,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("LIAGRODIS")
-    private String liagrodiss;
+    private String liagrodis;
 
     
     @JsonProperty("VENDINC")
@@ -122,7 +122,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("VENDINCDIS")
-    private String vendincdiss;
+    private String vendincdis;
 
     
     @JsonProperty("MAIBUSINC")
@@ -130,7 +130,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("MAIBUSINCDIS")
-    private String maibusincdiss;
+    private String maibusincdis;
 
     
     @JsonProperty("PROGRO")
@@ -138,7 +138,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("PROGRODIS")
-    private String progrodiss;
+    private String progrodis;
 
     
     @JsonProperty("NETINC")
@@ -146,7 +146,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("NETINCDIS")
-    private String netincdiss;
+    private String netincdis;
 
     
     @JsonProperty("RATGRO")
@@ -154,7 +154,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("RATGRODIS")
-    private String ratgrodiss;
+    private String ratgrodis;
 
     
     @JsonProperty("TOTEQU")
@@ -162,7 +162,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("TOTEQUDIS")
-    private String totequdiss;
+    private String totequdis;
 
     
     @JsonProperty("NUMPARM")
@@ -182,7 +182,7 @@ public class AnBaseinfo implements Serializable {
 
     
     @JsonProperty("RESPARSECSIGN")
-    private String resparsesign;
+    private String resparsecsign;
 
     
     @JsonProperty("LASTUPDATETIME")