ck пре 4 година
родитељ
комит
f1fa19bfc3
1 измењених фајлова са 12 додато и 8 уклоњено
  1. 12 8
      app/etl/dw/dw_image_cost_day.py

+ 12 - 8
app/etl/dw/dw_image_cost_day.py

@@ -36,26 +36,30 @@ def run(dt):
         li.extend(i[-1].split(','))
     # print(li)
 
-    sql3 = f"select image_id,preview_url from image_info where  image_id in ({str(set(li))[1:-1]})"
+    sql3 = f"select image_id,preview_url,signature from image_info where  image_id in ({str(set(li))[1:-1]})"
 
     image_di = {}
     image_data = db.quchen_text.getData(sql3)
     for x in image_data:
-        image_di[x[0]] = x[1]
+        image_di[x[0]] = (x[1],x[2])
 
     # print(image_di)
 
     for i in data:
         y = ''
+        z = ''
         for j in i[-1].split(','):
             if image_di.get(j):
-                y = y + ',' + image_di.get(j)
+                y = y + ',' + image_di.get(j)[0]
+                z = z + ',' + image_di.get(j)[1]
         i.append(y[1:])
+        i.append(z[1:])
 
     # print(data)
     # print(data)
+    # exit(0)
     db.dm.execute(f'delete from dw_image_cost_day where dt="{dt}"')
-    db.dm.executeMany("replace into dw_image_cost_day values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",data)
+    db.dm.executeMany("replace into dw_image_cost_day values (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)",data)
 
 
 
@@ -72,8 +76,8 @@ def day():
 
 
 if __name__ == '__main__':
-    # run('2021-04-07')
+    run('2021-05-10')
 
-    for i in du.getDateLists('2021-04-01','2021-04-13'):
-        print(i)
-        run(i)
+    # for i in du.getDateLists('2021-04-01','2021-04-13'):
+    #     print(i)
+    #     run(i)