package org.jeecg.modules.eam.service.impl;

import org.jeecg.common.constant.CommonConstant;
import org.jeecg.modules.eam.entity.DeductionItem;
import org.jeecg.modules.eam.entity.OperationCertificate;
import org.jeecg.modules.eam.entity.OperationCertificateDetail;
import org.jeecg.modules.eam.mapper.OperationCertificateDetailMapper;
import org.jeecg.modules.eam.mapper.OperationCertificateMapper;
import org.jeecg.modules.eam.service.IDeductionItemService;
import org.jeecg.modules.eam.service.IOperationCertificateService;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

import java.io.Serializable;
import java.util.List;
import java.util.Collection;

/**
 * @Description: 操作证书管理
 * @Author: jeecg-boot
 * @Date: 2023-10-17
 * @Version: V1.0
 */
@Service
public class OperationCertificateServiceImpl extends ServiceImpl<OperationCertificateMapper, OperationCertificate> implements IOperationCertificateService {

    @Autowired
    private OperationCertificateMapper operationCertificateMapper;
    @Autowired
    private OperationCertificateDetailMapper operationCertificateDetailMapper;
    @Autowired
    private IDeductionItemService deductionItemService;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveMain(OperationCertificate operationCertificate, List<OperationCertificateDetail> operationCertificateDetailList) {
//        operationCertificateMapper.insert(operationCertificate);
//        if (operationCertificateDetailList != null && operationCertificateDetailList.size() > 0) {
//            for (OperationCertificateDetail entity : operationCertificateDetailList) {
//                //外键设置
//                entity.setOperationCertificateId(operationCertificate.getId());
//                operationCertificateDetailMapper.insert(entity);
//            }
//        }
        operationCertificateMapper.insert(operationCertificate);
        String equipmentIds = operationCertificate.getEquipmentIds();
        Integer currentCycleScore = operationCertificate.getCurrentCycleScore();
        for (OperationCertificateDetail entity : operationCertificateDetailList) {
            if ("addEquipment".equals(entity.getType()) && !equipmentIds.contains(entity.getEquipmentId())) {
                equipmentIds = equipmentIds + "," + entity.getEquipmentId();
            } else if ("deduction".equals(entity.getType())) {
                String deductionItemId = entity.getDeductionItem();
                Integer deductionScore = deductionItemService.getById(deductionItemId).getDeductionScore();
                currentCycleScore = currentCycleScore - deductionScore;
            }
            //外键设置
            entity.setOperationCertificateId(operationCertificate.getId());
            operationCertificateDetailMapper.insert(entity);

        }
        operationCertificate.setEquipmentIds(equipmentIds);
        if (currentCycleScore <= 0) {
            currentCycleScore = 0;
            // 当分数为0时,设置操作证的状态为禁用
            operationCertificate.setStatus(CommonConstant.STATUS_0);
        }
        operationCertificate.setCurrentCycleScore(currentCycleScore);
        operationCertificateMapper.updateById(operationCertificate);

    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateMain(OperationCertificate operationCertificate, List<OperationCertificateDetail> operationCertificateDetailList) {
//		operationCertificateMapper.updateById(operationCertificate);

        //1.先删除子表数据
//		operationCertificateDetailMapper.deleteByMainId(operationCertificate.getId());

//		//2.子表数据重新插入
//		if(operationCertificateDetailList!=null && operationCertificateDetailList.size()>0) {
//			for(OperationCertificateDetail entity:operationCertificateDetailList) {
//				//外键设置
//				entity.setOperationCertificateId(operationCertificate.getId());
//				operationCertificateDetailMapper.insert(entity);
//			}
//		}
        // 新增设备更新主表的equipmentIds字段，新增扣分则根据扣分项更新当前分数，分数为0时候禁用操作证
        String equipmentIds = operationCertificate.getEquipmentIds();
        Integer currentCycleScore = operationCertificate.getCurrentCycleScore();
        for (OperationCertificateDetail entity : operationCertificateDetailList) {
            if ("addEquipment".equals(entity.getType()) && !equipmentIds.contains(entity.getEquipmentId())) {
                equipmentIds = equipmentIds + "," + entity.getEquipmentId();
            } else if ("deduction".equals(entity.getType())) {
                String deductionItemId = entity.getDeductionItem();
                Integer deductionScore = deductionItemService.getById(deductionItemId).getDeductionScore();
                currentCycleScore = currentCycleScore - deductionScore;
            }
            //外键设置
            entity.setOperationCertificateId(operationCertificate.getId());
            operationCertificateDetailMapper.insert(entity);

        }
        operationCertificate.setEquipmentIds(equipmentIds);
        if (currentCycleScore <= 0) {
            currentCycleScore = 0;
            // 当分数为0时,设置操作证的状态为禁用
            operationCertificate.setStatus(CommonConstant.STATUS_0);
        }
        operationCertificate.setCurrentCycleScore(currentCycleScore);
        operationCertificateMapper.updateById(operationCertificate);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void delMain(String id) {
        operationCertificateDetailMapper.deleteByMainId(id);
        operationCertificateMapper.deleteById(id);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void delBatchMain(Collection<? extends Serializable> idList) {
        for (Serializable id : idList) {
            operationCertificateDetailMapper.deleteByMainId(id.toString());
            operationCertificateMapper.deleteById(id);
        }
    }

}