Python改写PHP刷类目映射脚本逻辑

1、文件Auto_update_data，需要处理的映射基础数据

1. #定义需要导入的映射数据
2. #以字典进行定义 [公司类目id : 平台类目id]
3. #d = {key1 : value1, key2 : value2, key3 : value3 }
4. ap_category_relation_data = {
5.         5807 : 10002200,
7.         6375 : 10100737,
9.         6772 : 10100733,
11.         5816 : 1540,
13.         5832 : 1540,
14. }

复制代码

2、文件Auto_update_db，自己封装的数据库操作

1. #数据库操作
2. import pymysql
4. #数据库类
5. class LazadaDb:
6.     def __init__(self, host, user, password, database, port):
7.         #打开数据库连接
8.         db = pymysql.connect(
9.             host = host,
10.             user = user,
11.             password = password,
12.             database = database,
13.             port = port
14.         )
15.         #使用 cursor()方法创建一个游标对象 cursor
16.         self.cursor = db.cursor()
17.    
18.     #定义一个查询的方法 查一列
19.     def get(self, sql):
20.         try:
21.             cursor = self.cursor
22.             #执行SQL语句
23.             cursor.execute(sql)
24.             #使用 fetchone() 方法获取单条数据
25.             data = cursor.fetchone()
26.             #返回数据
27.             return data
28.         except:
29.             return '获取数据出错101'

复制代码

3、文件Auto_update_way，递归，获取类目树方法

1. #书写公共方法
2. import Auto_update_db
4. #无限极往上获取平台类目树信息
5. def platformCategoryVerify(platform_category_id):
6.     tree = []
7.     #获取平台数据库类
8.     LazadaDb = Auto_update_db.LazadaDb('数据库ip', 'test', '密码', 'nt_auto_publish', 3311)
9.     #拼接查询sql
10.     sql = "SELECT category_id,category_name,parent_id,level FROM ap_categories WHERE platform = 1 AND site_code = 'MY' AND category_id = " + str(platform_category_id)
11.     #获取类目信息
12.     apCategories_info = LazadaDb.get(sql)
13.     #判断类目是否存在
14.     if apCategories_info:
15.         #存在，通过父类id继续获取上级
16.         tree = platformCategoryVerify(apCategories_info[2])
17.         #将获取到类目，添加到 定义的列表 tree 中
18.         tree.append(apCategories_info)
19.     return tree
21. #无限极往上获取公司类目树信息
22. def companyCategoryVerify(company_category_id):
23.     tree = []
24.     #获取公司数据库
25.     SysDb = Auto_update_db.LazadaDb('数据库ip', 'test', '密码', 'nt_product', 3307)
26.     #拼接查询sql
27.     sql = "SELECT id, category_name, parent_id, level FROM nt_categories WHERE status = 1 AND ID = " + str(company_category_id)
28.     #获取类目信息
29.     sysCategories_info = SysDb.get(sql)
30.     #p判断类目是否存在
31.     if sysCategories_info:
32.         #存在，通过父类id继续获取上级
33.         tree = companyCategoryVerify(sysCategories_info[2])
34.         #将获取到类目，添加到 定义的列表 tree 中
35.         tree.append(sysCategories_info)
36.     return tree

复制代码

4、文件Auto_update_attr，最后组装数据

1. #刷自动化类目
2. import Auto_update_data
3. import Auto_update_way
5. #获取需要处理的类目映射数据
6. list_data = Auto_update_data.ap_category_relation_data
8. #定义一个最终数据的列表
9. ap_category_relation_data = []
11. for i in list_data:
12.     print('处理=', list_data[i])
13.    
14.     #获取平台类目树信息
15.     platform_tree_info = Auto_update_way.platformCategoryVerify(list_data[i])
16.     platform_tree = '->' . join([str(platform_tree_info[i][0]) for i in range(0, len(platform_tree_info))])
17.     platform_tree_name = '->' . join([str(platform_tree_info[i][1]) for i in range(0, len(platform_tree_info))])
18.    
19.     #获取公司类目树信息
20.     company_tree_info = Auto_update_way.companyCategoryVerify(i)
21.     company_tree = '->' . join([str(company_tree_info[i][0]) for i in range(0, len(company_tree_info))])
22.     company_tree_name = '->' . join([str(company_tree_info[i][1]) for i in range(0, len(company_tree_info))])
24.     value_dic = {
25.         'platform' : 1,
26.         'site_code' : 'MY',
27.         
28.         'platform_category_id' : list_data[i], #平台类目信息
29.         'platform_category_name' : platform_tree_info[1][1],
30.         'platform_tree' : platform_tree,
31.         'platform_tree_name' : platform_tree_name,
33.         'company_category_id' : i, #公司类目信息
34.         'company_category_name' : company_tree_info[1][1],
35.         'company_tree' : company_tree,
36.         'company_tree_name' : company_tree_name,
37.     }
38.     ap_category_relation_data.append(value_dic)
40. #得到最后映射好的数据
41. for i in ap_category_relation_data:
42.     print(i)
43.     print('======')

复制代码

5、最后运行文件，打印输出