# coding=utf-8
__author__ = 'litao'
import util.dbutil as dbutil
import re
import sys
import csv
import time
import MySQLdb
from sqlalchemy import create_engine
import tushare as ts
try:
    #首先取出所有股票的代码，然后取得股票的上市时间，根据上市时间按年增加数据，一直进行循环
    conn = MySQLdb.connect(host='localhost',user='root',passwd='<PASSWORD>',db='stock',charset="utf8")
    cursor = conn.cursor()
    sql ="select * from stock_basic"
    cursor.execute(sql)
    stockDf =ts.get_stock_basics()
    startImport =  time.localtime(time.time())
    #通过循环获得股票的基本信息并写入到数据库中，并实现定义好股票的相关基本信息与数据库的字段相对应
    #通过循环获取当前股票的最大时间，然后利用最大时间与与当前时间设置差值，进行导入数据
    for row in cursor.fetchall():
        stockno = str(row[0])
        print stockno
        #获得上市时间
        sssj = str(stockDf.ix[stockno]['timeToMarket']) #上市日期YYYYMMDD
        ssYear =int(sssj[0:4])
        currentDay = time.strftime('%Y-%m-%d',time.localtime(time.time()))
        max_day_date = dbutil.get_day_maxdate(stockno)
        max_week_date = dbutil.get_week_maxdate(stockno)
        max_month_date = dbutil.get_month_maxdate(stockno)
        max_qfq_date = dbutil.get_qfq_maxdate(stockno)
        max_bfq_date = dbutil.get_bfq_maxdate(stockno)
        end = currentDay
        print end
        #dbutil.get_qfq_date(stockno,max_qfq_date,end)
        #dbutil.get_day_data(stockno,max_day_date,end)
        dbutil.get_week_data(stockno,max_week_date,end)
        #dbutil.get_month_data(stockno,max_month_date,end)
        #dbutil.get_bfq_data(stockno,max_bfq_date,end)

        #dbutil.get_five_data(stockno,start,end)
        print stockno + str(ssYear)+"success"
        ssYear = ssYear+1

       #取得当前的年月，并按年进行循环，插入数据相关数据

except Exception,e:
    e.message

# coding=utf-8
__author__ = 'litao'
import util.dbutil as dbutil
import re
import sys
import csv
import time
import MySQLdb
from sqlalchemy import create_engine
import tushare as ts
try:
    #首先取出所有股票的代码，然后取得股票的上市时间，根据上市时间按年增加数据，一直进行循环
    conn = MySQLdb.connect(host='localhost',user='root',passwd='<PASSWORD>',db='stock',charset="utf8")
    cursor = conn.cursor()
    sql ="select * from stock_basic"
    cursor.execute(sql)
    stockDf =ts.get_stock_basics()
    startImport =  time.localtime(time.time())
    #通过循环获得股票的基本信息并写入到数据库中，并实现定义好股票的相关基本信息与数据库的字段相对应
    #通过循环获取当前股票的最大时间，然后利用最大时间与与当前时间设置差值，进行导入数据
    for row in cursor.fetchall():
        stockno = str(row[0])
        print stockno
        #获得上市时间
        sssj = str(stockDf.ix[stockno]['timeToMarket']) #上市日期YYYYMMDD
        ssYear =int(sssj[0:4])
        currentDay = time.strftime('%Y-%m-%d',time.localtime(time.time()))
        max_day_date = dbutil.get_day_maxdate(stockno)
        max_week_date = dbutil.get_week_maxdate(stockno)
        max_month_date = dbutil.get_month_maxdate(stockno)
        max_qfq_date = dbutil.get_qfq_maxdate(stockno)
        max_bfq_date = dbutil.get_bfq_maxdate(stockno)
        end = currentDay
        print end
        #dbutil.get_qfq_date(stockno,max_qfq_date,end)
        #dbutil.get_day_data(stockno,max_day_date,end)
        dbutil.get_week_data(stockno,max_week_date,end)
        #dbutil.get_month_data(stockno,max_month_date,end)
        #dbutil.get_bfq_data(stockno,max_bfq_date,end)

        #dbutil.get_five_data(stockno,start,end)
        print stockno + str(ssYear)+"success"
        ssYear = ssYear+1

       #取得当前的年月，并按年进行循环，插入数据相关数据

except Exception,e:
    e.message

# coding=utf-8 #首先取出所有股票的代码，然后取得股票的上市时间，根据上市时间按年增加数据，一直进行循环 #通过循环获得股票的基本信息并写入到数据库中，并实现定义好股票的相关基本信息与数据库的字段相对应 #通过循环获取当前股票的最大时间，然后利用最大时间与与当前时间设置差值，进行导入数据 #获得上市时间 #上市日期YYYYMMDD #dbutil.get_qfq_date(stockno,max_qfq_date,end) #dbutil.get_day_data(stockno,max_day_date,end) #dbutil.get_month_data(stockno,max_month_date,end) #dbutil.get_bfq_data(stockno,max_bfq_date,end) #dbutil.get_five_data(stockno,start,end) #取得当前的年月，并按年进行循环，插入数据相关数据