| | |
| | | __jingxuan_cache_dict = {} |
| | | __industry_cache_dict = {} |
| | | |
| | | |
| | | def __get_limit_up_list(self): |
| | | # 统计目前为止的代码涨停数量(分涨停原因) |
| | | total_datas = KPLLimitUpDataRecordManager.total_datas |
| | |
| | | for code_info in codes_info: |
| | | code_info[4] = 1 if code_info[0] in want_codes else 0 |
| | | # 获取代码状态 |
| | | if trade_manager.CodesTradeStateManager().get_trade_state_cache(code_info[0]) != trade_manager.TRADE_STATE_NOT_TRADE: |
| | | if trade_manager.CodesTradeStateManager().get_trade_state_cache( |
| | | code_info[0]) != trade_manager.TRADE_STATE_NOT_TRADE: |
| | | code_info[5] = 1 |
| | | |
| | | response_data = json.dumps({"code": 0, "data": codes_info}) |
| | |
| | | self.__send_response(result_str) |
| | | |
| | | def __process_kpl_data(self, data): |
| | | def do_limit_up(result_list): |
| | | if result_list: |
| | | # 保存涨停时间 |
| | | for d in result_list: |
| | | code = d[0] |
| | | if code.find("00") == 0 or code.find("60") == 0: |
| | | limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2])) |
| | | code_price_manager.Buy1PriceManager().set_limit_up_time(code, limit_up_time) |
| | | kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list) |
| | | self.__kplDataManager.save_data(type_, result_list) |
| | | |
| | | type_ = data["type"] |
| | | print("开盘啦type:", type_) |
| | | if type_ == KPLDataType.BIDDING.value: |
| | |
| | | self.__kplDataManager.save_data(type_, result_list) |
| | | elif type_ == KPLDataType.LIMIT_UP.value: |
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP) |
| | | if result_list: |
| | | # 保存涨停时间 |
| | | for d in result_list: |
| | | code = d[0] |
| | | if code.find("00") == 0 or code.find("60") == 0: |
| | | limit_up_time = time.strftime("%H:%M:%S", time.localtime(d[2])) |
| | | code_price_manager.Buy1PriceManager().set_limit_up_time(code, limit_up_time) |
| | | self.__kplDataManager.save_data(type_, result_list) |
| | | kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list) |
| | | do_limit_up(result_list) |
| | | |
| | | elif type_ == KPLDataType.OPEN_LIMIT_UP.value: |
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP) |
| | | if result_list: |