古い白人とJavaScriptで遊んで - 買い物をするパートナーを作ること (7) 便利なツール なぜ役に立つのか理解してください!

作者: リン・ハーン小さな夢, 作成日: 2017-03-16 12:29:51, 更新日: 2017-10-11 10:37:54

便利なツールには,なぜ役に立つのかを知る必要があります!

日常で戦略を書くのは楽しいことですが,毎日のように空っぽのアイデアがエディタに飛び出します. この情熱に影響する唯一のものは,取引戦略システムにおける買い買いロジックの処理であり,この取引モジュールの処理は確かに重要ですが,少し退屈で,ロジックは比較的複雑です.

  • 簡単に使えるモジュールがあるのは幸いです (前回の記事で使いましたが) しかし,それを使うだけでなく,その仕組みを理解するために,コードを解説します:

/* Interval 失敗した再試行間隔 (ミリ秒) 数字型 (数) 500 SlideTick スライド価格ポイント数 ((整数) 数字型 ((数) 1) RiskControl 風制御をオン ブール型 ((true/false) false MaxTrade@RiskControl 平日の取引回数 最大数 数字型 ((number) 50 MaxTradeAmount@RiskControl 単筆最大単位の量 数字型 ((number) 1000 */

var __orderCount = 0 // 現行の曜日からの次回数を記録する var __orderDay = 0 // 現在の営業日の日付を記録する

function CanTrade ((tradeAmount) { // リスク管理モジュール,パラメータ:取引数 if (!RiskControl) { // デフォルトでは風力制御モジュールを起動しない.開かない場合,CanTrade関数は true を返します. 返信する {cH00ffff} if (typeof ((tradeAmount) == number && tradeAmount > MaxTradeAmount) { // 輸入パラメータ tradeAmount は数値型で,下單量はテンプレートパラメータで設定された単位の最大量よりも大きい. Log ( #ff0000 @) // 提示を出力,実行を中断. throw キーを中断する 返信は誤りです. {cH00ffff} var nowDay = new Date (().getDate ((); // 現在の日付を取得する if (nowDay!= __orderDay) { // getDate() は,Date オブジェクトから月の某日を (1 ~ 31) 返します. __orderDay = nowDay; // __orderDay グローバル変数は,風力制御モジュールに最初にアクセスしたトリガー日付を記録します. __orderCount = 0; // __orderDay の変数を更新し, __orderCount の変数をリセットする {cH00ffff} __orderCount++; //グローバル変数 __orderCount 次の単数,自己加算. if (__orderCount > MaxTrade) { // パラメータ設定の最大日取引数を上回るか判断する Log ((風制御モジュールの制限,取引不可,最大下位単数を超えた, MaxTrade, #ff0000 @); // 超えた,提示メッセージを出力,実行中断。 throw キーを中断する 返信は誤りです. {cH00ffff} return true; //上記の条件が触発されていないので true を返します. {cH00ffff}

function init ((() { // テンプレートの初期化関数,テンプレートが読み込まれる前に実行される. if (typeof(SlideTick) === undefined) { // SlideTick が定義されていないかどうかをチェックします。 SlideTick = 1; // 設定 デフォルト値は 1 } else { // 解析文字列を数値に変換する.しかし,非数字文字の文字列が NaN を返す場合,エラーが発生する可能性があります. SlideTick = parseInt (スライドティック) {cH00ffff} Log (商品取引類データベースに成功が読み込まれました) {cH00ffff}

function GetPosition ((e, contractType, direction, positions) { // 取引所オブジェクト,契約タイプ,方向,APIが返した保有データ (※空き) のパラメータで,同じ方向の契約の昨日のポジション,現在のポジションを組み合わせる
var allCost = 0; // contractType 方向性での契約 合計費用,一手契約の何点も割っていない ((全体として約定できるため) var allAmount = 0; // 合計契約手数 var allProfit = 0; // 利益と損失の総和 var allFrozen = 0; // 凍結した総数 var pos Margin = 0; // 保有契約 ハーバード if (typeof(positions) === undefined論!positions) { // パラグラムが API に送信されずに戻される保管情報 positions = _C ((e.GetPosition); //は,APIを呼び出し,保管情報を取得する. ありがとうございました. for (var i = 0; i < positions.length; i++) { // この保管情報配列を横切る. if (positions[i].ContractType == contractType && // 現在のインデックスの保有情報の契約コード == パラメータ指定の契約コード ((contractType) と方向は,パラメータが転送される方向 ((direction) と同じ現在のポジションまたは昨日のポジションである. (((positions[i].Type == PD_LONG のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_SHORT のポジション[i].Type == PD_SHORT_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_SHORT のポジション[i].Type == PD_SHORT_YD のポジション[i].Type == PD_SHORT_YD のポジション[i].Type == PD_SHORT_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_LONG_YD のポジション[i].Type == PD_SHORT_YD のポジション[i] &&&&&&&&&&&&&&&&&&&&&& ) { // 条件を満たした if ブロックを実行する posMargin = positions[i].MarginLevel; //レバレッジ値を取得する posMarginに値を与える allCost += (positions[i].Price * positions[i].Amount); // 総費用 (約1つの契約の割合,現在のインデックス保有価格 * 保有量) 累計 allAmount += positions[i].Amount; // 契約手数累計 allProfit += positions[i].Profit; // 契約浮動利益損失累計 allFrozen += positions[i].FrozenAmount; // 凍結した契約手数の累計 ありがとうございました. ありがとうございました. if (allAmount === 0) { // 横断完了後,累積された適正な契約手数が0である場合,null,つまり条件付きの合約保有が無くなると返します 返回 null について ありがとうございました. return { // allAmount は 0 でない. 結合されたオブジェクトの保管情報を返します. 投稿者:J.J. 投稿者:J.J. "FrozenAmount: allFrozen"は,FrozenAmountのサイトで公開されている. 価格: _N (allCost / allAmount) "Amount"は"allAmount"を表示しています 利潤:allProfit タイプ:方向, ContractType: 契約タイプ (笑) ありがとうございました.

function Open ((e, contractType, direction, opAmount) { // 操作単品契約の開場関数,パラメータ:取引所のオブジェクト,契約コード,方向性,操作数 var initPosition = GetPosition ((e, contractType, direction); // 上にあるGetPosition関数を呼び出し,結合後の保持情報を取得する. var isFirst = true; // isFirst を設定する var initAmount = initPosition? initPosition.Amount : 0; // initPosition が null の場合は initAmount を 0 に代入する.そうでなければ initPosition.Amount を代入する var positionNow = initPosition; // 変数 positionNow を表示し,現在保管されている情報を宣言する while (true) { // while ループ var needOpen = opAmount; // 暫定変数を needOpen と宣言し,参数 取引が必要とする量でそれに値付けします if (isFirst) { // 最初の実行の場合,isFirstのみを更新します. 更新が false になっているため,次のループでは else ブロックを実行します. isFirst = false; isFIRST = false. isFirst = false. isFirst = false. isFirst = false. { else } { ほかに } positionNow = GetPosition ((e, contractType, direction); // positionNowを更新する,現在の保持情報. if (positionNow) { // もし,保有情報がある場合,次に開く需要の取引数 needOpen は,パラメータ要求の操作量に等しい. needOpen = opAmount - (positionNow.Amount - initAmount) は,この設定をクリックして, ありがとうございました. ありがとうございました. var insDetail = _C ((e.SetContractType, contractType); // 契約の種類を設定する. // Log ((初期収納, initAmount,現在の収納, positionNow,追加収納, needOpen); if (needOpen < insDetail.MinLimitOrderVolume) { // 次の取引先の数が,その契約の制限リストの最小取引先数よりも小さい場合 break; // ループから飛び出します {cH00ffff} if (!CanTrade(opAmount)) { // 風制御モジュール 検知, False を返した場合はループを跳ね出して取引しない. ブロンクス: {cH00ffff} var depth = _C ((e.GetDepth); //市場深さの情報を取得する. var amount = Math.min ((insDetail.MaxLimitOrderVolume, needOpen); // 契約価格の制限値よりも下記の単位の最大値を超えないように制限する e.SetDirection ((direction == PD_LONG? buy キン: sell キン); //パラメータ direction に基づいて下記の方向を設定します。 オーダーIDを表示する if (direction == PD_LONG) { // パラグメントの方向性によって異なるAPIを呼び出し,取引を行う ((open more or open space) orderId = e.Buy ((depth.Asks[0].Price + (insDetail.PriceTick * SlideTick), Math.min ((amount, depth.Asks[0].Amount), contractType, Ask, depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); orderId = e.Buy (depth.Asks[0]); // API 文書を参照してください,CTP 商品先物価格の滑り値が insDetail.PriceTick に跳ね上がり,この値の整数倍である必要があります. // 呼び出すAPIの実際の下位単位は,ディスクの1段の量より大きいものではありません { else } { ほかに } orderId = e.Sell ((depth.Bids[0].Price - (insDetail.PriceTick * SlideTick), Math.min ((amount, depth.Bids[0].Amount), contractType, Bid , depth.Bids[0]); {cH00ffff} //PendingOrdersをキャンセルする while (true) { // 注文後,Interval の間隔で,未完了の注文をキャンセルします。 スリープ (interval) var orders = _C ((e.GetOrders); //未完了の注文をすべて取得する if (orders.length === 0) { // if (orders.length === 0) { // if (orders.length === 0) { // if (orders.length === 0) { // if (orders.length === 0) { // if (orders.length === 0) } ブロンクス: {cH00ffff} for (var j = 0; j < orders.length; j++) { // 未完了の注文の配列を横断する e.CancelOrder ((orders[j].Id); //現在のインデックス内の注文情報のIDで注文をキャンセルします。 if (j < (orders.length - 1)) { // は,一定の時間間隔を横切る.一方,周波数があまりにも高い. Sleep (インターバル); // Sleep (インターバル) を一時停止する {cH00ffff} {cH00ffff} {cH00ffff} } // 主回路がwhileで終了した場合 var ret = { // 返されるオブジェクトを宣言する price: 0, // 取引の平均価格 取引数: 0 position: positionNow // 最近入手したこの品種に関する保管情報 (笑) if (!positionNow) { // ストレージ情報がない場合,直接初期化されたret を返します 返信 ret; {cH00ffff} if (!initPosition) { // 現在の関数を実行開始時に,この種の保持情報が存在しない場合.』 ret.price = positionNow.Price; //現在の保有情報positionNowの価格はこの取引が完了した平均保有価格です ret.amount = positionNow.Amount; // 同上する } else { // この品種の保管情報が開始時に既に存在していた場合. ret.amount = positionNow.Amount - initPosition.Amount; // 差値は,新しいポジションを開設した数値である ret.price = _N (((((positionNow.Price * positionNow.Amount) - (initPosition.Price * initPosition.Amount)) /ret.amount); // この取引の新規追加費用は,新規開場によって除算され,この取引の平均価格が得られる. {cH00ffff} return ret; // ret を返す {cH00ffff}

function Cover ((e, contractType) { // 単品平仓関数,パラメータ: 取引所オブジェクト、契約コード var insDetail = _C ((e.SetContractType, contractType); // 契約の種類を設定する while (true) { // メインループ while var n = 0; // 平台操作のカウント var opAmount = 0; // 声明 操作 変数 var positions = _C ((e.GetPosition); // API を呼び出し 取得 保持情報,上記の 取得 保持関数を区別します.詳細については API 文書を参照してください. for (var i = 0; i < positions.length; i++) { // 閲覧 保存情報 if (positions[i].ContractType!= contractType) { // 現在のインデックスの保有情報である場合,契約は操作する契約に等しくありません: contractType continue; // を飛ばします ありがとうございました. var amount = Math.min ((insDetail.MaxLimitOrderVolume, positions[i].Amount); // コントロールする最大取引量 ワール・ディープ if (positions[i].Type == PD_LONG のポジション[i].Type == PD_LONG_YD) { // 多ポジション処理 depth = _C ((e.GetDepth); // API を呼び出し,現在のインプレートデータを取得する opAmount = Math.min ((amount, depth.Bids[0].Amount); // 制限 操作量は,ディスクの一段目以上の量ではない if (!CanTrade ((opAmount)) { // 風制御モジュール検出 返信する ありがとうございました. e.SetDirection ((positions[i].Type == PD_LONG? closebuy_today タグ: closebuy タグ); // 設定 取引方向,詳細についてはAPIドキュメントを参照してください

            e.Sell(depth.Bids[0].Price - (insDetail.PriceTick * SlideTick), opAmount, contractType, positions[i].Type == PD_LONG ? "平今" : "平昨", 'Bid', depth.Bids[0]);
                                                                                           // 执行平仓 API ,详细参见 API文档。
            n++;                                                                           // 操作计数累加
        } else if (positions[i].Type == PD_SHORT || positions[i].Type == PD_SHORT_YD) {    // 处理 空仓 类似多仓处理
            depth = _C(e.GetDepth);
            opAmount = Math.min(amount, depth.Asks[0].Amount);
            if (!CanTrade(opAmount)) {
                return;
            }
            e.SetDirection(positions[i].Type == PD_SHORT ? "closesell_today" : "closesell");
            e.Buy(depth.Asks[0].Price + (insDetail.PriceTick * SlideTick), opAmount, contractType, positions[i].Type == PD_SHORT ? "平今" : "平昨", 'Ask', depth.Asks[0]);
            n++;
        }
    }
    if (n === 0) {                                                                         // 如果n 等于 0 ,即初始为0 ,在遍历时没有累加,没有可平的仓位。
        break;                                                                             // 跳出主while循环
    }
    while (true) {                                                                         // 间隔一定时间后, 取消所有挂单。类似Open函数的  CancelPendingOrders
        Sleep(Interval);
        var orders = _C(e.GetOrders);
        if (orders.length === 0) {
            break;
        }
        for (var j = 0; j < orders.length; j++) {
            e.CancelOrder(orders[j].Id);
            if (j < (orders.length - 1)) {
                Sleep(Interval);
            }
        }
    }
}

}

var trans = { // 状態バーで詳細なアカウント情報を表示するために使用される,中国語翻訳辞書 アカウントIDタグ: 投資家のアカウントタグ Available: はお金ですることができます. Balance: 期貨決済準備金: 準備金: 準備金: 準備金: 準備金: 準備金: 準備金: 準備金: BrokerID:の代号は,の代理店の代号です. CashIn: の資金格差は急上昇し, CloseProfit: 平仓は損増し, クレジットカードの額は上昇し, Curr Margin : の現在の保証金総額はで, CurrencyIDタグ: コインのコードタグ 投資家は金貨を配達し,金貨を配達し,金貨を配達する. Deposit:金銭をに入れる 交換配達手数料:取引所が金貨を配達し,金貨を配達し,金貨を配達し,金貨を配達する. 取引所が金を担保しているため, 凍結した金庫: 凍結した金庫: 凍結した金庫 FrozenCommission: 凍結した手続料 凍結した金:凍結した金の保証金 FundMortgageAvailable: 通貨の抵当金残高は, FundMortgageIn: の通貨を担保する金額を担保する 基金MortgageOut: の資金は,金銭的な資産として, Interest: の利子収入は上昇し, 利息ベース:利息ベースは, 住宅ローンの支払いは,住宅ローンの支払いにかかる. ローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンスローナンス ポジションプロフィート: ポジションは損を上げ,損を上げます. PreBalance: が準備金庫を決済した際, PreCredit:前回のクレジットローンは急激に急激に急激に急激に急激に急激に急激に急激に急激に急激に急激に急激に急激に急激に 預金金金: 預金金金: 預金金金: 預金金金: 預金金 PreFundMortgageIn: は,先行した金額を押金し, PreFundMortgageOut: は,先回の融資で支払った金額を, PreMargin: が最後に保有していた保証金は, PreMortgage: 前回の抵当金について の基本準備金: の基本準備金は, 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス: 準備バランス SettlementID: の決済番号はで, 特定の商品を保有する場合は,利益を得たり損したりします. 特定製品委員会 (SpecProductCommission) は,特定の製品の手続費を特定し, SpecProductExchange Margin: の特殊商品取引所が金を担保している. SpecProductFrozenCommission:特殊製品の凍結手数料をする SpecProductFrozenMargin: の特殊製品の凍結保証金. SpecProductMargin: の特殊商品は金を担保しています. SPECPRODUCT POSITION PROFIT: 特殊商品を保有する場合は,利益と損を上げます. SpecProductPositionProfitByAlg: は,持有利回りアルゴリズムによって計算された特殊商品の持有利回り, TradingDay: の取引日記 Withdraw:金銭を抽出する WithdrawQuota: お金を引くは,金銭を引くで,金銭を引くで, (笑)

function AccountToTable ((jsStr, title) { // 関数関数は,アカウント情報を状態欄表に輸出する.パラメータ:表示するJSON構造文字列、タイトル if (typeof(title) === undefined) { // title 参数が入力されていない場合,初期化:アカウント情報 title = アカウント情報欄; {cH00ffff} var tbl = { // 状態バーで表示される,LogStatus関数に伝達される表のオブジェクトを宣言する type: table, // タイプ tableとして指定 title: title, // 参数 title tbl の title フィールドに値付け cols: [欄の,記述,], //表 列のタイトル rows: [] // 表の各行にデータを格納する行列フィールド,初期は空行列である. (笑) try { // 異常を検知する var fields = JSON.parse ((jsStr); // jsStr の文字列を解析する for (var k in fields) { // fields オブジェクトの属性,k が属性値,JS チュートリアルを参照してください. if (k == AccountID 前 の k == BrokerID 前 の) { // この 2 つの属性がある場合,飛ばします. 続きを読む {cH00ffff} var desc = trans[k]; // trans の属性名に基づいて,中国語のdesc にアクセスする var v = fields[k]; // 現在の属性名の値を取得する if (typeof(v) === number) { // 属性の値が数値型である場合,5位小数保持します。 v = _N ((v, 5); {cH00ffff} tbl.rows.push (([k, typeof(desc) === undefined??? : desc, v]); // 現在の属性,属性説明,属性値の組み合わせの1次元の配列を表オブジェクトtblのrows属性 (※) に押し込む. {cH00ffff} } catch (e) {} // 異常をキャプチャしたが処理しない return tbl; // tbl オブジェクトを返します {cH00ffff}

var PositionManager = (function() { // 変数 PositionManager を宣言します. PositionManager は匿名関数の返却値を受容し,その返却値は構成されたオブジェクトです. function PositionManager ((e) { // 匿名関数の内部にある PositionManager を宣言する. if (typeof(e) === undefined) { // 参数e が伝わらなければ,デフォルトでグローバル変数 exchange を e に代入する. e = 交換; {cH00ffff} if (e.GetName()!== Futures_CTP) { // 主取引所のオブジェクトeが商品先物取引所かどうか,もしそうでない場合は異常を投げ出すかを検知する. throw CTPのみサポートする; // CTPのみサポートする {cH00ffff} this.e = e; //は現在の関数 (実際はオブジェクトでもある) に属性 e を追加し,参数 e をそれに代入します. this.account = null; // account を追加する 変数は null で開始されます {cH00ffff} //キャッシュを取得する PositionManager.prototype.Account = function (() { // 上記宣言の PositionManager に Account 関数に方法を追加する if (!this.account) { // PositionManager の account 属性が null 値である場合 this.account = _C ((this.e.GetAccount); // this.e 取引所のオブジェクトの GetAccount 関数 (つまり取引所のオブジェクト API) を呼び出し,アカウント情報を取得します. {cH00ffff} return this.account; // この方法は,この PositionManager.account アカウント情報を返します。 (笑) PositionManager.prototype.GetAccount = function ((getTable) { // 追加方法 この方法は最新のアカウント情報を取得する この.account = _C ((this.e.getAccount); if (typeof(getTable)!== undefined && getTable) { // 最近取得したアカウント情報の詳細をオブジェクトとして返すには,getTable は true とする必要があります. return AccountToTable ((this.e.GetRawJSON()) // GetRawJSON関数 詳細についてはAPIドキュメントを参照してください {cH00ffff} return this.account; //更新されたアカウント情報を返します。 (笑)

PositionManager.prototype.GetPosition = function(contractType, direction, positions) { // 给 PositionManager 添加方法 用于在主策略中调用该模板的 函数
    return GetPosition(this.e, contractType, direction, positions);
};

PositionManager.prototype.OpenLong = function(contractType, shares) {                  // 添加 开多仓 方法
    if (!this.account) {
        this.account = _C(this.e.GetAccount);
    }
    return Open(this.e, contractType, PD_LONG, shares);
};

PositionManager.prototype.OpenShort = function(contractType, shares) {                 // 添加 开空仓 方法
    if (!this.account) {
        this.account = _C(this.e.GetAccount);
    }
    return Open(this.e, contractType, PD_SHORT, shares);
};

PositionManager.prototype.Cover = function(contractType) {                             // 添加 平仓 方法
    if (!this.account) {
        this.account = _C(this.e.GetAccount);
    }
    return Cover(this.e, contractType);
};
PositionManager.prototype.CoverAll = function() {                                      // 添加 所有仓位全平方法
    if (!this.account) {
        this.account = _C(this.e.GetAccount);
    }
    while (true) {
        var positions = _C(this.e.GetPosition)
        if (positions.length == 0) {
            break
        }
        for (var i = 0; i < positions.length; i++) {                                   // 首先平掉 对冲合约 对冲合约 举例 MA709&MA705
            // Cover Hedge Position First
            if (positions[i].ContractType.indexOf('&') != -1) {
                Cover(this.e, positions[i].ContractType)
                Sleep(1000)
            }
        }
        for (var i = 0; i < positions.length; i++) {
            if (positions[i].ContractType.indexOf('&') == -1) {
                Cover(this.e, positions[i].ContractType)
                Sleep(1000)
            }
        }
    }
};
PositionManager.prototype.Profit = function(contractType) {                            // 添加计算收益的方法
    var accountNow = _C(this.e.GetAccount);
    return _N(accountNow.Balance - this.account.Balance);
};

return PositionManager;                                                                // 匿名函数返回 在自身内声明的 PositionManager 函数(对象)。

})();

$.NewPositionManager = function(e) { //関数を輸出して,ポジションマネージャオブジェクトを構成する return new ポジションマネージャー ((e); (笑)

// 経由:http://mt.sohu.com/20160429/n446860150.shtml$.IsTrading = function ((symbol) { // 取引中の契約かどうかを判断する 期間内,参数 symbol 契約コード var now = new Date ((); // 現在の時間オブジェクトを取得する var day = now.getDay ((); // 週間の特定の日に現在の時間を取得します。 < hour = now.getHours ((); // 24時間間の時間を取ります. < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > < minute > > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute > / minute / minute / minute / minute / minute

if (day === 0 || (day === 6 && (hour > 2 || hour == 2 && minute > 30))) {              // 第一个过滤, day == 0 星期天  或者  day == 6 星期六并且
    return false;                                                                      // 2点30以后 。 星期五 夜盘结束。  返回 false  即所有品种不在交易时间
}
symbol = symbol.replace('SPD ', '').replace('SP ', '');                                // 正则表达式 匹配其交易系统用“SPD”表示跨期套利交易,若指令买进“SPD CF1609&CF17...
                                                                                       // 过滤掉 跨期套利的 合约编码
var p, i, shortName = "";
for (i = 0; i < symbol.length; i++) {                                                  // 遍历合约代码字符串,取出 代码(排除数字的部分)赋值给shortName 并且转换为大写
    var ch = symbol.charCodeAt(i);
    if (ch >= 48 && ch <= 57) {
        break;
    }
    shortName += symbol[i].toUpperCase();
}

var period = [                                                                         // 通常交易时间  9:00 - 10:15,
    [9, 0, 10, 15],                                                                    //             10:30 - 11:30
    [10, 30, 11, 30],                                                                  //              13:30 - 15:00
    [13, 30, 15, 0]
];
if (shortName === "IH" || shortName === "IF" || shortName === "IC") {                  // 如果是这些 品种,交易时间 period 调整
    period = [
        [9, 30, 11, 30],
        [13, 0, 15, 0]
    ];
} else if (shortName === "TF" || shortName === "T") {                                  // 国债品种  时间调整
    period = [
        [9, 15, 11, 30],
        [13, 0, 15, 15]
    ];
}


if (day >= 1 && day <= 5) {                                                            // 如果是 周一 到周五, 不考虑夜盘。 判断当前时间是否符合 period 设定的时间表
    for (i = 0; i < period.length; i++) {
        p = period[i];
        if ((hour > p[0] || (hour == p[0] && minute >= p[1])) && (hour < p[2] || (hour == p[2] && minute < p[3]))) {
            return true;                                                               // 符合遍历出的  时间表 中的 时间段,  即该品种在交易时间内。
        }
    }
}

var nperiod = [                                                                        // 额外判断 夜盘品种  nperiod[n][0] 是夜盘时间相同的一类
                                                                                       // 品种汇总,nperiod[n][1] 就是该类品种的夜盘交易时间
    [
        ['AU', 'AG'],
        [21, 0, 02, 30]
    ],
    [
        ['CU', 'AL', 'ZN', 'PB', 'SN', 'NI'],
        [21, 0, 01, 0]
    ],
    [
        ['RU', 'RB', 'HC', 'BU'],
        [21, 0, 23, 0]
    ],
    [
        ['P', 'J', 'M', 'Y', 'A', 'B', 'JM', 'I'],
        [21, 0, 23, 30]
    ],
    [
        ['SR', 'CF', 'RM', 'MA', 'TA', 'ZC', 'FG', 'IO'],
        [21, 0, 23, 30]
    ],
];
for (i = 0; i < nperiod.length; i++) {                                                // 遍历所有夜盘品种 交易时间段,对比当前时间。
    for (var j = 0; j < nperiod[i][0].length; j++) {
        if (nperiod[i][0][j] === shortName) {
            p = nperiod[i][1];
            var condA = hour > p[0] || (hour == p[0] && minute >= p[1]);
            var condB = hour < p[2] || (hour == p[2] && minute < p[3]);
            // in one day
            if (p[2] >= p[0]) {
                if ((day >= 1 && day <= 5) && condA && condB) {
                    return true;
                }
            } else {
                if (((day >= 1 && day <= 5) && condA) || ((day >= 2 && day <= 6) && condB)) {
                    return true;
                }
            }
            return false;
        }
    }
}
return false;

};

$.NewTaskQueue = function ((onTaskFinish) { // 多種多様な取引を行うために使用されるキューオブジェクト構築関数。 参数:タスク完了時に呼び戻す関数。 虚空のオブジェクトを宣言する self.ERR_SUCCESS = 0 // 定義 返信 成功 self.ERR_SET_SYMBOL = 1 // 契約設定のエラー self.ERR_GET_RECORDS = 2 // K線を取得するエラー self.ERR_GET_ORDERS = 3 // 注文が完了していないことを取得するエラー self.ERR_GET_POS = 4 // 収蔵情報を取得したエラー self.ERR_TRADE = 5 // 取引のエラー self.ERR_GET_DEPTH = 6 // 深度行列の誤りを取得する self.ERR_NOT_TRADING = 7 // 取引時にない self.ERR_BUSY = 8 //ブロック

self.onTaskFinish = typeof(onTaskFinish) === 'undefined' ? null : onTaskFinish  // 如果在 初始化队列对象时没有 传入需要回调的匿名函数,该属性赋值为null,否则赋值回调函数
self.retryInterval = 300                                                        // 重试间隔 毫秒数
self.tasks = []                                                                 // 这个是一个重要的属性,队列中储存任务的数组。
self.pushTask = function(e, symbol, action, amount, arg, onFinish) {            // 给空对象添加函数,该函数是压入 新任务 到任务数组中。参数分别为:
                                                                                // 交易所对象、合约代码、执行动作、数量、回调函数参数、回调函数
    var task = {                                                                // 构造一个任务对象
        e: e,                                                                   // 交易所对象
        action: action,                                                         // 执行的动作
        symbol: symbol,                                                         // 合约代码
        amount: amount,                                                         // 操作数量
        init: false,                                                            // 是否初始化
        finished: false,                                                        // 是否任务完成
        dealAmount: 0,                                                          // 已处理的 量
        preAmount: 0,                                                           // 上一次的 量
        preCost: 0,                                                             // 上一次的 花费
        retry: 0,                                                               // 重试次数
        maxRetry: 10,                                                           // 最大重试次数
        arg: typeof(onFinish) !== 'undefined' ? arg : undefined,                // 如果没有传入 回调函数,此项 设置为 undefined
        onFinish: typeof(onFinish) == 'undefined' ? arg : onFinish              // 如果没有传入回调函数,把 arg 复制给 onFinish(实际上是 arg没传入,中间隔过去了)
    }
    
    switch (task.action) {                                                      // 根据执行的动作初始化描述信息
        case "buy":
            task.desc = task.symbol + " 开多仓, 数量 " + task.amount
            break
        case "sell":
            task.desc = task.symbol + " 开空仓, 数量 " + task.amount
            break
        case "closebuy":
            task.desc = task.symbol + " 平多仓, 数量 " + task.amount
            break
        case "closesell":
            task.desc = task.symbol + " 平空仓, 数量 " + task.amount
            break
        default:
            task.desc = task.symbol + " " + task.action + ", 数量 " + task.amount
    }

    self.tasks.push(task)                                                       // 压入任务数组中
    Log("接收到任务", task.desc)                                                  // 输出日志 显示 接收到任务。
}

self.cancelAll = function(e) {                                                  // 添加函数,取消所有,参数: 交易所对象
    while (true) {                                                              // 遍历未完成的所有订单,逐个取消。
        var orders = e.GetOrders();
        if (!orders) {                                                          // 所有API 调用都不重试,如果API调用失败,立即返回。
            return self.ERR_GET_ORDERS;
        }
        if (orders.length == 0) {
            break;
        }
        for (var i = 0; i < orders.length; i++) {
            e.CancelOrder(orders[i].Id);
            Sleep(self.retryInterval);
        }
    }
    return self.ERR_SUCCESS                                                      // 返回 完成标记
}

self.pollTask = function(task) {                                                 // 执行数组中弹出的任务
    var insDetail = task.e.SetContractType(task.symbol);                         // 切换到当前 任务 task 对象保存的合约类型
    if (!insDetail) {                                                            // 切换失败 立即返回
        return self.ERR_SET_SYMBOL;
    }
    var ret = null;
    var isCover = task.action != "buy" && task.action != "sell";                 // 根据执行的动作,设置 是否是平仓的 标记
    do {                                                                         // do while 循环,先执行 do 以内
        if (!$.IsTrading(task.symbol)) {                                         // 判断是否在交易时间
            return self.ERR_NOT_TRADING;                                         // 不在交易时间立即返回
        }
        if (self.cancelAll(task.e) != self.ERR_SUCCESS) {                        // 调用全部取消函数 ,如果不等于 完成状态
            return self.ERR_TRADE;                                               // 返回交易失败
        }
        if (!CanTrade(task.amount)) {                                            // 风控模块检测。
            ret = null
            break
        }
        var positions = task.e.GetPosition();                                    // 获取持仓信息
        // Error
        if (!positions) {
            return self.ERR_GET_POS;                                             // 如果调用获取持仓 API 错误,立即返回
        }
        // search position
        var pos = null;
        for (var i = 0; i < positions.length; i++) {                             // 遍历持仓信息,查找持仓合并持仓,类似 上面的 GetPosition 函数
            if (positions[i].ContractType == task.symbol && (((positions[i].Type == PD_LONG || positions[i].Type == PD_LONG_YD) && (task.action == "buy" || task.action == "closebuy")) || ((positions[i].Type == PD_SHORT || positions[i].Type == PD_SHORT_YD) && (task.action == "sell" || task.action == "closesell")))) {
                if (!pos) {
                    pos = positions[i];
                    pos.Cost = positions[i].Price * positions[i].Amount;
                } else {
                    pos.Amount += positions[i].Amount;
                    pos.Profit += positions[i].Profit;
                    pos.Cost += positions[i].Price * positions[i].Amount;
                }
            }
        }
        // record pre position
        if (!task.init) {                                                        // 如果任务没有初始化,执行以下
            task.init = true;                                                    // 更新为已初始化
            if (pos) {                                                           // 如果查找到之前的持仓,把之前的持仓数量、 花费 复制给task 的相应变量保存
                task.preAmount = pos.Amount;
                task.preCost = pos.Cost;
            } else {                                                             // 如果执行这个任务 时没有 ,同样的方向  同样合约的持仓,把task相关变量赋值0
                task.preAmount = 0;
                task.preCost = 0;
                if (isCover) {                                                   // 如果是 平仓动作,输出日志 : 找不到仓位,跳出循环。
                    Log("找不到仓位", task.symbol, task.action);
                    ret = null;
                    break;
                }
            }
        }
        var remain = task.amount;                                                // 声明一个局部变量,用 任务的属性 amount(任务设定的交易量) 初始化
        if (isCover && !pos) {                                                   // 如果 第二次循环中 , 该任务动作是平仓,并且 没有持仓了,给pos 赋值
            pos = {Amount:0, Cost: 0, Price: 0}
        }
        if (pos) {                                                               // 如果 pos 不为null 
            task.dealAmount = pos.Amount - task.preAmount;                       // 已经处理的任务量 等于 每次获取的持仓信息持仓量 与最初开始循环的初始持仓信息持仓量的差值
            if (isCover) {                                                       // 如果是 平仓动作, dealAmount 是负值, 这里取反操作
                task.dealAmount = -task.dealAmount;
            }
            remain = parseInt(task.amount - task.dealAmount);                    // 任务的 交易量 减去 已经处理的交易量  得出 剩余需要处理的交易量
            if (remain <= 0 || task.retry >= task.maxRetry) {                    // 如果剩余需要的交易量小于等于0(此处分析应该是不会小于0,有兴趣的可以分析下。) 或者重试次数大于最大重试上限.
                ret = {                                                          // 更新ret 对象,  更新为已经成交的信息,和 当前仓位信息。
                    price: (pos.Cost - task.preCost) / (pos.Amount - task.preAmount),
                    amount: (pos.Amount - task.preAmount),
                    position: pos
                };
                if (isCover) {                                                   // 如果是 平仓动作
                    ret.amount = -ret.amount;                                    // 平仓时计算出的是负值  ,取反操作
                    if (pos.Amount == 0) {                                       // 如果持仓量为0了, 把ret 的持仓信息 赋值为 null
                        ret.position = null;
                    }
                }
                break;                                                           // remain <= 0 || task.retry >= task.maxRetry 符合这个条件,跳出while循环
            }
        } else if (task.retry >= task.maxRetry) {                                // 如果不是 平仓操作。pos 为null 没有持仓(平仓操作 pos 此处不会是null)
            ret = null;                                                          // 并且 该任务重试测试 大于最大重试次数。跳出循环。
            break;                                                               // 即此时  , 超过最大重试次数,并且 没有增加持仓(开仓 每次都失败了。),跳出循环
        }

        var depth = task.e.GetDepth();                                           // 获取 深度数据
        if (!depth) {
            return self.ERR_GET_DEPTH;                                           // 获取失败立即返回
        }
        var orderId = null;                                                      // 订单ID
        var slidePrice = insDetail.PriceTick * SlideTick;                        // 计算具体滑价值
        if (isCover) {                                                           // 如果是平仓操作
            for (var i = 0; i < positions.length; i++) {                         // 遍历本轮的  API 返回的持仓信息。
                if (positions[i].ContractType !== task.symbol) {                 // 不是当前任务 品种的  跳过。
                    continue;
                }
                if (parseInt(remain) < 1) {                                      // 需要处理的 交易的量 如果小于1,跳出 while
                    break
                }
                var amount = Math.min(insDetail.MaxLimitOrderVolume, positions[i].Amount, remain);  // 在合约规定的最大下单量、持仓量、需要处理的量中取最小值。 
                if (task.action == "closebuy" && (positions[i].Type == PD_LONG || positions[i].Type == PD_LONG_YD)) {   // 如果是平多仓, 持仓信息 为 今日多仓  或者 昨日多仓
                    task.e.SetDirection(positions[i].Type == PD_LONG ? "closebuy_today" : "closebuy");                  // 设置方向
                    amount = Math.min(amount, depth.Bids[0].Amount)                                                     // 根据盘口量 和 下单量 再取一个最小值。
                    orderId = task.e.Sell(_N(depth.Bids[0].Price - slidePrice, 2), amount, task.symbol, positions[i].Type == PD_LONG ? "平今" : "平昨", 'Bid', depth.Bids[0]);
                                                                                                                        // 执行具体的 API 操作,以下平空类似
                } else if (task.action == "closesell" && (positions[i].Type == PD_SHORT || positions[i].Type == PD_SHORT_YD)) {
                    task.e.SetDirection(positions[i].Type == PD_SHORT ? "closesell_today" : "closesell");
                    amount = Math.min(amount, depth.Asks[0].Amount)
                    orderId = task.e.Buy(_N(depth.Asks[0].Price + slidePrice, 2), amount, task.symbol, positions[i].Type == PD_SHORT ? "平今" : "平昨", 'Ask', depth.Asks[0]);
                }
                // assume order is success insert
                remain -= amount;                                                // 假设是成功执行, 需要处理的交易量 减去 此次交易的量。
            }
        } else {                                                                 // 开仓
            if (task.action == "buy") {
                task.e.SetDirection("buy");
                orderId = task.e.Buy(_N(depth.Asks[0].Price + slidePrice, 2), Math.min(remain, depth.Asks[0].Amount), task.symbol, 'Ask', depth.Asks[0]);
            } else {
                task.e.SetDirection("sell");
                orderId = task.e.Sell(_N(depth.Bids[0].Price - slidePrice, 2), Math.min(remain, depth.Bids[0].Amount), task.symbol, 'Bid', depth.Bids[0]);
            }
        }
        // symbol not in trading or other else happend
        if (!orderId) {                                                          // 没有返回具体的ID ,可能是 交易不在交易队列,或者其他错误。
            task.retry++;                                                        // 累计重试次数
            return self.ERR_TRADE;                                               // 返回错误信息。即使不成功, 重新 执行该任务的时候 会重新一次流程。除了task对象的数据 所有数据都会刷新
        }
    } while (true);                                                              // 循环判断 恒为真
    task.finished = true                                                         // 如果在 while 循环中没有直接 return  顺序执行到此,则任务完成                                                      

    if (self.onTaskFinish) {                                                     // 如果队列控制对象的 回调函数 设置 不为null(即 self.onTaskFinish 存在)
        self.onTaskFinish(task, ret)                                             // 执行回调函数。把 task 任务 对象  和 交易的结果  ret 对象 传入回调函数。 
    }

    if (task.onFinish) {                                                         // 处理 任务的回调函数
        task.onFinish(task, ret);
    }
    return self.ERR_SUCCESS;
}

self.poll = function() {                                                         // 迭代执行 弹出 tasks 中的任务 ,并调用 pollTask 执行任务。
    var processed = 0                                                            // 未执行完成的任务计数 ,每次初始0
    _.each(self.tasks, function(task) {                                          // 迭代  可以搜索 _.each 的用法
        if (!task.finished) {                                                    // 如果 任务不是完成状态,
            processed++                                                          // 未完成任务 计数 累计
            self.pollTask(task)                                                  // 执行弹出的任务
        }
    })
    if (processed == 0) {                                                        // 如果没有未完成的任务,即 所有任务队列内的任务完成 ,执行清空 队列对象中 tasks 数组.
        self.tasks = []
    }
}

self.size = function() {                                                         // 给队列对象添加 函数 size 获取 任务队列 中 任务个数
    return self.tasks.length
}

return self                                                                      // 返回构造好的队列对象

}

$.accountToTable = アカウントToTable;


もっと