package com.engine.salary.service.impl;

import com.engine.core.impl.Service;
import com.engine.salary.common.YearMonthRange;
import com.engine.salary.entity.salaryacct.po.SalaryAcctTaxAgentPO;
import com.engine.salary.mapper.salaryacct.SalaryAcctTaxAgentMapper;
import com.engine.salary.service.SalaryAcctTaxAgentService;
import com.engine.salary.util.db.MapperProxyFactory;
import org.apache.commons.collections4.CollectionUtils;

import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Objects;

public class SalaryAcctTaxAgentServiceImpl extends Service implements SalaryAcctTaxAgentService {

    private SalaryAcctTaxAgentMapper getSalaryAcctTaxAgentMapper() {
        return MapperProxyFactory.getProxy(SalaryAcctTaxAgentMapper.class);
    }
    @Override
    public List<SalaryAcctTaxAgentPO> listBySalaryAcctRecordIds(Collection<Long> salaryAcctRecordIds) {
        if (CollectionUtils.isEmpty(salaryAcctRecordIds)) {
            return Collections.emptyList();
        }
        return getSalaryAcctTaxAgentMapper().listAcctTaxAgent(salaryAcctRecordIds);
    }

    @Override
    public List<SalaryAcctTaxAgentPO> listByTaxCycleRange(YearMonthRange taxCycleRange) {
        SalaryAcctTaxAgentPO queryWrapper = new SalaryAcctTaxAgentPO();
        if (Objects.nonNull(taxCycleRange.getStartMonth())) {
            queryWrapper.setStartMonth(taxCycleRange.getStartMonth());
        }
        if (Objects.nonNull(taxCycleRange.getEndMonth())) {
            queryWrapper.setEndMonth(taxCycleRange.getEndMonth());
        }
        return getSalaryAcctTaxAgentMapper().listByTaxCycleRange(queryWrapper);
    }

//    @Override
//    public List<SalaryAcctTaxAgentPO> initBySalaryAcctEmployees(List<SalaryAcctEmployeePO> salaryAcctEmployees) {
//        if (CollectionUtils.isEmpty(salaryAcctEmployees)) {
//            return Collections.emptyList();
//        }
//        LocalDateTime now = LocalDateTime.now();
//        Set<String> keySet = Sets.newHashSet();
//        List<SalaryAcctTaxAgentPO> salaryAcctTaxAgents = Lists.newArrayList();
//        for (SalaryAcctEmployeePO salaryAcctEmployee : salaryAcctEmployees) {
//            String key = salaryAcctEmployee.getTaxAgentId() + "-" + salaryAcctEmployee.getTaxCycle() + "-" + salaryAcctEmployee.getIncomeCategory();
//            if (!keySet.contains(key)) {
//                keySet.add(key);
//                SalaryAcctTaxAgentPO salaryAcctTaxAgent = new SalaryAcctTaxAgentPO()
//                        .setId(IdGenerator.generate())
//                        .setSalaryAcctRecordId(salaryAcctEmployee.getSalaryAcctRecordId())
//                        .setIncomeCategory(Util.getIntValue(salaryAcctEmployee.getIncomeCategory()))
//                        .setTaxAgentId(salaryAcctEmployee.getTaxAgentId())
//                        .setSalaryMonth(salaryAcctEmployee.getSalaryMonth())
//                        .setTaxCycle(salaryAcctEmployee.getTaxCycle())
//                        .setCreator(employeeId)
//                        .setTenantKey(tenantKey)
//                        .setDeleteType(DeleteTypeEnum.NOT_DELETED.getValue())
//                        .setCreateTime(now)
//                        .setUpdateTime(now);
//                salaryAcctTaxAgents.add(salaryAcctTaxAgent);
//            }
//        }
//        return salaryAcctTaxAgents;
//    }
//
//    @Override
//    public void batchSave(List<SalaryAcctTaxAgentPO> salaryAcctTaxAgents) {
//        if (CollectionUtils.isNotEmpty(salaryAcctTaxAgents)) {
//            saveBatch(salaryAcctTaxAgents);
//        }
//    }
//
//    @Override
//    public void deleteBySalaryAcctRecordIds(Collection<Long> salaryAcctRecordIds) {
//        if (CollectionUtils.isEmpty(salaryAcctRecordIds)) {
//            return;
//        }
//        new LambdaUpdateChainWrapper<>(getSalaryAcctTaxAgentMapper())
//                .eq(SalaryAcctTaxAgentPO::getTenantKey, tenantKey)
//                .eq(SalaryAcctTaxAgentPO::getDeleteType, DeleteTypeEnum.NOT_DELETED.getValue())
//                .in(SalaryAcctTaxAgentPO::getSalaryAcctRecordId, salaryAcctRecordIds)
//                .set(SalaryAcctTaxAgentPO::getDeleteType, DeleteTypeEnum.DELETED.getValue())
//                .set(SalaryAcctTaxAgentPO::getUpdateTime, LocalDateTime.now())
//                .update();
//    }
}