fwh_powerFlow.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. package fwh_pro
  2. import (
  3. "fmt"
  4. "io"
  5. "net/http"
  6. "net/url"
  7. "time"
  8. )
  9. // 查询站点功率流信息
  10. func QuerySitePowerFlow(sn string, day time.Time) ([]byte, error) {
  11. baseURL := "https://energy.franklinwh.com/api-energy/power/getFhpPowerByDayOld"
  12. token := getLoginToken()
  13. // 构造 query 参数
  14. params := url.Values{}
  15. params.Add("gatewayId", sn)
  16. params.Add("dayTime", day.Format(time.DateOnly)) // 会自动 URL 编码
  17. // 拼接到 URL
  18. finalURL := baseURL + "?" + params.Encode()
  19. // 创建请求
  20. req, err := http.NewRequest(
  21. http.MethodGet,
  22. finalURL,
  23. nil)
  24. if err != nil {
  25. fmt.Println(err.Error())
  26. return nil, err
  27. }
  28. // 设置 Content-Type 和 Authorization
  29. req.Header.Set("Content-Type", "application/json")
  30. req.Header.Set("Logintoken", token)
  31. // fmt.Println(req.Header)
  32. // 发送请求
  33. client := &http.Client{Timeout: 5 * time.Second}
  34. resp, err := client.Do(req)
  35. if err != nil {
  36. fmt.Println(err.Error())
  37. return nil, err
  38. }
  39. defer resp.Body.Close()
  40. body, _ := io.ReadAll(resp.Body)
  41. // fmt.Printf("Status: %s\nBody: %s\n", resp.Status, body)
  42. return body, nil
  43. }