__author__ = 'weijie' from EmQuantAPI import * from datetime import timedelta, datetime import time import traceback import json from StockRestPojo import StockRestPojo from dbOperation import dbOperation # from dbOperationStock import dbOperationStock from threading import Thread import db_config def csqCallback(quantdata): # serialID = quantdata.SerialID # 设置线程序列号，标识正在抓取数据中 restData = quantdata.Data print(restData) db = dbOperation(db_config.db_gupiao) sql = 'insert into t_csq_data(`data_content`, `status`) values("' + str(restData) + '", 0);' # print(sql) db.insert(sql) db.close() # print ("csqCallback,", str(quantdata)) # db = dbOperation(db_config.db_gupiao) # for key,value in restData.items(): # if "None".strip() == str(value[0]).strip(): # print("无效数据跳过") # break # else: # # db.update("update t_stock_base_info set seralid = '"+str(serialID)+"' where code = '" + str(key) + "'") # stockRestPojo = StockRestPojo() # stockRestPojo.date = str(value[0]) # stockRestPojo.time = str(value[1]) # stockRestPojo.now = str(value[2]) # stockRestPojo.high = str(value[3]) # stockRestPojo.low = str(value[4]) # stockRestPojo.open = str(value[5]) # stockRestPojo.preclose = str(value[6]) # stockRestPojo.roundlot = str(value[7]) # stockRestPojo.change = str(value[8]) # stockRestPojo.pctchange = str(value[9]) # stockRestPojo.volume = str(value[10]) # stockRestPojo.amount = str(value[11]) # stockRestPojo.volumeratio = str(value[12]) # stockRestPojo.commissionratio = str(value[13]) # stockRestPojo.commissiondiff = str(value[14]) # stockRestPojo.tradestatus = str(value[15]) # stockRestPojo.outvolume = str(value[16]) # stockRestPojo.involume = str(value[17]) # stockRestPojo.highlimit = str(value[18]) # stockRestPojo.lowlimit = str(value[19]) # stockRestPojo.speed = str(value[20]) # stockRestPojo.averageprice = str(value[21]) # stockRestPojo.buyprice1 = str(value[22]) # stockRestPojo.buyprice2 = str(value[23]) # stockRestPojo.buyprice3 = str(value[24]) # stockRestPojo.buyprice4 = str(value[25]) # stockRestPojo.buyprice5 = str(value[26]) # stockRestPojo.buyvolume1 = str(value[27]) # stockRestPojo.buyvolume2 = str(value[28]) # stockRestPojo.buyvolume3 = str(value[29]) # stockRestPojo.buyvolume4 = str(value[30]) # stockRestPojo.buyvolume5 = str(value[31]) # stockRestPojo.sellprice1 = str(value[32]) # stockRestPojo.sellprice2 = str(value[33]) # stockRestPojo.sellprice3 = str(value[34]) # stockRestPojo.sellprice4 = str(value[35]) # stockRestPojo.sellprice5 = str(value[36]) # stockRestPojo.sellvolume1 = str(value[37]) # stockRestPojo.sellvolume2 = str(value[38]) # stockRestPojo.sellvolume3 = str(value[39]) # stockRestPojo.sellvolume4 = str(value[40]) # stockRestPojo.sellvolume5 = str(value[41]) # stockRestPojo.closedtime = str(value[42]) # stockRestPojo.closedvolume = str(value[43]) # stockRestPojo.closedamount = str(value[44]) # datTime = time.mktime(time.strptime(str(value[0]) + str(value[1]), "%Y%m%d%H%M%S")) # stockRestPojo.realTime = str(int(datTime)) # stockRestPojo.dateOne = "0" # stockRestPojo.dateFive = "0" # stockRestPojo.dateFifteen = "0" # stockRestPojo.dateThirty = "0" # stockRestPojo.dateSixty = "0" # sql = "insert into data_rt_" + str(key.replace(".", "_").lower()) + "(`realTime`,`date`,`time`,`now`,`high`,`low`,`open`,`preclose`,`roundlot`,`change`,`pctchange`,`volume`,`amount`,`volumeratio`,`commissionratio`,`commissiondiff`,`tradestatus`,`outvolume`,`involume`,`highlimit`,`lowlimit`,`speed`,`averageprice`,`buyprice1`,`buyprice2`,`buyprice3`,`buyprice4`,`buyprice5`,`buyvolume1`,`buyvolume2`,`buyvolume3`,`buyvolume4`,`buyvolume5`,`sellprice1`,`sellprice2`,`sellprice3`,`sellprice4`,`sellprice5`,`sellvolume1`,`sellvolume2`,`sellvolume3`,`sellvolume4`,`sellvolume5`,`closedtime`,`closedvolume`,`closedamount`,`dateOne`,`dateFive`,`dateFifteen`,`dateThirty`,`dateSixty`,`addTime`) values('" + str(stockRestPojo.realTime) + "','" + str(stockRestPojo.date) + "','" + str(stockRestPojo.time) + "','" + str(stockRestPojo.now) + "','" + str(stockRestPojo.high) + "','" + str(stockRestPojo.low) + "','" + str(stockRestPojo.open) + "','" + str(stockRestPojo.preclose) + "','" + str(stockRestPojo.roundlot) + "','" + str(stockRestPojo.change) + "','" + str(stockRestPojo.pctchange) + "','" + str(stockRestPojo.volume) + "','" + str(stockRestPojo.amount) + "','" + str(stockRestPojo.volumeratio) + "','" + str(stockRestPojo.commissionratio) + "','" + str(stockRestPojo.commissiondiff) + "','" + str(stockRestPojo.tradestatus) + "','" + str(stockRestPojo.outvolume) + "','" + str(stockRestPojo.involume) + "','" + str(stockRestPojo.highlimit) + "','" + str(stockRestPojo.lowlimit) + "','" + str(stockRestPojo.speed) + "','" + str(stockRestPojo.averageprice) + "','" + str(stockRestPojo.buyprice1) + "','" + str(stockRestPojo.buyprice2) + "','" + str(stockRestPojo.buyprice3) + "','" + str(stockRestPojo.buyprice4) + "','" + str(stockRestPojo.buyprice5) + "','" + str(stockRestPojo.buyvolume1) + "','" + str(stockRestPojo.buyvolume2) + "','" + str(stockRestPojo.buyvolume3) + "','" + str(stockRestPojo.buyvolume4) + "','" + str(stockRestPojo.buyvolume5) + "','" + str(stockRestPojo.sellprice1) + "','" + str(stockRestPojo.sellprice2) + "','" + str(stockRestPojo.sellprice3) + "','" + str(stockRestPojo.sellprice4) + "','" + str(stockRestPojo.sellprice5) + "','" + str(stockRestPojo.sellvolume1) + "','" + str(stockRestPojo.sellvolume2) + "','" + str(stockRestPojo.sellvolume3) + "','" + str(stockRestPojo.sellvolume4) + "','" + str(stockRestPojo.sellvolume5) + "','" + str(stockRestPojo.closedtime) + "','" + str(stockRestPojo.closedvolume) + "','" + str(stockRestPojo.closedamount) + "','" + str(stockRestPojo.dateOne) + "','" + str(stockRestPojo.dateFive) + "','" + str(stockRestPojo.dateFifteen) + "','" + str(stockRestPojo.dateThirty) + "','" + str(stockRestPojo.dateSixty) +"', now());" # db.insert(sql) # # if stockRestPojo.now != 0: # # stockRestData = StockRestData() # # stockRestData.updateStockInfo(key, stockRestPojo) # db.close() class StockRestData: def toGet(self): try: db = dbOperation(db_config.db_gupiao) stockPojoList = db.query_list("select id, code, name, list_date listDate, seralid from t_stock_base_info where is_rest_add = 0 order by id asc") # 拼接证券代码 codesStr = "" i = 1 for stockPojo in stockPojoList: if 0 != i%500 : codesStr = codesStr + stockPojo['code'] + ',' if 0 == i%500 or str(i) == str(len(stockPojoList)): if(codesStr != ""): #实时行情订阅使用范例 codesStr = codesStr[:-1] data = c.csq(codesStr, 'date,time,now,high,low,open,preclose,roundlot,change,pctchange,volume,amount,volumeratio,commissionratio,commissiondiff,tradestatus,outvolume,involume,highlimit,lowlimit,speed,averageprice,buyprice1,buyprice2,buyprice3,buyprice4,buyprice5,buyvolume1,buyvolume2,buyvolume3,buyvolume4,buyvolume5,sellprice1,sellprice2,sellprice3,sellprice4,sellprice5,sellvolume1,sellvolume2,sellvolume3,sellvolume4,sellvolume5,closedtime,closedvolume,closedamount','Pushtype=2',csqCallback) print(data) codesStr = "" i = i + 1 # db.close() text = input("press any key to cancel csq \r\n") except Exception as ee: print("error >>>",ee) traceback.print_exc() else: print("demo end") # def updateStockInfo(self, code, stockRestPojo): # db = dbOperationStock(db_config.db_stock) # sql = "update stock set `now` = '" + str(stockRestPojo.now) + "', `change` = '" + str(stockRestPojo.change) + "', `pct_change` = '" + str(stockRestPojo.pctchange) + "' where stock_code = '" + str(code) + "'" # db.update(sql) # db.close()