实现虎牙查询兑换记录

core/huya/activity_structs.py

@@ -120,6 +120,124 @@ class GetActPrizeListReq(TafStruct):
         self.sid = ins.read_int32(1, default=self.sid)
 
 
+class GetUserPrizeRecordsReq(TafStruct):
+    """webActUI.getUserPrizeRecords 请求。"""
+
+    def __init__(self):
+        self.userId = ActivityUserId()
+        self.sid: int = 0
+
+    def write_to(self, os: TafOutputStream):
+        os.write_struct(0, self.userId)
+        os.write_int32(1, self.sid)
+
+    def read_from(self, ins: TafInputStream):
+        self.userId = ins.read_struct(0, ActivityUserId) or self.userId
+        self.sid = ins.read_int32(1, default=self.sid)
+
+
+class UserPrizeRecordItem(TafStruct):
+    """用户兑换记录项，字段来自 getUserPrizeRecords 实测响应。"""
+
+    def __init__(self):
+        self.recordId: int = 0
+        self.prizeName: str = ""
+        self.score: int = 0
+        self.exchangeTime: int = 0
+        self.prizeStatus: int = 0
+        self.prizeType: int = 0
+        self.orderId: str = ""
+        self.icon: str = ""
+        self.prizeId: int = 0
+        self.prizeItemId: int = 0
+        self.ext: dict = {}
+        self.exchangeDate: int = 0
+
+    @staticmethod
+    def _status_label(status: int) -> str:
+        if status == 0:
+            return "未发放"
+        if status == 1:
+            return "已发放"
+        return f"状态{status}"
+
+    def read_from(self, ins: TafInputStream):
+        self.recordId = ins.read_int64(0, default=self.recordId)
+        self.prizeName = ins.read_string(1, default=self.prizeName)
+        self.score = ins.read_int64(2, default=self.score)
+        self.exchangeTime = ins.read_int64(3, default=self.exchangeTime)
+        self.prizeStatus = ins.read_int32(4, default=self.prizeStatus)
+        self.prizeType = ins.read_int32(10, default=self.prizeType)
+        self.orderId = ins.read_string(12, default=self.orderId)
+        self.icon = ins.read_string(14, default=self.icon)
+        self.prizeId = ins.read_int64(16, default=self.prizeId)
+        self.prizeItemId = ins.read_int64(19, default=self.prizeItemId)
+        self.ext = ins.read_map(20)
+        self.exchangeDate = ins.read_int64(21, default=self.exchangeDate)
+        while True:
+            pos = ins.buf.tell()
+            tag, dtype = ins.read_head()
+            if dtype == TafType.STRUCT_END:
+                ins.buf.seek(pos)
+                return
+            ins.skip_field(dtype)
+
+    def write_to(self, os: TafOutputStream):
+        pass
+
+    @staticmethod
+    def read_list_item(ins: TafInputStream, _tag: int):
+        item = UserPrizeRecordItem()
+        item.read_from(ins)
+        _end_tag, dtype = ins.read_head()
+        if dtype != TafType.STRUCT_END:
+            raise ValueError(f"期望兑换记录 STRUCT_END，实际 0x{dtype:02x}")
+        return item
+
+    def to_dict(self) -> dict:
+        return {
+            "record_id": self.recordId,
+            "prize_name": self.prizeName,
+            "score": self.score,
+            "exchange_time": self.exchangeTime,
+            "exchange_date": self.exchangeDate,
+            "prize_status": self.prizeStatus,
+            "status_label": self._status_label(self.prizeStatus),
+            "order_id": self.orderId,
+            "icon": self.icon,
+            "prize_id": self.prizeId,
+            "prize_type": self.prizeType,
+            "prize_item_id": self.prizeItemId,
+            "ext": dict(self.ext),
+        }
+
+
+class GetUserPrizeRecordsResp(TafStruct):
+    """webActUI.getUserPrizeRecords 响应。"""
+
+    def __init__(self):
+        self.status: int = 0
+        self.msg: str = ""
+        self.records: list[UserPrizeRecordItem] = []
+
+    def read_from(self, ins: TafInputStream):
+        self.status = ins.read_int32(0, default=self.status)
+        self.msg = ins.read_string(1, default=self.msg)
+        self.records = ins.read_list(2, item_reader=UserPrizeRecordItem.read_list_item)
+
+    def write_to(self, os: TafOutputStream):
+        pass
+
+    def to_dict(self) -> dict:
+        records = [item.to_dict() for item in self.records]
+        return {
+            "status": self.status,
+            "msg": self.msg,
+            "record_count": len(records),
+            "records": records,
+        }
+
+
 class GetActTaskDetailReq(TafStruct):
     """webActUI.getActTaskDetail 请求。"""
 

core/huya/http_client.py

@@ -286,6 +286,22 @@ class HuyaHttpClient:
             timeout=timeout,
         )
 
+    def get_user_prize_records(self, uid: int, cookie: str, sid: int, timeout: float = 15.0):
+        """查询用户兑换记录。"""
+        from .activity_structs import GetUserPrizeRecordsReq, GetUserPrizeRecordsResp
+        req = GetUserPrizeRecordsReq()
+        req.userId = self._build_activity_user(uid, cookie)
+        req.sid = sid
+        return self.call_rpc(
+            "webActUI",
+            "getUserPrizeRecords",
+            req,
+            GetUserPrizeRecordsResp,
+            uid=uid,
+            cookie=cookie,
+            timeout=timeout,
+        )
+
     def get_act_task_detail(self, uid: int, cookie: str, act_id: int, timeout: float = 15.0):
         """查询活动任务详情，用于发现充值商品 SPU。"""
         from .activity_structs import GetActTaskDetailReq, GetActTaskDetailResp