diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/redeemTaskPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/redeemTaskPlugin.java
new file mode 100644
index 0000000..84c603a
--- /dev/null
+++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/task/redeemTaskPlugin.java
@@ -0,0 +1,111 @@
+package shkd.sys.sys.plugin.task;
+
+import kd.bos.algo.DataSet;
+import kd.bos.algo.Row;
+import kd.bos.context.RequestContext;
+import kd.bos.dataentity.OperateOption;
+import kd.bos.dataentity.entity.DynamicObject;
+import kd.bos.dataentity.resource.ResManager;
+import kd.bos.entity.ExtendedDataEntity;
+import kd.bos.entity.operate.result.OperationResult;
+import kd.bos.exception.KDException;
+import kd.bos.logging.Log;
+import kd.bos.logging.LogFactory;
+import kd.bos.orm.query.QCP;
+import kd.bos.orm.query.QFilter;
+import kd.bos.schedule.executor.AbstractTask;
+import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.QueryServiceHelper;
+import kd.bos.servicehelper.operation.OperationServiceHelper;
+import kd.tmc.cdm.common.constant.CdmEntityConst;
+import kd.tmc.cdm.common.enums.BillStatusEnum;
+import kd.tmc.cdm.common.enums.DraftTradeTypeEnum;
+import kd.tmc.cdm.common.enums.DraftTranStatusEnum;
+import kd.tmc.fbp.common.util.EmptyUtil;
+
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class redeemTaskPlugin extends AbstractTask {
+
+    private static final Log logger = LogFactory.getLog(redeemTaskPlugin.class);
+
+    @Override
+    public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
+        QFilter filter = new QFilter("draftbillstatus", QCP.equals, "payoffed");
+        filter=filter.and(new QFilter("draftbilltype.name", QCP.like, "%商业承兑汇票%"));
+        DynamicObject[] CDM_PAYABLEBILLs = BusinessDataServiceHelper.load(CdmEntityConst.CDM_PAYABLEBILL, "id,billno,amount,billstatus,draftbilltranstatus", filter.toArray());
+        Set<Object> draftIds = (Set)Arrays.stream(CDM_PAYABLEBILLs).map((s) -> {
+            return s.getPkValue();
+        }).collect(Collectors.toSet());
+        QFilter filter1 = new QFilter("entrys.draftbill.id", "in", draftIds);
+        filter1.and("tradetype", "=", DraftTradeTypeEnum.REDEEM.getValue());
+        filter1.and("draftbilltranstatus", "=", "success");
+        Map<Long, BigDecimal> amountMap = new HashMap(16);
+        DataSet rows = QueryServiceHelper.queryDataSet("PayableBillRedeemValidator", "cdm_drafttradebill", "entrys.draftbill.id,entrys.billamt", filter1.toArray(), (String)null);
+        Throwable var8 = null;
+        try {
+            Iterator var9 = rows.iterator();
+
+            while(var9.hasNext()) {
+                Row row = (Row)var9.next();
+                Long draftBillId = row.getLong("entrys.draftbill.id");
+                BigDecimal orDefault = (BigDecimal)amountMap.getOrDefault(draftBillId, BigDecimal.ZERO);
+                amountMap.put(draftBillId, orDefault.add(row.getBigDecimal("entrys.billamt")));
+            }
+        } catch (Throwable throwable) {
+            var8 = throwable;
+            throw throwable;
+        } finally {
+            if (rows != null) {
+                if (var8 != null) {
+                    try {
+                        rows.close();
+                    } catch (Throwable var25) {
+                        var8.addSuppressed(var25);
+                    }
+                } else {
+                    rows.close();
+                }
+            }
+
+        }
+
+        for (int i = 0; i < CDM_PAYABLEBILLs.length; i++) {
+            DynamicObject cdm_payablebill = CDM_PAYABLEBILLs[i];
+            Long draftId = cdm_payablebill.getLong("id");
+            BigDecimal sumBillAmt = (BigDecimal)amountMap.getOrDefault(draftId, BigDecimal.ZERO);
+            BigDecimal amount = cdm_payablebill.getBigDecimal("amount");
+            boolean isNoAmount = sumBillAmt.compareTo(BigDecimal.ZERO) != 0 && amount.compareTo(sumBillAmt) == 0;
+            String billStatus = cdm_payablebill.getString("billstatus");
+            String draftbillTranstatus = cdm_payablebill.getString("draftbilltranstatus");
+            if (!BillStatusEnum.AUDIT.getValue().equals(billStatus) || !DraftTranStatusEnum.SUCCESS.getValue().equals(draftbillTranstatus) || isNoAmount) {
+                logger.info("单据编号："+cdm_payablebill.getString("billno")+"单据状态为“已审核”且票据交易状态为“交易成功”的未兑付票据才能操作票据兑付。");
+                continue;
+            }
+
+            List<Long> dataEntitys = new ArrayList<>();
+            dataEntitys.add(Long.parseLong(cdm_payablebill.getString("id")));
+            OperateOption option = OperateOption.create();
+            option.setVariableValue("tradeType", "redeem");
+            option.setVariableValue("remarks", "后台下推");
+            //调用方法执行数据 - 自动兑付下推
+            OperationResult operationResult = OperationServiceHelper.executeOperate("pushandsaveredeem",
+                    CdmEntityConst.CDM_PAYABLEBILL,
+                    dataEntitys.toArray(new Object[]{}), option);
+            if (operationResult.getAllErrorInfo().size()!=0) {
+                logger.info("单据编号："+cdm_payablebill.getString("billno")+"后台生单失败，原因："+operationResult.getAllErrorInfo().get(0).getMessage());
+                String targetpkvalue = operationResult.getAllErrorInfo().get(0).getErrorCustInfos().get("targetpkvalue");
+                DynamicObject cdm_drafttradebill = BusinessDataServiceHelper.loadSingle(targetpkvalue, "cdm_drafttradebill");
+                OperationResult delete = OperationServiceHelper.executeOperate("delete", "cdm_drafttradebill", new DynamicObject[]{cdm_drafttradebill}, OperateOption.create());
+                if (delete.isSuccess()==true){
+                    logger.info("删除单据编号："+cdm_payablebill.getString("billno")+"成功");
+                }else {
+                    logger.info("删除单据编号："+cdm_payablebill.getString("billno")+"失败，原因："+delete.getMessage());
+                }
+
+            }
+        }
+    }
+}