本地端群控千牛批量删除或上下架符合关键词的宝贝

  • A+
所属分类：编程语言

最近看到如下需求，和目前正在做的千牛批量处理比较类似，目前已经解决了无限账号登陆统一管理的问题，批量上下架宝贝的问题等。调查一下是否需求比较大，有大量需求的话和站长联系具体开发细节和功能需求，微信ak476118 

展开

  1. class TBApi(TBCore):
  3.     def search_order(self,orderId='3849201972101364512'):
  4.         url = 'https://trade.taobao.com/trade/itemlist/asyncSold.htm'
  5.         headers = {
  6.             'Referer': 'https://qn.taobao.com/',
  7.             'Accept': '*/*',
  8.             'Connection': 'keep-alive',
  9.             'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 SE 2.X MetaSr 1.0',
  10.         }
  11.         params = {
  12.             'event_submit_do_query': '1',
  13.             '_input_charset': 'utf8',
  14.         }
  16.         data = {
  17.             'prePageNo': '1',
  18.             'sifg': '0',
  19.             'action': 'itemlist/SoldQueryAction',
  20.             'tabCode': 'latest3Months',
  21.             'buyerNick': '',
  22.             'dateBegin': 'NaN',
  23.             'dateEnd': 'NaN',
  24.             'orderStatus': 'ALL',
  25.             'rateStatus': 'ALL',
  26.             'pageSize': '15',
  27.             'rxOldFlag': '0',
  28.             'rxSendFlag': '0',
  29.             'useCheckcode': 'false',
  30.             'tradeTag': '0',
  31.             'rxHasSendFlag': '0',
  32.             'auctionType': '0',
  33.             'close': '0',
  34.             'sellerNick': '',
  35.             'notifySendGoodsType': 'ALL',
  36.             'sellerMemoFlag': '0',
  37.             'useOrderInfo': 'false',
  38.             'logisticsService': 'ALL',
  39.             'isQnNew': 'true',
  40.             'pageNum': '1',
  41.             'o2oDeliveryType': 'ALL',
  42.             'rxAuditFlag': '0',
  43.             'queryOrder': 'desc',
  44.             'holdStatus': '0',
  45.             'rxElectronicAuditFlag': '0',
  46.             'queryMore': 'false',
  47.             'rxWaitSendflag': '0',
  48.             'sellerMemo': '0',
  49.             'rxElectronicAllFlag': '0',
  50.             'rxSuccessflag': '0',
  51.             'refund': 'ALL',
  52.             'errorCheckcode': 'false',
  53.             'mailNo': '',
  54.             'yushouStatus': 'ALL',
  55.             'orderType': 'ALL',
  56.             'deliveryTimeType': 'ALL',
  57.             'queryTag': '',
  58.             'orderId': orderId,
  59.             'buyerEncodeId': '',
  60.             'isHideNick': 'true',
  61.         }
  62.         req = self.session.post(url,params=params,data=data,headers=headers)
  63.         mainOrders = req.json().get('mainOrders')
  64.         pprint(mainOrders)
  65.         return req
  67.     def query_sold_item_list(self,orderStatus='PAID'):
  68.         """
  69.         订单查询处理,#如果不要该参数表示获取所有订单包括已经完成的 关闭的订单DROP，成功的订单SUCCESS，待发货的订单PAID，已发货SEND,等待付款的NOT_PAID
  70.         获取三个月内的订单信息
  71.         tabCode: before3Months 三月前的订单 rateStatus:"" orderStatus: ""
  72.         tabCode: deliveryHadTimeOut 已过时订单
  73.         tabCode: waitSend 等待发货
  74.         :return:
  75.         """
  76.         url = 'https://trade.taobao.com/trade/itemlist/asyncSold.htm'
  77.         headers = {
  78.             'Referer': 'https://qn.taobao.com/',
  79.             #     'Referer': 'https://trade.taobao.com/trade/itemlist/asyncSold.htm?event_submit_do_query=1&_input_charset=gbk&sifg=1',
  80.             'Accept': '*/*',
  81.             'Connection': 'keep-alive',
  82.             'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 SE 2.X MetaSr 1.0',
  83.         }
  85.         params = {
  86.             'event_submit_do_query': '1',
  87.             '_input_charset': 'utf8',
  88.         }
  89.         data = {
  90.             'action':'itemlist/SoldQueryAction',
  91.             'actionType':0,
  92.             'close':0,
  93.             'pageNum':1,
  94.             'pageSize':15,
  95.             'queryMore':False,
  96.             'showQueryTag':True,
  97.             'tradeTag':0,
  98.             'useOrderInfo':False,
  99.             'orderStatus':orderStatus,
  100.             'prePageNo':1,
  101.         }
  103.         req = self.session.post(url,params=params,data=data,headers=headers)
  104.         data = req.json().get("mainOrders")
  105.         pprint(data)
  106.         req = self.session.get('https://wuliu.taobao.com/user/order_list_new.htm?order_status_show=send')
  107.         print(req.text)
  108.         # <a class="btn" href="//wuliu.taobao.com/user/consign.htm?order_id=643946624243">发货</a> 要加一个old=1&
  109.         #get请求直接确认发货 https://wuliu.taobao.com/user/order_detail_old.htm?order_id=643946624243&show_menu_in_detail=true&change_result=true
  110.         return req
  112.     def memo_order_sold(self,orderId="3849201972101364512"):
  113.         """
  114.         查询订单的注释信息
  115.         :param orderId:
  116.         :return:
  117.         """
  118.         api = 'mtop.com.taobao.order.sold.memo'
  119.         body = json.dumps({"operation":"queryMemo","orderId":orderId}) #orderId"3849201972101364512"
  120.         response = self._h5request(api, body)
  121.         pprint(response.json())
  122.         return response
  124.     def update_memo_order_sold(self,orderId="3853424016200364512",flagId='4',memoContent='备注33333'):
  125.         """
  126.         设置订单备注信息
  127.         :param orderId:
  128.         operation：batchUpdate 批量标注则在batchOrderIdList中写订单编码
  129.         :return:
  130.         """
  131.         api = 'mtop.com.taobao.order.sold.memo'
  132.         body = json.dumps({"operation":"update","orderId":orderId,"params":json.dumps({"flagId":flagId,"flagTag":"","memoContent":memoContent,"tagToUpdateGlobal":"[]","batchOrderIdList":"[]"})}) #orderId"3849201972101364512"
  133.         response = self._h5request(api, body)
  134.         pprint(response.json())
  135.         return response
  137.     def soldop_trade(self,orderId="3853424016200364512"):
  138.         """
  139.         关闭订单
  140.         :param orderId:
  141.         operation：batchUpdate 批量标注则在batchOrderIdList中写订单编码
  142.         :return:
  143.         """
  144.         api = 'mtop.taobao.trade.soldop'
  145.         body = json.dumps({"paramMap":json.dumps({"closeReason":"买家信息填写错误，重新拍"}),"orderId":orderId,"code":"closeOrder","terminalType":"pc"}) #orderId"3849201972101364512"
  146.         response = self._h5request(api, body)
  147.         pprint(response.json())
  148.         return response
  150.     def get_shop_info(self):
  151.         """
  152.         获取店铺信息
  153.         :return:
  154.         """
  155.         api = 'mtop.taobao.jdy.resource.shop.info.get'
  156.         body = json.dumps({})
  157.         response = self._h5request(api, body)
  158.         self._parse_h5_res(response)
  159.         return response
  161.     def donate_goodsseller_projectlist(self):
  162.         """
  163.         获取公益捐赠项目
  164.         :return:
  165.         """
  166.         api = 'mtop.taobao.csr.donate.goodsseller.projectlist'
  167.         body = json.dumps({"projectCodeList":[]})
  168.         response = self._h5request(api, exparams=body)
  169.         print(json.loads(response.text))
  170.         # self._parse_h5_res(response)
  171.         return response
  173.     def set_csr_goods(self,IDs=["784380895646"]):
  174.         """
  175.         {"donateMode":0,"donateProjectCode":"d126578e45a44d09b0493258c88c2b61","csrProceed":true,"wholeShop":false,"itemIdList":"[\"780186781933\"]","showCsrDetail":true}
  176.         :return:
  177.         """
  178.         # IDs = ["780445794088","780186781933"]
  179.         api = 'mtop.taobao.csr.donate.goodsseller.setCsrGoods'
  180.         exparams = json.dumps({"donateMode":0,"donateProjectCode":"d126578e45a44d09b0493258c88c2b61","csrProceed":True,"wholeShop":False,"itemIdList":json.dumps(IDs),"showCsrDetail":True})
  181.         # exparams = '{"donateMode":0,"donateProjectCode":"d126578e45a44d09b0493258c88c2b61","csrProceed":true,"wholeShop":false,"itemIdList":"[\"780445794088\"]","showCsrDetail":true}'
  182.         response = self._h5request(api, exparams=exparams)
  183.         data = json.loads(response.text)
  184.         # self._parse_h5_res(response)
  185.         return response
  187.     def cancel_csr_goods(self,IDs=["784380895646"]):
  188.         """
  189.         获取店铺信息
  190.         :return:
  191.         """
  192.         # IDs = ["780445794088","780186781933"]
  193.         api = 'mtop.taobao.csr.donate.goodsseller.cancelSetCsrGoods'
  194.         body = json.dumps({"wholeShop":False,"itemIdList":json.dumps(IDs)})
  195.         response = self._h5request(api, exparams=body)
  196.         data = json.loads(response.text)
  197.         # self._parse_h5_res(response)
  198.         return response
  200.     def fast_edit_sell(self,itemId='780445794088',optType='downShelf'):
  201.         """
  202.         快速管理商品的上架、下架、删除
  203.         上架商品optType=upShelf
  204.         批量上架商品optType=batchUpShelf  {"itemId":[itemId,itemId],"auctionids":[itemId,itemId]}
  205.         下架商品optType=downShelf
  206.         删除商品optType=deleteItem
  207.         恢复商品optType=recycleItem
  208.         :return:
  209.         """
  210.         api = 'mtop.taobao.sell.pc.manage.async'
  211.         if optType in ['upShelf','downShelf','deleteItem']:
  212.             data = {"itemId":itemId}
  213.         elif optType in ['batchUpShelf','batchDownShelf','batchDeleteItem']:
  214.             if isinstance(itemId,str):
  215.                 itemId = [itemId]
  216.             if not isinstance(itemId,list):
  217.                 return '商品编码格式不正确！'
  218.             data = {"itemId":itemId,"auctionids":itemId}
  219.         elif optType in ['recycleItem']:
  220.             if isinstance(itemId,str):
  221.                 itemId = [itemId]
  222.             data = {"reasonSelect":{"value":"-1","text":"其他"},"itemId":itemId,"auctionids":itemId}
  223.         else:
  224.             data = {"itemId": itemId}
  225.         body = json.dumps({'url': f'/taobao/manager/fastEdit.htm?optType={optType}&action=submit', 'jsonBody': json.dumps(data)})
  226.         response = self._h5request(api, body)
  227.         self._parse_h5_res(response)
  228.         # pprint(result.get('data',{}).get('table',{}).get('dataSource'))
  229.         # print(result.get('dataSource'))
  230.         return response
  232.     def taobao_manager_table(self,tabtype='all',filter_type={},table_type={}):
  233.         """
  234.         tabtype='all' 全部商品，包括出售中，仓库中的,
  235.         tabtype='on_sale' 在售
  236.         tabtype='in_stock' 仓库中
  237.         tabtype='rubbish' 回收站中的
  238.         tabtype='draft' 草稿箱中的
  239.         unsalable #滞销下架
  240.         history #历史的商品
  241.         failed #违规的
  242.         后去商品数据，在售数据等
  243.         # filter_type = {} #商品搜索
  244.         # filter_type.update({"queryTitle":queryTitle}) #标题
  245.         # filter_type.update({"queryItemId":queryItemId}) #商品id
  246.         # filter_type.update({"queryOuterId":queryOuterId}) #商家编码
  247.         # filter_type.update({"queryShopCategoryId":queryShopCategoryId}) #店铺分类
  248.         # filter_type.update({"querySkuOuterId":querySkuOuterId}) #sku商家编码
  249.         # table_type = {} #表格排序
  250.         # table_type.update({"sort":{"soldQuantityPromotion":"desc"}})
  251.         # \"sort\":{\"soldQuantityPromotion\":\"desc\"} 累积销量 asc
  252.         #"sort\":{\"monthlySoldQuantity\":\"desc\"} 月销量
  253.         :return:
  254.         """
  255.         api = 'mtop.taobao.sell.pc.manage.async'
  256.         body = json.dumps({'url': '/taobao/manager/table.htm', 'jsonBody': json.dumps({"tab":tabtype,"pagination":{"current":1,"pageSize":20},"filter":filter_type,"table":table_type})})
  257.         response = self._h5request(api, body)
  258.         self._parse_h5_res(response)
  259.         # data = response.json()
  260.         # result = json.loads(data.get('data',{}).get('result','{}'))
  261.         # pprint(result)
  262.         # pprint(result.get('data',{}).get('table',{}).get('dataSource'))
  263.         # print(result.get('dataSource'))
  264.         return response
  266.     def send_product(self):
  267.         """
  268.         浏览物流列表，获取csrf
  269.         发货,可能需要先获取列表然后从cookie中获取'XSRF-TOKEN' 即是_csrf
  270.         首先根据订单号生成orderid 网址如下，请求后会注入csrf 同时返回参数信息
  271.         https://wuliu2.taobao.com/user/consign.do?from=list&params=v3&tradeId=3853137024409364512
  272.         :return:
  273.         """
  274.         url = 'https://wuliu2.taobao.com/user/do_consign.do'
  275.         headers = {
  276.             'Referer': 'https://qn.taobao.com/',
  277.             'Accept': '*/*',
  278.             'Connection': 'keep-alive',
  279.             'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 SE 2.X MetaSr 1.0',
  280.         }
  282.         data = {
  283.             '_csrf':self.session.cookies.get('XSRF-TOKEN',''), #'0bd944e8-8e07-4ad5-a47c-ed4e17af2b1b',
  284.             'params': json.dumps({}),
  285.             'type': '0',
  286.         }
  287.         # req = self.session.post(url,data=data,headers=headers)
  288.         # mainOrders = req.json().get('mainOrders')
  289.         # print(mainOrders)
  290.         req = self.session.get('https://wuliu.taobao.com/user/order_detail_old.htm?order_id=644456868389&show_menu_in_detail=true&change_result=true')
  291.         print(req.content)
  292.         return req
  294.     def query_order_list(self):
  295.         """查询物流信息,待发货"""
  296.         headers = {
  297.             'user-agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/94.0.4606.71 Safari/537.36 SE 2.X MetaSr 1.0',
  298.             'referer': 'https://qn.taobao.com/',
  299.         }
  300.         params = {
  301.             'pageSize': '20',
  302.             'pageIndex': '1',
  303.             'listType': 'send',
  304.             'orderType': '-1',
  305.         }
  306.         response = self.session.get('https://wuliu2.taobao.com/user/queryOrderList', params=params, headers=headers)
  307.         pprint(response.json())
  309. if __name__ == '__main__':
  310.     tbapi = TBApi()
  311.     tbapi.get_shop_info()
  312.     tbapi.query_order_list()
  313.     tbapi.memo_order_sold()
  314.     tbapi.taobao_manager_table(tabtype='in_stock')
  315.     tbapi.fast_edit_sell(itemId='780445794088',optType='downShelf')
  316.     tbapi.query_sold_item_list()
  317.     tbapi.send_product()
  318.     tbapi.donate_goodsseller_projectlist()
  319.     tbapi.set_csr_goods()
  320.     tbapi.cancel_csr_goods()

千牛批量处理

现在需要有一个后台 我能批量控制其他几百家或者上千家的淘宝店铺 批量删除或者上下架符合我要求的宝贝，比如关键词，上架时间，销量等，还需要能批量设置优惠券 和一些简单的功能比如（退货地址，店铺信息，子账号权限） 能减少人工重复操作的流程。

我们有多个淘宝店铺，目前正在使用千牛平台进行店铺的管理，包括日常的商品管理、订单管理、活动设置等等。
那么目前的需求则有：

1）、希望开发一个本地软件系统，能绑定多个淘宝店铺，无限制
2）、可以根据商品标题关键词检索勾选所有店铺或者要处理的多个店铺，进行商品的批量删除，批量下架操作，不需要每个店铺操作
3）、也可以批量一次设置多个店铺优惠券，营销宝
4.可以共享云违规功能（比如A店铺店铺出现某个违规 其他店铺会自动排查这个宝贝进行删除）

 

weinxin
我的微信公众号
爱真理，得永生！　　　　　　　　　　爱在灵灵久博客，网罗天下，福利大家！