异常保护

Administrator

4 天以前 48fb7a00951f91bdc707e5dd2d196e5bccb752c3

 servers/data_server.py

@@ -10,6 +10,7 @@

import constant
import inited_data
from api import low_suction_data_pusher
from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager
from l2.huaxin import huaxin_target_codes_manager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
@@ -1024,7 +1025,17 @@
                            logger_debug.exception(e)
                            deal_big_order_info = None
                        code_name = gpcode_manager.get_code_name(code)
                        fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info))

                        big_order_enough = 0
                        try:
                            total_deal_big_order_result = radical_buy_data_manager.get_total_deal_big_order_info(code,
                                                                                        gpcode_manager.get_limit_up_price_as_num(
                                                                                            code))
                            if total_deal_big_order_result and total_deal_big_order_result[0]<=0:
                                big_order_enough = 1
                        except:
                            pass
                        fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough))
                response_data = json.dumps({"code": 0, "data": fresults})
            except Exception as e:
                response_data = json.dumps({"code": 1, "data": str(1)})
@@ -1207,6 +1218,13 @@
                                    lambda: request_new_blocks_codes(update_new_block_plates, new_block_codes.keys()))
                    except Exception as e:
                        logger_debug.exception(e)

                    # 将数据推送至其他项目
                    try:
                        low_suction_data_pusher.push_limit_up_list(result_list_)
                    except:
                        pass

                    self.__kplDataManager.save_data(type_, result_list_)
            except Exception as e:
                logger_debug.exception(e)