blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Administrator
2023-06-25 4bd794d517a60ecd91dda4cb8236453582180649 
 server.py


@@ -24,7 +24,7 @@


import init


from l2 import l2_data_manager_new, l2_data_manager, l2_data_log, l2_log, code_price_manager


import l2_data_util


from l2.cancel_buy_strategy import HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil


from l2.cancel_buy_strategy import HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil, LCancelBigNumComputer


import l2.l2_data_util




import ths_industry_util


@@ -290,7 +290,8 @@


                                        codes.append(code)


                                        dataList.append(item)


                                        # 保存自由流通股本


                                        zyltgb_list.append({"code": code, "zyltgb": item["zyltgb"],"zyltgb_unit": item["zyltgbUnit"]})


                                        zyltgb_list.append(


                                            {"code": code, "zyltgb": item["zyltgb"], "zyltgb_unit": item["zyltgbUnit"]})


                                    else:


                                        # 获取涨停价


                                        _limit_up_price = gpcode_manager.get_limit_up_price(code)


@@ -379,7 +380,8 @@


                                                                     volumes_data)


                        gpcode_manager.FirstCodeManager.add_record(codes)


                        if new_add_codes:


                            gpcode_manager.set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes,fields = "symbol,sec_name,sec_type,sec_level"))


                            gpcode_manager.set_first_gp_codes_with_data(HistoryKDatasUtils.get_gp_latest_info(codes,


                                                                                                              fields="symbol,sec_name,sec_type,sec_level"))


                            # 加入首板历史记录




                            logger_first_code_record.info("新增首板：{}", new_add_codes)


@@ -593,6 +595,10 @@


                                                                                            code),


                                                                                        l2.l2_data_util.local_today_num_operate_map.get(


                                                                                            code))


                                            LCancelBigNumComputer.set_trade_progress(code, buy_progress_index,


                                                                                     l2.l2_data_util.local_today_datas.get(


                                                                                         code))




                                            logger_l2_trade_buy_queue.info("获取成交位置成功： code-{} index-{}  数据-{}", code,


                                                                           buy_progress_index,


                                                                           json.dumps(buy_queue_result_list))


@@ -1124,7 +1130,7 @@


            volumes_data = volumes_data[1:]


            volumes = init.parse_max_volume(volumes_data[:60],


                                            code_nature_analyse.is_new_top(limit_up_price,


                                                                             volumes_data[:60]))


                                                                           volumes_data[:60]))


            logger_first_code_record.info("{} 获取到首板60天最大量：{}", code, volumes)


            code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2])


            # 判断K线形态