weaver-hrm-salary/src/com/engine/salary/service/impl/TaxDeclarationDetailServiceImpl.java

package com.engine.salary.service.impl;

import com.engine.common.util.ServiceUtil;
import com.engine.core.impl.Service;
import com.engine.salary.encrypt.taxdeclaration.TaxDeclarationDetailEncrypt;
import com.engine.salary.encrypt.taxdeclaration.TaxDeclarationDetailPOEncrypt;
import com.engine.salary.entity.datacollection.DataCollectionEmployee;
import com.engine.salary.entity.taxdeclaration.bo.TaxDeclarationBO;
import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationDetailListDTO;
import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationLaborListDTO;
import com.engine.salary.entity.taxdeclaration.dto.TaxDeclarationWageListDTO;
import com.engine.salary.entity.taxdeclaration.param.TaxDeclarationDetailListQueryParam;
import com.engine.salary.entity.taxdeclaration.po.TaxDeclarationDetailPO;
import com.engine.salary.mapper.taxdeclaration.TaxDeclarationDetailMapper;
import com.engine.salary.service.SalaryEmployeeService;
import com.engine.salary.service.TaxDeclarationDetailService;
import com.engine.salary.util.db.MapperProxyFactory;
import com.engine.salary.util.page.PageInfo;
import com.google.common.collect.Lists;
import com.mzlion.core.lang.CollectionUtils;

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

/**
 * @description: 个税申报表明细
 * @author: xiajun
 * @modified By: xiajun
 * @date: Created in 1/23/22 4:29 PM
 * @version:v1.0
 */
public class TaxDeclarationDetailServiceImpl extends Service implements TaxDeclarationDetailService {

    private TaxDeclarationDetailMapper getTaxDeclarationDetailMapper() {
        return MapperProxyFactory.getProxy(TaxDeclarationDetailMapper.class);
    }

    private SalaryEmployeeService getSalaryEmployeeService() {
        return (SalaryEmployeeService) ServiceUtil.getService(SalaryEmployeeServiceImpl.class, user);
    }

    /*@Override
    public List<TaxDeclarationDetailPO> listByTaxDeclarationIdAndEmployeeIds(Long taxDeclarationId, Collection<Long> employeeIds, String tenantKey) {
        if (CollectionUtils.isEmpty(employeeIds)) {
            return Collections.emptyList();
        }
        return new LambdaQueryChainWrapper<>(taxDeclarationDetailMapper)
                .eq(TaxDeclarationDetailPO::getTenantKey, tenantKey)
                .eq(TaxDeclarationDetailPO::getDeleteType, 0)
                .eq(TaxDeclarationDetailPO::getTaxDeclarationId, taxDeclarationId)
                .in(TaxDeclarationDetailPO::getEmployeeId, employeeIds)
                .list();
    }

    @Override
    public Page<Long> listPage4EmployeeIdByParam(TaxDeclarationDetailListQueryParam queryParam, String tenantKey) {
        // 分页参数
        Page<Long> page = SalaryPageUtil.buildPage(queryParam.getCurrent(), queryParam.getPageSize());
        // 查询个税申报表明细中的人员（分页）
        return taxDeclarationDetailMapper.listEmployeeId(page, queryParam.getTaxDeclarationId(), tenantKey);
    }
*/
    @Override
    public PageInfo<TaxDeclarationDetailListDTO> listDtoPageByParam(TaxDeclarationDetailListQueryParam queryParam) {
        // 查询个税申报表明细的人员
        List<Long> employeeIdPage = getTaxDeclarationDetailMapper().listEmployeeId(queryParam.getTaxDeclarationId());
        PageInfo<TaxDeclarationDetailListDTO> dtoPage = new PageInfo<TaxDeclarationDetailListDTO>(TaxDeclarationDetailListDTO.class);
        dtoPage.setPageNum(queryParam.getCurrent());
        dtoPage.setPageSize(queryParam.getPageSize());
        if (null == employeeIdPage) {
            return dtoPage;
        }
        if (CollectionUtils.isNotEmpty(employeeIdPage)) {
            // 查询个税申报表明细
            List<TaxDeclarationDetailPO> taxDeclarationDetailPOS = listByTaxDeclarationIdAndEmployeeIds(queryParam.getTaxDeclarationId(), employeeIdPage);
            // 查询人员
            List<DataCollectionEmployee> simpleEmployees = getSalaryEmployeeService().listByIds(employeeIdPage);
            // List<SimpleEmployee> simpleEmployees = hrmCommonEmployeeService.getEmployeeByIds(employeeIdPage.getRecords(), tenantKey);
            // 转换成列表dto
            TaxDeclarationBO.buildDetailListDTO(queryParam.getTaxDeclarationId(), dtoPage, taxDeclarationDetailPOS, simpleEmployees);
        }
        return dtoPage;
    }

    @Override
    public PageInfo<TaxDeclarationLaborListDTO> listDtoPageByParam4Labor(TaxDeclarationDetailListQueryParam queryParam) {
        return null;
    }

    @Override
    public PageInfo<TaxDeclarationWageListDTO> listDtoPageByParam4Wage(TaxDeclarationDetailListQueryParam queryParam) {
        return null;
    }

    @Override
    public void batchSave(Collection<TaxDeclarationDetailPO> taxDeclarationDetailPOS) {
        if (CollectionUtils.isNotEmpty(taxDeclarationDetailPOS)) {
            TaxDeclarationDetailPOEncrypt.decryptTaxDeclarationDetailPOList(taxDeclarationDetailPOS);
            List<List<TaxDeclarationDetailPO>> partition = Lists.partition((List) taxDeclarationDetailPOS, 100);
            partition.forEach(getTaxDeclarationDetailMapper()::batchInsert);
        }
    }

    public List<TaxDeclarationDetailPO> listByTaxDeclarationIdAndEmployeeIds(Long taxDeclarationId, List<Long> employeeIds) {
        if (CollectionUtils.isEmpty(employeeIds)) {
            return Collections.emptyList();
        }

//        return new LambdaQueryChainWrapper<>(taxDeclarationDetailMapper)
//                .eq(TaxDeclarationDetailPO::getTenantKey, tenantKey)
//                .eq(TaxDeclarationDetailPO::getDeleteType, 0)
//                .eq(TaxDeclarationDetailPO::getTaxDeclarationId, taxDeclarationId)
//                .in(TaxDeclarationDetailPO::getEmployeeId, employeeIds)
//                .list();
        List<TaxDeclarationDetailPO> taxDeclarationDetailPOS = getTaxDeclarationDetailMapper().listByTaxDeclarationIdAndEmployeeIds(taxDeclarationId, employeeIds);
        return TaxDeclarationDetailPOEncrypt.decryptTaxDeclarationDetailPOList(taxDeclarationDetailPOS);
    }

    @Override
    public void deleteByTaxDeclarationIds(Collection<Long> taxDeclarationIds) {
        getTaxDeclarationDetailMapper().deleteByTaxDeclarationIds(taxDeclarationIds);
    }
}