put.go 856 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. package clt_client
  2. import (
  3. "bytes"
  4. "errors"
  5. "io"
  6. "lc/common/mqtt"
  7. "net/http"
  8. )
  9. // SwitchProgram 切换节目
  10. func (c cltClient) SwitchProgram(m mqtt.Message, baseurl string) {
  11. var p ProgramInfo
  12. m.PayloadJSON(&p)
  13. url := baseurl + "vsns/sources/lan/vsns/" + p.Name + ".vsn/activated"
  14. request, err := http.NewRequest("PUT", url, nil)
  15. if err != nil {
  16. return
  17. }
  18. request.Header.Set("Accept", "application/json")
  19. _, err = c.HttpClient.Do(request)
  20. if err != nil {
  21. return
  22. }
  23. }
  24. // brightness
  25. func (c cltClient) CommonPut(payload []byte, url string) error {
  26. var r io.Reader
  27. if payload == nil {
  28. return errors.New("func CommonPut error PUT操作消息体不能为空!")
  29. } else {
  30. r = bytes.NewReader(payload)
  31. }
  32. req, _ := http.NewRequest("PUT", url, r)
  33. req.Header.Add("Content-Type", "application/json")
  34. c.HttpClient.Do(req)
  35. return nil
  36. }