PushService.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358
  1. <?php
  2. namespace App\Modules\Push\Services;
  3. use App\Cache\PushCache;
  4. use App\Consts\PushConst;
  5. use App\Libs\Push\OPPOPush\OPPOPushCommon;
  6. use App\Libs\Push\XMPush\MiPushCommon;
  7. use App\Libs\Utils;
  8. use App\Consts\ErrorConst;
  9. use App\Libs\Push\HuaWei\HwPushCommon;
  10. use App\Modules\Push\Models\QappPushApp;
  11. use App\Exceptions\ApiException;
  12. use App\Modules\Push\Models\QappPushTask;
  13. use App\Modules\Push\Models\QappPushTaskLogs;
  14. use App\Modules\Push\Models\QappPushTaskUsers;
  15. use App\Modules\Push\Models\QappPushUser;
  16. use App\Modules\User\Models\QappPackage;
  17. use Exception;
  18. use GuzzleHttp\Exception\GuzzleException;
  19. class PushService
  20. {
  21. /**
  22. * 设置用户reg_id
  23. * @param $uid
  24. * @param string $regId
  25. * @param string $provider
  26. * @param string $package
  27. * @return bool
  28. */
  29. public static function setUserRegId($uid, string $regId, string $provider, string $package): bool
  30. {
  31. myLog('push')->info('setUserRegId', compact('uid', 'regId', 'provider', 'package'));
  32. // push服务商(转小写)
  33. $provider = strtolower($provider);
  34. if (empty($uid) || empty($regId) || empty($package) || empty($provider)) {
  35. return false;
  36. }
  37. // 获取缓存
  38. $userCacheRegId = PushCache::getUserPushRegId($uid);
  39. if ($regId === $userCacheRegId) {
  40. myLog('push')->info('setUserRegId', ['cache' => 'match']);
  41. return true;
  42. }
  43. // 获取包信息
  44. $packageInfo = QappPackage::getPackageByPackage($package);
  45. $packageId = getProp($packageInfo, 'id');
  46. $channelId = getProp($packageInfo, 'channel_id');
  47. $company = getProp($packageInfo, 'company');
  48. myLog('push')->info('setUserRegId', compact('packageId', 'channelId', 'company'));
  49. if (empty($packageId)) {
  50. return false;
  51. }
  52. // 获取app信息
  53. $pushApp = QappPushApp::getPushAppByPackageIdAndProvider($packageId, $provider);
  54. $pushAppId = getProp($pushApp, 'app_id');
  55. myLog('push')->info('setUserRegId', compact('pushAppId'));
  56. if (!$pushAppId) {
  57. return false;
  58. }
  59. // 设置
  60. $pushUser = QappPushUser::getPushUserByUid($uid);
  61. $pushUserRegId = (string)getProp($pushUser, 'reg_id');
  62. myLog('push')->info('setUserRegId', compact('pushUserRegId'));
  63. if ($pushUserRegId === $regId) {
  64. PushCache::setUserPushRegId($uid, $regId);
  65. return true;
  66. }
  67. // 初始化用户Push信息
  68. if (!$pushUser) {
  69. // 初始化push_users
  70. QappPushUser::initPushUser($uid, $regId, $pushAppId, $provider, $channelId);
  71. // 针对华为用户需要主动订阅topic,方便后续全量推送
  72. if ($provider === PushConst::PROVIDER_HW) {
  73. $client = new HwPushCommon($pushAppId, getProp($pushApp, 'app_secret'));
  74. $client->subscribeTopic(PushConst::TOPIC_ALL, [$regId]);
  75. }
  76. }
  77. // 更新用户reg id缓存
  78. $result = QappPushUser::setUserRegId($uid, $regId);
  79. if ($result) {
  80. PushCache::setUserPushRegId($uid, $regId);
  81. }
  82. return $result;
  83. }
  84. /**
  85. * 推送消息
  86. * @param $taskId
  87. * @return bool
  88. * @throws ApiException
  89. * @throws GuzzleException
  90. */
  91. public static function sendMessage($taskId): bool
  92. {
  93. if (empty($taskId)) {
  94. return false;
  95. }
  96. // 获取任务数据
  97. $pushTask = QappPushTask::getPushTaskById($taskId);
  98. if ((int)getProp($pushTask, 'status') !== PushConst::PUSH_STATUS_TODO ||
  99. (int)getProp($pushTask, 'select_user_status') !== PushConst::SELECT_USER_OK) {
  100. Utils::throwError(ErrorConst::PUSH_TASK_INVALID);
  101. }
  102. // 判断任务时间
  103. if (getProp($pushTask, 'push_time') > date('Y-m-d H:i:s')) {
  104. Utils::throwError(ErrorConst::PUSH_TASK_NOT_START);
  105. }
  106. // 获取全部子任务
  107. $subTasks = QappPushTaskLogs::getPushTaskLogsByTaskId($taskId);
  108. if (!$subTasks) {
  109. Utils::throwError(ErrorConst::PUSH_TASK_LOGS_NOT_FOUND);
  110. }
  111. // 获取推送应用信息
  112. $pushAppIds = array_column($subTasks, 'app_id');
  113. $pushApps = QappPushApp::getPushAppByAppIds($pushAppIds);
  114. if (!$pushApps) {
  115. Utils::throwError(ErrorConst::PUSH_APP_NOT_SET);
  116. }
  117. // 更新任务开始状态
  118. QappPushTask::updatePushTask(getProp($pushTask, 'id'), [
  119. 'status' => PushConst::PUSH_STATUS_DOING,
  120. 'updated_at' => date('Y-m-d H:i:s')
  121. ]);
  122. // 判断是全量发送还是批量发送
  123. if (getProp($pushTask, 'push_filter') === 'all') {
  124. $result = self::pushMessageToAll($pushTask, $subTasks, $pushApps);
  125. } else {
  126. $result = self::pushMessageToUsers($pushTask, $subTasks, $pushApps);
  127. }
  128. // 更新任务执行状态
  129. QappPushTask::updatePushTask(getProp($pushTask, 'id'), [
  130. 'status' => $result ? PushConst::PUSH_STATUS_SUCCESS : PushConst::PUSH_STATUS_FAIL,
  131. 'updated_at' => date('Y-m-d H:i:s')
  132. ]);
  133. return $result;
  134. }
  135. /**
  136. * 全部发送
  137. * @param $pushTask
  138. * @param $subTasks
  139. * @param $pushApps
  140. * @return bool
  141. * @throws GuzzleException
  142. */
  143. private static function pushMessageToAll($pushTask, $subTasks, $pushApps): bool
  144. {
  145. if (empty($pushTask) || empty($subTasks) || empty($pushApps)) {
  146. return false;
  147. }
  148. $pushResult = true;
  149. // 循环群发
  150. foreach ($subTasks as $subTask) {
  151. $appId = getProp($subTask, 'app_id');
  152. $subTaskId = getProp($subTask, 'id');
  153. $pushApp = collect($pushApps)->firstWhere('app_id', $appId);
  154. if (empty($pushApp)) {
  155. continue;
  156. }
  157. // push app相关
  158. $title = getProp($pushTask, 'title');
  159. $content = getProp($pushTask, 'content');
  160. $url = getProp($pushTask, 'url');
  161. $provider = strtolower(getProp($pushApp, 'provider'));
  162. $package = getProp($pushApp, 'package');
  163. $appId = getProp($pushApp, 'app_id');
  164. $appSecret = getProp($pushApp, 'app_secret');
  165. $appKey = getProp($pushApp, 'app_key');
  166. $masterSecret = getProp($pushApp, 'master_secret');
  167. $topic = PushConst::TOPIC_ALL;
  168. // 更新开始状态
  169. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  170. 'status' => PushConst::PUSH_STATUS_DOING,
  171. 'updated_at' => date('Y-m-d H:i:s')
  172. ]);
  173. $result = [];
  174. try {
  175. // 针对渠道做不同处理
  176. switch ($provider) {
  177. case PushConst::PROVIDER_HW:
  178. // 开发状态还是生产状态
  179. $target = env('APP_ENV') === 'production' ? 2 : 1;
  180. // 设置相关配置
  181. $client = new HwPushCommon($appId, $appSecret);
  182. $client->setFastAppTarget($target);
  183. $client->setTopic($topic);
  184. $client->setBigTag('Task_' . getProp($pushTask, 'id'));
  185. $result = $client->sendPushMessage($title, $content, $url);
  186. break;
  187. case PushConst::PROVIDER_MI:
  188. $client = new MiPushCommon($package, $appSecret);
  189. $result = $client->sendMessageToAll($title, $content, $url);
  190. break;
  191. case PushConst::PROVIDER_OPPO:
  192. // 实例化OPPO
  193. $client = new OPPOPushCommon($appKey, $masterSecret);
  194. $messageId = $client->getMessageId($title, $content, $url);
  195. $result = $client->broadCastAll($messageId);
  196. break;
  197. }
  198. } catch (Exception $e) {
  199. $pushResult = 0 && $pushResult;
  200. // 更新子任务失败状态
  201. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  202. 'status' => PushConst::PUSH_STATUS_FAIL,
  203. 'push_result' => json_encode($result, JSON_UNESCAPED_UNICODE),
  204. 'updated_at' => date('Y-m-d H:i:s')
  205. ]);
  206. continue;
  207. }
  208. // 更新成功状态
  209. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  210. 'status' => PushConst::PUSH_STATUS_SUCCESS,
  211. 'push_result' => json_encode($result, JSON_UNESCAPED_UNICODE),
  212. 'updated_at' => date('Y-m-d H:i:s')
  213. ]);
  214. }
  215. return $pushResult;
  216. }
  217. /**
  218. * @param $pushTask
  219. * @param $subTasks
  220. * @param $pushApps
  221. * @return bool
  222. * @throws ApiException
  223. * @throws GuzzleException
  224. */
  225. private static function pushMessageToUsers($pushTask, $subTasks, $pushApps)
  226. {
  227. // 获取需要推送的人
  228. $taskId = getProp($pushTask, 'id');
  229. $taskUsers = QappPushTaskUsers::getTaskUsers($taskId);
  230. if (!$taskUsers) {
  231. Utils::throwError(ErrorConst::PUSH_TASK_NO_USERS);
  232. }
  233. $pushResult = true;
  234. // 推送
  235. foreach ($subTasks as $subTask) {
  236. $subTaskId = getProp($subTask, 'id');
  237. $appId = getProp($subTask, 'app_id');
  238. $pushApp = collect($pushApps)->firstWhere('app_id', $appId);
  239. $uids = collect($taskUsers)->where('app_id', $appId)->pluck('uid');
  240. $users = QappPushUser::getPushUserByUids($uids);
  241. $regIds = array_column($users, 'reg_id');
  242. // push app相关
  243. $provider = strtolower(getProp($pushApp, 'provider'));
  244. $package = getProp($pushApp, 'package');
  245. $appId = getProp($pushApp, 'app_id');
  246. $appSecret = getProp($pushApp, 'app_secret');
  247. $appKey = getProp($pushApp, 'app_key');
  248. $masterSecret = getProp($pushApp, 'master_secret');
  249. $title = getProp($pushTask, 'title');
  250. $content = getProp($pushTask, 'content');
  251. $url = getProp($pushTask, 'url');
  252. // 更新开始状态
  253. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  254. 'status' => PushConst::PUSH_STATUS_DOING,
  255. 'updated_at' => date('Y-m-d H:i:s')
  256. ]);
  257. // 循环批量
  258. $regIdArr = array_chunk($regIds, 1000);
  259. try {
  260. switch ($provider) {
  261. // 华为
  262. case PushConst::PROVIDER_HW:
  263. // 初始化huawei推送
  264. $client = new HwPushCommon($appId, $appSecret);
  265. // 循环推送
  266. foreach ($regIdArr as $regIdList) {
  267. $client->setToken($regIdList);
  268. $result = $client->sendPushMessage($title, $content, $url);
  269. }
  270. break;
  271. // 小米
  272. case PushConst::PROVIDER_MI:
  273. // 初始化小米推送
  274. $client = new MiPushCommon($package, $appSecret);
  275. // 循环推送
  276. foreach ($regIdArr as $regIdList) {
  277. $client->setRegArr($regIdList);
  278. $result = $client->sendMessage($title, $content, $url);
  279. }
  280. break;
  281. // OPPO
  282. case PushConst::PROVIDER_OPPO:
  283. // 初始化oppo推送
  284. $client = new OPPOPushCommon($appKey, $masterSecret);
  285. $messageId = $client->getMessageId($title, $content, $url);
  286. // 循环推送
  287. foreach ($regIdArr as $regIdList) {
  288. $client->setRegArr($regIdList);
  289. $result = $client->broadCastRegIds($messageId);
  290. }
  291. break;
  292. }
  293. } catch (Exception $e) {
  294. $pushResult = 0 && $pushResult;
  295. // 更新子任务失败状态
  296. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  297. 'status' => PushConst::PUSH_STATUS_FAIL,
  298. 'push_result' => json_encode($result, JSON_UNESCAPED_UNICODE),
  299. 'updated_at' => date('Y-m-d H:i:s')
  300. ]);
  301. continue;
  302. }
  303. // 更新成功状态
  304. QappPushTaskLogs::updateData(['id' => $subTaskId], [
  305. 'status' => PushConst::PUSH_STATUS_SUCCESS,
  306. 'push_result' => json_encode($result, JSON_UNESCAPED_UNICODE),
  307. 'updated_at' => date('Y-m-d H:i:s')
  308. ]);
  309. }
  310. return $pushResult;
  311. }
  312. }