package jnpf.limsService.impl;
|
|
import jnpf.limsEntity.LimsMessageDeliveryEntity;
|
import jnpf.limsEntity.LimsMessageDeliveryStatus;
|
import jnpf.limsEntity.LimsMessageEventEntity;
|
import jnpf.limsEntity.LimsMessageEventStatus;
|
import jnpf.limsEntity.LimsMessageLedger;
|
import jnpf.limsEntity.LimsMessageRequest;
|
import jnpf.limsMapper.LimsMessageDeliveryMapper;
|
import jnpf.limsMapper.LimsMessageEventMapper;
|
import jnpf.util.JsonUtil;
|
import jnpf.util.RandomUtil;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@RequiredArgsConstructor
|
public class LimsMessageLedgerService {
|
private final LimsMessageEventMapper eventMapper;
|
private final LimsMessageDeliveryMapper deliveryMapper;
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
|
public LimsMessageLedger initialize(LimsMessageRequest request, List<String> recipients) {
|
Date now = new Date();
|
LimsMessageEventEntity event = new LimsMessageEventEntity();
|
event.setId(RandomUtil.uuId());
|
event.setTenantId(request.getTenantId());
|
event.setEventCode(request.getEvent().getCode());
|
event.setBizId(request.getBizId());
|
event.setRemindStage(request.getRemindStage());
|
event.setOccurrenceKey(request.getOccurrenceKey());
|
event.setRecipientSnapshot(JsonUtil.getObjectToString(request.getRecipients()));
|
event.setParameterSnapshot(JsonUtil.getObjectToString(request.getParameters()));
|
event.setStatus(LimsMessageEventStatus.PENDING);
|
event.setRecipientCount(recipients.size());
|
event.setSentCount(0);
|
event.setFailedCount(0);
|
event.setRetryCount(0);
|
event.setCreatedTime(now);
|
event.setLastModifyTime(now);
|
if (eventMapper.insertIfAbsent(event) == 0) {
|
return LimsMessageLedger.duplicate();
|
}
|
|
List<LimsMessageDeliveryEntity> deliveries = new ArrayList<>(recipients.size());
|
for (String recipient : recipients) {
|
LimsMessageDeliveryEntity delivery = new LimsMessageDeliveryEntity();
|
delivery.setId(RandomUtil.uuId());
|
delivery.setEventId(event.getId());
|
delivery.setTenantId(event.getTenantId());
|
delivery.setRecipientUserId(recipient);
|
delivery.setDeliveryKey(event.getTenantId() + ":" + event.getId() + ":" + recipient);
|
delivery.setStatus(LimsMessageDeliveryStatus.PENDING);
|
delivery.setRetryCount(0);
|
delivery.setCreatedTime(now);
|
delivery.setLastModifyTime(now);
|
deliveryMapper.insert(delivery);
|
deliveries.add(delivery);
|
}
|
return new LimsMessageLedger(true, event, deliveries);
|
}
|
}
|
