交通统计审核
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhizhijie
2026-09-10 93ccd040546983c92ecdcd906df81eec67a10ad6 
 traffic-audit-server/src/main/java/com/trafficaudit/dataimport/service/DataImportService.java


@@ -2,7 +2,9 @@




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.trafficaudit.auditengine.entity.AuditResult;


import com.trafficaudit.auditengine.entity.AuditRun;


import com.trafficaudit.auditengine.mapper.AuditResultMapper;


import com.trafficaudit.auditengine.mapper.AuditRunMapper;


import com.trafficaudit.common.util.RegionUtil;


import com.trafficaudit.dataimport.entity.EnergyAuthVehicle;


import com.trafficaudit.dataimport.entity.EnergyVehicleQuarterly;


@@ -56,6 +58,7 @@


import org.apache.poi.ss.usermodel.WorkbookFactory;


import cn.hutool.core.io.IoUtil;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import javax.annotation.Resource;


@@ -142,6 +145,8 @@


    private FreightTurnoverImportMapper freightTurnoverMapper;


    @Resource


    private AuditResultMapper auditResultMapper;


    @Resource


    private AuditRunMapper auditRunMapper;


    @Resource


    private PassengerEnterpriseMonthlyMapper passengerMapper;


    @Resource


@@ -1312,6 +1317,64 @@


        }


    }




    /** 清空指定报表期全部已导入数据与审核结果（含导入批次、审核通过标记），用于整月重导；投资项目主档保留 */


    @Transactional(rollbackFor = Exception.class)


    public Map<String, Object> clearPeriod(String period) {


        if (period == null || !period.matches("\\d{4}-\\d{2}")) {


            throw new IllegalArgumentException("报表期格式不正确，应为 yyyy-MM");


        }


        int dataRows = 0;


        dataRows += h2032Mapper.delete(new LambdaQueryWrapper<H2032EnterpriseMonthly>()


            .eq(H2032EnterpriseMonthly::getReportPeriod, period));


        dataRows += transportAuthMapper.delete(new LambdaQueryWrapper<TransportAuthVehicle>()


            .eq(TransportAuthVehicle::getReportPeriod, period));


        dataRows += trackMileageMapper.delete(new LambdaQueryWrapper<VehicleTrackMileage>()


            .eq(VehicleTrackMileage::getReportPeriod, period));


        dataRows += scaleSplitMapper.delete(new LambdaQueryWrapper<ScaleSplitTransport>()


            .eq(ScaleSplitTransport::getReportPeriod, period));


        dataRows += freightTurnoverMapper.delete(new LambdaQueryWrapper<FreightTurnoverImport>()


            .eq(FreightTurnoverImport::getReportPeriod, period));


        dataRows += passengerMapper.delete(new LambdaQueryWrapper<PassengerEnterpriseMonthly>()


            .eq(PassengerEnterpriseMonthly::getReportPeriod, period));


        dataRows += passengerIndividualMapper.delete(new LambdaQueryWrapper<PassengerIndividualMonthly>()


            .eq(PassengerIndividualMonthly::getReportPeriod, period));


        dataRows += passengerAuthMapper.delete(new LambdaQueryWrapper<PassengerAuthVehicle>()


            .eq(PassengerAuthVehicle::getReportPeriod, period));


        dataRows += energyMapper.delete(new LambdaQueryWrapper<EnergyVehicleQuarterly>()


            .eq(EnergyVehicleQuarterly::getReportPeriod, period));


        dataRows += energyAuthMapper.delete(new LambdaQueryWrapper<EnergyAuthVehicle>()


            .eq(EnergyAuthVehicle::getReportPeriod, period));


        dataRows += investMonthlyMapper.delete(new LambdaQueryWrapper<InvestmentMonthly>()


            .eq(InvestmentMonthly::getReportPeriod, period));


        dataRows += investSystemMapper.delete(new LambdaQueryWrapper<InvestmentSystem>()


            .eq(InvestmentSystem::getReportPeriod, period));


        dataRows += cityBusMapper.delete(new LambdaQueryWrapper<CityBusMonthly>()


            .eq(CityBusMonthly::getReportPeriod, period));


        dataRows += cityTaxiMapper.delete(new LambdaQueryWrapper<CityTaxiMonthly>()


            .eq(CityTaxiMonthly::getReportPeriod, period));


        dataRows += cityTaxiAuthMapper.delete(new LambdaQueryWrapper<CityTaxiAuth>()


            .eq(CityTaxiAuth::getReportPeriod, period));


        dataRows += wycTotalMapper.delete(new LambdaQueryWrapper<WycTotalMonthly>()


            .eq(WycTotalMonthly::getReportPeriod, period));


        dataRows += wycOrderMapper.delete(new LambdaQueryWrapper<WycOrderMonthly>()


            .eq(WycOrderMonthly::getReportPeriod, period));


        int auditRows = auditResultMapper.delete(new LambdaQueryWrapper<AuditResult>()


            .eq(AuditResult::getReportPeriod, period));


        int auditRunRows = auditRunMapper.delete(new LambdaQueryWrapper<AuditRun>()


            .eq(AuditRun::getReportPeriod, period));


        int batchRows = importBatchMapper.delete(new LambdaQueryWrapper<ImportBatch>()


            .eq(ImportBatch::getReportPeriod, period));


        Map<String, Object> stats = new LinkedHashMap<>();


        stats.put("period", period);


        stats.put("dataRows", dataRows);


        stats.put("auditRows", auditRows);


        stats.put("auditRunRows", auditRunRows);


        stats.put("batchRows", batchRows);


        log.info("清空报表期 {} 完成：业务数据 {} 行、审核结果 {} 行、审核标记 {} 行、导入批次 {} 行",


            period, dataRows, auditRows, auditRunRows, batchRows);


        return stats;


    }




    /** 数据变化后删除指定报表类型指定报表期的审核结果（需重新执行审核） */


    private void deleteRuleResults(String reportType, String period) {


        List<Long> ruleIds = new ArrayList<>();