# -*- codeing = utf-8 -*- # @Time : 2022/10/26 12:26 # @Author : Clown # @File : demo_20221026.py # @Software : PyCharm import re import pandas as pd import hashlib import requests import json import math from dateutil.parser import parse import time import random from datetime import datetime, timedelta # 登录 def getToken(): url = 'https://cloud.xc-fintech.com/api/v1/login' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36'} json_params = {"employee_relation_id": "7008629262119084032"} resp = requests.post ( url, headers = headers, json = json_params ).json () print ( json.dumps ( resp, ensure_ascii = False ) ) return resp['app_id'], resp['token'] # 下载或查询【订货商品】页面商品信息 mode:download下载 select查询 # 信息包含【商品系统id,商品编码,商品名称,所属分类,是否有图,定价模式】 def selectAllGoodsInfo(app_id, token, mode): # mode:download下载 select查询 df_out = [] url = 'https://cloud.xc-fintech.com/api/v1/good_centre/goods' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} page_size = 10 total_count = 100 current_page = 1 while page_size * current_page - total_count < 0: # time.sleep(random.uniform(1,2)) try: json_params = {"app_id": app_id, "sell_type": "2", "create_time_order": "desc", "current_page": current_page, "page_size": page_size} proxies = {'http': None, 'https': None} resp1 = requests.post ( url, headers = headers, json = json_params, proxies = proxies ) resp = resp1.json () current_page += 1 for good_info in resp['detail']: good_info_dict = {} good_info_dict['商品系统id'] = good_info['goods_id'] good_info_dict['商品编码'] = good_info['goods_no'] good_info_dict['商品名称'] = good_info['goods_name'] good_info_dict['所属分类'] = good_info['classify_name'] good_info_dict['是否有图'] = f"有{len ( good_info['pic_show_url'] )}张图" if good_info['price_mode'] == 2: good_info_dict['定价模式'] = '分区定价' elif good_info['price_mode'] == 1: good_info_dict['定价模式'] = '统一定价' publish_state = {'1': '上架', '0': '下架'} good_info_dict['上下架状态'] = publish_state[str ( good_info['publish_state'] )] df_out.append ( good_info_dict ) total_count = resp['total_count'] if current_page % 5 == 0: time.sleep ( random.uniform ( 1, 4 ) ) print ( f'\r当前已下载第{current_page}页', end = '' ) except: resp1.close () time.sleep ( 2 ) if mode == 'download': excel_out = pd.DataFrame ( df_out ) excel_out.to_excel ( 'selectAllGoodsInfo.xlsx', index = False ) elif mode == 'select': return df_out # 下载【订货商品】【定价】页面售价，采购价，限购量信息 def selectAllGoodsInfoInDetailPrice(app_id, token, downloadPath): df_in = selectAllGoodsInfo ( app_id, token, 'select' ) time.sleep ( random.uniform ( 1, 3 ) ) cnt_all = len ( df_in ) print ( f'已完成df_in执行,共计商品{cnt_all}个' ) df_out = [] cnt = 1 for goods_info in df_in: goods_id = goods_info['商品系统id'] a = 0 while a == 0: try: goods_units_info = selectGoodsInfoDetail ( app_id, token, 'select', '', '', goods_id ) goods_info.update ( goods_units_info ) # print('goods_info.update') # 获取商品区域售价 url_goods_price = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/query' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} json_goods_price = {"subscribe_type": "1", "goods_id": goods_id, "app_id": app_id} proxies = {'http': None, 'https': None} resp_goods_price_0 = requests.post ( url_goods_price, headers = headers, json = json_goods_price, proxies = proxies, timeout = 3 ) resp_goods_price = resp_goods_price_0.json () if goods_info['定价模式'] == '分区定价': for area_price_1 in resp_goods_price['data']['brand_list'][0]['store_area_list']: dict_l1 = {} store_area_id = area_price_1['store_area_id'] store_area_name = area_price_1['store_area_name'] dict_l1['区域id'] = store_area_id dict_l1['区域名称(1级)'] = store_area_name try: # 供应商你信息 dict_l1['供应商id'] = area_price_1['sup_id'] dict_l1['供应商名称'] = area_price_1['sup_name'] # 起订限订量 dict_l1['起订量'] = area_price_1['spu_order_price']['buy_limit_min'] try: dict_l1['限订量'] = area_price_1['spu_order_price']['buy_limit_max'] except: dict_l1['限订量'] = '' # 单位对应采购价 supply_price_list1 = area_price_1['supply_price_list'] m = 1 min_unit = '' for supply_price in supply_price_list1: if supply_price['is_min_unit']: dict_l1['最小单位采购价'] = int ( supply_price['supply_price_desc']['min'] ) / 100 min_unit = supply_price['unit'] else: dict_l1[f'副单位{m}采购价'] = int ( supply_price['supply_price_desc']['min'] ) / 100 m += 1 # 单位对应售价 unit_price_list1 = area_price_1['spu_order_price']['unit_price_list'] n = 1 for unit_price in unit_price_list1: if unit_price['is_min_unit'] and unit_price['unit'] == min_unit: dict_l1['最小单位售价'] = int ( unit_price['actual_amount'] ) / 100 else: dict_l1[f'副单位{n}售价'] = int ( unit_price['actual_amount'] ) / 100 n += 1 except: ... dict_l1.update ( goods_info ) df_out.append ( dict_l1 ) else: df_out.append ( goods_info ) a = 1 except: resp_goods_price_0.close () a = 0 time.sleep ( 2 ) print ( 'mark' ) print ( f'\r已完成{cnt}个产品下载,完成进度{int ( cnt / cnt_all * 100 )}%', end = '' ) cnt += 1 if cnt % 5 == 0: time.sleep ( random.uniform ( 0.5, 2.5 ) ) if cnt % 100 == 0: time.sleep ( random.uniform ( 10, 15 ) ) # columns = ['商品系统id','商品编码','商品名称','所属分类','是否有图','定价模式',] df_out = pd.DataFrame ( df_out ) df_out.to_excel ( downloadPath, index = False ) # 查询商品goods_no:为商品编码，返回上下架状态publish_state，及goods_id系统内商品id def selectGoodsInfoPubAndId(app_id, token, goods_no): # goods_no = "P9265021186" url = 'https://cloud.xc-fintech.com/api/v1/good_centre/goods' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "sell_type": "2", "goods_no": goods_no, "create_time_order": "desc", "current_page": 1, "page_size": 10} resp = requests.post ( url, headers = headers, json = json_params ).json () # print (json.dumps (resp, ensure_ascii=False)) publish_state = resp['detail'][0]['publish_state'] publish_state_dict = {'1': '上架', '0': '下架'} publish_state_info = publish_state_dict[str ( publish_state )] # print(publish_state_info) return publish_state, resp['detail'][0]['goods_id'] # 【单品上下架】操作,【publish_state:0上架，1下架】 def updatePublishState(app_id, token, publish_state, goods_id): on_off_dict = {'1': 'off_shelf', '0': 'on_shelf'} turn_on_off = on_off_dict[str ( publish_state )] url = f'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/{turn_on_off}' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "goods_id": goods_id} resp = requests.post ( url, headers = headers, json = json_params ).json () return_result = resp['goods_id'] = goods_id return return_result # 【批量上下架】操作,【publish_state:0上架，1下架】goods_id_list:是列表 def updatePublishStateBatch(app_id, token, publish_state, goods_id_list): on_off_dict = {'1': 'batch_off_shelf', '0': 'batch_on_shelf'} turn_on_off = on_off_dict[str ( publish_state )] url = f'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/{turn_on_off}' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "goods_id_list": goods_id_list} resp = requests.post ( url, headers = headers, json = json_params ).json () print ( resp ) return_result = resp['message'] = '操作成功' return return_result # 下载或查询供应商列表 mode:download下载 select查询 查询返回列表格式[{'供应商id':'xxxx', '供应商全名':'xxxxx', '简称':'xxxx'}] def selectSupplierlist(app_id, token, mode): url = 'https://cloud.xc-fintech.com/api/v1/supplier/query' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} page_size = 10 total_count = 10 current_page = 0 df_out = [] while page_size * current_page - total_count < 0: current_page += 1 json_params = {"type": 1, "app_id": app_id, "current_page": current_page, "page_size": page_size} resp = requests.post ( url, headers = headers, json = json_params ).json () total_count = resp['total_count'] for sup_info in resp['detail']: sup_info_dict = {} sup_info_dict['供应商id'] = sup_info['supplier_id'] sup_info_dict['供应商全名'] = sup_info['sup_name'] sup_info_dict['供应商编号'] = sup_info['sup_no'] try: sup_info_dict['简称'] = sup_info['remark'] except: sup_info_dict['简称'] = '' df_out.append ( sup_info_dict ) # print(json.dumps(resp,ensure_ascii=False)) if mode == 'download': excel_out = pd.DataFrame ( df_out ) excel_out.to_excel ( 'SupplierInfoList.xlsx', sheet_name = 'sheet1' ) elif mode == 'select': return df_out # 获取【区域管理】层级树返回selectAreaTree1.xlsx文件 def selectAreaTree(app_id, token): url = 'https://cloud.xc-fintech.com/split/store/area/tree' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"parent_id": "0", "app_id": app_id} resp = requests.post ( url, headers = headers, json = json_params ).json ()['tree'][0] df_out = [] for children1 in resp['children']: # 省 level1 = {} level1['父级id'] = children1['id'] level1['父级名称'] = children1['name'] # 市 childrens2 = children1['children'] level0 = {'子级id': children1['id'], '子级名称': children1['name'], '父级id2': children1['id']} level0.update ( level1 ) df_out.append ( level0 ) if len ( childrens2 ) > 0: for children2 in childrens2: level2 = {} level2['子级id'] = children2['id'] level2['子级名称'] = children2['name'] level2['父级id2'] = children2['parentId'] parentId = children2['parentId'] level2.update ( level1 ) df_out.append ( level2 ) childrens3 = children2['children'] if len ( childrens3 ) > 0: for children3 in childrens3: level3 = {} level3['子级id'] = children3['id'] level3['子级名称'] = children3['name'] level3['父级id2'] = parentId level3.update ( level1 ) df_out.append ( level3 ) excel_out = pd.DataFrame ( df_out ) excel_out.to_excel ( 'selectAreaTree1.xlsx', sheet_name = 'sheet1' ) # 【单个更新】供应商供货区域 def updateSupplierAreaInfo(app_id, token, supUploadInfoDict): sup_id = supUploadInfoDict['sup_id'] # 供应商id store_area_id_list = supUploadInfoDict['store_area_id_list'] # 供应商服务区域对应id（全域） url = 'https://cloud.xc-fintech.com/api/v1/supplier/area/save' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {'app_id': app_id, 'sup_id': sup_id, 'store_area_id_list': store_area_id_list} resp = requests.post ( url, headers = headers, json = json_params ).json () return_result = resp['sup_id'] = sup_id return return_result # 读取供应商供货区域导入表 def readUploadFile(uploadFile): df_in = pd.read_excel ( uploadFile, dtype = str ) sup_ids = list ( df_in['供应商id'] ) sup_ids = list ( set ( sup_ids ) ) waite_list = [] for sup_id in sup_ids: sup_info_dict = {} sup_info_dict['sup_id'] = sup_id store_area_id_list = list ( df_in[df_in['供应商id'] == sup_id]['供货区域'] ) sup_info_dict['store_area_id_list'] = store_area_id_list waite_list.append ( sup_info_dict ) # for i in waite_list: # print(i) return waite_list # 【批量更新】供应商供货区域 def updateSuppliersAreaInfo(app_id, token, uploadFile): waite_list = readUploadFile ( uploadFile ) error_cnt = 0 error_list = [] for supUploadInfoDict in waite_list: return_result = updateSupplierAreaInfo ( app_id, token, supUploadInfoDict ) if return_result: ... else: error_list.append ( supUploadInfoDict['sup_id'] ) error_cnt += 1 if error_cnt == 0: print ( 'all Down' ) else: print ( 'error_list:', error_list ) # 供应商供货清单 def goodsInSupplierList(app_id, token, selectSupplierlist, mode): url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/supply_goods/freight/template/query' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} df_out = [] for supplierInfo in selectSupplierlist: supplierId = supplierInfo['供应商id'] try: supplierName = supplierInfo['供应商全名'] except: supplierName = '' page_size = 40 total_count = 40 current_page = 0 while page_size * current_page - total_count < 0: current_page += 1 json_params = {"sup_id": supplierId, "app_id": app_id, "current_page": current_page, "page_size": page_size} resp = requests.post ( url, headers = headers, json = json_params ).json () total_count = resp['total_count'] if total_count == 0: good_info_dict = {} good_info_dict['供应商id'] = supplierId good_info_dict['供应商全名'] = supplierName good_info_dict['商品系统id'] = '' good_info_dict['商品编码'] = '' good_info_dict['商品名称'] = '' good_info_dict['最小单位'] = '' df_out.append ( good_info_dict ) else: for good_info in resp['goods_list']: good_info_dict = {} good_info_dict['供应商id'] = supplierId good_info_dict['供应商全名'] = supplierName good_info_dict['商品系统id'] = good_info['goods_id'] good_info_dict['商品编码'] = good_info['goods_no'] good_info_dict['商品名称'] = good_info['goods_name'] spu_unit_list = good_info['spu_unit_list'] try: for unit_info in spu_unit_list: if unit_info['is_min_unit']: good_info_dict['最小单位'] = unit_info['unit'] else: good_info_dict['副单位'] = unit_info['unit'] except: good_info_dict['最小单位'] = '无最小单位' df_out.append ( good_info_dict ) excel_out = pd.DataFrame ( df_out ) if mode == 'download': excel_out.to_excel ( 'goodsInSupplierList.xlsx', sheet_name = 'sheet1' ) print ( 'all Down' ) elif mode == 'select': goods_in_suped = list ( excel_out['商品系统id'] ) print ( goods_in_suped ) return goods_in_suped # 【批量更新】供应商供货管理中供货列表 def addGoodsToSupplierSupList(app_id, token, uploadFile): url = 'https://cloud.xc-fintech.com/api/v1/supplier/sup_goods/batch_establish' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} df_in = pd.read_excel ( uploadFile, dtype = str ) sup_ids = list ( df_in['供应商id'] ) sup_ids = list ( set ( sup_ids ) ) # waite_list = [] for sup_id in sup_ids: goods_in_suped = goodsInSupplierList ( app_id, token, [{'供应商id': sup_id}], 'select' ) sup_info_dict = {} sup_info_dict['supplier_id'] = sup_id goods_in_sup = list ( df_in[df_in['供应商id'] == sup_id]['供货商品'] ) goods_in_sup = list ( set ( goods_in_sup ).difference ( set ( goods_in_suped ) ) ) sup_info_dict['goods_list'] = goods_in_sup sup_info_dict['app_id'] = app_id if 1 == 1: if len ( goods_in_sup ) > 0: resp = requests.post ( url, headers = headers, json = sup_info_dict ).json ()['message'] if resp == '操作成功': print ( sup_id, '\033[1;32m 新增商品成功 \033[0m' ) else: print ( resp ) print ( sup_id, '\033[1;31m 新增商品失败 \033[0m' ) else: print ( sup_id, '\033[1;33m 无有效商品需更新 \033[0m' ) # print(goods_in_sup) # 【批量更新】供应商供货管理中商品供货【1】或缺货【2】 def updateGoodsSupStatus(app_id, token, uploadFile): df_in = pd.read_excel ( uploadFile, dtype = str ) n = 0 for supplier_id in df_in['供应商id']: info = df_in.loc[n] goods_id = info['商品id'] status = info['供缺货操作'] n += 1 url = 'https://cloud.xc-fintech.com/api/v1/supplier/sup_goods/status/set' json_params = {"supplier_id": str ( supplier_id ), "goods_id": str ( goods_id ), "status": int ( status ), "app_id": app_id} headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} resp = requests.post ( url, headers = headers, json = json_params ).text print ( resp ) # 【批量更新】供应商供货管理中 区域商品建议售价及采购价 （仅需要输入需要更新的区域，如需清除区域定价，直接输入0，并在【订货商品】页面进行不供货设置 def updateGoodsAreaSupplierPrice(app_id, token, uploadFile): updateSingleGoodsPriceInGoodsInfoCentre ( app_id, token, uploadFile, 0 ) df_in = pd.read_excel ( uploadFile ) sup_ids = list ( set ( df_in['供应商id'] ) ) # print(sup_ids) for sup_id in sup_ids: goods_ids_l = df_in[df_in['供应商id'] == sup_id] goods_ids = list ( set ( goods_ids_l['商品id'] ) ) # print(goods_ids) for goods_id in goods_ids: area_prices = goods_ids_l[goods_ids_l['商品id'] == goods_id] area_prices = area_prices.to_dict ( 'records' ) area_prices_dict = {} for area_price in area_prices: supply_price_list = [] if area_price['副单位'] is not None: b = {'is_min_unit': False, 'unit': area_price['副单位'], 'suggested_order_price': area_price['副单位售价'] * 100, 'supply_price': area_price['副单位采购价'] * 100} supply_price_list.append ( b ) if area_price['副单位1'] is not None: c = {'is_min_unit': False, 'unit': area_price['副单位1'], 'suggested_order_price': area_price['副单位1售价'] * 100, 'supply_price': area_price['副单位1采购价'] * 100} supply_price_list.append(c) a = {'is_min_unit': True, 'unit': area_price['最小单位'], 'suggested_order_price': area_price['最小单位售价'] * 100, 'supply_price': area_price['最小单位采购价'] * 100} supply_price_list.append ( a ) area_prices_dict[str ( area_price['供货区域'] )] = supply_price_list # print(area_prices_dict) headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} # 获取当前供应商供应商品的明细信息 # sup_id = '6976780582995234816' # goods_id = '6952558678100807680' url_get = 'https://cloud.xc-fintech.com/api/v1/goods_centre/supply_goods/detail' json_params_get = {"app_id": app_id, "sup_id": sup_id, "goods_id": goods_id} resp = requests.post ( url_get, headers = headers, json = json_params_get ).json () # print(resp) publish_state = resp['publish_state'] # 上下架状态 price_mode = resp['price_mode'] unit_list = resp['unit_list'] supply_price_list_false = [] for unit in unit_list: unit.pop ( 'is_use' ) supply_price_list_false.append ( unit ) area_price_list = [] for areas_price_1 in resp['area_price_list']: area_price_1 = {} area_price_1['store_area_name'] = areas_price_1['store_area_name'] area_price_1['store_area_id'] = areas_price_1['store_area_id'] # print(area_price_1['store_area_id']) try: supply_price_list = area_prices_dict[area_price_1['store_area_id']] # print ('1', supply_price_list) except: try: supply_price_list = areas_price_1['sku_price_list'][0]['supply_price_list'] except: supply_price_list = supply_price_list_false area_price_1['sku_price_list'] = [{'sku_id': 0, 'supply_price_list': supply_price_list }] area_price_list.append ( area_price_1 ) if len ( areas_price_1['area_price_list'] ) > 0: for areas_price_2 in areas_price_1['area_price_list']: area_price_2 = {} area_price_2['store_area_name'] = areas_price_2['store_area_name'] area_price_2['store_area_id'] = areas_price_2['store_area_id'] try: supply_price_list = area_prices_dict[areas_price_2['store_area_id']] # print ('2', supply_price_list) except: supply_price_list = supply_price_list_false # supply_price_list = areas_price_2['sku_price_list'][0]['supply_price_list'] area_price_2['sku_price_list'] = [{'sku_id': 0, 'supply_price_list': supply_price_list }] area_price_list.append ( area_price_2 ) if len ( areas_price_2['area_price_list'] ) > 0: for areas_price_3 in areas_price_2['area_price_list']: area_price_3 = {} area_price_3['store_area_name'] = areas_price_3['store_area_name'] area_price_3['store_area_id'] = areas_price_3['store_area_id'] try: supply_price_list = area_prices_dict[area_price_1['store_area_id']] # print ('3', supply_price_list) except: supply_price_list = supply_price_list_false # supply_price_list = areas_price_3['sku_price_list'][0]['supply_price_list'] area_price_3['sku_price_list'] = [{'sku_id': 0, 'supply_price_list': supply_price_list }] area_price_list.append ( area_price_3 ) # print(area_price_list) # 构建json_params_up # price_mode = '2' supply_rela_list = [{'sku_id': 0, 'm_supply_count': '', 'init_stock': ''}] # 默认 # area_price = {'store_area_name':'上海', # 'store_area_id':'5843112869169733638', # 'sku_price_list':[{'sku_id':0, # 'supply_price_list':[{'is_min_unit':True, # 'unit':'箱', # 'suggested_order_price':99900, # 'supply_price':34000 # }] # }]} # area_price_list = [] json_params_up = {'app_id': app_id, 'goods_id': goods_id, 'price_mode': 2, 'sup_id': sup_id, 'supply_rela_list': supply_rela_list, 'area_price_list': area_price_list} # print(json_params_up) if publish_state == 1: # 下架 if updatePublishState ( app_id, token, 1, goods_id ): url_up = 'https://cloud.xc-fintech.com/api/v1/supplier/sup_goods/establish' resp_up = requests.post ( url_up, headers = headers, json = json_params_up ).json () print ( resp_up ) print ( sup_id, goods_id, resp_up['sup_id'] == sup_id ) # 上架 updatePublishState ( app_id, token, 0, goods_id ) else: print ( sup_id, goods_id, '无法操作下架' ) else: url_up = 'https://cloud.xc-fintech.com/api/v1/supplier/sup_goods/establish' resp_up = requests.post ( url_up, headers = headers, json = json_params_up ).json () print ( sup_id, goods_id, resp_up ) print ( sup_id, goods_id, resp_up['sup_id'] == sup_id ) updateSingleGoodsPriceInGoodsInfoCentre ( app_id, token, uploadFile, 1 ) # 【单独更新】订货商品中改价界面的参数，配合updateGoodsAreaSupplierPrice执行，主要在调整供应商端采购价和建议售价时，完成订货商品【供货方】调整 # mode = 0时为【供货方】调整为【不供货】，mode = 1时为【供货方】调整为表中指定供应商 def updateSingleGoodsPriceInGoodsInfoCentre(app_id, token, uploadFile, mode): df_in = pd.read_excel ( uploadFile ) goods_ids = list ( set ( df_in['商品id'] ) ) df_in_dict = {} for goods_id in goods_ids: df_in_dict[str ( goods_id )] = {} area_ids_l = df_in[df_in['商品id'] == goods_id] area_ids = list ( set ( area_ids_l['供货区域'] ) ) for area_id in area_ids: df_in_dict[str ( goods_id )][str ( area_id )] = {} sup_ids_l = area_ids_l[area_ids_l['供货区域'] == area_id] sup_ids_l = sup_ids_l.to_dict ( 'records' ) try: if len ( sup_ids_l ) > 1: print ( f'商品【{goods_id}】在【{area_id}】存在多个供应商，请检查此字段【订货商品【供货方】是否立即调整】是否有调整' ) except: print ( '一品一地多供点检出错' ) sup_info = sup_ids_l[0] unit_price_list = [] if str ( sup_info['副单位'] ) != 'nan': b = {'is_min_unit': False, 'unit': sup_info['副单位'], 'actual_amount': int ( sup_info['副单位售价'] * 100 )} unit_price_list.append ( b ) if str ( sup_info['副单位1'] ) != 'nan': c = {'is_min_unit': False, 'unit': sup_info['副单位1'], 'actual_amount': int ( sup_info['副单位1售价'] * 100 )} unit_price_list.append ( c ) a = {'is_min_unit': True, 'unit': sup_info['最小单位'], 'actual_amount': int ( sup_info['最小单位售价'] * 100 )} unit_price_list.append ( a ) if str ( sup_info['限订量'] ) != 'nan': buy_limit_max = sup_info['限订量'] else: buy_limit_max = '' if sup_info['订货商品【供货方】是否立即调整'] != 'nan': isAddToListRightNow = sup_info['订货商品【供货方】是否立即调整'] else: isAddToListRightNow = 0 df_in_dict[str ( goods_id )][str ( area_id )] = {'sup_id': str ( sup_info['供应商id'] ), 'buy_limit_min': sup_info['起订量'], 'buy_limit_max': buy_limit_max, 'unit_price_list': unit_price_list, 'isAddToListRightNow': isAddToListRightNow} df_in_dict[str ( goods_id )][str ( area_id )][str ( sup_info['供应商id'] )] = { 'sup_id': str ( sup_info['供应商id'] ), 'buy_limit_min': sup_info['起订量'], 'buy_limit_max': buy_limit_max, 'unit_price_list': unit_price_list, 'isAddToListRightNow': isAddToListRightNow} # 以上对导入表进行字典化整理df_in_dict print ( len ( goods_ids ) ) headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} for goods_id in goods_ids: # 查询商品相关规格信息 url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/' + str ( goods_id ) json = {"app_id": app_id} resp_goodsInfo = requests.post ( url, headers = headers, json = json ).json () unit_list = [] publish_state = resp_goodsInfo['publish_state'] for unit_info in resp_goodsInfo['spu_unit_list']: unit_info_dict = {} unit_info_dict['is_min_unit'] = unit_info['is_min_unit'] unit_info_dict['unit'] = unit_info['unit'] unit_list.append ( unit_info_dict ) if publish_state == 1: # 下架 updatePublishState ( app_id, token, 1, goods_id ) # 返回规格数据unit_list # 按goods_id搜索当前商品定价界面相关信息 url_goods_price = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/query' json_goods_price = {"subscribe_type": "1", "goods_id": goods_id, "app_id": app_id} resp_goods_price = requests.post ( url_goods_price, headers = headers, json = json_goods_price ).json () if mode == 0: # area_price_list为构建的请求参数中的列表参数 area_price_list = [] for area_price_1 in resp_goods_price['data']['brand_list'][0]['store_area_list']: dict_l1 = {} store_area_id = area_price_1['store_area_id'] store_area_name = area_price_1['store_area_name'] is_extend = area_price_1['is_extend'] dict_l1['is_extend'] = is_extend dict_l1['store_area_id'] = store_area_id dict_l1['store_area_name'] = store_area_name # dict_l1['is_supply'] = True # dict_l1['spu_order_price'] = {} try: sup_id = area_price_1['sup_id'] # print(sup_id) except: ... # 判断是否在上载的表里 try: # 如果'在'则进行【不供货】调整 sup_id_in = df_in_dict[str ( goods_id )][str ( store_area_id )][str ( sup_id )]['sup_id'] dict_l1['is_supply'] = False print ( goods_id, '|区域', store_area_id, '已设置值不供货' ) # dict_l1['spu_order_price']['buy_limit_min'] = df_in_dict[str (goods_id)][store_area_id][sup_id]['buy_limit_min'] # dict_l1['spu_order_price']['buy_limit_max'] = df_in_dict[str (goods_id)][store_area_id][sup_id]['buy_limit_max'] # dict_l1['spu_order_price']['unit_price_list'] = df_in_dict[str (goods_id)][store_area_id][sup_id][ # 'unit_price_list'] except: # 判断是否已分配供应商 dict_l1['is_supply'] = True dict_l1['spu_order_price'] = {} try: dict_l1['sup_id'] = sup_id dict_l1['spu_order_price']['buy_limit_min'] = area_price_1['spu_order_price']['buy_limit_min'] try: dict_l1['spu_order_price']['buy_limit_max'] = area_price_1['spu_order_price'][ 'buy_limit_max'] except: dict_l1['spu_order_price']['buy_limit_max'] = '' dict_l1['spu_order_price']['unit_price_list'] = area_price_1['spu_order_price'][ 'unit_price_list'] except: dict_l1['spu_order_price']['unit_price_list'] = unit_list dict_l1['spu_order_price']['buy_limit_min'] = '' dict_l1['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l1 ) store_area_list2 = area_price_1['store_area_list'] if len ( store_area_list2 ) > 0: for area_price_2 in store_area_list2: dict_l2 = {} store_area_id = area_price_2['store_area_id'] store_area_name = area_price_2['store_area_name'] is_extend = area_price_2['is_extend'] dict_l2['is_extend'] = is_extend dict_l2['store_area_id'] = store_area_id dict_l2['store_area_name'] = store_area_name # dict_l2['spu_order_price'] = {} # dict_l2['is_supply'] = True # try: # dict_l2['sup_id'] = df_in_dict[str (goods_id)][store_area_id][sup_id]['sup_id'] # dict_l2['is_supply'] = False # # dict_l2['spu_order_price']['buy_limit_min'] = df_in_dict[str (goods_id)][store_area_id][ # # 'buy_limit_min'] # # dict_l2['spu_order_price']['buy_limit_max'] = df_in_dict[str (goods_id)][store_area_id][ # # 'buy_limit_max'] # # dict_l2['spu_order_price']['unit_price_list'] = df_in_dict[str (goods_id)][store_area_id][ # # 'unit_price_list'] # except: dict_l2['spu_order_price'] = {} dict_l2['is_supply'] = True dict_l2['spu_order_price']['unit_price_list'] = unit_list dict_l2['spu_order_price']['buy_limit_min'] = '' dict_l2['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l2 ) store_area_list3 = area_price_2['store_area_list'] if len ( store_area_list3 ) > 0: for area_price_3 in store_area_list3: dict_l3 = {} store_area_id = area_price_3['store_area_id'] store_area_name = area_price_3['store_area_name'] is_extend = area_price_3['is_extend'] dict_l3['is_extend'] = is_extend dict_l3['is_supply'] = True dict_l3['store_area_id'] = store_area_id dict_l3['store_area_name'] = store_area_name dict_l3['spu_order_price'] = {} # try: # dict_l3['sup_id'] = df_in_dict[str (goods_id)][store_area_id]['sup_id'] # dict_l3['spu_order_price']['buy_limit_min'] = df_in_dict[str (goods_id)][store_area_id][ # 'buy_limit_min'] # dict_l3['spu_order_price']['buy_limit_max'] = df_in_dict[str (goods_id)][store_area_id][ # 'buy_limit_max'] # dict_l3['spu_order_price']['unit_price_list'] = \ # df_in_dict[str (goods_id)][store_area_id][ # 'unit_price_list'] # except: dict_l3['spu_order_price']['unit_price_list'] = unit_list dict_l3['spu_order_price']['buy_limit_min'] = '' dict_l3['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l3 ) brand_list = [{'brand_id': '0', 'area_price_list': area_price_list}] json_params_full_update = {'app_id': app_id, 'goods_id': goods_id, 'subscribe_type': '1', 'brand_list': brand_list} url_full_update = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/full_update' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} resp_full_update = requests.post ( url_full_update, headers = headers, json = json_params_full_update ).text print ( resp_full_update ) if mode == 1: area_price_list = [] for area_price_1 in resp_goods_price['data']['brand_list'][0]['store_area_list']: dict_l1 = {} store_area_id = area_price_1['store_area_id'] store_area_name = area_price_1['store_area_name'] is_extend = area_price_1['is_extend'] dict_l1['is_extend'] = is_extend dict_l1['is_supply'] = True dict_l1['store_area_id'] = store_area_id dict_l1['store_area_name'] = store_area_name dict_l1['spu_order_price'] = {} try: dict_l1['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l1['spu_order_price']['buy_limit_min'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l1['spu_order_price']['buy_limit_max'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l1['spu_order_price']['unit_price_list'] = df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: # 判断是否已分配供应商 try: dict_l1['sup_id'] = area_price_1['sup_id'] dict_l1['spu_order_price']['buy_limit_min'] = area_price_1['spu_order_price']['buy_limit_min'] try: dict_l1['spu_order_price']['buy_limit_max'] = area_price_1['spu_order_price'][ 'buy_limit_max'] except: dict_l1['spu_order_price']['buy_limit_max'] = '' dict_l1['spu_order_price']['unit_price_list'] = area_price_1['spu_order_price'][ 'unit_price_list'] except: dict_l1['spu_order_price']['unit_price_list'] = unit_list dict_l1['spu_order_price']['buy_limit_min'] = '' dict_l1['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l1 ) store_area_list2 = area_price_1['store_area_list'] if len ( store_area_list2 ) > 0: for area_price_2 in store_area_list2: dict_l2 = {} store_area_id = area_price_2['store_area_id'] store_area_name = area_price_2['store_area_name'] is_extend = area_price_2['is_extend'] dict_l2['is_extend'] = is_extend dict_l2['is_supply'] = True dict_l2['store_area_id'] = store_area_id dict_l2['store_area_name'] = store_area_name dict_l2['spu_order_price'] = {} try: dict_l2['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l2['spu_order_price']['buy_limit_min'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l2['spu_order_price']['buy_limit_max'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l2['spu_order_price']['unit_price_list'] = df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: dict_l2['spu_order_price']['unit_price_list'] = unit_list dict_l2['spu_order_price']['buy_limit_min'] = '' dict_l2['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l2 ) store_area_list3 = area_price_2['store_area_list'] if len ( store_area_list3 ) > 0: for area_price_3 in store_area_list3: dict_l3 = {} store_area_id = area_price_3['store_area_id'] store_area_name = area_price_3['store_area_name'] is_extend = area_price_3['is_extend'] dict_l3['is_extend'] = is_extend dict_l3['is_supply'] = True dict_l3['store_area_id'] = store_area_id dict_l3['store_area_name'] = store_area_name dict_l3['spu_order_price'] = {} try: dict_l3['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l3['spu_order_price']['buy_limit_min'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l3['spu_order_price']['buy_limit_max'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l3['spu_order_price']['unit_price_list'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: dict_l3['spu_order_price']['unit_price_list'] = unit_list dict_l3['spu_order_price']['buy_limit_min'] = '' dict_l3['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l3 ) brand_list = [{'brand_id': '0', 'area_price_list': area_price_list}] json_params_full_update = {'app_id': app_id, 'goods_id': goods_id, 'subscribe_type': '1', 'brand_list': brand_list} url_full_update = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/full_update' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} resp_full_update = requests.post ( url_full_update, headers = headers, json = json_params_full_update ).text print ( resp_full_update ) if publish_state == 1: # 上架 updatePublishState ( app_id, token, 0, goods_id ) print ( '----------【不供货】操作----------' ) # 【批量更新】订货商品中改价界面的参数 def updateGoodsPriceInGoodsInfoCentre(app_id, token, uploadFile): df_in = pd.read_excel ( uploadFile ) goods_ids = list ( set ( df_in['商品id'] ) ) df_in_dict = {} for goods_id in goods_ids: df_in_dict[str ( goods_id )] = {} area_ids_l = df_in[df_in['商品id'] == goods_id] area_ids = list ( set ( area_ids_l['区域id'] ) ) for area_id in area_ids: df_in_dict[str ( goods_id )][str ( area_id )] = {} sup_ids_l = area_ids_l[area_ids_l['区域id'] == area_id] sup_ids_l = sup_ids_l.to_dict ( 'records' ) try: if len ( sup_ids_l ) > 1: print ( f'商品【{goods_id}】在【{area_id}】存在多个供应商，请检查此字段【订货商品【供货方】是否立即调整】是否有调整' ) except: print ( '一品一地多供点检出错' ) sup_info = sup_ids_l[0] unit_price_list = [] if str ( sup_info['副单位'] ) != 'nan': b = {'is_min_unit': False, 'unit': sup_info['副单位'], 'actual_amount': int ( sup_info['副单位售价'] * 100 )} unit_price_list.append ( b ) if str ( sup_info['副单位1'] ) != 'nan': c = {'is_min_unit': False, 'unit': sup_info['副单位1'], 'actual_amount': int ( sup_info['副单位1售价'] * 100 )} unit_price_list.append ( c ) a = {'is_min_unit': True, 'unit': sup_info['最小单位'], 'actual_amount': int ( sup_info['最小单位售价'] * 100 )} unit_price_list.append ( a ) if str ( sup_info['限订量'] ) != 'nan': buy_limit_max = sup_info['限订量'] else: buy_limit_max = '' df_in_dict[str ( goods_id )][str ( area_id )] = {'sup_id': str ( sup_info['供应商id'] ), 'buy_limit_min': sup_info['起订量'], 'buy_limit_max': buy_limit_max, 'unit_price_list': unit_price_list} # 以上对导入表进行字典化整理df_in_dict print ( len ( goods_ids ) ) headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} for goods_id in goods_ids: # 查询商品相关规格信息 url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/' + str ( goods_id ) json = {"app_id": app_id} resp_goodsInfo = requests.post ( url, headers = headers, json = json ).json () unit_list = [] publish_state = resp_goodsInfo['publish_state'] for unit_info in resp_goodsInfo['spu_unit_list']: unit_info_dict = {} unit_info_dict['is_min_unit'] = unit_info['is_min_unit'] unit_info_dict['unit'] = unit_info['unit'] unit_list.append ( unit_info_dict ) if publish_state == 1: # 下架 updatePublishState ( app_id, token, 1, goods_id ) # 返回规格数据unit_list # 按goods_id搜索当前商品定价界面相关信息 url_goods_price = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/query' json_goods_price = {"subscribe_type": "1", "goods_id": goods_id, "app_id": app_id} resp_goods_price = requests.post ( url_goods_price, headers = headers, json = json_goods_price ).json () area_price_list = [] for area_price_1 in resp_goods_price['data']['brand_list'][0]['store_area_list']: dict_l1 = {} store_area_id = area_price_1['store_area_id'] store_area_name = area_price_1['store_area_name'] is_extend = area_price_1['is_extend'] dict_l1['is_extend'] = is_extend dict_l1['is_supply'] = True dict_l1['store_area_id'] = store_area_id dict_l1['store_area_name'] = store_area_name dict_l1['spu_order_price'] = {} # in_put_area_dict_l1 = {'is_extend': is_extend, # 'is_supply': True, # 'spu_order_price': {'buy_limit_min': buy_limit_min, # 'buy_limit_max': buy_limit_max, # 'unit_price_list': unit_price_list}, # 'store_area_id': store_area_id, # 'store_area_name': store_area_name, # 'sup_id': sup_id} # in_put_area_dict_l1 = {'is_extend': is_extend, # 'is_supply': True, # 'spu_order_price': {'buy_limit_min': '', # 'buy_limit_max': '', # 'unit_price_list': unit_price_list}, # 'store_area_id': store_area_id, # 'store_area_name': store_area_name, # } # 判断是否在上载的表里 try: dict_l1['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l1['spu_order_price']['buy_limit_min'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l1['spu_order_price']['buy_limit_max'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l1['spu_order_price']['unit_price_list'] = df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: # 判断是否已分配供应商 try: dict_l1['sup_id'] = area_price_1['sup_id'] dict_l1['spu_order_price']['buy_limit_min'] = area_price_1['spu_order_price']['buy_limit_min'] try: dict_l1['spu_order_price']['buy_limit_max'] = area_price_1['spu_order_price']['buy_limit_max'] except: dict_l1['spu_order_price']['buy_limit_max'] = '' dict_l1['spu_order_price']['unit_price_list'] = area_price_1['spu_order_price']['unit_price_list'] except: dict_l1['spu_order_price']['unit_price_list'] = unit_list dict_l1['spu_order_price']['buy_limit_min'] = '' dict_l1['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l1 ) store_area_list2 = area_price_1['store_area_list'] if len ( store_area_list2 ) > 0: for area_price_2 in store_area_list2: dict_l2 = {} store_area_id = area_price_2['store_area_id'] store_area_name = area_price_2['store_area_name'] is_extend = area_price_2['is_extend'] dict_l2['is_extend'] = is_extend dict_l2['is_supply'] = True dict_l2['store_area_id'] = store_area_id dict_l2['store_area_name'] = store_area_name dict_l2['spu_order_price'] = {} try: dict_l2['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l2['spu_order_price']['buy_limit_min'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l2['spu_order_price']['buy_limit_max'] = df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l2['spu_order_price']['unit_price_list'] = df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: dict_l2['spu_order_price']['unit_price_list'] = unit_list dict_l2['spu_order_price']['buy_limit_min'] = '' dict_l2['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l2 ) store_area_list3 = area_price_2['store_area_list'] if len ( store_area_list3 ) > 0: for area_price_3 in store_area_list3: dict_l3 = {} store_area_id = area_price_3['store_area_id'] store_area_name = area_price_3['store_area_name'] is_extend = area_price_3['is_extend'] dict_l3['is_extend'] = is_extend dict_l3['is_supply'] = True dict_l3['store_area_id'] = store_area_id dict_l3['store_area_name'] = store_area_name dict_l3['spu_order_price'] = {} try: dict_l3['sup_id'] = df_in_dict[str ( goods_id )][store_area_id]['sup_id'] dict_l3['spu_order_price']['buy_limit_min'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_min'] dict_l3['spu_order_price']['buy_limit_max'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'buy_limit_max'] dict_l3['spu_order_price']['unit_price_list'] = \ df_in_dict[str ( goods_id )][store_area_id][ 'unit_price_list'] except: dict_l3['spu_order_price']['unit_price_list'] = unit_list dict_l3['spu_order_price']['buy_limit_min'] = '' dict_l3['spu_order_price']['buy_limit_max'] = '' area_price_list.append ( dict_l3 ) brand_list = [{'brand_id': '0', 'area_price_list': area_price_list}] json_params_full_update = {'app_id': app_id, 'goods_id': goods_id, 'subscribe_type': '1', 'brand_list': brand_list} url_full_update = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/full_update' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} resp_full_update = requests.post ( url_full_update, headers = headers, json = json_params_full_update ).text print ( resp_full_update ) if publish_state == 1: # 上架 updatePublishState ( app_id, token, 0, goods_id ) ''' goods_id = "6997811305520701440" url_full_update = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/full_update' headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Content-Type': 'application/json; charset=UTF-8'} area_price_list=[] #按goods_id搜索当前商品定价界面相关信息 url_goods_price = 'https://cloud.xc-fintech.com/api/v2/goods_centre/goods/goods_price/query' json_goods_price = {"subscribe_type":"1", "goods_id":goods_id, "app_id":app_id} resp_goods_price = requests.post(url_goods_price,headers=headers,json=json_goods_price).json() for area_price_1 in resp_goods_price['data']['brand_list'][0]['store_area_list']: store_area_list2 = area_price_1['store_area_list'] if len(store_area_list2)>0: for area_price_2 in store_area_list2: store_area_list3 = area_price_2['store_area_list'] if len(store_area_list3)>0: for area_price_3 in store_area_list3: ... in_put_area_F_dict = {'is_extend': False, 'is_supply': True, 'spu_order_price': {'buy_limit_min': 1, 'buy_limit_max': '', 'unit_price_list': [{'actual_amount': 37280, 'is_min_unit': True, 'unit': '桶'}]}, 'store_area_id': '5843111700124934144', 'store_area_name': '河北省', 'sup_id': '6976010005263032320'} in_put_area_S_dict = {'is_extend': True, 'is_supply': True, 'spu_order_price': {'buy_limit_min': 1, 'buy_limit_max': '', 'unit_price_list': [{'actual_amount': '', 'is_min_unit': True, 'unit': '桶'}]}, 'store_area_id': '6990852309777522688', 'store_area_name': '河北省a顶灿'} brand_list= [{'brand_id':'0', 'area_price_list':area_price_list}] json_params_full_update = {'app_id':app_id, 'goods_id':goods_id, 'subscribe_type':'1', 'brand_list':brand_list} ''' # 获取【订货橱窗】中的商品信息 def goodsInGoodsCentre(app_id, token, downloadPath): # 第一步构造 目录列表包含信息['品牌id','品牌名称','L1橱窗id','L1橱窗名称','L2橱窗id','L2橱窗名称','publish_goods_count'] headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} # 获取所有品牌名称及id brand_url = 'https://cloud.xc-fintech.com/api/v1/brand/list' brand_json_params = {"current_page": 1, "page_size": 999, "app_id": app_id} brand_list = requests.post ( brand_url, headers = headers, json = brand_json_params ).json ()['detail'] # print(brand_list) df_out = [] i = 0 for brand_info in brand_list: brand_id = brand_info['brand_id'] brand_name = brand_info['brand_name'] # 创建表信息 brand_info_dict = {'品牌id': brand_id, '品牌名称': brand_name} # 获取当前品牌下各分类名称及id shop_window_url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/shop_window/tree/query' shop_window_json_params = {"app_id": app_id, "sell_type": 2, "brand_id": brand_id} try: shop_window_list = \ requests.post ( shop_window_url, headers = headers, json = shop_window_json_params ).json ()[ 'shop_window_detail'] shop_window_list_out = [] for shop_window_info in shop_window_list: try: childs = shop_window_info['child'] for child in childs: shop_window_id = child['shop_window_id'] shop_window_name = child['shop_window_name'] publish_goods_count = child['publish_goods_count'] shop_window_info_dict = {'橱窗id': shop_window_id, '橱窗名称': shop_window_name, 'publish_goods_count': publish_goods_count} shop_window_info_dict.update ( brand_info_dict ) shop_window_list_out.append ( shop_window_info_dict ) except: shop_window_name = shop_window_info['shop_window_name'] shop_window_id = shop_window_info['shop_window_id'] # 创建表信息 publish_goods_count = shop_window_info['publish_goods_count'] shop_window_info_dict = {'橱窗id': shop_window_id, '橱窗名称': shop_window_name, 'publish_goods_count': publish_goods_count} shop_window_info_dict.update ( brand_info_dict ) shop_window_list_out.append ( shop_window_info_dict ) for shop_window_info_dict in shop_window_list_out: page_size = 40 page_count = math.ceil ( shop_window_info_dict['publish_goods_count'] / page_size ) for current_page in range ( 1, page_count + 1 ): goodsInGoodsCentre_url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/shop_window/goods' goodsInGoodsCentre_json_params = {"sell_type": 2, "shop_window_id": shop_window_info_dict['橱窗id'], "current_page": current_page, "page_size": page_size, "app_id": app_id} goodsInGoodsCentre = requests.post ( goodsInGoodsCentre_url, headers = headers, json = goodsInGoodsCentre_json_params ).json ()['detail'] for goodsInfo in goodsInGoodsCentre: goods_id = goodsInfo['goods_id'] goods_name = goodsInfo['goods_name'] goods_no = goodsInfo['goods_no'] publish_state_judge = {'1': '上架', '0': '下架'} publish_state = publish_state_judge[str ( goodsInfo['publish_state'] )] i += 1 # 查看商品适用于哪些门店 apply_store_url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods_shop_window/apply_store/query' apply_store_json_params = {"goods_id": goods_id, "shop_window_id": shop_window_info_dict['橱窗id'], "app_id": app_id} apply_store_info = requests.post ( apply_store_url, headers = headers, json = apply_store_json_params ).json () apply_type_mark = apply_store_info['data']['apply_type'] if apply_type_mark == 1: apply_type = '全部门店适用' elif apply_type_mark == 2: apply_type = '部分门店适用' elif apply_type_mark == 3: apply_type = '部分门店不适用' else: apply_type = '未知' # 创建表信息 goodsInfo_dict = {'商品id': goods_id, '商品编号': goods_no, '商品名称': goods_name, '商品状态': publish_state, '适用门店类型': apply_type} goodsInfo_dict.update ( shop_window_info_dict ) try: for apply_store_id in apply_store_info['data']['apply_store_id_list']: apply_store_dict = selectStoreNoByStoreId ( app_id, token, apply_store_id ) # store_info_dict = {'门店编号':store_no,'门店名称':store_name,'所属品牌':brand_name} apply_store_dict['相关门店id'] = apply_store_id apply_store_dict.update ( goodsInfo_dict ) df_out.append ( apply_store_dict ) except: df_out.append ( goodsInfo_dict ) print ( brand_info_dict, '完成' ) except: print ( brand_info_dict, '出错' ) df_headers = ['品牌id', '品牌名称', '橱窗id', '橱窗名称', '商品id', '商品编号', '商品名称', '商品状态', '适用门店类型', '相关门店id', '门店编号', '门店名称', '所属品牌'] df_out = pd.DataFrame ( df_out, columns = df_headers ) df_out.to_excel ( downloadPath + '/goodsInGoodsCentre.xlsx' ) # 获取【订货橱窗】中商品对应的【适用门店】 def selectGoodInGoodsCentreSUPshops(app_id, token, goods_id, shop_window_id): url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods_shop_window/apply_store/query' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"goods_id": goods_id, "shop_window_id": shop_window_id, "app_id": app_id} resp = requests.post ( url, headers = headers, json = json_params ).json () print(resp) return resp # 更新【订货橱窗】中的商品对应的【适用门店】 def updateGoodsInGoodsCentreSUPshops(app_id, token, uploadFile): headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} df_in = pd.read_excel ( uploadFile ) goods_ids = list ( set ( df_in['商品id'] ) ) for goods_id in goods_ids: shop_window_ids_df = df_in[df_in['商品id'] == goods_id] shop_window_ids = list ( set ( shop_window_ids_df['橱窗id'] ) ) for shop_window_id in shop_window_ids: # brand_id = list (set (shop_window_ids_df[shop_window_ids_df['橱窗id'] == shop_window_id]['品牌id']))[0] # apply_store_ids = list(set(shop_window_ids_df[shop_window_ids_df['橱窗id']==shop_window_id]['门店编号'])) # apply_store_ids1 = selectStoreIdByStoreNo (app_id, token, apply_store_ids,brand_id) #门店编码转门店id # apply_type = list(set(shop_window_ids_df[shop_window_ids_df['橱窗id']==shop_window_id]['适用类型']))[0] #适用类型 apply_store_ids_df = shop_window_ids_df[shop_window_ids_df['橱窗id'] == shop_window_id] apply_types = list ( set ( shop_window_ids_df[shop_window_ids_df['橱窗id'] == shop_window_id]['适用类型'] ) ) # 适用类型 for apply_type in apply_types: time.sleep(random.uniform(2,4)) brand_id = list ( set ( shop_window_ids_df[shop_window_ids_df['橱窗id'] == shop_window_id]['品牌id'] ) )[0] apply_store_ids = list ( set ( apply_store_ids_df[apply_store_ids_df['适用类型'] == apply_type]['门店编号'] ) ) apply_store_ids1 = selectStoreIdByStoreNo ( app_id, token, apply_store_ids, brand_id ) # 门店编码转门店id goods_info = selectGoodInGoodsCentreSUPshops ( app_id, token, goods_id, shop_window_id ) goods_info_apply_type = goods_info['data']['apply_type'] url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods_shop_window/apply_store/set' # 在当前适用类型下追加 if int ( goods_info_apply_type ) == int ( apply_type ): apply_store_id_list = goods_info['data']['apply_store_id_list'] apply_store_ids2 = list ( set ( apply_store_ids1 ) | set ( apply_store_id_list ) ) json_params = {"apply_type": apply_type, "shop_window_id": shop_window_id, "goods_id": goods_id, "apply_store_id_list": apply_store_ids2, "app_id": app_id} no = 1 # 在当前适用类型下移除门店 elif int ( goods_info_apply_type ) != int ( apply_type ) and int ( goods_info_apply_type ) != 1 and int ( apply_type ) != 1: apply_store_id_list = goods_info['data']['apply_store_id_list'] for apply_store_id in apply_store_ids1: try: apply_store_id_list.remove ( apply_store_id ) except: ... json_params = {"apply_type": goods_info_apply_type, "shop_window_id": shop_window_id, "goods_id": goods_id, "apply_store_id_list": apply_store_id_list, "app_id": app_id} no = 2 # 初始进行适用类型划分 elif int ( goods_info_apply_type ) == 1: json_params = {"apply_type": apply_type, "shop_window_id": shop_window_id, "goods_id": goods_id, "apply_store_id_list": apply_store_ids1, "app_id": app_id} no = 3 # 恢复全部门店可见 elif int ( apply_type ) == 1: json_params = {"apply_type": apply_type, "shop_window_id": shop_window_id, "goods_id": goods_id, "app_id": app_id} no = 4 try: resp = requests.post ( url, json = json_params, headers = headers ).json ()['message'] print ( goods_id, shop_window_id, apply_type, resp, no ) except: print ( '参数有误！' ) # 按门店编号查门店id def selectStoreIdByStoreNo(app_id, token, store_no, brand_id): if str ( type ( store_no ) ) != "": url = 'https://cloud.xc-fintech.com/split/get_store_list' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "store_no": store_no, "page": 0, "page_size": 10, "open_align": True, "business_scene_list": []} store_id = requests.post ( url, headers = headers, json = json_params ).json ()['store_list'][0]['store_id'] else: url = 'https://cloud.xc-fintech.com/split/get_store_list' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "page": 0, "page_size": 9999, "brand_id": brand_id} store_list = requests.post ( url, headers = headers, json = json_params ).json ()['store_list'] df_in0 = pd.DataFrame ( store_list ).set_index ( 'store_no' ) df_in1 = pd.DataFrame ( store_no, columns = ['store_no'] ) df_in1['store_no'] = df_in1['store_no'].astype ( str ) df_out = df_in1.join ( df_in0, on = 'store_no', how = 'inner' ) store_id = list ( set ( df_out['store_id'] ) ) return store_id # 按门店id查门店信息 def selectStoreNoByStoreId(app_id, token, store_id): url = 'https://cloud.xc-fintech.com/split/get_store_list' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_params = {"app_id": app_id, "store_id": store_id, "page": 0, "page_size": 10, "open_align": False, "business_scene_list": []} store_info = requests.post ( url, headers = headers, json = json_params ).json ()['store_list'][0] store_no = store_info['store_no'] brand_name = store_info['brand_name'] store_name = store_info['store_name'] store_info_dict = {'门店编号': store_no, '门店名称': store_name, '所属品牌': brand_name} # print(json.dumps(store_info,ensure_ascii=False)) return store_info_dict # 查询所有门店信息 def selectAllStoreInfo(app_id, token, downloadPath): template_dict = selectServiceRate ( app_id, token ) df_out = [] url = 'https://cloud.xc-fintech.com/split/get_store_list' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_0 = {"app_id": app_id, "page": 0, "page_size": 40, "open_align": True, "align_status": 2, "business_scene_list": ["meituan", "eleme", "meituan_group_purchase", "dou_yin_life"]} n = 0 x = requests.post ( url, headers = headers, json = json_0 ).json ()['total_count'] / 40 while n <= x: print ( n ) json_1 = {"app_id": app_id, "page": n, "page_size": 40, "open_align": True, "align_status": 2, "business_scene_list": ["meituan", "eleme", "meituan_group_purchase", "dou_yin_life"]} n += 1 resp = requests.post ( url, headers = headers, json = json_1 ).json () print ( json.dumps ( resp, ensure_ascii = False ) ) store_list = resp['store_list'] for store_info in store_list: try: store_info_dic = { 'store_no': store_info['store_no'], 'store_name': store_info['store_name'], 'brand_name': store_info['brand_name'], 'store_id': store_info['store_id'], 'store_area_name': store_info['store_area_name'], 'store_area_no': store_info['store_area_no'], 'brand_id': store_info['brand_id']} except: store_info_dic = { 'store_no': store_info['store_no'], 'store_name': store_info['store_name'], 'store_id': store_info['store_id'] } try: store_info_dic['order_template_name'] = template_dict[store_info['order_template_id']] except: ... try: trade_mch_list = store_info['trade_mch_list'] trade_mch_dict = {} for trade_mch_info in trade_mch_list: scene = trade_mch_info['scene'] trade_mch_dict[scene] = trade_mch_info['mch_no'] store_info_dic.update ( trade_mch_dict ) except: ... df_out.append ( store_info_dic ) df_out = pd.DataFrame ( df_out ) df_out.to_excel ( downloadPath ) # 查询费率模板 def selectServiceRate(app_id, token): url = 'https://cloud.xc-fintech.com/split/store/area/template' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} params = {"template_type": 1, "app_id": app_id} template_dict = {} try: resp = requests.post ( url, headers = headers, json = params ).json ()['template_list'] for i in resp: name = i['template_name'] rate = name.split ( '取' )[1].split ( '服' )[0] template_dict[i['template_id']] = rate except: ... return template_dict # 查询供应商供货管理中的采购价及建议售价，需上传文件(可参考文件uploadGoods.xlsx) def selectGoodsPriceInSup(app_id, token, uploadFile, downloadPath): # uploadFile = io_path + '/uploadGoods.xlsx' df_in = pd.read_excel ( uploadFile, dtype = str ) n = 0 df_out = [] for sup_id in df_in['供应商id']: goods_id = df_in.loc[n]['商品id'] n += 1 url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/supply_goods/detail' json = {"app_id": app_id, "sup_id": sup_id, "goods_id": goods_id} headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} resp = requests.post ( url, headers = headers, json = json ).json ()['area_price_list'] for a in resp: store_area_id = a['store_area_id'] try: unit = a['sku_price_list'][0]['supply_price_list'][0]['unit'] supply_price = a['sku_price_list'][0]['supply_price_list'][0]['supply_price'] except: unit = '' supply_price = '' l = [sup_id, goods_id, store_area_id, unit, supply_price] df_out.append ( l ) df_out = pd.DataFrame ( df_out, columns = ['sup_id', 'goods_id', 'store_area_id', 'unit', 'supply_price'] ) df_out.to_excel ( downloadPath ) # 查询下载商品具体信息mode(select【需传入goods_id】,download【需传入uploadFile,downloadPath】) def selectGoodsInfoDetail(app_id, token, mode, uploadFile, downloadPath, goods_id): if mode == 'download': df_in = pd.read_excel ( uploadFile, dtype = str ) goods_ids = list ( set ( df_in['商品id'] ) ) df_out = [] for goods_id in goods_ids: df_dict = {} url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/' + goods_id headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json = {"app_id": app_id} resp = requests.post ( url, headers = headers, json = json ).json () df_dict['商品id'] = goods_id df_dict['商品编码'] = resp['goods_no'] df_dict['商品名称'] = resp['name'] df_dict['上下架状态'] = resp['publish_state'] units_info = resp['spu_unit_list'] n = 1 for unit_info in units_info: if unit_info['is_min_unit']: df_dict['最小单位'] = unit_info['unit'] # df_dict['最小单位换算值'] = unit_info['rela_num'] else: df_dict[f'副单位{n}'] = unit_info['unit'] df_dict[f'副单位{n}换算值'] = unit_info['rela_num'] n += 1 df_out.append ( df_dict ) df_out = pd.DataFrame ( df_out, columns = ['商品id', '商品编码', '商品名称', '上下架状态', '最小单位', '副单位1', '副单位1换算值', '副单位2', '副单位2换算值'] ) df_out.to_excel ( downloadPath ) elif mode == 'select': df_dict = {} url = 'https://cloud.xc-fintech.com/api/v1/goods_centre/goods/' + goods_id headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json = {"app_id": app_id} resp = requests.post ( url, headers = headers, json = json ).json () df_dict['上下架状态'] = resp['publish_state'] units_info = resp['spu_unit_list'] n = 1 for unit_info in units_info: if unit_info['is_min_unit']: df_dict['最小单位'] = unit_info['unit'] df_dict['最小单位开关'] = str ( unit_info['orderable'] ) else: df_dict[f'副单位{n}'] = unit_info['unit'] df_dict[f'副单位{n}开关'] = str ( unit_info['orderable'] ) df_dict[f'副单位{n}换算值'] = unit_info['rela_num'] n += 1 return df_dict def selectGoodsOrderByGoodsOrderId(app_id, token, orderId, goodsInfoDf): order_list = [] sup_list = [] url = f'https://cloud.xc-fintech.com/api/v1/goods_order/{int ( orderId )}/query' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} json_p = {"app_id": app_id} resp = requests.post ( url, headers = headers, json = json_p ).json () try: goods_order = resp['goods_order'] goods_order_id = str ( orderId ) store_id = goods_order['store_id'] store_info = selectStoreNoByStoreId ( app_id, token, store_id ) store_no = str ( store_info['门店编号'] ) store_name = store_info['门店名称'] store_brand = store_info['所属品牌'] store_area_name = goods_order['store_area_name'] # print(store_area_name) receiver = goods_order['receiver'] receiver_mobile = goods_order['receiver_mobile'] receiver_address = goods_order['receiver_address'] try: receiver_province_name = goods_order['receiver_province_name'] receiver_city_name = goods_order['receiver_city_name'] receiver_district_name = goods_order['receiver_district_name'] except: try: area_dict = {'无锡市':'江苏省', '盐城市':'江苏省', '苏州市':'江苏省', '南京市':'江苏省', '泰州市':'江苏省', '华江':'上海', '浦东新区':'上海', '青浦区':'上海', '奉贤区':'上海', '嘉定区':'上海', '拉萨市':'西藏自治区', '岳阳市':'湖南省'} receiver_province_name = area_dict[store_area_name] receiver_city_name = '' receiver_district_name = '' except Exception as e: print(e) receiver_province_name = receiver_address[:2] receiver_city_name = '' receiver_district_name = '' print ( orderId, receiver_province_name, receiver_address ) create_time = goods_order['create_time'] temp_time = str ( int ( parse ( create_time ).timestamp () ) ) amount = goods_order['amount'] / 100 goods_order_detail_list = goods_order['goods_order_detail_list'] for goods_order_detail in goods_order_detail_list: goods_id = goods_order_detail['goods_id'] goods_name = goods_order_detail['goods_name'] goods_count = goods_order_detail['goods_count'] unit = goods_order_detail['unit'] store_unit_amount = goods_order_detail['store_unit_amount'] / 100 store_total_amount = goods_order_detail['store_total_amount'] / 100 df_out = goodsInfoDf[goodsInfoDf['商品系统id'] == str ( goods_id )] df_out = df_out[df_out['区域名称(1级)'] == str ( receiver_province_name )] df_out = pd.DataFrame ( df_out ).to_dict ( 'records' ) if len ( df_out ) == 1: dict_out = df_out[0] min_unit = dict_out['最小单位'] classify_name = dict_out['所属分类'] goods_no = dict_out['商品编码'] sup_id = dict_out['供应商id'] sup_name = dict_out['供应商名称'] min_sup_sale = dict_out['最小单位采购价'] sup_sale = dict_out['副单位1采购价'] send_id = str ( sup_id[:9] ) + temp_time if min_unit == unit: goods_count_min = goods_count sup_sale_out = float ( min_sup_sale ) sup_unit = unit else: rela_num = int ( dict_out['副单位1换算值'] ) sup_sale_out = float ( sup_sale ) sup_unit = f'{unit}({rela_num}{min_unit})' goods_count_min = rela_num * goods_count sup_sale_total = float ( sup_sale_out ) * goods_count else: if goods_name == '运费补差价': min_unit = '单' classify_name = '运费' goods_no = 'P12345' sup_id = '4976010005263032320' sup_name = '上海餐小白贸易有限公司' send_id = str ( sup_id[:9] ) + temp_time goods_count_min = goods_count sup_sale_out = 0 sup_sale_total = 0 sup_unit = '单' else: min_unit = 'error' classify_name = 'error' goods_no = 'error' sup_id = 'error' sup_name = 'error' send_id = 'error' goods_count_min = 'error' sup_sale_out = 'error' sup_sale_total = 'error' sup_unit = 'error' print ( goods_order_id, goods_id, '异常' ) dict_out_order = {'订货单号': goods_order_id, '订货门店编号': store_no, '订货门店': store_name, '所属区域': store_area_name, '加盟商级别': '-', '品牌': store_brand, '收货人': receiver, '收货人电话': receiver_mobile, '收货地址': f'{receiver_province_name}/{receiver_city_name}/{receiver_district_name}/{receiver_address}', '下单时间': create_time, '订货单状态': '-', '关闭/完成时间': '-', '订货单总金额（包含运费）': amount, '商品分类': classify_name, '商品编号': goods_no, '商品名称': goods_name, '商品厂商': '-', '规格货号': '-', '规格内容': '-', '商品单位': unit, '商品数量': goods_count, '最小单位': min_unit, '最小单位数量': goods_count_min, '销售单价': store_unit_amount, '小计': store_total_amount, '退款金额': 0, '发货单号': send_id, '发货方编号': sup_id, '发货方名称': sup_name, '发货单状态': '-', '运单号': '-', '发货时间': '-', '签收时间': '-'} dict_out_sup = {'订货门店编号': store_no, '订货门店名称': store_name, '品牌': store_brand, '所属省市区': f'{receiver_province_name}{receiver_city_name}{receiver_district_name}', '发货单号': send_id, '订货单号': goods_order_id, '发货方': sup_name, '发货单金额': '-', '结算金额': '-', '服务费': '-', '交易手续费': '-', '通道手续费': '-', '发货单状态': '-', '创建时间': create_time, '下单时间': create_time, '发货时间': '-', '签收时间': '-', '商品分类': classify_name, '商品编号': goods_no, '商品名称': goods_name, '商品厂商': '-', '货号': '-', '规格': '-', '数量': goods_count, '订货单价': store_unit_amount, '订货小计': store_total_amount, '采购单价': sup_sale_out, '采购小计': sup_sale_total, '单位': sup_unit, '收货人': receiver, '收货人电话': receiver_mobile, '收货地址': f'{receiver_province_name}/{receiver_city_name}/{receiver_district_name}/{receiver_address}', } order_list.append ( dict_out_order ) sup_list.append ( dict_out_sup ) except: print ( orderId, json.dumps ( resp, ensure_ascii = False ) ) return order_list, sup_list def readExcelByPd(upLoadFilePath): df_in = pd.read_excel ( upLoadFilePath, dtype = str ) # receiver_province_name = '江苏省' # goods_id = '4993092771502759936' # df_out = df_in[df_in['商品系统id']==str(goods_id)] # df_out = df_out[df_out['区域名称(1级)']==str(receiver_province_name)] # df_out = pd.DataFrame(df_out).to_dict('records') # if len(df_out) == 1: # dict_out = df_out[0] # print(dict_out) return df_in def selectGoodsOrderByGoodsOrderIds(app_id, token, outDfPath, upLoadFile_goods, upLoadFile_orderids): goodsInfoDf = readExcelByPd ( upLoadFile_goods ) orderidsDF = readExcelByPd ( upLoadFile_orderids ) orderIds = list ( set ( orderidsDF['订货单号'] ) ) order_df_out = [] sup_df_out = [] for orderId in orderIds: order_list, sup_list = selectGoodsOrderByGoodsOrderId ( app_id, token, orderId, goodsInfoDf ) order_df_out = order_df_out + order_list sup_df_out = sup_df_out + sup_list order_df_out = pd.DataFrame ( order_df_out ) sup_df_out = pd.DataFrame ( sup_df_out ) writer = pd.ExcelWriter ( outDfPath ) orderidsDF.to_excel ( writer, sheet_name = '查询订货单号', columns = ['订货单号'], index = False ) order_df_out.to_excel ( writer, sheet_name = '订货单', index = False ) sup_df_out.to_excel ( writer, sheet_name = '发货单', index = False ) writer.save () # 创建发货单下载请求 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 def createInvoiceDownload(app_id, token, start_date, end_date, mode='pay'): ''' mode参数 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 ''' url = 'https://cloud.xc-fintech.com/api/v1/file/create' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} params = {"download_file_type": 40, "sale_type_list": [1, 2, 3, 5, 6], f"start_{mode}_time": f"{start_date} 00:00:00", f"end_{mode}_time": f"{end_date} 23:59:59", "app_id": app_id} resp = requests.post ( url, json = params, headers = headers ).text log_time = datetime.now ().strftime ( '%Y-%m-%d %H:%M:%S' ) print ( log_time, len ( resp ) ) # 查询发货单下载列表，循环检查 发货单是否可以进行下载 def selectInvoiceDownloadList(app_id, token) -> str: ''' 【返回值】为 task_id -> str ''' url = 'https://cloud.xc-fintech.com/api/v1/file/buffer_area/list' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token} params = {"file_type": 40, "current_page": 1, "page_size": 5, "app_id": app_id} a = 2 n = 0 task_ids = [] while a == 2 and n <= 10: try: resp = requests.post(url, json = params, headers = headers, timeout = 2) resp_json = resp.json () task_list = resp_json['task_list'] handle_status = task_list[0]['handle_status'] task_id = task_list[0]['task_id'] task_ids.append ( task_id ) a = handle_status time.sleep(10) except: resp.close () time.sleep (10) a = 2 n += 1 print(n,end ='-') return task_ids[0] # 下载发货单 def invoiceDownload(app_id, token, task_id, save_path, start_date, end_date, mode = 'pay') -> str: ''' 【save_path参数】例：'C:/Users/ClownHe/Desktop/店务通数据' 【mode参数】'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 【返回值】为 df_path -> str格式 ''' url = 'https://cloud.xc-fintech.com/api/v1/file/download' headers = { 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/106.0.0.0 Safari/537.36', 'Authorization': token, 'Accept':'application/json, text/plain, */*', 'Accept-Encoding':'gzip, deflate, br'} params = {"task_id":task_id, "app_id":app_id, "token":token} df_data = requests.post(url,headers=headers,json=params).content with open(save_path + f'/{start_date}至{end_date}发货单({mode}).xlsx', mode = 'wb') as f: f.write(df_data) print(f'【已下载】{start_date}至{end_date}发货单({mode}).xlsx') df_path = save_path + f'/{start_date}至{end_date}发货单({mode}).xlsx' return df_path # 运行发货单下载 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 def runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode = 'pay') -> str: ''' 【save_path参数】例：'C:/Users/ClownHe/Desktop/店务通数据' 【mode参数】'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 【返回值】为 df_path -> str格式 ''' createInvoiceDownload(app_id, token, start_date, end_date, mode) time.sleep(0.5) task_id = selectInvoiceDownloadList(app_id, token) print(task_id) df_path = invoiceDownload(app_id, token, task_id, save_path, start_date, end_date, mode) print(df_path) if 1==1: dfFormatting(df_path) return df_path def dfFormatting(df_in_path): df_in = pd.read_excel(df_in_path) df_in['一级区域'] = df_in['一级区域'].fillna('') df_in['二级区域'] = df_in['二级区域'].fillna('') df_in['三级区域'] = df_in['三级区域'].fillna('') df_in['所属省市区'] = df_in['一级区域'] + df_in['二级区域'] + df_in['三级区域'] df_in['商品分类'] = df_in['二级分类'].fillna(df_in['一级分类']) df_in['发货单号'] = df_in['发货单号'].astype(str) df_in['订货单号'] = df_in['订货单号'].astype(str) # print(df_in.info()) df_out = df_in[ ['订货门店编号', '订货门店名称', '品牌', '所属省市区', '发货单号', '订货单号', '发货方', '发货单金额', '结算金额', '服务费', '交易手续费', '通道手续费', '发货单状态', '创建时间', '下单时间', '发货时间', '签收时间', '商品分类', '商品编号', '商品名称', '商品厂商', '货号', '规格', '数量', '订货单价', '订货小计', '采购单价', '采购小计', '单位', '收货人', '收货人电话', '收货地址']] df_out.to_excel(df_in_path,index = False) if __name__ == '__main__': if 1==1: app_id, token = getToken () print ( app_id, token ) # app_id = '7005337094168150016' # token ='20230207-bff9c872aa2842d2b03f75e25bfb37a0' goods_no = 'P4464051565' io_path = 'C:/Users/ClownHe/Desktop/店务通数据' if 1 == 0: # 获取商品上下架状态及商品id publish_state, goods_id = selectGoodsInfoPubAndId ( app_id, token, goods_no ) # 操作商品上下架，并返回操作结果 return_result = updatePublishState ( app_id, token, publish_state, goods_id ) if return_result: print ( '已完成操作' ) readUploadFile ( 'uploadfileForSupArea.xlsx' ) selectSupplierlist ( app_id, token, 'download' ) selectAllGoodsInfo ( app_id, token, 'download' ) selectAreaTree ( app_id, token ) updateSuppliersAreaInfo ( app_id, token, 'uploadfileForSupArea.xlsx' ) # 以下两步操作，导出供应商在供商品 selectSupplierlist = selectSupplierlist ( app_id, token, 'select' ) goodsInSupplierList ( app_id, token, selectSupplierlist, 'download' ) publish_state, goods_id = selectGoodsInfoPubAndId ( app_id, token, goods_no ) print ( publish_state, goods_id ) addGoodsToSupplierSupList ( app_id, token, io_path + '/addGoodsToSupplierSupList.xlsx' ) selectSupplierlist = selectSupplierlist ( app_id, token, 'select' ) goodsInSupplierList ( app_id, token, selectSupplierlist, 'download' ) updateGoodsAreaSupplierPrice ( app_id, token, io_path + '/updateGoodsAreaSupplierPrice.xlsx' ) goodsInGoodsCentre ( app_id, token, io_path ) selectGoodsInfoDetail ( app_id, token, io_path + '/selectGoodsInfoDetailUP.xlsx', io_path + '/selectGoodsInfoDetail.xlsx' ) updateGoodsSupStatus ( app_id, token, io_path + '/updateGoodsSupStatus-模板.xlsx' ) updateGoodsPriceInGoodsInfoCentre ( app_id, token, io_path + '/updateGoodsPriceInGoodsInfoCentre.xlsx' ) selectAllGoodsInfoInDetailPrice ( app_id, token, io_path + '/selectAllGoodsInfoInDetailPrice.xlsx' ) updateGoodsAreaSupplierPrice ( app_id, token, io_path + '/updateGoodsAreaSupplierPrice.xlsx' ) selectAllStoreInfo ( app_id, token, io_path + '/selectAllStoreInfo.xlsx' ) selectAllGoodsInfoInDetailPrice ( app_id, token, io_path + '/selectAllGoodsInfoInDetailPrice(20230524.9.57).xlsx' ) goodsInGoodsCentre ( app_id, token, io_path ) # 以下三步完成单品绑定供应商，变更供货，实现价格更新 addGoodsToSupplierSupList ( app_id, token, io_path + '/addGoodsToSupplierSupList.xlsx' ) updateGoodsSupStatus ( app_id, token, io_path + '/updateGoodsSupStatus.xlsx' ) updateGoodsAreaSupplierPrice ( app_id, token, io_path + '/updateGoodsAreaSupplierPrice.xlsx' ) readExcelByPd ( io_path + '/selectAllGoodsInfoInDetailPrice(20230524.9.57).xlsx' ) # 按 订货单号 查询订单信息 及发货信息 upLoadFile_goods = '/selectAllGoodsInfoInDetailPrice(20230524.13.00).xlsx' upLoadFile_orderids = '/订货单号查询(截至2023-05-24 12-10-02).xlsx' selectGoodsOrderByGoodsOrderIds ( app_id, token, io_path + '/selectGoodsOrderByGoodsOrderIds.xlsx', io_path + upLoadFile_goods, io_path + upLoadFile_orderids ) selectSupplierlist = [{'供应商id': '7036927150058246144', '供应商全名': '上海炳优实业有限公司', '简称': ''}] goodsInSupplierList ( app_id, token, selectSupplierlist, 'download' ) for i in [0, 1, 2, 3]: updateGoodsAreaSupplierPrice ( app_id, token, io_path + f'/updateGoodsAreaSupplierPrice{i}.xlsx' ) time.sleep ( 4 ) # 运行发货单下载 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 start_date = '2023-10-01' end_date = '2023-10-27' mode = 'supplier_split' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) if 1==0: goodsInGoodsCentre(app_id, token, io_path) if 1==0: updateGoodsInGoodsCentreSUPshops(app_id, token, io_path + '/updateGoodsInGoodsCentreSUPshops.xlsx') if 1==1: # 操作区 # 运行发货单下载 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 start_date = '2024-03-01' end_date = '2024-03-31' mode = 'supplier_split' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) start_date = '2024-04-01' end_date = '2024-04-05' mode = 'supplier_split' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 11 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) start_date = '2024-03-30' end_date = '2024-04-05' mode = 'supplier_split' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) start_date = '2024-03-01' end_date = '2024-03-31' mode = 'pay' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) start_date = '2024-04-01' end_date = '2024-04-05' mode = 'pay' # 'pay'指定为下单时间 'supplier_split'指定为供应商预结算时间 save_path = io_path runInvoiceDownload(app_id, token, save_path, start_date, end_date, mode) # upLoadFile_goods = '/selectAllGoodsInfoInDetailPrice(20231012.16.50).xlsx' # upLoadFile_orderids = '/活动赠送产品订单查询10.12v1.xlsx' # selectGoodsOrderByGoodsOrderIds(app_id, token, # io_path + '/selectGoodsOrderByGoodsOrderIds(赠品)1.xlsx', # io_path + upLoadFile_goods, # io_path + upLoadFile_orderids) # beginTime_int = int ((datetime.today () + timedelta (days=-1)).strftime ('%Y%m%d')) # 20220623 # endTime_int = int ((datetime.today () + timedelta (days=-1)).strftime ('%Y%m%d')) # 20220623 # beginTime_temp = parse (str(beginTime_int)).timestamp () # endTime_temp = parse (str(beginTime_int)).timestamp () # endTime_temp = int(time.time()*1000) # print(endTime_temp) if 1 == 0: # 批量上下架产品 df_in = pd.read_excel ( io_path + '/updatePublishStateBatch.xlsx', dtype = str ) goods_id_list = list ( set ( df_in['商品id'] ) ) for goods_id in goods_id_list: result = updatePublishState ( app_id, token, 0, goods_id ) print ( goods_id, result ) if 1==0: df_path = r'C:\Users\ClownHe\Desktop\店务通数据\2024-03-01至2024-03-31发货单(pay).xlsx' df_in = pd.read_excel(df_path) col = list(df_in.columns) print(col)