package com.ots.project.exam.service.impl;
|
import com.ots.common.enums.TestMemberStatusEnum;
|
import com.ots.common.enums.UsageCountEnum;
|
import com.ots.common.exception.BusinessException;
|
import com.ots.common.utils.DateUtils;
|
import com.ots.common.utils.MessageUtils;
|
import com.ots.common.utils.StringUtils;
|
import com.ots.common.utils.text.Convert;
|
import com.ots.project.exam.domain.EntTestMember;
|
import com.ots.project.exam.domain.EntTestPackage;
|
import com.ots.project.exam.domain.SysUserExtend;
|
import com.ots.project.exam.domain.TExamReport;
|
import com.ots.project.exam.mapper.EntTestMemberMapper;
|
import com.ots.project.exam.mapper.EntTestPackageMapper;
|
import com.ots.project.exam.mapper.SysUserExtendMapper;
|
import com.ots.project.exam.mapper.TExamReportMapper;
|
import com.ots.project.exam.service.IEntTestMemberService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
import static com.ots.common.enums.ResponseCode.*;
|
import static com.ots.common.enums.TestMemberStatusEnum.*;
|
|
@Service
|
@Slf4j
|
public class EntTestMemberServiceImpl implements IEntTestMemberService {
|
@Autowired
|
private EntTestMemberMapper entTestMemberMapper;
|
@Autowired
|
private EntTestPackageMapper entTestPackageMapper;
|
@Autowired
|
private SysUserExtendMapper sysUserExtendMapper;
|
@Autowired
|
private TExamReportMapper tReportTemplateMapper;
|
|
@Override
|
public EntTestMember selectEntTestMemberById(Long memberId) {
|
return entTestMemberMapper.selectEntTestMemberById(memberId);
|
}
|
|
@Override
|
public List<EntTestMember> selectEntTestMemberList(EntTestMember entTestMember) {
|
return entTestMemberMapper.selectEntTestMemberList(entTestMember);
|
}
|
@Override
|
public List<EntTestMember> selectEntTestMemberTopList(EntTestMember entTestMember) {
|
return entTestMemberMapper.selectEntTestMemberTopList(entTestMember);
|
}
|
@Override
|
public List<EntTestMember> selectEntTestMemberQueryList(EntTestMember entTestMember) {
|
List<EntTestMember> entTestMembers = entTestMemberMapper.selectEntTestMemberQueryList(entTestMember);
|
|
List<String> collect = entTestMembers.stream().map(p -> String.valueOf(p.getMemberId())).collect(Collectors.toList());
|
if (Objects.isNull(collect)) {
|
return new ArrayList<>();
|
}
|
String[] memberIds = collect.toArray(new String[collect.size()]);
|
if (Objects.isNull(memberIds) || memberIds.length == 0) {
|
return new ArrayList<>();
|
}
|
List<TExamReport> tExamReports = tReportTemplateMapper.selectTReportTemplatesByMemberId(memberIds);
|
|
Map<String, EntTestMember> map = new HashMap();
|
for (EntTestMember testMember : entTestMembers) {
|
map.put(String.valueOf(testMember.getMemberId()), testMember);
|
}
|
for (TExamReport report : tExamReports) {
|
String memberId = String.valueOf(report.getMemberId());
|
if (map.containsKey(memberId)) {
|
EntTestMember testMember = map.get(memberId);
|
testMember.setSendHrEmail(report.getSendHrStatus());
|
testMember.setReportAddress(report.getReportAddress());
|
testMember.setReportId(report.getId());
|
}
|
}
|
return entTestMembers;
|
}
|
@Override
|
public List<EntTestMember> selectEntTestMemberList(Map params) {
|
return entTestMemberMapper.selectEntTestMemberListByMap(params);
|
}
|
|
@Override
|
@Transactional
|
public int insertEntTestMember(EntTestMember entTestMember) {
|
entTestMember.setCreateTime(DateUtils.getNowDate());
|
entTestMember.setToken(UUID.randomUUID().toString());
|
int result = entTestMemberMapper.insertEntTestMember(entTestMember);
|
usageCount(entTestMember, UsageCountEnum.reduce);
|
return result;
|
}
|
|
private void usageCount(EntTestMember entTestMember, UsageCountEnum op) {
|
MISSING_PARAMETERS.assertNotNull(entTestMember.getTestId(), "测试包编码");
|
EntTestPackage entTestPackage = entTestPackageMapper.selectEntTestPackageById(entTestMember.getTestId());
|
ERROR_MESSAGE_CHECK.assertNotNull(entTestPackage, "测试包信息不存在！");
|
SysUserExtend sysUserExtend = sysUserExtendMapper.selectSysUserExtendById(entTestPackage.getUserId());
|
ERROR_MESSAGE_CHECK.assertNotNull(sysUserExtend, "未配置可使用次数！");
|
USR_TIME_ISOVER.assertIsTrue(sysUserExtend.getTestNum() > 0, entTestPackage.getUserId());
|
sysUserExtend.setTestNum(sysUserExtend.getTestNum() + op.getOp());
|
sysUserExtendMapper.updateSysUserExtend(sysUserExtend);
|
}
|
|
@Override
|
@Transactional
|
public int updateEntTestMember(EntTestMember entTestMember) {
|
entTestMember.setUpdateTime(DateUtils.getNowDate());
|
int reslut = entTestMemberMapper.updateEntTestMember(entTestMember);
|
|
List<String> status = Arrays.asList(TestMemberStatusEnum.recover.getCode(), TestMemberStatusEnum.expiryRecovery.getCode());
|
if (status.contains(entTestMember.getStatus())) {
|
usageCount(entTestMember, UsageCountEnum.add);
|
}
|
return reslut;
|
}
|
|
@Override
|
public int deleteEntTestMemberByIds(String ids) {
|
return entTestMemberMapper.deleteEntTestMemberByIds(Convert.toStrArray(ids));
|
}
|
|
public int deleteEntTestMemberById(Long memberId) {
|
return entTestMemberMapper.deleteEntTestMemberById(memberId);
|
}
|
@Override
|
public String importEntTestMember(List<EntTestMember> entTestMemberList, Boolean isUpdateSupport) {
|
if (StringUtils.isNull(entTestMemberList) || entTestMemberList.size() == 0) {
|
throw new BusinessException("Import user data cannot be empty！");
|
}
|
int successNum = 0;
|
int failureNum = 0;
|
StringBuilder successMsg = new StringBuilder();
|
StringBuilder failureMsg = new StringBuilder();
|
for (EntTestMember entTestMember : entTestMemberList) {
|
try {
|
insertEntTestMember(entTestMember);
|
} catch (Exception ex) {
|
failureNum++;
|
successNum++;
|
failureMsg.append("<br/>" + failureNum + "、" + MessageUtils.message("jsp.testPackage.name") + " " + entTestMember.getMemberName() + " " + MessageUtils.message("import.failed") + "：" + ex.getMessage());
|
successMsg.append("<br/>" + successNum + "、" + MessageUtils.message("dataFormatError"));
|
log.error(entTestMember.getMemberName() + "导入失败：{}", ex.getMessage(), ex);
|
continue;
|
}
|
successNum++;
|
successMsg.append("<br/>" + successNum + "、"+ MessageUtils.message("jsp.testPackage.name") +" " + entTestMember.getMemberName() + MessageUtils.message("imported.successfully"));
|
}
|
if (failureNum > 0) {
|
failureMsg.insert(0, MessageUtils.message("import.internationalization.001") + failureNum + MessageUtils.message("import.internationalization.002"));
|
|
} else {
|
successMsg.insert(0, MessageUtils.message("import.internationalization.003") + successNum + MessageUtils.message("import.internationalization.004"));
|
}
|
return successMsg.toString();
|
}
|
public EntTestMember findEntTestMember(String token, List<String> status) {
|
Map paramMap = new HashMap();
|
paramMap.put("token", token);
|
paramMap.put("status", status);
|
return entTestMemberMapper.findEntTestMember(paramMap);
|
}
|
@Override
|
public int updateTestMemberStatus(TestMemberStatusEnum statusEnum, long memberId) {
|
EntTestMember member = selectEntTestMemberById(memberId);
|
member.setStatus(statusEnum.getCode());
|
if (answering == statusEnum) {
|
member.setStartTime(new Date());
|
} else if (completed == statusEnum || timeOut == statusEnum) {
|
member.setEndTime(new Date());
|
}
|
int result = updateEntTestMember(member);
|
return result;
|
}
|
@Override
|
public boolean checkMemberHasReport(List<String> asList, Long testId) {
|
return false;
|
}
|
}
|
