直播添加ip归属地解析数据文件配成路程

slive/pom.xml

@@ -92,6 +92,13 @@
             <artifactId>poi</artifactId>
             <version>3.17</version>
         </dependency>
+
+        <!--解析ip-->
+        <dependency>
+            <groupId>org.lionsoul</groupId>
+            <artifactId>ip2region</artifactId>
+            <version>2.6.6</version>
+        </dependency>
     </dependencies>
     <dependencyManagement>
         <dependencies>

slive/src/main/java/com/xhkjedu/slive/config/ConfigKey.java

@@ -55,4 +55,11 @@ public class ConfigKey {
     public void setExpirationTimeInSeconds(Integer expirationTimeInSeconds) {
         ConfigKey.expirationTimeInSeconds = expirationTimeInSeconds;
     }
+
+    public static String ipregiondb;//解析ip地址归属地
+
+    @Value("${ipregiondb}")
+    public void setIpregiondb(String ipregiondb){
+        ConfigKey.ipregiondb = ipregiondb;
+    }
 }

slive/src/main/java/com/xhkjedu/slive/controller/liveplay/CourseSectionStudentController.java

@@ -11,6 +11,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 
 /**
@@ -26,8 +27,8 @@ public class CourseSectionStudentController {
     private CourseSectionStudentService courseSectionStudentService;
 
     @PostMapping("/add")
-    public ResultVo add(@RequestBody LCourseSectionStudent student) {
-        courseSectionStudentService.save(student);
+    public ResultVo add(@RequestBody LCourseSectionStudent student, HttpServletRequest request) {
+        courseSectionStudentService.save(student,request);
         return new ResultVo(0, "保存成功");
     }
 
@@ -40,10 +41,10 @@ public class CourseSectionStudentController {
     }
 
     @PostMapping("/in_section")
-    public ResultVo inSection(@RequestBody LCourseSectionStudent student) {
+    public ResultVo inSection(@RequestBody LCourseSectionStudent student,HttpServletRequest request) {
         N_Utils.validation(new Object[]{student.getSectionid(),"课节id",1,student.getStudentid(),"学生id",1
                 ,student.getDevice(),"设备类型",2});
-        return courseSectionStudentService.inSection(student);
+        return courseSectionStudentService.inSection(student,request);
     }
 
     @PostMapping("/out_section")

slive/src/main/java/com/xhkjedu/slive/service/liveplay/CourseSectionStudentService.java

@@ -4,6 +4,8 @@ import com.xhkjedu.slive.mapper.liveplay.CourseSectionMapper;
 import com.xhkjedu.slive.mapper.liveplay.CourseSectionStudentMapper;
 import com.xhkjedu.slive.model.liveplay.LCourseSection;
 import com.xhkjedu.slive.model.liveplay.LCourseSectionStudent;
+import com.xhkjedu.slive.utils.IpRegionUtil;
+import com.xhkjedu.slive.utils.LiveUtil;
 import com.xhkjedu.slive.vo.liveplay.CSStudentVo;
 import com.xhkjedu.slive.vo.liveplay.CourseVo;
 import com.xhkjedu.utils.N_Utils;
@@ -11,6 +13,7 @@ import com.xhkjedu.vo.ResultVo;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
 import java.util.List;
 
 /**
@@ -27,11 +30,20 @@ public class CourseSectionStudentService {
     private CourseSectionMapper courseSectionMapper;
 
     //添加
-    public void save(LCourseSectionStudent model) {
+    public void save(LCourseSectionStudent model, HttpServletRequest request) {
         model.setCreatetime(N_Utils.getSecondTimestamp());
         if (model.getTotaltime() == null) {
             model.setTotaltime(0);
         }
+
+        String ip = LiveUtil.getIpAddress(request);
+        String region = null;
+        if(N_Utils.isNotEmpty(ip)){
+            IpRegionUtil ipRegionUtil = new IpRegionUtil();
+            region = ipRegionUtil.getIpForAddress(ip);
+        }
+        model.setLogip(ip);
+        model.setLogaddress(region);
         courseSectionStudentMapper.save(model);
         courseSectionMapper.updateStuNum(model.getSectionid());
     }
@@ -47,7 +59,7 @@ public class CourseSectionStudentService {
     }
 
     //学生进入课节
-    public ResultVo inSection(LCourseSectionStudent student) {
+    public ResultVo inSection(LCourseSectionStudent student,HttpServletRequest request) {
         CourseVo course = courseSectionMapper.getCourseBySectionId(student.getSectionid());
         if (course.getCoursestate() == 3 || course.getDeleted() == 10) return new ResultVo(1,"已结束");
         LCourseSectionStudent cs = courseSectionStudentMapper.getByStudent(student);//学生进入课节记录
@@ -58,7 +70,7 @@ public class CourseSectionStudentService {
         } else {//没有学生进入课节记录添加
             student.setTostamp(N_Utils.getSecondTimestamp());
             student.setOutstamp(0);
-            save(student);
+            save(student,request);
         }
         return new ResultVo(0,"学生进入课节成功");
     }

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

@@ -0,0 +1,54 @@
+package com.xhkjedu.slive.utils;
+
+import com.xhkjedu.slive.config.ConfigKey;
+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 = ConfigKey.ipregiondb;
+        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;
+    }
+}

slive/src/main/java/com/xhkjedu/slive/utils/LiveUtil.java

@@ -1,15 +1,17 @@
 package com.xhkjedu.slive.utils;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
 
-import java.text.SimpleDateFormat;
+import javax.servlet.http.HttpServletRequest;
 import java.time.DayOfWeek;
 import java.time.LocalDate;
-import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
-import java.util.*;
-import java.util.stream.Collectors;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 import java.util.stream.Stream;
 
 /**
@@ -189,4 +191,38 @@ public class LiveUtil {
         return rtnlst;
     }
 
+    /**
+     * @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;
+    }
+
 }

slive/src/main/resources/application.properties

@@ -101,5 +101,8 @@ cron.updateLicense=0 0 0 * * ?
 #每隔1小时修改license状态
 cron.updateLicenseState=0 0 0/1 * * ?
 
+#解析ip归属地数据
+ipregiondb=D:\\school\\ip2region.xdb
+
 #版本号
 versionname=Test_v3.6.0

suser/src/main/java/com/xhkjedu/suser/config/ConfigKey.java

@@ -51,4 +51,11 @@ public class ConfigKey {
     public void setSecretKey(String secretKey) {
         ConfigKey.secretKey = secretKey;
     }
+
+    public static String ipregiondb;//解析ip地址归属地
+
+    @Value("${ipregiondb}")
+    public void setIpregiondb(String ipregiondb){
+        ConfigKey.ipregiondb = ipregiondb;
+    }
 }

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

@@ -1,5 +1,6 @@
 package com.xhkjedu.suser.utils;
 
+import com.xhkjedu.suser.config.ConfigKey;
 import com.xhkjedu.utils.N_Utils;
 import lombok.extern.slf4j.Slf4j;
 import org.lionsoul.ip2region.xdb.Searcher;
@@ -17,7 +18,7 @@ public class IpRegionUtil {
     public String getIpForAddress(String ip){
         String region = "";
         // 1、创建 searcher 对象
-        String dbPath = "ip2region.xdb";
+        String dbPath = ConfigKey.ipregiondb;
         Searcher searcher = null;
         try {
             searcher = Searcher.newWithFileOnly(dbPath);

suser/src/main/resources/application.properties

@@ -56,5 +56,9 @@ zt.url=http://api.mix2.zthysms.com/
 signName=【河南星火燎原】
 #郑州管城大数据SSO认证鉴权接口
 ssourl=http://gcdsj.zzgcjy.cn/portal/sso/api/agent
+
+#解析ip归属地数据
+ipregiondb=D:\\school\\ip2region.xdb
+
 #版本号
 versionname=Test_v3.6.0