update

liuxiaobleach · liuxiaobleach · commit 07d563b7327a · 2021-09-26T22:03:58.000+08:00
diff --git a/server/dal.go b/server/dal.go
@@ -324,7 +324,7 @@ func (d *DAL) GetRecoverTimeoutPendingRefund() ([]*Transfer, error) {
 
 func (d *DAL) GetAllRefundAbleTransferIn() ([]*Transfer, error) {
 	q := fmt.Sprintf(`SELECT %s from transfer where status = $1 and timelock < $2 and transfertype = $3`, transferAllColumns)
-	rows, err := d.Query(q, cbn.TransferStatus_TRANSFER_STATUS_LOCKED, time.Now().Add(-1*refundSafeMargin), cbn.TransferType_TRANSFER_TYPE_IN)
+	rows, err := d.Query(q, cbn.TransferStatus_TRANSFER_STATUS_LOCKED, time.Now(), cbn.TransferType_TRANSFER_TYPE_IN)
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -324,7 +324,7 @@ func (d DAL) GetRecoverTimeoutPendingRefund() ([]Transfer, error) {`
`324`	`324`
`325`	`325`	`func (d DAL) GetAllRefundAbleTransferIn() ([]Transfer, error) {`
`326`	`326`	q := fmt.Sprintf(`SELECT %s from transfer where status = $1 and timelock < $2 and transfertype = $3`, transferAllColumns)
`327`		`- rows, err := d.Query(q, cbn.TransferStatus_TRANSFER_STATUS_LOCKED, time.Now().Add(-1*refundSafeMargin), cbn.TransferType_TRANSFER_TYPE_IN)`
	`327`	`+ rows, err := d.Query(q, cbn.TransferStatus_TRANSFER_STATUS_LOCKED, time.Now(), cbn.TransferType_TRANSFER_TYPE_IN)`
`328`	`328`	`if err != nil {`
`329`	`329`	`return nil, err`
`330`	`330`	`}`