获取商品数据

Author: xianengqi

db/goods.js

@@ -99,10 +99,15 @@ detailAction = async (request) => {
       where: {
         user_id: request.query.openIdUserName
       },
-      // attributes: [
-      //   'number'
-      // ],
     })
+    let allnumber = 0;
+
+    if (oldNumber.length > 0) {
+      for (let i = 0; i < oldNumber.length; i++) {
+        const element = oldNumber[i];
+        allnumber += element.number
+      }
+    }
     return {
       results: {
         info,
@@ -121,8 +126,112 @@ detailAction = async (request) => {
   catch(e){
     return { results: e, dataBaseError: true}
   }
+};
+
+goodsList = async (request) => {
+  try{
+    const categoryId = request.query.categoryId;
+    const isNew = request.query.isNew;
+    const isHot = request.query.isHot;
+    let order = request.query.order;
+    let goodsList = [];
+
+    if (categoryId) {
+      // 获得商品列表
+      goodsList = await models.nideshop_goods.findAndCountAll({
+        where: {
+          "category_id": categoryId
+        },
+      });
+      // 获得当前分类
+      const currentNav = await models.nideshop_category.findAndCountAll({
+        where: {
+          "id": categoryId
+        }
+      });
+
+      // 如果goodslist没有可能这个分类是主分类 例如： 居家，厨具
+      if (goodsList.length == 0) {
+        // 找到与之相关的子类， 再找到与子类相关的商品列表
+        let subIds = await models.nideshop_category.findAndCountAll({
+          where: {
+            "parent_id": categoryId
+          },
+          attributes: [
+            'id',
+          ],
+        });
+        // 需要变成数组形式， childCategoryIds [1020000,1036002]
+        if (subIds.length != 0) {
+          subIds = subIds.map((item) => {
+            return item.id;
+          });
+        };
+        goodsList = await models.nideshop_goods.findAndCountAll({
+          where: {
+            category_id: {
+              [Op.in]: subIds
+            },
+          },
+          limit: 50,
+        });
+      };
+      return {
+        results: {
+          data: goodsList,
+          currentNav: currentNav[0]
+        },
+        dataBaseError: false
+      }
+    };
+
+    if (!order) {
+      order = '';
+      orderBy = "id"
+    } else {
+      orderBy = "retail_price"
+    };
+    /**
+     * 新品列表
+     */
+    if (isNew) {
+      goodsList = await models.nideshop_goods.findAndCountAll({
+        where: {
+          is_new: isNew
+        },
+        order: [orderBy, order],
+      });
+      return {
+        results: {
+          data: goodsList,
+        },
+        dataBaseError: false
+      }
+    };
+    /**
+     * 热门商品
+     */
+    if (isHot) {
+      goodsList = await models.nideshop_goods.findAndCountAll({
+        where: {
+          is_hot: isHot
+        },
+        order: [orderBy, order],
+      });
+      return {
+        results: {
+          data: goodsList,
+        },
+        dataBaseError: false
+      }
+    }
+  }
+  catch(e) {
+    return { results: e, dataBaseError: true}
+  }
 }
 
 module.exports = {
   detailAction,
+  goodsList
 }

plugins/hapi-pagination.js

@@ -77,6 +77,7 @@ const pageOptions = {
       '/category/currentAction',
       '/category/categoryNav',
       '/goods/detailaction',
+      '/goods/goodsList',
     ],
     exclude: [],
   },

routes/goods.js

@@ -33,13 +33,23 @@ module.exports = [
   },
   {
     method: 'GET',
-    path: `/${GROUP_NAME}/{categoryId}/goodsList`,
+    path: `/${GROUP_NAME}/goodsList`,
     handler: async (request, reply) => {
-      reply();
+      let res = await controllers.goods.goodsList(request);
+      middleware.dbErrorMiddleware(request, res, reply);
     },
     config: {
       tags: ['api', GROUP_NAME],
-      description: '获取商品列表'
+      description: '获取商品列表',
+      validate: {
+        query: {
+          ...paginationDefine,
+          categoryId: Joi.number().description('获得商品类别Id'),
+          isNew: Joi.boolean().description('是否有新品列表'),
+          order: Joi.number().description('订单ID'),
+          isHot: Joi.boolean().description('最热商品'),
+        }
+      }
     }
   }
 ]