marketing.py 3.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. # -*- coding: utf-8 -*-
  2. from __future__ import absolute_import, unicode_literals
  3. import json
  4. import datetime
  5. from optionaldict import optionaldict
  6. from library.wechatpy.client.api.base import BaseWeChatAPI
  7. class WeChatMarketing(BaseWeChatAPI):
  8. API_BASE_URL = 'https://api.weixin.qq.com/marketing/'
  9. def add_user_action_sets(self, _type, name, description, version='v1.0'):
  10. """
  11. 创建数据源
  12. https://wximg.qq.com/wxp/pdftool/get.html?id=rkalQXDBM&pa=39
  13. :param _type: 用户行为源类型
  14. :param name: 用户行为源名称 必填
  15. :param description: 用户行为源描述,字段长度最小 1 字节,长度最大 128 字节
  16. :param version: 版本号 v1.0
  17. :return: 数据源唯一ID
  18. """
  19. return self._post(
  20. 'user_action_sets/add',
  21. params={'version': version},
  22. json=optionaldict(
  23. type=_type,
  24. name=name,
  25. description=description,
  26. version=version
  27. ),
  28. result_processor=lambda x: x['data']['user_action_set_id']
  29. )
  30. def get_user_action_sets(self, user_action_set_id, version='v1.0'):
  31. """
  32. 获取数据源信息
  33. :param user_action_set_id: 数据源唯一ID
  34. :param version: 版本号 v1.0
  35. """
  36. return self._get(
  37. 'user_action_sets/get',
  38. params={'version': version, 'user_action_set_id': user_action_set_id},
  39. result_processor=lambda x: x['data']['list']
  40. )
  41. def add_user_actions(self, actions=(), version='v1.0'):
  42. """
  43. 回传数据
  44. https://wximg.qq.com/wxp/pdftool/get.html?id=rkalQXDBM&pa=39
  45. :param actions: 用户行为源类型
  46. :param version: 版本号 v1.0
  47. """
  48. return self._post(
  49. 'user_actions/add',
  50. params={'version': version},
  51. json={'actions': actions}
  52. )
  53. def get_ad_leads(self, start_date=None, end_date=None, filtering=(), page=1, page_size=100, version='v1.0'):
  54. """
  55. 获取朋友圈销售线索数据接口
  56. :param start_date: 开始日期 默认今天
  57. :param end_date: 结束日期 默认今天
  58. :param filtering: 过滤条件 [{field: 过滤字段, operator: 操作符, values: 字段取值}]
  59. :param page: 页码,获取指定页数据
  60. :param page_size: 一页获取的数据条数(1-100)
  61. :param version: 版本号 v1.0
  62. """
  63. today = datetime.date.today()
  64. if start_date is None:
  65. start_date = today
  66. if end_date is None:
  67. end_date = today
  68. if isinstance(start_date, datetime.date):
  69. start_date = start_date.strftime("%Y-%m-%d")
  70. if isinstance(end_date, datetime.date):
  71. end_date = end_date.strftime("%Y-%m-%d")
  72. return self._get(
  73. 'wechat_ad_leads/get',
  74. params=optionaldict(
  75. date_range=json.dumps({'start_date': start_date, 'end_date': end_date}),
  76. filtering=json.dumps(filtering) if filtering else None,
  77. page=page,
  78. page_size=page_size,
  79. version=version
  80. ),
  81. result_processor=lambda x: x['data']
  82. )