Created
March 31, 2020 13:05
-
-
Save atsu666/cd69db2f5695c943e8be69df9285d3be to your computer and use it in GitHub Desktop.
php/ACMS/Filter.php
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <?php | |
| /** | |
| * ACMS_Filter | |
| * | |
| * SQLヘルパの各種処理をラップしたメソッド群です | |
| * メソッドの外で，条件対象のテーブルが選択されている必要があります | |
| * 例外で，_field, _keywordはメソッド内でテーブルを自動で選択します | |
| * | |
| * @package ACMS | |
| */ | |
| class ACMS_Filter | |
| { | |
| //------ | |
| // blog | |
| /** | |
| * ブログの階層構造を，axisを指定して絞り込みます | |
| * | |
| * [example] | |
| * self : 指定されたbidのブログ | |
| * descendant : 指定されたbidの子孫ブログ | |
| * ancestor : 指定されたbidの先祖ブログ | |
| * | |
| * ACMS_Filter::blogTree($SQL, $bid, 'self-or-descendant'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param int $bid | |
| * @param string $axis self|descendant|ancestor | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function blogTree(& $SQL, $bid, $axis='self', $scope=null) | |
| { | |
| $self = is_int(strpos($axis, 'self')); | |
| if ( is_int(strpos($axis, 'descendant')) ) { | |
| $eq = $self ? '=' : ''; | |
| $l = ACMS_RAM::blogLeft($bid); | |
| $r = ACMS_RAM::blogRight($bid); | |
| if ( 1 < ($r - $l) ) { | |
| $SQL->addWhereOpr('blog_left', $l, '>'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('blog_right', $r, '<'.$eq, 'AND', $scope); | |
| } else if ( !$self ) { | |
| $SQL->addWhere('0'); | |
| } else { | |
| $axis = 'self'; | |
| } | |
| } else if ( is_int(strpos($axis, 'ancestor')) ) { | |
| $eq = $self ? '=' : ''; | |
| $l = ACMS_RAM::blogLeft($bid); | |
| $r = ACMS_RAM::blogRight($bid); | |
| $SQL->addWhereOpr('blog_left', $l, '<'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('blog_right', $r, '>'.$eq, 'AND', $scope); | |
| } | |
| if ( 'self' == $axis ) $SQL->addWhereOpr('blog_id', $bid, '=', 'AND', $scope); | |
| } | |
| /** | |
| * ブログの公開状態とアクセス中の権限に応じて，表示条件を振り分けます | |
| * | |
| * ACMS_Filter::blogStatus($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function blogStatus(& $SQL, $scope=null) | |
| { | |
| if ( !sessionWithAdministration() ) { | |
| $aryStatus = array('open'); | |
| if ( sessionWithSubscription() ) { | |
| $aryStatus[] = 'secret'; | |
| } | |
| $SQL->addWhereIn('blog_status', $aryStatus, 'AND', $scope); | |
| } | |
| } | |
| /** | |
| * ブログをfieldテーブルから，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::blogField($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return void | |
| */ | |
| public static function blogField(& $SQL, $Field) | |
| { | |
| ACMS_Filter::_field($SQL, $Field, 'field_bid', 'blog_id'); | |
| } | |
| /** | |
| * ブログの公開状態とアクセス中の権限に応じて，表示条件を振り分けます | |
| * secretモードを表示対象にします | |
| * | |
| * ACMS_Filter::blogDisclosureSecretStatus($SQL); | |
| * | |
| * @access public | |
| * @static | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function blogDisclosureSecretStatus(& $SQL, $scope=null) | |
| { | |
| if ( !sessionWithAdministration() ) { | |
| $aryStatus = array('open', 'secret'); | |
| $SQL->addWhereIn('blog_status', $aryStatus, 'AND', $scope); | |
| } | |
| } | |
| /** | |
| * ブログの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * id-desc : ID降順 | |
| * code-asc : コード昇順 | |
| * | |
| * ACMS_Filter::blogOrder($SQL, 'id-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scp | |
| * @return void | |
| */ | |
| public static function blogOrder(& $SQL, $order, $scp=null) | |
| { | |
| list($field, $order) = explode('-', $order); | |
| $SQL->addOrder('blog_'.$field, $order, $scp); | |
| } | |
| /** | |
| * ブログをfulltextテーブルから，指定されたキーワードで全文検索します | |
| * | |
| * ACMS_Filter::blogKeyword($SQL, 'first second third keywords') | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $keyword | |
| * @return void | |
| */ | |
| public static function blogKeyword(& $SQL, $keyword) | |
| { | |
| ACMS_Filter::_keyword($SQL, $keyword, 'fulltext_bid', 'blog_id'); | |
| } | |
| //------ | |
| // user | |
| /** | |
| * ユーザーの公開状態とアクセス中の権限に応じて，表示条件を振り分けます | |
| * | |
| * ACMS_Filter::userStatus($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function userStatus(& $SQL, $scope=null) | |
| { | |
| if ( !sessionWithAdministration() ) { | |
| $SQL->addWhereOpr('user_status', 'open', '=', 'AND', $scope); | |
| } | |
| } | |
| /** | |
| * ユーザーの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * id-desc : ID降順 | |
| * code-asc : コード昇順 | |
| * | |
| * ACMS_Filter::userOrder($SQL, 'code-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scp | |
| * @return void | |
| */ | |
| public static function userOrder(& $SQL, $order, $scp=null) | |
| { | |
| $aryOrder = explode('-', $order); | |
| $fd = isset($aryOrder[0]) ? $aryOrder[0] : null; | |
| $seq = isset($aryOrder[1]) ? $aryOrder[1] : null; | |
| if ( 'random' == $fd ) { | |
| $Fd = SQL::newFunction(null, 'random', $scp); | |
| } else { | |
| if ( 'field' == $fd ) { | |
| if ( false !== strpos($SQL->get(), 'field_sort') ) { | |
| $fd = 'strfield_sort'; | |
| } else { | |
| $fd = 'user_id'; | |
| } | |
| } else if ( 'intfield' == $fd ) { | |
| if ( false !== strpos($SQL->get(), 'intfield_sort') ) { | |
| $fd = 'intfield_sort'; | |
| } else { | |
| $fd = 'user_id'; | |
| } | |
| } else if ( 'amount' == $fd ) { | |
| $fd = 'entry_amount'; | |
| } else { | |
| $fd = 'user_'.$fd; | |
| } | |
| $Fd = SQL::newField($fd, $scp); | |
| } | |
| $SQL->addOrder($Fd, $seq, $scp); | |
| } | |
| /** | |
| * ユーザーをfulltextテーブルから，指定されたキーワードで全文検索します | |
| * | |
| * ACMS_Filter::userKeyword($SQL, 'first second third keywords') | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $keyword | |
| * @return void | |
| */ | |
| public static function userKeyword(& $SQL, $keyword) | |
| { | |
| ACMS_Filter::_keyword($SQL, $keyword, 'fulltext_uid', 'user_id'); | |
| } | |
| /** | |
| * ユーザーをfieldテーブルから，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::userField($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return void | |
| */ | |
| public static function userField(& $SQL, $Field) | |
| { | |
| ACMS_Filter::_field($SQL, $Field, 'field_uid', 'user_id'); | |
| } | |
| //---------- | |
| // category | |
| /** | |
| * カテゴリーの公開状態とアクセス中の権限に応じて，表示条件を振り分けます | |
| * | |
| * ACMS_Filter::categoryStatus($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function categoryStatus(& $SQL, $scope=null) | |
| { | |
| if ( !sessionWithContribution() ) { | |
| $Where = SQL::newWhere(); | |
| $Where->addWhereOpr('category_status', null, '=', 'OR', $scope); | |
| $Where->addWhereOpr('category_status', 'open', '=', 'OR', $scope); | |
| $SQL->addWhere($Where, 'AND'); | |
| } | |
| } | |
| /** | |
| * カテゴリーの階層構造で，指定されたbid以下すべてを対象とします | |
| * | |
| * ACMS_Filter::categoryTreeGlobal($SQL, $bid); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param int $bid | |
| * @param bool $self | |
| * @param null $categoryScope | |
| * @param null $blogScope | |
| * @return void | |
| */ | |
| public static function categoryTreeGlobal(& $SQL, $bid, $self=true, $categoryScope=null, $blogScope=null) | |
| { | |
| $bleft = ACMS_RAM::blogLeft($bid); | |
| $bright = ACMS_RAM::blogRight($bid); | |
| if ( $self ) { | |
| $SQLWhereGlobal = SQL::newWhere(); | |
| $SQLWhereGlobal->addWhereOpr('category_scope', 'global', '=', 'AND', $categoryScope); | |
| $SQLWhereGlobal->addWhereOpr('blog_left', $bleft, '<', 'AND', $blogScope); | |
| $SQLWhereGlobal->addWhereOpr('blog_right', $bright, '>', 'AND', $blogScope); | |
| $SQLWhereScope = SQL::newWhere(); | |
| $SQLWhereScope->addWhereOpr('category_blog_id', $bid, '=', 'AND', $categoryScope); | |
| $SQLWhereScope->addWhere($SQLWhereGlobal, 'OR'); | |
| $SQL->addWhere($SQLWhereScope); | |
| } else { | |
| $SQL->addWhereOpr('category_scope', 'global', '=', 'AND', $categoryScope); | |
| $SQL->addWhereOpr('blog_left', $bleft, '<', 'AND', $blogScope); | |
| $SQL->addWhereOpr('blog_right', $bright, '>', 'AND', $blogScope); | |
| } | |
| } | |
| /** | |
| * カテゴリーをfieldテーブルから，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::categoryField($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return void | |
| */ | |
| public static function categoryField(& $SQL, $Field) | |
| { | |
| ACMS_Filter::_field($SQL, $Field, 'field_cid', 'category_id'); | |
| } | |
| /** | |
| * カテゴリーの階層構造を，axisを指定して絞り込みます | |
| * | |
| * [example] | |
| * self : 指定されたbidのカテゴリー | |
| * descendant : 指定されたbidの子孫カテゴリー | |
| * ancestor : 指定されたbidの先祖カテゴリー | |
| * | |
| * ACMS_Filter::categoryTree($SQL, $cid, 'descendant'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param int $cid | |
| * @param string $axis | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function categoryTree(& $SQL, $cid, $axis='self', $scope=null) | |
| { | |
| if ( empty($cid) ) return true; | |
| $self = is_int(strpos($axis, 'self')); | |
| if ( is_int(strpos($axis, 'descendant')) ) { | |
| $eq = $self ? '=' : ''; | |
| $l = ACMS_RAM::categoryLeft($cid); | |
| $r = ACMS_RAM::categoryRight($cid); | |
| $cbid = ACMS_RAM::categoryBlog($cid); | |
| if ( 1 < ($r - $l) ) { | |
| $SQL->addWhereOpr('category_left', $l, '>'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('category_right', $r, '<'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('category_blog_id', $cbid, '=', 'AND', $scope); | |
| } else if ( !$self ) { | |
| $SQL->addWhere('0'); | |
| } else { | |
| $axis = 'self'; | |
| } | |
| } else if ( is_int(strpos($axis, 'ancestor')) ) { | |
| $eq = $self ? '=' : ''; | |
| $l = ACMS_RAM::categoryLeft($cid); | |
| $r = ACMS_RAM::categoryRight($cid); | |
| $cbid = ACMS_RAM::categoryBlog($cid); | |
| $SQL->addWhereOpr('category_left', $l, '<'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('category_right', $r, '>'.$eq, 'AND', $scope); | |
| $SQL->addWhereOpr('category_blog_id', $cbid, '=', 'AND', $scope); | |
| } | |
| if ( 'self' == $axis ) $SQL->addWhereOpr('category_id', $cid, '=', 'AND', $scope); | |
| } | |
| /** | |
| * カテゴリーの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * id-desc : ID降順 | |
| * code-asc : コード昇順 | |
| * | |
| * ACMS_Filter::categoryOrder($SQL, 'code-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function categoryOrder(& $SQL, $order, $scope=null) | |
| { | |
| list($field, $order) = explode('-', $order); | |
| if ( 'amount' == $field ) $field = 'entry_'.$field; | |
| if ( 'sort' == $field ) $field = 'left'; | |
| if ( $field === 'left' ) { | |
| $SQL->addOrder('category_blog_id', config('global_category_sort', 'DESC')); | |
| } | |
| $SQL->addOrder('category_'.$field, $order, $scope); | |
| } | |
| /** | |
| * カテゴリーをfulltextテーブルから，指定されたキーワードで全文検索します | |
| * | |
| * ACMS_Filter::categoryKeyword($SQL, 'first second third keywords') | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $keyword | |
| * @return void | |
| */ | |
| public static function categoryKeyword(& $SQL, $keyword) | |
| { | |
| ACMS_Filter::_keyword($SQL, $keyword, 'fulltext_cid', 'category_id'); | |
| } | |
| //------- | |
| // entry | |
| /** | |
| * エントリーの公開状態とアクセス中の権限に応じて，表示条件を振り分けます | |
| * | |
| * ACMS_Filter::entryStatus($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function entryStatus(& $SQL, $scope=null) | |
| { | |
| if ( true || !sessionWithCompilation() ) { | |
| $SQLWhereEntryStatus = SQL::newWhere(); | |
| $SQLWhereEntryStatus->addWhereOpr('entry_status', 'open', '=', 'AND', $scope); | |
| if ( sessionWithContribution() ) { | |
| $SQLWhereContributor = SQL::newWhere(); | |
| $SQLWhereContributor->addWhereOpr('entry_user_id', SUID, '=', 'AND', $scope); | |
| $SQLWhereEntryStatus->addWhere($SQLWhereContributor); | |
| } | |
| $SQL->addWhere($SQLWhereEntryStatus); | |
| } | |
| } | |
| /** | |
| * 指定された日時が，公開期間に含まれているエントリーを絞り込みます | |
| * | |
| * ACMS_Filter::entryValidSpan($SQL, '2011-04-21 13:00:00'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $datetime '1001-01-01 00:00:00' | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function entryValidSpan(& $SQL, $datetime, $scope=null) | |
| { | |
| $SQL->addWhereOpr('entry_start_datetime', $datetime, '<=', 'AND', $scope); | |
| $SQL->addWhereOpr('entry_end_datetime', $datetime, '>=', 'AND', $scope); | |
| } | |
| /** | |
| * 現在の日時が，公開期間に含まれていて，アクセス中の権限で表示可能なエントリーを絞り込みます | |
| * | |
| * ACMS_Filter::entrySession($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scp | |
| * @return void | |
| */ | |
| public static function entrySession(& $SQL, $scp=null, $private=false) | |
| { | |
| $SQLWhereSession = SQL::newWhere(); | |
| //------------ | |
| // valid span | |
| // @todo issue: 秒のタイムスタンプを 00 に丸めてMySQLキャッシュを効かせるオプションが必要 | |
| $SQLWhereSession->addWhereOpr('entry_start_datetime', date('Y-m-d H:i:s', requestTime()), '<=', 'AND', $scp); | |
| $SQLWhereSession->addWhereOpr('entry_end_datetime', date('Y-m-d H:i:s', requestTime()), '>=', 'AND', $scp); | |
| //-------- | |
| // status | |
| $SQLWhereSession->addWhereOpr('entry_status', 'open', '=', 'AND', $scp); | |
| $SQLWhereSession->addWhereOpr('entry_approval', 'pre_approval', '<>', 'AND', $scp); | |
| if ($private || timemachineMode()) { | |
| $SQL->addWhere($SQLWhereSession); | |
| } else if ( 1 | |
| && !sessionWithCompilation() | |
| && !approvalAvailableUser(SUID) | |
| ) { | |
| if ( 1 | |
| && roleAvailableUser() | |
| && roleAuthorization('entry_edit', BID) | |
| && roleAuthorization('entry_edit_all', BID) | |
| ) { | |
| if ( !(defined('RVID') && RVID) && !isset($_GET['trash']) ) { | |
| $SQL->addWhereOpr('entry_status', 'trash', '<>', 'AND', $scp); | |
| } | |
| return; | |
| } else if ( sessionWithContribution() ) { | |
| $SQLWhereStatus = SQL::newWhere(); | |
| if ( 1 | |
| && !approvalAvailableUser(SUID) | |
| && ( 'on' == config('session_contributor_only_own_entry') ) | |
| ) { | |
| $connector = 'AND'; | |
| } else { | |
| $SQLWhereStatus->addWhere($SQLWhereSession); | |
| $connector = 'OR'; | |
| } | |
| $SQLWhereStatus->addWhereOpr('entry_user_id', SUID, '=', $connector, $scp); | |
| $SQL->addWhere($SQLWhereStatus); | |
| $SQL->addWhereOpr('entry_status', 'trash', '<>', 'AND', $scp); | |
| } else { | |
| $SQL->addWhere($SQLWhereSession); | |
| } | |
| } else if ( !(defined('RVID') && RVID) && !isset($_GET['trash']) ) { | |
| $SQL->addWhereOpr('entry_status', 'trash', '<>', 'AND', $scp); | |
| } | |
| } | |
| /** | |
| * 開始〜終了の指定による期間の該当する日付のエントリーを絞り込みます | |
| * | |
| * ACMS_Filter::entrySpan($SQL, '2010-01-01', '2010-12-31'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $start '1001-01-01 00:00:00' | |
| * @param string $end '9999-12-31 23:59:59' | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function entrySpan(& $SQL, $start, $end, $scope=null) | |
| { | |
| $SQL->addWhereBw('entry_datetime', $start, $end, 'AND', $scope); | |
| } | |
| /** | |
| * エントリーをタグで絞り込みます | |
| * | |
| * ACMS_Filter::entryTag($SQL, $tags); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param array $tags | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function entryTag(& $SQL, $tags, $scope=null) | |
| { | |
| if ( !is_array($tags) and empty($tags) ) return false; | |
| $tag = array_shift($tags); | |
| $SQL->addLeftJoin('tag', 'tag_entry_id', 'entry_id', 'tag0'); | |
| $SQL->addWhereOpr('tag_name', $tag, '=', 'AND', 'tag0'); | |
| $i = 1; | |
| while ( $tag = array_shift($tags) ) { | |
| $SQL->addLeftJoin('tag', 'tag_entry_id', 'tag_entry_id', 'tag'.$i, 'tag'.($i-1)); | |
| $SQL->addWhereOpr('tag_name', $tag, '=', 'AND', 'tag'.$i); | |
| $i++; | |
| } | |
| } | |
| /** | |
| * エントリーfulltextテーブルから，指定されたキーワードで全文検索します | |
| * | |
| * ACMS_Filter::entryKeyword($SQL, 'first second third keywords'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $keyword | |
| * @return void | |
| */ | |
| public static function entryKeyword(& $SQL, $keyword) | |
| { | |
| ACMS_Filter::_keyword($SQL, $keyword, 'fulltext_eid', 'entry_id'); | |
| } | |
| /** | |
| * エントリーをfieldテーブルから，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::entryField($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return array | |
| */ | |
| public static function entryField(& $SQL, $Field) | |
| { | |
| return ACMS_Filter::_field($SQL, $Field, 'field_eid', 'entry_id'); | |
| } | |
| /** | |
| * エントリーの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * id-desc : ID降順 | |
| * code-asc : コード昇順 | |
| * | |
| * ACMS_Filter::entryOrder($SQL, 'code-asc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string | array $order | |
| * @param null $uid | |
| * @param null $cid | |
| * @param bool|int $secondary_filed_sort | |
| * @param bool|string $field_name | |
| * | |
| * @return string | |
| */ | |
| public static function entryOrder(& $SQL, $order, $uid=null, $cid=null, $secondary_filed_sort=false, $field_name=false) | |
| { | |
| $orders = array(); | |
| $sortFd = ''; | |
| if ( is_array($order) ) { | |
| $orderKeys = array(); | |
| foreach ( $order as $item ) { | |
| if ( preg_match('/^[^-]+-(asc|desc)$/i', $item) ) { | |
| $order_info = explode('-', $item); | |
| $fd = isset($order_info[0]) ? $order_info[0] : null; | |
| if ( !isset($orderKeys[$fd]) ) { | |
| $orderKeys[$fd] = $item; | |
| } | |
| } else { | |
| $orderKeys[$item] = $item; | |
| } | |
| } | |
| $order = array_values($orderKeys); | |
| $first = array_shift($order); | |
| $orders = $order; | |
| } else { | |
| $first = $order; | |
| $order = null; | |
| } | |
| $fd = $first; | |
| $seq = 'asc'; | |
| $field_num = ''; | |
| if ( intval($secondary_filed_sort) > 1 ) { | |
| $field_num = '_' . $secondary_filed_sort; | |
| } | |
| if ( preg_match('/^[^-]+-(asc|desc)$/i', $first) ) { | |
| $order_info = explode('-', $first); | |
| $fd = isset($order_info[0]) ? $order_info[0] : null; | |
| $seq = isset($order_info[1]) ? $order_info[1] : null; | |
| } | |
| if ( 'random' == $fd ) { | |
| $SQL->setOrder(SQL::newFunction(null, 'random')); | |
| } else { | |
| switch ( $fd ) { | |
| case 'sort': | |
| if (!empty($uid) && is_numeric($uid)) { | |
| $SQL->addOrder('entry_user_sort', $seq); | |
| $sortFd = 'entry_user_sort'; | |
| } else if (!empty($cid) && is_numeric($cid)) { | |
| $SQL->addOrder('entry_category_sort', $seq); | |
| $sortFd = 'entry_category_sort'; | |
| } else { | |
| $SQL->addOrder('entry_sort', $seq); | |
| $sortFd = 'entry_sort'; | |
| } | |
| break; | |
| case 'id': | |
| case 'code': | |
| case 'status': | |
| case 'user_sort': | |
| case 'category_sort': | |
| case 'title': | |
| case 'link': | |
| case 'datetime': | |
| case 'start_datetime': | |
| case 'end_datetime': | |
| case 'posted_datetime': | |
| case 'updated_datetime': | |
| case 'summary_range': | |
| case 'indexing': | |
| case 'primary_image': | |
| case 'category_id': | |
| case 'user_id': | |
| case 'blog_id': | |
| $SQL->addOrder('entry_'.$fd, $seq); | |
| $sortFd = 'entry_'.$fd; | |
| break; | |
| case 'field': | |
| if (!empty($field_name)) { | |
| $SUB = SQL::newSelect('field'); | |
| $SUB->addSelect('field_eid'); | |
| $SUB->addSelect('field_value', 'strfield_sort_column'); | |
| $SUB->addWhereOpr('field_key', $field_name); | |
| $SQL->addLeftJoin('(' . $SUB->get(dsn()) . ')', 'field_eid', 'entry_id', 'sortFieldTable' . $secondary_filed_sort); | |
| $SQL->addOrder(SQL::newOpr('strfield_sort_column', null, '='), 'ASC'); | |
| $SQL->addOrder('strfield_sort_column', $seq); | |
| } else if ( false !== strpos($SQL->get(), 'strfield_sort') ) { | |
| $SQL->addOrder('strfield_sort' . $field_num, $seq); | |
| } | |
| if ( intval($secondary_filed_sort) > 1 ) { | |
| $secondary_filed_sort++; | |
| } else { | |
| $secondary_filed_sort = 2; | |
| } | |
| break; | |
| case 'intfield': | |
| if (!empty($field_name)) { | |
| $SUB = SQL::newSelect('field'); | |
| $SUB->addSelect('field_eid'); | |
| $SUB->addSelect(SQL::newOpr('field_value', 0, '+'), 'intfield_sort_column'); | |
| $SUB->addWhereOpr('field_key', $field_name); | |
| $SQL->addLeftJoin('(' . $SUB->get(dsn()) . ')', 'field_eid', 'entry_id', 'sortFieldTable' . $secondary_filed_sort); | |
| $SQL->addOrder(SQL::newOpr('intfield_sort_column', null, '='), 'ASC'); | |
| $SQL->addOrder('intfield_sort_column', $seq); | |
| } else if ( false !== strpos($SQL->get(), 'intfield_sort') ) { | |
| $SQL->addOrder('intfield_sort' . $field_num, $seq); | |
| } | |
| if (intval($secondary_filed_sort) > 1) { | |
| $secondary_filed_sort++; | |
| } else { | |
| $secondary_filed_sort = 2; | |
| } | |
| break; | |
| default: | |
| break; | |
| } | |
| foreach ( $orders as $order ) { | |
| if ( $order !== 'random' ) { | |
| self::entryOrder($SQL, $order, $uid, $cid, $secondary_filed_sort, $field_name); | |
| } | |
| } | |
| } | |
| return $sortFd; | |
| } | |
| //----- | |
| // tag | |
| /** | |
| * タグの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * name-desc : 名前降順 | |
| * | |
| * ACMS_Filter::tagOrder($SQL, 'name-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function tagOrder(& $SQL, $order, $scope=null) | |
| { | |
| list($field, $order) = explode('-', $order); | |
| $SQL->addOrder('tag_'.$field, $order); | |
| } | |
| /** | |
| * タグの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * name-desc : 名前降順 | |
| * | |
| * ACMS_Filter::tagOrder($SQL, 'name-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function mediaTagOrder(& $SQL, $order, $scope=null) | |
| { | |
| list($field, $order) = explode('-', $order); | |
| $SQL->addOrder('media_tag_'.$field, $order); | |
| } | |
| /** | |
| * メディアの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * name-desc : 名前降順 | |
| * | |
| * ACMS_Filter::mediaOrder($SQL, 'name-desc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function mediaOrder(& $SQL, $order, $scope=null) | |
| { | |
| list($field, $order) = explode('-', $order); | |
| if ($field === 'last_modified') { | |
| $field = 'update_date'; | |
| } | |
| if ($field === 'media_datetime') { | |
| $field = 'upload_date'; | |
| } | |
| $SQL->addOrder('media_'.$field, $order); | |
| } | |
| //------- | |
| // field | |
| /** | |
| * fieldテーブルを，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::fieldList($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return void | |
| */ | |
| public static function fieldList(& $SQL, $Field) | |
| { | |
| ACMS_Filter::_field($SQL, $Field); | |
| } | |
| //-------- | |
| // common | |
| private static function _field_where(& $Where, $Field, $fd, $aryOperator, & $emptyAry ) | |
| { | |
| $res = true; | |
| foreach ( $aryOperator as $i => $operator ) { | |
| $value = $Field->get($fd, '', $i); | |
| if ( 1 | |
| and '' === $value | |
| and 'em' <> $operator | |
| and 'nem' <> $operator | |
| ) { | |
| continue; | |
| } | |
| switch ( $operator ) { | |
| case 'eq': | |
| $operator = '='; | |
| break; | |
| case 'neq': | |
| $operator = '<>'; | |
| break; | |
| case 'lt': | |
| $operator = '<'; | |
| $value = is_numeric($value) ? ( ( $value == intval($value) ) ? intval($value) : floatval($value) ) : $value; | |
| break; | |
| case 'lte': | |
| $operator = '<='; | |
| $value = is_numeric($value) ? ( ( $value == intval($value) ) ? intval($value) : floatval($value) ) : $value; | |
| break; | |
| case 'gt': | |
| $operator = '>'; | |
| $value = is_numeric($value) ? ( ( $value == intval($value) ) ? intval($value) : floatval($value) ) : $value; | |
| break; | |
| case 'gte': | |
| $operator = '>='; | |
| $value = is_numeric($value) ? ( ( $value == intval($value) ) ? intval($value) : floatval($value) ) : $value; | |
| break; | |
| case 'lk': | |
| $operator = 'LIKE'; | |
| break; | |
| case 'nlk': | |
| $operator = 'NOT LIKE'; | |
| break; | |
| case 're': | |
| $operator = 'REGEXP'; | |
| break; | |
| case 'nre': | |
| $operator = 'NOT REGEXP'; | |
| break; | |
| case 'nem': | |
| $operator = '<>'; | |
| $value = ''; | |
| break; | |
| case 'em': | |
| $emptyAry[] = $fd; | |
| $res = false; | |
| continue 2; | |
| break; | |
| default: // exception | |
| continue 2; | |
| } | |
| $value = preg_replace('/\\\(.)/u', '${1}', $value); // エスケープを考慮 | |
| $value = is_numeric($value) ? ( ( $value == intval($value) ) ? intval($value) : floatval($value) ) : $value; | |
| if ( $operator === 'LIKE' and !preg_match('@^%|%$@', $value) ) { | |
| $value = '%'.$value.'%'; | |
| } | |
| $Where->addWhereOpr('field_value', $value, $operator, | |
| ('OR' == strtoupper($Field->getConnector($fd, $i))) ? | |
| 'OR' : 'AND'); | |
| } | |
| return $res; | |
| } | |
| /** | |
| * field | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @param string $fieldKey | |
| * @param string $tableKey | |
| * @return array | |
| */ | |
| private static function _field(& $SQL, $Field, $fieldKey = null, $tableKey = null) | |
| { | |
| $sortFields = array(); | |
| if ( config('advanced_search_field') === 'on' ) { | |
| ACMS_Filter::_field_index($SQL, $Field, $fieldKey, $tableKey); | |
| return true; | |
| } | |
| $unionAry = array(); | |
| $emptyAry = array(); | |
| $sort = false; | |
| foreach ( $Field->listFields() as $j => $fd ) { | |
| $Where = SQL::newWhere(); | |
| $aryOperator = $Field->getOperator($fd, null); | |
| if ( !ACMS_Filter::_field_where($Where, $Field, $fd, $aryOperator, $emptyAry) ) { | |
| continue; | |
| } | |
| if ( 1 | |
| and !!$Where->get() | |
| and !!$fieldKey | |
| and !!$tableKey | |
| ) { | |
| $SUB = SQL::newSelect('field'); | |
| $SUB->addSelect($fieldKey); | |
| if ( !$sort ) { | |
| $sort = true; | |
| $SUB->addSelect('field_value', 'strfield_sort'); | |
| $SUB->addSelect(SQL::newOpr('field_value', 0, '+'), 'intfield_sort'); | |
| $sortFields[] = 'strfield_sort'; | |
| $sortFields[] = 'intfield_sort'; | |
| } else { | |
| $SUB->addSelect('field_value', 'strfield_sort_' . ($j + 1)); | |
| $SUB->addSelect(SQL::newOpr('field_value', 0, '+'), 'intfield_sort_' . ($j + 1)); | |
| $sortFields[] = 'strfield_sort_' . ($j + 1); | |
| $sortFields[] = 'intfield_sort_' . ($j + 1); | |
| } | |
| $SUB->addWhereOpr('field_key', $fd); | |
| $SUB->addWhere($Where); | |
| if ( empty($j) ) { | |
| $unionAry[] = clone $SUB; | |
| } else { | |
| $separator = $Field->getSeparator($fd); | |
| if ( $separator === 'or' ) { | |
| $unionAry[] = clone $SUB; | |
| array_pop($sortFields); | |
| array_pop($sortFields); | |
| } else { | |
| $uniouCount = count($unionAry); | |
| if ( $uniouCount > 1 ) { | |
| $UNION = SQL::newSelect($unionAry[0], 'field_union'.$j); | |
| } | |
| for ( $i=1; $i<$uniouCount; $i++ ) { | |
| $UNION->addUnion($unionAry[$i]); | |
| } | |
| if ( $uniouCount > 1 ) { | |
| $SQL->addInnerJoin($UNION, $fieldKey, $tableKey, 'field'.$j); | |
| } else if ( $uniouCount > 0 ) { | |
| $SQL->addInnerJoin($unionAry[0], $fieldKey, $tableKey, 'field'.$j); | |
| } | |
| $unionAry = array(); | |
| $unionAry[] = clone $SUB; | |
| } | |
| } | |
| } else { | |
| $Where->addWhereOpr('field_key', $fd); | |
| $SQL->addWhere($Where); | |
| } | |
| } | |
| $uniouCount = count($unionAry); | |
| if ( $uniouCount > 1 ) { | |
| $UNION = SQL::newSelect($unionAry[0], 'field_union_end'); | |
| } | |
| for ( $i=1; $i<$uniouCount; $i++ ) { | |
| $UNION->addUnion($unionAry[$i]); | |
| } | |
| if ( $uniouCount > 1 ) { | |
| $SQL->addInnerJoin($UNION, $fieldKey, $tableKey, 'field_end'); | |
| } else if ( $uniouCount > 0 ) { | |
| $SQL->addInnerJoin($unionAry[0], $fieldKey, $tableKey, 'field_end'); | |
| } | |
| //------- | |
| // empty | |
| if ( !empty($emptyAry) ) { | |
| $temp = '`'. substr(base_convert(md5(uniqid()), 16, 36), 0, 8) . '`'; | |
| $NOT_EXISTS = SQL::newSelect('field'); | |
| $NOT_EXISTS->setSelect($fieldKey, null, null, 'DISTINCT'); | |
| $NOT_EXISTS->addWhereIn('field_key', $emptyAry); | |
| $NOT_EXISTS->addWhereOpr('field_value', '', '<>'); | |
| $NOT_EXISTS_WHERE = SQL::newWhere(); | |
| $NOT_EXISTS_WHERE->addWhereOpr($fieldKey, null); | |
| $SQL->addLeftJoin($NOT_EXISTS, $fieldKey, $tableKey, $temp); | |
| $SQL->addWhereOpr($fieldKey, null, '=', 'AND', $temp); | |
| } | |
| return $sortFields; | |
| } | |
| /** | |
| * use index field search | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @param string $fieldKey | |
| * @param string $tableKey | |
| * @return void | |
| */ | |
| private static function _field_index(& $SQL, $Field, $fieldKey = null, $tableKey = null) | |
| { | |
| $DB = DB::singleton(dsn()); | |
| $emptyAry = array(); | |
| $SubQuery = array(); | |
| $sortKey = false; | |
| foreach ( $Field->listFields() as $j => $fd ) { | |
| $SUB = SQL::newSelect('field'); | |
| $SUB->setSelect($fieldKey, null, null, 'DISTINCT'); | |
| if ( !$sortKey ) $sortKey = $fd; | |
| $Where = SQL::newWhere(); | |
| $Where2 = SQL::newWhere(); | |
| $aryOperator = $Field->getOperator($fd, null); | |
| $separator = $Field->getSeparator($fd); | |
| ACMS_Filter::_field_where($Where, $Field, $fd, $aryOperator, $emptyAry); | |
| if ( !in_array($fd, $emptyAry) ) { | |
| $Where2->addWhereOpr('field_key', $fd); | |
| $Where2->addWhere($Where); | |
| if ( strtoupper($separator) === 'OR' ) { | |
| $SUB->addWhere($Where2, 'OR'); | |
| } else { | |
| $SUB->addWhere($Where2, 'OR'); | |
| $SQL->addWhereIn($tableKey, $DB->subQuery($SUB, true)); | |
| } | |
| } | |
| } | |
| //------- | |
| // empty | |
| if ( !empty($emptyAry) ) { | |
| $temp = substr(base_convert(md5(uniqid()), 16, 36), 0, 8); | |
| $NOT_EXISTS = SQL::newSelect('field'); | |
| $NOT_EXISTS->setSelect($fieldKey, null, null, 'DISTINCT'); | |
| $NOT_EXISTS->addWhereIn('field_key', $emptyAry); | |
| $NOT_EXISTS->addWhereOpr('field_value', '', '<>'); | |
| $NOT_EXISTS_WHERE = SQL::newWhere(); | |
| $NOT_EXISTS_WHERE->addWhereOpr($fieldKey, null); | |
| $SQL->addLeftJoin($NOT_EXISTS, $fieldKey, $tableKey, $temp); | |
| $SQL->addWhereOpr($fieldKey, null, '=', 'AND', $temp); | |
| } | |
| if ( $fieldKey && $tableKey && $sortKey ) { | |
| $SQL->addLeftJoin('field', $fieldKey, $tableKey); | |
| $SQL->addSelect('*'); | |
| $SQL->addSelect('field_value', 'field_sort'); | |
| $SQL->addSelect('field_sort', 'field_key_sort'); | |
| $SQL->addSelect(SQL::newOpr('field_value', 0, '+'), 'intfield_sort'); | |
| $SQL->addWhereOpr('field_key', $sortKey); | |
| } | |
| } | |
| /** | |
| * _keyword | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $keyword | |
| * @param string $fulltextKey | |
| * @param string $tableKey | |
| * @return void | |
| */ | |
| private static function _keyword(& $SQL, $keyword, $fulltextKey, $tableKey) | |
| { | |
| if ( empty($keyword) ) return false; | |
| $keyword = addcslashes($keyword, '%_'); | |
| if ( !$aryWord = preg_split('/( |\s)+/u', $keyword, -1, PREG_SPLIT_NO_EMPTY) ) return false; | |
| //---------------------- | |
| // NGRAM & BOOLEAN MODE | |
| if ( config('ngram') ) { | |
| $against = ''; | |
| foreach ( $aryWord as $word ) { | |
| $operator = '+'; | |
| if ( substr($word, 0, 1) === '-' ) { | |
| $operator = '-'; | |
| $word = substr($word, 1); | |
| } | |
| $aryToken = ngram($word, config('ngram')); | |
| $against .= ' '.$operator.'(+'.join(' +', $aryToken).')'; | |
| } | |
| $ngramSQL = SQL::newSelect('fulltext'); | |
| $ngramSQL->setSelect($fulltextKey); | |
| $ngramSQL->addWhere('MATCH ( fulltext_ngram ) AGAINST ('."'".$against."'".' IN BOOLEAN MODE)'); | |
| $SQL->addInnerJoin($ngramSQL, $fulltextKey, $tableKey, 'ft'); | |
| //----------- | |
| // LIKE MODE | |
| } else { | |
| foreach ( $aryWord as $word ) { | |
| if ( substr($word, 0, 1) === '-' ) { | |
| $word = substr($word, 1); | |
| $SQL->addWhereOpr('fulltext_value', '%'.$word.'%', 'NOT LIKE'); | |
| } else { | |
| $SQL->addWhereOpr('fulltext_value', '%'.$word.'%', 'LIKE'); | |
| } | |
| } | |
| $SQL->addLeftJoin('fulltext', $fulltextKey, $tableKey); | |
| } | |
| } | |
| /** | |
| * エントリーの特定フィールドを指定して，昇順または降順で並び替えます | |
| * | |
| * [example] | |
| * id-desc : ID降順 | |
| * code-asc : コード昇順 | |
| * | |
| * ACMS_Filter::formbuildOrder($SQL, 'code-asc'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $order asc|desc | |
| * @param null $uid | |
| * @param null $cid | |
| * @return void | |
| */ | |
| public static function formbuildOrder(& $SQL, $order, $uid=null, $cid=null) | |
| { | |
| $aryOrder = explode('-', $order); | |
| $fd = isset($aryOrder[0]) ? $aryOrder[0] : null; | |
| $seq = isset($aryOrder[1]) ? $aryOrder[1] : null; | |
| if ( 'random' == $fd ) { | |
| $SQL->setOrder(SQL::newFunction(null, 'random')); | |
| } else { | |
| switch ( $fd ) { | |
| case 'id': | |
| break; | |
| case 'sort': | |
| if ( !empty($uid) ) { | |
| $SQL->addOrder('formbuild_user_sort', $seq); | |
| } else if ( !empty($cid) ) { | |
| $SQL->addOrder('formbuild_category_sort', $seq); | |
| } else { | |
| $SQL->addOrder('formbuild_sort', $seq); | |
| } | |
| break; | |
| case 'code': | |
| case 'status': | |
| case 'user_sort': | |
| case 'category_sort': | |
| case 'title': | |
| case 'link': | |
| case 'datetime': | |
| case 'start_datetime': | |
| case 'end_datetime': | |
| case 'posted_datetime': | |
| case 'updated_datetime': | |
| case 'summary_range': | |
| case 'indexing': | |
| case 'primary_image': | |
| case 'category_id': | |
| case 'user_id': | |
| case 'blog_id': | |
| $SQL->addOrder('formbuild_'.$fd, $seq); | |
| break; | |
| case 'field': | |
| if ( false !== strpos($SQL->get(), 'strfield_sort') ) { | |
| $SQL->addOrder('strfield_sort', $seq); | |
| } | |
| break; | |
| case 'intfield': | |
| if ( false !== strpos($SQL->get(), 'intfield_sort') ) { | |
| $SQL->addOrder('intfield_sort', $seq); | |
| } | |
| break; | |
| default: | |
| break; | |
| } | |
| $SQL->addOrder('formbuild_id', $seq); | |
| } | |
| } | |
| /** | |
| * 現在の日時が，公開期間に含まれていて，アクセス中の権限で表示可能なエントリーを絞り込みます | |
| * | |
| * ACMS_Filter::formbuildSession($SQL); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param null $scp | |
| * @return void | |
| */ | |
| public static function formbuildSession(& $SQL, $scp=null) | |
| { | |
| if ( !sessionWithCompilation() ) { | |
| $SQLWhereSession = SQL::newWhere(); | |
| //------------ | |
| // valid span | |
| // @todo issue: 秒のタイムスタンプを 00 に丸めてMySQLキャッシュを効かせるオプションが必要 | |
| $SQLWhereSession->addWhereOpr('formbuild_start_datetime', date('Y-m-d H:i:s', requestTime()), '<=', 'AND', $scp); | |
| $SQLWhereSession->addWhereOpr('formbuild_end_datetime', date('Y-m-d H:i:s', requestTime()), '>=', 'AND', $scp); | |
| //-------- | |
| // status | |
| $SQLWhereSession->addWhereOpr('formbuild_status', 'open', '=', 'AND', $scp); | |
| if ( sessionWithContribution() ) { | |
| $SQLWhereStatus = SQL::newWhere(); | |
| if ( 'on' == config('session_contributor_only_own_entry') ) { | |
| $connector = 'AND'; | |
| } else { | |
| $SQLWhereStatus->addWhere($SQLWhereSession); | |
| $connector = 'OR'; | |
| } | |
| $SQLWhereStatus->addWhereOpr('formbuild_user_id', SUID, '=', $connector, $scp); | |
| $SQL->addWhere($SQLWhereStatus); | |
| } else { | |
| $SQL->addWhere($SQLWhereSession); | |
| } | |
| } | |
| } | |
| /** | |
| * 開始〜終了の指定による期間の該当する日付のエントリーを絞り込みます | |
| * | |
| * ACMS_Filter::formbuildSpan($SQL, '2010-01-01', '2010-12-31'); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param string $start '1001-01-01 00:00:00' | |
| * @param string $end '9999-12-31 23:59:59' | |
| * @param null $scope | |
| * @return void | |
| */ | |
| public static function formbuildSpan(& $SQL, $start, $end, $scope=null) | |
| { | |
| $SQL->addWhereBw('formbuild_datetime', $start, $end, 'AND', $scope); | |
| } | |
| /** | |
| * エントリーをfieldテーブルから，指定されたフィールドで検索します | |
| * | |
| * ACMS_Filter::formbuildField($SQL, $Field); | |
| * | |
| * @param SQL_Select|SQL_Update|SQL_Delete $SQL | |
| * @param Field $Field | |
| * @return void | |
| */ | |
| public static function formbuildField(& $SQL, $Field) | |
| { | |
| ACMS_Filter::_field($SQL, $Field, 'field_eid', 'formbuild_id'); | |
| } | |
| public static function crmMailField(& $SQL, $Field) | |
| { | |
| foreach ( $Field->listFields() as $j => $fd ) { | |
| $Where = SQL::newWhere(); | |
| $aryOperator = $Field->getOperator($fd, null); | |
| foreach ( $aryOperator as $i => $operator ) { | |
| $value = $Field->get($fd, '', $i); | |
| $notexist = false; | |
| if ( '' == $value ) { | |
| continue; | |
| } | |
| switch ( $operator ) { | |
| case 'eq': | |
| $operator = '='; | |
| break; | |
| case 'neq': | |
| $operator = '<>'; | |
| break; | |
| case 'lt': | |
| $operator = '<'; | |
| $value = $value; | |
| break; | |
| case 'lte': | |
| $operator = '<='; | |
| $value = $value; | |
| break; | |
| case 'gt': | |
| $operator = '>'; | |
| $value = $value; | |
| break; | |
| case 'gte': | |
| $operator = '>='; | |
| $value = $value; | |
| break; | |
| case 'lk': | |
| $operator = 'LIKE'; | |
| break; | |
| case 'nlk': | |
| $operator = 'NOT LIKE'; | |
| break; | |
| case 're': | |
| $operator = 'REGEXP'; | |
| break; | |
| case 'nre': | |
| $operator = 'NOT REGEXP'; | |
| break; | |
| case 'em': | |
| $operator = '='; | |
| $value = ''; | |
| break; | |
| case 'nem': | |
| $operator = '<>'; | |
| $value = ''; | |
| break; | |
| default: // exception | |
| continue 2; | |
| } | |
| if ( $operator === 'LIKE' and !preg_match('@^%|%$@', $value) ) { | |
| $value = '%'.$value.'%'; | |
| } | |
| $Where->addWhereOpr($fd, $value, $operator, | |
| ('OR' != strtoupper($Field->getConnector($fd, $i))) ? 'AND' : 'OR'); | |
| } | |
| $DB = DB::singleton(dsn()); | |
| $Customer = SQL::newSelect('crm_thread'); | |
| $Customer->setLimit(0, 1); | |
| $res = $DB->query($Customer->get(dsn()), 'exec'); | |
| $fieldCount = $DB->columnCount($res); | |
| $cfields = array(); | |
| for ( $i=0; $i<$fieldCount; $i++ ) { | |
| $cfields[] = $DB->columnMeta($i); | |
| } | |
| if ( array_search($fd, $cfields) !== false ) { | |
| $SQL->addWhere($Where); | |
| } | |
| } | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment