diff --git a/im-platform/src/main/java/com/bx/implatform/dto/LoginDTO.java b/im-platform/src/main/java/com/bx/implatform/dto/LoginDTO.java index d0a231e..c0b8400 100644 --- a/im-platform/src/main/java/com/bx/implatform/dto/LoginDTO.java +++ b/im-platform/src/main/java/com/bx/implatform/dto/LoginDTO.java @@ -25,4 +25,7 @@ public class LoginDTO { @Schema(description = "用户密码") private String password; + @Schema(description = "ip地址") + private String ip; + } diff --git a/im-platform/src/main/java/com/bx/implatform/entity/User.java b/im-platform/src/main/java/com/bx/implatform/entity/User.java index 6b43806..b34d948 100644 --- a/im-platform/src/main/java/com/bx/implatform/entity/User.java +++ b/im-platform/src/main/java/com/bx/implatform/entity/User.java @@ -94,4 +94,14 @@ public class User { */ private Integer isCustomer = 1; + /** + * 最后登录ip + */ + private String lastLoginIp; + + /** + * ip转换的地址 + */ + private String ipAddress; + } diff --git a/im-platform/src/main/java/com/bx/implatform/service/UserService.java b/im-platform/src/main/java/com/bx/implatform/service/UserService.java index 4319bb7..c46e5a3 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/UserService.java +++ b/im-platform/src/main/java/com/bx/implatform/service/UserService.java @@ -90,5 +90,12 @@ public interface UserService extends IService { */ List getOnlineTerminals(String userIds); + /** + * 记录ip与ip地址 + * + * @param user 用户 + */ + void updateIpAndAddress(User user); + } diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/UserServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/UserServiceImpl.java index d1d5466..3a89f18 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/impl/UserServiceImpl.java +++ b/im-platform/src/main/java/com/bx/implatform/service/impl/UserServiceImpl.java @@ -4,6 +4,7 @@ import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.bx.imclient.IMClient; @@ -25,6 +26,7 @@ import com.bx.implatform.service.UserService; import com.bx.implatform.session.SessionContext; import com.bx.implatform.session.UserSession; import com.bx.implatform.util.BeanUtils; +import com.bx.implatform.util.IpUtils; import com.bx.implatform.util.SensitiveFilterUtil; import com.bx.implatform.vo.LoginVO; import com.bx.implatform.vo.OnlineTerminalVO; @@ -85,6 +87,33 @@ public class UserServiceImpl extends ServiceImpl implements Us @Override public LoginVO login(LoginDTO dto) { + User user = this.findUserByUserName(dto.getUserName()); + if (Objects.isNull(user)) { + throw new GlobalException("用户不存在"); + } + if(user.getIsCustomer() == 2){ + throw new GlobalException("用户不存在"); + } + if (user.getIsBanned()) { + String tip = String.format("您的账号因'%s'已被管理员封禁,请联系客服!",user.getReason()); + throw new GlobalException(tip); + } + if (!passwordEncoder.matches(dto.getPassword(), user.getPassword())) { + throw new GlobalException(ResultCode.PASSWOR_ERROR); + } + if(!Objects.isNull(dto.getIp())){ + user.setLastLoginIp(dto.getIp()); + this.updateIpAndAddress(user); + } + // 生成token + UserSession session = BeanUtils.copyProperties(user, UserSession.class); + session.setUserId(user.getId()); + session.setTerminal(dto.getTerminal()); + String strJson = JSON.toJSONString(session); + String accessToken = JwtUtil.sign(user.getId(), strJson, jwtProperties.getAccessTokenExpireIn(), + jwtProperties.getAccessTokenSecret()); + String refreshToken = JwtUtil.sign(user.getId(), strJson, jwtProperties.getRefreshTokenExpireIn(), + jwtProperties.getRefreshTokenSecret()); // 生成游客唯一标识UUID String guestUuid = UUID.randomUUID().toString(); @@ -328,4 +357,14 @@ public class UserServiceImpl extends ServiceImpl implements Us }); return vos; } + + @Override + public void updateIpAndAddress(User user) { + String ip = user.getLastLoginIp(); + String address = IpUtils.getIpAddress(ip); + this.update(new UpdateWrapper().lambda() + .eq(User::getId, user.getId()) + .set(User::getLastLoginIp, ip) + .set(User::getIpAddress, address)); + } } diff --git a/im-platform/src/main/java/com/bx/implatform/util/IpUtils.java b/im-platform/src/main/java/com/bx/implatform/util/IpUtils.java new file mode 100644 index 0000000..2c7cf5f --- /dev/null +++ b/im-platform/src/main/java/com/bx/implatform/util/IpUtils.java @@ -0,0 +1,75 @@ +package com.bx.implatform.util; + +import cn.hutool.http.HttpUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * IP 地址查询工具类 + * 使用 ipify 和 httpbin 获取 IP 地址的地理位置信息 + */ +@Slf4j +@Component +public class IpUtils { + + private static final String IP_API = "http://ip-api.com/json/"; + + + /** + * 根据 IP 地址查询地理位置 + * + * @param ip IP 地址 + * @return 地理位置信息，格式如："中国广东省深圳市" + */ + public static String getIpAddress(String ip) { + System.out.println("333333333"); + System.out.println(ip); + + + if (ip == null || ip.trim().isEmpty() || "unknown".equalsIgnoreCase(ip)) { + return ""; + } + + try { + // 使用 ip-api.com 查询 IP 归属地 + String url = IP_API + ip; + String response = HttpUtil.get(url, 5000); + + System.out.println("2222222222222222"); + System.out.println( response); + + if (response != null && !response.isEmpty()) { + JSONObject json = JSON.parseObject(response); + String status = json.getString("status"); + + if ("success".equals(status)) { + String country = json.getString("country"); + String regionName = json.getString("regionName"); + String city = json.getString("city"); + + StringBuilder address = new StringBuilder(); + if (country != null && !country.isEmpty()) { + address.append(country); + } + if (regionName != null && !regionName.isEmpty() && !regionName.equals(country)) { + address.append(regionName); + } + if (city != null && !city.isEmpty() && !city.equals(regionName)) { + address.append(city); + } + + log.info("IP 地址查询成功：ip={}, address={}", ip, address); + return address.toString(); + } + } + } catch (Exception e) { + log.error("IP 地址查询失败：ip={}, error={}", ip, e.getMessage()); + } + + // 如果查询失败，返回空字符串 + return ""; + } + +} diff --git a/im-uniapp/pages/login/login.vue b/im-uniapp/pages/login/login.vue index 54d0327..2e8b51a 100644 --- a/im-uniapp/pages/login/login.vue +++ b/im-uniapp/pages/login/login.vue @@ -1,14 +1,57 @@