zhangmeng
2024-01-19 01dfd9dc8de7b19f9dfa4284722e01bbd5837801
fileAnalysis.go
@@ -2,24 +2,24 @@
import (
   "basic.com/pubsub/protomsg.git"
   json "github.com/json-iterator/go"
   jsoniter "github.com/json-iterator/go"
   "strconv"
)
type FileAnalysisApi struct{
type FileAnalysisApi struct {
}
func (api FileAnalysisApi) Save(paramBody map[string]interface{}) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/save"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false
   }
@@ -27,12 +27,12 @@
   return res.Success
}
func (api FileAnalysisApi) Show(id string) (bool,interface{}) {
func (api FileAnalysisApi) Show(id string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/fileAnalysis/show"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
      "id":id,
   paramQuery := map[string]string{
      "id": id,
   }
   body, err := client.DoGetRequest(url, paramQuery, nil)
   if err != nil {
@@ -40,6 +40,7 @@
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false, nil
   }
@@ -47,15 +48,15 @@
   return res.Success, res.Data
}
func (api FileAnalysisApi) FindAllFile(fileName string,fType int, page int, size int) (bool,interface{}){
func (api FileAnalysisApi) FindAllFile(fileName string, fType int, page int, size int) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/fileAnalysis/findAllFile"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramQuery := map[string]string {
   paramQuery := map[string]string{
      "fileName": fileName,
      "type": strconv.Itoa(fType),
      "page": strconv.Itoa(page),
      "size": strconv.Itoa(size),
      "type":     strconv.Itoa(fType),
      "page":     strconv.Itoa(page),
      "size":     strconv.Itoa(size),
   }
   body, err := client.DoGetRequest(url, paramQuery, nil)
   if err != nil {
@@ -63,6 +64,7 @@
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false, nil
   }
@@ -70,7 +72,7 @@
   return res.Success, res.Data
}
func (api FileAnalysisApi) GetAnalysisFiles() (files []protomsg.FileAnalysis,err error){
func (api FileAnalysisApi) GetAnalysisFiles() (files []protomsg.FileAnalysis, err error) {
   url := DATA_URL_PREFIX + "/fileAnalysis/getAnalysisFiles"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
@@ -81,8 +83,9 @@
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return files,err
      return files, err
   }
   bytes, _ := json.Marshal(res.Data)
@@ -91,33 +94,34 @@
   return files, err
}
func (api FileAnalysisApi) FindByStackId(stackId string, typ int,name string, page int, size int) (bool,interface{}) {
func (api FileAnalysisApi) FindByStackId(stackId string, typ int, name string, page int, size int) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/fileAnalysis/findByStackId"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]string {
   paramBody := map[string]string{
      "stackId": stackId,
      "type": strconv.Itoa(typ),
      "name": name,
      "page": strconv.Itoa(page),
      "size": strconv.Itoa(size),
      "type":    strconv.Itoa(typ),
      "name":    name,
      "page":    strconv.Itoa(page),
      "size":    strconv.Itoa(size),
   }
   body, err := client.DoGetRequest(url, paramBody, nil)
   if err != nil {
      logPrint("err:",err)
      return false,nil
      logPrint("err:", err)
      return false, nil
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint("unmarshal res err:",err)
      return false,nil
      logPrint("unmarshal res err:", err)
      return false, nil
   }
   return res.Success,res.Data
   return res.Success, res.Data
}
func (api FileAnalysisApi) GetFileAnalysisSet() (set protomsg.FileAnalysisSetting,err error) {
func (api FileAnalysisApi) GetFileAnalysisSet() (set protomsg.FileAnalysisSetting, err error) {
   url := DATA_URL_PREFIX + "/fileSetting/show"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
@@ -128,8 +132,9 @@
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return set,err
      return set, err
   }
   bytes, _ := json.Marshal(res.Data)
@@ -142,16 +147,17 @@
   url := DATA_URL_PREFIX + "/fileAnalysis/updateProgress"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "ids":ids,
   paramBody := map[string]interface{}{
      "ids":      ids,
      "progress": progress,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -164,15 +170,16 @@
   url := DATA_URL_PREFIX + "/fileSetting/changeEnable"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "enable":enable,
   paramBody := map[string]interface{}{
      "enable": enable,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -185,16 +192,17 @@
   url := DATA_URL_PREFIX + "/fileAnalysis/updateStatus"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "ids":idArr,
   paramBody := map[string]interface{}{
      "ids":    idArr,
      "status": status,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -207,15 +215,16 @@
   url := DATA_URL_PREFIX + "/fileAnalysis/delete"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "ids":idArr,
   paramBody := map[string]interface{}{
      "ids": idArr,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -224,20 +233,21 @@
   return res.Success
}
func (api FileAnalysisApi) SortFile(id string,direct int) bool {
func (api FileAnalysisApi) SortFile(id string, direct int) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/sortFile"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "id": id,
   paramBody := map[string]interface{}{
      "id":     id,
      "direct": direct,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -246,20 +256,21 @@
   return res.Success
}
func (api FileAnalysisApi) Rename(id string,name string) bool {
func (api FileAnalysisApi) Rename(id string, name string) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/rename"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "id": id,
   paramBody := map[string]interface{}{
      "id":   id,
      "name": name,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -268,20 +279,21 @@
   return res.Success
}
func (api FileAnalysisApi) Move(id string,stackId string) bool {
func (api FileAnalysisApi) Move(id string, stackId string) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/move"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "id": id,
   paramBody := map[string]interface{}{
      "id":      id,
      "stackId": stackId,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_FORM, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_FORM, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
@@ -290,24 +302,25 @@
   return res.Success
}
func (api FileAnalysisApi) Copy(id string,stackIds []string) bool {
func (api FileAnalysisApi) Copy(id string, stackIds []string) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/copy"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
      "id": id,
   paramBody := map[string]interface{}{
      "id":       id,
      "stackIds": stackIds,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody,nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false
   }
   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      logPrint(err)
      return false
   }
   return res.Success
}
}