| | |
|---|
| | | __kplPlatManager = KPLPlatManager() |
|---|
| | | __LimitUpCodesPlateKeyManager = LimitUpCodesPlateKeyManager() |
|---|
| | | __CodesPlateKeysManager = CodesHisReasonAndBlocksManager() |
|---|
| | | __current_code_reason_dict = {} |
|---|
| | | __current_code_reasons_dict = {} |
|---|
| | | __current_reason_codes_dict = {} |
|---|
| | | __records_cache = {} |
|---|
| | | |
|---|
| | |
|---|
| | | cls.latest_origin_datas = records |
|---|
| | | cls.__LimitUpCodesPlateKeyManager.set_today_limit_up([(r[0], r[5]) for r in records]) |
|---|
| | | |
|---|
| | | code_reason_dict = {} |
|---|
| | | reason_code_dict = {} |
|---|
| | | code_reasons_dict = {} |
|---|
| | | reason_codes_dict = {} |
|---|
| | | for d in records: |
|---|
| | | code_reason_dict[d[0]] = d[5] |
|---|
| | | if d[5] not in reason_code_dict: |
|---|
| | | reason_code_dict[d[5]] = set() |
|---|
| | | reason_code_dict[d[5]].add(d[0]) |
|---|
| | | cls.__current_code_reason_dict = code_reason_dict |
|---|
| | | cls.__current_reason_codes_dict = reason_code_dict |
|---|
| | | # 涨停原因 + 推荐原因 |
|---|
| | | bs = {d[5]} |
|---|
| | | if d[6]: |
|---|
| | | bs |= set(d[6].split("、")) |
|---|
| | | code_reasons_dict[d[0]] = bs |
|---|
| | | for b in bs: |
|---|
| | | if b not in reason_codes_dict: |
|---|
| | | reason_codes_dict[b] = set() |
|---|
| | | reason_codes_dict[b].add(d[0]) |
|---|
| | | cls.__current_code_reasons_dict = code_reasons_dict |
|---|
| | | cls.__current_reason_codes_dict = reason_codes_dict |
|---|
| | | |
|---|
| | | # 涨停数据记录 |
|---|
| | | mysqldb = mysql_data.Mysqldb() |
|---|
| | |
|---|
| | | return bs |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def get_current_block(cls, code): |
|---|
| | | return cls.__current_code_reason_dict.get(code) |
|---|
| | | def get_current_blocks(cls, code): |
|---|
| | | return cls.__current_code_reasons_dict.get(code) |
|---|
| | | |
|---|
| | | @classmethod |
|---|
| | | def get_current_codes_by_block(cls, block): |
|---|
| | |
|---|
| | | requests.post("http://127.0.0.1:9004/upload_kpl_data", json.dumps(root_data)) |
|---|
| | | |
|---|
| | | def get_limit_up(): |
|---|
| | | last_time = 0 |
|---|
| | | while True: |
|---|
| | | if tool.is_trade_time(): |
|---|
| | | if tool.is_trade_time() and int(tool.get_now_time_str().replace(':', '')) > int("092530"): |
|---|
| | | try: |
|---|
| | | results = kpl_api.getLimitUpInfo() |
|---|
| | | results = kpl_api.getLimitUpInfoNew() |
|---|
| | | result = json.loads(results) |
|---|
| | | start_time = time.time() |
|---|
| | | __upload_data("limit_up", result) |
|---|
| | | if start_time - last_time >= 60: |
|---|
| | | last_time = time.time() |
|---|
| | | # 记录涨停数据 |
|---|
| | | logger_kpl_limit_up.info(result) |
|---|
| | | # logger_kpl_limit_up_reason_change.info("上传耗时：{}", time.time() - start_time) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | time.sleep(3) |
|---|
| | |
|---|
| | | time.sleep(3) |
|---|
| | | |
|---|
| | | threading.Thread(target=get_limit_up, daemon=True).start() |
|---|
| | | threading.Thread(target=get_bidding_money, daemon=True).start() |
|---|
| | | # threading.Thread(target=get_bidding_money, daemon=True).start() |
|---|
| | | # threading.Thread(target=get_market_industry, daemon=True).start() |
|---|
| | | # threading.Thread(target=get_market_jingxuan, daemon=True).start() |
|---|
| | | |
|---|
