From 2c52eaf28f9b8a666547e1307a76c3032598e57f Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期三, 11 五月 2022 16:50:24 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ximon-admin/src/main/java/com/sandu/ximon/admin/service/WaterQualityEquipmentService.java | 7 +++++--
ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java | 21 ++++++++++++---------
ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java | 1 +
ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java | 5 ++++-
ximon-admin/src/main/java/com/sandu/ximon/admin/service/LedPlayerEntityService.java | 11 +++++++----
5 files changed, 29 insertions(+), 16 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
index 24be7c1..3f35397 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/PoleController.java
@@ -76,12 +76,15 @@
return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
}
CommonPage commonPage = poleService.queryAllStatesAndList(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(), param);
+ List<Pole> listCommonPage = (List<Pole>) commonPage.getList();
+
List<PoleBindVO> listResult = new ArrayList<>();
- for (Pole pole : (List<Pole>) commonPage.getList()) {
+ for (Pole pole : listCommonPage) {
PoleBindVO bindByPoleId = poleService.getBindByPoleId(pole.getId());
bindByPoleId.setPole(pole);
listResult.add(bindByPoleId);
}
+ commonPage.setList(listResult);
return ResponseUtil.success(commonPage);
}
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LedPlayerEntityService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LedPlayerEntityService.java
index 310c2d8..fa11ba3 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LedPlayerEntityService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LedPlayerEntityService.java
@@ -74,6 +74,9 @@
}
LedPlayerEntity one = getOne(Wrappers.lambdaQuery(LedPlayerEntity.class).eq(LedPlayerEntity::getSn, sn));
+ if (one == null) {
+ return equipmentInfo;
+ }
List<LedPlayerEntity> list = new ArrayList<>();
list.add(one);
List<LedPlayerEntity> ledPlayerEntities = vnnoxAPIUtil.syncCurrentInfo(list);
@@ -81,11 +84,11 @@
if (one != null) {
equipmentInfo.setEquipmentMac(one.getSn());
equipmentInfo.setEquipmentName(one.getName());
- if (onlineStatus == 0) {
+ if (onlineStatus == 0) {
equipmentInfo.setEquipmentState("鍦ㄧ嚎");
- }else {
- equipmentInfo.setEquipmentName("绂荤嚎");
- }
+ } else {
+ equipmentInfo.setEquipmentName("绂荤嚎");
+ }
}
return equipmentInfo;
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
index 32e0f03..ad0012e 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
@@ -276,6 +276,7 @@
}
List<Pole> PoleResult = isOnLine(poleList, param);
+ setCount(PoleResult);
CommonPage commonPage = ListPagingUtils.pages(PoleResult, pageNo, pageSize);
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/WaterQualityEquipmentService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/WaterQualityEquipmentService.java
index 9667ea6..fcb937d 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/WaterQualityEquipmentService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/WaterQualityEquipmentService.java
@@ -109,8 +109,11 @@
try {
String s = HttpUtil.get(WATER_QUALITY_DATA_URL + waterQualityEquipmentCode + ".json");
- System.out.println(s);
-
+ System.out.println(waterQualityEquipmentCode+"-------------------------------"+s);
+ if(!s.startsWith("{")){
+ equipmentInfo.setEquipmentState("鏈煡");
+ return equipmentInfo;
+ }
WaterQualityDataDto waterQualityDataDto = JSON.parseObject(s, WaterQualityDataDto.class);
//璁剧疆姘磋川璁惧鐘舵��
if (waterQualityDataDto != null) {
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
index 70034c0..d9a01d9 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/utils/VnnoxAPIUtil.java
@@ -31,39 +31,40 @@
/**
* 鑾峰彇token
*/
- public void getToken () {
+ public void getToken() {
String result = VnnoxRequestUtil.PostWithHeader(
VnnoxUrl.getUrl(VnnoxUrl.GET_TOKEN),
new VnnoxGetTokenRequest().toJson(),
new CommonHeader(CommonHeader.FORM, false)
);
- CommonResponse commonResponse = JSON.parseObject(result,CommonResponse.class);
+ CommonResponse commonResponse = JSON.parseObject(result, CommonResponse.class);
VnnoxGetTokenResponse response = new VnnoxGetTokenResponse().parse(commonResponse);
// 灏唗oken淇濆瓨鍒皉edis缂撳瓨涓�
- redisUtils.set(VnnoxConstant.REDIS_TOKEN_NAME,response.getToken(),(long)(response.getExpire()-30));
+ redisUtils.set(VnnoxConstant.REDIS_TOKEN_NAME, response.getToken(), (long) (response.getExpire() - 30));
}
/**
* 鑾峰彇鎾斁鍣ㄥ垪琛�
+ *
* @param count 姣忔璇诲彇鏁伴噺锛岄粯璁�20锛屽彇鍊艰寖鍥达細1~100
* @param start 浠庣鍑犳潯璁板綍寮�濮嬭鍙栵紝榛樿0
* @return
*/
- public VnnoxPlayerListResponse getPlayerList(Integer count, Integer start,String name) throws URISyntaxException {
+ public VnnoxPlayerListResponse getPlayerList(Integer count, Integer start, String name) throws URISyntaxException {
List<NameValuePair> urlParameters = new ArrayList<>();
- urlParameters.add(new BasicNameValuePair("count",count.toString()));
- urlParameters.add(new BasicNameValuePair("start",start.toString()));
- urlParameters.add(new BasicNameValuePair("name",name));
+ urlParameters.add(new BasicNameValuePair("count", count.toString()));
+ urlParameters.add(new BasicNameValuePair("start", start.toString()));
+ urlParameters.add(new BasicNameValuePair("name", name));
String result = VnnoxRequestUtil.GetWithHeader(
VnnoxUrl.getUrl(VnnoxUrl.GET_PLAYER_LIST),
urlParameters,
new CommonHeader(CommonHeader.JSON, true)
);
- return new VnnoxPlayerListResponse().parse(JSON.parseObject(result,CommonResponse.class));
+ return new VnnoxPlayerListResponse().parse(JSON.parseObject(result, CommonResponse.class));
}
/**
@@ -74,6 +75,9 @@
*/
public List<LedPlayerEntity> syncCurrentInfo(List<LedPlayerEntity> list) {
List<String> playerIds = new ArrayList<>();
+ if (list.isEmpty()) {
+ return list;
+ }
for (LedPlayerEntity playerEntity : list) {
playerIds.add(playerEntity.getPlayerId());
@@ -224,7 +228,6 @@
/**
* 鍚屾鎾斁
- *
*/
public VnnoxResult syncPlay(List<String> playerId, Integer option) {
VnnoxBaseRequest request = new VnnoxBaseRequest();
--
Gitblit v1.9.3