作业路线数据

geo/geojson_processor.go

@@ -50,13 +50,22 @@ func connectDB() (*sql.DB, error) {
 }
 
 func createTable(db *sql.DB) error {
+	// _, err := db.Exec(`
+	// 	CREATE TABLE IF NOT EXISTS geojson_data (
+	// 		id SERIAL PRIMARY KEY,
+	// 		type VARCHAR(64),
+	// 		geom geometry(Geometry,4326),
+	// 		properties JSONB
+	// 	)
+	// `)
 	_, err := db.Exec(`
-		CREATE TABLE IF NOT EXISTS geojson_data (
-			id SERIAL PRIMARY KEY,
+		create table IF NOT EXISTS opt_fly_routes (
+			id serial PRIMARY key,
 			type VARCHAR(64),
-			geom geometry(Geometry,4326),
-			properties JSONB
-		)
+			properties JSONB,
+			opt_time timestamp,
+			geometry geometry(linestring,4326)
+		);
 	`)
 	return err
 }
@@ -125,9 +134,15 @@ func processFile(filename string, db *sql.DB) error {
 			log.Printf("转换properties失败: %v", err)
 			continue
 		}
+
+		// 	_, err = tx.Exec(`
+		// 	INSERT INTO geojson_data (type, geom, properties)
+		// 	VALUES ($1, ST_GeomFromGeoJSON($2), $3)
+		// `, feature.Type, string(geometryJSON), string(propertiesJSON))
+
 		_, err = tx.Exec(`
-			INSERT INTO geojson_data (type, geom, properties)
-			VALUES ($1, ST_GeomFromGeoJSON($2), $3)
+			INSERT INTO opt_fly_routes (type, geometry, properties,opt_time)
+			VALUES ($1, ST_GeomFromGeoJSON($2), $3,now())
 		`, feature.Type, string(geometryJSON), string(propertiesJSON))
 		if err != nil {
 			log.Printf("插入数据失败: %v", err)

geo/geojson_processor_test.go

@@ -3,6 +3,6 @@ package geo
 import "testing"
 
 func TestInitProcessFile(t *testing.T) {
-	filename := "/Users/liang/Downloads/山西省村界.geojson"
+	filename := "/Users/liang/Downloads/dji.geojson"
 	ProcessGeoJSONFile(filename)
 }

sql/area.sql

@@ -4,7 +4,7 @@ create table opt_routes (
 	id serial PRIMARY key,
 	type VARCHAR(64),
 	properties JSONB,
-	opt_time date,
+	opt_time timestamp,
 	geometry geometry(linestring,4326)
 );
 
@@ -13,7 +13,7 @@ create table opt_fly_routes (
 	id serial PRIMARY key,
 	type VARCHAR(64),
 	properties JSONB,
-	opt_time date,
+	opt_time timestamp,
 	geometry geometry(linestring,4326)
 );
 
@@ -22,7 +22,7 @@ create table opt_area(
 	id serial PRIMARY key,
 	type VARCHAR(64),
 	properties JSONB,
-	opt_time date,
+	opt_time timestamp,
 	geometry geometry(polygon,4326)
 );