package jnpf.dmsService;
|
|
import jnpf.audit.sdk.annotation.AuditLog;
|
import jnpf.base.ActionResultCode;
|
import jnpf.dmsEntity.storage.DmsTemplateNotification;
|
import jnpf.dmsMapper.DmsTemplateNotificationMapper;
|
import jnpf.exception.DataException;
|
import jnpf.message.SentMessageApi;
|
import jnpf.message.model.DmsUpgradeMessage;
|
import jnpf.util.JsonUtil;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
import java.util.*;
|
|
/** 与文件登记重试独立；通知重试每次查询模板最新部门，远端按事件/用户幂等落站内信。 */
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class DmsTemplateNotificationService {
|
private final DmsTemplateNotificationMapper mapper;
|
private final SentMessageApi messages;
|
|
@Scheduled(cron = "${dms.template-upgrade-notification.cron:0 * * * * ?}")
|
@AuditLog(action = "DMS_TEMPLATE_UPGRADE_NOTIFY", bizCodeExpr = "''", recordSuccess = false)
|
public void recover() {
|
mapper.discover();
|
for (DmsTemplateNotification event : mapper.pending()) deliver(event);
|
}
|
|
/** 工作流回调即时尝试；失败只留通知重试，不阻塞已有文件登记。 */
|
public void approved(String tenant, String task) {
|
try {
|
mapper.discover();
|
DmsTemplateNotification event = mapper.find(tenant, task);
|
if (event != null) deliver(event);
|
} catch (RuntimeException failure) {
|
log.error("升版通知待自动恢复 tenant={} task={}", tenant, task, failure);
|
}
|
}
|
|
void deliver(DmsTemplateNotification event) {
|
String token = UUID.randomUUID().toString();
|
if (mapper.claim(event, token) != 1) return;
|
try {
|
Map<String,Object> template = mapper.template(event.getTenantId(), event.getTemplateId());
|
if (template == null) throw new DataException("来源模板不存在或已删除");
|
List<String> departments = departmentIds(template.get("departments"));
|
List<String> users = departments.isEmpty() ? List.of() : mapper.recipients(event.getTenantId(), departments);
|
if (!users.isEmpty()) {
|
DmsUpgradeMessage request = new DmsUpgradeMessage();
|
request.setTenantId(event.getTenantId()); request.setTaskId(event.getTaskId());
|
request.setActorId(event.getActorId()); request.setToUserIds(users);
|
Map<String,String> parameters = new LinkedHashMap<>();
|
parameters.put("DocumentNo", Objects.toString(event.getDocumentNo(), ""));
|
parameters.put("DocumentName", Objects.toString(event.getDocumentName(), ""));
|
parameters.put("Version", Objects.toString(event.getVersionLabel(), ""));
|
parameters.put("TemplateName", Objects.toString(template.get("name"), ""));
|
request.setParameters(parameters);
|
var result = messages.sendDmsUpgrade(request);
|
if (result == null || !ActionResultCode.SUCCESS.getCode().equals(result.getCode())
|
|| !Boolean.TRUE.equals(result.getData())) throw new DataException("站内信未返回持久化成功确认");
|
}
|
if (mapper.finish(event, token, null, users.isEmpty() ? "NO_RECIPIENTS" : "SENT") != 1)
|
throw new DataException("通知执行租约已变化");
|
} catch (RuntimeException failure) {
|
String error = Objects.toString(failure.getMessage(), failure.getClass().getSimpleName());
|
mapper.finish(event, token, error.substring(0, Math.min(error.length(), 1000)), "RETRY");
|
log.error("升版模板部门通知失败，保留任务待重试 tenant={} task={}", event.getTenantId(), event.getTaskId(), failure);
|
}
|
}
|
|
static List<String> departmentIds(Object value) {
|
if (value == null || value instanceof String && ((String) value).isBlank()) return List.of();
|
Object parsed = value instanceof String ? JsonUtil.getJsonToBean((String) value, List.class) : value;
|
if (!(parsed instanceof List<?>)) throw new DataException("模板提醒部门配置不是数组");
|
Set<String> result = new LinkedHashSet<>();
|
for (Object id : (List<?>) parsed) {
|
if (!(id instanceof String) || ((String) id).isBlank()) throw new DataException("模板提醒部门ID无效");
|
result.add((String) id);
|
}
|
return new ArrayList<>(result);
|
}
|
}
|
