分类页aggregate函数的优化以及索引的添加

fecshop · Jul 29, 2017 · bbd1546 · bbd1546
1 parent f16a5c3
commit bbd1546
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 1 deletion.
diff --git a/models/mongodb/Product.php b/models/mongodb/Product.php
@@ -111,7 +111,11 @@ public static function create_index()
         $indexs = [
             ['spu'        => -1],
             ['sku'        => -1],
-            ['category' => -1],
+            ['category' => -1,'score'           => 1],
+            ['category' => -1,'review_count'    => 1],
+            ['category' => -1,'favorite_count'  => 1],
+            ['category' => -1,'created_at'      => 1],
+            ['category' => -1,'final_price'     => 1],
         ];
 
         $options = ['background' => true];

diff --git a/services/product/ProductMongodb.php b/services/product/ProductMongodb.php
@@ -20,6 +20,7 @@
 class ProductMongodb implements ProductInterface
 {
     public $numPerPage = 20;
+    public $maxCount = 6000;
 
     protected $_productModelName = '\fecshop\models\mongodb\Product';
     protected $_productModel;
@@ -541,6 +542,12 @@ public function getFrontCategoryProducts($filter)
             $project[$column] = 1;
             $group[$column] = ['$first' => '$'.$column];
         }
+
+        $langCode = Yii::$service->store->currentLangCode;
+        $name_lang  = Yii::$service->fecshoplang->getLangAttrName('name',$langCode);
+        $project['name'] = [
+            $name_lang => 1
+        ];
         $pipelines = [
             [
                 '$match'    => $where,
@@ -559,6 +566,9 @@ public function getFrontCategoryProducts($filter)
             [
                 '$sort'    => $orderBy,
             ],
+            [
+                '$limit'    => $this->maxCount,
+            ],
         ];
         $product_data = $this->_productModel->getCollection()->aggregate($pipelines);
         $product_total_count = count($product_data);
@@ -595,6 +605,9 @@ public function getFrontCategoryFilter($filter_attr, $where)
             [
                 '$group'    => $group,
             ],
+            [
+                '$limit'    => $this->maxCount,
+            ], 
         ];
         $filter_data = $this->_productModel->getCollection()->aggregate($pipelines);