package com.ycl.platform.service.impl;
|
|
import com.alibaba.fastjson2.JSONArray;
|
import com.baomidou.mybatisplus.extension.service.IService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ycl.exception.job.TaskException;
|
import com.ycl.platform.base.BaseSelect;
|
import com.ycl.platform.domain.entity.CheckTemplate;
|
import com.ycl.platform.domain.entity.CheckTemplateRule;
|
import com.ycl.platform.domain.query.CheckTemplateQuery;
|
import com.ycl.platform.mapper.CheckTemplateMapper;
|
import com.ycl.platform.mapper.CheckTemplateRuleMapper;
|
import com.ycl.platform.service.ICheckTemplateRuleService;
|
import com.ycl.platform.service.ICheckTemplateService;
|
import com.ycl.system.AjaxResult;
|
import com.ycl.system.Result;
|
import com.ycl.system.domain.SysJob;
|
import com.ycl.system.entity.SysDept;
|
import com.ycl.system.service.ISysDeptService;
|
import com.ycl.system.service.ISysJobService;
|
import com.ycl.utils.SecurityUtils;
|
import constant.CheckConstants;
|
import org.quartz.SchedulerException;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
import utils.DateUtils;
|
import utils.StringUtils;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 考核模板Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2024-04-01
|
*/
|
@Service
|
public class CheckTemplateServiceImpl extends ServiceImpl<CheckTemplateMapper, CheckTemplate> implements ICheckTemplateService {
|
@Autowired
|
private CheckTemplateMapper checkTemplateMapper;
|
@Autowired
|
private ICheckTemplateRuleService templateRuleServicee;
|
@Autowired
|
private CheckTemplateRuleMapper checkTemplateRuleMapper;
|
@Autowired
|
private ISysJobService jobService;
|
|
/**
|
* 查询考核模板
|
*
|
* @param id 考核模板主键
|
* @return 考核模板
|
*/
|
@Override
|
public CheckTemplateQuery selectCheckTemplateById(Integer id) {
|
CheckTemplate checkTemplate = checkTemplateMapper.selectCheckTemplateById(id);
|
CheckTemplateQuery checkTemplateQuery = new CheckTemplateQuery();
|
BeanUtils.copyProperties(checkTemplate, checkTemplateQuery);
|
List<Integer> deptIds = JSONArray.parseArray(checkTemplate.getDeptId(), Integer.class);
|
checkTemplateQuery.setDeptId(deptIds)
|
.setAdjustCoefficient(checkTemplate.getAdjustCoefficient() + "")
|
.setAlarmScore(checkTemplate.getAlarmScore() + "");
|
//查询规则权重
|
List<CheckTemplateRule> templateRuleList = checkTemplateRuleMapper.selectListByTemplateId(checkTemplate.getId());
|
List<Map<String, Object>> list = new ArrayList<>();
|
for (CheckTemplateRule checkTemplateRule : templateRuleList) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("ruleId", checkTemplateRule.getCheckRuleId());
|
map.put("weight", checkTemplateRule.getWeight());
|
list.add(map);
|
}
|
checkTemplateQuery.setRuleFormList(list);
|
|
return checkTemplateQuery;
|
}
|
|
/**
|
* 查询考核模板列表
|
*
|
* @param checkTemplateDTO 考核模板
|
* @return 考核模板
|
*/
|
@Override
|
public List<CheckTemplateQuery> selectCheckTemplateList(CheckTemplateQuery checkTemplateDTO) {
|
List<CheckTemplate> checkTemplates = checkTemplateMapper.selectCheckTemplateList(checkTemplateDTO);
|
List<CheckTemplateQuery> checkTemplateList = new ArrayList<>();
|
//转换部门id为集合,转换alarmScore为string
|
for (CheckTemplate template : checkTemplates) {
|
List<Integer> deptIds = JSONArray.parseArray(template.getDeptId(), Integer.class);
|
CheckTemplateQuery checkTemplateQuery = new CheckTemplateQuery();
|
BeanUtils.copyProperties(template, checkTemplateQuery);
|
checkTemplateQuery.setDeptId(deptIds)
|
.setAdjustCoefficient(template.getAdjustCoefficient() + "");
|
checkTemplateList.add(checkTemplateQuery);
|
}
|
|
return checkTemplateList;
|
}
|
|
/**
|
* 新增考核模板
|
*
|
* @param checkTemplateDTO 考核模板
|
* @return 结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int insertCheckTemplate(CheckTemplateQuery checkTemplateDTO) throws SchedulerException, TaskException {
|
String username = SecurityUtils.getUsername();
|
/** 插入t_template */
|
CheckTemplate checkTemplate = new CheckTemplate();
|
BeanUtils.copyProperties(checkTemplateDTO, checkTemplate);
|
//从小到大排序
|
List<Integer> deptId = checkTemplateDTO.getDeptId();
|
Collections.sort(deptId);
|
Date nowDate = DateUtils.getNowDate();
|
checkTemplate.setDeptId(JSONArray.toJSONString(deptId))
|
.setUpdateUserName(username)
|
.setCreateUserName(username)
|
.setAdjustCoefficient(new BigDecimal(checkTemplateDTO.getAdjustCoefficient() + ""))
|
//不填报警分数---->零分---->不报警
|
.setAlarmScore(new BigDecimal(checkTemplateDTO.getAlarmScore() == null ? "" : checkTemplateDTO.getAlarmScore()));
|
int i = checkTemplateMapper.insertCheckTemplate(checkTemplate);
|
|
//新增定时任务，状态同模板,然后赋值jobId给template
|
SysJob sysJob = addJob(checkTemplateDTO.setId(checkTemplate.getId()));
|
checkTemplate.setJobId(Integer.parseInt(sysJob.getJobId() + ""));
|
checkTemplateMapper.updateCheckTemplate(checkTemplate);
|
|
/** t_template_rule新增权重 */
|
insertTemlpateRule(checkTemplateDTO, checkTemplate);
|
|
return i;
|
}
|
|
/**
|
* 复制考核模板
|
*
|
* @param checkTemplate 考核模板
|
* @return 结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int copyCheckTemplate(CheckTemplateQuery checkTemplateDTO) throws SchedulerException, TaskException {
|
//插入模板表
|
CheckTemplate checkTemplate = checkTemplateMapper.selectCheckTemplateById(checkTemplateDTO.getId());
|
String username = SecurityUtils.getUsername();
|
checkTemplate.setUpdateUserName(username)
|
.setCreateUserName(username)
|
.setStatus(CheckConstants.Status_Stop)
|
.setId(null);
|
int i = checkTemplateMapper.insertCheckTemplate(checkTemplate);
|
//插入template_rule表
|
List<CheckTemplateRule> templateRuleList = checkTemplateRuleMapper.selectListByTemplateId(checkTemplateDTO.getId());
|
templateRuleList.forEach(checkTemplateRule -> checkTemplateRule.setCheckTemplateId(checkTemplate.getId()).setId(null));
|
templateRuleServicee.saveBatch(templateRuleList);
|
//新增定时任务，状态同模板,然后赋值jobId给template
|
SysJob sysJob = addJob(checkTemplateDTO.setId(checkTemplate.getId()));
|
checkTemplate.setJobId(Integer.parseInt(sysJob.getJobId() + ""));
|
checkTemplateMapper.updateCheckTemplate(checkTemplate);
|
return i;
|
}
|
|
/**
|
* 修改考核模板
|
*
|
* @param checkTemplate 考核模板
|
* @return 结果
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public AjaxResult updateCheckTemplate(CheckTemplateQuery checkTemplateDTO) throws SchedulerException, TaskException {
|
CheckTemplate checkTemplate = new CheckTemplate();
|
BeanUtils.copyProperties(checkTemplateDTO, checkTemplate);
|
checkTemplate.setUpdateUserName(SecurityUtils.getUsername());
|
List<Integer> deptId = checkTemplateDTO.getDeptId();
|
Collections.sort(deptId);
|
checkTemplate.setDeptId(JSONArray.toJSONString(deptId))
|
.setAdjustCoefficient(new BigDecimal(checkTemplateDTO.getAdjustCoefficient() + ""));
|
checkTemplateMapper.updateCheckTemplate(checkTemplate);
|
|
/** t_template_rule修改权重 */
|
if (!CollectionUtils.isEmpty(checkTemplateDTO.getRuleFormList())) {
|
//先删除原数据
|
checkTemplateRuleMapper.deleteByTemplateId(checkTemplate.getId());
|
//插入新规则数据
|
insertTemlpateRule(checkTemplateDTO, checkTemplate);
|
}
|
//调整job表里的状态
|
SysJob job = jobService.selectJobById(Long.valueOf(checkTemplateDTO.getJobId()));
|
job.setStatus(checkTemplateDTO.getStatus());
|
jobService.updateJob(job);
|
return AjaxResult.success();
|
}
|
|
/**
|
* 删除考核模板信息
|
*
|
* @param id 考核模板主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteCheckTemplateById(Integer id) throws SchedulerException {
|
CheckTemplate checkTemplate = checkTemplateMapper.selectCheckTemplateById(id);
|
//删除定时任务
|
SysJob job = new SysJob();
|
if (checkTemplate.getJobId() != null) {
|
job.setJobId(Long.valueOf(checkTemplate.getJobId()));
|
job.setJobGroup("CHECK");
|
jobService.deleteJob(job);
|
}
|
return checkTemplateMapper.deleteCheckTemplateById(id);
|
}
|
|
@Override
|
public Result pullList() {
|
List<CheckTemplate> checkTemplates = checkTemplateMapper.selectCheckTemplateList(new CheckTemplateQuery());
|
|
return Result.ok().data(checkTemplates);
|
}
|
|
|
private void insertTemlpateRule(CheckTemplateQuery checkTemplateDTO, CheckTemplate checkTemplate) {
|
List<Map<String, Object>> ruleFormList = checkTemplateDTO.getRuleFormList();
|
if (!CollectionUtils.isEmpty(ruleFormList)) {
|
List<CheckTemplateRule> templateRuleList = new ArrayList<>();
|
for (Map<String, Object> map : ruleFormList) {
|
templateRuleList.add(new CheckTemplateRule()
|
.setCheckRuleId((Integer) map.get("ruleId"))
|
.setCheckTemplateId(checkTemplate.getId())
|
.setWeight(new BigDecimal(map.get("weight").toString())));
|
}
|
//批量插入数据库
|
templateRuleServicee.saveBatch(templateRuleList);
|
}
|
}
|
|
private SysJob addJob(CheckTemplateQuery checkTemplateDTO) throws SchedulerException, TaskException {
|
SysJob job = new SysJob();
|
job.setCreateBy(SecurityUtils.getLoginUser().getUsername());
|
//调用方法名
|
job.setInvokeTarget("checkScoreTask.executeTemplate(" + checkTemplateDTO.getId() + ")");
|
job.setConcurrent("1");
|
job.setStatus(checkTemplateDTO.getStatus());
|
job.setJobGroup("CHECK");
|
job.setCronExpression("0 0 8 * * ?");
|
job.setJobName(checkTemplateDTO.getTemplateName());
|
int i = jobService.insertJob(job);
|
return job;
|
}
|
|
// /**
|
// * 批量删除考核模板
|
// *
|
// * @param ids 需要删除的考核模板主键
|
// * @return 结果
|
// */
|
// @Override
|
// public int deleteCheckTemplateByIds(Integer[] ids) {
|
// return checkTemplateMapper.deleteCheckTemplateByIds(ids);
|
// }
|
}
|
