import { Init, Inject, Provide } from '@midwayjs/core';
|
import { BaseService, CoolCommException } from '@cool-midway/core';
|
import { InjectEntityModel } from '@midwayjs/typeorm';
|
import { Equal, Repository } from 'typeorm';
|
import { GoodsCommentEntity } from '../entity/comment';
|
import { OrderInfoService } from '../../order/service/info';
|
import { OrderGoodsEntity } from '../../order/entity/goods';
|
|
/**
|
* 商品评论
|
*/
|
@Provide()
|
export class GoodsCommentService extends BaseService {
|
@InjectEntityModel(GoodsCommentEntity)
|
goodsCommentEntity: Repository<GoodsCommentEntity>;
|
|
@InjectEntityModel(OrderGoodsEntity)
|
orderGoodsEntity: Repository<OrderGoodsEntity>;
|
|
@Inject()
|
orderInfoService: OrderInfoService;
|
|
@Init()
|
async init() {
|
await super.init();
|
this.setEntity(this.goodsCommentEntity);
|
}
|
|
/**
|
* 提交评论
|
* @param userId
|
* @param orderId
|
* @param comment
|
*/
|
async submit(userId: number, orderId: number, comment: GoodsCommentEntity) {
|
const order = await this.orderInfoService.info(orderId);
|
if (order && order.userId != userId) {
|
throw new CoolCommException('无权限');
|
}
|
if (![3, 4].includes(order.status)) {
|
throw new CoolCommException('不是可评价的订单状态');
|
}
|
const goods = await this.orderGoodsEntity.findOneBy({
|
goodsId: Equal(comment.goodsId),
|
orderId: Equal(orderId),
|
});
|
if (!goods) {
|
throw new CoolCommException('商品不存在');
|
}
|
if (goods.isComment) {
|
throw new CoolCommException('已评价过，不能重复评价');
|
}
|
// 更新订单商品状态
|
await this.orderGoodsEntity.update(goods.id, { isComment: 1 });
|
// 订单状态改为交易完成
|
if (order.status == 3) {
|
await this.orderInfoService.changeStatus(orderId, 4);
|
}
|
comment.userId = userId;
|
await this.add(comment);
|
}
|
}
|
