ck 4 lat temu
rodzic
commit
bd1d228d03
1 zmienionych plików z 4 dodań i 1 usunięć
  1. 4 1
      app/etl/src/src_book_info.py

+ 4 - 1
app/etl/src/src_book_info.py

@@ -7,7 +7,9 @@ db= MysqlUtils()
 ck = CkUtils()
 
 def src_book_info():
-    sql="""SELECT  date_format(a.effect_day,'%Y-%m-%d'),a.type,b.book_name,c.platform_name,a.node_price from t_platform_book_ratio a 
+    sql="""SELECT  date_format(a.effect_day,'%Y-%m-%d'),
+            case a.type when 'mp' then 'vx' when 'gdt' then 'qq' 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 """
 
@@ -26,6 +28,7 @@ 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 values (%s,%s,%s,%s,%s)",li)