update 联联查询统计信息接口

This commit is contained in:
Lemon
2023-05-27 17:03:30 +08:00
parent 57541bdcf9
commit 6225b9b122
4 changed files with 74 additions and 28 deletions

View File

@@ -45,7 +45,7 @@ public interface LianLianService {
* @param dto
* @return
*/
StationStatsInfo query_station_stats(QueryStationInfoDTO dto);
Map<String, String> query_station_stats(QueryStationInfoDTO dto);
/**

View File

@@ -389,17 +389,15 @@ public class LianLianServiceImpl implements LianLianService {
* @return
*/
@Override
public StationStatsInfo query_station_stats(QueryStationInfoDTO dto) {
public Map<String, String> query_station_stats(QueryStationInfoDTO dto) {
DockingPlatformConfig configInfo = dockingPlatformConfigService.getInfoByOperatorId(dto.getOperatorId());
if (configInfo == null) {
return null;
}
// 根据站点id 查出这段时间的充电量
List<AccumulativeInfoVO> list = orderBasicInfoService.getAccumulativeInfoForLianLian(dto);
if (CollectionUtils.isEmpty(list)) {
return StationStatsInfo.builder()
.StationID(dto.getStationID())
.StartTime(dto.getStartTime())
.EndTime(dto.getEndTime())
.StationElectricity(BigDecimal.ZERO)
.equipmentStatsInfos(Lists.newArrayList()) // 设备列表
.build();
return null;
}
// 根据充电桩编号分组 key=充电桩编号
@@ -465,7 +463,19 @@ public class LianLianServiceImpl implements LianLianService {
.equipmentStatsInfos(equipmentStatsInfoList) // 设备列表
.build();
return stationStatsInfo;
// 加密
Map<String, String> resultMap = Maps.newLinkedHashMap();
// 加密数据
byte[] encryptText = Cryptos.aesEncrypt(JSONObject.toJSONString(stationStatsInfo).getBytes(),
configInfo.getOperatorSecret().getBytes(), configInfo.getDataSecretIv().getBytes());
String encryptData = Encodes.encodeBase64(encryptText);
resultMap.put("Data", encryptData);
// 生成sig
String resultSign = GBSignUtils.sign(resultMap, configInfo.getOperatorSecret());
resultMap.put("Sig", resultSign);
return resultMap;
}
/**