diff --git a/op-api/op-api-system/src/main/java/com/op/system/api/RemoteQualityService.java b/op-api/op-api-system/src/main/java/com/op/system/api/RemoteQualityService.java
index f62f615f..d0e897c1 100644
--- a/op-api/op-api-system/src/main/java/com/op/system/api/RemoteQualityService.java
+++ b/op-api/op-api-system/src/main/java/com/op/system/api/RemoteQualityService.java
@@ -38,4 +38,7 @@ public interface RemoteQualityService {
 
     @PostMapping("/qcIncome/removeDatasource")
     public R removeDatasource(@RequestBody DataSourcePropertyDTO dataSourceProperty);
+
+    @PostMapping("/qcWarehousing/createCPBatchTask")
+    public R createCPBatchTask();
 }
diff --git a/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteQualityFallbackFactory.java b/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteQualityFallbackFactory.java
index 717a9f63..7d6ea765 100644
--- a/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteQualityFallbackFactory.java
+++ b/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteQualityFallbackFactory.java
@@ -52,6 +52,11 @@ public class RemoteQualityFallbackFactory implements FallbackFactory<RemoteQuali
 			public R removeDatasource(DataSourcePropertyDTO dataSourceProperty) {
 				return R.fail("质量数据源移除失败:" + throwable.getMessage());
 			}
+
+			@Override
+			public R createCPBatchTask() {
+				return R.fail("入库检验任务创建失败:" + throwable.getMessage());
+			}
 		};
 	}
 }
diff --git a/op-modules/op-job/src/main/java/com/op/job/task/RyTask.java b/op-modules/op-job/src/main/java/com/op/job/task/RyTask.java
index 394e2fbc..dc37a972 100644
--- a/op-modules/op-job/src/main/java/com/op/job/task/RyTask.java
+++ b/op-modules/op-job/src/main/java/com/op/job/task/RyTask.java
@@ -166,6 +166,12 @@ public class RyTask {
 		logger.info("++质量管理系统+来料检验任务创建+开始++createIncomeBatchTask+++++");
 		remoteQualityService.createIncomeBatchTask();
 	}
+
+	//成品检验任务创建，每3分钟执行一次
+	public void createCPBatchTask(){
+		logger.info("++质量管理系统+成品检验任务创建+开始++createCPBatchTask+++++");
+		remoteQualityService.createCPBatchTask();
+	}
 	/************质量管理系统定时任务结束*****************/
 
 	/************hr 人力基础数据定时任务开始*****************/
diff --git a/op-modules/op-mes/src/main/java/com/op/mes/domain/MesReportWorkConsume.java b/op-modules/op-mes/src/main/java/com/op/mes/domain/MesReportWorkConsume.java
index 10aa4395..56ab9ce0 100644
--- a/op-modules/op-mes/src/main/java/com/op/mes/domain/MesReportWorkConsume.java
+++ b/op-modules/op-mes/src/main/java/com/op/mes/domain/MesReportWorkConsume.java
@@ -112,6 +112,15 @@ public class MesReportWorkConsume extends BaseEntity {
     private String warehouseCode;
     private String warehouseName;
     private String planQuantity;
+    private String machineCode;
+
+    public String getMachineCode() {
+        return machineCode;
+    }
+
+    public void setMachineCode(String machineCode) {
+        this.machineCode = machineCode;
+    }
 
     public String getPlanQuantity() {
         return planQuantity;
diff --git a/op-modules/op-mes/src/main/java/com/op/mes/service/impl/IWCInterfaceServiceImpl.java b/op-modules/op-mes/src/main/java/com/op/mes/service/impl/IWCInterfaceServiceImpl.java
index 83345e77..b5d72ead 100644
--- a/op-modules/op-mes/src/main/java/com/op/mes/service/impl/IWCInterfaceServiceImpl.java
+++ b/op-modules/op-mes/src/main/java/com/op/mes/service/impl/IWCInterfaceServiceImpl.java
@@ -354,6 +354,7 @@ public class IWCInterfaceServiceImpl implements IWCSInterfaceService {
             mesReportWork.setUploadStatus("1");//除了1报工成功的，都需要报工
             mesReportWork.setProdType("prod");
             mesReportWork.setWorkorderCode(workOrders.get(0).getWorkorderCode());
+            mesReportWork.setMachineCode(mesReportWork.getMachineCode());
             MesReportWork sHzWorks = mesReportWorkMapper.getReportWorkHz(mesReportWork);
             if(sHzWorks==null){
                 return R.fail("未查询到一层报工单");
@@ -375,6 +376,7 @@ public class IWCInterfaceServiceImpl implements IWCSInterfaceService {
             mesReportWork.setUploadStatus("1");//除了1报工成功的，都需要报工
             mesReportWork.setProdType("prod");
             mesReportWork.setWorkorderCode(workOrders.get(0).getWorkorderCode());
+            mesReportWork.setMachineCode(mesReportWork.getMachineCode());
             MesReportWork sHzWorks = mesReportWorkMapper.getReportWorkHz(mesReportWork);
             if(sHzWorks==null){
                 return R.fail("未查询到子报工单");
@@ -388,6 +390,7 @@ public class IWCInterfaceServiceImpl implements IWCSInterfaceService {
             if(sapRson.getCode()== 200){
                 //一定是子单报工成功返回后，再母单报工
                 mesReportWork.setWorkorderCode(workOrders.get(1).getWorkorderCode());
+                mesReportWork.setMachineCode(mesReportWork.getMachineCode());
                 MesReportWork pHzWork = mesReportWorkMapper.getReportWorkHz(mesReportWork);
                 if(pHzWork==null){
                     return R.fail("未查询到母报工单");
@@ -416,10 +419,10 @@ public class IWCInterfaceServiceImpl implements IWCSInterfaceService {
             BigDecimal gamng = null;
             for(int n=0;n<workOrders.size();n++){
                 MesReportWork workOrder = workOrders.get(n);
-
                 mesReportWork.setUploadStatus("1");//除了1报工成功的，都需要报工
                 mesReportWork.setProdType("prod");
                 mesReportWork.setWorkorderCode(workOrder.getWorkorderCode());
+                mesReportWork.setMachineCode(mesReportWork.getMachineCode());
                 MesReportWork sHzWorks = mesReportWorkMapper.getReportWorkHz(mesReportWork);
                 if (sHzWorks == null) {
                     return R.fail(workOrder.getWorkorderCode()+"未查询到报工单");
diff --git a/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkConsumeMapper.xml b/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkConsumeMapper.xml
index 0263194d..54a5239e 100644
--- a/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkConsumeMapper.xml
+++ b/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkConsumeMapper.xml
@@ -124,6 +124,9 @@
             and mpd.del_flag = '0'
 		where mrwc.del_flag = '0' and pow.del_flag = '0'
 			and mrwc.workorder_code = #{workorderCode}
+            <if test="machineCode!=''">
+                and pow.workorder_name = #{machineCode}
+            </if>
         order by mrwc.recoil,mrwc.attr1
 	</select>
     <select id="getSonConsumeList" resultType="com.op.mes.domain.MesReportWorkConsume">
diff --git a/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkMapper.xml b/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkMapper.xml
index 226ffd67..8c3eb224 100644
--- a/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkMapper.xml
+++ b/op-modules/op-mes/src/main/resources/mapper/mes/MesReportWorkMapper.xml
@@ -573,6 +573,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			<if test='parentOrder!="0"'>
 				and mrw.parent_order = #{workorderCode}
 			</if>
+			<if test='machineCode!=""'>
+				and mrw.machine_code = #{machineCode}
+			</if>
             order by mrw.batch
 	</select>
 	<select id="getPrepareList" resultType="com.op.mes.domain.MesPrepareDetail">
@@ -614,7 +617,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 				 from
 					 mes_report_work
 				 where upload_status != #{uploadStatus} and prod_type = #{prodType}
-			and workorder_code =  #{workorderCode} and del_flag='0'
+				 and workorder_code =  #{workorderCode} and del_flag='0'
+				 <if test='machineCode!=""'>
+					and machine_code = #{machineCode}
+				 </if>
 				 group by workorder_code,product_code,product_name,remark
 		) mrw
 		left join pro_order_workorder ow on mrw.workorder_code = ow.workorder_code
diff --git a/op-modules/op-quality/src/main/java/com/op/quality/controller/QcCheckTaskWarehousingController.java b/op-modules/op-quality/src/main/java/com/op/quality/controller/QcCheckTaskWarehousingController.java
index f2bcff53..25462d04 100644
--- a/op-modules/op-quality/src/main/java/com/op/quality/controller/QcCheckTaskWarehousingController.java
+++ b/op-modules/op-quality/src/main/java/com/op/quality/controller/QcCheckTaskWarehousingController.java
@@ -7,6 +7,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.op.common.core.domain.R;
 import com.op.common.core.utils.DateUtils;
 import com.op.common.core.utils.bean.BeanUtils;
 import com.op.quality.domain.QcCheckTaskIncome;
@@ -154,4 +155,13 @@ public class QcCheckTaskWarehousingController extends BaseController {
 		List<QcCheckTaskWarehousing> list = qcCheckTaskWarehousingService.getQcListLoc(qcCheckTaskWarehousing);
 		return getDataTable(list);
 	}
+
+	/**
+	 * 生产过程检验：巡检任务生产
+	 **/
+	@PostMapping("/createCPBatchTask")
+	public R createCPBatchTask() {
+		qcCheckTaskWarehousingService.createCPBatchTask();
+		return R.ok();
+	}
 }
diff --git a/op-modules/op-quality/src/main/java/com/op/quality/domain/QcCheckTaskWarehousing.java b/op-modules/op-quality/src/main/java/com/op/quality/domain/QcCheckTaskWarehousing.java
index c30895ec..d1497c14 100644
--- a/op-modules/op-quality/src/main/java/com/op/quality/domain/QcCheckTaskWarehousing.java
+++ b/op-modules/op-quality/src/main/java/com/op/quality/domain/QcCheckTaskWarehousing.java
@@ -176,6 +176,7 @@ public class QcCheckTaskWarehousing extends BaseEntity {
     private BigDecimal aNoOkquality;
     private BigDecimal bNoOkquality;
     private BigDecimal cNoOkquality;
+    private String workorderCode;
 
     public BigDecimal getaNoOkquality() {
         return aNoOkquality;
diff --git a/op-modules/op-quality/src/main/java/com/op/quality/mapper/QcCheckTaskProduceMapper.java b/op-modules/op-quality/src/main/java/com/op/quality/mapper/QcCheckTaskProduceMapper.java
index 0fd8942b..3878ffdc 100644
--- a/op-modules/op-quality/src/main/java/com/op/quality/mapper/QcCheckTaskProduceMapper.java
+++ b/op-modules/op-quality/src/main/java/com/op/quality/mapper/QcCheckTaskProduceMapper.java
@@ -86,4 +86,5 @@ public interface QcCheckTaskProduceMapper {
     public List<QcCheckTaskProduce> getOrderWorksW2(ProOrderWorkorderDTO qoWork);
 
     public QcCheckTaskProduce getLastXJTask(QcCheckTaskProduce productTask);
+
 }
diff --git a/op-modules/op-quality/src/main/java/com/op/quality/service/IQcCheckTaskWarehousingService.java b/op-modules/op-quality/src/main/java/com/op/quality/service/IQcCheckTaskWarehousingService.java
index fd9b4ad3..5221e45e 100644
--- a/op-modules/op-quality/src/main/java/com/op/quality/service/IQcCheckTaskWarehousingService.java
+++ b/op-modules/op-quality/src/main/java/com/op/quality/service/IQcCheckTaskWarehousingService.java
@@ -2,6 +2,7 @@ package com.op.quality.service;
 
 import java.util.List;
 
+import com.op.common.core.web.domain.AjaxResult;
 import com.op.quality.domain.QcCheckTaskWarehousing;
 import com.op.system.api.domain.quality.QcCheckTaskWarehousingDTO;
 
@@ -61,4 +62,6 @@ public interface IQcCheckTaskWarehousingService {
     public int deleteQcCheckTaskWarehousingByRecordId(String recordId);
 
     List<QcCheckTaskWarehousing> getQcListLoc(QcCheckTaskWarehousing qcCheckTaskWarehousing);
+
+    AjaxResult createCPBatchTask();
 }
diff --git a/op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcCheckTaskWarehousingServiceImpl.java b/op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcCheckTaskWarehousingServiceImpl.java
index d239d3c1..6c3e3aab 100644
--- a/op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcCheckTaskWarehousingServiceImpl.java
+++ b/op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcCheckTaskWarehousingServiceImpl.java
@@ -1,21 +1,35 @@
 package com.op.quality.service.impl;
 
 import java.math.BigDecimal;
+import java.time.LocalTime;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 import ch.qos.logback.core.net.SyslogOutputStream;
+import cn.hutool.core.date.DateUnit;
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
+import com.op.common.core.domain.R;
 import com.op.common.core.utils.DateUtils;
 import com.op.common.core.utils.StringUtils;
+import com.op.common.core.utils.bean.BeanUtils;
 import com.op.common.core.utils.uuid.IdUtils;
+import com.op.common.core.web.domain.AjaxResult;
 import com.op.common.security.utils.SecurityUtils;
 import com.op.quality.domain.*;
 import com.op.quality.mapper.*;
 import com.op.quality.service.IQcCheckTaskDefectService;
 import com.op.quality.service.IQcCheckTaskUserService;
+import com.op.system.api.RemoteUserService;
+import com.op.system.api.domain.SysUser;
+import com.op.system.api.domain.mes.ProOrderWorkorderDTO;
 import com.op.system.api.domain.quality.QcUserMaterialDTO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -29,6 +43,9 @@ import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.servlet.http.HttpServletRequest;
 
+import static com.op.common.core.web.domain.AjaxResult.error;
+import static com.op.common.core.web.domain.AjaxResult.success;
+
 /**
  * 成品入库检验任务Service业务层处理
  *
@@ -58,7 +75,10 @@ public class QcCheckTaskWarehousingServiceImpl implements IQcCheckTaskWarehousin
 	private IQcCheckTaskDefectService qcCheckTaskDefectService;
 	@Autowired
 	private QcSampleRuleMapper qcSampleRuleMapper;
-
+	@Autowired
+	private RemoteUserService remoteUserService;
+	@Autowired
+	private QcCheckTaskProduceMapper qcCheckTaskProduceMapper;
 	/**
 	 * 查询成品入库检验任务
 	 *
@@ -311,4 +331,60 @@ public class QcCheckTaskWarehousingServiceImpl implements IQcCheckTaskWarehousin
 		return qcCheckTaskWarehousingMapper.getQcListLoc(qcCheckTaskWarehousing);
 	}
 
+	/**入库检验定时任务**/
+	@Override
+	public AjaxResult createCPBatchTask() {
+
+		// 加载sf-cloud库的sys_datasource
+		SysUser sysUser = new SysUser();
+		sysUser.setUserId(1L);
+		R<List<Map<String, String>>> dateSources0 = remoteUserService.getPoolNameList(sysUser);
+		List<Map<String, String>> dateSources = dateSources0.getData();
+		ExecutorService executorService = new ThreadPoolExecutor(
+				dateSources.size(),
+				dateSources.size(),
+				0L, TimeUnit.MILLISECONDS,
+				new LinkedBlockingQueue<Runnable>());
+		try {
+			dateSources.forEach(dateSource -> {
+				if("ds_1000".equals(dateSource.get("poolName"))){
+					logger.info("++++++++++++" + dateSource.get("poolName") + "++++成品入库检验巡检开始++++++++++");
+					Runnable run = () -> createCPFunc(dateSource.get("poolName"));
+					executorService.execute(run);
+				}
+			});
+		} catch (Exception e) {
+			logger.error("service == createCPBatchTask == exception", e);
+			return error("service == createCPBatchTask == exception");
+		} finally {
+			executorService.shutdown();
+		}
+		return success();
+	}
+
+	public void createCPFunc(String poolName){
+		DynamicDataSourceContextHolder.push(poolName);// 这是数据源的key
+		ProOrderWorkorderDTO qoWork = new ProOrderWorkorderDTO();
+		qoWork.setStatus("w3");
+		//报工的
+		List<QcCheckTaskProduce> w3works = qcCheckTaskProduceMapper.getOrderWorksW2(qoWork);
+		for(QcCheckTaskProduce productTask:w3works){
+			QcCheckTaskWarehousing cpTask = new QcCheckTaskWarehousing();
+			BeanUtils.copyProperties(productTask,cpTask);
+
+			productTask.setCheckType("checkTypeCP");//入库检验
+			productTask.setOrderNo(productTask.getWorkorderCode());
+
+//			//是否已经存在入库检验
+//			QcCheckTaskProduce cpTask0 = qcCheckTaskProduceMapper.getLastXJTask(productTask);
+//            if(cpTask0 == null){
+//				logger.info("++++++++++++入库检验任务生成:已经存在++++++++++++++");
+//			}else{
+//				int m = insertQcCheckTaskWarehousing(cpTask);
+//				logger.info("++++++++++++入库检验任务生成" + m + "++++++++++++++");
+//			}
+
+		}
+		logger.info("++++++++++++" + poolName + "++++入库检验巡检结束++++++++++");
+	}
 }
diff --git a/op-modules/op-quality/src/main/resources/mapper/quality/QcCheckTaskProduceMapper.xml b/op-modules/op-quality/src/main/resources/mapper/quality/QcCheckTaskProduceMapper.xml
index bd864332..037a0401 100644
--- a/op-modules/op-quality/src/main/resources/mapper/quality/QcCheckTaskProduceMapper.xml
+++ b/op-modules/op-quality/src/main/resources/mapper/quality/QcCheckTaskProduceMapper.xml
@@ -433,7 +433,7 @@
         from pro_order_workorder pow
         left join base_equipment be on be.equipment_code = pow.workorder_name and be.equipment_type_code = 'equ_type_bzx'
         where pow.del_flag = '0'
-          and pow.status = 'w2' and pow.parent_order = '0'
+          and pow.status = #{status} and pow.parent_order = '0'
           <!--and (pow.product_date = CONVERT(varchar(10),GETDATE(), 120)
                    or pow.product_date = CONVERT(varchar(10),DATEADD(DAY, -1, GETDATE()), 120))-->
     </select>