package com.ruoyi.errand.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.errand.constant.DelFlagConstant;
|
import com.ruoyi.errand.domain.*;
|
import com.ruoyi.errand.mapper.*;
|
import com.ruoyi.errand.object.dto.sys.AddCommunityDTO;
|
import com.ruoyi.errand.object.dto.sys.CommunityPageListDTO;
|
import com.ruoyi.errand.object.dto.sys.EditCommunityDTO;
|
import com.ruoyi.errand.object.vo.app.CommunityListVO;
|
import com.ruoyi.errand.object.vo.sys.AllCommunityListVO;
|
import com.ruoyi.errand.object.vo.sys.CommunityPageListVO;
|
import com.ruoyi.errand.object.vo.sys.CommunitySysDetailVO;
|
import com.ruoyi.errand.object.vo.sys.CourierPageListVO;
|
import com.ruoyi.errand.service.CommunityService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.LocalTime;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Objects;
|
|
@Service
|
public class CommunityServiceImpl extends ServiceImpl<CommunityMapper, Community> implements CommunityService {
|
|
|
private final CommunityCourierMapper communityCourierMapper;
|
private final OrderMapper orderMapper;
|
private final RegionMapper regionMapper;
|
private final CourierMapper courierMapper;
|
private final PhoneMapper phoneMapper;
|
|
public CommunityServiceImpl(CommunityCourierMapper communityCourierMapper, OrderMapper orderMapper, RegionMapper regionMapper, CourierMapper courierMapper, PhoneMapper phoneMapper) {
|
this.communityCourierMapper = communityCourierMapper;
|
this.orderMapper = orderMapper;
|
this.regionMapper = regionMapper;
|
this.courierMapper = courierMapper;
|
this.phoneMapper = phoneMapper;
|
}
|
|
@Override
|
public R<List<CommunityListVO>> getCommunity(Integer regionId) {
|
List<CommunityListVO> communityListVOS = this.getBaseMapper().selectListByRegionId(regionId);
|
return R.ok(communityListVOS);
|
|
}
|
|
@Override
|
public R<List<CommunityListVO>> getTotalCommunityList() {
|
List<CommunityListVO> communityListVOS = this.getBaseMapper().getTotalCommunityList();
|
return R.ok(communityListVOS);
|
}
|
|
@Override
|
public List<AllCommunityListVO> getAllCommunityList() {
|
List<Integer> list=communityCourierMapper.getAllCommunityList();
|
return this.baseMapper.getAllCommunityList(list);
|
}
|
|
@Override
|
public IPage<CommunityPageListVO> getCommunityPageList(CommunityPageListDTO dto) {
|
IPage<CommunityPageListVO> page = new Page<>(dto.getPageNum(),dto.getPageSize());
|
IPage<CommunityPageListVO> iPage=this.baseMapper.getCommunityPageList(page,dto);
|
iPage.getRecords().forEach(x->{
|
List<Order> orderList = orderMapper.selectList(new LambdaQueryWrapper<Order>()
|
.eq(Order::getCommunityId, x.getId())
|
.eq(Order::getDelFlag, DelFlagConstant.UNDELETE)
|
.eq(Order::getPayStatus,2));
|
if (orderList!=null&& !orderList.isEmpty()){
|
x.setTotal(orderList.size());//总订单数
|
LocalDateTime start = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
LocalDateTime end = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
long today = orderList.stream().filter(order -> order.getOrderTime().isAfter(start.minusNanos(1)))
|
.filter(order -> order.getOrderTime().isBefore(end.plusNanos(1))).count();
|
x.setToday((int) today);//今日订单数
|
}
|
});
|
|
return iPage;
|
}
|
|
@Override
|
@Transactional
|
public void add(AddCommunityDTO addCommunityDTO) {
|
|
//城市地址是否存在
|
Region region = regionMapper.selectById(addCommunityDTO.getRegionId());
|
if (region==null){
|
throw new ServiceException("所在城市id错误");
|
}
|
//跑腿人员是否存在
|
Courier courier = courierMapper.selectById(addCommunityDTO.getCourierId());
|
if (courier==null|| Objects.equals(courier.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("跑腿人员不存在");
|
}
|
//是否被绑定
|
Long count = communityCourierMapper.selectCount(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCourierId, addCommunityDTO.getCourierId()));
|
if (count>0){
|
throw new ServiceException("跑腿人员已绑定");
|
}
|
//添加小区
|
Community community = new Community();
|
BeanUtils.copyProperties(addCommunityDTO,community);
|
this.save(community);
|
if (addCommunityDTO.getServicePhone()!=null){
|
//保存客服电话
|
Phone phone = new Phone();
|
phone.setType(2);
|
phone.setCommunity_id(community.getId());
|
phone.setPhone(addCommunityDTO.getServicePhone());
|
phoneMapper.insert(phone);
|
}
|
//保存跑腿员关系
|
CommunityCourier communityCourier = new CommunityCourier();
|
communityCourier.setCommunityId(community.getId());
|
communityCourier.setCourierId(addCommunityDTO.getCourierId());
|
communityCourier.setCreateTime(LocalDateTime.now());
|
communityCourierMapper.insert(communityCourier);
|
|
}
|
|
@Override
|
@Transactional
|
public void edit(EditCommunityDTO editCommunityDTO) {
|
//检查小区是否存在
|
Community community = this.baseMapper.selectById(editCommunityDTO.getId());
|
if (community==null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("该小区不存在");
|
}
|
//检查所在城市是否更改
|
if (!Objects.equals(editCommunityDTO.getRegionId(), community.getRegionId())){
|
//检查城市是否存在
|
Region region = regionMapper.selectById(editCommunityDTO.getRegionId());
|
if (region==null){
|
throw new ServiceException("所在城市id错误");
|
}
|
}
|
//检查客服电话是否更改
|
if (editCommunityDTO.getServicePhone()!=null){
|
Phone phone = phoneMapper.selectOne(new LambdaQueryWrapper<Phone>()
|
.eq(Phone::getCommunity_id, editCommunityDTO.getId())
|
.eq(Phone::getType, 2));
|
if (phone==null){
|
//添加
|
//保存客服电话
|
phone = new Phone();
|
phone.setType(2);
|
phone.setCommunity_id(community.getId());
|
phone.setPhone(editCommunityDTO.getServicePhone());
|
phoneMapper.insert(phone);
|
}else {
|
//修改
|
phone.setPhone(editCommunityDTO.getServicePhone());
|
phoneMapper.updateById(phone);
|
}
|
|
}
|
//检查跑腿员是否存在
|
Courier courier = courierMapper.selectById(editCommunityDTO.getCourierId());
|
if (courier==null|| Objects.equals(courier.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("跑腿人员不存在");
|
}
|
//检查跑腿员是否绑定
|
Long count = communityCourierMapper.selectCount(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCourierId, editCommunityDTO.getCourierId()));
|
if (count>0){
|
throw new ServiceException("跑腿人员已绑定");
|
}
|
//检查跑腿员是否更改
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCommunityId, editCommunityDTO.getId()));
|
if (communityCourier==null){
|
//新增
|
communityCourier = new CommunityCourier();
|
communityCourier.setCommunityId(editCommunityDTO.getId());
|
communityCourier.setCourierId(editCommunityDTO.getCourierId());
|
}else {
|
//修改
|
communityCourier.setCourierId(editCommunityDTO.getCourierId());
|
communityCourierMapper.updateById(communityCourier);
|
}
|
|
}
|
|
@Override
|
public void delete(Integer id) {
|
Community community = this.baseMapper.selectById(id);
|
if (community==null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("未找到该小区");
|
}
|
//删除关系
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCommunityId, id));
|
if (communityCourier!=null){
|
communityCourierMapper.deleteById(communityCourier.getId());
|
}
|
//删除小区
|
community.setDelFlag(DelFlagConstant.DELETE);
|
community.setUpdateTime(LocalDateTime.now());
|
this.baseMapper.updateById(community);
|
}
|
|
@Override
|
public void froze(Integer id) {
|
//冻结/解冻
|
Community community = this.baseMapper.selectById(id);
|
if (community==null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("未找到该小区");
|
}
|
community.setStatus(community.getStatus()==0?1:0);
|
community.setUpdateTime(LocalDateTime.now());
|
this.baseMapper.updateById(community);
|
}
|
|
@Override
|
public CommunitySysDetailVO detail(Integer id) {
|
Community community = this.getById(id);
|
if (community==null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)){
|
throw new ServiceException("小区不存在");
|
}
|
CommunitySysDetailVO vo = new CommunitySysDetailVO();
|
BeanUtils.copyProperties(community,vo);
|
//
|
//所在城市Str 根据城市id查询整个字符
|
String regionStr =getAllStrById(community.getRegionId());
|
vo.setRegionStr(regionStr);
|
//跑腿员id和名称
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>().eq(CommunityCourier::getCommunityId, community.getId()));
|
if (communityCourier!=null){
|
vo.setCourierId(communityCourier.getCourierId());
|
Courier courier = courierMapper.selectById(vo.getCourierId());
|
if (null!=courier && Objects.equals(courier.getDelFlag(), DelFlagConstant.UNDELETE)){
|
vo.setCourierName(courier.getName());
|
}
|
}
|
//客服电话
|
Phone phone = phoneMapper.selectOne(new LambdaQueryWrapper<Phone>().eq(Phone::getCommunity_id, community.getId()));
|
if (phone!=null){
|
vo.setServicePhone(phone.getPhone());
|
}
|
return vo;
|
}
|
|
private String getAllStrById(Integer regionId) {
|
if (regionId == null||regionId==0) {
|
return "";
|
}
|
Region region = regionMapper.selectById(regionId);
|
if (region == null) {
|
return "";
|
}
|
// 获取父级区域的完整名称
|
String parentName = getAllStrById(region.getParentId());
|
// 拼接当前区域名称
|
if (parentName.isEmpty()) {
|
return region.getName();
|
} else {
|
return parentName + "-" + region.getName();
|
}
|
}
|
}
|
