更新 SMSServiceTest.java

src/main/java/com/kimgo/wepush/common/PhoneNumberValidation.java

@@ -13,7 +13,7 @@ public class PhoneNumberValidation {
         try {
             Phonenumber.PhoneNumber phoneNumber = phoneNumberUtil.parse(number, "CN");
             boolean isCorrect = phoneNumberUtil.isValidNumber(phoneNumber);
-            logger.info("号码：{},是否合法: {}",number,isCorrect);
+            logger.debug("号码：{},是否合法: {}",number,isCorrect);
             return isCorrect;
         } catch (NumberParseException e) {
             logger.error("NumberParseException was thrown: ",e);

src/main/java/com/kimgo/wepush/controller/CallerController.java

@@ -25,7 +25,7 @@ public class CallerController {
         }
         if (callInfo == null || isNullOrEmptyOrLiteralNull(callInfo.getPhoneNumber()) ||
                 isNullOrEmptyOrLiteralNull(callInfo.getCallTime())) {
-            logger.info("CallInfo has invalid fields.");
+            logger.debug("CallInfo has invalid fields.");
             return ServerResponseEntity.fail("json body value error.");
         }
         return callService.getPhoneNumber(accessToken,callInfo);

src/main/java/com/kimgo/wepush/controller/SMSController.java

@@ -21,7 +21,7 @@ public class SMSController {
     public ServerResponseEntity receiveSMS(@RequestHeader("accessToken") String accessToken,
                                            @RequestBody SMSInfo smsInfo) {
 
-        logger.info("SMSInfo: {},accessToken: {}",smsInfo.toString(),accessToken);
+        logger.info("SMSInfo: {}",smsInfo.toString());
         if(accessToken == null){
             return ServerResponseEntity.fail("accessToken cannot be empty.");
         }

src/main/java/com/kimgo/wepush/request/WeChatAPI.java

@@ -31,7 +31,7 @@ public class WeChatAPI {
             ObjectMapper objectMapper1 = new ObjectMapper();
             QyWeChatGetAccessTokenApiResponse qyWeChatGetAccessTokenApiResponse = objectMapper1.readValue(responseBody, QyWeChatGetAccessTokenApiResponse.class);
             if (qyWeChatGetAccessTokenApiResponse.getErrcode() == 0){
-                logger.info("get qyWeChat AccessToken Success");
+                logger.debug("get qyWeChat AccessToken Success");
                 return qyWeChatGetAccessTokenApiResponse.getAccess_token();
             } else {
                 logger.error("getAccessToken error: {}",qyWeChatGetAccessTokenApiResponse.getErrmsg());

src/main/java/com/kimgo/wepush/service/CallService.java

@@ -94,6 +94,7 @@ public class CallService {
             QyWeChatSendMessageApiResponse apiResponse = objectMapper1.readValue(responseBody, QyWeChatSendMessageApiResponse.class);
 
             if (apiResponse.getErrcode() == 0) {
+                logger.debug("Request qyWeChat Success.");
                 return apiResponse;
             } else if (apiResponse.getErrcode() == 42001 || apiResponse.getErrcode() == 40014) {
                 logger.info("Access token expired. Refreshing token...");

src/main/java/com/kimgo/wepush/service/TokenService.java

@@ -75,7 +75,7 @@ public class TokenService {
 
         int result = qyWeChatAppInfoMapper.update(null, updateWrapper);
         if (result > 0) {
-            logger.info("Update successful");
+            logger.debug("Update successful");
         } else {
             logger.warn("Update failed: No rows affected");
         }

src/test/java/com/kimgo/wepush/service/SMSServiceTest.java

@@ -8,7 +8,8 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
-import static org.junit.jupiter.api.Assertions.*;
+import java.util.ArrayList;
+import java.util.List;
 
 @SpringBootTest
 class SMSServiceTest {
@@ -35,14 +36,41 @@ class SMSServiceTest {
                 "【宽带专区】回“9”\n" +
                 "【在线客服】若您有话费/流量疑问、业务咨询/退订等其他需求可联系在线文字客服，点击官方认证通道: https://dx.10086.cn/Q_HZBg \n" +
                 "【为您推荐】尊敬的客户，您好！您有10元话费券待领取： http://dx.10086.cn/D/jEd1Jq ，点击查看话费使用详情： https://dx.10086.cn/38UvEQ 。。【中国移动】";
+        String shortMsg = "【腾讯科技】尊敬的用户，您的账号whj139****3736，经人工客服核实，已根据账号使用情况进行处理，请重新登录即可。";
+        String superMsg = generateMsg();
 
         String accessToken = "gKGCDSgWV82XbU0H";
-        SMSInfo smsInfo = new SMSInfo();
+        List<SMSInfo> smsInfoList = new ArrayList<>();
-        smsInfo.setSmsContent(message);
+        for (int i = 0; i < 3; i++) {
-        smsInfo.setSmsNumber("11111");
+            SMSInfo smsInfo = new SMSInfo();
-        smsInfo.setSmsAcceptanceTime("11111");
+            smsInfo.setSmsNumber("12321");
+            smsInfo.setSmsAcceptanceTime("1123321");
+            smsInfoList.add(smsInfo);
+        }
 
-        ServerResponseEntity serverResponseEntity = smsService.getSMSInfo(accessToken,smsInfo);
+        smsInfoList.get(0).setSmsContent(message);
-        logger.info(serverResponseEntity.toString());
+        smsInfoList.get(1).setSmsContent(shortMsg);
+        smsInfoList.get(2).setSmsContent(superMsg);
+        for (int i = 0; i < 3; i++) {
+            ServerResponseEntity serverResponseEntity = smsService.getSMSInfo(accessToken,smsInfoList.get(i));
+            logger.info(serverResponseEntity.toString());
+            try {
+                Thread.sleep(3000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+        }
     }
+    private String generateMsg() {
+        StringBuilder msg = new StringBuilder("这是一条超长消息用于测试。");
+        int size = msg.toString().getBytes(java.nio.charset.StandardCharsets.UTF_8).length;
+
+        while (size <= 2100) {
+            msg.append("这是一条超长消息用于测试。");
+            size = msg.toString().getBytes(java.nio.charset.StandardCharsets.UTF_8).length;
+        }
+
+        return msg.toString();
+    }
+
 }