taskIds = serviceTaskopers.stream().map(ServiceTaskMatchDto::getTaskId).collect(Collectors.toList());
patMedOperation1.setLongTaskReason("该手术编码，有多个随访长期任务:" + taskIds);
operationService.update(patMedOperation1);
ServiceTaskMatchDto serviceTaskoper1 = serviceTaskopers.get(0);
serviceTaskopers = new ArrayList<>();
serviceTaskopers.add(serviceTaskoper1);
}
writeInSubTask(taskApi, serviceTaskopers.get(0).getTaskId(), Boolean.TRUE, patMedOperation1, patArchive);
} catch (Exception e) {
e.printStackTrace();
log.error("人员处理出异常了：{}", e.getMessage());
}
}
return 1;
}
/**
* 把一条手术记录写入随访子任务。
*
* 逐行对应原 {@code PatMedOperationServiceImpl#writeInSubTask}（L152-187）。
*
*
⚠️ {@code check} 参数在原实现里没有被使用
* 原方法签名带 {@code Boolean check}，但方法体里一次都没读它
* （不像门诊版会用它决定"先停旧再新增"）。这里刻意保留同样的签名与"不读"的写法，
* 以免将来对照代码时误以为漏了一段逻辑。
*
* @param check 原实现传入但未使用；保留签名只为逐行可比
*/
private void writeInSubTask(VisitTaskCreateApi taskApi, Long taskid, Boolean check,
PatMedOperation patMedOperation1, VisitArchiveRow patArchive) {
String longTaskReason = patMedOperation1.getLongTaskReason();
if (StringUtils.isEmpty(longTaskReason)) longTaskReason = "";
// 原 L156-159：查「已发布的长期任务」（taskid + sendState=2）
VisitLongTaskDto serviceTask = taskApi.findPublishedLongTask(taskid);
if (serviceTask == null) {
log.error("该手术编码长期任务不存在,任务ID为：{}", taskid);
patMedOperation1.setCheckFlag("2");
patMedOperation1.setLongTaskReason(longTaskReason + " & 该手术编码长期任务不存在,任务ID为:" + taskid);
operationService.update(patMedOperation1);
return;
}
// 封装serviceSubtask
VisitSubtaskDraft serviceSubtask = boxedServiceSubtask(serviceTask, patMedOperation1, patArchive);
boolean i = taskApi.insertSubtask(serviceSubtask);
if (i) {
// 将check_flag改成1（已处理）
PatMedOperation patMedOperation = new PatMedOperation();
patMedOperation.setId(patMedOperation1.getId());
patMedOperation.setCheckFlag("1");
operationService.update(patMedOperation);
} else {
// 生成子任务失败，
log.error("生成子任务失败serviceSubtask为：{}", serviceSubtask);
PatMedOperation patMedOperation = new PatMedOperation();
patMedOperation.setId(patMedOperation1.getId());
patMedOperation.setRemark("生成子任务失败");
operationService.update(patMedOperation);
}
}
/**
* 手术版子任务组装。
*
* 逐字段对应原 {@code boxedServiceSubtask}（L191-238，29 个 setter）。
*
*
原实现第一行是 {@code DtoConversionUtils.sourceToTarget(serviceTask, ServiceSubtask.class)}
* 它整批拷了 {@code ServiceTask} 与 {@code ServiceSubtask} 的 33 个同名字段，
* 其中 18 个之后再没被显式覆盖。本次换了数据来源——
* {@code serviceTask} 现在是 {@link VisitLongTaskDto}（15 个字段的任务快照），
* 不是 {@code ServiceTask} 实体。
*
* ⚠️ 这是一个已登记的、与门诊版完全相同的口径限制：
* 那 18 个"靠拷贝带进子任务"的字段里，{@code VisitLongTaskDto} 只承载
* {@code taskName}/{@code type}/{@code preachformDesc}/{@code createBy} 等已列出的几个，
* 其余（{@code guid}/{@code pid}/{@code sendType}/{@code isupload}/…）
* 需要由将来的「随访任务创建模块」在实现 {@code insertSubtask} 时补齐。
* 本模块不自己补，也不把它们加到 {@code VisitSubtaskDraft} 上 ——
* 那会让出入院/门诊两条已验收的链路多写列。
* 落地方式与门诊侧（{@code OuthospVisitTaskService#boxedServiceSubtask}）一致。
*
*
⚠️ 刻意保留的原行为
*
* - {@code setStarttime} 与 {@code setEndtime} 同值（都取 {@code opreqtime}），原样保留；
* - {@code serviceTask.getSendDay() == null} 时按 1 天处理，且写回 serviceTask；
* - {@code addDays} 的基准是 {@code opreqtime}（可能为 null，
* 原实现同样会 NPE —— 不额外加保护）；
* - 不需要随访时置 {@code sendstate=4} + {@code result="error"} 并把原因写进 remark，
* 但仍然继续 insert（原实现没有提前 return）；
* - {@code setPhone} 只在 {@code telcode} 为空时才回落到 {@code relativetelcode}
* （与门诊版"三元表达式"写法等价，此处照抄原 if 写法）。
*
*/
public VisitSubtaskDraft boxedServiceSubtask(VisitLongTaskDto serviceTask,
PatMedOperation patMedOperation1,
VisitArchiveRow patArchive) {
VisitSubtaskDraft serviceSubtask = new VisitSubtaskDraft();
serviceSubtask.setTaskid(serviceTask.getTaskid());
serviceSubtask.setOrgid(serviceTask.getOrgid());
serviceSubtask.setCampusid(serviceTask.getCampusid());
// 原 L194-195：libtemplateid 在 ServiceTask 里是 String，落库列/草稿里是 Long，
// 原实现显式 Long.valueOf 转换，且【仅在非空时】设值（为空则保持 null -> 列不写）。原样保留。
if (StringUtils.isNotEmpty(serviceTask.getLibtemplateid()))
serviceSubtask.setLibtemplateid(Long.valueOf(serviceTask.getLibtemplateid()));
serviceSubtask.setNurseId(patMedOperation1.getNurseId());
serviceSubtask.setNurseName(patMedOperation1.getNurseName());
// serviceSubtask.setInhospid(patMedOperation1.getInhospid());
serviceSubtask.setDrcode(patMedOperation1.getDrcode());
serviceSubtask.setDrname(patMedOperation1.getDrname());
serviceSubtask.setDeptcode(patMedOperation1.getDeptcode());
serviceSubtask.setDeptname(patMedOperation1.getDeptname());
serviceSubtask.setTemplateid(serviceTask.getTemplateid());
serviceSubtask.setTemplatename(serviceTask.getTemplatename());
serviceSubtask.setPatid(patArchive.getId());
serviceSubtask.setSendname(patArchive.getName());
serviceSubtask.setSfzh(patArchive.getIdcardno());
serviceSubtask.setPhone(patArchive.getTelcode());
if (StringUtils.isBlank(patArchive.getTelcode())) serviceSubtask.setPhone(patArchive.getRelativetelcode());
serviceSubtask.setSex(patArchive.getSex());
serviceSubtask.setAge(patArchive.getAge());
serviceSubtask.setSendstate(SENDSTATE_PENDING);
serviceSubtask.setStarttime(patMedOperation1.getOpreqtime());
serviceSubtask.setEndtime(patMedOperation1.getOpreqtime());
serviceSubtask.setServiceType("2");
serviceSubtask.setPreachform(serviceTask.getPreachform());
serviceSubtask.setHospType(HOSP_TYPE_OPERATION);
serviceSubtask.setCreateTime(new Date());
serviceSubtask.setUpdateTime(new Date());
// serviceSubtask.setCreateBy(patMedInhosp1.getNurseName());
// serviceSubtask.setLeavehospitaldistrictcode(patMedInhosp1.getLeavehospitaldistrictcode());
// serviceSubtask.setLeavehospitaldistrictname(patMedInhosp1.getLeavehospitaldistrictname());
// 设置发送时间
if (serviceTask.getSendDay() == null) serviceTask.setSendDay(1L);
Date newDate = addDays(patMedOperation1.getOpreqtime(), serviceTask.getSendDay().intValue());
serviceSubtask.setLongSendTime(newDate);
serviceSubtask.setVisitTime(newDate);
// 患者发送时间
if (StringUtils.isNotEmpty(patArchive.getNotrequiredFlag()) && patArchive.getNotrequiredFlag().equals("1")) {
String remark = patArchive.getNotrequiredreason();
serviceSubtask.setRemark(remark);
serviceSubtask.setResult("error");
// serviceSubtask.setFinishtime(new Date());
// 不执行
serviceSubtask.setSendstate(SENDSTATE_SKIP);
}
return serviceSubtask;
}
/**
* 在 {@code date} 上加 {@code days} 天；{@code days} 为 null 时按 1 天。
*
* 逐行对应原 {@code PatMedOperationServiceImpl#addDays}（L240-248）。
* ⚠️ 与出入院侧的 {@code minusDay} 不是同一个方法（那个硬编码减 2 天并忽略入参）。
*/
private Date addDays(Date date, Integer days) {
if (days == null) {
days = 1;
}
Calendar calendar = Calendar.getInstance();
calendar.setTime(date);
calendar.add(Calendar.DAY_OF_MONTH, days);
return calendar.getTime();
}
// ==========================================================================
// 契约取用（与门诊/出入院模块同一写法：ObjectProvider + stream，取不到就降级）
// ==========================================================================
private ServiceTaskMatchApi matchApi() {
return providerGet(matchApiProvider, "ServiceTaskMatchApi");
}
private ArchiveReadApi archiveApi() {
return providerGet(archiveApiProvider, "ArchiveReadApi");
}
private VisitTaskCreateApi taskApi() {
return providerGet(taskApiProvider, "VisitTaskCreateApi");
}
private T providerGet(ObjectProvider p, String name) {
if (p == null) {
return null;
}
try {
return p.stream().findFirst().orElse(null);
} catch (Exception e) {
log.warn("【手术随访】获取 {} 失败，按不可用处理：{}", name, e.toString());
return null;
}
}
}