package jnpf.limsService.impl;
|
|
import jnpf.limsEntity.LimsJianyanXiangEntity;
|
import jnpf.limsEntity.LimsMessageEvent;
|
import jnpf.limsEntity.LimsMessageRequest;
|
import jnpf.limsEntity.LimsMessageSendResult;
|
import jnpf.limsEntity.LimsRecipientRef;
|
import jnpf.limsMapper.LimsJianceTaskRemindMapper;
|
import jnpf.limsService.LimsJianceTaskRemindService;
|
import jnpf.limsService.LimsMessageService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class LimsJianceTaskRemindServiceImpl implements LimsJianceTaskRemindService {
|
private static final String DATE_PATTERN = "yyyy-MM-dd";
|
|
private final LimsJianceTaskRemindMapper remindMapper;
|
private final LimsMessageService messageService;
|
|
@Value("${lims.message.enabled:false}")
|
private boolean messageEnabled;
|
|
@Scheduled(cron = "${lims.remind.cron:0 0 8 * * ?}")
|
public void cronTrigger() {
|
if (!messageEnabled) {
|
log.info("[lims-remind] skipped because lims.message.enabled=false");
|
return;
|
}
|
log.info("[lims-remind] cron triggered");
|
scanAndRemind(false);
|
}
|
|
@Override
|
public Map<String, Map<String, Integer>> scanAndRemind(boolean dryRun) {
|
Map<String, Map<String, Integer>> stats = new LinkedHashMap<>();
|
stats.put("D7", processDueIn(7, dryRun));
|
stats.put("D3", processDueIn(3, dryRun));
|
stats.put("D1", processDueIn(1, dryRun));
|
stats.put("EXPIRED", processExpired(dryRun));
|
log.info("[lims-remind] done, dryRun={}, stats={}", dryRun, stats);
|
return stats;
|
}
|
|
private Map<String, Integer> processDueIn(int days, boolean dryRun) {
|
String stage = "D" + days;
|
List<LimsJianyanXiangEntity> rows = remindMapper.selectDueIn(days, stage);
|
int sent = 0;
|
for (LimsJianyanXiangEntity row : rows) {
|
LimsMessageSendResult result = messageService.send(LimsMessageRequest.builder()
|
.event(LimsMessageEvent.INSPECTION_TASK_DUE)
|
.tenantId(row.getTenantId())
|
.bizId(row.getId())
|
.remindStage(stage)
|
.occurrenceKey(occurrenceKey(LimsMessageEvent.INSPECTION_TASK_DUE, row, stage))
|
.recipients(Arrays.asList(LimsRecipientRef.user(row.getJianchaRen())))
|
.parameters(dueParameters(row, days))
|
.dryRun(dryRun)
|
.build());
|
if (isComplete(result)) {
|
sent++;
|
appendLegacyFlag(row.getId(), stage, dryRun);
|
}
|
}
|
return statRow(rows.size(), sent);
|
}
|
|
private Map<String, Integer> processExpired(boolean dryRun) {
|
List<LimsJianyanXiangEntity> rows = remindMapper.selectExpired();
|
int sent = 0;
|
for (LimsJianyanXiangEntity row : rows) {
|
List<LimsRecipientRef> recipients = new ArrayList<>();
|
recipients.add(LimsRecipientRef.user(row.getJianchaRen()));
|
recipients.add(LimsRecipientRef.user(row.getRenwuFenpeiren()));
|
LimsMessageSendResult result = messageService.send(LimsMessageRequest.builder()
|
.event(LimsMessageEvent.INSPECTION_TASK_OVERDUE)
|
.tenantId(row.getTenantId())
|
.bizId(row.getId())
|
.remindStage("OVERDUE")
|
.occurrenceKey(occurrenceKey(LimsMessageEvent.INSPECTION_TASK_OVERDUE, row, "OVERDUE"))
|
.recipients(recipients)
|
.parameters(dueParameters(row, 0))
|
.dryRun(dryRun)
|
.build());
|
if (isComplete(result)) {
|
sent++;
|
appendLegacyFlag(row.getId(), "EXPIRED", dryRun);
|
}
|
}
|
return statRow(rows.size(), sent);
|
}
|
|
private Map<String, Object> dueParameters(LimsJianyanXiangEntity row, int remainingDays) {
|
Map<String, Object> parameters = new HashMap<>();
|
parameters.put("bizId", row.getId());
|
parameters.put("remainingDays", remainingDays);
|
parameters.put("dueDate", formatDate(row.getWanchengRiqi()));
|
parameters.put("productName", value(row.getChanpinMingcheng()));
|
parameters.put("batchNo", value(row.getPihao()));
|
parameters.put("itemName", value(row.getJianyanXiangmuMingcheng()));
|
return parameters;
|
}
|
|
private String occurrenceKey(LimsMessageEvent event, LimsJianyanXiangEntity row, String stage) {
|
return event.getCode() + ":" + row.getId() + ":" + formatCompactDate(row.getWanchengRiqi()) + ":" + stage;
|
}
|
|
private void appendLegacyFlag(String rowId, String flag, boolean dryRun) {
|
if (!dryRun) {
|
remindMapper.appendFlag(rowId, flag);
|
}
|
}
|
|
private String formatDate(Date date) {
|
return date == null ? "" : new SimpleDateFormat(DATE_PATTERN).format(date);
|
}
|
|
private String formatCompactDate(Date date) {
|
return date == null ? "NO_DATE" : new SimpleDateFormat("yyyyMMdd").format(date);
|
}
|
|
private String value(String value) {
|
return value == null ? "" : value;
|
}
|
|
private Map<String, Integer> statRow(int hit, int sent) {
|
Map<String, Integer> row = new HashMap<>();
|
row.put("hit", hit);
|
row.put("sent", sent);
|
row.put("skipped", hit - sent);
|
return row;
|
}
|
|
private boolean isComplete(LimsMessageSendResult result) {
|
return result.isAccepted() && result.getRecipientCount() > 0
|
&& result.getSentCount() == result.getRecipientCount()
|
&& result.getFailedCount() == 0;
|
}
|
}
|
