init

matchSKU.py

+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+Created on Tue Jan  7 15:26:43 2020
+
+@author: rico
+"""
+import pymssql
+import pandas as pd
+
+
+def matchSKU(sku_list,frm = ('SN','JD','MG') ):
+    conn = pymssql.connect(host='123.56.115.207', user='zgcprice3311',password='admin@2018@)!*',database='ZI_DataBase')
+    cursor = conn.cursor()
+    print('正在删除库中产品状态为6的sku，稍等。。。')#首先将库中错误状态产品的JD/SN/GM的SKU删除
+    cursor.execute("DELETE from productcode_sku where productcode in (select productcode from info_product where state='6') and frm in('JD','SN','GM')")
+    conn.commit()
+    print('正在获取当前库中所有sku,请稍等.....')#获取库中所有的SKU,以供检查
+    try:
+        get_all_sku = f"select  * from productcode_sku where frm in {frm}"
+        cursor.execute(get_all_sku)
+        data_sku = (cursor.fetchall())
+        data_sku_file = pd.DataFrame(data_sku,columns=['id','productcode','sku','skuname','createddate','frm'])
+    except:
+        get_all_sku = f"select  * from productcode_sku where frm='{frm}'"
+        cursor.execute(get_all_sku)
+        data_sku = (cursor.fetchall())
+        data_sku_file = pd.DataFrame(data_sku,columns=['id','productcode','sku','skuname','createddate','frm'])
+        
+    print('sku获取完毕')
+    conn.close()
+    cursor.close() 
+    sku_check = {}
+    for sku in set(sku_list):
+        #print(sku)
+        #sku = 100004460761
+        if str(sku) in list(data_sku_file['sku']):
+            try:
+                product_no = [target for sku_source,target in zip(list(data_sku_file['sku']),list(data_sku_file['productcode'])) if str(sku) == sku_source]
+                sku_check[f'{sku}'] = product_no[0]
+            except:
+                sku_check[f'{sku}'] = '2' #匹配上多个SKU，属于问题数据
+                
+        else:
+            if frm == 'SN':
+                sku_add = '0000000000/'+ str(sku)
+                if str(sku_add) in list(data_sku_file['sku']):
+                    try:
+                        product_no = [target for sku_source,target in zip(list(data_sku_file['sku']),list(data_sku_file['productcode'])) if str(sku_add) == sku_source]
+                        sku_check[f'{sku}'] = product_no[0]
+                    except:
+                        sku_check[f'{sku}'] = '2' #匹配上多个SKU，属于问题数据
+                else:
+                    sku_check[f'{sku}'] = '0'
+            else:
+                sku_check[f'{sku}'] = '0'
+    return sku_check