龚焕茏
2024-04-26 eb806b5ec0bb72536e78c1a7fcffb94bcd24cbbe
ycl-server/src/main/java/com/ycl/platform/service/impl/CheckTemplateServiceImpl.java
@@ -1,97 +1,236 @@
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.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.Result;
import com.ycl.system.entity.SysDept;
import com.ycl.system.service.ISysDeptService;
import com.ycl.utils.SecurityUtils;
import constant.CheckConstants;
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.util.List;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
/**
 * 考核模板Service业务层处理
 *
 *
 * @author ruoyi
 * @date 2024-04-01
 */
@Service
public class CheckTemplateServiceImpl implements ICheckTemplateService
{
public class CheckTemplateServiceImpl extends ServiceImpl<CheckTemplateMapper,CheckTemplate> implements ICheckTemplateService {
    @Autowired
    private CheckTemplateMapper checkTemplateMapper;
    @Autowired
    private ICheckTemplateRuleService templateRuleServicee;
    @Autowired
    private CheckTemplateRuleMapper checkTemplateRuleMapper;
    /**
     * 查询考核模板
     *
     *
     * @param id 考核模板主键
     * @return 考核模板
     */
    @Override
    public CheckTemplate selectCheckTemplateById(Long id)
    {
        return checkTemplateMapper.selectCheckTemplateById(id);
    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);
        //TODO:查询template_rule表中的权重信息。
        return checkTemplateQuery;
    }
    /**
     * 查询考核模板列表
     *
     * @param checkTemplate 考核模板
     *
     * @param checkTemplateDTO 考核模板
     * @return 考核模板
     */
    @Override
    public List<CheckTemplate> selectCheckTemplateList(CheckTemplate checkTemplate)
    {
        return checkTemplateMapper.selectCheckTemplateList(checkTemplate);
    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) {
        //TODO:新增定时任务,状态同模板,然后赋值jobId给template
        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);
        /** t_template_rule新增权重 */
        insertTemlpateRule(checkTemplateDTO, checkTemplate);
        return i;
    }
    /**
     * 复制考核模板
     *
     * @param checkTemplate 考核模板
     * @return 结果
     */
    @Override
    public int insertCheckTemplate(CheckTemplate checkTemplate)
    {
        checkTemplate.setCreateTime(DateUtils.getNowDate());
        return checkTemplateMapper.insertCheckTemplate(checkTemplate);
    @Transactional(rollbackFor = Exception.class)
    public int copyCheckTemplate(CheckTemplateQuery checkTemplateDTO) {
        //TODO:新增定时任务,状态同模板,然后赋值jobId给template
        //插入模板表
        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);
        return i;
    }
    /**
     * 修改考核模板
     *
     *
     * @param checkTemplate 考核模板
     * @return 结果
     */
    @Override
    public int updateCheckTemplate(CheckTemplate checkTemplate)
    {
        checkTemplate.setUpdateTime(DateUtils.getNowDate());
        return checkTemplateMapper.updateCheckTemplate(checkTemplate);
    @Transactional(rollbackFor = Exception.class)
    public int updateCheckTemplate(CheckTemplateQuery checkTemplateDTO) {
        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()+""));
        int i = checkTemplateMapper.updateCheckTemplate(checkTemplate);
        /** t_template_rule修改权重 */
        //先删除原数据
        checkTemplateRuleMapper.deleteByTemplateId(checkTemplate.getId());
        //插入新规则数据
        insertTemlpateRule(checkTemplateDTO, checkTemplate);
        //TODO:判断状态是否修改,调整job表里的状态
        return i;
    }
    /**
     * 批量删除考核模板
     *
     *
     * @param ids 需要删除的考核模板主键
     * @return 结果
     */
    @Override
    public int deleteCheckTemplateByIds(Long[] ids)
    {
    public int deleteCheckTemplateByIds(Integer[] ids) {
        return checkTemplateMapper.deleteCheckTemplateByIds(ids);
    }
    /**
     * 删除考核模板信息
     *
     *
     * @param id 考核模板主键
     * @return 结果
     */
    @Override
    public int deleteCheckTemplateById(Long id)
    {
        return checkTemplateMapper.deleteCheckTemplateById(id);
    public int deleteCheckTemplateById(Integer id) {
        //TODO:删除定时任务
        return checkTemplateMapper.updateCheckTemplate(new CheckTemplate().setId(id)
                .setDeleted(CheckConstants.Delete));
    }
    @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);
        }
    }
}