package com.qianwen.smartman.modules.notify.manager;

import cn.hutool.json.JSONUtil;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.core.notify.provider.internal.message.IInternalMessageServer;
import com.qianwen.core.notify.provider.internal.message.ParsedInternalMessageTemplate;
import com.qianwen.core.tool.jackson.JsonUtil;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.core.websocket.distribute.MessageDO;
import com.qianwen.core.websocket.distribute.RedisMessageDistributor;
import com.qianwen.smartman.modules.notify.entity.NotifySystem;
import com.qianwen.smartman.modules.notify.service.INotifySystemService;
import com.qianwen.smartman.modules.notify.websocket.InternalMessageResponseJsonWebSocketMessage;
import org.springframework.stereotype.Component;

@Component
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/notify/manager/DefaultInternalMessageServer.class */
class DefaultInternalMessageServer implements IInternalMessageServer {
    private static final Logger log = LoggerFactory.getLogger(DefaultInternalMessageServer.class);
    private final INotifySystemService notifySystemService;

    public DefaultInternalMessageServer(final INotifySystemService notifySystemService) {
        this.notifySystemService = notifySystemService;
    }

    public void submitInternalMessage(ParsedInternalMessageTemplate template, List<String> sendTo) {
        if (Func.isNotEmpty(sendTo)) {
            List<NotifySystem> notifySystems = new ArrayList<>(sendTo.size());
            Date now = new Date();
            sendTo.forEach(item -> {
                NotifySystem notifySystem = new NotifySystem();
                notifySystem.setNotifyType(1);
                notifySystem.setNotifyTime(now);
                notifySystem.setMessage(template.getContent());
                notifySystem.setAttachments(JsonUtil.toJson(template.getAttachments()));
                notifySystem.setBusinessName(template.getSubject());
                notifySystem.setNotifyUser(item);
                notifySystem.setStatus(0);
                notifySystems.add(notifySystem);
            });
            this.notifySystemService.saveBatch(notifySystems);
            notifySystems.forEach(o -> {
                RedisMessageDistributor messageDistributor = (RedisMessageDistributor) SpringUtil.getBean(RedisMessageDistributor.class);
                InternalMessageResponseJsonWebSocketMessage internalMessageResponseJsonWebSocketMessage = new InternalMessageResponseJsonWebSocketMessage();
                internalMessageResponseJsonWebSocketMessage.setHaveUnread(true);
                internalMessageResponseJsonWebSocketMessage.setNotifySystemId(String.valueOf(o.getId()));
                internalMessageResponseJsonWebSocketMessage.setNotifyType(1);
                MessageDO messageDO = new MessageDO();
                messageDO.setNeedBroadcast(Boolean.FALSE);
                messageDO.setMessageText(JSONUtil.toJsonStr(internalMessageResponseJsonWebSocketMessage));
                messageDO.setSessionKeys(Arrays.asList(o.getNotifyUser()));
                messageDistributor.distribute(messageDO);
            });
        }
    }
}