|
@@ -24,6 +24,7 @@ import com.usky.common.core.util.DateUtils;
|
|
|
import com.usky.common.security.utils.SecurityUtils;
|
|
import com.usky.common.security.utils.SecurityUtils;
|
|
|
import com.usky.meeting.controller.web.SignOnOutRequestVO;
|
|
import com.usky.meeting.controller.web.SignOnOutRequestVO;
|
|
|
import com.usky.meeting.domain.*;
|
|
import com.usky.meeting.domain.*;
|
|
|
|
|
+import com.usky.meeting.mapper.MeetingDeviceMapper;
|
|
|
import com.usky.meeting.mapper.MeetingFloorMapper;
|
|
import com.usky.meeting.mapper.MeetingFloorMapper;
|
|
|
import com.usky.meeting.mapper.MeetingInfoMapper;
|
|
import com.usky.meeting.mapper.MeetingInfoMapper;
|
|
|
import com.usky.meeting.mapper.MeetingRoomMapper;
|
|
import com.usky.meeting.mapper.MeetingRoomMapper;
|
|
@@ -91,6 +92,8 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
private MeetingFloorMapper meetingFloorMapper;
|
|
private MeetingFloorMapper meetingFloorMapper;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private MeetingFileService meetingFileService;
|
|
private MeetingFileService meetingFileService;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private MeetingDeviceMapper deviceMapper;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public Map<String, Object> meetingSummary(Integer tenantId) {
|
|
public Map<String, Object> meetingSummary(Integer tenantId) {
|
|
@@ -98,8 +101,8 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public Map<String, Object> meetingSummaryByYear(String year,Integer tenantId) {
|
|
|
|
|
- return dmMeetingRepository.meetingSummaryByYear(year,tenantId);
|
|
|
|
|
|
|
+ public Map<String, Object> meetingSummaryByYear(String year, Integer tenantId) {
|
|
|
|
|
+ return dmMeetingRepository.meetingSummaryByYear(year, tenantId);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -112,32 +115,32 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
Date date = dtf.parse(dayTime);
|
|
Date date = dtf.parse(dayTime);
|
|
|
Calendar cal = Calendar.getInstance();
|
|
Calendar cal = Calendar.getInstance();
|
|
|
cal.setTime(date);
|
|
cal.setTime(date);
|
|
|
- //获取日期中得年
|
|
|
|
|
- Integer year= cal.get(Calendar.YEAR);
|
|
|
|
|
- System.out.println("year:"+year);
|
|
|
|
|
- //获取日期中得月
|
|
|
|
|
- Integer month= (cal.get(Calendar.MONTH) + 1);
|
|
|
|
|
- System.out.println("month:"+month);
|
|
|
|
|
- //获取日期中得日
|
|
|
|
|
- Integer day= Integer.valueOf(String.format("%td", date));
|
|
|
|
|
- List<MeetingInfo> dmMeetings = dmMeetingRepository.getDmMeetingByStartDatDay(roomId,year,month,day,tenantId);
|
|
|
|
|
|
|
+ // 获取日期中得年
|
|
|
|
|
+ Integer year = cal.get(Calendar.YEAR);
|
|
|
|
|
+ System.out.println("year:" + year);
|
|
|
|
|
+ // 获取日期中得月
|
|
|
|
|
+ Integer month = (cal.get(Calendar.MONTH) + 1);
|
|
|
|
|
+ System.out.println("month:" + month);
|
|
|
|
|
+ // 获取日期中得日
|
|
|
|
|
+ Integer day = Integer.valueOf(String.format("%td", date));
|
|
|
|
|
+ List<MeetingInfo> dmMeetings = dmMeetingRepository.getDmMeetingByStartDatDay(roomId, year, month, day, tenantId);
|
|
|
LambdaQueryWrapper<SysUser> sysUserQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<SysUser> sysUserQuery = Wrappers.lambdaQuery();
|
|
|
- sysUserQuery.eq(SysUser::getTenantId,tenantId);
|
|
|
|
|
|
|
+ sysUserQuery.eq(SysUser::getTenantId, tenantId);
|
|
|
List<SysUser> userList = sysUserService.list(sysUserQuery);
|
|
List<SysUser> userList = sysUserService.list(sysUserQuery);
|
|
|
- if(userList.size() <= 0){
|
|
|
|
|
|
|
+ if (userList.size() <= 0) {
|
|
|
throw new BusinessException("用户信息不能为空");
|
|
throw new BusinessException("用户信息不能为空");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(!ObjectUtil.isEmpty(dmMeetings)){
|
|
|
|
|
- for(MeetingInfo dmMeeting : dmMeetings){
|
|
|
|
|
- //参会人员信息
|
|
|
|
|
|
|
+ if (!ObjectUtil.isEmpty(dmMeetings)) {
|
|
|
|
|
+ for (MeetingInfo dmMeeting : dmMeetings) {
|
|
|
|
|
+ // 参会人员信息
|
|
|
List<SysUser> attendeeUserList = new ArrayList<>();
|
|
List<SysUser> attendeeUserList = new ArrayList<>();
|
|
|
- List<MeetingAttendee> attendeeList = meetingAttendeeRepository.findMeetingAttendeeList(dmMeeting.getMeetingId(),null, tenantId);
|
|
|
|
|
- if(attendeeList.size() > 0){
|
|
|
|
|
|
|
+ List<MeetingAttendee> attendeeList = meetingAttendeeRepository.findMeetingAttendeeList(dmMeeting.getMeetingId(), null, tenantId);
|
|
|
|
|
+ if (attendeeList.size() > 0) {
|
|
|
for (int i = 0; i < attendeeList.size(); i++) {
|
|
for (int i = 0; i < attendeeList.size(); i++) {
|
|
|
Long uid = attendeeList.get(i).getUserId();
|
|
Long uid = attendeeList.get(i).getUserId();
|
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
|
- if(uid.equals(userList.get(j).getUserId())){
|
|
|
|
|
|
|
+ if (uid.equals(userList.get(j).getUserId())) {
|
|
|
attendeeUserList.add(userList.get(j));
|
|
attendeeUserList.add(userList.get(j));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -145,9 +148,9 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
dmMeeting.setUsers(attendeeUserList);
|
|
dmMeeting.setUsers(attendeeUserList);
|
|
|
- //发起人信息
|
|
|
|
|
|
|
+ // 发起人信息
|
|
|
for (int i = 0; i < userList.size(); i++) {
|
|
for (int i = 0; i < userList.size(); i++) {
|
|
|
- if(userList.get(i).getUserId().equals(Long.valueOf(dmMeeting.getInitiatorId()))){
|
|
|
|
|
|
|
+ if (userList.get(i).getUserId().equals(Long.valueOf(dmMeeting.getInitiatorId()))) {
|
|
|
dmMeeting.setInitiatorUser(userList.get(i));
|
|
dmMeeting.setInitiatorUser(userList.get(i));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -161,7 +164,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
Date meetingStartDate = new Date(meetingStartTimestamp.getTime());
|
|
Date meetingStartDate = new Date(meetingStartTimestamp.getTime());
|
|
|
Calendar meetingStartCal = Calendar.getInstance();
|
|
Calendar meetingStartCal = Calendar.getInstance();
|
|
|
meetingStartCal.setTime(meetingStartDate);
|
|
meetingStartCal.setTime(meetingStartDate);
|
|
|
- if(cal.get(Calendar.YEAR) == meetingStartCal.get(Calendar.YEAR) && cal.get(Calendar.DAY_OF_YEAR) == meetingStartCal.get(Calendar.DAY_OF_YEAR)) {
|
|
|
|
|
|
|
+ if (cal.get(Calendar.YEAR) == meetingStartCal.get(Calendar.YEAR) && cal.get(Calendar.DAY_OF_YEAR) == meetingStartCal.get(Calendar.DAY_OF_YEAR)) {
|
|
|
int meetingStartHours = meetingStartDate.getHours();
|
|
int meetingStartHours = meetingStartDate.getHours();
|
|
|
meetingStartNumber = meetingStartNumber + meetingStartHours;
|
|
meetingStartNumber = meetingStartNumber + meetingStartHours;
|
|
|
int meetingStartMinutes = meetingStartDate.getMinutes();
|
|
int meetingStartMinutes = meetingStartDate.getMinutes();
|
|
@@ -177,7 +180,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
Date meetingEndDate = new Date(meetingEndTimestamp.getTime());
|
|
Date meetingEndDate = new Date(meetingEndTimestamp.getTime());
|
|
|
Calendar meetingEndCal = Calendar.getInstance();
|
|
Calendar meetingEndCal = Calendar.getInstance();
|
|
|
meetingEndCal.setTime(meetingEndDate);
|
|
meetingEndCal.setTime(meetingEndDate);
|
|
|
- if(cal.get(Calendar.YEAR) == meetingEndCal.get(Calendar.YEAR) && cal.get(Calendar.DAY_OF_YEAR) == meetingEndCal.get(Calendar.DAY_OF_YEAR)) {
|
|
|
|
|
|
|
+ if (cal.get(Calendar.YEAR) == meetingEndCal.get(Calendar.YEAR) && cal.get(Calendar.DAY_OF_YEAR) == meetingEndCal.get(Calendar.DAY_OF_YEAR)) {
|
|
|
int meetingEndHours = meetingEndDate.getHours();
|
|
int meetingEndHours = meetingEndDate.getHours();
|
|
|
meetingEndNumber = meetingEndNumber + meetingEndHours;
|
|
meetingEndNumber = meetingEndNumber + meetingEndHours;
|
|
|
int meetingEndMinutes = meetingEndDate.getMinutes();
|
|
int meetingEndMinutes = meetingEndDate.getMinutes();
|
|
@@ -207,10 +210,10 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
System.out.println("date:" + date);
|
|
System.out.println("date:" + date);
|
|
|
Calendar cal = Calendar.getInstance();
|
|
Calendar cal = Calendar.getInstance();
|
|
|
cal.setTime(date);
|
|
cal.setTime(date);
|
|
|
- //获取日期中得年
|
|
|
|
|
|
|
+ // 获取日期中得年
|
|
|
Integer year = cal.get(Calendar.YEAR);
|
|
Integer year = cal.get(Calendar.YEAR);
|
|
|
System.out.println("year:" + year);
|
|
System.out.println("year:" + year);
|
|
|
- //获取日期中得月
|
|
|
|
|
|
|
+ // 获取日期中得月
|
|
|
Integer month = (cal.get(Calendar.MONTH) + 1);
|
|
Integer month = (cal.get(Calendar.MONTH) + 1);
|
|
|
System.out.println("month:" + month);
|
|
System.out.println("month:" + month);
|
|
|
|
|
|
|
@@ -228,7 +231,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
set.add(startDay);
|
|
set.add(startDay);
|
|
|
// 设置日期
|
|
// 设置日期
|
|
|
calendar.setTime(startDate);
|
|
calendar.setTime(startDate);
|
|
|
- //把日期增加一天
|
|
|
|
|
|
|
+ // 把日期增加一天
|
|
|
calendar.add(Calendar.DATE, 1);
|
|
calendar.add(Calendar.DATE, 1);
|
|
|
// 获取增加后的日期
|
|
// 获取增加后的日期
|
|
|
startDate = calendar.getTime();
|
|
startDate = calendar.getTime();
|
|
@@ -249,7 +252,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
if (meetingMode.equals("1")) {
|
|
if (meetingMode.equals("1")) {
|
|
|
|
|
|
|
|
} else if (meetingMode.equals("0") || meetingMode.equals("2")) {
|
|
} else if (meetingMode.equals("0") || meetingMode.equals("2")) {
|
|
|
- //判断指定会议室预约的时间是否与存在的预约单冲突
|
|
|
|
|
|
|
+ // 判断指定会议室预约的时间是否与存在的预约单冲突
|
|
|
List<Map<String, String>> dmMeetingList = dmMeetingRepository.checkDmRoomMeetingDate(resources.getRoom().getRoomId(), resources.getStartDate(), resources.getEndDate(), resources.getMeetingId());
|
|
List<Map<String, String>> dmMeetingList = dmMeetingRepository.checkDmRoomMeetingDate(resources.getRoom().getRoomId(), resources.getStartDate(), resources.getEndDate(), resources.getMeetingId());
|
|
|
if (dmMeetingList != null && dmMeetingList.size() > 0) {
|
|
if (dmMeetingList != null && dmMeetingList.size() > 0) {
|
|
|
throw new BusinessException("预约时间段冲突,请重设预约时间");
|
|
throw new BusinessException("预约时间段冲突,请重设预约时间");
|
|
@@ -278,9 +281,9 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
MeetingInfo meeting = this.toEntity(resources);
|
|
MeetingInfo meeting = this.toEntity(resources);
|
|
|
this.save(meeting);
|
|
this.save(meeting);
|
|
|
|
|
|
|
|
- //循环保存会议id和会议文件记录到会议文件表中
|
|
|
|
|
|
|
+ // 循环保存会议id和会议文件记录到会议文件表中
|
|
|
Long meetingId = meeting.getMeetingId();
|
|
Long meetingId = meeting.getMeetingId();
|
|
|
- if(!ObjectUtils.isEmpty(resources.getMeetingFileList())){
|
|
|
|
|
|
|
+ if (!ObjectUtils.isEmpty(resources.getMeetingFileList())) {
|
|
|
for (MeetingFile meetingFile : resources.getMeetingFileList()) {
|
|
for (MeetingFile meetingFile : resources.getMeetingFileList()) {
|
|
|
meetingFile.setMeetingId(meetingId);
|
|
meetingFile.setMeetingId(meetingId);
|
|
|
meetingFile.setUploadUser(SecurityUtils.getUsername());
|
|
meetingFile.setUploadUser(SecurityUtils.getUsername());
|
|
@@ -291,7 +294,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if (!ObjectUtils.isEmpty(resources.getUsers())) {
|
|
if (!ObjectUtils.isEmpty(resources.getUsers())) {
|
|
|
- for(SysUser dmUser : resources.getUsers()){
|
|
|
|
|
|
|
+ for (SysUser dmUser : resources.getUsers()) {
|
|
|
MeetingAttendee meetingAttendee = new MeetingAttendee();
|
|
MeetingAttendee meetingAttendee = new MeetingAttendee();
|
|
|
meetingAttendee.setMeetingId(meeting.getMeetingId());
|
|
meetingAttendee.setMeetingId(meeting.getMeetingId());
|
|
|
meetingAttendee.setUserId(dmUser.getUserId());
|
|
meetingAttendee.setUserId(dmUser.getUserId());
|
|
@@ -304,23 +307,23 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public CommonPage<MeetingInfo> meetingInfoList(MeetingInfoRequestVO requestVO){
|
|
|
|
|
- Page<MeetingInfo> page = new Page<>(requestVO.getCurrent(),requestVO.getSize());
|
|
|
|
|
|
|
+ public CommonPage<MeetingInfo> meetingInfoList(MeetingInfoRequestVO requestVO) {
|
|
|
|
|
+ Page<MeetingInfo> page = new Page<>(requestVO.getCurrent(), requestVO.getSize());
|
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
|
|
|
|
|
|
- if(StringUtils.isNotBlank(requestVO.getName())){
|
|
|
|
|
|
|
+ if (StringUtils.isNotBlank(requestVO.getName())) {
|
|
|
List<String> initiatorIdList = new ArrayList<>();
|
|
List<String> initiatorIdList = new ArrayList<>();
|
|
|
LambdaQueryWrapper<SysUser> sysUserQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<SysUser> sysUserQuery = Wrappers.lambdaQuery();
|
|
|
- sysUserQuery.like(SysUser::getNickName,requestVO.getName())
|
|
|
|
|
- .eq(SysUser::getTenantId,SecurityUtils.getTenantId());
|
|
|
|
|
|
|
+ sysUserQuery.like(SysUser::getNickName, requestVO.getName())
|
|
|
|
|
+ .eq(SysUser::getTenantId, SecurityUtils.getTenantId());
|
|
|
List<SysUser> userList = sysUserService.list(sysUserQuery);
|
|
List<SysUser> userList = sysUserService.list(sysUserQuery);
|
|
|
- if(userList.size() > 0){
|
|
|
|
|
|
|
+ if (userList.size() > 0) {
|
|
|
for (int i = 0; i < userList.size(); i++) {
|
|
for (int i = 0; i < userList.size(); i++) {
|
|
|
initiatorIdList.add(userList.get(i).getUserId().toString());
|
|
initiatorIdList.add(userList.get(i).getUserId().toString());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(CollectionUtils.isNotEmpty(initiatorIdList)) {
|
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(initiatorIdList)) {
|
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
|
.in(MeetingInfo::getInitiatorId, initiatorIdList)
|
|
.in(MeetingInfo::getInitiatorId, initiatorIdList)
|
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
@@ -329,7 +332,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
.between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()), MeetingInfo::getEndDate, requestVO.getStartDate(), requestVO.getEndDate())
|
|
.between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()), MeetingInfo::getEndDate, requestVO.getStartDate(), requestVO.getEndDate())
|
|
|
.eq(MeetingInfo::getTenantId, SecurityUtils.getTenantId())
|
|
.eq(MeetingInfo::getTenantId, SecurityUtils.getTenantId())
|
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
|
- }else{
|
|
|
|
|
|
|
+ } else {
|
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
|
.in(MeetingInfo::getInitiatorId, "")
|
|
.in(MeetingInfo::getInitiatorId, "")
|
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
@@ -339,7 +342,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
.eq(MeetingInfo::getTenantId, SecurityUtils.getTenantId())
|
|
.eq(MeetingInfo::getTenantId, SecurityUtils.getTenantId())
|
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
|
}
|
|
}
|
|
|
- }else{
|
|
|
|
|
|
|
+ } else {
|
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
queryWrapper.like(StringUtils.isNotBlank(requestVO.getRoomName()), MeetingInfo::getRoomName, requestVO.getRoomName())
|
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
.eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
|
.eq(null != requestVO.getApproveStatus(), MeetingInfo::getApproveStatus, requestVO.getApproveStatus())
|
|
.eq(null != requestVO.getApproveStatus(), MeetingInfo::getApproveStatus, requestVO.getApproveStatus())
|
|
@@ -349,46 +352,46 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- page = this.page(page,queryWrapper);
|
|
|
|
|
- if(page.getRecords().size() > 0){
|
|
|
|
|
|
|
+ page = this.page(page, queryWrapper);
|
|
|
|
|
+ if (page.getRecords().size() > 0) {
|
|
|
List<Long> roomIdList = new ArrayList<>();
|
|
List<Long> roomIdList = new ArrayList<>();
|
|
|
List<Long> initIdList = new ArrayList<>();
|
|
List<Long> initIdList = new ArrayList<>();
|
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
|
- if(!roomIdList.contains(page.getRecords().get(i).getRoomId())){
|
|
|
|
|
|
|
+ if (!roomIdList.contains(page.getRecords().get(i).getRoomId())) {
|
|
|
roomIdList.add(page.getRecords().get(i).getRoomId());
|
|
roomIdList.add(page.getRecords().get(i).getRoomId());
|
|
|
}
|
|
}
|
|
|
- if(!initIdList.contains(page.getRecords().get(i).getInitiatorId())){
|
|
|
|
|
|
|
+ if (!initIdList.contains(page.getRecords().get(i).getInitiatorId())) {
|
|
|
initIdList.add(Long.valueOf(page.getRecords().get(i).getInitiatorId()));
|
|
initIdList.add(Long.valueOf(page.getRecords().get(i).getInitiatorId()));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- //房间以及对应楼层信息
|
|
|
|
|
- if(roomIdList.size() > 0){
|
|
|
|
|
|
|
+ // 房间以及对应楼层信息
|
|
|
|
|
+ if (roomIdList.size() > 0) {
|
|
|
LambdaQueryWrapper<MeetingRoom> meetingRoomQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingRoom> meetingRoomQuery = Wrappers.lambdaQuery();
|
|
|
- meetingRoomQuery.in(MeetingRoom::getRoomId,roomIdList)
|
|
|
|
|
- .eq(MeetingRoom::getTenantId,SecurityUtils.getTenantId())
|
|
|
|
|
- .eq(MeetingRoom::getStatus,0);
|
|
|
|
|
|
|
+ meetingRoomQuery.in(MeetingRoom::getRoomId, roomIdList)
|
|
|
|
|
+ .eq(MeetingRoom::getTenantId, SecurityUtils.getTenantId())
|
|
|
|
|
+ .eq(MeetingRoom::getStatus, 0);
|
|
|
List<MeetingRoom> meetingRoomList = meetingRoomMapper.selectList(meetingRoomQuery);
|
|
List<MeetingRoom> meetingRoomList = meetingRoomMapper.selectList(meetingRoomQuery);
|
|
|
|
|
|
|
|
List<Long> floorIdList = new ArrayList<>();
|
|
List<Long> floorIdList = new ArrayList<>();
|
|
|
- if(meetingRoomList.size() > 0){
|
|
|
|
|
|
|
+ if (meetingRoomList.size() > 0) {
|
|
|
for (int i = 0; i < meetingRoomList.size(); i++) {
|
|
for (int i = 0; i < meetingRoomList.size(); i++) {
|
|
|
- if(!floorIdList.contains(meetingRoomList.get(i).getFloorId())){
|
|
|
|
|
|
|
+ if (!floorIdList.contains(meetingRoomList.get(i).getFloorId())) {
|
|
|
floorIdList.add(meetingRoomList.get(i).getFloorId());
|
|
floorIdList.add(meetingRoomList.get(i).getFloorId());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
LambdaQueryWrapper<MeetingFloor> floorWrapper = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingFloor> floorWrapper = Wrappers.lambdaQuery();
|
|
|
- floorWrapper.in(MeetingFloor::getFloorId,floorIdList)
|
|
|
|
|
- .eq(MeetingFloor::getTenantId,SecurityUtils.getTenantId());
|
|
|
|
|
|
|
+ floorWrapper.in(MeetingFloor::getFloorId, floorIdList)
|
|
|
|
|
+ .eq(MeetingFloor::getTenantId, SecurityUtils.getTenantId());
|
|
|
List<MeetingFloor> meetingFloorList = meetingFloorMapper.selectList(floorWrapper);
|
|
List<MeetingFloor> meetingFloorList = meetingFloorMapper.selectList(floorWrapper);
|
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
|
for (int j = 0; j < meetingRoomList.size(); j++) {
|
|
for (int j = 0; j < meetingRoomList.size(); j++) {
|
|
|
- if(page.getRecords().get(i).getRoomId().equals(meetingRoomList.get(j).getRoomId())){
|
|
|
|
|
|
|
+ if (page.getRecords().get(i).getRoomId().equals(meetingRoomList.get(j).getRoomId())) {
|
|
|
page.getRecords().get(i).setRoomInfo(meetingRoomList.get(j));
|
|
page.getRecords().get(i).setRoomInfo(meetingRoomList.get(j));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
for (int j = 0; j < meetingFloorList.size(); j++) {
|
|
for (int j = 0; j < meetingFloorList.size(); j++) {
|
|
|
- if(page.getRecords().get(i).getRoomInfo().getFloorId().equals(meetingFloorList.get(j).getFloorId())){
|
|
|
|
|
|
|
+ if (page.getRecords().get(i).getRoomInfo().getFloorId().equals(meetingFloorList.get(j).getFloorId())) {
|
|
|
page.getRecords().get(i).getRoomInfo().setMeetingFloor(meetingFloorList.get(j));
|
|
page.getRecords().get(i).getRoomInfo().setMeetingFloor(meetingFloorList.get(j));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -396,16 +399,16 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- //发起人信息
|
|
|
|
|
- if(initIdList.size() > 0){
|
|
|
|
|
|
|
+ // 发起人信息
|
|
|
|
|
+ if (initIdList.size() > 0) {
|
|
|
LambdaQueryWrapper<SysUser> initIdQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<SysUser> initIdQuery = Wrappers.lambdaQuery();
|
|
|
- initIdQuery.in(SysUser::getUserId,initIdList)
|
|
|
|
|
- .eq(SysUser::getTenantId,SecurityUtils.getTenantId());
|
|
|
|
|
|
|
+ initIdQuery.in(SysUser::getUserId, initIdList)
|
|
|
|
|
+ .eq(SysUser::getTenantId, SecurityUtils.getTenantId());
|
|
|
List<SysUser> userList = sysUserService.list(initIdQuery);
|
|
List<SysUser> userList = sysUserService.list(initIdQuery);
|
|
|
- if(userList.size() > 0){
|
|
|
|
|
|
|
+ if (userList.size() > 0) {
|
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
|
- if(page.getRecords().get(i).getInitiatorId().equals(userList.get(j).getUserId().toString())){
|
|
|
|
|
|
|
+ if (page.getRecords().get(i).getInitiatorId().equals(userList.get(j).getUserId().toString())) {
|
|
|
page.getRecords().get(i).setInitiatorUser(userList.get(j));
|
|
page.getRecords().get(i).setInitiatorUser(userList.get(j));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -418,11 +421,11 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
- return new CommonPage<>(page.getRecords(),page.getTotal(),requestVO.getSize(),requestVO.getCurrent());
|
|
|
|
|
|
|
+ return new CommonPage<>(page.getRecords(), page.getTotal(), requestVO.getSize(), requestVO.getCurrent());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public void cancel(Long meetingId){
|
|
|
|
|
|
|
+ public void cancel(Long meetingId) {
|
|
|
MeetingInfo one = this.getById(meetingId);
|
|
MeetingInfo one = this.getById(meetingId);
|
|
|
one.setIsCancel(1);
|
|
one.setIsCancel(1);
|
|
|
one.setMeetingStatus(2);
|
|
one.setMeetingStatus(2);
|
|
@@ -430,10 +433,10 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public CommonPage<MeetingInfo> myMeetingList(MyMeetingInfoRequestVO requestVO){
|
|
|
|
|
|
|
+ public CommonPage<MeetingInfo> myMeetingList(MyMeetingInfoRequestVO requestVO) {
|
|
|
Integer current = requestVO.getCurrent();
|
|
Integer current = requestVO.getCurrent();
|
|
|
Integer size = requestVO.getSize();
|
|
Integer size = requestVO.getSize();
|
|
|
- Page<MeetingInfo> page = new Page<>(current,size);
|
|
|
|
|
|
|
+ Page<MeetingInfo> page = new Page<>(current, size);
|
|
|
|
|
|
|
|
Long userId = SecurityUtils.getUserId();
|
|
Long userId = SecurityUtils.getUserId();
|
|
|
List<BigInteger> meetingIdList = new ArrayList<>();
|
|
List<BigInteger> meetingIdList = new ArrayList<>();
|
|
@@ -446,34 +449,34 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
meetingIds.add(bigInteger.longValue());
|
|
meetingIds.add(bigInteger.longValue());
|
|
|
}
|
|
}
|
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
|
- queryWrapper.in(CollectionUtils.isNotEmpty(meetingIds),MeetingInfo::getMeetingId,meetingIds)
|
|
|
|
|
- .eq(MeetingInfo::getIsCancel,0)
|
|
|
|
|
- .like(StringUtils.isNotBlank(requestVO.getMeetingName()),MeetingInfo::getMeetingName,requestVO.getMeetingName())
|
|
|
|
|
- .like(StringUtils.isNotBlank(requestVO.getMeetingDescribe()),MeetingInfo::getMeetingDescribe,requestVO.getMeetingDescribe())
|
|
|
|
|
- .eq(null != requestVO.getMeetingMode(),MeetingInfo::getMeetingMode,requestVO.getMeetingMode())
|
|
|
|
|
- .eq(null != requestVO.getMeetingStatus(),MeetingInfo::getMeetingStatus,requestVO.getMeetingStatus())
|
|
|
|
|
- .between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()),MeetingInfo::getStartDate,requestVO.getStartDate(),requestVO.getEndDate())
|
|
|
|
|
- .between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()),MeetingInfo::getEndDate,requestVO.getStartDate(),requestVO.getEndDate())
|
|
|
|
|
- .eq(MeetingInfo::getTenantId,SecurityUtils.getTenantId())
|
|
|
|
|
|
|
+ queryWrapper.in(CollectionUtils.isNotEmpty(meetingIds), MeetingInfo::getMeetingId, meetingIds)
|
|
|
|
|
+ .eq(MeetingInfo::getIsCancel, 0)
|
|
|
|
|
+ .like(StringUtils.isNotBlank(requestVO.getMeetingName()), MeetingInfo::getMeetingName, requestVO.getMeetingName())
|
|
|
|
|
+ .like(StringUtils.isNotBlank(requestVO.getMeetingDescribe()), MeetingInfo::getMeetingDescribe, requestVO.getMeetingDescribe())
|
|
|
|
|
+ .eq(null != requestVO.getMeetingMode(), MeetingInfo::getMeetingMode, requestVO.getMeetingMode())
|
|
|
|
|
+ .eq(null != requestVO.getMeetingStatus(), MeetingInfo::getMeetingStatus, requestVO.getMeetingStatus())
|
|
|
|
|
+ .between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()), MeetingInfo::getStartDate, requestVO.getStartDate(), requestVO.getEndDate())
|
|
|
|
|
+ .between(StringUtils.isNotBlank(requestVO.getStartDate()) && StringUtils.isNotBlank(requestVO.getEndDate()), MeetingInfo::getEndDate, requestVO.getStartDate(), requestVO.getEndDate())
|
|
|
|
|
+ .eq(MeetingInfo::getTenantId, SecurityUtils.getTenantId())
|
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
.orderByDesc(MeetingInfo::getMeetingId);
|
|
|
- page = this.page(page,queryWrapper);
|
|
|
|
|
- if(page.getRecords().size() > 0){
|
|
|
|
|
|
|
+ page = this.page(page, queryWrapper);
|
|
|
|
|
+ if (page.getRecords().size() > 0) {
|
|
|
List<Long> initIdList = new ArrayList<>();
|
|
List<Long> initIdList = new ArrayList<>();
|
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
|
- if(!initIdList.contains(page.getRecords().get(i).getInitiatorId())){
|
|
|
|
|
|
|
+ if (!initIdList.contains(page.getRecords().get(i).getInitiatorId())) {
|
|
|
initIdList.add(Long.valueOf(page.getRecords().get(i).getInitiatorId()));
|
|
initIdList.add(Long.valueOf(page.getRecords().get(i).getInitiatorId()));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- //发起人信息
|
|
|
|
|
- if(initIdList.size() > 0){
|
|
|
|
|
|
|
+ // 发起人信息
|
|
|
|
|
+ if (initIdList.size() > 0) {
|
|
|
LambdaQueryWrapper<SysUser> initIdQuery = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<SysUser> initIdQuery = Wrappers.lambdaQuery();
|
|
|
- initIdQuery.in(SysUser::getUserId,initIdList)
|
|
|
|
|
- .eq(SysUser::getTenantId,SecurityUtils.getTenantId());
|
|
|
|
|
|
|
+ initIdQuery.in(SysUser::getUserId, initIdList)
|
|
|
|
|
+ .eq(SysUser::getTenantId, SecurityUtils.getTenantId());
|
|
|
List<SysUser> userList = sysUserService.list(initIdQuery);
|
|
List<SysUser> userList = sysUserService.list(initIdQuery);
|
|
|
- if(userList.size() > 0){
|
|
|
|
|
|
|
+ if (userList.size() > 0) {
|
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
for (int j = 0; j < userList.size(); j++) {
|
|
|
- if(page.getRecords().get(i).getInitiatorId().equals(userList.get(j).getUserId().toString())){
|
|
|
|
|
|
|
+ if (page.getRecords().get(i).getInitiatorId().equals(userList.get(j).getUserId().toString())) {
|
|
|
page.getRecords().get(i).setInitiatorUser(userList.get(j));
|
|
page.getRecords().get(i).setInitiatorUser(userList.get(j));
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -485,40 +488,43 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- return new CommonPage<>(page.getRecords(),page.getTotal(),size,current);
|
|
|
|
|
|
|
+ return new CommonPage<>(page.getRecords(), page.getTotal(), size, current);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public List<Map<String,Object>> meetingSignList(Long meetingId){
|
|
|
|
|
|
|
+ public List<Map<String, Object>> meetingSignList(Long meetingId) {
|
|
|
Integer tenantId = SecurityUtils.getTenantId();
|
|
Integer tenantId = SecurityUtils.getTenantId();
|
|
|
- List<Map<String, Object>> signList = dmMeetingRepository.meetingSignList(meetingId,tenantId);
|
|
|
|
|
|
|
+ List<Map<String, Object>> signList = dmMeetingRepository.meetingSignList(meetingId, tenantId);
|
|
|
return signList;
|
|
return signList;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public void signOnOut(SignOnOutRequestVO requestVO){
|
|
|
|
|
|
|
+ public void signOnOut(SignOnOutRequestVO requestVO) {
|
|
|
LambdaQueryWrapper<MeetingAttendee> queryWrapper = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingAttendee> queryWrapper = Wrappers.lambdaQuery();
|
|
|
- queryWrapper.eq(MeetingAttendee::getMeetingId,requestVO.getMeetingId())
|
|
|
|
|
- .eq(MeetingAttendee::getUserId,requestVO.getUserId());
|
|
|
|
|
-
|
|
|
|
|
- String domain = requestVO.getDomain();
|
|
|
|
|
- if(StringUtils.isNotBlank(domain)){
|
|
|
|
|
- Integer tenantId = meetingRoomRepository.getTenantIdByDomain(domain);
|
|
|
|
|
|
|
+ queryWrapper.eq(MeetingAttendee::getMeetingId, requestVO.getMeetingId())
|
|
|
|
|
+ .eq(MeetingAttendee::getUserId, requestVO.getUserId());
|
|
|
|
|
+
|
|
|
|
|
+ String deviceCode = requestVO.getDeviceCode();
|
|
|
|
|
+ Integer tenantId;
|
|
|
|
|
+ if (StringUtils.isNotBlank(deviceCode)) {
|
|
|
|
|
+ LambdaQueryWrapper<MeetingDevice> queryWrapper1 = new LambdaQueryWrapper<>();
|
|
|
|
|
+ queryWrapper1.eq(MeetingDevice::getDeviceCode, requestVO.getDeviceCode());
|
|
|
|
|
+ tenantId = deviceMapper.selectOne(queryWrapper1).getTenantId();
|
|
|
queryWrapper.eq(MeetingAttendee::getTenantId, tenantId);
|
|
queryWrapper.eq(MeetingAttendee::getTenantId, tenantId);
|
|
|
- }else{
|
|
|
|
|
|
|
+ } else {
|
|
|
queryWrapper.eq(MeetingAttendee::getTenantId, SecurityUtils.getTenantId());
|
|
queryWrapper.eq(MeetingAttendee::getTenantId, SecurityUtils.getTenantId());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
MeetingAttendee one = meetingAttendeeService.getOne(queryWrapper);
|
|
MeetingAttendee one = meetingAttendeeService.getOne(queryWrapper);
|
|
|
- if(one != null){
|
|
|
|
|
- //签到签退类别(0.签到 1.签退)
|
|
|
|
|
- if(requestVO.getMothodType().equals(0)){
|
|
|
|
|
|
|
+ if (one != null) {
|
|
|
|
|
+ // 签到签退类别(0.签到 1.签退)
|
|
|
|
|
+ if (requestVO.getMothodType().equals(0)) {
|
|
|
one.setIsSign(1);
|
|
one.setIsSign(1);
|
|
|
one.setSignDate(LocalDateTime.now());
|
|
one.setSignDate(LocalDateTime.now());
|
|
|
- //签到签退方式(0.人工 1.人脸)
|
|
|
|
|
|
|
+ // 签到签退方式(0.人工 1.人脸)
|
|
|
one.setSignType(requestVO.getSignType());
|
|
one.setSignType(requestVO.getSignType());
|
|
|
|
|
|
|
|
- }else{
|
|
|
|
|
|
|
+ } else {
|
|
|
one.setIsSignOut(1);
|
|
one.setIsSignOut(1);
|
|
|
one.setSignOutDate(LocalDateTime.now());
|
|
one.setSignOutDate(LocalDateTime.now());
|
|
|
one.setSignOutType(requestVO.getSignType());
|
|
one.setSignOutType(requestVO.getSignType());
|
|
@@ -528,36 +534,36 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- //UPDATE meeting_info SET meeting_status = 0 WHERE is_cancel = 0 AND meeting_status != 2 AND start_date > SYSDATE;
|
|
|
|
|
- //UPDATE meeting_info SET meeting_status = 1 WHERE is_cancel = 0 AND meeting_status != 2 AND start_date <= SYSDATE AND end_date >= SYSDATE;
|
|
|
|
|
- //UPDATE meeting_info SET meeting_status = 2 WHERE is_cancel = 0 AND meeting_status != 2 AND end_date < SYSDATE;
|
|
|
|
|
|
|
+ // UPDATE meeting_info SET meeting_status = 0 WHERE is_cancel = 0 AND meeting_status != 2 AND start_date > SYSDATE;
|
|
|
|
|
+ // UPDATE meeting_info SET meeting_status = 1 WHERE is_cancel = 0 AND meeting_status != 2 AND start_date <= SYSDATE AND end_date >= SYSDATE;
|
|
|
|
|
+ // UPDATE meeting_info SET meeting_status = 2 WHERE is_cancel = 0 AND meeting_status != 2 AND end_date < SYSDATE;
|
|
|
@Override
|
|
@Override
|
|
|
- public void updateMeetingInfoStatus(){
|
|
|
|
|
- //根据使用中的会议id去更新对应会议室的状态
|
|
|
|
|
- //更新会议室使用状态为 1-使用中
|
|
|
|
|
|
|
+ public void updateMeetingInfoStatus() {
|
|
|
|
|
+ // 根据使用中的会议id去更新对应会议室的状态
|
|
|
|
|
+ // 更新会议室使用状态为 1-使用中
|
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
|
- queryWrapper.eq(MeetingInfo::getIsCancel,0)
|
|
|
|
|
- .ne(MeetingInfo::getMeetingStatus,2)
|
|
|
|
|
- .le(MeetingInfo::getStartDate,LocalDateTime.now())
|
|
|
|
|
- .ge(MeetingInfo::getEndDate,LocalDateTime.now());
|
|
|
|
|
|
|
+ queryWrapper.eq(MeetingInfo::getIsCancel, 0)
|
|
|
|
|
+ .ne(MeetingInfo::getMeetingStatus, 2)
|
|
|
|
|
+ .le(MeetingInfo::getStartDate, LocalDateTime.now())
|
|
|
|
|
+ .ge(MeetingInfo::getEndDate, LocalDateTime.now());
|
|
|
List<MeetingInfo> list = this.list(queryWrapper);
|
|
List<MeetingInfo> list = this.list(queryWrapper);
|
|
|
Set<Long> roomIdList = new HashSet<>();
|
|
Set<Long> roomIdList = new HashSet<>();
|
|
|
- if(list.size() > 0){
|
|
|
|
|
|
|
+ if (list.size() > 0) {
|
|
|
for (int i = 0; i < list.size(); i++) {
|
|
for (int i = 0; i < list.size(); i++) {
|
|
|
roomIdList.add(list.get(i).getRoomId());
|
|
roomIdList.add(list.get(i).getRoomId());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
meetingRoomRepository.updateMeetingRoomStatusOnUse(roomIdList);
|
|
meetingRoomRepository.updateMeetingRoomStatusOnUse(roomIdList);
|
|
|
- //更新将会议室使用状态恢复为 0-未使用
|
|
|
|
|
|
|
+ // 更新将会议室使用状态恢复为 0-未使用
|
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper1 = Wrappers.lambdaQuery();
|
|
LambdaQueryWrapper<MeetingInfo> queryWrapper1 = Wrappers.lambdaQuery();
|
|
|
- queryWrapper1.eq(MeetingInfo::getIsCancel,0)
|
|
|
|
|
- .ne(MeetingInfo::getMeetingStatus,2)
|
|
|
|
|
- .lt(MeetingInfo::getEndDate,LocalDateTime.now());
|
|
|
|
|
|
|
+ queryWrapper1.eq(MeetingInfo::getIsCancel, 0)
|
|
|
|
|
+ .ne(MeetingInfo::getMeetingStatus, 2)
|
|
|
|
|
+ .lt(MeetingInfo::getEndDate, LocalDateTime.now());
|
|
|
List<MeetingInfo> list1 = this.list(queryWrapper1);
|
|
List<MeetingInfo> list1 = this.list(queryWrapper1);
|
|
|
Set<Long> roomIdList1 = new HashSet<>();
|
|
Set<Long> roomIdList1 = new HashSet<>();
|
|
|
- if(list1.size() > 0){
|
|
|
|
|
|
|
+ if (list1.size() > 0) {
|
|
|
for (int i = 0; i < list1.size(); i++) {
|
|
for (int i = 0; i < list1.size(); i++) {
|
|
|
- if(!roomIdList.contains(list1.get(i).getRoomId())){
|
|
|
|
|
|
|
+ if (!roomIdList.contains(list1.get(i).getRoomId())) {
|
|
|
roomIdList1.add(list1.get(i).getRoomId());
|
|
roomIdList1.add(list1.get(i).getRoomId());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -566,17 +572,17 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
|
|
|
|
|
|
|
|
|
|
UpdateWrapper<MeetingInfo> updateWrapper = Wrappers.update();
|
|
UpdateWrapper<MeetingInfo> updateWrapper = Wrappers.update();
|
|
|
- updateWrapper.set("meeting_status",1)
|
|
|
|
|
- .eq("is_cancel",0)
|
|
|
|
|
- .ne("meeting_status",2)
|
|
|
|
|
- .le("start_date",LocalDateTime.now())
|
|
|
|
|
- .ge("end_date",LocalDateTime.now());
|
|
|
|
|
|
|
+ updateWrapper.set("meeting_status", 1)
|
|
|
|
|
+ .eq("is_cancel", 0)
|
|
|
|
|
+ .ne("meeting_status", 2)
|
|
|
|
|
+ .le("start_date", LocalDateTime.now())
|
|
|
|
|
+ .ge("end_date", LocalDateTime.now());
|
|
|
this.update(updateWrapper);
|
|
this.update(updateWrapper);
|
|
|
UpdateWrapper<MeetingInfo> updateWrapper1 = Wrappers.update();
|
|
UpdateWrapper<MeetingInfo> updateWrapper1 = Wrappers.update();
|
|
|
- updateWrapper1.set("meeting_status",2)
|
|
|
|
|
- .eq("is_cancel",0)
|
|
|
|
|
- .ne("meeting_status",2)
|
|
|
|
|
- .lt("end_date",LocalDateTime.now());
|
|
|
|
|
|
|
+ updateWrapper1.set("meeting_status", 2)
|
|
|
|
|
+ .eq("is_cancel", 0)
|
|
|
|
|
+ .ne("meeting_status", 2)
|
|
|
|
|
+ .lt("end_date", LocalDateTime.now());
|
|
|
this.update(updateWrapper1);
|
|
this.update(updateWrapper1);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -584,7 +590,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
|
|
|
|
|
if (StringUtils.isNotBlank(resources.getSendType())) {
|
|
if (StringUtils.isNotBlank(resources.getSendType())) {
|
|
|
String[] typeList = resources.getSendType().split(",");
|
|
String[] typeList = resources.getSendType().split(",");
|
|
|
- if(typeList.length > 0){
|
|
|
|
|
|
|
+ if (typeList.length > 0) {
|
|
|
for (int i = 0; i < typeList.length; i++) {
|
|
for (int i = 0; i < typeList.length; i++) {
|
|
|
String sendType = typeList[i];
|
|
String sendType = typeList[i];
|
|
|
|
|
|
|
@@ -595,17 +601,17 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
DefaultProfile profile = DefaultProfile.getProfile("cn-beijing", "LTAI5tH3VvRL5BUkovCokHJX", "SaaWUouNqvcA0C746gcNOH9m6SRYN4");
|
|
DefaultProfile profile = DefaultProfile.getProfile("cn-beijing", "LTAI5tH3VvRL5BUkovCokHJX", "SaaWUouNqvcA0C746gcNOH9m6SRYN4");
|
|
|
IAcsClient client = new DefaultAcsClient(profile);
|
|
IAcsClient client = new DefaultAcsClient(profile);
|
|
|
SendSmsRequest request = new SendSmsRequest();
|
|
SendSmsRequest request = new SendSmsRequest();
|
|
|
- request.setPhoneNumbers(dmUser.getPhonenumber());//接收短信的手机号码
|
|
|
|
|
- request.setSignName("上海永天科技股份有限公司");//短信签名名称
|
|
|
|
|
- request.setTemplateCode("SMS_465362899");//短信模板CODE
|
|
|
|
|
- request.setTemplateParam("{\"meet\":\""+resources.getMeetingName()+"\","+"\"time\":\""+resources.getStartDate()+"\","+
|
|
|
|
|
- "\"room\":\""+resources.getRoomName()+"\"}");
|
|
|
|
|
|
|
+ request.setPhoneNumbers(dmUser.getPhonenumber());// 接收短信的手机号码
|
|
|
|
|
+ request.setSignName("上海永天科技股份有限公司");// 短信签名名称
|
|
|
|
|
+ request.setTemplateCode("SMS_465362899");// 短信模板CODE
|
|
|
|
|
+ request.setTemplateParam("{\"meet\":\"" + resources.getMeetingName() + "\"," + "\"time\":\"" + resources.getStartDate() + "\"," +
|
|
|
|
|
+ "\"room\":\"" + resources.getRoomName() + "\"}");
|
|
|
SendSmsResponse code = client.getAcsResponse(request);
|
|
SendSmsResponse code = client.getAcsResponse(request);
|
|
|
- if(code.getCode() != null && code.getCode().equals("OK")) {
|
|
|
|
|
- //请求成功
|
|
|
|
|
- }else {
|
|
|
|
|
|
|
+ if (code.getCode() != null && code.getCode().equals("OK")) {
|
|
|
|
|
+ // 请求成功
|
|
|
|
|
+ } else {
|
|
|
// throw new BusinessException("发送短信失败");
|
|
// throw new BusinessException("发送短信失败");
|
|
|
- log.info(dmUser.getPhonenumber()+"发送短信失败");
|
|
|
|
|
|
|
+ log.info(dmUser.getPhonenumber() + "发送短信失败");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -704,7 +710,7 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
// }
|
|
// }
|
|
|
|
|
|
|
|
public MeetingInfo toEntity(DmMeetingDto dto) {
|
|
public MeetingInfo toEntity(DmMeetingDto dto) {
|
|
|
- if ( dto == null ) {
|
|
|
|
|
|
|
+ if (dto == null) {
|
|
|
return null;
|
|
return null;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -713,27 +719,27 @@ public class MeetingInfoServiceImpl extends AbstractCrudService<MeetingInfoMappe
|
|
|
dmMeeting.setCreateBy(SecurityUtils.getUsername());
|
|
dmMeeting.setCreateBy(SecurityUtils.getUsername());
|
|
|
dmMeeting.setCreateTime(LocalDateTime.now());
|
|
dmMeeting.setCreateTime(LocalDateTime.now());
|
|
|
dmMeeting.setTenantId(SecurityUtils.getTenantId());
|
|
dmMeeting.setTenantId(SecurityUtils.getTenantId());
|
|
|
- dmMeeting.setMeetingName( dto.getMeetingName() );
|
|
|
|
|
|
|
+ dmMeeting.setMeetingName(dto.getMeetingName());
|
|
|
dmMeeting.setRoomId(dto.getRoomId());
|
|
dmMeeting.setRoomId(dto.getRoomId());
|
|
|
- dmMeeting.setRoomName( dto.getRoomName() );
|
|
|
|
|
- dmMeeting.setMeetingDescribe( dto.getMeetingDescribe() );
|
|
|
|
|
- dmMeeting.setMeetingType( dto.getMeetingType() );
|
|
|
|
|
|
|
+ dmMeeting.setRoomName(dto.getRoomName());
|
|
|
|
|
+ dmMeeting.setMeetingDescribe(dto.getMeetingDescribe());
|
|
|
|
|
+ dmMeeting.setMeetingType(dto.getMeetingType());
|
|
|
dmMeeting.setInitiatorId(dto.getInitiatorUser().getId());
|
|
dmMeeting.setInitiatorId(dto.getInitiatorUser().getId());
|
|
|
- dmMeeting.setStartDate(LocalDateTime.parse(dto.getStartDate(),DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) );
|
|
|
|
|
- dmMeeting.setEndDate(LocalDateTime.parse(dto.getEndDate(),DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) );
|
|
|
|
|
- dmMeeting.setApproveStatus( dto.getApproveStatus() );
|
|
|
|
|
- dmMeeting.setApproveSuggest( dto.getApproveSuggest() );
|
|
|
|
|
- dmMeeting.setActualCount( dto.getActualCount() );
|
|
|
|
|
- dmMeeting.setPlanCount( dto.getPlanCount() );
|
|
|
|
|
- dmMeeting.setIsDelay( dto.getIsDelay() );
|
|
|
|
|
- dmMeeting.setRemark( dto.getRemark() );
|
|
|
|
|
- dmMeeting.setMeetingStatus( dto.getMeetingStatus() );
|
|
|
|
|
- dmMeeting.setTaskId( dto.getTaskId() );
|
|
|
|
|
- dmMeeting.setProcInstId( dto.getProcInstId() );
|
|
|
|
|
- dmMeeting.setIsCancel( dto.getIsCancel() );
|
|
|
|
|
- dmMeeting.setSendType( dto.getSendType() );
|
|
|
|
|
- dmMeeting.setIsApprove( dto.getIsApprove() );
|
|
|
|
|
- dmMeeting.setMeetingMode( dto.getMeetingMode() );
|
|
|
|
|
|
|
+ dmMeeting.setStartDate(LocalDateTime.parse(dto.getStartDate(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
|
|
|
|
+ dmMeeting.setEndDate(LocalDateTime.parse(dto.getEndDate(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
|
|
|
|
+ dmMeeting.setApproveStatus(dto.getApproveStatus());
|
|
|
|
|
+ dmMeeting.setApproveSuggest(dto.getApproveSuggest());
|
|
|
|
|
+ dmMeeting.setActualCount(dto.getActualCount());
|
|
|
|
|
+ dmMeeting.setPlanCount(dto.getPlanCount());
|
|
|
|
|
+ dmMeeting.setIsDelay(dto.getIsDelay());
|
|
|
|
|
+ dmMeeting.setRemark(dto.getRemark());
|
|
|
|
|
+ dmMeeting.setMeetingStatus(dto.getMeetingStatus());
|
|
|
|
|
+ dmMeeting.setTaskId(dto.getTaskId());
|
|
|
|
|
+ dmMeeting.setProcInstId(dto.getProcInstId());
|
|
|
|
|
+ dmMeeting.setIsCancel(dto.getIsCancel());
|
|
|
|
|
+ dmMeeting.setSendType(dto.getSendType());
|
|
|
|
|
+ dmMeeting.setIsApprove(dto.getIsApprove());
|
|
|
|
|
+ dmMeeting.setMeetingMode(dto.getMeetingMode());
|
|
|
|
|
|
|
|
return dmMeeting;
|
|
return dmMeeting;
|
|
|
}
|
|
}
|