gemma: pkg/imports/fd.go annotate

annotate pkg/imports/fd.go @ 1900:6a67cd819e93

To prepare stretch import made some model data types re-usable.

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Fri, 18 Jan 2019 15:04:53 +0100
parents	8a56a64e4410
children	ec7360afd5e1

rev	line source
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	1 // This is Free Software under GNU Affero General Public License v >= 3.0
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	2 // without warranty, see README.md and license for details.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	3 //
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	4 // SPDX-License-Identifier: AGPL-3.0-or-later
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	5 // License-Filename: LICENSES/AGPL-3.0.txt
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	6 //
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	7 // Copyright (C) 2018 by via donau
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	8 // – Österreichische Wasserstraßen-Gesellschaft mbH
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	9 // Software engineering by Intevation GmbH
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	10 //
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	11 // Author(s):
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	12 // * Raimund Renkert <raimund.renkert@intevation.de>
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	13
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	14 package imports
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	15
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	16 import (
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	17 "context"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	18 "database/sql"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	19 "encoding/json"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	20 "errors"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	21 "fmt"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	22 "io"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	23 "time"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	24
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	25 "gemma.intevation.de/gemma/pkg/common"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	26 "gemma.intevation.de/gemma/pkg/wfs"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	27 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	28
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	29 // FairwayDimension is an import job to import
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	30 // the fairway dimensions in form of polygon geometries
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	31 // and attribute data from a WFS service.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	32 type FairwayDimension struct {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	33 // URL the GetCapabilities URL of the WFS service.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	34 URL string `json:"url"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	35 // FeatureType selects the feature type of the WFS service.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	36 FeatureType string `json:"feature-type"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	37 SortBy string `json:"sort-by"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	38 LOS int `json:"los"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	39 MinWidth int `json:"min-width"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	40 MaxWidth int `json:"max-width"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	41 Depth int `json:"depth"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	42 SourceOrganization string `json:"source-organization"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	43 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	44
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	45 type fdTime struct{ time.Time }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	46
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	47 func (fdt *fdTime) UnmarshalJSON(data []byte) error {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	48 var s string
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	49 if err := json.Unmarshal(data, &s); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	50 return err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	51 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	52 t, err := time.Parse("20060102", s)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	53 if err == nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	54 *fdt = fdTime{t}
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	55 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	56 return err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	57 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	58
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	59 // FDJobKind is the import queue type identifier.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	60 const FDJobKind JobKind = "fd"
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	61
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	62 type fdJobCreator struct{}
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	63
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	64 func init() {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	65 RegisterJobCreator(FDJobKind, fdJobCreator{})
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	66 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	67
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	68 func (fdJobCreator) Description() string { return "fairway dimension" }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	69
1890 b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	70 func (fdJobCreator) AutoAccept() bool { return false }
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	71
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	72 func (fdJobCreator) Create(_ JobKind, data string) (Job, error) {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	73 fd := new(FairwayDimension)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	74 if err := common.FromJSONString(data, fd); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	75 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	76 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	77 return fd, nil
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	78 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	79
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	80 func (fdJobCreator) Depends() []string {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	81 return []string{
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	82 "fairway_dimensions",
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	83 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	84 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	85
1890 b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	86 func (fdJobCreator) StageDone(
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	87 ctx context.Context,
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	88 tx *sql.Tx,
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	89 id int64,
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	90 ) error {
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	91 // Delete the old features.
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	92 if _, err := tx.ExecContext(ctx, deleteFairwayDimensionSQL); err != nil {
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	93 return err
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	94 }
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	95
1890 b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	96 _, err := tx.ExecContext(ctx, fdStageDoneSQL, id)
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	97 return err
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	98 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	99
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	100 // CleanUp for fairway dimension imports is a NOP.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	101 func (*FairwayDimension) CleanUp() error { return nil }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	102
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	103 type fairwayDimensionProperties struct {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	104 HydroSorDat fdTime `json:"hydro_sordat"`
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	105 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	106
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	107 type fdSummary struct {
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	108 Lat float64 `json:"lat"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	109 Lon float64 `json:"lon"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	110 ID int64 `json:"id"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	111 }
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	112
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	113 const (
1890 b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	114 fdStageDoneSQL = `
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	115 UPDATE waterway.fairway_dimensions SET staging_done = true
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	116 WHERE id IN (
1890 b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	117 SELECT key from waterway.track_imports
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	118 WHERE import_id = $1 AND
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	119 relation = 'waterway.fairway_dimensions'::regclass)`
b1b0db195cc5 Put fairway dimension import to staging area. Raimund Renkert <raimund.renkert@intevation.de> parents: 1841 diff changeset	120
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	121 deleteFairwayDimensionSQL = `
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	122 WITH resp AS (
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	123 SELECT best_utm(area::geometry) AS t,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	124 ST_Transform(area::geometry, best_utm(area::geometry)) AS a
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	125 FROM users.responsibility_areas
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	126 WHERE country = users.current_user_country()
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	127 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	128 DELETE FROM waterway.fairway_dimensions
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	129 WHERE ST_Covers(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	130 (SELECT a FROM resp),
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	131 ST_Transform(area::geometry, (SELECT t FROM resp))) AND staging_done = true
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	132 `
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	133
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	134 // The ST_MakeValid (line125) and ST_Buffer (line124) are a workarround to
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	135 // avoid errors due to reprojection.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	136 insertFairwayDimensionSQL = `
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	137 WITH resp AS (
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	138 SELECT best_utm(area::geometry) AS t,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	139 ST_Transform(area::geometry, best_utm(area::geometry)) AS a
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	140 FROM users.responsibility_areas
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	141 WHERE country = users.current_user_country()
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	142 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	143 INSERT INTO waterway.fairway_dimensions (area, level_of_service, min_width, max_width, min_depth, date_info, source_organization)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	144 SELECT ST_Transform(clipped.geom, 4326)::geography, $3, $4, $5, $6, $7, $8 FROM (
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	145 SELECT (ST_Dump(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	146 ST_Intersection(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	147 (SELECT ST_Buffer(a, -0.0001) FROM resp),
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	148 ST_MakeValid(ST_Transform(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	149 ST_GeomFromWKB($1, $2::integer),
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	150 (SELECT t FROM resp)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	151 ))
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	152 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	153 )).geom AS geom
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	154 ) AS clipped
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	155 WHERE clipped.geom IS NOT NULL
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	156 RETURNING id,
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	157 ST_X(ST_Centroid(area::geometry)),
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	158 ST_Y(ST_Centroid(area::geometry))
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	159 `
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	160 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	161
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	162 // Do executes the actual fairway dimension import.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	163 func (fd *FairwayDimension) Do(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	164 ctx context.Context,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	165 importID int64,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	166 conn *sql.Conn,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	167 feedback Feedback,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	168 ) (interface{}, error) {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	169
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	170 start := time.Now()
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	171
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	172 feedback.Info("Import fairway dimension")
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	173
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	174 feedback.Info("Loading capabilities from %s", fd.URL)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	175 caps, err := wfs.GetCapabilities(fd.URL)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	176 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	177 feedback.Error("Loading capabilities failed: %v", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	178 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	179 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	180
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	181 ft := caps.FindFeatureType(fd.FeatureType)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	182 if ft == nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	183 return nil, fmt.Errorf("Unknown feature type '%s'", fd.FeatureType)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	184 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	185
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	186 feedback.Info("Found feature type '%s'", fd.FeatureType)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	187
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	188 epsg, err := wfs.CRSToEPSG(ft.DefaultCRS)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	189 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	190 feedback.Error("Unsupported CRS name '%s'", ft.DefaultCRS)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	191 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	192 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	193
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	194 urls, err := wfs.GetFeaturesGET(
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	195 caps, fd.FeatureType, "application/json", fd.SortBy)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	196 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	197 feedback.Error("Cannot create GetFeature URLs. %v", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	198 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	199 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	200
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	201 tx, err := conn.BeginTx(ctx, nil)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	202 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	203 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	204 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	205 defer tx.Rollback()
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	206
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	207 insertStmt, err := tx.PrepareContext(ctx, insertFairwayDimensionSQL)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	208 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	209 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	210 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	211 defer insertStmt.Close()
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	212
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	213 var (
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	214 unsupported = stringCounter{}
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	215 missingProperties int
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	216 badProperties int
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	217 features int
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	218 fds []fdSummary
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	219 )
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	220
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	221 if err := wfs.DownloadURLs(urls, func(r io.Reader) error {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	222 rfc, err := wfs.ParseRawFeatureCollection(r)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	223 if err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	224 return fmt.Errorf("parsing GetFeature document failed: %v", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	225 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	226 if rfc.CRS != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	227 crsName := rfc.CRS.Properties.Name
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	228 if epsg, err = wfs.CRSToEPSG(crsName); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	229 feedback.Error("Unsupported CRS: %d", crsName)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	230 return err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	231 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	232 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	233
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	234 // No features -> ignore.
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	235 if rfc.Features == nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	236 return nil
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	237 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	238
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	239 feedback.Info("Using EPSG: %d", epsg)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	240
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	241 for _, feature := range rfc.Features {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	242 if feature.Geometry.Coordinates == nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	243 missingProperties++
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	244 continue
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	245 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	246
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	247 var props fairwayDimensionProperties
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	248
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	249 if err := json.Unmarshal(*feature.Properties, &props); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	250 badProperties++
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	251 continue
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	252 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	253 switch feature.Geometry.Type {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	254 case "Polygon":
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	255 var p polygonSlice
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	256 if err := json.Unmarshal(*feature.Geometry.Coordinates, &p); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	257 return err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	258 }
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	259 var fdid int64
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	260 var lat, lon float64
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	261 if err := insertStmt.QueryRowContext(
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	262 ctx,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	263 p.asWKB(),
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	264 epsg,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	265 fd.LOS,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	266 fd.MinWidth,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	267 fd.MaxWidth,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	268 fd.Depth,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	269 props.HydroSorDat.Time,
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	270 fd.SourceOrganization,
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	271 ).Scan(&fdid, &lat, &lon); err != nil {
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	272 feedback.Error("error: %s", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	273 return err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	274 }
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	275 // Store for potential later removal.
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	276 if err = track(ctx, tx, importID, "waterway.fairway_dimensions", fdid); err != nil {
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	277 return err
9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	278 }
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	279 fds = append(fds, fdSummary{ID: fdid, Lat: lat, Lon: lon})
1893 9beff970b107 Track fairway dimension import and delete old data on staging done. Raimund Renkert <raimund.renkert@intevation.de> parents: 1890 diff changeset	280
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	281 features++
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	282 default:
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	283 unsupported[feature.Geometry.Type]++
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	284 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	285 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	286 return nil
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	287 }); err != nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	288 feedback.Error("Downloading features failed: %v", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	289 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	290 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	291
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	292 if badProperties > 0 {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	293 feedback.Warn("Bad properties: %d", badProperties)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	294 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	295
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	296 if missingProperties > 0 {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	297 feedback.Warn("Missing properties: %d", missingProperties)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	298 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	299
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	300 if len(unsupported) != 0 {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	301 feedback.Warn("Unsupported types found: %s", unsupported)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	302 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	303
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	304 if features == 0 {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	305 err := errors.New("No features found")
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	306 feedback.Error("%v", err)
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	307 return nil, err
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	308 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	309
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	310 if err = tx.Commit(); err == nil {
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	311 feedback.Info("Storing %d features took %s",
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	312 features, time.Since(start))
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	313 }
491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	314
1898 8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	315 summary := struct {
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	316 Date time.Time `json:"date"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	317 LOS int `json:"los"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	318 SourceOrganization string `json:"source-organization"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	319 FdArea []fdSummary `json:"fd-area"`
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	320 }{
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	321 Date: time.Now(),
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	322 LOS: fd.LOS,
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	323 SourceOrganization: fd.SourceOrganization,
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	324 FdArea: fds,
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	325 }
8a56a64e4410 Summarize the result of fairway dimension import for review. Raimund Renkert <raimund.renkert@intevation.de> parents: 1893 diff changeset	326 return &summary, err
1841 491f5b68da9e Implemented fairway dimension import. Raimund Renkert <raimund.renkert@intevation.de> parents: diff changeset	327 }

Mercurial > gemma

annotate pkg/imports/fd.go @ 1900:6a67cd819e93