From 9dede2eaa1d3e68be387c5fd612eb48226a54c9d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 04 八月 2023 16:07:22 +0800
Subject: [PATCH] HOST修改
---
kpl/gui.py | 106 +++++++++++++++++++++++++++++++++-------------------
1 files changed, 67 insertions(+), 39 deletions(-)
diff --git a/kpl/gui.py b/kpl/gui.py
index a5ff6bd..503641f 100644
--- a/kpl/gui.py
+++ b/kpl/gui.py
@@ -169,6 +169,9 @@
t1.setDaemon(True)
t1.start()
+ # 鑷姩寮�鍚噰闆�
+ self.__start_all_task(None)
+
def run_schedule(self):
while True:
schedule.run_pending()
@@ -212,54 +215,72 @@
def __exec_limit_up(self):
if not self.__can_capture(0):
return
- results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_UP)
- result = json.loads(results)
- self.logger.info(f"娑ㄥ仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
- self.__upload_data(self.keys[0], result)
+ try:
+ results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_UP)
+ result = json.loads(results)
+ self.logger.info(f"娑ㄥ仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
+ self.__upload_data(self.keys[0], result)
+ except:
+ pass
def __exec_open_limit_up(self):
if not self.__can_capture(1):
return
- results = kpl_api.daBanList(kpl_api.DABAN_TYPE_OPEN_LIMIT_UP)
- result = json.loads(results)
- self.logger.info(f"鐐告澘浠ｇ爜鏁伴噺锛歿len(result['list'])}")
- self.__upload_data(self.keys[1], result)
+ try:
+ results = kpl_api.daBanList(kpl_api.DABAN_TYPE_OPEN_LIMIT_UP)
+ result = json.loads(results)
+ self.logger.info(f"鐐告澘浠ｇ爜鏁伴噺锛歿len(result['list'])}")
+ self.__upload_data(self.keys[1], result)
+ except:
+ pass
def __exec_limit_down(self):
if not self.__can_capture(2):
return
- results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_DOWN)
- result = json.loads(results)
- self.logger.info(f"璺屽仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
- self.__upload_data(self.keys[2], result)
+ try:
+ results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_DOWN)
+ result = json.loads(results)
+ self.logger.info(f"璺屽仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
+ self.__upload_data(self.keys[2], result)
+ except:
+ pass
def __exec_ever_limit_down(self):
if not self.__can_capture(3):
return
- results = kpl_api.daBanList(kpl_api.DABAN_TYPE_EVER_LIMIT_DOWN)
- result = json.loads(results)
- self.logger.info(f"鏇剧粡璺屽仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
- self.__upload_data(self.keys[3], result)
+ try:
+ results = kpl_api.daBanList(kpl_api.DABAN_TYPE_EVER_LIMIT_DOWN)
+ result = json.loads(results)
+ self.logger.info(f"鏇剧粡璺屽仠浠ｇ爜鏁伴噺锛歿len(result['list'])}")
+ self.__upload_data(self.keys[3], result)
+ except:
+ pass
def __exec_fengkou(self):
if not self.__can_capture(4):
return
- results = kpl_api.getFengKouList(tool.get_now_date_str())
- result = json.loads(results)
- self.logger.info(f"甯傚満椋庡彛浠ｇ爜鏁伴噺锛歿len(result['List'])}")
- self.__upload_data(self.keys[4], result)
+ try:
+ results = kpl_api.getFengKouList(tool.get_now_date_str())
+ result = json.loads(results)
+ self.logger.info(f"甯傚満椋庡彛浠ｇ爜鏁伴噺锛歿len(result['List'])}")
+ self.__upload_data(self.keys[4], result)
+ except:
+ pass
def __exec_fengkou_best(self):
- if not self.__can_capture(5):
- return
- if not os.path.exists("D:/kpl/GetFengKListBest_0_0.log"):
- return
- with open("D:/kpl/GetFengKListBest_0_0.log", mode='r', encoding="utf-16") as f:
- lines = f.readlines()
- if lines:
- data = json.loads(lines[0])
- self.logger.info(f"鏈�寮洪鍙ｄ唬鐮佹暟閲忥細{data['Count']}")
- self.__upload_data(self.keys[5], data)
+ try:
+ if not self.__can_capture(5):
+ return
+ if not os.path.exists("D:/kpl/GetFengKListBest_0_0.log"):
+ return
+ with open("D:/kpl/GetFengKListBest_0_0.log", mode='r', encoding="utf-16") as f:
+ lines = f.readlines()
+ if lines:
+ data = json.loads(lines[0])
+ self.logger.info(f"鏈�寮洪鍙ｄ唬鐮佹暟閲忥細{data['Count']}")
+ self.__upload_data(self.keys[5], data)
+ except:
+ pass
def __exec_fengxiang(self):
if not self.__can_capture(6):
@@ -276,18 +297,25 @@
def __exec_industry_rank(self):
if not self.__can_capture(7):
return
- results = kpl_api.getMarketIndustryRealRankingInfo()
- result = json.loads(results)
- self.logger.info(f"琛屼笟娑ㄥ箙鎺掕浠ｇ爜鏁伴噺锛歿len(result['list'])}")
- self.__upload_data(self.keys[7], result)
+ try:
+ results = kpl_api.getMarketIndustryRealRankingInfo()
+ result = json.loads(results)
+ self.logger.info(f"琛屼笟娑ㄥ箙鎺掕浠ｇ爜鏁伴噺锛歿len(result['list'])}")
+ self.__upload_data(self.keys[7], result)
+ except:
+ pass
def __exec_jingxuan_rank(self):
if not self.__can_capture(8):
return
- results = kpl_api.getMarketJingXuanRealRankingInfo()
- result = json.loads(results)
- self.logger.info(f"绮鹃�夋祦鍏ユ帓琛屼唬鐮佹暟閲忥細{len(result['list'])}")
- self.__upload_data(self.keys[8], result)
+ try:
+ results = kpl_api.getMarketJingXuanRealRankingInfo()
+ result = json.loads(results)
+ self.logger.info(f"绮鹃�夋祦鍏ユ帓琛屼唬鐮佹暟閲忥細{len(result['list'])}")
+ self.__upload_data(self.keys[8], result)
+ except:
+ pass
+
# 寮�濮嬫墍鏈夌殑浠诲姟
def __start_all_task(self, event):
@@ -309,7 +337,7 @@
"type": type,
"data": datas
}
- requests.post("http://111.230.16.67:9004/upload_kpl_data", json.dumps(root_data))
+ requests.post("http://43.138.167.68:9004/upload_kpl_data", json.dumps(root_data))
def OnExit(self, e):
sys.exit(0)
--
Gitblit v1.8.0