保存服务返回值保存

src/spider/msgservice.go

@@ -8,6 +8,7 @@ import (
 	"math/rand"
 	mu "mfw/util"
 	qu "qfw/util"
+	"strings"
 
 	util "spiderutil"
 	"time"
@@ -259,9 +260,11 @@ func SaveObj(event int, checkAtrr string, data map[string]interface{}, saveredis
 		Msclient.WriteObj("", "", mu.SERVICE_SPIDER_ECPS, mu.SENDTO_TYPE_ALL_RECIVER, data)
 	default:
 		flag := true
+		idAndColl := ""
 		for i := 1; i < 6; i++ {
 			bs, err := Msclient.Call("", mu.UUID(8), event, mu.SENDTO_TYPE_ALL_RECIVER, tmp, 30)
-			if string(bs) != "" && err == nil {
+			idAndColl = string(bs)
+			if idAndColl != "" && err == nil {
 				flag = false
 				break
 			}
@@ -279,6 +282,10 @@ func SaveObj(event int, checkAtrr string, data map[string]interface{}, saveredis
 			hashHref := HexText(href)
 			isExists := util.RedisClusterExists(hashHref)
 			data["redisexists"] = isExists
+			if arr := strings.Split(idAndColl, "+"); len(arr) == 2 { //保存服务未成功推送的信息（异常、重复等）,返回值不是id
+				data["biddingid"] = arr[0]
+				data["biddingcoll"] = arr[1]
+			}
 			MgoS.Save("data_bak", data)
 			if !isExists {
 				util.RedisClusterSet(hashHref, "", -1)