package cn.stylefeng.rest.modular.user.controller;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.collection.ListUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.stylefeng.guns.modular.business.entity.CounsellingInfo;
|
import cn.stylefeng.guns.modular.business.entity.CounsellingOrderReservation;
|
import cn.stylefeng.guns.modular.business.entity.Course;
|
import cn.stylefeng.guns.modular.business.entity.UserEvaluate;
|
import cn.stylefeng.guns.modular.business.service.*;
|
import cn.stylefeng.roses.kernel.auth.api.context.LoginContext;
|
import cn.stylefeng.roses.kernel.customer.modular.entity.Customer;
|
import cn.stylefeng.roses.kernel.customer.modular.service.CustomerService;
|
import cn.stylefeng.roses.kernel.db.api.factory.PageFactory;
|
import cn.stylefeng.roses.kernel.db.api.factory.PageResultFactory;
|
import cn.stylefeng.roses.kernel.db.api.pojo.page.PageResult;
|
import cn.stylefeng.roses.kernel.rule.annotation.BusinessLog;
|
import cn.stylefeng.roses.kernel.rule.enums.ResBizTypeEnum;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.ErrorResponseData;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.ResponseData;
|
import cn.stylefeng.roses.kernel.rule.pojo.response.SuccessResponseData;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.ApiResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.GetResource;
|
import cn.stylefeng.roses.kernel.scanner.api.annotation.PostResource;
|
import com.alibaba.druid.sql.visitor.functions.If;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 用户评价表管理类
|
* @author guo
|
*/
|
@RestController
|
@Api(tags = "用户评价")
|
@ApiResource(name = "用户评价", resBizType = ResBizTypeEnum.BUSINESS)
|
@RequestMapping
|
public class UserEvaluateController {
|
|
@Resource
|
private IUserEvaluateService userEvaluateService;
|
|
@Resource
|
private ICourseService courseService;
|
|
@Resource
|
private ICounsellingInfoService counsellingInfoService;
|
|
@Resource
|
private CustomerService customerService;
|
|
|
|
/**
|
* 添加用户评价表
|
*/
|
@ApiOperation("添加用户评价表")
|
@PostResource(name = "添加用户评价表", path = "/userEvaluate/add")
|
public ResponseData<?> add(@RequestBody UserEvaluate userEvaluate) {
|
userEvaluate.setCreateTime(new Date());
|
userEvaluate.setUpdateTime(new Date());
|
if (userEvaluate.getUserId() == null){
|
userEvaluate.setUserId(LoginContext.me().getLoginUser().getUserId());
|
}
|
this.userEvaluateService.save(userEvaluate);
|
//查询评价评分
|
Map<String,Object> map = this.userEvaluateService.getMap(new QueryWrapper<UserEvaluate>().select(" IFNULL(AVG(score),0) score ").lambda().eq(UserEvaluate::getBuinessId,userEvaluate.getBuinessId())
|
.eq(UserEvaluate::getBuinessType,userEvaluate.getBuinessType()).eq(UserEvaluate::getIsDelete,false));
|
if (map != null){
|
//计算对应评分 业务类型 1-课程，2-咨询
|
if (userEvaluate.getBuinessType().intValue() ==1){
|
if (map.get("score") != null){
|
this.courseService.update(new LambdaUpdateWrapper<Course>().set(Course::getTotalScore,map.get("score")).eq(Course::getId,userEvaluate.getBuinessId()));
|
}
|
}else if (userEvaluate.getBuinessType().intValue() == 2){
|
if (map.get("score") != null){
|
this.counsellingInfoService.update(new LambdaUpdateWrapper<CounsellingInfo>().set(CounsellingInfo::getTotalScore,map.get("score")).eq(CounsellingInfo::getId,userEvaluate.getBuinessId()));
|
}
|
}
|
}
|
return new SuccessResponseData<>();
|
}
|
|
|
|
/**
|
* 修改用户评价表
|
*/
|
@ApiOperation("修改用户评价表")
|
@PostResource(name = "修改用户评价表", path = "/userEvaluate/edit")
|
public ResponseData<?> edit(@RequestBody UserEvaluate userEvaluate) {
|
this.userEvaluateService.updateById(userEvaluate);
|
//判断是否有修改评分
|
if (userEvaluate.getScore() != null){
|
//查询评价评分
|
Map<String,Object> map = this.userEvaluateService.getMap(new QueryWrapper<UserEvaluate>().select(" IFNULL(AVG(score),0) score ").lambda().eq(UserEvaluate::getBuinessId,userEvaluate.getBuinessId())
|
.eq(UserEvaluate::getBuinessType,userEvaluate.getBuinessType()).eq(UserEvaluate::getIsDelete,false));
|
if (map != null){
|
//计算对应评分 业务类型 1-课程，2-咨询
|
if (userEvaluate.getBuinessType().intValue() ==1){
|
if (map.get("score") != null){
|
this.courseService.update(new LambdaUpdateWrapper<Course>().set(Course::getTotalScore,map.get("score")).eq(Course::getId,userEvaluate.getBuinessId()));
|
}
|
}else if (userEvaluate.getBuinessType().intValue() == 2){
|
if (map.get("score") != null){
|
this.counsellingInfoService.update(new LambdaUpdateWrapper<CounsellingInfo>().set(CounsellingInfo::getTotalScore,map.get("score")).eq(CounsellingInfo::getId,userEvaluate.getBuinessId()));
|
}
|
}
|
}
|
}
|
|
|
return new SuccessResponseData<>();
|
}
|
|
|
|
|
|
/**
|
* 获取用户评价表列表(分页)
|
*/
|
|
@ApiOperation(value = "获取用户评价表列表(分页)")
|
@GetResource(name = "获取用户评价表列表(分页)", path = "/userEvaluate/page")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageNo", value = "分页：第几页（从1开始）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "pageSize", value = "分页：每页大小（默认10）", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "buinessType", value = "业务类型 1-课程，2-咨询", dataTypeClass = Integer.class, paramType = "query"),
|
@ApiImplicitParam(name = "buinessId", value = "业务id 课程id或咨询人员id", dataTypeClass = Long.class, paramType = "query"),
|
@ApiImplicitParam(name = "userId", value = "评价用户id（查询自己的评价时候使用）", dataTypeClass = Long.class, paramType = "query"),
|
})
|
public ResponseData<PageResult<UserEvaluate>> page(Integer pageNo, Integer pageSize, Integer buinessType, Long buinessId,Long userId) {
|
LambdaQueryWrapper<UserEvaluate> lambdaQueryWrapper = new LambdaQueryWrapper<UserEvaluate>().eq(UserEvaluate::getIsDelete,false)
|
.orderByDesc(UserEvaluate::getUpdateTime);
|
lambdaQueryWrapper.eq(buinessType != null,UserEvaluate::getBuinessType,buinessType);
|
lambdaQueryWrapper.eq(buinessId != null,UserEvaluate::getBuinessId,buinessId);
|
lambdaQueryWrapper.eq(userId != null,UserEvaluate::getUserId,userId);
|
Page<UserEvaluate> page = this.userEvaluateService.page(PageFactory.defaultPage(), lambdaQueryWrapper);
|
if (CollectionUtil.isNotEmpty(page.getRecords())){
|
page.getRecords().forEach(userEvaluate -> {
|
Customer customer = this.customerService.getById(userEvaluate.getUserId());
|
if (customer != null){
|
userEvaluate.setAvatar(customer.getAvatarObjectName());
|
userEvaluate.setNickName(customer.getNickName());
|
}
|
});
|
}
|
return new SuccessResponseData<>(PageResultFactory.createPageResult(page));
|
}
|
|
}
|
