package com.ruoyi.inhospvisit.service;
|
|
import com.ruoyi.common.core.service.ScheduleRollPort;
|
import com.ruoyi.common.core.service.dto.VisitScheduleRollResultDto;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.springframework.beans.factory.ObjectProvider;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* 任务组「轮次滚动」编排器 —— 逐行搬自
|
* {@code ServiceTaskScheduleServiceImpl#rollCycleTasks}（L170-190，21 行）。
|
*
|
* <h3>为什么这里只有"编排"（第 9 步的设计）</h3>
|
* 真正滚动单个计划要做一次 {@code ServiceSubtask} 的 <b>116 字段全字段深拷贝</b>，
|
* 那部分<b>刻意留在实现侧</b>（smartor 的 {@code ScheduleRollPortBridge}），
|
* 不跨越模块边界传 116 字段的 DTO —— 理由见 {@link ScheduleRollPort} 的类注释。
|
* <p>
|
* 本类负责的部分（与原文逐行对应）：
|
* <ol>
|
* <li>批次上限 {@code ROLL_BATCH_LIMIT = 200}（原 L50 / L171）；</li>
|
* <li>扫描日志 {@code [任务组-滚动] 扫描到 {} 个待评估的循环计划}（原 L175）；</li>
|
* <li>逐条 {@code try/catch}，单条失败不影响其它计划（原 L178-186）；</li>
|
* <li>计数与收尾日志 {@code 本次推进 {} 个计划}（原 L188）。</li>
|
* </ol>
|
*
|
* <h3>⚠️ 与原实现的两处已知差异（都已登记）</h3>
|
* <ol>
|
* <li><b>事务边界</b>：原实现在 {@code rollOneSchedule} 上标 {@code @Transactional}
|
* （方法在同一个类里，通过 {@code SpringUtils.getAopProxy(this)} 自调以让注解生效，见原 L180）。
|
* 搬迁后 {@code @Transactional} 落在桥实现 {@code ScheduleRollPortBridge#rollOneSchedule} 上
|
* —— <b>跨 Bean 调用，事务照常生效</b>，所以不再需要 AOP 自调那一步。
|
* 这是等价改写，不是行为变更。</li>
|
* <li><b>计划对象是重查的</b>：原实现把"查询结果里的计划对象"直接传给 {@code rollOneSchedule}；
|
* 端口只给 id，所以桥里按 id 重查一次。差异只在"两次读取之间计划是否被改过"这个毫秒级窗口，
|
* 且 roll 内部仍会做"本轮是否结束"的校验。已在桥的注释里说明。</li>
|
* </ol>
|
*
|
* <h3>⚠️ 过渡期禁止双跑</h3>
|
* 本类在第 10 步（把 {@code RyTask.rollTaskGroupCycle} 的方法体切过来）之前，
|
* <b>不能被挂到任何调度上</b>：老的 {@code rollCycleTasks} 还在跑，
|
* 两边都会"推进轮次 + 新建 subtask"，双跑会造成重复轮次。
|
* 目前本类只被自检程序调用。
|
*/
|
@Slf4j
|
@Service
|
public class TaskGroupCycleRoller {
|
|
/** 单次扫描的最大计划数，避免长事务（原 {@code ServiceTaskScheduleServiceImpl} L50）。 */
|
private static final int ROLL_BATCH_LIMIT = 200;
|
|
@Autowired
|
private ObjectProvider<ScheduleRollPort> rollPortProvider;
|
|
/**
|
* 扫描循环任务组计划并推进已完成的轮次。
|
* <p>
|
* 逐行对应原 {@code rollCycleTasks()}（L170-190）。
|
*
|
* @return 本次推进的计划数
|
*/
|
public int rollCycleTasks() {
|
ScheduleRollPort port = rollPort();
|
if (port == null) {
|
log.warn("【出入院随访】ScheduleRollPort 不可用（任务组端口未装配），本次不推进任何轮次。");
|
return 0;
|
}
|
|
// 原 L171-174
|
List<Long> scheduleIds = port.selectActiveCycleSchedules(ROLL_BATCH_LIMIT);
|
if (CollectionUtils.isEmpty(scheduleIds)) {
|
return 0;
|
}
|
// 原 L175
|
log.info("[任务组-滚动] 扫描到 {} 个待评估的循环计划", scheduleIds.size());
|
|
int rolled = 0;
|
for (Long scheduleId : scheduleIds) {
|
try {
|
// 原 L180：if (SpringUtils.getAopProxy(this).rollOneSchedule(schedule)) rolled++;
|
// 搬迁后 @Transactional 在桥实现上，跨 Bean 调用即生效，无需 AOP 自调。
|
VisitScheduleRollResultDto result = port.rollOneSchedule(scheduleId);
|
if (result != null && result.isRolled()) {
|
rolled++;
|
}
|
} catch (Exception e) {
|
// 原 L183-186：单条失败不影响其它计划，记日志继续
|
log.error("[任务组-滚动] scheduleId={} 滚动失败：{}", scheduleId, e.getMessage(), e);
|
}
|
}
|
// 原 L188-189
|
log.info("[任务组-滚动] 本次推进 {} 个计划", rolled);
|
return rolled;
|
}
|
|
private ScheduleRollPort rollPort() {
|
if (rollPortProvider == null) {
|
return null;
|
}
|
try {
|
return rollPortProvider.stream().findFirst().orElse(null);
|
} catch (Exception e) {
|
log.warn("【出入院随访】获取 ScheduleRollPort 失败：{}", e.toString());
|
return null;
|
}
|
}
|
}
|
