Merge remote-tracking branch 'origin/main-meitian'
commit
3571c94fd3
|
|
@ -5,8 +5,7 @@ package com.ff.base.constant;
|
||||||
*
|
*
|
||||||
* @author ff
|
* @author ff
|
||||||
*/
|
*/
|
||||||
public class CacheConstants
|
public class CacheConstants {
|
||||||
{
|
|
||||||
/**
|
/**
|
||||||
* 登录用户 redis key
|
* 登录用户 redis key
|
||||||
*/
|
*/
|
||||||
|
|
@ -45,49 +44,54 @@ public class CacheConstants
|
||||||
/**
|
/**
|
||||||
* jili 游戏
|
* jili 游戏
|
||||||
*/
|
*/
|
||||||
public static final String JILI_GAMES= "jili_games:";
|
public static final String JILI_GAMES = "jili_games:";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* xk 游戏
|
* xk 游戏
|
||||||
*/
|
*/
|
||||||
public static final String XK_GAMES= "xk_games:";
|
public static final String XK_GAMES = "xk_games:";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* pgx游戏
|
* pgx游戏
|
||||||
*/
|
*/
|
||||||
public static final String PGX_GAMES= "pgx_games:";
|
public static final String PGX_GAMES = "pgx_games:";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* pg游戏
|
* pg游戏
|
||||||
*/
|
*/
|
||||||
public static final String PG_GAMES= "pg_games:";
|
public static final String PG_GAMES = "pg_games:";
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* fc游戏
|
* fc游戏
|
||||||
*/
|
*/
|
||||||
public static final String FC_GAMES= "fc_games:";
|
public static final String FC_GAMES = "fc_games:";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* sa游戏
|
* sa游戏
|
||||||
*/
|
*/
|
||||||
public static final String SA_GAMES= "sa_games:";
|
public static final String SA_GAMES = "sa_games:";
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* dg游戏
|
* dg游戏
|
||||||
*/
|
*/
|
||||||
public static final String DG_GAMES= "dg_games:";
|
public static final String DG_GAMES = "dg_games:";
|
||||||
/**
|
/**
|
||||||
* pg游戏投注货币
|
* pg游戏投注货币
|
||||||
*/
|
*/
|
||||||
public static final String PG_GAMES_BET_CURRENCY= "pg_games:bet:currency";
|
public static final String PG_GAMES_BET_CURRENCY = "pg_games:bet:currency";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* ae时间从
|
* ae时间从
|
||||||
*/
|
*/
|
||||||
public static final String AE_TIME_FROM= "ae:time:from";
|
public static final String AE_TIME_FROM= "ae:time:from";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 美天棋牌游戏
|
||||||
|
*/
|
||||||
|
public static final String MeiTian_GAMES = "meitian_games:";
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -222,6 +222,11 @@ public class Constants {
|
||||||
*/
|
*/
|
||||||
public static final String SA_API_BASE_URL = "sa.api.base.url";
|
public static final String SA_API_BASE_URL = "sa.api.base.url";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 美天平台
|
||||||
|
*/
|
||||||
|
public static final String MEITIAN_API_BASE_URL = "meitian.api.base.url";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 服务
|
* 服务
|
||||||
*/
|
*/
|
||||||
|
|
|
||||||
|
|
@ -11,6 +11,7 @@ public enum GamePlatforms {
|
||||||
FC("FC", "FC"),
|
FC("FC", "FC"),
|
||||||
SA("SA", "SA"),
|
SA("SA", "SA"),
|
||||||
DG("DG", "DG"),
|
DG("DG", "DG"),
|
||||||
|
MeiTian("MeiTian","美天棋牌"),
|
||||||
AE("AE", "AE"),
|
AE("AE", "AE"),
|
||||||
;
|
;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,53 @@
|
||||||
|
package com.ff.base.enums;
|
||||||
|
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
import java.util.Optional;
|
||||||
|
import java.util.stream.Stream;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author cengy
|
||||||
|
*/
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum MeiTianGameType {
|
||||||
|
ELECTRON(4, 1, "电子"),
|
||||||
|
CHESS(2, 2, "棋牌"),
|
||||||
|
GAME_HALL(0, 3, "游戏大厅"),
|
||||||
|
CATCH_FISH(3, 4, "捕鱼"),
|
||||||
|
bai_ren(1, 5,"百人场")
|
||||||
|
,
|
||||||
|
;
|
||||||
|
private final Integer code;
|
||||||
|
private final Integer systemCode;
|
||||||
|
private final String info;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按代码查找系统
|
||||||
|
*
|
||||||
|
* @param code 代码
|
||||||
|
* @return {@link String }
|
||||||
|
*/
|
||||||
|
public static Integer findSystemByCode(Integer code) {
|
||||||
|
Optional<Integer> system = Stream.of(MeiTianGameType.values())
|
||||||
|
.filter(gameType -> gameType.getCode().equals(code))
|
||||||
|
.map(MeiTianGameType::getSystemCode)
|
||||||
|
.findFirst();
|
||||||
|
return system.orElse(null);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按代码查找信息
|
||||||
|
*
|
||||||
|
* @param code 代码
|
||||||
|
* @return {@link String }
|
||||||
|
*/
|
||||||
|
public static String findInfoByCode(Integer code) {
|
||||||
|
Optional<String> system = Stream.of(MeiTianGameType.values())
|
||||||
|
.filter(gameType -> gameType.getCode().equals(code))
|
||||||
|
.map(MeiTianGameType::getInfo)
|
||||||
|
.findFirst();
|
||||||
|
return system.orElse(null);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -11,6 +11,8 @@ import java.util.List;
|
||||||
*/
|
*/
|
||||||
public interface ISysConfigService
|
public interface ISysConfigService
|
||||||
{
|
{
|
||||||
|
|
||||||
|
SysConfig getByConfigKey(String configKey);
|
||||||
/**
|
/**
|
||||||
* 查询参数配置信息
|
* 查询参数配置信息
|
||||||
*
|
*
|
||||||
|
|
|
||||||
|
|
@ -32,6 +32,12 @@ public class SysConfigServiceImpl implements ISysConfigService {
|
||||||
@Autowired
|
@Autowired
|
||||||
private RedisCache redisCache;
|
private RedisCache redisCache;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public SysConfig getByConfigKey(String configKey) {
|
||||||
|
SysConfig config = new SysConfig();
|
||||||
|
config.setConfigKey(configKey);
|
||||||
|
return configMapper.selectConfig(config);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 查询参数配置信息
|
* 查询参数配置信息
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1,29 @@
|
||||||
|
package com.ff.game.api.meitian.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;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author shi
|
||||||
|
* @date 2025/02/10
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
public class MeiTianAddressSource implements AddressSource {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private ISysConfigService configService;
|
||||||
|
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public ForestAddress getAddress(ForestRequest request) {
|
||||||
|
String apiBaseUrl = configService.selectConfigByKey(Constants.MEITIAN_API_BASE_URL);
|
||||||
|
return new ForestAddress("https", apiBaseUrl, 443, "services");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,157 @@
|
||||||
|
package com.ff.game.api.meitian.client;
|
||||||
|
|
||||||
|
import com.dtflys.forest.annotation.Address;
|
||||||
|
import com.dtflys.forest.annotation.Post;
|
||||||
|
import com.dtflys.forest.annotation.Var;
|
||||||
|
import com.ff.game.api.meitian.address.MeiTianAddressSource;
|
||||||
|
import com.ff.game.api.meitian.dto.*;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* jili 请求
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2025/02/10
|
||||||
|
*/
|
||||||
|
@Address(source = MeiTianAddressSource.class)
|
||||||
|
public interface MeiTianClient {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建会员
|
||||||
|
*
|
||||||
|
* @param playerName
|
||||||
|
* @param merchantId
|
||||||
|
* @param pwd
|
||||||
|
* @return {@link MeiTianCreateMemberResponseDTO}
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/playerCreate2/{playerName}/{merchantId}/{pwd}/{code}/{data}")
|
||||||
|
MeiTianCreateMemberResponseDTO createMember(
|
||||||
|
@Var("playerName") String playerName,
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("pwd") String pwd,
|
||||||
|
@Var("code") String code,
|
||||||
|
@Var("data") String data);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 查询余额
|
||||||
|
*
|
||||||
|
* @param playerName 用户名
|
||||||
|
* @param merchantId 商户号
|
||||||
|
* @return {@link MeiTianMemberInfoDTO}
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/getPlayerBalance/{playerName}/{merchantId}")
|
||||||
|
MeiTianMemberInfoDTO getMemberInfo(
|
||||||
|
@Var("playerName") String playerName,
|
||||||
|
@Var("merchantId") String merchantId);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 登录
|
||||||
|
*
|
||||||
|
* @param merchantId 商户id
|
||||||
|
* @param playerName 玩家名
|
||||||
|
* @return {@link MeiTianLoginResultDTO }
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/playerPlatformUrl/{merchantId}/{playerName}/{pwd}/{code}/{data}")
|
||||||
|
MeiTianLoginResultDTO loginWithoutRedirect(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("playerName") String playerName,
|
||||||
|
@Var("pwd") String pwd,
|
||||||
|
@Var("code") String code,
|
||||||
|
@Var("data") String data
|
||||||
|
);
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 转入
|
||||||
|
*
|
||||||
|
* @param merchantId
|
||||||
|
* @param playerName
|
||||||
|
* @param coins
|
||||||
|
* @param extTransId
|
||||||
|
* @param code
|
||||||
|
* @param data
|
||||||
|
* @return {@link MeiTianExchangeMoneyResponseDTO}
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/deposit2/{merchantId}/{playerName}/{coins}/{extTransId}/{code}/{data}")
|
||||||
|
MeiTianExchangeMoneyResponseDTO transferIn(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("playerName") String playerName,
|
||||||
|
@Var("coins") String coins,
|
||||||
|
@Var("extTransId") String extTransId,
|
||||||
|
@Var("code") String code,
|
||||||
|
@Var("data") String data
|
||||||
|
);
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 转出
|
||||||
|
*
|
||||||
|
* @param merchantId
|
||||||
|
* @param playerName
|
||||||
|
* @param coins
|
||||||
|
* @param extTransId
|
||||||
|
* @param code
|
||||||
|
* @param data
|
||||||
|
* @return {@link MeiTianExchangeMoneyResponseDTO}
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/withdraw2/{merchantId}/{playerName}/{coins}/{extTransId}/{code}/{data}")
|
||||||
|
MeiTianExchangeMoneyResponseDTO transferOut(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("playerName") String playerName,
|
||||||
|
@Var("coins") String coins,
|
||||||
|
@Var("extTransId") String extTransId,
|
||||||
|
@Var("code") String code,
|
||||||
|
@Var("data") String data
|
||||||
|
);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按recordId获取投注记录
|
||||||
|
*
|
||||||
|
* @param merchantId 代理id
|
||||||
|
* @param data
|
||||||
|
* @return {@link MeiTianBetRecordResponseDTO }
|
||||||
|
*/
|
||||||
|
@Post(url = "/dg/player/queryMerchantGameRecord2/{merchantId}/{data}")
|
||||||
|
MeiTianBetRecordResponseDTO syncRecordByRecordID(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("data") String data);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按照日期获取投注记录
|
||||||
|
*
|
||||||
|
* @param merchantId
|
||||||
|
* @param data
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
@Post(url = "/dg/player/queryMerchantGameRecord3/{merchantId}/{data}")
|
||||||
|
MeiTianBetRecordResponseDTO syncRecordByDate(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("data") String data);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 踢出
|
||||||
|
*
|
||||||
|
* @param merchantId
|
||||||
|
* @param playerName
|
||||||
|
* @return {@link MeiTianLogoutDTO }
|
||||||
|
*/
|
||||||
|
@Post("/dg/player/logOutGame/{merchantId}/{playerName}")
|
||||||
|
MeiTianLogoutDTO kickMember(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("playerName") String playerName
|
||||||
|
);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取游戏详情
|
||||||
|
*
|
||||||
|
* @param merchantId
|
||||||
|
* @param code
|
||||||
|
* @param data
|
||||||
|
* @return {@link MeiTianGameRecordDetailDTO}
|
||||||
|
*/
|
||||||
|
@Post("dg/player/playCheckUrl/{merchantId}/{code}/{data}")
|
||||||
|
MeiTianGameRecordDetailDTO getGameDetail(
|
||||||
|
@Var("merchantId") String merchantId,
|
||||||
|
@Var("code") String code,
|
||||||
|
@Var("data") String data
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,89 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* JiLi游戏纪录查询返回数据类型
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/21
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class JILIBetRecordDataResponseDTO {
|
||||||
|
/**
|
||||||
|
* 账户
|
||||||
|
*/
|
||||||
|
@JsonProperty("Account")
|
||||||
|
private String account;
|
||||||
|
/**
|
||||||
|
* 投注id
|
||||||
|
*/
|
||||||
|
@JsonProperty("WagersId")
|
||||||
|
private String wagersId;
|
||||||
|
/**
|
||||||
|
* 游戏id
|
||||||
|
*/
|
||||||
|
@JsonProperty("GameId")
|
||||||
|
private String gameId;
|
||||||
|
/**
|
||||||
|
* 下注时间
|
||||||
|
*/
|
||||||
|
@JsonProperty("WagersTime")
|
||||||
|
private Long wagersTime;
|
||||||
|
/**
|
||||||
|
* 投注金额
|
||||||
|
*/
|
||||||
|
@JsonProperty("BetAmount")
|
||||||
|
private BigDecimal betAmount;
|
||||||
|
/**
|
||||||
|
* 回报时间
|
||||||
|
*/
|
||||||
|
@JsonProperty("PayoffTime")
|
||||||
|
private Long payoffTime;
|
||||||
|
/**
|
||||||
|
* 支付金额
|
||||||
|
*/
|
||||||
|
@JsonProperty("PayoffAmount")
|
||||||
|
private BigDecimal payoffAmount;
|
||||||
|
/**
|
||||||
|
* 注单状态 1: 赢 2: 输 3: 平局
|
||||||
|
*/
|
||||||
|
@JsonProperty("Status")
|
||||||
|
private int status;
|
||||||
|
/**
|
||||||
|
* 结算时间
|
||||||
|
*/
|
||||||
|
@JsonProperty("SettlementTime")
|
||||||
|
private Long settlementTime;
|
||||||
|
/**
|
||||||
|
* 游戏类别id
|
||||||
|
*/
|
||||||
|
@JsonProperty("GameCategoryId")
|
||||||
|
private int gameCategoryId;
|
||||||
|
/**
|
||||||
|
* 类型
|
||||||
|
*/
|
||||||
|
@JsonProperty("Type")
|
||||||
|
private int type;
|
||||||
|
/**
|
||||||
|
* 代理id
|
||||||
|
*/
|
||||||
|
@JsonProperty("AgentId")
|
||||||
|
private String agentId;
|
||||||
|
/**
|
||||||
|
* 有效投注金额
|
||||||
|
*/
|
||||||
|
@JsonProperty("Turnover")
|
||||||
|
private BigDecimal turnover;
|
||||||
|
/**
|
||||||
|
* 圆形指数
|
||||||
|
*/
|
||||||
|
@JsonProperty("RoundIndex")
|
||||||
|
private long roundIndex;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,77 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 游戏纪录查询返回值
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/21
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianBetRecordResponseDTO {
|
||||||
|
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
|
||||||
|
@JsonProperty("transList")
|
||||||
|
private List<DataBean> dataList;
|
||||||
|
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public static class DataBean {
|
||||||
|
@JsonProperty("rowID")
|
||||||
|
private String rowID; // 美天棋牌交易流水号
|
||||||
|
@JsonProperty("playerName")
|
||||||
|
private String playerName;
|
||||||
|
@JsonProperty("gameDate")
|
||||||
|
private String gameDate;
|
||||||
|
@JsonProperty("gameCode")
|
||||||
|
private String gameCode;
|
||||||
|
@JsonProperty("period")
|
||||||
|
private String period; // 游戏局ID
|
||||||
|
@JsonProperty("betAmount")
|
||||||
|
private String betAmount; // 下注金额
|
||||||
|
@JsonProperty("commissionable")
|
||||||
|
private String commissionable; // 有效投注量
|
||||||
|
private String roomFee;// 房费
|
||||||
|
private String income; // 赢得金额-下注金额-房费
|
||||||
|
@JsonProperty("recordID")
|
||||||
|
private String recordID; // 游戏记录ID
|
||||||
|
private String gameType; // 游戏类型 1表示百人场，2表示对战，3表示捕鱼，4表示街机
|
||||||
|
private String timeZone; // 时区
|
||||||
|
private String currency; // 币种
|
||||||
|
}
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum ResultMessage {
|
||||||
|
QueryException(0, "查询异常"),
|
||||||
|
QuerySuccess(1, "查询成功"),
|
||||||
|
MerchantNotExist(2, "商户不存在"),
|
||||||
|
MerchantInvalid(3, "商户无效"),
|
||||||
|
IPLimited(15, "IP被限制"),
|
||||||
|
OptionalParameterError(32, "可选参数错误"),
|
||||||
|
MaintenanceMode(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知错误"),
|
||||||
|
;
|
||||||
|
private final int code;
|
||||||
|
private final String message;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ResultMessage get(int code) {
|
||||||
|
for (ResultMessage message : ResultMessage.values()) {
|
||||||
|
if (message.code == code) {
|
||||||
|
return message;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ResultMessage.Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,46 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建成员响应dto
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/22
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class MeiTianCreateMemberResponseDTO {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 错误代码
|
||||||
|
*/
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int resultCode;
|
||||||
|
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum CreateMemberResultCode {
|
||||||
|
/**
|
||||||
|
* 成功
|
||||||
|
*/
|
||||||
|
CreateException(0, "创建异常"),
|
||||||
|
CreateSuccess(1, "创建成功"),
|
||||||
|
MerchantNotExist(2, "商户不存在"),
|
||||||
|
MerchantInvalid(3, "商户无效"),
|
||||||
|
AlreadyRegistered(5, "商户用户已注册"),
|
||||||
|
IpLimit(15, "IP被限制"),
|
||||||
|
DecryptError(21, "解密错误"),
|
||||||
|
OptionalParameterError(32, "可选参数错误"),
|
||||||
|
Maintenance(40, "维护模式"),
|
||||||
|
;
|
||||||
|
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,118 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* jiliexchange货币回应
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/22
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class MeiTianExchangeMoneyResponseDTO {
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 错误代码
|
||||||
|
*/
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
/**
|
||||||
|
* 交易序号，额度转移纪录唯一值, 长度上限 50
|
||||||
|
*/
|
||||||
|
@JsonProperty("transId")
|
||||||
|
private String transactionId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 币种
|
||||||
|
*/
|
||||||
|
@JsonProperty("currency")
|
||||||
|
private String currency;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 余额
|
||||||
|
*/
|
||||||
|
@JsonProperty("curBalance")
|
||||||
|
private BigDecimal balance;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 时区(商户时区) GMT+8
|
||||||
|
*/
|
||||||
|
@JsonProperty("timezone")
|
||||||
|
private String timezone;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 交易时间 2018-08-08 12:23:44
|
||||||
|
*/
|
||||||
|
@JsonProperty("date")
|
||||||
|
private String date;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum TransferIn {
|
||||||
|
// 提现异常
|
||||||
|
WITHDRAW_ERROR(0, "充值异常"),
|
||||||
|
// 提现成功
|
||||||
|
WITHDRAW_SUCCESS(1, "充值成功"),
|
||||||
|
MERCHANT_NOT_EXIST(2, "商户不存在"),
|
||||||
|
MERCHANT_INVALID(3, "商户无效"),
|
||||||
|
MERCHANT_USER_NOT_EXIST(4, "商户用户不存在"),
|
||||||
|
MERCHANT_USER_SYSTEM_DISABLED(6, "商户用户系统禁用"),
|
||||||
|
MERCHANT_USER_GOLD_BALANCE_INSUFFICIENT(9, "商户用户金币余额不足"),
|
||||||
|
GAME_NOT_SETTLED(12, "游戏未结算"),
|
||||||
|
IP_LIMIT(15, "IP被限制"),
|
||||||
|
DECRYPT_ERROR(21, "解密错误"),
|
||||||
|
OPTIONAL_PARAMETER_ERROR(32, "可选参数错误"),
|
||||||
|
EXIST_UNPROCESSED_ORDER(36, "存在未处理订单"),
|
||||||
|
MAINTENANCE(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知");;
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
|
||||||
|
|
||||||
|
public static TransferIn get(int code) {
|
||||||
|
for (TransferIn resultMessage : TransferIn.values()) {
|
||||||
|
if (resultMessage.code == code) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum TransferOut {
|
||||||
|
WITHDRAW_ERROR(0, "提现异常"),
|
||||||
|
WITHDRAW_SUCCESS(1, "提现成功"),
|
||||||
|
MERCHANT_NOT_EXIST(2, "商户不存在"),
|
||||||
|
MERCHANT_INVALID(3, "商户无效"),
|
||||||
|
MERCHANT_USER_NOT_EXIST(4, "商户用户不存在"),
|
||||||
|
MERCHANT_USER_SYSTEM_DISABLED(6, "商户用户系统禁用"),
|
||||||
|
MERCHANT_USER_GOLD_BALANCE_INSUFFICIENT(9, "商户用户金币余额不足"),
|
||||||
|
GAME_NOT_SETTLED(12, "游戏未结算"),
|
||||||
|
IP_LIMIT(15, "IP被限制"),
|
||||||
|
DECRYPT_ERROR(21, "解密错误"),
|
||||||
|
OPTIONAL_PARAMETER_ERROR(32, "可选参数错误"),
|
||||||
|
EXIST_UNPROCESSED_ORDER(36, "存在未处理订单"),
|
||||||
|
MAINTENANCE(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知");;
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
|
||||||
|
|
||||||
|
public static TransferOut get(int code) {
|
||||||
|
for (TransferOut resultMessage : TransferOut.values()) {
|
||||||
|
if (resultMessage.code == code) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,31 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Builder;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* jiligames数据dto
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/22
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@AllArgsConstructor
|
||||||
|
public class MeiTianGameDataDTO {
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
*自己系统游戏id
|
||||||
|
*/
|
||||||
|
private Long systemGameId;
|
||||||
|
private String gameId;
|
||||||
|
private String cnName;
|
||||||
|
private String enName;
|
||||||
|
private Integer gameCategoryId;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,51 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取游戏详细信息请求dto
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/11/12
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianGameRecordDetailDTO {
|
||||||
|
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
|
||||||
|
private String url;
|
||||||
|
private String currency;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum ResultMessage {
|
||||||
|
QueryException(0, "查询异常"),
|
||||||
|
QuerySuccess(1, "查询成功"),
|
||||||
|
MerchantNotExist(2, "商户不存在"),
|
||||||
|
MerchantInvalid(3, "商户无效"),
|
||||||
|
IPLimited(15, "IP被限制"),
|
||||||
|
DecryptError(21, "解密错误"),
|
||||||
|
OptionalParameterError(32, "可选参数错误"),
|
||||||
|
MaintenanceMode(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知错误"),
|
||||||
|
;
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ResultMessage get(int code) {
|
||||||
|
for (ResultMessage resultMessage : ResultMessage.values()) {
|
||||||
|
if (resultMessage.getCode() == code) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ResultMessage.Unknown;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,171 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 游戏
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/22
|
||||||
|
*/
|
||||||
|
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianGamesDTO {
|
||||||
|
|
||||||
|
// 捕鱼：3棋牌：2街机：4百人：1全部：0或不传
|
||||||
|
private List<MeiTianGameDataDTO> data;
|
||||||
|
|
||||||
|
{
|
||||||
|
data = new java.util.ArrayList<>();
|
||||||
|
// 捕鱼游戏数据列表
|
||||||
|
String[][] buyu = {
|
||||||
|
{"PTG0056", "3D捕鱼", "3D Fishing", "3"},
|
||||||
|
{"PTG0011", "李逵劈鱼", "Fishing Kui Lee", "3"},
|
||||||
|
{"PTG0045", "金蟾捕鱼", "Golden Toad", "3"},
|
||||||
|
{"PTG0100", "海王2", "Ocean King 2", "3"},
|
||||||
|
{"PTG0094", "疯狂捕鱼", "Crazy Fishing", "3"},
|
||||||
|
{"PTG0004", "捕鱼来了", "Fishing Joy", "3"},
|
||||||
|
{"PTG0104", "疯狂魔鬼城", "Trick or Treat", "3"},
|
||||||
|
{"PTG0125", "水果炸翻天", "Fruits Carnival", "3"},
|
||||||
|
};
|
||||||
|
|
||||||
|
addGames(buyu, data);
|
||||||
|
|
||||||
|
// 棋牌游戏数据列表
|
||||||
|
String[][] qipai = {
|
||||||
|
{"PTG0042", "五人牛牛", "Beat Bullfight", "2"},
|
||||||
|
{"PTG0022", "通比牛牛", "Mutual Bullfight", "2"},
|
||||||
|
{"PTG0013", "二人牛牛", "Versus Niu-Niu", "2"},
|
||||||
|
{"PTG0039", "十三水", "Winning Thirteen", "2"},
|
||||||
|
{"PTG0062", "炸金花", "Fraud Jinhua", "2"},
|
||||||
|
{"PTG0037", "德州扑克", "Texas Hold'em", "2"},
|
||||||
|
{"PTG0006", "欢乐斗地主", "Fight the Landlord", "2"},
|
||||||
|
{"PTG0023", "黑杰克", "Black Jack", "2"},
|
||||||
|
{"PTG0017", "二人梭哈", "Show Hand", "2"},
|
||||||
|
{"PTG0080", "抢庄牌九", "Pai Gow", "2"},
|
||||||
|
{"PTG0082", "三公", "3-card poker", "2"},
|
||||||
|
{"PTG0061", "明牌牛牛", "Spread Bullfight", "2"},
|
||||||
|
{"PTG0084", "土豪百家乐", "Rich Baccarat", "2"},
|
||||||
|
{"PTG0085", "推筒子", "versus 2-8 bar", "2"},
|
||||||
|
{"PTG0086", "二人雀神", "Versus Mahjong", "2"},
|
||||||
|
{"PTG0093", "血流成河", "Rivers of Blood", "2"},
|
||||||
|
{"PTG0110", "看牌牛牛", "Royal Bull-fight", "2"},
|
||||||
|
{"PTG0121", "越式13张", "TIEN LEN", "2"},
|
||||||
|
{"PTG0127", "UNO", "UNO", "2"},
|
||||||
|
{"PTG0122", "Dummy", "Dummy", "2"},
|
||||||
|
{"PTG0123", "九鸡", "Jiu-Ji", "2"}, // 未分类
|
||||||
|
{"PTG0124", "博丁", "Bo-Ding", "2"}, // 未分类
|
||||||
|
{"PTG0126", "牌肯", "Card Ken", "2"},
|
||||||
|
{"PTG0133", "泰式十三支", "Thai 13 Cards", "2"},
|
||||||
|
{"PTG0134", "泰九牌", "Gao Gae Thai", "2"},
|
||||||
|
{"PTG0136", "Dummy Speto", "Dummy Speto", "2"},
|
||||||
|
{"PTG0137", "Gao Gae Sam Bai Thod", "Gao Gae Sam Bai Thod", "2"},
|
||||||
|
{"PTG0138", "Slave Card", "Slave Card", "2"}
|
||||||
|
};
|
||||||
|
addGames(qipai, data);
|
||||||
|
|
||||||
|
// 百人场游戏数据列表
|
||||||
|
String[][] bairenchang = {
|
||||||
|
{"PTG0058", "红黑大战", "King's Queen", "1"},
|
||||||
|
{"PTG0044", "百人牛牛", "Hundred Niu-Niu", "1"},
|
||||||
|
{"PTG0059", "百家乐", "Baccarat", "1"},
|
||||||
|
{"PTG0008", "豪车漂移", "Drift Car Racing", "-1"}, // 未分类
|
||||||
|
{"PTG0041", "龙虎斗", "The Chinese Boxer", "1"},
|
||||||
|
{"PTG0007", "飞禽走兽", "Fowls and Beasts", "-1"}, // 未分类
|
||||||
|
{"PTG0036", "五星宏辉", "Five Star Stud", "1"},
|
||||||
|
{"PTG0064", "金鲨银鲨", "Golden Shark", "1"},
|
||||||
|
{"PTG0020", "西游争霸", "Journey to the West", "1"},
|
||||||
|
{"PTG0018", "港式赛马", "Horse Racing", "-1"}, // 未分类
|
||||||
|
{"PTG0070", "二八杠", "2-8 Bar", "-1"}, // 未分类
|
||||||
|
{"PTG0081", "骰宝", "Sic bo", "1"},
|
||||||
|
{"PTG0067", "森林舞会", "Forest Party", "-1"}, // 未分类
|
||||||
|
{"PTG0091", "鱼虾蟹", "Crab and Shrimp", "1"},
|
||||||
|
{"PTG0092", "红包扫雷", "Minesweeping", "-1"}, // 未分类
|
||||||
|
{"PTG0089", "动物跑跑跑", "Animal Running", "-1"}, // 未分类
|
||||||
|
{"PTG0116", "越式鱼虾蟹", "Vietnamese Fish-Prawn-Crab", "-1"}, // 未分类
|
||||||
|
{"PTG0102", "正版抢车位", "GA Car Parking", "-1"}, // 未分类
|
||||||
|
{"PTG0120", "番摊", "FAN TAN", "1"},
|
||||||
|
{"PTG2008", "西游争霸战无不胜", "Monkey King2 PLUS", "-1"}, // 未分类
|
||||||
|
{"PTG0135", "泰式鱼虾蟹", "Thai Fish Prawn Crab", "-1"} // 未分类
|
||||||
|
};
|
||||||
|
addGames(bairenchang, data);
|
||||||
|
|
||||||
|
// 街机游戏数据列表
|
||||||
|
String[][] dianzi = {
|
||||||
|
{"PTG0060", "超级大亨", "Super Tycoon", "4"},
|
||||||
|
{"PTG0069", "ATT金皇冠", "ATT Gold Crown", "4"},
|
||||||
|
{"PTG0001", "水果机", "Super Frootz", "4"},
|
||||||
|
{"PTG0010", "水浒传", "The Water Margin", "4"},
|
||||||
|
{"PTG0066", "大满贯水果机", "Grand Slam Frootz", "4"},
|
||||||
|
{"PTG0068", "泰山闯天关2", "Tarzan Adventure 2", "4"},
|
||||||
|
{"PTG0083", "财神到", "Mammon", "4"},
|
||||||
|
{"PTG0079", "不倒翁", "Happy tumbler", "4"},
|
||||||
|
{"PTG0087", "醉西游", "Monkey King", "4"},
|
||||||
|
{"PTG0090", "延禧攻略", "Story of Yanxi Palace", "4"},
|
||||||
|
{"PTG0095", "连环夺宝", "Linking Jewels", "4"},
|
||||||
|
{"PTG0098", "三只小猪", "Three Little Pigs", "4"},
|
||||||
|
{"PTG0097", "招财猫", "Fortune Cat", "4"},
|
||||||
|
{"PTG0099", "欲望魅影", "Sexy Succubus", "4"},
|
||||||
|
{"PTG0096", "绝地求生", "Playerunknown's Battlegrounds", "4"},
|
||||||
|
{"PTG0101", "埃及艳后", "Cleopatra's treasures", "4"},
|
||||||
|
{"PTG0103", "年年有鱼", "Lucky boy", "4"},
|
||||||
|
{"PTG0105", "天空之神", "God of Sky", "4"},
|
||||||
|
{"PTG0107", "阿拉丁神灯", "PLUS ALADDIN'S GOLD", "4"},
|
||||||
|
{"PTG0109", "武媚娘传奇", "Empress Wu Zetian", "4"},
|
||||||
|
{"PTG0106", "亿万富翁", "Billionaire", "4"},
|
||||||
|
{"PTG0115", "萝卜跳一跳", "Jump Hot", "4"},
|
||||||
|
{"PTG0117", "宫心计", "Beyond The Realm Of Conscience", "4"},
|
||||||
|
{"PTG2001", "恭喜发财", "Good Fortune", "4"},
|
||||||
|
{"PTG2002", "新潘金莲", "Pan Jinlian", "4"},
|
||||||
|
{"PTG2003", "宫本武藏", "Miyamoto Musashi", "4"},
|
||||||
|
{"PTG2004", "武则天", "Empress of the Great Tang", "4"},
|
||||||
|
{"PTG2005", "发发发", "Fa Fa Fa", "4"},
|
||||||
|
{"PTG2007", "赏金船长", "Captain's Bounty", "4"},
|
||||||
|
{"PTG2009", "爱尔兰精灵", "Leprechaun Riches", "4"},
|
||||||
|
{"PTG2010", "水浒传豪华版", "Water Margin DELUXE", "4"},
|
||||||
|
{"PTG2011", "金钱豹水果机", "Golden Jaguar", "4"},
|
||||||
|
{"PTG0118", "疯狂猴子", "Crazy Monkey", "4"},
|
||||||
|
{"PTG2015", "金刚", "King Kong", "4"},
|
||||||
|
{"PTG2016", "福星献舞", "Dancing FU", "4"},
|
||||||
|
{"PTG2017", "野蛮世界", "HUGA", "4"},
|
||||||
|
{"PTG2018", "上海甜心", "Shanghai Honey", "4"},
|
||||||
|
{"PTG2019", "美洲野牛", "Buffalo Gold", "4"},
|
||||||
|
{"PTG2020", "白蛇传", "The Legend of White Snake", "4"},
|
||||||
|
{"PTG2021", "笑弥勒", "Happys Prosperous", "4"},
|
||||||
|
{"PTG2013", "招财推币机", "Fortune Coindozer", "4"},
|
||||||
|
{"PTG2025", "东海之王", "Dragon Of The Eastern Ocean", "4"},
|
||||||
|
{"PTG2028", "中国龙", "Dragon World", "4"},
|
||||||
|
{"PTG2023", "秦皇传说", "Legend of Emperor Qin", "4"},
|
||||||
|
{"PTG2026", "辣椒多多", "More Chilli", "4"},
|
||||||
|
{"PTG2029", "财神驾到", "CHOY SUN DOA", "4"},
|
||||||
|
{"PTG2030", "招财猫2", "Fortune Cat 2", "4"},
|
||||||
|
{"PTG2031", "黄金城魅影", "Gold City Treasure Hunt", "4"},
|
||||||
|
{"PTG2032", "亡灵宝藏", "WILD BANDITO", "4"},
|
||||||
|
{"PTG2033", "麒麟献宝", "WAYS OF THE QILIN", "4"},
|
||||||
|
{"PTG2034", "天将神兵", "Heavenly Warriors", "4"}
|
||||||
|
};
|
||||||
|
|
||||||
|
addGames(dianzi, data);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public void addGames(String[][] gameData, List<MeiTianGameDataDTO> dataList) {
|
||||||
|
// 添加数据到 List
|
||||||
|
for (String[] game : gameData) {
|
||||||
|
String gameId = game[0];
|
||||||
|
String cnName = game[1];
|
||||||
|
String enName = game[2];
|
||||||
|
Integer categoryId = Integer.valueOf(game[3]);
|
||||||
|
dataList.add(MeiTianGameDataDTO.builder().gameId(gameId)
|
||||||
|
.cnName(cnName)
|
||||||
|
.enName(enName)
|
||||||
|
.gameCategoryId(categoryId)
|
||||||
|
.build());
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,52 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 登录时不重定向响应dto
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/22
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianLoginResultDTO {
|
||||||
|
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
@JsonProperty("url")
|
||||||
|
private String url;
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum ResultMessage {
|
||||||
|
LoginException(0, "登录异常"),
|
||||||
|
LoginSuccess(1, "登录成功"),
|
||||||
|
MerchantNotExist(2, "商户不存在"),
|
||||||
|
MerchantInvalid(3, "商户无效"),
|
||||||
|
MerchantUserNotExist(4, "商户用户不存在"),
|
||||||
|
MerchantUserSystemDisabled(6, "商户用户系统禁用"),
|
||||||
|
PasswordError(7, "密码错误"),
|
||||||
|
IPLimited(15, "IP被限制"),
|
||||||
|
DecryptError(21, "解密错误"),
|
||||||
|
MerchantUserLoginDisabled(22, "商户用户登录禁用"),
|
||||||
|
OptionalParameterError(32, "可选参数错误"),
|
||||||
|
MaintenanceMode(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知错误");
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ResultMessage get(int errorCode) {
|
||||||
|
for (ResultMessage resultMessage : ResultMessage.values()) {
|
||||||
|
if (resultMessage.getCode() == errorCode) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ResultMessage.Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,43 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianLogoutDTO {
|
||||||
|
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum ResultMessage {
|
||||||
|
QueryException(0, "查询异常"),
|
||||||
|
QuerySuccess(1, "查询成功"),
|
||||||
|
MerchantNotExist(2, "商户不存在"),
|
||||||
|
MerchantInvalid(3, "商户无效"),
|
||||||
|
MerchantUserNotExist(4, "商户用户不存在"),
|
||||||
|
MerchantUserSystemDisabled(6, "商户用户系统禁用"),
|
||||||
|
MerchantUserGameOnline(12, "商户用户游戏在线"),
|
||||||
|
IPLimited(15, "IP被限制"),
|
||||||
|
MaintenanceMode(40, "维护模式"),
|
||||||
|
Unknown(-1, "未知错误")
|
||||||
|
,;
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static ResultMessage get(int errorCode) {
|
||||||
|
for (ResultMessage resultMessage : ResultMessage.values()) {
|
||||||
|
if (resultMessage.code == errorCode) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ResultMessage.Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,69 @@
|
||||||
|
package com.ff.game.api.meitian.dto;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.Getter;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 会员信息dto
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/30
|
||||||
|
*/
|
||||||
|
@NoArgsConstructor
|
||||||
|
@Data
|
||||||
|
public class MeiTianMemberInfoDTO {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 错误代码
|
||||||
|
*/
|
||||||
|
@JsonProperty("resultCode")
|
||||||
|
private int errorCode;
|
||||||
|
/**
|
||||||
|
* 余额
|
||||||
|
*/
|
||||||
|
@JsonProperty("coinBalance")
|
||||||
|
private BigDecimal balance;
|
||||||
|
|
||||||
|
@JsonProperty("status")
|
||||||
|
private Integer status;
|
||||||
|
|
||||||
|
@JsonProperty("currency")
|
||||||
|
private String currency;
|
||||||
|
|
||||||
|
|
||||||
|
@Getter
|
||||||
|
@AllArgsConstructor
|
||||||
|
public enum ResultMessage {
|
||||||
|
Excep(0,"查询异常"),
|
||||||
|
Success(1,"查询成功"),
|
||||||
|
// 商户不存在
|
||||||
|
MerchantNotExist(2,"商户不存在"),
|
||||||
|
// 商户无效
|
||||||
|
MerchantInvalid(3,"商户无效"),
|
||||||
|
// 商户用户不存在
|
||||||
|
AccountNotExist(4,"商户用户不存在"),
|
||||||
|
// IP被限制
|
||||||
|
IpLimit(15,"IP被限制"),
|
||||||
|
// 维护模式
|
||||||
|
Maintenance(40,"维护模式"),
|
||||||
|
|
||||||
|
Unknown(-1, "未知")
|
||||||
|
,;
|
||||||
|
private int code;
|
||||||
|
private String message;
|
||||||
|
|
||||||
|
public static ResultMessage getResultMessage(int code) {
|
||||||
|
for (ResultMessage resultMessage : ResultMessage.values()) {
|
||||||
|
if (resultMessage.code == code) {
|
||||||
|
return resultMessage;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return Unknown;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,808 @@
|
||||||
|
package com.ff.game.api.meitian.impl;
|
||||||
|
|
||||||
|
import cn.hutool.core.codec.Base64;
|
||||||
|
import cn.hutool.core.util.IdUtil;
|
||||||
|
import com.alibaba.fastjson2.JSON;
|
||||||
|
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.domain.SysConfig;
|
||||||
|
import com.ff.base.system.service.ISysConfigService;
|
||||||
|
import com.ff.base.system.service.impl.SysConfigServiceImpl;
|
||||||
|
import com.ff.base.utils.DateUtils;
|
||||||
|
import com.ff.base.utils.sign.Md5Utils;
|
||||||
|
import com.ff.base.utils.uuid.IdUtils;
|
||||||
|
import com.ff.game.api.IGamesService;
|
||||||
|
import com.ff.game.api.meitian.client.MeiTianClient;
|
||||||
|
import com.ff.game.api.meitian.dto.*;
|
||||||
|
import com.ff.game.api.request.*;
|
||||||
|
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.beans.factory.annotation.Autowired;
|
||||||
|
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.math.RoundingMode;
|
||||||
|
import java.nio.charset.StandardCharsets;
|
||||||
|
import java.text.ParseException;
|
||||||
|
import java.text.SimpleDateFormat;
|
||||||
|
import java.time.LocalDate;
|
||||||
|
import java.time.format.DateTimeFormatter;
|
||||||
|
import java.util.*;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 游戏数据解析服务
|
||||||
|
*
|
||||||
|
* @author shi
|
||||||
|
* @date 2024/10/21
|
||||||
|
*/
|
||||||
|
@Service("MeiTianService")
|
||||||
|
@Slf4j
|
||||||
|
public class MeiTianGameServiceImpl 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 IGameSecretKeyService gameSecretKeyService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private MeiTianClient meiTianClient;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private IGameBettingDetailsService gameBettingDetailsService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private IGameSecretKeyCurrencyService gameSecretKeyCurrencyService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private IGameNameService gameNameService;
|
||||||
|
@Autowired
|
||||||
|
private SysConfigServiceImpl sysConfigServiceImpl;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得就是成功
|
||||||
|
*
|
||||||
|
* @param errorCode 错误代码
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
private Boolean isSuccess(Integer errorCode) {
|
||||||
|
return 1 == errorCode;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建成员
|
||||||
|
*
|
||||||
|
* @param createMemberRequestDTO 创建成员请求dto
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean createMember(CreateMemberRequestDTO createMemberRequestDTO) {
|
||||||
|
GameSecretKey gameSecretKey = gameSecretKeyService.selectGameSecretKeyByCode(createMemberRequestDTO.getAgentId());
|
||||||
|
|
||||||
|
String playerName = createMemberRequestDTO.getAccount();
|
||||||
|
String merchantId = createMemberRequestDTO.getAgentId();
|
||||||
|
String md5Password = Md5Utils.md5New(gameSecretKey.getPassword());
|
||||||
|
Map<String, String> rawMap = new LinkedHashMap<>();
|
||||||
|
rawMap.put("nickname", createMemberRequestDTO.getAccount());
|
||||||
|
rawMap.put("playerLevel", "0");
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes(StandardCharsets.UTF_8));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] encode rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.ERROR.getCode());
|
||||||
|
}
|
||||||
|
String md5Code = Md5Utils.md5New(gameSecretKey.getKey() + rawData);//MD5(key+rawData);
|
||||||
|
MeiTianCreateMemberResponseDTO createMemberResponseDTO =
|
||||||
|
meiTianClient.createMember(
|
||||||
|
playerName,
|
||||||
|
merchantId,
|
||||||
|
md5Password,
|
||||||
|
md5Code,
|
||||||
|
data);
|
||||||
|
int errorCode = createMemberResponseDTO.getResultCode();
|
||||||
|
log.info("[MeiTian]创建会员失败返回结果:{}", errorCode);
|
||||||
|
if (1 == errorCode) {
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
if (5 == errorCode) {
|
||||||
|
throw new ApiException(ErrorCode.GAME_ACCOUNT_CREATION_FAILED.getCode());
|
||||||
|
}
|
||||||
|
//判断是否获取成功
|
||||||
|
return Boolean.FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取会员信息
|
||||||
|
*
|
||||||
|
* @param memberInfoRequestDTO 会员信息请求dto
|
||||||
|
* @return {@link MemberInfoResponseDTO }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public MemberInfoResponseDTO getMemberInfo(MemberInfoRequestDTO memberInfoRequestDTO) {
|
||||||
|
|
||||||
|
String playerName = memberInfoRequestDTO.getAccounts();
|
||||||
|
String merchantId = memberInfoRequestDTO.getAgentId();
|
||||||
|
MeiTianMemberInfoDTO memberInfoDTO = meiTianClient.getMemberInfo(playerName, merchantId);
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(memberInfoDTO.getErrorCode())) {
|
||||||
|
return MemberInfoResponseDTO.builder()
|
||||||
|
.status(GameMemberStatus.UNKNOWN.getCode())
|
||||||
|
.balance(memberInfoDTO.getBalance())
|
||||||
|
.account(playerName)
|
||||||
|
.build();
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianMemberInfoDTO.ResultMessage.getResultMessage(memberInfoDTO.getErrorCode()).getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 无重定向登录
|
||||||
|
*
|
||||||
|
* @param gamesLogin 游戏登录
|
||||||
|
* @return {@link String }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public String loginWithoutRedirect(GamesLogin gamesLogin) {
|
||||||
|
GameSecretKey gameSecretKey = gameSecretKeyService.selectGameSecretKeyByCode(gamesLogin.getAgentId());
|
||||||
|
|
||||||
|
String merchantId = gamesLogin.getAgentId();
|
||||||
|
String playerName = gamesLogin.getAccount();
|
||||||
|
String md5Password = Md5Utils.md5New(gameSecretKey.getPassword());
|
||||||
|
Map<String, String> rawMap = new LinkedHashMap<>();
|
||||||
|
/*rawMap.put("gameHall ", gamesLogin.getGameType());*/
|
||||||
|
rawMap.put("gameCode", gamesLogin.getGameId());
|
||||||
|
rawMap.put("lang", gamesLogin.getLang());
|
||||||
|
rawMap.put("roomID", "0");
|
||||||
|
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes(StandardCharsets.UTF_8));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] encode rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.ERROR.getCode());
|
||||||
|
}
|
||||||
|
String code = Md5Utils.md5New(gameSecretKey.getKey() + rawData);
|
||||||
|
MeiTianLoginResultDTO loginWithoutRedirectResponseDTO =
|
||||||
|
meiTianClient.loginWithoutRedirect(
|
||||||
|
merchantId,
|
||||||
|
playerName,
|
||||||
|
md5Password,
|
||||||
|
code,
|
||||||
|
data
|
||||||
|
);
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(loginWithoutRedirectResponseDTO.getErrorCode())) {
|
||||||
|
return loginWithoutRedirectResponseDTO.getUrl();
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianLoginResultDTO.get(loginWithoutRedirectResponseDTO.getErrorCode()).getMessage());
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取游戏列表
|
||||||
|
*
|
||||||
|
* @param gamesBaseRequestDTO 游戏请求dto
|
||||||
|
* @return {@link String }
|
||||||
|
*/
|
||||||
|
@Transactional
|
||||||
|
@Override
|
||||||
|
public String getGameList(GamesBaseRequestDTO gamesBaseRequestDTO) {
|
||||||
|
|
||||||
|
List<MeiTianGameDataDTO> gamesDatas = redisCache.getCacheList(CacheConstants.MeiTian_GAMES);
|
||||||
|
if (!CollectionUtils.isEmpty(gamesDatas)) {
|
||||||
|
return CacheConstants.MeiTian_GAMES;
|
||||||
|
}
|
||||||
|
|
||||||
|
MeiTianGamesDTO gameList = new MeiTianGamesDTO();
|
||||||
|
|
||||||
|
for (MeiTianGameDataDTO gamesDataDTO : gameList.getData()) {
|
||||||
|
GamePlatform gamePlatform = GamePlatform.builder()
|
||||||
|
.platformType(MeiTianGameType.findSystemByCode(gamesDataDTO.getGameCategoryId()))
|
||||||
|
.platformCode(GamePlatforms.MeiTian.getCode())
|
||||||
|
.build();
|
||||||
|
List<GamePlatform> gamePlatforms = gamePlatformService.selectGamePlatformList(gamePlatform);
|
||||||
|
//没有此平台就新增一个平台
|
||||||
|
if (CollectionUtils.isEmpty(gamePlatforms)) {
|
||||||
|
gamePlatform.setPlatformName(GamePlatforms.MeiTian.getInfo() + MeiTianGameType.findInfoByCode(gamesDataDTO.getGameCategoryId()));
|
||||||
|
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(String.valueOf(gamesDataDTO.getGameId()))
|
||||||
|
.build();
|
||||||
|
List<Game> games = gameService.selectGameList(game);
|
||||||
|
//不存在这个游戏
|
||||||
|
if (CollectionUtils.isEmpty(games)) {
|
||||||
|
game.setGameSourceType(String.valueOf(gamesDataDTO.getGameCategoryId()));
|
||||||
|
game.setFreespin(false);
|
||||||
|
game.setSortNo(gameService.selectMaxSortNoByPlatformId(gamePlatform.getId()) + 1);
|
||||||
|
game.setGameName(gamesDataDTO.getCnName());
|
||||||
|
game.setCreateBy(Constants.SYSTEM);
|
||||||
|
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());
|
||||||
|
//
|
||||||
|
gameNameService.insertGameName(GameName.builder()
|
||||||
|
.gameId(game.getId())
|
||||||
|
.gameName(gamesDataDTO.getEnName())
|
||||||
|
.langCode("en-US")
|
||||||
|
.createBy(Constants.SYSTEM)
|
||||||
|
.build());
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
redisCache.deleteObject(CacheConstants.MeiTian_GAMES);
|
||||||
|
redisCache.setCacheList(CacheConstants.MeiTian_GAMES, gameList.getData());
|
||||||
|
redisCache.expire(CacheConstants.MeiTian_GAMES, 5L, TimeUnit.HOURS);
|
||||||
|
|
||||||
|
return CacheConstants.MeiTian_GAMES;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按代理id进行交换转账
|
||||||
|
*
|
||||||
|
* @param exchangeTransferMoneyRequestDTO 外汇转账moeny dto
|
||||||
|
* @return {@link Long }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
@Transactional
|
||||||
|
public Long exchangeTransferByAgentId(ExchangeTransferMoneyRequestDTO exchangeTransferMoneyRequestDTO) {
|
||||||
|
GameSecretKeyCurrencyDTO gameSecretKey = gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||||
|
.code(exchangeTransferMoneyRequestDTO.getAgentId())
|
||||||
|
.currency(exchangeTransferMoneyRequestDTO.getCurrency()).build());
|
||||||
|
|
||||||
|
Member member = memberService.selectMemberByGameAccount(exchangeTransferMoneyRequestDTO.getAccount());
|
||||||
|
String transactionId = GamePlatforms.MeiTian.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()
|
||||||
|
.orderId(exchangeTransferMoneyRequestDTO.getOrderId())
|
||||||
|
.tenantKey(exchangeTransferMoneyRequestDTO.getTenantKey())
|
||||||
|
.quota(exchangeTransferMoneyRequestDTO.getQuota())
|
||||||
|
.balance(exchangeTransferMoneyRequestDTO.getAmount())
|
||||||
|
.exchangeType(exchangeTransferMoneyRequestDTO.getTransferType())
|
||||||
|
.currencyCode(gameSecretKey.getSystemCurrency())
|
||||||
|
.memberId(member.getId())
|
||||||
|
.transactionId(transactionId)
|
||||||
|
.platformCode(GamePlatforms.MeiTian.getCode())
|
||||||
|
.build();
|
||||||
|
exchangeMoney.setCreateBy(Constants.SYSTEM);
|
||||||
|
//接口限制限制50字符
|
||||||
|
exchangeMoney.setTransactionId(transactionId);
|
||||||
|
|
||||||
|
|
||||||
|
String key = gameSecretKey.getKey();
|
||||||
|
String merchantId = exchangeTransferMoneyRequestDTO.getAgentId();
|
||||||
|
String playerName = exchangeTransferMoneyRequestDTO.getAccount();
|
||||||
|
String coins = exchangeTransferMoneyRequestDTO.getAmount().setScale(4, RoundingMode.DOWN).toString();
|
||||||
|
Map<String, String> rawMap = new LinkedHashMap<>();
|
||||||
|
rawMap.put("merchantId", merchantId);
|
||||||
|
rawMap.put("playerName", playerName);
|
||||||
|
rawMap.put("extTransId", transactionId);
|
||||||
|
rawMap.put("coins", coins);
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes(StandardCharsets.UTF_8));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] base64 rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.BALANCE_TRANSFER_FAILED.getCode());
|
||||||
|
}
|
||||||
|
String md5Code = Md5Utils.md5New(key + rawData);
|
||||||
|
// 转入到游戏商 type == 2
|
||||||
|
if (exchangeTransferMoneyRequestDTO.getTransferType().equals(TransferType.GAMES.getCode())) {
|
||||||
|
|
||||||
|
MeiTianExchangeMoneyResponseDTO exchangeMoneyResponse = meiTianClient
|
||||||
|
.transferIn(
|
||||||
|
merchantId,
|
||||||
|
playerName,
|
||||||
|
coins,
|
||||||
|
transactionId,
|
||||||
|
md5Code,
|
||||||
|
data
|
||||||
|
);
|
||||||
|
|
||||||
|
//判断是否转移成功
|
||||||
|
if (this.isSuccess(exchangeMoneyResponse.getErrorCode())) {
|
||||||
|
//更新数据
|
||||||
|
exchangeMoney.setBalance(exchangeMoneyResponse.getBalance());
|
||||||
|
BigDecimal transAmount = exchangeTransferMoneyRequestDTO.getAmount();
|
||||||
|
exchangeMoney.setCoinBefore(exchangeMoneyResponse.getBalance().subtract(transAmount));
|
||||||
|
exchangeMoney.setCoinAfter(exchangeMoneyResponse.getBalance());
|
||||||
|
exchangeMoney.setCurrencyBefore(exchangeMoneyResponse.getBalance().subtract(transAmount));
|
||||||
|
exchangeMoney.setCurrencyAfter(exchangeMoneyResponse.getBalance());
|
||||||
|
exchangeMoney.setStatus(1); // SUCCESS
|
||||||
|
gameExchangeMoneyService.insertGameExchangeMoney(exchangeMoney);
|
||||||
|
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianExchangeMoneyResponseDTO.TransferIn.get(exchangeMoneyResponse.getErrorCode()).getMessage());
|
||||||
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
|
||||||
|
MeiTianExchangeMoneyResponseDTO exchangeMoneyResponse = meiTianClient
|
||||||
|
.transferOut(
|
||||||
|
merchantId,
|
||||||
|
playerName,
|
||||||
|
coins,
|
||||||
|
transactionId,
|
||||||
|
md5Code,
|
||||||
|
data
|
||||||
|
);
|
||||||
|
|
||||||
|
//判断是否转移成功
|
||||||
|
if (this.isSuccess(exchangeMoneyResponse.getErrorCode())) {
|
||||||
|
//更新数据
|
||||||
|
exchangeMoney.setBalance(exchangeMoneyResponse.getBalance());
|
||||||
|
BigDecimal transAmount = exchangeTransferMoneyRequestDTO.getAmount();
|
||||||
|
exchangeMoney.setCoinBefore(exchangeMoneyResponse.getBalance().add(transAmount));
|
||||||
|
exchangeMoney.setCoinAfter(exchangeMoneyResponse.getBalance());
|
||||||
|
exchangeMoney.setCurrencyBefore(exchangeMoneyResponse.getBalance().add(transAmount));
|
||||||
|
exchangeMoney.setCurrencyAfter(exchangeMoneyResponse.getBalance());
|
||||||
|
exchangeMoney.setStatus(1); // SUCCESS
|
||||||
|
gameExchangeMoneyService.insertGameExchangeMoney(exchangeMoney);
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianExchangeMoneyResponseDTO.TransferOut.get(exchangeMoneyResponse.getErrorCode()).getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return exchangeMoney.getId();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 汇兑转移状态
|
||||||
|
*
|
||||||
|
* @param exchangeTransferMoneyRequestDTO 兑换转账请求dto
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean exchangeTransferStatus(ExchangeTransferStatusRequestDTO exchangeTransferMoneyRequestDTO) {
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按时间获取投注记录
|
||||||
|
*
|
||||||
|
* @param betRecordByTimeDTO 按时间dto投注记录
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean getBetRecordByTime(BetRecordByTimeDTO betRecordByTimeDTO) {
|
||||||
|
return doSyncRecordByRecordID(betRecordByTimeDTO);
|
||||||
|
}
|
||||||
|
|
||||||
|
boolean doSyncRecordByRecordID(BetRecordByTimeDTO betRecordByTimeDTO) {
|
||||||
|
String configKey = GamePlatforms.MeiTian.getCode() + ":lastRecordID";
|
||||||
|
String lastRecordID = sysConfigServiceImpl.selectConfigByKey(configKey);
|
||||||
|
long recordID = 0;
|
||||||
|
if (lastRecordID == null || lastRecordID.isEmpty()) {
|
||||||
|
|
||||||
|
} else {
|
||||||
|
recordID = Long.parseLong(lastRecordID);
|
||||||
|
}
|
||||||
|
String merchantId = betRecordByTimeDTO.getAgentId();
|
||||||
|
Map<String, Object> rawMap = new LinkedHashMap<>();
|
||||||
|
rawMap.put("recordID", recordID);
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes(StandardCharsets.UTF_8));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] base64 rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.ERROR.getCode());
|
||||||
|
}
|
||||||
|
|
||||||
|
//获取key
|
||||||
|
MeiTianBetRecordResponseDTO recordResponse =
|
||||||
|
meiTianClient.syncRecordByRecordID(merchantId, data);
|
||||||
|
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(recordResponse.getErrorCode())) {
|
||||||
|
List<MeiTianBetRecordResponseDTO.DataBean> dataList = recordResponse.getDataList();
|
||||||
|
if (CollectionUtils.isEmpty(dataList)) {
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
//数据插入
|
||||||
|
this.batchInsert(recordResponse);
|
||||||
|
MeiTianBetRecordResponseDTO.DataBean dataBean = dataList.get(dataList.size() - 1);
|
||||||
|
SysConfig config = sysConfigServiceImpl.getByConfigKey(configKey);
|
||||||
|
if (config == null) {
|
||||||
|
config = new SysConfig();
|
||||||
|
config.setConfigKey(configKey);
|
||||||
|
config.setConfigValue(dataBean.getRecordID());
|
||||||
|
sysConfigServiceImpl.insertConfig(config);
|
||||||
|
} else {
|
||||||
|
config.setConfigValue(dataBean.getRecordID());
|
||||||
|
sysConfigServiceImpl.updateConfig(config);
|
||||||
|
}
|
||||||
|
// 它每次返回25000条，所以需要判断，如果大于25000条，则继续拉取
|
||||||
|
if (dataList.size() >= 25000) {
|
||||||
|
doSyncRecordByRecordID(betRecordByTimeDTO);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.error("[MeiTian] syncRecordByRecordID failure, errorCode:{}", recordResponse.getErrorCode());
|
||||||
|
return Boolean.FALSE;
|
||||||
|
}
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
boolean doSyncRecordByDate(BetRecordByTimeDTO betRecordByTimeDTO, int daysToSubtract) {
|
||||||
|
|
||||||
|
String date = getDateStr(daysToSubtract);
|
||||||
|
String configKey = GamePlatforms.MeiTian.getCode() + ":lastSyncDate";
|
||||||
|
String syncDateStr = sysConfigServiceImpl.selectConfigByKey(configKey);
|
||||||
|
Map<String, Long> syncDateMap = new HashMap<>();
|
||||||
|
long recordID = 0;
|
||||||
|
if (syncDateStr == null || syncDateStr.isEmpty()) {
|
||||||
|
} else {
|
||||||
|
syncDateMap = JSON.parseObject(syncDateStr, Map.class);
|
||||||
|
}
|
||||||
|
if (syncDateMap.containsKey(date)) {
|
||||||
|
recordID = syncDateMap.get(date);
|
||||||
|
if (syncDateMap.size() > 10) {
|
||||||
|
syncDateMap.clear();
|
||||||
|
syncDateMap.put(date, recordID);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
syncDateMap.put(date, recordID);
|
||||||
|
}
|
||||||
|
String merchantId = betRecordByTimeDTO.getAgentId();
|
||||||
|
Map<String, Object> rawMap = new LinkedHashMap<>();
|
||||||
|
rawMap.put("rowID", recordID);
|
||||||
|
rawMap.put("startTime", date);
|
||||||
|
rawMap.put("endTime", date);
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes(StandardCharsets.UTF_8));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] base64 rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.ERROR.getCode());
|
||||||
|
}
|
||||||
|
|
||||||
|
//获取key
|
||||||
|
MeiTianBetRecordResponseDTO recordResponse =
|
||||||
|
meiTianClient.syncRecordByDate(merchantId, data);
|
||||||
|
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(recordResponse.getErrorCode())) {
|
||||||
|
List<MeiTianBetRecordResponseDTO.DataBean> dataList = recordResponse.getDataList();
|
||||||
|
if (CollectionUtils.isEmpty(dataList)) {
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
//数据插入
|
||||||
|
this.batchInsert(recordResponse);
|
||||||
|
MeiTianBetRecordResponseDTO.DataBean dataBean = dataList.get(dataList.size() - 1);
|
||||||
|
syncDateMap.put(date, Long.parseLong(dataBean.getRowID()));
|
||||||
|
SysConfig config = sysConfigServiceImpl.getByConfigKey(configKey);
|
||||||
|
if (null == config) {
|
||||||
|
config = new SysConfig();
|
||||||
|
config.setConfigKey(configKey);
|
||||||
|
config.setConfigValue(JSON.toJSONString(syncDateMap));
|
||||||
|
sysConfigServiceImpl.insertConfig(config);
|
||||||
|
} else {
|
||||||
|
config.setConfigValue(JSON.toJSONString(syncDateMap));
|
||||||
|
sysConfigServiceImpl.updateConfig(config);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 它每次返回25000条，所以需要判断，如果大于25000条，则继续拉取
|
||||||
|
if (dataList.size() >= 25000) {
|
||||||
|
doSyncRecordByDate(betRecordByTimeDTO, daysToSubtract);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log.error("[MeiTian] syncRecordByDate error, errorCode:{}", recordResponse.getErrorCode());
|
||||||
|
return Boolean.FALSE;
|
||||||
|
}
|
||||||
|
return Boolean.TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 按历史时间获取投注记录
|
||||||
|
*
|
||||||
|
* @param betRecordByTimeDTO 按时间dto投注记录
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean getBetRecordByHistoryTime(BetRecordByTimeDTO betRecordByTimeDTO) {
|
||||||
|
doSyncRecordByDate(betRecordByTimeDTO, 0);
|
||||||
|
doSyncRecordByDate(betRecordByTimeDTO, 1); // yesterday
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 赠送免费局数
|
||||||
|
*
|
||||||
|
* @param createFreeSpinRequest 创建自由旋转请求
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean createFreeSpin(CreateFreeSpinRequestDTO createFreeSpinRequest) {
|
||||||
|
throw new BaseException("暂不支持免费局数");
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取游戏详细信息
|
||||||
|
*
|
||||||
|
* @param getGameDetailRequestDTO 获取游戏详细信息请求dto
|
||||||
|
* @return {@link GetGameDetailResponseDTO }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public GetGameDetailResponseDTO getGameDetail(GetGameDetailRequestDTO getGameDetailRequestDTO) {
|
||||||
|
GameSecretKey gameSecretKey = gameSecretKeyService.selectGameSecretKeyByCode(getGameDetailRequestDTO.getAgentId());
|
||||||
|
|
||||||
|
String key = gameSecretKey.getKey();
|
||||||
|
String merchantId = getGameDetailRequestDTO.getAgentId();
|
||||||
|
Map<String, String> rawMap = new LinkedHashMap<>();
|
||||||
|
rawMap.put("rowID", getGameDetailRequestDTO.getWagersId());
|
||||||
|
rawMap.put("lang", getGameDetailRequestDTO.getLang());
|
||||||
|
|
||||||
|
String rawData = JSON.toJSONString(rawMap);
|
||||||
|
String data = null;
|
||||||
|
try {
|
||||||
|
data = Base64.encode(rawData.getBytes("UTF-8"));
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("[MeiTian] encode rawData failure", e);
|
||||||
|
throw new ApiException(ErrorCode.ERROR.getCode());
|
||||||
|
}
|
||||||
|
String code = Md5Utils.md5New(data + key);
|
||||||
|
MeiTianGameRecordDetailDTO responseDTO = meiTianClient.getGameDetail(merchantId, code, data);
|
||||||
|
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(responseDTO.getErrorCode())) {
|
||||||
|
GetGameDetailResponseDTO getGameDetailResponseDTO = new GetGameDetailResponseDTO();
|
||||||
|
getGameDetailResponseDTO.setUrl(responseDTO.getUrl());
|
||||||
|
return getGameDetailResponseDTO;
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianGameRecordDetailDTO.get(responseDTO.getErrorCode()).getMessage());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 强制会员从游戏注销
|
||||||
|
*
|
||||||
|
* @param kickMemberRequestDTO 踢会员请求dto
|
||||||
|
* @return {@link Boolean }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public Boolean kickMember(KickMemberRequestDTO kickMemberRequestDTO) {
|
||||||
|
|
||||||
|
String merchantId = kickMemberRequestDTO.getAgentId();
|
||||||
|
String playerName = kickMemberRequestDTO.getAccount();
|
||||||
|
|
||||||
|
MeiTianLogoutDTO jiliKickMemberDTO = meiTianClient.kickMember(
|
||||||
|
merchantId,
|
||||||
|
playerName);
|
||||||
|
//判断是否获取成功
|
||||||
|
if (this.isSuccess(jiliKickMemberDTO.getErrorCode())) {
|
||||||
|
return Boolean.TRUE;
|
||||||
|
} else {
|
||||||
|
throw new BaseException(MeiTianLogoutDTO.get(jiliKickMemberDTO.getErrorCode()).getMessage());
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 踢成员全部
|
||||||
|
*
|
||||||
|
* @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 recordResponse 投注记录
|
||||||
|
*/
|
||||||
|
private void batchInsert(MeiTianBetRecordResponseDTO recordResponse) {
|
||||||
|
List<GameBettingDetails> gameBettingDetails = new ArrayList<>();
|
||||||
|
List<String> wagersIds = new ArrayList<>();
|
||||||
|
//数据组装
|
||||||
|
List<MeiTianBetRecordResponseDTO.DataBean> dataList = recordResponse.getDataList();
|
||||||
|
if (CollectionUtils.isEmpty(dataList)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
//数据转化
|
||||||
|
for (MeiTianBetRecordResponseDTO.DataBean dataBean : dataList) {
|
||||||
|
GameBettingDetails bettingDetails = this.dataBuild(GamesDataBuildDTO.builder()
|
||||||
|
.data(dataBean).build());
|
||||||
|
if (!ObjectUtils.isEmpty(bettingDetails)) {
|
||||||
|
bettingDetails.setId(IdUtil.getSnowflakeNextId());
|
||||||
|
gameBettingDetails.add(bettingDetails);
|
||||||
|
}
|
||||||
|
wagersIds.add(dataBean.getRowID());
|
||||||
|
}
|
||||||
|
if (!CollectionUtils.isEmpty(gameBettingDetails)) {
|
||||||
|
//查询重复数据id
|
||||||
|
List<String> removeWagersIds = gameBettingDetailsService.selectGameBettingDetailsByWagersId(wagersIds, GamePlatforms.MeiTian.getCode());
|
||||||
|
//用steam流清除list中与wagersIds集合相同的数据
|
||||||
|
gameBettingDetails = gameBettingDetails.stream()
|
||||||
|
.filter(detail -> !removeWagersIds.contains(detail.getWagersId()))
|
||||||
|
.collect(Collectors.toList());
|
||||||
|
if (!CollectionUtils.isEmpty(gameBettingDetails)) {
|
||||||
|
gameBettingDetailsService.batchInsert(gameBettingDetails);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 数据构建
|
||||||
|
*
|
||||||
|
* @param gamesDataBuildDTO 数据
|
||||||
|
* @return {@link GameBettingDetails }
|
||||||
|
*/
|
||||||
|
@Override
|
||||||
|
public GameBettingDetails dataBuild(GamesDataBuildDTO gamesDataBuildDTO) {
|
||||||
|
|
||||||
|
//转化类
|
||||||
|
MeiTianBetRecordResponseDTO.DataBean dataBean = (MeiTianBetRecordResponseDTO.DataBean) gamesDataBuildDTO.getData();
|
||||||
|
GameSecretKeyCurrencyDTO gameSecretKey =
|
||||||
|
gameSecretKeyCurrencyService.findByGameSecretKeyCurrencyDTO(GameSecretKeyCurrencyDTO.builder()
|
||||||
|
.currency(dataBean.getCurrency())
|
||||||
|
.platformCode(GamePlatforms.MeiTian.getCode()).build());
|
||||||
|
|
||||||
|
|
||||||
|
Member member = memberService.selectMemberByGameAccount(dataBean.getPlayerName());
|
||||||
|
if (ObjectUtils.isEmpty(member)) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
List<MeiTianGameDataDTO> gameDatas = redisCache.getCacheList(CacheConstants.MeiTian_GAMES);
|
||||||
|
Map<String, MeiTianGameDataDTO> dataDTOMap = gameDatas.stream().collect(Collectors.toMap(MeiTianGameDataDTO::getGameId, e -> e));
|
||||||
|
MeiTianGameDataDTO gamesDataDTO = dataDTOMap.get(dataBean.getGameCode());
|
||||||
|
BigDecimal originPayoffAmount = new BigDecimal(dataBean.getIncome()); // 这个值是到手的
|
||||||
|
|
||||||
|
int compareResult = originPayoffAmount.compareTo(BigDecimal.ZERO);
|
||||||
|
long gameTime = getTime(dataBean.getGameDate());
|
||||||
|
//数据构造
|
||||||
|
GameBettingDetails gameBettingDetails = GameBettingDetails.builder()
|
||||||
|
.tenantKey(member.getTenantKey())
|
||||||
|
//保存我们的币种id
|
||||||
|
.currencyCode(gameSecretKey.getSystemCurrency())
|
||||||
|
.memberId(member.getId())
|
||||||
|
.gameCode(dataBean.getGameCode())
|
||||||
|
.gameType(MeiTianGameType.findSystemByCode(Integer.parseInt(dataBean.getGameType())))
|
||||||
|
.platformCode(GamePlatforms.MeiTian.getCode())
|
||||||
|
.gameId(gamesDataDTO.getSystemGameId())
|
||||||
|
.gameName(gamesDataDTO.getCnName())
|
||||||
|
.gameStatus(compareResult > 0 ? GameStatus.WIN.getCode() : compareResult < 0 ? GameStatus.FAIL.getCode() : GameStatus.FLAT.getCode())
|
||||||
|
.gameStatusType(1) // 一般下注
|
||||||
|
.gameCurrencyCode(dataBean.getCurrency())
|
||||||
|
.account(dataBean.getPlayerName())
|
||||||
|
.wagersId(dataBean.getRowID())
|
||||||
|
.wagersTime(gameTime)
|
||||||
|
.betAmount(new BigDecimal(dataBean.getBetAmount()))
|
||||||
|
.payoffTime(gameTime)
|
||||||
|
.payoffAmount(originPayoffAmount.abs())
|
||||||
|
.settlementTime(gameTime)
|
||||||
|
.turnover(new BigDecimal(dataBean.getCommissionable()))
|
||||||
|
.orderNo(dataBean.getRowID())
|
||||||
|
.settlementStatus(SettlementStatusEnum.COMPLETED.getCode())
|
||||||
|
.build();
|
||||||
|
gameBettingDetails.setCreateBy(Constants.SYSTEM);
|
||||||
|
gameBettingDetails.setCreateTime(DateUtils.getNowDate());
|
||||||
|
return gameBettingDetails;
|
||||||
|
}
|
||||||
|
|
||||||
|
public long getTime(String date) {
|
||||||
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||||||
|
try {
|
||||||
|
Date parse = simpleDateFormat.parse(date);
|
||||||
|
return parse.getTime();
|
||||||
|
} catch (ParseException e) {
|
||||||
|
return System.currentTimeMillis();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public LocalDate getDate(int daysToSubtract) {
|
||||||
|
return LocalDate.now().minusDays(daysToSubtract); // 获取当前日期减去两天
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDateStr(int daysToSubtract) {
|
||||||
|
// 获取当前日期减去指定天数
|
||||||
|
LocalDate date = LocalDate.now().minusDays(daysToSubtract);
|
||||||
|
|
||||||
|
// 定义日期格式
|
||||||
|
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
||||||
|
|
||||||
|
// 返回格式化日期字符串
|
||||||
|
return date.format(formatter);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue