package com.ots.project.exam.service.impl;
|
|
import com.ots.common.enums.SenderType;
|
import com.ots.common.enums.SendtaskStatus;
|
import com.ots.common.utils.DateUtils;
|
import com.ots.common.utils.text.Convert;
|
import com.ots.framework.config.VueConfig;
|
import com.ots.project.exam.domain.EntTestMember;
|
import com.ots.project.exam.domain.EntTestSendtask;
|
import com.ots.project.exam.dto.SendTask;
|
import com.ots.project.exam.mapper.EntTestSendtaskMapper;
|
import com.ots.project.exam.service.IEntTestSendtaskService;
|
import com.ots.project.system.user.domain.User;
|
import com.ots.project.system.user.service.IUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.text.MessageFormat;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Objects;
|
|
import static com.ots.common.enums.ResponseCode.*;
|
|
/**
|
* 评测邀请发送任务Service业务层处理
|
*
|
* @author ots
|
* @date 2019-12-19
|
*/
|
@Service
|
@Slf4j
|
public class EntTestSendtaskServiceImpl implements IEntTestSendtaskService {
|
@Autowired
|
private EntTestSendtaskMapper entTestSendtaskMapper;
|
|
@Autowired
|
private EntTestMemberServiceImpl entTestMemberService;
|
|
@Autowired
|
private EntTestPackageServiceImpl entTestPackageService;
|
|
@Autowired
|
private VueConfig vueConfig;
|
@Autowired
|
private IUserService userService;
|
|
/**
|
* 查询评测邀请发送任务
|
*
|
* @param id 评测邀请发送任务ID
|
* @return 评测邀请发送任务
|
*/
|
@Override
|
public EntTestSendtask selectEntTestSendtaskById(Long id) {
|
return entTestSendtaskMapper.selectEntTestSendtaskById(id);
|
}
|
|
/**
|
* 查询评测邀请发送任务列表
|
*
|
* @param entTestSendtask 评测邀请发送任务
|
* @return 评测邀请发送任务
|
*/
|
@Override
|
public List<EntTestSendtask> selectEntTestSendtaskList(EntTestSendtask entTestSendtask) {
|
return entTestSendtaskMapper.selectEntTestSendtaskList(entTestSendtask);
|
}
|
|
/**
|
* 新增评测邀请发送任务
|
*
|
* @param entTestSendtask 评测邀请发送任务
|
* @return 结果
|
*/
|
@Override
|
public int insertEntTestSendtask(EntTestSendtask entTestSendtask) {
|
entTestSendtask.setCreateTime(DateUtils.getNowDate());
|
return entTestSendtaskMapper.insertEntTestSendtask(entTestSendtask);
|
}
|
|
/**
|
* 修改评测邀请发送任务
|
*
|
* @param entTestSendtask 评测邀请发送任务
|
* @return 结果
|
*/
|
@Override
|
public int updateEntTestSendtask(EntTestSendtask entTestSendtask) {
|
entTestSendtask.setUpdateTime(DateUtils.getNowDate());
|
return entTestSendtaskMapper.updateEntTestSendtask(entTestSendtask);
|
}
|
|
/**
|
* 删除评测邀请发送任务对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteEntTestSendtaskByIds(String ids) {
|
return entTestSendtaskMapper.deleteEntTestSendtaskByIds(Convert.toStrArray(ids));
|
}
|
|
/**
|
* 删除评测邀请发送任务信息
|
*
|
* @param id 评测邀请发送任务ID
|
* @return 结果
|
*/
|
public int deleteEntTestSendtaskById(Long id) {
|
return entTestSendtaskMapper.deleteEntTestSendtaskById(id);
|
}
|
|
@Override
|
public int insertEntTestSendtaskFromMemberIds(SendTask sendTask) {
|
String memberIds = sendTask.getMemberIds();
|
String[] split = memberIds.split(",");
|
TEST_MEMBER_EMPTY.assertNotEmpty(split);
|
TEST_SEND_ERROR.assertIsTrue(sendTask.getContent().indexOf("{url}")>0);
|
List<String> memberList = Arrays.asList(split);
|
String memberId = memberList.get(0);
|
Long testId = entTestMemberService.selectEntTestMemberById(Long.parseLong(memberId)).getTestId();
|
Long userId = entTestPackageService.selectEntTestPackageById(testId).getUserId();
|
User user = userService.selectUserById(userId);
|
memberList.forEach(p -> {
|
EntTestMember entTestMember = entTestMemberService.selectEntTestMemberById(Long.parseLong(p));
|
EntTestSendtask entTestSendtask = new EntTestSendtask();
|
BeanUtils.copyProperties(sendTask, entTestSendtask);
|
entTestSendtask.setTestId(entTestMember.getTestId());
|
entTestSendtask.setUserId(userId);
|
entTestSendtask.setMemberId(entTestMember.getMemberId());
|
entTestSendtask.setStatus(SendtaskStatus.Untreated.getStatus());
|
if (Objects.equals(entTestSendtask.getType(), SenderType.email.getType())) {
|
entTestSendtask.setAddressee(entTestMember.getMemberEmail());
|
} else if (Objects.equals(entTestSendtask.getType(), SenderType.sms.getType())) {
|
TEL_IS_NOLL.assertNotNull(entTestMember.getMemberPhone());
|
entTestSendtask.setAddressee(entTestMember.getMemberPhone());
|
}
|
//生成链接专属地址
|
String url = vueConfig.getUrl();
|
String token = entTestMember.getToken();
|
String urlNew = MessageFormat.format(url, token);
|
//替换链接地址
|
String content = entTestSendtask.getContent();
|
String replace = content.replace("{url}", urlNew);
|
//替换公司名称
|
String content2 = replace.replace("{Company}",user.getUserName());
|
//替换用户名称
|
String content3 = content2.replace("{FullName}",entTestMember.getMemberName());
|
entTestSendtask.setContent(content3);
|
entTestSendtask.setCreateTime(DateUtils.getNowDate());
|
entTestSendtaskMapper.insertEntTestSendtask(entTestSendtask);
|
});
|
return 1;
|
}
|
}
|
