| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 |
- package clt_client
- import (
- "bytes"
- "errors"
- "github.com/sirupsen/logrus"
- "io"
- "io/ioutil"
- "lc/common/mqtt"
- "net/http"
- )
- // SwitchProgram 切换节目
- func (c cltclient) SwitchProgram(m mqtt.Message, baseurl string) {
- var p Programm
- m.PayloadJSON(&p)
- url := baseurl + "vsns/sources/lan/vsns/" + p.Name + ".vsn/activated"
- request, err := http.NewRequest("PUT", url, nil)
- if err != nil {
- logrus.Errorf("Newrequest出错:%v", err)
- return
- }
- request.Header.Set("Accept", "application/json")
- resp, err := c.HttpClient.Do(request)
- if err != nil {
- logrus.Errorf("http错误%v", err)
- return
- }
- defer resp.Body.Close()
- ioutil.ReadAll(resp.Body)
- }
- // brightness
- func (c cltclient) CommonPut(payload []byte, url string) error {
- var r io.Reader
- if payload == nil {
- return errors.New("func CommonPut error PUT操作消息体不能为空!")
- } else {
- r = bytes.NewReader(payload)
- }
- req, err := http.NewRequest("PUT", url, r)
- req.Header.Add("Content-Type", "application/json")
- resp, err := c.HttpClient.Do(req)
- if err != nil {
- return err
- }
- defer resp.Body.Close()
- ioutil.ReadAll(resp.Body)
- return nil
- }
|