blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Administrator
2022-12-09 954e42723fab626b33f6dbff9246bd235981fe7a 
 server.py


@@ -26,6 +26,7 @@


import ths_industry_util


import ths_util


import tool


import trade_gui


import trade_manager


import l2_code_operate


from code_data_util import ZYLTGBUtil


@@ -49,7 +50,7 @@


    l2_data_error_dict = {}


    last_trade_delegate_data = None


    buy1_volumn_manager = THSBuy1VolumnManager()


    latest_buy1_volumn_dict={}


    latest_buy1_volumn_dict = {}


    buy1_price_manager = Buy1PriceManager()




    def setup(self):


@@ -186,7 +187,6 @@


                        if limit_up_time_manager.get_limit_up_time(d["code"]) is None:


                            limit_up_time_manager.save_limit_up_time(d["code"], d["time"])






                elif type == 3:


                    # 交易成功信息


                    dataList = data_process.parseList(_str)


@@ -197,6 +197,7 @@


                    trade_manager.save_trade_success_data(dataList)




                elif type == 5:


                    logger_trade_delegate.debug("接收到委托信息")


                    # 交易委托信息


                    dataList = data_process.parseList(_str)


                    if self.last_trade_delegate_data != _str:


@@ -208,6 +209,8 @@


                    except Exception as e:


                        logging.exception(e)


                    trade_manager.save_trade_delegate_data(dataList)


                    # 刷新交易界面


                    trade_gui.THSGuiTrade().refresh_data()




                elif type == 4:


                    # 行业代码信息


@@ -242,8 +245,9 @@


                elif type == 50:


                    data = data_process.parse(_str)["data"]


                    if data is not None:


                        print(data)


                        index = data["index"]


                        code_name = data["codeName"]


                        code_name = data["codeName"].replace(" ", "")


                        volumn = data["volumn"]


                        price = data["price"]


                        time_ = data["time"]


@@ -253,12 +257,12 @@


                        code = global_util.name_codes.get(code_name)


                        if code is not None:


                            # 记录日志


                            if self.latest_buy1_volumn_dict.get(code) != "{}-{}".format(volumn,price):


                            if self.latest_buy1_volumn_dict.get(code) != "{}-{}".format(volumn, price):


                                # 记录数据


                                logger_buy_1_volumn_record.info("{}-{}",code,data)


                            self.latest_buy1_volumn_dict[code] = "{}-{}".format(volumn,price)


                                logger_buy_1_volumn_record.info("{}-{}", code, data)


                            self.latest_buy1_volumn_dict[code] = "{}-{}".format(volumn, price)


                            # 保存买1价格


                            self.buy1_price_manager.save(code,price)


                            self.buy1_price_manager.save(code, price)


                            # 校正时间


                            time_ = tool.compute_buy1_real_time(time_)


                            # 保存数据