From c560f1a14ae1fc468d90e50e6a32d805295875da Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期一, 01 九月 2025 15:35:59 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/2.0' into 2.0
---
cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/GateDataController.java | 83 +++++++++++++++++++++++++++++++++++++----
1 files changed, 75 insertions(+), 8 deletions(-)
diff --git a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/GateDataController.java b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/GateDataController.java
index bb2b034..103e876 100644
--- a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/GateDataController.java
+++ b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/GateDataController.java
@@ -22,9 +22,12 @@
import com.dsh.guns.modular.system.model.*;
import com.dsh.guns.modular.system.service.ICityService;
import com.dsh.guns.modular.system.service.IRegionService;
+import com.dsh.guns.modular.system.service.IStoreService;
+import com.dsh.guns.modular.system.service.TOperatorService;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.collect.Lists;
import com.google.maps.internal.ApiResponse;
+import groovyjarjarpicocli.CommandLine;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
@@ -52,26 +55,35 @@
@Autowired
private SiteClient siteClient;
private String PREFIX = "/system/gateData/";
-
-
-
+ @Autowired
+ private TOperatorService operatorService;
+
+ @Autowired
+ private IStoreService storeService;
+
+
+
/**
* 跳转到充值记录页面
*/
@RequestMapping("")
public String index(Model model) {
+ List<TOperator> list = operatorService.list(new QueryWrapper<TOperator>().ne("state", 3));
+ model.addAttribute("list",list);
+ model.addAttribute("objectType", UserExt.getUser().getObjectType());
+ TStore tStore = storeService.getById(UserExt.getUser().getObjectId());
+ model.addAttribute("tStore", tStore);
return PREFIX + "GateData.html";
}
/**
- * 获取教练类型列表
+ * 获取闸机数据列表
*/
@RequestMapping("/list")
@ResponseBody
- public Object list() {
- List<Site> list = siteClient.getList();
+ public Object list(Integer storeId) {
try {
- for (Site site : list) {
- String apiUrl = "https://try.daowepark.com/v7/user_api/general/spaceDoorData?space_id=" + site.getId();
+ if (storeId!=null){
+ String apiUrl = "https://port.daowepark.com/v7/user_api/general/spaceDoorData?space_id="+storeId;
URL url = new URL(apiUrl);
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setRequestMethod("GET");
@@ -107,6 +119,61 @@
System.out.println("请求失败: " + responseCode);
}
}
+
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ return new ArrayList<>();
+ }
+ /**
+ * 获取教练类型列表
+ */
+ @RequestMapping("/totalNum")
+ @ResponseBody
+ public Object totalNum(Integer storeId) {
+ try {
+ if (storeId!=null){
+ String apiUrl = "https://port.daowepark.com/v7/user_api/general/spaceDoorData?space_id="+storeId;
+ URL url = new URL(apiUrl);
+ HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+ connection.setRequestMethod("GET");
+ // 发送请求并获取响应
+ int responseCode = connection.getResponseCode();
+ if (responseCode == HttpURLConnection.HTTP_OK) {
+ System.err.println("調用======");
+ BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+ String line;
+ StringBuilder response = new StringBuilder();
+ while ((line = reader.readLine()) != null) {
+ response.append(line);
+ }
+ reader.close();
+ // 处理响应数据
+ String data = response.toString();
+ // 使用Jackson库将JSON字符串转换为Java对象
+ ObjectMapper objectMapper = new ObjectMapper();
+ GateDataResponse res = objectMapper.readValue(data, GateDataResponse.class);
+ // 访问Java对象中的数据
+ int code = res.getCode();
+ String message = res.getMessage();
+ // 场地总入场人数
+ int totalNum = res.getData().getTotal_num();
+ int temp = 0 ;
+ List<GateDataResponse.Data.Region> regionNumList = res.getData().getRegion_num();
+ System.err.println("返回列表"+regionNumList);
+ for (GateDataResponse.Data.Region regionNum : regionNumList) {
+ String name = regionNum.getName();
+ int enterNum = regionNum.getEnter_num();
+ temp+=enterNum;
+ System.out.println("Region: " + name + ", EnterNum: " + enterNum);
+ }
+ System.err.println("最終===="+temp);
+ return temp;
+
+ } else {
+ System.out.println("请求失败: " + responseCode);
+ }
+ }
} catch (IOException e) {
e.printStackTrace();
}
--
Gitblit v1.7.1