From e992f6c13602feadd60f9df16c65ffccc1cdcb6a Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期五, 05 七月 2024 18:22:35 +0800
Subject: [PATCH] 代码初始化
---
server/meeting/meeting_service/src/main/java/com/doumee/service/business/impl/BookingsServiceImpl.java | 582 ++++++++++++++++++++++++++++++++++++++-------------------
1 files changed, 385 insertions(+), 197 deletions(-)
diff --git a/server/meeting/meeting_service/src/main/java/com/doumee/service/business/impl/BookingsServiceImpl.java b/server/meeting/meeting_service/src/main/java/com/doumee/service/business/impl/BookingsServiceImpl.java
index 5aa39f1..7a3ccc1 100644
--- a/server/meeting/meeting_service/src/main/java/com/doumee/service/business/impl/BookingsServiceImpl.java
+++ b/server/meeting/meeting_service/src/main/java/com/doumee/service/business/impl/BookingsServiceImpl.java
@@ -1,6 +1,5 @@
package com.doumee.service.business.impl;
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -15,23 +14,29 @@
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.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.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.model.SystemDepartment;
-import com.doumee.dao.system.model.SystemDepartmentUser;
-import com.doumee.dao.system.model.SystemUser;
-import com.doumee.dao.system.vo.RoomStatisticsVo;
+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.*;
+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;
@@ -46,18 +51,10 @@
import java.awt.print.Book;
import java.text.SimpleDateFormat;
-import java.time.LocalTime;
-import java.time.format.DateTimeFormatter;
-import java.time.temporal.TemporalAdjusters;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
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;
@@ -78,6 +75,7 @@
private SystemUserMapper systemUserMapper;
@Autowired
private RoomRecordMapper roomRecordMapper;
+
@Autowired
private BookingsJoinMapper bookingsJoinMapper;
@@ -110,7 +108,7 @@
private MultifileMapper multifileMapper;
@Autowired
- private NoticeService noticeService;
+ private NoticesJoinMapper noticesMapper;
@Autowired
private UserRelMapper userRelMapper;
@@ -127,13 +125,12 @@
@Override
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
public Integer create(Bookings bookings) {
- LoginUserInfo user = new LoginUserInfo();
- user.setId(bookings.getCreator());
+ LoginUserInfo user = bookings.getLoginUserInfo();
isCreateParamValid(bookings, user);
bookings.setCreateDate(new Date());
bookings.setCreator(user.getId());
- bookings.setIsdeleted(Constants.ZERO);
- bookings.setStatus(Constants.ZERO);
+ bookings.setIsdeleted(MeetConstants.ZERO);
+ bookings.setStatus(MeetConstants.ZERO);
bookingsMapper.insert(bookings);
//鏇存柊浼氳瀹ら瀹氭椂闂存
updateBookingTimes(bookings, user);
@@ -143,7 +140,7 @@
updateProjectRel(bookings, user);
handleFile(bookings, user);
//鍙戦�佷細璁绾︽垚鍔熼�氱煡
- this.sendNotice(bookings, Constants.TWO);
+ this.sendNotice(bookings, MeetConstants.TWO);
//鍙戦�佸井淇¤闃呴�氱煡
sendWxMessage.bookingsReservation(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId()));
@@ -152,17 +149,17 @@
public void handleFile(Bookings bookings, LoginUserInfo user) {
QueryWrapper<Multifile> bookquery = new QueryWrapper<>();
- bookquery.lambda().eq(Multifile::getIsdeleted, Constants.ZERO);
+ 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(Constants.ZERO);
+ s.setIsdeleted(MeetConstants.ZERO);
s.setCreateDate(new Date());
s.setCreator(user.getId());
s.setObjId(bookings.getId());
- s.setType(Constants.TWO);
- s.setObjType(Constants.ZERO);
+ s.setType(MeetConstants.TWO);
+ s.setObjType(MeetConstants.ZERO);
multifileJoinMapper.insert(s);
});
}
@@ -191,9 +188,10 @@
bookquery.selectAll(Bookings.class);
bookquery.selectAs(BookingTime::getTimeId, Bookings::getRoomTimeId);
bookquery.selectAs(BookingTime::getId, Bookings::getBookingTimeId);
- bookquery.eq(Bookings::getIsdeleted, Constants.ZERO);
+ bookquery.eq(Bookings::getIsdeleted, MeetConstants.ZERO);
+ bookquery.eq(BookingTime::getIsdeleted, MeetConstants.ZERO);
bookquery.eq(Bookings::getRoomId, bookings.getRoomId());
- bookquery.eq(Bookings::getStatus, Constants.ZERO);
+ 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") + "%' ");
@@ -203,10 +201,17 @@
List<Bookings> 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() > Constants.ZERO) {
-
+ 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 -> Constants.equalsInteger(s.getTimeId(), a.getRoomTimeId())
+ bookList.stream().filter(a -> MeetConstants.equalsInteger(s.getTimeId(), a.getRoomTimeId())
).collect(Collectors.toList());
if (detailDataDtoStream.size() > 0) {
@@ -214,21 +219,19 @@
//缂栬緫
List<Bookings> chriList =
detailDataDtoStream.stream()
- .filter(a -> !Constants.equalsInteger(a.getId(), bookings.getId()))
- .filter(a -> Constants.equalsInteger(a.getRoomTimeId(), s.getTimeId()))
+ .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<Bookings> chriList =
detailDataDtoStream.stream()
- .filter(a -> Constants.equalsInteger(a.getRoomTimeId(), s.getTimeId()))
+ .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() + "鏃堕棿娈靛唴宸茶浣跨敤");
}
}
@@ -242,89 +245,88 @@
public void updateBookingTimes(Bookings bookings, LoginUserInfo user) {
QueryWrapper<BookingTime> updateWrapper = new QueryWrapper<BookingTime>();
- updateWrapper.eq("ISDELETED", Constants.ZERO);
+ updateWrapper.eq("ISDELETED", MeetConstants.ZERO);
updateWrapper.eq("BOOKING_ID", bookings.getId());
BookingTime bookingTime = new BookingTime();
- bookingTime.setIsdeleted(Constants.ONE);
+ 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(Constants.ZERO);
+ 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, Constants.ZERO);
+ updateWrapper.lambda().eq(UserRel::getIsdeleted, MeetConstants.ZERO);
updateWrapper.lambda().eq(UserRel::getObjId, bookings.getId());
- updateWrapper.lambda().eq(UserRel::getObjType, Constants.ONE);
+ updateWrapper.lambda().eq(UserRel::getObjType, MeetConstants.ONE);
UserRel userRel = new UserRel();
- userRel.setIsdeleted(Constants.ONE);
+ userRel.setIsdeleted(MeetConstants.ONE);
userRelJoinMapper.update(userRel, updateWrapper);
}
- bookings.getSysList().stream().forEach(s -> {
- s.setIsdeleted(Constants.ZERO);
- s.setCreateDate(new Date());
- s.setCreator(user.getId());
- s.setUserId(s.getUserId());
- s.setObjId(bookings.getId());
- s.setObjType(Constants.ONE);
- userRelJoinMapper.insert(s);
- });
-
+ 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, Constants.ZERO);
+ updateWrapper.lambda().eq(ProjectRel::getIsdeleted, MeetConstants.ZERO);
updateWrapper.lambda().eq(ProjectRel::getObjId, rooms.getId());
- updateWrapper.lambda().eq(ProjectRel::getObjType, Constants.ONE);
+ updateWrapper.lambda().eq(ProjectRel::getObjType, MeetConstants.ONE);
ProjectRel projectRel = new ProjectRel();
- projectRel.setIsdeleted(Constants.ONE);
+ projectRel.setIsdeleted(MeetConstants.ONE);
projectRelJoinMapper.update(projectRel, updateWrapper);
rooms.getProjectList().stream().forEach(s -> {
-
- s.setIsdeleted(Constants.ZERO);
+ 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(Constants.ONE);
+ s.setObjType(MeetConstants.ONE);
projectRelJoinMapper.insert(s);
});
}
}
@Override
- public void deleteById(Integer id) {
- LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+ public void deleteById(Integer id,LoginUserInfo user) {
Bookings bookings = new Bookings();
bookings.setId(id);
- bookings.setIsdeleted(Constants.ONE);
+ bookings.setIsdeleted(MeetConstants.ONE);
bookings.setEditDate(new Date());
bookings.setEditor(user.getId());
bookingsMapper.updateById(bookings);
}
@Override
- public void delete(Bookings bookings) {
+ 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 = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
+ public void deleteByIdInBatch(List<Integer> ids,LoginUserInfo user) {
if (CollectionUtils.isEmpty(ids)) {
return;
}
@@ -341,7 +343,7 @@
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "浼氳宸插紑濮�,鏃犳硶鍒犻櫎");
}
bookings.setId(s);
- bookings.setIsdeleted(Constants.ONE);
+ bookings.setIsdeleted(MeetConstants.ONE);
bookings.setEditDate(new Date());
bookings.setEditor(user.getId());
bookingsMapper.updateById(bookings);
@@ -353,11 +355,10 @@
@Transactional(rollbackFor = {BusinessException.class, Exception.class})
public void updateById(Bookings bookings) {
Bookings dbBookings = bookingsMapper.selectById(bookings.getId());
- if(dbBookings.getStatus().equals(Constants.ONE)){
+ if(dbBookings.getStatus().equals(MeetConstants.ONE)){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鏈鎿嶄綔澶辫触,棰勭害鐘舵�佸凡娴佽浆");
}
- LoginUserInfo user = new LoginUserInfo();
- user.setId(bookings.getCreator());
+ LoginUserInfo user = bookings.getLoginUserInfo();
isCreateParamValid(bookings, user);
bookings.setEditDate(new Date());
bookings.setEditor(user.getId());
@@ -370,7 +371,7 @@
updateProjectRel(bookings, user);
handleFile(bookings, user);
//鍙戦�佷細璁�氱煡
- this.sendNotice(bookings, Constants.TWO);
+ this.sendNotice(bookings, MeetConstants.TWO);
}
@Override
@@ -392,6 +393,9 @@
@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());
@@ -400,7 +404,7 @@
if(Objects.isNull(query)){
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), ResponseStatus.DATA_EMPTY.getMessage());
}
- if(Constants.equalsInteger(query.getStatus(),Constants.ONE)){
+ if(MeetConstants.equalsInteger(query.getStatus(),MeetConstants.ONE)){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鐘舵�佸凡娴佽浆锛岀姝㈡搷浣�");
}
if (System.currentTimeMillis() > query.getStartTime().getTime()) {
@@ -408,7 +412,7 @@
}
bookings.setCancelTime(new Date());
bookings.setCancelUser(user.getId());
- bookings.setStatus(Constants.ONE);
+ bookings.setStatus(MeetConstants.ONE);
bookings.setEditDate(new Date());
bookings.setEditor(user.getId());
@@ -422,12 +426,12 @@
if (System.currentTimeMillis() > bookings.getStartTime().getTime()) {
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "浼氳宸插紑濮�,鏃犳硶杩涜鍙栨秷");
}
- if(bookings.getStatus().equals(Constants.ONE)){
+ if(bookings.getStatus().equals(MeetConstants.ONE)){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鏈鎿嶄綔澶辫触,棰勭害鐘舵�佸凡娴佽浆");
}
bookings.setCancelTime(new Date());
bookings.setCancelUser(user.getId());
- bookings.setStatus(Constants.ONE);
+ bookings.setStatus(MeetConstants.ONE);
bookings.setEditDate(new Date());
bookings.setEditor(user.getId());
bookingsMapper.updateById(bookings);
@@ -459,22 +463,41 @@
queryWrapper.selectAll(Bookings.class);
queryWrapper.selectAs(Rooms::getName, Bookings::getRoomName);
queryWrapper.selectAs(SystemUser::getRealname, Bookings::getRealName);
- queryWrapper.selectAs(SystemDepartment::getName, Bookings::getDepartmentName);
-
+ queryWrapper.selectAs(Company::getName, Bookings::getDepartmentName);
+ queryWrapper.select(" CASE WHEN t.START_TIME > now() 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(SystemDepartmentUser.class, SystemDepartmentUser::getUserId, Bookings::getCreator);
- queryWrapper.leftJoin(SystemDepartment.class, SystemDepartment::getId, SystemDepartmentUser::getDepartmentId);
-
+ queryWrapper.leftJoin(Company.class,Company::getId,SystemUser::getCompanyId);
queryWrapper.orderByDesc(Bookings::getCreateDate);
- queryWrapper.eq(Bookings::getIsdeleted, Constants.ZERO);
+ 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, SystemDepartment::getId, pageWrap.getModel().getDepartmentId());
+ 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());
@@ -485,19 +508,28 @@
}
queryWrapper.orderByDesc(Bookings::getCreateDate);
- String path = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
+ 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, Constants.ZERO);
+ 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.setFileFullUrl(path + a.getFileurl());
+ a.setFileurlFull(path + a.getFileurl());
}
});
s.setFileList(filelist);
@@ -509,7 +541,7 @@
//鍙備細浜哄憳鍒楄〃
MPJLambdaWrapper<UserRel> urquery = new MPJLambdaWrapper<>();
urquery.selectAll(UserRel.class);
- urquery.eq(UserRel::getIsdeleted, Constants.ZERO);
+ 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);
@@ -518,15 +550,15 @@
//鏈嶅姟椤�
MPJLambdaWrapper<ProjectRel> prquery = new MPJLambdaWrapper<>();
prquery.selectAll(ProjectRel.class);
- prquery.eq(ProjectRel::getIsdeleted, Constants.ZERO);
+ prquery.eq(ProjectRel::getIsdeleted, MeetConstants.ZERO);
prquery.eq(ProjectRel::getObjId, s.getId());
- prquery.select("(select p.name from projects p where t.PROJECT_ID = p.id and p.ISDELETED = 0 ) as projectName");
+ 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(Constants.ZERO);
+ s.setFlag(MeetConstants.ZERO);
if (System.currentTimeMillis() > s.getStartTime().getTime()) {
- s.setFlag(Constants.ONE);
+ s.setFlag(MeetConstants.ONE);
}
});
@@ -540,12 +572,11 @@
queryWrapper.selectAll(Bookings.class);
queryWrapper.selectAs(Rooms::getName, Bookings::getRoomName);
queryWrapper.selectAs(SystemUser::getRealname, Bookings::getRealName);
- queryWrapper.selectAs(SystemDepartment::getName, Bookings::getDepartmentName);
+ queryWrapper.selectAs(Company::getName, Bookings::getDepartmentName);
queryWrapper.leftJoin(Rooms.class, Rooms::getId, Bookings::getRoomId);
queryWrapper.leftJoin(SystemUser.class, SystemUser::getId, Bookings::getCreator);
- queryWrapper.leftJoin(SystemDepartmentUser.class, SystemDepartmentUser::getUserId, Bookings::getCreator);
- queryWrapper.leftJoin(SystemDepartment.class, SystemDepartment::getId, SystemDepartmentUser::getDepartmentId);
- queryWrapper.eq(Bookings::getIsdeleted, Constants.ZERO);
+ 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) {
@@ -557,18 +588,18 @@
}
queryWrapper.orderByDesc(Bookings::getCreateDate);
-// String path = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
- String path = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
+// 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, Constants.ZERO);
+ 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.setFileFullUrl(path + a.getFileurl());
+ a.setFileurlFull(path + a.getFileurl());
}
});
result.setFileList(filelist);
@@ -599,10 +630,10 @@
if (user == null || user.getDeleted()) {
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "璇诲ご鎵爜锛氭棤鏁堢敤鎴�");
}
- if (Constants.equalsInteger(param.getType(), Constants.ZERO)) {
+ if (MeetConstants.equalsInteger(param.getType(), MeetConstants.ZERO)) {
//浼氳寮�闂�
bookOpenDoor(user, param);
- } else if (Constants.equalsInteger(param.getType(), Constants.ONE)) {
+ } else if (MeetConstants.equalsInteger(param.getType(), MeetConstants.ONE)) {
//浼氳瀹ょ鐞嗗憳寮�闂�
roomManagerOpenDoor(user, param);
}
@@ -618,7 +649,7 @@
Long time = param.getTimestamp();
Long validTime = 0l;
try {
- validTime = Long.parseLong(systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.QR_OPENROOM_VALIDTIME).getCode());
+ validTime = Long.parseLong(systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.QR_OPENROOM_VALIDTIME).getCode());
} catch (Exception e) {
}
if (validTime > 0 && System.currentTimeMillis() - time > validTime * 60*1000) {
@@ -626,28 +657,28 @@
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "璇诲ご鎵爜锛氳浜岀淮鐮佸凡杩囨湡锛�");
}
Devices devices = new Devices();
- devices.setIsdeleted(Constants.ZERO);
- devices.setStatus(Constants.ZERO);
+ 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(!Constants.equalsInteger(param.getObjId(),devices.getRoomId())){
+ if(!MeetConstants.equalsInteger(param.getObjId(),devices.getRoomId())){
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "璇诲ご鎵爜锛氭棤鏁堣澶囩粦瀹�");
}
//鏌ヨ浼氳瀹よ褰�
Rooms rooms = roomsMapper.selectById(param.getObjId());
- if (rooms == null || Constants.equalsInteger(rooms.getIsdeleted(), Constants.ONE)) {
+ if (rooms == null || MeetConstants.equalsInteger(rooms.getIsdeleted(), MeetConstants.ONE)) {
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "璇诲ご鎵爜锛氭棤鏁堜細璁");
}
UserRel rel = new UserRel();
- rel.setIsdeleted(Constants.ZERO);
+ rel.setIsdeleted(MeetConstants.ZERO);
rel.setObjId(rooms.getId());
rel.setUserId(user.getId());
- rel.setObjType(Constants.UserRelObjType.objTypeRoom);
+ rel.setObjType(MeetConstants.UserRelObjType.objTypeRoom);
//鏌ヨ鏄惁鍙備細浜哄憳
rel = userRelJoinMapper.selectOne(new QueryWrapper<>(rel).last("limit 1"));
if (rel == null) {
@@ -656,12 +687,12 @@
}
RoomRecord record = new RoomRecord();
record.setCreateDate(new Date());
- record.setIsdeleted(Constants.ZERO);
+ record.setIsdeleted(MeetConstants.ZERO);
record.setCreator(user.getId());
record.setObjId(rooms.getId());
record.setUserId(user.getId());
record.setRoomId(rooms.getId());
- record.setObjType(Constants.RoomRecordObjType.objTypeRoom);
+ record.setObjType(MeetConstants.RoomRecordObjType.objTypeRoom);
//寮�闂ㄨ褰�
roomRecordMapper.insert(record);
}
@@ -677,7 +708,7 @@
Long time = param.getTimestamp();
Long validTime = 0l;
try {
- validTime = Long.parseLong(systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.QR_OPENBOOK_VALIDTIME).getCode());
+ validTime = Long.parseLong(systemDictDataBiz.queryByCode(MeetConstants.SYSTEM, MeetConstants.QR_OPENBOOK_VALIDTIME).getCode());
} catch (Exception e) {
}
if (validTime > 0 && System.currentTimeMillis() - time > validTime * 60*1000) {
@@ -685,30 +716,30 @@
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "璇诲ご鎵爜:浜岀淮鐮佸凡澶辨晥");
}
Devices devices = new Devices();
- devices.setIsdeleted(Constants.ZERO);
- devices.setStatus(Constants.ZERO);
+ 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 || Constants.equalsInteger(book.getIsdeleted(), Constants.ONE)) {
+ if (book == null || MeetConstants.equalsInteger(book.getIsdeleted(), MeetConstants.ONE)) {
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "璇诲ご鎵爜:鏃犳晥浼氳");
}
- if(!Constants.equalsInteger(book.getRoomId(),devices.getRoomId())){
+ if(!MeetConstants.equalsInteger(book.getRoomId(),devices.getRoomId())){
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "璇诲ご鎵爜:鏃犳晥璁惧缁戝畾");
}
- if (!Constants.equalsInteger(book.getStatus(), Constants.ZERO)) {
+ 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(Constants.SYSTEM, Constants.ADVANCE_IN).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(), "璇诲ご鎵爜:浼氳鏈紑濮�");
}
@@ -717,24 +748,24 @@
}
RoomRecord record = new RoomRecord();
record.setCreateDate(new Date());
- record.setIsdeleted(Constants.ZERO);
+ 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(Constants.ZERO);
+ rel.setIsdeleted(MeetConstants.ZERO);
rel.setObjId(book.getId());
rel.setUserId(user.getId());
- rel.setObjType(Constants.UserRelObjType.objTypeBook);
+ rel.setObjType(MeetConstants.UserRelObjType.objTypeBook);
//鏌ヨ鏄惁鍙備細浜哄憳
rel = userRelJoinMapper.selectOne(new QueryWrapper<>(rel).last("limit 1"));
if (rel == null) {
//璁垮
- record.setObjType(Constants.RoomRecordObjType.objTypeBook_out);
+ record.setObjType(MeetConstants.RoomRecordObjType.objTypeBook_out);
} else {
//鍙備細浜哄憳
- record.setObjType(Constants.RoomRecordObjType.objTypeBook_in);
+ record.setObjType(MeetConstants.RoomRecordObjType.objTypeBook_in);
}
//寮�闂ㄨ褰�
roomRecordMapper.insert(record);
@@ -751,10 +782,10 @@
@Override
public List<Bookings> getMyBookings(Integer userId, String dateMsg) {
return bookingsMapper.selectList(new QueryWrapper<Bookings>()
- .apply(" id in ( select u.OBJ_ID from user_rel u where u.USER_ID = '" + userId + "' and u.ISDELETED = 0 and OBJ_TYPE = 1 ) ")
- .eq("ISDELETED",Constants.ZERO)
-// .eq("STATUS",Constants.ZERO)
- .apply(" ROOM_ID in ( select r.id from rooms r where r.ISDELETED = 0 and r.STATUS = 0 )")
+ .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));
}
@@ -767,32 +798,92 @@
*/
@Override
public IPage<MeetingListResponse> getMyMeetingPage(PageWrap<MeetingPageRequest> pageWrap) {
- IPage<MeetingListResponse> page = bookingsMapper.myMeetingPage(pageWrap.toPage(), new QueryWrapper<MeetingListResponse>()
+
+ 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(Constants.ONE) && !Objects.isNull(pageWrap.getModel().getUserId()),
- " select 1 from 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(Constants.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(Constants.ONE), " now() < a.END_TIME and a.STATUS = 0 ")
- .and(!Objects.isNull(pageWrap.getModel().getStatus()) && pageWrap.getModel().getStatus().equals(Constants.TWO),
- j -> j.apply("now() >= a.END_TIME ").or()
- .eq(" a.STATUS", Constants.ONE))
- .eq("b.ISDELETED",Constants.ZERO)
- .eq("b.STATUS",Constants.ZERO)
- .eq("a.ISDELETED",Constants.ZERO)
- .orderByDesc(!Objects.isNull(pageWrap.getModel().getStatus())&&pageWrap.getModel().getStatus().equals(Constants.TWO),"a.START_TIME")
- .orderByAsc(Objects.isNull(pageWrap.getModel().getStatus())||pageWrap.getModel().getStatus().equals(Constants.ONE),"a.START_TIME")
- );
- String prefixUrl = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
- ;
+ .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);
+ String path = systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.FTP_RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(MeetConstants.FTP, MeetConstants.PROJECTS).getCode();
page.getRecords().forEach(i -> {
- i.setPrefixUrl(prefixUrl);
+ i.setPrefixUrl(path);
+ if(i.getMeetingStatus().equals(Constants.ZERO)){
+ if(i.getMeetingStatus()==Constants.ONE){
+ //寮�濮嬪墠120鍒嗛挓 澶т簬褰撳墠鏃堕棿 鍒欐樉绀哄嵆灏嗗紑濮�
+ if(DateUtil.afterMinutesDate(i.getStartTime(),-120).getTime()>System.currentTimeMillis()){
+ i.setMeetingStatus(4);
+ }
+ }
+ }
+
});
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());
+ }catch (Exception e){
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+
+
/**
* 浼氳璇︽儏
@@ -807,44 +898,49 @@
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "鏈煡璇㈠埌浼氳璇︽儏");
}
//棰勭害浜�
- meetingDetailResponse.setBookingUser(systemUserService.getUserInfo(meetingDetailResponse.getBookingUserId()));
+ meetingDetailResponse.setBookingUser(systemUserService.findById(meetingDetailResponse.getBookingUserId()));
//鏃堕棿娈靛垪琛�
meetingDetailResponse.setBookingTimeList(bookingTimeMapper.selectList(new QueryWrapper<BookingTime>()
.eq("BOOKING_ID", id)
- .eq("ISDELETED", Constants.ZERO)
+ .eq("ISDELETED", MeetConstants.ZERO)
));
//鍙備細浜哄憳鍒楄〃
+
List<UserResponse> userResponseList = systemUserService.getUserList(id);
- String avatarPath = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
+ String avatarPath = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode()
+ +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
userResponseList.forEach(i -> {
- i.setPrefixUrl(avatarPath);
+ if(StringUtils.isNotBlank(i.getAvatar())){
+ i.setAvatar(avatarPath+i.getAvatar());
+ }
});
meetingDetailResponse.setUserResponseList(userResponseList);
//鏈嶅姟椤�
- String projectsPath = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.FILE_DIR).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.PROJECTS).getCode();
- List<ProjectsResponse> projectsResponseList = projectsService.getProjectsList(id, Constants.ONE);
+ 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", Constants.ZERO)
+ .eq("OBJ_TYPE", MeetConstants.ZERO)
);
multiFileList.forEach(i -> {
- i.setFileFullUrl(projectsPath);
+ i.setFileurlFull(projectsPath);
});
//闄勪欢淇℃伅
meetingDetailResponse.setMultiFileList(multiFileList);
//浼氳瀹ょ鐞嗕汉鍛�
List<UserRel> userRelList = userRelMapper.selectList(new QueryWrapper<UserRel>()
- .eq("ISDELETED",Constants.ZERO)
+ .eq("ISDELETED",MeetConstants.ZERO)
.eq("OBJ_ID", meetingDetailResponse.getRoomId())
- .eq("OBJ_TYPE",Constants.ZERO)
+ .eq("OBJ_TYPE",MeetConstants.ZERO)
);
if (!Objects.isNull(userRelList) && userRelList.size() > 0) {
- meetingDetailResponse.setRoomUser(systemUserService.getUserInfo(userRelList.get(Constants.ZERO).getUserId()));
+ meetingDetailResponse.setRoomUser(systemUserService.findById(userRelList.get(MeetConstants.ZERO).getUserId()));
}
return meetingDetailResponse;
}
@@ -859,11 +955,11 @@
@Override
public String getQrCode(Integer id, Integer userId) {
Bookings model = bookingsMapper.selectById(id);
- if (model == null || !Constants.equalsInteger(model.getIsdeleted(), Constants.ZERO)) {
+ if (model == null || !MeetConstants.equalsInteger(model.getIsdeleted(), MeetConstants.ZERO)) {
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "鏈煡璇㈠埌浼氳璇︽儏");
}
QrOpenDoorDto dto = new QrOpenDoorDto();
- dto.setType(Constants.ZERO);
+ dto.setType(MeetConstants.ZERO);
dto.setUserId(userId);
dto.setTimestamp(System.currentTimeMillis());
dto.setObjId(id);
@@ -893,30 +989,29 @@
/**
* 浼氳棰勭害璁板綍鍙栨秷
- *
- * @param id
- * @param userId
*/
@Override
- public void reservationCancel(Integer id, Integer userId) {
- Bookings bookings = bookingsMapper.selectById(id);
+ @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(userId)) {
+ if (!bookings.getCreator().equals(businessOverDTO.getUserId())) {
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "闈炰綘鐨勯绾﹁褰�,鏃犳硶杩涜鍙栨秷");
}
if (System.currentTimeMillis() > bookings.getStartTime().getTime()) {
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "浼氳宸插紑濮�,鏃犳硶杩涜鍙栨秷");
}
- if(bookings.getStatus().equals(Constants.ONE)){
+ if(bookings.getStatus().equals(MeetConstants.ONE)){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "鏈鎿嶄綔澶辫触,棰勭害鐘舵�佸凡娴佽浆");
}
bookings.setCancelTime(new Date());
- bookings.setCancelUser(userId);
- bookings.setStatus(Constants.ONE);
+ bookings.setCancelUser(businessOverDTO.getUserId());
+ bookings.setCancelInfo(businessOverDTO.getBusinessRemark());
+ bookings.setStatus(MeetConstants.ONE);
bookings.setEditDate(new Date());
- bookings.setEditor(userId);
+ bookings.setEditor(businessOverDTO.getUserId());
bookingsMapper.updateById(bookings);
//鍙栨秷浼氳 鍙戦�佸彇娑堥�氱煡
this.sendNotice(bookings, 3);
@@ -925,27 +1020,84 @@
}
+ @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.ONE)
+ .eq(UserRel::getUserId,businessOverDTO.getUserId()));
+
+ if (!bookings.getCreator().equals(businessOverDTO.getUserId()) && userRelList <= 0) {
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "闈炰綘鐨勯绾﹁褰�,鏃犳硶杩涜璇ユ搷浣�");
+ }
+ if (System.currentTimeMillis() < bookings.getStartTime().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);
+ }
+ }
+
+ }
+
/**
* 瀹氭椂鍙戦�佷細璁� 鍗冲皢寮�濮嬮�氱煡
*/
@Override
public void sendBookingsNotice() {
//鏌ヨ閰嶇疆
- String configMinute = systemDictDataBiz.queryByCode(Constants.SYSTEM, Constants.NOTICE_TIME).getCode();
+ 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",Constants.ZERO)
- .eq("ISDELETED",Constants.ZERO)
- .eq("SEND_NOTICE", Constants.ZERO)
+ .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 rooms r where r.ISDELETED = 0 and r.STATUS = 0 )")
+ .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(Constants.ONE);
+ bookings.setSendNotice(MeetConstants.ONE);
bookings.setEditDate(new Date());
bookingsMapper.updateById(bookings);
- this.sendNotice(bookings, Constants.ONE);
+ this.sendNotice(bookings, MeetConstants.ONE);
//鍙戦�佸井淇￠�氱煡
sendWxMessage.bookingsStart(systemUserMapper.selectById(bookings.getCreator()), bookings, roomsMapper.selectById(bookings.getRoomId()));
}
@@ -963,26 +1115,28 @@
//2銆佷細璁瀹氭垚鍔燂紝缁欐墍鏈夊弬浼氫汉鍛樹笌棰勭害浜洪兘鍙戦��
//3銆佷細璁彇娑� 浼氳鍙栨秷锛岀粰鎵�鏈夊弬浼氫汉鍛橀兘鍙戦��
List<UserRel> userRelList = userRelMapper.selectList(new QueryWrapper<UserRel>()
- .eq("OBJ_TYPE", Constants.ONE)
+ .eq("OBJ_TYPE", MeetConstants.ONE)
.eq("OBJ_ID", bookings.getId())
- .eq("ISDELETED", Constants.ZERO)
+ .eq("ISDELETED", MeetConstants.ZERO)
);
- for (UserRel i : userRelList) {
- noticeService.sendNotice(sendType, i.getUserId(), bookings.getId(), bookings.getCreator());
+ List<Notices> 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 (sendType.equals(Constants.ONE)) {
- noticeService.sendNotice(Constants.ZERO, bookings.getUserId(), bookings.getId(), bookings.getUserId());
- } else if (sendType.equals(Constants.TWO) || sendType.equals(3)) {
- Boolean flag = true;
+ if(userRelList!=null && userRelList.size()>0){
for (UserRel i : userRelList) {
- if (i.getUserId().equals(bookings.getCreator())) {
- flag = false;
- break;
- }
+ Notices notices = new Notices(noticeObjectType,i.getId(),noticeObjectType.getInfo(), i.getUserId(), Constants.ZERO);
+ noticeList.add(notices);
}
- if (flag) {
- noticeService.sendNotice(sendType, bookings.getCreator(), bookings.getId(), bookings.getCreator());
- }
+ }
+ //缁欏弬浼氫汉鍛樻彃鍏�
+ Notices notices = new Notices(noticeObjectType,bookings.getId(),noticeObjectType.getInfo(),bookings.getCreator(), Constants.ZERO);
+ noticeList.add(notices);
+ if(noticeList.size()>0){
+ noticesMapper.insert(noticeList);
}
}
@@ -999,7 +1153,7 @@
lambdaWrapper.selectAll(Bookings.class)
.selectAs(SystemUser::getRealname, Bookings::getRealName)
- .selectAs(SystemDepartment::getName, Bookings::getDepartmentName)
+ .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" +
@@ -1013,13 +1167,12 @@
// .leftJoin(RoomTime.class, RoomTime::getId, BookingTime::getTimeId)
.leftJoin(SystemUser.class, SystemUser::getId, Bookings::getCreator)
.leftJoin(Rooms.class, Rooms::getId, Bookings::getRoomId)
- .leftJoin(SystemDepartmentUser.class, SystemDepartmentUser::getUserId, Bookings::getCreator)
- .leftJoin(SystemDepartment.class, SystemDepartment::getId, SystemDepartmentUser::getDepartmentId)
+ .leftJoin(Company.class,Company::getId,SystemUser::getCompanyId)
.eq(Objects.nonNull(roomId), Bookings::getRoomId, roomId)
- .eq(Bookings::getIsdeleted, Constants.ZERO)
- .eq(Bookings::getStatus, Constants.ZERO)
- // .eq(BookingTime::getIsdeleted, Constants.ZERO)
- // .eq(RoomTime::getIsdeleted, Constants.ZERO)
+ .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)
@@ -1085,5 +1238,40 @@
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)
+ .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;
+ }
+
+
}
--
Gitblit v1.9.3