|
|
@@ -2,8 +2,8 @@ package com.mokamrp.privates.service.impl;
|
|
|
|
|
|
import com.aliyun.oss.OSS;
|
|
|
import com.aliyun.oss.model.PutObjectRequest;
|
|
|
-import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
|
|
-import com.baomidou.mybatisplus.plugins.Page;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.mokamrp.privates.config.OSSConfiguration;
|
|
|
import com.mokamrp.privates.constant.HttpStatus;
|
|
|
import com.mokamrp.privates.entity.GetWorkRoomHandle;
|
|
|
@@ -14,13 +14,12 @@ import com.mokamrp.privates.mapper.vo.WorkContactEmployeeVo;
|
|
|
import com.mokamrp.privates.mapper.vo.WorkContactRoomGroupDataVo;
|
|
|
import com.mokamrp.privates.mapper.vo.WorkRoomVo;
|
|
|
import com.mokamrp.privates.service.WorkRoomService;
|
|
|
-import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.mokamrp.privates.utils.OssFile;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
-
|
|
|
import java.io.ByteArrayInputStream;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.*;
|
|
|
@@ -69,7 +68,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
resMap.put("list", null);
|
|
|
resMap.put("total", 0);
|
|
|
|
|
|
- EntityWrapper<WorkRoom> obj = getWrapper(handle);
|
|
|
+ QueryWrapper<WorkRoom> obj = getWrapper(handle);
|
|
|
|
|
|
Integer total = mapperObj.getVoListTotal(obj);
|
|
|
resMap.put("total", total);
|
|
|
@@ -97,7 +96,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
List<Object> headList = Arrays.asList(head);
|
|
|
Date currentTime = new Date();
|
|
|
|
|
|
- EntityWrapper<WorkRoom> obj = getWrapper(handle);
|
|
|
+ QueryWrapper<WorkRoom> obj = getWrapper(handle);
|
|
|
Integer total = mapperObj.getVoListTotal(obj);
|
|
|
Page<WorkRoom> pageObj = new Page<>(1, total);
|
|
|
List<WorkRoomVo> list = getCommonList(pageObj, obj);
|
|
|
@@ -141,7 +140,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
- private List<WorkRoomVo> getCommonList(Page<WorkRoom> pageObj, EntityWrapper<WorkRoom> room) {
|
|
|
+ private List<WorkRoomVo> getCommonList(Page<WorkRoom> pageObj, QueryWrapper<WorkRoom> room) {
|
|
|
|
|
|
List<WorkRoomVo> list = mapperObj.getVoList(pageObj, room);
|
|
|
|
|
|
@@ -167,7 +166,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
|
|
|
}
|
|
|
|
|
|
- private EntityWrapper<WorkRoom> getWrapper(GetWorkRoomHandle handle) {
|
|
|
+ private QueryWrapper<WorkRoom> getWrapper(GetWorkRoomHandle handle) {
|
|
|
String name = handle.getName();
|
|
|
Integer corp_id = handle.getCorpId();
|
|
|
String start_create_time = handle.getStartCreateTime();
|
|
|
@@ -178,7 +177,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
List tag_id = handle.getTagId();
|
|
|
List<Integer> authCorpIds = handle.getAuthCorpIds();
|
|
|
|
|
|
- EntityWrapper<WorkRoom> obj = new EntityWrapper<WorkRoom>();
|
|
|
+ QueryWrapper<WorkRoom> obj = new QueryWrapper<WorkRoom>();
|
|
|
|
|
|
obj.in("a.corp_id", authCorpIds);
|
|
|
|
|
|
@@ -232,7 +231,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
|
|
|
//3-绑定插入但是要检测已经存在的
|
|
|
|
|
|
- EntityWrapper<RoomTag> obj = new EntityWrapper<RoomTag>();
|
|
|
+ QueryWrapper<RoomTag> obj = new QueryWrapper<RoomTag>();
|
|
|
obj.in("id", ids);
|
|
|
RoomTag roomTagObj;
|
|
|
|
|
|
@@ -240,7 +239,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
for (Integer id : ids) {
|
|
|
for (Integer tagId : tagIds) {
|
|
|
//检测是否已经存在
|
|
|
- obj = new EntityWrapper<RoomTag>();
|
|
|
+ obj = new QueryWrapper<RoomTag>();
|
|
|
obj.eq("room_id", id);
|
|
|
obj.eq("tag_id", tagId);
|
|
|
|
|
|
@@ -269,7 +268,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
|
|
|
//3-绑定插入但是要检测已经存在的
|
|
|
//roomTagMapperObj.
|
|
|
- EntityWrapper<RoomTag> obj = new EntityWrapper<RoomTag>();
|
|
|
+ QueryWrapper<RoomTag> obj = new QueryWrapper<RoomTag>();
|
|
|
obj.in("id", ids);
|
|
|
RoomTag roomTagObj;
|
|
|
|
|
|
@@ -277,7 +276,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
for (Integer id : ids) {
|
|
|
for (Integer tagId : tagIds) {
|
|
|
//检测是否已经存在
|
|
|
- obj = new EntityWrapper<RoomTag>();
|
|
|
+ obj = new QueryWrapper<RoomTag>();
|
|
|
obj.eq("room_id", id);
|
|
|
obj.eq("tag_id", tagId);
|
|
|
if (roomTagMapperObj.selectCount(obj) >= 0) {//插入
|
|
|
@@ -291,7 +290,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
|
|
|
private Object checkOption(Integer[] ids, Integer[] tagIds) {
|
|
|
//1-先查room是否存在
|
|
|
- EntityWrapper<WorkRoom> obj = new EntityWrapper<WorkRoom>();
|
|
|
+ QueryWrapper<WorkRoom> obj = new QueryWrapper<WorkRoom>();
|
|
|
obj.in("id", ids);
|
|
|
|
|
|
Integer total = mapperObj.selectCount(obj);
|
|
|
@@ -300,7 +299,7 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
}
|
|
|
|
|
|
//2-tag是否都存在
|
|
|
- EntityWrapper<Tag> tagWrapper = new EntityWrapper<Tag>();
|
|
|
+ QueryWrapper<Tag> tagWrapper = new QueryWrapper<Tag>();
|
|
|
tagWrapper.in("id", tagIds);
|
|
|
Integer tagTotal = tagMapperObj.selectCount(tagWrapper);
|
|
|
|
|
|
@@ -317,26 +316,26 @@ public class WorkRoomServiceImpl extends ServiceImpl<WorkRoomMapper, WorkRoom> i
|
|
|
String todayEndDate = (new SimpleDateFormat("yyyy-MM-dd 23:59:59")).format(new Date());
|
|
|
|
|
|
//获取数据 群人数 ,当日新增,当日离开
|
|
|
- EntityWrapper<WorkContactRoom> contactRoomEntityWrapperTotal = new EntityWrapper<WorkContactRoom>();
|
|
|
- EntityWrapper<WorkContactRoom> contactRoomEntityWrapperTodayAdd = new EntityWrapper<WorkContactRoom>();
|
|
|
- EntityWrapper<WorkContactRoom> contactRoomEntityWrapperTodayLeft = new EntityWrapper<WorkContactRoom>();
|
|
|
- contactRoomEntityWrapperTotal.in("room_id", ids);
|
|
|
- contactRoomEntityWrapperTotal.eq("status", 1);
|
|
|
-
|
|
|
- contactRoomEntityWrapperTodayAdd.in("room_id", ids);
|
|
|
- contactRoomEntityWrapperTodayAdd.eq("status", 1);
|
|
|
- contactRoomEntityWrapperTodayAdd.le("join_time", todayEndDate);
|
|
|
- contactRoomEntityWrapperTodayAdd.ge("join_time", todayStartDate);//大于
|
|
|
-
|
|
|
-
|
|
|
- contactRoomEntityWrapperTodayLeft.in("room_id", ids);
|
|
|
- contactRoomEntityWrapperTodayLeft.eq("status", 2);
|
|
|
- contactRoomEntityWrapperTodayLeft.le("out_time", todayEndDate);
|
|
|
- contactRoomEntityWrapperTodayLeft.ge("out_time", todayStartDate);//大于
|
|
|
-
|
|
|
- List<WorkContactRoomGroupDataVo> todayLefts = contanctMapperObj.getNum(contactRoomEntityWrapperTodayLeft);
|
|
|
- List<WorkContactRoomGroupDataVo> todayAdds = contanctMapperObj.getNum(contactRoomEntityWrapperTodayAdd);
|
|
|
- List<WorkContactRoomGroupDataVo> totals = contanctMapperObj.getNum(contactRoomEntityWrapperTotal);
|
|
|
+ QueryWrapper<WorkContactRoom> contactRoomQueryWrapperTotal = new QueryWrapper<WorkContactRoom>();
|
|
|
+ QueryWrapper<WorkContactRoom> contactRoomQueryWrapperTodayAdd = new QueryWrapper<WorkContactRoom>();
|
|
|
+ QueryWrapper<WorkContactRoom> contactRoomQueryWrapperTodayLeft = new QueryWrapper<WorkContactRoom>();
|
|
|
+ contactRoomQueryWrapperTotal.in("room_id", ids);
|
|
|
+ contactRoomQueryWrapperTotal.eq("status", 1);
|
|
|
+
|
|
|
+ contactRoomQueryWrapperTodayAdd.in("room_id", ids);
|
|
|
+ contactRoomQueryWrapperTodayAdd.eq("status", 1);
|
|
|
+ contactRoomQueryWrapperTodayAdd.le("join_time", todayEndDate);
|
|
|
+ contactRoomQueryWrapperTodayAdd.ge("join_time", todayStartDate);//大于
|
|
|
+
|
|
|
+
|
|
|
+ contactRoomQueryWrapperTodayLeft.in("room_id", ids);
|
|
|
+ contactRoomQueryWrapperTodayLeft.eq("status", 2);
|
|
|
+ contactRoomQueryWrapperTodayLeft.le("out_time", todayEndDate);
|
|
|
+ contactRoomQueryWrapperTodayLeft.ge("out_time", todayStartDate);//大于
|
|
|
+
|
|
|
+ List<WorkContactRoomGroupDataVo> todayLefts = contanctMapperObj.getNum(contactRoomQueryWrapperTodayLeft);
|
|
|
+ List<WorkContactRoomGroupDataVo> todayAdds = contanctMapperObj.getNum(contactRoomQueryWrapperTodayAdd);
|
|
|
+ List<WorkContactRoomGroupDataVo> totals = contanctMapperObj.getNum(contactRoomQueryWrapperTotal);
|
|
|
|
|
|
|
|
|
HashMap<Integer, HashMap<String, Integer>> dataById =
|