api 上报用户地址信息添加经纬度转换 后台 添加省份用户数量分布,修改根据省份查询用户列表

rouyi-api/src/main/java/com/info666/infraredRemote/controller/UserLoginController.java

@@ -1,6 +1,9 @@
 package com.info666.infraredRemote.controller;
 
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ruoyi.common.core.baiduMap.SearchHttpAK;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.DateUtils;
@@ -8,8 +11,10 @@ import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.system.domain.UserAddress;
 import com.ruoyi.system.domain.UserInfo;
 import com.ruoyi.system.domain.vo.SmsResponseVo;
+import com.ruoyi.system.domain.vo.baiduMap.Result;
 import com.ruoyi.system.service.UserAddressService;
 import com.ruoyi.system.service.UserInfoService;
+import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -36,6 +41,9 @@ public class UserLoginController {
     @Autowired
     private RedisCache redisCache;
 
+    @Autowired
+    private SearchHttpAK searchHttpAK;
+
     /**
      * 登录接口
      */
@@ -62,8 +70,25 @@ public class UserLoginController {
      * 上传用户地址
      */
     @PostMapping("/uploadAddress")
-    public R<SmsResponseVo> sendSms(@RequestBody UserAddress param) {
+    public R<T> uploadAddress(@RequestBody UserAddress param) throws Exception {
         UserInfo one = userInfoService.getOne(new LambdaQueryWrapper<UserInfo>().eq(UserInfo::getUserPhone, param.getUserPhone()),false);
+        if ( StringUtils.isEmpty(param.getLongitude()) || StringUtils.isEmpty(param.getLatitude())){
+            return R.fail("经纬度信息不能为空");
+        }
+        String data = searchHttpAK.convertIp(param.getLatitude()+","+param.getLongitude());
+        JSONObject json = JSON.parseObject(data);
+            Integer status = json.getInteger("status");
+        if (status != 0){
+            return R.fail("经纬度转换失败 状态码:{}"+status);
+        }
+        String result = json.getString("result");
+        Result detail = JSONObject.parseObject(result, Result.class);
+        param.setFormattedAddress(detail.getFormatted_address());
+        param.setProvince(detail.getAddressComponent().getProvince());
+        param.setCity(detail.getAddressComponent().getCity());
+        param.setDistrict(detail.getAddressComponent().getDistrict());
+        param.setTown(detail.getAddressComponent().getTown());
+        param.setStreet(detail.getAddressComponent().getStreet());
         param.setUserId(one.getId());
         param.setCreateTime(DateUtils.getNowDate());
         userAddressService.save(param);

ruoyi-admin/src/main/java/com/ruoyi/web/controller/platform/UserInfoController.java

@@ -4,9 +4,11 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.system.domain.BaseParam;
 import com.ruoyi.system.domain.UserAddress;
 import com.ruoyi.system.domain.UserInfo;
+import com.ruoyi.system.domain.vo.DistributedVo;
 import com.ruoyi.system.service.UserAddressService;
 import com.ruoyi.system.service.UserInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,6 +18,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.HashMap;
+import java.util.List;
 
 /**
  * 用户信息Controller
@@ -39,7 +42,7 @@ public class UserInfoController extends BaseController {
     @PostMapping("/list")
     public R<IPage<UserInfo>> list(@RequestBody BaseParam param) {
         Page<UserInfo> page = new Page<>(param.getCurrent(), param.getSize());
-        IPage<UserInfo> userInfoIPage = userInfoService.getUserInfoList(page, null);
+        IPage<UserInfo> userInfoIPage = userInfoService.getUserInfoList(page, param.getName());
 //        IPage<UserInfo> userInfoIPage = userInfoService.page(new Page<UserInfo>().setCurrent(param.getCurrent()).setSize(param.getSize()),
 //                new LambdaQueryWrapper<UserInfo>().eq(UserInfo::getDelFlag,0));
 
@@ -59,41 +62,17 @@ public class UserInfoController extends BaseController {
     }
 
     /**
-     * 获取用户地址详情信息
+     * 获取用户省份人数统计信息
      */
     @PostMapping(value = "/distributed")
     public R<HashMap<String, Integer>> distributed() {
         HashMap<String, Integer> map = new HashMap<>();
-        map.put("北京市", 1000);
-        map.put("上海市", 2000);
-        map.put("天津市", 3000);
-        map.put("重庆市", 8000);
-        map.put("河北省", 2000);
-        map.put("山西省", 6000);
-        map.put("辽宁省", 4000);
-        map.put("吉林省", 2000);
-        map.put("黑龙江省", 3000);
-        map.put("浙江省", 4000);
-        map.put("福建省", 5000);
-        map.put("山东省", 6000);
-        map.put("河南省", 10000);
-        map.put("湖北省", 8000);
-        map.put("湖南省", 9000);
-        map.put("广东省", 10000);
-        map.put("海南省", 11000);
-        map.put("四川省", 6000);
-        map.put("贵州省", 6000);
-        map.put("云南省", 6000);
-        map.put("江西省", 8000);
-        map.put("陕西省", 8000);
-        map.put("青海省", 8000);
-        map.put("甘肃省", 8000);
-        map.put("广西壮族自治区", 8000);
-        map.put("新疆维吾尔自治区", 8000);
-        map.put("内蒙古自治区", 9000);
-        map.put("西藏自治区", 6000);
-        map.put("安徽省", 7000);
-        map.put("江苏省", 9000);
+        List<DistributedVo> distributed = userAddressService.getProvince();
+        for (DistributedVo distributedVo : distributed) {
+            if (StringUtils.isNotEmpty(distributedVo.getProvince())){
+                map.put(distributedVo.getProvince(),distributedVo.getNumber());
+            }
+        }
         return R.ok(map);
     }
 

ruoyi-common/src/main/java/com/ruoyi/common/core/baiduMap/SearchHttpAK.java

@@ -0,0 +1,83 @@
+
+package com.ruoyi.common.core.baiduMap;
+
+import org.springframework.stereotype.Component;
+import org.springframework.web.util.UriUtils;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.LinkedHashMap;
+import java.util.Map;
+/**
+ * 选择了ak或使用IP白名单校验：
+ */
+@Component
+public class SearchHttpAK {
+
+    public static String URL = "https://api.map.baidu.com/reverse_geocoding/v3?";
+
+    public static String AK = "bkclPNKHhZfdCXNoNVpvrFkYVVdvrzBG";
+
+    public String convertIp (String latitudeAndLongitude) throws Exception {
+
+        SearchHttpAK snCal = new SearchHttpAK();
+
+        Map<String, String> params = new LinkedHashMap<>();
+        params.put("ak", AK);
+        params.put("output", "json");
+        params.put("coordtype", "wgs84ll");
+        params.put("extensions_poi", "0");
+//        params.put("location", "3.90098,1.02223");
+        params.put("location", latitudeAndLongitude);
+
+
+        return snCal.requestGetAK(URL, params);
+    }
+
+    /**
+     * 默认ak
+     * 选择了ak，使用IP白名单校验：
+     * 根据您选择的AK已为您生成调用代码
+     * 检测到您当前的ak设置了IP白名单校验
+     * 您的IP白名单中的IP非公网IP，请设置为公网IP，否则将请求失败
+     * 请在IP地址为的计算发起请求，否则将请求失败
+     */
+    public String requestGetAK(String strUrl, Map<String, String> param) throws Exception {
+        if (strUrl == null || strUrl.length() <= 0 || param == null || param.size() <= 0) {
+            return "入参信息有误";
+        }
+
+        StringBuilder queryString = new StringBuilder();
+        queryString.append(strUrl);
+        for (Map.Entry<?, ?> pair : param.entrySet()) {
+            queryString.append(pair.getKey()).append("=");
+            //    第一种方式使用的 jdk 自带的转码方式  第二种方式使用的 spring 的转码方法 两种均可
+            //    queryString.append(URLEncoder.encode((String) pair.getValue(), "UTF-8").replace("+", "%20") + "&");
+            queryString.append(UriUtils.encode((String) pair.getValue(), "UTF-8")).append("&");
+        }
+
+        if (queryString.length() > 0) {
+            queryString.deleteCharAt(queryString.length() - 1);
+        }
+
+        java.net.URL url = new URL(queryString.toString());
+//        System.out.println(queryString.toString());
+        URLConnection httpConnection = (HttpURLConnection) url.openConnection();
+        httpConnection.connect();
+
+        InputStreamReader isr = new InputStreamReader(httpConnection.getInputStream());
+        BufferedReader reader = new BufferedReader(isr);
+        StringBuilder buffer = new StringBuilder();
+        String line;
+        while ((line = reader.readLine()) != null) {
+            buffer.append(line);
+        }
+        reader.close();
+        isr.close();
+        System.out.println("AK: " + buffer.toString());
+        return buffer.toString();
+    }
+}

ruoyi-system/src/main/java/com/ruoyi/system/domain/UserAddress.java

@@ -35,6 +35,26 @@ public class UserAddress implements Serializable {
     @Excel(name = "纬度")
     private String latitude;
 
+    /** 地址信息 */
+    @Excel(name = "地址信息")
+    private String formattedAddress;
+
+    /** 省 */
+    private String province;
+
+    /** 市 */
+    private String city;
+
+    /** 区 */
+    private String district;
+
+    /** 镇 */
+    private String town;
+
+    /** 街道 */
+    private String street;
+
+
     /** 删除标志（0代表存在 2代表删除） */
     private String delFlag;
 

ruoyi-system/src/main/java/com/ruoyi/system/domain/UserInfo.java

@@ -70,5 +70,17 @@ public class UserInfo implements Serializable {
     @TableField(exist = false)
     private String positionTime;
 
+    /** 省 */
+    @TableField(exist = false)
+    private String province;
+
+    /** 市 */
+    @TableField(exist = false)
+    private String city;
+
+    /** 区 */
+    @TableField(exist = false)
+    private String district;
+
 
 }

ruoyi-system/src/main/java/com/ruoyi/system/domain/vo/DistributedVo.java

@@ -0,0 +1,16 @@
+package com.ruoyi.system.domain.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author: LiMingMing
+ * @Date: 2023/8/16 17:45
+ * @Description: TODO
+ **/
+@Data
+public class DistributedVo implements Serializable {
+    private String province;
+    private Integer number;
+}

ruoyi-system/src/main/java/com/ruoyi/system/domain/vo/baiduMap/AddressComponent.java

@@ -0,0 +1,28 @@
+package com.ruoyi.system.domain.vo.baiduMap;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author: LiMingMing
+ * @Date: 2023/8/16 16:59
+ * @Description: TODO
+ **/
+@Data
+public class AddressComponent implements Serializable {
+    //省
+    private String province;
+
+    //市
+    private String city;
+
+    //区
+    private String district;
+
+    //镇
+    private String town;
+
+    //街道
+    private String street;
+}

ruoyi-system/src/main/java/com/ruoyi/system/domain/vo/baiduMap/Result.java

@@ -0,0 +1,19 @@
+package com.ruoyi.system.domain.vo.baiduMap;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author: LiMingMing
+ * @Date: 2023/8/16 16:55
+ * @Description: TODO
+ **/
+@Data
+public class Result implements Serializable {
+    //整体地址信息
+    private String formatted_address;
+    //详细信息
+    private AddressComponent addressComponent;
+
+}

ruoyi-system/src/main/java/com/ruoyi/system/mapper/UserAddressMapper.java

@@ -2,8 +2,11 @@ package com.ruoyi.system.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.ruoyi.system.domain.UserAddress;
+import com.ruoyi.system.domain.vo.DistributedVo;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * 用户地址信息Mapper接口
  * 
@@ -13,4 +16,6 @@ import org.apache.ibatis.annotations.Param;
 public interface UserAddressMapper extends BaseMapper<UserAddress> {
 
     UserAddress getAddress(@Param("userId") Long userId);
+
+    List<DistributedVo> getProvince();
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/UserAddressService.java

@@ -2,6 +2,9 @@ package com.ruoyi.system.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ruoyi.system.domain.UserAddress;
+import com.ruoyi.system.domain.vo.DistributedVo;
+
+import java.util.List;
 
 /**
  * 用户地址信息Service接口
@@ -10,10 +13,15 @@ import com.ruoyi.system.domain.UserAddress;
  * @date 2023-08-01
  */
 public interface UserAddressService extends IService<UserAddress> {
+
     /**
      * 根据用户id查询最新一条用户的地址信息
-     * @param id
-     * @return
      */
     UserAddress getAddress(Long userId);
+
+    /**
+     * 获取用户省份人数统计信息
+     */
+    List<DistributedVo> getProvince();
+
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/UserAddressServiceImpl.java

@@ -2,11 +2,14 @@ package com.ruoyi.system.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.system.domain.UserAddress;
+import com.ruoyi.system.domain.vo.DistributedVo;
 import com.ruoyi.system.mapper.UserAddressMapper;
 import com.ruoyi.system.service.UserAddressService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * 用户地址信息Service业务层处理
  * 
@@ -22,4 +25,9 @@ public class UserAddressServiceImpl  extends ServiceImpl<UserAddressMapper, User
     public UserAddress getAddress(Long userId) {
         return userAddressMapper.getAddress(userId);
     }
+
+    @Override
+    public List<DistributedVo> getProvince() {
+        return baseMapper.getProvince();
+    }
 }

ruoyi-system/src/main/resources/mapper/system/platform/UserAddressMapper.xml

@@ -28,6 +28,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         ORDER BY create_time DESC
             LIMIT 1
     </select>
+    <select id="getProvince" resultType="com.ruoyi.system.domain.vo.DistributedVo">
+        SELECT
+            province,
+            COUNT(DISTINCT user_id) AS number
+        FROM
+            `t_user_address`
+        GROUP BY province
+    </select>
 
 
 </mapper>

ruoyi-system/src/main/resources/mapper/system/platform/UserInfoMapper.xml

@@ -18,11 +18,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         select id, user_phone, del_flag, create_by, create_time, update_by, update_time from t_user_info
     </sql>
     <select id="getUserInfoList" resultType="com.ruoyi.system.domain.UserInfo">
-        SELECT a.*, c.latitude, c.longitude, c.max_create_time AS positionTime
+        SELECT a.*, c.latitude, c.longitude, c.max_create_time AS positionTime,c.province,c.city,c.district
         FROM t_user_info a
-                 LEFT JOIN (
-            SELECT b.user_id, MAX(b.create_time) AS max_create_time, b.latitude, b.longitude
+                 RIGHT JOIN (
+            SELECT b.user_id, MAX(b.create_time) AS max_create_time, b.latitude, b.longitude,b.province,b.city,b.district
             FROM t_user_address b
+            WHERE b.province = #{param}
             GROUP BY b.user_id
         ) c ON a.id = c.user_id
         WHERE a.del_flag = 0