zhangzengfei
2024-03-12 ccb6685b1b28dcd7d376887504cd98b5cd410b44
service/server.go
@@ -2,11 +2,13 @@
import (
   "basic.com/pubsub/esutil.git"
   "basic.com/valib/logger.git"
   "bytes"
   "data_msg_push_server/config"
   "data_msg_push_server/model"
   "data_msg_push_server/util"
   "encoding/json"
   "errors"
   "fmt"
   "io/ioutil"
   "net/http"
@@ -107,14 +109,19 @@
         for _, picMaxUrl := range source[0]["picMaxUrl"].([]interface{}) {
            picMaxImageData, err := GetImageData("http://" + picMaxUrl.(string))
            if err != nil {
               fmt.Println("获取大图数据失败:", err)
               logger.Warn("获取大图数据失败:", err.Error())
               continue
            }
            picMaxImages = append(picMaxImages, picMaxImageData)
         }
         fmt.Println("图片数据数组大小:", len(picMaxImages))
      }
   }
   if len(picMaxImages) == 0 {
      return nil, errors.New("获取大图失败, id:" + source[0]["id"].(string))
   }
   //fmt.Println("图片数据数组大小:", len(picMaxImages))
   picSmImages := make([][]byte, 0) // 存储图片数据的数组
   if source[0]["targetInfo"].(interface{}) != nil {
@@ -126,13 +133,17 @@
         }
         picSmImageData, err := GetImageData("http://" + picSmUrl)
         if err != nil {
            fmt.Println("获取图片数据失败:", err)
            fmt.Println("获取小图数据失败:", err)
            continue
         }
         picSmImages = append(picSmImages, picSmImageData)
      }
   }
   if len(picSmImages) == 0 {
      return nil, errors.New("获取小图数据失败, id:" + source[0]["id"].(string))
   }
   // 上报机构名称
   source[0]["orgName"] = config.Options.OrgName