发送push和站内信新增用户是否存在判断

src/main/java/cn/qg/qaplatform/service/stools/impl/MsgServiceImpl.java

@@ -38,7 +38,14 @@ public class MsgServiceImpl extends ServiceImpl<MsgMapper, MsgTemplate> implemen
      */
     @Override
     public boolean sendPush(String namespace, String phoneNo, String contentId, List<String> contentArgs) {
-        String userId = xyqbBasicQueryService.getUserInfoByPhoneNo(namespace, phoneNo).getUserId();
+        XjfqGenProcessVo xjfqGenProcessVo = xyqbBasicQueryService.getUserInfoByPhoneNo(namespace, phoneNo);
+        String userId;
+        if (xjfqGenProcessVo == null) {
+            log.info("用户中心查不到手机号{}，因此本次不发送短信.", phoneNo);
+            return false;
+        } else {
+            userId = xjfqGenProcessVo.getUserId();
+        }
         String url = "https://msgapi-" + namespace + ".liangkebang.net/middle_office/send/message/appPush";
         List<Map<String, Object>> paramList = new ArrayList<>();
         Map<String, Object> sendMap = new HashMap<>();
@@ -63,7 +70,14 @@ public class MsgServiceImpl extends ServiceImpl<MsgMapper, MsgTemplate> implemen
      */
     @Override
     public boolean sendStationLetter(String namespace, String phoneNo, String contentId, List<String> contentArgs) {
-        String userId = xyqbBasicQueryService.getUserInfoByPhoneNo(namespace, phoneNo).getUserId();
+        XjfqGenProcessVo xjfqGenProcessVo = xyqbBasicQueryService.getUserInfoByPhoneNo(namespace, phoneNo);
+        String userId;
+        if (xjfqGenProcessVo == null) {
+            log.info("用户中心查不到手机号{}，因此本次不发送短信.", phoneNo);
+            return false;
+        } else {
+            userId = xjfqGenProcessVo.getUserId();
+        }
         String url = "https://msgapi-" + namespace + ".liangkebang.net/middle_office/send/message/stationLetter";
         List<Map<String, Object>> paramList = new ArrayList<>();
         Map<String, Object> sendMap = new HashMap<>();