yssource / flashfunk Goto Github PK

use chrono::{Local, NaiveDateTime, Timelike};

use flashfunk_core::constants::{Direction, Offset, Exchange, OrderType, Status};
use flashfunk_core::interface::Interface;
use flashfunk_core::structs::{CancelRequest, Generator, LoginForm, OrderData, OrderRequest, TickData};
use flashfunk_core::prelude::{Ac, IntoStrategy, Context, ContextTrait, Flash};
use flashfunk_core::ctp::md_api::MdApi;
use flashfunk_core::ctp::td_api::TdApi;
use flashfunk_codegen::Strategy;

#[derive(Strategy)]
#[name("flash_ni")]
#[symbol("ni2102")]
pub struct Collector{
    ticks: Vec<TickData>
}

impl Ac for Collector {
    fn on_tick(&mut self, tick:&TickData, ctx: &mut Context){
        println!("{} {}", tick.datetime, tick.last_price);    
    }   
    
    fn on_order(&mut self, order: &OrderData, ctx: &mut Context){
        // get your order back infomation   
    }   

}

fn main() {
    // build a strategy instance 
    let tor = Collector {
            ticks: vec![]
    };
    // get the login infomation
    let login_form = LoginForm::new()
        .user_id("089131")
        .password("350888")
        .broke_id("9999")
        .app_id("simnow_client_test")
        .md_address("tcp://180.168.146.187:10131")   // simnow24小时环境
        .td_address("tcp://180.168.146.187:10130")
        // .md_address("tcp://218.202.237.33:10112")  // simnow移动正常环境
        // .td_address("tcp://218.202.237.33:10102")
        .auth_code("0000000000000000")
        .production_info("");
    
    // build running environment to run strategy and start
    Flash::builder::<MdApi, TdApi, _>("flash")
        .strategies(vec![tor.into_str()])
        .id("flash")
        .login_form(login_form)
        .start();
}