Subscription.php 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. <?php
  2. /**
  3. * 订阅/取消订阅标签.
  4. * @author wangkuiwei
  5. * @name Subscription
  6. *
  7. */
  8. class Subscription extends HttpBase {
  9. public function __construct() {
  10. parent::__construct();
  11. }
  12. public function subscribe($regId, $topic, $retries = 1) {
  13. $fields = array('registration_id' => $regId, 'topic' => $topic);
  14. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC(), $fields, $retries);
  15. }
  16. public function subscribeForRegids($regIdList, $topic, $retries = 1) {
  17. $jointRegIds = '';
  18. foreach ($regIdList as $regId) {
  19. if (isset($regId)) {
  20. $jointRegIds .= $regId . \Constants::$comma;
  21. }
  22. }
  23. $fields = array('registration_id' => $jointRegIds, 'topic' => $topic);
  24. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC(), $fields, $retries);
  25. }
  26. public function unsubscribe($regId, $topic, $retries = 1) {
  27. $fields = array('registration_id' => $regId, 'topic' => $topic);
  28. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC(), $fields, $retries);
  29. }
  30. public function unsubscribeForRegids($regIdList, $topic, $retries = 1) {
  31. $jointRegIds = '';
  32. foreach ($regIdList as $regId) {
  33. if (isset($regId)) {
  34. $jointRegIds .= $regId . \Constants::$comma;
  35. }
  36. }
  37. $fields = array('registration_id' => $jointRegIds, 'topic' => $topic);
  38. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC(), $fields, $retries);
  39. }
  40. public function subscribeTopicByAlias($aliasList, $topic, $retries = 1) {
  41. $jointAliases = '';
  42. foreach ($aliasList as $alias) {
  43. if (isset($alias)) {
  44. $jointAliases .= $alias . \Constants::$comma;
  45. }
  46. }
  47. $fields = array('aliases' => $jointAliases, 'topic' => $topic);
  48. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC_BY_ALIAS(), $fields, $retries);
  49. }
  50. public function unsubscribeTopicByAlias($aliasList, $topic, $retries = 1) {
  51. $jointAliases = '';
  52. foreach ($aliasList as $alias) {
  53. if (isset($alias)) {
  54. $jointAliases .= $alias . \Constants::$comma;
  55. }
  56. }
  57. $fields = array('aliases' => $jointAliases, 'topic' => $topic);
  58. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC_BY_ALIAS(), $fields, $retries);
  59. }
  60. public function subscribeByPackageName($regId, $topic, $packageName, $retries = 1) {
  61. $fields = array('registration_id' => $regId, 'topic' => $topic, 'restricted_package_name' => $packageName);
  62. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC(), $fields, $retries);
  63. }
  64. public function subscribeForRegidsByPackageName($regIdList, $topic, $packageName, $retries = 1) {
  65. $jointRegIds = '';
  66. foreach ($regIdList as $regId) {
  67. if (isset($regId)) {
  68. $jointRegIds .= $regId . \Constants::$comma;
  69. }
  70. }
  71. $fields = array('registration_id' => $jointRegIds, 'topic' => $topic, 'restricted_package_name' => $packageName);
  72. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC(), $fields, $retries);
  73. }
  74. public function unsubscribeByPackageName($regId, $topic, $packageName, $retries = 1) {
  75. $fields = array('registration_id' => $regId, 'topic' => $topic, 'restricted_package_name' => $packageName);
  76. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC(), $fields, $retries);
  77. }
  78. public function unsubscribeForRegidsByPackageName($regIdList, $topic, $packageName, $retries = 1) {
  79. $jointRegIds = '';
  80. foreach ($regIdList as $regId) {
  81. if (isset($regId)) {
  82. $jointRegIds .= $regId . \Constants::$comma;
  83. }
  84. }
  85. $fields = array('registration_id' => $jointRegIds, 'topic' => $topic, 'restricted_package_name' => $packageName);
  86. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC(), $fields, $retries);
  87. }
  88. public function subscribeTopicByPackageNameAlias($aliasList, $topic, $packageName, $retries = 1) {
  89. $jointAliases = '';
  90. foreach ($aliasList as $alias) {
  91. if (isset($alias)) {
  92. $jointAliases .= $alias . \Constants::$comma;
  93. }
  94. }
  95. $fields = array('aliases' => $jointAliases, 'topic' => $topic, 'restricted_package_name' => $packageName);
  96. return $this->postResult(\PushRequestPath::V2_SUBSCRIBE_TOPIC_BY_ALIAS(), $fields, $retries);
  97. }
  98. public function unsubscribeTopicByPackageNameAlias($aliasList, $topic, $packageName, $retries = 1) {
  99. $jointAliases = '';
  100. foreach ($aliasList as $alias) {
  101. if (isset($alias)) {
  102. $jointAliases .= $alias . \Constants::$comma;
  103. }
  104. }
  105. $fields = array('aliases' => $jointAliases, 'topic' => $topic, 'restricted_package_name' => $packageName);
  106. return $this->postResult(\PushRequestPath::V2_UNSUBSCRIBE_TOPIC_BY_ALIAS(), $fields, $retries);
  107. }
  108. }
  109. ?>