|
@@ -6,10 +6,9 @@ import (
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
"go.mongodb.org/mongo-driver/bson/primitive"
|
|
|
- "go.uber.org/zap"
|
|
|
"google.golang.org/grpc"
|
|
|
"gopkg.in/mgo.v2/bson"
|
|
|
- . "jy_publishing/Logger"
|
|
|
+ "jy_publishing/Logger"
|
|
|
jypb "jy_publishing/proto/common"
|
|
|
pb "jy_publishing/proto/proto"
|
|
|
"jygit.jydev.jianyu360.cn/BP/servicerd/proto"
|
|
@@ -217,6 +216,9 @@ func InfoPub(info map[string]interface{}) {
|
|
|
jyMap := make(map[string]interface{})
|
|
|
extractType := 0
|
|
|
for _, f := range InfoFields {
|
|
|
+ if f == "deliveryAddress" {
|
|
|
+ log.Println("----------deliveryAddress----------", tmp[f])
|
|
|
+ }
|
|
|
if tmp[f] == nil {
|
|
|
continue
|
|
|
}
|
|
@@ -261,7 +263,7 @@ func InfoPub(info map[string]interface{}) {
|
|
|
if s != "" {
|
|
|
atts := map[string]interface{}{}
|
|
|
if err := json.Unmarshal([]byte(s), &atts); err != nil {
|
|
|
- Logger.Error("data Unmarshal Failed:", zap.Any("error", err))
|
|
|
+ Logger.Error("data Unmarshal Failed:", Logger.Field("error", err))
|
|
|
}
|
|
|
for _, i := range atts {
|
|
|
i2 := i.(map[string]interface{})
|
|
@@ -275,7 +277,7 @@ func InfoPub(info map[string]interface{}) {
|
|
|
if s := util.ObjToString(tmp[f]); s != "" {
|
|
|
atts_txt := map[string]interface{}{}
|
|
|
if err := json.Unmarshal([]byte(s), &atts_txt); err != nil {
|
|
|
- Logger.Error("data Unmarshal Failed:", zap.Any("error", err))
|
|
|
+ Logger.Error("data Unmarshal Failed:", Logger.Field("error", err))
|
|
|
}
|
|
|
for k, v := range atts_txt {
|
|
|
atts_txt[k] = map[string]interface{}{k: v}
|