驳回非多渠道数据函数

main_merge.py

@@ -278,6 +278,23 @@ def return_error(table):
     table.columns = ['sku','name','url','source','remark','create_time']
     table.to_sql('API_returnErrorData', sql_zi_zh.engine, if_exists='append', index=False)
 
+def return_multi_channel(table):
+    sql_zi_zh = sql_find('zi_zh', False)
+    NowTime = time.strftime('%Y-%m-%d %H:%M:%S',time.localtime())
+    #table = pd.read_excel('api_data/ZH_SN_no_category_data_2019-12-27.xlsx', dtype = {'SKU' : str})
+    table = table[['SKU','产品名称','url','来源']]
+    l = len(table)
+    create_time_list = []
+    remark_list = []
+    for i in range(l):
+        create_time_list.append(NowTime)
+        remark_list.append('没有多渠道来源')
+    table['remark'] = remark_list
+    table['create_time'] = create_time_list
+
+    table.columns = ['sku','name','url','source','remark','create_time']
+    table.to_sql('API_returnErrorData', sql_zi_zh.engine, if_exists='append', index=False)
+
 class data_fetch():
     def __init__(self, model = 'LXWL_model', localhost = True, source = 'ZH_LXWL'):
         '''