pk_teisendame_jooni.R 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. #' Piirkonnale andmebaasides olevate joonte teisendamine
  2. #'
  3. #' Etteantud piirkonna geomeetrilise piirjoone ('piir') ja selle joone piirikasti ('bb') järele leitakse nende aladega kaetud jooned. Andmed salvestatakse postgis andmebaasi.
  4. #'
  5. #' @param obj str Objekti nimi. Edaspidi on oluline ainult see nimi. Piirkonna geomeetrilist joont ei ole vaja lisada.
  6. #' @param conf A list() of configuration variables. Default values \code{\link[ruut]{get_config}}.
  7. #' @return Uute andmebaasi kihtide 'piir_...' ja 'bb_...' loomine.
  8. #' @seealso [sf::st_read()], [sf::write_sf()],[sf::st_transform()],[ruut::pk_sellest_alustame_db_loomist()],[ruut::pk_lisame_ruudustikud()] ,[ruut::pk_lisame_polygoonid()],[ruut::pk_lisame_jooned()],[ruut::pk_lisame_punktid()],[ruut::pk_lisame_piirkonnale_punktid()],[ruut::pk_teisendame_polygoone()],[ruut::pk_teisendame_jooni()],[ruut::pk_teisendame_punkte()]
  9. #' @keywords postgis, boundary box, EPSG:3301
  10. #' @export
  11. #' @examples
  12. #' \dontrun{
  13. #'
  14. #' obj <- "marja"
  15. #' pk_teisendame_jooni(obj = obj, conf = NULL)
  16. #'
  17. #' # Layers list.
  18. #' ruut::db_schema_tablenames(conf = conf)
  19. #' }
  20. pk_teisendame_jooni <- function(obj = NULL, conf = NULL) {
  21. obj <- gsub(" ", "_", tolower(obj))
  22. ## Konfiguratsiooni muutujale väärtuste omistamine, kui seda pole antud.
  23. if (is.null(conf)) {
  24. conf <- ruut::get_config()
  25. conf$schema <- obj
  26. }
  27. if (!any("piir" %in% ruut::db_schema_tablenames(conf = conf))) {
  28. cat("\nAndmebaas loomata. Palun funktsiooniga ruut::pk_sellest_alustame_db_loomist() andmebaasi loomist.\n")
  29. return(NULL)
  30. }
  31. ## ------------- muutujad ja teisendused ---------------
  32. conn <- ruut::db_connect(conf = conf)
  33. try(piir <- sf::st_read(dsn = conn, layer = c(conf$schema, "piir")))
  34. tmp_dir <- tempdir()
  35. tmp_gpkg_file <- sprintf("%s/%s.gpkg", tmp_dir, obj)
  36. # system(sprintf("touch %s", tmp_gpkg_file))
  37. conf$gpkg_home <- tmp_dir
  38. conf$gpkg_file <- obj
  39. conf$gpkg_table <- "test_layer"
  40. tmp_gpkg_file_output <- ruut::construct_to_gpkg_output_file_str(conf = conf, is_input_str = F)
  41. tmp_gpkg_file_input <- ruut::construct_to_gpkg_output_file_str(conf = conf, is_input_str = T)
  42. conf$gpkg_table <- "test_layer_2"
  43. tmp_gpkg_file_output_2 <- ruut::construct_to_gpkg_output_file_str(conf = conf, is_input_str = F)
  44. tmp_gpkg_file_input_2 <- ruut::construct_to_gpkg_output_file_str(conf = conf, is_input_str = T)
  45. # write to gpkg
  46. sf::write_sf(piir, dsn = tmp_gpkg_file, layer = "piir", driver = "gpkg", fid_column_name = "id", delete_dsn = T)
  47. # unlink(tmp_gpkg_file)
  48. ## ====================== teisendused =====================
  49. # Layers list
  50. conf$schema <- obj
  51. layer_names <- ruut::db_schema_tablenames(conf = conf)
  52. layer_names <- layer_names[!layer_names %in% c("bb2", "epk10t_grid", "epk02t_grid", "epk2t_grid")] # c("bb", "bb2", "bb_epk10t_grid", "bb_epk02t_grid", "bb_epk2t_grid", "bb_epk10t", "bb_epk02t")]
  53. for (layer_name in layer_names) {
  54. try(ruumiline_obj <- sf::st_read(dsn = conn, layer = c(conf$schema, layer_name)))
  55. ## Kontlrollime kas geomeetriline objekt on polügoon.
  56. ## Arvutame sel juhul pindala.
  57. is_line <- any(grepl("line", tolower(attributes(ruumiline_obj$geom)$class), fixed = TRUE))
  58. if (is_line) {
  59. ## Lõikame objekti ruudistikga tükkideks. Ühte ruutu võib jääda mitu tükki.
  60. ## Peame need pärast ühendama
  61. # ruut::qgis_algorithm_search_by_word("Intersection")
  62. algorithm <- "native:intersection"
  63. conf$table <- sprintf("%s", layer_name)
  64. input <- ruut::construct_to_gpkg_output_postgres_str(
  65. conf = conf, geometry_type = "MultiLineString", srid = 3301,
  66. checkPrimaryKeyUnicity = TRUE, key = "id", geometry_field = "geom"
  67. )
  68. conf$table <- sprintf("%s", "epk02t_grid")
  69. overlay <- ruut::construct_to_gpkg_output_postgres_str(
  70. conf = conf, geometry_type = "Polygon", srid = 3301,
  71. checkPrimaryKeyUnicity = TRUE, key = "id", geometry_field = "geom"
  72. )
  73. output <- tmp_gpkg_file_output # ajutine fail
  74. str <- sprintf("{ 'INPUT' : '%s', 'INPUT_FIELDS' : ['fid'], 'OUTPUT' : '%s', 'OVERLAY' : '%s', 'OVERLAY_FIELDS' : [], 'OVERLAY_FIELDS_PREFIX' : '' }", input, output, overlay)
  75. cmd <- ruut::construct_qgis_output_result_to_better_format(str = str, algorithm = algorithm)
  76. system(cmd)
  77. ## Ühendame ruudus olevad pinnad
  78. # ruut::qgis_algorithm_search_by_word("Dissolve")
  79. algorithm <- "native:dissolve"
  80. input <- tmp_gpkg_file_input # ajutine fail
  81. output <- tmp_gpkg_file_output_2 # ajutine fail
  82. str <- sprintf("{ 'FIELD' : ['%s'], 'INPUT' : '%s', 'OUTPUT' : '%s' }", "id", input, output)
  83. cmd <- ruut::construct_qgis_output_result_to_better_format(str = str, algorithm = algorithm)
  84. system(cmd)
  85. ## Lisame joonte pikkused
  86. # ruut::qgis_algorithm_search_by_word("attributes")
  87. algorithm <- "qgis:exportaddgeometrycolumns"
  88. input <- tmp_gpkg_file_input_2 # ajutine fail
  89. conf$table <- sprintf("%s_epk02t", layer_name)
  90. output <- ruut::construct_to_gpkg_output_postgres_str(conf = conf, geometry_field = "geom", geometry_type = "Polygon", srid = 3301, checkPrimaryKeyUnicity = FALSE, key = "id")
  91. str <- sprintf("{ 'CALC_METHOD' : 0, 'INPUT' : '%s', 'OUTPUT' : '%s' }", input, output)
  92. cmd <- ruut::construct_qgis_output_result_to_better_format(str = str, algorithm = algorithm)
  93. system(cmd)
  94. }
  95. }
  96. ## Layers list
  97. conf$schema <- obj
  98. ruut::db_schema_tablenames(conf = conf)
  99. sf::st_layers(dsn = tmp_gpkg_file)
  100. }