tag.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369
  1. package externalcontact
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/silenceper/wechat/v2/util"
  6. )
  7. const (
  8. // getCropTagURL 获取标签列表
  9. getCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_corp_tag_list"
  10. // addCropTagURL 添加标签
  11. addCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_corp_tag"
  12. // editCropTagURL 修改标签
  13. editCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_corp_tag"
  14. // delCropTagURL 删除标签
  15. delCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_corp_tag"
  16. // markCropTagURL 为客户打上、删除标签
  17. markCropTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/mark_tag"
  18. // getStrategyTagListURL 获取指定规则组下的企业客户标签
  19. getStrategyTagListURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/get_strategy_tag_list?access_token=%s"
  20. // addStrategyTagURL 为指定规则组创建企业客户标签
  21. addStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/add_strategy_tag?access_token=%s"
  22. // editStrategyTagURL 编辑指定规则组下的企业客户标签
  23. editStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/edit_strategy_tag?access_token=%s"
  24. // delStrategyTagURL 删除指定规则组下的企业客户标签
  25. delStrategyTagURL = "https://qyapi.weixin.qq.com/cgi-bin/externalcontact/del_strategy_tag?access_token=%s"
  26. )
  27. // GetCropTagRequest 获取企业标签请求
  28. type GetCropTagRequest struct {
  29. TagID []string `json:"tag_id"`
  30. GroupID []string `json:"group_id"`
  31. }
  32. // GetCropTagListResponse 获取企业标签列表响应
  33. type GetCropTagListResponse struct {
  34. util.CommonError
  35. TagGroup []TagGroup `json:"tag_group"`
  36. }
  37. // TagGroup 企业标签组
  38. type TagGroup struct {
  39. GroupID string `json:"group_id"`
  40. GroupName string `json:"group_name"`
  41. CreateTime int64 `json:"create_time"`
  42. GroupOrder int `json:"group_order"`
  43. Deleted bool `json:"deleted"`
  44. Tag []TagGroupTagItem `json:"tag"`
  45. }
  46. // TagGroupTagItem 企业标签内的子项
  47. type TagGroupTagItem struct {
  48. ID string `json:"id"`
  49. Name string `json:"name"`
  50. CreateTime int64 `json:"create_time"`
  51. Order int `json:"order"`
  52. Deleted bool `json:"deleted"`
  53. }
  54. // GetCropTagList 获取企业标签库
  55. // @see https://developer.work.weixin.qq.com/document/path/92117
  56. func (r *Client) GetCropTagList(req GetCropTagRequest) ([]TagGroup, error) {
  57. accessToken, err := r.GetAccessToken()
  58. if err != nil {
  59. return nil, err
  60. }
  61. var response []byte
  62. jsonData, err := json.Marshal(req)
  63. if err != nil {
  64. return nil, err
  65. }
  66. response, err = util.HTTPPost(fmt.Sprintf("%s?access_token=%v", getCropTagURL, accessToken), string(jsonData))
  67. if err != nil {
  68. return nil, err
  69. }
  70. var result GetCropTagListResponse
  71. err = util.DecodeWithError(response, &result, "GetCropTagList")
  72. if err != nil {
  73. return nil, err
  74. }
  75. return result.TagGroup, nil
  76. }
  77. // AddCropTagRequest 添加企业标签请求
  78. type AddCropTagRequest struct {
  79. GroupID string `json:"group_id,omitempty"`
  80. GroupName string `json:"group_name"`
  81. Order int `json:"order"`
  82. Tag []AddCropTagItem `json:"tag"`
  83. AgentID int `json:"agentid"`
  84. }
  85. // AddCropTagItem 添加企业标签子项
  86. type AddCropTagItem struct {
  87. Name string `json:"name"`
  88. Order int `json:"order"`
  89. }
  90. // AddCropTagResponse 添加企业标签响应
  91. type AddCropTagResponse struct {
  92. util.CommonError
  93. TagGroup TagGroup `json:"tag_group"`
  94. }
  95. // AddCropTag 添加企业客户标签
  96. // @see https://developer.work.weixin.qq.com/document/path/92117
  97. func (r *Client) AddCropTag(req AddCropTagRequest) (*TagGroup, error) {
  98. var accessToken string
  99. accessToken, err := r.GetAccessToken()
  100. if err != nil {
  101. return nil, err
  102. }
  103. var response []byte
  104. jsonData, err := json.Marshal(req)
  105. if err != nil {
  106. return nil, err
  107. }
  108. response, err = util.HTTPPost(fmt.Sprintf("%s?access_token=%v", addCropTagURL, accessToken), string(jsonData))
  109. if err != nil {
  110. return nil, err
  111. }
  112. var result AddCropTagResponse
  113. err = util.DecodeWithError(response, &result, "AddCropTag")
  114. if err != nil {
  115. return nil, err
  116. }
  117. return &result.TagGroup, nil
  118. }
  119. // EditCropTagRequest 编辑客户企业标签请求
  120. type EditCropTagRequest struct {
  121. ID string `json:"id"`
  122. Name string `json:"name"`
  123. Order int `json:"order"`
  124. AgentID string `json:"agent_id"`
  125. }
  126. // EditCropTag 修改企业客户标签
  127. // @see https://developer.work.weixin.qq.com/document/path/92117
  128. func (r *Client) EditCropTag(req EditCropTagRequest) error {
  129. accessToken, err := r.GetAccessToken()
  130. if err != nil {
  131. return err
  132. }
  133. var response []byte
  134. jsonData, err := json.Marshal(req)
  135. if err != nil {
  136. return err
  137. }
  138. response, err = util.HTTPPost(fmt.Sprintf("%s?access_token=%v", editCropTagURL, accessToken), string(jsonData))
  139. if err != nil {
  140. return err
  141. }
  142. return util.DecodeWithCommonError(response, "EditCropTag")
  143. }
  144. // DeleteCropTagRequest 删除企业标签请求
  145. type DeleteCropTagRequest struct {
  146. TagID []string `json:"tag_id"`
  147. GroupID []string `json:"group_id"`
  148. AgentID string `json:"agent_id"`
  149. }
  150. // DeleteCropTag 删除企业客户标签
  151. // @see https://developer.work.weixin.qq.com/document/path/92117
  152. func (r *Client) DeleteCropTag(req DeleteCropTagRequest) error {
  153. accessToken, err := r.GetAccessToken()
  154. if err != nil {
  155. return err
  156. }
  157. var response []byte
  158. jsonData, err := json.Marshal(req)
  159. if err != nil {
  160. return err
  161. }
  162. response, err = util.HTTPPost(fmt.Sprintf("%s?access_token=%v", delCropTagURL, accessToken), string(jsonData))
  163. if err != nil {
  164. return err
  165. }
  166. return util.DecodeWithCommonError(response, "DeleteCropTag")
  167. }
  168. // MarkTagRequest 给客户打标签请求
  169. // 相关文档地址:https://developer.work.weixin.qq.com/document/path/92118
  170. type MarkTagRequest struct {
  171. UserID string `json:"userid"`
  172. ExternalUserID string `json:"external_userid"`
  173. AddTag []string `json:"add_tag"`
  174. RemoveTag []string `json:"remove_tag"`
  175. }
  176. // MarkTag 为客户打上标签
  177. // @see https://developer.work.weixin.qq.com/document/path/92118
  178. func (r *Client) MarkTag(request MarkTagRequest) error {
  179. accessToken, err := r.GetAccessToken()
  180. if err != nil {
  181. return err
  182. }
  183. var response []byte
  184. jsonData, err := json.Marshal(request)
  185. if err != nil {
  186. return err
  187. }
  188. response, err = util.HTTPPost(fmt.Sprintf("%s?access_token=%v", markCropTagURL, accessToken), string(jsonData))
  189. if err != nil {
  190. return err
  191. }
  192. return util.DecodeWithCommonError(response, "MarkTag")
  193. }
  194. // GetStrategyTagListRequest 获取指定规则组下的企业客户标签请求
  195. type GetStrategyTagListRequest struct {
  196. StrategyID int `json:"strategy_id"`
  197. TagID []string `json:"tag_id"`
  198. GroupID []string `json:"group_id"`
  199. }
  200. // GetStrategyTagListResponse 获取指定规则组下的企业客户标签响应
  201. type GetStrategyTagListResponse struct {
  202. util.CommonError
  203. TagGroup []StrategyTagGroup `json:"tag_group"`
  204. }
  205. // StrategyTagGroup 规则组下的企业标签组
  206. type StrategyTagGroup struct {
  207. GroupID string `json:"group_id"`
  208. GroupName string `json:"group_name"`
  209. CreateTime int64 `json:"create_time"`
  210. Order int `json:"order"`
  211. StrategyID int `json:"strategy_id"`
  212. Tag []StrategyTag `json:"tag"`
  213. }
  214. // StrategyTag 规则组下的企业标签
  215. type StrategyTag struct {
  216. ID string `json:"id"`
  217. Name string `json:"name"`
  218. CreateTime int64 `json:"create_time"`
  219. Order int `json:"order"`
  220. }
  221. // GetStrategyTagList 获取指定规则组下的企业客户标签
  222. // @see https://developer.work.weixin.qq.com/document/path/94882#%E8%8E%B7%E5%8F%96%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
  223. func (r *Client) GetStrategyTagList(req *GetStrategyTagListRequest) (*GetStrategyTagListResponse, error) {
  224. var (
  225. accessToken string
  226. err error
  227. )
  228. if accessToken, err = r.GetAccessToken(); err != nil {
  229. return nil, err
  230. }
  231. var response []byte
  232. if response, err = util.PostJSON(fmt.Sprintf(getStrategyTagListURL, accessToken), req); err != nil {
  233. return nil, err
  234. }
  235. result := &GetStrategyTagListResponse{}
  236. if err = util.DecodeWithError(response, result, "GetStrategyTagList"); err != nil {
  237. return nil, err
  238. }
  239. return result, nil
  240. }
  241. // AddStrategyTagRequest 为指定规则组创建企业客户标签请求
  242. type AddStrategyTagRequest struct {
  243. StrategyID int `json:"strategy_id"`
  244. GroupID string `json:"group_id"`
  245. GroupName string `json:"group_name"`
  246. Order int `json:"order"`
  247. Tag []AddStrategyTagRequestItem `json:"tag"`
  248. }
  249. // AddStrategyTagRequestItem 为指定规则组创建企业客户标签请求条目
  250. type AddStrategyTagRequestItem struct {
  251. Name string `json:"name"`
  252. Order int `json:"order"`
  253. }
  254. // AddStrategyTagResponse 为指定规则组创建企业客户标签响应
  255. type AddStrategyTagResponse struct {
  256. util.CommonError
  257. TagGroup AddStrategyTagResponseTagGroup `json:"tag_group"`
  258. }
  259. // AddStrategyTagResponseTagGroup 为指定规则组创建企业客户标签响应标签组
  260. type AddStrategyTagResponseTagGroup struct {
  261. GroupID string `json:"group_id"`
  262. GroupName string `json:"group_name"`
  263. CreateTime int64 `json:"create_time"`
  264. Order int `json:"order"`
  265. Tag []AddStrategyTagResponseItem `json:"tag"`
  266. }
  267. // AddStrategyTagResponseItem 标签组内的标签列表
  268. type AddStrategyTagResponseItem struct {
  269. ID string `json:"id"`
  270. Name string `json:"name"`
  271. CreateTime int64 `json:"create_time"`
  272. Order int `json:"order"`
  273. }
  274. // AddStrategyTag 为指定规则组创建企业客户标签
  275. // @see https://developer.work.weixin.qq.com/document/path/94882#%E4%B8%BA%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E5%88%9B%E5%BB%BA%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
  276. func (r *Client) AddStrategyTag(req *AddStrategyTagRequest) (*AddStrategyTagResponse, error) {
  277. var (
  278. accessToken string
  279. err error
  280. )
  281. if accessToken, err = r.GetAccessToken(); err != nil {
  282. return nil, err
  283. }
  284. var response []byte
  285. if response, err = util.PostJSON(fmt.Sprintf(addStrategyTagURL, accessToken), req); err != nil {
  286. return nil, err
  287. }
  288. result := &AddStrategyTagResponse{}
  289. if err = util.DecodeWithError(response, result, "AddStrategyTag"); err != nil {
  290. return nil, err
  291. }
  292. return result, nil
  293. }
  294. // EditStrategyTagRequest 编辑指定规则组下的企业客户标签请求
  295. type EditStrategyTagRequest struct {
  296. ID string `json:"id"`
  297. Name string `json:"name"`
  298. Order int `json:"order"`
  299. }
  300. // EditStrategyTag 编辑指定规则组下的企业客户标签
  301. // see https://developer.work.weixin.qq.com/document/path/94882#%E7%BC%96%E8%BE%91%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
  302. func (r *Client) EditStrategyTag(req *EditStrategyTagRequest) error {
  303. var (
  304. accessToken string
  305. err error
  306. )
  307. if accessToken, err = r.GetAccessToken(); err != nil {
  308. return err
  309. }
  310. var response []byte
  311. if response, err = util.PostJSON(fmt.Sprintf(editStrategyTagURL, accessToken), req); err != nil {
  312. return err
  313. }
  314. return util.DecodeWithCommonError(response, "EditStrategyTag")
  315. }
  316. // DelStrategyTagRequest 删除指定规则组下的企业客户标签请求
  317. type DelStrategyTagRequest struct {
  318. TagID []string `json:"tag_id"`
  319. GroupID []string `json:"group_id"`
  320. }
  321. // DelStrategyTag 删除指定规则组下的企业客户标签
  322. // see https://developer.work.weixin.qq.com/document/path/94882#%E5%88%A0%E9%99%A4%E6%8C%87%E5%AE%9A%E8%A7%84%E5%88%99%E7%BB%84%E4%B8%8B%E7%9A%84%E4%BC%81%E4%B8%9A%E5%AE%A2%E6%88%B7%E6%A0%87%E7%AD%BE
  323. func (r *Client) DelStrategyTag(req *DelStrategyTagRequest) error {
  324. var (
  325. accessToken string
  326. err error
  327. )
  328. if accessToken, err = r.GetAccessToken(); err != nil {
  329. return err
  330. }
  331. var response []byte
  332. if response, err = util.PostJSON(fmt.Sprintf(delStrategyTagURL, accessToken), req); err != nil {
  333. return err
  334. }
  335. return util.DecodeWithCommonError(response, "DelStrategyTag")
  336. }