u_map.go 2.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. package util
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "io/ioutil"
  6. "net/http"
  7. "pji_desktop_http/common/config/c_pji"
  8. "sync"
  9. )
  10. func ContainsKey(m *sync.Map, key string) bool {
  11. _, found := m.Load(key)
  12. return found
  13. }
  14. // 根据id获取解析后的地图文件列表
  15. func GetExactedMapFileById(id string) (fileList []string, err error) {
  16. url := c_pji.SenceOssDownUrl + id
  17. // 构建请求
  18. req, err := http.NewRequest("GET", url, nil)
  19. if err != nil {
  20. fmt.Println("Error creating request:", err)
  21. return nil, err
  22. }
  23. // 添加认证头
  24. req.Header.Set("Authorization", c_pji.Token)
  25. // 发送请求
  26. client := &http.Client{}
  27. resp, err := client.Do(req)
  28. if err != nil {
  29. fmt.Println("Error executing request:", err)
  30. return nil, err
  31. }
  32. defer resp.Body.Close()
  33. body, _ := ioutil.ReadAll(resp.Body)
  34. // Json转换为map
  35. var data map[string]interface{}
  36. err = json.Unmarshal(body, &data)
  37. // 提取响应体中的data字段
  38. dataField, ok := data["data"].([]interface{})
  39. if !ok {
  40. fmt.Println("Error extracting data field")
  41. return nil, err
  42. }
  43. // 转换字符串切片
  44. for _, item := range dataField {
  45. str, ok := item.(string)
  46. if !ok {
  47. fmt.Println("Error converting item to string")
  48. return nil, err
  49. }
  50. fileList = append(fileList, str)
  51. }
  52. return fileList, nil
  53. }
  54. // 根据id获取对应的原始bag文件
  55. func GetRosFileById(id string) (file string, err error) {
  56. url := c_pji.SenceInfoUrl + id
  57. // 构建请求
  58. req, err := http.NewRequest("GET", url, nil)
  59. if err != nil {
  60. fmt.Println("Error creating request:", err)
  61. return "", err
  62. }
  63. // 添加认证头
  64. req.Header.Set("Authorization", c_pji.Token)
  65. // 发送请求
  66. client := &http.Client{}
  67. resp, err := client.Do(req)
  68. if err != nil {
  69. fmt.Println("Error executing request:", err)
  70. return "", err
  71. }
  72. defer resp.Body.Close()
  73. body, _ := ioutil.ReadAll(resp.Body)
  74. // Json转换为map
  75. var data map[string]interface{}
  76. err = json.Unmarshal(body, &data)
  77. //fmt.Println("data:", data)
  78. // 提取响应体中的data字段
  79. dataField, ok := data["data"].(map[string]interface{})
  80. if !ok {
  81. fmt.Println("Error extracting data field")
  82. return "", err
  83. }
  84. // 从 data字段中提取 rosField
  85. rosField, ok := dataField["rosFileId"].(string)
  86. if !ok {
  87. fmt.Println("ID not found or not a string")
  88. return
  89. }
  90. if !ok {
  91. fmt.Println("Error extracting rosFileId field")
  92. return "", err
  93. }
  94. //println("rosFileId:", rosField)
  95. return rosField, nil
  96. }