第二张报表导出0915

chengf

2025-09-15 ebf6117ccea680eae81a91f2fa355ce3a76eb621

 service-job/src/main/java/com/java110/job/importData/adapt/ImportRoomFeeQueueDataAdapt.java

@@ -102,8 +102,13 @@
    public void importData(List<AssetImportLogDetailDto> assetImportLogDetailDtos) {

        for (AssetImportLogDetailDto assetImportLogDetailDto : assetImportLogDetailDtos) {
            try {
                doImportData(assetImportLogDetailDto);
                updateImportLogDetailState(assetImportLogDetailDto.getDetailId());
            } catch (Exception e) {
                e.printStackTrace();
                updateImportLogDetailState(assetImportLogDetailDto.getDetailId(), e);
            }
        }
    }

@@ -113,6 +118,7 @@

        String communityId = importRoomFee.getCommunityId();
        String batchId = importRoomFee.getBatchId();


        doImportRoomCreateFee(importRoomFee, batchId);
        doImportCarCreateFee(importRoomFee, batchId);
@@ -207,7 +213,7 @@
     * @param importRoomFee
     * @param batchId
     */
    private void doImportContractFee(ImportRoomFee importRoomFee, String batchId) {
    public void doImportContractFee(ImportRoomFee importRoomFee, String batchId) {
        if (!FeeDto.PAYER_OBJ_TYPE_CAR.equals(importRoomFee.getObjType())) {
            return;
        }
@@ -221,6 +227,15 @@
            if (StringUtil.isEmpty(tmpImportRoomFee.getCarId())) {
                throw new IllegalArgumentException(tmpImportRoomFee.getCarNum() + "不存在");
            }
        }
        try {
            Integer.parseInt(importRoomFees.get(0).getFeeTypeCd());
        }catch (Exception e){
            DictDto dictDto = new DictDto();
            dictDto.setTableName("pay_fee_config");
            dictDto.setName(importRoomFees.get(0).getFeeTypeCd());
            List<DictDto> dictDtos = iDictV1InnerServiceSMO.queryDicts(dictDto);
            importRoomFees.get(0).setFeeTypeCd(dictDtos.get(0).getStatusCd());
        }
        doCreateFeeAndAttrs(importRoomFees.get(0), batchId);
    }
@@ -257,6 +272,7 @@
        payFeePo.setConfigId(feeConfigDtos.get(0).getConfigId());
        if (FeeDto.PAYER_OBJ_TYPE_CONTRACT.equals(importRoomFee.getObjType())) {
            ContractDto contractDto = new ContractDto();
            contractDto.setCommunityId(importRoomFee.getCommunityId());
            contractDto.setContractCode(importRoomFee.getContractId());
            List<ContractDto> contractDtos = iContractInnerServiceSMO.queryContracts(contractDto);
            if(contractDtos.size() == 0){
@@ -267,11 +283,12 @@
            payFeePo.setContractFee(contractDtos.get(0).getContractId());
//            payFeePo.setCreateTime(importFeeDetailPo.getC);
            ContractPartyaDto contractPartyaDto = new ContractPartyaDto();
            contractPartyaDto.setCommunityId(importRoomFee.getCommunityId());
            if(importRoomFee.getPayerObjName() == null || Objects.equals(importRoomFee.getPayerObjName(), "")){//当没写入主体时
                contractPartyaDto.setPartyaId(contractDtos.get(0).getbPartyaId());
            }
            else{//写入了
                contractPartyaDto.setPartyA(importRoomFee.getPayerObjName());
                contractPartyaDto.setIsPartyA(importRoomFee.getPayerObjName());
            }
            List<ContractPartyaDto> contractPartyaDtos = iContractPartyaInnerServiceSMO.queryContractPartyas(contractPartyaDto);
            if (ListUtil.isNull(contractPartyaDtos)) {
@@ -297,7 +314,6 @@
        FeeDto feeDto = new FeeDto();
        feeDto.setFeeTypeCd(importRoomFee.getFeeTypeCd());
        feeDto.setCommunityId(importRoomFee.getCommunityId());
        String dateStr = importRoomFee.getStartTime();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        try {
            feeDto.setStartTime(sdf.parse(importRoomFee.getStartTime()));
@@ -306,6 +322,10 @@
            throw new RuntimeException("导入起始时间异常");
        }
        feeDto.setPayerObjId(payFeePo.getPayerObjId());
        if (payFeePo.getPayerObjType()!= null && payFeePo.getPayerObjType().equals(FeeDto.PAYER_OBJ_TYPE_CONTRACT)) {
            feeDto.setIsContractFee("O");
            feeDto.setContractFee(payFeePo.getContractFee());
        }
        int feeDtos = feeInnerServiceSMOImpl.getFeeInfoBus(feeDto);
        if(feeDtos > 0){
            throw new IllegalArgumentException("重复的费用");
@@ -317,7 +337,7 @@
        payFeePo.setIncomeObjId(importRoomFee.getStoreId());
        FeeConfigDto payFeePo1 = new FeeConfigDto();
        payFeePo1.setFeeTypeCd(importRoomFee.getFeeTypeCd());
        List<FeeConfigDto> feeConfigDtos1 = payFeeConfigV1InnerServiceSMOImpl.queryPayFeeConfigs(payFeePo1);
//        List<FeeConfigDto> feeConfigDtos1 = payFeeConfigV1InnerServiceSMOImpl.queryPayFeeConfigs(payFeePo1);
        payFeePo.setFeeTypeCd(importRoomFee.getFeeTypeCd());
        payFeePo.setFeeFlag(feeConfigDtos.get(0).getFeeFlag());
        payFeePo.setAmount(importRoomFee.getAmount());
@@ -427,7 +447,11 @@
        PayFeeDetailRefreshFeeMonthDto payFeeDetailRefreshFeeMonthDto = new PayFeeDetailRefreshFeeMonthDto();
        payFeeDetailRefreshFeeMonthDto.setCommunityId(importRoomFee.getCommunityId());
        payFeeDetailRefreshFeeMonthDto.setFeeId(payFeePos.get(0).getFeeId());
        payFeeMonthInnerServiceSMOImpl.doGeneratorOrRefreshFeeMonth(payFeeDetailRefreshFeeMonthDto);
        try {
            payFeeMonthInnerServiceSMOImpl.doGeneratorOrRefreshFeeMonth(payFeeDetailRefreshFeeMonthDto);
        }catch (Exception e){

        }
    }

    private void saveImportFee(ImportRoomFee importRoomFee, PayFeePo payFeePo) {