添加设备所属机构的配置字段上报

zhangzengfei

2024-02-23 b4f52495ea8c990bba30efcb3f36a6167cc85bab

 service/server.go

@@ -13,7 +13,7 @@
)

func ConnectControl() bool {
   url := config.ServUrls.ServerUrl
   url := config.Options.ServerUrl
   resp, err := http.Get(url)
   if err != nil {
      fmt.Println("连接失败", err)
@@ -26,7 +26,7 @@
}

func GetTotal() (total int, err error) {
   url := "http://" + config.ServUrls.EsUrl + "/ai_ocean/_search"
   url := "http://" + config.Options.EsUrl + "/ai_ocean/_search"
   queryDSL := `{
    "size": "1",
    "query": {
@@ -63,9 +63,9 @@
}

func GetData() (interface{}, error) {
   //fmt.Println(config.ServUrls.EsUrl)
   //fmt.Println(config.ServUrls.ServerUrl)
   url := "http://" + config.ServUrls.EsUrl + "/ai_ocean/_search"
   //fmt.Println(config.Options.EsUrl)
   //fmt.Println(config.Options.ServerUrl)
   url := "http://" + config.Options.EsUrl + "/ai_ocean/_search"
   queryDSL := `{
    "size": "1",
    "query": {
@@ -132,6 +132,10 @@
         picSmImages = append(picSmImages, picSmImageData)
      }
   }

   // 上报机构名称
   source[0]["orgName"] = config.Options.OrgName

   model.PushDataInfo.SourceData = source[0]
   model.PushDataInfo.PicMaxImages = picMaxImages
   model.PushDataInfo.PicSmImages = picSmImages
@@ -172,7 +176,7 @@
}

func DeleteData(id string) bool {
   url := "http://" + config.ServUrls.EsUrl + "/ai_ocean/_delete_by_query?refresh=true"
   url := "http://" + config.Options.EsUrl + "/ai_ocean/_delete_by_query?refresh=true"
   deleteDSL := `{
               "query":{
                  "bool":{
@@ -199,7 +203,7 @@
}

func MarkData(id string) bool {
   url := "http://" + config.ServUrls.EsUrl + "/ai_ocean/_update_by_query?refresh=true"
   url := "http://" + config.Options.EsUrl + "/ai_ocean/_update_by_query?refresh=true"
   markDSL := `{
    "script": {
        "source": "ctx._source.isDelete=true"