xzzn/emsback
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

dev #2

Merged
dashixiong merged 349 commits from dev into main 2026-02-11 01:55:46 +00:00
Conversation 0 Commits 349 Files Changed 375 +27511 -1024
241 changed files with 27511 additions and 1024 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 7cd5a9b131 - Show all commits

7
ems-admin/src/main/java/com/xzzn/web/controller/ems/EmsSiteConfigController.java
View File

@ -147,10 +147,11 @@ public class EmsSiteConfigController extends BaseController{
*/ */
@GetMapping("/getDevicePointList") @GetMapping("/getDevicePointList")
public TableDataInfo getDevicePointList(@RequestParam String siteId,@RequestParam String deviceId, public TableDataInfo getDevicePointList(@RequestParam String siteId,@RequestParam String deviceId,
@RequestParam String deviceCategory, String dataPointName, @RequestParam String deviceCategory, String sortMethod,
String dataPoint) String dataPointName, String dataPoint)
{ {
List<PointQueryResponse> result = iEmsDeviceSettingService.getSingleSiteDevicePoints(siteId,deviceId,deviceCategory,dataPointName,dataPoint); List<PointQueryResponse> result = iEmsDeviceSettingService.getSingleSiteDevicePoints(
siteId,deviceId,deviceCategory,dataPointName,dataPoint,sortMethod);
return getDataTable2(result); return getDataTable2(result);
} }
} }

2
ems-system/src/main/java/com/xzzn/ems/service/IEmsDeviceSettingService.java
View File

@ -25,5 +25,5 @@ public interface IEmsDeviceSettingService
public List<DeviceCategory> getDeviceCategory(); public List<DeviceCategory> getDeviceCategory();
public List<PointQueryResponse> getSingleSiteDevicePoints(String siteId, String deviceId, String deviceCategory, public List<PointQueryResponse> getSingleSiteDevicePoints(String siteId, String deviceId, String deviceCategory,
String dataPointName, String dataPoint); String dataPointName, String dataPoint, String sortMethod);
} }

63
ems-system/src/main/java/com/xzzn/ems/service/impl/EmsDeviceSettingServiceImpl.java
View File

@ -17,6 +17,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
/** /**
* 站点信息 服务层实现 * 站点信息 服务层实现
@ -120,41 +121,49 @@ public class EmsDeviceSettingServiceImpl implements IEmsDeviceSettingService
@Override @Override
public List<PointQueryResponse> getSingleSiteDevicePoints(String siteId, String deviceId, public List<PointQueryResponse> getSingleSiteDevicePoints(String siteId, String deviceId,
String deviceCategory, String dataPointName,String dataPoint) { String deviceCategory, String dataPointName,
String dataPoint, String sortMethod) {
List<PointQueryResponse> response = emsPointMatchMapper.getSingleSiteDevicePoints(siteId,deviceCategory,dataPointName,dataPoint); List<PointQueryResponse> response = emsPointMatchMapper.getSingleSiteDevicePoints(siteId,deviceCategory,dataPointName,dataPoint);
// 电动所的电池簇特殊处理-来源pcs+bmsd // 电动所的电池簇特殊处理-来源pcs+bmsd
if (siteId.equals(DDS_SITE_ID) && DeviceCategory.CLUSTER.getCode().equals(deviceCategory)) { if (siteId.equals(DDS_SITE_ID) && DeviceCategory.CLUSTER.getCode().equals(deviceCategory)) {
response = specialDealWithDDSCluster(response,siteId,deviceId); response = specialDealWithDDSCluster(response,siteId,deviceId);
return response; } else {
} // 从redis取最新数据
JSONObject mqttJson = redisCache.getCacheObject(RedisKeyConstants.ORIGINAL_MQTT_DATA + siteId + "_" + deviceId);
// 从redis取最新数据 if(mqttJson == null){
//String test = redisCache.getCacheObject(RedisKeyConstants.ORIGINAL_MQTT_DATA + siteId + "_" + deviceId); return response;
JSONObject mqttJson = redisCache.getCacheObject(RedisKeyConstants.ORIGINAL_MQTT_DATA + siteId + "_" + deviceId); }
if(mqttJson == null){ String deviceFromMqtt = mqttJson.get("Device").toString();
return response; String jsonData = mqttJson.get("Data").toString();
} if (StringUtils.isEmpty(jsonData) || !deviceId.equals(deviceFromMqtt)) {
String deviceFromMqtt = mqttJson.get("Device").toString(); return response;
String jsonData = mqttJson.get("Data").toString(); }
if (StringUtils.isEmpty(jsonData) || !deviceId.equals(deviceFromMqtt)) {
return response; Map<String, Object> obj = JSON.parseObject(jsonData, new TypeReference<Map<String, Object>>() {});
} for (PointQueryResponse pointInfo : response) {
String dataKey = pointInfo.getDataPoint();
Map<String, Object> obj = JSON.parseObject(jsonData, new TypeReference<Map<String, Object>>() {}); int isNeedDeviceId = pointInfo.getIsNeedDeviceId();
for (PointQueryResponse pointInfo : response) { if (isNeedDeviceId == 1) {// 需要根据deviceId拼接point
String dataKey = pointInfo.getDataPoint(); dataKey = deviceId + dataKey;
int isNeedDeviceId = pointInfo.getIsNeedDeviceId(); pointInfo.setDataPoint(dataKey);
if (isNeedDeviceId == 1) {// 需要根据deviceId拼接point }
dataKey = deviceId + dataKey; pointInfo.setPointValue(obj.get(dataKey));
pointInfo.setDataPoint(dataKey); Long updateTime = Long.valueOf(mqttJson.get("timestamp").toString());
Date latestUpdateTime = convertUpdateTime(updateTime);
pointInfo.setUpdateTime(latestUpdateTime);
} }
pointInfo.setPointValue(obj.get(dataKey));
Long updateTime = Long.valueOf(mqttJson.get("timestamp").toString());
Date latestUpdateTime = convertUpdateTime(updateTime);
pointInfo.setUpdateTime(latestUpdateTime);
} }
if (response == null || response.isEmpty()) {
return response;
}
// 结果排序
if (sortMethod==null || sortMethod.isEmpty() || "asc".equals(sortMethod)) {// 升序
response = response.stream().sorted(Comparator.comparing(PointQueryResponse::getUpdateTime)).collect(Collectors.toList());
} else if ("desc".equals(sortMethod)) {//降序
response = response.stream().sorted(Comparator.comparing(PointQueryResponse::getUpdateTime).reversed()).collect(Collectors.toList());
}
return response; return response;
} }