| @@ 132-145 (lines=14) @@ | ||
| 129 | * |
|
| 130 | * @return FederatedLink[] |
|
| 131 | */ |
|
| 132 | public function getLinksFromCircle($circleUniqueId, $status = 0) { |
|
| 133 | $qb = $this->getLinksSelectSql(); |
|
| 134 | $this->limitToCircleId($qb, $circleUniqueId); |
|
| 135 | $this->limitToStatus($qb, $status); |
|
| 136 | ||
| 137 | $links = []; |
|
| 138 | $cursor = $qb->execute(); |
|
| 139 | while ($data = $cursor->fetch()) { |
|
| 140 | $links[] = $this->parseLinksSelectSql($data); |
|
| 141 | } |
|
| 142 | $cursor->closeCursor(); |
|
| 143 | ||
| 144 | return $links; |
|
| 145 | } |
|
| 146 | ||
| 147 | ||
| 148 | /** |
|
| @@ 96-109 (lines=14) @@ | ||
| 93 | * |
|
| 94 | * @return SharesToken[] |
|
| 95 | */ |
|
| 96 | public function getTokensFromMember(Member $member) { |
|
| 97 | $qb = $this->getTokensSelectSql(); |
|
| 98 | $this->limitToUserId($qb, $member->getUserId()); |
|
| 99 | $this->limitToCircleId($qb, $member->getCircleId()); |
|
| 100 | ||
| 101 | $shares = []; |
|
| 102 | $cursor = $qb->execute(); |
|
| 103 | while ($data = $cursor->fetch()) { |
|
| 104 | $shares[] = $this->parseTokensSelectSql($data); |
|
| 105 | } |
|
| 106 | $cursor->closeCursor(); |
|
| 107 | ||
| 108 | return $shares; |
|
| 109 | } |
|
| 110 | ||
| 111 | ||
| 112 | /** |
|