2025
/
intelligence-site
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

2025年5月13日09:13:14

Browse Source 
1.设备统计
main
liuao 2 weeks ago
parent 292b7097e8
commit 41670ae65b
4 changed files with 110 additions and 35 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 9
      src/main/java/com/zilber/boot/module/vehicle/constant/Constant.java
  2. 8
      src/main/java/com/zilber/boot/module/vehicle/controller/VehicleController.java
  3. 4
      src/main/java/com/zilber/boot/module/vehicle/service/TourRunService.java
  4. 124
      src/main/java/com/zilber/boot/module/vehicle/service/impl/TourRunServiceImpl.java

9
src/main/java/com/zilber/boot/module/vehicle/constant/Constant.java
Unescape View File

@ -1,5 +1,8 @@
package com.zilber.boot.module.vehicle.constant;
import java.util.Arrays;
import java.util.List;
/**
* @Author LJX
* @TIME 2025-05-06 13:38
@ -23,4 +26,10 @@ public class Constant {
public final static String SUCCESS_CODE = "0";
public final static List<String> SCOPES = Arrays.asList("aotomobile", "personal");
public final static String SCOPE1 = "aotomobile";
public final static String SCOPE2 = "personal";
}

8
src/main/java/com/zilber/boot/module/vehicle/controller/VehicleController.java
Unescape View File

@ -12,6 +12,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
/**
* @Author LJX
* @TIME 2025-05-06 11:57
@ -33,6 +35,12 @@ public class VehicleController {
return AjaxResult.success(service.list(pr));
}
@GetMapping("/stat")
@ApiOperation("统计")
public AjaxResult stat() {
return AjaxResult.success(service.stat());
}
@GetMapping("/h5")
@ApiOperation("h5")
public AjaxResult h5(

4
src/main/java/com/zilber/boot/module/vehicle/service/TourRunService.java
Unescape View File

@ -3,6 +3,8 @@ package com.zilber.boot.module.vehicle.service;
import com.zilber.boot.module.vehicle.dto.pr.DevicePR;
import com.zilber.boot.utils.page.PageUtils;
import java.util.Map;
/**
* @Author LJX
* @TIME 2025-05-06 11:51
@ -14,6 +16,8 @@ public interface TourRunService {
PageUtils list(DevicePR pr);
Map<String, Integer> stat();
String h5(String tabType, String imei);
String token();

124
src/main/java/com/zilber/boot/module/vehicle/service/impl/TourRunServiceImpl.java
Unescape View File

@ -1,7 +1,6 @@
package com.zilber.boot.module.vehicle.service.impl;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.ArrayUtils;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.zilber.boot.exception.ServiceException;
import com.zilber.boot.module.vehicle.constant.Constant;
@ -14,16 +13,13 @@ import com.zilber.boot.utils.StringUtils;
import com.zilber.boot.utils.page.PageUtils;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.net.HttpURLConnection;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;
import java.util.stream.Collectors;
import static com.zilber.boot.module.vehicle.util.http.HttpUtils.sendGet;
@ -67,38 +63,38 @@ public class TourRunServiceImpl
@Override
public PageUtils list(DevicePR pr) {
String token = token();
Map<String, String> paramMap = paramMap(Method.LIST.getCode());
// 私有参数
paramMap.put("access_token", token);
paramMap.put("target", properties.getTourRunAccount());
// 计算签名
String sign = "";
try {
sign = SignUtils.signTopRequest(paramMap, properties.getAppSecret(), Constant.MD5);
paramMap.put("sign", sign);
} catch (IOException e) {
e.printStackTrace();
}
//调用com/zilber/boot/module/vehicle/util/http/HttpUtils方法
JSONObject jsonObject = sendPost(properties.getOpenapiUrl(), headerMap(), paramMap);
//初始化列表
// List<JSONObject> resultList = null;
// if ( jsonObject != null) {
// if ( !jsonObject.get("code").toString().equals("0"))
// {
// throw new ServiceException(jsonObject.get("message").toString());
// }
// resultList = jsonObject.getList("result", JSONObject.class);
// }
// else {
// throw new ServiceException("列表获取失败");
// String token = token();
//
// Map<String, String> paramMap = paramMap(Method.LIST.getCode());
//
// // 私有参数
// paramMap.put("access_token", token);
// paramMap.put("target", properties.getTourRunAccount());
// // 计算签名
// String sign = "";
// try {
// sign = SignUtils.signTopRequest(paramMap, properties.getAppSecret(), Constant.MD5);
// paramMap.put("sign", sign);
// } catch (IOException e) {
// e.printStackTrace();
// }
List<JSONObject> resultList = handleResult(jsonObject, JSONObject.class, "获取列表失败");
if (CollectionUtils.isNotEmpty(resultList))
{
// //调用com/zilber/boot/module/vehicle/util/http/HttpUtils方法
// JSONObject jsonObject = sendPost(properties.getOpenapiUrl(), headerMap(), paramMap);
// //初始化列表
//// List<JSONObject> resultList = null;
//// if ( jsonObject != null) {
//// if ( !jsonObject.get("code").toString().equals("0"))
//// {
//// throw new ServiceException(jsonObject.get("message").toString());
//// }
//// resultList = jsonObject.getList("result", JSONObject.class);
//// }
//// else {
//// throw new ServiceException("列表获取失败");
//// }
// List<JSONObject> resultList = handleResult(jsonObject, JSONObject.class, "获取列表失败");
List<JSONObject> resultList = resultList();
if (CollectionUtils.isNotEmpty(resultList)) {
List<JSONObject> handledList = resultList.stream()
.filter(jo -> jo.get("mcTypeUseScope").toString().equals(pr.getScope()))
.sorted((o1, o2) -> StringUtils.compare(o1.get("imei").toString(), o2.get("imei").toString()))
@ -116,6 +112,31 @@ public class TourRunServiceImpl
return new PageUtils(new ArrayList<>(), 0, pr.getPageSize(), pr.getPageNo());
}
@Override
public Map<String, Integer> stat() {
Map<String, Integer> resultMap = new HashMap<>(2);
List<JSONObject> resultList = resultList();
if (CollectionUtils.isNotEmpty(resultList)) {
Map<String, List<JSONObject>> scopeMap
= resultList.stream()
.collect(Collectors.groupingBy(jo -> jo.get("mcTypeUseScope").toString()));
for (String scope: Constant.SCOPES) {
List<JSONObject> jsonObjects = scopeMap.get(scope);
if ( CollectionUtils.isNotEmpty(jsonObjects)) {
resultMap.put(scope, jsonObjects.size());
}
else {
resultMap.put(scope, 0);
}
}
return resultMap;
}
for (String scope: Constant.SCOPES) {
resultMap.put(scope, 0);
}
return resultMap;
}
//https://openh5.aichezaixian.com/?token=XXX&imei=AAA&appKey=BBB&activeTab=CCC
@Override
public String h5(String tabType, String imei) {
@ -201,6 +222,39 @@ public class TourRunServiceImpl
return paramMap;
}
private List<JSONObject> resultList() {
String token = token();
Map<String, String> paramMap = paramMap(Method.LIST.getCode());
// 私有参数
paramMap.put("access_token", token);
paramMap.put("target", properties.getTourRunAccount());
// 计算签名
String sign = "";
try {
sign = SignUtils.signTopRequest(paramMap, properties.getAppSecret(), Constant.MD5);
paramMap.put("sign", sign);
} catch (IOException e) {
e.printStackTrace();
}
//调用com/zilber/boot/module/vehicle/util/http/HttpUtils方法
JSONObject jsonObject = sendPost(properties.getOpenapiUrl(), headerMap(), paramMap);
//初始化列表
// List<JSONObject> resultList = null;
// if ( jsonObject != null) {
// if ( !jsonObject.get("code").toString().equals("0"))
// {
// throw new ServiceException(jsonObject.get("message").toString());
// }
// resultList = jsonObject.getList("result", JSONObject.class);
// }
// else {
// throw new ServiceException("列表获取失败");
// }
return handleResult(jsonObject, JSONObject.class, "获取列表失败");
}
/**
* 处理接收到的返回结果（列表）
* @param result 返回结果

Write Preview
Loading…
Cancel
Save