| | |
|---|
| | | sell_1_price, sell_1_volume // 100) |
|---|
| | | pre_close_price = round(float(limit_up_price) / 1.1, 2) |
|---|
| | | # 如果涨幅大于7%就读取板块 |
|---|
| | | if (buy_1_price - pre_close_price) / pre_close_price > 0.07: |
|---|
| | | if not self.__KPLCodeJXBlockManager.get_jx_blocks(code): |
|---|
| | | price_rate = (buy_1_price - pre_close_price) / pre_close_price |
|---|
| | | if price_rate > 0.07: |
|---|
| | | if not self.__KPLCodeJXBlockManager.get_jx_blocks_cache(code): |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | self.__KPLCodeJXBlockManager.save_jx_blocks(code, blocks) |
|---|
| | | elif price_rate > 0.03: |
|---|
| | | # 添加备用板块 |
|---|
| | | if not self.__KPLCodeJXBlockManager.get_jx_blocks_cache(code, by=True): |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | self.__KPLCodeJXBlockManager.save_jx_blocks(code, blocks, by=True) |
|---|
| | | |
|---|
| | | # 更新板块信息 |
|---|
| | | yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() |
|---|
| | | CodePlateKeyBuyManager.update_can_buy_blocks(code, |
|---|
| | |
|---|
| | | continue |
|---|
| | | if d["sec_level"] != 1: |
|---|
| | | continue |
|---|
| | | if d["pre_close"] * 1.1 > constant.MAX_CODE_PRICE: |
|---|
| | | if d["pre_close"] * 1.1 > constant.MAX_SUBSCRIPT_CODE_PRICE: |
|---|
| | | continue |
|---|
| | | if (d["listed_date"] + datetime.timedelta( |
|---|
| | | days=100)).timestamp() > datetime.datetime.now().timestamp(): |
|---|
| | |
|---|
| | | code = data["code"] |
|---|
| | | order_no = data["data"] |
|---|
| | | hx_logger_l2_upload.info(f"{code}-正在成交的订单撤单，order_no:{order_no}") |
|---|
| | | # buyno_map = l2_data_util.local_today_buyno_map.get(code) |
|---|
| | | # if buyno_map: |
|---|
| | | # l2_data = buyno_map.get(order_no) |
|---|
| | | # buyno_map.get(order_no) |
|---|
| | | # 执行撤单 |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "G撤撤单", "G撤") |
|---|
| | | else: |
|---|
| | |
|---|
| | | memory_info = psutil.virtual_memory() |
|---|
| | | cpu_percent = psutil.cpu_percent(interval=1) |
|---|
| | | fdata["device"] = {"cpu": cpu_percent, "memery": memory_info.percent} |
|---|
| | | # 获取交易通道 |
|---|
| | | try: |
|---|
| | | can_access = huaxin_trade_api.test_trade_channel() |
|---|
| | | fdata["trade_channel_access"] = 1 if can_access else 0 |
|---|
| | | except: |
|---|
| | | fdata["trade_channel_access"] = 0 |
|---|
| | | |
|---|
| | | result = {"code": 0, "data": fdata, "msg": ""} |
|---|
| | | print("OnGetEnvInfo 成功") |
|---|
| | | self.send_response(result, client_id, request_id) |
|---|
