updage commit proof

validator/validator.go

@@ -49,12 +49,12 @@ func (p *ProofWorker) ProofStorage() {
 					proofByte, err := json.Marshal(proof)
 					if err != nil {
 						log.Error("Failed to marshal proof: ", err)
-						return
+						continue
 					}
 					err = db.Put(proof.TaskId, proofByte)
 					if err != nil {
 						log.Error("leveldb put proof failed: ", err)
-						return
+						continue
 					}
 					p.isCommitProof[proof.TaskId] = false
 				}
@@ -63,15 +63,16 @@ func (p *ProofWorker) ProofStorage() {
 	}(p.productProofChan)
 
 	timer := time.NewTicker(time.Minute)
-	defer timer.Stop()
 	randomMinute := getRandInt()
 	for {
 		select {
 		case <-timer.C:
 			min := time.Now().Minute()
+			if min == 0 {
+				randomMinute = getRandInt()
+			}
 			// 检查是否在指定时间范围内（40-59分钟）
 			if min >= 40 && min <= 59 && min == randomMinute {
-				randomMinute = getRandInt()
 				proofs := make([]*witnessV1.Proof, 0)
 				iter, err := db.NewIterator()
 				if err != nil {
@@ -87,7 +88,7 @@ func (p *ProofWorker) ProofStorage() {
 					err := json.Unmarshal(iter.Value(), proof)
 					if err != nil {
 						log.Error("Error parsing proof from database: ", err)
-						return
+						continue
 					}
 					if p.isCommitProof[proof.TaskId] {
 						continue
@@ -102,6 +103,7 @@ func (p *ProofWorker) ProofStorage() {
 				}
 				if len(proofs) > 0 {
 					p.consumeProofChan <- proofs
+					log.Info("---------------------------Storage proof data---------------------------")
 				}
 			}
 		}
@@ -121,10 +123,11 @@ func (p *ProofWorker) CommitWitness() {
 			pushProof, err := validatorClient.PushProof(context.Background(), proofsReq, grpc.EmptyCallOption{})
 			if err != nil {
 				log.Error("Push proof failed :", err)
-				return
+				continue
 			}
 			workload := pushProof.GetWorkload()
 			log.Info("Push proof response received : %v", workload)
+			log.Info("---------------------------Commit witness data---------------------------")
 		}
 	}
 }