From 56acb65a68fbe85e3ab8fc3b66e512eb4fcd8a30 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期一, 08 四月 2024 17:54:34 +0800
Subject: [PATCH] 修复数据推送的延时问题
---
service/server.go | 17 ++++++++++++++---
1 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/service/server.go b/service/server.go
index 5f1eb69..2ad02fd 100644
--- a/service/server.go
+++ b/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
--
Gitblit v1.8.0