diff --git a/coolstore-partner-common/src/main/java/com/cool/store/constants/RedisConstant.java b/coolstore-partner-common/src/main/java/com/cool/store/constants/RedisConstant.java
index 7bbb03f77..a210ffa1a 100644
--- a/coolstore-partner-common/src/main/java/com/cool/store/constants/RedisConstant.java
+++ b/coolstore-partner-common/src/main/java/com/cool/store/constants/RedisConstant.java
@@ -341,7 +341,7 @@ public class RedisConstant {
      * 建店资料总部订货收款账户信息
      */
     public static final String BUILD_RECEIVE_BANK_INFO = "zxjp_build_receive_bank_info";
-    
+
     /**
      * 加盟线下收款银行默认配置
      */
@@ -352,6 +352,12 @@ public class RedisConstant {
      */
     public static final String TP_PENALTY_APPLY_IMPORT_LOCK = "tp_penalty_apply_import_lock";
 
+    /**
+     * 十二分审批按钮权限id
+     */
+    public static final String TP_AUDIT_AUTH_MENU_ID = "tp_audit_auth_menu_id";
+
+
     public static final String STANDARD_STORE_PAY_LOCK_KEY = "standard_store_pay_lock_key:{0}";
 
     /**
diff --git a/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqGroupEnum.java b/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqGroupEnum.java
index 576928f44..defb4596d 100644
--- a/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqGroupEnum.java
+++ b/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqGroupEnum.java
@@ -38,6 +38,7 @@ public enum RocketMqGroupEnum {
 
     STORE_MASTER_ISSUE("store_master_issue", new ArrayList<>(Arrays.asList(RocketMqTagEnum.STORE_MASTER_ISSUE))),
     VISIT_RECORD_INVALID("visit_record_invalid", new ArrayList<>(Arrays.asList(RocketMqTagEnum.VISIT_RECORD_INVALID))),
+    TP_PENALTY_APPEAL_OVERDUE("tp_penalty_appeal_overdue", new ArrayList<>(Arrays.asList(RocketMqTagEnum.TP_PENALTY_APPEAL_OVERDUE))),
     ;
 
     private final String group;
diff --git a/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqTagEnum.java b/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqTagEnum.java
index 90a73f27e..72a14d4c1 100644
--- a/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqTagEnum.java
+++ b/coolstore-partner-common/src/main/java/com/cool/store/enums/RocketMqTagEnum.java
@@ -22,6 +22,7 @@ public enum RocketMqTagEnum {
     DELAY_SHOP_DECORATION_ASSIGN("shop_decoration_assign","门店装修分配"),
     STORE_MASTER_ISSUE("store_master_issue","门店主数据下发"),
     VISIT_RECORD_INVALID("visit_record_invalid", "拜访记录失效"),
+    TP_PENALTY_APPEAL_OVERDUE("tp_penalty_appeal_overdue", "十二分惩处单复议逾期"),
     ;
 
 
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/tp/TpAuditRecordDAO.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/tp/TpAuditRecordDAO.java
index 8299713ce..97a61587c 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/tp/TpAuditRecordDAO.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/tp/TpAuditRecordDAO.java
@@ -137,48 +137,13 @@ public class TpAuditRecordDAO {
      * @param applyId 申请单id
      * @return 审批记录列表
      */
-    public List<AuditInfoResponse> getAuditRecordList(Long applyId) {
+    public List<TpAuditRecordDO> getAuditRecordList(Long applyId) {
         Example example = new Example(TpAuditRecordDO.class);
         example.createCriteria()
                 .andEqualTo("applyId", applyId)
-                .andNotEqualTo("auditStatus", 0)
                 .andEqualTo("deleted", 0);
         example.setOrderByClause("create_time ASC");
-        List<TpAuditRecordDO> recordList = tpAuditRecordMapper.selectByExample(example);
-        List<AuditInfoResponse> result = new ArrayList<>();
-        for (TpAuditRecordDO auditRecordDO : recordList) {
-            AuditInfoResponse response = AuditInfoResponse.builder()
-                    .type(getAuditInfoType(auditRecordDO))
-                    .execute(auditRecordDO.getRecordType() - 1)
-                    .status(CommonConstants.INDEX_ZERO.equals(auditRecordDO.getAuditStatus()) ? 0 : 1)
-                    .createTime(auditRecordDO.getReceiveTaskTime())
-                    .remark(auditRecordDO.getRemark())
-                    .actualUserId(auditRecordDO.getHandlerUserId())
-                    .build();
-            List<AuditInfoResponse.AuditUserInfoVO> auditUserList = Collections.singletonList(
-                    new AuditInfoResponse.AuditUserInfoVO(auditRecordDO.getHandlerUserId(), auditRecordDO.getHandlerUserName(), null)
-            );
-            response.setList(auditUserList);
-            result.add(response);
-        }
-        return result;
-    }
-
-    private Integer getAuditInfoType(TpAuditRecordDO auditRecordDO) {
-        if (CommonConstants.INDEX_ONE.equals(auditRecordDO.getRecordType())) {
-            return OperationLogAuditEnum.SUBMIT_AUDIT.getCode();
-        } else {
-            switch (auditRecordDO.getAuditStatus()) {
-                case 0:
-                    return OperationLogAuditEnum.WAIT_AUDIT.getCode();
-                case 1:
-                    return OperationLogAuditEnum.PASS.getCode();
-                case 2:
-                    return OperationLogAuditEnum.REFUSE.getCode();
-                default:
-                    return null;
-            }
-        }
+        return tpAuditRecordMapper.selectByExample(example);
     }
 
     /**
diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/SysRoleMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/SysRoleMapper.java
index adb5e668e..ac4b6c6bf 100644
--- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/SysRoleMapper.java
+++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/SysRoleMapper.java
@@ -1,6 +1,7 @@
 package com.cool.store.mapper;
 
 import com.cool.store.dto.UserRoleDTO;
+import com.cool.store.dto.openPreparation.UserNameDTO;
 import com.cool.store.dto.store.StoreUserDTO;
 import com.cool.store.entity.EnterpriseUserRole;
 import com.cool.store.entity.SysRoleDO;
@@ -115,6 +116,8 @@ public interface SysRoleMapper {
      */
    List<String> getPositionUserIds( @Param("positionIds") List<String> positionIds);
 
+   List<UserNameDTO> getPositionUsers(@Param("positionIds") List<String> positionIds);
+
    List<EnterpriseUserRole> selectUserRoleBySourceAndUserId(@Param("source") String source ,
                                                             @Param("userIdList") List<String> userIdList);
 
diff --git a/coolstore-partner-dao/src/main/resources/mapper/SysRoleMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/SysRoleMapper.xml
index c27321ab5..e149e818c 100644
--- a/coolstore-partner-dao/src/main/resources/mapper/SysRoleMapper.xml
+++ b/coolstore-partner-dao/src/main/resources/mapper/SysRoleMapper.xml
@@ -296,6 +296,17 @@
         and eu.active = true
     </select>
 
+    <select id="getPositionUsers" resultType="com.cool.store.dto.openPreparation.UserNameDTO">
+        select eu.user_id, eu.name from
+        enterprise_user_role_${enterpriseId} eur
+        left join enterprise_user_${enterpriseId} eu USING(user_id)
+        where eur.role_id in
+        <foreach collection="positionIds" item="roleId" open="(" separator="," close=")">
+            #{roleId}
+        </foreach>
+        and eu.active = true
+    </select>
+
     <select id="selectUserByDingRole" resultType="java.lang.String">
         select b.user_id from sys_role_${enterpriseId} a
         left join enterprise_user_role_${enterpriseId} b on a.id=b.role_id
diff --git a/coolstore-partner-model/src/main/java/com/cool/store/vo/tp/TpAppealListVO.java b/coolstore-partner-model/src/main/java/com/cool/store/vo/tp/TpAppealListVO.java
index 93aad75bf..f890ee545 100644
--- a/coolstore-partner-model/src/main/java/com/cool/store/vo/tp/TpAppealListVO.java
+++ b/coolstore-partner-model/src/main/java/com/cool/store/vo/tp/TpAppealListVO.java
@@ -35,4 +35,8 @@ public class TpAppealListVO extends TpApplyListBaseVO {
 
     @ApiModelProperty("复议详细理由")
     private String appealDetailReason;
+
+    @ApiModelProperty("项目名称")
+    @DictField
+    private String projectNameName;
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java
index 938ee7513..35a1e6c7c 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/ConsumerClient.java
@@ -8,10 +8,7 @@ import com.aliyun.openservices.ons.api.bean.Subscription;
 import com.cool.store.constants.CommonConstants;
 import com.cool.store.enums.RocketMqGroupEnum;
 import com.cool.store.mq.RocketMqConfig;
-import com.cool.store.mq.consumer.listener.ShopDecorationAssignListener;
-import com.cool.store.mq.consumer.listener.StoreUserUpdateListener;
-import com.cool.store.mq.consumer.listener.VisitRecordListener;
-import com.cool.store.mq.consumer.listener.XfsgTrainingPersonSyncListener;
+import com.cool.store.mq.consumer.listener.*;
 import com.google.common.collect.Maps;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -41,6 +38,8 @@ public class ConsumerClient {
     private ShopDecorationAssignListener shopDecorationAssignListener;
     @Resource
     private VisitRecordListener visitRecordListener;
+    @Resource
+    private TpPenaltyAppealListener tpPenaltyAppealListener;
 
     /**
      * 获取通用配置
@@ -133,4 +132,17 @@ public class ConsumerClient {
         return consumerBean;
     }
 
+    @Bean(initMethod = "start", destroyMethod = "shutdown")
+    public ConsumerBean tpPenaltyAppealOverdue() {
+        RocketMqGroupEnum groupEnum = RocketMqGroupEnum.TP_PENALTY_APPEAL_OVERDUE;
+        ConsumerBean consumerBean = new ConsumerBean();
+        //配置文件
+        Properties properties = getCommonProperties(groupEnum);
+        consumerBean.setProperties(properties);
+        Map<Subscription, MessageListener> commonSubscriptionTable = getCommonSubscriptionTable(groupEnum, tpPenaltyAppealListener);
+        //订阅多个topic如上面设置
+        consumerBean.setSubscriptionTable(commonSubscriptionTable);
+        return consumerBean;
+    }
+
 }
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/TpPenaltyAppealListener.java b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/TpPenaltyAppealListener.java
new file mode 100644
index 000000000..4e63bd818
--- /dev/null
+++ b/coolstore-partner-service/src/main/java/com/cool/store/mq/consumer/listener/TpPenaltyAppealListener.java
@@ -0,0 +1,53 @@
+package com.cool.store.mq.consumer.listener;
+
+import com.aliyun.openservices.ons.api.Action;
+import com.aliyun.openservices.ons.api.ConsumeContext;
+import com.aliyun.openservices.ons.api.Message;
+import com.aliyun.openservices.ons.api.MessageListener;
+import com.cool.store.constants.CommonConstants;
+import com.cool.store.service.tp.TpApplyService;
+import com.cool.store.utils.RedisUtilPool;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 十二分惩处单复议申请逾期
+ * </p>
+ *
+ * @author wangff
+ * @since 2026/3/10
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class TpPenaltyAppealListener implements MessageListener {
+    private final RedisUtilPool redisUtilPool;
+    private final TpApplyService tpApplyService;
+
+    @Override
+    public Action consume(Message message, ConsumeContext consumeContext) {
+        String text = new String(message.getBody());
+        if (StringUtils.isBlank(text)) {
+            log.info("消息体为空,tag:{},messageId:{}", message.getTag(), message.getMsgID());
+            return Action.CommitMessage;
+        }
+        String lockKey = "TpPenaltyAppealListener:" + message.getMsgID();
+        boolean lock = redisUtilPool.setNxExpire(lockKey, message.getMsgID(), CommonConstants.NORMAL_LOCK_TIMES);
+        if (lock) {
+            try {
+                tpApplyService.appealOverdue(Long.valueOf(text));
+            } catch (Exception e) {
+                log.error("TpPenaltyAppealListener consume error", e);
+                return Action.ReconsumeLater;
+            } finally {
+                redisUtilPool.delKey(lockKey);
+            }
+            log.info("消费成功,tag:{},messageId:{},reqBody={}", message.getTag(), message.getMsgID(), text);
+            return Action.CommitMessage;
+        }
+        return Action.ReconsumeLater;
+    }
+}
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/tp/TpApplyService.java b/coolstore-partner-service/src/main/java/com/cool/store/service/tp/TpApplyService.java
index 7b9a4e170..a054cf8b6 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/tp/TpApplyService.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/tp/TpApplyService.java
@@ -156,6 +156,12 @@ public interface TpApplyService {
      */
     Boolean acceptPenalty(Long applyId);
 
+    /**
+     * 复议逾期
+     * @param applyId 惩处申请单id
+     */
+    void appealOverdue(Long applyId);
+
     /**
      * 完成缴费
      * @param applyId 惩处申请单id
diff --git a/coolstore-partner-service/src/main/java/com/cool/store/service/tp/impl/TpApplyServiceImpl.java b/coolstore-partner-service/src/main/java/com/cool/store/service/tp/impl/TpApplyServiceImpl.java
index a8fd5e3ab..add392b69 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/service/tp/impl/TpApplyServiceImpl.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/service/tp/impl/TpApplyServiceImpl.java
@@ -10,20 +10,23 @@ import com.cool.store.dao.EnterpriseUserDAO;
 import com.cool.store.dao.StoreDao;
 import com.cool.store.dao.tp.*;
 import com.cool.store.dto.ImportOaOldShopDataErrorDTO;
+import com.cool.store.dto.openPreparation.UserNameDTO;
 import com.cool.store.dto.tp.TpPenaltyImportErrorDTO;
 import com.cool.store.entity.ImportTaskDO;
 import com.cool.store.entity.StoreDO;
 import com.cool.store.entity.tp.TpApplyFormDO;
+import com.cool.store.entity.tp.TpAuditRecordDO;
 import com.cool.store.entity.tp.TpRuleDO;
 import com.cool.store.entity.tp.TpScoreJournalDO;
-import com.cool.store.enums.ErrorCodeEnum;
-import com.cool.store.enums.FileTypeEnum;
-import com.cool.store.enums.ImportTaskStatusEnum;
+import com.cool.store.enums.*;
 import com.cool.store.enums.tp.TpFormStatusEnum;
 import com.cool.store.enums.tp.TpFormTypeEnum;
 import com.cool.store.enums.tp.TpPayStatusEnum;
 import com.cool.store.exception.ServiceException;
 import com.cool.store.mapper.ImportTaskMapper;
+import com.cool.store.mapper.SysRoleMapper;
+import com.cool.store.mapper.SysRoleMenuMapper;
+import com.cool.store.mq.producer.SimpleMessageService;
 import com.cool.store.oss.OssClientService;
 import com.cool.store.request.tp.*;
 import com.cool.store.response.AuditInfoResponse;
@@ -41,6 +44,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Service;
@@ -57,6 +61,7 @@ import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Collectors;
 
 import static com.cool.store.utils.poi.DateUtils.SPECIAL_DATE_START_1;
 
@@ -86,8 +91,13 @@ public class TpApplyServiceImpl implements TpApplyService {
     @Resource(name = "generalThreadPool")
     private ThreadPoolTaskExecutor executor;
     private final EasyExcelUtil easyExcelUtil;
+    private final SysRoleMenuMapper sysRoleMenuMapper;
+    private final SimpleMessageService simpleMessageService;
+
     @Value("${mybatis.configuration.variables.enterpriseId}")
     private String eid;
+    @Autowired
+    private SysRoleMapper sysRoleMapper;
 
     @Override
     @Transactional
@@ -163,6 +173,8 @@ public class TpApplyServiceImpl implements TpApplyService {
         // 第一次提交后添加审批记录
         if (!isDraft) {
             tpAuditRecordDAO.firstAddRecord(formDO.getId(), formDO.getType(), request.getApplyUserId(), request.getApplyUserName());
+            // 发送延时任务
+            simpleMessageService.send(String.valueOf(formDO.getId()), RocketMqTagEnum.TP_PENALTY_APPEAL_OVERDUE, formDO.getAppealEndDate().getTime());
         }
         return true;
     }
@@ -314,7 +326,56 @@ public class TpApplyServiceImpl implements TpApplyService {
 
     @Override
     public List<AuditInfoResponse> getAuditRecordList(Long applyId) {
-        return tpAuditRecordDAO.getAuditRecordList(applyId);
+        List<TpAuditRecordDO> list = tpAuditRecordDAO.getAuditRecordList(applyId);
+        List<AuditInfoResponse> result = new ArrayList<>();
+        for (TpAuditRecordDO auditRecordDO : list) {
+            AuditInfoResponse response = AuditInfoResponse.builder()
+                    .type(getAuditInfoType(auditRecordDO))
+                    .execute(auditRecordDO.getRecordType() - 1)
+                    .status(CommonConstants.INDEX_ZERO.equals(auditRecordDO.getAuditStatus()) ? 0 : 1)
+                    .createTime(auditRecordDO.getReceiveTaskTime())
+                    .remark(auditRecordDO.getRemark())
+                    .actualUserId(auditRecordDO.getHandlerUserId())
+                    .build();
+            if (CommonConstants.INDEX_ZERO.equals(auditRecordDO.getAuditStatus())) {
+                // 待审批记录根据功能权限分解待审批人
+                String menuId = redisUtilPool.hashGet(RedisConstant.TP_AUDIT_AUTH_MENU_ID, String.valueOf(auditRecordDO.getApplyType()));
+                if (StringUtils.isNotBlank(menuId)) {
+                    List<Long> roleIds = sysRoleMenuMapper.listSysRoleMenuIdByMenuId(PlatFormTypeEnum.PC.getCode(), Long.valueOf(menuId));
+                    // 根据角色分解用户
+                    if (CollectionUtils.isNotEmpty(roleIds)) {
+                        List<UserNameDTO> users = sysRoleMapper.getPositionUsers(roleIds.stream().map(String::valueOf).collect(Collectors.toList()));
+                        List<AuditInfoResponse.AuditUserInfoVO> auditUserList = CollStreamUtil.toList(users, v -> new AuditInfoResponse.AuditUserInfoVO(v.getUserId(), v.getName(), null));
+                        response.setList(auditUserList);
+                        result.add(response);
+                    }
+                }
+            } else {
+                List<AuditInfoResponse.AuditUserInfoVO> auditUserList = Collections.singletonList(
+                        new AuditInfoResponse.AuditUserInfoVO(auditRecordDO.getHandlerUserId(), auditRecordDO.getHandlerUserName(), null)
+                );
+                response.setList(auditUserList);
+                result.add(response);
+            }
+        }
+        return result;
+    }
+
+    private Integer getAuditInfoType(TpAuditRecordDO auditRecordDO) {
+        if (CommonConstants.INDEX_ONE.equals(auditRecordDO.getRecordType())) {
+            return OperationLogAuditEnum.SUBMIT_AUDIT.getCode();
+        } else {
+            switch (auditRecordDO.getAuditStatus()) {
+                case 0:
+                    return OperationLogAuditEnum.WAIT_AUDIT.getCode();
+                case 1:
+                    return OperationLogAuditEnum.PASS.getCode();
+                case 2:
+                    return OperationLogAuditEnum.REFUSE.getCode();
+                default:
+                    return null;
+            }
+        }
     }
 
     @Override
@@ -380,6 +441,16 @@ public class TpApplyServiceImpl implements TpApplyService {
         return true;
     }
 
+    @Override
+    @Transactional
+    public void appealOverdue(Long applyId) {
+        TpApplyFormDO formDO = tpApplyFormDAO.getEffectiveById(applyId);
+        if (Objects.nonNull(formDO) && (TpFormStatusEnum.PASS.getStatus().equals(formDO.getStatus()) || TpFormStatusEnum.INEFFECTIVE.getStatus().equals(formDO.getStatus()))) {
+            tpApplyFormDAO.updateStatus(applyId, TpFormStatusEnum.EFFECTIVE);
+            scoreChange(formDO);
+        }
+    }
+
     @Override
     public Boolean completePayment(Long applyId) {
         TpApplyFormDO formDO = tpApplyFormDAO.getEffectiveById(applyId);
@@ -450,7 +521,7 @@ public class TpApplyServiceImpl implements TpApplyService {
      */
     @Override
     public void scoreChange(TpApplyFormDO formDO) {
-        if (TpFormStatusEnum.PASS.getStatus().equals(formDO.getStatus())) {
+        if (TpFormStatusEnum.PASS.getStatus().equals(formDO.getStatus()) || TpFormStatusEnum.INEFFECTIVE.getStatus().equals(formDO.getStatus()) && TpFormTypeEnum.isPenalty(formDO.getType())) {
             BigDecimal occurBeforeScore = storeDao.getStoreScore(formDO.getStoreId());
             BigDecimal occurAfterScore = null;
             String occurScore = "";
diff --git a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
index 67d6034f5..29f62d63d 100644
--- a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
+++ b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java
@@ -539,7 +539,7 @@ public class XxlJobHandler {
         int pageNum = 1;
         int pageSize = CommonConstants.BATCH_SIZE;
         TpApplyQueryRequest request = new TpApplyQueryRequest();
-        request.setStatusList(Collections.singletonList(TpFormStatusEnum.PASS.getStatus()));
+        request.setStatusList(Arrays.asList(TpFormStatusEnum.PASS.getStatus(), TpFormStatusEnum.INEFFECTIVE.getStatus()));
         request.setIsPenalty(true);
         request.setIsDraft(0);
         request.setOverdue(true);