Merge remote-tracking branch 'origin/main' into main-meitian
# Conflicts: # ff-base/src/main/java/com/ff/base/constant/CacheConstants.javamain-meitian
commit
f1aa9d26e7
|
|
@ -51,6 +51,13 @@ public class CacheConstants {
|
|||
*/
|
||||
public static final String XK_GAMES = "xk_games:";
|
||||
|
||||
|
||||
/**
|
||||
* km游戏
|
||||
*/
|
||||
public static final String KM_GAMES = "km_games:";
|
||||
|
||||
|
||||
/**
|
||||
* pgx游戏
|
||||
*/
|
||||
|
|
@ -94,6 +101,12 @@ public class CacheConstants {
|
|||
|
||||
|
||||
public static final String Platform = "platform:";
|
||||
|
||||
/**
|
||||
* km用户令牌
|
||||
*/
|
||||
public static final String KM_USER_TOKEN = "km:user:token:";
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -227,6 +227,17 @@ public class Constants {
|
|||
*/
|
||||
public static final String MEITIAN_API_BASE_URL = "meitian.api.base.url";
|
||||
|
||||
|
||||
/**
|
||||
* km-api基本url
|
||||
*/
|
||||
public static final String KM_API_BASE_URL_LOGIN = "km.api.base.url";
|
||||
/**
|
||||
* km-api基本登录url
|
||||
*/
|
||||
public static final String KM_API_BASE_LOGIN_URL = "km.api.base.login.url";
|
||||
|
||||
|
||||
/**
|
||||
* 服务
|
||||
*/
|
||||
|
|
@ -238,15 +249,12 @@ public class Constants {
|
|||
public static final String SYSTEM = "system";
|
||||
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 主 数据源
|
||||
*/
|
||||
public static final String DATA_SOURCE = "master";
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 租户id
|
||||
*/
|
||||
|
|
@ -300,5 +308,5 @@ public class Constants {
|
|||
/**
|
||||
* 一百
|
||||
*/
|
||||
public static final BigDecimal HUNDRED =new BigDecimal("100") ;
|
||||
public static final BigDecimal HUNDRED = new BigDecimal("100");
|
||||
}
|
||||
|
|
|
|||
|
|
@ -13,6 +13,7 @@ public enum GamePlatforms {
|
|||
DG("DG", "DG"),
|
||||
MT("MT", "美天棋牌"),
|
||||
AE("AE", "AE"),
|
||||
KM("KM", "KM")
|
||||
;
|
||||
|
||||
private final String code;
|
||||
|
|
|
|||
|
|
@ -0,0 +1,70 @@
|
|||
package com.ff.base.enums;
|
||||
|
||||
|
||||
import java.util.Optional;
|
||||
import java.util.stream.Stream;
|
||||
|
||||
|
||||
/**
|
||||
* xkgame类型
|
||||
*
|
||||
* @author shi
|
||||
* @date 2024/11/13
|
||||
*/
|
||||
public enum KMGameType {
|
||||
|
||||
ELECTRON("KMQM", 1,"电子")
|
||||
|
||||
;
|
||||
|
||||
private final String code;
|
||||
private final Integer systemCode;
|
||||
private final String info;
|
||||
KMGameType(String code, Integer systemCode, String info)
|
||||
{
|
||||
this.code = code;
|
||||
this.systemCode = systemCode;
|
||||
this.info = info;
|
||||
}
|
||||
|
||||
public String getCode()
|
||||
{
|
||||
return code;
|
||||
}
|
||||
|
||||
public Integer getSystemCode()
|
||||
{
|
||||
return systemCode;
|
||||
}
|
||||
public String getInfo()
|
||||
{
|
||||
return info;
|
||||
}
|
||||
/**
|
||||
* 按代码查找系统
|
||||
*
|
||||
* @param code 代码
|
||||
* @return {@link String }
|
||||
*/
|
||||
public static Integer findSystemByCode(String code) {
|
||||
Optional<Integer> system = Stream.of(KMGameType.values())
|
||||
.filter(gameType -> gameType.getCode().equals(code))
|
||||
.map(KMGameType::getSystemCode)
|
||||
.findFirst();
|
||||
return system.orElse(null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 按代码查找信息
|
||||
*
|
||||
* @param code 代码
|
||||
* @return {@link String }
|
||||
*/
|
||||
public static String findInfoByCode(String code) {
|
||||
Optional<String> system = Stream.of(KMGameType.values())
|
||||
.filter(gameType -> gameType.getCode().equals(code))
|
||||
.map(KMGameType::getInfo)
|
||||
.findFirst();
|
||||
return system.orElse(null);
|
||||
}
|
||||
}
|
||||
|
|
@ -108,7 +108,7 @@ public class JsonUtil {
|
|||
*
|
||||
* @param map 地图
|
||||
* @return {@link String }
|
||||
*/// 将LinkedHashMap转换为查询字符串
|
||||
*/ // 将LinkedHashMap转换为查询字符串
|
||||
public static String mapToQueryString(Map<String, Object> map) {
|
||||
return map.entrySet().stream()
|
||||
.map(entry -> entry.getKey() + "=" + entry.getValue())
|
||||
|
|
|
|||
|
|
@ -422,7 +422,6 @@ public class ApiGameController extends BaseController {
|
|||
ApiException.notNull(iGamesService, ErrorCode.PLATFORM_NOT_EXIST.getCode());
|
||||
|
||||
|
||||
|
||||
KickMemberAllDTO kickMemberAllDTO = KickMemberAllDTO.builder()
|
||||
.agentId(gameSecretKey.getCode())
|
||||
.agentKey(gameSecretKey.getKey())
|
||||
|
|
@ -589,4 +588,43 @@ public class ApiGameController extends BaseController {
|
|||
|
||||
return AjaxResult.success(balanceMap);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequest 游戏演示登录请求
|
||||
* @return {@link AjaxResult }
|
||||
*/
|
||||
@PostMapping("/demo/login")
|
||||
public AjaxResult demoLogin(@Validated @RequestBody GameDemoLoginRequest gameDemoLoginRequest) {
|
||||
|
||||
Game game = gameService.selectGameById(gameDemoLoginRequest.getGameId());
|
||||
ApiException.notNull(game, ErrorCode.GAME_NOT_EXIST.getCode());
|
||||
|
||||
GamePlatform gamePlatform = gamePlatformService.selectGamePlatformById(game.getPlatformId());
|
||||
ApiException.notNull(gamePlatform, ErrorCode.PLATFORM_NOT_EXIST.getCode());
|
||||
|
||||
|
||||
IGamesService iGamesService = gamesService.get(gamePlatform.getPlatformCode() + Constants.SERVICE);
|
||||
|
||||
|
||||
GameSecretKeyLangDTO gameSecretKeyLangDTO = gameSecretKeyLangService.findGameSecretKeyLangDTO(GameSecretKeyLangDTO.builder()
|
||||
.platformCode(gamePlatform.getPlatformCode())
|
||||
.systemLangCode(gameDemoLoginRequest.getLangCode())
|
||||
.build());
|
||||
ApiException.notNull(gameSecretKeyLangDTO, ErrorCode.LANG_NOT_EXIST.getCode());
|
||||
|
||||
|
||||
GameDemoLoginRequestDTO gamesLogin = GameDemoLoginRequestDTO.builder()
|
||||
.gameId(game.getGameCode())
|
||||
.gameType(game.getGameSourceType())
|
||||
.lang(gameSecretKeyLangDTO.getLang())
|
||||
.build();
|
||||
|
||||
GameDemoLoginResponseDTO gameDemoLoginResponseDTO = iGamesService.gameDemoLogin(gamesLogin);
|
||||
GameDemoLoginResponse gameDemoLoginResponse = new GameDemoLoginResponse();
|
||||
BeanUtils.copyProperties(gameDemoLoginResponseDTO, gameDemoLoginResponse);
|
||||
return AjaxResult.success(gameDemoLoginResponse);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -133,6 +133,7 @@ public class ApiMemberController extends BaseController {
|
|||
.agentId(gameSecretKey.getCode())
|
||||
.agentKey(gameSecretKey.getKey())
|
||||
.betLimit(memberCreateApiRequest.getBetLimit())
|
||||
.platformType(memberCreateApiRequest.getPlatformType())
|
||||
.currency(gameSecretKey.getCurrency())
|
||||
.build();
|
||||
Boolean result = iGamesService.createMember(gamesBaseRequestDTO);
|
||||
|
|
|
|||
|
|
@ -0,0 +1,53 @@
|
|||
package com.ff.api.request;
|
||||
|
||||
import lombok.Data;
|
||||
import org.hibernate.validator.constraints.Length;
|
||||
|
||||
import javax.validation.constraints.NotBlank;
|
||||
import javax.validation.constraints.NotNull;
|
||||
import java.io.Serializable;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 游戏登录请求
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/02/11
|
||||
*/
|
||||
@Data
|
||||
public class GameDemoLoginRequest implements Serializable {
|
||||
private final static long serialVersionUID = 7699430372422335056L;
|
||||
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 语种id
|
||||
*/
|
||||
@NotBlank(message = "langCode不能为空")
|
||||
@Length(max = 32, message = "langCode长度不能超过32个字符")
|
||||
private String langCode;
|
||||
|
||||
|
||||
/**
|
||||
* 游戏id
|
||||
*/
|
||||
@NotNull(message = "gameId不能为空")
|
||||
private Long gameId;
|
||||
|
||||
|
||||
/**
|
||||
* 游戏回主页功能导向位置
|
||||
*/
|
||||
private String homeUrl;
|
||||
/**
|
||||
* 带入 web 或是 app
|
||||
*/
|
||||
private String platform;
|
||||
/**
|
||||
* 带入 1 即关闭全屏幕模式
|
||||
*/
|
||||
private Integer disableFullScreen;
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -40,4 +40,8 @@ public class MemberCreateApiRequest implements Serializable{
|
|||
*/
|
||||
private Map<String, Map<String, Map<String, Object>>> betLimit;
|
||||
|
||||
/**
|
||||
* 平台类型 0 桌面 1 移动
|
||||
*/
|
||||
private Integer platformType;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,28 @@
|
|||
package com.ff.api.response;
|
||||
|
||||
import lombok.Data;
|
||||
import org.hibernate.validator.constraints.Length;
|
||||
|
||||
import javax.validation.constraints.NotBlank;
|
||||
import javax.validation.constraints.NotNull;
|
||||
import java.io.Serializable;
|
||||
|
||||
|
||||
/**
|
||||
* 游戏演示登录响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/03
|
||||
*/
|
||||
@Data
|
||||
public class GameDemoLoginResponse implements Serializable {
|
||||
private final static long serialVersionUID = 7699430372422335056L;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 网址
|
||||
*/
|
||||
private String url;
|
||||
|
||||
}
|
||||
|
|
@ -96,6 +96,8 @@ public interface IGamesService {
|
|||
*/
|
||||
Boolean createFreeSpin(CreateFreeSpinRequestDTO createFreeSpinRequest);
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 获取游戏详细信息
|
||||
*
|
||||
|
|
@ -136,6 +138,13 @@ public interface IGamesService {
|
|||
*/
|
||||
Boolean cancelFreeSpin(CancelFreeSpinRequestDTO cancelFreeSpinRequestDTO);
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO);
|
||||
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -531,6 +531,17 @@ public class GamesAEServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 批量插入
|
||||
|
|
|
|||
|
|
@ -501,6 +501,19 @@ public class GamesDGServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 取消赠送免费局数
|
||||
*
|
||||
|
|
|
|||
|
|
@ -610,6 +610,17 @@ public class GamesFCServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 数据构建
|
||||
|
|
|
|||
|
|
@ -692,6 +692,17 @@ public class GamesJILIServiceImpl implements IGamesService {
|
|||
throw new BaseException(cancelFreeSpinResponseDTO.getMessage());
|
||||
}
|
||||
}
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -0,0 +1,31 @@
|
|||
package com.ff.game.api.km.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 MyKMAddressSource implements AddressSource {
|
||||
|
||||
@Resource
|
||||
private ISysConfigService configService;
|
||||
|
||||
|
||||
@Override
|
||||
public ForestAddress getAddress(ForestRequest request) {
|
||||
String apiBaseUrl = configService.selectConfigByKey(Constants.KM_API_BASE_URL_LOGIN);
|
||||
return new ForestAddress("https",apiBaseUrl, 443,"api");
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,95 @@
|
|||
package com.ff.game.api.km.client;
|
||||
|
||||
|
||||
import com.dtflys.forest.annotation.*;
|
||||
import com.ff.game.api.dg.dto.DGBetRecordResponseDTO;
|
||||
import com.ff.game.api.dg.dto.DGResponse;
|
||||
import com.ff.game.api.dg.dto.DGUserListResponseDTO;
|
||||
import com.ff.game.api.km.address.MyKMAddressSource;
|
||||
import com.ff.game.api.km.dto.*;
|
||||
import com.ff.game.api.km.success.MyKMSuccessCondition;
|
||||
import com.ff.game.api.xk.dto.XKBetRecordResponseDTO;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* dg 请求
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/02/10
|
||||
*/
|
||||
@Address(source = MyKMAddressSource.class)
|
||||
@Success(condition = MyKMSuccessCondition.class)
|
||||
public interface KMClient {
|
||||
/**
|
||||
* 创建成员
|
||||
*
|
||||
* @param params 参数
|
||||
* @param header 头球
|
||||
* @return {@link DGResponse }
|
||||
*/
|
||||
@Post("/player/authorize")
|
||||
KMAuthTokenResponse createMember(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
|
||||
|
||||
/**
|
||||
* 获取会员信息
|
||||
*
|
||||
* @param params 参数
|
||||
*/
|
||||
@Get("/player/balance?{params}")
|
||||
KMBalanceResponse getMemberInfo(@Var("params") String params, @Header Map<String, Object> header);
|
||||
|
||||
|
||||
/**
|
||||
* 游戏
|
||||
*
|
||||
* @param params 参数
|
||||
* @param header 头球
|
||||
* @return {@link KMGameResponse }
|
||||
*/
|
||||
@Get("/games?{params}")
|
||||
KMGameResponse getGameList(@Var("params") String params, @Header Map<String, Object> header);
|
||||
|
||||
|
||||
/**
|
||||
* 加钱
|
||||
*
|
||||
* @param params 参数
|
||||
* @param header 头球
|
||||
* @return {@link KMTransactionResponse }
|
||||
*/
|
||||
@Post(url = "/wallet/credit")
|
||||
KMTransactionResponse credit(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
|
||||
|
||||
|
||||
/**
|
||||
* 扣钱
|
||||
*
|
||||
* @param params 参数
|
||||
* @param header 头球
|
||||
* @return {@link KMTransactionResponse }
|
||||
*/
|
||||
@Post(url = "/wallet/debit")
|
||||
KMTransactionResponse debit(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
|
||||
|
||||
/**
|
||||
* 按时间获取投注记录
|
||||
*
|
||||
* @param params 参数
|
||||
* @return {@link KMBetRecordResponse }
|
||||
*/
|
||||
@Get(url ="/v2/history/bets?{params}")
|
||||
KMBetRecordResponse getBetRecordByTime(@Var("params")String params, @Header Map<String, Object> header);
|
||||
|
||||
|
||||
/**
|
||||
* 踢腿队员
|
||||
*
|
||||
* @param params 参数
|
||||
* @param header 头球
|
||||
* @return {@link KMKickMemberResponse }
|
||||
*/
|
||||
@Post(url = "/player/deauthorize")
|
||||
KMKickMemberResponse kickMember(@JSONBody Map<String, Object> params, @Header Map<String, Object> header);
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,37 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* kmaust令牌响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/02
|
||||
*/
|
||||
@Data
|
||||
public class KMAuthTokenResponse {
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
/**
|
||||
* 身份验证令牌
|
||||
*/
|
||||
@JsonProperty("authtoken")
|
||||
private String authToken;
|
||||
|
||||
/**
|
||||
* 是否为新用户
|
||||
*/
|
||||
@JsonProperty("isnew")
|
||||
private Boolean isNew;
|
||||
}
|
||||
|
|
@ -0,0 +1,38 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
|
||||
/**
|
||||
* km平衡响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/02
|
||||
*/
|
||||
@Data
|
||||
public class KMBalanceResponse {
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
/**
|
||||
* 余额
|
||||
*/
|
||||
@JsonProperty("bal")
|
||||
private BigDecimal balance;
|
||||
|
||||
/**
|
||||
* 货币代码
|
||||
*/
|
||||
@JsonProperty("cur")
|
||||
private String currency;
|
||||
}
|
||||
|
|
@ -0,0 +1,145 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* kmbet记录响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/02
|
||||
*/
|
||||
@Data
|
||||
public class KMBetRecordResponse {
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
|
||||
/**
|
||||
* bets 包含下列字段的对象数组容器。
|
||||
*/
|
||||
@JsonProperty("bets")
|
||||
private List<Bet> bets;
|
||||
|
||||
@Data
|
||||
public static class Bet {
|
||||
|
||||
/**
|
||||
* KM内部投注辨识码。此字段是唯一的标识符。
|
||||
*/
|
||||
@JsonProperty("id")
|
||||
private String id;
|
||||
|
||||
/**
|
||||
* 记录在KM服务器的投注时间，采用ISO 8601格式。
|
||||
*/
|
||||
@JsonProperty("beton")
|
||||
private Date beton; // 使用 Date 类型来表示 ISO 8601 格式的时间
|
||||
|
||||
/**
|
||||
* 投注关闭的时间，采用ISO 8601格式。如果回合尚未结束，则为null。
|
||||
*/
|
||||
@JsonProperty("closedon")
|
||||
private Date closedon; // 使用 Date 类型来表示 ISO 8601 格式的时间
|
||||
|
||||
/**
|
||||
* 交易回合的唯一辨识代码。
|
||||
*/
|
||||
@JsonProperty("roundid")
|
||||
private String roundId;
|
||||
|
||||
/**
|
||||
* 游戏交易执行回合时的游戏供应商辨识码。
|
||||
*/
|
||||
@JsonProperty("externalroundid")
|
||||
private String externalRoundId;
|
||||
|
||||
/**
|
||||
* 游戏供应商代码，例如 "KMQM"。
|
||||
*/
|
||||
@JsonProperty("gpcode")
|
||||
private String gpCode;
|
||||
|
||||
/**
|
||||
* 游戏代码。
|
||||
*/
|
||||
@JsonProperty("gcode")
|
||||
private String gCode;
|
||||
|
||||
/**
|
||||
* 游戏平台的类型。
|
||||
*/
|
||||
@JsonProperty("platformtype")
|
||||
private Integer platformType;
|
||||
|
||||
/**
|
||||
* 玩家专属辨识代码。
|
||||
*/
|
||||
@JsonProperty("userid")
|
||||
private String userId;
|
||||
|
||||
/**
|
||||
* 玩家在KM系统使用的货币。
|
||||
*/
|
||||
@JsonProperty("cur")
|
||||
private String currency;
|
||||
|
||||
/**
|
||||
* 投注的总金额，为负数表示从账户扣款。
|
||||
*/
|
||||
@JsonProperty("riskamt")
|
||||
private BigDecimal riskAmount;
|
||||
|
||||
/**
|
||||
* 投注赢的金额，若玩家赢得金额则为正数，若没有输赢则为0。
|
||||
*/
|
||||
@JsonProperty("winamt")
|
||||
private BigDecimal winAmount;
|
||||
|
||||
/**
|
||||
* 回合中所有投注的有效投注总金额。
|
||||
*/
|
||||
@JsonProperty("validbet")
|
||||
private BigDecimal validBet;
|
||||
|
||||
/**
|
||||
* 下注玩家的佣金金额。
|
||||
*/
|
||||
@JsonProperty("commission")
|
||||
private BigDecimal commission;
|
||||
|
||||
/**
|
||||
* 累积奖金对象，包含贡献金额和中奖金额。若没有配置累积奖金，则为null。
|
||||
*/
|
||||
@JsonProperty("jackpot")
|
||||
private Jackpot jackpot;
|
||||
|
||||
@Data
|
||||
public static class Jackpot {
|
||||
|
||||
/**
|
||||
* 贡献到累积奖金的金额。
|
||||
*/
|
||||
@JsonProperty("contrib")
|
||||
private BigDecimal contrib;
|
||||
|
||||
/**
|
||||
* 本注的累积奖金赢取金额。
|
||||
*/
|
||||
@JsonProperty("winamt")
|
||||
private BigDecimal winAmount;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,130 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* kmgame响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/02
|
||||
*/
|
||||
@Data
|
||||
public class KMGameResponse {
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
/**
|
||||
* 游戏图标解析度
|
||||
*/
|
||||
@JsonProperty("iconres")
|
||||
private List<String> iconResolutions;
|
||||
|
||||
/**
|
||||
* 游戏数组，包含具体的游戏信息
|
||||
*/
|
||||
@JsonProperty("games")
|
||||
private List<Game> games;
|
||||
|
||||
@Data
|
||||
public static class Game {
|
||||
|
||||
/**
|
||||
* 游戏供应商游戏专属辨识代码
|
||||
*/
|
||||
@JsonProperty("externalid")
|
||||
private String externalId;
|
||||
|
||||
/**
|
||||
* 游戏代码
|
||||
*/
|
||||
@JsonProperty("code")
|
||||
private String code;
|
||||
|
||||
/**
|
||||
* 游戏名称
|
||||
*/
|
||||
@JsonProperty("name")
|
||||
private String name;
|
||||
|
||||
/**
|
||||
* 游戏说明
|
||||
*/
|
||||
@JsonProperty("description")
|
||||
private String description;
|
||||
|
||||
/**
|
||||
* 游戏供应商代码
|
||||
*/
|
||||
@JsonProperty("providercode")
|
||||
private String providerCode;
|
||||
|
||||
/**
|
||||
* 游戏的状态
|
||||
*/
|
||||
@JsonProperty("isactive")
|
||||
private Boolean isActive;
|
||||
|
||||
/**
|
||||
* 游戏种类代码
|
||||
*/
|
||||
@JsonProperty("type")
|
||||
private Integer type;
|
||||
|
||||
/**
|
||||
* 游戏图标 URL（此字段不可用）
|
||||
*/
|
||||
@JsonProperty("iconurl")
|
||||
private String iconUrl;
|
||||
|
||||
/**
|
||||
* 系统游戏id
|
||||
*/
|
||||
private Long systemGameId;
|
||||
|
||||
/**
|
||||
* 游戏是否提供试玩
|
||||
*/
|
||||
@JsonProperty("supportdemourl")
|
||||
private Boolean supportDemoUrl;
|
||||
|
||||
/**
|
||||
* 投注限额数组（如果有的话）
|
||||
*/
|
||||
@JsonProperty("betlimits")
|
||||
private List<BetLimit> betLimits;
|
||||
|
||||
@Data
|
||||
public static class BetLimit {
|
||||
|
||||
/**
|
||||
* 游戏供应商的投注限制辨识码
|
||||
*/
|
||||
@JsonProperty("id")
|
||||
private String id;
|
||||
|
||||
/**
|
||||
* 最小投注金额
|
||||
*/
|
||||
@JsonProperty("min")
|
||||
private BigDecimal min;
|
||||
|
||||
/**
|
||||
* 最大投注金额
|
||||
*/
|
||||
@JsonProperty("max")
|
||||
private BigDecimal max;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,37 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* kmkick成员响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/03
|
||||
*/
|
||||
@Data
|
||||
public class KMKickMemberResponse {
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
|
||||
/**
|
||||
* 成功标志，true 表示操作成功，false 表示操作失败
|
||||
*/
|
||||
@JsonProperty("success")
|
||||
private boolean success;
|
||||
|
||||
/**
|
||||
* 描述信息
|
||||
*/
|
||||
@JsonProperty("desc")
|
||||
private String description;
|
||||
}
|
||||
|
|
@ -0,0 +1,59 @@
|
|||
package com.ff.game.api.km.dto;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
|
||||
/**
|
||||
* km事务响应
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/02
|
||||
*/
|
||||
@Data
|
||||
public class KMTransactionResponse {
|
||||
|
||||
/**
|
||||
* 错误代码
|
||||
*/
|
||||
@JsonProperty("err")
|
||||
private Integer errorCode;
|
||||
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
@JsonProperty("errdesc")
|
||||
private String errorDescription;
|
||||
|
||||
/**
|
||||
* 余额
|
||||
*/
|
||||
@JsonProperty("bal")
|
||||
private BigDecimal balance;
|
||||
|
||||
/**
|
||||
* 货币类型
|
||||
*/
|
||||
@JsonProperty("cur")
|
||||
private String currency;
|
||||
|
||||
/**
|
||||
* 交易 ID
|
||||
*/
|
||||
@JsonProperty("txid")
|
||||
private String txId;
|
||||
|
||||
/**
|
||||
* 平台交易 ID
|
||||
*/
|
||||
@JsonProperty("ptxid")
|
||||
private String ptxId;
|
||||
|
||||
/**
|
||||
* 是否为重复交易
|
||||
*/
|
||||
@JsonProperty("dup")
|
||||
private Boolean isDuplicate;
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,733 @@
|
|||
package com.ff.game.api.km.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.ConfigConstants;
|
||||
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.ip.IpUtils;
|
||||
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.dto.DGBetRecordResponseDTO;
|
||||
import com.ff.game.api.dg.dto.DGResponse;
|
||||
import com.ff.game.api.dg.dto.DGUserListResponseDTO;
|
||||
import com.ff.game.api.jili.dto.JILIGamesDataDTO;
|
||||
import com.ff.game.api.km.client.KMClient;
|
||||
import com.ff.game.api.km.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.net.URLEncoder;
|
||||
import java.util.*;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
|
||||
/**
|
||||
* DG 游戏 impl
|
||||
*
|
||||
* @author shi
|
||||
* @date 2024/11/12
|
||||
*/
|
||||
@Service("KMService")
|
||||
@Slf4j
|
||||
public class GamesKMServiceImpl 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 KMClient KMClient;
|
||||
|
||||
|
||||
@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) {
|
||||
return 200 == errorCode;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取密钥
|
||||
*
|
||||
* @param gamesBaseRequestDTO 游戏请求dto
|
||||
* @return {@link String }
|
||||
*/
|
||||
private Map<String, Object> getKey(GamesBaseRequestDTO gamesBaseRequestDTO) {
|
||||
|
||||
//取出对应的key跟密钥跟请求参数
|
||||
String agentKey = gamesBaseRequestDTO.getAgentKey();
|
||||
String agentId = gamesBaseRequestDTO.getAgentId();
|
||||
|
||||
Map<String, Object> keyMap = new HashMap<>();
|
||||
keyMap.put("X-QM-ClientId", agentId);
|
||||
keyMap.put("X-QM-ClientSecret", agentKey);
|
||||
return keyMap;
|
||||
}
|
||||
|
||||
/**
|
||||
* 创建成员
|
||||
*
|
||||
* @param createMemberRequestDTO 创建成员请求dto
|
||||
* @return {@link Boolean }
|
||||
*/
|
||||
@Override
|
||||
public Boolean createMember(CreateMemberRequestDTO createMemberRequestDTO) {
|
||||
log.info("GamesKMServiceImpl [createMember] 请求参数 {}", createMemberRequestDTO);
|
||||
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("ipaddress", IpUtils.getHostIp());
|
||||
params.put("username", createMemberRequestDTO.getAccount());
|
||||
params.put("userid", createMemberRequestDTO.getAccount());
|
||||
params.put("lang", "en-US");
|
||||
params.put("cur", createMemberRequestDTO.getCurrency());
|
||||
/* 1 青铜-基本额度
|
||||
2 白银-升级额度
|
||||
3 黄金-高级额度
|
||||
4 白金-贵宾额度*/
|
||||
params.put("betlimitid", 4);
|
||||
//TODO 后面去掉
|
||||
params.put("istestplayer", Boolean.TRUE);
|
||||
params.put("platformtype", ObjectUtils.isEmpty(createMemberRequestDTO.getPlatformType()) ? 1 : createMemberRequestDTO.getPlatformType());
|
||||
|
||||
Map<String, Object> headerMap = this.getKey(createMemberRequestDTO);
|
||||
KMAuthTokenResponse member = KMClient.createMember(params, headerMap);
|
||||
if (ObjectUtils.isEmpty(member.getErrorCode()) || this.getIsSuccess(member.getErrorCode())) {
|
||||
redisCache.setCacheObject(CacheConstants.KM_USER_TOKEN + createMemberRequestDTO.getAccount(), member.getAuthToken());
|
||||
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<>();
|
||||
Member member = memberService.selectMemberByGameAccount(memberInfoRequestDTO.getAccounts());
|
||||
GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||
.platformCode(GamePlatforms.KM.getInfo())
|
||||
.currency(member.getCurrencyCode())
|
||||
.build());
|
||||
|
||||
paramsMap.put("userid", memberInfoRequestDTO.getAccounts());
|
||||
paramsMap.put("cur", currencyDTO.getCurrency());
|
||||
Map<String, Object> headerMap = this.getKey(memberInfoRequestDTO);
|
||||
KMBalanceResponse memberInfo = KMClient.getMemberInfo(JsonUtil.mapToQueryString(paramsMap), headerMap);
|
||||
if (ObjectUtils.isEmpty(memberInfo.getErrorCode()) || this.getIsSuccess(memberInfo.getErrorCode())) {
|
||||
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("GamesKMServiceImpl [loginWithoutRedirect] 请求参数 {}", gamesLogin);
|
||||
String kmUserToken = redisCache.getCacheObject(CacheConstants.KM_USER_TOKEN + gamesLogin.getAccount());
|
||||
if (StringUtils.isEmpty(kmUserToken)) {
|
||||
Member member = memberService.selectMemberByGameAccount(gamesLogin.getAccount());
|
||||
GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||
.platformCode(GamePlatforms.KM.getInfo())
|
||||
.currency(member.getCurrencyCode())
|
||||
.build());
|
||||
|
||||
CreateMemberRequestDTO gamesBaseRequestDTO = CreateMemberRequestDTO.builder()
|
||||
.account(gamesLogin.getAccount())
|
||||
.agentId(gamesLogin.getAgentId())
|
||||
.agentKey(gamesLogin.getAgentKey())
|
||||
.currency(currencyDTO.getCurrency())
|
||||
.build();
|
||||
this.createMember(gamesBaseRequestDTO);
|
||||
kmUserToken = redisCache.getCacheObject(CacheConstants.KM_USER_TOKEN + gamesLogin.getAccount());
|
||||
}
|
||||
|
||||
|
||||
String selectConfigByKey = configService.selectConfigByKey(Constants.KM_API_BASE_LOGIN_URL);
|
||||
|
||||
return selectConfigByKey + "/gamelauncher?gpcode=" + gamesLogin.getGameType()
|
||||
+ "&gcode=" + gamesLogin.getGameId()
|
||||
+ "&token=" + kmUserToken
|
||||
+ "&lang=" + gamesLogin.getLang();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取游戏列表
|
||||
*
|
||||
* @param gamesBaseRequestDTO 游戏请求dto
|
||||
* @return {@link String }
|
||||
*/
|
||||
@Transactional
|
||||
@Override
|
||||
public String getGameList(GamesBaseRequestDTO gamesBaseRequestDTO) {
|
||||
|
||||
List<XKGamesDTO.DataBean> gamesDatas = redisCache.getCacheList(CacheConstants.KM_GAMES);
|
||||
if (!CollectionUtils.isEmpty(gamesDatas)) {
|
||||
return CacheConstants.KM_GAMES;
|
||||
}
|
||||
|
||||
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("lang", "zh-CN");
|
||||
params.put("platformtype", 1);
|
||||
Map<String, Object> headerMap = this.getKey(gamesBaseRequestDTO);
|
||||
KMGameResponse gameMobiles = KMClient.getGameList(JsonUtil.mapToQueryString(params), headerMap);
|
||||
//判断是否获取成功
|
||||
List<KMGameResponse.Game> gameListData = new ArrayList<>();
|
||||
if (ObjectUtils.isEmpty(gameMobiles.getErrorCode()) || this.getIsSuccess(gameMobiles.getErrorCode())) {
|
||||
gameListData.addAll(this.gameList(gameMobiles, IngressType.MOBILE_WEB.getValue()));
|
||||
|
||||
} else {
|
||||
throw new BaseException(gameMobiles.getErrorDescription());
|
||||
|
||||
}
|
||||
params = new LinkedHashMap<>();
|
||||
params.put("lang", "zh-CN");
|
||||
params.put("platformtype", 0);
|
||||
KMGameResponse gamePCs = KMClient.getGameList(JsonUtil.mapToQueryString(params), headerMap);
|
||||
//判断是否获取成功
|
||||
if (ObjectUtils.isEmpty(gamePCs.getErrorCode()) || this.getIsSuccess(gamePCs.getErrorCode())) {
|
||||
gameListData.addAll(this.gameList(gamePCs, IngressType.PC_WEB.getValue()));
|
||||
|
||||
} else {
|
||||
throw new BaseException(gamePCs.getErrorDescription());
|
||||
}
|
||||
// 使用集合操作来找出相同 code 的对象
|
||||
List<KMGameResponse.Game> games = gameMobiles.getGames().stream()
|
||||
.filter(mobile -> gamePCs.getGames().stream()
|
||||
.anyMatch(pc -> pc.getCode().equals(mobile.getCode())))
|
||||
.collect(Collectors.toList());
|
||||
for (KMGameResponse.Game game : games) {
|
||||
GamePlatform gamePlatform = GamePlatform.builder()
|
||||
.platformType(KMGameType.findSystemByCode(game.getProviderCode()))
|
||||
.platformCode(GamePlatforms.KM.getCode())
|
||||
.build();
|
||||
List<GamePlatform> gamePlatforms = gamePlatformService.selectGamePlatformList(gamePlatform);
|
||||
//没有此平台就新增一个平台
|
||||
if (CollectionUtils.isEmpty(gamePlatforms)) {
|
||||
gamePlatform.setPlatformName(GamePlatforms.KM.getInfo() + KMGameType.findInfoByCode(game.getProviderCode()));
|
||||
gamePlatform.setSortNo(gamePlatformService.selectMaxSortNo() + 1);
|
||||
gamePlatform.setCreateBy(Constants.SYSTEM);
|
||||
gamePlatformService.insertGamePlatform(gamePlatform);
|
||||
} else {
|
||||
gamePlatform = gamePlatforms.get(0);
|
||||
}
|
||||
Game gameOne = Game.builder()
|
||||
.platformId(gamePlatform.getId())
|
||||
.gameCode(game.getCode())
|
||||
.build();
|
||||
List<Game> gameOnes = gameService.selectGameList(gameOne);
|
||||
for (Game one : gameOnes) {
|
||||
one.setIngress(IngressType.PC_AND_MOBILE_WEB.getValue());
|
||||
gameService.updateGame(one);
|
||||
}
|
||||
}
|
||||
|
||||
redisCache.deleteObject(CacheConstants.KM_GAMES);
|
||||
redisCache.setCacheList(CacheConstants.KM_GAMES, gameListData);
|
||||
redisCache.expire(CacheConstants.KM_GAMES, 5L, TimeUnit.HOURS);
|
||||
return CacheConstants.KM_GAMES;
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏列表
|
||||
*
|
||||
* @param gameList 游戏列表
|
||||
* @param ingress 进入
|
||||
* @return {@link List }<{@link KMGameResponse.Game }>
|
||||
*/
|
||||
private List<KMGameResponse.Game> gameList(KMGameResponse gameList, Integer ingress) {
|
||||
for (KMGameResponse.Game gamesDataDTO : gameList.getGames()) {
|
||||
GamePlatform gamePlatform = GamePlatform.builder()
|
||||
.platformType(KMGameType.findSystemByCode(gamesDataDTO.getProviderCode()))
|
||||
.platformCode(GamePlatforms.KM.getCode())
|
||||
.build();
|
||||
List<GamePlatform> gamePlatforms = gamePlatformService.selectGamePlatformList(gamePlatform);
|
||||
//没有此平台就新增一个平台
|
||||
if (CollectionUtils.isEmpty(gamePlatforms)) {
|
||||
gamePlatform.setPlatformName(GamePlatforms.KM.getInfo() + KMGameType.findInfoByCode(gamesDataDTO.getProviderCode()));
|
||||
gamePlatform.setSortNo(gamePlatformService.selectMaxSortNo() + 1);
|
||||
gamePlatform.setCreateBy(Constants.SYSTEM);
|
||||
gamePlatformService.insertGamePlatform(gamePlatform);
|
||||
} else {
|
||||
gamePlatform = gamePlatforms.get(0);
|
||||
}
|
||||
Game game = Game.builder()
|
||||
.platformId(gamePlatform.getId())
|
||||
.gameCode(gamesDataDTO.getCode())
|
||||
.build();
|
||||
List<Game> games = gameService.selectGameList(game);
|
||||
//不存在这个游戏
|
||||
if (CollectionUtils.isEmpty(games)) {
|
||||
game.setGameSourceType(gamesDataDTO.getProviderCode());
|
||||
game.setFreespin(Boolean.FALSE);
|
||||
game.setDemoStatus(gamesDataDTO.getSupportDemoUrl());
|
||||
game.setSortNo(gameService.selectMaxSortNoByPlatformId(gamePlatform.getId()) + 1);
|
||||
game.setGameName(gamesDataDTO.getName());
|
||||
game.setCreateBy(Constants.SYSTEM);
|
||||
game.setIngress(ingress);
|
||||
gameService.insertGame(game);
|
||||
} else {
|
||||
game = games.get(0);
|
||||
}
|
||||
gamesDataDTO.setSystemGameId(game.getId());
|
||||
List<GameName> gameNames = gameNameService.selectGameNameList(GameName.builder().gameId(game.getId()).gameName(game.getGameName()).build());
|
||||
if (CollectionUtils.isEmpty(gameNames)) {
|
||||
gameNameService.insertGameName(GameName.builder()
|
||||
.gameId(game.getId())
|
||||
.gameName(game.getGameName())
|
||||
.langCode("zh-CN")
|
||||
.createBy(Constants.SYSTEM)
|
||||
.build());
|
||||
}
|
||||
|
||||
}
|
||||
return gameList.getGames();
|
||||
}
|
||||
|
||||
/**
|
||||
* 按代理id进行交换转账
|
||||
*
|
||||
* @param exchangeTransferMoneyRequestDTO 外汇转账moeny dto
|
||||
* @return {@link Long }
|
||||
*/
|
||||
@Override
|
||||
@Transactional
|
||||
public Long exchangeTransferByAgentId(ExchangeTransferMoneyRequestDTO exchangeTransferMoneyRequestDTO) {
|
||||
log.info("GamesKMServiceImpl [exchangeTransferByAgentId] 请求参数 {}", exchangeTransferMoneyRequestDTO);
|
||||
GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||
.platformCode(GamePlatforms.KM.getInfo())
|
||||
.currency(exchangeTransferMoneyRequestDTO.getCurrency())
|
||||
.build());
|
||||
|
||||
Member member = memberService.selectMemberByGameAccount(exchangeTransferMoneyRequestDTO.getAccount());
|
||||
String transactionId = GamePlatforms.KM.getInfo() + 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.KM.getInfo())
|
||||
.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();
|
||||
|
||||
amount = this.getMemberInfo(gamesBaseRequestDTO).getBalance();
|
||||
}
|
||||
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("userid", exchangeTransferMoneyRequestDTO.getAccount());
|
||||
params.put("amt", amount);
|
||||
params.put("cur", currencyDTO.getCurrency());
|
||||
params.put("txid", transactionId);
|
||||
|
||||
Map<String, Object> headerMap = this.getKey(exchangeTransferMoneyRequestDTO);
|
||||
KMTransactionResponse kmTransactionResponse;
|
||||
if (TransferType.ALL.getCode().equals(exchangeTransferMoneyRequestDTO.getTransferType())) {
|
||||
kmTransactionResponse = KMClient.debit(params, headerMap);
|
||||
} else {
|
||||
kmTransactionResponse = KMClient.credit(params, headerMap);
|
||||
}
|
||||
|
||||
//判断是否转移成功
|
||||
if (ObjectUtils.isEmpty(kmTransactionResponse.getErrorCode()) || this.getIsSuccess(kmTransactionResponse.getErrorCode())) {
|
||||
|
||||
//更新数据
|
||||
exchangeMoney.setBalance(amount);
|
||||
exchangeMoney.setCoinBefore(NumberUtil.sub(amount, kmTransactionResponse.getBalance()).abs());
|
||||
exchangeMoney.setCoinAfter(kmTransactionResponse.getBalance());
|
||||
exchangeMoney.setCurrencyBefore(exchangeMoney.getCoinBefore());
|
||||
exchangeMoney.setCurrencyAfter(exchangeMoney.getCoinAfter());
|
||||
exchangeMoney.setStatus(StatusType.SUCCESS.getValue());
|
||||
gameExchangeMoneyService.insertGameExchangeMoney(exchangeMoney);
|
||||
} else {
|
||||
log.error("GamesDGServiceImpl [exchangeTransferByAgentId] 金额转移失败,错误代码{},错误信息{}", kmTransactionResponse.getErrorCode(), kmTransactionResponse.getErrorDescription());
|
||||
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("GamesKMServiceImpl [getBetRecordByTime] 请求参数 {}", betRecordByTimeDTO);
|
||||
Map<String, Object> key = this.getKey(betRecordByTimeDTO);
|
||||
String startTime = null;
|
||||
String endTime = null;
|
||||
try {
|
||||
|
||||
|
||||
startTime = URLEncoder.encode(DateUtils.convertTimestampToFormattedDate(betRecordByTimeDTO.getStartTime(), DateUtils.ISO_8601_FORMAT, "GMT+8") + "+08:00", "UTF-8");
|
||||
endTime = URLEncoder.encode(DateUtils.convertTimestampToFormattedDate(betRecordByTimeDTO.getEndTime(), DateUtils.ISO_8601_FORMAT, "GMT+8") + "+08:00", "UTF-8");
|
||||
} catch (Exception e) {
|
||||
throw new BaseException(e.getMessage());
|
||||
}
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("startdate", startTime);
|
||||
params.put("enddate", endTime);
|
||||
params.put("includetestplayers", Boolean.TRUE);
|
||||
params.put("issettled", Boolean.TRUE);
|
||||
|
||||
KMBetRecordResponse betRecordByTime = KMClient.getBetRecordByTime(JsonUtil.mapToQueryString(params), key);
|
||||
|
||||
if (ObjectUtils.isEmpty(betRecordByTime.getErrorCode()) || this.getIsSuccess(betRecordByTime.getErrorCode())) {
|
||||
this.batchInsert(betRecordByTime);
|
||||
|
||||
|
||||
return Boolean.TRUE;
|
||||
} else {
|
||||
log.error("GamesKMServiceImpl [getBetRecordByTime] 获取投注记录失败,错误代码{},错误信息{}", betRecordByTime.getErrorCode(), betRecordByTime.getErrorDescription());
|
||||
throw new BaseException(betRecordByTime.getErrorDescription());
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 按历史时间获取投注记录
|
||||
*
|
||||
* @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) {
|
||||
log.info("GamesKMServiceImpl [kickMember] 请求参数 {}", kickMemberRequestDTO);
|
||||
Map<String, Object> key = this.getKey(kickMemberRequestDTO);
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("userid", kickMemberRequestDTO.getAccount());
|
||||
KMKickMemberResponse kickMember = KMClient.kickMember(params, key);
|
||||
if (ObjectUtils.isEmpty(kickMember.getErrorCode()) || this.getIsSuccess(kickMember.getErrorCode())) {
|
||||
redisCache.deleteObject(CacheConstants.KM_USER_TOKEN + kickMemberRequestDTO.getAccount());
|
||||
return kickMember.isSuccess();
|
||||
}else {
|
||||
throw new BaseException(kickMember.getDescription());
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 踢成员全部
|
||||
*
|
||||
* @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 gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
log.info("GamesKMServiceImpl [gameDemoLogin] 请求参数 {}", gameDemoLoginRequestDTO);
|
||||
Map<String, Object> params = new LinkedHashMap<>();
|
||||
params.put("lang", gameDemoLoginRequestDTO.getLang());
|
||||
String selectConfigByKey = configService.selectConfigByKey(Constants.KM_API_BASE_LOGIN_URL);
|
||||
return GameDemoLoginResponseDTO.builder()
|
||||
.url(selectConfigByKey + "/demolauncher?gpcode=" + gameDemoLoginRequestDTO.getGameType()
|
||||
+ "&gcode=" + gameDemoLoginRequestDTO.getGameId()
|
||||
+ "&lang=" + gameDemoLoginRequestDTO.getLang())
|
||||
.build();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 批量插入
|
||||
*
|
||||
* @param betRecordByTime dg投注记录响应dto
|
||||
*/
|
||||
private void batchInsert(KMBetRecordResponse betRecordByTime) {
|
||||
List<GameBettingDetails> gameBettingDetails = new ArrayList<>();
|
||||
List<String> wagersIds = new ArrayList<>();
|
||||
//数据组装
|
||||
List<KMBetRecordResponse.Bet> report = betRecordByTime.getBets();
|
||||
//数据转化
|
||||
for (KMBetRecordResponse.Bet 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, GamePlatforms.KM.getInfo());
|
||||
//用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) {
|
||||
//转化类
|
||||
KMBetRecordResponse.Bet resultBean = (KMBetRecordResponse.Bet) gamesDataBuildDTO.getData();
|
||||
|
||||
|
||||
GameSecretKeyCurrency currencyDTO = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||
.platformCode(GamePlatforms.KM.getInfo())
|
||||
.currency(resultBean.getCurrency())
|
||||
.build());
|
||||
|
||||
|
||||
Member member = memberService.selectMemberByGameAccount(resultBean.getUserId());
|
||||
if (ObjectUtils.isEmpty(member)) {
|
||||
return null;
|
||||
}
|
||||
List<KMGameResponse.Game> gamesDatas = redisCache.getCacheList(CacheConstants.KM_GAMES);
|
||||
Map<String, KMGameResponse.Game> dataDTOMap = gamesDatas.stream() .collect(Collectors.toMap(
|
||||
KMGameResponse.Game::getCode,
|
||||
e -> e,
|
||||
(existing, replacement) -> existing
|
||||
));;
|
||||
KMGameResponse.Game gamesDataDTO = dataDTOMap.get(resultBean.getGCode());
|
||||
|
||||
//输赢状态
|
||||
Integer gameStatus = GameStatus.FLAT.getCode();
|
||||
BigDecimal payoffAmount =NumberUtil.sub(resultBean.getWinAmount(), resultBean.getRiskAmount().abs());
|
||||
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(currencyDTO.getSystemCurrency())
|
||||
.memberId(member.getId())
|
||||
.gameCode(gamesDataDTO.getCode())
|
||||
.gameType(PlatformType.CARD_GAME.getCode())
|
||||
.platformCode(GamePlatforms.KM.getInfo())
|
||||
.gameId(GAME_ID)
|
||||
.gameName(gamesDataDTO.getName())
|
||||
.gameStatus(gameStatus)
|
||||
.gameStatusType(1)
|
||||
.gameCurrencyCode(currencyDTO.getCurrency())
|
||||
.account(resultBean.getUserId())
|
||||
.wagersId(resultBean.getId())
|
||||
.wagersTime(resultBean.getBeton().getTime())
|
||||
.betAmount(resultBean.getRiskAmount().abs())
|
||||
.payoffTime(resultBean.getClosedon().getTime())
|
||||
.payoffAmount(payoffAmount.abs())
|
||||
.settlementTime(resultBean.getClosedon().getTime())
|
||||
.turnover(resultBean.getValidBet())
|
||||
.settlementStatus(SettlementStatusEnum.COMPLETED.getCode())
|
||||
.orderNo(resultBean.getExternalRoundId())
|
||||
.round(resultBean.getRoundId())
|
||||
.build();
|
||||
gameBettingDetails.setCreateBy(Constants.SYSTEM);
|
||||
gameBettingDetails.setCreateTime(DateUtils.getNowDate());
|
||||
return gameBettingDetails;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
package com.ff.game.api.km.success;
|
||||
|
||||
|
||||
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 MyKMSuccessCondition 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() 获取业务数据
|
||||
// 再根据业务数据判断是否成功
|
||||
}
|
||||
}
|
||||
|
|
@ -683,6 +683,17 @@ public class MeiTianGameServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 批量插入
|
||||
|
|
|
|||
|
|
@ -645,7 +645,7 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
*/
|
||||
@Override
|
||||
public Boolean getBetRecordByHistoryTime(BetRecordByTimeDTO betRecordByTimeDTO) {
|
||||
return null;
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
|
|
@ -659,7 +659,7 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
public Boolean createFreeSpin(CreateFreeSpinRequestDTO createFreeSpinRequest) {
|
||||
|
||||
|
||||
return null;
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
@ -689,7 +689,7 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
@Override
|
||||
public Boolean kickMember(KickMemberRequestDTO kickMemberRequestDTO) {
|
||||
|
||||
return null;
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
@ -701,7 +701,7 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
@Override
|
||||
public Boolean kickMemberAll(KickMemberAllDTO kickMemberAllDTO) {
|
||||
|
||||
return null;
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
@ -714,7 +714,7 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
public List<GameFreeRecord> getFreeSpinDashflow(GetFreeSpinDashflowRequestDTO getFreeSpinDashflowRequestDTO) {
|
||||
|
||||
|
||||
return Collections.emptyList();
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
@ -726,8 +726,19 @@ public class GamesPGServiceImpl implements IGamesService {
|
|||
@Override
|
||||
public Boolean cancelFreeSpin(CancelFreeSpinRequestDTO cancelFreeSpinRequestDTO) {
|
||||
|
||||
return null;
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -559,6 +559,17 @@ public class GamesPGXServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 批量插入
|
||||
|
|
|
|||
|
|
@ -29,5 +29,10 @@ public class CreateMemberRequestDTO extends GamesBaseRequestDTO {
|
|||
*/
|
||||
private Map<String, Map<String, Map<String, Object>>> betLimit;
|
||||
|
||||
/**
|
||||
* 平台类型 0 桌面 1 移动
|
||||
*/
|
||||
private Integer platformType;
|
||||
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,34 @@
|
|||
package com.ff.game.api.request;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* 游戏演示登录请求dto
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/03
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@SuperBuilder
|
||||
public class GameDemoLoginRequestDTO extends GamesBaseRequestDTO{
|
||||
/**
|
||||
* 语言
|
||||
*/
|
||||
private String lang;
|
||||
|
||||
|
||||
/**
|
||||
* 游戏类型
|
||||
*/
|
||||
private String gameType;
|
||||
|
||||
/**
|
||||
* 游戏id
|
||||
*/
|
||||
private String gameId;
|
||||
}
|
||||
|
|
@ -0,0 +1,23 @@
|
|||
package com.ff.game.api.request;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
/**
|
||||
* 游戏演示登录响应dto
|
||||
*
|
||||
* @author shi
|
||||
* @date 2025/04/03
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Builder
|
||||
public class GameDemoLoginResponseDTO {
|
||||
/**
|
||||
* 网址
|
||||
*/
|
||||
private String url;
|
||||
}
|
||||
|
|
@ -524,6 +524,17 @@ public class GamesSAServiceImpl implements IGamesService {
|
|||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 批量插入
|
||||
|
|
|
|||
|
|
@ -535,6 +535,17 @@ public class GamesXKServiceImpl implements IGamesService {
|
|||
public Boolean cancelFreeSpin(CancelFreeSpinRequestDTO cancelFreeSpinRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
/**
|
||||
* 游戏演示登录
|
||||
*
|
||||
* @param gameDemoLoginRequestDTO 游戏演示登录请求dto
|
||||
* @return {@link GameDemoLoginResponseDTO }
|
||||
*/
|
||||
@Override
|
||||
public GameDemoLoginResponseDTO gameDemoLogin(GameDemoLoginRequestDTO gameDemoLoginRequestDTO) {
|
||||
throw new ApiException(ErrorCode.PLATFORM_NOT_METHODS.getCode());
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -55,15 +55,15 @@ public class MemberServiceImpl implements IMemberService {
|
|||
@Override
|
||||
public synchronized String getMemberGameAccount(String platformCode) {
|
||||
String gameAccount = null;
|
||||
if (GamePlatforms.DG.getInfo().equals(platformCode)) {
|
||||
if (GamePlatforms.DG.getInfo().equals(platformCode) || GamePlatforms.KM.getInfo().equals(platformCode)) {
|
||||
do {
|
||||
gameAccount = RandomGeneratorUtils.generateRandomAccountUpper();
|
||||
} while (!ObjectUtils.isEmpty(memberMapper.selectMemberByGameAccount(gameAccount)));
|
||||
}else if (GamePlatforms.PG.getInfo().equals(platformCode)||GamePlatforms.PGX.getInfo().equals(platformCode)){
|
||||
} else if (GamePlatforms.PG.getInfo().equals(platformCode) || GamePlatforms.PGX.getInfo().equals(platformCode)) {
|
||||
do {
|
||||
gameAccount = RandomGeneratorUtils.generateRandomAccountLower();
|
||||
} while (!ObjectUtils.isEmpty(memberMapper.selectMemberByGameAccount(gameAccount)));
|
||||
}else {
|
||||
} else {
|
||||
do {
|
||||
gameAccount = RandomGeneratorUtils.generateRandomAccount();
|
||||
} while (!ObjectUtils.isEmpty(memberMapper.selectMemberByGameAccount(gameAccount)));
|
||||
|
|
|
|||
Loading…
Reference in New Issue