package jnpf.message.service;

import jnpf.base.UserInfo;
import jnpf.exception.DataException;
import jnpf.message.entity.MessageReceiveEntity;
import jnpf.message.entity.MessageTemplateConfigEntity;
import jnpf.message.mapper.DmsUpgradeMessageMapper;
import jnpf.message.model.DmsUpgradeMessage;
import jnpf.message.util.PushMessageUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.web.util.HtmlUtils;
import java.util.*;

/** DMS专属可靠站内信分支；不改变其他消息的发送行为。 */
@Slf4j
@Service
@RequiredArgsConstructor
public class DmsUpgradeMessageService {
    private final DmsUpgradeMessageMapper mapper;

    @Transactional(rollbackFor = Exception.class)
    public boolean send(DmsUpgradeMessage request) {
        if (request == null || blank(request.getTenantId()) || blank(request.getTaskId())
                || request.getToUserIds() == null || request.getToUserIds().isEmpty()
                || request.getToUserIds().stream().anyMatch(DmsUpgradeMessageService::blank))
            throw new DataException("升版通知缺少事件或接收人");
        List<MessageTemplateConfigEntity> templates = mapper.templates(request.getTenantId());
        if (templates.size() != 1) throw new DataException("请配置唯一且启用的站内信模板 dmsTemplateUpgrade");
        MessageTemplateConfigEntity template = templates.get(0);
        if (blank(template.getTitle()) || blank(template.getContent())) throw new DataException("升版消息模板标题或正文为空");
        String title = render(template.getTitle(), request.getParameters(), false);
        String content = render(template.getContent(), request.getParameters(), true);
        Map<String,MessageReceiveEntity> inserted = new LinkedHashMap<>();
        for (String user : new LinkedHashSet<>(request.getToUserIds())) {
            if (mapper.claimDelivery(request.getTenantId(), request.getTaskId(), user) == 0) continue;
            MessageReceiveEntity message = new MessageReceiveEntity();
            message.setId(UUID.randomUUID().toString().replace("-", "")); message.setUserId(user);
            message.setTitle(title); message.setBodyText(content); message.setType(3); message.setIsRead(0);
            message.setCreatorUserId(request.getActorId()); message.setCreatorTime(new Date());
            if (mapper.insertMessage(message, request.getTenantId()) != 1) throw new DataException("站内信保存失败");
            inserted.put(user, message);
        }
        UserInfo actor = new UserInfo(); actor.setTenantId(request.getTenantId()); actor.setUserId(request.getActorId());
        // 事务提交即为可靠送达；WebSocket仅刷新在线界面，不把离线或推送失败误判为丢消息。
        if (!inserted.isEmpty()) TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override public void afterCommit() {
                try { PushMessageUtil.pushMessage(inserted, actor, 3); }
                catch (RuntimeException error) { log.warn("升版站内信已保存，在线推送刷新失败", error); }
            }
        });
        return true;
    }

    static String render(String template, Map<String,String> values, boolean html) {
        java.util.regex.Matcher matcher = java.util.regex.Pattern.compile("\\{@([A-Za-z][A-Za-z0-9]*)}").matcher(template);
        StringBuffer result = new StringBuffer();
        while (matcher.find()) {
            String value = values == null ? null : values.get(matcher.group(1));
            if (value == null) throw new DataException("升版消息模板包含未知参数：" + matcher.group(1));
            matcher.appendReplacement(result, java.util.regex.Matcher.quoteReplacement(html ? HtmlUtils.htmlEscape(value) : value));
        }
        matcher.appendTail(result); return result.toString();
    }
    private static boolean blank(String value) { return value == null || value.isBlank(); }
}