package com.ruoyi.errand.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
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.AddCourierDTO;
|
import com.ruoyi.errand.object.dto.sys.CourierPageListDTO;
|
import com.ruoyi.errand.object.dto.sys.EditCourierDTO;
|
import com.ruoyi.errand.object.vo.app.CompleteOrderDTO;
|
import com.ruoyi.errand.object.vo.app.CourierInfoVO;
|
import com.ruoyi.errand.object.vo.app.CourierOrderListVO;
|
import com.ruoyi.errand.object.vo.app.CourierStatisticsVO;
|
import com.ruoyi.errand.object.vo.sys.AllCourierListVO;
|
import com.ruoyi.errand.object.vo.sys.AppUserPageListVO;
|
import com.ruoyi.errand.object.vo.sys.CourierPageListVO;
|
import com.ruoyi.errand.object.vo.sys.CourierSysDetailVO;
|
import com.ruoyi.errand.service.AppUserService;
|
import com.ruoyi.errand.service.CourierService;
|
import com.ruoyi.errand.utils.RedisService;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.security.core.context.SecurityContextHolder;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.DayOfWeek;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.LocalTime;
|
import java.time.temporal.TemporalAdjusters;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class CourierServiceImpl extends ServiceImpl<CourierMapper, Courier> implements CourierService {
|
|
@Resource
|
private EvaluationMapper evaluationMapper;
|
@Autowired
|
private OrderMapper orderMapper;
|
@Autowired
|
private CommunityCourierMapper communityCourierMapper;
|
@Autowired
|
private RedisService redisService;
|
@Autowired
|
private AppUserMapper appUserMapper;
|
@Autowired
|
private CommunityMapper communityMapper;
|
|
|
@Override
|
public CourierInfoVO getCourierInfo() {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
return this.baseMapper.getCourierInfo(appuser.getCourierId());
|
}
|
|
@Override
|
public CourierStatisticsVO getDatStatistics() {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
|
//本日 本周 本月
|
CourierStatisticsVO vo =this.baseMapper.getDatStatistics(appuser.getCourierId());
|
//统计五星好评的订单数量
|
Integer fiveCount=evaluationMapper.getFiveCount(appuser.getCourierId());
|
vo.setFive(fiveCount);
|
return vo;
|
}
|
|
@Override
|
public IPage<CourierOrderListVO> getCourierOrderList(Integer pageNum, Integer pageSize, Integer orderStatus) {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
IPage<CourierOrderListVO> page=new Page<>(pageNum, pageSize);
|
return this.baseMapper.getCourierOrderList(page,appuser.getCourierId(),orderStatus);
|
}
|
|
@Override
|
public void receiveOrder(Integer id) {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
if (appuser.getCourierId()==null){
|
throw new ServiceException("您还不是跑腿员");
|
}
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>().eq(CommunityCourier::getCourierId, appuser.getCourierId()));
|
if(communityCourier==null){
|
throw new ServiceException("您未绑定小区");
|
}
|
//判断订单是否存在
|
Order order = orderMapper.selectById(id);
|
if (order==null || order.getDelFlag().equals(DelFlagConstant.DELETE)){
|
throw new ServiceException("订单不存在");
|
}
|
if (order.getOrderStatus()!=1){
|
throw new ServiceException("订单状态错误");
|
}
|
if (!order.getCommunityId().equals(communityCourier.getCommunityId())){
|
throw new ServiceException("该订单不属于您绑定的小区");
|
}
|
|
//修改订单状态
|
order.setOrderStatus(2);
|
order.setCourierId(appuser.getCourierId());
|
order.setReceivingTime(LocalDateTime.now());
|
orderMapper.updateById(order);
|
|
}
|
|
@Override
|
public void completeOrder(CompleteOrderDTO completeOrderDTO) {
|
AppUser appuser = (AppUser) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
|
if (appuser.getCourierId()==null){
|
throw new ServiceException("您还不是跑腿员");
|
}
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaUpdateWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCourierId, appuser.getCourierId()));
|
if(communityCourier==null){
|
throw new ServiceException("您未绑定小区");
|
}
|
//判断订单是否存在
|
Order order = orderMapper.selectById(completeOrderDTO.getId());
|
if (order==null || order.getDelFlag().equals(DelFlagConstant.DELETE)){
|
throw new ServiceException("订单不存在");
|
}
|
if (order.getOrderStatus()!=2){
|
throw new ServiceException("订单状态错误");
|
}
|
if (!order.getCommunityId().equals(communityCourier.getCommunityId())){
|
throw new ServiceException("该订单不属于您绑定的小区");
|
}
|
|
order.setOrderStatus(4);
|
order.setCourierPics(completeOrderDTO.getCourierPics());
|
order.setFinishTime(LocalDateTime.now());
|
orderMapper.updateById(order);
|
//评价
|
if (completeOrderDTO.getRating()!=null){
|
Evaluation evaluation = new Evaluation();
|
evaluation.setOrderId(order.getId());
|
evaluation.setType(1);
|
evaluation.setRating(completeOrderDTO.getRating());
|
if (null!=completeOrderDTO.getContent()){
|
evaluation.setContent(completeOrderDTO.getContent());
|
}
|
evaluationMapper.insert(evaluation);
|
}
|
}
|
|
@Override
|
public IPage<CourierPageListVO> getCourierPageList(CourierPageListDTO dto) {
|
IPage<CourierPageListVO> page = new Page<>(dto.getPageNum(),dto.getPageSize());
|
IPage<CourierPageListVO> iPage=this.baseMapper.getCourierPageList(page,dto);
|
|
iPage.getRecords().forEach(x->{
|
List<Order> orderList = orderMapper.selectList(new LambdaUpdateWrapper<Order>()
|
.eq(Order::getCourierId, x.getId())
|
.eq(Order::getDelFlag,DelFlagConstant.UNDELETE)
|
.eq(Order::getPayMethod,2));
|
if (orderList!=null&& !orderList.isEmpty()){
|
//当天接单量
|
LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
LocalDateTime todayEnd = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
long todayNum = countByTimeRange(orderList, todayStart, todayEnd);
|
x.setToday((int) todayNum);
|
//本周接单量
|
LocalDate today = LocalDate.now();
|
LocalDate monday = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
|
LocalDateTime weekStart = LocalDateTime.of(monday, LocalTime.MIN);
|
LocalDate sunday = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
|
LocalDateTime weekEnd = LocalDateTime.of(sunday, LocalTime.MAX);
|
long week = countByTimeRange(orderList, weekStart, weekEnd);
|
x.setWeek((int) week);
|
//本月接单量
|
LocalDate firstDay = today.withDayOfMonth(1);
|
LocalDateTime mouthStart = LocalDateTime.of(firstDay, LocalTime.MIN);
|
LocalDate lastDay = today.with(TemporalAdjusters.lastDayOfMonth());
|
LocalDateTime mouthEnd = LocalDateTime.of(lastDay, LocalTime.MAX);
|
long mouth = countByTimeRange(orderList, mouthStart, mouthEnd);
|
x.setMouth((int) mouth);
|
//五星好评数
|
List<Integer> orderIds = orderList.stream().map(Order::getId).collect(Collectors.toList());
|
Long five = evaluationMapper.selectCount(new LambdaQueryWrapper<Evaluation>()
|
.in(Evaluation::getOrderId, orderIds)
|
.eq(Evaluation::getType, 0)
|
.eq(Evaluation::getRating, 5.0));
|
x.setFive(five.intValue());
|
}
|
|
});
|
return iPage;
|
}
|
|
@Override
|
public CourierSysDetailVO detail(Integer id) {
|
CourierSysDetailVO vo=this.baseMapper.detail(id);
|
List<Order> orderList = orderMapper.selectList(new LambdaUpdateWrapper<Order>()
|
.eq(Order::getCourierId, id)
|
.eq(Order::getDelFlag,DelFlagConstant.UNDELETE)
|
.eq(Order::getPayMethod,2));
|
if (orderList!=null&& !orderList.isEmpty()){
|
//当天接单量
|
LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
LocalDateTime todayEnd = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
long todayNum = countByTimeRange(orderList, todayStart, todayEnd);
|
vo.setToday((int) todayNum);
|
//本周接单量
|
LocalDate today = LocalDate.now();
|
LocalDate monday = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
|
LocalDateTime weekStart = LocalDateTime.of(monday, LocalTime.MIN);
|
LocalDate sunday = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
|
LocalDateTime weekEnd = LocalDateTime.of(sunday, LocalTime.MAX);
|
long week = countByTimeRange(orderList, weekStart, weekEnd);
|
vo.setWeek((int) week);
|
//本月接单量
|
LocalDate firstDay = today.withDayOfMonth(1);
|
LocalDateTime mouthStart = LocalDateTime.of(firstDay, LocalTime.MIN);
|
LocalDate lastDay = today.with(TemporalAdjusters.lastDayOfMonth());
|
LocalDateTime mouthEnd = LocalDateTime.of(lastDay, LocalTime.MAX);
|
long mouth = countByTimeRange(orderList, mouthStart, mouthEnd);
|
vo.setMouth((int) mouth);
|
//五星好评
|
List<Integer> orderIds = orderList.stream().map(Order::getId).collect(Collectors.toList());
|
Long five = evaluationMapper.selectCount(new LambdaQueryWrapper<Evaluation>()
|
.in(Evaluation::getOrderId, orderIds)
|
.eq(Evaluation::getType, 0)
|
.eq(Evaluation::getRating, 5.0));
|
vo.setFive(five.intValue());
|
//总共接单量
|
vo.setTotal(orderIds.size());
|
}
|
|
|
return vo;
|
}
|
|
@Override
|
public void add(AddCourierDTO addCourierDTO) {
|
AppUser appUser = appUserMapper.selectOne(new LambdaQueryWrapper<AppUser>().eq(AppUser::getPhone, addCourierDTO.getPhone()).
|
eq(AppUser::getDelFlag, DelFlagConstant.UNDELETE));
|
if (appUser == null) {
|
throw new ServiceException("请先注册小程序");
|
}
|
//手机号是否存在
|
Courier courier = this.getBaseMapper().selectOne(new LambdaQueryWrapper<Courier>().eq(Courier::getPhone, addCourierDTO.getPhone())
|
.eq(Courier::getDelFlag, DelFlagConstant.UNDELETE));
|
if (courier != null) {
|
throw new ServiceException("该手机号的跑腿员已存在");
|
}
|
if (addCourierDTO.getCommunityId() != null) {
|
//绑定的小区是否存在
|
Community community = communityMapper.selectById(addCourierDTO.getCommunityId());
|
if (community == null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)) {
|
throw new ServiceException("绑定的小区不存在");
|
}
|
//绑定的小区是否被别人绑定了
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCommunityId, addCourierDTO.getCommunityId()));
|
if (communityCourier != null) {
|
throw new ServiceException("该小区已被绑定");
|
}
|
|
}
|
//保存跑腿人员
|
Courier courier1 = new Courier();
|
BeanUtils.copyProperties(addCourierDTO, courier1);
|
this.save(courier1);
|
//绑定小区
|
if (addCourierDTO.getCommunityId() != null) {
|
CommunityCourier communityCourier = new CommunityCourier();
|
communityCourier.setCommunityId(addCourierDTO.getCommunityId());
|
communityCourier.setCourierId(courier1.getId());
|
communityCourierMapper.insert(communityCourier);
|
}
|
}
|
|
@Override
|
public void edit(EditCourierDTO editCourierDTO) {
|
Courier courier = this.getById(editCourierDTO.getId());
|
//检查是否存在
|
if (courier == null || courier.getDelFlag().equals(DelFlagConstant.DELETE)) {
|
throw new ServiceException("该跑腿员不存在");
|
}
|
//是否更改了手机号
|
if (!courier.getPhone().equals(editCourierDTO.getPhone())) {
|
//更改了手机号
|
AppUser appUser = appUserMapper.selectOne(new LambdaQueryWrapper<AppUser>().eq(AppUser::getPhone, editCourierDTO.getPhone()).
|
eq(AppUser::getDelFlag, DelFlagConstant.UNDELETE));
|
if (appUser == null) {
|
throw new ServiceException("请先注册小程序");
|
}
|
Courier courier1 = this.getBaseMapper().selectOne(new LambdaQueryWrapper<Courier>().eq(Courier::getPhone, editCourierDTO.getPhone())
|
.eq(Courier::getDelFlag, DelFlagConstant.UNDELETE));
|
if (courier1 != null ) {
|
throw new ServiceException("该手机号的跑腿员已存在");
|
}
|
}
|
//是否更改了小区
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>().eq(CommunityCourier::getCourierId, editCourierDTO.getId()));
|
if (communityCourier != null) {
|
//之前有绑定小区
|
if (editCourierDTO.getCommunityId() == null) {
|
//现在没有绑定，之前的要解绑
|
communityCourierMapper.deleteById(communityCourier.getId());
|
|
}else if (!editCourierDTO.getCommunityId().equals(communityCourier.getCommunityId())) {
|
//现在绑定了，不和之前的一样
|
//绑定的小区是否存在
|
Community community = communityMapper.selectById(editCourierDTO.getCommunityId());
|
if (community == null|| Objects.equals(community.getDelFlag(), DelFlagConstant.DELETE)) {
|
throw new ServiceException("绑定的小区不存在");
|
}
|
//绑定的小区是否被别人绑定了
|
CommunityCourier communityCourier1 = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>()
|
.eq(CommunityCourier::getCommunityId, editCourierDTO.getCommunityId()));
|
if (communityCourier1 != null) {
|
throw new ServiceException("该小区已被绑定");
|
}
|
//修改
|
communityCourier.setCommunityId(editCourierDTO.getCommunityId());
|
communityCourier.setUpdateTime(LocalDateTime.now());
|
communityCourierMapper.updateById(communityCourier);
|
}
|
}
|
//修改
|
BeanUtils.copyProperties(editCourierDTO, courier);
|
this.updateById(courier);
|
|
}
|
|
@Override
|
public void froze(Integer id) {
|
Courier courier= this.getById(id);
|
if (courier == null||courier.getDelFlag().equals(DelFlagConstant.DELETE)) {
|
throw new ServiceException("该跑腿员不存在");
|
}
|
courier.setStatus(courier.getStatus()==0?1:0);
|
courier.setUpdateTime(LocalDateTime.now());
|
this.updateById(courier);
|
}
|
|
@Override
|
public void delete(Integer id) {
|
Courier courier= this.getById(id);
|
if (courier == null||courier.getDelFlag().equals(DelFlagConstant.DELETE)) {
|
throw new ServiceException("该跑腿员不存在");
|
}
|
//判断跑腿员是否绑定了小区
|
CommunityCourier communityCourier = communityCourierMapper.selectOne(new LambdaQueryWrapper<CommunityCourier>().eq(CommunityCourier::getCourierId, id));
|
if (communityCourier != null) {
|
communityCourierMapper.deleteById(communityCourier.getId());//解绑
|
}
|
courier.setDelFlag(DelFlagConstant.DELETE);
|
courier.setUpdateTime(LocalDateTime.now());
|
this.updateById(courier);
|
|
}
|
|
@Override
|
public List<AllCourierListVO> getAllCourierList() {
|
List<Integer> couriers= communityCourierMapper.getAllCourierList();
|
return this.baseMapper.getAllCourierList(couriers);
|
|
}
|
|
private static long countByTimeRange(List<Order> orderList, LocalDateTime start, LocalDateTime end) {
|
return orderList.stream()
|
.filter(order -> order.getOrderTime() != null) // 过滤空时间
|
.filter(order -> order.getOrderTime().isAfter(start.minusNanos(1))) // 大于等于 start
|
.filter(order -> order.getOrderTime().isBefore(end.plusNanos(1))) // 小于等于 end
|
.count();
|
}
|
|
|
}
|
