diff --git a/juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java b/juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java
index cbb3429..b137a55 100644
--- a/juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java
+++ b/juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java
@@ -197,7 +197,7 @@ public class SparkEtlService implements Serializable {
 //        schemaFields.add(DataTypes.createStructField("updateTime", DataTypes.StringType, true));
 
         List<StructField> schemaFields = new ArrayList<StructField>();
-        schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false));
+        schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
         schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true));
@@ -281,7 +281,7 @@ public class SparkEtlService implements Serializable {
 //        schemaFields.add(DataTypes.createStructField("reason", DataTypes.StringType, true));
 //        schemaFields.add(DataTypes.createStructField("other", DataTypes.StringType, true));
 //        schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true));
-        schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false));
+        schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
         schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("household_num", DataTypes.StringType, true));
@@ -370,7 +370,7 @@ public class SparkEtlService implements Serializable {
 //        schemaFields.add(DataTypes.createStructField("phoneTwo", DataTypes.StringType, true));
 //        schemaFields.add(DataTypes.createStructField("phone", DataTypes.StringType, true));
 //        schemaFields.add(DataTypes.createStructField("createTime", DataTypes.StringType, true));
-        schemaFields.add(DataTypes.createStructField("id", DataTypes.IntegerType, false));
+        schemaFields.add(DataTypes.createStructField("id", DataTypes.LongType, false));
         schemaFields.add(DataTypes.createStructField("name", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("sys_org_code", DataTypes.StringType, true));
         schemaFields.add(DataTypes.createStructField("identity", DataTypes.StringType, true));