125 lines
8.0 KiB
Java
125 lines
8.0 KiB
Java
package gr.cite.notification.service.message.builder;
|
|
|
|
import gr.cite.notification.cache.NotificationTemplateCache;
|
|
import gr.cite.notification.common.StringUtils;
|
|
import gr.cite.notification.common.enums.IsActive;
|
|
import gr.cite.notification.common.enums.NotificationContactType;
|
|
import gr.cite.notification.common.enums.NotificationTemplateChannel;
|
|
import gr.cite.notification.common.enums.NotificationTemplateKind;
|
|
import gr.cite.notification.common.types.notification.FieldInfo;
|
|
import gr.cite.notification.config.notification.NotificationConfig;
|
|
import gr.cite.notification.config.notification.NotificationProperties;
|
|
import gr.cite.notification.data.LanguageEntity;
|
|
import gr.cite.notification.data.NotificationEntity;
|
|
import gr.cite.notification.errorcode.ErrorThesaurusProperties;
|
|
import gr.cite.notification.model.NotificationTemplate;
|
|
import gr.cite.notification.query.LanguageQuery;
|
|
import gr.cite.notification.query.NotificationTemplateQuery;
|
|
import gr.cite.notification.service.formatting.FormattingService;
|
|
import gr.cite.notification.service.message.common.MessageBuilderBase;
|
|
import gr.cite.notification.service.message.infobuilder.MessageInfoBuilderService;
|
|
import gr.cite.notification.service.message.model.EmailMessage;
|
|
import gr.cite.notification.service.message.model.Message;
|
|
import gr.cite.notification.service.message.model.MessageInfo;
|
|
import gr.cite.notification.service.notificationtemplate.NotificationTemplateService;
|
|
import gr.cite.tools.cipher.CipherService;
|
|
import gr.cite.tools.cipher.config.CipherProfileProperties;
|
|
import gr.cite.tools.data.query.QueryFactory;
|
|
import gr.cite.tools.logging.LoggerService;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.web.context.annotation.RequestScope;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.Map;
|
|
import java.util.UUID;
|
|
|
|
@Component
|
|
@RequestScope
|
|
public class EmailMessageBuilder extends MessageBuilderBase implements MessageBuilder{
|
|
private static final LoggerService logger = new LoggerService(LoggerFactory.getLogger(EmailMessageBuilder.class));
|
|
private final NotificationProperties properties;
|
|
private final Map<String, Map<UUID, NotificationProperties.Flow>> flowMap;
|
|
private final MessageInfoBuilderService messageInfoBuilderService;
|
|
private final Map<UUID, FieldCiphering> cipherFields;
|
|
private final NotificationTemplateService notificationTemplateService;
|
|
private final QueryFactory queryFactory;
|
|
|
|
@Autowired
|
|
public EmailMessageBuilder(NotificationProperties properties,
|
|
@Qualifier(NotificationConfig.BeanQualifier.FLOW_MAP)
|
|
Map<String, Map<UUID, NotificationProperties.Flow>> flowMap,
|
|
MessageInfoBuilderService messageInfoBuilderService,
|
|
ErrorThesaurusProperties errors,
|
|
@Qualifier(NotificationConfig.BeanQualifier.CIPHER_FIELDS)
|
|
Map<UUID, FieldCiphering> cipherFields,
|
|
CipherService cipherService,
|
|
CipherProfileProperties cipherProfileProperties,
|
|
FormattingService formattingService,
|
|
NotificationTemplateCache cache, NotificationTemplateService notificationTemplateService, QueryFactory queryFactory) {
|
|
super(logger, errors, cipherService, cipherProfileProperties, formattingService, cache);
|
|
this.properties = properties;
|
|
this.flowMap = flowMap;
|
|
this.messageInfoBuilderService = messageInfoBuilderService;
|
|
this.cipherFields = cipherFields;
|
|
this.notificationTemplateService = notificationTemplateService;
|
|
this.queryFactory = queryFactory;
|
|
}
|
|
|
|
@Override
|
|
public Message buildMessage(NotificationEntity notification) {
|
|
MessageInfo messageInfo = this.messageInfoBuilderService.buildMessageInfo(notification);
|
|
NotificationProperties.Flow flow = this.flowMap.get("email").getOrDefault(notification.getType(), null);
|
|
if (flow == null) return null;
|
|
|
|
NotificationTemplate template = notificationTemplateService.lookupOverriddenTemplates(notification.getType(), NotificationTemplateChannel.Email, this.queryFactory.query(LanguageQuery.class).codes(messageInfo.getLanguage()).isActive(IsActive.Active).first().getId());
|
|
String subjectTemplate = null;
|
|
ReplaceResult subjectResult = null;
|
|
String bodyTemplate = null;
|
|
ReplaceResult bodyResult = null;
|
|
|
|
// fallback
|
|
if (template != null && template.getValue() != null){
|
|
if (!StringUtils.isNullOrEmpty(template.getValue().getSubjectKey())) subjectTemplate = messageInfo.getFields().stream().filter(fieldInfo -> fieldInfo.getKey().equals(template.getValue().getSubjectKey())).findFirst().orElse(new FieldInfo()).getValue();
|
|
if (StringUtils.isNullOrEmpty(subjectTemplate)) subjectTemplate = template.getValue().getSubjectText();
|
|
FieldFormatting subjectFormatting = this.buildFieldFormatting(template.getValue().getSubjectFieldOptions());
|
|
subjectResult = this.buildTemplate(notification.getId(), subjectTemplate, messageInfo, template.getValue().getSubjectFieldOptions(), subjectFormatting, cipherFields.get(notification.getType()));
|
|
|
|
if(!StringUtils.isNullOrEmpty(template.getValue().getBodyKey())) bodyTemplate = messageInfo.getFields().stream().filter(fieldInfo -> fieldInfo.getKey().equals(template.getValue().getBodyKey())).findFirst().orElse(new FieldInfo()).getValue();
|
|
if (StringUtils.isNullOrEmpty(bodyTemplate)) bodyTemplate = template.getValue().getBodyText();
|
|
FieldFormatting bodyFormatting = this.buildFieldFormatting(template.getValue().getBodyFieldOptions());
|
|
bodyResult = this.buildTemplate(notification.getId(), bodyTemplate, messageInfo, template.getValue().getBodyFieldOptions(), bodyFormatting, cipherFields.get(notification.getType()));
|
|
}else {
|
|
if(!StringUtils.isNullOrEmpty(flow.getSubjectKey())) subjectTemplate = messageInfo.getFields().stream().filter(fieldInfo -> fieldInfo.getKey().equals(flow.getSubjectKey())).findFirst().orElse(new FieldInfo()).getValue();
|
|
if (StringUtils.isNullOrEmpty(subjectTemplate)) subjectTemplate = this.lookupOrReadLocalizedFile(this.getTemplate().getTemplateCache(), flow.getSubjectPath(), messageInfo.getLanguage());
|
|
FieldFormatting subjectFormatting = this.buildFieldFormatting(flow.getSubjectFieldOptions());
|
|
subjectResult = this.buildTemplate(notification.getId(), subjectTemplate, messageInfo, flow.getSubjectFieldOptions(), subjectFormatting, cipherFields.get(notification.getType()));
|
|
|
|
if(!StringUtils.isNullOrEmpty(flow.getBodyKey())) bodyTemplate = messageInfo.getFields().stream().filter(fieldInfo -> fieldInfo.getKey().equals(flow.getBodyKey())).findFirst().orElse(new FieldInfo()).getValue();
|
|
if (StringUtils.isNullOrEmpty(bodyTemplate)) bodyTemplate = this.lookupOrReadLocalizedFile(this.getTemplate().getTemplateCache(), flow.getBodyPath(), messageInfo.getLanguage());
|
|
FieldFormatting bodyFormatting = this.buildFieldFormatting(flow.getBodyFieldOptions());
|
|
bodyResult = this.buildTemplate(notification.getId(), bodyTemplate, messageInfo, flow.getBodyFieldOptions(), bodyFormatting, cipherFields.get(notification.getType()));
|
|
|
|
}
|
|
if (bodyResult != null && subjectResult != null) {
|
|
EmailMessage emailMessage = new EmailMessage();
|
|
emailMessage.setBody(bodyResult.getText());
|
|
emailMessage.setSubject(subjectResult.getText());
|
|
|
|
return emailMessage;
|
|
}
|
|
return null;
|
|
}
|
|
|
|
private NotificationProperties.Template getTemplate() {
|
|
return this.properties.getMessage().get("email");
|
|
}
|
|
|
|
@Override
|
|
public NotificationContactType supports() {
|
|
return NotificationContactType.EMAIL;
|
|
}
|
|
}
|