用户注册、用户留言 成功发送消息

flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/CtleaveMessageServiceImpl.java

@@ -34,6 +34,7 @@ public class CtleaveMessageServiceImpl implements ICtleaveMeassageService {
     public int saveCtleaveMeassage(CtLeaveMessage ctLeaveMessage) {
         // 留言成功发送消息
         WxScriptMessage wxScriptMessage = wxScriptMessageMapper.selectOneByMessageType(MessageTypeEnum.SUBMIT_MESSAGE.getCode());
+        if (wxScriptMessage != null) {
             WxUserScriptLog wxUserScriptLog = new WxUserScriptLog();
             BeanUtils.copyProperties(wxScriptMessage, wxUserScriptLog);
             wxUserScriptLog.setId(null);
@@ -43,6 +44,8 @@ public class CtleaveMessageServiceImpl implements ICtleaveMeassageService {
             wxUserScriptLog.setTitile(wxScriptMessage.getMessageTitle());
             wxUserScriptLog.setContent(wxScriptMessage.getMessageContent());
             wxUserScriptLogMapper.insertWxUserScriptLog(wxUserScriptLog);
+        }
+
 
         // 保存消息
         CtLeaveMessageEnum ctLeaveMessageEnum = CtLeaveMessageEnum.fromString(ctLeaveMessage.getSource());

flossom-modules/flossom-mini-program/src/main/java/com/flossom/miniProgram/service/impl/WxUserMemberServiceImpl.java

@@ -55,6 +55,7 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService {
     private WxUserScriptLogMapper wxUserScriptLogMapper;
 
     @Override
+    @Transactional
     public LoginUserVo login(String code) throws Exception {
         // 1、使用临时凭证 code 获取 appi + appsecret + unionid
         String result = MiniProgramUtils.getSessionKeyAndOpenId(code);
@@ -80,6 +81,9 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService {
             // 2.2、微信用户表注册
             wxUserMemberMapper.insertWxUserMember(wxUserMember);
             // 2.3、系统表注册
+            /**
+             * TODO: 分布式事务
+             */
             RegisterBody registerBody = new RegisterBody();
             registerBody.setUsername(wxUserMember.getOpenid());
             registerBody.setPassword(UserConstants.WX_SYSTEM_USER_PASSWORD);
@@ -90,6 +94,7 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService {
             }
             // 2.4、用户注册成功发送消息
             WxScriptMessage wxScriptMessage = wxScriptMessageMapper.selectOneByMessageType(MessageTypeEnum.USER_REGISTRATION.getCode());
+            if (wxScriptMessage != null) {
                 WxUserScriptLog wxUserScriptLog = new WxUserScriptLog();
                 BeanUtils.copyProperties(wxScriptMessage, wxUserScriptLog);
                 wxUserScriptLog.setId(null);
@@ -100,6 +105,7 @@ public class WxUserMemberServiceImpl implements IWxUserMemberService {
                 wxUserScriptLog.setContent(wxScriptMessage.getMessageContent());
                 wxUserScriptLogMapper.insertWxUserScriptLog(wxUserScriptLog);
             }
+        }
 
         // 3、登录请求，获取 token
         R<Map<String, String>> loginResult = remoteAuthService.wxLogin(wxUserMember);