add model

数据治理平台线下处理/线下建库/zgcindex_data2DB.py

@@ -53,11 +53,24 @@ categoryId_list = df['FINISH_P_LASTCATEGORY_CODE'].apply(lambda x:str(x)).tolist
 name_list = df['FINISH_P_NAME'].tolist()
 
 #params_list = df['FINISH_P_PARAMS'].apply(lambda x:eval(x.replace("null","{}").replace("无","{}"))).tolist()
+df['FINISH_P_MODEL'] = df['FINISH_P_MODEL'].apply(lambda x:str(x))
+df['DEAL_FINISH_P_MODEL'] = df['FINISH_P_MODEL'].apply(lambda x: 0 if x == '无' or x == 'nan' else x)
+
 params_list = [eval(params) if "{" in params else eval("{}") for params in df['FINISH_P_PARAMS'].tolist()]
+deal_params_list = []
+for params,model in zip(params_list,df['DEAL_FINISH_P_MODEL'].tolist()):
+    for key in list(params.keys()):
+        if params[key] == '需人工补充':
+            del params[key]
             
+    if model == 0:
+        pass
+    else:
+        params.update({'产品型号':model})
+    deal_params_list.append(params)
 
 
-res = stock_in_product(brand_list,brandId_list,category_list,categoryId_list,params_list,name_list)
+res = stock_in_product(brand_list,brandId_list,category_list,categoryId_list,deal_params_list,name_list)
 print(res)
 sku_list = res['sku_list']
 had_sku_list = res['had_sku_list']