浏览代码

字段缺失修改

WH01243 2 年之前
父节点
当前提交
65df758c59
共有 1 个文件被更改,包括 4 次插入2 次删除
  1. 4 2
      jyBXSubscribe/rpc/model/push.go

+ 4 - 2
jyBXSubscribe/rpc/model/push.go

@@ -210,6 +210,7 @@ func (s *subscribePush) InfoFormat(p *PushCa, info *map[string]interface{}) *bxs
 		BidOpenTime:  common.Int64All((*info)["bidopentime"]),
 		CaFileExists: p.FileExists,
 		Source:       p.Source,
+		Site:         common.InterfaceToStr((*info)["site"]),
 	}
 }
 
@@ -683,7 +684,8 @@ func (s *subscribePush) GetJyPushs(datas []map[string]interface{}, codeMap *code
 		if len(iss) > 0 {
 			industry = iss[0]
 		}
-		//PublishTime:=common.InterfaceToStr(v["publishtime"])
+		publishTimeStr := common.InterfaceToStr(v["publishtime"])
+		publishTime, _ := time.Parse("2006-01-02 15:04:05", publishTimeStr)
 		subscribeInfo = append(subscribeInfo, &bxsubscribe.SubscribeInfo{
 			XId:          encrypt.EncodeArticleId2ByCheck(common.ObjToString(v["infoid"])),
 			Title:        common.InterfaceToStr(v["title"]),
@@ -691,7 +693,7 @@ func (s *subscribePush) GetJyPushs(datas []map[string]interface{}, codeMap *code
 			BuyerClass:   buyerClass,
 			Subtype:      subtype,
 			Industry:     industry,
-			PublishTime:  common.Int64All(v["publishtime"]),
+			PublishTime:  publishTime.Unix(),
 			CaIndex:      common.Int64All(v["id"]),
 			CaDate:       common.Int64All(v["date"]),
 			CaIsvisit:    common.Int64All(v["isvisit"]),