Fixed Connectivity and Consensus

packages/daemons/candidate_node_votings.go

@@ -27,6 +27,7 @@ type VotingTotal struct {
 	Data          map[string]VotingRes `json:"data"`
 	AgreeQuantity int64                `json:"agreeQuantity"`
 	LocalAddress  string               `json:"localAddress"`
+	St            int64                `json:"st"`
 }
 
 func ToUpdateMachineStatus(currentTcpAddress, tcpAddress string, ch chan map[string]VotingRes, logger *log.Entry) error {
@@ -78,6 +79,7 @@ func CandidateNodeVoting(ctx context.Context, d *daemon) error {
 		candidateNodes sqldb.CandidateNodes
 		err            error
 		agreeQuantity  int64
+		st             int64
 	)
 	defer func() {
 		d.sleepTime = time.Minute
@@ -144,13 +146,14 @@ func CandidateNodeVoting(ctx context.Context, d *daemon) error {
 		}
 	}
 	close(ch)
+	st = time.Now().UnixMilli()
 	if len(nodeConnMap) > 0 {
 		var wg sync.WaitGroup
 		for _, node := range candidateNodes {
 			wg.Add(1)
 			go func(tcpAddress string) {
 				defer wg.Done()
-				votingTotal := VotingTotal{Data: nodeConnMap, AgreeQuantity: agreeQuantity, LocalAddress: currentTcpAddress}
+				votingTotal := VotingTotal{Data: nodeConnMap, AgreeQuantity: agreeQuantity, LocalAddress: currentTcpAddress, St: st}
 				err = ToBroadcastNodeConnInfo(votingTotal, tcpAddress, d.logger)
 				if err != nil {
 					d.logger.WithFields(log.Fields{"type": consts.NetworkError, "error": err, "tcpAddress": tcpAddress}).Error("broadcast node conn info error")

packages/network/tcpserver/candidate_node_voting.go

@@ -43,6 +43,7 @@ type VotingTotal struct {
 	Data          map[string]VotingRes `json:"data"`
 	AgreeQuantity int64                `json:"agreeQuantity"`
 	LocalAddress  string               `json:"localAddress"`
+	St            int64                `json:"st"`
 }
 
 func SyncMatchineStateRes(request *network.BroadcastNodeConnInfoRequest) (*network.BroadcastNodeConnInfoResponse, error) {
@@ -58,6 +59,7 @@ func SyncMatchineStateRes(request *network.BroadcastNodeConnInfoRequest) (*netwo
 		candidateNode := &sqldb.CandidateNode{
 			TcpAddress:     votingTotal.LocalAddress,
 			ReplyCount:     votingTotal.AgreeQuantity,
+			DateReply:      votingTotal.St,
 			CandidateNodes: request.Data,
 		}
 		err = candidateNode.UpdateCandidateNodeInfo()

packages/storage/sqldb/candidate_node.go

@@ -1,8 +1,6 @@
 package sqldb
 
 import (
-	"time"
-
 	"github.com/IBAX-io/go-ibax/packages/consts"
 	"github.com/shopspring/decimal"
 )
@@ -61,7 +59,7 @@ func (c *CandidateNode) UpdateCandidateNodeInfo() error {
 	if err != nil {
 		return err
 	}
-	err = GetDB(nil).Model(&c).Where("tcp_address = ? and deleted = ? and earnest_total >= ?", c.TcpAddress, 0, pledgeAmount).Updates(CandidateNode{ReplyCount: c.ReplyCount, DateReply: time.Now().UnixMilli(), CandidateNodes: c.CandidateNodes}).Error
+	err = GetDB(nil).Model(&c).Where("tcp_address = ? and deleted = ? and earnest_total >= ?", c.TcpAddress, 0, pledgeAmount).Updates(CandidateNode{ReplyCount: c.ReplyCount, DateReply: c.DateReply, CandidateNodes: c.CandidateNodes}).Error
 	if err != nil {
 		return err
 	}