fix decode CheckTransactionStateRequestHeader (#1225)

wsy6543 · web-flow · commit 83df64e17e19 · 2025-11-12T15:20:02.000+08:00
diff --git a/internal/request.go b/internal/request.go
@@ -175,10 +175,10 @@ func (request *CheckTransactionStateRequestHeader) Decode(properties map[string]
 		request.MsgId = v
 	}
 	if v, existed := properties["transactionId"]; existed {
-		request.MsgId = v
+		request.TransactionId = v
 	}
 	if v, existed := properties["offsetMsgId"]; existed {
-		request.MsgId = v
+		request.OffsetMsgId = v
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -175,10 +175,10 @@ func (request *CheckTransactionStateRequestHeader) Decode(properties map[string]`
`175`	`175`	`request.MsgId = v`
`176`	`176`	`}`
`177`	`177`	`if v, existed := properties["transactionId"]; existed {`
`178`		`- request.MsgId = v`
	`178`	`+ request.TransactionId = v`
`179`	`179`	`}`
`180`	`180`	`if v, existed := properties["offsetMsgId"]; existed {`
`181`		`- request.MsgId = v`
	`181`	`+ request.OffsetMsgId = v`
`182`	`182`	`}`
`183`	`183`	`}`
`184`	`184`