From 59fba698b03a51a8da5b56a919ebbf94d4784f74 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 06 一月 2023 15:06:27 +0800
Subject: [PATCH] 买入策略修改
---
code_data_util.py | 37 +++++++++++++++++++++++++++++++++++++
1 files changed, 37 insertions(+), 0 deletions(-)
diff --git a/code_data_util.py b/code_data_util.py
index 1387f1d..2821c4a 100644
--- a/code_data_util.py
+++ b/code_data_util.py
@@ -3,10 +3,26 @@
"""
# 鑲＄エ浠ｇ爜鐩稿叧鐨勫弬鏁�
+import decimal
+import time
+
+import gpcode_manager
+import mysql_data
import redis_manager
+import tool
_redisManager = redis_manager.RedisManager(0)
+
+# 浠ｇ爜瀵瑰簲鐨勪环鏍兼槸鍚︽纭�
+def is_same_code_with_price(code, price):
+ # 鏄ㄦ棩鏀剁洏浠�
+ price_close = gpcode_manager.get_price_pre(code)
+ max_price = tool.to_price(decimal.Decimal(str(price_close)) * decimal.Decimal("1.1"))
+ min_price = tool.to_price(decimal.Decimal(str(price_close)) * decimal.Decimal("0.9"))
+ if min_price <= decimal.Decimal(str(price)) <= max_price:
+ return True
+ return False
# 鑷敱娴侀�氳偂鏈伐鍏风被
class ZYLTGBUtil:
@@ -24,3 +40,24 @@
if val is not None:
return int(val)
return None
+
+ @classmethod
+ def save_list(self, datasList):
+ # 淇濆瓨鑷敱娴侀�氬競鍊�
+ mysqldb = mysql_data.Mysqldb()
+ for data in datasList:
+ # 淇濆瓨
+ _dict = {"_id": data["code"], "zyltgb": data["zyltgb"], "zyltgb_unit": data["zyltgb_unit"],
+ "update_time": int(round(time.time() * 1000))}
+ if float(data["zyltgb"]) > 0:
+ # 淇濆瓨10澶�
+ ZYLTGBUtil.save(data["code"], data["zyltgb"], data["zyltgb_unit"])
+ result = mysqldb.select_one("select * from ths_zylt where _id='{}'".format(data["code"]))
+ if result is None:
+ mysqldb.execute(
+ "insert into ths_zylt(_id,zyltgb,zyltgb_unit,update_time) values ('{}','{}',{},{})".format(
+ data["code"], data["zyltgb"], data["zyltgb_unit"], round(time.time() * 1000)))
+ else:
+ mysqldb.execute(
+ "update ths_zylt set zyltgb='{}',zyltgb_unit={},update_time={} where _id='{}'".format(
+ data["zyltgb"], data["zyltgb_unit"], round(time.time() * 1000), data["code"]))
--
Gitblit v1.8.0