diff --git a/ff-base/src/main/java/com/ff/base/constant/CacheConstants.java b/ff-base/src/main/java/com/ff/base/constant/CacheConstants.java index 0dbb96e..8d67c0a 100644 --- a/ff-base/src/main/java/com/ff/base/constant/CacheConstants.java +++ b/ff-base/src/main/java/com/ff/base/constant/CacheConstants.java @@ -57,7 +57,10 @@ public class CacheConstants */ public static final String PG_GAMES= "pg_games:"; - + /** + * pp游戏 + */ + public static final String PP_GAMES= "pp_games:"; /** * fc游戏 */ diff --git a/ff-base/src/main/java/com/ff/base/constant/Constants.java b/ff-base/src/main/java/com/ff/base/constant/Constants.java index 4f76fe7..53a6678 100644 --- a/ff-base/src/main/java/com/ff/base/constant/Constants.java +++ b/ff-base/src/main/java/com/ff/base/constant/Constants.java @@ -209,7 +209,10 @@ public class Constants { */ public static final String DG_API_BASE_URL = "dg.api.base.url"; - + /** + * pp api基本url + */ + public static final String PP_API_BASE_URL = "pp.api.base.url"; /** * sa-api基本url */ diff --git a/ff-game/src/main/java/com/ff/agent/domain/TenantAgentCommission.java b/ff-game/src/main/java/com/ff/agent/domain/TenantAgentCommission.java index a8e8f7f..c7bf945 100644 --- a/ff-game/src/main/java/com/ff/agent/domain/TenantAgentCommission.java +++ b/ff-game/src/main/java/com/ff/agent/domain/TenantAgentCommission.java @@ -74,7 +74,7 @@ public class TenantAgentCommission extends BaseEntity @Excel(name = "USDT金额") private BigDecimal usdtBalance; - /** 佣金审批状态 ff_tenant_agent_approval_status 0 未提现 1 提现中 1 已提现 */ + /** 佣金审批状态 ff_tenant_agent_approval_status 0 未提现 1 提现中 2 已提现 */ @Excel(name = "佣金审批状态 0 未提现 1 提现中 1 已提现") private Integer approvalStatus; diff --git a/ff-game/src/main/java/com/ff/game/api/pp/address/MyPPAddressSource.java b/ff-game/src/main/java/com/ff/game/api/pp/address/MyPPAddressSource.java new file mode 100644 index 0000000..d116664 --- /dev/null +++ b/ff-game/src/main/java/com/ff/game/api/pp/address/MyPPAddressSource.java @@ -0,0 +1,31 @@ +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.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 MyPPAddressSource implements AddressSource { + + @Resource + private ISysConfigService configService; + + + @Override + public ForestAddress getAddress(ForestRequest request) { + String apiBaseUrl = configService.selectConfigByKey(Constants.PP_API_BASE_URL); + return new ForestAddress("https",apiBaseUrl, 443,"/IntegrationService/v3/http/CasinoGameAPI"); + } +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/client/PPClient.java b/ff-game/src/main/java/com/ff/game/api/pp/client/PPClient.java new file mode 100644 index 0000000..235e45c --- /dev/null +++ b/ff-game/src/main/java/com/ff/game/api/pp/client/PPClient.java @@ -0,0 +1,117 @@ +package com.ff.game.api.pp.client; + +import com.dtflys.forest.annotation.*; +import com.ff.game.api.jili.dto.JILIGamesDTO; +import com.ff.game.api.pp.address.MyPPAddressSource; +import com.ff.game.api.pp.dto.*; +import com.ff.game.api.xk.dto.XKBetRecordResponseDTO; +import com.ff.game.api.xk.dto.XKGamesDTO; + +import java.util.Map; + +/** + * dg 请求 + * + * @author shi + * @date 2025/02/10 + */ +@Address(source = MyPPAddressSource.class) +public interface PPClient { + /** + * 创建成员 + * + * @param params 参数 + * @param header 头球 + * @return {@link DGResponse } + */ + @Post("/v2/api/signup") + DGResponse createMember(@JSONBody Map params, @Header Map header); + + /** + * 获取会员信息 + * + * @param params 参数 + */ + @Post("/v2/api/balance") + DGUserAccountResponse getMemberInfo(@JSONBody Map params, @Header Map header); + + /** + * 无重定向登录 + * + * @param params 参数 + * @param header 头球 + * @return {@link DGLoginWithoutRedirectResponse } + */ + @Post("/v2/api/login") + DGLoginWithoutRedirectResponse loginWithoutRedirect(@JSONBody Map params, @Header Map header); + + /** + * 获取游戏列表 + * + * @param parameters 参数 + * @return {@link PPGameResponseDTO } + */ + @Post( url ="/getCasinoGames/", + headers = { + "Content-type: application/x-www-form-urlencoded" + }) + + PPGameResponseDTO getGameList(@Body String parameters); + /** + * 按代理id进行交换转账 + * + * @param params 参数 + * @return {@link DGTransactionResponseDTO } + */ + @Post(url = "/v2/api/transfer") + DGTransactionResponseDTO exchangeTransferByAgentId(@JSONBody Map params, @Header Map header); + + /** + * 按时间获取投注记录 + * + * @param params 参数 + * @return {@link XKBetRecordResponseDTO } + */ + @Post(url ="/v2/api/report", + headers = { + "Content-type: application/x-www-form-urlencoded" + }) + DGBetRecordResponseDTO getBetRecordByTime(@Header Map params); + + /** + * 标记报告 + * + * @param params 参数 + * @return {@link DGResponse } + */ + @Post(url = "/v2/api/markReport") + DGResponse markReport(@JSONBody Map params, @Header Map header); + /** + * 踢出队员 + * + * @param params 参数 + * @return {@link DGResponse } + */ + @Post("/v2/api/offline") + DGResponse kickMember(@JSONBody Map params, @Header Map header); + + + @Post("/v2/api/offlineAll") + DGResponse kickMemberAll(@JSONBody Map params, @Header Map header); + + /** + * 会员在线 + * + * @param params 参数 + * @return {@link DGUserListResponseDTO } + */ + @Post(url ="/v2/api/online", + headers = { + "Content-type: application/x-www-form-urlencoded" + }) + DGUserListResponseDTO memberOnlines(@Header Map params); + + + + +} diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGBetRecordResponseDTO.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGBetRecordResponseDTO.java new file mode 100644 index 0000000..2fa59c2 --- /dev/null +++ b/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 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; + } +} diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGLoginWithoutRedirectResponse.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGLoginWithoutRedirectResponse.java new file mode 100644 index 0000000..576a000 --- /dev/null +++ b/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 list; + + /** + * 限制组 + */ + @JsonProperty("limitGroup") + private String limitGroup; + + /** + * 限制区间 + */ + @JsonProperty("limits") + private List limits; + + /** + * 限制区间内部类 + */ + @Data + public static class Limit { + + /** + * 最小值 + */ + @JsonProperty("min") + private int min; + + /** + * 最大值 + */ + @JsonProperty("max") + private int max; + } +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGResponse.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGResponse.java new file mode 100644 index 0000000..d7652d3 --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGTransactionResponseDTO.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGTransactionResponseDTO.java new file mode 100644 index 0000000..195e39e --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserAccountResponse.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserAccountResponse.java new file mode 100644 index 0000000..e5f6506 --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserListResponseDTO.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/DGUserListResponseDTO.java new file mode 100644 index 0000000..13fe63d --- /dev/null +++ b/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 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; + } +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameResponseDTO.java b/ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameResponseDTO.java new file mode 100644 index 0000000..56d46dd --- /dev/null +++ b/ff-game/src/main/java/com/ff/game/api/pp/dto/PPGameResponseDTO.java @@ -0,0 +1,100 @@ +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 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 features; + + /** 游戏数据类型 */ + @JsonProperty("dataType") + private String dataType; + + /** 支持的司法管辖区列表 */ + @JsonProperty("jurisdictions") + private List jurisdictions; + } +} \ No newline at end of file diff --git a/ff-game/src/main/java/com/ff/game/api/pp/impl/GamesPPServiceImpl.java b/ff-game/src/main/java/com/ff/game/api/pp/impl/GamesPPServiceImpl.java new file mode 100644 index 0000000..9548422 --- /dev/null +++ b/ff-game/src/main/java/com/ff/game/api/pp/impl/GamesPPServiceImpl.java @@ -0,0 +1,419 @@ +package com.ff.game.api.pp.impl; + +import cn.hutool.core.util.IdUtil; +import cn.hutool.core.util.NumberUtil; +import com.alibaba.druid.support.json.JSONUtils; +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.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.pp.client.PPClient; +import com.ff.game.api.pp.dto.*; +import com.ff.game.api.request.*; +import com.ff.game.api.xk.dto.XKGamesDTO; +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("PPService") +@Slf4j +public class GamesPPServiceImpl 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 PPClient PPClient; + + + @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(String errorCode) { + 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); + } + + /** + * 创建成员 + * + * @param createMemberRequestDTO 创建成员请求dto + * @return {@link Boolean } + */ + @Override + public Boolean createMember(CreateMemberRequestDTO createMemberRequestDTO) { + log.info("GamesDGServiceImpl [createMember] 请求参数 {}", createMemberRequestDTO); + + //判断是否获取成功 + return Boolean.FALSE; + } + + + /** + * 获取会员信息 + * + * @param memberInfoRequestDTO 会员信息请求dto + * @return {@link MemberInfoResponseDTO } + */ + @Override + public MemberInfoResponseDTO getMemberInfo(MemberInfoRequestDTO memberInfoRequestDTO) { + throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode()); + } + + /** + * 无重定向登录 + * + * @param gamesLogin 游戏登录 + * @return {@link String } + */ + @Override + public String loginWithoutRedirect(GamesLogin gamesLogin) { + throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode()); + } + + + /** + * 获取游戏列表 + * + * @param gamesBaseRequestDTO 游戏请求dto + * @return {@link String } + */ + @Transactional + @Override + public String getGameList(GamesBaseRequestDTO gamesBaseRequestDTO) { + List gamesDatas = redisCache.getCacheList(CacheConstants.PP_GAMES); + if (!CollectionUtils.isEmpty(gamesDatas)) { + return CacheConstants.PP_GAMES; + } + + + Map 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(JSONUtils.toJSONString(params)); + + + return CacheConstants.PP_GAMES; + } + + /** + * 按代理id进行交换转账 + * + * @param exchangeTransferMoneyRequestDTO 外汇转账moeny dto + * @return {@link Long } + */ + @Override + @Transactional + public Long exchangeTransferByAgentId(ExchangeTransferMoneyRequestDTO exchangeTransferMoneyRequestDTO) { + throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode()); + } + + /** + * 汇兑转移状态 + * + * @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) { + throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode()); + + } + + /** + * 按历史时间获取投注记录 + * + * @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) { + throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.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 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 = new ArrayList<>(); + List wagersIds = new ArrayList<>(); + //数据组装 + List report = dgBetRecordResponseDTO.getList(); + //数据转化 + 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 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); + } + } + + } + + /** + * 数据构建 + * + * @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(); + } + Game game = gameService.selectGameById(GAME_ID); + + + //数据构造 + 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.DG.getInfo()) + .gameId(GAME_ID) + .gameName(game.getGameName()) + .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()) + .betContent(resultBean.getBetDetail()) + .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; + } +}