| | |
| | | func (api FileStackApi) Save(paramBody map[string]interface{}) bool { |
| | | url := DATA_URL_PREFIX + "/fileStack/save" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil) |
| | | if err != nil { |
| | |
| | | func (api FileStackApi) Show(id string) (b bool,sck protomsg.FileStack) { |
| | | url := DATA_URL_PREFIX + "/fileStack/show" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false,sck |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramQuery := map[string]string { |
| | | "id": id, |
| | |
| | | func (api FileStackApi) FindAllByPage(name string,fType int, page int, size int) (bool,interface{}){ |
| | | url := DATA_URL_PREFIX + "/fileStack/findAllByPage" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramQuery := map[string]string { |
| | | "name": name, |
| | |
| | | func (api FileStackApi) FindAllDoingStacks() (flag bool,stacks []protomsg.FileStack){ |
| | | url := DATA_URL_PREFIX + "/fileStack/findAllDoingStacks" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | |
| | | body, err := client.DoGetRequest(url, nil, nil) |
| | |
| | | return false, nil |
| | | } |
| | | |
| | | if !res.Success { |
| | | logPrint("FindAllDoingStacks ret false,res:", res) |
| | | return false,nil |
| | | } |
| | | b, err := json.Marshal(res.Data) |
| | | if err !=nil { |
| | | logPrint("unmarshal FileStackApi FindAll.result err") |
| | |
| | | func (api FileStackApi) ChangeEnable(id string,enable bool) bool { |
| | | url := DATA_URL_PREFIX + "/fileStack/changeEnable" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody := map[string]interface{} { |
| | | "id": id, |
| | |
| | | func (api FileStackApi) Delete(id string) bool { |
| | | url := DATA_URL_PREFIX + "/fileStack/delete" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody := map[string]interface{} { |
| | | "id": id, |
| | |
| | | func (api FileStackApi) UpdateStatus(idArr []string, status int) bool { |
| | | url := DATA_URL_PREFIX + "/fileStack/updateStatus" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody := map[string]interface{} { |
| | | "ids":idArr, |
| | |
| | | func (api FileStackApi) UpdateChannelCount(count int) bool { |
| | | url := DATA_URL_PREFIX + "/fileSetting/updateChannelCount" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | paramBody := map[string]interface{} { |
| | | "channelCount":count, |
| | |
| | | func (api FileStackApi) FindAll() (flag bool,stacks []protomsg.FileStack) { |
| | | url := DATA_URL_PREFIX + "/fileStack/findAll" |
| | | netNode := getNetNode(url2Topic(Topic_Stack_Service, url)) |
| | | if netNode == nil { |
| | | return false,nil |
| | | } |
| | | client := NewClient(WithNodes(netNode)) |
| | | |
| | | body, err := client.DoGetRequest(url, nil, nil) |