/* * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * Neither the name of the dreamlu.net developer nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * Author: Chill 庄骞 (smallchill@163.com) */ package org.springblade.modules.property.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.apache.logging.log4j.util.Strings; import org.springblade.core.secure.utils.AuthUtil; import org.springblade.modules.property.entity.PropertyCompanyCommentEntity; import org.springblade.modules.property.entity.PropertyCompanyScoreEntity; import org.springblade.modules.property.service.IPropertyCompanyScoreService; import org.springblade.modules.property.vo.PropertyCompanyCommentVO; import org.springblade.modules.property.mapper.PropertyCompanyCommentMapper; import org.springblade.modules.property.service.IPropertyCompanyCommentService; import org.springblade.core.mp.base.BaseServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.baomidou.mybatisplus.core.metadata.IPage; import org.springframework.transaction.annotation.Transactional; /** * 物业公司评论表 服务实现类 * * @author BladeX * @since 2024-01-05 */ @Service public class PropertyCompanyCommentServiceImpl extends ServiceImpl implements IPropertyCompanyCommentService { @Autowired private IPropertyCompanyScoreService propertyCompanyScoreService; @Override public IPage selectPropertyCompanyCommentPage(IPage page, PropertyCompanyCommentVO propertyCompanyComment) { if (null!=propertyCompanyComment.getIsRec()){ // 递归查询 return page.setRecords(baseMapper.selectPropertyCompanyCommentPageRec(page, propertyCompanyComment)); } return page.setRecords(baseMapper.selectPropertyCompanyCommentPage(page, propertyCompanyComment)); } /** * 物业公司评论表 自定义新增或修改 */ @Override @Transactional(rollbackFor = Exception.class) public boolean saveOrUpdatePropertyCompanyComment(PropertyCompanyCommentVO propertyCompanyComment) { boolean save = save(propertyCompanyComment); // 更新评分 updatePropertyCompanyScore(propertyCompanyComment); // 返回 return save; } /** * 更新评分 * @param propertyCompanyComment */ public void updatePropertyCompanyScore(PropertyCompanyCommentVO propertyCompanyComment) { // 查询当前的物业公司,当前人是否已经评分,如果已经评分,则更新,否则新增 if (null!=propertyCompanyComment.getScore()){ QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("is_deleted",0).eq("create_user", AuthUtil.getUserId()) .eq("property_company_id",propertyCompanyComment.getPropertyCompanyId()); PropertyCompanyScoreEntity one = propertyCompanyScoreService.getOne(queryWrapper); if (null!=one){ one.setScore(propertyCompanyComment.getScore()); // 更新 propertyCompanyScoreService.updateById(one); }else { PropertyCompanyScoreEntity propertyCompanyScoreEntity = new PropertyCompanyScoreEntity(); propertyCompanyScoreEntity.setScore(propertyCompanyComment.getScore()); propertyCompanyScoreEntity.setPropertyCompanyId(propertyCompanyComment.getPropertyCompanyId()); propertyCompanyScoreEntity.setCreateUser(AuthUtil.getUserId()); // 新增 propertyCompanyScoreService.save(propertyCompanyScoreEntity); } } } }