package cn.iocoder.yudao.module.mes.service.dv.metering;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.iocoder.yudao.module.infra.api.config.ConfigApi;
|
import cn.iocoder.yudao.module.mes.dal.dataobject.dv.metering.MesDvMeteringDO;
|
import cn.iocoder.yudao.module.mes.dal.mysql.dv.metering.MesDvMeteringMapper;
|
import cn.iocoder.yudao.module.mes.dal.redis.dv.metering.MesDvMeteringRemindRedisDAO;
|
import cn.iocoder.yudao.module.system.api.notify.NotifyMessageSendApi;
|
import cn.iocoder.yudao.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDate;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* MES 计量器具到期提醒 Service 实现类
|
*
|
* @author 超级管理员
|
*/
|
@Slf4j
|
@Service
|
public class MesDvMeteringRemindServiceImpl implements MesDvMeteringRemindService {
|
|
/**
|
* 提醒天数配置 KEY（infra_config）
|
*/
|
private static final String REMIND_DAYS_CONFIG_KEY = "mes.dv-metering.remind-days";
|
/**
|
* 提醒天数默认值
|
*/
|
private static final int DEFAULT_REMIND_DAYS = 30;
|
/**
|
* 到期提醒站内信模板编号
|
*/
|
private static final String REMIND_TEMPLATE_CODE = "mes_metering_expire_remind";
|
|
@Resource
|
private MesDvMeteringMapper meteringMapper;
|
@Resource
|
private MesDvMeteringRemindRedisDAO meteringRemindRedisDAO;
|
@Resource
|
private ConfigApi configApi;
|
@Resource
|
private NotifyMessageSendApi notifyMessageSendApi;
|
|
@Override
|
public void sendExpireRemind() {
|
try {
|
// 1. 抢当天扫描门闩，避免多实例/多次并发重复扫描
|
LocalDate today = LocalDate.now();
|
if (!meteringRemindRedisDAO.tryAcquireScanLock(today)) {
|
return;
|
}
|
// 2. 读取提醒天数（默认 30）
|
int remindDays = getRemindDays();
|
// 3. 查询 [today, today + remindDays] 到期的器具
|
List<MesDvMeteringDO> list = meteringMapper.selectListByNextCheckDateBetween(
|
today, today.plusDays(remindDays));
|
// 4. 逐台发送站内信（按器具 + 到期日去重）
|
for (MesDvMeteringDO metering : list) {
|
if (metering.getChargeUserId() == null || metering.getNextCheckDate() == null) {
|
continue;
|
}
|
if (!meteringRemindRedisDAO.tryMarkReminded(metering.getId(), metering.getNextCheckDate())) {
|
continue;
|
}
|
sendRemindMessage(metering);
|
}
|
} catch (Exception ex) {
|
// best-effort：提醒失败不影响列表查询
|
log.error("[sendExpireRemind][发送计量器具到期提醒失败]", ex);
|
}
|
}
|
|
private int getRemindDays() {
|
String value = configApi.getConfigValueByKey(REMIND_DAYS_CONFIG_KEY);
|
if (StrUtil.isBlank(value)) {
|
return DEFAULT_REMIND_DAYS;
|
}
|
try {
|
return Integer.parseInt(value.trim());
|
} catch (NumberFormatException ex) {
|
log.warn("[getRemindDays][配置 {} 的值 {} 非法，使用默认值 {}]", REMIND_DAYS_CONFIG_KEY, value, DEFAULT_REMIND_DAYS);
|
return DEFAULT_REMIND_DAYS;
|
}
|
}
|
|
private void sendRemindMessage(MesDvMeteringDO metering) {
|
Map<String, Object> params = new HashMap<>();
|
params.put("meteringCode", metering.getCode());
|
params.put("meteringName", metering.getName());
|
params.put("nextCheckDate", metering.getNextCheckDate().toString());
|
NotifySendSingleToUserReqDTO reqDTO = new NotifySendSingleToUserReqDTO()
|
.setUserId(metering.getChargeUserId())
|
.setTemplateCode(REMIND_TEMPLATE_CODE)
|
.setTemplateParams(params);
|
notifyMessageSendApi.sendSingleMessageToAdmin(reqDTO);
|
}
|
|
}
|
