AdPositionService.php 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191
  1. <?php
  2. namespace App\Modules\AdPosition\Services;
  3. use App\Libs\Singleton;
  4. use App\Modules\AdPosition\Models\AdPosition;
  5. use App\Modules\AdPosition\Models\AdPositionDispatch;
  6. use App\Modules\Trade\Services\OrderService;
  7. use App\Modules\User\Models\QappUser;
  8. class AdPositionService
  9. {
  10. use Singleton;
  11. /**
  12. * @param $uid
  13. * @param $accountId
  14. * @return array
  15. */
  16. public function getAdPositions($uid, $accountId): array
  17. {
  18. // 参数判断
  19. if (empty($uid) || empty($accountId)) {
  20. return [];
  21. }
  22. // 获取所有有效广告位
  23. $positions = AdPosition::getAllValidAdPositions();
  24. if (empty($positions)) {
  25. return [];
  26. }
  27. // 获取广告位分配信息
  28. $positionIds = array_column($positions, 'id');
  29. $dispatches = AdPositionDispatch::getValidPositionDispatches($positionIds, $accountId);
  30. if (empty($dispatches)) {
  31. return [];
  32. }
  33. // 获取用户相关数据
  34. $userData = $this->getUserFilterData($uid);
  35. // 针对分配数据筛选出优先级最高的分配任务
  36. $result = [];
  37. $dispatches = collect($dispatches)->groupBy('ad_position_id')->all();
  38. foreach ($positions as $position) {
  39. // 相关变量获取
  40. $positionId = getProp($position, 'id');
  41. $ident = getProp($position, 'ident');
  42. // 获取对应广告位所有任务
  43. $validDispatches = getProp($dispatches, $positionId, []);
  44. if (empty($validDispatches)) {
  45. continue;
  46. }
  47. // 根据优先级循环匹配,直到匹配到为止
  48. $validDispatches = collect($validDispatches)->sortByDesc('priority')->all();
  49. $validDispatch = [];
  50. foreach ($validDispatches as $value) {
  51. // 过滤条件判断
  52. $filterContentJson = getProp($value, 'filter_condition');
  53. $matchFilter = $this->filterDispatch($filterContentJson, $userData);
  54. if ($matchFilter) {
  55. $validDispatch = $value;
  56. break;
  57. }
  58. }
  59. // 判断
  60. if (empty($validDispatch)) {
  61. continue;
  62. }
  63. // 添加到数据中
  64. $result[$ident][] = $this->buildPositionData($validDispatch, $position);
  65. }
  66. return $result;
  67. }
  68. /**
  69. * 用户的数据
  70. * @param $uid
  71. * @return array
  72. */
  73. private function getUserFilterData($uid): array
  74. {
  75. // 获取用户信息
  76. $user = QappUser::getUserByUid($uid);
  77. $registerAt = getProp($user, 'created_at');
  78. $registerUnix = strtotime($registerAt);
  79. // 获取用户付费情况
  80. $order = OrderService::getUserLastestOrder($uid);
  81. $isPaid = $order ? 1 : 0;
  82. return compact('registerUnix', 'isPaid');
  83. }
  84. /**
  85. * 过滤条件筛选
  86. * @param $filterContentJson
  87. * @param $userData
  88. * @return bool
  89. */
  90. private function filterDispatch($filterContentJson, $userData): bool
  91. {
  92. // 过滤条件
  93. $filterContent = json_decode($filterContentJson, true);
  94. if (empty($userData) || empty($filterContentJson) || empty($filterContent)) {
  95. return true;
  96. }
  97. // 判断注册时间
  98. $registerFilter = true;
  99. $registerAtArr = getProp($filterContent, 'registerAt');
  100. if ($registerAtArr) {
  101. // 默认值
  102. $registerFilter = false;
  103. $registerUnix = $userData['registerUnix'];
  104. // 循环条件,满足一条即可
  105. foreach ($registerAtArr as $register) {
  106. $unit = getProp($register, 'unit');
  107. $range = getProp($register, 'range');
  108. sort($range);
  109. [$min, $max] = $range;
  110. $startUnix = strtotime('-' . $max . ' ' . $unit);
  111. $endUnix = strtotime('-' . $min . ' ' . $unit);
  112. if ($registerUnix >= $startUnix && $registerUnix <= $endUnix) {
  113. $registerFilter = true;
  114. break;
  115. }
  116. }
  117. }
  118. // 判断付费情况
  119. $paidFilter = true;
  120. if (getProp($filterContent, 'isPaid') !== '') {
  121. // 获取用户付费情况
  122. $isPaid = getProp($userData, 'isPaid', 0);
  123. // 有付费
  124. if ($isPaid && getProp($filterContent, 'isPaid') === 1) {
  125. $paidFilter = true;
  126. }
  127. // 未付费
  128. if (!$isPaid && getProp($filterContent, 'isPaid') === 0) {
  129. $paidFilter = true;
  130. }
  131. }
  132. // 两者全部满足条件才可展示
  133. return $registerFilter && $paidFilter;
  134. }
  135. /**
  136. * 返回可显示数据
  137. * @param $validDispatch
  138. * @param $position
  139. * @return array
  140. */
  141. private function buildPositionData($validDispatch, $position): array
  142. {
  143. if (empty($validDispatch)) {
  144. return [];
  145. }
  146. // 链接做特殊处理
  147. $url = getProp($validDispatch, 'link_url');
  148. $urlArr = parse_url($url);
  149. parse_str(getProp($urlArr, 'query'), $queryArr);
  150. // 广告位图片
  151. $image = getProp($validDispatch, 'image_url');
  152. if (empty($image)) {
  153. $image = getProp($position, 'default_img');
  154. }
  155. return [
  156. 'img' => $image,
  157. 'url' => getProp($urlArr, 'path'),
  158. 'title' => getProp($validDispatch, 'title'),
  159. 'params' => $queryArr ?: (object)[]
  160. ];
  161. }
  162. }