fix: log id

0xcregis · Jan 22, 2024 · 5ccecbd · 5ccecbd
1 parent f2f29f6
commit 5ccecbd
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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)