dbapi.git - Gitblit

New file
			@@ -0,0 +1,59 @@
			package dbapi

			import (
			"basic.com/pubsub/protomsg.git"
			"encoding/json"
			"fmt"
			)

			type SoApi struct {}

			//获取所有sdkId与soName映射信息
			func (api SoApi) FindAll() (soInfos []protomsg.SoInfo) {
			url := BASIC_URL + DATA_URL_PREFIX + "/soInfo/findAll"
			client := NewClient()

			respBody, err := client.DoGetRequest(url, nil, nil)
			if err !=nil {
			return soInfos
			}
			var res Result
			if err = json.Unmarshal(respBody, &res); err != nil {
			fmt.Println(err)
			return soInfos
			}
			bytes, _ := json.Marshal(res.Data)
			err = json.Unmarshal(bytes, &soInfos)
			return soInfos
			}

			func (api SoApi) Add(paramBody map[string]interface{}) (bool,interface{}) {
			url := BASIC_URL + DATA_URL_PREFIX + "/soInfo/addSo"
			client := NewClient()
			respBody, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
			if err != nil {
			return false,nil
			}
			var res Result
			if err = json.Unmarshal(respBody, &res); err != nil {
			fmt.Println(err)
			return false,nil
			}
			return res.Success,res.Data
			}

			func (api SoApi) Delete(taskId string) (bool,interface{}){
			url := BASIC_URL + DATA_URL_PREFIX + "/task/delete"
			client := NewClient()
			paramQuery :=make(map[string]string,0)
			paramQuery["taskId"] = taskId
			respBody, err := client.DoGetRequest(url, paramQuery, nil)
			if err != nil {
			return false,nil
			}
			var res Result
			if err = json.Unmarshal(respBody, &res); err != nil {
			return false,nil
			}
			return res.Success,res.Data
			}