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
    %>
                

 
    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
    %>
                

 
    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
                

 
    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

    %>
                

 
    function getMemberBalance($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'
                                    ];
            }

            $param = json_decode($data);
            $KPLAYId = $param->user_id;

            //check if user is exist
            $selectSQL = "SELECT user_id 
                            FROM users
                            WHERE KPLAY_id = ".$KPLAYId;

            $db = $conn->query($selectSQL);

            if ($db->num_rows > 0) 
            {
                while($row = $db->fetch_assoc()) 
                {
                    $userId = $row['user_id'];
                }
            }
            else
            {
                return $response = [
                                        'status' => 0
                                        ,'error' => 'INVALID_USER'
                                    ];
            }

            //get balance from user balance table
            $selectSQL = "SELECT user_id, balance 
                            FROM users_balance
                            WHERE user_id = ".$userId;

            $db = $conn->query($selectSQL);

            if ($db->num_rows > 0) 
            {
                while($row = $db->fetch_assoc()) 
                {
                    $userId = $row['user_id'];
                    $userBalance = $row['balance'];
                }
            }
            else
            {
                return $response = [
                                        'status' => 0
                                        ,'error' => 'INVALID_USER'
                                    ];
            }

            $response = [
                            'status' => 1
                            ,'balance' => $userBalance
                        ];

            return $response;
        } 
        catch (Exception $e) 
        {
            //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 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
    %>
                

 
    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);

            //if connect to DB failed
            if ($conn->connect_error) 
            {
                return $response = [
                                        'status' => 0
                                        ,'error' => 'UNKNOWN_ERROR'
                                    ];
            }

            $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";

            $db = $conn->query($selectSQL);

            if ($db->num_rows > 0) 
            {
                while($row = $db->fetch_assoc()) 
                {
                    $txnId = $row['txn_id'];
                    $prdId = $row['prd_id'];
                    $userId = $row['user_id'];

                    $method = 'results'; //auth game method

                    $url = $hostName.$method.'/'.$prdId.'/'.$txnId; //auth game endpoint

                    //prepare header
                    $header = [
                                'Content-Type: application/json',
                                'Ag-Code: '.$agent,
                                'Ag-Token:'.$token,
                            ];

                    $data = [];

                    $helper = new Helper;
                    $response = $helper->getData($url,$header);

                    $data = json_decode($response);

                    $status = $data->status;
                    $type = $data->type;

                    if ($status == 1 && $type == 1) 
                    {
                        $gameId = $data->game_id;
                        $stake = $data->stake;
                        $payout = $data->payout;
                        $isCancel = $data->is_cancel;

                        if ($isCancel == 1) 
                        {
                            $betType = 'x';
                            $credit = $stake;
                        }
                        else
                        {
                            $betType = 'c';
                            $credit = $payout;
                        }

                        //Insert credit record to DB
                        $insertSQL = "INSERT INTO credit
                                (txn_id,type,amount)
                                VALUES
                                ('".$txnId."','".$betType."',".$credit.")";

                        $insertDB = $conn->query($insertSQL);

                        // Update user balance
                        $updateSQL = "UPDATE users_balance
                                    SET balance = balance + ".$credit."
                                    WHERE user_id = ".$userId;

                        $updateDB = $conn->query($updateSQL);
                    }
                    else
                    {
                        $error = $data->error;
                        var_dump($error);

                        exit;
                    }
                }
            }
            else
            {
                exit;
            }
        } 
        catch (Exception $e) 
        {
            var_dump($e);
        }
        
    }
                

 
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.util.HashMap;
    import java.util.Map;
    import com.google.gson.JsonObject;
    import com.google.gson.JsonParser;

    public class Results {
        private String dbServerName;
        private String dbUsername;
        private String dbPassword;
        private String dbName;
        private String KPLAYHostname;
        private String KPLAYCode;
        private String KPLAYToken;
        public Results() {
            // 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.assToken = constant.KPLAY_TOKEN;
        }

        public void processResults() {
            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 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";

                // Execute the SQL query
                PreparedStatement stmt = conn.prepareStatement(selectSQL);
                ResultSet resultSet = stmt.executeQuery();

                while (resultSet.next()) {
                    String txnId = resultSet.getString("txn_id");
                    String prdId = resultSet.getString("prd_id");
                    String userId = resultSet.getString("user_id");

                    String method = "results"; // Results retrieval method

                    String url = hostName + method + "/" + prdId + "/" + txnId; // Results retrieval endpoint

                    // Prepare header
                    Map headers = new HashMap<>();
                    headers.put("Content-Type", "application/json");
                    headers.put("Ag-Code", agent);
                    headers.put("Ag-Token", token);

                    String response = Helper.getData(url, headers);

                    JsonParser jsonParser = new JsonParser();
                    JsonObject jo = (JsonObject)jsonParser.parse(response);

                    int status = jo.get("status").getAsInt();
                    int type = jo.get("type").getAsInt();

                    if (status == 1 && type == 1) {
                        double stake = jo.get("stake").getAsDouble();
                        double payout = jo.get("payout").getAsDouble();
                        int isCancel = jo.get("is_cancel").getAsInt();

                        String betType;
                        double credit;

                        if (isCancel == 1) {
                            betType = "x";
                            credit = stake;
                        } else {
                            betType = "c";
                            credit = payout;
                        }

                        // Insert credit record into DB
                        String insertSQL = "INSERT INTO credit (txn_id, type, amount) VALUES (?, ?, ?)";
                        PreparedStatement insertStmt = conn.prepareStatement(insertSQL);
                        insertStmt.setString(1, txnId);
                        insertStmt.setString(2, betType);
                        insertStmt.setDouble(3, credit);
                        insertStmt.executeUpdate();
                        insertStmt.close();

                        // Update user balance
                        String updateSQL = "UPDATE users_balance SET balance = balance + ? WHERE user_id = ?";
                        PreparedStatement updateStmt = conn.prepareStatement(updateSQL);
                        updateStmt.setDouble(1, credit);
                        updateStmt.setString(2, userId);
                        updateStmt.executeUpdate();
                        updateStmt.close();
                    } else {
                        String error = jo.get("error").getAsString();
                        System.out.println(error);
                    }
                }

                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        public static void main(String[] args) {
            Results results = new Results();
            results.processResults();
        }
    }
                

 
    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
    %>
                

 
    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
    %>
                

 
    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);
            $conn->query("SET NAMES 'UTF8'");

            //if connect to DB failed
            if ($conn->connect_error) 
            {
                var_dump("Connection failed: " . $conn->connect_error);
                exit;
            }

            $method = 'productlist'; //auth game method

            $url = $hostName.$method; //auth game endpoint

            //prepare header
            $header = [
                        'Content-Type: application/json',
                        'Ag-Code: '.$agent,
                        'Ag-Token:'.$token,
                    ];
            
            $lang = 'en';
            $data = ['language' => $lang, 'wallet' => 1];

            $helper = new Helper;
            $response = $helper->postData($url,$data,$header);

            $data = json_decode($response);

            $status = $data->status;
            $mainData = $data->data;

            if ($status == 1 && !empty($mainData) ) 
            {
                foreach ($mainData as $key => $productInfo) 
                {
                    $prdId = $productInfo->prd_id;
                    $prdName = $productInfo->prd_name;

                    $stmt = $conn->prepare("SELECT prd_id, prd_name_en, prd_name_ko
                               FROM product_list
                               WHERE prd_id = ?
                              ");

                    $stmt->bind_param("i", $prdId);
                    $stmt->execute();

                    $result = $stmt->get_result();
                    $db = $result->fetch_all(MYSQLI_ASSOC);

                    $stmt->close();

                    if (sizeof($db) == 0) 
                    {
                        if ($lang == 'en') 
                        {
                            $insertEn = "INSERT INTO product_list(prd_id, prd_name_en)
                                    VALUES(".$prdId .",'".$prdName."'')";


                            $db = $conn->query($insertEn);
                            // $sql = "INSERT INTO product_list(prd_id, prd_name_en)
                            //         VALUES(?, ?)";
                        }
                        else
                        {
                            $insertKo = "INSERT INTO product_list(prd_id, prd_name_ko)
                                    VALUES(".$prdId .",'".$prdName."')";

                            $db = $conn->query($insertKo);
                            // $sql = "INSERT INTO product_list(prd_id, prd_name_ko)
                            //         VALUES(?, ?)";
                        }
                        
                        // $stmt = $conn->prepare($sql);
                        // $stmt->bind_param("is", $prdId, $prdName);
                        // $stmt->execute();
                        // $stmt->close();
                    } 
                    else 
                    {
                        if ($lang == 'en') 
                        {
                            $sql = "UPDATE product_list
                                    SET prd_name_en = ?
                                    WHERE prd_id = ?";
                        }
                        else
                        {
                            $sql = "UPDATE product_list
                                    SET prd_name_ko = ?
                                    WHERE prd_id = ?";
                        }

                        $stmt = $conn->prepare($sql);
                        $stmt->bind_param("si", $prdName, $prdId);

                        $stmt->execute();
                        $stmt->close();
                    }
                }

                var_dump($mainData);
            }
            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.sql.ResultSet;
    import java.util.HashMap;
    import java.util.Map;
    import com.google.gson.JsonObject;
    import com.google.gson.JsonParser;
    import com.google.gson.JsonArray;

    public class ProductList {
        private String dbServerName;
        private String dbUsername;
        private String dbPassword;
        private String dbName;
        private String KPLAYHostname;
        private String KPLAYCode;
        private String KPLAYToken;

        public ProductList() {
            // 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 synchronizeProductList() {
            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 = "productlist";

                // 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("language", "en");
                data.put("wallet", 1);

                String url = hostName + method;

                String response = Helper.postData(url, data, header);

                // Parse the response JSON
                JsonParser jsonParser = new JsonParser();
                JsonObject jo = (JsonObject) jsonParser.parse(response);

                if (jo.has("status") && jo.get("status").getAsInt() == 1) {
                    JsonArray mainData = jo.getAsJsonArray("data");

                    for (int i = 0; i < mainData.size(); i++) {
                        JsonObject productInfo = mainData.get(i).getAsJsonObject();
                        int prdId = productInfo.get("prd_id").getAsInt();
                        String prdName = productInfo.get("prd_name").getAsString();

                        String sql = "SELECT prd_id, prd_name_en, prd_name_ko FROM product_list WHERE prd_id = ?";
                        PreparedStatement stmt = conn.prepareStatement(sql);
                        stmt.setInt(1, prdId);

                        ResultSet result = stmt.executeQuery();

                        if (!result.next()) {
                            String insertSql = "INSERT INTO product_list (prd_id, prd_name_en, prd_name_ko) VALUES (?, ?, ?)";
                            PreparedStatement insertStmt = conn.prepareStatement(insertSql);
                            insertStmt.setInt(1, prdId);
                            insertStmt.setString(2, prdName);
                            insertStmt.setString(3, prdName);

                            insertStmt.execute();
                            insertStmt.close();
                        } else {
                            String updateSql = "UPDATE product_list SET prd_name_en = ?, prd_name_ko = ? WHERE prd_id = ?";
                            PreparedStatement updateStmt = conn.prepareStatement(updateSql);
                            updateStmt.setString(1, prdName);
                            updateStmt.setString(2, prdName);
                            updateStmt.setInt(3, prdId);

                            updateStmt.execute();
                            updateStmt.close();
                        }
                    }

                    System.out.println(mainData.toString());
                } else if (jo.has("status") && jo.get("status").getAsInt() == 0) {
                    String error = jo.get("error").getAsString();
                    System.out.println(error);
                } else {
                    System.out.println("call_api_error");
                }

                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 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()
    %>                    
                

 
    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 = '/gamelist';

            $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);

            if (!empty($data) && array_key_exists('game_list', $data)) 
            {
                if ($data->status == 1) 
                {
                    $gameList = (array) $data->game_list;

                    foreach ($gameList as $prdId => $gameInfo) 
                    {
                        foreach ($gameInfo as $info) 
                        {
                            $gameId = $info->game_id;
                            $gameName = $info->game_name;
                            $isEnabled = $info->game_status;

                            $stmt = $conn->prepare("SELECT prd_id, game_id, game_name_en, game_name_ko
                               FROM game_list
                               WHERE prd_id = ?
                               AND game_id = ?
                              ");

                            $stmt->bind_param("ii", $prdId, $gameId);
                            $stmt->execute();

                            $result = $stmt->get_result();
                            $db = $result->fetch_all(MYSQLI_ASSOC);

                            $stmt->close();

                            if (sizeof($db) == 0) 
                            {
                                $sql = "INSERT INTO game_list(prd_id, game_id, game_name_en, is_enabled)
                                        VALUES(?, ?, ?, ?)";

                                $stmt = $conn->prepare($sql);
                                $stmt->bind_param("iisi", $prdId, $gameId, $gameName, $isEnabled);
                                $stmt->execute();
                                $stmt->close();
                            } 
                            else 
                            {
                                $dbGameNameEn = $db[0]['game_name_en'];
                                $dbGameNameKr = $db[0]['game_name_ko'];

                                if ($dbGameNameKr == null || $dbGameNameEn == null || $dbGameNameKr == 'N/A' || $dbGameNameEn == 'N/A') 
                                {
                                    $sql = "UPDATE KPLAY_game_list
                                    SET prd_id = ?
                                        ,game_id = ?
                                        ,game_name_en = ?
                                        ,is_enabled = ?
                                        ,updated_at = ?
                                    WHERE prd_id = ?
                                    AND game_id = ?";

                                    $stmt = $conn->prepare($sql);
                                    $stmt->bind_param("iisisii", $prdId, $gameId, $gameName, $isEnabled, $updatedAt, $prdId, $gameId);

                                    $updatedAt = date("Y-m-d H:i:s"); // Set the updated_at value
                                    $stmt->execute();
                                    $stmt->close();
                                }
                            }
                        }
                    }
                }
            }
            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.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
    %>  
                

 
    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
    %>
                

 
    function __construct()
    {
        $this->servername = DB_SERVER_NAME;
        $this->username = DB_USERNAME;
        $this->password = DB_PASSWORD;
        $this->dbname = DB_NAME;

        $this->hostName = KPLAY_HOSTNAME; //Hostname
        $this->token = KPLAY_TOKEN; //AG Token
        $this->agent = KPLAY_CODE; //AG Code

        //prepare header
        $this->header = [
                            'Content-Type: application/json',
                            'Ag-Code: '.KPLAY_CODE,
                            'Ag-Token:'.KPLAY_TOKEN,
                        ];
    }

    public function getPushBet($prdId, $txnId)
    {
        try
        {
            $method = 'getpushbets'; //auth game method

            $url = $this->hostName.$method;

            //prepare data
            $data = [
                        'prd_id' => $prdId,
                        'txn_id' => $txnId
                    ];

            $helper = new Helper;
            $response = $helper->postData($url,$data,$this->header);

            $data = json_decode($response);

            if ($data->status == 1 && !empty($data->data)) 
            {
                $conn = new \mysqli($this->servername, $this->username, $this->password, $this->dbname);
                $conn->query("SET NAMES 'UTF8'");
                
                //if connect to DB failed
                if ($conn->connect_error) 
                {
                    var_dump("Connection failed: " . $conn->connect_error);
                    exit;
                }

                $txnId = $data->data[0]->txn_id;
                $pushedAmt = $data->data[0]->pushed_amount;
                $pushedAmt1 = $data->data[0]->pushed_amount1;

                $stmt = $conn->prepare("INSERT INTO pushed_txn
                                        (txn_id, prd_id,pushed_amount,pushed_amount1)
                                        VALUES(?,?,?,?)");

                $prdId = 1;
                $stmt->bind_param("siii", $txnId, $prdId ,$pushedAmt,$pushedAmt1);
                $stmt->execute();

                $stmt->close();
            }

            return $response;
        }
        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.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
    %>
                

 
    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
            }
        }
    }
                

 
    function __construct()
    {
        $this->servername = DB_SERVER_NAME;
        $this->username = DB_USERNAME;
        $this->password = DB_PASSWORD;
        $this->dbname = DB_NAME;

        $this->hostName = KPLAY_HOSTNAME; //Hostname
        $this->token = KPLAY_TOKEN; //AG Token
        $this->agent = KPLAY_CODE; //AG Code

        //prepare header
        $this->header = [
                            'Content-Type: application/json',
                            'Ag-Code: '.KPLAY_CODE,
                            'Ag-Token:'.KPLAY_TOKEN,
                        ];
    }

    public function betDetails($prdId, $txnId)
    {
        try
        {
            $method = 'betresults'; //auth game method

            $url = $this->hostName.$method;

            $language = 'en';

            //prepare data
            $data = [
                        'lang' => $language,
                        'prd_id' => $prdId,
                        'txn_id' => $txnId
                    ];

            $helper = new Helper;
            $response = $helper->postData($url,$data,$this->header);

            return $response;
        }
        catch(\Exception $e)
        {
            return '';
        }
    }
                

 
    import java.util.HashMap;
    import java.util.Map;

    public class BetDetail {
        private String KPLAYHostname;
        private String KPLAYCode;
        private String KPLAYToken;

        public BetDetail() {
            // Get constants from constant.java (KPLAY Hostname, KPLAY Code, KPLAY Token)
            this.KPLAYHostname = constant.KPLAY_HOSTNAME;
            this.KPLAYCode = constant.KPLAY_CODE;
            this.KPLAYToken = constant.KPLAY_TOKEN;
        }

        public String getBetDetails(String prdId, String txnId) {
            try {
                String method = "betresults"; // Bet details method
                String url = this.KPLAYHostname + method;
                String language = "en";

                // Prepare headers
                Map headers = new HashMap<>();
                headers.put("Content-Type", "application/json");
                headers.put("Ag-Code", this.KPLAYCode);
                headers.put("Ag-Token", this.KPLAYToken);

                // Prepare data
                Map data = new HashMap<>();
                data.put("lang", language);
                data.put("prd_id", prdId);
                data.put("txn_id", txnId);

                String response = Helper.postData(url, data, headers);

                return response;
            } catch (Exception e) {
                e.printStackTrace();
                return "";
            }
        }
    }
                

 
    using System;
    using System.Net.Http;
    using System.Text;
    using System.Threading.Tasks;
    
    public class BetDetail
    {
        private string serverName;
        private string userName;
        private string password;
        private string dbName;
        private string hostName;
        private string token;
        private string agent;
        private string[] header;
    
        public BetDetail()
        {
            serverName = Constants.DB_SERVER_NAME;
            userName = Constants.DB_USERNAME;
            password = Constants.DB_PASSWORD;
            dbName = Constants.DB_NAME;
    
            hostName = Constants.KPLAY_HOSTNAME;
            token = Constants.KPLAY_TOKEN;
            agent = Constants.KPLAY_CODE;
    
            header = new string[]
            {
                "Content-Type: application/json",
                "Ag-Code: " + Constants.KPLAY_CODE,
                "Ag-Token: " + Constants.KPLAY_TOKEN
            };
        }
    
        public async Task BetDetails(int prdId, int txnId)
        {
            try
            {
                string method = "betresults";
                string url = hostName + method;
                string language = "en";
    
                var data = new
                {
                    lang = language,
                    prd_id = prdId,
                    txn_id = txnId
                };
    
                using (var httpClient = new HttpClient())
                {
                    foreach (var headerItem in header)
                    {
                        httpClient.DefaultRequestHeaders.Add(headerItem.Split(':')[0], headerItem.Split(':')[1].Trim());
                    }
    
                    var json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
                    var content = new StringContent(json, Encoding.UTF8, "application/json");
    
                    var response = await httpClient.PostAsync(url, content);
                    string responseContent = await response.Content.ReadAsStringAsync();
    
                    return responseContent;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e);
                return string.Empty;
            }
        }
    }                    
                

 
    <%
    Sub betDetails(prdId, txnId)
        ' Define API parameters
        Dim hostName, method, url, data, header, ch, language, responseKPLAY
        hostName = KPLAY_HOSTNAME ' Hostname
        method = "betresults" ' Auth game method
        url = hostName & method

        language = "en"

        ' Prepare data
        Set data = Server.CreateObject("Scripting.Dictionary")
        data.Add "lang", language
        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
            responseKPLAY = xmlhttp.responseText
            betDetails = responseKPLAY
        Else
            ' HTTP request failed
            betDetails = "HTTP request failed"
        End If

        ' Clean up objects
        Set xmlhttp = 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
    %>
                

 
    function __construct()
    {
        $this->servername = DB_SERVER_NAME;
        $this->username = DB_USERNAME;
        $this->password = DB_PASSWORD;
        $this->dbname = DB_NAME;

        $this->hostName = KPLAY_HOSTNAME; //Hostname
        $this->token = KPLAY_TOKEN; //AG Token
        $this->agent = KPLAY_CODE; //AG Code

        //prepare header
        $this->header = [
                            'Content-Type: application/json',
                            'Ag-Code: '.KPLAY_CODE,
                            'Ag-Token:'.KPLAY_TOKEN,
                        ];
    }

    public function remainingDeposit()
    {
        try
        {
            $method = 'remainingdeposit'; //auth game method

            $url = $this->hostName.$method;

            //post header&data via helper curl
            $helper = new Helper;
            $response = $helper->getData($url,$this->header);
            $data = json_decode($response);

            if ($data->status == 1) 
            {
                $given = $data->given_deposit;
                $available = $data->available_deposit;
                $status = $data->status;

                $insertDeposit = "INSERT INTO remaining_deposit
                                (ag_code, given_deposit,available_deposit)
                                VALUES('".$this->agent."',".$given .",".$available.")
                                ON DUPLICATE KEY UPDATE given_deposit = ".$given.",
                                available_deposit = ".$available;

                $conn = new \mysqli($this->servername, $this->username, $this->password, $this->dbname);

                //if connect to DB failed
                if ($conn->connect_error) 
                {
                    var_dump("Connection failed: " . $conn->connect_error);
                    exit;
                }

                $db = $conn->query($insertDeposit);
            }
            
            return $response;
        }
        catch(\Exception $e)
        {
            return '';
        }
    }
                

 
    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
    %>
                

 
    function __construct()
    {
        try
        {
            $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
            $header = [
                        'Content-Type: application/json',
                        'Ag-Code: '.KPLAY_CODE,
                        'Ag-Token:'.KPLAY_TOKEN,
                      ];
        
            $method = 'getgametable'; //auth game method

            $url = $hostName.$method;

            //post header&data via helper curl
            $helper = new Helper;
            $response = $helper->getData($url,$header);
            $data = json_decode($response);

            if ($data->status == 1 && !empty($data->tables) ) 
            {
                $skinId = $data->tables[0]->skin_id;
                $gameName = $data->tables[0]->game_name;
                $tableId = $data->tables[0]->table_id;

                $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;

                $conn = new \mysqli($servername, $username, $password, $dbname);

                //if connect to DB failed
                if ($conn->connect_error) 
                {
                    var_dump("Connection failed: " . $conn->connect_error);
                    exit;
                }

                $db = $conn->query($insertTableId);
            }

            var_dump($response);
        }
        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;

    public class GetGameTableId {
        private String dbServerName;
        private String dbUsername;
        private String dbPassword;
        private String dbName;
        private String KPLAYHostname;
        private String KPLAYCode;
        private String KPLAYToken;

        public GetGameTableId() {
            // 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 retrieveGameTableId() {
            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 = "getgametable"; // Game table retrieval method

                // Prepare headers
                Map headers = new HashMap<>();
                headers.put("Content-Type", "application/json");
                headers.put("Ag-Code", agent);
                headers.put("Ag-Token", token);

                String url = hostName + method;

                String response = Helper.getData(url, headers);

                // Parse the response JSON
                JsonParser jsonParser = new JsonParser();
                JsonObject data = (JsonObject) jsonParser.parse(response);

                if (data.get("status").getAsInt() == 1 && data.has("tables")) {
                    JsonObject tableInfo = data.getAsJsonArray("tables").get(0).getAsJsonObject();
                    int skinId = tableInfo.get("skin_id").getAsInt();
                    String gameName = tableInfo.get("game_name").getAsString();
                    int tableId = tableInfo.get("table_id").getAsInt();

                    // SQL query to insert or update table information
                    String insertOrUpdateQuery = "INSERT INTO evo_table_id (prd_id, skin_id, table_id, game_name) " +
                            "VALUES (1, ?, ?, ?) " +
                            "ON DUPLICATE KEY UPDATE skin_id = ?, table_id = ?, game_name = ?";

                    PreparedStatement stmt = conn.prepareStatement(insertOrUpdateQuery);
                    stmt.setInt(1, skinId);
                    stmt.setInt(2, tableId);
                    stmt.setString(3, gameName);
                    stmt.setInt(4, skinId);
                    stmt.setInt(5, tableId);
                    stmt.setString(6, gameName);

                    stmt.executeUpdate();
                    stmt.close();
                }

                System.out.println(response);
                conn.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        public static void main(String[] args) {
            GetGameTableId gameTableId = new GetGameTableId();
            gameTableId.retrieveGameTableId();
        }
    }
                

 
    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

    %>
                

 
    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);
            $conn->query("SET NAMES 'UTF8'");

            //if connect to DB failed
            if ($conn->connect_error) 
            {
                var_dump("Connection failed: " . $conn->connect_error);
                exit;
            }

            $method = 'getrake'; // method

            $url = $hostName.$method; // endpoint

            //prepare header
            $header = [
                        'Content-Type: application/json',
                        'Ag-Code: '.$agent,
                        'Ag-Token:'.$token,
                    ];
            
            $startDate = '2023-04-17';
            $endDate = '2023-04-18';
            $data = ['start_date' => $startDate, 'end_date' => $endDate];

            $helper = new Helper;
            $response = $helper->postData($url,$data,$header);

            $data = json_decode($response);

            if ($data->status == 1 && !empty($data->data) ) 
            {
                // do next step
            }

            var_dump($response);
        } 
        catch (Exception $e) 
        {
            var_dump($e);
            exit;
        }
    }
                

 
    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
    %>