diff --git a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/excess/CreateAnAuditQueryEnterpriseProcessService.java b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/excess/CreateAnAuditQueryEnterpriseProcessService.java
new file mode 100644
index 0000000..02a9a78
--- /dev/null
+++ b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/data/analyse/task/execute/report/excess/CreateAnAuditQueryEnterpriseProcessService.java
@@ -0,0 +1,71 @@
+package cn.cecep.talroad.data.analyse.task.execute.report.excess;
+
+import cn.cecep.talroad.domain.BMainActionReports;
+import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditFactoryInfo;
+import cn.cecep.talroad.enums.EmlTypeEnums;
+import cn.cecep.talroad.mapper.BMainActionReportsMapper;
+import cn.cecep.talroad.mapper.analysis.SRaActionReportsAuditFactoryInfoMapper;
+import cn.cecep.talroad.util.DateUtil;
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.util.IdUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Service
+@Slf4j
+public class CreateAnAuditQueryEnterpriseProcessService {
+
+    @Autowired
+    private BMainActionReportsMapper mainActionReportsMapper;
+
+    @Resource
+    private SRaActionReportsAuditFactoryInfoMapper sRaActionReportsAuditFactoryInfoMapper;
+
+    public void execute(EmlTypeEnums type) {
+
+        List<SRaActionReportsAuditFactoryInfo> reportsAuditResults = new ArrayList<>();
+
+        LambdaQueryWrapper<BMainActionReports> queryWrapper = new QueryWrapper<BMainActionReports>().lambda()
+                .eq(BMainActionReports::getReportsType, type.getCode())
+                .eq(BMainActionReports::getReportsTime, getLastTime(type));
+        List<BMainActionReports> bMainActionReports = mainActionReportsMapper.selectList(queryWrapper);
+        for (BMainActionReports bMainActionReport : bMainActionReports) {
+            SRaActionReportsAuditFactoryInfo factoryInfo = new SRaActionReportsAuditFactoryInfo();
+            factoryInfo.setId(IdUtil.simpleUUID());
+            factoryInfo.setFactoryId(bMainActionReport.getFactoryId());
+            factoryInfo.setReportId(bMainActionReport.getId());
+            factoryInfo.setCommitTime(new Date());
+            factoryInfo.setAuditStatus(0);
+            factoryInfo.setCreateTime(new Date());
+            factoryInfo.setUpdateTime(new Date());
+            factoryInfo.setCreateBy("Timed tasks");
+            factoryInfo.setUpdateBy("Timed tasks");
+            reportsAuditResults.add(factoryInfo);
+        }
+        if (CollectionUtil.isNotEmpty(reportsAuditResults)) {
+            sRaActionReportsAuditFactoryInfoMapper.insertBatch(reportsAuditResults);
+        }
+
+    }
+
+    private String getLastTime(EmlTypeEnums type) {
+        if (EmlTypeEnums.YEAR.equals(type)) {
+            return DateUtil.getYear(DateUtil.getDayOfYear(-1));
+        } else if (EmlTypeEnums.MONTH.equals(type)) {
+            return DateUtil.getYearMonth(DateUtil.getDayOfMonth(-1));
+        } else if (EmlTypeEnums.QUARTER.equals(type)) {
+            return DateUtil.getYearMonth(DateUtil.getDayOfMonth(-3));
+        } else {
+            return DateUtil.getDay();
+        }
+    }
+}
+
diff --git a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/analysis/SRaActionReportsAuditFactoryInfoMapper.java b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/analysis/SRaActionReportsAuditFactoryInfoMapper.java
index 53d2041..cf527c5 100644
--- a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/analysis/SRaActionReportsAuditFactoryInfoMapper.java
+++ b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/mapper/analysis/SRaActionReportsAuditFactoryInfoMapper.java
@@ -3,6 +3,7 @@ package cn.cecep.talroad.mapper.analysis;
 import cn.cecep.talroad.domain.analysis.SRaActionReportsAuditFactoryInfo;
 import cn.cecep.talroad.domain.vo.AuditRecordLIstVO;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -12,4 +13,6 @@ import java.util.List;
 public interface SRaActionReportsAuditFactoryInfoMapper extends BaseMapper<SRaActionReportsAuditFactoryInfo> {
 
     List<AuditRecordLIstVO> selectUnAuditFactory(String reportId);
+
+    void insertBatch(@Param("addList") List<SRaActionReportsAuditFactoryInfo> i);
 }
diff --git a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/task/ExecuteReportController.java b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/task/ExecuteReportController.java
index 451ae9c..d6f41ec 100644
--- a/szhpt-fixed-task/src/main/java/cn/cecep/talroad/task/ExecuteReportController.java
+++ b/szhpt-fixed-task/src/main/java/cn/cecep/talroad/task/ExecuteReportController.java
@@ -2,6 +2,7 @@ package cn.cecep.talroad.task;
 
 import cn.cecep.talroad.common.core.web.domain.AjaxResults;
 import cn.cecep.talroad.data.analyse.task.execute.report.PollutionDischargeProcessService;
+import cn.cecep.talroad.data.analyse.task.execute.report.excess.CreateAnAuditQueryEnterpriseProcessService;
 import cn.cecep.talroad.data.analyse.task.execute.report.specifications.month.AnomalyAnalysisService;
 import cn.cecep.talroad.data.analyse.task.execute.report.specifications.month.ExhaustExceedingProcessService;
 import cn.cecep.talroad.data.analyse.task.label.ExecuteReportTaskService;
@@ -38,6 +39,8 @@ public class ExecuteReportController {
     @Autowired
     private  ExhaustExceedingProcessService exhaustExceedingProcessService;
 
+    @Autowired
+    private CreateAnAuditQueryEnterpriseProcessService createAnAuditQueryEnterpriseProcessService;
 
 
     /**
@@ -149,5 +152,38 @@ public class ExecuteReportController {
         }
     }
 
+    @GetMapping("/create/audit/enterprise/year")
+    public AjaxResults<Void> createAnAuditQueryEnterpriseYear() {
+        try {
+            createAnAuditQueryEnterpriseProcessService.execute(EmlTypeEnums.YEAR);
+            return AjaxResults.success();
+        } catch (Exception e) {
+            log.error("执行报告规范性审核新建审核查询企业 -- 年 error . 原因:{}", e.getMessage(), e);
+            return AjaxResults.error();
+        }
+    }
+
+    @GetMapping("/create/audit/enterprise/quarter")
+    public AjaxResults<Void> createAnAuditQueryEnterpriseQuarter() {
+        try {
+            createAnAuditQueryEnterpriseProcessService.execute(EmlTypeEnums.QUARTER);
+            return AjaxResults.success();
+        } catch (Exception e) {
+            log.error("执行报告规范性审核新建审核查询企业 -- 年 error . 原因:{}", e.getMessage(), e);
+            return AjaxResults.error();
+        }
+    }
+
+    @GetMapping("/create/audit/enterprise/month")
+    public AjaxResults<Void> createAnAuditQueryEnterpriseMonth() {
+        try {
+            createAnAuditQueryEnterpriseProcessService.execute(EmlTypeEnums.MONTH);
+            return AjaxResults.success();
+        } catch (Exception e) {
+            log.error("执行报告规范性审核新建审核查询企业 -- 年 error . 原因:{}", e.getMessage(), e);
+            return AjaxResults.error();
+        }
+    }
+
 
 }
diff --git a/szhpt-fixed-task/src/main/resources/mapper/talroad/analysis/SRaActionReportsAuditFactoryInfoMapper.xml b/szhpt-fixed-task/src/main/resources/mapper/talroad/analysis/SRaActionReportsAuditFactoryInfoMapper.xml
index 68edf90..11306e4 100644
--- a/szhpt-fixed-task/src/main/resources/mapper/talroad/analysis/SRaActionReportsAuditFactoryInfoMapper.xml
+++ b/szhpt-fixed-task/src/main/resources/mapper/talroad/analysis/SRaActionReportsAuditFactoryInfoMapper.xml
@@ -24,4 +24,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         where factoryInfo.audit_status  = 0 and report.id = #{reportId}
 
     </select>
+
+    <insert id="insertBatch">
+        INSERT INTO s_ra_action_reports_audit_factory_info (id, factory_id, report_id, audit_status, create_time,
+                                                            update_time, create_by, update_by, commit_time) VALUES
+        <foreach collection="addList" separator="," item="item">
+            (#{item.id}, #{item.factoryId}, #{item.reportId}, #{item.auditStatus}, #{item.createTime},
+             #{item.updateTime}, #{item.createBy}, #{item.updateBy}, #{item.commitTime})
+        </foreach>
+    </insert>
 </mapper>