MOD:修改数据库

app/etl/src/src_book_info.py

@@ -11,11 +11,13 @@ ck = CkUtils()
 def src_book_info():
     logging.info('书籍卡点信息,开始')
     logging.info("run> src_book_info")
-    sql = """SELECT  date_format(a.effect_day,'%Y-%m-%d'),
+    sql = """
+            SELECT  date_format(a.effect_day,'%Y-%m-%d'),
             case a.type when 'mp' then 'MP' when 'gdt' then 'GDT' end type,
-            b.book_name,c.platform_name,a.node_price from t_platform_book_ratio a 
-            left join  t_platform_book b on a.platform_book_id=b.id 
-            left join t_platform_novel c on b.platform_id=c.id  order by a.effect_day"""
+            b.book_name,c.platform_name,a.node_price from zx_platform.t_zx_book_ratio a 
+            left join zx_platform.t_zx_book b on a.zx_book_id=b.id 
+            left join zx_platform.t_platform_info c on b.platform_id=c.id  
+            """
 
     data = db.zx.getData(sql)
 
@@ -31,9 +33,8 @@ def src_book_info():
     li = []
     for i, j in di.items():
         li.append(i.split(',') + [j])
-
-    db.dm.execute("truncate table src_book_info")
-    db.dm.executeMany("insert into src_book_info(dt,type,book,platform,node) values (%s,%s,%s,%s,%s)", li)
+    # db.dm.execute("truncate table src_book_info")
+    db.dm.executeMany("replace into src_book_info(dt,type,book,platform,node) values (%s,%s,%s,%s,%s)", li)
     logging.info('src_book_info success')
     logging.info('书籍卡点信息,结束')