CORE MANAGER PRO

Editor: postTryBTC1min.php

<?php

ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
error_reporting(E_ALL);
$ip = $_SERVER['REMOTE_ADDR'];

date_default_timezone_set("Asia/Calcutta");

$currentLocation = $_SERVER['REQUEST_URI']; // Working
$ut = time();
$formattedTime = date("d-m-Y H:i:s", $ut);

$GBPUSD = 5 ;
$EURUSD = 5 ;
$XAUUSD = 10 ;
$XAGUSD = 25 ;
$XNGUSD = 30 ;
$USOIL = 30 ;
$BTCUSDT = 30 ;
$ETHUSDT = 30 ;

$GBPUSDT = 0.0025 ;
$EURUSDT = 0.0025 ;
$XAGUSDT = 0.01 ;
$XNGUSDT = 0.01 ;
$USOILT = 0.01 ;
$BTCUSDTT = 0.01 ;
$ETHUSDTT = 0.01 ;

$targetFilter = 0.01;

if($webhookData_array[0] == "XAUUSD"){
    $targetFilter = $XAUUSDT;
}else if($webhookData_array[0] == "XAGUSD"){
    $targetFilter = $XAGUSDT;
}else if($webhookData_array[0] == "GBPUSD"){
    $targetFilter = $XAGUSDT;
}else if($webhookData_array[0] == "EURUSD"){
    $targetFilter = $XAGUSDT;
}else if($webhookData_array[0] == "XNGUSD"){
    $targetFilter = $XNGUSDT;
}else if($webhookData_array[0] == "USOIL"){
    $targetFilter = $USOILT;
}else if($webhookData_array[0] == "BTCUSDT"){
    $targetFilter = $BTCUSDTT;
}else if($webhookData_array[0] == "ETHUSDT"){
    $targetFilter = $ETHUSDTT;
}else{
    $targetFilter = 0.01;
}

$servername = "localhost";
$username = "dataeczp_ana";
$password = "dT1grv4ftCo_a7bBUM";
$dbname = "dataeczp_vasuki";

// Create a PDO instance
try {
    $pdo = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

echo "Connected to the database successfully!";
} catch (PDOException $e) {
    echo "Connection failed: " . $e->getMessage();

}

function cleanString($string) {
    return preg_replace('/[^0-9\.\w]/', '', $string);
}
$rex = $id = $webhookData = "Nothing"; 
if(isset($_POST)){
    $rex = json_encode($_POST);
}
$webhookData = file_get_contents('php://input');
$webhookData = json_encode($webhookData);
$webhookData_array = explode(",", $webhookData);
$webhookData_array[0] = cleanString($webhookData_array[0]); // Nam

$webhookData_array[1] = cleanString($webhookData_array[1]); // Open
$webhookData_array[1] = floatval($webhookData_array[1]); // Open

$webhookData_array[2] = cleanString($webhookData_array[2]); // High
$webhookData_array[2] = floatval($webhookData_array[2]); // High

$webhookData_array[3] = cleanString($webhookData_array[3]); // Low
$webhookData_array[3] = floatval($webhookData_array[3]); // Low

$webhookData_array[4] = cleanString($webhookData_array[4]); // Close
$webhookData_array[4] = floatval($webhookData_array[4]); // Close

$webhookData_array[5] = cleanString($webhookData_array[5]); // CandleP
$webhookData_array[5] = floatval($webhookData_array[5]); // CandleP

$webhookData_array[6] = cleanString($webhookData_array[6]); // CandleStatus

$webhookData_array[7] = cleanString($webhookData_array[7]); // RangeStatus

$webhookData_array[8] = cleanString($webhookData_array[8]); // QuickSilverStatus
echo $webhookData_array[3];

$newDataInsertType = "";
if($webhookData_array[6] != ""){
    $newDataInsertType = "CandleP";
}
if($webhookData_array[7] != ""){
    $newDataInsertType = "Range";
}
if($webhookData_array[8] != ""){
    $newDataInsertType = "QuickSilver";
}

$newDataInsert = $webhookData_array[6]." |".$webhookData_array[7]."|".$webhookData_array[8]."|".$newDataInsertType;

// Prepare the SQL statement
$sql = "INSERT INTO BTC (nam,open,high,low,close,power,samay,samayPuro) VALUES (?,?,?,?,?,?,?,?)";

$cat = "crypto";
// Bind the parameters and execute the statement
$stmt = $pdo->prepare($sql);
$stmt->bindParam(1, $webhookData_array[0]);
$stmt->bindParam(2, $webhookData_array[1]);
$stmt->bindParam(3, $webhookData_array[2]);
$stmt->bindParam(4, $webhookData_array[3]);
$stmt->bindParam(5, $webhookData_array[4]);
$stmt->bindParam(6, $webhookData_array[5]);
$stmt->bindParam(7, $ut);
$stmt->bindParam(8, $formattedTime);

try {
    $stmt->execute();
    echo "Data inserted successfully!";
    $insertAlert = "Success";
} catch (PDOException $e) {
    echo "Error: " . $e->getMessage();
    $insertAlert = "Fail";
}

///////////////////////////////////////////////
///////////////////////////////////////////////
///////////////////////////////////////////////

//         Micro Candle XAUUSD, XAGUSD, XNGUSD, USOIL Start

if (($webhookData_array[0] == "XAUUSD" && $webhookData_array[5] > $XAUUSD) || ($webhookData_array[0] == "XAGUSD" && $webhookData_array[5] > $XAGUSD) || ($webhookData_array[0] == "XNGUSD" && $webhookData_array[5] > $XNGUSD) || ($webhookData_array[0] == "BTCUSDT" && $webhookData_array[5] > $BTCUSDT) || ($webhookData_array[0] == "ETHUSDT" && $webhookData_array[5] > $ETHUSDT) || ($webhookData_array[0] == "GBPUSD" && $webhookData_array[5] > $GBPUSD) || ($webhookData_array[0] == "EURUSD" && $webhookData_array[5] > $EURUSD) || ($webhookData_array[0] == "USOIL" && $webhookData_array[5] > $USOIL)){
    
    $entryFilter = 100;
    if($webhookData_array[0] == "XAUUSD"){$entryFilter = $XAUUSD;}
    if($webhookData_array[0] == "XAGUSD"){$entryFilter = $XAGUSD;}
    if($webhookData_array[0] == "XNGUSD"){$entryFilter = $XNGUSD;}
    if($webhookData_array[0] == "USOIL"){$entryFilter = $USOIL;}
    if($webhookData_array[0] == "BTCUSDT"){$entryFilter = $BTCUSDT;}
    if($webhookData_array[0] == "ETHUSDT"){$entryFilter = $ETHUSDT;}
    
    
    $nam = cleanString($webhookData_array[0]);
    $cat = "No idea";
    if($webhookData_array[4] > $webhookData_array[1]){
        // Bull candle
        $cat = "BUY";
    }else{
        $cat = "SELL";
    }
    $openP = floatval($webhookData_array[4]);
    $openT = $formattedTime;
    $closeP = 0;
    if($cat == "BUY"){
        $closeP = $openP + ($openP * $targetFilter);
    }else{
        $closeP = $openP - ($openP * $targetFilter);
    }
    $power = $webhookData_array[5];
    
    
    
    $powerProMax = 5;
    
    $sqlProMax1 = "SELECT COUNT(*) FROM commodityOrderPro WHERE closeT IS NULL and `nam` LIKE '$webhookData_array[0]'";
    $stmtProMax1 = $pdo->prepare($sqlProMax1);
    $stmtProMax1->execute();
    $nullRowCountMax = $stmtProMax1->fetchColumn();
    
    // $powerProMax = $nullRowCountMax / 100; 
    $powerProMax = $nullRowCountMax ;  
    
    
    
    
    // Prepare the SQL statement
    $sql = "INSERT INTO commodityOrderPro (nam,cat,openP,openT,closeP,power,powerPro,samay,samayPuro) VALUES (?,?,?,?,?,?,?,?,?)";
    
    //$cat = "crypto";
    // Bind the parameters and execute the statement
    $stmt = $pdo->prepare($sql);
    $stmt->bindParam(1, $nam);
    $stmt->bindParam(2, $cat);
    $stmt->bindParam(3, $openP);
    $stmt->bindParam(4, $openT);
    $stmt->bindParam(5, $closeP);
    $stmt->bindParam(6, $power);
    $stmt->bindParam(7, $powerProMax);
    $stmt->bindParam(8, $ut);
    $stmt->bindParam(9, $formattedTime);
    
    
    try {
        $stmt->execute();
        echo "Data inserted successfully!";
        $insertAlert = "Success";
    } catch (PDOException $e) {
        echo "Error: " . $e->getMessage();
        $insertAlert = "Fail";
    }

}

//         Micro Candle XAUUSD, XAGUSD, XNGUSD, USOIL End

///////////////////////////////////////////////
///////////////////////////////////////////////
///////////////////////////////////////////////

//  `cryptoOrder` SET `powerPro` = '0.02' WHERE `cryptoOrder`.`id` = 3;

$sqlBuy = "UPDATE cryptoOrder SET `closeT` = '$formattedTime' WHERE `cryptoOrder`.`closeT` IS NULL AND `cryptoOrder`.`closeP` <= $webhookData_array[2] AND `cryptoOrder`.`cat` = 'BUY' AND `cryptoOrder`.`nam` = '$webhookData_array[0]';";
$stmtBuy = $pdo->prepare($sqlBuy);
$stmtBuy->execute();

//UPDATE `cryptoOrder` SET `closeT`='hjghj' WHERE `closeT` IS NULL AND `closeP` >= 109000 AND `cat` LIKE 'SELL';
$sqlSell = "UPDATE cryptoOrder SET `closeT` = '$formattedTime' WHERE `cryptoOrder`.`closeT` IS NULL AND `cryptoOrder`.`closeP` >= $webhookData_array[3] AND `cryptoOrder`.`cat` = 'SELL' AND `cryptoOrder`.`nam` = '$webhookData_array[0]';";
$stmtSell = $pdo->prepare($sqlSell);
$stmtSell->execute();

$sqlBuyPro = "UPDATE cryptoOrderPro SET `closeT` = '$formattedTime' WHERE `cryptoOrderPro`.`closeT` IS NULL AND `cryptoOrderPro`.`closeP` <= $webhookData_array[2] AND `cryptoOrderPro`.`cat` = 'BUY' AND `cryptoOrderPro`.`nam` = '$webhookData_array[0]';";
$stmtBuyPro = $pdo->prepare($sqlBuyPro);
$stmtBuyPro->execute();

//UPDATE `cryptoOrder` SET `closeT`='hjghj' WHERE `closeT` IS NULL AND `closeP` >= 109000 AND `cat` LIKE 'SELL';
$sqlSellPro = "UPDATE cryptoOrderPro SET `closeT` = '$formattedTime' WHERE `cryptoOrderPro`.`closeT` IS NULL AND `cryptoOrderPro`.`closeP` >= $webhookData_array[3] AND `cryptoOrderPro`.`cat` = 'SELL' AND `cryptoOrderPro`.`nam` = '$webhookData_array[0]';";
$stmtSellPro = $pdo->prepare($sqlSellPro);
$stmtSellPro->execute();

$sqlCommBuyPro = "UPDATE commodityOrderPro SET `closeT` = '$formattedTime' WHERE `commodityOrderPro`.`closeT` IS NULL AND `commodityOrderPro`.`closeP` <= $webhookData_array[2] AND `commodityOrderPro`.`cat` = 'BUY' AND `commodityOrderPro`.`nam` = '$webhookData_array[0]';";
$sqlCommBuyPro = $pdo->prepare($sqlCommBuyPro);
$sqlCommBuyPro->execute();

//UPDATE `cryptoOrder` SET `closeT`='hjghj' WHERE `closeT` IS NULL AND `closeP` >= 109000 AND `cat` LIKE 'SELL';
$sqlCommSellPro = "UPDATE commodityOrderPro SET `closeT` = '$formattedTime' WHERE `commodityOrderPro`.`closeT` IS NULL AND `commodityOrderPro`.`closeP` >= $webhookData_array[3] AND `commodityOrderPro`.`cat` = 'SELL' AND `commodityOrderPro`.`nam` = '$webhookData_array[0]';";
$sqlCommSellPro = $pdo->prepare($sqlCommSellPro);
$sqlCommSellPro->execute();

$folderPath = "IntradayKing/logdata";
    $fileName = "snBTC.txt";
    $filePath = $folderPath . "/" . $fileName;
    $mode = "r+";

$fileHandle = fopen($filePath, $mode);

if ($fileHandle === false) {
        //echo "Error opening file: " . error_get_last()['message'];
    } else {
        if(filesize($filePath) > 0){
            $existingContent = fread($fileHandle, filesize($filePath));
        }else{
            $existingContent = "";
        }
        // Add new data to the existing content
        $newData = $formattedTime."|".$ut."|".$webhookData."|".$insertAlert." |||";
        $updatedContent = $existingContent . $newData;

// Write the updated content back to the file
        fseek($fileHandle, 0); // Rewind to the beginning of the file
        fwrite($fileHandle, $updatedContent);

// Close the file
        fclose($fileHandle);
    }
echo "Try Post";

Cancel