把ck 的order源改为ods_order

app/etl/sync_to_ck_task.py

@@ -13,7 +13,7 @@ def order(ymd):
     log.debug("sync order")
     col = "date,stage,platform,channel,channel_id,user_id,order_time,reg_time,amount,from_novel,order_id"
 
-    sql ="select * from `order` where date=UNIX_TIMESTAMP('{}') ".format(ymd)
+    sql ="select * from ods_order where date='{}'".format(ymd)
 
     data = db.quchen_text.getData(sql)
 
@@ -22,22 +22,27 @@ def order(ymd):
     for x in data:
         li = list(x)
 
-        li[6] = li[6].replace('T',' ').replace('+08:00','').replace('/','-')
-
-        if li[6] == None or li[6] == '':
-            li[6] = '0000-00-00 00:00:00'
-
-        if li[7]==None or li[7]=='':
-            li[7]='0000-00-00 00:00:00'
-        else:
-            li[7] = li[7].replace('T',' ').replace('+08:00','').replace('/','-')
-
-        try:
-            li[6]=str(datetime.strptime(li[6],'%Y-%m-%d %H:%M'))
-            li[7]=str(datetime.strptime(li[7],'%Y-%m-%d %H:%M'))
-            # li[7]=str(datetime.strptime(li[7],'%Y/%m/%d %H:%M:%S'))
-        except:
-            pass
+        li[0]=str(li[0])
+        li[6]=str(li[6])
+        li[7]=str(li[7])
+
+        #
+        # li[6] = li[6].replace('T',' ').replace('+08:00','').replace('/','-')
+        #
+        # if li[6] == None or li[6] == '':
+        #     li[6] = '0000-00-00 00:00:00'
+        #
+        # if li[7]==None or li[7]=='':
+        #     li[7]='0000-00-00 00:00:00'
+        # else:
+        #     li[7] = li[7].replace('T',' ').replace('+08:00','').replace('/','-')
+        #
+        # try:
+        #     li[6]=str(datetime.strptime(li[6],'%Y-%m-%d %H:%M'))
+        #     li[7]=str(datetime.strptime(li[7],'%Y-%m-%d %H:%M'))
+        #     # li[7]=str(datetime.strptime(li[7],'%Y/%m/%d %H:%M:%S'))
+        # except:
+        #     pass
             # print("======================")
         #     try:
         #         li[6] = str(datetime.strptime(li[6][:17], '%Y-%m-%d %H:%M'))
@@ -47,13 +52,13 @@ def order(ymd):
                 # li[6]='2020-11-01 00:00:00'
                 # li[7]='2020-11-01 00:00:00'
 
-        li[6] =li[6][:19]
-        li[7] =li[7][:19]
-
-        li[9] = '' if li[9] is None else li[9]
-        li[5] = '' if li[5] is None else li[5]
-        li[1] = '' if li[1] is None else li[1]
-
+        # li[6] =li[6][:19]
+        # li[7] =li[7][:19]
+        #
+        # li[9] = '' if li[9] is None else li[9]
+        # li[5] = '' if li[5] is None else li[5]
+        # li[1] = '' if li[1] is None else li[1]
+        #
         data1.append(tuple(li))
 
     # 删除分区
@@ -190,4 +195,4 @@ def campaign_vx():
 
 
 if __name__ == '__main__':
-    platform_change()
+    order('2020-12-09')