From d5531b6c34c72354128591acac30167af24b5b84 Mon Sep 17 00:00:00 2001
From: sh <2022704648@qq.com>
Date: Mon, 1 Aug 2022 14:44:03 +0800
Subject: [PATCH] 修改id为LongType

---
 juvenile-prosecution-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/handle/service/SparkEtlService.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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));
--
libgit2 0.21.4