df = pd.DataFrame({'A': [1, 2, 3, 4, 5], 'B': [10, 20, 30, 40, 50]})

    df2 = pd.DataFrame({'A': [6], 'B': [60]})

    print 'df\n', df

    print 'df2\n', df2

    df_x = [df, df2]

    result = pd.concat(df_x)

    print 'first result\n', result

    basic=ts.get_stock_basics()

    

    print basic.info()

    print basic.head(10)



    basic.to_excel('basic2017.xls',encoding='gbk')

    basic.to_csv('2017_all_price_change.xls',encoding='gbk')

    df=pd.read_csv('2017_all_price_change.xls',encoding='gbk')

    df.to_excel('2017_all_price_change.xls',encoding='gbk')

	df=pd.read_excel('600050.xls',dtype={'datetime':np.datetime64})

	df=df.set_index('datetime')

	df['close'].plot(use_index=True,grid=True)

	plt.show()

这个策略是我做虚拟货币以来的主要策略，后面经过不断完善和修改，复杂了很多，但主要思想并没有改变，分享的这个版本是无明显bug的 最初版本，最为简单清晰，没有仓位管理，每次交易都是满仓，没有卡死后重启等等，但也足够说明问题。

function GetPrice(Type) {

   //_C()是平台的容错函数

    var depth=_C(exchange.GetDepth);

    var amountBids=0;

    var amountAsks=0;

    //计算买价，获取累计深度达到预设的价格

    if(Type=="Buy"){

       for(var i=0;i<20;i++){

           amountBids+=depth.Bids[i].Amount;

           //参数floatamountbuy是预设的累计深度

           if (amountBids>floatamountbuy){

               //稍微加0.01，使得订单排在前面

              return depth.Bids[i].Price+0.01;}

        }

    }

    //同理计算卖价

    if(Type=="Sell"){

       for(var j=0; j<20; j++){

    	   amountAsks+=depth.Asks[j].Amount;

            if (amountAsks>floatamountsell){

            return depth.Asks[j].Price-0.01;}

        }

    }

    //遍历了全部深度仍未满足需求，就返回一个价格，以免出现bug

    return depth.Asks[0].Price

}



// 每个循环的主函数onTick(),这里定的循环时间3.5s，每次循环都会把原来的单子撤销，重新挂单，越简单越不会遇到bug.



function onTick() {

    var buyPrice = GetPrice("Buy");

    var sellPrice= GetPrice("Sell");

    //diffprice是预设差价，买卖价差如果小于预设差价，就会挂一个相对更深的价格

    if ((sellPrice - buyPrice) <= diffprice){

            buyPrice-=10;

            sellPrice+=10;}

    //把原有的单子全部撤销，实际上经常出现新的价格和已挂单价格相同的情况，此时不需要撤销

    CancelPendingOrders() 

    //获取账户信息，确定目前账户存在多少钱和多少币

    var account=_C(exchange.GetAccount);

    //可买的比特币量，_N()是平台的精度函数

    var amountBuy = _N((account.Balance / buyPrice-0.1),2); 

    //可卖的比特币量，注意到没有仓位的限制，有多少就买卖多少，因为我当时的钱很少

    var amountSell = _N((account.Stocks),2); 

    if (amountSell > 0.02) {

        exchange.Sell(sellPrice,amountSell);}

    if (amountBuy > 0.02) {

        exchange.Buy(buyPrice, amountBuy);}

    //休眠，进入下一轮循环

    Sleep(sleeptime);

}

date = date + '-01-01'

        cmd = 'select * from `{}` where datetime > \'{}\''.format(code, date)



        try:

            df = pd.read_sql(cmd, history_engine,index_col='index')

        except Exception,e:

            print e

            return None

        

        # 不知道为啥，这里的类型发生改变

        idx= df['low'].idxmin()

datetime    datetime64[ns]

code                object

name                object

open                object

close               object

high                object

low                 object

vol                float64

amount             float64

dtype: object

df['low']=df['low'].astype('float64')

# -*-coding=utf-8-*-

__author__ = 'Rocky'

'''

http://30daydo.com

Contact: weigesysu@qq.com

'''

import random

import hashlib

import hmac,time

import smtplib

from email.mime.text import MIMEText

from email import Utils

import threading

import requests,datetime,itchat



from toolkit import Toolkit





class Jubi_web():

    def __init__(self, send=None):

        cfg = Toolkit.getUserData('data.cfg')

        self.public_key = cfg['public_key']

        self.private_key = cfg['private_key']

        self.send=send

        from_mail = cfg['from_mail']

        password = cfg['password']

        to_mail = cfg['to_mail']

        smtp_server = 'smtp.qq.com'



        self.server = smtp_server

        self.username = from_mail.split("@")[0]

        self.from_mail = from_mail

        self.password = password

        self.to_mail = to_mail

        self.coin_list=['IFC','DOGE','EAC','DNC','MET','ZET','SKT','YTC','PLC','LKC',

                        'JBC','MRYC','GOOC','QEC','PEB','XRP','NXT','WDC','MAX','ZCC',

                        'HLB','RSS','PGC','RIO','XAS','TFC','BLK','FZ','ANS','XPM','VTC',

                        'KTC','VRC','XSGS','LSK','PPC','ETC','GAME','LTC','ETH','BTC']

        # 初始化邮箱设置读取需要股票信息

        # 这样子只登陆一次

        if self.send == 'msn':



            try:

                self.smtp = smtplib.SMTP_SSL(port=465)

                self.smtp.connect(self.server)

                self.smtp.login(self.username, self.password)

            except smtplib.SMTPException, e:

                print e

                return 0



        if send=='wechat':

            self.w_name=u'xxxxx'

            

            itchat.auto_login(hotReload=True)

            account=itchat.get_friends(self.w_name)





    def send_wechat(self,name,content):

        w_content=name+' '+content

        itchat.send(w_content,toUserName=self.toName)

        time.sleep(1)

        itchat.send(w_content,toUserName='filehelper')





    def send_text(self, name, content):



        subject = '%s' % name

        self.msg = MIMEText(content, 'plain', 'utf-8')

        self.msg['to'] = self.to_mail

        self.msg['from'] = self.from_mail

        self.msg['Subject'] = subject

        self.msg['Date'] = Utils.formatdate(localtime=1)

        try:

            self.smtp.sendmail(self.msg['from'], self.msg['to'], self.msg.as_string())

            self.smtp.quit()

            print "sent"

        except smtplib.SMTPException, e:

            print e

            return 0



    def warming(self, coin, up_price, down_price):

        url = 'https://www.jubi.com/api/v1/ticker/'

        while 1:

            time.sleep(5)

            try:

                data = requests.post(url, data={'coin': coin}).json()

            except Exception,e:

                print e

                print "time out. Retry"

                time.sleep(15)

                continue



            current = float(data['last'])

            if current >= up_price:

                print "Up to ", up_price

                print "current price ",current



                if self.send=='msn':

                    self.send_text(coin,str(current))

                if self.send=='wechat':

                    self.send_wechat(coin,str(current))



                time.sleep(1200)

            if current <= down_price:

                print "Down to ", down_price

                print "current price ",current

                if self.send=='msn':

                    self.send_text(coin,str(current))

                if self.send=='wechat':

                    self.send_wechat(coin,str(current))

                time.sleep(1200)

    #上面的内容尽量不用修改。





    def getContent(self):

        url = 'https://www.jubi.com/api/v1/trade_list'

        params_data = {'key': 'x', 'signature': 'x'}

        s = requests.get(url=url, params=params_data)



    def getHash(self, s):

        m = hashlib.md5()

        m.update(s)

        return m.hexdigest()



    def sha_convert(self, s):

        return hashlib.sha256(self.getHash(s)).hexdigest()



    def get_nonce(self):

        lens = 12

        return ''.join([str(random.randint(0, 9)) for i in range(lens)])



    def get_signiture(self):

        url = 'xxxxxxxxx'

        coin = 'zet'

        nonce = self.get_nonce()



        # sha=self.sha_convert(private_key)

        md5 = self.getHash(self.private_key)

        message = 'nonce=' + nonce + '&' + 'key=' + self.public_key

        # print message

        signature = hmac.new(md5, message, digestmod=hashlib.sha256).digest()

        # print signature



        # req=requests.post(url,data={'signature':signature,'key':public_key,'nonce':nonce,'coin':'zet'})

        req = requests.post(url, data={'coin': coin})

        print req.status_code

        print req.text



    def real_time_ticker(self, coin):

        url = 'xxxxxxxx'

        try:

            data = requests.post(url, data={'coin': coin}).json()

            #print data

        except Exception ,e:

            print e

        return data





    def real_time_depth(self, coin):

        url = 'xxxxxxxxx'

        data = requests.post(url, data={'coin': coin}).json()

        print data

        data_bids = data['bids']

        data_asks = data['asks']

        print "bids"

        for i in data_bids:

            print i[0],

            print ' ',

            print i[1]

        print "asks"

        for j in data_asks:

            print j[0],

            print ' ',

            print j[1]



    def list_all_price(self):

        for i in self.coin_list:

            print i,

            print " price: ",

            p=self.real_time_ticker(i.lower())

            if p is not None:

                print p[u'last']



    def getOrder(self,coin):

        url='https://www.jubi.com/api/v1/orders/'

        try:

            req=requests.get(url,params={'coin':coin})

        except Exception,e:

            print e



        data=req.json()

        return data

    # recent 100 trade turn over

    def turnover(self,coin):

        i=coin.lower()

        coins=Toolkit.getUserData('coins.csv')

        total=long(coins[i])

[i]        [/i]p=self.getOrder(i)

        print p

        amount=0.00

        for j in p:

            t= j[u'amount']

            amount=float(t)+amount

        #current=float(self.real_time_ticker(i)[u'last'])

        turn_over=amount*1.00/total*100

        print turn_over



    def multi_thread(self,coin_list,price_list):

        thread_num=len(coin_list)

        thread_list=

        for i in range(thread_num):

            t=threading.Thread(target=self.warming, args=(coin_list,price_list[0],price_list[1]),)

            thread_list.append(t)

        for j in thread_list:

            j.start()

        for k in thread_list:

            k.join()



if __name__ == '__main__':



    obj = Jubi_web(send='wechat')

    coin_list=['zet','doge']

    price_list=[[0.2,0.13],[0.03,0.024]]

    obj.multi_thread(coin_list,price_list)



[/i]