proof finish time as int64

main.go

@@ -550,8 +550,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
 			// TaskProfitAccount      string
 			// TaskWorkerAccount      string
 
-			nanoseconds := int64(proof.TaskFinishTimestamp)
-			seconds := nanoseconds / 1e9
+			// nanoseconds := int64(proof.TaskFinishTimestamp)
+			// seconds := nanoseconds / 1e9
 
 			for {
 
@@ -559,7 +559,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
 					Table(proofTableName).
 					Symbol("TaskType", fmt.Sprintf("%d", proof.TaskType)).
 					StringColumn("TaskId", proof.TaskId).
-					TimestampColumn("TaskFinishTimestamp", time.Unix(seconds, nanoseconds%1e9)).
+					Int64Column("TaskFinishTimestamp", int64(proof.TaskFinishTimestamp)).
+					//TimestampColumn("TaskFinishTimestamp", time.Unix(seconds, nanoseconds%1e9)).
 					Int64Column("TaskWorkload", int64(proof.TaskWorkload)).
 					StringColumn("TaskReqHash", proof.TaskReqHash).
 					StringColumn("TaskRespHash", proof.TaskRespHash).
@@ -711,7 +712,7 @@ func main() {
 	flag.StringVar(&aigcProduceTopic, "aigcProduceTopic", "pbaigc", "produce topic, default value is: pbaigc")
 	flag.StringVar(&aigcTaskreceiptTopic, "aigcTaskreceiptTopic", "taskreceipt", "consumer topic, default value is: taskreceipt")
 
-	flag.StringVar(&aigcTaskProof, "aigcTaskProof", "taskproof", "TaskProof topic, default value is: aigcTaskProof")
+	flag.StringVar(&aigcTaskProof, "aigcTaskProof", "taskproof", "TaskProof topic, default value is: TaskProof")
 
 	flag.BoolVar(&withBillDb, "withbilldb", true, "enable with bill db, or simulate")