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

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

ff-base/pom.xml

@@ -0,0 +1,207 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>ff</artifactId>
+        <groupId>com.ff</groupId>
+        <version>0.0.1</version>
+    </parent>
+
+    <groupId>com.ff</groupId>
+    <artifactId>ff-base</artifactId>
+    <version>0.0.1</version>
+    <name>ff-base</name>
+    <description>ff-base</description>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+
+        <dependency>
+            <groupId>com.dtflys.forest</groupId>
+            <artifactId>forest-spring-boot-starter</artifactId>
+            <version>1.6.3</version>
+        </dependency>
+        <!-- SpringBoot的依赖配置-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-dependencies</artifactId>
+            <version>2.5.15</version>
+            <type>pom</type>
+            <scope>import</scope>
+        </dependency>
+
+        <!-- SpringBoot Web容器 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <!-- SpringBoot 拦截器 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+
+        <!-- 阿里数据库连接池 -->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>druid-spring-boot-starter</artifactId>
+        </dependency>
+
+        <!-- 验证码 -->
+        <dependency>
+            <groupId>pro.fessional</groupId>
+            <artifactId>kaptcha</artifactId>
+        </dependency>
+
+        <!-- 获取系统信息 -->
+        <dependency>
+            <groupId>com.github.oshi</groupId>
+            <artifactId>oshi-core</artifactId>
+        </dependency>
+
+        <!-- Spring框架基本的核心工具 -->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+        </dependency>
+
+        <!-- SpringWeb模块 -->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-web</artifactId>
+        </dependency>
+
+        <!-- spring security 安全认证 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-security</artifactId>
+        </dependency>
+
+        <!-- pagehelper 分页插件 -->
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper-spring-boot-starter</artifactId>
+        </dependency>
+
+        <!-- 自定义验证注解 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+
+        <!--常用工具类 -->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+
+        <!-- JSON工具类 -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+        </dependency>
+
+        <!-- 阿里JSON解析器 -->
+        <dependency>
+            <groupId>com.alibaba.fastjson2</groupId>
+            <artifactId>fastjson2</artifactId>
+        </dependency>
+
+        <!-- io常用工具类 -->
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+        </dependency>
+
+
+
+
+        <!-- excel工具 -->
+        <dependency>
+            <groupId>org.apache.poi</groupId>
+            <artifactId>poi-ooxml</artifactId>
+        </dependency>
+
+        <!--http-->
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+        </dependency>
+        <!-- yml解析器 -->
+        <dependency>
+            <groupId>org.yaml</groupId>
+            <artifactId>snakeyaml</artifactId>
+        </dependency>
+
+        <!-- Token生成与解析-->
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt</artifactId>
+        </dependency>
+
+        <!-- Jaxb -->
+        <dependency>
+            <groupId>javax.xml.bind</groupId>
+            <artifactId>jaxb-api</artifactId>
+        </dependency>
+
+        <!-- redis 缓存操作 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+
+        <!-- pool 对象池 -->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+        </dependency>
+
+        <!-- 解析客户端操作系统、浏览器等 -->
+        <dependency>
+            <groupId>eu.bitwalker</groupId>
+            <artifactId>UserAgentUtils</artifactId>
+        </dependency>
+
+        <!-- servlet包 -->
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+        </dependency>
+
+       <!-- 二维码生成 -->
+        <dependency>
+            <groupId>com.google.zxing</groupId>
+            <artifactId>core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.google.zxing</groupId>
+            <artifactId>javase</artifactId>
+        </dependency>
+
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

ff-base/src/main/java/com/ff/base/annotation/Excels.java

@@ -1,5 +1,7 @@
 package com.ff.base.annotation;
 
+import com.ff.base.annotation.Excel;
+
 import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;

ff-base/src/main/java/com/ff/base/aspectj/DataScopeAspect.java

@@ -2,13 +2,13 @@ package com.ff.base.aspectj;
 
 import com.ff.base.annotation.DataScope;
 import com.ff.base.core.domain.BaseEntity;
-import com.ff.base.core.domain.model.LoginUser;
-import com.ff.base.core.text.Convert;
-import com.ff.base.security.context.PermissionContextHolder;
 import com.ff.base.system.domain.SysRole;
 import com.ff.base.system.domain.SysUser;
+import com.ff.base.core.domain.model.LoginUser;
+import com.ff.base.core.text.Convert;
 import com.ff.base.utils.SecurityUtils;
 import com.ff.base.utils.StringUtils;
+import com.ff.base.security.context.PermissionContextHolder;
 import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.annotation.Aspect;
 import org.aspectj.lang.annotation.Before;

ff-base/src/main/java/com/ff/base/aspectj/DataSourceAspect.java

@@ -1,8 +1,8 @@
 package com.ff.base.aspectj;
 
 import com.ff.base.annotation.DataSource;
-import com.ff.base.datasource.DynamicDataSourceContextHolder;
 import com.ff.base.utils.StringUtils;
+import com.ff.base.datasource.DynamicDataSourceContextHolder;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;

ff-base/src/main/java/com/ff/base/aspectj/LogAspect.java

@@ -2,18 +2,18 @@ package com.ff.base.aspectj;
 
 import com.alibaba.fastjson2.JSON;
 import com.ff.base.annotation.Log;
+import com.ff.base.system.domain.SysUser;
 import com.ff.base.core.domain.model.LoginUser;
 import com.ff.base.enums.BusinessStatus;
 import com.ff.base.enums.HttpMethod;
 import com.ff.base.filter.PropertyPreExcludeFilter;
-import com.ff.base.manager.AsyncManager;
-import com.ff.base.manager.factory.AsyncFactory;
-import com.ff.base.system.domain.SysOperLog;
-import com.ff.base.system.domain.SysUser;
 import com.ff.base.utils.SecurityUtils;
 import com.ff.base.utils.ServletUtils;
 import com.ff.base.utils.StringUtils;
 import com.ff.base.utils.ip.IpUtils;
+import com.ff.base.manager.AsyncManager;
+import com.ff.base.manager.factory.AsyncFactory;
+import com.ff.base.system.domain.SysOperLog;
 import org.apache.commons.lang3.ArrayUtils;
 import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.annotation.AfterReturning;

ff-base/src/main/java/com/ff/base/config/I18nConfig.java

@@ -10,6 +10,8 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 import org.springframework.web.servlet.i18n.AcceptHeaderLocaleResolver;
 import org.springframework.web.servlet.i18n.LocaleChangeInterceptor;
 
+import java.lang.reflect.Field;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Locale;

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

@@ -5,8 +5,7 @@ package com.ff.base.constant;
  *
  * @author ff
  */
-public class CacheConstants
-{
+public class CacheConstants {
     /**
      * 登录用户 redis key
      */
@@ -52,15 +51,32 @@ public class CacheConstants
      */
     public static final String XK_GAMES = "xk_games:";
 
+    /**
+     * ae游戏
+     */
+    public static final String AE_GAMES = "ae_games:";
+    /**
+     * km游戏
+     */
+    public static final String KM_GAMES = "km_games:";
+
+
+    /**
+     * pgx游戏
+     */
+    public static final String PGX_GAMES = "pgx_games:";
+
     /**
      * pg游戏
      */
     public static final String PG_GAMES = "pg_games:";
 
     /**
-     * pp游戏
+     * pgt游戏
      */
-    public static final String PP_GAMES= "pp_games:";
+    public static final String PGT_GAMES = "pgt_games:";
+
+
     /**
      * fc游戏
      */
@@ -76,10 +92,61 @@ public class CacheConstants
      * dg游戏
      */
     public static final String DG_GAMES = "dg_games:";
+    /**
+     * fb体育
+     */
+    public static final String FB_Sports = "fp_sports:";
+
+    /**
+     * db体育
+     */
+    public static final String DB_Sports = "db_sports:";
     /**
      * pg游戏投注货币
      */
     public static final String PG_GAMES_BET_CURRENCY = "pg_games:bet:currency";
 
 
+    /**
+     * pgt下一个id
+     */
+    public static final String PGT_NEXT_ID = "pgt_next:id:";
+
+    /**
+     * ae时间从
+     */
+    public static final String AE_TIME_FROM= "ae:time:from";
+
+    /**
+     * 美天棋牌游戏
+     */
+    public static final String MeiTian_GAMES = "meitian_games:";
+
+
+    public static final String Platform = "platform:";
+
+    /**
+     * km用户令牌
+     */
+    public static final String KM_USER_TOKEN = "km:user:token:";
+
+
+    /**
+     * ae时间从
+     */
+    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/core/controller/BaseController.java

@@ -1,5 +1,7 @@
 package com.ff.base.core.controller;
 
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
 import com.ff.base.constant.HttpStatus;
 import com.ff.base.core.domain.AjaxResult;
 import com.ff.base.core.domain.model.LoginUser;
@@ -11,8 +13,6 @@ import com.ff.base.utils.PageUtils;
 import com.ff.base.utils.SecurityUtils;
 import com.ff.base.utils.StringUtils;
 import com.ff.base.utils.sql.SqlUtil;
-import com.github.pagehelper.PageHelper;
-import com.github.pagehelper.PageInfo;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.web.bind.WebDataBinder;

ff-base/src/main/java/com/ff/base/core/domain/BaseEntity.java

@@ -5,6 +5,7 @@ import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import lombok.AllArgsConstructor;
+import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 import lombok.experimental.SuperBuilder;
@@ -22,7 +23,8 @@ import java.util.Map;
 @SuperBuilder
 @AllArgsConstructor
 @NoArgsConstructor
-public class BaseEntity implements Serializable {
+public class BaseEntity implements Serializable
+{
     private static final long serialVersionUID = 1L;
 
     /**
@@ -30,48 +32,37 @@ public class BaseEntity implements Serializable {
      */
     private Long id;
 
-    /**
-     * 搜索值
-     */
+    /** 搜索值 */
     @JsonIgnore
     private String searchValue;
 
-    /**
-     * 创建者
-     */
+    /** 创建者 */
     private String createBy;
 
-    /**
-     * 创建时间
-     */
+    /** 创建时间 */
     @JsonSerialize(using = ToStringSerializer.class)
     private Long createTime;
 
-    /**
-     * 更新者
-     */
+    /** 更新者 */
     private String updateBy;
 
-    /**
-     * 更新时间
-     */
+    /** 更新时间 */
     @JsonSerialize(using = ToStringSerializer.class)
     private Long updateTime;
 
-    /**
-     * 备注
-     */
+    /** 备注 */
     private String remark;
 
-    /**
-     * 请求参数
-     */
+    /** 请求参数 */
     @JsonInclude(JsonInclude.Include.NON_EMPTY)
     private Map<String, Object> params;
 
 
-    public Map<String, Object> getParams() {
-        if (params == null) {
+
+    public Map<String, Object> getParams()
+    {
+        if (params == null)
+        {
             params = new HashMap<>();
         }
         return params;

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

@@ -1,5 +1,6 @@
 package com.ff.base.enums;
 
+import lombok.Data;
 import lombok.Getter;
 
 /**

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

@@ -37,6 +37,7 @@ public enum ErrorCode {
     Transfer_Not_Exist(1021, "转帐操作不存在"),
     Get_Url_Failure(1022, "获取URL失败"),
     Miss_Config(1023, "缺少配置"),
+    DUPLICATE_ORDER_ID (1024, "重复的订单id"),
     ;
 
     // 获取错误码

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

@@ -3,6 +3,7 @@ package com.ff.base.enums;
 
 import lombok.Getter;
 
+import java.util.HashMap;
 import java.util.Optional;
 import java.util.stream.Stream;
 

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

@@ -0,0 +1,34 @@
+package com.ff.base.enums;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.Getter;
+
+/**
+ * 游戏交换步骤
+ *
+ * @author shi
+ * @date 2025/04/08
+ */
+@Getter
+@AllArgsConstructor
+public enum GameExchangeStep {
+    CREATE_ORDER(1, "创建订单"),
+    DEDUCT_BALANCE(2, "转入提前扣租户余额"),
+    PLATFORM_TRANSACTION(3, "平台交易成功"),
+    TENANT_QUOTA_DEDUCTED(4, "转出租户额度增加成功");
+
+    private final Integer code;
+    private final String description;
+
+    // 根据 code 获取对应的枚举
+    public static GameExchangeStep getByCode(int code) {
+        for (GameExchangeStep step : GameExchangeStep.values()) {
+            if (step.getCode() == code) {
+                return step;
+            }
+        }
+        return null;
+    }
+}

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

@@ -1,5 +1,6 @@
 package com.ff.base.enums;
 
+import lombok.Data;
 import lombok.Getter;
 
 /**

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

@@ -1,5 +1,7 @@
 package com.ff.base.enums;
 
+import com.ff.base.exception.base.ApiException;
+
 import java.util.ArrayList;
 import java.util.List;
 
@@ -17,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;
@@ -27,6 +30,20 @@ public enum GamePlatforms {
         this.info = info;
     }
 
+    /**
+     * 通过代码获取
+     *
+     * @param code 代码
+     * @return {@link GamePlatforms }
+     */
+    public static GamePlatforms getByCode(String code) {
+        for (GamePlatforms platform : GamePlatforms.values()) {
+            if (platform.getCode().equals(code)) {
+                return platform;
+            }
+        }
+        throw new ApiException(ErrorCode.PLATFORM_NOT_EXIST.getCode());
+    }
 
     public static List<String> getCodes() {
         List<String> result = new ArrayList<>();

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

@@ -2,9 +2,12 @@ package com.ff.base.enums;
 
 import lombok.Getter;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.Optional;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 /**
  * ng平台 支持游戏

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

@@ -1,6 +1,7 @@
 package com.ff.base.enums;
 
 import lombok.AllArgsConstructor;
+import lombok.Data;
 import lombok.Getter;
 
 /**

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

@@ -1,6 +1,7 @@
 package com.ff.base.enums;
 
 import lombok.AllArgsConstructor;
+import lombok.Data;
 import lombok.Getter;
 
 import java.util.Optional;

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

@@ -1,6 +1,8 @@
 package com.ff.base.enums;
 
+import com.dtflys.forest.annotation.Get;
 import lombok.AllArgsConstructor;
+import lombok.Data;
 import lombok.Getter;
 
 /**