|
@@ -17,12 +17,12 @@ import com.zd.laboratory.domain.LabGradeManageRuleUser;
|
|
|
import com.zd.laboratory.domain.LabMessageDynamic;
|
|
import com.zd.laboratory.domain.LabMessageDynamic;
|
|
|
import com.zd.laboratory.domain.vo.LabManageWorkChartVo;
|
|
import com.zd.laboratory.domain.vo.LabManageWorkChartVo;
|
|
|
import com.zd.laboratory.mapper.*;
|
|
import com.zd.laboratory.mapper.*;
|
|
|
-import com.zd.laboratory.mqtt.constants.MqttConstants;
|
|
|
|
|
import com.zd.laboratory.mqtt.entiy.MessageBody;
|
|
import com.zd.laboratory.mqtt.entiy.MessageBody;
|
|
|
import com.zd.laboratory.mqtt.service.impl.CommonSend;
|
|
import com.zd.laboratory.mqtt.service.impl.CommonSend;
|
|
|
import com.zd.laboratory.service.ILabGradeManageRecordService;
|
|
import com.zd.laboratory.service.ILabGradeManageRecordService;
|
|
|
import com.zd.laboratory.service.ILabSubjectService;
|
|
import com.zd.laboratory.service.ILabSubjectService;
|
|
|
import com.zd.laboratory.utils.word.WordUtils;
|
|
import com.zd.laboratory.utils.word.WordUtils;
|
|
|
|
|
+import com.zd.model.constant.MqttConstants;
|
|
|
import com.zd.model.domain.R;
|
|
import com.zd.model.domain.R;
|
|
|
import com.zd.model.domain.per.PerPrefix;
|
|
import com.zd.model.domain.per.PerPrefix;
|
|
|
import com.zd.model.entity.SysDept;
|
|
import com.zd.model.entity.SysDept;
|
|
@@ -34,7 +34,6 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
-
|
|
|
|
|
import javax.validation.constraints.NotNull;
|
|
import javax.validation.constraints.NotNull;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
@@ -90,37 +89,36 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
labGradeManageRecord.setDetail(labGradeManageRecordDetailMapper.selectLabGradeManageRecordDetailByRecordId(id));
|
|
labGradeManageRecord.setDetail(labGradeManageRecordDetailMapper.selectLabGradeManageRecordDetailByRecordId(id));
|
|
|
// 列出规则制定的所有人员- 沙士比鸭
|
|
// 列出规则制定的所有人员- 沙士比鸭
|
|
|
- if(labGradeManageRecord.getStatus() == 0){
|
|
|
|
|
|
|
+ if (labGradeManageRecord.getStatus() == 0) {
|
|
|
LabGradeManageRuleUser ruleUser = labGradeManageRuleUserMapper.selectLabGradeManageRuleUserById(labGradeManageRecord.getRuleUserId());
|
|
LabGradeManageRuleUser ruleUser = labGradeManageRuleUserMapper.selectLabGradeManageRuleUserById(labGradeManageRecord.getRuleUserId());
|
|
|
- if(StringUtils.isNull(ruleUser)){
|
|
|
|
|
- throw new ServiceException("管控工作已失效或被删除!",504);
|
|
|
|
|
|
|
+ if (StringUtils.isNull(ruleUser)) {
|
|
|
|
|
+ throw new ServiceException("管控工作已失效或被删除!", 504);
|
|
|
}
|
|
}
|
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
|
|
|
|
|
|
List<Long> users = new ArrayList<>();
|
|
List<Long> users = new ArrayList<>();
|
|
|
- if(ruleUser.getType() == 3){
|
|
|
|
|
- users.addAll( Arrays.asList(ruleUser.getUserIds() .split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList()));
|
|
|
|
|
- }else if(ruleUser.getType() == 1){
|
|
|
|
|
|
|
+ if (ruleUser.getType() == 3) {
|
|
|
|
|
+ users.addAll(Arrays.asList(ruleUser.getUserIds().split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList()));
|
|
|
|
|
+ } else if (ruleUser.getType() == 1) {
|
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
users.add(d.get("adminId"));
|
|
users.add(d.get("adminId"));
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 2){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 2) {
|
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
users.add(d.get("userId"));
|
|
users.add(d.get("userId"));
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 4){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 4) {
|
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
users.add(d.get("userId"));
|
|
users.add(d.get("userId"));
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
|
- if(users.size() > 0){
|
|
|
|
|
|
|
+ if (users.size() > 0) {
|
|
|
labGradeManageRecord.setAllUserName(labGradeManageRuleUserMapper.selectUserNameByUserIds(users));
|
|
labGradeManageRecord.setAllUserName(labGradeManageRuleUserMapper.selectUserNameByUserIds(users));
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
return labGradeManageRecord;
|
|
return labGradeManageRecord;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -131,7 +129,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
* @return 管控执行记录
|
|
* @return 管控执行记录
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
- @DataScope(deptAlias = "d" , userAlias = "u" , permi = PerPrefix.LABORATORY_GRADEMANAGERECORD)
|
|
|
|
|
|
|
+ @DataScope(deptAlias = "d", userAlias = "u", permi = PerPrefix.LABORATORY_GRADEMANAGERECORD)
|
|
|
public List<LabGradeManageRecord> selectLabGradeManageRecordList(LabGradeManageRecord labGradeManageRecord) {
|
|
public List<LabGradeManageRecord> selectLabGradeManageRecordList(LabGradeManageRecord labGradeManageRecord) {
|
|
|
return labGradeManageRecordMapper.selectLabGradeManageRecordList(labGradeManageRecord);
|
|
return labGradeManageRecordMapper.selectLabGradeManageRecordList(labGradeManageRecord);
|
|
|
}
|
|
}
|
|
@@ -174,11 +172,10 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
LabGradeManageRecord record = new LabGradeManageRecord();
|
|
LabGradeManageRecord record = new LabGradeManageRecord();
|
|
|
record.setJoinUserId(SecurityUtils.getUserId());
|
|
record.setJoinUserId(SecurityUtils.getUserId());
|
|
|
record.setStatus(0);
|
|
record.setStatus(0);
|
|
|
- if(labGradeManageRecordMapper.selectLabGradeManageRecordList(record).size() == 0){
|
|
|
|
|
|
|
+ if (labGradeManageRecordMapper.selectLabGradeManageRecordList(record).size() == 0) {
|
|
|
// 1 新工作通知, 2 已过期工作通知, 21 关闭已过期通知
|
|
// 1 新工作通知, 2 已过期工作通知, 21 关闭已过期通知
|
|
|
- commonSend.send(MqttConstants.LAB_MANAGE_WORK+SecurityUtils.getUserId(), new MessageBody("您已过期的管控工作已全部完成。", 21));
|
|
|
|
|
|
|
+ commonSend.send(MqttConstants.TOPIC_LAB_MANAGE_WORK + SecurityUtils.getUserId(), new MessageBody("您已过期的管控工作已全部完成。", 21));
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
return labGradeManageRecord;
|
|
return labGradeManageRecord;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -229,7 +226,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
List<Long> ruleIds = manageRuleUserList.stream().map(LabGradeManageRuleUser::getGradeManageRuleId).collect(Collectors.toList());
|
|
List<Long> ruleIds = manageRuleUserList.stream().map(LabGradeManageRuleUser::getGradeManageRuleId).collect(Collectors.toList());
|
|
|
|
|
|
|
|
- if(CollectionUtils.isNotEmpty(ruleIds)){
|
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(ruleIds)) {
|
|
|
|
|
|
|
|
List<LabGradeManageRecord> insertRecordList = new ArrayList<>();
|
|
List<LabGradeManageRecord> insertRecordList = new ArrayList<>();
|
|
|
|
|
|
|
@@ -245,15 +242,15 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
// 2.7 获取实验室方式变动- 此处要修改
|
|
// 2.7 获取实验室方式变动- 此处要修改
|
|
|
//LabGradeManage manage = labGradeManageMapper.selectLabGradeManageById(ruleUser.getGradeManageId());
|
|
//LabGradeManage manage = labGradeManageMapper.selectLabGradeManageById(ruleUser.getGradeManageId());
|
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
|
- if(subIds.size() == 0){
|
|
|
|
|
|
|
+ if (subIds.size() == 0) {
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
|
for (Long subId : subIds) {
|
|
for (Long subId : subIds) {
|
|
|
- if(ruleUser.getIsAll() == 0){
|
|
|
|
|
|
|
+ if (ruleUser.getIsAll() == 0) {
|
|
|
queryRecord.setSubId(subId);
|
|
queryRecord.setSubId(subId);
|
|
|
// 单人执行,有一个人执行,则其他人都不生成过期数据
|
|
// 单人执行,有一个人执行,则其他人都不生成过期数据
|
|
|
executedCount = labGradeManageRecordMapper.selectCountByUserRecord(queryRecord);
|
|
executedCount = labGradeManageRecordMapper.selectCountByUserRecord(queryRecord);
|
|
|
- if(executedCount > 0){
|
|
|
|
|
|
|
+ if (executedCount > 0) {
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -262,8 +259,8 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
//List<Long> users = new ArrayList<>();
|
|
//List<Long> users = new ArrayList<>();
|
|
|
|
|
|
|
|
// String userPosition = null;
|
|
// String userPosition = null;
|
|
|
- if(ruleUser.getType() == 3){
|
|
|
|
|
- List<Long> users = Arrays.asList(ruleUser.getUserIds() .split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList());
|
|
|
|
|
|
|
+ if (ruleUser.getType() == 3) {
|
|
|
|
|
+ List<Long> users = Arrays.asList(ruleUser.getUserIds().split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList());
|
|
|
|
|
|
|
|
// 多个实验室则需要生成多条工作 - 过期未执行记录
|
|
// 多个实验室则需要生成多条工作 - 过期未执行记录
|
|
|
for (Long subId : subIds) {
|
|
for (Long subId : subIds) {
|
|
@@ -296,14 +293,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
// insertRecordList.add(labGradeManageRecord);
|
|
// insertRecordList.add(labGradeManageRecord);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- }else if(ruleUser.getType() == 1){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 1) {
|
|
|
// 查询实验室负责人
|
|
// 查询实验室负责人
|
|
|
// users = labSubjectMapper.selectAdminIds(subIds);
|
|
// users = labSubjectMapper.selectAdminIds(subIds);
|
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
// adminId, id as subId
|
|
// adminId, id as subId
|
|
|
- if(s.equals(d.get("subId")) && d.get("adminId") != null){
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("adminId") != null) {
|
|
|
putUserData(ruleUser, d.get("subId"), d.get("adminId"), insertRecordList, "实验室负责人");
|
|
putUserData(ruleUser, d.get("subId"), d.get("adminId"), insertRecordList, "实验室负责人");
|
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
@@ -325,14 +322,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 2){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 2) {
|
|
|
// 当天进入实验室人员
|
|
// 当天进入实验室人员
|
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
// userId, subject_id as subId
|
|
// userId, subject_id as subId
|
|
|
- if(s.equals(d.get("subId")) && d.get("userId") != null){
|
|
|
|
|
- putUserData(ruleUser,d.get("subId"), d.get("userId"), insertRecordList, "当天进入实验室人员");
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("userId") != null) {
|
|
|
|
|
+ putUserData(ruleUser, d.get("subId"), d.get("userId"), insertRecordList, "当天进入实验室人员");
|
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
|
// labGradeManageRecord.setUserId(-1L);
|
|
// labGradeManageRecord.setUserId(-1L);
|
|
@@ -353,13 +350,13 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 4){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 4) {
|
|
|
// 实验室准入人员
|
|
// 实验室准入人员
|
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
// userId, subject_id as subId
|
|
// userId, subject_id as subId
|
|
|
- if(s.equals(d.get("subId")) && d.get("userId") != null){
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("userId") != null) {
|
|
|
putUserData(ruleUser, d.get("subId"), d.get("userId"), insertRecordList, "实验室准入人员");
|
|
putUserData(ruleUser, d.get("subId"), d.get("userId"), insertRecordList, "实验室准入人员");
|
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
// LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
// labGradeManageRecord.setCreateTime(DateUtils.getNowDate());
|
|
@@ -381,7 +378,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else {
|
|
|
|
|
|
|
+ } else {
|
|
|
logger.error("workArrange: 分级管控周期工作编排数据异常, {}", JSONUtil.toJsonStr(ruleUser));
|
|
logger.error("workArrange: 分级管控周期工作编排数据异常, {}", JSONUtil.toJsonStr(ruleUser));
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
@@ -397,7 +394,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}*/
|
|
}*/
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(insertRecordList.size() > 0){
|
|
|
|
|
|
|
+ if (insertRecordList.size() > 0) {
|
|
|
// 批量存储
|
|
// 批量存储
|
|
|
labGradeManageRecordMapper.insertBatch(insertRecordList);
|
|
labGradeManageRecordMapper.insertBatch(insertRecordList);
|
|
|
}
|
|
}
|
|
@@ -421,14 +418,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
private void putUserData(LabGradeManageRuleUser ruleUser, @NotNull Long subId, @NotNull Long userId,
|
|
private void putUserData(LabGradeManageRuleUser ruleUser, @NotNull Long subId, @NotNull Long userId,
|
|
|
- List<LabGradeManageRecord> insertRecordList, String userPosition){
|
|
|
|
|
|
|
+ List<LabGradeManageRecord> insertRecordList, String userPosition) {
|
|
|
LabGradeManageRecord queryRecord = new LabGradeManageRecord();
|
|
LabGradeManageRecord queryRecord = new LabGradeManageRecord();
|
|
|
queryRecord.setRuleId(ruleUser.getGradeManageRuleId());
|
|
queryRecord.setRuleId(ruleUser.getGradeManageRuleId());
|
|
|
queryRecord.setRuleUserId(ruleUser.getId());
|
|
queryRecord.setRuleUserId(ruleUser.getId());
|
|
|
queryRecord.setCycleCount(ruleUser.getCycleCount());
|
|
queryRecord.setCycleCount(ruleUser.getCycleCount());
|
|
|
queryRecord.setSubId(subId);
|
|
queryRecord.setSubId(subId);
|
|
|
queryRecord.setJoinUserId(userId);
|
|
queryRecord.setJoinUserId(userId);
|
|
|
- if(labGradeManageRecordMapper.selectCountByUserRecord(queryRecord) > 0){
|
|
|
|
|
|
|
+ if (labGradeManageRecordMapper.selectCountByUserRecord(queryRecord) > 0) {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
LabGradeManageRecord labGradeManageRecord = new LabGradeManageRecord();
|
|
@@ -492,9 +489,9 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
messageUsers.add(labMessageUser);
|
|
messageUsers.add(labMessageUser);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
- if(manageRecords.size() > 0){
|
|
|
|
|
|
|
+ if (manageRecords.size() > 0) {
|
|
|
labMessageUserMapper.insertLabMessageUserBatch(messageUsers);
|
|
labMessageUserMapper.insertLabMessageUserBatch(messageUsers);
|
|
|
- }else {
|
|
|
|
|
|
|
+ } else {
|
|
|
throw new ServiceException("消息通知未匹配到关联人员,事务回滚");
|
|
throw new ServiceException("消息通知未匹配到关联人员,事务回滚");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -530,13 +527,13 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
// 查询哪些人需要通知
|
|
// 查询哪些人需要通知
|
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
List<Long> subIds = labGradeManageMapper.selectSubIdsByManageId(ruleUser.getGradeManageId());
|
|
|
- if(ruleUser.getType() == 3){
|
|
|
|
|
- List<Long> users = Arrays.asList(ruleUser.getUserIds() .split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList());
|
|
|
|
|
|
|
+ if (ruleUser.getType() == 3) {
|
|
|
|
|
+ List<Long> users = Arrays.asList(ruleUser.getUserIds().split(",")).stream().map(s -> (Long.parseLong(s.trim()))).collect(Collectors.toList());
|
|
|
|
|
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
users.forEach(u -> {
|
|
users.forEach(u -> {
|
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(u, 2, s, ruleUser.getId());
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(u, 2, s, ruleUser.getId());
|
|
|
- if(count == 0){
|
|
|
|
|
|
|
+ if (count == 0) {
|
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
|
labMessageUser.setJoinUserId(u);
|
|
labMessageUser.setJoinUserId(u);
|
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
@@ -549,14 +546,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 1){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 1) {
|
|
|
// 查询实验室负责人
|
|
// 查询实验室负责人
|
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
List<Map<String, Long>> datas = labSubjectMapper.selectLabAdminByIds(subIds);
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
- if(s.equals(d.get("subId")) && d.get("adminId") != null){
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("adminId") != null) {
|
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("adminId"), 2, d.get("subId"), ruleUser.getId());
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("adminId"), 2, d.get("subId"), ruleUser.getId());
|
|
|
- if(count == 0){
|
|
|
|
|
|
|
+ if (count == 0) {
|
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
|
labMessageUser.setJoinUserId(d.get("adminId"));
|
|
labMessageUser.setJoinUserId(d.get("adminId"));
|
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
@@ -569,14 +566,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 2){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 2) {
|
|
|
// 当天进入实验室人员
|
|
// 当天进入实验室人员
|
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
List<Map<String, Long>> datas = labSubjectAccessRecordMapper.selectJoinUsers(subIds, ruleUser.getUpdateTime());
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
- if(s.equals(d.get("subId")) && d.get("userId") != null){
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("userId") != null) {
|
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("userId"), 2, s, ruleUser.getId());
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("userId"), 2, s, ruleUser.getId());
|
|
|
- if(count == 0){
|
|
|
|
|
|
|
+ if (count == 0) {
|
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
|
labMessageUser.setJoinUserId(d.get("userId"));
|
|
labMessageUser.setJoinUserId(d.get("userId"));
|
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
@@ -589,14 +586,14 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
- }else if(ruleUser.getType() == 4){
|
|
|
|
|
|
|
+ } else if (ruleUser.getType() == 4) {
|
|
|
// 实验室准入人员
|
|
// 实验室准入人员
|
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
List<Map<String, Long>> datas = labSecurityApplyMapper.selectApplyListBySubIds(subIds);
|
|
|
subIds.forEach(s -> {
|
|
subIds.forEach(s -> {
|
|
|
datas.forEach(d -> {
|
|
datas.forEach(d -> {
|
|
|
- if(s.equals(d.get("subId")) && d.get("userId") != null){
|
|
|
|
|
|
|
+ if (s.equals(d.get("subId")) && d.get("userId") != null) {
|
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("userId"), 2, s, ruleUser.getId());
|
|
int count = labGradeManageRecordMapper.selectExecutionsByUserId(d.get("userId"), 2, s, ruleUser.getId());
|
|
|
- if(count == 0){
|
|
|
|
|
|
|
+ if (count == 0) {
|
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
LabMessageUser labMessageUser = new LabMessageUser();
|
|
|
labMessageUser.setJoinUserId(d.get("userId"));
|
|
labMessageUser.setJoinUserId(d.get("userId"));
|
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
labMessageUser.setCreateTime(DateUtils.getNowDate());
|
|
@@ -612,48 +609,48 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(messageUsers.size() > 0){
|
|
|
|
|
|
|
+ if (messageUsers.size() > 0) {
|
|
|
labMessageUserMapper.insertLabMessageUserBatch(messageUsers);
|
|
labMessageUserMapper.insertLabMessageUserBatch(messageUsers);
|
|
|
- }else {
|
|
|
|
|
|
|
+ } else {
|
|
|
throw new ServiceException("消息通知未匹配到关联人员,事务回滚");
|
|
throw new ServiceException("消息通知未匹配到关联人员,事务回滚");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * 分级管控通知类型(执行人-可跳转处理)
|
|
|
|
|
- * 2.执行通知:周,每周五早8点
|
|
|
|
|
- * 3.执行周期:月,提前三天早8点
|
|
|
|
|
- * 4.执行周期:年,季度,半年,提前一周早8点,提前三天早8点 各一次
|
|
|
|
|
|
|
+ * 分级管控通知类型(执行人-可跳转处理)
|
|
|
|
|
+ * 2.执行通知:周,每周五早8点
|
|
|
|
|
+ * 3.执行周期:月,提前三天早8点
|
|
|
|
|
+ * 4.执行周期:年,季度,半年,提前一周早8点,提前三天早8点 各一次
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
public void workExecute() {
|
|
public void workExecute() {
|
|
|
|
|
|
|
|
- if(DateUtil.dayOfWeek(DateUtil.date()) == 6){
|
|
|
|
|
|
|
+ if (DateUtil.dayOfWeek(DateUtil.date()) == 6) {
|
|
|
workExecuteByDay("一周");
|
|
workExecuteByDay("一周");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2){
|
|
|
|
|
|
|
+ if (DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2) {
|
|
|
workExecuteByDay("一月");
|
|
workExecuteByDay("一月");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(DateUtil.month(DateUtil.endOfQuarter(DateUtil.date())) == DateUtil.month(DateUtil.date()) && (
|
|
|
|
|
|
|
+ if (DateUtil.month(DateUtil.endOfQuarter(DateUtil.date())) == DateUtil.month(DateUtil.date()) && (
|
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
|
- DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
- )){
|
|
|
|
|
|
|
+ DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
+ )) {
|
|
|
workExecuteByDay("季度");
|
|
workExecuteByDay("季度");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if((DateUtil.thisMonth() == 6 || DateUtil.thisMonth() == 12) && (
|
|
|
|
|
|
|
+ if ((DateUtil.thisMonth() == 6 || DateUtil.thisMonth() == 12) && (
|
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
|
- DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
- )){
|
|
|
|
|
|
|
+ DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
+ )) {
|
|
|
workExecuteByDay("半年");
|
|
workExecuteByDay("半年");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if(DateUtil.thisMonth() == 12 && (
|
|
|
|
|
|
|
+ if (DateUtil.thisMonth() == 12 && (
|
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 2 ||
|
|
|
- DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
- )){
|
|
|
|
|
|
|
+ DateUtil.dayOfMonth(DateUtil.endOfMonth(DateUtil.date())) - DateUtil.dayOfMonth(DateUtil.date()) == 6
|
|
|
|
|
+ )) {
|
|
|
workExecuteByDay("一年");
|
|
workExecuteByDay("一年");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -666,13 +663,13 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
public void sendManageMsgBySiginUser(Long userId, Long subId) {
|
|
public void sendManageMsgBySiginUser(Long userId, Long subId) {
|
|
|
|
|
|
|
|
try {
|
|
try {
|
|
|
- logger.info("进入实验室人员进行消息通知执行..." + subId + " : "+ userId);
|
|
|
|
|
|
|
+ logger.info("进入实验室人员进行消息通知执行..." + subId + " : " + userId);
|
|
|
List<LabGradeManageRuleUser> manageRuleUserList = labGradeManageRuleUserMapper.selectType2ByAdminSubId(subId);
|
|
List<LabGradeManageRuleUser> manageRuleUserList = labGradeManageRuleUserMapper.selectType2ByAdminSubId(subId);
|
|
|
- if(manageRuleUserList.size() > 0){
|
|
|
|
|
- commonSend.send(MqttConstants.LAB_MANAGE_WORK+userId, new MessageBody("您当前有" + manageRuleUserList.size() + "条管控工作需完成,请点击查看详情。", 1));
|
|
|
|
|
|
|
+ if (manageRuleUserList.size() > 0) {
|
|
|
|
|
+ commonSend.send(MqttConstants.TOPIC_LAB_MANAGE_WORK + userId, new MessageBody("您当前有" + manageRuleUserList.size() + "条管控工作需完成,请点击查看详情。", 1));
|
|
|
logger.info("已执行发送...");
|
|
logger.info("已执行发送...");
|
|
|
}
|
|
}
|
|
|
- }catch (Exception e){
|
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
logger.error("进入实验室人员管控工作通知异常,{}", e.getMessage());
|
|
logger.error("进入实验室人员管控工作通知异常,{}", e.getMessage());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -683,25 +680,25 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
@Override
|
|
@Override
|
|
|
public Map<String, Object> queryManageWorkInfo(LabManageWorkChartVo labManageWorkChartVo) {
|
|
public Map<String, Object> queryManageWorkInfo(LabManageWorkChartVo labManageWorkChartVo) {
|
|
|
labManageWorkChartVo.setStartTime(DateUtil.beginOfWeek(DateUtils.getNowDate()));
|
|
labManageWorkChartVo.setStartTime(DateUtil.beginOfWeek(DateUtils.getNowDate()));
|
|
|
- labManageWorkChartVo.setEndTime( DateUtil.offsetDay(labManageWorkChartVo.getStartTime(), 4));
|
|
|
|
|
|
|
+ labManageWorkChartVo.setEndTime(DateUtil.offsetDay(labManageWorkChartVo.getStartTime(), 4));
|
|
|
|
|
|
|
|
labManageWorkChartVo.setTitle(
|
|
labManageWorkChartVo.setTitle(
|
|
|
DateUtil.format(labManageWorkChartVo.getStartTime(), dateFormat) + "至" + DateUtil.format(labManageWorkChartVo.getEndTime(), dateFormat) +
|
|
DateUtil.format(labManageWorkChartVo.getStartTime(), dateFormat) + "至" + DateUtil.format(labManageWorkChartVo.getEndTime(), dateFormat) +
|
|
|
- "分级管控工作");
|
|
|
|
|
|
|
+ "分级管控工作");
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
map.put("title", labManageWorkChartVo.getTitle());
|
|
map.put("title", labManageWorkChartVo.getTitle());
|
|
|
|
|
|
|
|
List<LabManageWorkChartVo> list;
|
|
List<LabManageWorkChartVo> list;
|
|
|
|
|
|
|
|
- if(labManageWorkChartVo.getType() == 1){
|
|
|
|
|
|
|
+ if (labManageWorkChartVo.getType() == 1) {
|
|
|
list = new ArrayList<>();
|
|
list = new ArrayList<>();
|
|
|
R r = remoteDeptService.getDeptList(new SysDept());
|
|
R r = remoteDeptService.getDeptList(new SysDept());
|
|
|
List<SysDept> deptList = (List<SysDept>) r.getData();
|
|
List<SysDept> deptList = (List<SysDept>) r.getData();
|
|
|
|
|
|
|
|
- LabManageWorkChartVo workChartVo ;
|
|
|
|
|
- if(deptList.size() > 0){
|
|
|
|
|
|
|
+ LabManageWorkChartVo workChartVo;
|
|
|
|
|
+ if (deptList.size() > 0) {
|
|
|
for (SysDept dept : deptList) {
|
|
for (SysDept dept : deptList) {
|
|
|
- if(labManageWorkChartVo.getDeptId() == null || (labManageWorkChartVo.getDeptId() != null && dept.getDeptId().equals(labManageWorkChartVo.getDeptId()))){
|
|
|
|
|
|
|
+ if (labManageWorkChartVo.getDeptId() == null || (labManageWorkChartVo.getDeptId() != null && dept.getDeptId().equals(labManageWorkChartVo.getDeptId()))) {
|
|
|
workChartVo = new LabManageWorkChartVo();
|
|
workChartVo = new LabManageWorkChartVo();
|
|
|
|
|
|
|
|
workChartVo.setDeptId(dept.getDeptId());
|
|
workChartVo.setDeptId(dept.getDeptId());
|
|
@@ -719,7 +716,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- }else {
|
|
|
|
|
|
|
+ } else {
|
|
|
list = labGradeManageRecordMapper.queryManageWorkChartDetailsType2(labManageWorkChartVo);
|
|
list = labGradeManageRecordMapper.queryManageWorkChartDetailsType2(labManageWorkChartVo);
|
|
|
for (LabManageWorkChartVo workChartVo : list) {
|
|
for (LabManageWorkChartVo workChartVo : list) {
|
|
|
|
|
|
|
@@ -743,6 +740,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 分级管控统计 柱状图2.4需求
|
|
* 分级管控统计 柱状图2.4需求
|
|
|
|
|
+ *
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
@@ -782,54 +780,54 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
chart.setParams(labManageWorkChartVo.getParams());
|
|
chart.setParams(labManageWorkChartVo.getParams());
|
|
|
|
|
|
|
|
- chart.setCurrentDateStr( DateUtil.format(chart.getCurrentDate(), dateFormat));
|
|
|
|
|
- chart.setOfWeek("星期" + WordUtils.CN_NUM[(DateUtil.dayOfWeek(chart.getCurrentDate()) -2)]);
|
|
|
|
|
|
|
+ chart.setCurrentDateStr(DateUtil.format(chart.getCurrentDate(), dateFormat));
|
|
|
|
|
+ chart.setOfWeek("星期" + WordUtils.CN_NUM[(DateUtil.dayOfWeek(chart.getCurrentDate()) - 2)]);
|
|
|
|
|
|
|
|
|
|
|
|
|
int compare = DateUtil.compare(chart.getCurrentDate(), now);
|
|
int compare = DateUtil.compare(chart.getCurrentDate(), now);
|
|
|
for (LabManageWorkChartVo date : dates) {
|
|
for (LabManageWorkChartVo date : dates) {
|
|
|
- if(i == 0){
|
|
|
|
|
- if(date.getCurrentDate().equals(chart.getCurrentDate())){
|
|
|
|
|
- if("一天".equals(date.getCycle())){
|
|
|
|
|
|
|
+ if (i == 0) {
|
|
|
|
|
+ if (date.getCurrentDate().equals(chart.getCurrentDate())) {
|
|
|
|
|
+ if ("一天".equals(date.getCycle())) {
|
|
|
chart.setPlanNum(date.getPlanNum());
|
|
chart.setPlanNum(date.getPlanNum());
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- }else if(i == 1){
|
|
|
|
|
- if(date.getCurrentDate().equals(chart.getCurrentDate())){
|
|
|
|
|
- if("一天".equals(date.getCycle())){
|
|
|
|
|
- chart.setPlanNum(date.getPlanNum() + list.get(i-1).getPlanNum());
|
|
|
|
|
|
|
+ } else if (i == 1) {
|
|
|
|
|
+ if (date.getCurrentDate().equals(chart.getCurrentDate())) {
|
|
|
|
|
+ if ("一天".equals(date.getCycle())) {
|
|
|
|
|
+ chart.setPlanNum(date.getPlanNum() + list.get(i - 1).getPlanNum());
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
- }else if(i == 2){
|
|
|
|
|
- if(date.getCurrentDate().equals(chart.getCurrentDate())){
|
|
|
|
|
- if("一天".equals(date.getCycle())){
|
|
|
|
|
- chart.setPlanNum(date.getPlanNum() + list.get(i-1).getPlanNum());
|
|
|
|
|
|
|
+ } else if (i == 2) {
|
|
|
|
|
+ if (date.getCurrentDate().equals(chart.getCurrentDate())) {
|
|
|
|
|
+ if ("一天".equals(date.getCycle())) {
|
|
|
|
|
+ chart.setPlanNum(date.getPlanNum() + list.get(i - 1).getPlanNum());
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
- }else if(i == 3){
|
|
|
|
|
- if("一天".equals(date.getCycle()) && date.getCurrentDate().equals(chart.getCurrentDate())){
|
|
|
|
|
- chart.setPlanNum(date.getPlanNum() + list.get(i-1).getPlanNum());
|
|
|
|
|
|
|
+ } else if (i == 3) {
|
|
|
|
|
+ if ("一天".equals(date.getCycle()) && date.getCurrentDate().equals(chart.getCurrentDate())) {
|
|
|
|
|
+ chart.setPlanNum(date.getPlanNum() + list.get(i - 1).getPlanNum());
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
- }else if(i == 4){
|
|
|
|
|
- if(date.getCurrentDate().equals(chart.getCurrentDate())){
|
|
|
|
|
- if("一天".equals(date.getCycle())){
|
|
|
|
|
- chart.setPlanNum(date.getPlanNum() + list.get(i-1).getPlanNum());
|
|
|
|
|
|
|
+ } else if (i == 4) {
|
|
|
|
|
+ if (date.getCurrentDate().equals(chart.getCurrentDate())) {
|
|
|
|
|
+ if ("一天".equals(date.getCycle())) {
|
|
|
|
|
+ chart.setPlanNum(date.getPlanNum() + list.get(i - 1).getPlanNum());
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
- if("一周".equals(date.getCycle())){
|
|
|
|
|
|
|
+ if ("一周".equals(date.getCycle())) {
|
|
|
chart.setPlanNum(date.getPlanNum() + chart.getPlanNum());
|
|
chart.setPlanNum(date.getPlanNum() + chart.getPlanNum());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 如果今天大于这天, 查询的计划数量永远是0 需要查询记录中已执行和未执行的总和
|
|
// 如果今天大于这天, 查询的计划数量永远是0 需要查询记录中已执行和未执行的总和
|
|
|
- if(compare < 0){
|
|
|
|
|
|
|
+ if (compare < 0) {
|
|
|
chart.setPlanNum(chart.getPlanNum() + labGradeManageRecordMapper.selectAllWorkCountByDate(chart));
|
|
chart.setPlanNum(chart.getPlanNum() + labGradeManageRecordMapper.selectAllWorkCountByDate(chart));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -840,10 +838,10 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
List<List<Object>> datas = new ArrayList<>();
|
|
List<List<Object>> datas = new ArrayList<>();
|
|
|
- List<Object> data ;
|
|
|
|
|
|
|
+ List<Object> data;
|
|
|
for (LabManageWorkChartVo workChartVo : list) {
|
|
for (LabManageWorkChartVo workChartVo : list) {
|
|
|
data = new ArrayList<>();
|
|
data = new ArrayList<>();
|
|
|
- data.add(workChartVo.getOfWeek()+" - " + workChartVo.getCurrentDateStr());
|
|
|
|
|
|
|
+ data.add(workChartVo.getOfWeek() + " - " + workChartVo.getCurrentDateStr());
|
|
|
data.add(workChartVo.getPlanNum());
|
|
data.add(workChartVo.getPlanNum());
|
|
|
data.add(workChartVo.getFinishedNum());
|
|
data.add(workChartVo.getFinishedNum());
|
|
|
|
|
|
|
@@ -854,20 +852,21 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 分级管控统计 详情页列表2.4需求
|
|
* 分级管控统计 详情页列表2.4需求
|
|
|
|
|
+ *
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
public List<LabManageWorkChartVo> queryManageWorkChartDetails(LabManageWorkChartVo labManageWorkChartVo) {
|
|
public List<LabManageWorkChartVo> queryManageWorkChartDetails(LabManageWorkChartVo labManageWorkChartVo) {
|
|
|
|
|
|
|
|
List<LabManageWorkChartVo> list = new ArrayList<>();
|
|
List<LabManageWorkChartVo> list = new ArrayList<>();
|
|
|
- if(labManageWorkChartVo.getType() == 1){
|
|
|
|
|
|
|
+ if (labManageWorkChartVo.getType() == 1) {
|
|
|
R r = remoteDeptService.getDeptList(new SysDept());
|
|
R r = remoteDeptService.getDeptList(new SysDept());
|
|
|
List<SysDept> deptList = (List<SysDept>) r.getData();
|
|
List<SysDept> deptList = (List<SysDept>) r.getData();
|
|
|
|
|
|
|
|
- LabManageWorkChartVo workChartVo ;
|
|
|
|
|
- if(deptList.size() > 0){
|
|
|
|
|
|
|
+ LabManageWorkChartVo workChartVo;
|
|
|
|
|
+ if (deptList.size() > 0) {
|
|
|
for (SysDept dept : deptList) {
|
|
for (SysDept dept : deptList) {
|
|
|
- if(labManageWorkChartVo.getDeptId() == null || (labManageWorkChartVo.getDeptId() != null && dept.getDeptId().equals(labManageWorkChartVo.getDeptId()))){
|
|
|
|
|
|
|
+ if (labManageWorkChartVo.getDeptId() == null || (labManageWorkChartVo.getDeptId() != null && dept.getDeptId().equals(labManageWorkChartVo.getDeptId()))) {
|
|
|
workChartVo = new LabManageWorkChartVo();
|
|
workChartVo = new LabManageWorkChartVo();
|
|
|
|
|
|
|
|
workChartVo.setDeptId(dept.getDeptId());
|
|
workChartVo.setDeptId(dept.getDeptId());
|
|
@@ -885,7 +884,7 @@ public class LabGradeManageRecordServiceImpl implements ILabGradeManageRecordSer
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- }else {
|
|
|
|
|
|
|
+ } else {
|
|
|
list = labGradeManageRecordMapper.queryManageWorkChartDetailsType2(labManageWorkChartVo);
|
|
list = labGradeManageRecordMapper.queryManageWorkChartDetailsType2(labManageWorkChartVo);
|
|
|
|
|
|
|
|
for (LabManageWorkChartVo workChartVo : list) {
|
|
for (LabManageWorkChartVo workChartVo : list) {
|