From 12cceec509057e006fe85e18db6efccfd2c8cd1f Mon Sep 17 00:00:00 2001
From: laixingyu <xingyu.lai@suwell.cn>
Date: Sat, 12 Aug 2023 19:07:12 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0=E5=90=8C=E6=AD=A5?=
 =?UTF-8?q?=E5=85=B6=E4=BB=96=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 transAllData.py               |  4 ++
 transferOhterRyData_python.py | 85 +++++++++++++++++++++++++++++++++++
 2 files changed, 89 insertions(+)
 create mode 100644 transferOhterRyData_python.py

diff --git a/transAllData.py b/transAllData.py
index a5f0347..126dd52 100644
--- a/transAllData.py
+++ b/transAllData.py
@@ -2,6 +2,7 @@ import transferIndustrySatistics_python as tis
 import transferData_python as td
 import transferIndustryData_python as tid
 import transferNewrecordData_python as tnd
+import transferOhterRyData_python as trd
 import pymysql
 
 def main() :
@@ -33,6 +34,9 @@ def main() :
 
         trade_date = '2023-08-09'
 
+        #传输ry库其他数据
+        trd.toTransRyOhterData(db_a_conn,db_a_cursor,db_b_conn,db_b_cursor,trade_date)
+
         #转换数据
         td.toTransData(db_a_conn,db_a_cursor,db_b_conn,db_b_cursor,trade_date)
 
diff --git a/transferOhterRyData_python.py b/transferOhterRyData_python.py
new file mode 100644
index 0000000..04c2059
--- /dev/null
+++ b/transferOhterRyData_python.py
@@ -0,0 +1,85 @@
+import pymysql
+
+#a ry库  b是mojn库
+def toTransStockBasis(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    # 连接数据库A  ry库
+    db_a_conn = db_conn_a
+    db_ry_cursor = dbcursor_a
+    # 连接数据库B  mojin库
+    db_b_conn = db_conn_b
+    db_mojin_cursor = dbcursor_b
+
+    trans_date = trade_date
+
+    mojin_stock_basic_map = {}
+
+    #查询mojn库中的basis数据
+    sql_qurey = 'select code,name,blemind2,blemind3 from stock_basis'
+    db_mojin_cursor.execute(sql_qurey)
+    basisDatas = db_mojin_cursor.fetchall()
+    for row in basisDatas:
+        code,name,blemind2,blemind3 = row
+        mojin_stock_basic_map[code] = (code,name,blemind2,blemind3)
+    
+    #查询ry库中的基础数据
+    sql_qurey = 'select code,name,blemind2,blemind3 from stock_basis'
+    db_ry_cursor.execute(sql_qurey)
+    basisDatas = db_ry_cursor.fetchall()
+    hasInsertData =  False
+    for row in basisDatas:
+        code,name,blemind2,blemind3 = row
+        if code in mojin_stock_basic_map:
+            if mojin_stock_basic_map[code][1] == name:
+                sql_insert = 'update stock_basis set name = %s where code = %s'
+                db_mojin_cursor.execute(sql_insert, (name,code))
+                hasInsertData = True
+            else:
+                continue
+        else:
+            sql_insert = f"INSERT INTO stock_basis (code,name,blemind2,blemind3) VALUES ( %s, %s, %s, %s)"
+            db_mojin_cursor.execute(sql_insert, (code,name,blemind2,blemind3))
+            hasInsertData = True
+    if hasInsertData:
+        db_mojin_cursor.commit()
+    
+    print('successed transfer stockBasis  ',trans_date , ' data.' )
+    print('\r\n')
+
+def toTransStockFinancial(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStockIndex(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocks(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocksInTrend(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocksLimit(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocksLimitUp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocksNewRecord(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransStocksTmp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransTrends(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    return True
+
+def toTransRyOhterData(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date):
+    toTransStockBasis(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStockFinancial(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStockIndex(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocks(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocksInTrend(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocksLimit(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocksLimitUp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocksNewRecord(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransStocksTmp(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
+    toTransTrends(db_conn_a,dbcursor_a,db_conn_b,dbcursor_b,trade_date)
\ No newline at end of file