replace json to json-iterator

zhangmeng

2024-01-19 01dfd9dc8de7b19f9dfa4284722e01bbd5837801

 fileAnalysis.go

@@ -2,28 +2,24 @@

import (
   "basic.com/pubsub/protomsg.git"
   "encoding/json"
   "errors"
   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))
   if netNode == nil {
      return false
   }
   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
   }
@@ -31,15 +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))
   if netNode == nil {
      return false,nil
   }
   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 {
@@ -47,6 +40,7 @@
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false, nil
   }
@@ -54,18 +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))
   if netNode == nil {
      return false,nil
   }
   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 {
@@ -73,6 +64,7 @@
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false, nil
   }
@@ -80,12 +72,9 @@
   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))
   if netNode == nil {
      return nil,errors.New("stack-service proc not found")
   }
   client := NewClient(WithNodes(netNode))

   body, err := client.DoGetRequest(url, nil, nil)
@@ -94,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)
@@ -104,41 +94,36 @@
   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))
   if netNode == nil {
      return false,nil
   }
   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))
   if netNode == nil {
      return set,errors.New("stack-service proc not found")
   }
   client := NewClient(WithNodes(netNode))

   body, err := client.DoGetRequest(url, nil, nil)
@@ -147,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)
@@ -160,20 +146,18 @@
func (api FileAnalysisApi) UpdateProgress(ids []string, progress int) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/updateProgress"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   if netNode == nil {
      return false
   }
   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
@@ -185,19 +169,17 @@
func (api FileAnalysisApi) ChangeEnable(enable bool) bool {
   url := DATA_URL_PREFIX + "/fileSetting/changeEnable"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   if netNode == nil {
      return false
   }
   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
@@ -209,20 +191,18 @@
func (api FileAnalysisApi) UpdateStatus(idArr []string, status int) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/updateStatus"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   if netNode == nil {
      return false
   }
   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
@@ -234,19 +214,17 @@
func (api FileAnalysisApi) Delete(idArr []string) bool {
   url := DATA_URL_PREFIX + "/fileAnalysis/delete"
   netNode := getNetNode(url2Topic(Topic_Stack_Service, url))
   if netNode == nil {
      return false
   }
   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
@@ -255,23 +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))
   if netNode == nil {
      return false
   }
   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
@@ -280,23 +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))
   if netNode == nil {
      return false
   }
   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
@@ -305,23 +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))
   if netNode == nil {
      return false
   }
   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
@@ -330,27 +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))
   if netNode == nil {
      return false
   }
   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
}
}