浏览代码

修复登录消息发送失败问题

fuyuchuan 1 周之前
父节点
当前提交
9876bcc5c8

+ 1 - 1
base-modules/service-system/service-system-biz/src/main/java/com/usky/system/service/impl/MceMbuserServiceImpl.java

@@ -117,7 +117,7 @@ public class MceMbuserServiceImpl extends AbstractCrudService<MceMbuserMapper, M
                 // 登录账号 userName
                 data.put("thing6", new TemplateData(requestVO.getUserName(), "#173177"));
                 // 登录IP
-                data.put("character_string8", new TemplateData(requestVO.getLoginAddress(), "#173177"));
+                data.put("character_string8", new TemplateData(requestVO.getIpAddress(), "#173177"));
                 // 登录地点
                 data.put("thing9", new TemplateData(requestVO.getLoginAddress(), "#173177"));
                 // 登录方式

+ 3 - 0
base-modules/service-system/service-system-biz/src/main/java/com/usky/system/service/impl/MceReceiveServiceImpl.java

@@ -253,11 +253,14 @@ public class MceReceiveServiceImpl extends AbstractCrudService<MceReceiveMapper,
     @Override
     public void addMceReceive(MceRequestVO mceRequestVO) {
 
+        System.out.println(mceRequestVO.toString());
+
         // 登录成功 infoType 为 0,只给登录用户发送公众号消息
         if ("0".equals(mceRequestVO.getInfoType())){
             List<MceMbuser> mbuserList = mceMbuserService.list(Wrappers.lambdaQuery(MceMbuser.class).in(MceMbuser::getUserId, mceRequestVO.getUserIds()));
             String openid = mbuserList.get(0).getOpenid();
             mceContentService.sendAppNew(mceRequestVO, openid, 0, 1);
+            return;
         }
 
         // 如果 infoTypeName 为空,则从字典数据中获取

+ 4 - 3
base-modules/service-system/service-system-biz/src/main/java/com/usky/system/service/util/AsyncFactory.java

@@ -75,15 +75,16 @@ public class AsyncFactory
         // 日志状态
         if (StringUtils.equalsAny(status, Constants.LOGIN_SUCCESS, Constants.LOGOUT, Constants.REGISTER)) {
             logininfor.setStatus(String.valueOf(Constants.LOGIN_SUCCESS_STATUS)); // 使用String.valueOf进行转换
-
-            // 微信公众号推送登录消息
-            sendWeChatMessage(logininfor);
         } else if (Constants.LOGIN_FAIL.equals(status)) {
             logininfor.setStatus(String.valueOf(Constants.LOGIN_FAIL_STATUS)); // 使用String.valueOf进行转换
         }
         sys_user_logger.info("log is {}", JSON.toJSONString(logininfor));
         // 插入数据
         SpringContextUtils.getBean(ISysLogininforService.class).insertLogininfor(logininfor);
+        if (Constants.LOGIN_SUCCESS.equals(logininfor.getStatus())){
+            // 微信公众号推送登录消息
+            sendWeChatMessage(logininfor);
+        }
     }
 
     public static String getBlock(Object msg)