金の生る樹

プログラム・ソースの先頭に必ず、御自身のKEYを設定した共通関数を組み込んでください。

#共通処理
Function Get-Header($Query){...}    ☜  共通関数を組み込んで下さい。

#
#        *** 収支報告をする樹 ***
#
function Convert-UnixTimeToDateTime($unixTimestamp){
 # $origin = New-Object -Type DateTime -ArgumentList 1970, 1, 1, 0, 0, 0, 0
 # $origin.AddSeconds($unixTime)

#  $unixTimestamp = <unix timestampの値></p>
    $utcDate = ([DateTime]::Parse("1970/01/01 00:00:00")).addSeconds($unixTimestamp);
    $localDate = [TimeZoneInfo]::ConvertTimeFromUtc($utcDate, [TimezoneInfo]::Local);
    return $localDate
}

#残高情報（軽量）の取得
Function get_info2(){
    $Url = "https://api.zaif.jp/tapi"
    $Nonce = ([System.DateTime]::UtcNow - (Get-Date("1970, 1, 1"))).TotalSeconds
    $Body = New-Object "System.Collections.Generic.Dictionary[[String],[String]]"
    $Body.Add("nonce", "$Nonce")
    $Body.Add("method", "get_info2")
    $Header = Get-Header $Body
    Try{      
        $res = Invoke-RestMethod $Url -Method POST -Headers $Header -Body $Body
        If($res.success -eq 0){
            Write-Host "Oder Error! " $res.error -ForegroundColor Red >> $logfile
            Return "error"
        }Else{
            Return $res
        }
    }Catch{
        Write-Host "Oder Error! " $_.ErrorDetails.Message -ForegroundColor Red >> $logfile
        #Start-Sleep -Milliseconds 5000
        $startdate = (Get-Date).AddSeconds(5)
        Return "error"
    }
}
Function Get-Asset2($AssetName){
    $res = get_info2
    If($AssetName -eq "deposit"){
        Return $res.return.deposit
    }ElseIf($AssetName -eq "jpy"){
        $Asset = $res.return.funds.($AssetName)
        Return $Asset.ToString("#,0")
    }Else{
        $Asset = $res.return.funds.($AssetName)
        Return $Asset.ToString("#,0.00000000")
    }
}

#ユーザー自身の取引履歴を取得
Function trade_history($pair){
    $Url = "https://api.zaif.jp/tapi"
    $Nonce = ([System.DateTime]::UtcNow - (Get-Date("1970, 1, 1"))).TotalSeconds
    $Body = New-Object "System.Collections.Generic.Dictionary[[String],[String]]"
    $Body.Add("nonce", "$Nonce")
    $Body.Add("method", "trade_history")  
    $Body.Add("count", 500)  
    $Body.Add("currency_pair", $pair)  
    $Header = Get-Header $Body    
    Try{      
        $res = Invoke-RestMethod $Url -Method POST -Headers $Header -Body $Body
        If($res.success -eq 0){
            Write-Host "Oder Error! " $res.error -ForegroundColor Red
            Return "error"
        }Else{
            Return $res
        }
    }Catch{
        Write-Host "Oder Error! " $_.ErrorDetails.Message -ForegroundColor Red
        Return "error"
    }
}
Function own_history($pair){
    $res = trade_history $pair 
    Return $res.return
}
#取引き履歴チェック

Function trade-check($pair,$base_date){
    Switch ($pair) {
        "btc_jpy"  { $asset = "btc";  [float]$unit = 0.0001; $column = "<#,0"};    <# 売却時 #>
        "xym_jpy"  { $asset = "XYM";  [float]$unit = 0.1;    $column = "<#,0.0000"};
        "xem_jpy"  { $asset = "xem";  [float]$unit = 0.1;    $column = "<#,0.0000"};
        "cicc_jpy" { $asset = "CICC"; [float]$unit = 0.1;    $column = "<#,0.0000"} ;
        "zaif_jpy" { $asset = "ZAIF"; [float]$unit = 0.1;    $column = "<#,0.0000"} ;
        "mona_jpy" { $asset = "mona"; [float]$unit = 1;      $column = "<#,0.0000"} ;
    };
<#+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++#>
    $res = Get-Asset2 $asset ;                       <#保有コイン枚数を取得#>
    $stock = [float]$res  ;                        　<##>
#   Write-Host "stock = $stock";

$res = own_history $pair ;    <#ユーザー自身の取引履歴の取得#>
    $Keys2 = $res -split ";";
    $counter = $Keys2.length;
    $coin_count = $stock;
    $table1      = @();

$disp = $Keys2.length;
<#   Write-Host "Keys2.length = $disp";#>

for ($i = 0; $i -le $Keys2.length -1; $i++) {    <# 有効な注文データを抽出する。#>
        <#Write-Host $i;#>
        $cheng = $Keys2[$i];
        $cheng = $cheng -replace " ","";
        $cheng = $cheng -replace "=","";
        $cheng = $cheng -replace "@","";
        $cheng = $cheng -replace "{","";
        $cheng = $cheng -replace "}","";
    <#   Write-Host "$i $cheng" ;#>
        $objPs = New-Object PSCustomObject;
    <#   $objPs | Add-Member -NotePropertyMembers @{No            = $i}#>
    <#   $objPs | Add-Member -NotePropertyMembers @{currency_pair = $res.$cheng.currency_pair}#>
    <#   $objPs | Add-Member -NotePropertyMembers @{action        = $res.$cheng.action}#>
        $objPs | Add-Member -NotePropertyMembers @{amount        = $res.$cheng.amount};
        $objPs | Add-Member -NotePropertyMembers @{price         = $res.$cheng.price};
        $objPs | Add-Member -NotePropertyMembers @{fee           = $res.$cheng.fee};
        $objPs | Add-Member -NotePropertyMembers @{fee_amount    = $res.$cheng.fee_amount};
        $objPs | Add-Member -NotePropertyMembers @{your_action   = $res.$cheng.your_action};
    <#   $objPs | Add-Member -NotePropertyMembers @{bonus         = $res.$cheng.bonus}#>
        $res.$cheng.timestamp = Convert-UnixTimeToDateTime($res.$cheng.timestamp);
        $objPs | Add-Member -NotePropertyMembers @{timestamp     = $res.$cheng.timestamp};
        $objPs | Add-Member -NotePropertyMembers @{comment       = $res.$cheng.comment};

<#   $work_date  = $res.$cheng.timestamp;#>
    <#   $check_date = $work_date.ToString("yyyy-MM-dd");#>

<#   Write-Host "check_date = $check_date : base_date = $base_date  ";#>
        if ($res.$cheng.your_action -eq "ask") {
            $coin_count = $coin_count + $res.$cheng.amount;
        };
        if ($res.$cheng.your_action -eq "bid") {
            $coin_count = $coin_count - $res.$cheng.amount + $res.$cheng.fee_amount;
        };
        $table1 += $objPs;      <#   保有コイン数分の履歴を遡り、注文データを抽出する。#>
    <#   Write-Host "coin_count = $coin_count";#>
    <#   if ($coin_count -le 0.000001) { break }#>
        if ($coin_count -le 0.00001) { break };
    };

<# ---------------------------------------------------------------------------------------#>
    $counter = $table1.length;
 #  Write-Host "table1.length = $counter"; 
    $coin_count = 0;
    $ask_moneys = 0;
    $bid_moneys = 0;
    $fee_moneys = 0;
    $flag = $null;
    $ask_priceL = 0;
    $ask_priceS = 0;
    $table2      = @();

$base_date = $base_date.ToString("yyyy-MM-dd");          <# 報告日付#>
    for ($i = 0; $i -le $table1.length -1; $i++) {           <# 売上を算出する#>
        $work_date = $table1[$i].timestamp;                  <# 取引き日時#>
        $check_date = $work_date.ToString("yyyy-MM-dd");     <# 取引き日付#>

<#   Write-Host "check_date = $check_date : base_date = $base_date  ";#>
        if ($check_date -le $base_date) {
            if (($table1[$i].your_action -eq "ask") -or ($flag -eq "start")) {
                if ($flag -eq $null) {
                    $ask_priceL = $table1[$i].price;
                    $ask_priceS = 0;
                <#   Write-Host "ask_priceS = $ask_priceS ask_priceL = $ask_priceL";#>
                };
                $flag = "start";
                if (($table1[$i].your_action -eq "ask") -and ($check_date -eq $base_date)) {
                                                <# 報告日の売り上げを抽出する。#>
                    $table2 += $table1[$i];
                    $coin_count = $coin_count + $table1[$i].amount;
               <#   $ask_moneys = $ask_moneys - $table1[$i].amount * $table1[$i].price - $table1[$i].fee;#>
                    $ask_moneys = $ask_moneys + $table1[$i].amount * $table1[$i].price;    <# 売上累計#>
                    $fee_moneys = $fee_moneys + $table1[$i].fee_amount;                    <# 手数料累計#>
                }else{
                    $table2 += $table1[$i] ;    <# 報告日の最初のask以前(過去)の注文を抽出する。#>
                };
            }else{
            <#   報告日、最初のask前のbidは不要#>
            };
        }else{
        <#   報告日より未来日は不要#>
        };
    };
<#   Write-Host "coin_count = $coin_count : ask_moneys = $ask_moneys : fee_moneys = $fee_moneys  ";#>

$table3 = @();       <#  仕入コイン注文テーブル#>
    $counter2 = 0;
    $coins  = 0;

$counter = $table2.length;
<#   Write-Host "trade-check 集計対象注文件数 = $counter";#>
<#   Write-Host "loop start ask_priceS = $ask_priceS ask_priceL = $ask_priceL";#>

for ($j = 0; $j -le $table2.length - 1; $j++) {
        switch ($table2[$j].your_action) {
            "ask" {        <# 最初は必ず "ask"#>
            #   Write-Host "ask_priceL = $ask_priceL"; 
                $work_date = $table2[$j].timestamp;                  <# 取引き日時#>
                $check_date = $work_date.ToString("yyyy-MM-dd");     <# 取引き日付#>

#   Write-Host "check_date = $check_date : base_date = $base_date  ";　
                if ($check_date -ne $base_date) {     #  集計日の"ask"は条件としない
                    if ($table2[$j].price -ge $ask_priceL) {
                        $ask_priceL = $table2[$j].price;
                    }elseif ($table2[$j].price -gt $ask_priceL) {
                        $flag = "break";
                    }elseif ($table2[$j].price -ge $ask_priceS) {
                        $work_date = $table1[$j].timestamp;                  <# 取引き日時#>
                        $check_date = $work_date.ToString("yyyy-MM-dd");     <# 取引き日付#>
                        if ($check_date -ne $base_date) {
                            $ask_priceS = $table2[$j].price ;
                        };
                    };
            #       Write-Host "ask_priceS = $ask_priceS   ask_priceL = $ask_priceL"; 
                }
            };
            "bid" {
            #   Write-Host "           ask_priceS = $ask_priceS ask_priceL = $ask_priceL"; 
                $limit_line = $table2[$j].price * $table2[$j].amount / ($table2[$j].amount * 0.999) * 1.001;
                <# limit_line  売ってはいけない限界価格#>
            #   Write-Host "           limit_line = $limit_line "; 
                if (($ask_priceS -lt $limit_line) -and ($limit_line -lt $ask_priceL)) {
                #  
                    $coins  = $coins  + $table2[$j].amount - $table2[$j].fee_amount;
                #   Write-Host "$j coins = $coins : coin_count = $coin_count"; 
                    if ($coins -ge $coin_count) {     <#  売却コイン数の仕入れ数#>
                        $flag = "break";
                        $coins = $coins - $table2[$j].amount + $table2[$j].fee_amount;
                        $loss = $coin_count - $coins
                    #   Write-Host "loss = $loss : coins = $coins : coin_count = $coin_count";
                        $bid_moneys = $bid_moneys + $loss * $table2[$j].price;                   <# 補正累計#>
                    }else{
                        $bid_moneys = $bid_moneys + $table2[$j].amount     * $table2[$j].price;  <# 仕入累計#>
                        $fee_moneys = $fee_moneys + $table2[$j].fee_amount * $table2[$j].price ; <# 手数料累計#>
                    #   $amount = $table2[$j].amount * $table2[$j].price;
                    #   $fee_amount = $table2[$j].fee_amount * $table2[$j].price;
                   <#   Write-Host "$j amount = $amount : fee_amount = $fee_amount";#>
                        $table3 += $table2[$j];        <# 仕入注文収集#>
                    };
                # 
                };
            };
        };
        if ($flag -eq "break") { break };     <#  forループからの脱出#>
    };

<#   Write-Host "coins = $coins";#>
<#   Write-Host "ask_moneys = $ask_moneys  and  bid_moneys = $bid_moneys  and  fee_moneys = $fee_moneys";#>

$objPs = New-Object PSCustomObject;
    $objPs | Add-Member -NotePropertyMembers @{table       = $table3};        <# テーブル#>
    $objPs | Add-Member -NotePropertyMembers @{date        = $base_date};     <# 収支日付#>
    $objPs | Add-Member -NotePropertyMembers @{ask_moneys  = $ask_moneys};    <# 売却金額#>
    $objPs | Add-Member -NotePropertyMembers @{bid_moneys  = $bid_moneys};    <# 仕入金額#>
    $objPs | Add-Member -NotePropertyMembers @{fee_moneys  = $fee_moneys};    <# 手数料#>
    $objPs | Add-Member -NotePropertyMembers @{coins       = $coins};         <# 仕入枚数#>
    $objPs | Add-Member -NotePropertyMembers @{coin_count  = $coin_count};    <# 売却枚数#>

return $objPs;
};

Function trade-report($pair,$now){
    echo "収支報告 開始"

Switch ($pair) {
        "btc_jpy"  { $asset = "btc";  [float]$unit = 0.0001; $column = "#,0"}
        "xym_jpy"  { $asset = "XYM";  [float]$unit = 0.1;    $column = "#,0.0000"}
        "xem_jpy"  { $asset = "xem";  [float]$unit = 0.1;    $column = "#,0.0000"}
        "cicc_jpy" { $asset = "CICC"; [float]$unit = 0.1;    $column = "#,0.0000"} 
        "zaif_jpy" { $asset = "ZAIF"; [float]$unit = 0.1;    $column = "#,0.0000"} 
        "mona_jpy" { $asset = "mona"; [float]$unit = 1;      $column = "#,0.0000"} 
    }

$coin = 0               # 保有コイン数
    $money = 0              # 購入金額
    $table = @()

$base_date = (Get-Date).adddays($now)

$res = trade-check $pair $base_date
    
    $table       = $res.table       # 
    $report_day  = $res.date          # 売却金額
    $ask_moneys  = $res.ask_moneys    # 売却金額
    $bid_moneys  = $res.bid_moneys    # 仕入金額
    $fee_moneys  = $res.fee_moneys    # 手数料
    $coins       = $res.coins         # 仕入枚数
    $coin_count  = $res.coin_count    # 売却枚数

if ($ask_moneys -eq 0) {
        echo "$base_date　本日、取引きが有りませんでした。"
    }else{
        $bid_count = $table.length
        Write-Host "仕入リスト  $bid_count 件"
        $table | Sort-Object -property timestamp  | Ft * -AutoSize
    #   $table | Ft * -AutoSize

Write-Host "収支日付  = $report_day"    # 売却金額
        Write-Host "売上金額  = $ask_moneys"    # 売却金額
        Write-Host "仕入金額  = $bid_moneys"    # 仕入金額
        Write-Host "手数料    = $fee_moneys"    # 手数料
        Write-Host "仕入枚数  = $coins"         # 仕入枚数
        Write-Host "売却枚数  = $coin_count"    # 売却枚数
        $ask_bid = $ask_moneys - $bid_moneys - $fee_moneys
        echo "利益($ask_bid) = 売上($ask_moneys) - 仕入($bid_moneys) - 手数料($fee_moneys)"
    }
    [float]$Asset2 = Get-Asset2 $Asset     #残高を取得
    $display = $Asset2.Tostring("#,#0.######") + "枚"
    Write-Host "在庫枚数 = $display"
}

cls     # 収支報告
#Function trade-report($pair     ,$When )
          trade-report "btc_jpy"  -1

実行結果です。

プログラム・ソースは画面左上のファイル(F)をクリックし、任意の名前を付けて保存して下さい。

収支報告する樹

仕様

留意事項

プログラム・ソース