获取ip并解析归属地

suser/pom.xml

             <artifactId>mapper-spring-boot-starter</artifactId>
             <version>2.0.2</version>
         </dependency>
+        <!--解析ip-->
+        <dependency>
+            <groupId>org.lionsoul</groupId>
+            <artifactId>ip2region</artifactId>
+            <version>2.6.6</version>
+        </dependency>
 
     </dependencies>
     <dependencyManagement>

suser/src/main/java/com/xhkjedu/suser/controller/system/UserController.java

 import com.xhkjedu.suser.model.system.TUser;
 import com.xhkjedu.suser.model.system.TUserUsecret;
 import com.xhkjedu.suser.service.system.UserService;
+import com.xhkjedu.suser.utils.IpRegionUtil;
 import com.xhkjedu.suser.utils.UserUtil;
 import com.xhkjedu.suser.vo.assess.AssessParams;
 import com.xhkjedu.utils.N_Utils;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.context.request.RequestAttributes;
+import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 import java.util.Map;
+import java.util.TreeMap;
 
 /**
  * @ClassName UserController
         userService.batchActivate(userids);
         return new ResultVo(0, "批量激活成功");
     }
+
+    @GetMapping("/ip")
+    public ResultVo getIpRegion(){
+        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
+        // 从获取RequestAttributes中获取HttpServletRequest的信息
+        HttpServletRequest request = (HttpServletRequest) requestAttributes.resolveReference(RequestAttributes.REFERENCE_REQUEST);
+
+        String ip = UserUtil.getIpAddress(request);
+        String region = "";
+        if(N_Utils.isNotEmpty(ip)){
+            IpRegionUtil ipRegionUtil = new IpRegionUtil();
+            region = ipRegionUtil.getIpForAddress(ip);
+        }
+        Map map = new TreeMap();
+        map.put("ip",ip);
+        map.put("region",region);
+        return new ResultVo(0,"获取成功",map);
+    }
 }

suser/src/main/java/com/xhkjedu/suser/service/system/UserService.java

 import com.xhkjedu.suser.model.system.TUser;
 import com.xhkjedu.suser.model.system.TUserLog;
 import com.xhkjedu.suser.model.system.TUserUsecret;
-import com.xhkjedu.suser.utils.JedisUtil;
-import com.xhkjedu.suser.utils.PoiUtils;
-import com.xhkjedu.suser.utils.SMSSender;
-import com.xhkjedu.suser.utils.UserUtil;
+import com.xhkjedu.suser.utils.*;
 import com.xhkjedu.suser.vo.assess.AssessParams;
 import com.xhkjedu.suser.vo.system.UserVo;
 import com.xhkjedu.suser.vo.system.ZtMsgVo;
-import com.xhkjedu.utils.DESUtils;
-import com.xhkjedu.utils.DatesUtil;
-import com.xhkjedu.utils.MD5;
-import com.xhkjedu.utils.N_Utils;
-import com.xhkjedu.utils.PageUtil;
+import com.xhkjedu.utils.*;
 import com.xhkjedu.vo.PageResult;
 import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
         Integer usertype = user.getUsertype();
         if (result.getCode() == 0) {
             UserVo userVo = (UserVo) result.getObj();
-            //以下代码登录的时候进行判断
-            /*if (userVo.getUserlock() == 1) {
-                result.setCode(1);
-                result.setMsg("此账号已锁定，禁止登录");
-                return result;
-            }
-            String usertime = userVo.getUsertime();
-            if (N_Utils.isNotEmpty(usertime)) {
-                String dayBegin = DatesUtil.getDayBegin();
-                if (usertime.compareTo(dayBegin) < 0) {
-                    result.setCode(1);
-                    if (usertype == 2) {//学生
-                        result.setMsg("账号已过有效期，请联系老师");
-                    } else {
-                        result.setMsg("账号已过有效期，请联系管理员");
-                    }
-                    return result;
-                }
-            }*/
-
             //redis
             String ticketKey = UUID.randomUUID().toString().replace("-", "");
             String token = DESUtils.encrypt(ticketKey, ConfigKey.secretKey);//加密
             userLog.setUserid(user.getUserid());
             userLog.setUsername(user.getUsername());
             userLog.setSchoolid(user.getSchoolid());
-            userLog.setLogip(user.getLogip());
-            userLog.setLogaddress(user.getLogaddress());
+//            userLog.setLogip(user.getLogip());
+//            userLog.setLogaddress(user.getLogaddress());
+            //获取请求ip并解析区域
+            String ip = UserUtil.getIpAddress(request);
+            String region = null;
+            if(N_Utils.isNotEmpty(ip)){
+                IpRegionUtil ipRegionUtil = new IpRegionUtil();
+                region = ipRegionUtil.getIpForAddress(ip);
+            }
+            userLog.setLogip(ip);
+            userLog.setLogaddress(region);
+
             if(user.getUltype().equals("p_web") && usertype != null){
                 //网页端学生和教师合并登录，前端传p_web,拼接完整的ultype
                 if(usertype == 2){

suser/src/main/java/com/xhkjedu/suser/utils/IpRegionUtil.java

+package com.xhkjedu.suser.utils;
+
+import com.xhkjedu.utils.N_Utils;
+import lombok.extern.slf4j.Slf4j;
+import org.lionsoul.ip2region.xdb.Searcher;
+
+import java.io.IOException;
+
+/**
+ * @Description 解析ip归属地
+ * @Author WN
+ * Date 2022/11/27 22:31
+ **/
+@Slf4j
+public class IpRegionUtil {
+
+    public String getIpForAddress(String ip){
+        String region = "";
+        // 1、创建 searcher 对象
+        String dbPath = "ip2region.xdb";
+        Searcher searcher = null;
+        try {
+            searcher = Searcher.newWithFileOnly(dbPath);
+        } catch (IOException e) {
+//            System.out.printf("failed to create searcher with `%s`: %s\n", dbPath, e);
+            log.error("创建searcher失败："+ e.getMessage());
+            return null;
+        }
+
+        // 2、查询
+        try {
+//            long sTime = System.nanoTime();
+            region = searcher.search(ip);
+//            long cost = TimeUnit.NANOSECONDS.toMicros((long) (System.nanoTime() - sTime));
+//            System.out.printf("{region: %s, ioCount: %d, took: %d μs}\n", region, searcher.getIOCount(), cost);
+            if(N_Utils.isNotEmpty(region)){
+                region = region.replace("0|","").replace("|"," ");
+            }
+        } catch (Exception e) {
+//            System.out.printf("failed to search(%s): %s\n", ip, e);
+            log.error("根据ip获取地址失败："+ e.getMessage());
+            return null;
+        }
+
+        // 3、关闭资源
+        try {
+            searcher.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return region;
+    }
+}

suser/src/main/java/com/xhkjedu/suser/utils/UserUtil.java

 
 import com.xhkjedu.vo.ResultVo;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.MediaType;
 import org.springframework.web.client.RestClientException;
 import org.springframework.web.client.RestTemplate;
 
+import javax.servlet.http.HttpServletRequest;
 import java.util.ArrayList;
 import java.util.List;
 
         }
         return resultVo;
     }
+
+    /**
+     * @Description 获取请求ip
+     * @Param [request]
+     * @Return java.lang.String
+     * @Author wn
+     * @Date 2022/11/27 22:26
+     **/
+    public static String getIpAddress(HttpServletRequest request){
+        String ip = request.getHeader("x-forwarded-for");
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("WL-Proxy-Client-IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("HTTP_CLIENT_IP");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getHeader("HTTP_X_FORWARDED_FOR");
+        }
+        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
+            ip = request.getRemoteAddr();
+        }
+
+        if(StringUtils.isNotEmpty(ip)){
+            String[] ipArr = ip.split(",");
+            if(ipArr.length > 0){
+                ip = ipArr[0];
+            }
+        }
+        return ip;
+    }
 }