Skip to content

岳巧源 / my-awesome-project

Go to a project
Commit 8723b442 by 岳巧源
Options

add sql

parent da4dd649
Inline Side-by-side
Showing with 65 additions and 16 deletions
release.py
...@@ -3,7 +3,9 @@ import json ...@@ -3,7 +3,9 @@ import json
import mysql.connector import mysql.connector
import requests import requests
url = "/sync/Address/updateAddress" # 线上地址需要更改 # 线上地址需要更改
dev_url = "http://united_data.liexindev.net/sync/Address/updateAddress" #测试环境url
prod_url = "" #生产环境
def get_user_detail_address_by_code(province: int, city: int, district: int, detail_address: str) -> str: def get_user_detail_address_by_code(province: int, city: int, district: int, detail_address: str) -> str:
...@@ -37,13 +39,53 @@ def pur(): ...@@ -37,13 +39,53 @@ def pur():
database="liexin_purchase" database="liexin_purchase"
) )
cursor = db.cursor() cursor = db.cursor()
cursor.execute("") cursor.execute("select end_cust_cn, end_cust_en, create_uid, create_name, end_cust_id, com_addr from lie_end_cust_info")
result = cursor.fetchall() result = cursor.fetchall()
for row in result: for row in result:
json_map = { end_cust_cn = row[0]
end_cust_en = row[1]
create_uid = row[2]
create_name = row[3]
end_cust_id = row[4]
com_addr = row[5]
json_map_cn = {
"company_name_cn": end_cust_cn,
"business_license": "",
"source_system_id": "5", # ???? 来源系统1供应商 2供应链 3crm 4一体化 5采购系统 6-订单系统
"create_uid": create_uid, # ok
"create_name": create_name, # ok
"address_data": [{
"source_id": "end_cust_id_" + str(end_cust_id), #也是主键id
"source_code": "",
"address_type": "终端地址",
"address": com_addr
}],
"is_delete": 0
} }
json_map_en = {
"company_name_cn": end_cust_en,
"business_license": "",
"source_system_id": "5", # ???? 来源系统1供应商 2供应链 3crm 4一体化 5采购系统 6-订单系统
"create_uid": create_uid, # ok
"create_name": create_name, # ok
"address_data": [{
"source_id": "end_cust_id_" + str(end_cust_id), #也是主键id
"source_code": "",
"address_type": "终端地址",
"address": com_addr
}],
"is_delete": 0
}
post_data_to_update_address(json_map_cn)
post_data_to_update_address(json_map_en)
print("-------------------------pur已更新！--------------------------------")
cursor.close()
db.close()
###################################################### ######################################################
def liexin(): def liexin():
...@@ -80,7 +122,7 @@ def liexin(): ...@@ -80,7 +122,7 @@ def liexin():
tax_detail_address += consignee_address tax_detail_address += consignee_address
# 获取客户地址 # 获取客户地址
sql_user_address = "select province, city, district, detail_address from lie_user_address where uc_id = " + str(uc_id) sql_user_address = "select province, city, district, detail_address, address_type from lie_user_address where uc_id = " + str(uc_id)
cursor.execute(sql_user_address) cursor.execute(sql_user_address)
user_address_result = cursor.fetchall() user_address_result = cursor.fetchall()
user_detail_address_list = [] user_detail_address_list = []
...@@ -89,15 +131,17 @@ def liexin(): ...@@ -89,15 +131,17 @@ def liexin():
city = user_address_result[i][1] city = user_address_result[i][1]
district = user_address_result[i][2] district = user_address_result[i][2]
detail_address = user_address_result[i][3] detail_address = user_address_result[i][3]
address_type = user_address_result[i][4]
user_address = get_user_detail_address_by_code(province, city, district, detail_address) user_address = get_user_detail_address_by_code(province, city, district, detail_address)
user_detail_address_list.append(user_address) user_detail_address_list.append(user_address)
json_map = { json_map = {
"company_name_cn": tax_title, # tax_title "company_name_cn": tax_title, # tax_title
"business_license": business_license, # business_license "business_license": business_license, # business_license
"source_system_id": "", # ????? "source_system_id": "3", # ????? # 1供应商 2供应链 3crm 4一体化 5采购系统 6-订单系统
"create_uid": "", # ???? "create_uid": "1000", #
"create_name": "", # ????? "create_name": "admin", #
"address_data": [] "address_data": [],
"is_delete": 0
} }
# 发票地址不为空，加入发票地址信息 # 发票地址不为空，加入发票地址信息
if len(company_address) != 0: if len(company_address) != 0:
...@@ -110,7 +154,7 @@ def liexin(): ...@@ -110,7 +154,7 @@ def liexin():
# 收票地址不为空，加入收票地址信息 # 收票地址不为空，加入收票地址信息
if len(tax_detail_address) != 0: if len(tax_detail_address) != 0:
json_map["address_data"].append({ json_map["address_data"].append({
"source_id": "consignee_address_" + str(tax_id), "source_id": "tax_invoice_collection_address_" + str(tax_id),
"source_code": user_sn, "source_code": user_sn,
"address_type": "收票地址", "address_type": "收票地址",
"address": tax_detail_address "address": tax_detail_address
...@@ -119,15 +163,20 @@ def liexin(): ...@@ -119,15 +163,20 @@ def liexin():
for i in range(len(user_detail_address_list)): for i in range(len(user_detail_address_list)):
if len(user_detail_address_list[i]) == 0: if len(user_detail_address_list[i]) == 0:
continue continue
address_type_str = "收票地址"
if address_type == 0:
address_type_str = "收货地址"
json_map["address_data"].append({ json_map["address_data"].append({
"source_id": "user_address_" + str(tax_id), "source_id": "crm_invoice_user_" + str(tax_id),
"source_code": user_sn, "source_code": user_sn,
"address_type": "客户地址", "address_type": address_type_str,
"address": user_detail_address_list[i] "address": user_detail_address_list[i]
}) })
print(json_map) print(json_map)
post_data_to_update_address(json_map) post_data_to_update_address(json_map)
print("-------------------------liexin已更新！--------------------------------") print("-------------------------liexin已更新！--------------------------------")
cursor.close()
db.close()
...@@ -156,7 +205,7 @@ def crm(): ...@@ -156,7 +205,7 @@ def crm():
"company_name_cn": com_name, # com_name "company_name_cn": com_name, # com_name
"business_license": business_license_src, # business_license_src "business_license": business_license_src, # business_license_src
"source_system_id": "3", # 1供应商 2供应链 3crm 4一体化 5采购系统 6-订单系统 "source_system_id": "3", # 1供应商 2供应链 3crm 4一体化 5采购系统 6-订单系统
"create_uid": str(creator_id), # creator_id "create_uid": creator_id, # creator_id
"create_name": creator_name, # creator_name "create_name": creator_name, # creator_name
"address_data": [ "address_data": [
{ {
...@@ -165,12 +214,12 @@ def crm(): ...@@ -165,12 +214,12 @@ def crm():
"address_type": "公司地址", "address_type": "公司地址",
"address": com_addr # com_addr "address": com_addr # com_addr
} }
] ],
"is_delete": 0
} }
if len(com_addr) == 0: if len(com_addr) == 0:
json_map["address_data"] = [] json_map["address_data"] = []
print(json_map) print(json_map)
continue
post_data_to_update_address(json_map) post_data_to_update_address(json_map)
print("-------------------------crm已更新！--------------------------------") print("-------------------------crm已更新！--------------------------------")
cursor.close() cursor.close()
...@@ -178,9 +227,9 @@ def crm(): ...@@ -178,9 +227,9 @@ def crm():
def post_data_to_update_address(data: dict): def post_data_to_update_address(data: dict):
response = requests.post(url=url, data=json.dumps(data), headers={"Content-Type": "application/json"}) response = requests.post(url=dev_url, data=json.dumps(data), headers={"Content-Type": "application/json"})
print("=======" + str(response.status_code) + "======") print("=======" + str(response.status_code) + "======")
if __name__ == '__main__': if __name__ == '__main__':
crm() liexin()
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment