package com.doumee.service.business.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.doumee.biz.system.SystemDictDataBiz;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.LoginUserInfo;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.*;
|
import com.doumee.core.wx.MeetConstants;
|
import com.doumee.core.wx.SendWxMessage;
|
import com.doumee.core.wx.WxPlatNotice;
|
import com.doumee.dao.admin.request.BusinessOverDTO;
|
import com.doumee.dao.admin.request.QrOpenDoorDto;
|
import com.doumee.dao.admin.response.DevWgResponseParam;
|
import com.doumee.dao.business.*;
|
import com.doumee.dao.business.dao.SmsConfigMapper;
|
import com.doumee.dao.business.dao.SmsEmailMapper;
|
import com.doumee.dao.business.join.*;
|
import com.doumee.dao.business.model.*;
|
import com.doumee.dao.business.vo.RoomStatisticsVo;
|
import com.doumee.dao.system.MultifileMapper;
|
import com.doumee.dao.system.SystemUserMapper;
|
import com.doumee.dao.system.dto.UserStatisticsDTO;
|
import com.doumee.dao.system.join.NoticesJoinMapper;
|
import com.doumee.dao.system.model.*;
|
import com.doumee.dao.system.vo.UserResponse;
|
import com.doumee.dao.system.vo.UserStatisticsVo;
|
import com.doumee.dao.web.request.BookingsRequest;
|
import com.doumee.dao.web.request.MeetingPageRequest;
|
import com.doumee.dao.web.request.UserPageRequest;
|
import com.doumee.dao.web.response.*;
|
import com.doumee.service.business.BookingsService;
|
import com.doumee.service.business.DevicesService;
|
import com.doumee.service.business.ProjectsService;
|
import com.doumee.service.system.SystemUserService;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.awt.print.Book;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.time.temporal.TemporalAdjusters;
|
import java.util.*;
|
import java.util.Date;
|
import java.util.stream.Collectors;
|
|
/**
|
* 会议室预定信息表Service实现
|
*
|
* @author 江蹄蹄
|
* @date 2023/05/04 18:18
|
*/
|
@Service
|
public class BookingsServiceImpl implements BookingsService {
|
|
@Value("${des_pwd}")
|
private String desPwd;
|
@Autowired
|
private BookingsMapper bookingsMapper;
|
@Autowired
|
private SmsConfigMapper smsConfigMapper;
|
@Autowired
|
private SystemUserMapper systemUserMapper;
|
@Autowired
|
private RoomRecordMapper roomRecordMapper;
|
|
|
@Autowired
|
private BookingsJoinMapper bookingsJoinMapper;
|
|
@Autowired
|
private RoomsMapper roomsMapper;
|
@Autowired
|
private ProjectRelJoinMapper projectRelJoinMapper;
|
@Autowired
|
private UserRelJoinMapper userRelJoinMapper;
|
@Autowired
|
private BookingTimeJoinMapper bookingTimeJoinMapper;
|
@Autowired
|
private RoomTimeJoinMapper roomTimeJoinMapper;
|
@Autowired
|
private MultifileJoinMapper multifileJoinMapper;
|
|
@Autowired
|
private SystemDictDataBiz systemDictDataBiz;
|
|
@Autowired
|
private SystemUserService systemUserService;
|
@Autowired
|
private DevicesService devicesService;
|
|
@Autowired
|
private ProjectsService projectsService;
|
|
@Autowired
|
private MultifileMapper multifileMapper;
|
|
@Autowired
|
private NoticesJoinMapper noticesMapper;
|
@Autowired
|
private SmsEmailMapper smsEmailMapper;
|
|
@Autowired
|
private UserRelMapper userRelMapper;
|
|
@Autowired
|
private BookingTimeMapper bookingTimeMapper;
|
|
@Autowired
|
private ProjectsMapper projectsMapper;
|
|
@Autowired
|
private SendWxMessage sendWxMessage;
|
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
|
public Integer create(Bookings bookings) {
|
LoginUserInfo user = bookings.getLoginUserInfo();
|
Rooms rooms = roomsMapper.selectById(bookings.getRoomId());
|
if(rooms==null ){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该会议室暂时无法预约");
|
}
|
bookings.setRoomName(rooms.getName());
|
isCreateParamValid(bookings, user);
|
bookings.setCreateDate(new Date());
|
bookings.setCreator(user.getId());
|
bookings.setIsdeleted(MeetConstants.ZERO);
|
bookings.setStatus(MeetConstants.ZERO);
|
bookingsMapper.insert(bookings);
|
bookings.setManagerInfo(user.getRealname());
|
//更新会议室预定时间段
|
updateBookingTimes(bookings, user);
|
//添加管理人员
|
updateManager(bookings, user);
|
//添加管服务项目
|
updateProjectRel(bookings, user);
|
handleFile(bookings, user);
|
//发送会议预约成功通知
|
if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){
|
this.sendNotice(bookings, MeetConstants.TWO);
|
SystemUser systemUser = systemUserMapper.selectById(user.getId());
|
this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ZERO);
|
}
|
|
return bookings.getId();
|
}
|
|
public void handleFile(Bookings bookings, LoginUserInfo user) {
|
QueryWrapper<Multifile> bookquery = new QueryWrapper<>();
|
bookquery.lambda().eq(Multifile::getIsdeleted, MeetConstants.ZERO);
|
bookquery.lambda().eq(Multifile::getObjId, bookings.getId());
|
multifileJoinMapper.delete(bookquery);
|
if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(bookings.getFileList())) {
|
bookings.getFileList().stream().forEach(s -> {
|
s.setIsdeleted(MeetConstants.ZERO);
|
s.setCreateDate(new Date());
|
s.setCreator(user.getId());
|
s.setObjId(bookings.getId());
|
s.setType(MeetConstants.TWO);
|
s.setObjType(MeetConstants.ZERO);
|
multifileJoinMapper.insert(s);
|
});
|
}
|
|
}
|
|
public void isCreateParamValid(Bookings bookings, LoginUserInfo user) {
|
|
if (bookings.getRoomId() == null ||
|
bookings.getStartTime() == null ||
|
bookings.getEndTime() == null ||
|
org.apache.commons.collections4.CollectionUtils.isEmpty(bookings.getBookingTimeList()) ||
|
StringUtils.isBlank(bookings.getName())/* ||*/
|
/* StringUtils.isBlank(bookings.getContent())*/
|
/* ||org.apache.commons.collections4.CollectionUtils.isEmpty(bookings.getSysList())*/
|
) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
|
if(Objects.nonNull(bookings.getId())){
|
return;
|
}
|
|
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
SimpleDateFormat format1 = new SimpleDateFormat("yyyy-MM-dd");
|
String gsDate = format1.format(bookings.getStartTime());
|
//查询当前会议预定时间段是否可用
|
|
MPJLambdaWrapper<Bookings> bookquery = new MPJLambdaWrapper<>();
|
bookquery.selectAll(Bookings.class);
|
bookquery.selectAs(BookingTime::getTimeId, Bookings::getRoomTimeId);
|
bookquery.selectAs(BookingTime::getId, Bookings::getBookingTimeId);
|
bookquery.eq(Bookings::getIsdeleted, MeetConstants.ZERO);
|
bookquery.eq(BookingTime::getIsdeleted, MeetConstants.ZERO);
|
bookquery.eq(Bookings::getRoomId, bookings.getRoomId());
|
bookquery.eq(Bookings::getStatus, MeetConstants.ZERO);
|
//bookquery.ge(Bookings::getStartTime, bookings.getStartTime());
|
|
bookquery.apply(" t.START_TIME like '" + DateUtil.dateToString(bookings.getStartTime(), "yyyy-MM-dd") + "%' ");
|
//bookquery.apply("DATE_FORMAT(t.START_TIME,'%Y-%m-%d') = DATE_FORMAT("+DateUtil.dateToString(bookings.getStartTime(),"yyyy-MM-dd")+",'%Y-%m-%d') " );
|
bookquery.innerJoin(BookingTime.class, BookingTime::getBookingId, Bookings::getId);
|
|
List<Bookings> bookList = bookingsJoinMapper.selectJoinList(Bookings.class, bookquery);
|
for (int i = 0; i < bookings.getBookingTimeList().size(); i++) {
|
BookingTime s = bookings.getBookingTimeList().get(i);
|
RoomTime roomTime = roomTimeJoinMapper.selectById(s.getTimeId());
|
if(Objects.isNull(roomTime)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"存在未查询到的配置日期，请刷新重试");
|
}
|
String endRoomTime = gsDate + " " + roomTime.getEndTime()+":00";
|
if(DateUtil.StringToDate(endRoomTime, "yyyy-MM-dd HH:mm:ss").getTime()<=System.currentTimeMillis()){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),endRoomTime + "已超过当前时间，无法进行预约");
|
}
|
if (!Objects.isNull(bookList) && bookList.size() > MeetConstants.ZERO) {
|
List<Bookings> detailDataDtoStream =
|
bookList.stream().filter(a -> MeetConstants.equalsInteger(s.getTimeId(), a.getRoomTimeId())
|
).collect(Collectors.toList());
|
|
if (detailDataDtoStream.size() > 0) {
|
if (bookings.getId() != null) {
|
//编辑
|
List<Bookings> chriList =
|
detailDataDtoStream.stream()
|
.filter(a -> !MeetConstants.equalsInteger(a.getId(), bookings.getId()))
|
.filter(a -> MeetConstants.equalsInteger(a.getRoomTimeId(), s.getTimeId()))
|
.collect(Collectors.toList());
|
if (chriList.size() > 0) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该会议：" + roomTime.getStartTime() + "-" + roomTime.getEndTime() + "时间段内已被使用");
|
}
|
} else {
|
//插入
|
List<Bookings> chriList =
|
detailDataDtoStream.stream()
|
.filter(a -> MeetConstants.equalsInteger(a.getRoomTimeId(), s.getTimeId()))
|
.collect(Collectors.toList());
|
if (chriList.size() > 0) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该会议：" + roomTime.getStartTime() + "-" + roomTime.getEndTime() + "时间段内已被使用");
|
}
|
}
|
|
}
|
|
}
|
}
|
|
}
|
|
public void updateBookingTimes(Bookings bookings, LoginUserInfo user) {
|
QueryWrapper<BookingTime> updateWrapper = new QueryWrapper<BookingTime>();
|
updateWrapper.eq("ISDELETED", MeetConstants.ZERO);
|
updateWrapper.eq("BOOKING_ID", bookings.getId());
|
BookingTime bookingTime = new BookingTime();
|
bookingTime.setIsdeleted(MeetConstants.ONE);
|
bookingTimeJoinMapper.update(bookingTime, updateWrapper);
|
|
|
bookings.getBookingTimeList().stream().forEach(s -> {
|
s.setId(null);
|
s.setCreator(user.getId());
|
s.setCreateDate(new Date());
|
s.setIsdeleted(MeetConstants.ZERO);
|
s.setBookingId(bookings.getId());
|
bookingTimeJoinMapper.insert(s);
|
});
|
}
|
|
public void updateManager(Bookings bookings, LoginUserInfo user) {
|
if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(bookings.getSysList())) {
|
QueryWrapper<UserRel> updateWrapper = new QueryWrapper<>();
|
updateWrapper.lambda().eq(UserRel::getIsdeleted, MeetConstants.ZERO);
|
updateWrapper.lambda().eq(UserRel::getObjId, bookings.getId());
|
updateWrapper.lambda().eq(UserRel::getObjType, MeetConstants.ONE);
|
UserRel userRel = new UserRel();
|
userRel.setIsdeleted(MeetConstants.ONE);
|
userRelJoinMapper.update(userRel, updateWrapper);
|
}
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(bookings.getSysList())){
|
bookings.getSysList().stream().forEach(s -> {
|
s.setId(null);
|
s.setIsdeleted(MeetConstants.ZERO);
|
s.setCreateDate(new Date());
|
s.setCreator(user.getId());
|
s.setUserId(s.getUserId());
|
s.setObjId(bookings.getId());
|
s.setObjType(MeetConstants.ONE);
|
userRelJoinMapper.insert(s);
|
});
|
}
|
}
|
|
public void updateProjectRel(Bookings rooms, LoginUserInfo user) {
|
if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(rooms.getProjectList())) {
|
QueryWrapper<ProjectRel> updateWrapper = new QueryWrapper<>();
|
updateWrapper.lambda().eq(ProjectRel::getIsdeleted, MeetConstants.ZERO);
|
updateWrapper.lambda().eq(ProjectRel::getObjId, rooms.getId());
|
updateWrapper.lambda().eq(ProjectRel::getObjType, MeetConstants.ONE);
|
ProjectRel projectRel = new ProjectRel();
|
projectRel.setIsdeleted(MeetConstants.ONE);
|
projectRelJoinMapper.update(projectRel, updateWrapper);
|
|
rooms.getProjectList().stream().forEach(s -> {
|
s.setId(null);
|
s.setIsdeleted(MeetConstants.ZERO);
|
s.setCreateDate(new Date());
|
s.setCreator(user.getId());
|
s.setProjectId(s.getProjectId());
|
s.setObjId(rooms.getId());
|
s.setObjType(MeetConstants.ONE);
|
projectRelJoinMapper.insert(s);
|
});
|
}
|
}
|
|
@Override
|
public void deleteById(Integer id,LoginUserInfo user) {
|
Bookings bookings = new Bookings();
|
bookings.setId(id);
|
bookings.setIsdeleted(MeetConstants.ONE);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(user.getId());
|
bookingsMapper.updateById(bookings);
|
}
|
|
@Override
|
public void delete(Bookings bookings,LoginUserInfo user) {
|
UpdateWrapper<Bookings> deleteWrapper = new UpdateWrapper<>(bookings);
|
bookingsMapper.delete(deleteWrapper);
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids,LoginUserInfo user) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
Bookings bookings = new Bookings();
|
for(int i=0;i<ids.size();i++){
|
Integer s=ids.get(i);
|
|
Bookings bkjs = bookingsMapper.selectById(s);
|
if (Objects.isNull(bkjs)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录");
|
}
|
|
if (System.currentTimeMillis() > bkjs.getStartTime().getTime()&&System.currentTimeMillis() <= bkjs.getEndTime().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已开始,无法删除");
|
}
|
bookings.setId(s);
|
bookings.setIsdeleted(MeetConstants.ONE);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(user.getId());
|
bookingsMapper.updateById(bookings);
|
}
|
// bookingsMapper.deleteBatchIds(ids);
|
}
|
|
@Override
|
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
|
public void updateById(Bookings bookings) {
|
Bookings dbBookings = bookingsMapper.selectById(bookings.getId());
|
if(dbBookings.getStatus().equals(MeetConstants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "本次操作失败,预约状态已流转");
|
}
|
Rooms rooms = roomsMapper.selectById(dbBookings.getRoomId());
|
if(rooms==null ){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该会议室暂时无法预约");
|
}
|
bookings.setRoomName(rooms.getName());
|
LoginUserInfo user = bookings.getLoginUserInfo();
|
isCreateParamValid(bookings, user);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(user.getId());
|
bookingsMapper.updateById(bookings);
|
bookings.setManagerInfo(user.getRealname());
|
bookings.setCreator(dbBookings.getCreator());
|
//更新会议室预定时间段
|
updateBookingTimes(bookings, user);
|
//添加管理人员
|
updateManager(bookings, user);
|
//添加管服务项目
|
updateProjectRel(bookings, user);
|
handleFile(bookings, user);
|
//发送会议通知
|
if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){
|
this.sendNotice(bookings, MeetConstants.TWO);
|
SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator());
|
this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ZERO);
|
}
|
}
|
|
@Override
|
public void updateByIdInBatch(List<Bookings> bookingss) {
|
if (CollectionUtils.isEmpty(bookingss)) {
|
return;
|
}
|
for (Bookings bookings : bookingss) {
|
this.updateById(bookings);
|
}
|
}
|
|
@Override
|
public Bookings findById(Integer id) {
|
return bookingsMapper.selectById(id);
|
}
|
|
|
@Override
|
public void cancelById(Bookings bs) {
|
LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
if(user == null){
|
user = bs.getLoginUserInfo();
|
}
|
/*
|
if(Objects.isNull(bookings)||bookings.getId()==null){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), ResponseStatus.BAD_REQUEST.getMessage());
|
}
|
Bookings query=bookingsJoinMapper.selectById(bookings.getId());
|
if(Objects.isNull(query)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), ResponseStatus.DATA_EMPTY.getMessage());
|
}
|
if(MeetConstants.equalsInteger(query.getStatus(),MeetConstants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "状态已流转，禁止操作");
|
}
|
if (System.currentTimeMillis() > query.getStartTime().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已开始，不允许取消");
|
}
|
bookings.setCancelTime(new Date());
|
bookings.setCancelUser(user.getId());
|
bookings.setStatus(MeetConstants.ONE);
|
|
bookings.setEditDate(new Date());
|
bookings.setEditor(user.getId());
|
bookingsMapper.updateById(bookings);*/
|
|
Bookings bookings = bookingsMapper.selectById(bs.getId());
|
if (Objects.isNull(bookings)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录");
|
}
|
|
if (System.currentTimeMillis() > bookings.getStartTime().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已开始,无法进行取消");
|
}
|
if(bookings.getStatus().equals(MeetConstants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "本次操作失败,预约状态已流转");
|
}
|
bookings.setCancelTime(new Date());
|
bookings.setCancelUser(user.getId());
|
bookings.setStatus(MeetConstants.ONE);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(user.getId());
|
bookingsMapper.updateById(bookings);
|
SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator());
|
|
bookings.setManagerInfo(systemUser.getRealname());
|
//取消会议 发送取消通知
|
if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){
|
this.sendNotice(bookings, 3);
|
this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ONE);
|
}
|
}
|
|
@Override
|
public Bookings findOne(Bookings bookings) {
|
QueryWrapper<Bookings> wrapper = new QueryWrapper<>(bookings);
|
return bookingsMapper.selectOne(wrapper);
|
}
|
|
@Override
|
public List<Bookings> findList(Bookings bookings) {
|
QueryWrapper<Bookings> wrapper = new QueryWrapper<>(bookings);
|
return bookingsMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<Bookings> findPage(PageWrap<Bookings> pageWrap) {
|
IPage<Bookings> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<Bookings> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
|
queryWrapper.selectAll(Bookings.class);
|
queryWrapper.selectAs(Rooms::getName, Bookings::getRoomName);
|
queryWrapper.selectAs(SystemUser::getRealname, Bookings::getRealName);
|
queryWrapper.selectAs(Company::getName, Bookings::getDepartmentName);
|
queryWrapper.select(" CASE WHEN t.START_TIME_REAL IS NULL AND t.`STATUS` = 0 THEN 1 WHEN ( ( t.END_TIME < now() AND t.`STATUS` = 0 ) or t.`STATUS` = 2 ) THEN 3 WHEN t.`STATUS` = 1 THEN 5 ELSE 2 END meetingStatus ");
|
queryWrapper.leftJoin(Rooms.class, Rooms::getId, Bookings::getRoomId);
|
queryWrapper.leftJoin(SystemUser.class, SystemUser::getId, Bookings::getCreator);
|
queryWrapper.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId);
|
queryWrapper.orderByDesc(Bookings::getCreateDate);
|
queryWrapper.eq(Bookings::getIsdeleted, MeetConstants.ZERO);
|
|
//数据权限开始--------------------start----------------
|
LoginUserInfo userInfo =pageWrap.getModel().getLoginUserInfo();
|
if(userInfo!=null && userInfo.getCompanyIdList()!=null){
|
if( userInfo.getCompanyIdList().size() ==0){
|
//只看自己
|
queryWrapper.and(wrapper ->{
|
wrapper.eq(Bookings::getCreator,userInfo.getId())
|
.or().exists("select rel.id from meeting_user_rel rel where rel.OBJ_TYPE=0 and rel.obj_id=t.id and rel.isdeleted=0 and rel.user_id="+userInfo.getId());
|
});
|
queryWrapper.eq(Bookings::getCreator,userInfo.getId());
|
}else{
|
//权限范围内
|
queryWrapper.and(wrapper ->{
|
wrapper.in(SystemUser::getCompanyId ,userInfo.getCompanyIdList())
|
.or().exists("select rel.id from meeting_user_rel rel where rel.OBJ_TYPE=0 and rel.obj_id=t.id and rel.isdeleted=0 and rel.user_id="+userInfo.getId());
|
});
|
}
|
}
|
//数据权限开始--------------------end----------------
|
|
queryWrapper.eq(pageWrap.getModel().getRoomId() != null, Bookings::getRoomId, pageWrap.getModel().getRoomId());
|
queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getName()), Bookings::getName, pageWrap.getModel().getName());
|
queryWrapper.eq(pageWrap.getModel().getStatus() != null, Bookings::getStatus, pageWrap.getModel().getStatus());
|
queryWrapper.like(StringUtils.isNotBlank(pageWrap.getModel().getRealName()), SystemUser::getRealname, pageWrap.getModel().getRealName());
|
queryWrapper.eq(pageWrap.getModel().getDepartmentId() != null, Company::getId, pageWrap.getModel().getDepartmentId());
|
|
queryWrapper.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.ONE),
|
" ( now() < t.START_TIME and t.status = 0 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.TWO),
|
" ( now() >= t.START_TIME and t.END_TIME >= now() and t.status = 0 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.THREE),
|
" ( ( now() > t.END_TIME and t.`STATUS` = 0 ) or t.`STATUS` = 2 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.FOUR),
|
" now() < t.START_TIME AND SUBDATE( t.START_TIME, INTERVAL 120 MINUTE ) < NOW() "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.FIVE),
|
" t.STATUS = 1 "
|
);
|
|
if (pageWrap.getModel().getStartTime() != null) {
|
queryWrapper.ge(Bookings::getStartTime, pageWrap.getModel().getStartTime());
|
}
|
|
if (pageWrap.getModel().getEndTime() != null) {
|
queryWrapper.le(Bookings::getEndTime, pageWrap.getModel().getEndTime());
|
}
|
queryWrapper.orderByDesc(Bookings::getCreateDate);
|
|
String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
|
SimpleDateFormat format = new SimpleDateFormat("MM-dd HH:mm");
|
SimpleDateFormat format1 = new SimpleDateFormat("HH:mm");
|
IPage<Bookings> result = bookingsJoinMapper.selectJoinPage(page, Bookings.class, queryWrapper);
|
result.getRecords().stream().forEach(s -> {
|
|
if(s.getMeetingStatus().equals(Constants.ZERO)){
|
if(s.getMeetingStatus()==Constants.ONE){
|
//开始前120分钟 大于当前时间 则显示即将开始
|
if(DateUtil.afterMinutesDate(s.getStartTime(),-120).getTime()>System.currentTimeMillis()){
|
s.setMeetingStatus(4);
|
}
|
}
|
}
|
MPJLambdaWrapper<Multifile> bookquery = new MPJLambdaWrapper<>();
|
bookquery.eq(Multifile::getIsdeleted, MeetConstants.ZERO);
|
bookquery.eq(Multifile::getObjId, s.getId());
|
List<Multifile> filelist = multifileJoinMapper.selectList(bookquery);
|
filelist.stream().forEach(a -> {
|
if (StringUtils.isNotBlank(a.getFileurl())) {
|
a.setFileurlFull(path + a.getFileurl());
|
}
|
});
|
s.setFileList(filelist);
|
if (s.getStartTime() != null && s.getEndTime() != null) {
|
s.setMeetingTime(format.format(s.getStartTime()) + "-" + format1.format(s.getEndTime()));
|
}
|
s.setManagerInfo(s.getDepartmentName() + "-" + s.getRealName());
|
|
//参会人员列表
|
MPJLambdaWrapper<UserRel> urquery = new MPJLambdaWrapper<>();
|
urquery.selectAll(UserRel.class);
|
urquery.eq(UserRel::getIsdeleted, MeetConstants.ZERO);
|
urquery.eq(UserRel::getObjId, s.getId());
|
urquery.select("(select REALNAME from system_user s where t.USER_ID = s.id and s.DELETED = 0 ) as realName");
|
List<UserRel> userrelList = userRelJoinMapper.selectJoinList(UserRel.class, urquery);
|
s.setSysList(userrelList);
|
|
//服务项
|
MPJLambdaWrapper<ProjectRel> prquery = new MPJLambdaWrapper<>();
|
prquery.selectAll(ProjectRel.class);
|
prquery.eq(ProjectRel::getIsdeleted, MeetConstants.ZERO);
|
prquery.eq(ProjectRel::getObjId, s.getId());
|
prquery.select("(select p.name from meeting_projects p where t.PROJECT_ID = p.id and p.ISDELETED = 0 ) as projectName");
|
List<ProjectRel> prList = projectRelJoinMapper.selectJoinList(ProjectRel.class, prquery);
|
s.setProjectList(prList);
|
|
s.setFlag(MeetConstants.ZERO);
|
if (System.currentTimeMillis() > s.getStartTime().getTime()) {
|
s.setFlag(MeetConstants.ONE);
|
}
|
|
});
|
return PageData.from(result);
|
}
|
|
@Override
|
public Bookings findJoinOne(Bookings queryParam) {
|
MPJLambdaWrapper<Bookings> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(queryParam);
|
queryWrapper.selectAll(Bookings.class);
|
queryWrapper.selectAs(Rooms::getName, Bookings::getRoomName);
|
queryWrapper.selectAs(SystemUser::getRealname, Bookings::getRealName);
|
queryWrapper.selectAs(Company::getName, Bookings::getDepartmentName);
|
queryWrapper.leftJoin(Rooms.class, Rooms::getId, Bookings::getRoomId);
|
queryWrapper.leftJoin(SystemUser.class, SystemUser::getId, Bookings::getCreator);
|
queryWrapper.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId);
|
queryWrapper.eq(Bookings::getIsdeleted, MeetConstants.ZERO);
|
queryWrapper.eq(queryParam.getId() != null, Bookings::getId, queryParam.getId());
|
queryWrapper.eq(queryParam.getRoomId() != null, Bookings::getRoomId, queryParam.getRoomId());
|
if (queryParam.getStartTime() != null) {
|
queryWrapper.ge(Bookings::getStartTime, queryParam.getStartTime());
|
}
|
|
if (queryParam.getEndTime() != null) {
|
queryWrapper.le(Bookings::getEndTime, queryParam.getEndTime());
|
}
|
queryWrapper.orderByDesc(Bookings::getCreateDate);
|
|
// String path = systemDictDataBiz.queryByCode(MeetConstants.OSS, MeetConstants.RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.OSS, MeetConstants.PROJECTS).getCode();
|
String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
Bookings result = bookingsJoinMapper.selectOne(queryWrapper.last("limit 1"));
|
|
if (result != null) {
|
MPJLambdaWrapper<Multifile> bookquery = new MPJLambdaWrapper<>();
|
bookquery.eq(Multifile::getIsdeleted, MeetConstants.ZERO);
|
bookquery.eq(Multifile::getObjId, result.getId());
|
List<Multifile> filelist = multifileJoinMapper.selectList(bookquery);
|
filelist.stream().forEach(a -> {
|
if (StringUtils.isNotBlank(a.getFileurl())) {
|
a.setFileurlFull(path + a.getFileurl());
|
}
|
});
|
result.setFileList(filelist);
|
}
|
return result;
|
}
|
|
@Override
|
public long count(Bookings bookings) {
|
QueryWrapper<Bookings> wrapper = new QueryWrapper<>(bookings);
|
return bookingsMapper.selectCount(wrapper);
|
}
|
|
|
|
/**
|
* 门禁读头扫码开门
|
*
|
* @param json
|
*/
|
@Override
|
public void openRoomDoor(DevWgResponseParam json) throws Exception {
|
|
//解析获取请求参数
|
QrOpenDoorDto param = QrOpenDoorDto.getObjectFromParam(desPwd, json);
|
//查询用户数据
|
SystemUser user = systemUserMapper.selectById(param.getUserId());
|
if (user == null || user.getDeleted()) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码：无效用户");
|
}
|
if (MeetConstants.equalsInteger(param.getType(), MeetConstants.ZERO)) {
|
//会议开门
|
bookOpenDoor(user, param);
|
} else if (MeetConstants.equalsInteger(param.getType(), MeetConstants.ONE)) {
|
//会议室管理员开门
|
roomManagerOpenDoor(user, param);
|
}
|
}
|
|
/**
|
* 管理员开门
|
*
|
* @param user
|
* @param param
|
*/
|
private void roomManagerOpenDoor(SystemUser user, QrOpenDoorDto param) {
|
Long time = param.getTimestamp();
|
Long validTime = 0l;
|
try {
|
validTime = Long.parseLong(systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.QR_OPENROOM_VALIDTIME).getCode());
|
} catch (Exception e) {
|
}
|
if (validTime > 0 && System.currentTimeMillis() - time > validTime * 60*1000) {
|
//如果二维码已过期，无效
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "读头扫码：该二维码已过期！");
|
}
|
Devices devices = new Devices();
|
devices.setIsdeleted(MeetConstants.ZERO);
|
devices.setStatus(MeetConstants.ZERO);
|
devices.setCode(param.getDeviceCode());
|
devices = devicesService.findOne(devices);
|
if(devices == null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码：无效设备");
|
}
|
if(!MeetConstants.equalsInteger(param.getObjId(),devices.getRoomId())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码：无效设备绑定");
|
}
|
|
//查询会议室记录
|
Rooms rooms = roomsMapper.selectById(param.getObjId());
|
if (rooms == null || MeetConstants.equalsInteger(rooms.getIsdeleted(), MeetConstants.ONE)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码：无效会议室");
|
}
|
|
UserRel rel = new UserRel();
|
rel.setIsdeleted(MeetConstants.ZERO);
|
rel.setObjId(rooms.getId());
|
rel.setUserId(user.getId());
|
rel.setObjType(MeetConstants.UserRelObjType.objTypeRoom);
|
//查询是否参会人员
|
rel = userRelJoinMapper.selectOne(new QueryWrapper<>(rel).last("limit 1"));
|
if (rel == null) {
|
//非管理员
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "读头扫码：非法开门");
|
}
|
RoomRecord record = new RoomRecord();
|
record.setCreateDate(new Date());
|
record.setIsdeleted(MeetConstants.ZERO);
|
record.setCreator(user.getId());
|
record.setObjId(rooms.getId());
|
record.setUserId(user.getId());
|
record.setRoomId(rooms.getId());
|
record.setObjType(MeetConstants.RoomRecordObjType.objTypeRoom);
|
//开门记录
|
roomRecordMapper.insert(record);
|
}
|
|
/**
|
* 会议开门
|
*
|
* @param user
|
* @param param
|
*/
|
private void bookOpenDoor(SystemUser user, QrOpenDoorDto param) {
|
//查询会议记录
|
Long time = param.getTimestamp();
|
Long validTime = 0l;
|
try {
|
validTime = Long.parseLong(systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.QR_OPENBOOK_VALIDTIME).getCode());
|
} catch (Exception e) {
|
}
|
if (validTime > 0 && System.currentTimeMillis() - time > validTime * 60*1000) {
|
//如果二维码已过期，无效
|
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "读头扫码:二维码已失效");
|
}
|
Devices devices = new Devices();
|
devices.setIsdeleted(MeetConstants.ZERO);
|
devices.setStatus(MeetConstants.ZERO);
|
devices.setCode(param.getDeviceCode());
|
devices = devicesService.findOne(devices);
|
if(devices == null){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:无效设备");
|
}
|
Bookings book = findById(param.getObjId());
|
if (book == null || MeetConstants.equalsInteger(book.getIsdeleted(), MeetConstants.ONE)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:无效会议");
|
}
|
|
if(!MeetConstants.equalsInteger(book.getRoomId(),devices.getRoomId())){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:无效设备绑定");
|
}
|
|
if (!MeetConstants.equalsInteger(book.getStatus(), MeetConstants.ZERO)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:会议状态错误");
|
}
|
if (book.getStartTime() == null || book.getEndTime() == null) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:会议时间溢出");
|
}
|
//提前进入时间
|
Long advanceInTime = Long.parseLong(systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.ADVANCE_IN).getCode());
|
if ((book.getStartTime().getTime() - advanceInTime * 60L * 1000L) > System.currentTimeMillis()) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:会议未开始");
|
}
|
if (book.getEndTime().getTime() < System.currentTimeMillis()) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "读头扫码:会议已结束");
|
}
|
RoomRecord record = new RoomRecord();
|
record.setCreateDate(new Date());
|
record.setIsdeleted(MeetConstants.ZERO);
|
record.setCreator(user.getId());
|
record.setObjId(book.getId());
|
record.setUserId(user.getId());
|
record.setRoomId(book.getRoomId());
|
UserRel rel = new UserRel();
|
rel.setIsdeleted(MeetConstants.ZERO);
|
rel.setObjId(book.getId());
|
rel.setUserId(user.getId());
|
rel.setObjType(MeetConstants.UserRelObjType.objTypeBook);
|
//查询是否参会人员
|
rel = userRelJoinMapper.selectOne(new QueryWrapper<>(rel).last("limit 1"));
|
if (rel == null) {
|
//访客
|
record.setObjType(MeetConstants.RoomRecordObjType.objTypeBook_out);
|
} else {
|
//参会人员
|
record.setObjType(MeetConstants.RoomRecordObjType.objTypeBook_in);
|
}
|
//开门记录
|
roomRecordMapper.insert(record);
|
}
|
|
|
/****************************************移动端接口开始********************************************************************/
|
|
/**
|
* 获取我的会议记录
|
*
|
* @return
|
*/
|
@Override
|
public List<Bookings> getMyBookings(Integer userId, String dateMsg) {
|
return bookingsMapper.selectList(new QueryWrapper<Bookings>()
|
.apply(" id in ( select u.OBJ_ID from meeting_user_rel u where u.USER_ID = '" + userId + "' and u.ISDELETED = 0 and OBJ_TYPE = 1 ) ")
|
.eq("ISDELETED",MeetConstants.ZERO)
|
// .eq("STATUS",MeetConstants.ZERO)
|
.apply(" ROOM_ID in ( select r.id from meeting_rooms r where r.ISDELETED = 0 and r.STATUS = 0 )")
|
.like(StringUtils.isNotBlank(dateMsg), "START_TIME", dateMsg));
|
}
|
|
|
/**
|
* 我的预约/我的会议
|
*
|
* @param pageWrap
|
* @return
|
*/
|
@Override
|
public IPage<MeetingListResponse> getMyMeetingPage(PageWrap<MeetingPageRequest> pageWrap) {
|
|
QueryWrapper queryWrapper = new QueryWrapper<MeetingListResponse>()
|
.and(StringUtils.isNotBlank(pageWrap.getModel().getRoomsName()),
|
j -> j.like("a.NAME",pageWrap.getModel().getRoomsName()).or()
|
.like(" b.NAME", pageWrap.getModel().getRoomsName()))
|
.exists(pageWrap.getModel().getQueryType().equals(MeetConstants.ONE) && !Objects.isNull(pageWrap.getModel().getUserId()),
|
" select 1 from meeting_user_rel u where a.id = u.OBJ_ID and u.USER_ID = '" + pageWrap.getModel().getUserId() + "' and u.ISDELETED = 0 and OBJ_TYPE = 1 ")
|
.eq(pageWrap.getModel().getQueryType().equals(MeetConstants.TWO) && !Objects.isNull(pageWrap.getModel().getUserId()), "a.CREATOR", pageWrap.getModel().getUserId())
|
.like(StringUtils.isNotBlank(pageWrap.getModel().getQueryDate()), "a.START_TIME", pageWrap.getModel().getQueryDate())
|
.eq(!Objects.isNull(pageWrap.getModel().getRoomsId()), "b.id", pageWrap.getModel().getRoomsId())
|
.apply(!Objects.isNull(pageWrap.getModel().getStatus()) && pageWrap.getModel().getStatus().equals(MeetConstants.ONE), " now() < a.END_TIME and a.STATUS = 0 ")
|
.and(!Objects.isNull(pageWrap.getModel().getStatus()) && pageWrap.getModel().getStatus().equals(MeetConstants.TWO),
|
j -> j.apply("now() >= a.END_TIME ").or()
|
.eq(" a.STATUS", MeetConstants.ONE))
|
.eq("b.ISDELETED",MeetConstants.ZERO)
|
.eq("b.STATUS",MeetConstants.ZERO)
|
.eq("a.ISDELETED",MeetConstants.ZERO)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.ONE),
|
" ( now() < a.START_TIME and a.status = 0 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.TWO),
|
" ( now() >= a.START_TIME and a.END_TIME >= now() and a.status = 0 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.THREE),
|
" ( ( now() > a.END_TIME and a.`STATUS` = 0 ) or a.`STATUS` = 2 ) "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.FOUR),
|
" now() < a.START_TIME AND SUBDATE( a.START_TIME, INTERVAL 120 MINUTE ) < NOW() "
|
)
|
.apply(Objects.nonNull(pageWrap.getModel().getMeetingStatus())
|
&&Constants.equalsInteger(pageWrap.getModel().getMeetingStatus(),Constants.FIVE),
|
" a.STATUS = 1 "
|
)
|
// .orderByDesc(!Objects.isNull(pageWrap.getModel().getStatus())&&pageWrap.getModel().getStatus().equals(MeetConstants.TWO),"a.START_TIME")
|
// .orderByAsc(Objects.isNull(pageWrap.getModel().getStatus())||pageWrap.getModel().getStatus().equals(MeetConstants.ONE),"a.START_TIME")
|
.orderByDesc(Constants.equalsInteger(pageWrap.getModel().getQueryType(),MeetConstants.TWO),"a.CREATE_DATE")
|
.orderByAsc(Constants.equalsInteger(pageWrap.getModel().getQueryType(),MeetConstants.ONE),"a.START_TIME");
|
|
IPage<MeetingListResponse> page = bookingsMapper.myMeetingPage(pageWrap.toPage(), queryWrapper);
|
this.dealMeetingStatus(page.getRecords());
|
return page;
|
}
|
|
|
@Override
|
public MeetingDetailResponse getMeetingDetailByDate(Bookings bean){
|
try {
|
if(Objects.isNull(bean)
|
|| Objects.isNull(bean.getRoomId())
|
|| Objects.isNull(bean.getStartTime())
|
|| Objects.isNull(bean.getEndTime())){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Bookings bookings = bookingsMapper.selectOne(new QueryWrapper<Bookings>().lambda()
|
.eq(Bookings::getRoomId,bean.getRoomId())
|
.ge(Bookings::getEndTime,DateUtil.getPlusTime(bean.getEndTime()))
|
.le(Bookings::getStartTime,DateUtil.getPlusTime(bean.getStartTime()))
|
);
|
if(Objects.isNull(bookings)){
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
return getMeetingDetail(bookings.getId(),null);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
|
|
|
/**
|
* 会议详情
|
*
|
* @param id
|
* @return
|
*/
|
@Override
|
public MeetingDetailResponse getMeetingDetail(Integer id,Integer sysUserId) {
|
MeetingDetailResponse meetingDetailResponse = bookingsMapper.meetingDetail(id);
|
if (Objects.isNull(meetingDetailResponse)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到会议详情");
|
}
|
//预约人
|
meetingDetailResponse.setBookingUser(systemUserService.findById(meetingDetailResponse.getBookingUserId()));
|
//时间段列表
|
meetingDetailResponse.setBookingTimeList(bookingTimeMapper.selectList(new QueryWrapper<BookingTime>()
|
.eq("BOOKING_ID", id)
|
.eq("ISDELETED", MeetConstants.ZERO)
|
));
|
//参会人员列表
|
List<UserResponse> userResponseList = systemUserService.getUserList(id);
|
String avatarPath = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
|
userResponseList.forEach(i -> {
|
if(StringUtils.isNotBlank(i.getAvatar()) && !i.getAvatar().startsWith("HKIMG") ){
|
i.setAvatar(avatarPath+i.getAvatar());
|
}else{
|
i.setAvatar(null);
|
}
|
});
|
meetingDetailResponse.setUserResponseList(userResponseList);
|
//服务项
|
String projectsPath = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode()
|
+ systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
List<ProjectsResponse> projectsResponseList = projectsService.getProjectsList(id, MeetConstants.ONE);
|
projectsResponseList.forEach(i -> {
|
i.setPrefixUrl(projectsPath);
|
});
|
meetingDetailResponse.setProjectsResponseList(projectsResponseList);
|
List<Multifile> multiFileList = multifileMapper.selectList(new QueryWrapper<Multifile>()
|
.eq("OBJ_ID", id)
|
.eq("OBJ_TYPE", MeetConstants.ZERO)
|
);
|
multiFileList.forEach(i -> {
|
i.setFileurlFull(projectsPath);
|
});
|
//附件信息
|
meetingDetailResponse.setMultiFileList(multiFileList);
|
//会议室管理人员
|
List<UserRel> userRelList = userRelMapper.selectList(new QueryWrapper<UserRel>()
|
.eq("ISDELETED",MeetConstants.ZERO)
|
.eq("OBJ_ID", meetingDetailResponse.getRoomId())
|
.eq("OBJ_TYPE",MeetConstants.ZERO)
|
);
|
if(Constants.equalsInteger(sysUserId,meetingDetailResponse.getBookingUserId())){
|
meetingDetailResponse.setIsAdmin(Constants.ONE);
|
}
|
if (!Objects.isNull(userRelList) && userRelList.size() > 0) {
|
meetingDetailResponse.setRoomUser(systemUserService.findById(userRelList.get(MeetConstants.ZERO).getUserId()));
|
if( Objects.nonNull(sysUserId) &&
|
userRelList.stream().filter(i->Constants.equalsInteger(i.getUserId(),sysUserId)).collect(Collectors.toList()).size()>Constants.ZERO
|
){
|
meetingDetailResponse.setIsAdmin(Constants.ONE);
|
}
|
}
|
|
return meetingDetailResponse;
|
}
|
|
/**
|
* 获取开门二维码
|
*
|
* @param id
|
* @param userId
|
* @return
|
*/
|
@Override
|
public String getQrCode(Integer id, Integer userId) {
|
Bookings model = bookingsMapper.selectById(id);
|
if (model == null || !MeetConstants.equalsInteger(model.getIsdeleted(), MeetConstants.ZERO)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到会议详情");
|
}
|
QrOpenDoorDto dto = new QrOpenDoorDto();
|
dto.setType(MeetConstants.ZERO);
|
dto.setUserId(userId);
|
dto.setTimestamp(System.currentTimeMillis());
|
dto.setObjId(id);
|
|
return DESUtil.encrypt(desPwd, QrOpenDoorDto.getParamFromObject(dto));
|
}
|
|
/**
|
* 预约记录新增/修改
|
*
|
* @param bookingsRequest
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class, BusinessException.class})
|
public Integer reservationMeeting(BookingsRequest bookingsRequest) {
|
Bookings bookings = new Bookings();
|
BeanUtils.copyProperties(bookingsRequest, bookings);
|
if (Objects.isNull(bookingsRequest.getId())) {
|
this.create(bookings);
|
return bookings.getId();
|
} else {
|
this.updateById(bookings);
|
return bookings.getId();
|
}
|
}
|
|
|
/**
|
* 会议预约记录取消
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void reservationCancel(BusinessOverDTO businessOverDTO) {
|
Bookings bookings = bookingsMapper.selectById(businessOverDTO.getId());
|
if (Objects.isNull(bookings)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录");
|
}
|
if (!bookings.getCreator().equals(businessOverDTO.getUserId())) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "非你的预约记录,无法进行取消");
|
}
|
if (Objects.nonNull(bookings.getStartTimeReal()) && System.currentTimeMillis() > bookings.getStartTimeReal().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已开始,无法进行取消");
|
}
|
if(bookings.getStatus().equals(MeetConstants.ONE)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "本次操作失败,预约状态已流转");
|
}
|
bookings.setCancelTime(new Date());
|
bookings.setCancelUser(businessOverDTO.getUserId());
|
bookings.setCancelInfo(businessOverDTO.getBusinessRemark());
|
bookings.setStatus(MeetConstants.ONE);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(businessOverDTO.getUserId());
|
Rooms rooms = roomsMapper.selectById(bookings.getRoomId());
|
if(Objects.nonNull(rooms)){
|
bookings.setRoomName(rooms.getName());
|
}
|
bookingsMapper.updateById(bookings);
|
//取消会议 发送取消通知
|
if(Constants.equalsInteger(bookings.getJoinNotice(),Constants.ZERO)){
|
// this.sendNotice(bookings, 3);
|
SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator());
|
bookings.setManagerInfo(systemUser.getRealname());
|
this.sendWxNotice(bookings,Objects.isNull(systemUser)||StringUtils.isBlank(systemUser.getOpenid())?null:systemUser.getOpenid(),Constants.ONE);
|
|
}
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void reservationOver(BusinessOverDTO businessOverDTO) {
|
if(Objects.isNull(businessOverDTO)
|
|| Objects.isNull(businessOverDTO.getUserId())
|
|| Objects.isNull(businessOverDTO.getId())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Bookings bookings = bookingsMapper.selectById(businessOverDTO.getId());
|
if (Objects.isNull(bookings)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录");
|
}
|
Long userRelList = userRelMapper.selectCount(new QueryWrapper<UserRel>().lambda()
|
.eq(UserRel::getIsdeleted,Constants.ZERO)
|
.eq(UserRel::getObjId,bookings.getRoomId())
|
.eq(UserRel::getObjType,Constants.ZERO)
|
.eq(UserRel::getUserId,businessOverDTO.getUserId()));
|
|
if (!bookings.getCreator().equals(businessOverDTO.getUserId()) && userRelList <= 0) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "非你的预约记录,无法进行该操作");
|
}
|
if (System.currentTimeMillis() < bookings.getStartTimeReal().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议未开始,无法进行结束，如需该操作请使用取消功能");
|
}
|
if (System.currentTimeMillis() > bookings.getEndTime().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已结束，无法进行该操作");
|
}
|
if(!bookings.getStatus().equals(MeetConstants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "本次操作失败,会议状态已流转");
|
}
|
bookings.setDoneDate(new Date());
|
bookings.setDoneUserId(businessOverDTO.getUserId());
|
bookings.setStatus(MeetConstants.TWO);
|
bookings.setEditDate(new Date());
|
bookings.setEditor(businessOverDTO.getUserId());
|
bookingsMapper.updateById(bookings);
|
|
//查询所有的预约时间
|
List<BookingTime> bookingTimeList = bookingTimeJoinMapper.selectJoinList(BookingTime.class,
|
new MPJLambdaWrapper<BookingTime>()
|
.selectAll(BookingTime.class)
|
.selectAs(RoomTime::getEndTime,BookingTime::getEndTime)
|
.leftJoin(RoomTime.class,RoomTime::getId,BookingTime::getTimeId)
|
.eq(BookingTime::getBookingId,bookings.getId()));
|
//获取当天 只有当天日期内可以处理
|
String today = DateUtil.dateToString(new Date(),"yyyy-mm-dd");
|
//循环标记数据为已删除 不再占用
|
for (BookingTime bookingTime:bookingTimeList) {
|
if(DateUtil.getDateFromString(today + " " + bookingTime.getEndTime() +":00").getTime()>System.currentTimeMillis()){
|
bookingTime.setIsdeleted(Constants.ZERO);
|
bookingTimeJoinMapper.updateById(bookingTime);
|
}
|
}
|
}
|
|
/**
|
* 正常开始
|
* @param businessOverDTO
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void start(BusinessOverDTO businessOverDTO) {
|
this.startEarly(businessOverDTO);
|
}
|
|
/**
|
* 提前开始
|
* @param businessOverDTO
|
*/
|
@Override
|
@Transactional(rollbackFor = {Exception.class,BusinessException.class})
|
public void startEarly(BusinessOverDTO businessOverDTO) {
|
if(Objects.isNull(businessOverDTO)
|
|| Objects.isNull(businessOverDTO.getUserId())
|
|| Objects.isNull(businessOverDTO.getStartType())
|
|| Objects.isNull(businessOverDTO.getId())
|
){
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
Bookings bookings = bookingsMapper.selectById(businessOverDTO.getId());
|
if (Objects.isNull(bookings)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录");
|
}
|
Long userRelList = userRelMapper.selectCount(new QueryWrapper<UserRel>().lambda()
|
.eq(UserRel::getIsdeleted,Constants.ZERO)
|
.eq(UserRel::getObjId,bookings.getRoomId())
|
.eq(UserRel::getObjType,Constants.ZERO)
|
.eq(UserRel::getUserId,businessOverDTO.getUserId()));
|
|
if (!bookings.getCreator().equals(businessOverDTO.getUserId()) && userRelList <= 0) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "非你的预约记录,无法进行该操作");
|
}
|
if(!Constants.equalsInteger(bookings.getStatus(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议状态已流转，无法进行该操作");
|
}
|
if(Objects.nonNull(bookings.getStartTimeReal())){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已开始，请勿重复操作");
|
}
|
if (System.currentTimeMillis() > bookings.getEndTime().getTime()) {
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "会议已结束，无法进行该操作");
|
}
|
if(Constants.equalsInteger(businessOverDTO.getStartType(),Constants.ZERO)){
|
//根据配置获取提前开始的分钟数量
|
String configMinute = systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.EARLY_START).getCode();
|
Integer beforeMinutes = StringUtils.isNotBlank(configMinute) ? Integer.valueOf(configMinute) : 120;
|
if(DateUtil.afterMinutesDate(bookings.getStartTime(),-beforeMinutes).getTime()>System.currentTimeMillis()){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"会议仅可以提前"+beforeMinutes+"分钟开始");
|
}
|
//查询是否存在其他未开始的会议 防止颗粒度与提前开始的问题
|
if(bookingsMapper.selectCount(new QueryWrapper<Bookings>()
|
.lambda()
|
.apply(" now() < START_TIME and END_TIME <= '" + DateUtil.DateToStr(bookings.getStartTime(),"yyyy-MM-dd HH:mm:ss") +"'" )
|
.isNull(Bookings::getStartTimeReal)
|
.isNull(Bookings::getDoneDate)
|
.eq(Bookings::getStatus,Constants.ZERO)
|
.eq(Bookings::getRoomId,bookings.getRoomId())
|
.ne(Bookings::getId,bookings.getId())
|
)>Constants.ZERO){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"存在未开启会议，无法开始会议");
|
};
|
|
if(bookingsMapper.selectCount(new QueryWrapper<Bookings>()
|
.lambda()
|
.apply(" ( ( END_TIME > now() and START_TIME < now() ) or ( END_TIME > now() and START_TIME_REAL < now() ) ) ")
|
.isNotNull(Bookings::getStartTimeReal)
|
.isNull(Bookings::getDoneDate)
|
.eq(Bookings::getStatus,Constants.ZERO)
|
.eq(Bookings::getRoomId,bookings.getRoomId())
|
)>Constants.ZERO){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"当前开启时间与其他会议存在冲突，无法开始会议");
|
};
|
}else{
|
if(bookings.getStartTime().getTime() > System.currentTimeMillis()){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未到会议申请开始时间，无法开始");
|
}
|
}
|
bookings.setStartTimeReal(new Date());
|
bookings.setEditDate(new Date());
|
bookings.setEditor(businessOverDTO.getUserId());
|
bookingsMapper.updateById(bookings);
|
//更新已结束但未结束的会议信息为已结束
|
bookingsMapper.update(null,new UpdateWrapper<Bookings>()
|
.lambda()
|
.set(Bookings::getStatus,Constants.TWO)
|
.set(Bookings::getDoneDate,new Date())
|
.set(Bookings::getDoneInfo,"其他会议开始，自动关闭")
|
.apply(" ( END_TIME < now() or ( END_TIME > now() and START_TIME < now() and START_TIME_REAL is null ) )")
|
.eq(Bookings::getStatus,Constants.ZERO)
|
.eq(Bookings::getRoomId,bookings.getRoomId())
|
);
|
|
}
|
|
|
@Override
|
public RoomDetailResponse getRoomDetail(Integer roomId){
|
Rooms rooms = roomsMapper.selectById(roomId);
|
if(Objects.isNull(rooms) || !Constants.equalsInteger(rooms.getIsdeleted(),Constants.ZERO)
|
|| !Constants.equalsInteger(rooms.getStatus(),Constants.ZERO)){
|
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"会议室信息无效，请联系管理员");
|
}
|
RoomDetailResponse response = new RoomDetailResponse();
|
response.setRoomName(rooms.getName());
|
response.setFileType(rooms.getFileType());
|
|
List<Multifile> multifileList = multifileJoinMapper.selectList(new QueryWrapper<Multifile>().lambda()
|
.eq(Multifile::getObjId,roomId)
|
.eq(Multifile::getObjType,Constants.FOUR)
|
);
|
|
String prefix = systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.MEET_CODE_PREFIX).getCode() ;
|
response.setPrefix(prefix);
|
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){
|
String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH)
|
.getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
String localPath = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_LOCAL_RESOURCE_PATH)
|
.getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
for (Multifile multifile:multifileList) {
|
multifile.setFileurlFull(path + multifile.getFileurl());
|
multifile.setLocalFileurlFull(localPath + multifile.getFileurl());
|
}
|
response.setMultifileList(multifileList);
|
}
|
|
//查询会议列表
|
List<MeetingListResponse> meetingList = bookingsMapper.meetingList(
|
new QueryWrapper<Bookings>()
|
.eq( "b.id", rooms.getId())
|
.eq("b.ISDELETED",MeetConstants.ZERO)
|
.eq("b.STATUS",MeetConstants.ZERO)
|
.eq("a.ISDELETED",MeetConstants.ZERO)
|
.eq("a.status",Constants.ZERO)
|
.ne("a.status",Constants.TWO)
|
.like("a.start_time",DateUtil.getCurrDate())
|
.apply(" not exists ( select 1 from meeting_book mb where mb.END_TIME < now() and mb.id = a.id and START_TIME_REAL is null ) ")
|
.orderByAsc("a.start_time")
|
);
|
this.dealMeetingStatus(meetingList);
|
response.setMeetingListResponseList(meetingList);
|
return response;
|
}
|
|
|
public void dealMeetingStatus(List<MeetingListResponse> meetingResponseList){
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(meetingResponseList)){
|
String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
|
String configMinute = systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.EARLY_START).getCode();
|
Integer minute = StringUtils.isNotBlank(configMinute) ? Integer.valueOf(configMinute) : 120;
|
for (MeetingListResponse m:meetingResponseList) {
|
if(Constants.equalsInteger(m.getStatus(),Constants.ZERO)&&Constants.equalsInteger(m.getMeetingStatus(),Constants.ONE)){
|
//开始前120分钟 大于当前时间 则显示即将开始
|
if(
|
DateUtil.afterMinutesDate(m.getStartTime(),-minute).getTime()<=System.currentTimeMillis()
|
){
|
m.setMeetingStatus(4);
|
}
|
}
|
m.setPrefixUrl(path);
|
}
|
}
|
}
|
|
|
/**
|
* 定时发送会议 即将开始通知
|
*/
|
@Override
|
public void sendBookingsNotice() {
|
//查询配置
|
String configMinute = systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.NOTICE_TIME).getCode();
|
Integer minute = StringUtils.isNotBlank(configMinute) ? Integer.valueOf(configMinute) : 30;
|
//查询会议开始三十分钟前的会议
|
List<Bookings> bookingsList = bookingsMapper.selectList(new QueryWrapper<Bookings>()
|
.eq("STATUS",MeetConstants.ZERO)
|
.eq("ISDELETED",MeetConstants.ZERO)
|
.eq("SEND_NOTICE", MeetConstants.ZERO)
|
.apply(" now() >= SUBDATE(START_TIME,interval + " + minute + " minute) ")
|
.apply(" ROOM_ID in ( select r.id from meeting_rooms r where r.ISDELETED = 0 and r.STATUS = 0 )")
|
);
|
for (Bookings bookings : bookingsList) {
|
bookings.setSendNotice(MeetConstants.ONE);
|
bookings.setEditDate(new Date());
|
bookingsMapper.updateById(bookings);
|
this.sendNotice(bookings, MeetConstants.ONE);
|
|
//发送微信通知
|
// sendWxMessage.bookingsStart(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId()));
|
}
|
}
|
|
/**
|
* 发送会议通知
|
*
|
* @param bookings
|
* @param sendType 1 = 参与会议 2 = 预定成功 3 = 会议取消
|
*/
|
@Async
|
public void sendNotice(Bookings bookings, Integer sendType) {
|
//1、参与会议：参与会议即将开始 给每个参会人员发送会议通知并且给会议预约人发送预定的会议即将开始 如果预订人也参与会议，则会有2条会议通知
|
//2、会议预定成功，给所有参会人员与预约人都发送
|
//3、会议取消 会议取消，给所有参会人员都发送
|
List<UserRel> userRelList = userRelMapper.selectJoinList(UserRel.class,new MPJLambdaWrapper<UserRel>()
|
.selectAll(UserRel.class)
|
.selectAs(SystemUser::getRealname,UserRel::getRealName)
|
.selectAs(SystemUser::getMobile,UserRel::getUserPhone)
|
.leftJoin(SystemUser.class,SystemUser::getId,UserRel::getUserId)
|
.eq(UserRel::getObjType, MeetConstants.ONE)
|
.eq(UserRel::getObjId, bookings.getId())
|
.eq(UserRel::getIsdeleted, MeetConstants.ZERO)
|
);
|
List<SmsEmail> smsEmailList = new ArrayList<>();
|
List<Notices> noticeList = new ArrayList<>();
|
SmsConfig smsConfig = null;
|
Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.MEETING_START;
|
if (sendType.equals(MeetConstants.THREE)){
|
noticeObjectType = Constants.NoticeObjectType.MEETING_CACEL;
|
smsConfig = smsConfigMapper.selectOne(new QueryWrapper<SmsConfig>().lambda().eq(SmsConfig::getCode,
|
SmsConstants.meetingContent.meetingBookCancel)
|
.eq(SmsConfig::getIsdeleted,Constants.ZERO)
|
.last(" limit 1 "));
|
}else if (sendType.equals(MeetConstants.TWO)){
|
noticeObjectType = Constants.NoticeObjectType.MEETING_BOOK_SUCCESS;
|
smsConfig = smsConfigMapper.selectOne(new QueryWrapper<SmsConfig>().lambda().eq(SmsConfig::getCode,
|
SmsConstants.meetingContent.meetingBookJoinUser)
|
.eq(SmsConfig::getIsdeleted,Constants.ZERO)
|
.last(" limit 1 "));
|
}
|
if(userRelList!=null && userRelList.size()>0){
|
for (UserRel i : userRelList) {
|
Notices notices = new Notices(noticeObjectType,i.getId(),noticeObjectType.getInfo(), i.getUserId(), Constants.ZERO);
|
noticeList.add(notices);
|
if (smsConfig!=null && Constants.equalsInteger(smsConfig.getStatus(),Constants.ZERO)){
|
SmsEmail smsEmail = new SmsEmail();
|
//{参会人员姓名}，您好！您有一个新的会议，会议主题：{会议主题}，会议地点：{会议室名称}，会议时间：{会议时间段}，请按时参加
|
String timeInfo =DateUtil.getFomartDate( bookings.getStartTime(),"MM/dd HH:mm")+"-"
|
+DateUtil.getFomartDate( bookings.getEndTime(),"HH:mm");
|
smsEmail.setPhone(i.getUserPhone());
|
smsEmail.setRemark("等待发送");
|
smsEmail.setStatus(Constants.TWO);//
|
smsEmail.setIsdeleted(Constants.ZERO);
|
smsEmail.setType(Constants.ZERO);
|
smsEmail.setObjId(bookings.getId());
|
smsEmail.setCreateDate(new Date());
|
smsEmail.setTitle("会议室申请参会通知");
|
smsEmail.setContent(StringUtils.defaultString(smsConfig.getContent(),"")
|
.replace("{参会人员姓名}",StringUtils.defaultString(i.getRealName(),""))
|
.replace("{会议主题}",StringUtils.defaultString(bookings.getName(),""))
|
.replace("{会议室名称}",StringUtils.defaultString(bookings.getRoomName(),""))
|
.replace("{会议时间段}",StringUtils.defaultString(timeInfo,"")));
|
smsEmailList.add(smsEmail);
|
}
|
}
|
}
|
//给创建人发送短信信息
|
SystemUser systemUser = systemUserMapper.selectById(bookings.getCreator());
|
if(Objects.nonNull(systemUser)){
|
if(userRelList.stream().filter(i->Constants.equalsInteger(i.getUserId(),systemUser.getId())).collect(Collectors.toList()).size()==Constants.ZERO){
|
if (smsConfig!=null && Constants.equalsInteger(smsConfig.getStatus(),Constants.ZERO)){
|
SmsEmail smsEmail = new SmsEmail();
|
//{参会人员姓名}，您好！您有一个新的会议，会议主题：{会议主题}，会议地点：{会议室名称}，会议时间：{会议时间段}，请按时参加
|
String timeInfo =DateUtil.getFomartDate( bookings.getStartTime(),"MM/dd HH:mm")+"-"
|
+DateUtil.getFomartDate( bookings.getEndTime(),"HH:mm");
|
smsEmail.setPhone(systemUser.getMobile());
|
smsEmail.setRemark("等待发送");
|
smsEmail.setStatus(Constants.TWO);//
|
smsEmail.setIsdeleted(Constants.ZERO);
|
smsEmail.setType(Constants.ZERO);
|
smsEmail.setObjId(bookings.getId());
|
smsEmail.setCreateDate(new Date());
|
smsEmail.setTitle("会议室申请参会通知");
|
smsEmail.setContent(StringUtils.defaultString(smsConfig.getContent(),"")
|
.replace("{参会人员姓名}",StringUtils.defaultString(systemUser.getRealname(),""))
|
.replace("{会议主题}",StringUtils.defaultString(bookings.getName(),""))
|
.replace("{会议室名称}",StringUtils.defaultString(bookings.getRoomName(),""))
|
.replace("{会议时间段}",StringUtils.defaultString(timeInfo,"")));
|
smsEmailList.add(smsEmail);
|
}
|
}
|
}
|
//给参会人员插入
|
Notices notices = new Notices(noticeObjectType,bookings.getId(),noticeObjectType.getInfo(),bookings.getCreator(), Constants.ZERO);
|
noticeList.add(notices);
|
if(noticeList.size()>0){
|
noticesMapper.insert(noticeList);
|
}
|
if(smsEmailList.size()>0){
|
smsEmailMapper.insert(smsEmailList);//待发短信数据
|
}
|
}
|
|
|
@Async
|
public void sendWxNotice(Bookings bookings,String openid, Integer sendType) {
|
try{
|
List<UserRel> userRelList = userRelMapper.selectJoinList(UserRel.class,new MPJLambdaWrapper<UserRel>()
|
.selectAll(UserRel.class)
|
.selectAs(SystemUser::getRealname,UserRel::getRealName)
|
.selectAs(SystemUser::getMobile,UserRel::getUserPhone)
|
.selectAs(SystemUser::getOpenid,UserRel::getOpenid)
|
.leftJoin(SystemUser.class,SystemUser::getId,UserRel::getUserId)
|
.eq(UserRel::getObjType, MeetConstants.ONE)
|
.eq(UserRel::getObjId, bookings.getId())
|
.eq(UserRel::getIsdeleted, MeetConstants.ZERO)
|
.isNotNull(SystemUser::getOpenid)
|
);
|
List<String> openIdList = userRelList.stream().map(i->i.getOpenid()).collect(Collectors.toList());
|
openIdList.add(openid);
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(openIdList)){
|
return;
|
}
|
Set<String> openIds = new HashSet<String>(openIdList);
|
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(openIds)){
|
WxPlatNotice wxPlatNotice = new WxPlatNotice();
|
if(Constants.equalsInteger(sendType,Constants.ZERO)){
|
wxPlatNotice.sendMeetingBookTemplateNotice(systemDictDataBiz,bookings,"CuoDoxOl6SFwi4NhNgOQgKSJVjDD4VCIaPYlnbv_zdY",
|
systemDictDataBiz.queryByCode(Constants.WX_PLATFORM, Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),openIds);
|
}else if(Constants.equalsInteger(sendType,Constants.ONE)){
|
wxPlatNotice.sendMeetingBookCancelTemplateNotice(systemDictDataBiz,bookings,"CiB6vCT2InovAoQfudY-lvzLSV0-3lfz3a5GsSFCzd8",
|
systemDictDataBiz.queryByCode(Constants.WX_PLATFORM, Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),openIds);
|
}
|
}
|
}catch (Exception e){
|
|
}
|
|
|
}
|
|
|
@Override
|
public List<Bookings> getMyJoinBookingMeet(Integer userId, Integer roomId, LocalDateTime startTime, LocalDateTime endTime) {
|
DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
SimpleDateFormat fmt1 =new SimpleDateFormat("HH:mm");
|
MPJLambdaWrapper<Bookings> lambdaWrapper = new MPJLambdaWrapper<>();
|
|
String start = startTime.format(fmt);
|
String end = endTime.format(fmt);
|
|
|
lambdaWrapper.selectAll(Bookings.class)
|
.selectAs(SystemUser::getRealname, Bookings::getRealName)
|
.selectAs(Company::getName, Bookings::getDepartmentName)
|
.selectAs(Rooms::getName, Bookings::getRoomName)
|
.select("CASE DAYOFWEEK(t.START_TIME)\n" +
|
"\tWHEN 1 THEN \t\"星期日\" \tWHEN 2 THEN \"星期一\"\n" +
|
"\t\t\tWHEN 3 THEN \"星期二\" \tWHEN 4 THEN \"星期三\"\n" +
|
"\t\t\tWHEN 5 THEN \t\"星期四\" WHEN 6 THEN \"星期五\"\n" +
|
"\t\t\tWHEN 7 THEN \"星期六\" \tELSE \t\"\"\n" +
|
"END weekday")
|
// .selectAs(RoomTime::getStartTime, Bookings::getStartHour)
|
// .selectAs(RoomTime::getEndTime, Bookings::getEndHour)
|
// .leftJoin(BookingTime.class, BookingTime::getBookingId, Bookings::getId)
|
// .leftJoin(RoomTime.class, RoomTime::getId, BookingTime::getTimeId)
|
.leftJoin(SystemUser.class, SystemUser::getId, Bookings::getCreator)
|
.leftJoin(Rooms.class, Rooms::getId, Bookings::getRoomId)
|
.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId)
|
.eq(Objects.nonNull(roomId), Bookings::getRoomId, roomId)
|
.eq(Bookings::getIsdeleted, MeetConstants.ZERO)
|
.eq(Bookings::getStatus, MeetConstants.ZERO)
|
// .eq(BookingTime::getIsdeleted, MeetConstants.ZERO)
|
// .eq(RoomTime::getIsdeleted, MeetConstants.ZERO)
|
.apply("DATE_FORMAT(t.START_TIME,'%Y-%m-%d') between '" + start + "' and '" + end + "'")
|
// .between(Bookings::getStartTime,start,end )
|
// .orderByAsc(Bookings::getRoomId)
|
// .orderByDesc(Bookings::getCreateDate)
|
.orderByAsc(RoomTime::getStartTime);
|
List<Bookings> bookings = bookingsJoinMapper.selectJoinList(Bookings.class, lambdaWrapper);
|
if(bookings!=null){
|
bookings.stream().forEach(s ->{
|
if(s.getStartTime()!=null&&s.getEndTime()!=null){
|
s.setStartHour(fmt1.format(s.getStartTime()));
|
s.setEndHour(fmt1.format(s.getEndTime()));
|
}
|
});
|
}
|
return bookings;
|
}
|
|
@Override
|
public List<DateTimeResourceDate> findMothBookingMeet(Integer userId, Integer roomId, String dateMonth) {
|
|
LocalDateTime monthFirst = DateUtil.getMonthFirst();
|
LocalDateTime monthLast = DateUtil.getMonthLast();
|
|
if (StringUtils.isNotBlank(dateMonth)) {
|
|
LocalDateTime date = LocalDateTime.of(Integer.valueOf(dateMonth.split("-")[0]), Integer.valueOf(dateMonth.split("-")[1]), 14, 00, 00, 00);
|
// LocalDateTime lastMonth = date.minusMonths(1); // 当前月份减1
|
monthFirst = date.with(TemporalAdjusters.firstDayOfMonth()); // 获取当前月的第一天
|
monthLast = date.with(TemporalAdjusters.lastDayOfMonth()); // 获取当前月的最后一天
|
}
|
|
List<Bookings> myJoinBookingMeet = getMyJoinBookingMeet(userId, roomId, monthFirst, monthLast);
|
Map<LocalDate, List<Bookings>> collect = myJoinBookingMeet.stream()
|
.collect(Collectors.groupingBy(s -> DateUtil.toDateLocalDateTime(s.getStartTime()).toLocalDate()));
|
|
Integer dayOfMonth = monthLast.getDayOfMonth();
|
Integer year = monthLast.getYear();
|
Integer monthValue = monthLast.getMonthValue();
|
List<DateTimeResourceDate> list = new ArrayList<>();
|
List<Bookings> bookings1 = new ArrayList<>();
|
for (int i = 1; i <= dayOfMonth; i++) {
|
DateTimeResourceDate timeResource = new DateTimeResourceDate();
|
timeResource.setLocalDate(LocalDate.of(year, monthValue, i));
|
List<Bookings> bookings = collect.get(timeResource.getLocalDate());
|
if (bookings != null) {
|
timeResource.setResource(bookings);
|
} else {
|
timeResource.setResource(bookings1);
|
}
|
list.add(timeResource);
|
}
|
return list;
|
}
|
|
@Override
|
public List<RoomStatisticsVo> getRoomStatistics(Integer yearNum) {
|
return bookingsMapper.getRoomStatistics(yearNum);
|
}
|
|
@Override
|
public PageData<UserStatisticsVo> getUserStatistics(PageWrap<UserStatisticsDTO> pageWrap) {
|
IPage<UserStatisticsVo> userStatistics = bookingsMapper.getUserStatistics(pageWrap.toPage(), pageWrap.getModel().getYearNum(), pageWrap.getModel().getUserId());
|
return PageData.from(userStatistics);
|
}
|
|
/**
|
* 查询参会人员分页
|
* @param pageWrap
|
* @return
|
*/
|
@Override
|
public IPage<UserResponse> getUserPage(PageWrap<UserPageRequest> pageWrap) {
|
IPage<UserResponse> page = systemUserMapper.getUserPage(pageWrap.toPage(),new QueryWrapper<UserResponse>()
|
.and(StringUtils.isNotBlank(pageWrap.getModel().getKeyword()), i -> i.like("c.realName", pageWrap.getModel().getKeyword())
|
.or().like("d.COMPANY_NAME_PATH", pageWrap.getModel().getKeyword())
|
)
|
.eq("c.DELETED",0)
|
.eq("c.status",0)
|
.eq("m.WORK_STATUS",0)
|
.orderByAsc("c.id")
|
);
|
String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()
|
+systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
|
//查询是否处于会议中
|
page.getRecords().forEach(j->{
|
j.setPrefixUrl(path);
|
if(bookingsMapper.selectCount(new QueryWrapper<Bookings>()
|
.exists(" select 1 from meeting_user_rel u where u.OBJ_ID = meeting_book.id and u.USER_ID = '"+j.getId()+"' and u.OBJ_TYPE = 1 ")
|
.and(i -> i.between("START_TIME", pageWrap.getModel().getStartTime()+":00",pageWrap.getModel().getEndTime()+":00")
|
.or().between("END_TIME", pageWrap.getModel().getStartTime()+":00",pageWrap.getModel().getEndTime()+":00")
|
)
|
)>Constants.ZERO){
|
j.setStatus(Constants.ONE);
|
}else{
|
j.setStatus(Constants.ZERO);
|
}
|
});
|
return page;
|
}
|
|
|
|
}
|
