In seamless integration, a member's balance is stored on the merchant side. Merchant will be required to expose a certain API for the KPLAY system to call during the launching and in-play of the games provided.
In order for the seamless integration to work, merchants will be required to have an endpoint with the APIs listed below.
• Debit – API to deduct player’s money
• Credit – API to add back player’s money
• Balance – API to get latest player’s money
• Bonus – API to get player’s bonus (Applicable for slot only)
• Buyin – API to deduct player’s money for fishing game (Applicable for fishing only)
1.9 Data Flow and Cronjob
In KPLAY, every debit will be paired with a credit. The linkage is done through a matching txn_id. All debit without a credit should be considered as pending. Merchant have to prepare cronjob which monitor pending debits and use results API
to settle it within 10 minutes of debit call time.
2. AUTH (Mandatory)
Merchant will call this API to launch the game. API will automatically create or update member's info.
HTTP methods : POST
Live Casino URL : <KPLAY endpoint>/auth
2.1 Request Format
Header
Field
Type
Description
Mandatory
ag-code
string
KPLAY merchant code
y
ag-token
string
KPLAY merchant code
y
Body
Field
Type
Description
Mandatory
user
object
y
user.id
integer
Unique identifier for user
Length 9
y
user.name
string
Unique name for the user. Name can't be changed once it is created.
For slots, the format for the call back URL will be http://{domain_url}/slots/{product_id}/{type}?isMobile=false. You are required to map this call back URL back to this auth method (section 2. User authentication), passing in the {product_id}
and {type} variable to launch the slot game.
public function __construct()
{
//Get constant from constant.php (merchant Code/ merchant Token/ merchant Secret Key)
$this->KPLAYHostname = KPLAY_HOSTNAME;
$this->KPLAYCode = KPLAY_CODE;
$this->KPLAYToken = KPLAY_TOKEN;
$this->KPLAYSecretKey = KPLAY_SECRET_KEY;
}
public function getGame($gameId,$type,$isMobile)
{
try
{
$memberId = EXAMPLE_MEMBER_ID;
$domainUrl = DOMAIN_URL;
//get DB from constant.php
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if DB error
if ($conn->connect_error)
{
var_dump("Connection failed: " . $conn->connect_error);exit;
}
//select id/balance/username from db
//select member 10001
$selectBalance = "SELECT a.user_id,a.balance,b.username
FROM users_balance a
LEFT JOIN users b
ON a.user_id = b.user_id
WHERE a.user_id = ".$memberId;
// var_dump($selectBalance);exit;
$db = $conn->query($selectBalance);
if ($db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
$balance = $row['balance'];//member Balance for KPLAY
$userName = $row['username']; //member Name for KPLAY
}
}
else
{
var_dump('USER_DOES_NOT_HAVE_BALANCE');exit;
}
$locale = 'en'; //language (en/ko) English/Korean
$hostName = $this->KPLAYHostname; //KPLAY Hostname
$token = $this->KPLAYToken; //KPLAY Token
$agent = $this->KPLAYCode; //KPLAY Code
$method = 'auth'; //auth game method
$url = $hostName.$method; //auth game endpoint
//check is it mobile version
if($isMobile == '1' || $isMobile)
{
$isMobile = true;
}
else
{
$isMobile = false;
}
//prepare header
$header = [
'Content-Type: application/json',
'Ag-Code: '.$agent,
'Ag-Token:'.$token,
];
//prepare data
$data = [
'user' =>
[
'id' => $userId
,'name' => $userName
,'balance' => $balance
,'language' => $locale
],
'prd' =>
[
'id' => $gameId
,'type' => $type
,'is_mobile' => $isMobile
]
];
if($gameId == 0 || ($gameId >= 200 && $gameId < 300))
{
$data['user']['domain_url'] = $domainUrl;
}
//post header&data via helper curl
$helper = new Helper;
$response = $helper->postData($url,$data,$header);
$data = json_decode($response);
//get IFRAME and KPLAY ID from response
$iframe = $data->launch_url;
$KPLAYId = $data->user_id;
//pass these variable to update user details
self::updateKPLAYUsers($userId,$KPLAYId);
//return Iframe
return $iframe;
}
catch(\Exception $e)
{
var_dump($e);exit;
}
}
public static function updateKPLAYUsers($userId,$KPLAYId)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error)
{
var_dump("Connection failed: " . $conn->connect_error);exit;
}
//insert User to DB
$insertSQL = "INSERT INTO users (user_id,KPLAY_id)
VALUES (".$userId.",".$KPLAYId.")
ON duplicate key UPDATE
KPLAY_id = ".$KPLAYId;
$db = $conn->query($insertSQL);
}
catch (Exception $e)
{
var_dump($e);exit;
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonElement;
public class Auth {
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public Auth() {
// Get constants from constant.java (merchant Code/ merchant Token/ merchant Secret Key)
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
}
public String getGame(int gameId, String type, boolean isMobile) {
try {
String memberId = constant.EXAMPLE_MEMBER_ID;
String domainUrl = constant.DOMAIN_URL;
// Get DB connection details from constant.java
String servername = constant.DB_SERVER_NAME;
String username = constant.DB_USERNAME;
String password = constant.DB_PASSWORD;
String dbname = constant.DB_NAME;
Connection conn = DriverManager.getConnection("jdbc:mysql://" + servername + "/" + dbname, username, password);
// If DB error
if (conn == null) {
System.out.println("Connection failed");
return null;
}
// Select id/balance/username from db
// Select member 10001
String selectBalance = "SELECT a.user_id, a.balance, b.username " +
"FROM users_balance a " +
"LEFT JOIN users b ON a.user_id = b.user_id " +
"WHERE a.user_id = " + memberId;
Statement statement = conn.createStatement();
ResultSet resultSet = statement.executeQuery(selectBalance);
int userId = 0;
int balance = 0;
String userName = "";
if (resultSet.next()) {
userId = resultSet.getInt("user_id"); // member ID for KPLAY
balance = resultSet.getInt("balance"); // member Balance for KPLAY
userName = resultSet.getString("username"); // member Name for KPLAY
} else {
System.out.println("USER_DOES_NOT_HAVE_BALANCE");
return null;
}
String locale = "en"; // language (en/ko) English/Korean
String hostName = this.KPLAYHostname; // KPLAY Hostname
String token = this.KPLAYToken; // KPLAY Token
String agent = this.KPLAYCode; // KPLAY Code
String method = "auth"; // auth game method
String url = hostName + method; // auth game endpoint
// Check if it's the mobile version
if (isMobile) {
isMobile = true;
} else {
isMobile = false;
}
// Prepare header
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("Ag-Code", agent);
header.put("Ag-Token", token);
// Prepare data
Map data = new HashMap<>();
Map user = new HashMap<>();
user.put("id", userId);
user.put("name", userName);
user.put("balance", balance);
user.put("language", locale);
Map prd = new HashMap<>();
prd.put("id", gameId);
prd.put("type", type);
prd.put("is_mobile", isMobile);
data.put("user", user);
data.put("prd", prd);
if (gameId == 0 || (gameId >= 200 && gameId < 300)) {
data.put("domain_url", domainUrl);
}
String response = Helper.postData(url, data, header);
// Parse the response JSON
// (You can use a JSON library like Jackson or Gson for this)
// Example:
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject)jsonParser.parse(response);
JsonElement iframeElement = jo.get("launch_url");
String iframe = (iframeElement != null && !iframeElement.isJsonNull()) ? iframeElement.getAsString() : null;
JsonElement KPLAYIdElement = jo.get("user_id");
int KPLAYId = (KPLAYIdElement != null && !KPLAYIdElement.isJsonNull()) ? KPLAYIdElement.getAsInt() : 0;
// Pass these variables to update user details
updateKPLAYUsers(userId, KPLAYId);
// Return Iframe
// (You would need to return the appropriate data based on your JSON parsing)
return iframe;
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}
public static void updateKPLAYUsers(int userId, int KPLAYId) {
try {
// DB connection
String servername = constant.DB_SERVER_NAME;
String username = constant.DB_USERNAME;
String password = constant.DB_PASSWORD;
String dbname = constant.DB_NAME;
Connection conn = DriverManager.getConnection("jdbc:mysql://" + servername + "/" + dbname, username, password);
if (conn == null) {
System.out.println("Connection failed");
return;
}
// Insert User to DB
String insertSQL = "INSERT INTO users (user_id, KPLAY_id) " +
"VALUES (" + userId + ", " + KPLAYId + ") " +
"ON DUPLICATE KEY UPDATE KPLAY_id = " + KPLAYId;
Statement statement = conn.createStatement();
statement.executeUpdate(insertSQL);
} catch (SQLException e) {
e.printStackTrace();
}
}
}
using System;
using System.Data;
using System.Data.SqlClient;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using Newtonsoft.Json.Linq;
public class Auth
{
private readonly string KPLAYHostname;
private readonly string KPLAYCode;
private readonly string KPLAYToken;
private readonly string KPLAYSecretKey;
public Auth()
{
// Get constants from constant.cs
KPLAYHostname = Constants.KPLAYHostname;
KPLAYCode = Constants.KPLAYCode;
KPLAYToken = Constants.KPLAYToken;
KPLAYSecretKey = Constants.KPLAYSecretKey;
}
public async Task GetGame(int gameId, string type, bool isMobile)
{
try
{
int memberId = Constants.ExampleMemberId;
string domainUrl = Constants.DomainUrl;
// Database connection
string connectionString = Constants.DbConnectionString;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Select id/balance/username from the database
string selectBalance = $"SELECT a.user_id, a.balance, b.username FROM users_balance a " +
$"LEFT JOIN users b ON a.user_id = b.user_id " +
$"WHERE a.user_id = {memberId}";
using (SqlCommand cmd = new SqlCommand(selectBalance, conn))
{
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (reader.Read())
{
int userId = reader.GetInt32(0); // Member ID for KPLAY
decimal balance = reader.GetDecimal(1); // Member Balance for KPLAY
string userName = reader.GetString(2); // Member Name for KPLAY
string locale = "en"; // Language (en/ko) English/Korean
string hostName = KPLAYHostname; // KPLAY Hostname
string token = KPLAYToken; // KPLAY Token
string agent = KPLAYCode; // KPLAY Code
string method = "auth"; // Auth game method
string url = hostName + method; // Auth game endpoint
if (isMobile)
{
isMobile = true;
}
else
{
isMobile = false;
}
// Prepare headers
var headers = new Dictionary
{
{ "Content-Type", "application/json" },
{ "Ag-Code", agent },
{ "Ag-Token", token }
};
// Prepare data
var userData = new
{
id = userId,
name = userName,
balance = balance,
language = locale
};
var productData = new
{
id = gameId,
type = type,
is_mobile = isMobile
};
var data = new
{
user = userData,
prd = productData
};
if (gameId == 0 || (gameId >= 200 && gameId < 300))
{
data.user.domain_url = domainUrl;
}
// Post header & data via HttpClient
using (HttpClient httpClient = new HttpClient())
{
foreach (var header in headers)
{
httpClient.DefaultRequestHeaders.Add(header.Key, header.Value);
}
var json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
var content = new StringContent(json, Encoding.UTF8, "application/json");
HttpResponseMessage response = await httpClient.PostAsync(url, content);
string responseContent = await response.Content.ReadAsStringAsync();
dynamic responseData = JObject.Parse(responseContent);
// Get IFRAME and KPLAY ID from the response
string iframe = responseData.launch_url;
int KPLAYId = responseData.user_id;
// Pass these variables to update user details
UpdateKPLAYUsers(userId, KPLAYId);
// Return IFrame
return iframe;
}
}
else
{
throw new Exception("USER_DOES_NOT_HAVE_BALANCE");
}
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
throw;
}
}
public static void UpdateKPLAYUsers(int userId, int KPLAYId)
{
try
{
// Database connection
string connectionString = Constants.DbConnectionString;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Insert user into the database
string insertSQL = $"INSERT INTO users (user_id, KPLAY_id) VALUES ({userId}, {KPLAYId}) " +
$"ON DUPLICATE KEY UPDATE KPLAY_id = {KPLAYId}";
using (SqlCommand cmd = new SqlCommand(insertSQL, conn))
{
cmd.ExecuteNonQuery();
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
throw;
}
}
}
<%
Sub GetGame(gameId, type, isMobile)
On Error Resume Next
Dim memberId, domainUrl, servername, username, password, dbname, conn, selectBalance, db, userId, balance, userName
Dim locale, hostName, token, agent, method, url, header, data, isMobileBool, ch, responseKPLAY, iframe, KPLAYId
' Constants
Const EXAMPLE_MEMBER_ID = 10001
Const DOMAIN_URL = "your_domain_url_here"
Const DB_SERVER_NAME = "your_db_server_name_here"
Const DB_USERNAME = "your_db_username_here"
Const DB_PASSWORD = "your_db_password_here"
Const DB_NAME = "your_db_name_here"
' Set constants and variables
memberId = EXAMPLE_MEMBER_ID
domainUrl = DOMAIN_URL
servername = DB_SERVER_NAME
username = DB_USERNAME
password = DB_PASSWORD
dbname = DB_NAME
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & servername & ";Initial Catalog=" & dbname & ";User ID=" & username & ";Password=" & password
' Check for a database connection error
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Exit Sub
End If
' SQL query to select balance and username
selectBalance = "SELECT a.user_id, a.balance, b.username " & _
"FROM users_balance a " & _
"LEFT JOIN users b ON a.user_id = b.user_id " & _
"WHERE a.user_id = " & memberId
' Execute the SQL query
Set db = conn.Execute(selectBalance)
' Check if any rows were returned
If Not db.EOF Then
userId = db("user_id")
balance = db("balance")
userName = db("username")
Else
Response.Write "USER_DOES_NOT_HAVE_BALANCE"
Exit Sub
End If
' Set language/locale
locale = "en"
' Constants for KPLAY configuration
hostName = "your_KPLAY_hostname_here"
token = "your_KPLAY_token_here"
agent = "your_KPLAY_code_here"
' Game method and endpoint
method = "auth"
url = hostName & method
' Check if it's a mobile version
If isMobile = "1" Or isMobile Then
isMobileBool = True
Else
isMobileBool = False
End If
' Prepare headers
Set header = Server.CreateObject("Scripting.Dictionary")
header("Content-Type") = "application/json"
header("Ag-Code") = agent
header("Ag-Token") = token
' Prepare data
Set data = Server.CreateObject("Scripting.Dictionary")
Set userData = Server.CreateObject("Scripting.Dictionary")
Set prdData = Server.CreateObject("Scripting.Dictionary")
userData("id") = userId
userData("name") = userName
userData("balance") = balance
userData("language") = locale
prdData("id") = gameId
prdData("type") = type
prdData("is_mobile") = isMobileBool
data.Add "user", userData
data.Add "prd", prdData
' Add domain_url if game ID conditions are met
If gameId = 0 Or (gameId >= 200 And gameId < 300) Then
userData("domain_url") = domainUrl
End If
' Create a request using ServerXMLHTTP
Set ch = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
ch.open "POST", url, False
For Each key In header.Keys
ch.setRequestHeader key, header(key)
Next
dataStr = JSONStringify(data)
ch.send dataStr
responseKPLAY = ch.responseText
' Parse the response JSON
Set data = JSONParse(responseKPLAY)
' Get the iframe and KPLAY ID from the response
iframe = data("launch_url")
KPLAYId = data("user_id")
' Close the database connection
conn.Close
Set conn = Nothing
' Return the iframe
GetGame = iframe
End Sub
' Sub to parse JSON data
Sub JSONParse(jsonString)
Dim json, jsonText
Set json = Server.CreateObject("MSXML2.DOMDocument.6.0")
json.async = False
json.loadXML jsonString
If Not json.parseError.errorCode Then
Set JSONParse = ParseJSONObject(json.documentElement)
Else
Set JSONParse = Nothing
End If
End Sub
' Sub to parse JSON object
Sub ParseJSONObject(objJSON)
Dim json, pair, key, value
Set json = Server.CreateObject("Scripting.Dictionary")
For Each pair In objJSON.ChildNodes
key = pair.ChildNodes.Item(0).Text
If pair.ChildNodes.Item(1).baseName = "Object" Then
Set value = ParseJSONObject(pair.ChildNodes.Item(1))
Else
value = pair.ChildNodes.Item(1).Text
End If
json(key) = value
Next
Set ParseJSONObject = json
End Sub
' Sub to convert a dictionary to JSON string
Sub JSONStringify(jsonData)
Dim jsonStr, key, value, valueType
jsonStr = "{"
For Each key In jsonData.Keys
value = jsonData(key)
valueType = VarType(value)
If Len(jsonStr) > 1 Then
jsonStr = jsonStr & ","
End If
jsonStr = jsonStr & """" & key & """:"
Select Case valueType
Case 8 ' String
jsonStr = jsonStr & """" & Replace(value, """", "\""") & """"
Case 3 ' Integer
jsonStr = jsonStr & value
Case Else
jsonStr = jsonStr & "null"
End Select
Next
jsonStr = jsonStr & "}"
JSONStringify = jsonStr
End Sub
%>
3. DEBIT (Mandatory)
KPLAY will call this API in the merchant system to notify merchants that a debit occurs.
HTTP methods : POST
URL : <Merchant endpoint>/debit
3.1 Request Format
Header
Field
Type
Description
secret-key
string
KPLAY merchant secret key. For merchants to verify the request comes from KPLAY.
Body
Field
Type
Description
user_id
integer
KPLAY user ID
amount
decimal(15, 2)
Debit amount
prd_id
integer
Product ID
txn_id
string
Unique transaction ID, also used to be paired with credit call.
game_id
integer
Game ID available to call using product game list API. Refer to 10. Product Game List
*Note:
Game ID of DG and IM will be always zero in debit requests. If you need the Game ID, please call the “Results” API to update the game ID.
Product(s) affected:-
➢ DG
➢ IM
table_id
string
Table ID
* Only applicable for Evo Live Casino
round_id
string
Round ID
* Only applicable after 24/07/2024 (KRW)
Product(s) which not include the round id:-
➢ Dream Gaming
➢ Beter Esports
➢ Spade Gaming
➢ FastSpin
credit_amount
decimal(15, 2)
If credit_amount exists, then AG needs to generate credit settlement for it.
Check if a debit with the same “txn_id” exists in the merchant system.
INSUFFICIENT_FUNDS
Check if the member has enough balance for the debit.
UNKNOWN_ERROR
Internal error in the merchant system.
*Note: Game ID of DG and E-sport will be always zero in debit requests. If you need the Game ID, please call the “Results” API to update the game ID.
*Note: When debit = 0, AG must return response with status = 1.
function processDebit($data)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if connect to DB failed
if ($conn->connect_error)
{
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
$conn->begin_transaction();
//get data from debit request
$param = json_decode($data);
$KPLAYId = $param->user_id;
$amount = $param->amount;
$txnId = $param->txn_id;
$prdId = $param->prd_id;
$gameId = $param->game_id;
$type = $param->type;
$credit = null; //some slots will send debit and credit pair
if(isset($param->credit_amount))
{
$credit = $param->credit_amount;
}
//select member from DB
$selectSQL = "SELECT user_id
FROM users
WHERE KPLAY_id = ".$KPLAYId;
$db = $conn->query($selectSQL);
//check if member exist
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
$selectSQL = "SELECT balance
FROM users_balance
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
//check if member have balance
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$balance = $row['balance'];//member balance
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
//Check if the balance is enough for the bet amount
if ($balance >= $amount)
{
$balance = $balance - $amount;
$selectSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
}
else
{
$conn->rollback();
//if INSUFFICIENT_FUNDS
return $response = [
'status' => 0
,'error' => 'INSUFFICIENT_FUNDS'
];
}
//Check if this transaction already in database
$selectSQL = "SELECT txn_id
FROM debit
WHERE txn_id = '".$txnId."'";
$db = $conn->query($selectSQL);
//If transaction already in database
if (isset($db->num_rows) && $db->num_rows > 0)
{
$conn->rollback();
return $response = [
'status' => 0
,'error' => 'DUPLICATE_DEBIT'
];
}
else
{
$insertSQL = "INSERT INTO debit
(user_id,amount,txn_id,prd_id,game_id,type)
VALUES
(".$userId.",".$amount.",'".$txnId."',".$prdId.",".$gameId.",".$type.")";
$db = $conn->query($insertSQL);
if(!is_null($credit))
{//do credit
//Insert credit record to DB
$insertCreditSQL = "INSERT INTO credit
(txn_id,type,amount)
VALUES
('".$txnId."','c',".$credit.")";
$db = $conn->query($insertCreditSQL);
//Update user balance
$balance = $balance + $credit;
$updateCreditSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($updateCreditSQL);
}
$conn->commit();
return $response = [
'status' => 1
,'balance' => $balance
];
}
}
catch (Exception $e)
{
$conn->rollback();
//if error
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.json.JSONObject;
import org.springframework.ejb.access.EjbAccessException;
public class Debit {
private String servername;
private String username;
private String password;
private String dbname;
public Debit() {
// Initialize constants from constant.java (DB Server, Username, Password, DB Name)
this.servername = constant.DB_SERVER_NAME;
this.username = constant.DB_USERNAME;
this.password = constant.DB_PASSWORD;
this.dbname = constant.DB_NAME;
}
public Map processDebit(String data) {
Map response = new HashMap<>();
try {
// Database connection
String jdbcUrl = "jdbc:mysql://" + servername + "/" + dbname;
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// If the connection to the database fails
if (conn == null) {
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
conn.setAutoCommit(false); // Start a transaction
// Parsing JSON data (Assuming you have implemented parseJson method)
Map param = parseJson(data);
int KPLAYId = (int) param.get("user_id");
double amount = (double) param.get("amount");
String txnId = (String) param.get("txn_id");
int prdId = (int) param.get("prd_id");
int gameId = (int) param.get("game_id");
Double credit = (Double) param.get("credit_amount");
// Select member from DB
String selectUserSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement userStatement = conn.prepareStatement(selectUserSQL);
userStatement.setInt(1, KPLAYId);
ResultSet userResultSet = userStatement.executeQuery();
int userId = 0;
if (userResultSet.next()) {
userId = userResultSet.getInt("user_id");
} else {
// If member does not exist
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Select balance from the user balance table
String selectBalanceSQL = "SELECT balance FROM users_balance WHERE user_id = ?";
PreparedStatement balanceStatement = conn.prepareStatement(selectBalanceSQL);
balanceStatement.setInt(1, userId);
ResultSet balanceResultSet = balanceStatement.executeQuery();
double userBalance = 0.0;
if (balanceResultSet.next()) {
userBalance = balanceResultSet.getDouble("balance");
} else {
// If member does not have a balance
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Check if the balance is enough for the bet amount
if (userBalance >= amount) {
userBalance -= amount;
String updateBalanceSQL = "UPDATE users_balance SET balance = ? WHERE user_id = ?";
PreparedStatement updateBalanceStatement = conn.prepareStatement(updateBalanceSQL);
updateBalanceStatement.setDouble(1, userBalance);
updateBalanceStatement.setInt(2, userId);
int rowsUpdated = updateBalanceStatement.executeUpdate();
if (rowsUpdated != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_BALANCE_ERROR");
return response;
}
// Check if this transaction already exists in the database
String selectDebitSQL = "SELECT txn_id FROM debit WHERE txn_id = ?";
PreparedStatement debitStatement = conn.prepareStatement(selectDebitSQL);
debitStatement.setString(1, txnId);
ResultSet debitResultSet = debitStatement.executeQuery();
if (debitResultSet.next()) {
conn.rollback();
response.put("status", 0);
response.put("error", "DUPLICATE_DEBIT");
return response;
} else {
// Insert debit record into DB
String insertDebitSQL = "INSERT INTO debit (user_id, amount, txn_id, prd_id, game_id) " +
"VALUES (?, ?, ?, ?, ?)";
PreparedStatement insertDebitStatement = conn.prepareStatement(insertDebitSQL);
insertDebitStatement.setInt(1, userId);
insertDebitStatement.setDouble(2, amount);
insertDebitStatement.setString(3, txnId);
insertDebitStatement.setInt(4, prdId);
insertDebitStatement.setInt(5, gameId);
int rowsInsertedDebit = insertDebitStatement.executeUpdate();
if (rowsInsertedDebit != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_DEBIT_ERROR");
return response;
}
if (credit != null) {
// Insert credit record into DB
String insertCreditSQL = "INSERT INTO credit (txn_id, type, amount) VALUES (?, 'c', ?)";
PreparedStatement insertCreditStatement = conn.prepareStatement(insertCreditSQL);
insertCreditStatement.setString(1, txnId);
insertCreditStatement.setDouble(2, credit);
int rowsInsertedCredit = insertCreditStatement.executeUpdate();
if (rowsInsertedCredit != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_CREDIT_ERROR");
return response;
}
// Update user balance
userBalance += credit;
updateBalanceStatement.setDouble(1, userBalance);
rowsUpdated = updateBalanceStatement.executeUpdate();
if (rowsUpdated != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_BALANCE_ERROR");
return response;
}
}
conn.commit();
response.put("status", 1);
response.put("balance", userBalance);
return response;
}
} else {
conn.rollback();
// If INSUFFICIENT_FUNDS
response.put("status", 0);
response.put("error", "INSUFFICIENT_FUNDS");
return response;
}
} catch (SQLException e) {
e.printStackTrace();
// If there is an error
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
}
// Function to parse JSON data into a map using org.json
private Map parseJson(String json) {
Map resultMap = new HashMap<>();
try {
// Create a JSON object from the input JSON string
JSONObject jsonObject = new JSONObject();
// Iterate through the keys in the JSON object and add them to the map
for (String key : jsonObject.keySet()) {
Object value = jsonObject.get(key);
resultMap.put(key, value);
}
return resultMap;
} catch (EjbAccessException e) {
e.printStackTrace(); // Handle the exception appropriately
return null; // Return null in case of parsing error
}
}
}
using System;
using System.Data;
using System.Data.SqlClient;
public class Debit
{
public dynamic ProcessDebit(string data)
{
try
{
// Database connection
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction transaction = conn.BeginTransaction())
{
// Deserialize the JSON data
dynamic param = Newtonsoft.Json.JsonConvert.DeserializeObject(data);
int KPLAYId = param.user_id;
decimal amount = param.amount;
string txnId = param.txn_id;
int prdId = param.prd_id;
int gameId = param.game_id;
string type = param.type;
decimal? credit = null;
if (param.credit_amount != null)
{
credit = param.credit_amount;
}
// Select member from the database
string selectSQL = $"SELECT user_id FROM users WHERE KPLAY_id = {KPLAYId}";
using (SqlCommand cmd = new SqlCommand(selectSQL, conn, transaction))
{
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (reader.Read())
{
int userId = reader.GetInt32(0); // Member ID for KPLAY
// Select balance for the user
string selectBalanceSQL = $"SELECT balance FROM users_balance WHERE user_id = {userId}";
using (SqlCommand balanceCmd = new SqlCommand(selectBalanceSQL, conn, transaction))
{
using (SqlDataReader balanceReader = balanceCmd.ExecuteReader())
{
if (balanceReader.Read())
{
decimal balance = balanceReader.GetDecimal(0); // Member balance
// Check if the balance is enough for the bet amount
if (balance >= amount)
{
balance -= amount;
string updateBalanceSQL = $"UPDATE users_balance SET balance = {balance} WHERE user_id = {userId}";
using (SqlCommand updateBalanceCmd = new SqlCommand(updateBalanceSQL, conn, transaction))
{
updateBalanceCmd.ExecuteNonQuery();
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INSUFFICIENT_FUNDS"
};
}
// Check if this transaction already exists in the database
string selectDebitSQL = $"SELECT txn_id FROM debit WHERE txn_id = '{txnId}'";
using (SqlCommand debitCmd = new SqlCommand(selectDebitSQL, conn, transaction))
{
using (SqlDataReader debitReader = debitCmd.ExecuteReader())
{
if (debitReader.Read())
{
transaction.Rollback();
return new
{
status = 0,
error = "DUPLICATE_DEBIT"
};
}
}
}
string insertDebitSQL = "INSERT INTO debit " +
"(user_id, amount, txn_id, prd_id, game_id, type) " +
$"VALUES ({userId}, {amount}, '{txnId}', {prdId}, {gameId}, {type})";
using (SqlCommand insertDebitCmd = new SqlCommand(insertDebitSQL, conn, transaction))
{
insertDebitCmd.ExecuteNonQuery();
}
if (credit != null)
{
// Insert credit record into the database
string insertCreditSQL = "INSERT INTO credit " +
"(txn_id, type, amount) " +
$"VALUES ('{txnId}', 'c', {credit})";
using (SqlCommand insertCreditCmd = new SqlCommand(insertCreditSQL, conn, transaction))
{
insertCreditCmd.ExecuteNonQuery();
}
// Update user balance
balance += (decimal)credit;
string updateCreditSQL = $"UPDATE users_balance SET balance = {balance} WHERE user_id = {userId}";
using (SqlCommand updateCreditCmd = new SqlCommand(updateCreditSQL, conn, transaction))
{
updateCreditCmd.ExecuteNonQuery();
}
}
transaction.Commit();
return new
{
status = 1,
balance = balance
};
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
return new
{
status = 0,
error = "UNKNOWN_ERROR"
};
}
}
}
<%
Sub ProcessDebit(data)
On Error Resume Next
' Database connection parameters
Dim servername, username, password, dbname, conn, selectSQL, db, userId, balance
Dim KPLAYId, amount, txnId, prdId, gameId, type, credit, responseKPLAY
' Constants
Const DB_SERVER_NAME = "your_db_server_name_here"
Const DB_USERNAME = "your_db_username_here"
Const DB_PASSWORD = "your_db_password_here"
Const DB_NAME = "your_db_name_here"
' Set database connection parameters
servername = DB_SERVER_NAME
username = DB_USERNAME
password = DB_PASSWORD
dbname = DB_NAME
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & servername & ";Initial Catalog=" & dbname & ";User ID=" & username & ";Password=" & password
' Check for a database connection error
If Err.Number <> 0 Then
Response.Write "Database connection failed: " & Err.Description
Exit Sub
End If
' Start a transaction
conn.BeginTrans
' Parse JSON data from the request
Dim json, jsonObject
Set json = JSONParse(data)
' Extract data from the JSON object
KPLAYId = json("user_id")
amount = json("amount")
txnId = json("txn_id")
prdId = json("prd_id")
gameId = json("game_id")
type = json("type")
' Check for the presence of credit_amount in the JSON
If IsObject(json("credit_amount")) Then
credit = json("credit_amount")
Else
credit = Null
End If
' Select a user based on KPLAY_id
selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = " & KPLAYId
Set db = conn.Execute(selectSQL)
' Check if a user exists
If Not db.EOF Then
userId = db("user_id")
Else
' Rollback the transaction and return an error response
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INVALID_USER""}"
Exit Sub
End If
' Select the balance of the user
selectSQL = "SELECT balance FROM users_balance WHERE user_id = " & userId
Set db = conn.Execute(selectSQL)
' Check if the user has a balance
If Not db.EOF Then
balance = db("balance")
Else
' Rollback the transaction and return an error response
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INVALID_USER""}"
Exit Sub
End If
' Check if the balance is enough for the bet amount
If balance >= amount Then
balance = balance - amount
' Update the user's balance
selectSQL = "UPDATE users_balance SET balance = " & balance & " WHERE user_id = " & userId
conn.Execute selectSQL
Else
' Rollback the transaction and return an error response
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INSUFFICIENT_FUNDS""}"
Exit Sub
End If
' Check if the transaction already exists in the database
selectSQL = "SELECT txn_id FROM debit WHERE txn_id = '" & txnId & "'"
Set db = conn.Execute(selectSQL)
' If the transaction already exists, rollback the transaction and return an error response
If Not db.EOF Then
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""DUPLICATE_DEBIT""}"
Exit Sub
End If
' Insert the debit transaction into the database
selectSQL = "INSERT INTO debit (user_id, amount, txn_id, prd_id, game_id, type) VALUES
(" & userId & "," & amount & ",'" & txnId & "'," & prdId & "," & gameId & "," & type & ")"
conn.Execute selectSQL
' If credit is provided, process it
If Not IsNull(credit) Then
' Insert the credit transaction into the database
selectSQL = "INSERT INTO credit (txn_id, type, amount) VALUES ('" & txnId & "','c'," & credit & ")"
conn.Execute selectSQL
' Update the user's balance with the credit amount
balance = balance + credit
selectSQL = "UPDATE users_balance SET balance = " & balance & " WHERE user_id = " & userId
conn.Execute selectSQL
End If
' Commit the transaction
conn.CommitTrans
' Return a success response
Response.Write "{""status"":1,""balance"":" & balance & "}"
' Clean up resources
db.Close
conn.Close
Set db = Nothing
Set conn = Nothing
End Sub
' Sub to parse JSON data
Sub JSONParse(jsonString)
Dim json, jsonText
Set json = Server.CreateObject("MSXML2.DOMDocument.6.0")
json.async = False
json.loadXML jsonString
Set jsonText = json.documentElement
Set JSONParse = JSONText
End Sub
%>
4. CREDIT (Mandatory)
KPLAY will call this API in the merchant system to notify merchants that a credit occurs. (TIP: please beware and handle concurrent requests send by KPLAY).
HTTP methods : POST
URL : <Merchant endpoint>/credit
4.1 Request Format
Header
Field
Type
Description
secret-key
string
KPLAY merchant secret key. For merchants to verify the request comes from KPLAY.
Body
Field
Type
Description
user_id
integer
KPLAY user ID
amount
decimal(15,2)
Credit amount
prd_id
integer
Product ID
txn_id
string
Unique transaction ID, also used to pair with debit call.
is_cancel
integer
Normal credit = 0
Credit due to cancel or refund = 1
game_id
integer
Game ID
* Only applicable for Evo Live Casino
table_id
string
Table ID
* Only applicable for Evo Live Casino
round_id
string
Round ID
* Only applicable after 24/07/2024 (KRW)
Product(s) which not include the round id:-
➢ Dream Gaming
➢ Beter Esports
➢ Spade Gaming
➢ FastSpin
total_bet
decimal(15,2)
Total bet amount
* Only applicable for Hidden Poker
rake
decimal(15,2)
Total rake amount
* Only applicable for Hidden Poker
4.2 Request Example
{
"user_id":1000011,
"amount":195.00,
"prd_id":1,
"txn_id":"A00000005",
"is_cancel":0,
"round_id":"343093"
}
4.3 Response Format
Field
Type
Description
status
integer
0 = error
1 = success
balance
decimal(15,2)
Latest member balance
error
string
Error message when status = 0
4.4 Response Example
When success
{
"status":1,
"balance":505.50
}
When error
{
"status":0,
"error":"ACCESS_DENIED"
}
Error message
Description
ACCESS_DENIED
Invalid secret key.
INVALID_USER
Check if a user exists in the merchant system.
INVALID_DEBIT
Check if a debit exists with the key “txn_id” in the merchant system.
DUPLICATE_CREDIT
Check if a credit with the same “txn_id” exists in the merchant system.
UNKNOWN_ERROR
Internal error in the merchant system
function processCredit($data)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if connect to DB failed
if ($conn->connect_error)
{
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
$conn->begin_transaction();
//get data from debit request
$param = json_decode($data);
$KPLAYId = $param->user_id;
$amount = $param->amount;
$txnId = $param->txn_id;
//select member from DB
$selectSQL = "SELECT user_id
FROM users
WHERE KPLAY_id = ".$KPLAYId;
$db = $conn->query($selectSQL);
//check if member exist
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
$selectSQL = "SELECT balance
FROM users_balance
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
//check if member have balance
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$balance = $row['balance'];//member balance
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
//Check if this debit exist in database
$selectSQL = "SELECT txn_id
FROM debit
WHERE txn_id = '".$txnId."'";
$db = $conn->query($selectSQL);
//Check if this debit exist in database
if (isset($db->num_rows) && $db->num_rows <= 0)
{
$conn->rollback();
return $response = [
'status' => 0
,'error' => 'INVALID_DEBIT'
];
}
//Check if this credit already exist in database
$selectSQL = "SELECT txn_id
FROM credit
WHERE txn_id = '".$txnId."'";
$db = $conn->query($selectSQL);
//Check if this credit already exist in database
if (isset($db->num_rows) && $db->num_rows > 0)
{
$conn->rollback();
return $response = [
'status' => 0
,'error' => 'DUPLICATE_CREDIT'
];
}
else
{
//Insert credit record to DB
$insertSQL = "INSERT INTO credit
(txn_id,type,amount)
VALUES
('".$txnId."','c',".$amount.")";
$db = $conn->query($insertSQL);
//Update user balance
$balance = $balance + $amount;
$updateSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($updateSQL);
$conn->commit();
return $response = [
'status' => 1
,'balance' => $balance
];
}
}
catch (Exception $e)
{
$conn->rollback();
//if error
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.json.JSONObject;
import org.springframework.ejb.access.EjbAccessException;
public class Credit {
private String servername;
private String username;
private String password;
private String dbname;
public Credit() {
// Initialize constants from constant.java (DB Server, Username, Password, DB Name)
this.servername = constant.DB_SERVER_NAME;
this.username = constant.DB_USERNAME;
this.password = constant.DB_PASSWORD;
this.dbname = constant.DB_NAME;
}
public Map processCredit(String data) {
Map response = new HashMap<>();
try {
// Database connection
String jdbcUrl = "jdbc:mysql://" + servername + "/" + dbname;
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// If the connection to the database fails
if (conn == null) {
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
conn.setAutoCommit(false); // Start a transaction
// Parsing JSON data (Implement your JSON parsing logic here)
Map param = parseJson(data);
int KPLAYId = Integer.parseInt((String) param.get("user_id"));
String txnId = (String) param.get("txn_id");
double amount = Double.parseDouble((String) param.get("amount"));
// Select member from DB
String selectUserSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement userStatement = conn.prepareStatement(selectUserSQL);
userStatement.setInt(1, KPLAYId);
ResultSet userResultSet = userStatement.executeQuery();
int userId = 0;
if (userResultSet.next()) {
userId = userResultSet.getInt("user_id");
} else {
// If member does not exist
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Select balance from the user balance table
String selectBalanceSQL = "SELECT balance FROM users_balance WHERE user_id = ?";
PreparedStatement balanceStatement = conn.prepareStatement(selectBalanceSQL);
balanceStatement.setInt(1, userId);
ResultSet balanceResultSet = balanceStatement.executeQuery();
double userBalance = 0.0;
if (balanceResultSet.next()) {
userBalance = balanceResultSet.getDouble("balance");
} else {
// If member does not have a balance
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Check if this debit exists in the database
String selectDebitSQL = "SELECT txn_id FROM debit WHERE txn_id = ?";
PreparedStatement debitStatement = conn.prepareStatement(selectDebitSQL);
debitStatement.setString(1, txnId);
ResultSet debitResultSet = debitStatement.executeQuery();
if (!debitResultSet.next()) {
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_DEBIT");
return response;
}
// Check if this credit already exists in the database
String selectCreditSQL = "SELECT txn_id FROM credit WHERE txn_id = ?";
PreparedStatement creditStatement = conn.prepareStatement(selectCreditSQL);
creditStatement.setString(1, txnId);
ResultSet creditResultSet = creditStatement.executeQuery();
if (creditResultSet.next()) {
conn.rollback();
response.put("status", 0);
response.put("error", "DUPLICATE_CREDIT");
return response;
} else {
// Insert credit record into DB
String insertCreditSQL = "INSERT INTO credit (txn_id, type, amount) VALUES (?, 'c', ?)";
PreparedStatement insertCreditStatement = conn.prepareStatement(insertCreditSQL);
insertCreditStatement.setString(1, txnId);
insertCreditStatement.setDouble(2, amount);
int rowsInsertedCredit = insertCreditStatement.executeUpdate();
if (rowsInsertedCredit != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_CREDIT_ERROR");
return response;
}
// Update user balance
userBalance += amount;
String updateBalanceSQL = "UPDATE users_balance SET balance = ? WHERE user_id = ?";
PreparedStatement updateBalanceStatement = conn.prepareStatement(updateBalanceSQL);
updateBalanceStatement.setDouble(1, userBalance);
updateBalanceStatement.setInt(2, userId);
int rowsUpdated = updateBalanceStatement.executeUpdate();
if (rowsUpdated != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_BALANCE_ERROR");
return response;
}
conn.commit();
response.put("status", 1);
response.put("balance", userBalance);
return response;
}
} catch (SQLException e) {
e.printStackTrace();
// If there is an error
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
}
// Function to parse JSON data into a map using org.json
private Map parseJson(String json) {
Map resultMap = new HashMap<>();
try {
// Create a JSON object from the input JSON string
JSONObject jsonObject = new JSONObject();
// Iterate through the keys in the JSON object and add them to the map
for (String key : jsonObject.keySet()) {
Object value = jsonObject.get(key);
resultMap.put(key, value);
}
return resultMap;
} catch (EjbAccessException e) {
e.printStackTrace(); // Handle the exception appropriately
return null; // Return null in case of parsing error
}
}
}
using System;
using System.Data;
using System.Data.SqlClient;
public class Credit
{
public dynamic ProcessCredit(string data)
{
try
{
// Database connection
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction transaction = conn.BeginTransaction())
{
// Deserialize the JSON data
dynamic param = Newtonsoft.Json.JsonConvert.DeserializeObject(data);
int KPLAYId = param.user_id;
decimal amount = param.amount;
string txnId = param.txn_id;
// Select member from the database
string selectSQL = $"SELECT user_id FROM users WHERE KPLAY_id = {KPLAYId}";
using (SqlCommand cmd = new SqlCommand(selectSQL, conn, transaction))
{
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (reader.Read())
{
int userId = reader.GetInt32(0); // Member ID for KPLAY
// Select balance for the user
string selectBalanceSQL = $"SELECT balance FROM users_balance WHERE user_id = {userId}";
using (SqlCommand balanceCmd = new SqlCommand(selectBalanceSQL, conn, transaction))
{
using (SqlDataReader balanceReader = balanceCmd.ExecuteReader())
{
if (balanceReader.Read())
{
decimal balance = balanceReader.GetDecimal(0); // Member balance
// Check if this debit exists in the database
string selectDebitSQL = $"SELECT txn_id FROM debit WHERE txn_id = '{txnId}'";
using (SqlCommand debitCmd = new SqlCommand(selectDebitSQL, conn, transaction))
{
using (SqlDataReader debitReader = debitCmd.ExecuteReader())
{
if (!debitReader.Read())
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_DEBIT"
};
}
}
}
// Check if this credit already exists in the database
string selectCreditSQL = $"SELECT txn_id FROM credit WHERE txn_id = '{txnId}'";
using (SqlCommand creditCmd = new SqlCommand(selectCreditSQL, conn, transaction))
{
using (SqlDataReader creditReader = creditCmd.ExecuteReader())
{
if (creditReader.Read())
{
transaction.Rollback();
return new
{
status = 0,
error = "DUPLICATE_CREDIT"
};
}
// Insert credit record into the database
string insertCreditSQL = $"INSERT INTO credit (txn_id, type, amount) " +
$"VALUES ('{txnId}', 'c', {amount})";
using (SqlCommand insertCreditCmd = new SqlCommand(insertCreditSQL, conn, transaction))
{
insertCreditCmd.ExecuteNonQuery();
}
// Update user balance
balance += amount;
string updateBalanceSQL = $"UPDATE users_balance SET balance = {balance} WHERE user_id = {userId}";
using (SqlCommand updateBalanceCmd = new SqlCommand(updateBalanceSQL, conn, transaction))
{
updateBalanceCmd.ExecuteNonQuery();
}
transaction.Commit();
return new
{
status = 1,
balance = balance
};
}
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
return new
{
status = 0,
error = "UNKNOWN_ERROR"
};
}
}
}
<%
Sub ProcessCredit(data)
On Error Resume Next
' Database connection parameters
Dim servername, username, password, dbname, conn, selectSQL, db, userId, balance
Dim KPLAYId, amount, txnId, responseKPLAY
' Constants
Const DB_SERVER_NAME = "your_db_server_name_here"
Const DB_USERNAME = "your_db_username_here"
Const DB_PASSWORD = "your_db_password_here"
Const DB_NAME = "your_db_name_here"
' Set database connection parameters
servername = DB_SERVER_NAME
username = DB_USERNAME
password = DB_PASSWORD
dbname = DB_NAME
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & servername & ";Initial Catalog=" & dbname & ";User ID=" & username & ";Password=" & password
' Check for a database connection error
If Err.Number <> 0 Then
Response.Write "Database connection failed: " & Err.Description
Exit Sub
End If
' Start a transaction
conn.BeginTrans
' Parse JSON data from the request
Dim json, jsonObject
Set json = JSONParse(data)
' Extract data from the JSON object
KPLAYId = json("user_id")
amount = json("amount")
txnId = json("txn_id")
' Select a user based on KPLAY_id
selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = " & KPLAYId
Set db = conn.Execute(selectSQL)
' Check if a user exists
If Not db.EOF Then
userId = db("user_id")
Else
' Rollback the transaction and return an error response
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INVALID_USER""}"
Exit Sub
End If
' Select the balance of the user
selectSQL = "SELECT balance FROM users_balance WHERE user_id = " & userId
Set db = conn.Execute(selectSQL)
' Check if the user has a balance
If Not db.EOF Then
balance = db("balance")
Else
' Rollback the transaction and return an error response
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INVALID_USER""}"
Exit Sub
End If
' Check if the debit transaction exists in the database
selectSQL = "SELECT txn_id FROM debit WHERE txn_id = '" & txnId & "'"
Set db = conn.Execute(selectSQL)
' If the debit transaction doesn't exist, rollback the transaction and return an error response
If db.EOF Then
conn.RollbackTrans
Response.Write "{""status"":0,""error"":""INVALID_DEBIT""}"
Exit Sub
End If
' Check if the credit transaction already exists in the database
selectSQL = "SELECT txn_id FROM credit WHERE txn_id = '" & txnId & "'"
Set db
5. Resettlement (Mandatory for sportbook only)
KPLAY will call this API in the merchant system to adjust user balance for sportsbook resettlement.
Note: Only available for Sportbook only.
HTTP methods: POST
URL: <Merchant endpoint>/resettle
5.1 Request Format
Header
Field
Type
Description
secret-key
string
KPLAY merchant secret key. For merchants to verify the request comes from KPLAY.
Body
Field
Type
Description
user_id
integer
KPLAY user ID
amount
integer
Credit Amount
txn_id
string
Unique transaction ID
prd_id
integer
Product ID
is_cancel
integer
Normal credit = 0
Credit due to cancel or refund = 1
resettlement_time
datetime
Resettlement date/time
Under timezone UTC+0
In ISO format
5.2 Request Example
{
"user_id":12345,
"amount":1000,
"txn_id":ABC12345,
"prd_id": 103,
"is_cancel":0,
"resettlement_time":2022-09-12 10:00:00
}
5.3 Response Format
Field
Type
Description
status
integer
0 = error
1 = success
balance
decimal(15, 2)
User balance
error
string
Error message when status = 0
5.4 Response Example
When success
{
"status":1
"balance":2000.00
}
When error
{
"status":0
"error":"INVALID_USER"
}
Error message
Description
INVALID_USER
Check if user exists in merchant system.
*Note: The request will be sent to the merchant until the merchant responds to the request
function processResettle($data)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if connect to DB failed
if ($conn->connect_error)
{
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
$conn->begin_transaction();
//get data from debit request
$param = json_decode($data);
$KPLAYId = $param->user_id;
$amount = $param->amount;
$txnId = $param->txn_id;
$prdId = $param->prd_id;
$isCancel = $param->is_cancel;
$resettleTime = $param->resettlement_time;
if(isset($param->credit_amount))
{
$credit = $param->credit_amount;
}
//select member from DB
$selectSQL = "SELECT user_id
FROM users
WHERE KPLAY_id = ".$KPLAYId;
$db = $conn->query($selectSQL);
//check if member exist
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
$getLastResettle = DB::select('SELECT txn_id,amount
FROM resettle
WHERE txn_id = ? AND user_id = ? order by id desc'
,[$txnId,$KPLAYId]);
$previousAmt = 0;
if (isset($getLastResettle[0]->amount))
{
$previousAmt = $getLastResettle[0]->amount;
}
else
{
$getLastCredit = DB::select('SELECT txn_id,amount
FROM KPLAY_credit
WHERE txn_id = ? order by id desc'
,[$txnId]);
if (isset($getLastCredit[0]->amount))
{
$previousAmt = $getLastCredit[0]->amount;
}
}
$saveResettl = DB::insert('INSERT INTO resettle
(txn_id,is_cancel,user_id,amount,prd_id,resettlement_time)
VALUES (?,?,?,?,?,?)'
,[$txnId,$isCancel,$KPLAYId,$amount,$prdId,$resettleTime]);
$updateBalance = DB::update('UPDATE users_balance SET balance = balance + ? - ? WHERE user_id = ?', [$amount,$previousAmt, $userId[0]->user_id]);
//check USER_NOT_EXIST and get balance
$db = DB::select('SELECT c.balance
FROM KPLAY_users a
LEFT JOIN users b ON a.user_id = b.id
LEFT JOIN users_balance c ON b.id = c.user_id
WHERE a.KPLAY_id = ?
LIMIT 1',[$KPLAYId]);
$userBalance = $db[0]->balance;
return $response = [
'status' => 1
,'balance' => $userBalance
];
}
catch (Exception $e)
{
$conn->rollback();
//if error
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
public class Resettle {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
public Resettle() {
// Get constants from constant.java (DB settings)
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
}
public Map processResettle(String data) {
Map response = new HashMap<>();
Connection conn = null;
try {
// Establish a database connection
conn = DriverManager.getConnection("jdbc:mysql://" + dbServerName + "/" + dbName, dbUsername, dbPassword);
conn.createStatement().execute("SET NAMES 'UTF8'");
conn.setAutoCommit(false);
// Parse the JSON data
JsonParser jsonParser = new JsonParser();
JsonObject param = (JsonObject) jsonParser.parse(data);
int KPLAYId = param.get("user_id").getAsInt();
double amount = param.get("amount").getAsDouble();
String txnId = param.get("txn_id").getAsString();
int prdId = param.get("prd_id").getAsInt();
int isCancel = param.get("is_cancel").getAsInt();
String resettleTime = param.get("resettlement_time").getAsString();
if (param.has("credit_amount")) {
}
// Select the member from DB
String selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement selectStmt = conn.prepareStatement(selectSQL);
selectStmt.setInt(1, KPLAYId);
ResultSet resultSet = selectStmt.executeQuery();
// Check if the member exists
int userId = 0;
if (resultSet.next()) {
userId = resultSet.getInt("user_id"); // Member ID for KPLAY
} else {
// If member does not exist
response.put("status", 0);
response.put("error", "INVALID_USER");
conn.rollback();
return response;
}
// Get the previous resettle amount
double previousAmt = 0;
PreparedStatement getLastResettleStmt = conn.prepareStatement("SELECT txn_id, amount FROM resettle WHERE txn_id = ?
AND user_id = ? ORDER BY id DESC");
getLastResettleStmt.setString(1, txnId);
getLastResettleStmt.setInt(2, KPLAYId);
ResultSet lastResettleResultSet = getLastResettleStmt.executeQuery();
if (lastResettleResultSet.next()) {
previousAmt = lastResettleResultSet.getDouble("amount");
} else {
PreparedStatement getLastCreditStmt = conn.prepareStatement("SELECT txn_id, amount FROM KPLAY_credit WHERE txn_id = ? ORDER BY id DESC");
getLastCreditStmt.setString(1, txnId);
ResultSet lastCreditResultSet = getLastCreditStmt.executeQuery();
if (lastCreditResultSet.next()) {
previousAmt = lastCreditResultSet.getDouble("amount");
}
}
// Save the resettle record
PreparedStatement saveResettleStmt = conn.prepareStatement("INSERT INTO resettle (txn_id, is_cancel, user_id, amount, prd_id,
resettlement_time) VALUES (?, ?, ?, ?, ?, ?)");
saveResettleStmt.setString(1, txnId);
saveResettleStmt.setInt(2, isCancel);
saveResettleStmt.setInt(3, KPLAYId);
saveResettleStmt.setDouble(4, amount);
saveResettleStmt.setInt(5, prdId);
saveResettleStmt.setString(6, resettleTime);
saveResettleStmt.executeUpdate();
// Update user balance
PreparedStatement updateBalanceStmt = conn.prepareStatement("UPDATE users_balance SET balance = balance + ? - ? WHERE user_id = ?");
updateBalanceStmt.setDouble(1, amount);
updateBalanceStmt.setDouble(2, previousAmt);
updateBalanceStmt.setInt(3, userId);
updateBalanceStmt.executeUpdate();
// Check USER_NOT_EXIST and get the balance
PreparedStatement userBalanceStmt = conn.prepareStatement("SELECT c.balance FROM KPLAY_users a LEFT JOIN users b ON a.user_id = b.id
LEFT JOIN users_balance c ON b.id = c.user_id WHERE a.KPLAY_id = ? LIMIT 1");
userBalanceStmt.setInt(1, KPLAYId);
ResultSet userBalanceResultSet = userBalanceStmt.executeQuery();
if (userBalanceResultSet.next()) {
double userBalance = userBalanceResultSet.getDouble("balance");
response.put("status", 1);
response.put("balance", userBalance);
}
conn.commit();
} catch (Exception e) {
if (conn != null) {
try {
conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
}
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
e.printStackTrace();
} finally {
if (conn != null) {
try {
conn.setAutoCommit(true);
conn.close();
} catch (SQLException ex) {
ex.printStackTrace();
}
}
}
return response;
}
}
using System;
using System.Data.SqlClient;
using System.Transactions;
public class Resettlement
{
private string serverName;
private string username;
private string password;
private string dbName;
public Resettlement()
{
this.serverName = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbName = Constants.DB_NAME;
}
public object ProcessResettle(string data)
{
try
{
using (TransactionScope transactionScope = new TransactionScope())
{
// Database Connection
string connectionString = $"Server={serverName};Database={dbName};User Id={username};Password={password};";
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Parse the JSON data
dynamic param = Newtonsoft.Json.JsonConvert.DeserializeObject(data);
int KPLAYId = param.user_id;
double amount = param.amount;
string txnId = param.txn_id;
int prdId = param.prd_id;
int isCancel = param.is_cancel;
DateTime resettleTime = param.resettlement_time;
double credit = (param.credit_amount != null) ? param.credit_amount : 0;
// Check if the user exists
using (SqlCommand cmd = new SqlCommand("SELECT user_id FROM users WHERE KPLAY_id = @KPLAYId", conn))
{
cmd.Parameters.AddWithValue("@KPLAYId", KPLAYId);
SqlDataReader reader = cmd.ExecuteReader();
if (!reader.HasRows)
{
return new { status = 0, error = "INVALID_USER" };
}
reader.Close();
}
// Get the previous amount
double previousAmt = 0;
using (SqlCommand cmd = new SqlCommand("SELECT TOP 1 amount FROM resettle WHERE txn_id = @txnId AND user_id = @KPLAYId ORDER BY id DESC", conn))
{
cmd.Parameters.AddWithValue("@txnId", txnId);
cmd.Parameters.AddWithValue("@KPLAYId", KPLAYId);
SqlDataReader reader = cmd.ExecuteReader();
if (reader.HasRows)
{
reader.Read();
previousAmt = reader.GetDouble(0);
}
else
{
reader.Close();
using (SqlCommand cmdCredit = new SqlCommand("SELECT TOP 1 amount FROM KPLAY_credit WHERE txn_id = @txnId ORDER BY id DESC", conn))
{
cmdCredit.Parameters.AddWithValue("@txnId", txnId);
SqlDataReader creditReader = cmdCredit.ExecuteReader();
if (creditReader.HasRows)
{
creditReader.Read();
previousAmt = creditReader.GetDouble(0);
}
creditReader.Close();
}
}
reader.Close();
}
// Insert the resettle record
using (SqlCommand cmdInsertResettle = new SqlCommand("INSERT INTO resettle (txn_id, is_cancel, user_id, amount, prd_id, resettlement_time) VALUES (@txnId, @isCancel, @KPLAYId, @amount, @prdId, @resettleTime)", conn))
{
cmdInsertResettle.Parameters.AddWithValue("@txnId", txnId);
cmdInsertResettle.Parameters.AddWithValue("@isCancel", isCancel);
cmdInsertResettle.Parameters.AddWithValue("@KPLAYId", KPLAYId);
cmdInsertResettle.Parameters.AddWithValue("@amount", amount);
cmdInsertResettle.Parameters.AddWithValue("@prdId", prdId);
cmdInsertResettle.Parameters.AddWithValue("@resettleTime", resettleTime);
cmdInsertResettle.ExecuteNonQuery();
}
// Update the balance
using (SqlCommand cmdUpdateBalance = new SqlCommand("UPDATE users_balance SET balance = balance + @amount - @previousAmt WHERE user_id = (SELECT id FROM users WHERE KPLAY_id = @KPLAYId)", conn))
{
cmdUpdateBalance.Parameters.AddWithValue("@amount", amount);
cmdUpdateBalance.Parameters.AddWithValue("@previousAmt", previousAmt);
cmdUpdateBalance.Parameters.AddWithValue("@KPLAYId", KPLAYId);
cmdUpdateBalance.ExecuteNonQuery();
}
// Get the user's balance
double userBalance = 0;
using (SqlCommand cmdUserBalance = new SqlCommand("SELECT balance FROM users_balance WHERE user_id = (SELECT id FROM users WHERE KPLAY_id = @KPLAYId)", conn))
{
cmdUserBalance.Parameters.AddWithValue("@KPLAYId", KPLAYId);
SqlDataReader balanceReader = cmdUserBalance.ExecuteReader();
if (balanceReader.HasRows)
{
balanceReader.Read();
userBalance = balanceReader.GetDouble(0);
}
balanceReader.Close();
}
transactionScope.Complete();
return new { status = 1, balance = userBalance };
}
}
}
catch (Exception e)
{
return new { status = 0, error = "UNKNOWN_ERROR" };
}
}
}
<%
Sub processResettle()
Dim servername, username, password, dbname, conn, param, KPLAYId, amount, txnId, prdId, isCancel, resettleTime, credit,
selectSQL, db, userId, getLastResettle, previousAmt, getLastCredit, saveResettle, updateBalance, userBalance, responseKPLAY
' Database connection settings
servername = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbname = "DB_NAME"
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & servername & ";Initial Catalog=" & dbname & ";User ID=" & username & ";Password=" & password
' Check if the database connection is successful
If Not conn.State = 1 Then
Set conn = Nothing
Response.Write "{""status"": 0, ""error"": ""UNKNOWN_ERROR""}"
Response.End
End If
conn.BeginTrans ' Begin a database transaction
' Get the JSON data from the request
Set param = GetJSONData(Request.BinaryRead(Request.TotalBytes))
' Extract data from the JSON object
KPLAYId = param("user_id")
amount = param("amount")
txnId = param("txn_id")
prdId = param("prd_id")
isCancel = param("is_cancel")
resettleTime = param("resettlement_time")
If IsObject(param("credit_amount")) Then
credit = param("credit_amount")
End If
' Select the user from the database based on KPLAY_id
selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = " & KPLAYId
Set db = conn.Execute(selectSQL)
' Check if the user exists
If Not db.EOF Then
userId = db("user_id")
Else
conn.RollbackTrans ' Rollback the transaction
db.Close
Set db = Nothing
Set conn = Nothing
Response.Write "{""status"": 0, ""error"": ""INVALID_USER""}"
Response.End
End If
db.Close
' Retrieve the last resettle record or, if not found, the last credit record
Set getLastResettle = conn.Execute("SELECT TOP 1 txn_id, amount FROM resettle
WHERE txn_id = '" & txnId & "' AND user_id = " & KPLAYId & "
ORDER BY id DESC")
previousAmt = 0
If Not getLastResettle.EOF Then
previousAmt = getLastResettle("amount")
Else
Set getLastCredit = conn.Execute("SELECT TOP 1 txn_id, amount FROM KPLAY_credit WHERE txn_id = '" & txnId & "' ORDER BY id DESC")
If Not getLastCredit.EOF Then
previousAmt = getLastCredit("amount")
End If
End If
' Insert a new resettle record
saveResettle = conn.Execute("INSERT INTO resettle (txn_id, is_cancel, user_id, amount, prd_id, resettlement_time) VALUES
('" & txnId & "', " & isCancel & ", " & KPLAYId & ", " & amount & ", " & prdId & ", '" & resettleTime & "')")
' Update the user's balance
updateBalance = conn.Execute("UPDATE users_balance SET balance = balance + " & amount & " - " & previousAmt & "
WHERE user_id = " & userId)
' Check USER_NOT_EXIST and get the balance
Set db = conn.Execute("SELECT c.balance FROM KPLAY_users a LEFT JOIN users b ON a.user_id = b.id
LEFT JOIN users_balance c ON b.id = c.user_id WHERE a.KPLAY_id = " & KPLAYId & " LIMIT 1")
userBalance = db("balance")
' Commit the transaction
conn.CommitTrans
' Prepare the response JSON
responseKPLAY = "{""status"": 1, ""balance"": " & userBalance & "}"
' Clean up and close the database connection
db.Close
Set db = Nothing
Set conn = Nothing
Response.Write responseKPLAY
End sub
Sub GetJSONData(jsonData)
Dim jsonString
Dim objJSON
jsonString = BytesToString(jsonData)
Set objJSON = Server.CreateObject("MSScriptControl.ScriptControl")
objJSON.Language = "JScript"
objJSON.ExecuteStatement "var data = " & jsonString
Set GetJSONData = objJSON.Eval("data")
Set objJSON = Nothing
End Sub
Sub BytesToString(bytes)
Dim Stream
Set Stream = Server.CreateObject("ADODB.Stream")
Stream.Type = 1 ' Binary
Stream.Open
Stream.Write bytes
Stream.Position = 0
Stream.Type = 2 ' Text (convert to text)
BytesToString = Stream.ReadText
Stream.Close
Set Stream = Nothing
End Sub
%>
6. BALANCE (Mandatory)
KPLAY will call this API in the merchant system to get the latest member's balance.
HTTP methods: POST
URL: <Merchant endpoint>/balance
6.1 Request Format
Header
Field
Type
Description
secret-key
string
KPLAY merchant secret key. For merchants to verify the request comes from KPLAY.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.json.JSONObject;
import org.springframework.ejb.access.EjbAccessException;
public class Balance {
private String servername;
private String username;
private String password;
private String dbname;
public Balance() {
// Initialize constants from constant.java (DB Server, Username, Password, DB Name)
this.servername = constant.DB_SERVER_NAME;
this.username = constant.DB_USERNAME;
this.password = constant.DB_PASSWORD;
this.dbname = constant.DB_NAME;
}
public Map getMemberBalance(String data) {
Map response = new HashMap<>();
try {
// Database connection
String jdbcUrl = "jdbc:mysql://" + servername + "/" + dbname;
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// If the connection to the database fails
if (conn == null) {
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
// Parsing JSON data (Implement your JSON parsing logic here)
Map param = parseJson(data);
int KPLAYId = Integer.parseInt((String) param.get("user_id"));
// Check if the user exists
String selectUserSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement userStatement = conn.prepareStatement(selectUserSQL);
userStatement.setInt(1, KPLAYId);
ResultSet userResultSet = userStatement.executeQuery();
int userId = 0;
if (userResultSet.next()) {
userId = userResultSet.getInt("user_id");
} else {
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Get the balance from the user balance table
String selectBalanceSQL = "SELECT user_id, balance FROM users_balance WHERE user_id = ?";
PreparedStatement balanceStatement = conn.prepareStatement(selectBalanceSQL);
balanceStatement.setInt(1, userId);
ResultSet balanceResultSet = balanceStatement.executeQuery();
double userBalance = 0.0;
if (balanceResultSet.next()) {
userBalance = balanceResultSet.getDouble("balance");
} else {
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
response.put("status", 1);
response.put("balance", userBalance);
return response;
} catch (SQLException e) {
// If there is an error
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
}
// Function to parse JSON data into a map using org.json
private Map parseJson(String json) {
Map resultMap = new HashMap<>();
try {
// Create a JSON object from the input JSON string
JSONObject jsonObject = new JSONObject();
// Iterate through the keys in the JSON object and add them to the map
for (String key : jsonObject.keySet()) {
Object value = jsonObject.get(key);
resultMap.put(key, value);
}
return resultMap;
} catch (EjbAccessException e) {
e.printStackTrace(); // Handle the exception appropriately
return null; // Return null in case of parsing error
}
}
}
using System;
using System.Data;
using System.Data.SqlClient;
public class Balance
{
public dynamic GetMemberBalance(string data)
{
try
{
// Database connection
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Deserialize the JSON data
dynamic param = Newtonsoft.Json.JsonConvert.DeserializeObject(data);
int KPLAYId = param.user_id;
// Check if the user exists
string selectSQL = $"SELECT user_id FROM users WHERE KPLAY_id = {KPLAYId}";
using (SqlCommand cmd = new SqlCommand(selectSQL, conn))
{
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (reader.Read())
{
int userId = reader.GetInt32(0);
// Get balance from the user balance table
string selectBalanceSQL = $"SELECT user_id, balance FROM users_balance WHERE user_id = {userId}";
using (SqlCommand balanceCmd = new SqlCommand(selectBalanceSQL, conn))
{
using (SqlDataReader balanceReader = balanceCmd.ExecuteReader())
{
if (balanceReader.Read())
{
userId = balanceReader.GetInt32(0);
decimal userBalance = balanceReader.GetDecimal(1);
dynamic response = new
{
status = 1,
balance = userBalance
};
return response;
}
else
{
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
else
{
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
throw;
}
}
}
<%
Sub getMemberBalance(data)
' Define database connection parameters
Dim serverName, username, password, dbName
serverName = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbName = "DB_NAME"
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Not conn.State = 1 Then
Dim responseKPLAY
Set responseKPLAY = CreateObject("Scripting.Dictionary")
responseKPLAY("status") = 0
responseKPLAY("error") = "UNKNOWN_ERROR"
getMemberBalance = responseKPLAY
Exit Sub
End If
' Parse the JSON data
Dim json
Set json = Server.CreateObject("JSONLib")
Dim param
Set param = json.decode(data)
Dim KPLAYId
KPLAYId = param("user_id")
' Check if the user exists
Dim selectSQL, db, userId
selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = " & KPLAYId
Set db = conn.Execute(selectSQL)
If Not db.EOF Then
userId = db("user_id")
Else
Dim responseKPLAY
Set responseKPLAY = CreateObject("Scripting.Dictionary")
responseKPLAY("status") = 0
responseKPLAY("error") = "INVALID_USER"
getMemberBalance = responseKPLAY
db.Close
Set db = Nothing
conn.Close
Set conn = Nothing
Exit Sub
End If
' Get the user's balance
selectSQL = "SELECT user_id, balance FROM users_balance WHERE user_id = " & userId
Set db = conn.Execute(selectSQL)
If Not db.EOF Then
userBalance = db("balance")
Else
Dim responseKPLAY
Set responseKPLAY = CreateObject("Scripting.Dictionary")
responseKPLAY("status") = 0
responseKPLAY("error") = "INVALID_USER"
getMemberBalance = responseKPLAY
db.Close
Set db = Nothing
conn.Close
Set conn = Nothing
Exit Sub
End If
' Create and return the responseKPLAY
Dim responseKPLAY
Set responseKPLAY = CreateObject("Scripting.Dictionary")
responseKPLAY("status") = 1
responseKPLAY("balance") = userBalance
' Clean up resources
db.Close
Set db = Nothing
conn.Close
Set conn = Nothing
Set json = Nothing
getMemberBalance = responseKPLAY
End Sub
%>
7. RESULTS (Mandatory)
Merchants can call this API to get the results from KPLAY.
*Note: If credit is not received after 10 minutes of debit’s time, merchants have to use the result API to settle.
HTTP methods : GET
URL: <KPLAY endpoint>/results/{prd_id}/{txn_id}
7.1 Request Format
Header
Field
Type
Description
Mandatory
ag-code
string
KPLAY merchant code
y
ag-token
string
KPLAY merchant token
y
Body
Field
Type
Description
Mandatory
prd_id
integer
Product ID
y
txn_id
string
Unique transaction ID, also used to pair with debit call. ID
using System;
using System.Data.SqlClient;
using System.Transactions;
public class Results
{
private string serverName;
private string username;
private string password;
private string dbName;
public Results()
{
this.serverName = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbName = Constants.DB_NAME;
}
public void ProcessResults()
{
try
{
using (TransactionScope transactionScope = new TransactionScope())
{
// Database Connection
string connectionString = $"Server={serverName};Database={dbName};User Id={username};Password={password};";
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Check if database connection failed
if (conn.State != System.Data.ConnectionState.Open)
{
Console.WriteLine("Database connection failed.");
return;
}
// Query the database to get rows where txn_id in debit table does not exist in credit table
using (SqlCommand cmdSelect = new SqlCommand("SELECT a.txn_id, a.prd_id, a.user_id FROM debit a LEFT JOIN credit b ON a.txn_id = b.txn_id WHERE b.txn_id IS NULL", conn))
using (SqlDataReader reader = cmdSelect.ExecuteReader())
{
while (reader.Read())
{
string txnId = reader.GetString(0);
int prdId = reader.GetInt32(1);
int userId = reader.GetInt32(2);
string method = "results"; // Auth game method
string url = $"{hostName}{method}/{prdId}/{txnId}"; // Auth game endpoint
// Prepare headers
string[] header = {
"Content-Type: application/json",
"Ag-Code: " + agent,
"Ag-Token: " + token
};
string[] data = { };
// Execute HTTP GET request using Helper
Helper helper = new Helper();
string response = helper.GetData(url, header);
// Parse the JSON response
dynamic data = Newtonsoft.Json.JsonConvert.DeserializeObject(response);
int status = data.status;
int type = data.type;
if (status == 1 && type == 1)
{
int gameId = data.game_id;
double stake = data.stake;
double payout = data.payout;
int isCancel = data.is_cancel;
string betType, credit;
if (isCancel == 1)
{
betType = "x";
credit = stake.ToString();
}
else
{
betType = "c";
credit = payout.ToString();
}
// Insert credit record into the database
using (SqlCommand cmdInsert = new SqlCommand("INSERT INTO credit (txn_id, type, amount) VALUES (@txnId, @betType, @credit)", conn))
{
cmdInsert.Parameters.AddWithValue("@txnId", txnId);
cmdInsert.Parameters.AddWithValue("@betType", betType);
cmdInsert.Parameters.AddWithValue("@credit", credit);
cmdInsert.ExecuteNonQuery();
}
// Update user balance
using (SqlCommand cmdUpdate = new SqlCommand("UPDATE users_balance SET balance = balance + @credit WHERE user_id = @userId", conn))
{
cmdUpdate.Parameters.AddWithValue("@credit", credit);
cmdUpdate.Parameters.AddWithValue("@userId", userId);
cmdUpdate.ExecuteNonQuery();
}
}
else
{
string error = data.error;
Console.WriteLine(error);
return;
}
}
}
transactionScope.Complete();
}
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
}
<%
Sub GetResult()
' Define database connection parameters
Dim serverName, username, password, dbName
serverName = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbName = "DB_NAME"
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Not conn.State = 1 Then
Response.Write "Error: Database connection failed"
Exit Sub
End If
Dim hostName, token, agent
hostName = "KPLAY_HOSTNAME" ' KPLAY Hostname
token = "KPLAY_TOKEN" ' KPLAY Token
agent = "KPLAY_CODE" ' KPLAY Code
' Execute SQL query to retrieve transactions
Dim selectSQL, db, row
selectSQL = "SELECT a.txn_id, a.prd_id, a.user_id FROM debit a LEFT JOIN credit b ON a.txn_id = b.txn_id WHERE b.txn_id IS NULL"
Set db = conn.Execute(selectSQL)
' Check if there are rows in the result
If Not db.EOF Then
Do While Not db.EOF
Dim txnId, prdId, userId
txnId = db("txn_id")
prdId = db("prd_id")
userId = db("user_id")
' Construct the URL for the request
Dim method, url
method = "results" ' auth game method
url = hostName & method & "/" & prdId & "/" & txnId ' auth game endpoint
' Prepare the request header
Dim header
Set header = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
header.Open "GET", url, False
header.setRequestHeader "Content-Type", "application/json"
header.setRequestHeader "Ag-Code", agent
header.setRequestHeader "Ag-Token", token
' Send the request
header.send
' Capture the response
Dim responseText
responseText = header.responseText
' Parse the response JSON
Dim responseData
Set responseData = JSONParse(responseText)
Dim status, type
status = responseData("status")
type = responseData("type")
If status = 1 And type = 1 Then
' Settle the transaction accordingly
Else
Dim error
error = responseData("error")
Response.Write "Error: " & error
Exit Sub
End If
db.MoveNext
Loop
Else
' No rows found, exit or handle as needed
End If
' Close the database connection
conn.Close
Set conn = Nothing
End Sub
%>
8. Bonus (Mandatory)
KPLAY will call this API in the merchant system to notify merchants that a Bonus occurs.
Unique transaction ID, it is not paired with debit call
8.2 Request Example
{
"user_id":1000011,
"type":0,
"amount":200.00,
"prd_id":200,
"game_id":438,
"txn_id":"A00000005"
}
8.3 Response Format
Field
Type
Description
status
integer
0 if error
1 if success
balance
decimal(15,2)
Latest member balance
error
string
Error message when status = 0
8.4 Response Example
When success
{
"status":1,
"balance":1500.00
}
When error
{
"status":0,
"error":"ACCESS_DENIED"
}
Error Message
Description
ACCESS_DENIED
Invalid secret key
INVALID_USER
Check if user exists in merchant system
UNKNOWN_ERROR
Internal error in merchant system
FAQ
Q: What is the difference between type 0 and type 1 in the bonus endpoint?
A: Type 0 is free spin in game while type 1 bonus/promo is a promotion given by Agent or provider.
Q: Is type 0 In Game Bonus send to CREDIT endpoint?
A: Type 0 is send to BONUS endpoint and not send to CREDIT endpoint, it would not have a debit request send to merchant upon spin.
function processBonus($data)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if connect to DB failed
if ($conn->connect_error)
{
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
$conn->begin_transaction();
//get data from debit request
$param = json_decode($data);
$KPLAYId = $param->user_id;
$amount = $param->amount;
$txnId = $param->txn_id;
$prdId = $param->prd_id;
$type = $param->type;
//select member from DB
$selectSQL = "SELECT user_id
FROM users
WHERE KPLAY_id = ".$KPLAYId;
$db = $conn->query($selectSQL);
//check if member exist
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
}
}
else
{
//if member does not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
$selectSQL = "SELECT balance
FROM users_balance
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
//check if member have balance
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$balance = $row['balance'];//member balance
}
}
else
{
//if member does not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
//Insert credit record to DB
$insertSQL = "INSERT INTO bonus
(txn_id,prd_id,type,amount)
VALUES
('".$txnId."','".$prdId."',".$type.",".$amount.")";
$db = $conn->query($insertSQL);
//Update user balance
$balance = $balance + $amount;
$updateSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($updateSQL);
$conn->commit();
return $response = [
'status' => 1
,'balance' => $balance
];
}
catch (Exception $e)
{
$conn->rollback();
//if error
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.json.JSONObject;
import org.springframework.ejb.access.EjbAccessException;
public class Bonus {
private String servername;
private String username;
private String password;
private String dbname;
public Bonus() {
// Initialize constants from constant.java (DB Server, Username, Password, DB Name)
this.servername = constant.DB_SERVER_NAME;
this.username = constant.DB_USERNAME;
this.password = constant.DB_PASSWORD;
this.dbname = constant.DB_NAME;
}
public Map processBonus(String data) {
Map response = new HashMap<>();
try {
// Database connection
String jdbcUrl = "jdbc:mysql://" + servername + "/" + dbname;
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// If the connection to the database fails
if (conn == null) {
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
conn.setAutoCommit(false); // Start a transaction
// Parsing JSON data (Implement your JSON parsing logic here)
Map param = parseJson(data);
int KPLAYId = Integer.parseInt((String) param.get("user_id"));
double amount = Double.parseDouble((String) param.get("amount"));
String txnId = (String) param.get("txn_id");
int prdId = Integer.parseInt((String) param.get("prd_id"));
int type = Integer.parseInt((String) param.get("type"));
// Select member from DB
String selectUserSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement userStatement = conn.prepareStatement(selectUserSQL);
userStatement.setInt(1, KPLAYId);
ResultSet userResultSet = userStatement.executeQuery();
int userId = 0;
if (userResultSet.next()) {
userId = userResultSet.getInt("user_id");
} else {
// If member does not exist
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Select balance from the user balance table
String selectBalanceSQL = "SELECT balance FROM users_balance WHERE user_id = ?";
PreparedStatement balanceStatement = conn.prepareStatement(selectBalanceSQL);
balanceStatement.setInt(1, userId);
ResultSet balanceResultSet = balanceStatement.executeQuery();
double userBalance = 0.0;
if (balanceResultSet.next()) {
userBalance = balanceResultSet.getDouble("balance");
} else {
// If member does not have a balance
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Insert credit record into DB
String insertSQL = "INSERT INTO bonus (txn_id, prd_id, type, amount) VALUES (?, ?, ?, ?)";
PreparedStatement insertStatement = conn.prepareStatement(insertSQL);
insertStatement.setString(1, txnId);
insertStatement.setInt(2, prdId);
insertStatement.setInt(3, type);
insertStatement.setDouble(4, amount);
int rowsInserted = insertStatement.executeUpdate();
if (rowsInserted != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_ERROR");
return response;
}
// Update user balance
userBalance += amount;
String updateSQL = "UPDATE users_balance SET balance = ? WHERE user_id = ?";
PreparedStatement updateStatement = conn.prepareStatement(updateSQL);
updateStatement.setDouble(1, userBalance);
updateStatement.setInt(2, userId);
int rowsUpdated = updateStatement.executeUpdate();
if (rowsUpdated != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_ERROR");
return response;
}
conn.commit();
response.put("status", 1);
response.put("balance", userBalance);
return response;
} catch (SQLException e) {
e.printStackTrace();
// If there is an error
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
}
// Function to parse JSON data into a map using org.json
private Map parseJson(String json) {
Map resultMap = new HashMap<>();
try {
// Create a JSON object from the input JSON string
JSONObject jsonObject = new JSONObject();
// Iterate through the keys in the JSON object and add them to the map
for (String key : jsonObject.keySet()) {
Object value = jsonObject.get(key);
resultMap.put(key, value);
}
return resultMap;
} catch (EjbAccessException e) {
e.printStackTrace(); // Handle the exception appropriately
return null; // Return null in case of parsing error
}
}
}
using System;
using System.Data;
using System.Data.SqlClient;
public class Bonus
{
public dynamic ProcessBonus(string data)
{
try
{
// Database connection
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction transaction = conn.BeginTransaction())
{
// Deserialize the JSON data
dynamic param = Newtonsoft.Json.JsonConvert.DeserializeObject(data);
int KPLAYId = param.user_id;
decimal amount = param.amount;
int txnId = param.txn_id;
int prdId = param.prd_id;
int type = param.type;
// Select member from the database
string selectSQL = $"SELECT user_id FROM users WHERE KPLAY_id = {KPLAYId}";
using (SqlCommand cmd = new SqlCommand(selectSQL, conn, transaction))
{
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (reader.Read())
{
int userId = reader.GetInt32(0); // Member ID for KPLAY
// Select balance for the user
string selectBalanceSQL = $"SELECT balance FROM users_balance WHERE user_id = {userId}";
using (SqlCommand balanceCmd = new SqlCommand(selectBalanceSQL, conn, transaction))
{
using (SqlDataReader balanceReader = balanceCmd.ExecuteReader())
{
if (balanceReader.Read())
{
decimal balance = balanceReader.GetDecimal(0); // Member balance
// Insert credit record into the database
string insertSQL = $"INSERT INTO bonus (txn_id, prd_id, type, amount) " +
$"VALUES ('{txnId}', '{prdId}', {type}, {amount})";
using (SqlCommand insertCmd = new SqlCommand(insertSQL, conn, transaction))
{
insertCmd.ExecuteNonQuery();
// Update user balance
balance += amount;
string updateSQL = $"UPDATE users_balance SET balance = {balance} WHERE user_id = {userId}";
using (SqlCommand updateCmd = new SqlCommand(updateSQL, conn, transaction))
{
updateCmd.ExecuteNonQuery();
}
transaction.Commit();
return new
{
status = 1,
balance = balance
};
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
else
{
transaction.Rollback();
return new
{
status = 0,
error = "INVALID_USER"
};
}
}
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
return new
{
status = 0,
error = "UNKNOWN_ERROR"
};
}
}
}
<%
Sub ProcessBonus(data)
' Define database connection parameters
Dim serverName, username, password, dbName
serverName = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbName = "DB_NAME"
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Not conn.State = 1 Then
Response.Write "Error: Database connection failed"
Exit Sub
End If
On Error Resume Next
conn.BeginTrans
' Parse JSON data
Dim jsonObj
Set jsonObj = JSONParse(data)
If Err.Number <> 0 Then
Response.Write "Error: Invalid JSON data"
conn.Rollback
conn.Close
Exit Sub
End If
Dim KPLAYId, amount, txnId, prdId, type
KPLAYId = jsonObj("user_id")
amount = jsonObj("amount")
txnId = jsonObj("txn_id")
prdId = jsonObj("prd_id")
type = jsonObj("type")
On Error Goto 0
' Execute SQL query to find the user by KPLAY_id
Dim selectSQL, db, userId, balance
selectSQL = "SELECT user_id FROM users WHERE KPLAY_id = " & KPLAYId
Set db = conn.Execute(selectSQL)
If Not db.EOF Then
userId = db("user_id")
Else
' Member does not exist
Response.Write "Error: INVALID_USER"
conn.Rollback
conn.Close
Exit Sub
End If
' Get the user's balance
selectSQL = "SELECT balance FROM users_balance WHERE user_id = " & userId
Set db = conn.Execute(selectSQL)
If Not db.EOF Then
balance = db("balance")
Else
' User balance not found
Response.Write "Error: INVALID_USER"
conn.Rollback
conn.Close
Exit Sub
End If
' Insert bonus record into the 'bonus' table
Dim insertSQL
insertSQL = "INSERT INTO bonus (txn_id, prd_id, type, amount) VALUES ('" & txnId & "', " & prdId & ", " & type & ", " & amount & ")"
conn.Execute insertSQL
' Update user balance
balance = balance + amount
Dim updateSQL
updateSQL = "UPDATE users_balance SET balance = " & balance & " WHERE user_id = " & userId
conn.Execute updateSQL
conn.Commit
conn.Close
' Prepare and return the response JSON
Dim responseJson
Set responseJson = Server.CreateObject("Scripting.Dictionary")
responseJson("status") = 1
responseJson("balance") = balance
Dim responseStr
responseStr = JSONStringify(responseJson)
Response.Write responseStr
End Sub
%>
9. Product List (Optional)
Merchants can call this API to get current available products from KPLAY.
HTTP methods : POST
URL : <KPLAY endpoint>/productlist
9.1 Request Format
Header
Field
Type
Description
ag-code
string
KPLAY merchant code
ag-token
string
KPLAY merchant token
Body
Field
Type
Description
language
string
Language option for product name
Korean : ko/kr,
English : en
Default is in English
wallet
integer
0 - All wallets
1 - Seamless Wallet
2 - Transfer Wallet
Default is in All wallets
9.2 Request Example
{
"language":"kr",
"wallet":1
}
9.3 Response Format
Field
Type
Description
status
integer
0 - error
1 - success
prd_id
string
ID of the products
prd_name
integer
Name of the products
error
string
Error message when status = 0
9.4 Response Example
{
"status":1,
"data":[
{
"prd_id":1,
"prd_name":"에볼루션",
},
{
"prd_id":2,
"prd_name":"빅게이밍",
},
{
"prd_id":5,
"prd_name":"아시아 게이밍",
}
]
}
Error Message
Description
INVALID_PARAMETER
The AG token or AG code is missing
ACCESS_DENIED
The AG is disabled.
USER_NOT_EXIST
The AG is not found in KPLAY or incorrect AG token.
using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using Newtonsoft.Json;
public class ProductList
{
private string servername;
private string username;
private string password;
private string dbname;
private string hostName;
private string token;
private string agent;
private string KPLAYCode;
private string KPLAYToken;
public ProductList()
{
this.servername = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbname = Constants.DB_NAME;
this.hostName = Constants.KPLAYHostname; // KPLAY Hostname
this.token = Constants.KPLAYToken; // KPLAY Token
this.agent = Constants.KPLAYCode; // KPLAY Code
}
public async Task UpdateProductList()
{
try
{
// Assuming you have valid values for KPLAY parameters
string KPLAYHostname = hostName;
KPLAYToken = token;
KPLAYCode = agent;
string method = "productlist"; // Auth game method
string url = KPLAYHostname + method; // Auth game endpoint
// Prepare header
var KPLAYHeader = new HttpClient();
KPLAYHeader.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
KPLAYHeader.DefaultRequestHeaders.Add("Ag-Code", KPLAYCode);
KPLAYHeader.DefaultRequestHeaders.Add("Ag-Token", KPLAYToken);
// Prepare data
var data = new
{
language = "en", // Language
wallet = 1
};
var jsonData = JsonConvert.SerializeObject(data);
var content = new StringContent(jsonData);
content.Headers.ContentType = new MediaTypeHeaderValue("application/json");
// Send a POST request to the KPLAY endpoint
var response = await KPLAYHeader.PostAsync(url, content);
if (response.IsSuccessStatusCode)
{
string responseContent = await response.Content.ReadAsStringAsync();
dynamic responseData = JsonConvert.DeserializeObject(responseContent);
int status = responseData.status;
if (status == 1)
{
var mainData = responseData.data;
foreach (var productInfo in mainData)
{
int prdId = productInfo.prd_id;
string prdName = productInfo.prd_name;
// Assuming you have a database connection
using (var conn = new SqlConnection(connectionString))
{
conn.Open();
string sql = "";
if (data.language == "en")
{
sql = "UPDATE product_list SET prd_name_en = @prdName WHERE prd_id = @prdId";
}
else
{
sql = "UPDATE product_list SET prd_name_ko = @prdName WHERE prd_id = @prdId";
}
using (var cmd = new SqlCommand(sql, conn))
{
cmd.Parameters.AddWithValue("@prdName", prdName);
cmd.Parameters.AddWithValue("@prdId", prdId);
cmd.ExecuteNonQuery();
}
}
}
Console.WriteLine(responseContent);
}
else if (status == 0)
{
string error = responseData.error;
Console.WriteLine(error);
}
else
{
Console.WriteLine("Call API Error");
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
<%
Sub productList()
' Constants from constant.asp (You need to define these)
Dim DB_SERVER_NAME, DB_USERNAME, DB_PASSWORD, DB_NAME
Dim KPLAY_HOSTNAME, KPLAY_TOKEN, KPLAY_CODE
DB_SERVER_NAME = "your_db_server_name"
DB_USERNAME = "your_db_username"
DB_PASSWORD = "your_db_password"
DB_NAME = "your_db_name"
KPLAY_HOSTNAME = "your_KPLAY_hostname"
KPLAY_TOKEN = "your_KPLAY_token"
KPLAY_CODE = "your_KPLAY_code"
' Create and configure the XMLHTTP object
Set xmlhttp = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Prepare the SQL connection
Dim conn, selectSQL
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & DB_SERVER_NAME & ";Initial Catalog=" & DB_NAME & ";User Id=" & DB_USERNAME & ";Password=" & DB_PASSWORD & ";"
' If DB connection fails
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Response.End
End If
' Set the method and URL for the API request
method = "productlist"
url = KPLAY_HOSTNAME & method
' Create a JSON string for the data
requestData = "{""language"": ""en"", ""wallet"": 1}"
' Send the HTTP POST request
xmlhttp.open "POST", url, False
xmlhttp.setRequestHeader "Content-Type", "application/json"
xmlhttp.setRequestHeader "Ag-Code", KPLAY_CODE
xmlhttp.setRequestHeader "Ag-Token", KPLAY_TOKEN
xmlhttp.send requestData
' Check the response
If xmlhttp.Status = 200 Then
' Parse JSON response
Set json = Server.CreateObject("JSONScriptObject")
json.decode xmlhttp.responseText
' Get status and data from the response
status = json.data("status")
Set mainData = json.data("data")
' Check the status
If status = 1 And Not mainData Is Nothing Then
' Loop through products in mainData
For Each productInfo In mainData
prdId = productInfo("prd_id")
prdName = productInfo("prd_name")
' Process data here
Next
ElseIf status = 0 Then
error = json.data("error")
Response.Write error
Else
Response.Write "call_api_error"
End If
' Clean up JSON object
Set json = Nothing
Else
Response.Write "HTTP request failed with status: " & xmlhttp.Status
End If
' Clean up the XMLHTTP object
Set xmlhttp = Nothing
' Close the database connection
conn.Close
Set conn = Nothing
End Sub
' Call the function
Call productList()
%>
10. Product Game List (Mandatory)
Merchants can call this API to get product game lists from KPLAY.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonElement;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
public class GameList {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public GameList() {
// Get constants from constant.java (DB and KPLAY settings)
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
}
public void synchronizeGameList() {
try {
// Establish a database connection
Connection conn = DriverManager.getConnection("jdbc:mysql://" + dbServerName +
"/" + dbName, dbUsername, dbPassword);
conn.createStatement().execute("SET NAMES 'UTF8'");
String hostName = KPLAYHostname;
String token = KPLAYToken;
String agent = KPLAYCode;
String method = "/gamelist";
// Prepare headers
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("ag-code", agent);
header.put("ag-token", token);
// Create a Map for your data
Map data = new HashMap<>();
data.put("language", "en");;
String url = hostName + method;
String response = Helper.postData(url, data, header);
// Parse the response JSON
// (You can use a JSON library like Jackson or Gson for this)
// Example:
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject)jsonParser.parse(response);
if (jo.has("game_list")) {
if (jo.get("status").getAsInt() == 1) {
JsonObject gameList = jo.getAsJsonObject("game_list");
for (Map.Entry entry : gameList.entrySet()) {
String prdId = entry.getKey();
JsonObject gameInfo = entry.getValue().getAsJsonObject();
for (Map.Entry entry2 : gameInfo.entrySet()) {
JsonObject info = entry2.getValue().getAsJsonObject();
int gameId = info.get("game_id").getAsInt();
String gameName = info.get("game_name").getAsString();
int isEnabled = info.get("game_status").getAsInt();
PreparedStatement stmt = conn.prepareStatement(
"SELECT prd_id, game_id, game_name_en, game_name_ko FROM game_list WHERE prd_id = ? AND game_id = ?");
stmt.setInt(1, Integer.parseInt(prdId));
stmt.setInt(2, gameId);
ResultSet result = stmt.executeQuery();
List> db = new ArrayList<>();
while (result.next()) {
Map row = new HashMap<>();
row.put("prd_id", result.getInt("prd_id"));
row.put("game_id", result.getInt("game_id"));
row.put("game_name_en", result.getString("game_name_en"));
row.put("game_name_ko", result.getString("game_name_ko"));
db.add(row);
}
stmt.close();
if (db.isEmpty()) {
String sql = "INSERT INTO game_list(prd_id, game_id, game_name_en, is_enabled) VALUES (?, ?, ?, ?)";
PreparedStatement insertStmt = conn.prepareStatement(sql);
insertStmt.setInt(1, Integer.parseInt(prdId));
insertStmt.setInt(2, gameId);
insertStmt.setString(3, gameName);
insertStmt.setInt(4, isEnabled);
insertStmt.execute();
insertStmt.close();
} else {
String dbGameNameEn = (String) db.get(0).get("game_name_en");
String dbGameNameKr = (String) db.get(0).get("game_name_ko");
if (dbGameNameKr == null || dbGameNameEn == null || dbGameNameKr.equals("N/A")
|| dbGameNameEn.equals("N/A")) {
String sql = "UPDATE game_list SET prd_id = ?, game_id = ?, game_name_en = ?, is_enabled = ?, updated_at = ?
WHERE prd_id = ? AND game_id = ?";
PreparedStatement updateStmt = conn.prepareStatement(sql);
updateStmt.setInt(1, Integer.parseInt(prdId));
updateStmt.setInt(2, gameId);
updateStmt.setString(3, gameName);
updateStmt.setInt(4, isEnabled);
updateStmt.setString(5, getCurrentTimestamp());
updateStmt.setInt(6, Integer.parseInt(prdId));
updateStmt.setInt(7, gameId);
updateStmt.execute();
updateStmt.close();
}
}
}
}
}
} else {
System.out.println("call_api_error");
}
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
private String getCurrentTimestamp() {
// Define the desired date-time format
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
// Get the current date and time
LocalDateTime currentDateTime = LocalDateTime.now();
// Format the current date and time using the formatter
String formattedTimestamp = currentDateTime.format(formatter);
return formattedTimestamp;
}
public static void main(String[] args) {
GameList gameList = new GameList();
gameList.synchronizeGameList();
}
}
using System;
using System.Data;
using System.Data.SqlClient;
public class GameList
{
public GameList()
{
try
{
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Set the encoding to UTF8
var utf8Encoding = System.Text.Encoding.GetEncoding("UTF-8");
var utf8EncodingBytes = utf8Encoding.GetBytes("UTF-8");
// If the connection to the database fails
if (conn.State != ConnectionState.Open)
{
Console.WriteLine("Connection failed: " + conn.State);
return;
}
string hostName = Constants.KPLAYHostname; // Hostname
string token = Constants.KPLAYToken; // AG Token
string agent = Constants.KPLAYCode; // AG Code
string method = "/gamelist";
// Prepare headers
var headers = new Dictionary
{
{ "Content-Type", "application/json" },
{ "ag-code", agent },
{ "ag-token", token }
};
// Prepare data
var data = new
{
language = "en"
};
string url = hostName + method;
// Post data via HttpClient
using (HttpClient httpClient = new HttpClient())
{
foreach (var header in headers)
{
httpClient.DefaultRequestHeaders.Add(header.Key, header.Value);
}
var json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
var content = new StringContent(json, utf8Encoding, "application/json");
HttpResponseMessage response = await httpClient.PostAsync(url, content);
string responseContent = await response.Content.ReadAsStringAsync();
error_log(json);
error_log(responseContent);
dynamic responseData = JObject.Parse(responseContent);
if (responseData != null && responseData.status == 1)
{
var gameList = responseData.game_list;
foreach (var prdId in gameList)
{
foreach (var gameInfo in gameList[prdId])
{
var gameId = gameInfo.game_id;
var gameName = gameInfo.game_name;
var isEnabled = gameInfo.game_status;
// Check if the game exists in the database
string selectSQL = "SELECT prd_id, game_id, game_name_en, game_name_ko " +
"FROM game_list " +
"WHERE prd_id = @prdId AND game_id = @gameId";
using (SqlCommand cmd = new SqlCommand(selectSQL, conn))
{
cmd.Parameters.AddWithValue("@prdId", prdId);
cmd.Parameters.AddWithValue("@gameId", gameId);
using (SqlDataReader reader = cmd.ExecuteReader())
{
if (!reader.HasRows)
{
// Insert the game into the database
string insertSQL = "INSERT INTO game_list(prd_id, game_id, game_name_en, is_enabled) " +
"VALUES(@prdId, @gameId, @gameName, @isEnabled)";
using (SqlCommand insertCmd = new SqlCommand(insertSQL, conn))
{
insertCmd.Parameters.AddWithValue("@prdId", prdId);
insertCmd.Parameters.AddWithValue("@gameId", gameId);
insertCmd.Parameters.AddWithValue("@gameName", gameName);
insertCmd.Parameters.AddWithValue("@isEnabled", isEnabled);
insertCmd.ExecuteNonQuery();
}
}
else
{
reader.Read();
var dbGameNameEn = reader["game_name_en"];
var dbGameNameKr = reader["game_name_ko"];
if (dbGameNameKr == DBNull.Value || dbGameNameEn == DBNull.Value ||
dbGameNameKr.ToString() == "N/A" || dbGameNameEn.ToString() == "N/A")
{
// Update the game information
string updateSQL = "UPDATE game_list " +
"SET prd_id = @prdId, game_id = @gameId, game_name_en = @gameName, " +
"is_enabled = @isEnabled, updated_at = @updatedAt " +
"WHERE prd_id = @prdId AND game_id = @gameId";
using (SqlCommand updateCmd = new SqlCommand(updateSQL, conn))
{
updateCmd.Parameters.AddWithValue("@prdId", prdId);
updateCmd.Parameters.AddWithValue("@gameId", gameId);
updateCmd.Parameters.AddWithValue("@gameName", gameName);
updateCmd.Parameters.AddWithValue("@isEnabled", isEnabled);
updateCmd.Parameters.AddWithValue("@updatedAt", DateTime.Now);
updateCmd.ExecuteNonQuery();
}
}
}
}
}
}
}
}
else
{
Console.WriteLine("call_api_error");
return;
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
return;
}
}
}
<%
Sub gamelist()
On Error Resume Next
' Define database connection parameters
Dim serverName, username, password, dbName
serverName = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbName = "DB_NAME"
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Err.Clear
Set conn = Nothing
Exit Sub
End If
conn.Execute "SET NAMES 'UTF8'"
' Define API parameters
Dim hostName, token, agent, method
hostName = "KPLAY_HOSTNAME" ' Hostname
token = "KPLAY_TOKEN" ' AG Token
agent = "KPLAY_CODE" ' AG Code
method = "/gamelist"
' Prepare API request headers
Dim header
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
header.Add "ag-code", agent
header.Add "ag-token", token
' Prepare API request data
Dim data
Set data = Server.CreateObject("Scripting.Dictionary")
data.Add "language", "en"
' Build API request URL
Dim url
url = hostName & method
' Create an HTTP request object
Dim xmlhttp
Set xmlhttp = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Set request headers
For Each key In header.Keys
xmlhttp.setRequestHeader key, header(key)
Next
' Send a POST request with JSON data
xmlhttp.open "POST", url, False
xmlhttp.setRequestHeader "Content-Type", "application/json"
If IsObject(data) Then
dataStr = JSONStringify(data)
End If
xmlhttp.send dataStr
' Check if the request was successful
If xmlhttp.Status = 200 Then
' Parse the JSON response
Dim responseJson
Set responseJson = JSONParse(xmlhttp.responseText)
' Check if the 'status' key exists in the response
If responseJson.Exists("status") Then
If responseJson("status") = 1 Then
' Get the 'game_list' data
Dim gameList
Set gameList = responseJson("game_list")
' Loop through the game list
For Each prdId In gameList.Keys
For Each info In gameList(prdId)
Dim gameId, gameName, isEnabled, stmt, result, db, dbGameNameEn, dbGameNameKr, sql
gameId = info("game_id")
gameName = info("game_name")
isEnabled = info("game_status")
' Execute a SQL query to check if the game exists in the database
sql = "SELECT prd_id, game_id, game_name_en, game_name_ko FROM game_list WHERE prd_id = ? AND game_id = ?"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Execute
Set result = stmt.ResultSet(1)
db = result.GetRows()
' Close the statement
stmt.Close
If UBound(db, 2) = -1 Then
' Game does not exist in the database, insert it
sql = "INSERT INTO game_list (prd_id, game_id, game_name_en, is_enabled) VALUES (?, ?, ?, ?)"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Parameters.Append stmt.CreateParameter("@gameName", 200, 1, Len(gameName), gameName)
stmt.Parameters.Append stmt.CreateParameter("@isEnabled", 3, 1, 4, isEnabled)
stmt.Execute
stmt.Close
Else
' Game exists in the database, check if translation is needed
dbGameNameEn = db(2, 0)
dbGameNameKr = db(3, 0)
If IsNull(dbGameNameKr) Or IsNull(dbGameNameEn) Or dbGameNameKr = "N/A" Or dbGameNameEn = "N/A" Then
' Translation is needed, update the game entry
sql = "UPDATE KPLAY_game_list SET prd_id = ?, game_id = ?, game_name_en = ?, is_enabled = ?, updated_at = ?
WHERE prd_id = ? AND game_id = ?"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Parameters.Append stmt.CreateParameter("@gameName", 200, 1, Len(gameName), gameName)
stmt.Parameters.Append stmt.CreateParameter("@isEnabled", 3, 1, 4, isEnabled)
stmt.Parameters.Append stmt.CreateParameter("@updatedAt", 135, 1, 19, Now())
stmt.Parameters.Append stmt.CreateParameter("@prdId2", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId2", 3, 1, 4, gameId)
stmt.Execute
stmt.Close
End If
End If
Next
Next
End If
End If
Else
' API request failed
Response.Write "Error: API request failed"
End If
' Clean up objects
Set xmlhttp = Nothing
Set responseJson = Nothing
Set data = Nothing
Set header = Nothing
' Close the database connection
conn.Close
Set conn = Nothing
End Sub
%>
11. Get Game Info (Optional)
Merchants can call this API to get game info from KPLAY.
HTTP methods : POST
URL : <KPLAY endpoint>/gameinfo
11.1 Request Format
Header
Field
Type
Description
ag-code
string
KPLAY merchant code
ag-token
string
KPLAY merchant token
Body
Field
Type
Description
language
string
Language option for game name.
Default English
Korean : ko, English : en
Note: 1 call request per minute for game info API
11.2 Request Example
{
"language":"en"
}
11.3 Response Format
Field
Type
Description
status
integer
0 if error
1 if success
recommended
string
Recommended games
popular
string
Popular games
new_game
string
New games
game_id
integer
Product game ID
game_name
string
Product game name
error
string
Error message when status = 0
11.4 Response Example
When success
{
"status":1,
"recommended":{
"200":[
{
"game_id": 14,
"game_name":"Wild West Gold"
},
"209":[
{
"game_id": 62,
"game_name":"Basketball Star"
}
]
},
"popular":{
"202":[
{
"game_id": 466,
"game_name":"Supa Crew"
},
"205":[
{
"game_id": 153,
"game_name":"Christmas Miracles"
}
]
},
"new_game":{
"200":[
{
"game_id": 512,
"game_name":"Kingdom of The Dead"
},
"220":[
{
"game_id": 277,
"game_name":"Treasure Pirate"
}
]
}
}
When Error
{
"status":0,
"error":"INVALID_PARAMETER"
}
Error Message
Description
INVALID_PARAMETER
Invalid secret key
INVALID_PRODUCT
Check if product id exists in merchant system
INTERNAL_ERROR
KPLAY internal error
function __construct()
{
try
{
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
$conn->query("SET NAMES 'UTF8'");
//if connect to DB failed
if ($conn->connect_error)
{
var_dump("Connection failed: " . $conn->connect_error);
exit;
}
$hostName = KPLAY_HOSTNAME; //Hostname
$token = KPLAY_TOKEN; //AG Token
$agent = KPLAY_CODE; //AG Code
$method = '/gameinfo';
$header = array('Content-Type: application/json',
'ag-code: '.$agent,
'ag-token:'.$token);
$data = array(
'language' => "en"
);
$url = $hostName.$method;
$helper = new Helper;
$response = $helper->postData($url,$data,$header);
error_log(json_encode($data));
error_log($response);
$data = json_decode($response);
$status = $data->status;
$recommended = (array) $data->recommended;
$popular = (array) $data->popular;
$new_game = (array) $data->new_game;
if ($status == 1 && (!empty($recommended) || !empty($popular) || !empty($new_game)))
{
if (!empty($recommended))
{
$sql = "UPDATE game_list SET is_recommended = 0";
$stmt = $conn->prepare($sql);
$stmt->execute();
$stmt->close();
foreach ($recommended as $prdId => $gameInfos)
{
foreach($gameInfos as $gameInfo)
{
$gameId = $gameInfo->game_id;
$gameName = $gameInfo->game_name;
$sql = "UPDATE game_list
SET prd_id = ?
,game_id = ?
,game_name = ?
,is_recommended = 1
,updated_at = ?
WHERE prd_id = ?
AND game_id = ?";
$stmt = $conn->prepare($sql);
$updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
$stmt->bind_param("iissii", $prdId, $gameId, $gameName, $updatedAt, $prdId, $gameId);
$stmt->execute();
$stmt->close();
}
}
}
if (!empty($popular))
{
$sql = "UPDATE game_list SET is_popular = 0";
$stmt = $conn->prepare($sql);
$updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
$stmt->execute();
$stmt->close();
foreach ($popular as $prdId => $gameInfos)
{
foreach($gameInfos as $gameInfo)
{
$gameId = $gameInfo->game_id;
$gameName = $gameInfo->game_name;
$sql = "UPDATE game_list
SET prd_id = ?
,game_id = ?
,game_name = ?
,is_popular = 1
,updated_at = ?
WHERE prd_id = ?
AND game_id = ?";
$stmt = $conn->prepare($sql);
$updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
$stmt->bind_param("iissii", $prdId, $gameId, $gameName, $updatedAt, $prdId, $gameId);
$stmt->execute();
$stmt->close();
}
}
}
if (!empty($new_game))
{
$sql = "UPDATE game_list SET is_new = 0";
$stmt = $conn->prepare($sql);
$updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
$stmt->execute();
$stmt->close();
foreach ($new_game as $prdId => $gameInfos)
{
foreach($gameInfos as $gameInfo)
{
$gameId = $gameInfo->game_id;
$gameName = $gameInfo->game_name;
$sql = "UPDATE game_list
SET prd_id = ?
,game_id = ?
,game_name = ?
,is_new = 1
,updated_at = ?
WHERE prd_id = ?
AND game_id = ?";
$stmt = $conn->prepare($sql);
$updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
$stmt->bind_param("iissii", $prdId, $gameId, $gameName, $updatedAt, $prdId, $gameId);
$stmt->execute();
$stmt->close();
}
}
}
}
else if ($status == 0 )
{
$error = $data->error;
var_dump($error);
exit;
}
else
{
var_dump("call_api_error");
exit;
}
}
catch (Exception $e)
{
var_dump($e);
exit;
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
public class GetGameInfo {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public GetGameInfo() {
try {
// Initialize database connection settings from constants
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
// Establish a database connection
Connection conn = DriverManager.getConnection(
"jdbc:mysql://" + dbServerName + "/" + dbName, dbUsername, dbPassword
);
conn.createStatement().execute("SET NAMES 'UTF8'");
// Initialize Amazon API settings from constants
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
String method = "/gameinfo"; // Game info retrieval method
// Prepare headers for the API request
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("ag-code", KPLAYCode);
header.put("ag-token", KPLAYToken);
// Prepare data for the API request
Map data = new HashMap<>();
data.put("language", "en");
String url = KPLAYHostname + method;
// Create an instance of Helper class to send the API request
String response = Helper.postData(url, data, header);
// Parse the response JSON
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject) jsonParser.parse(response);
int status = jo.get("status").getAsInt();
if (status == 1 && jo.has("recommended") && jo.has("popular") && jo.has("new_game")) {
com.google.gson.JsonArray recommendedArray = jo.getAsJsonArray("recommended");
com.google.gson.JsonArray popularArray = jo.getAsJsonArray("popular");
com.google.gson.JsonArray newGameArray = jo.getAsJsonArray("new_game");
// Process and update the database for recommended games
processAndInsertGames(recommendedArray, "is_recommended", conn);
// Process and update the database for popular games
processAndInsertGames(popularArray, "is_popular", conn);
// Process and update the database for new games
processAndInsertGames(newGameArray, "is_new", conn);
} else if (status == 0) {
// Handle error case
String error = jo.get("error").getAsString();
System.out.println(error);
} else {
// Handle call API error
System.out.println("call_api_error");
}
// Close the database connection
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
// Function to Process and Update Games for a Specific Category (recommended, popular, or new)
private void processAndInsertGames(JsonArray gamesArray, String columnName, Connection conn) {
try {
// Clear the corresponding column (e.g., is_recommended, is_popular, is_new)
clearDatabaseColumn(conn, columnName);
// Iterate through the games and insert/update them in the database
for (JsonElement gameElement : gamesArray) {
JsonObject gameObject = gameElement.getAsJsonObject();
int prdId = gameObject.get("prd_id").getAsInt();
int gameId = gameObject.get("game_id").getAsInt();
String gameName = gameObject.get("game_name").getAsString();
// Insert or update the game in the database for the specified category
insertOrUpdateGame(conn, prdId, gameId, gameName, columnName);
}
} catch (Exception e) {
e.printStackTrace();
}
}
// Function to Clear a Database Column
private void clearDatabaseColumn(Connection conn, String columnName) {
try {
String clearColumnSql = "UPDATE game_list SET " + columnName + " = 0";
PreparedStatement clearStmt = conn.prepareStatement(clearColumnSql);
clearStmt.executeUpdate();
clearStmt.close();
} catch (Exception e) {
e.printStackTrace();
}
}
// Function to Insert or Update a Game in the Database
private void insertOrUpdateGame(Connection conn, int prdId, int gameId, String gameName, String columnName) {
try {
if (gameExistsInDatabase(conn, prdId, gameId)) {
// Update the existing game record
String updateSql = "UPDATE game_list SET " + columnName + " = 1, game_name = ? WHERE prd_id = ? AND game_id = ?";
PreparedStatement updateStmt = conn.prepareStatement(updateSql);
updateStmt.setString(1, gameName);
updateStmt.setInt(2, prdId);
updateStmt.setInt(3, gameId);
updateStmt.executeUpdate();
updateStmt.close();
} else {
// Insert a new game record
String insertSql = "INSERT INTO game_list (prd_id, game_id, game_name, " + columnName + ") VALUES (?, ?, ?, 1)";
PreparedStatement insertStmt = conn.prepareStatement(insertSql);
insertStmt.setInt(1, prdId);
insertStmt.setInt(2, gameId);
insertStmt.setString(3, gameName);
insertStmt.executeUpdate();
insertStmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
private boolean gameExistsInDatabase(Connection conn, int prdId, int gameId) {
try {
String checkIfExistsSql = "SELECT COUNT(*) FROM game_list WHERE prd_id = ? AND game_id = ?";
PreparedStatement checkIfExistsStmt = conn.prepareStatement(checkIfExistsSql);
checkIfExistsStmt.setInt(1, prdId);
checkIfExistsStmt.setInt(2, gameId);
return checkIfExistsStmt.executeQuery().next();
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
public static void main(String[] args) {
GetGameInfo gameInfo = new GetGameInfo();
}
}
using System;
using System.Data;
using System.Data.SqlClient;
using System.Net.Http;
public class GetGameInfo
{
public GetGameInfo()
{
try
{
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
// Set the encoding to UTF8
var utf8Encoding = System.Text.Encoding.GetEncoding("UTF-8");
var utf8EncodingBytes = utf8Encoding.GetBytes("UTF-8");
// If the connection to the database fails
if (conn.State != ConnectionState.Open)
{
Console.WriteLine("Connection failed: " + conn.State);
return;
}
string hostName = Constants.KPLAYHostname; // Hostname
string token = Constants.KPLAYToken; // AG Token
string agent = Constants.KPLAYCode; // AG Code
string method = "/gameinfo";
// Prepare headers
var headers = new Dictionary
{
{ "Content-Type", "application/json" },
{ "ag-code", agent },
{ "ag-token", token }
};
// Prepare data
var data = new
{
language = "en"
};
string url = hostName + method;
// Post data via HttpClient
using (HttpClient httpClient = new HttpClient())
{
foreach (var header in headers)
{
httpClient.DefaultRequestHeaders.Add(header.Key, header.Value);
}
var json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
var content = new StringContent(json, utf8Encoding, "application/json");
HttpResponseMessage response = await httpClient.PostAsync(url, content);
string responseContent = await response.Content.ReadAsStringAsync();
error_log(json);
error_log(responseContent);
dynamic responseData = JObject.Parse(responseContent);
int status = responseData.status;
var recommended = (JObject)responseData.recommended;
var popular = (JObject)responseData.popular;
var new_game = (JObject)responseData.new_game;
if (status == 1 && (recommended.Count > 0 || popular.Count > 0 || new_game.Count > 0))
{
if (recommended.Count > 0)
{
// Update the game list to clear the "is_recommended" flag
string clearRecommendedSQL = "UPDATE game_list SET is_recommended = 0";
using (SqlCommand clearRecommendedCmd = new SqlCommand(clearRecommendedSQL, conn))
{
clearRecommendedCmd.ExecuteNonQuery();
}
foreach (var prdId in recommended)
{
foreach (var gameInfo in recommended[prdId])
{
int gameId = gameInfo.game_id;
string gameName = gameInfo.game_name;
// Update game information with "is_recommended" flag
string updateRecommendedSQL = "UPDATE game_list " +
"SET prd_id = @prdId, game_id = @gameId, game_name = @gameName, is_recommended = 1, updated_at = @updatedAt " +
"WHERE prd_id = @prdId AND game_id = @gameId";
using (SqlCommand updateRecommendedCmd = new SqlCommand(updateRecommendedSQL, conn))
{
updateRecommendedCmd.Parameters.AddWithValue("@prdId", prdId);
updateRecommendedCmd.Parameters.AddWithValue("@gameId", gameId);
updateRecommendedCmd.Parameters.AddWithValue("@gameName", gameName);
updateRecommendedCmd.Parameters.AddWithValue("@updatedAt", DateTime.Now);
updateRecommendedCmd.ExecuteNonQuery();
}
}
}
}
if (popular.Count > 0)
{
// Update the game list to clear the "is_popular" flag
string clearPopularSQL = "UPDATE game_list SET is_popular = 0";
using (SqlCommand clearPopularCmd = new SqlCommand(clearPopularSQL, conn))
{
clearPopularCmd.ExecuteNonQuery();
}
foreach (var prdId in popular)
{
foreach (var gameInfo in popular[prdId])
{
int gameId = gameInfo.game_id;
string gameName = gameInfo.game_name;
// Update game information with "is_popular" flag
string updatePopularSQL = "UPDATE game_list " +
"SET prd_id = @prdId, game_id = @gameId, game_name = @gameName, is_popular = 1, updated_at = @updatedAt " +
"WHERE prd_id = @prdId AND game_id = @gameId";
using (SqlCommand updatePopularCmd = new SqlCommand(updatePopularSQL, conn))
{
updatePopularCmd.Parameters.AddWithValue("@prdId", prdId);
updatePopularCmd.Parameters.AddWithValue("@gameId", gameId);
updatePopularCmd.Parameters.AddWithValue("@gameName", gameName);
updatePopularCmd.Parameters.AddWithValue("@updatedAt", DateTime.Now);
updatePopularCmd.ExecuteNonQuery();
}
}
}
}
if (new_game.Count > 0)
{
// Update the game list to clear the "is_new" flag
string clearNewSQL = "UPDATE game_list SET is_new = 0";
using (SqlCommand clearNewCmd = new SqlCommand(clearNewSQL, conn))
{
clearNewCmd.ExecuteNonQuery();
}
foreach (var prdId in new_game)
{
foreach (var gameInfo in new_game[prdId])
{
int gameId = gameInfo.game_id;
string gameName = gameInfo.game_name;
// Update game information with "is_new" flag
string updateNewSQL = "UPDATE game_list " +
"SET prd_id = @prdId, game_id = @gameId, game_name = @gameName, is_new = 1, updated_at = @updatedAt " +
"WHERE prd_id = @prdId AND game_id = @gameId";
using (SqlCommand updateNewCmd = new SqlCommand(updateNewSQL, conn))
{
updateNewCmd.Parameters.AddWithValue("@prdId", prdId);
updateNewCmd.Parameters.AddWithValue("@gameId", gameId);
updateNewCmd.Parameters.AddWithValue("@gameName", gameName);
updateNewCmd.Parameters.AddWithValue("@updatedAt", DateTime.Now);
updateNewCmd.ExecuteNonQuery();
}
}
}
}
}
else if (status == 0)
{
string error = responseData.error;
Console.WriteLine(error);
return;
}
else
{
Console.WriteLine("call_api_error");
return;
}
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
return;
}
}
}
<%
Sub gameinfo()
On Error Resume Next
' Define database connection parameters
Dim serverName, username, password, dbName
serverName = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbName = "DB_NAME"
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Err.Clear
Set conn = Nothing
Exit Sub
End If
conn.Execute "SET NAMES 'UTF8'"
' Define API parameters
Dim hostName, token, agent, method
hostName = "KPLAY_HOSTNAME" ' Hostname
token = "KPLAY_TOKEN" ' AG Token
agent = "KPLAY_CODE" ' AG Code
method = "/gameinfo"
' Prepare API request headers
Dim header
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
header.Add "ag-code", agent
header.Add "ag-token", token
' Prepare API request data
Dim data
Set data = Server.CreateObject("Scripting.Dictionary")
data.Add "language", "en"
' Build API request URL
Dim url
url = hostName & method
' Create an HTTP request object
Dim xmlhttp
Set xmlhttp = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Set request headers
For Each key In header.Keys
xmlhttp.setRequestHeader key, header(key)
Next
' Send a POST request with JSON data
xmlhttp.open "POST", url, False
xmlhttp.setRequestHeader "Content-Type", "application/json"
If IsObject(data) Then
dataStr = JSONStringify(data)
End If
xmlhttp.send dataStr
' Check if the request was successful
If xmlhttp.Status = 200 Then
' Parse the JSON response
Dim responseJson
Set responseJson = JSONParse(xmlhttp.responseText)
' Check if the 'status' key exists in the response
If responseJson.Exists("status") Then
If responseJson("status") = 1 Then
' Get the data from the response
Dim recommended, popular, new_game
Set recommended = responseJson("recommended")
Set popular = responseJson("popular")
Set new_game = responseJson("new_game")
' Clear existing flags in the database
Dim clearSql
clearSql = "UPDATE game_list SET is_recommended = 0, is_popular = 0, is_new = 0"
conn.Execute clearSql
' Process recommended games
If Not recommended Is Nothing Then
For Each prdId In recommended.Keys
For Each gameInfo In recommended(prdId)
Dim gameId, gameName, stmt, sql, updatedAt
gameId = gameInfo("game_id")
gameName = gameInfo("game_name")
updatedAt = Now()
' Update the game in the database
sql = "UPDATE game_list SET prd_id = ?, game_id = ?, game_name = ?, is_recommended = 1, updated_at = ?
WHERE prd_id = ? AND game_id = ?"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Parameters.Append stmt.CreateParameter("@gameName", 200, 1, Len(gameName), gameName)
stmt.Parameters.Append stmt.CreateParameter("@updatedAt", 135, 1, 19, updatedAt)
stmt.Parameters.Append stmt.CreateParameter("@prdId2", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId2", 3, 1, 4, gameId)
stmt.Execute
stmt.Close
Next
Next
End If
' Process popular games
If Not popular Is Nothing Then
For Each prdId In popular.Keys
For Each gameInfo In popular(prdId)
Dim gameId, gameName, stmt, sql, updatedAt
gameId = gameInfo("game_id")
gameName = gameInfo("game_name")
updatedAt = Now()
' Update the game in the database
sql = "UPDATE game_list SET prd_id = ?, game_id = ?, game_name = ?, is_popular = 1, updated_at = ?
WHERE prd_id = ? AND game_id = ?"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Parameters.Append stmt.CreateParameter("@gameName", 200, 1, Len(gameName), gameName)
stmt.Parameters.Append stmt.CreateParameter("@updatedAt", 135, 1, 19, updatedAt)
stmt.Parameters.Append stmt.CreateParameter("@prdId2", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId2", 3, 1, 4, gameId)
stmt.Execute
stmt.Close
Next
Next
End If
' Process new games
If Not new_game Is Nothing Then
For Each prdId In new_game.Keys
For Each gameInfo In new_game(prdId)
Dim gameId, gameName, stmt, sql, updatedAt
gameId = gameInfo("game_id")
gameName = gameInfo("game_name")
updatedAt = Now()
' Update the game in the database
sql = "UPDATE game_list SET prd_id = ?, game_id = ?, game_name = ?, is_new = 1, updated_at = ? WHERE prd_id = ? AND game_id = ?"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId", 3, 1, 4, gameId)
stmt.Parameters.Append stmt.CreateParameter("@gameName", 200, 1, Len(gameName), gameName)
stmt.Parameters.Append stmt.CreateParameter("@updatedAt", 135, 1, 19, updatedAt)
stmt.Parameters.Append stmt.CreateParameter("@prdId2", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@gameId2", 3, 1, 4, gameId)
stmt.Execute
stmt.Close
Next
Next
End If
ElseIf responseJson("status") = 0 Then
' API request returned an error
Dim errorDescription
errorDescription = responseJson("error")
Response.Write "Error: " & errorDescription
Else
' API request error
Response.Write "API request error"
End If
End If
Else
' HTTP request failed
Response.Write "HTTP request failed"
End If
' Clean up objects
Set xmlhttp = Nothing
Set responseJson = Nothing
Set data = Nothing
Set header = Nothing
' Close the database connection
conn.Close
Set conn = Nothing
End Sub
Sub JSONStringify(data)
Dim jsonString, key, value, valueType
jsonString = "{"
For Each key In data.Keys
value = data(key)
valueType = TypeName(value)
If valueType = "String" Then
jsonString = jsonString & """" & key & """:""" & Replace(value, """", "\""") & ""","
ElseIf valueType = "Double" Then
jsonString = jsonString & """" & key & """:" & Replace(value, ",", ".") & ","
ElseIf valueType = "Integer" Then
jsonString = jsonString & """" & key & """:" & value & ","
ElseIf valueType = "Boolean" Then
jsonString = jsonString & """" & key & """:" & IIf(value, "true", "false") & ","
ElseIf valueType = "Dictionary" Then
jsonString = jsonString & """" & key & """:" & JSONStringify(value) & ","
End If
Next
If Right(jsonString, 1) = "," Then
jsonString = Left(jsonString, Len(jsonString) - 1)
End If
jsonString = jsonString & "}"
JSONStringify = jsonString
End Sub
Sub JSONParse(jsonString)
Dim xmlDoc, jsonText
Set xmlDoc = Server.CreateObject("MSXML2.DOMDocument.6.0")
xmlDoc.async = False
xmlDoc.loadXML jsonString
If xmlDoc.parseError.errorCode <> 0 Then
Set JSONParse = Nothing
Exit Sub
End If
Set jsonText = Server.CreateObject("Scripting.Dictionary")
JSONParse = JSONPopulateObject(jsonText, xmlDoc.documentElement)
End Sub
Sub JSONPopulateObject(ByRef obj, xml)
Dim i, xmlNode, nodeName, nodeValue, childNode, childName
For Each xmlNode In xml.childNodes
nodeName = xmlNode.nodeName
nodeValue = xmlNode.nodeValue
If xmlNode.nodeType = 3 Then
obj(nodeName) = nodeValue
ElseIf xmlNode.nodeType = 1 And xmlNode.hasChildNodes Then
Set childNode = Server.CreateObject("Scripting.Dictionary")
JSONPopulateObject childNode, xmlNode
obj(nodeName) = childNode
End If
Next
Set JSONPopulateObject = obj
End Sub
%>
12. Get Push Bets (Optional)
Merchant will call this API from KPLAY to get pushed bet history.
● If the result of the game is a tie, transactions that bet on the player and banker will become "pushed" transactions.
E.g. A player places a bet on either player or banker but the result is tie, then the refunded amount = pushed_amount.
● If the pushed amount = 0, it means there is no push in the transaction.
● If the transaction is not in the list it means the data is not available yet.
● If the txn_id parameter exists, start_date and end_date fields will be ignored and become NOT
mandatory. It is just specify and grab ONE ONLY.
Note:
● This is used for merchants to get pushed bet history details from Evolution ONLY.
● Merchants are required to request date time in UTC+0.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonElement;
public class GetPushBet {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public GetPushBet() {
// Get constants from constant.java (DB and KPLAY settings)
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
}
public String getPushBet(String prdId, String txnId) {
try {
String method = "getpushbets"; // Push bet method
String url = KPLAYHostname + method;
String token = KPLAYToken;
String agent = KPLAYCode;
// Prepare headers
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("ag-code", agent);
header.put("ag-token", token);
// Prepare data
Map data = new HashMap<>();
data.put("prd_id", prdId);
data.put("txn_id", txnId);
String response = Helper.postData(url, data, header);
// Parse the response JSON
// (You can use a JSON library like Jackson or Gson for this)
// Example:
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject)jsonParser.parse(response);
if (jo.get("status").getAsInt() == 1 && jo.has("data")) {
Connection conn = DriverManager.getConnection("jdbc:mysql://" + dbServerName + "/" + dbName, dbUsername, dbPassword);
conn.createStatement().execute("SET NAMES 'UTF8'");
JsonElement jsonData = jo.getAsJsonArray("data").get(0);
String txnIdValue = jsonData.getAsJsonObject().get("txn_id").getAsString();
int pushedAmt = jsonData.getAsJsonObject().get("pushed_amount").getAsInt();
int pushedAmt1 = jsonData.getAsJsonObject().get("pushed_amount1").getAsInt();
String insertQuery = "INSERT INTO pushed_txn (txn_id, prd_id, pushed_amount, pushed_amount1) VALUES (?, ?, ?, ?)";
PreparedStatement stmt = conn.prepareStatement(insertQuery);
stmt.setString(1, txnIdValue);
stmt.setInt(2, Integer.parseInt(prdId));
stmt.setInt(3, pushedAmt);
stmt.setInt(4, pushedAmt1);
stmt.executeUpdate();
stmt.close();
conn.close();
}
return response;
} catch (Exception e) {
e.printStackTrace();
return "";
}
}
public static void main(String[] args) {
GetPushBet pushBet = new GetPushBet();
String response = pushBet.getPushBet("your_prd_id_here", "your_txn_id_here");
System.out.println(response);
}
}
using System;
using System.Data.SqlClient;
using System.Net.Http;
using Newtonsoft.Json;
using System.Collections.Generic;
public class GetPushBet
{
private string servername;
private string username;
private string password;
private string dbname;
private string hostName;
private string token;
private string agent;
private Dictionary header;
public GetPushBet()
{
this.servername = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbname = Constants.DB_NAME;
this.hostName = Constants.KPLAYHostname; // Hostname
this.token = Constants.KPLAYToken; // AG Token
this.agent = Constants.KPLAYCode; // AG Code
// Prepare headers
this.header = new Dictionary
{
{ "Content-Type", "application/json" },
{ "Ag-Code", agent },
{ "Ag-Token", token }
};
}
public string GetPushBet(int prdId, string txnId)
{
try
{
string method = "getpushbets"; // Auth game method
string url = hostName + method;
// Prepare data
var data = new Dictionary
{
{ "prd_id", prdId },
{ "txn_id", txnId }
};
using (HttpClient httpClient = new HttpClient())
{
foreach (var headerItem in header)
{
httpClient.DefaultRequestHeaders.Add(headerItem.Key, headerItem.Value);
}
string jsonData = JsonConvert.SerializeObject(data);
HttpContent content = new StringContent(jsonData);
content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
HttpResponseMessage response = httpClient.PostAsync(url, content).Result;
string responseContent = response.Content.ReadAsStringAsync().Result;
dynamic responseData = JsonConvert.DeserializeObject(responseContent);
if (responseData.status == 1 && responseData.data.Count > 0)
{
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
string txnIdFromData = responseData.data[0].txn_id;
int pushedAmt = responseData.data[0].pushed_amount;
int pushedAmt1 = responseData.data[0].pushed_amount1;
string insertPushedTxn = "INSERT INTO pushed_txn (txn_id, prd_id, pushed_amount, pushed_amount1) VALUES (@txnId, @prdId, @pushedAmt, @pushedAmt1)";
using (SqlCommand insertPushedTxnCmd = new SqlCommand(insertPushedTxn, conn))
{
insertPushedTxnCmd.Parameters.AddWithValue("@txnId", txnIdFromData);
insertPushedTxnCmd.Parameters.AddWithValue("@prdId", prdId);
insertPushedTxnCmd.Parameters.AddWithValue("@pushedAmt", pushedAmt);
insertPushedTxnCmd.Parameters.AddWithValue("@pushedAmt1", pushedAmt1);
insertPushedTxnCmd.ExecuteNonQuery();
}
}
}
return responseContent;
}
}
catch (Exception e)
{
Console.WriteLine(e);
return e.ToString();
}
}
}
<%
Sub getPushBet(prdId, txnId)
On Error Resume Next
' Define API parameters
Dim method, url, data, header, conn
method = "getpushbets" ' Auth game method
url = hostName & method
' Prepare data
Set data = Server.CreateObject("Scripting.Dictionary")
data.Add "prd_id", prdId
data.Add "txn_id", txnId
' Create an HTTP request object
Dim xmlhttp
Set xmlhttp = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Set request headers
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
' Send a POST request with JSON data
xmlhttp.open "POST", url, False
For Each key In header.Keys
xmlhttp.setRequestHeader key, header(key)
Next
xmlhttp.send JSONStringify(data)
' Check if the request was successful
If xmlhttp.Status = 200 Then
' Parse the JSON response
Dim responseJson
Set responseJson = JSONParse(xmlhttp.responseText)
' Check if the 'status' key exists in the response
If responseJson.Exists("status") Then
If responseJson("status") = 1 Then
' Get data from the response
Set dataArray = responseJson("data")
If Not IsEmpty(dataArray) Then
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & serverName & ";Initial Catalog=" & dbName & ";User ID=" &
username & ";Password=" & password & ";"
' Check if the database connection is successful
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Err.Clear
Set conn = Nothing
Exit Sub
End If
conn.Execute "SET NAMES 'UTF8'"
' Get data from the response
txnId = dataArray(0)("txn_id")
pushedAmt = dataArray(0)("pushed_amount")
pushedAmt1 = dataArray(0)("pushed_amount1")
' Prepare and execute the SQL INSERT statement
sql = "INSERT INTO pushed_txn (txn_id, prd_id, pushed_amount, pushed_amount1) VALUES (?, ?, ?, ?)"
Set stmt = conn.Prepare(sql)
stmt.Parameters.Append stmt.CreateParameter("@txnId", 200, 1, Len(txnId), txnId)
stmt.Parameters.Append stmt.CreateParameter("@prdId", 3, 1, 4, prdId)
stmt.Parameters.Append stmt.CreateParameter("@pushedAmt", 3, 1, 4, pushedAmt)
stmt.Parameters.Append stmt.CreateParameter("@pushedAmt1", 3, 1, 4, pushedAmt1)
stmt.Execute
stmt.Close
' Clean up the database connection
conn.Close
Set conn = Nothing
End If
End If
End If
Else
' HTTP request failed
Response.Write "HTTP request failed"
End If
' Clean up objects
Set xmlhttp = Nothing
Set responseJson = Nothing
Set data = Nothing
Set header = Nothing
End Sub
Sub JSONStringify(data)
Dim jsonString, key, value, valueType
jsonString = "{"
For Each key In data.Keys
value = data(key)
valueType = TypeName(value)
If valueType = "String" Then
jsonString = jsonString & """" & key & """:""" & Replace(value, """", "\""") & ""","
ElseIf valueType = "Double" Then
jsonString = jsonString & """" & key & """:" & Replace(value, ",", ".") & ","
ElseIf valueType = "Integer" Then
jsonString = jsonString & """" & key & """:" & value & ","
ElseIf valueType = "Boolean" Then
jsonString = jsonString & """" & key & """:" & IIf(value, "true", "false") & ","
ElseIf valueType = "Dictionary" Then
jsonString = jsonString & """" & key & """:" & JSONStringify(value) & ","
End If
Next
If Right(jsonString, 1) = "," Then
jsonString = Left(jsonString, Len(jsonString) - 1)
End If
jsonString = jsonString & "}"
JSONStringify = jsonString
End Sub
Sub JSONParse(jsonString)
Dim xmlDoc, jsonText
Set xmlDoc = Server.CreateObject("MSXML2.DOMDocument.6.0")
xmlDoc.async = False
xmlDoc.loadXML jsonString
If xmlDoc.parseError.errorCode <> 0 Then
Set JSONParse = Nothing
Exit Sub
End If
Set jsonText = Server.CreateObject("Scripting.Dictionary")
JSONParse = JSONPopulateObject(jsonText, xmlDoc.documentElement)
End Sub
Sub JSONPopulateObject(ByRef obj, xml)
Dim i, xmlNode, nodeName, nodeValue, childNode, childName
For Each xmlNode In xml.childNodes
nodeName = xmlNode.nodeName
nodeValue = xmlNode.nodeValue
If xmlNode.nodeType = 3 Then
obj(nodeName) = nodeValue
ElseIf xmlNode.nodeType = 1 And xmlNode.hasChildNodes Then
Set childNode = Server.CreateObject("Scripting.Dictionary")
JSONPopulateObject childNode, xmlNode
obj(nodeName) = childNode
End If
Next
Set JSONPopulateObject = obj
End Sub
%>
13. BUY-IN (Mandatory)
KPLAY will call this API in the merchant system to notify merchants that a buyin occurs. (Only for P2P Product)
HTTP methods : POST
URL : <Merchant endpoint>/buyin
13.1 Request Format
Header
Field
Type
Description
secret-key
string
KPLAY merchant secret key. For merchants to verify the request comes from KPLAY.
Body
Field
Type
Description
user_id
integer
KPLAY user ID
amount
decimal(15, 2)
Buy-in amount
prd_id
integer
Product ID
txn_id
string
Unique transaction ID, also used to be paired with credit call.
game_id
integer
Game ID available to call using product game list API. Refer to 10. Product Game List
credit_amount
decimal(15, 2)
If credit_amount exists, then AG needs to generate credit settlement for it.
13.2 Request Example
{
"user_id":1000011,
"amount":100.00,
"prd_id":506,
"txn_id":"A00000005",
"game_id":1005
}
With credit_amount
{
"user_id":1000011,
"amount":100.00,
"prd_id":506,
"txn_id":"A00000005",
"game_id":1005,
"credit_amount":100
}
13.3 Response Format
Field
Type
Description
status
integer
0 = error
1 = success
balance
decimal(15, 2)
Latest member balance
error
string
Error message when status = 0
13.4 Response Example
When success
{
"status":1,
"balance":505.50
}
When error
{
"status":0,
"error":"ACCESS_DENIED"
}
Error Message
Description
ACCESS_DENIED
Invalid Secret Key
INVALID_USER
Check if user exists in merchant system
DUPLICATE_DEBIT
Check if a debit with the same “txn_id” exists in the merchant system.
INSUFFICIENT_FUNDS
Check if the member has enough balance for the debit.
UNKNOWN_ERROR
Internal error in merchant system
function processBuyin($data)
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$conn = new \mysqli($servername, $username, $password, $dbname);
//if connect to DB failed
if ($conn->connect_error)
{
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
$conn->begin_transaction();
//get data from debit request
$param = json_decode($data);
$KPLAYId = $param->user_id;
$amount = $param->amount;
$txnId = $param->txn_id;
$prdId = $param->prd_id;
$gameId = $param->game_id;
$credit = null; //some slots will send debit and credit pair
if(isset($param->credit_amount))
{
$credit = $param->credit_amount;
}
//select member from DB
$selectSQL = "SELECT user_id
FROM users
WHERE KPLAY_id = ".$KPLAYId;
$db = $conn->query($selectSQL);
//check if member exist
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$userId = $row['user_id'];//member ID for KPLAY
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
$selectSQL = "SELECT balance
FROM users_balance
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
//check if member have balance
if (isset($db->num_rows) && $db->num_rows > 0)
{
while($row = $db->fetch_assoc())
{
$balance = $row['balance'];//member balance
}
}
else
{
//if member are not exist
return $response = [
'status' => 0
,'error' => 'INVALID_USER'
];
}
//Check if the balance is enough for the bet amount
if ($balance >= $amount)
{
$balance = $balance - $amount;
$selectSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($selectSQL);
}
else
{
$conn->rollback();
//if INSUFFICIENT_FUNDS
return $response = [
'status' => 0
,'error' => 'INSUFFICIENT_FUNDS'
];
}
//Check if this transaction already in database
$selectSQL = "SELECT txn_id
FROM debit
WHERE txn_id = '".$txnId."'";
$db = $conn->query($selectSQL);
//If transaction already in database
if (isset($db->num_rows) && $db->num_rows > 0)
{
$conn->rollback();
return $response = [
'status' => 0
,'error' => 'DUPLICATE_DEBIT'
];
}
else
{
$insertSQL = "INSERT INTO debit
(user_id,amount,txn_id,prd_id,game_id)
VALUES
(".$userId.",".$amount.",'".$txnId."',".$prdId.",".$gameId.")";
$db = $conn->query($insertSQL);
if(!is_null($credit))
{//do credit
//Insert credit record to DB
$insertCreditSQL = "INSERT INTO credit
(txn_id,type,amount)
VALUES
('".$txnId."','c',".$credit.")";
$db = $conn->query($insertCreditSQL);
//Update user balance
$balance = $balance + $credit;
$updateCreditSQL = "UPDATE users_balance
SET balance = ".$balance."
WHERE user_id = ".$userId;
$db = $conn->query($updateCreditSQL);
}
$conn->commit();
return $response = [
'status' => 1
,'balance' => $balance
];
}
}
catch (Exception $e)
{
$conn->rollback();
//if error
return $response = [
'status' => 0
,'error' => 'UNKNOWN_ERROR'
];
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import org.json.JSONObject;
import org.springframework.ejb.access.EjbAccessException;
public class Buyin {
private String servername;
private String username;
private String password;
private String dbname;
public Buyin() {
// Initialize constants from constant.java (DB Server, Username, Password, DB Name)
this.servername = constant.DB_SERVER_NAME;
this.username = constant.DB_USERNAME;
this.password = constant.DB_PASSWORD;
this.dbname = constant.DB_NAME;
}
public Map processBuyin(String data) {
Map response = new HashMap<>();
try {
// Database connection
String jdbcUrl = "jdbc:mysql://" + servername + "/" + dbname;
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// If the connection to the database fails
if (conn == null) {
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
conn.setAutoCommit(false); // Start a transaction
// Parsing JSON data (Implement your JSON parsing logic here)
Map param = parseJson(data);
int KPLAYId = Integer.parseInt((String) param.get("user_id"));
double amount = Double.parseDouble((String) param.get("amount"));
String txnId = (String) param.get("txn_id");
int prdId = Integer.parseInt((String) param.get("prd_id"));
int gameId = Integer.parseInt((String) param.get("game_id"));
Double credit = (param.containsKey("credit_amount")) ? Double.parseDouble((String) param.get("credit_amount")) : null;
// Select member from DB
String selectUserSQL = "SELECT user_id FROM users WHERE KPLAY_id = ?";
PreparedStatement userStatement = conn.prepareStatement(selectUserSQL);
userStatement.setInt(1, KPLAYId);
ResultSet userResultSet = userStatement.executeQuery();
int userId = 0;
if (userResultSet.next()) {
userId = userResultSet.getInt("user_id");
} else {
// If member does not exist
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Select balance from the user balance table
String selectBalanceSQL = "SELECT balance FROM users_balance WHERE user_id = ?";
PreparedStatement balanceStatement = conn.prepareStatement(selectBalanceSQL);
balanceStatement.setInt(1, userId);
ResultSet balanceResultSet = balanceStatement.executeQuery();
double userBalance = 0.0;
if (balanceResultSet.next()) {
userBalance = balanceResultSet.getDouble("balance");
} else {
// If member does not have a balance
conn.rollback();
response.put("status", 0);
response.put("error", "INVALID_USER");
return response;
}
// Check if the balance is enough for the bet amount
if (userBalance >= amount) {
userBalance -= amount;
String updateBalanceSQL = "UPDATE users_balance SET balance = ? WHERE user_id = ?";
PreparedStatement updateBalanceStatement = conn.prepareStatement(updateBalanceSQL);
updateBalanceStatement.setDouble(1, userBalance);
updateBalanceStatement.setInt(2, userId);
int rowsUpdated = updateBalanceStatement.executeUpdate();
if (rowsUpdated != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_BALANCE_ERROR");
return response;
}
} else {
conn.rollback();
// If INSUFFICIENT_FUNDS
response.put("status", 0);
response.put("error", "INSUFFICIENT_FUNDS");
return response;
}
// Check if this transaction already exists in the database
String selectTransactionSQL = "SELECT txn_id FROM debit WHERE txn_id = ?";
PreparedStatement transactionStatement = conn.prepareStatement(selectTransactionSQL);
transactionStatement.setString(1, txnId);
ResultSet transactionResultSet = transactionStatement.executeQuery();
if (transactionResultSet.next()) {
conn.rollback();
response.put("status", 0);
response.put("error", "DUPLICATE_DEBIT");
return response;
}
// Insert debit record into DB
String insertDebitSQL = "INSERT INTO debit (user_id, amount, txn_id, prd_id, game_id) VALUES (?, ?, ?, ?, ?)";
PreparedStatement insertDebitStatement = conn.prepareStatement(insertDebitSQL);
insertDebitStatement.setInt(1, userId);
insertDebitStatement.setDouble(2, amount);
insertDebitStatement.setString(3, txnId);
insertDebitStatement.setInt(4, prdId);
insertDebitStatement.setInt(5, gameId);
int rowsInserted = insertDebitStatement.executeUpdate();
if (rowsInserted != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_DEBIT_ERROR");
return response;
}
if (credit != null) {
// Insert credit record into DB
String insertCreditSQL = "INSERT INTO credit (txn_id, type, amount) VALUES (?, 'c', ?)";
PreparedStatement insertCreditStatement = conn.prepareStatement(insertCreditSQL);
insertCreditStatement.setString(1, txnId);
insertCreditStatement.setDouble(2, credit);
int rowsInsertedCredit = insertCreditStatement.executeUpdate();
if (rowsInsertedCredit != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "INSERT_CREDIT_ERROR");
return response;
}
// Update user balance with credit
userBalance += credit;
String updateCreditBalanceSQL = "UPDATE users_balance SET balance = ? WHERE user_id = ?";
PreparedStatement updateCreditBalanceStatement = conn.prepareStatement(updateCreditBalanceSQL);
updateCreditBalanceStatement.setDouble(1, userBalance);
updateCreditBalanceStatement.setInt(2, userId);
int rowsUpdatedCreditBalance = updateCreditBalanceStatement.executeUpdate();
if (rowsUpdatedCreditBalance != 1) {
conn.rollback();
response.put("status", 0);
response.put("error", "UPDATE_CREDIT_BALANCE_ERROR");
return response;
}
}
conn.commit();
response.put("status", 1);
response.put("balance", userBalance);
return response;
} catch (SQLException e) {
e.printStackTrace();
// If there is an error
response.put("status", 0);
response.put("error", "UNKNOWN_ERROR");
return response;
}
}
// Function to parse JSON data into a map using org.json
private Map parseJson(String json) {
Map resultMap = new HashMap<>();
try {
// Create a JSON object from the input JSON string
JSONObject jsonObject = new JSONObject();
// Iterate through the keys in the JSON object and add them to the map
for (String key : jsonObject.keySet()) {
Object value = jsonObject.get(key);
resultMap.put(key, value);
}
return resultMap;
} catch (EjbAccessException e) {
e.printStackTrace(); // Handle the exception appropriately
return null; // Return null in case of parsing error
}
}
}
14. BET DETAIL
Merchant can call this API to get the detail of the bet
HTTP methods : POST
URL : <KPLAY endpoint>/betresults
14.1 Request Format
Header
Name
Type
Mandatory
Remark
ag-code
String
Y
ag-token
String
Y
Body
Name
Type
Mandatory
Remark
lang
String
Y
Korean: ko,
English: en
prd_id
Number
Y
txn_id
string
Y
14.2 Request Example
{
"lang":"en",
"prd_id":5001,
"txn_id":"8888888888"
}
14.3 Response Format
If the txn id is valid and successfully retrieves bet detail, we will return a URL that will open the bet detail page. If txn id is not valid or fails to retrieve bet detail, we will respond with the error code.
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
public class RemainingDeposit {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public RemainingDeposit() {
// Get constants from constant.java (DB and KPLAY settings)
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
}
public void synchronizeRemainingDeposit() {
try {
// Establish a database connection
Connection conn = DriverManager.getConnection("jdbc:mysql://" + dbServerName + "/" + dbName, dbUsername, dbPassword);
conn.createStatement().execute("SET NAMES 'UTF8'");
String token = KPLAYToken;
String agent = KPLAYCode;
String method = "remainingdeposit"; // auth game method
String url = KPLAYHostname + method;
// Prepare headers
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("ag-code", agent);
header.put("ag-token", token);
String response = Helper.getData(url, header);
// Parse the response JSON
// (You can use a JSON library like Jackson or Gson for this)
// Example:
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject)jsonParser.parse(response);
if (jo.has("status") && jo.get("status").getAsInt() == 1) {
int given = jo.get("given_deposit").getAsInt();
int available = jo.get("available_deposit").getAsInt();
String insertCredit = "INSERT INTO remaining_deposit (ag_code, given_deposit, available_deposit) VALUES (?, ?, ?)"
+ " ON DUPLICATE KEY UPDATE given_deposit = ?, available_deposit = ?";
PreparedStatement stmt = conn.prepareStatement(insertCredit);
stmt.setString(1, KPLAYCode);
stmt.setInt(2, given);
stmt.setInt(3, available);
stmt.setInt(4, given);
stmt.setInt(5, available);
stmt.executeUpdate();
stmt.close();
}
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using Newtonsoft.Json;
public class RemainingDeposit
{
private string servername;
private string username;
private string password;
private string dbname;
private string hostName;
private string token;
private string agent;
public RemainingDeposit()
{
this.servername = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbname = Constants.DB_NAME;
this.hostName = Constants.KPLAYHostname; // KPLAY Hostname
this.token = Constants.KPLAYToken; // KPLAY Token
this.agent = Constants.KPLAYCode; // KPLAY Code
}
public async Task UpdateRemainingDeposit()
{
try
{
// Assuming you have valid values for KPLAY parameters
string KPLAYHostname = hostName;
string KPLAYToken = token;
string KPLAYCode = agent;
string method = "remainingDeposit";
string url = KPLAYHostname + method;
// Prepare header
var KPLAYHeader = new HttpClient();
KPLAYHeader.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
KPLAYHeader.DefaultRequestHeaders.Add("Ag-Code", KPLAYCode);
KPLAYHeader.DefaultRequestHeaders.Add("Ag-Token", KPLAYToken);
// Send a GET request to the KPLAY endpoint
var response = await KPLAYHeader.GetAsync(url);
if (response.IsSuccessStatusCode)
{
string responseContent = await response.Content.ReadAsStringAsync();
dynamic responseData = JsonConvert.DeserializeObject(responseContent);
int status = responseData.status;
if (status == 1)
{
double given = responseData.given_deposit;
double available = responseData.available_deposit;
// Assuming you have a database connection
using (var conn = new SqlConnection(connectionString))
{
conn.Open();
string sql = "INSERT INTO remaining_deposit (ag_code, given_deposit, available_deposit) VALUES (@agent, @given, @available) ON DUPLICATE KEY UPDATE given_deposit = @given, available_deposit = @available";
using (var cmd = new SqlCommand(sql, conn))
{
cmd.Parameters.AddWithValue("@agent", KPLAYCode);
cmd.Parameters.AddWithValue("@given", given);
cmd.Parameters.AddWithValue("@available", available);
cmd.ExecuteNonQuery();
}
}
Console.WriteLine(responseContent);
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
<%
Sub remainingDeposit()
' Define API parameters
Dim hostName, method, url, header, ch, responseKPLAY, data, given, available, status, insertCredit
hostName = KPLAY_HOSTNAME ' Hostname
method = "remainingDeposit" ' Auth game method
url = hostName & method
' Create an HTTP request object
Dim xmlhttp
Set xmlhttp = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Set request headers
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
' Send a GET request
xmlhttp.open "GET", url, False
For Each key In header.Keys
xmlhttp.setRequestHeader key, header(key)
Next
xmlhttp.send
' Check if the request was successful
If xmlhttp.Status = 200 Then
responseKPLAY = xmlhttp.responseText
' Parse JSON response
Set data = JSONParse(responseKPLAY)
If IsObject(data) Then
If data.status = 1 Then
given = data.given_deposit
available = data.available_deposit
status = data.status
' Prepare SQL statement
insertCredit = "INSERT INTO remaining_deposit (ag_code, given_deposit, available_deposit) " & _
"VALUES ('" & agent & "', " & given & ", " & available & ") " & _
"ON DUPLICATE KEY UPDATE given_deposit = " & given & ", available_deposit = " & available
' Create a database connection
Dim conn
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=MySQLProv;Data Source=" & DB_SERVER_NAME & ";User ID=" & DB_USERNAME & ";
Password=" & DB_PASSWORD & ";Initial Catalog=" & DB_NAME
' Execute SQL statement
On Error Resume Next
conn.Execute insertCredit
If Err.Number <> 0 Then
responseKPLAY = "Database Error: " & Err.Description
End If
On Error Goto 0
' Close database connection
conn.Close
Set conn = Nothing
End If
End If
Else
' HTTP request failed
responseKPLAY = "HTTP request failed"
End If
' Clean up objects
Set xmlhttp = Nothing
Set header = Nothing
Set data = Nothing
' Return the API response
remainingDeposit = responseKPLAY
End Sub
Sub JSONParse(jsonString)
Dim objJSON
Set objJSON = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
objJSON.Open "GET", "data:text/plain;charset=UTF-8," & Server.URLEncode(jsonString), False
objJSON.setRequestHeader "Content-Type", "text/xml;charset=UTF-8"
objJSON.send ""
JSONParse = objJSON.responseXML
Set objJSON = Nothing
End Sub
%>
17. Get Game Table ID
Merchants can call this API to get table ID(s) of Evolution based on their current skin setting from KPLAY. For direct launch to specific table purposes.
HTTP methods : GET
URL : <KPLAY endpoint>/getgametable
17.1 Request Format
Header
Field
Type
Description
ag-code
String
KPLAY merchant code
ag-token
String
KPLAY merchant token
Body
Field
Type
Description
language
string
Language option for game name.
Default English
Korean : ko, English : en
17.2 Request Example
{
"language":"en"
}
17.3 Response Format
Field
Type
Desciptipn
status
Int
0 - error 1 - success
skin_id
Int
The current skin ID of the AG.
game_name
String
The name of the game, from Evolution.
table_id
String
The table ID for direct launch to a specific game table.
using System;
using System.Data.SqlClient;
using System.Net.Http;
using Newtonsoft.Json;
public class GetGameTableId
{
public GetGameTableId()
{
try
{
string connectionString = Constants.DB_CONNECTION_STRING;
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
string hostName = Constants.KPLAYHostname; // Hostname
string token = Constants.KPLAYToken; // AG Token
string agent = Constants.KPLAYCode; // AG Code
// Prepare headers
var headers = new Dictionary
{
{ "Content-Type", "application/json" },
{ "Ag-Code", agent },
{ "Ag-Token", token }
};
string method = "getgametable"; // Auth game method
string url = hostName + method;
// Post data via HttpClient
using (HttpClient httpClient = new HttpClient())
{
foreach (var header in headers)
{
httpClient.DefaultRequestHeaders.Add(header.Key, header.Value);
}
HttpResponseMessage response = httpClient.GetAsync(url).Result;
string responseContent = response.Content.ReadAsStringAsync().Result;
dynamic data = JsonConvert.DeserializeObject(responseContent);
if (data.status == 1 && data.tables.Count > 0)
{
int skinId = data.tables[0].skin_id;
string gameName = data.tables[0].game_name;
int tableId = data.tables[0].table_id;
string insertTableId =
$"INSERT INTO evo_table_id (prd_id, skin_id, table_id, game_name) " +
$"VALUES (1, {skinId}, {tableId}, '{gameName}') " +
$"ON DUPLICATE KEY UPDATE skin_id = {skinId}, table_id = {tableId}, game_name = '{gameName}'";
using (SqlCommand insertTableIdCmd = new SqlCommand(insertTableId, conn))
{
insertTableIdCmd.ExecuteNonQuery();
}
}
Console.WriteLine(responseContent);
}
}
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
<%
sub getGameTable()
Dim servername,username,password,dbname,hostName,token,agent,header,method,url,ch,responseKPLAY,data
servername = "DB_SERVER_NAME"
username = "DB_USERNAME"
password = "DB_PASSWORD"
dbname = "DB_NAME"
hostName = "KPLAY_HOSTNAME" ' Hostname
token = "KPLAY_TOKEN" ' AG Token
agent = "KPLAY_CODE" ' AG Code
' Prepare header
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
header.Add "Ag-Code", agent
header.Add "Ag-Token", token
method = "getgametable" ' Auth game method
url = hostName & method
Set ch = Server.CreateObject("MSXML2.ServerXMLHTTP")
ch.Open "GET", url, False
ch.setRequestHeader "Content-Type", header("Content-Type")
ch.send ""
responseKPLAY = ch.responseText
Set data = JsonDecode(responseKPLAY)
If data("status") = 1 And Not IsEmpty(data("tables")) Then
' Update the database here
End If
Set ch = Nothing
Set data = Nothing
End sub
%>
18. Get Rake API (P2P Product)
Merchants can call this API to get new rakes daily.
Note: Strictly for seamless wallet ONLY.
Note: To get accurate data, please always call this API with the date of yesterday, example for
accurate data on May 4th you should call this API on May 5th
HTTP methods : POST
URL : <KPLAY endpoint>/getrake
18.1 Request Format
Header
Field
Type
Description
ag-code
String
KPLAY merchant code
ag-token
String
KPLAY merchant token
Body
Name
Type
Description
prd_id
Int
P2P Product ID
start_date
Date
Begin date of rake.
end_date
Date
End date of rake
18.2 Request Example
{
"prd_id":10002,
"start_date": "2023-04-17",
"end_date": "2023-04-18"
}
18.3 Response Format
Field
Type
Desciptipn
status
Int
0 - error 1 - success
data
Object
username
String
The username of the user
member_id
Int
The user ID of KPLAY
date
Date
The date (UTC+9)
rake
Decimal
The daily rake
18.4 Response Example
When success
{
"status":1,
"data":[
{
"username": "babara",
"member_id":192928,
"date": 2023-04-17,
"rake":"123.00",
},
{
"username": zuhui,
"member_id":192930,
"date": 2023-04-18,
"rake":"123.00",
}
]
}
When error
{
"status":0,
"error":"ACCESS_DENIED"
}
Error Message
Description
INVALID_DATE
start_date or end_date from the request body is not empty/not found.
INVALID_PARAMETER
ag_code or ag_token from header is not found/mismatch.
ACCESS_DENIED
Merchant is disabled.
USER_NOT_EXIST
The Merchant does not exist.
UNKNOWN_ERROR
Invalid wallet. The request was not from seamless wallet Merchant.
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.HashMap;
import java.util.Map;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
public class GetRake {
private String dbServerName;
private String dbUsername;
private String dbPassword;
private String dbName;
private String KPLAYHostname;
private String KPLAYCode;
private String KPLAYToken;
public GetRake() {
// Get constants from constant.java (DB and KPLAY settings)
this.dbServerName = constant.DB_SERVER_NAME;
this.dbUsername = constant.DB_USERNAME;
this.dbPassword = constant.DB_PASSWORD;
this.dbName = constant.DB_NAME;
this.KPLAYHostname = constant.KPLAY_HOSTNAME;
this.KPLAYCode = constant.KPLAY_CODE;
this.KPLAYToken = constant.KPLAY_TOKEN;
}
public void retrieveRakeData() {
try {
// Establish a database connection
Connection conn = DriverManager.getConnection("jdbc:mysql://" + dbServerName + "/" + dbName, dbUsername, dbPassword);
conn.createStatement().execute("SET NAMES 'UTF8'");
String hostName = KPLAYHostname;
String token = KPLAYToken;
String agent = KPLAYCode;
String method = "getrake"; // Rake retrieval method
// Prepare URL
String url = hostName + method;
// Prepare headers
Map header = new HashMap<>();
header.put("Content-Type", "application/json");
header.put("ag-code", agent);
header.put("ag-token", token);
String startDate = "2023-04-17";
String endDate = "2023-04-18";
// Prepare data
Map data = new HashMap<>();
data.put("start_date", startDate);
data.put("end_date", endDate);
String response = Helper.postData(url, data, header);
// Parse the response JSON
// (You can use a JSON library like Jackson or Gson for this)
// Example:
JsonParser jsonParser = new JsonParser();
JsonObject jo = (JsonObject)jsonParser.parse(response);
if (jo.get("status").getAsInt() == 1 && jo.has("data")) {
JsonArray rakeDataArray = jo.getAsJsonArray("data");
for (JsonElement element : rakeDataArray) {
JsonObject rakeData = element.getAsJsonObject();
// Extract relevant information from the JSON object
String playerId = rakeData.get("player_id").getAsString();
String playerName = rakeData.get("player_name").getAsString();
double rakeAmount = rakeData.get("rake_amount").getAsDouble();
// Process the extracted data as needed
System.out.println("Player ID: " + playerId);
System.out.println("Player Name: " + playerName);
System.out.println("Rake Amount: " + rakeAmount);
// Perform additional processing or store the data in your application
}
}
System.out.println(response);
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
GetRake rake = new GetRake();
rake.retrieveRakeData();
}
}
using System;
using System.Data.SqlClient;
using System.Net.Http;
using Newtonsoft.Json;
using System.Collections.Generic;
public class GetRake
{
private string servername;
private string username;
private string password;
private string dbname;
private string hostName;
private string token;
private string agent;
private Dictionary header;
public GetRake()
{
this.servername = Constants.DB_SERVER_NAME;
this.username = Constants.DB_USERNAME;
this.password = Constants.DB_PASSWORD;
this.dbname = Constants.DB_NAME;
this.hostName = Constants.KPLAYHostname; // KPLAY Hostname
this.token = Constants.KPLAYToken; // KPLAY Token
this.agent = Constants.KPLAYCode; // KPLAY Code
// Prepare headers
this.header = new Dictionary
{
{ "Content-Type", "application/json" },
{ "Ag-Code", agent },
{ "Ag-Token", token }
};
}
public void GetRakeData(string startDate, string endDate)
{
try
{
string method = "getrake"; // method
string url = hostName + method; // endpoint
// Prepare data
var data = new Dictionary
{
{ "start_date", startDate },
{ "end_date", endDate }
};
using (HttpClient httpClient = new HttpClient())
{
foreach (var headerItem in header)
{
httpClient.DefaultRequestHeaders.Add(headerItem.Key, headerItem.Value);
}
string jsonData = JsonConvert.SerializeObject(data);
HttpContent content = new StringContent(jsonData);
content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
HttpResponseMessage response = httpClient.PostAsync(url, content).Result;
string responseContent = response.Content.ReadAsStringAsync().Result;
dynamic responseData = JsonConvert.DeserializeObject(responseContent);
if (responseData.status == 1 && responseData.data.Count > 0)
{
// Handle the data as needed
}
Console.WriteLine(responseContent);
}
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
<%
Sub getRake()
' Define API parameters
Dim servername, username, password, dbname, hostName, token, agent, conn, method, url, header, ch, responseKPLAY, data, startDate, endDate
servername = DB_SERVER_NAME
username = DB_USERNAME
password = DB_PASSWORD
dbname = DB_NAME
hostName = KPLAY_HOSTNAME ' KPLAY Hostname
token = KPLAY_TOKEN ' KPLAY Token
agent = KPLAY_CODE ' KPLAY Code
' Create a database connection
Set conn = Server.CreateObject("ADODB.Connection")
conn.Open "Provider=SQLOLEDB;Data Source=" & servername & ";Initial Catalog=" & dbname & ";User Id=" & username & ";Password=" & password & ";"
' Check if the database connection is successful
If Err.Number <> 0 Then
Response.Write "Connection failed: " & Err.Description
Err.Clear
Set conn = Nothing
Response.End
End If
method = "getrake" ' method
url = hostName & method ' endpoint
' Create an HTTP request object
Set ch = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
' Set request headers
Set header = Server.CreateObject("Scripting.Dictionary")
header.Add "Content-Type", "application/json"
header.Add "Ag-Code", agent
header.Add "Ag-Token", token
startDate = "2023-04-17"
endDate = "2023-04-18"
' Create a dictionary for the request data
Set data = Server.CreateObject("Scripting.Dictionary")
data.Add "start_date", startDate
data.Add "end_date", endDate
' Convert request data to JSON
Dim requestDataJson
requestDataJson = JSONStringify(data)
' Send a POST request
ch.open "POST", url, False
For Each key In header.Keys
ch.setRequestHeader key, header(key)
Next
ch.setRequestHeader "Content-Length", Len(requestDataJson)
ch.send requestDataJson
' Check if the request was successful
If ch.Status = 200 Then
responseKPLAY = ch.responseText
' Parse JSON response
Set data = JSONParse(responseKPLAY)
If IsObject(data) Then
If data.status = 1 And Not IsEmpty(data.data) Then
' Perform the next steps as needed
End If
End If
' Output the API response for testing
Response.Write responseKPLAY
Else
' HTTP request failed
Response.Write "HTTP request failed"
End If
' Clean up objects
Set ch = Nothing
Set header = Nothing
Set data = Nothing
Set conn = Nothing
End Sub
Sub JSONStringify(obj)
Dim json, key
json = "{"
For Each key In obj.Keys
json = json & """" & key & """" & ":" & """" & obj(key) & """" & ","
Next
If Len(json) > 1 Then
json = Left(json, Len(json) - 1)
End If
json = json & "}"
JSONStringify = json
End Sub
Sub JSONParse(jsonString)
Dim objJSON
Set objJSON = Server.CreateObject("MSXML2.ServerXMLHTTP.6.0")
objJSON.Open "GET", "data:text/plain;charset=UTF-8," & Server.URLEncode(jsonString), False
objJSON.setRequestHeader "Content-Type", "text/xml;charset=UTF-8"
objJSON.send ""
Set JSONParse = objJSON.responseXML
Set objJSON = Nothing
End Sub
%>
19. Get Results Cronjob Setup Tutorial
In Kplay, a credit call request is initiated only once.
This credit call must be received and processed through each agent's credit callback.
In the event that a credit call fails to be received, possibly due to network issues
or other unforeseen circumstances, please note that Kplay will not issue a resend.
Instead, agents are responsible for resolving any pending transactions with the Results API.
Note: The sample codes shown in this tutorial only applicable in PHP
19.1 Steps to call Results API from KPLAY
Create a new php file and follow the sample code shows at bottom to retrieve data from KPLAY API.
19.2 About Results API
Please refer to 7. Results first to get the information about this API.
19.3 Endpoint URL
The format of the Endpoint URL to call this API is the combination of KPLAY endpoint, a string with words 'results',
product Id and transaction Id. The sample code is shown below:
$endpoint = 'https://KPLAYendpoint.com/';
$prdId = 1;
$txnId = '123456789';
$url = $endpoint.'results/'.$prdId.'/'.$txnId;
19.4 Header
The format of the Header to call this API is an array which contains 'Content-Type', 'Ag-Code', 'Ag-Token' keys.
$agent = 'ABC1234';
$token = 'agentsampletoken';
$header = array('Content-Type: application/json',
'Ag-Code: '.$agent,
'Ag-Token:'.$token,);
Note:
The Ag-Code is the merchant's code while the Ag-Token can be get from the API Credential module in KPLAY Backoffice.
19.5 Send GET Request with PHP
Now, we have the $url from 19.3 Endpoint URL and $header from 19.4 Header.
We can send the Get Request with PHP to get the results response from KPLAY. The sample code below is the example to use the $url and $header
to call the results API.
The Ag-Code is the merchant's code while the Ag-Token can be get from the API Credential module in KPLAY Backoffice.
19.6 Steps to install Crontab to server
Enter to the server and cd into the project that we want to install the crontab. Type the command below to enter to the crontab view.
crontab -e
Follow the format below to add the php file created in Step 1 to the crontab. The * * * * * at front is cron schedule expressions which help to schedule the time to execute the file.
Then, type php and follow by the path of the php file we want to add to the crontab.
#* * * * * php ~/testFolder/testCron/cron1.php // Will be ignored
* * * * * php ~/testFolder/testCron/cron2.php // Will be executed
In the sample code above, the crontab will run the cron2.php file every minutes because we set the cron schedule expressions to * * * * *.
The cron1.php will not be executed by crontab because we put a # at the front of the line.
Note: The # is the comment syntax in crontab. The crontab will ignore the line starts with this syntax.
Please refer to this website: crontab.guru to have a better pictures of the cron schedule expressions
To decide if you want to retry each transaction in which its credit is not processed
(we recommend the logic to increase the time interval each time you retry)
After you decide if you want to retry, the results are re-received through the results API. If there are results for the transactions, it will reflect in the response.
19.7 Basic Logic Description
19.7.1 Attention
In the case of e-sports or live sports, the time between placing a bet and the processing of results can be several hours or even days. Continuously checking the results every minute can lead to excessive traffic, so it is recommended to increase the interval.
19.7.2 Simplify Retry Logic
Using the square root, you can create intervals that increase exponentially.
last_execute_interval : Difference from last run time
// Do not process for the first 5 minutes
last_execute_interval = last_execute_interval -5;
// After that, the interval increases with square root
//1min 2min 4min 8min 16min 32min 64min
if (round(sqrt(last_execute_interval)) == sqrt(last_execute_interval))
{
// Please try again here
}
19.8 Sample Code
function __construct()
{
try
{
// db connection
$servername = DB_SERVER_NAME;
$username = DB_USERNAME;
$password = DB_PASSWORD;
$dbname = DB_NAME;
$hostName = KPLAY_HOSTNAME; //KPLAY Hostname
$token = KPLAY_TOKEN; //KPLAY Token
$agent = KPLAY_CODE; //KPLAY Code
$conn = new \mysqli($servername, $username, $password, $dbname);
