'use strict';
const shopController = require('./shop.js');
// 商品接口控制器
module.exports = class ProductsController extends shopController {
// 使用模型
get useModel() {
const that = this;
return that.app.model.Products;
}
/**
* [detailValidate 查看商品详情验证器]
* @return {[type]} [description]
*/
get detailValidate() {
const that = this;
return {
product_id: that.ctx.rules.name('商品ID')
.required()
.number(),
};
}
// 商品搜索验证器
get searchValidate() {
const that = this;
return {
keyword: that.ctx.rules.name('商品关键字')
.required()
.trim()
.notEmpty(),
};
}
/**
* [commentValidate 商品评论]
* @return {[type]} [description]
*/
get commentValidate() {
const that = this;
return {
order_id: that.ctx.rules.name('订单ID')
.required()
.notEmpty()
.number(),
product_id: that.ctx.rules.name('商品ID')
.required()
.notEmpty()
.number(),
product_rate: that.ctx.rules.name('商品评分')
.required()
.notEmpty()
.number(),
user_id: that.ctx.rules.default(that.service.shop.getWebUserId())
.number(),
comment: that.ctx.rules.name('评论内容')
.required(),
create_time: that.ctx.rules.default(that.app.szjcomo.date('Y-m-d H:i:s'))
.required(),
};
}
/**
* [commentListValidate 获取商品评论列表]
* @return {[type]} [description]
*/
get commentListValidate() {
const that = this;
return {
product_id: that.ctx.rules.name('商品ID')
.required()
.notEmpty()
.number(),
page: that.ctx.rules.default(1)
.number(),
limit: that.ctx.rules.default(50)
.number(),
};
}
/**
* [homeProduct 获取家用家具首页商品]
* @return {[type]} [description]
*/
async homeProduct() {
const that = this;
try {
const seq = that.app.Sequelize;
// 2023/9/19 查询家具分类
const categoryResult = await that.app.model.ProductCategory.findAll({
where: { pid: 4 }, // 2023/9/19 家用家具
});
const categorys = JSON.parse(JSON.stringify(categoryResult));
const cate = [];
for (const category of categorys) {
cate.push(category.category_id);
}
const result = await that.useModel.findAll({
offset: 0, limit: 100,
where: { is_home: 1, product_stock: { [seq.Op.gte]: 1 }, is_sale: 1, category_id: { [seq.Op.in]: cate } },
attributes: [ 'product_id', 'category_id', 'product_name', 'product_image', 'shop_price', 'market_price', 'is_new', 'is_hot' ],
order: [[ 'is_hot', 'desc' ], [ 'is_new', 'desc' ], [ 'sale_count', 'desc' ]],
});
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
/**
* [homeProduct 获取办公家具首页商品]
* @return {[type]} [description]
* http://192.168.18.188:8106/oneshop/api/officeHomeProducts
*/
async officeHomeProducts() {
const that = this;
try {
const seq = that.app.Sequelize;
// 2023/9/19 查询家具分类
const categoryResult = await that.app.model.ProductCategory.findAll({
where: { pid: 1 }, // 2023/9/19 办公家具
});
const categorys = JSON.parse(JSON.stringify(categoryResult));
const cate = [];
for (const category of categorys) {
cate.push(category.category_id);
}
const result = await that.useModel.findAll({
offset: 0, limit: 100,
where: { is_home: 1, product_stock: { [seq.Op.gte]: 1 }, is_sale: 1, category_id: { [seq.Op.in]: cate } },
attributes: [ 'product_id', 'category_id', 'product_name', 'product_image', 'shop_price', 'market_price', 'is_new', 'is_hot' ],
order: [[ 'is_hot', 'desc' ], [ 'is_new', 'desc' ], [ 'sale_count', 'desc' ], [ 'product_stock', 'desc' ], [ 'category_id', 'asc' ]],
});
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
/**
* [search 商品搜索]
* @return {[type]} [description]
*/
async search() {
const that = this;
try {
const data = await that.ctx.validate(that.searchValidate, await that.ctx.getParse());
const result = await that.useModel.findAll({
offset: 0, limit: 100, order: [[ 'product_id', 'desc' ]],
where: { product_name: { [that.app.Sequelize.Op.regexp]: data.keyword }, is_sale: 1 },
attributes: [ 'product_id', 'category_id', 'product_name', 'product_image', 'shop_price', 'market_price', 'is_new', 'is_hot' ],
});
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
/**
* [detail 查看商品详情]
* @return {[type]} [description]
*/
async detail() {
const that = this;
try {
const seq = that.app.Sequelize;
const data = await that.ctx.validate(that.detailValidate, await that.ctx.getParse());
const result = await that.useModel.findOne({
where: { product_id: data.product_id, is_sale: 1 },
include: [
{ model: that.app.model.ProductContents, as: 'contents', attributes: [] },
{ model: that.app.model.ProductCarousels, as: 'carousels', attributes: [] },
{ model: that.app.model.ProductCategory, as: 'categorys', attributes: [] },
{ model: that.app.model.ProductSku, as: 'productSkus', attributes: { exclude: [ 'create_time' ] } },
],
attributes: {
include: [
[ seq.col('categorys.category_name'), 'category_name' ],
[ seq.col('categorys.pid'), 'pid' ],
[ seq.col('contents.desction'), 'product_content' ],
[ seq.col('carousels.content'), 'product_carouse' ],
],
exclude: [ 'carousel_id', 'content_id', 'supplier_id', 'admin_id', 'update_time', 'create_time' ],
},
});
if (result) result.setDataValue('spes', await that.detailSpes(data.product_id));
// let real_total = await that.service.shop.productSaleCount(data.product_id);
if (result) result.setDataValue('product_sale_count', Number(result.sale_count));
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
/**
* [detailSpes 获取商品规格]
* @param {Number} product_id [description]
* @return {[type]} [description]
*/
async detailSpes(product_id = 0) {
const that = this;
const seq = that.app.Sequelize;
const result = await that.app.model.ProductSpes.findAll({
where: { product_id },
include: [
{ model: that.app.model.ProductTypesItem, as: 'product_types_item', attributes: [] },
],
attributes: {
include: [[ seq.col('product_types_item.item_name'), 'item_name' ]],
exclude: [ 'product_id', 'item_id', 'admin_id', 'create_time', 'update_time', 'spe_id' ],
},
});
return result;
}
/**
* [comment 商品评论]
* @return {[type]} [description]
*/
async comment() {
const that = this;
let transaction;
try {
const data = await that.ctx.validate(that.commentValidate, await that.ctx.postParse());
transaction = await that.app.model.transaction();
const createBean = await that.app.comoBean.instance(data);
const result = await that.service.base.create(createBean, that.app.model.ProductComment, '商品评论添加失败,请稍候重试');
const updateBean = await that.app.comoBean.instance({
order_status: 4,
success_time: that.app.szjcomo.date('Y-m-d H:i:s'),
}, {
where: {
order_id: data.order_id,
}, transaction,
});
await that.service.base.update(updateBean, that.app.model.Orders, '更新订单交易完成失败,请稍候重试');
await that.service.order.orderAction({
order_id: data.order_id,
admin_id: 0,
action_desc: '商品进行评价',
}, transaction);
await transaction.commit();
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
if (transaction) await transaction.rollback();
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
/**
* [commentList 商品评论列表]
* @return {[type]} [description]
*/
async commentList() {
const that = this;
try {
const data = await that.ctx.validate(that.commentListValidate, await that.ctx.getParse());
const seq = that.app.Sequelize;
const selectBean = await that.app.comoBean.instance(data, {
offset: (data.page - 1) * data.limit, limit: data.limit, where: { product_id: data.product_id, status: 1 },
include: [
{ model: that.app.model.Users, as: 'users', attributes: [] },
],
attributes: [
[ seq.col('users.nickname'), 'nickname' ], [ seq.col('users.account_name'), 'account_name' ],
[ seq.col('users.headimgurl'), 'headimgurl' ], 'comment', 'create_time',
],
order: [[ 'comment_id', 'desc' ]],
});
const result = await that.service.base.select(selectBean, that.app.model.ProductComment, '查询商品评论失败,请稍候重试', true, true);
return that.ctx.appJson(that.app.szjcomo.appResult('SUCCESS', result, false));
} catch (err) {
return that.ctx.appJson(that.app.szjcomo.appResult(err.message));
}
}
};