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.Constants; import com.doumee.core.utils.DESUtil; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.core.wx.MeetConstants; import com.doumee.core.wx.SendWxMessage; import com.doumee.dao.admin.request.QrOpenDoorDto; import com.doumee.dao.admin.response.DevWgResponseParam; import com.doumee.dao.business.*; 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.UserStatisticsVo; import com.doumee.dao.web.request.BookingsRequest; import com.doumee.dao.web.request.MeetingPageRequest; 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.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.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 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 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(); user.setId(bookings.getCreator()); isCreateParamValid(bookings, user); bookings.setCreateDate(new Date()); bookings.setCreator(user.getId()); bookings.setIsdeleted(MeetConstants.ZERO); bookings.setStatus(MeetConstants.ZERO); bookingsMapper.insert(bookings); //更新会议室预定时间段 updateBookingTimes(bookings, user); //添加管理人员 updateManager(bookings, user); //添加管服务项目 updateProjectRel(bookings, user); handleFile(bookings, user); //发送会议预约成功通知 this.sendNotice(bookings, MeetConstants.TWO); //发送微信订阅通知 sendWxMessage.bookingsReservation(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId())); return bookings.getId(); } public void handleFile(Bookings bookings, LoginUserInfo user) { QueryWrapper 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()); } SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat format1 = new SimpleDateFormat("yyyy-MM-dd"); String gsDate = format1.format(bookings.getStartTime()); //查询当前会议预定时间段是否可用 MPJLambdaWrapper 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(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 bookList = bookingsJoinMapper.selectJoinList(Bookings.class, bookquery); for (int i = 0; i < bookings.getBookingTimeList().size(); i++) { BookingTime s = bookings.getBookingTimeList().get(i); if (!Objects.isNull(bookList) && bookList.size() > MeetConstants.ZERO) { List detailDataDtoStream = bookList.stream().filter(a -> MeetConstants.equalsInteger(s.getTimeId(), a.getRoomTimeId()) ).collect(Collectors.toList()); if (detailDataDtoStream.size() > 0) { if (bookings.getId() != null) { //编辑 List 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) { RoomTime roomTime = roomTimeJoinMapper.selectById(s.getTimeId()); throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该会议：" + roomTime.getStartTime() + "-" + roomTime.getEndTime() + "时间段内已被使用"); } } else { //插入 List chriList = detailDataDtoStream.stream() .filter(a -> MeetConstants.equalsInteger(a.getRoomTimeId(), s.getTimeId())) .collect(Collectors.toList()); if (chriList.size() > 0) { RoomTime roomTime = roomTimeJoinMapper.selectById(s.getTimeId()); throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "该会议：" + roomTime.getStartTime() + "-" + roomTime.getEndTime() + "时间段内已被使用"); } } } } } } public void updateBookingTimes(Bookings bookings, LoginUserInfo user) { QueryWrapper updateWrapper = new QueryWrapper(); 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.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 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); } bookings.getSysList().stream().forEach(s -> { 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 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.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 deleteWrapper = new UpdateWrapper<>(bookings); bookingsMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids,LoginUserInfo user) { if (CollectionUtils.isEmpty(ids)) { return; } Bookings bookings = new Bookings(); for(int i=0;i 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(), "本次操作失败,预约状态已流转"); } LoginUserInfo user = bookings.getLoginUserInfo(); isCreateParamValid(bookings, user); bookings.setEditDate(new Date()); bookings.setEditor(user.getId()); bookingsMapper.updateById(bookings); //更新会议室预定时间段 updateBookingTimes(bookings, user); //添加管理人员 updateManager(bookings, user); //添加管服务项目 updateProjectRel(bookings, user); handleFile(bookings, user); //发送会议通知 this.sendNotice(bookings, MeetConstants.TWO); } @Override public void updateByIdInBatch(List 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); //取消会议 发送取消通知 this.sendNotice(bookings, 3); //发送微信订阅通知 sendWxMessage.bookingsCancel(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId())); } @Override public Bookings findOne(Bookings bookings) { QueryWrapper wrapper = new QueryWrapper<>(bookings); return bookingsMapper.selectOne(wrapper); } @Override public List findList(Bookings bookings) { QueryWrapper wrapper = new QueryWrapper<>(bookings); return bookingsMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper 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.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); 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, SystemUser::getId, pageWrap.getModel().getDepartmentId()); 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 result = bookingsJoinMapper.selectJoinPage(page, Bookings.class, queryWrapper); result.getRecords().stream().forEach(s -> { MPJLambdaWrapper bookquery = new MPJLambdaWrapper<>(); bookquery.eq(Multifile::getIsdeleted, MeetConstants.ZERO); bookquery.eq(Multifile::getObjId, s.getId()); List filelist = multifileJoinMapper.selectList(bookquery); filelist.stream().forEach(a -> { if (StringUtils.isNotBlank(a.getFileurl())) { a.setFileFullUrl(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 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 userrelList = userRelJoinMapper.selectJoinList(UserRel.class, urquery); s.setSysList(userrelList); //服务项 MPJLambdaWrapper 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 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 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 bookquery = new MPJLambdaWrapper<>(); bookquery.eq(Multifile::getIsdeleted, MeetConstants.ZERO); bookquery.eq(Multifile::getObjId, result.getId()); List filelist = multifileJoinMapper.selectList(bookquery); filelist.stream().forEach(a -> { if (StringUtils.isNotBlank(a.getFileurl())) { a.setFileFullUrl(path + a.getFileurl()); } }); result.setFileList(filelist); } return result; } @Override public long count(Bookings bookings) { QueryWrapper 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 getMyBookings(Integer userId, String dateMsg) { return bookingsMapper.selectList(new QueryWrapper() .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 rooms r where r.ISDELETED = 0 and r.STATUS = 0 )") .like(StringUtils.isNotBlank(dateMsg), "START_TIME", dateMsg)); } /** * 我的预约/我的会议 * * @param pageWrap * @return */ @Override public IPage getMyMeetingPage(PageWrap pageWrap) { IPage page = bookingsMapper.myMeetingPage(pageWrap.toPage(), new QueryWrapper() .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) .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") ); String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode(); page.getRecords().forEach(i -> { i.setPrefixUrl(path); if(i.getMeetingStatus().equals(Constants.ZERO)){ if(i.getStatus()==Constants.ONE){ i.setMeetingStatus(5); }else{ //开始前5分钟 大于当前时间 则显示即将开始 if(DateUtil.afterMinutesDate(i.getStartTime(),-5).getTime()>System.currentTimeMillis()){ i.setMeetingStatus(4); } } } }); return page; } /** * 会议详情 * * @param id * @return */ @Override public MeetingDetailResponse getMeetingDetail(Integer id) { 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() .eq("BOOKING_ID", id) .eq("ISDELETED", MeetConstants.ZERO) )); //参会人员列表 SystemUser param = new SystemUser(); List userResponseList = systemUserService.findList(param); String avatarPath = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.MEMBER_IMG).getCode(); userResponseList.forEach(i -> { if(StringUtils.isNotBlank(i.getAvatar())){ i.setAvatar(avatarPath+i.getAvatar()); } }); meetingDetailResponse.setUserResponseList(userResponseList); //服务项 String projectsPath = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode(); List projectsResponseList = projectsService.getProjectsList(id, MeetConstants.ONE); projectsResponseList.forEach(i -> { i.setPrefixUrl(projectsPath); }); meetingDetailResponse.setProjectsResponseList(projectsResponseList); List multiFileList = multifileMapper.selectList(new QueryWrapper() .eq("OBJ_ID", id) .eq("OBJ_TYPE", MeetConstants.ZERO) ); multiFileList.forEach(i -> { i.setFileFullUrl(projectsPath); }); //附件信息 meetingDetailResponse.setMultiFileList(multiFileList); //会议室管理人员 List userRelList = userRelMapper.selectList(new QueryWrapper() .eq("ISDELETED",MeetConstants.ZERO) .eq("OBJ_ID", meetingDetailResponse.getRoomId()) .eq("OBJ_TYPE",MeetConstants.ZERO) ); if (!Objects.isNull(userRelList) && userRelList.size() > 0) { meetingDetailResponse.setRoomUser(systemUserService.findById(userRelList.get(MeetConstants.ZERO).getUserId())); } 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(); } } /** * 会议预约记录取消 * * @param id * @param userId */ @Override public void reservationCancel(Integer id, Integer userId) { Bookings bookings = bookingsMapper.selectById(id); if (Objects.isNull(bookings)) { throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "未查询到预约记录"); } if (!bookings.getCreator().equals(userId)) { throw new BusinessException(ResponseStatus.NOT_ALLOWED.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(userId); bookings.setStatus(MeetConstants.ONE); bookings.setEditDate(new Date()); bookings.setEditor(userId); bookingsMapper.updateById(bookings); //取消会议 发送取消通知 this.sendNotice(bookings, 3); //发送微信订阅通知 sendWxMessage.bookingsCancel(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId())); } /** * 定时发送会议 即将开始通知 */ @Override public void sendBookingsNotice() { //查询配置 String configMinute = systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.NOTICE_TIME).getCode(); Integer minute = StringUtils.isNotBlank(configMinute) ? Integer.valueOf(configMinute) : 30; //查询会议开始三十分钟前的会议 List bookingsList = bookingsMapper.selectList(new QueryWrapper() .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 userRelList = userRelMapper.selectList(new QueryWrapper() .eq("OBJ_TYPE", MeetConstants.ONE) .eq("OBJ_ID", bookings.getId()) .eq("ISDELETED", MeetConstants.ZERO) ); List noticeList = new ArrayList<>(); Constants.NoticeObjectType noticeObjectType = Constants.NoticeObjectType.MEETING_START; if (sendType.equals(MeetConstants.THREE)){ noticeObjectType = Constants.NoticeObjectType.MEETING_CACEL; }else if (sendType.equals(MeetConstants.TWO)){ noticeObjectType = Constants.NoticeObjectType.MEETING_BOOK_SUCCESS; } 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); } } //给参会人员插入 Notices notices = new Notices(noticeObjectType,bookings.getId(),noticeObjectType.getInfo(),bookings.getCreator(), Constants.ZERO); noticeList.add(notices); if(noticeList.size()>0){ noticesMapper.insertBatchSomeColumn(noticeList); } } @Override public List getMyJoinBookingMeet(Integer userId, Integer roomId, LocalDateTime startTime, LocalDateTime endTime) { DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM-dd"); SimpleDateFormat fmt1 =new SimpleDateFormat("HH:mm"); MPJLambdaWrapper 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 = 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 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 myJoinBookingMeet = getMyJoinBookingMeet(userId, roomId, monthFirst, monthLast); Map> 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 list = new ArrayList<>(); List bookings1 = new ArrayList<>(); for (int i = 1; i <= dayOfMonth; i++) { DateTimeResourceDate timeResource = new DateTimeResourceDate(); timeResource.setLocalDate(LocalDate.of(year, monthValue, i)); List bookings = collect.get(timeResource.getLocalDate()); if (bookings != null) { timeResource.setResource(bookings); } else { timeResource.setResource(bookings1); } list.add(timeResource); } return list; } @Override public List getRoomStatistics(Integer yearNum) { return bookingsMapper.getRoomStatistics(yearNum); } @Override public PageData getUserStatistics(PageWrap pageWrap) { IPage userStatistics = bookingsMapper.getUserStatistics(pageWrap.toPage(), pageWrap.getModel().getYearNum(), pageWrap.getModel().getUserId()); return PageData.from(userStatistics); } }