refactor(game): 将 ApiCFBalanceTransferResponseDTO 中的 bankID可以避免在处理大额交易时可能出现的溢出问题

- 在查询平台列表时添加了停用状态过滤条件- 仅缓存未停用的平台信息，提高数据准确性

ff-base/src/main/java/com/ff/base/constant/CacheConstants.java

@@ -137,8 +137,14 @@ public class CacheConstants {
     public static final String SV388_TIME_FROM= "sv388:time:from";
 
     public static final String SV388_GAMES = "sv388_games:";
-
-
+    /**
+     * pp游戏
+     */
+    public static final String PP_GAMES= "pp_games:";
+    /**
+     * pp时间点
+     */
+    public static final String PP_TIME_POINT =  "pp:time:point:";
 }
 
 

ff-base/src/main/java/com/ff/base/enums/GamePlatforms.java

@@ -19,6 +19,7 @@ public enum GamePlatforms {
     PGT("PGT", "PGT"),
     FBSports("FBSports", "FB体育"),
     SV388("SV388", "SV388真人"),
+    PP("PP", "PP"),
     DBSports("DBSports", "DB体育");
 
     private final String code;

ff-base/src/main/java/com/ff/base/enums/PPGameType.java

@@ -0,0 +1,64 @@
+package com.ff.base.enums;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.Optional;
+import java.util.stream.Stream;
+
+
+/**
+ * xkgame类型
+ *
+ * @author shi
+ * @date 2024/11/13
+ */
+@Getter
+@AllArgsConstructor
+public enum PPGameType {
+
+    ELECTRONIC("vs", 1,"电子"),
+//    CARD_GAME("rl",2, "轮盘"),
+//    VIDEO("vp",6, "视频扑克"),
+//    SCRATCH_CARD("sc",7, "刮刮乐"),
+//    BLACK_JACK("bj",2, "21点"),
+//    CLASSIC_SLOTS("cs",1, "电子"),
+//    BACCARAT_NEW("bn",2, "百家乐新"),
+//    BACCARAT("bc",2, "百家乐"),
+//    LIVE_GAMES("lg",6, "现场游戏"),
+    ;
+
+    private final String code;
+    private final Integer systemCode;
+    private final String info;
+
+
+    /**
+     * 按代码查找系统
+     *
+     * @param code 代码
+     * @return {@link String }
+     */
+    public static Integer findSystemByCode(String code) {
+        Optional<Integer> system = Stream.of(PPGameType.values())
+                .filter(gameType -> gameType.getCode().equals(code))
+                .map(PPGameType::getSystemCode)
+                .findFirst();
+        return system.orElse(null);
+    }
+
+    /**
+     * 按代码查找信息
+     *
+     * @param code 代码
+     * @return {@link String }
+     */
+    public static String findInfoByCode(String code) {
+        Optional<String> system = Stream.of(PPGameType.values())
+                .filter(gameType -> gameType.getCode().equals(code))
+                .map(PPGameType::getInfo)
+                .findFirst();
+        return system.orElse(null);
+    }
+}

ff-base/src/main/java/com/ff/base/utils/DateUtils.java

@@ -975,4 +975,23 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils {
         }
 
     }
+
+    /**
+     * 将自定义格式的时间字符串转换为毫秒级时间戳(UTC)
+     *
+     * @param dateStr 时间字符串
+     * @param pattern 时间格式模式(如"yyyy-MM-dd HH:mm:ss")
+     * @return 毫秒级时间戳
+     * @throws ParseException 如果解析失败
+     */
+    public static long toTimestamp(String dateStr, String pattern) {
+        try {
+            SimpleDateFormat sdf = new SimpleDateFormat(pattern);
+            sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
+            return sdf.parse(dateStr).getTime();
+        } catch (Exception e) {
+            return 0;
+        }
+
+    }
 }

ff-game/src/main/java/com/ff/api/controller/ApiGameController.java

@@ -159,6 +159,8 @@ public class ApiGameController extends BaseController {
         ApiException.notNull(targetLang, ErrorCode.LANG_NOT_EXIST.getCode());
 
 
+        ApiException.isTrue(game.getStopStatus(), ErrorCode.GAME_NOT_EXIST.getCode());
+
         Member member = memberService.selectMemberByAccount(loginRequest.getAccount(), loginRequest.getCurrencyCode(), platform.getPlatformCode());
         ApiException.notNull(member, ErrorCode.ACCOUNT_NOT_EXIST.getCode());
 

ff-game/src/main/java/com/ff/game/api/fc/dto/ApiCFBalanceTransferResponseDTO.java

@@ -25,7 +25,7 @@ public class ApiCFBalanceTransferResponseDTO {
      * 银行ID
      */
     @JsonProperty("BankID")
-    private int bankID;
+    private Long bankID;
 
     /**
      * 交易ID

ff-game/src/main/java/com/ff/game/api/fc/dto/ApiCFBalanceTransferStatusResponseDTO.java

@@ -25,7 +25,7 @@ public class ApiCFBalanceTransferStatusResponseDTO {
      * 银行 ID
      */
     @JsonProperty("bankID")
-    private int bankId;
+    private Long bankId;
 
     /**
      * 交易 ID

ff-game/src/main/java/com/ff/game/api/pgx/client/PGXClient.java

@@ -56,7 +56,7 @@ public interface PGXClient {
      * @param parameters 范围
      * @return {@link PGXGameLoginResponse }
      */
-    @Post("/launchGames.aspx?${parameters}")
+    @Get("/launchGames.aspx?${parameters}")
     PGXGameLoginResponse loginWithoutRedirect(@Var("parameters") String parameters);
 
     /**

ff-game/src/main/java/com/ff/game/api/pp/address/MyPPAddressSource.java

@@ -0,0 +1,35 @@
+package com.ff.game.api.pp.address;
+
+import com.dtflys.forest.callback.AddressSource;
+import com.dtflys.forest.http.ForestAddress;
+import com.dtflys.forest.http.ForestRequest;
+import com.ff.base.enums.GamePlatforms;
+import com.ff.game.domain.Platform;
+import com.ff.game.service.IPlatformService;
+import com.sun.media.jfxmediaimpl.platform.PlatformManager;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+
+/**
+ * 我jili address来源
+ *
+ * @author shi
+ * @date 2025/02/10
+ */
+@Component
+public class MyPPAddressSource implements AddressSource {
+    @Resource
+    private IPlatformService platformService;
+
+
+    @Override
+    public ForestAddress getAddress(ForestRequest request) {
+        Platform platform = platformService.get(GamePlatforms.PP.getCode());
+        String apiBaseUrl = platform.getUrlInfo().getUrl();
+        String host = platform.getUrlInfo().getHost();
+        String https = platform.getUrlInfo().getHttps();
+        return new ForestAddress(https, apiBaseUrl, Integer.parseInt(host), "/IntegrationService/v3");
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/client/PPClient.java

@@ -0,0 +1,121 @@
+package com.ff.game.api.pp.client;
+
+import com.dtflys.forest.annotation.*;
+import com.ff.game.api.pp.address.MyPPAddressSource;
+import com.ff.game.api.pp.dto.*;
+import com.ff.game.api.pp.forest.MySuccessCondition;
+
+import java.util.Map;
+
+/**
+ * pp 请求
+ *
+ * @author shi
+ * @date 2025/02/10
+ */
+@Address(source = MyPPAddressSource.class)
+public interface PPClient {
+    /**
+     * 创建成员
+     *
+     * @param params 参数
+     * @return {@link PPUserAccountResponse }
+     */
+    @Post( url ="/http/CasinoGameAPI/player/account/create/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    PPUserAccountResponse createMember(@Body Map<String, Object> params);
+
+
+    /**
+     * 获取会员信息
+     *
+     * @param params 参数
+     * @return {@link PPPlayerAccountResponse }
+     */
+    @Post( url ="/http/CasinoGameAPI/balance/current/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    PPPlayerAccountResponse getMemberInfo(@Body Map<String, Object> params);
+
+
+
+    /**
+     * 无重定向登录
+     *
+     * @param params 参数
+     * @return {@link PPGameLaunchResponse }
+     */
+    @Post(url ="/http/CasinoGameAPI/game/start/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    PPGameLaunchResponse loginWithoutRedirect(@Body Map<String, Object> params);
+
+    /**
+     * 获取游戏列表
+     *
+     * @param params 参数
+     * @return {@link PPGameResponseDTO }
+     */
+    @Post( url ="/http/CasinoGameAPI/getCasinoGames/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+
+    PPGameResponseDTO getGameList(@Body  Map<String, Object> params);
+
+    /**
+     * 按代理id进行交换转账
+     *
+     * @param params 参数
+     * @return {@link PPTransactionResponse }
+     */
+    @Post(url = "/http/CasinoGameAPI/balance/transfer/",
+            headers = {
+            "Content-type: application/x-www-form-urlencoded"
+    })
+    @Success(condition = MySuccessCondition.class)
+    PPTransactionResponse exchangeTransfer(@Body Map<String, Object> params);
+
+    /**
+     * 汇兑转移状态
+     *
+     * @param params     参数
+     * @return {@link PPTransactionStatusResponse }
+     */
+    @Post(url = "/http/CasinoGameAPI/balance/transfer/status/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    PPTransactionStatusResponse exchangeTransferStatus( @Body Map<String, Object> params);
+
+    /**
+     * 按时间获取投注记录
+     *
+     * @param params 参数
+     * @return {@link String }
+     */
+    @Get(url ="/DataFeeds/gamerounds/finished/?{params}")
+    String getBetRecordByTime(@Var("params") String params);
+
+
+    /**
+     * 踢出队员
+     *
+     * @param params 参数
+     * @return {@link PPResponse }
+     */
+    @Post(url = "/http/CasinoGameAPI/game/session/terminate/",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    PPResponse kickMember(@Body Map<String, Object> params);
+
+
+
+
+
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGBetRecordResponseDTO.java

@@ -0,0 +1,129 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * dgbet记录响应数据
+ *
+ * @author shi
+ * @date 2025/03/27
+ */
+@Data
+public class DGBetRecordResponseDTO {
+
+    /** 错误码 (参考文档定义) */
+    @JsonProperty("codeId")
+    private Integer codeId;
+
+    /** 错误信息 */
+    @JsonProperty("msg")
+    private String msg;
+
+    /** 注单报告 */
+    @JsonProperty("list")
+    private List<ReportDTO> list;
+
+    /**
+     * 注单报告类
+     */
+    @Data
+    public static class ReportDTO {
+
+        /** 注单ID（唯一） */
+        @JsonProperty("id")
+        private Long id;
+
+        /** 游戏桌号（红包小费记录没有） */
+        @JsonProperty("tableId")
+        private Integer tableId;
+
+        /** 游戏靴号（红包小费记录没有） */
+        @JsonProperty("shoeId")
+        private Long shoeId;
+
+        /** 当靴局号（红包小费记录没有） */
+        @JsonProperty("playId")
+        private Long playId;
+
+        /** 游戏厅号（1:旗舰厅；2:亚洲厅；3，4:现场厅；5:性感厅；8,9:区块链厅） */
+        @JsonProperty("lobbyId")
+        private Integer lobbyId;
+
+        /** 注单类型（1:注单，2:红包小费） */
+        @JsonProperty("gameType")
+        private Integer gameType;
+
+        /** 游戏类型（百家乐，龙虎等） */
+        @JsonProperty("gameId")
+        private Integer gameId;
+
+        /** 下注时间 */
+        @JsonProperty("betTime")
+        private Date betTime;
+
+        /** 结算时间 */
+        @JsonProperty("calTime")
+        private Date calTime;
+
+        /** 派彩金额（含本金） */
+        @JsonProperty("winOrLoss")
+        private BigDecimal winOrLoss;
+
+        /** 下注前余额（仅作参考） */
+        @JsonProperty("balanceBefore")
+        private BigDecimal balanceBefore;
+
+        /** 下注金额（下注扣款金额） */
+        @JsonProperty("betPoints")
+        private BigDecimal betPoints;
+
+        /** 洗码金额（用于计算佣金） */
+        @JsonProperty("availableBet")
+        private BigDecimal availableBet;
+
+        /** 会员账号 */
+        @JsonProperty("userName")
+        private String userName;
+
+        /** 游戏结果 */
+        @JsonProperty("result")
+        private String result;
+
+        /** 注单详情 */
+        @JsonProperty("betDetail")
+        private String betDetail;
+
+        /** 客户端IP */
+        @JsonProperty("ip")
+        private String ip;
+
+        /** 游戏唯一局号 */
+        @JsonProperty("ext")
+        private String ext;
+
+        /** 结算状态（0:未结算，1:已结算，2:已撤销，3:冻结） */
+        @JsonProperty("isRevocation")
+        private Integer isRevocation;
+
+        /** 更改单时对应的注单记录 */
+        @JsonProperty("parentBetId")
+        private Long parentBetId;
+
+        /** 币种ID（请参考对应关系说明） */
+        @JsonProperty("currencyId")
+        private Integer currencyId;
+
+        /** 客户端平台ID（1: PC 2: 安卓 3: 苹果 5: H5） */
+        @JsonProperty("deviceType")
+        private Integer deviceType;
+
+        /** 钱包扣款记录（转账模式API没有） */
+        @JsonProperty("transfers")
+        private String transfers;
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGLoginWithoutRedirectResponse.java

@@ -0,0 +1,74 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 响应结果类
+ */
+@Data
+public class DGLoginWithoutRedirectResponse {
+
+    /**
+     * 响应的代码ID
+     */
+    @JsonProperty("codeId")
+    private int codeId;
+
+    /**
+     * 响应的消息
+     */
+    @JsonProperty("msg")
+    private String msg;
+
+    /**
+     * 响应的 token
+     */
+    @JsonProperty("token")
+    private String token;
+
+    /**
+     * 响应的域名信息
+     */
+    @JsonProperty("domains")
+    private String domains;
+
+    /**
+     * 列表数据
+     */
+    @JsonProperty("list")
+    private List<String> list;
+
+    /**
+     * 限制组
+     */
+    @JsonProperty("limitGroup")
+    private String limitGroup;
+
+    /**
+     * 限制区间
+     */
+    @JsonProperty("limits")
+    private List<Limit> limits;
+
+    /**
+     * 限制区间内部类
+     */
+    @Data
+    public static class Limit {
+
+        /**
+         * 最小值
+         */
+        @JsonProperty("min")
+        private int min;
+
+        /**
+         * 最大值
+         */
+        @JsonProperty("max")
+        private int max;
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGResponse.java

@@ -0,0 +1,26 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 响应类，用于返回基本的状态信息。
+ *
+ * @author shi
+ * @date 2025/03/26
+ */
+@Data
+public class DGResponse {
+
+    /**
+     * 响应的代码ID。
+     */
+    @JsonProperty("codeId")
+    private int codeId;
+
+    /**
+     * 响应的消息。
+     */
+    @JsonProperty("msg")
+    private String msg;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGTransactionResponseDTO.java

@@ -0,0 +1,45 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 交易信息返回实体
+ *
+ * @author shi
+ * @date 2025/03/27
+ */
+@Data
+public class DGTransactionResponseDTO {
+
+
+    /** 响应代码 */
+    @JsonProperty("codeId")
+    private Integer codeId;
+
+    /** 响应消息 */
+    @JsonProperty("msg")
+    private String msg;
+
+    /** 用户名 */
+    @JsonProperty("username")
+    private String username;
+
+    /** 交易金额 */
+    @JsonProperty("amount")
+    private BigDecimal amount;
+
+    /** 账户余额 */
+    @JsonProperty("balance")
+    private BigDecimal balance;
+
+    /** 交易流水号 */
+    @JsonProperty("serial")
+    private String serial;
+
+    /** 交易时间 */
+    @JsonProperty("time")
+    private String time;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserAccountResponse.java

@@ -0,0 +1,40 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 用户账户信息响应类
+ *
+ * @author shi
+ * @date 2025/03/26
+ */
+@Data
+public class DGUserAccountResponse {
+
+    /**
+     * 响应的代码ID。
+     */
+    @JsonProperty("codeId")
+    private int codeId;
+
+    /**
+     * 响应的消息。
+     */
+    @JsonProperty("msg")
+    private String msg;
+
+    /**
+     * 用户名。
+     */
+    @JsonProperty("username")
+    private String username;
+
+    /**
+     * 用户余额。
+     */
+    @JsonProperty("balance")
+    private BigDecimal balance;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserListResponseDTO.java

@@ -0,0 +1,70 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 用户列表响应类
+ *
+ * @author shi
+ * @date 2025/03/27
+ */
+@Data
+public class DGUserListResponseDTO {
+
+    /**
+     * 响应的代码ID。
+     */
+    @JsonProperty("codeId")
+    private int codeId;
+
+    /**
+     * 响应的消息。
+     */
+    @JsonProperty("msg")
+    private String msg;
+    /** 用户列表 */
+    @JsonProperty("list")
+    private List<UserDTO> list;
+
+    /**
+     * 用户信息类
+     */
+    @Data
+    public static class UserDTO {
+
+        /** 用户名 */
+        @JsonProperty("username")
+        private String username;
+
+        /** 昵称 */
+        @JsonProperty("nickname")
+        private String nickname;
+
+        /** 币种名称 */
+        @JsonProperty("currencyName")
+        private String currencyName;
+
+        /** 用户IP */
+        @JsonProperty("ip")
+        private String ip;
+
+        /** 用户设备 */
+        @JsonProperty("device")
+        private String device;
+
+        /** 登录时间 */
+        @JsonProperty("login")
+        private String login;
+
+        /** 会员ID */
+        @JsonProperty("memberId")
+        private Long memberId;
+
+        /** 用户余额 */
+        @JsonProperty("balance")
+        private Double balance;
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameLaunchResponse.java

@@ -0,0 +1,35 @@
+package com.ff.game.api.pp.dto;
+
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * ppgame发布响应
+ *
+ * @author shi
+ * @date 2025/04/14
+ */
+@Data
+public class PPGameLaunchResponse {
+    /**
+     * 响应状态码
+     * 示例: "0" 表示成功
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述
+     * 示例: "OK" 表示成功
+     */
+    @JsonProperty("description")
+    private String description;
+
+    /**
+     * 游戏启动URL
+     * 包含token、游戏符号、技术平台、语言、货币等参数
+     */
+    @JsonProperty("gameURL")
+    private String gameUrl;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameResponseDTO.java

@@ -0,0 +1,111 @@
+package com.ff.game.api.pp.dto;
+
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 响应类 - 游戏信息列表
+ *
+ * @author shi
+ * @date 2025/03/27
+ */
+@Data
+public class PPGameResponseDTO {
+
+    /** 错误码 (参考文档定义) */
+    @JsonProperty("error")
+    private String error;
+
+    /** 错误信息 */
+    @JsonProperty("description")
+    private String description;
+
+    /** 游戏信息列表 */
+    @JsonProperty("gameList")
+    private List<CasinoGame> gameList;
+
+    /**
+     * 游戏信息类
+     */
+    @Data
+    public static class CasinoGame {
+
+        /** 游戏唯一标识符 */
+        @JsonProperty("gameID")
+        private String gameID;
+
+        /** 游戏名称 */
+        @JsonProperty("gameName")
+        private String gameName;
+
+        /** 游戏类型标识符 */
+        @JsonProperty("gameTypeID")
+        private String gameTypeID;
+
+        /** 游戏类型描述 */
+        @JsonProperty("typeDescription")
+        private String typeDescription;
+
+        /** 游戏技术描述 */
+        @JsonProperty("technology")
+        private String technology;
+
+        /** 游戏支持的平台 */
+        @JsonProperty("platform")
+        private String platform;
+
+        /** 是否提供演示游戏 */
+        @JsonProperty("demoGameAvailable")
+        private boolean demoGameAvailable;
+
+        /** 游戏宽高比 */
+        @JsonProperty("aspectRatio")
+        private String aspectRatio;
+
+        /** 游戏技术标识符 */
+        @JsonProperty("technologyID")
+        private String technologyID;
+
+        /** 数值型游戏 ID */
+        @JsonProperty("gameIdNumeric")
+        private Long gameIdNumeric;
+
+        /** 是否提供免费回合奖励 */
+        @JsonProperty("frbAvailable")
+        private boolean frbAvailable;
+
+        /** 是否提供可变免费回合奖励 */
+        @JsonProperty("variableFrbAvailable")
+        private boolean variableFrbAvailable;
+
+        /** 游戏的投注线数 */
+        @JsonProperty("lines")
+        private Integer lines;
+
+        /** 游戏支持的功能列表 */
+        @JsonProperty("features")
+        private List<String> features;
+
+        /** 游戏数据类型 */
+        @JsonProperty("dataType")
+        private String dataType;
+
+        /** 支持的司法管辖区列表 */
+        @JsonProperty("jurisdictions")
+        private List<String> jurisdictions;
+
+
+        /**
+         * 系统游戏id
+         */
+        private String systemGameId;
+
+        /**
+         * 系统游戏类型
+         */
+        private Integer systemPlatformType;
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameRoundRecord.java

@@ -0,0 +1,279 @@
+package com.ff.game.api.pp.dto;
+
+
+import com.ff.base.utils.DateUtils;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * ppgame回合记录
+ *
+ * @author shi
+ * @date 2025/04/15
+ */
+@Data
+public class PPGameRoundRecord   {
+    private static final DateTimeFormatter DATE_FORMATTER =
+            DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
+
+    /**
+     * 时间戳（Unix毫秒时间戳）
+     * <p>记录生成时的系统时间戳，格式为 timepoint=1618298161139</p>
+     */
+    private Long timepoint;
+
+    /**
+     * 玩家在Pragmatic Play系统中的唯一ID
+     *
+     * @example 531288
+     */
+    private String playerID;
+
+    /**
+     * 娱乐场运营商系统中的玩家ID
+     *
+     * @example 889325
+     */
+    private String extPlayerID;
+
+    /**
+     * 游戏唯一标识符
+     *
+     * @example "vs20magicpot"
+     */
+    private String gameID;
+
+    /**
+     * 当前游戏会话ID
+     * <p>每个游戏回合的唯一编号</p>
+     *
+     * @example 50994065
+     */
+    private String playSessionID;
+
+    /**
+     * 父游戏会话ID
+     * <p>对于免费游戏，此值为触发免费游戏的母游戏ID</p>
+     *
+     * @example 50994064
+     */
+    private String parentSessionID;
+
+    /**
+     * 游戏回合开始时间
+     * <p>格式：yyyy-MM-dd HH:mm:ss</p>
+     *
+     * @example "2021-04-13 07:06:18"
+     */
+    private Long startDate;
+
+    /**
+     * 游戏回合结束时间
+     * <p>未完成时为null，格式：yyyy-MM-dd HH:mm:ss</p>
+     *
+     * @example "2021-04-13 07:06:18"
+     */
+    private Long endDate;
+
+    /**
+     * 游戏状态
+     * <p>可能值：
+     * <ul>
+     *   <li>C - 已完成</li>
+     *   <li>F - 取消/最终确定</li>
+     * </ul>
+     * </p>
+     *
+     * @example "C"
+     */
+    private String status;
+
+    /**
+     * 游戏类型
+     * <p>可能值：
+     * <ul>
+     *   <li>F - 免费旋转</li>
+     * </ul>
+     * </p>
+     *
+     * @example "F"
+     */
+    private String type;
+
+    /**
+     * 投注金额（固定2位小数）
+     *
+     * @example 0.00
+     */
+    private BigDecimal bet;
+
+    /**
+     * 赢取金额（固定2位小数）
+     *
+     * @example 0.00
+     */
+    private BigDecimal win;
+
+    /**
+     * 货币代码（ISO 3字母）
+     *
+     * @example "EUR"
+     */
+    private String currency;
+
+    /**
+     * 累积奖金金额（固定2位小数）
+     *
+     * @example 0.00
+     */
+    private BigDecimal jackpot;
+
+    /**
+     * 免费回合奖励ID
+     * <p>当值为"null"字符串时表示无奖励</p>
+     *
+     * @example "null"
+     */
+    private String bonusCode;
+
+    /**
+     * 奖金投注金额（固定2位小数）
+     *
+     * @example 0.00
+     */
+    private BigDecimal bonusBet;
+
+    /**
+     * 奖金赢取金额（固定2位小数）
+     *
+     * @example 0.00
+     */
+    private BigDecimal bonusWin;
+
+    public static List<PPGameRoundRecord> parse(String data) {
+        List<PPGameRoundRecord> transactions = new ArrayList<>();
+
+        // 按行分割数据
+        String[] lines = data.split("\n");
+
+        if (lines.length < 3) {
+            return new ArrayList<>();
+        }
+
+
+        // 解析列名（第二行）
+        String[] headers = lines[1].trim().split(",");
+
+        for (int j = 2; j < lines.length; j++) {
+            // 解析数据行（第三行开始）
+            String[] values = lines[j].trim().split(",");
+
+            // 确保列数和值数匹配
+            if (headers.length != values.length) {
+                continue;
+            }
+
+            // 创建交易记录对象
+            PPGameRoundRecord transaction = new PPGameRoundRecord();
+
+            // 根据列名设置对应的值
+            for (int i = 0; i < headers.length; i++) {
+                String header = headers[i].trim();
+                String value = values[i].trim();
+
+                switch (header) {
+                    case "playerID":
+                        transaction.setPlayerID(value);
+                        break;
+                    case "extPlayerID":
+                        transaction.setExtPlayerID(value);
+                        break;
+                    case "gameID":
+                        transaction.setGameID(value);
+                        break;
+                    case "playSessionID":
+                        transaction.setPlaySessionID(value);
+                        break;
+                    case "parentSessionID":
+                        transaction.setParentSessionID(value);
+                        break;
+                    case "startDate":
+                        transaction.setStartDate(DateUtils.toTimestamp(value, DateUtils.YYYY_MM_DD_HH_MM_SS));
+                        break;
+                    case "endDate":
+                        transaction.setEndDate(DateUtils.toTimestamp(value, DateUtils.YYYY_MM_DD_HH_MM_SS));
+                        break;
+                    case "status":
+                        transaction.setStatus(value);
+                        break;
+                    case "type":
+                        transaction.setType(value);
+                        break;
+                    case "bet":
+                        transaction.setBet(new BigDecimal(value));
+                        break;
+                    case "win":
+                        transaction.setWin(new BigDecimal(value));
+                        break;
+                    case "currency":
+                        transaction.setCurrency(value);
+                        break;
+                    case "jackpot":
+                        transaction.setJackpot(new BigDecimal(value));
+                        break;
+                    case "bonusCode":
+                        transaction.setBonusCode("null".equals(value) ? null : value);
+                        break;
+                    case "bonusBet":
+                        transaction.setBonusBet(new BigDecimal(value));
+                        break;
+                    case "bonusWin":
+                        transaction.setBonusWin(new BigDecimal(value));
+                        break;
+
+                }
+            }
+
+            transactions.add(transaction);
+        }
+
+        return transactions;
+    }
+
+
+    /**
+     * 解析长
+     *
+     * @param s s
+     * @return {@link Long }
+     */// 辅助解析方法
+    private static Long parseLong(String s) {
+        return s.isEmpty() ? null : Long.parseLong(s);
+    }
+
+    /**
+     * 解析双精度
+     *
+     * @param s s
+     * @return {@link BigDecimal }
+     */
+    private static BigDecimal parseDouble(String s) {
+        return s.isEmpty() ? null : new BigDecimal(s);
+    }
+
+    /**
+     * 解析日期时间
+     *
+     * @param s s
+     * @return {@link LocalDateTime }
+     */
+    private static Date parseDateTime(String s) {
+        return s.isEmpty() ? null : DateUtils.parseDate(s);
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPPlayerAccountResponse.java

@@ -0,0 +1,35 @@
+package com.ff.game.api.pp.dto;
+
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 玩家账户信息响应实体
+ */
+@Data
+public class PPPlayerAccountResponse {
+
+    /**
+     * 响应状态码 (必需)
+     * 示例: "0" 表示成功
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述 (必需)
+     * 示例: "OK" 表示成功
+     */
+    @JsonProperty("description")
+    private String description;
+
+    /**
+     * 玩家余额 (必需)
+     * 示例: 999.99
+     */
+    @JsonProperty("balance")
+    private BigDecimal balance;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPResponse.java

@@ -0,0 +1,30 @@
+package com.ff.game.api.pp.dto;
+
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * ppgame发布响应
+ *
+ * @author shi
+ * @date 2025/04/14
+ */
+@Data
+public class PPResponse {
+    /**
+     * 响应状态码
+     * 示例: "0" 表示成功
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述
+     * 示例: "OK" 表示成功
+     */
+    @JsonProperty("description")
+    private String description;
+
+
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPTransactionResponse.java

@@ -0,0 +1,43 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 回复
+ *
+ * @author shi
+ * @date 2025/04/14
+ */
+@Data
+public class PPTransactionResponse {
+    /**
+     * 响应状态码 (必需)
+     * 示例: "0" 表示成功
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述 (必需)
+     * 示例: "OK" 表示成功
+     */
+    @JsonProperty("description")
+    private String description;
+
+    /**
+     * 交易ID (必需)
+     * 示例: 1908759
+     */
+    @JsonProperty("transactionId")
+    private String transactionId;
+
+    /**
+     * 账户余额 (必需)
+     * 示例: 999.99
+     */
+    @JsonProperty("balance")
+    private BigDecimal balance;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPTransactionStatusResponse.java

@@ -0,0 +1,90 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * 替换
+ *
+ * @author shi
+ * @date 2025/04/14
+ */
+@Data
+public class PPTransactionStatusResponse {
+    /**
+     * 响应状态码
+     * <p>
+     * 遵循系统定义的错误码规范：
+     * <ul>
+     *   <li>"0" - 表示成功</li>
+     *   <li>其他值 - 表示具体错误类型</li>
+     * </ul>
+     * </p>
+     *
+     * @apiNote 必填字段
+     * @example "0"
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述
+     * <p>人类可读的状态说明信息</p>
+     *
+     * @apiNote 必填字段
+     * @example "OK"
+     */
+    @JsonProperty("description")
+    private String description;
+
+    /**
+     * 交易唯一标识符
+     * <p>系统生成的交易流水号，用于后续查询和跟踪</p>
+     *
+     * @apiNote 必填字段
+     * @example 1908759
+     */
+    @JsonProperty("transactionId")
+    private Long transactionId;
+
+    /**
+     * 交易状态
+     * <p>
+     * 可能的值包括：
+     * <ul>
+     *   <li>"Success" - 交易成功</li>
+     *   <li>"Pending" - 处理中</li>
+     *   <li>"Failed" - 交易失败</li>
+     * </ul>
+     * </p>
+     *
+     * @apiNote 必填字段
+     * @example "Success"
+     */
+    @JsonProperty("status")
+    private String status;
+
+    /**
+     * 交易金额
+     * <p>
+     * 字符串格式的金额数值，保留两位小数。
+     * </p>
+     *
+     * @apiNote 必填字段
+     * @example "999.99"
+     */
+    @JsonProperty("amount")
+    private BigDecimal amount;
+
+    /**
+     * 账户余额
+     * <p>交易完成后的实时余额，使用BigDecimal保证精度</p>
+     *
+     * @apiNote 可选字段（某些查询接口可能返回null）
+     * @example 999.99
+     */
+    @JsonProperty("balance")
+    private BigDecimal balance;
+}

ff-game/src/main/java/com/ff/game/api/pp/dto/PPUserAccountResponse.java

@@ -0,0 +1,33 @@
+package com.ff.game.api.pp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+/**
+ * 娱乐场运营商系统用户账户响应实体
+ * 严格保密 - 仅用于预期目的和接收者！
+ */
+@Data
+public class PPUserAccountResponse {
+
+    /**
+     * 响应状态码 (必需)
+     * 示例: "0" 表示成功
+     */
+    @JsonProperty("error")
+    private String error;
+
+    /**
+     * 响应状态描述 (必需)
+     * 示例: "OK" 表示成功
+     */
+    @JsonProperty("description")
+    private String description;
+
+    /**
+     * 玩家唯一标识符 (必需)
+     * 示例: 6749178
+     */
+    @JsonProperty("playerId")
+    private Long playerId;
+}

ff-game/src/main/java/com/ff/game/api/pp/forest/MySuccessCondition.java

@@ -0,0 +1,31 @@
+package com.ff.game.api.pp.forest;
+
+
+import com.dtflys.forest.callback.SuccessWhen;
+import com.dtflys.forest.http.ForestRequest;
+import com.dtflys.forest.http.ForestResponse;
+
+/**
+ * 我kmsuccess状态
+ *
+ * @author shi
+ * @date 2025/04/02
+ */
+public class MySuccessCondition implements SuccessWhen {
+
+    /**
+     * 请求成功条件
+     * @param req Forest请求对象
+     * @param res Forest响应对象
+     * @return 是否成功，true: 请求成功，false: 请求失败
+     */
+    @Override
+    public boolean successWhen(ForestRequest req, ForestResponse res) {
+        // req 为Forest请求对象，即 ForestRequest 类实例
+        // res 为Forest响应对象，即 ForestResponse 类实例
+        // 返回值为 ture 则表示请求成功，false 表示请求失败
+        return res.noException();
+        // 当然在这里也可以写其它条件，比如 通过 res.getResult() 或 res.getContent() 获取业务数据
+        // 再根据业务数据判断是否成功
+    }
+}

ff-game/src/main/java/com/ff/game/api/pp/impl/GamesPPServiceImpl.java

@@ -0,0 +1,645 @@
+package com.ff.game.api.pp.impl;
+
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.NumberUtil;
+import com.ff.base.constant.CacheConstants;
+import com.ff.base.constant.Constants;
+import com.ff.base.core.redis.RedisCache;
+import com.ff.base.enums.*;
+import com.ff.base.exception.base.ApiException;
+import com.ff.base.exception.base.BaseException;
+import com.ff.base.utils.DateUtils;
+import com.ff.base.utils.JsonUtil;
+import com.ff.base.utils.StringUtils;
+import com.ff.base.utils.sign.Md5Utils;
+import com.ff.game.api.IGamesService;
+import com.ff.game.api.pp.client.PPClient;
+import com.ff.game.api.pp.dto.*;
+import com.ff.game.api.request.*;
+import com.ff.game.domain.*;
+import com.ff.game.service.IGameBettingDetailsService;
+import com.ff.game.service.IGameExchangeMoneyService;
+import com.ff.game.service.IGameFreeRecordService;
+import com.ff.game.service.IGameService;
+import com.ff.member.domain.Member;
+import com.ff.member.service.IMemberService;
+import com.ff.utils.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.ObjectUtils;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+
+/**
+ * DG 游戏 impl
+ *
+ * @author shi
+ * @date 2024/11/12
+ */
+@Service("PPService")
+@Slf4j
+public class GamesPPServiceImpl implements IGamesService {
+
+
+    @Resource
+    private RedisCache gRedisCache;
+
+    @Resource
+    private IGameService gameService;
+
+    @Resource
+    private IMemberService memberService;
+
+    @Resource
+    private IGameFreeRecordService gameFreeRecordService;
+
+    @Resource
+    private PPClient ppClient;
+
+    @Resource
+    private IGameBettingDetailsService gameBettingDetailsService;
+
+
+    @Resource
+    private IGameExchangeMoneyService gameExchangeMoneyService;
+
+
+
+    /**
+     * 获得就是成功
+     *
+     * @param errorCode 错误代码
+     * @return {@link Boolean }
+     */
+    private Boolean getIsSuccess(String errorCode) {
+        ApiException.isTrue(!"7".equals(errorCode), ErrorCode.INSUFFICIENT_PLAYER_BALANCE.getCode());
+        return "0".equals(errorCode);
+    }
+
+
+    /**
+     * 获取密钥
+     *
+     * @param gamesBaseRequestDTO 游戏请求dto
+     * @return {@link String }
+     */
+    private String getKey(GamesBaseRequestDTO gamesBaseRequestDTO) {
+        //取出对应的key跟密钥跟请求参数
+        String agentKey = gamesBaseRequestDTO.getAgentKey();
+
+        return Md5Utils.md5New(gamesBaseRequestDTO.getQuery() + agentKey);
+    }
+
+    /**
+     * 转换为ingress
+     *
+     * @param terminalTypes 终端类型
+     * @return {@link Integer }
+     */
+    public Integer convertToIngress(String terminalTypes) {
+        if (terminalTypes == null || terminalTypes.isEmpty()) {
+            return null;
+        }
+
+        boolean hasMobile = terminalTypes.contains("MOBILE");
+        boolean hasWeb = terminalTypes.contains("WEB");
+
+        if (hasMobile && hasWeb) {
+            return IngressType.PC_AND_MOBILE_WEB.getValue();
+        } else if (hasMobile) {
+            return IngressType.MOBILE_WEB.getValue();
+        } else if (hasWeb) {
+            return IngressType.PC_WEB.getValue();
+        } else {
+            return null;
+        }
+    }
+
+
+    /**
+     * 创建成员
+     *
+     * @param createMemberRequestDTO 创建成员请求dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean createMember(CreateMemberRequestDTO createMemberRequestDTO) {
+        log.info("GamesPPServiceImpl [createMember] 请求参数 {}", createMemberRequestDTO);
+        Map<String, Object> params = new TreeMap<>();
+        params.put("externalPlayerId", createMemberRequestDTO.getAccount());
+        params.put("secureLogin", createMemberRequestDTO.getAgentId());
+        params.put("currency", createMemberRequestDTO.getCurrency());
+        String query = JsonUtil.mapToQueryString(params);
+        createMemberRequestDTO.setQuery(query);
+        String key = this.getKey(createMemberRequestDTO);
+        params.put("hash", key);
+        PPUserAccountResponse member = ppClient.createMember(params);
+        if (this.getIsSuccess(member.getError())) {
+            return Boolean.TRUE;
+        }
+        //判断是否获取成功
+        return Boolean.FALSE;
+    }
+
+
+    /**
+     * 获取会员信息
+     *
+     * @param memberInfoRequestDTO 会员信息请求dto
+     * @return {@link MemberInfoResponseDTO }
+     */
+    @Override
+    public MemberInfoResponseDTO getMemberInfo(MemberInfoRequestDTO memberInfoRequestDTO) {
+        log.info("GamesPPServiceImpl [loginWithoutRedirect] 请求参数 {}", memberInfoRequestDTO);
+        Map<String, Object> params = new TreeMap<>();
+        params.put("secureLogin", memberInfoRequestDTO.getAgentId());
+        params.put("externalPlayerId", memberInfoRequestDTO.getAccounts());
+        String query = JsonUtil.mapToQueryString(params);
+        memberInfoRequestDTO.setQuery(query);
+        String key = this.getKey(memberInfoRequestDTO);
+        params.put("hash", key);
+        PPPlayerAccountResponse memberInfo = ppClient.getMemberInfo(params);
+        if (this.getIsSuccess(memberInfo.getError())) {
+            return MemberInfoResponseDTO.builder().account(memberInfoRequestDTO.getAccounts())
+                    .balance(memberInfo.getBalance())
+                    .status(GameMemberStatus.UNKNOWN.getCode()).build();
+        }
+        throw new ApiException(ErrorCode.ACCOUNT_NOT_EXIST.getCode());
+    }
+
+
+    /**
+     * 无重定向登录
+     *
+     * @param gamesLogin 游戏登录
+     * @return {@link String }
+     */
+    @Override
+    public String loginWithoutRedirect(GamesLogin gamesLogin) {
+        log.info("GamesPPServiceImpl [loginWithoutRedirect] 请求参数 {}", gamesLogin);
+
+        Map<String, Object> params = new TreeMap<>();
+        params.put("secureLogin", gamesLogin.getAgentId());
+        params.put("externalPlayerId", gamesLogin.getAccount());
+        params.put("gameId", gamesLogin.getGameId());
+        params.put("language", gamesLogin.getLang());
+        if (!StringUtils.isEmpty(gamesLogin.getPlatform())) {
+            if ("web".equalsIgnoreCase(gamesLogin.getPlatform())) {
+                params.put("platform", "WEB");
+            } else {
+                params.put("platform", "MOBILE");
+            }
+
+        }
+        params.put("lobbyURL", gamesLogin.getHomeUrl());
+        String query = JsonUtil.mapToQueryString(params);
+        gamesLogin.setQuery(query);
+        String key = this.getKey(gamesLogin);
+        params.put("hash", key);
+        PPGameLaunchResponse ppGameLaunchResponse = ppClient.loginWithoutRedirect(params);
+
+
+        if (this.getIsSuccess(ppGameLaunchResponse.getError())) {
+            return ppGameLaunchResponse.getGameUrl();
+        } else {
+            throw new ApiException(ErrorCode.ACCOUNT_NOT_EXIST.getCode());
+        }
+    }
+
+
+    /**
+     * 获取游戏列表
+     *
+     * @param gamesBaseRequestDTO 游戏请求dto
+     * @return {@link String }
+     */
+    @Transactional
+    @Override
+    public String getGameList(GamesBaseRequestDTO gamesBaseRequestDTO) {
+        List<PPGameResponseDTO.CasinoGame> gamesDatas = gRedisCache.getCacheList(CacheConstants.PP_GAMES);
+        if (!CollectionUtils.isEmpty(gamesDatas)) {
+            return CacheConstants.PP_GAMES;
+        }
+
+
+        Map<String, Object> params = new LinkedHashMap<>();
+        params.put("secureLogin", gamesBaseRequestDTO.getAgentId());
+        String query = JsonUtil.mapToQueryString(params);
+        gamesBaseRequestDTO.setQuery(query);
+        String key = this.getKey(gamesBaseRequestDTO);
+        params.put("hash", key);
+
+        PPGameResponseDTO gameList = ppClient.getGameList(params);
+        if (this.getIsSuccess(gameList.getError())) {
+            for (PPGameResponseDTO.CasinoGame apiGameInfoResponseDTO : gameList.getGameList()) {
+                Integer platformType = PPGameType.findSystemByCode(apiGameInfoResponseDTO.getGameTypeID());
+                //不支持的游戏跳过
+                if (ObjectUtils.isEmpty(platformType)) {
+                    continue;
+                }
+                Integer ingress = convertToIngress(apiGameInfoResponseDTO.getPlatform());
+                //不需要的平台
+                if (ObjectUtils.isEmpty(ingress)) {
+                    continue;
+                }
+
+                Game game = Game.builder()
+                        .platformCode(GamePlatforms.PP.getCode())
+                        .platformType(platformType)
+                        .gameCode(apiGameInfoResponseDTO.getGameID())
+                        .build();
+                List<Game> games = gameService.selectGameList(game);
+                //不存在这个游戏
+                if (CollectionUtils.isEmpty(games)) {
+                    game.setIngress(ingress);
+                    game.setGameSourceType(apiGameInfoResponseDTO.getGameTypeID());
+                    game.setFreespin(Boolean.FALSE);
+                    game.setDemoStatus(Boolean.FALSE);
+                    game.setSortNo(gameService.selectMaxSortNo(platformType, GamePlatforms.PP.getCode()) + 1);
+                    game.setGameName(apiGameInfoResponseDTO.getGameName());
+                    game.setCreateBy("system");
+                    game.setPlatformCode(GamePlatforms.PP.getCode());
+                    game.setPlatformType(platformType);
+                    game.setGameId(StringUtils.addSuffix(GamePlatforms.PP.getCode(), apiGameInfoResponseDTO.getGameID()));
+                    List<NameInfo> nameInfos = new ArrayList<>();
+                    nameInfos.add(new NameInfo(apiGameInfoResponseDTO.getGameName(), "en-US"));
+                    game.setNameInfo(nameInfos);
+                    gameService.insertGame(game);
+                } else {
+                    game = games.get(0);
+                }
+                apiGameInfoResponseDTO.setSystemGameId(game.getGameId());
+                apiGameInfoResponseDTO.setSystemPlatformType(platformType);
+
+            }
+
+            gRedisCache.deleteObject(CacheConstants.PP_GAMES);
+            gRedisCache.setCacheList(CacheConstants.PP_GAMES, gameList.getGameList());
+            gRedisCache.expire(CacheConstants.PP_GAMES, 5L, TimeUnit.HOURS);
+        } else {
+            throw new BaseException(gameList.getDescription());
+        }
+
+        return CacheConstants.PP_GAMES;
+    }
+
+    /**
+     * 获取交易id
+     *
+     * @param transactionIdRequestDTO 事务id请求dto
+     * @return {@link String }
+     */
+    @Override
+    public String getTransactionId(TransactionIdRequestDTO transactionIdRequestDTO) {
+        return GamePlatforms.PP.getCode() + IdUtil.getSnowflakeNextIdStr();
+    }
+
+    /**
+     * 按代理id进行交换转账
+     *
+     * @param exchangeTransferMoneyRequestDTO 外汇转账moeny dto
+     * @return {@link Long }
+     */
+    @Override
+    @Transactional
+    public Long exchangeTransferByAgentId(ExchangeTransferMoneyRequestDTO exchangeTransferMoneyRequestDTO) {
+        log.info("GamesKMServiceImpl [exchangeTransferByAgentId] 请求参数 {}", exchangeTransferMoneyRequestDTO);
+
+
+        GameExchangeMoney exchangeMoney = gameExchangeMoneyService.selectGameExchangeMoneyById(exchangeTransferMoneyRequestDTO.getGameExchangeId());
+
+
+        BigDecimal amount = exchangeTransferMoneyRequestDTO.getAmount();
+        if (TransferType.ALL.getCode().equals(exchangeTransferMoneyRequestDTO.getTransferType())) {
+            // 获取第三方钱包余额
+            MemberInfoRequestDTO gamesBaseRequestDTO = MemberInfoRequestDTO.builder()
+                    .accounts(exchangeTransferMoneyRequestDTO.getAccount())
+                    .agentId(exchangeTransferMoneyRequestDTO.getAgentId())
+                    .currency(exchangeTransferMoneyRequestDTO.getCurrency())
+                    .agentKey(exchangeTransferMoneyRequestDTO.getAgentKey())
+                    .build();
+
+            amount = this.getMemberInfo(gamesBaseRequestDTO).getBalance().negate();
+        }
+
+        Map<String, Object> params = new TreeMap<>();
+        params.put("secureLogin", exchangeTransferMoneyRequestDTO.getAgentId());
+        params.put("externalPlayerId", exchangeTransferMoneyRequestDTO.getAccount());
+        params.put("externalTransactionId", exchangeTransferMoneyRequestDTO.getTransactionId());
+        params.put("amount", amount);
+        String query = JsonUtil.mapToQueryString(params);
+        exchangeTransferMoneyRequestDTO.setQuery(query);
+        String key = this.getKey(exchangeTransferMoneyRequestDTO);
+        params.put("hash", key);
+
+        PPTransactionResponse transactionResponse = ppClient.exchangeTransfer(params);
+        //判断是否转移成功
+        if (this.getIsSuccess(transactionResponse.getError())) {
+            amount = amount.abs();
+            //更新数据
+            exchangeMoney.setBalance(amount);
+            exchangeMoney.setCoinBefore(NumberUtil.sub(amount, transactionResponse.getBalance()).abs());
+            exchangeMoney.setCoinAfter(transactionResponse.getBalance());
+            exchangeMoney.setCurrencyBefore(exchangeMoney.getCoinBefore());
+            exchangeMoney.setCurrencyAfter(exchangeMoney.getCoinAfter());
+            exchangeMoney.setStep(GameExchangeStep.PLATFORM_TRANSACTION.getCode());
+            exchangeMoney.setStepStatus(GameExchangeStepStatus.SUCCESS.getCode());
+            exchangeMoney.setPartyTransactionId(transactionResponse.getTransactionId());
+            gameExchangeMoneyService.updateGameExchangeMoney(exchangeMoney);
+        } else {
+
+            exchangeMoney.setStep(GameExchangeStep.PLATFORM_TRANSACTION.getCode());
+            exchangeMoney.setStepStatus(GameExchangeStepStatus.FAILURE.getCode());
+            gameExchangeMoneyService.updateGameExchangeMoney(exchangeMoney);
+            log.error("GamesPPServiceImpl [exchangeTransferByAgentId] 金额转移失败,错误代码{},错误信息{}", transactionResponse.getError(), transactionResponse.getDescription());
+            throw new ApiException(ErrorCode.BALANCE_TRANSFER_FAILED.getCode());
+        }
+
+        return exchangeMoney.getId();
+    }
+
+    /**
+     * 汇兑转移状态
+     *
+     * @param exchangeTransferMoneyRequestDTO 兑换转账请求dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public ExchangeTransferStatusResponseDTO exchangeTransferStatus(ExchangeTransferStatusRequestDTO exchangeTransferMoneyRequestDTO) {
+        log.info("GamesPPServiceImpl [exchangeTransferStatus] 请求参数 {}", exchangeTransferMoneyRequestDTO);
+        GameExchangeMoney exchangeMoney = gameExchangeMoneyService.selectGameExchangeMoneyById(exchangeTransferMoneyRequestDTO.getGameExchangeMoneyId());
+
+        Map<String, Object> params = new TreeMap<>();
+        params.put("secureLogin", exchangeTransferMoneyRequestDTO.getAgentId());
+        params.put("externalTransactionId", StringUtils.isEmpty(exchangeMoney.getPartyTransactionId()) ? "0" : exchangeMoney.getPartyTransactionId());
+        params.put("externalPlayerId", exchangeTransferMoneyRequestDTO.getOrderId());
+        String query = JsonUtil.mapToQueryString(params);
+        exchangeTransferMoneyRequestDTO.setQuery(query);
+        String key = this.getKey(exchangeTransferMoneyRequestDTO);
+        params.put("hash", key);
+
+        PPTransactionStatusResponse ppTransactionStatusResponse = ppClient.exchangeTransferStatus(params);
+        if (this.getIsSuccess(ppTransactionStatusResponse.getError())) {
+            Integer status = StatusType.IN_PROGRESS.getValue();
+            if ("Success".equals(ppTransactionStatusResponse.getStatus())) {
+                status = StatusType.SUCCESS.getValue();
+            } else {
+                status = StatusType.FAILURE.getValue();
+            }
+            return ExchangeTransferStatusResponseDTO.builder()
+                    .statusType(status)
+                    .balance(ppTransactionStatusResponse.getAmount())
+                    .coinAfter(ppTransactionStatusResponse.getBalance())
+                    .build();
+        } else {
+            log.error("GamesPPServiceImpl [exchangeTransferStatus] 金额转移确认失败,错误代码{},错误信息{}", ppTransactionStatusResponse.getError(), ppTransactionStatusResponse.getDescription());
+            return ExchangeTransferStatusResponseDTO.builder()
+                    .statusType(StatusType.FAILURE.getValue())
+                    .build();
+        }
+
+    }
+
+
+    /**
+     * 按时间获取投注记录
+     *
+     * @param betRecordByTimeDTO 按时间dto投注记录
+     * @return {@link List }<{@link GameBettingDetails }>
+     */
+    @Override
+    public Boolean getBetRecordByTime(BetRecordByTimeDTO betRecordByTimeDTO) {
+        Long timepoint = gRedisCache.getCacheObject(CacheConstants.PP_TIME_POINT);
+        if (ObjectUtils.isEmpty(timepoint)) {
+            timepoint = betRecordByTimeDTO.getStartTime();
+        }
+
+        //请求参数
+        log.info("GamesPPServiceImpl [getBetRecordByTime] 请求参数 {}", betRecordByTimeDTO);
+        Map<String, Object> params = new LinkedHashMap<>();
+        params.put("login", betRecordByTimeDTO.getAgentId());
+        params.put("password", betRecordByTimeDTO.getAgentKey());
+        params.put("timepoint", timepoint);
+        String result = ppClient.getBetRecordByTime(JsonUtil.mapToQueryString(params));
+        this.batchInsert(PPGameRoundRecord.parse(result), betRecordByTimeDTO);
+        //重新保存最新的时间
+        String[] lines = result.split("\n");
+        timepoint = Long.parseLong(lines[0].replace("timepoint=", ""));
+        gRedisCache.setCacheObject(CacheConstants.PP_TIME_POINT, timepoint);
+
+        return Boolean.TRUE;
+
+    }
+
+
+    /**
+     * 按历史时间获取投注记录
+     *
+     * @param betRecordByTimeDTO 按时间dto投注记录
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean getBetRecordByHistoryTime(BetRecordByTimeDTO betRecordByTimeDTO) {
+
+        //请求参数
+        log.info("GamesPPServiceImpl [getBetRecordByHistoryTime] 请求参数 {}", betRecordByTimeDTO);
+        long timepoint = betRecordByTimeDTO.getStartTime();
+        while (timepoint < betRecordByTimeDTO.getEndTime()) {
+            Map<String, Object> params = new LinkedHashMap<>();
+            params.put("login", betRecordByTimeDTO.getAgentId());
+            params.put("password", betRecordByTimeDTO.getAgentKey());
+            params.put("timepoint", timepoint);
+            String result = ppClient.getBetRecordByTime(JsonUtil.mapToQueryString(params));
+            this.batchInsert(PPGameRoundRecord.parse(result), betRecordByTimeDTO);
+            //重新保存最新的时间
+            String[] lines = result.split("\n");
+            timepoint = Long.parseLong(lines[0].replace("timepoint=", ""));
+        }
+
+
+        return Boolean.TRUE;
+    }
+
+    /**
+     * 赠送免费局数
+     *
+     * @param createFreeSpinRequest 创建自由旋转请求
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean createFreeSpin(CreateFreeSpinRequestDTO createFreeSpinRequest) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+    /**
+     * 获取游戏详细信息
+     *
+     * @param getGameDetailRequestDTO 获取游戏详细信息请求dto
+     * @return {@link GetGameDetailResponseDTO }
+     */
+    @Override
+    public GetGameDetailResponseDTO getGameDetail(GetGameDetailRequestDTO getGameDetailRequestDTO) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+    /**
+     * 强制会员从游戏注销
+     *
+     * @param kickMemberRequestDTO 踢会员请求dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean kickMember(KickMemberRequestDTO kickMemberRequestDTO) {
+        log.info("GamesPPServiceImpl [kickMember] 请求参数 {}", kickMemberRequestDTO);
+        Map<String, Object> params = new TreeMap<>();
+        params.put("secureLogin", kickMemberRequestDTO.getAgentId());
+        params.put("externalPlayerId", kickMemberRequestDTO.getAccount());
+        String query = JsonUtil.mapToQueryString(params);
+        kickMemberRequestDTO.setQuery(query);
+        String key = this.getKey(kickMemberRequestDTO);
+        params.put("hash", key);
+        PPResponse kickMember = ppClient.kickMember(params);
+        if (this.getIsSuccess(kickMember.getError())) {
+            return Boolean.TRUE;
+        } else {
+            throw new ApiException(ErrorCode.KICK_OUT_AILED.getCode());
+        }
+    }
+
+    /**
+     * 踢成员全部
+     *
+     * @param kickMemberAllDTO 踢成员全部dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean kickMemberAll(KickMemberAllDTO kickMemberAllDTO) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+    /**
+     * 免费游戏玩家使用的纪录
+     *
+     * @param getFreeSpinDashflowRequestDTO 获取自由旋转dashflow请求dto
+     * @return {@link List }<{@link GameFreeRecord }>
+     */
+    @Override
+    public List<GameFreeRecord> getFreeSpinDashflow(GetFreeSpinDashflowRequestDTO getFreeSpinDashflowRequestDTO) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+    /**
+     * 取消赠送免费局数
+     *
+     * @param cancelFreeSpinRequestDTO 取消免费旋转请求
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean cancelFreeSpin(CancelFreeSpinRequestDTO cancelFreeSpinRequestDTO) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+    @Override
+    public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
+        throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
+    }
+
+
+    /**
+     * 批量插入
+     */
+    private synchronized void batchInsert(List<PPGameRoundRecord> report, GamesBaseRequestDTO gamesBaseRequestDTO) {
+        List<GameBettingDetails> gameBettingDetails = new ArrayList<>();
+        List<String> wagersIds = new ArrayList<>();
+        //数据转化
+        for (PPGameRoundRecord bean : report) {
+            GameBettingDetails bettingDetails = this.dataBuild(GamesDataBuildDTO.builder().platform(gamesBaseRequestDTO.getVendor()).data(bean).build());
+            if (!ObjectUtils.isEmpty(bettingDetails)) {
+                bettingDetails.setId(IdUtil.getSnowflakeNextId());
+                gameBettingDetails.add(bettingDetails);
+            }
+            wagersIds.add(String.valueOf(bean.getPlaySessionID()));
+        }
+        if (!CollectionUtils.isEmpty(gameBettingDetails)) {
+            //查询重复数据id
+            List<String> removeWagersIds = gameBettingDetailsService.selectGameBettingDetailsByWagersId(wagersIds, GamePlatforms.PP.getCode());
+            //用steam流清除list中与wagersIds集合相同的数据
+            gameBettingDetails = gameBettingDetails.stream()
+                    .filter(detail -> !removeWagersIds.contains(detail.getWagersId()))
+                    .collect(Collectors.toList());
+            if (!CollectionUtils.isEmpty(gameBettingDetails)) {
+                gameBettingDetailsService.batchInsert(gameBettingDetails);
+            }
+        }
+
+    }
+
+    /**
+     * 数据构建
+     *
+     * @param gamesDataBuildDTO 数据
+     * @return {@link GameBettingDetails }
+     */
+    @Override
+    public GameBettingDetails dataBuild(GamesDataBuildDTO gamesDataBuildDTO) {
+        //转化类
+        PPGameRoundRecord resultBean = (PPGameRoundRecord) gamesDataBuildDTO.getData();
+
+
+        Member member = memberService.selectMemberByGameAccount(resultBean.getExtPlayerID());
+        if (ObjectUtils.isEmpty(member)) {
+            return null;
+        }
+        List<PPGameResponseDTO.CasinoGame> gamesDatas = gRedisCache.getCacheList(CacheConstants.PP_GAMES);
+        Map<String, PPGameResponseDTO.CasinoGame> dataDTOMap = gamesDatas.stream().collect(Collectors.toMap(
+                PPGameResponseDTO.CasinoGame::getGameID,
+                e -> e,
+                (existing, replacement) -> existing
+        ));
+        PPGameResponseDTO.CasinoGame casinoGame = dataDTOMap.get(resultBean.getGameID());
+
+        BigDecimal payoffAmount = NumberUtil.sub(resultBean.getWin(), resultBean.getBet());
+        Integer gameStatus = GameStatus.FLAT.getCode();
+        if (payoffAmount.compareTo(BigDecimal.ZERO) > 0) {
+            gameStatus = GameStatus.WIN.getCode();
+        } else if (payoffAmount.compareTo(BigDecimal.ZERO) < 0) {
+            gameStatus = GameStatus.FAIL.getCode();
+        }
+
+
+        //数据构造
+        GameBettingDetails gameBettingDetails = GameBettingDetails.builder()
+                .tenantKey(member.getTenantKey())
+                //保存我们的币种id
+                .currencyCode(gamesDataBuildDTO.getPlatform().getOurCurrency(resultBean.getCurrency()))
+                .memberId(member.getId())
+                .gameCode(resultBean.getGameID())
+                .gameType(casinoGame.getSystemPlatformType())
+                .platformCode(GamePlatforms.PP.getInfo())
+                .gameId(casinoGame.getSystemGameId())
+                .gameName(casinoGame.getGameName())
+                .gameStatus(gameStatus)
+                .gameStatusType("F".equals(resultBean.getType()) ? 19 : 1)
+                .gameCurrencyCode(resultBean.getCurrency())
+                .account(resultBean.getExtPlayerID())
+                .wagersId(resultBean.getPlaySessionID())
+                .wagersTime(resultBean.getStartDate())
+                .betAmount(resultBean.getBet())
+                .payoffTime(resultBean.getEndDate())
+                .payoffAmount(payoffAmount.abs())
+                .settlementTime(resultBean.getEndDate())
+                .turnover(resultBean.getBet())
+                .settlementStatus(SettlementStatusEnum.COMPLETED.getCode())
+                .build();
+        gameBettingDetails.setCreateBy(Constants.SYSTEM);
+        gameBettingDetails.setCreateTime(DateUtils.getNowDate());
+        return gameBettingDetails;
+    }
+}

ff-game/src/main/java/com/ff/game/domain/GameExchangeMoney.java

@@ -99,4 +99,9 @@ public class GameExchangeMoney extends BaseEntity
      * 步骤状态   GameExchangeStepStatus  枚举
      */
     private Integer stepStatus;
+
+    /**
+     * 部分平台使用 第三方平台交易id
+     */
+    private String     partyTransactionId;
 }

ff-game/src/main/java/com/ff/game/service/impl/PlatformServiceImpl.java

@@ -61,7 +61,9 @@ public class PlatformServiceImpl implements IPlatformService {
             Object key = entry.getKey();
             // 设置数据源类型
             DynamicDataSourceContextHolder.setDataSourceType(key.toString());
-            List<Platform> list = selectList(new Platform());
+            Platform platform = new Platform();
+            platform.setStopStatus(Boolean.FALSE);
+            List<Platform> list = selectList(platform);
             for (Platform pp : list) {
                 redisCache.setCacheObject(getCacheKey(pp.getPlatformCode()), pp);
             }