es

@@ -215,7 +215,7 @@ class MailListV2Es extends Base {
         if(empty($where['flagged'])){
         if(empty($where['flagged'])){
             $query['bool']['must'][] = $this->assignSql($folder);
             $query['bool']['must'][] = $this->assignSql($folder);
         }else{
         }else{
-            $query['bool']['must'][] = $this->assignSql2();
+            $query['bool']['must'][] = $this->assignSql('收件箱');
         }
         }
 
 
         logs('请求es前');
         logs('请求es前');
@@ -542,15 +542,8 @@ class MailListV2Es extends Base {
      */
      */
     private function countFlagged($body){
     private function countFlagged($body){
         $body['query']['bool']['must'][] = ['term'=>['flagged'=>1]];
         $body['query']['bool']['must'][] = ['term'=>['flagged'=>1]];
-        $body['query']['bool']['must'][] = $this->assignSql2();
-        return $this->es->count($body,['aggs' => [
-            'unique_udate' => [
-                'terms' => [
-                    'field' => 'udate', // 替换为你的字段名称
-                    'size' => 500 // 设置返回的去重值的数量
-                ]
-            ]
-        ]]);
+        $body['query']['bool']['must'][] = $this->assignSql('收件箱');
+        return $this->es->count($body);
     }
     }
 
 
 }
 }

@@ -94,17 +94,13 @@ class Es {
      * @author：dc
      * @author：dc
      * @time 2025/3/4 9:47
      * @time 2025/3/4 9:47
      */
      */
-    public function count(array $body,$other=[]){
+    public function count(array $body){
 
 
         $params = [
         $params = [
             'index' => $this->getIndex(),
             'index' => $this->getIndex(),
             'body'  => $body
             'body'  => $body
         ];
         ];
 
 
-        if($other){
-            $params = array_merge($params,$other);
-        }
-
         try {
         try {
             $response = $this->client->count($params);
             $response = $this->client->count($params);
         }catch (\Throwable $e) {
         }catch (\Throwable $e) {