fea: update caravan play

Author: Lanly109

autopcr/core/pcrclient.py

@@ -79,6 +79,19 @@ async def caravan_dish_sell(self, season_id: int, block_id: int, dish_list: List
         req.surplus_dish_list = surplus_dish_list
         return await self.request(req)
 
+    async def caravan_spots_choice(self, season_id: int, choice: int):
+        req = CaravanSpotsChoiceRequest()
+        req.season_id = season_id
+        req.choice = choice
+        return await self.request(req)
+
+    async def caravan_dice_reroll(self, season_id: int, current_count: int, roll_num: int):
+        req = CaravanDiceRerollRequest()
+        req.season_id = season_id
+        req.current_count = current_count
+        req.roll_num = roll_num
+        return await self.request(req)
+
     async def caravan_dice_roll(self, season_id: int, current_num: int, roll_num: int):
         req = CaravanDiceRollRequest()
         req.season_id = season_id
@@ -135,6 +148,18 @@ async def caravan_gacha_block_exec(self, season_id: int, block_id: int, gacha_ty
         req.current_currency_num = current_currency_num
         return await self.request(req)
 
+    async def caravan_minigame_bs_start(self, season_id: int):
+        req = CaravanMinigameCccBsStartRequest()
+        req.season_id = season_id
+        return await self.request(req)
+
+    async def caravan_minigame_bs_finish(self, season_id: int, play_id: int, items: Dict[int, int]):
+        req = CaravanMinigameCccBsFinishRequest()
+        req.season_id = season_id
+        req.play_id = play_id
+        req.object_list = [CccFinishItemCountInfo(ccc_object_id=item_id, count=count) for item_id, count in items.items()]
+        return await self.request(req)
+
     async def caravan_minigame_start(self):
         req = CaravanMinigameCccStartRequest()
         return await self.request(req)

autopcr/db/database.py

@@ -66,6 +66,14 @@ def redeem_unit(self) -> Dict[int, Dict[int, RedeemUnit]]:
                 .to_dict(lambda x: x.key, lambda x: x.to_dict(lambda x: x.slot_id, lambda x: x))
             )
 
+    @lazy_property
+    def caravan_buddy(self) -> Dict[int, CaravanBuddy]:
+        with self.dbmgr.session() as db:
+            return (
+                CaravanBuddy.query(db)
+                .to_dict(lambda x: x.buddy_id, lambda x: x)
+            )
+
     @lazy_property
     def caravan_dish(self) -> Dict[int, CaravanDish]:
         with self.dbmgr.session() as db:

autopcr/db/methods.py

@@ -112,6 +112,14 @@ def get_effect_desc(self, lasting = True) -> str:
             lasting_msg = ""
         return lasting_msg
 
+@method
+class CaravanBuddy(models.CaravanBuddy):
+    def get_effect_desc(self, lasting = True) -> str:
+        lasting_msg = f"持续{self.effect_turn}回合" if self.effect_turn > 0 else "一次性"
+        if not lasting:
+            lasting_msg = ""
+        return f"{self.description.format(self.effect_value_1, self.effect_value_2)} {lasting_msg}"
+
 @method
 class EnemyRewardDatum(models.EnemyRewardDatum):
     def get_rewards(self) -> Iterator[Reward]:

autopcr/model/handlers.py

@@ -73,6 +73,13 @@ async def update(self, mgr: datamgr, request):
             for item in self.reward_list:
                 mgr.update_inventory(item)
 
+@handles
+class CaravanMinigameCccBsFinishResponse(responses.CaravanMinigameCccBsFinishResponse):
+    async def update(self, mgr: datamgr, request):
+        if self.reward_list:
+            for item in self.reward_list:
+                mgr.update_inventory(item)
+
 @handles
 class CaravanDishUseResponse(responses.CaravanDishUseResponse):
     async def update(self, mgr: datamgr, request):
@@ -83,6 +90,20 @@ async def update(self, mgr: datamgr, request):
             for item in self.sub_reward_list:
                 mgr.update_inventory(item)
 
+@handles
+class CaravanDiceRollResponse(responses.CaravanDiceRollResponse):
+    async def update(self, mgr: datamgr, request):
+        if self.buddy_reward_list:
+            for item in self.buddy_reward_list:
+                mgr.update_inventory(item)
+
+@handles
+class CaravanProgressTurnResponse(responses.CaravanProgressTurnResponse):
+    async def update(self, mgr: datamgr, request):
+        if self.buddy_reward_list:
+            for item in self.buddy_reward_list:
+                mgr.update_inventory(item)
+
 @handles
 class CaravanGachaBlockExecResponse(responses.CaravanGachaBlockExecResponse):
     async def update(self, mgr: datamgr, request):