正在显示
1 个修改的文件
包含
13 行增加
和
2 行删除
| @@ -16,6 +16,17 @@ use Model\folderSql; | @@ -16,6 +16,17 @@ use Model\folderSql; | ||
| 16 | */ | 16 | */ |
| 17 | class HomeEs extends Base { | 17 | class HomeEs extends Base { |
| 18 | 18 | ||
| 19 | + /** | ||
| 20 | + * @var \Lib\Es\Es | ||
| 21 | + */ | ||
| 22 | + public $es; | ||
| 23 | + | ||
| 24 | + public function __construct() | ||
| 25 | + { | ||
| 26 | + $this->es = \es('email_lists_copy'); | ||
| 27 | + $postid = app()->request('postid','','intval'); | ||
| 28 | + if($postid) $this->es->setIndex('email_lists_branch_'.$postid); | ||
| 29 | + } | ||
| 19 | 30 | ||
| 20 | /** | 31 | /** |
| 21 | * 邮件列表 | 32 | * 邮件列表 |
| @@ -253,7 +264,7 @@ class HomeEs extends Base { | @@ -253,7 +264,7 @@ class HomeEs extends Base { | ||
| 253 | ]; | 264 | ]; |
| 254 | } | 265 | } |
| 255 | 266 | ||
| 256 | - $lists = es()->search(['query'=>['constant_score'=>['filter'=>$query['query']]]], ($page-1)*$limit, $limit,['udate'=>'desc']); | 267 | + $lists = $this->es->search(['query'=>['constant_score'=>['filter'=>$query['query']]]], ($page-1)*$limit, $limit,['udate'=>'desc']); |
| 257 | 268 | ||
| 258 | $total = $lists['hits']['total']['value']??0; | 269 | $total = $lists['hits']['total']['value']??0; |
| 259 | $lists = $lists['hits']['hits']??[]; | 270 | $lists = $lists['hits']['hits']??[]; |
| @@ -367,7 +378,7 @@ class HomeEs extends Base { | @@ -367,7 +378,7 @@ class HomeEs extends Base { | ||
| 367 | } | 378 | } |
| 368 | 379 | ||
| 369 | 380 | ||
| 370 | - return es()->count($body); | 381 | + return $this->es->count($body); |
| 371 | 382 | ||
| 372 | }; | 383 | }; |
| 373 | 384 |
-
请 注册 或 登录 后发表评论