feat(game): 添加 DG 游戏平台支持

- 新增 DG游戏平台的 API 接口和实现类
- 添加 DG游戏的登录、转账、获取游戏列表等功能
- 实现 DG 游戏的注单记录获取和处理
- 在数据库中添加 DG 游戏平台的相关配置

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

@@ -69,7 +69,10 @@ public class CacheConstants
     public static final String SA_GAMES= "sa_games:";
 
 
-
+    /**
+     * dg游戏
+     */
+    public static final String DG_GAMES= "dg_games:";
     /**
      * pg游戏投注货币
      */

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

@@ -204,6 +204,12 @@ public class Constants {
     public static final String XK_API_BASE_URL = "xk.api.base.url";
 
 
+    /**
+     * dg-api基本url
+     */
+    public static final String DG_API_BASE_URL = "dg.api.base.url";
+
+
     /**
      * sa-api基本url
      */

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

@@ -9,6 +9,7 @@ public enum GamePlatforms {
     PG("PG", "PG"),
     FC("FC", "FC"),
     SA("SA", "SA"),
+    DG("DG", "DG"),
     ;
 
     private final String code;

ff-game/src/main/java/com/ff/game/api/dg/address/MyDGAddressSource.java

@@ -0,0 +1,31 @@
+package com.ff.game.api.dg.address;
+
+import com.dtflys.forest.callback.AddressSource;
+import com.dtflys.forest.http.ForestAddress;
+import com.dtflys.forest.http.ForestRequest;
+import com.ff.base.constant.Constants;
+import com.ff.base.system.service.ISysConfigService;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+
+/**
+ * 我jili address来源
+ *
+ * @author shi
+ * @date 2025/02/10
+ */
+@Component
+public class MyDGAddressSource implements AddressSource {
+
+    @Resource
+    private ISysConfigService configService;
+
+
+    @Override
+    public ForestAddress getAddress(ForestRequest request) {
+        String apiBaseUrl = configService.selectConfigByKey(Constants.DG_API_BASE_URL);
+        return new ForestAddress("http",apiBaseUrl, 80,"");
+    }
+}

ff-game/src/main/java/com/ff/game/api/dg/client/DGClient.java

@@ -0,0 +1,105 @@
+package com.ff.game.api.dg.client;
+
+import com.dtflys.forest.annotation.*;
+import com.ff.game.api.dg.address.MyDGAddressSource;
+import com.ff.game.api.dg.dto.*;
+import com.ff.game.api.jili.dto.*;
+import com.ff.game.api.xk.address.MyXKAddressSource;
+import com.ff.game.api.xk.dto.*;
+
+import java.util.Map;
+
+/**
+ * dg 请求
+ *
+ * @author shi
+ * @date 2025/02/10
+ */
+@Address(source = MyDGAddressSource.class)
+public interface DGClient {
+    /**
+     * 创建成员
+     *
+     * @param params 参数
+     * @param header 头球
+     * @return {@link DGResponse }
+     */
+    @Post("/v2/api/signup")
+    DGResponse createMember(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
+
+    /**
+     * 获取会员信息
+     *
+     * @param params 参数
+     */
+    @Post("/v2/api/balance")
+    DGUserAccountResponse getMemberInfo(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
+
+    /**
+     * 无重定向登录
+     *
+     * @param params 参数
+     * @param header 头球
+     * @return {@link DGLoginWithoutRedirectResponse }
+     */
+    @Post("/v2/api/login")
+    DGLoginWithoutRedirectResponse loginWithoutRedirect(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
+
+    /**
+     * 获取游戏列表
+     *
+     * @param params 参数
+     * @return {@link JILIGamesDTO }
+     */
+    @Post("/getGameList")
+    XKGamesDTO getGameList(@JSONBody Map<String, Object> params);
+
+    /**
+     * 按代理id进行交换转账
+     *
+     * @param params 参数
+     * @return {@link DGTransactionResponseDTO }
+     */
+    @Post(url = "/v2/api/transfer")
+    DGTransactionResponseDTO exchangeTransferByAgentId(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
+
+    /**
+     * 按时间获取投注记录
+     *
+     * @param params 参数
+     * @return {@link XKBetRecordResponseDTO }
+     */
+    @Post(url ="/v2/api/report",
+            headers = {
+                    "Content-type: application/x-www-form-urlencoded"
+            })
+    DGBetRecordResponseDTO getBetRecordByTime(@Header Map<String, Object> params);
+
+    /**
+     * 标记报告
+     *
+     * @param params 参数
+     * @return {@link DGResponse }
+     */
+    @Post(url = "/v2/api/markReport")
+    DGResponse markReport(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
+    /**
+     * 踢出队员
+     *
+     * @param params 参数
+     * @return {@link JILIKickMemberDTO }
+     */
+    @Post("/kickMember")
+    XKKickMemberDTO kickMember(@JSONBody Map<String, Object> params);
+
+    /**
+     * 踢出所有队员
+     *
+     * @param params 参数
+     * @return {@link JILIKickMemberAllDTO }
+     */
+    @Get("/kickMemberAll")
+    XKKickMemberAllDTO kickMemberAll(@JSONBody Map<String, Object> params);
+
+
+}

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

@@ -0,0 +1,129 @@
+package com.ff.game.api.dg.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("report")
+    private List<ReportDTO> report;
+
+    /**
+     * 注单报告类
+     */
+    @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/dg/dto/DGLoginWithoutRedirectResponse.java

@@ -0,0 +1,74 @@
+package com.ff.game.api.dg.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/dg/dto/DGResponse.java

@@ -0,0 +1,26 @@
+package com.ff.game.api.dg.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/dg/dto/DGTransactionResponseDTO.java

@@ -0,0 +1,45 @@
+package com.ff.game.api.dg.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/dg/dto/DGUserAccountResponse.java

@@ -0,0 +1,40 @@
+package com.ff.game.api.dg.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/dg/service/impl/GamesDGServiceImpl.java

@@ -0,0 +1,569 @@
+package com.ff.game.api.dg.service.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.system.service.ISysConfigService;
+import com.ff.base.utils.DateUtils;
+import com.ff.base.utils.JsonUtil;
+import com.ff.base.utils.SleepUtil;
+import com.ff.base.utils.StringUtils;
+import com.ff.base.utils.sign.Md5Utils;
+import com.ff.base.utils.uuid.IdUtils;
+import com.ff.config.KeyConfig;
+import com.ff.game.api.IGamesService;
+import com.ff.game.api.dg.client.DGClient;
+import com.ff.game.api.dg.dto.*;
+import com.ff.game.api.ng.dto.ApiLoginResponseDTO;
+import com.ff.game.api.ng.dto.ApiMemberInfoResponseDTO;
+import com.ff.game.api.ng.dto.ApiNGResponseDTO;
+import com.ff.game.api.request.*;
+import com.ff.game.api.xk.client.XKClient;
+import com.ff.game.api.xk.dto.*;
+import com.ff.game.domain.*;
+import com.ff.game.dto.GameSecretKeyCurrencyDTO;
+import com.ff.game.service.*;
+import com.ff.member.domain.Member;
+import com.ff.member.service.IMemberService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.Assert;
+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("DGService")
+@Slf4j
+public class GamesDGServiceImpl implements IGamesService {
+
+
+    @Resource
+    private ISysConfigService configService;
+
+    @Resource
+    private RedisCache redisCache;
+
+    @Resource
+    private IGameExchangeMoneyService gameExchangeMoneyService;
+
+
+    @Resource
+    private IGamePlatformService gamePlatformService;
+
+
+    @Resource
+    private IGameService gameService;
+
+
+    @Resource
+    private IMemberService memberService;
+
+    @Resource
+    private IGameFreeRecordService gameFreeRecordService;
+    @Resource
+    private IGameSecretKeyService gameSecretKeyService;
+
+    @Resource
+    private IGameSecretKeyCurrencyService gameSecretKeyCurrencyService;
+
+    @Resource
+    private DGClient DGClient;
+
+
+    @Resource
+    private KeyConfig keyConfig;
+
+    @Resource
+    private IGameBettingDetailsService gameBettingDetailsService;
+
+    @Resource
+    private IGameNameService gameNameService;
+
+
+    /**
+     * 游戏id
+     */
+    private static final Long GAME_ID = 1904452832756003817L;
+
+    /**
+     * 平台ID
+     */
+    private static final Long PLATFORM_ID = 1904411420157108325L;
+
+    /**
+     * 游戏名称id
+     */
+    private static final Long GAME_NAME_ID = 1904452832756002317L;
+
+    /**
+     * 获得就是成功
+     *
+     * @param errorCode 错误代码
+     * @return {@link Boolean }
+     */
+    private Boolean getIsSuccess(Integer errorCode) {
+        ApiException.isTrue(103 != errorCode, ErrorCode.GAME_ACCOUNT_CREATION_FAILED.getCode());
+        return 0 == errorCode;
+    }
+
+
+    /**
+     * 获取密钥
+     *
+     * @param gamesBaseRequestDTO 游戏请求dto
+     * @return {@link String }
+     */
+    private Map<String, Object> getKey(GamesBaseRequestDTO gamesBaseRequestDTO) {
+        Long time = DateUtils.getNowDate();
+        //取出对应的key跟密钥跟请求参数
+        String agentKey = gamesBaseRequestDTO.getAgentKey();
+        String agentId = gamesBaseRequestDTO.getAgentId();
+
+        String sign = Md5Utils.md5New(agentId + agentKey + time);
+        Map<String, Object> keyMap = new HashMap<>();
+        keyMap.put("agent", agentId);
+        keyMap.put("sign", sign);
+        keyMap.put("time", time);
+        return keyMap;
+    }
+
+    /**
+     * 创建成员
+     *
+     * @param createMemberRequestDTO 创建成员请求dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean createMember(CreateMemberRequestDTO createMemberRequestDTO) {
+        log.info("GamesDGServiceImpl [createMember] 请求参数 {}", createMemberRequestDTO);
+
+        Map<String, Object> params = new LinkedHashMap<>();
+        params.put("username", createMemberRequestDTO.getAccount());
+        params.put("currencyName", createMemberRequestDTO.getCurrency());
+        params.put("winLimit", 0);
+        params.put("password", Md5Utils.md5New(createMemberRequestDTO.getAccount()));
+
+        Map<String, Object> headerMap = this.getKey(createMemberRequestDTO);
+        DGResponse response = DGClient.createMember(params, headerMap);
+        if (this.getIsSuccess(response.getCodeId())) {
+            return Boolean.TRUE;
+        }
+        //判断是否获取成功
+        return Boolean.FALSE;
+    }
+
+
+    /**
+     * 获取会员信息
+     *
+     * @param memberInfoRequestDTO 会员信息请求dto
+     * @return {@link MemberInfoResponseDTO }
+     */
+    @Override
+    public MemberInfoResponseDTO getMemberInfo(MemberInfoRequestDTO memberInfoRequestDTO) {
+        log.info("GamesDGServiceImpl [getMemberInfo] 请求参数 {}", memberInfoRequestDTO);
+        Map<String, Object> paramsMap = new HashMap<>();
+        paramsMap.put("username", memberInfoRequestDTO.getAccounts());
+        Map<String, Object> headerMap = this.getKey(memberInfoRequestDTO);
+        DGUserAccountResponse memberInfo = DGClient.getMemberInfo(paramsMap, headerMap);
+        int errorCode = memberInfo.getCodeId();
+        if (this.getIsSuccess(errorCode)) {
+            return MemberInfoResponseDTO.builder().account(memberInfoRequestDTO.getAccounts()).balance(memberInfo.getBalance()).status(GameMemberStatus.UNKNOWN.getCode()).build();
+        } else {
+            throw new ApiException(ErrorCode.ACCOUNT_NOT_EXIST.getCode());
+        }
+    }
+
+    /**
+     * 无重定向登录
+     *
+     * @param gamesLogin 游戏登录
+     * @return {@link String }
+     */
+    @Override
+    public String loginWithoutRedirect(GamesLogin gamesLogin) {
+        log.info("GamesDGServiceImpl [loginWithoutRedirect] 请求参数 {}", gamesLogin);
+        Map<String, Object> paramsMap = new HashMap<>();
+        paramsMap.put("username", gamesLogin.getAccount());
+        paramsMap.put("currencyName", gamesLogin.getCurrency());
+        paramsMap.put("winLimit", 0);
+        paramsMap.put("language", gamesLogin.getLang());
+        Map<String, Object> headerMap = this.getKey(gamesLogin);
+        DGLoginWithoutRedirectResponse loginWithoutRedirectResponse = DGClient.loginWithoutRedirect(paramsMap, headerMap);
+        if (this.getIsSuccess(loginWithoutRedirectResponse.getCodeId())) {
+            String url = loginWithoutRedirectResponse.getList().get(0) + "&showapp=off";
+            if (!StringUtils.isEmpty(gamesLogin.getHomeUrl())) {
+                url += "&backUrl=" + gamesLogin.getHomeUrl();
+            }
+            return url;
+        } else {
+            throw new ApiException(ErrorCode.ACCOUNT_NOT_EXIST.getCode());
+        }
+    }
+
+
+    /**
+     * 获取游戏列表
+     *
+     * @param gamesBaseRequestDTO 游戏请求dto
+     * @return {@link String }
+     */
+    @Transactional
+    @Override
+    public String getGameList(GamesBaseRequestDTO gamesBaseRequestDTO) {
+        GamePlatform gamePlatform = gamePlatformService.selectGamePlatformById(PLATFORM_ID);
+        //没有此平台就新增一个平台
+        if (ObjectUtils.isEmpty(gamePlatform)) {
+            gamePlatform = new GamePlatform();
+            gamePlatform.setPlatformCode(GamePlatforms.DG.getInfo());
+            gamePlatform.setPlatformType(PlatformType.CARD_GAME.getCode());
+            gamePlatform.setPlatformName(GamePlatforms.DG.getInfo() + PlatformType.CARD_GAME.getName());
+            gamePlatform.setSortNo(gamePlatformService.selectMaxSortNo() + 1);
+            gamePlatform.setCreateBy(Constants.SYSTEM);
+            gamePlatformService.insertGamePlatform(gamePlatform);
+        }
+        Game game = gameService.selectGameById(GAME_ID);
+        //不存在这个游戏
+        if (ObjectUtils.isEmpty(game)) {
+            game = new Game();
+            game.setSortNo(gameService.selectMaxSortNoByPlatformId(gamePlatform.getId()) + 1);
+            game.setPlatformId(gamePlatform.getId());
+            game.setGameCode("1");
+            game.setGameSourceType(1);
+            game.setGameName("真人棋牌");
+            game.setCreateBy(Constants.SYSTEM);
+            gameService.insertGame(game);
+        }
+        GameName gameName = gameNameService.selectGameNameById(GAME_NAME_ID);
+        if (ObjectUtils.isEmpty(gameName)) {
+            gameNameService.insertGameName(GameName.builder()
+                    .gameId(game.getId())
+                    .gameName(game.getGameName())
+                    .langCode("zh-CN")
+                    .createBy(Constants.SYSTEM)
+                    .build());
+        }
+        return CacheConstants.DG_GAMES;
+    }
+
+    /**
+     * 按代理id进行交换转账
+     *
+     * @param exchangeTransferMoneyRequestDTO 外汇转账moeny dto
+     * @return {@link Long }
+     */
+    @Override
+    @Transactional
+    public Long exchangeTransferByAgentId(ExchangeTransferMoneyRequestDTO exchangeTransferMoneyRequestDTO) {
+        log.info("GamesDGServiceImpl [exchangeTransferByAgentId] 请求参数 {}", exchangeTransferMoneyRequestDTO);
+        GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
+                .platformCode(GamePlatforms.DG.getInfo())
+                .code(exchangeTransferMoneyRequestDTO.getAgentId())
+                .build());
+
+        Member member = memberService.selectMemberByGameAccount(exchangeTransferMoneyRequestDTO.getAccount());
+        String transactionId = GamePlatforms.DG.getCode() + IdUtils.simpleUUID();
+        List<GameExchangeMoney> gameExchangeMonies = gameExchangeMoneyService.selectGameExchangeMoneyList(
+                GameExchangeMoney.builder()
+                        .tenantKey(exchangeTransferMoneyRequestDTO.getTenantKey())
+                        .orderId(exchangeTransferMoneyRequestDTO.getOrderId())
+                        .build()
+        );
+        Assert.isTrue(CollectionUtils.isEmpty(gameExchangeMonies), "订单号重复");
+
+        //获取下一个自增id
+        GameExchangeMoney exchangeMoney = GameExchangeMoney
+                .builder()
+                .tenantKey(exchangeTransferMoneyRequestDTO.getTenantKey())
+                .orderId(exchangeTransferMoneyRequestDTO.getOrderId())
+                .quota(exchangeTransferMoneyRequestDTO.getQuota())
+                .balance(exchangeTransferMoneyRequestDTO.getAmount())
+                .exchangeType(exchangeTransferMoneyRequestDTO.getTransferType())
+                .currencyCode(currencyDTO.getSystemCurrency())
+                .memberId(member.getId())
+                .transactionId(transactionId)
+                .platformCode(GamePlatforms.DG.getCode())
+                .build();
+        exchangeMoney.setCreateBy(Constants.SYSTEM);
+
+        BigDecimal amount = exchangeTransferMoneyRequestDTO.getAmount();
+        if (TransferType.ALL.getCode().equals(exchangeTransferMoneyRequestDTO.getTransferType())) {
+            // 获取第三方钱包余额
+            MemberInfoRequestDTO gamesBaseRequestDTO = MemberInfoRequestDTO.builder()
+                    .accounts(member.getGameAccount())
+                    .agentId(exchangeTransferMoneyRequestDTO.getAgentId())
+                    .currency(exchangeTransferMoneyRequestDTO.getCurrency())
+                    .agentKey(exchangeTransferMoneyRequestDTO.getAgentKey())
+                    .build();
+
+            BigDecimal balance = this.getMemberInfo(gamesBaseRequestDTO).getBalance();
+            amount = balance.compareTo(BigDecimal.ZERO) > 0 ? balance.negate() : balance;
+        }
+
+        Map<String, Object> params = new LinkedHashMap<>();
+        params.put("username", exchangeTransferMoneyRequestDTO.getAccount());
+        params.put("amount", amount);
+        params.put("serial", transactionId);
+
+        Map<String, Object> headerMap = this.getKey(exchangeTransferMoneyRequestDTO);
+        DGTransactionResponseDTO dgTransactionResponseDTO = DGClient.exchangeTransferByAgentId(params, headerMap);
+        //判断是否转移成功
+        if (this.getIsSuccess(dgTransactionResponseDTO.getCodeId())) {
+
+            //更新数据
+            exchangeMoney.setBalance(dgTransactionResponseDTO.getAmount().abs());
+            exchangeMoney.setCoinBefore(NumberUtil.sub(dgTransactionResponseDTO.getBalance(), dgTransactionResponseDTO.getAmount().abs()).abs());
+            exchangeMoney.setCoinAfter(dgTransactionResponseDTO.getBalance());
+            exchangeMoney.setCurrencyBefore(exchangeMoney.getCoinBefore());
+            exchangeMoney.setCurrencyAfter(exchangeMoney.getCoinAfter());
+            exchangeMoney.setStatus(StatusType.SUCCESS.getValue());
+            gameExchangeMoneyService.insertGameExchangeMoney(exchangeMoney);
+        } else {
+            log.error("GamesXKServiceImpl [exchangeTransferByAgentId] 金额转移失败,错误代码{},错误信息{}", dgTransactionResponseDTO.getCodeId(), dgTransactionResponseDTO.getMsg());
+            throw new ApiException(ErrorCode.BALANCE_TRANSFER_FAILED.getCode());
+        }
+
+        return exchangeMoney.getId();
+    }
+
+    /**
+     * 汇兑转移状态
+     *
+     * @param exchangeTransferMoneyRequestDTO 兑换转账请求dto
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean exchangeTransferStatus(ExchangeTransferStatusRequestDTO exchangeTransferMoneyRequestDTO) {
+        return Boolean.TRUE;
+    }
+
+
+    /**
+     * 按时间获取投注记录
+     *
+     * @param betRecordByTimeDTO 按时间dto投注记录
+     * @return {@link List }<{@link GameBettingDetails }>
+     */
+    @Override
+    public Boolean getBetRecordByTime(BetRecordByTimeDTO betRecordByTimeDTO) {
+        //请求参数
+        log.info("GamesDGServiceImpl [getBetRecordByTime] 请求参数 {}", betRecordByTimeDTO);
+        Map<String, Object> key = this.getKey(betRecordByTimeDTO);
+        DGBetRecordResponseDTO betRecordByTime = DGClient.getBetRecordByTime(key);
+
+        //判断是否获取成功
+        if (this.getIsSuccess(betRecordByTime.getCodeId())) {
+            this.batchInsert(betRecordByTime,betRecordByTimeDTO);
+
+
+            return Boolean.TRUE;
+        } else {
+            log.error("GamesXKServiceImpl [getBetRecordByTime] 获取投注记录失败,错误代码{},错误信息{}", betRecordByTime.getCodeId(), betRecordByTime.getMsg());
+            throw new BaseException(betRecordByTime.getMsg());
+        }
+
+
+    }
+
+    /**
+     * 按历史时间获取投注记录
+     *
+     * @param betRecordByTimeDTO 按时间dto投注记录
+     * @return {@link Boolean }
+     */
+    @Override
+    public Boolean getBetRecordByHistoryTime(BetRecordByTimeDTO betRecordByTimeDTO) {
+        return null;
+    }
+
+    /**
+     * 赠送免费局数
+     *
+     * @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) {
+        return null;
+    }
+
+    /**
+     * 踢成员全部
+     *
+     * @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());
+    }
+
+
+    /**
+     * 批量插入
+     *
+     * @param dgBetRecordResponseDTO dg投注记录响应dto
+     */
+    private void batchInsert(DGBetRecordResponseDTO dgBetRecordResponseDTO,GamesBaseRequestDTO gamesBaseRequestDTO) {
+        List<GameBettingDetails> gameBettingDetails = new ArrayList<>();
+        List<String> wagersIds = new ArrayList<>();
+        //数据组装
+        List<DGBetRecordResponseDTO.ReportDTO> report = dgBetRecordResponseDTO.getReport();
+        //数据转化
+        for (DGBetRecordResponseDTO.ReportDTO bean : report) {
+            GameBettingDetails bettingDetails = this.dataBuild(GamesDataBuildDTO.builder().data(bean).build());
+            if (!ObjectUtils.isEmpty(bettingDetails)) {
+                bettingDetails.setId(IdUtil.getSnowflakeNextId());
+                gameBettingDetails.add(bettingDetails);
+            }
+            wagersIds.add(String.valueOf(bean.getId()));
+        }
+        if (!CollectionUtils.isEmpty(gameBettingDetails)) {
+            //查询重复数据id
+            List<String> removeWagersIds = gameBettingDetailsService.selectGameBettingDetailsByWagersId(wagersIds);
+            //用steam流清除list中与wagersIds集合相同的数据
+            gameBettingDetails = gameBettingDetails.stream()
+                    .filter(detail -> !removeWagersIds.contains(detail.getWagersId()))
+                    .collect(Collectors.toList());
+            if (!CollectionUtils.isEmpty(gameBettingDetails)) {
+                gameBettingDetailsService.batchInsert(gameBettingDetails);
+                Map<String, Object> key = this.getKey(gamesBaseRequestDTO);
+                Map<String, Object> params = new HashMap<>();
+                params.put("list", wagersIds);
+                DGClient.markReport(params,key);
+            }
+        }
+
+    }
+
+    /**
+     * 数据构建
+     *
+     * @param gamesDataBuildDTO 数据
+     * @return {@link GameBettingDetails }
+     */
+    @Override
+    public GameBettingDetails dataBuild(GamesDataBuildDTO gamesDataBuildDTO) {
+        //转化类
+        DGBetRecordResponseDTO.ReportDTO resultBean = (DGBetRecordResponseDTO.ReportDTO) gamesDataBuildDTO.getData();
+
+
+        GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
+                .platformCode(GamePlatforms.DG.getInfo())
+                .currencyId(String.valueOf(resultBean.getCurrencyId()))
+                .build());
+
+
+        Member member = memberService.selectMemberByGameAccount(resultBean.getUserName());
+        if (ObjectUtils.isEmpty(member)) {
+            return null;
+        }
+        //未结算的不要
+        if (0 == resultBean.getIsRevocation()) {
+            return null;
+        }
+
+        BigDecimal payoffAmount = BigDecimal.ZERO;
+        BigDecimal winOrLoss = resultBean.getWinOrLoss();
+        //输赢状态
+        Integer gameStatus = GameStatus.FLAT.getCode();
+        if (winOrLoss.compareTo(resultBean.getBetPoints()) > 0) {
+            payoffAmount = NumberUtil.sub(winOrLoss, resultBean.getBetPoints());
+            gameStatus = GameStatus.WIN.getCode();
+        } else if (winOrLoss.compareTo(resultBean.getBetPoints()) < 0) {
+            payoffAmount = NumberUtil.sub(resultBean.getWinOrLoss(), resultBean.getBetPoints()).negate();
+            gameStatus = GameStatus.FAIL.getCode();
+        }
+
+
+        //数据构造
+        GameBettingDetails gameBettingDetails = GameBettingDetails.builder()
+                .tenantKey(member.getTenantKey())
+                //保存我们的币种id
+                .currencyCode(currencyDTO.getSystemCurrency())
+                .memberId(member.getId())
+                .gameCode(String.valueOf(resultBean.getGameId()))
+                .gameType(PlatformType.CARD_GAME.getCode())
+                .platformCode(GamePlatforms.SA.getCode())
+                .gameId(GAME_ID)
+                .gameName(String.valueOf(resultBean.getGameId()))
+                .gameStatus(gameStatus)
+                .gameStatusType(resultBean.getGameType())
+                .gameCurrencyCode(currencyDTO.getCurrency())
+                .account(String.valueOf(resultBean.getUserName()))
+                .wagersId(String.valueOf(resultBean.getId()))
+                .wagersTime(resultBean.getBetTime().getTime())
+                .betAmount(resultBean.getBetPoints())
+                .payoffTime(resultBean.getCalTime().getTime())
+                .payoffAmount(payoffAmount)
+                .settlementTime(resultBean.getCalTime().getTime())
+                .turnover(resultBean.getAvailableBet())
+                .settlementStatus(SettlementStatusEnum.COMPLETED.getCode())
+                .build();
+        gameBettingDetails.setCreateBy(Constants.SYSTEM);
+        gameBettingDetails.setCreateTime(DateUtils.getNowDate());
+        return gameBettingDetails;
+    }
+}

ff-game/src/main/java/com/ff/game/api/sa/impl/GamesSAServiceImpl.java

@@ -245,6 +245,7 @@ public class GamesSAServiceImpl implements IGamesService {
         //没有此平台就新增一个平台
         if (ObjectUtils.isEmpty(gamePlatform)) {
             gamePlatform = new GamePlatform();
+            gamePlatform.setPlatformCode(GamePlatforms.SA.getInfo());
             gamePlatform.setPlatformType(PlatformType.CARD_GAME.getCode());
             gamePlatform.setPlatformName(GamePlatforms.SA.getInfo() + PlatformType.CARD_GAME.getName());
             gamePlatform.setSortNo(gamePlatformService.selectMaxSortNo() + 1);
@@ -594,7 +595,7 @@ public class GamesSAServiceImpl implements IGamesService {
                 .currencyCode(currencyDTO.getSystemCurrency())
                 .memberId(member.getId())
                 .gameCode(resultBean.getGameID())
-                .gameType(1)
+                .gameType(PlatformType.CARD_GAME.getCode())
                 .platformCode(GamePlatforms.SA.getCode())
                 .gameId(GAME_ID)
                 .gameName(game.getGameName())

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

@@ -80,6 +80,8 @@ public class GameBettingDetails extends BaseEntity
      18 满额必开 (开奖)
      19 免费游戏
      28 旋转奖金
+     DG
+     （1:注单，2:红包小费）
 
      */
     @Excel(name = "注单类型")

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

@@ -35,6 +35,10 @@ public class GameSecretKeyCurrency extends BaseEntity {
     @Excel(name = "平台", width = 30, dateFormat = "yyyy-MM-dd")
     private Long gameSecretKeyId;
 
+    /**
+     * 货币id
+     */
+    private String currencyId;
     /**
      * 币种
      */

ff-game/src/main/resources/logback.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <configuration>
     <!-- 日志存放路径 -->
-	<property name="log.path" value="/opt/sever/dist/ff-admin/logs" />
+	<property name="log.path" value="/opt/sever/dist/ff-game/logs" />
     <!-- 日志输出格式 -->
 	<property name="log.pattern" value="%d{yyyy-MM-dd HH:mm:ss.SSS}-[%X{dataSource}] [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
 

ff-game/src/main/resources/mapper/game/GameSecretKeyCurrencyMapper.xml

@@ -7,6 +7,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <resultMap type="GameSecretKeyCurrency" id="GameSecretKeyCurrencyResult">
         <result property="id"    column="id"    />
         <result property="gameSecretKeyId"    column="game_secret_key_id"    />
+        <result property="currencyId"    column="currency_id"    />
         <result property="currency"    column="currency"    />
         <result property="systemCurrency"    column="system_currency"    />
         <result property="createBy"    column="create_by"    />
@@ -18,6 +19,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <resultMap type="com.ff.game.dto.GameSecretKeyCurrencyDTO" id="GameSecretKeyCurrencyDTOResult">
         <result property="id"    column="id"    />
         <result property="gameSecretKeyId"    column="game_secret_key_id"    />
+        <result property="currencyId"    column="currency_id"    />
         <result property="currency"    column="currency"    />
         <result property="systemCurrency"    column="system_currency"    />
         <result property="createBy"    column="create_by"    />
@@ -29,7 +31,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </resultMap>
 
     <sql id="selectGameSecretKeyCurrencyVo">
-        select id, game_secret_key_id, currency, system_currency, create_by, create_time, update_by, update_time from ff_game_secret_key_currency
+        select id,currency_id, game_secret_key_id, currency, system_currency, create_by, create_time, update_by, update_time from ff_game_secret_key_currency
     </sql>
 
     <select id="selectGameSecretKeyCurrencyList" parameterType="GameSecretKeyCurrency" resultMap="GameSecretKeyCurrencyResult">
@@ -51,6 +53,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <trim prefix="(" suffix=")" suffixOverrides=",">
             <if test="id != null">id,</if>
             <if test="gameSecretKeyId != null">game_secret_key_id,</if>
+            <if test="currencyId != null">currency_id,</if>
             <if test="currency != null">currency,</if>
             <if test="systemCurrency != null and systemCurrency != ''">system_currency,</if>
             <if test="createBy != null">create_by,</if>
@@ -61,6 +64,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="id != null">#{id},</if>
             <if test="gameSecretKeyId != null">#{gameSecretKeyId},</if>
+            <if test="currencyId != null">#{currencyId},</if>
             <if test="currency != null">#{currency},</if>
             <if test="systemCurrency != null and systemCurrency != ''">#{systemCurrency},</if>
             <if test="createBy != null">#{createBy},</if>
@@ -74,6 +78,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         update ff_game_secret_key_currency
         <trim prefix="SET" suffixOverrides=",">
             <if test="gameSecretKeyId != null">game_secret_key_id = #{gameSecretKeyId},</if>
+            <if test="currencyId != null">currency_id = #{currencyId},</if>
             <if test="currency != null">currency = #{currency},</if>
             <if test="systemCurrency != null and systemCurrency != ''">system_currency = #{systemCurrency},</if>
             <if test="createBy != null">create_by = #{createBy},</if>
@@ -97,7 +102,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 
 
     <select id="findByGameSecretKeyCurrencyDTO" parameterType="com.ff.game.dto.GameSecretKeyCurrencyDTO" resultMap="GameSecretKeyCurrencyDTOResult">
-        select gskc.currency, gskc.system_currency,gskc.game_secret_key_id,gsk.code ,gsk.`key`,gsk.platform as platform_code
+        select gskc.currency, gskc.system_currency,gskc.game_secret_key_id,gsk.code ,gsk.`key`,gsk.platform,gskc.currency_id as platform_code
         from ff_game_secret_key gsk
         inner join ff_game_secret_key_currency gskc on gsk.id = gskc.game_secret_key_id
         <where>
@@ -111,12 +116,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
                     #{platformCode}
                 </foreach>
             </if>
+            <if test="currencyId != null "> and gskc.currency_id = #{currencyId}</if>
         </where>
         limit 1
     </select>
 
     <select id="findByGameSecretKeyCurrencyDTOList" parameterType="com.ff.game.dto.GameSecretKeyCurrencyDTO" resultMap="GameSecretKeyCurrencyDTOResult">
-        select gskc.currency, gskc.system_currency,gskc.game_secret_key_id,gsk.code ,gsk.`key`,gsk.platform as platform_code
+        select gskc.currency, gskc.system_currency,gskc.game_secret_key_id,gsk.code ,gsk.`key`,gsk.platform,gskc.currency_id as platform_code
         from ff_game_secret_key gsk
         inner join ff_game_secret_key_currency gskc on gsk.id = gskc.game_secret_key_id
         <where>