package com.gk.hotwork.Service.ServiceImpl;
|
|
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.gk.hotwork.Domain.DepartmentInfo;
|
import com.gk.hotwork.Domain.Enum.ErrorCode;
|
import com.gk.hotwork.Domain.Exception.BusinessException;
|
import com.gk.hotwork.Domain.Reserve;
|
import com.gk.hotwork.Domain.UserInfo;
|
import com.gk.hotwork.Domain.Utils.Msg;
|
import com.gk.hotwork.Domain.Utils.PageInfo;
|
import com.gk.hotwork.Domain.Utils.StringUtils;
|
import com.gk.hotwork.Domain.Vo.PageInfoExtension;
|
import com.gk.hotwork.Mapper.ReserveMapper;
|
import com.gk.hotwork.Service.DepartmentService;
|
import com.gk.hotwork.Service.ReserveService;
|
import com.gk.hotwork.Service.UserService;
|
import org.omg.PortableInterceptor.INACTIVE;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service("reserveService")
|
public class ReserveServiceImpl extends ServiceImpl<ReserveMapper, Reserve> implements ReserveService {
|
|
@Autowired
|
private ReserveMapper reserveMapper;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private DepartmentService departmentService;
|
|
|
/**
|
* @Description: 新增预约
|
* @date 2021/11/16 9:58
|
*/
|
@Override
|
public void addOne(Reserve reserve, UserInfo userInfo) {
|
|
//0.角色为部门负责人
|
UserInfo user = userService.getById(userInfo);
|
Byte isDepartment = user.getIsdepartment();
|
if ((byte) 1 != isDepartment)
|
throw new BusinessException("当前用户不是部门负责人，没有权限创建");
|
|
Date now = new Date();
|
Calendar instance = Calendar.getInstance();
|
instance.setTime(now);
|
instance.set(Calendar.HOUR_OF_DAY, 0);
|
instance.set(Calendar.MINUTE, 0);
|
instance.set(Calendar.SECOND, 0);
|
Date judgement = instance.getTime();
|
//1.预约时间
|
Date appointment = reserve.getAppointment();
|
if (appointment == null)
|
throw new BusinessException("预约时间为空");
|
if (appointment.before(judgement))
|
throw new BusinessException("预约时间为明日起");
|
|
//2.统计预约时间当日 该部门是否有单子
|
if (userInfo.getDepartment() == null) {
|
throw new BusinessException("用户未有部门");
|
}
|
DepartmentInfo dep = departmentService.getById(userInfo.getDepartment());
|
if (dep == null) {
|
throw new BusinessException("用户部门不存在");
|
}
|
if (this.isExistAtAppointment(appointment, dep.getDepartment()))
|
throw new BusinessException("预约当日已有预约单");
|
|
reserve.setCreateby(user.getId());
|
reserve.setCreatebyname(user.getRealname());
|
reserve.setUpdatebyname(user.getRealname());
|
reserve.setCreatetime(now);
|
reserve.setUpdatetime(now);
|
reserve.setCreatebydepartment(dep.getDepartment());
|
this.save(reserve);
|
}
|
|
/**
|
* @Description: 判断预约当日是否存在单子
|
* @date 2021/11/16 10:53
|
*/
|
@Override
|
public boolean isExistAtAppointment(Date appointment,String department) {
|
|
if (appointment == null)
|
throw new BusinessException("预约时间不能为空");
|
if (StringUtils.isBlank(department))
|
throw new BusinessException("部门不能为空");
|
|
Calendar instance = Calendar.getInstance();
|
instance.setTime(appointment);
|
instance.set(Calendar.HOUR_OF_DAY, 0);
|
instance.set(Calendar.MINUTE, 0);
|
instance.set(Calendar.SECOND, 0);
|
Date startTime = instance.getTime();
|
instance.set(Calendar.HOUR_OF_DAY, 23);
|
instance.set(Calendar.MINUTE, 59);
|
instance.set(Calendar.SECOND, 59);
|
Date endTime = instance.getTime();
|
|
LambdaQueryWrapper<Reserve> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.ge(Reserve::getAppointment, startTime)
|
.le(Reserve::getAppointment, endTime)
|
.eq(Reserve::getCreatebydepartment, department)
|
.eq(Reserve::getValidflag, true);
|
return reserveMapper.selectCount(queryWrapper) > 0;
|
|
|
}
|
|
/**
|
* @Description: 修改单子
|
* @date 2021/11/16 11:02
|
*/
|
@Override
|
public void modOne(Reserve reserve, UserInfo userInfo) {
|
|
if (reserve.getId() == null)
|
throw new BusinessException("参数传递有误");
|
Reserve old = this.getById(reserve);
|
|
//0.角色为部门负责人
|
UserInfo user = userService.getById(userInfo);
|
Byte isDepartment = user.getIsdepartment();
|
if ((byte) 1 != isDepartment)
|
throw new BusinessException("当前用户不是部门负责人，没有权限修改");
|
|
if (!old.getCreatebydepartment().equals(user.getDepartment()))
|
throw new BusinessException("当前用户不是当前单子的部门负责人");
|
|
Date now = new Date();
|
|
//更新 不修改预约时间
|
old.setSpace(reserve.getSpace());
|
old.setHoisting(reserve.getHoisting());
|
old.setSoild(reserve.getSoild());
|
old.setBreaks(reserve.getBreaks());
|
old.setHigh(reserve.getHigh());
|
old.setElectricity(reserve.getElectricity());
|
old.setBlindboard(reserve.getBlindboard());
|
old.setFire(reserve.getFire());
|
old.setUpdatebyname(user.getRealname());
|
old.setUpdatetime(now);
|
this.updateById(reserve);
|
}
|
|
/**
|
* @Description: 分页查询
|
* @date 2021/11/16 11:02
|
*/
|
@Override
|
public IPage selectPage(Page<Reserve> page, Map<String, Object> filter, UserInfo userInfo) {
|
|
LambdaQueryWrapper<Reserve> queryWrapper = new LambdaQueryWrapper<>();
|
UserInfo user = userService.getById(userInfo);
|
if (userInfo.getDepartment() == null) {
|
throw new BusinessException("用户未有部门");
|
}
|
DepartmentInfo dep = departmentService.getById(userInfo.getDepartment());
|
if (dep == null) {
|
throw new BusinessException("用户部门不存在");
|
}
|
queryWrapper.eq(Reserve::getCreatebydepartment, dep.getDepartment())
|
.eq(Reserve::getValidflag, true).orderByDesc(Reserve::getCreatetime);
|
if (StringUtils.isNotBlank((String) filter.get("starttime")))
|
queryWrapper.ge(Reserve::getAppointment, filter.get("starttime"));
|
if (StringUtils.isNotBlank((String) filter.get("endtime")))
|
queryWrapper.le(Reserve::getAppointment, filter.get("endtime"));
|
return reserveMapper.selectPage(page,queryWrapper);
|
}
|
|
|
/**
|
* @Description: 统计分页
|
* @date 2021/11/16 13:49
|
*/
|
@Override
|
public PageInfoExtension<Map> statistics(Page<Map> page, Map<String, Object> filter, UserInfo user) {
|
Map<String, Object> params = new HashMap<>();
|
params.put("appointment", filter.get("appointment"));
|
params.put("department", filter.get("department"));
|
Page pageInfo = reserveMapper.statistics(page,params);
|
PageInfoExtension<Map> extension = new PageInfoExtension<>(pageInfo);
|
Map totalNum = this.statisticsTotal(params);
|
extension.setExtension(totalNum);
|
return extension;
|
}
|
|
|
/**
|
* @Description: 统计分页 尾部 总计行
|
* @date 2021/11/16 14:14
|
*/
|
@Override
|
public Map statisticsTotal(Map<String, Object> params) {
|
return reserveMapper.selectStatisticsTotal(params);
|
}
|
}
|
