* 所以整个 roll 动作留在本类里原子完成；{@code ruoyi-inhospvisit} 只负责 * "批次上限 + 逐条 try/catch + 计数与日志"这部分编排。 * *
| 本类方法 | 原实现 | 行数 |
|---|---|---|
| {@link #selectActiveCycleSchedules(int)} | *{@code ServiceTaskScheduleServiceImpl#rollCycleTasks} L171 的查询部分 | — |
| {@link #rollOneSchedule(Long)} | *{@code rollOneSchedule} L196-280 | 85 |
| {@code cloneForNextLoop} | L285-313 | 29 |
| {@code copyPreachform} | L318-338 | 21 |
| {@code advance} | L343-361 | 19 |
* 只回传 id 列表：真正的 roll 动作在 {@link #rollOneSchedule(Long)} 里重新加载完整计划
* （原实现也是把整个 {@code ServiceTaskSchedule} 传进 rollOneSchedule，
* 所以语义一致）。
*/
@Override
public List
* ⚠️ 原实现接收的是整个 {@code ServiceTaskSchedule} 对象（由 {@code rollCycleTasks}
* 从查询结果里传进来）。端口签名只给 id，所以这里要**重新查一次**。
* 为此需要按 id 查计划：用 {@code selectByTaskid} 不行（那是按 taskid），
* 所以这里用 {@code selectActiveCycleSchedules} 的同款能力 ——
* 见下方 {@link #loadSchedule(Long)} 的说明。
*/
@Override
@Transactional(rollbackFor = Exception.class)
public VisitScheduleRollResultDto rollOneSchedule(Long scheduleId) {
ServiceTaskSchedule schedule = loadSchedule(scheduleId);
if (schedule == null) {
log.warn("[任务组-滚动] scheduleId={} 加载不到计划，跳过", scheduleId);
return VisitScheduleRollResultDto.skipped(scheduleId, "计划不存在");
}
return doRoll(schedule);
}
/**
* 按 id 加载计划。
*
* ⚠️ 这里与"原实现"有一个必须说明的差异：
* 原 {@code rollCycleTasks} 是把查询结果里的对象直接传进来（不重查）；
* 端口只给 id，所以必须重查。重查与"用查询结果"的差别只在于
* 两次读取之间计划是否被改过——同一批任务里这是毫秒级窗口，
* 且 rollOneSchedule 本身会做乐观的"本轮是否结束"校验，所以不改变可观察行为。
*
* 实现上用 {@code selectServiceTaskScheduleList} 按 id 过滤（该 Mapper 已有此能力）。
*/
private ServiceTaskSchedule loadSchedule(Long scheduleId) {
ServiceTaskSchedule q = new ServiceTaskSchedule();
q.setId(scheduleId);
List
* ⚠️ 第一行的全字段深拷贝（116 个字段）必须原样用 JSON 序列化，不要改写成逐字段 set。
*/
private ServiceSubtask cloneForNextLoop(ServiceSubtask src, ServiceTaskScheduleDetail detail,
long nextLoop, int stepNum, int stepUnit, Date now) {
ServiceSubtask copy = JSON.parseObject(JSON.toJSONString(src), ServiceSubtask.class);
copy.setId(null);
copy.setSenduuid(null);
copy.setResult(null);
copy.setFinishtime(null);
copy.setExrecallcount(null);
copy.setCurrentPreachform(null);
copy.setSendstate(2L);
copy.setLoopCount(nextLoop);
copy.setScheduleDetailId(detail.getId());
// 模板：detail 优先
if (detail.getTemplateid() != null) {
copy.setTemplateid(detail.getTemplateid());
copy.setTemplatename(detail.getTemplatename());
}
if (detail.getLibtemplateid() != null) {
copy.setLibtemplateid(detail.getLibtemplateid());
}
Date base = src.getVisitTime() != null ? src.getVisitTime() : now;
Date nextVisit = advance(base, stepNum, stepUnit);
copy.setVisitTime(nextVisit);
copy.setSenddate(nextVisit);
copy.setLongSendTime(nextVisit);
copy.setCreateTime(now);
copy.setUpdateTime(now);
return copy;
}
/**
* 复制源 subtask 的发送方式行到新 subtask —— 逐行搬自原 L318-338。
*
* ⚠️ 查源行的条件是 {@code subid + taskid}（不设 orgid，虽然 XML 支持），原样保留。
*/
private void copyPreachform(Long srcSubId, ServiceSubtask newSubtask) {
ServiceSubtaskPreachform q = new ServiceSubtaskPreachform();
q.setSubid(srcSubId);
q.setTaskid(newSubtask.getTaskid());
List