From 5ccecbdf1e92fe21bafa672f365b83c41c7f4d3a Mon Sep 17 00:00:00 2001
From: sunhongtao <sunhongtao@xiaohulu.com>
Date: Mon, 22 Jan 2024 10:25:47 +0800
Subject: [PATCH] fix: log id

---
 cmd/blockchain/app.go               |  2 +-
 cmd/blockchain/config_filecoin.json |  2 +-
 cmd/blockchain/config_xrp.json      |  2 +-
 collect/service/cmd/cmd.go          | 10 +++++-----
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/cmd/blockchain/app.go b/cmd/blockchain/app.go
index dc45379..a76ebb6 100644
--- a/cmd/blockchain/app.go
+++ b/cmd/blockchain/app.go
@@ -15,7 +15,7 @@ import (
 
 func main() {
 	var configPath string
-	flag.StringVar(&configPath, "blockchain", "./cmd/blockchain/config_tron.json", "The system file of config")
+	flag.StringVar(&configPath, "blockchain", "./cmd/blockchain/config_xrp.json", "The system file of config")
 	flag.Parse()
 	if len(configPath) < 1 {
 		panic("can not find config file")
diff --git a/cmd/blockchain/config_filecoin.json b/cmd/blockchain/config_filecoin.json
index a7cc820..598e8dd 100644
--- a/cmd/blockchain/config_filecoin.json
+++ b/cmd/blockchain/config_filecoin.json
@@ -9,7 +9,7 @@
   },
   "Nodes": [
     {
-      "BlockChain": 301,
+      "BlockChain": 2307,
       "NodeUrl": "https://api.node.glif.io/rpc/v0",
       "NodeToken": ""
     }
diff --git a/cmd/blockchain/config_xrp.json b/cmd/blockchain/config_xrp.json
index 363adec..804ef99 100644
--- a/cmd/blockchain/config_xrp.json
+++ b/cmd/blockchain/config_xrp.json
@@ -9,7 +9,7 @@
   },
   "Nodes": [
     {
-      "BlockChain": 310,
+      "BlockChain": 144,
       "NodeUrl": "https://xrplcluster.com",
       "NodeToken": ""
     }
diff --git a/collect/service/cmd/cmd.go b/collect/service/cmd/cmd.go
index ee01750..7e8e852 100644
--- a/collect/service/cmd/cmd.go
+++ b/collect/service/cmd/cmd.go
@@ -145,7 +145,7 @@ func (c *Cmd) ReadNodeTaskFromKafka(nodeId string, blockChain int, blockCh chan
 			continue
 		}
 		msg := <-receiver
-		log := c.log.WithFields(logrus.Fields{"model": "Dispatch", "id": time.Now().UnixMilli()})
+		log := c.log.WithFields(logrus.Fields{"model": "Dispatch", "id": time.Now().UnixNano()})
 		task := collect.NodeTask{}
 		err := json.Unmarshal(msg.Value, &task)
 		if err != nil {
@@ -226,7 +226,7 @@ func (c *Cmd) HandlerKafkaRespMessage(msList []*kafka.Message) {
 	//msList := <-kafkaRespCh
 	ids := make([]string, 0, 20)
 	log := c.log.WithFields(logrus.Fields{
-		"id":    time.Now().UnixMilli(),
+		"id":    time.Now().UnixNano(),
 		"model": "HandlerKafkaRespMessage",
 	})
 
@@ -279,7 +279,7 @@ func (c *Cmd) ExecReceiptTask(receiptChan chan *collect.NodeTask, kf chan []*kaf
 		//执行任务
 		receiptTask := <-receiptChan
 		log := c.log.WithFields(logrus.Fields{
-			"id":    time.Now().UnixMilli(),
+			"id":    time.Now().UnixNano(),
 			"model": "ExecReceiptTask",
 		})
 		//log.Printf("receiptTask=%+v", receiptTask)
@@ -389,7 +389,7 @@ func (c *Cmd) ExecTxTask(txCh chan *collect.NodeTask, kf chan []*kafka.Message)
 		//执行任务
 		txTask := <-txCh
 		log := c.log.WithFields(logrus.Fields{
-			"id":    time.Now().UnixMilli(),
+			"id":    time.Now().UnixNano(),
 			"model": "ExecTxTask",
 		})
 
@@ -576,7 +576,7 @@ func (c *Cmd) ExecBlockTask(blockCh chan *collect.NodeTask, kf chan []*kafka.Mes
 		//执行任务
 		blockTask := <-blockCh
 		log := c.log.WithFields(logrus.Fields{
-			"id":    time.Now().UnixMilli(),
+			"id":    time.Now().UnixNano(),
 			"model": "ExecBlockTask",
 		})
 		//log.Printf("taskBlock=%+v", blockTask)