| | |
|---|
| | | result = mysqldb.select_one("select * from kpl_limit_up_record where _id='{}'".format(_id)) |
|---|
| | | if not result: |
|---|
| | | mysqldb.execute( |
|---|
| | | f"insert into kpl_limit_up_record(_id,_day,_hot_block_name,_code,_code_name,_limit_up_time,_blocks,_latest_limit_up_time,_update_time,_create_time,_hot_block_code_count,_limit_up_high_info,_zylt_val) values('{_id}','{day}','{d[5]}','{d[0]}','{d[1]}','{d[2]}','{d[6]}','{d[3]}',now(),now(),{d[10]},'{d[4]}',{d[7]})") |
|---|
| | | f"insert into kpl_limit_up_record(_id,_day,_hot_block_name,_code,_code_name,_limit_up_time,_blocks,_latest_limit_up_time,_update_time,_create_time,_hot_block_code_count,_limit_up_high_info,_zylt_val,_hot_block_code) values('{_id}','{day}','{d[5]}','{d[0]}','{d[1]}','{d[2]}','{d[6]}','{d[3]}',now(),now(),{d[10]},'{d[4]}',{d[7]},{d[9]})") |
|---|
| | | cls.__load_hist_and_blocks(code) |
|---|
| | | else: |
|---|
| | | if _id in cls.latest_datas and json.dumps(cls.latest_datas.get(_id)) != json.dumps(d): |
|---|
| | |
|---|
| | | @classmethod |
|---|
| | | def load_total_datas(cls): |
|---|
| | | cls.total_datas = KPLLimitUpDataRecordManager.list_all(tool.get_now_date_str()) |
|---|
| | | LimitUpDataConstant.set_history_limit_up_datas(cls.total_datas) |
|---|
| | | cls.__LimitUpCodesPlateKeyManager.set_today_total_limit_up( |
|---|
| | | [(r[3], r[2], r[6].split("、") if r[6] else []) for r in cls.total_datas]) |
|---|
| | | for d in cls.total_datas: |
|---|
