From ab6eb14b5081e2ca979f84bbb97cb68db57a6791 Mon Sep 17 00:00:00 2001
From: wayne <wayne8692wayne8692@gmail.com>
Date: 星期一, 24 一月 2022 10:52:14 +0800
Subject: [PATCH] [ref] 調整命名以及修正未填寫滿意度的小鈴鐺批次時間
---
pamapi/src/main/java/com/pollex/pam/service/SendMsgService.java | 94 +++++++++++++++++++++++++++++++----------------
1 files changed, 62 insertions(+), 32 deletions(-)
diff --git a/pamapi/src/main/java/com/pollex/pam/service/SendMsgService.java b/pamapi/src/main/java/com/pollex/pam/service/SendMsgService.java
index 650fbac..05d8d73 100644
--- a/pamapi/src/main/java/com/pollex/pam/service/SendMsgService.java
+++ b/pamapi/src/main/java/com/pollex/pam/service/SendMsgService.java
@@ -1,7 +1,9 @@
package com.pollex.pam.service;
+import com.fasterxml.jackson.databind.ObjectMapper;
import com.pollex.pam.config.ApplicationProperties;
import com.pollex.pam.config.ApplicationProperties.SMS;
+import com.pollex.pam.repository.ConsultantRepository;
import com.pollex.pam.service.dto.*;
import com.pollex.pam.service.util.HttpRequestUtil;
import com.pollex.pam.web.rest.errors.SendEmailFailException;
@@ -11,15 +13,13 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
+import org.thymeleaf.spring5.SpringTemplateEngine;
import java.nio.charset.StandardCharsets;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
-import java.util.Base64;
+import java.util.*;
import java.util.Base64.Encoder;
-import java.util.Collections;
-import java.util.List;
-import java.util.UUID;
@Service
public class SendMsgService {
@@ -27,11 +27,24 @@
private static final Logger log = LoggerFactory.getLogger(SendMsgService.class);
private final Encoder encoder = Base64.getEncoder();
+ private static final String SEND_SMS_SUCCESS_CODE = "1";
+
@Autowired
ApplicationProperties applicationProperties;
- public void sendMsgBySMS(String toMobile, String content) throws SendSMSFailException{
- SMS smsProperties = applicationProperties.getSms();
+ @Autowired
+ ConsultantRepository consultantRepository;
+
+ @Autowired
+ SpringTemplateEngine springTemplateEngine;
+
+ public SendSMSResponse sendMsgBySMS(String toMobile, String content) throws SendSMSFailException {
+ if(!applicationProperties.isSendNotifyMsg()) {
+// return getMockSMSResponse();
+ return null;
+ }
+
+ SMS smsProperties = applicationProperties.getSms();
SendSMSRequest sendSMSRequest = new SendSMSRequest();
sendSMSRequest.setpKey(UUID.randomUUID().toString());
@@ -39,7 +52,7 @@
sendSMSRequest.setSender(smsProperties.getSender());
sendSMSRequest.setMsgTypeSet(smsProperties.getSmsType());
sendSMSRequest.setSendTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:00")));
- sendSMSRequest.setSubject("");
+ sendSMSRequest.setSubject(encoder.encodeToString(smsProperties.getSubject().getBytes(StandardCharsets.UTF_8)));
sendSMSRequest.setActivityId("");
SMSDetail smsDetail = new SMSDetail();
@@ -50,26 +63,38 @@
try {
ResponseEntity<SendSMSResponse> responseEntity = HttpRequestUtil.postWithJson(smsProperties.getUrl(), sendSMSRequest, SendSMSResponse.class);
+ SendSMSResponse response = responseEntity.getBody();
log.debug("response status code = {}", responseEntity.getStatusCode());
log.debug("smsResponse = {}", responseEntity.getBody());
- // todo ����閬�����隤方������葫��
- }
- catch (Exception e) {
- log.debug("send sms failed!", e);
- throw new SendSMSFailException();
+ if(!SEND_SMS_SUCCESS_CODE.equals(response.getReturnCode())) {
+ throw new SendSMSFailException("sms service return code = " + response.getReturnCode() + ", error_msg = " + response.getErrorMsg());
+ }
+
+ return responseEntity.getBody();
+ } catch (SendSMSFailException e) {
+ throw e;
+ } catch (Exception e) {
+ log.warn("send sms fail by other reason!", e);
+ throw new SendSMSFailException("send sms fail by other reason!");
}
}
- public void sendMsgByEmail(String from, String to, String subject, String content, boolean htmlFormat) throws SendEmailFailException{
- sendMsgByEmail(from, to, subject, content, htmlFormat, Collections.emptyList(), Collections.emptyList());
+// private SendSMSResponse getMockSMSResponse() {
+// SendSMSResponse mock = new SendSMSResponse();
+// mock.set
+// return null;
+// }
+
+ public String sendMsgByEmail(String to, String subject, String content, boolean htmlFormat) throws SendEmailFailException{
+ return sendMsgByEmail(to, subject, content, htmlFormat, Collections.emptyList(), Collections.emptyList());
}
- public void sendMsgByEmail(
- String fromAddress, String toAddress, String subject, String content, boolean htmlFormat, List<String> toCCAddress,
- List<String> attachments) throws SendEmailFailException
- {
+ public String sendMsgByEmail(String toAddress, String subject, String content, boolean htmlFormat, List<String> toCCAddress,
+ List<String> attachments) throws SendEmailFailException {
+ String fromAddress = applicationProperties.getEmail().getSenderEmail();
+
SendMailRequest sendMailRequest = new SendMailRequest();
sendMailRequest.setSendMailAddresses(Collections.singletonList(toAddress));
sendMailRequest.setFrom(fromAddress);
@@ -80,28 +105,33 @@
sendMailRequest.setHtmlFormat(htmlFormat);
sendMailRequest.setFunctionId(applicationProperties.getEmail().getFunctionId());
- sendMsgByEmail(sendMailRequest);
+ return sendMsgByEmail(sendMailRequest);
}
- public void sendMsgByEmail(SendMailRequest sendMailRequest) throws SendEmailFailException{
- try {
- ResponseEntity<SendMailResponse> responseEntity =
- HttpRequestUtil.postWithJson( applicationProperties.getEmail().getUrl(), sendMailRequest, SendMailResponse.class);
+ public String sendMsgByEmail(SendMailRequest sendMailRequest) throws SendEmailFailException{
+ if(!applicationProperties.isSendNotifyMsg()) {
+ return null;
+ }
+ try {
+ ResponseEntity<String> responseEntity =
+ HttpRequestUtil.postWithJson( applicationProperties.getEmail().getUrl(), sendMailRequest, String.class);
+ log.debug("responseEntity = {}", responseEntity);
- SendMailResponse sendMailResponse = responseEntity.getBody();
- log.debug("response status code = {}", responseEntity.getStatusCode());
- log.debug("emailResponse = {}", responseEntity.getBody());
+ String rawResponseString = responseEntity.getBody();
+ SendMailResponse sendMailResponse = new ObjectMapper().readValue(rawResponseString, SendMailResponse.class);
+ log.debug("sendMailResponse = {}", sendMailResponse);
- if(sendMailResponse == null || sendMailResponse.getData() == null || "ADDED".equalsIgnoreCase(sendMailResponse.getData().getMessageStatus())) {
- throw new SendEmailFailException();
+ if(sendMailResponse == null || sendMailResponse.getData() == null || !"ADDED".equalsIgnoreCase(sendMailResponse.getData().getMessageStatus())) {
+ throw new SendEmailFailException("send email service return error msg! raw response string= " + rawResponseString);
}
+
+ return responseEntity.getBody();
}
catch (SendEmailFailException e) {
throw e;
- }
- catch (Exception e) {
- log.debug("send email failed!", e);
- throw new SendEmailFailException();
+ } catch (Exception e) {
+ log.warn("send email fail by other reason", e);
+ throw new SendEmailFailException("send email failed!");
}
}
}
--
Gitblit v1.8.0