@ -2,7 +2,6 @@ package com.nmggs.query.service.impl;
import com.alibaba.fastjson.JSONObject ;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper ;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page ;
import com.nmggs.query.common.emnu.Constant ;
import com.nmggs.query.common.utils.DateTimeUtil ;
import com.nmggs.query.common.utils.LogUtil ;
@ -165,11 +164,9 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
}
@Override
public Page < NetDataConnectedJava > querySubCenterDataBacklog ( Map < String , Object > objectMap ) {
public List < NetDataConnectedJava > querySubCenterDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + objectMap + ",查询分中心积压数据信息" , "NetDataConnectedJavaServiceImpl-querySubCenterDataBacklog" ) ;
int currentPage = ( int ) objectMap . get ( "currentPage" ) ;
int pageSize = ( int ) objectMap . get ( "pageSize" ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询分中心积压数据信息" , "NetDataConnectedJavaServiceImpl-querySubCenterDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
@ -194,7 +191,8 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
try {
Map < String , Object > map = JSONObject . parseObject ( data . getDataJson ( ) , Map . class ) ;
int sum = map . entrySet ( ) . stream ( )
. filter ( entry - > entry . getKey ( ) . endsWith ( "out_port_center_recs" ) )
. filter ( entry - > entry . getKey ( ) . endsWith ( "recs" ) )
//.filter(entry -> entry.getKey().endsWith("out_port_center_recs"))
. mapToInt ( entry - > {
try {
return Integer . parseInt ( entry . getValue ( ) . toString ( ) ) ;
@ -209,24 +207,14 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
int fromIndex = ( currentPage - 1 ) * pageSize ;
int toIndex = Math . min ( fromIndex + pageSize , filteredList . size ( ) ) ;
List < NetDataConnectedJava > pageData = filteredList . subList ( fromIndex , toIndex ) ;
Page < NetDataConnectedJava > page = new Page < > ( ) ;
page . setCurrent ( currentPage ) ;
page . setSize ( pageSize ) ;
page . setTotal ( filteredList . size ( ) ) ;
page . setRecords ( pageData ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + objectMap + ",查询分中心积压数据信息条数" + page . getTotal ( ) , "NetDataConnectedJavaServiceImpl-querySubCenterDataBacklog" ) ;
return page ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询分中心积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-querySubCenterDataBacklog" ) ;
return filteredList ;
}
@Override
public Page < NetDataConnectedJava > queryStationDataBacklog ( Map < String , Object > objectMap ) {
public List < NetDataConnectedJava > queryStationDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + objectMap + ",查询收费站积压数据信息" , "NetDataConnectedJavaServiceImpl-queryStationDataBacklog" ) ;
int currentPage = ( int ) objectMap . get ( "currentPage" ) ;
int pageSize = ( int ) objectMap . get ( "pageSize" ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询收费站积压数据信息" , "NetDataConnectedJavaServiceImpl-queryStationDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
@ -251,8 +239,8 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
try {
Map < String , Object > map = JSONObject . parseObject ( data . getDataJson ( ) , Map . class ) ;
int sum = map . entrySet ( ) . stream ( )
//.filter(entry -> entry.getKey().endsWith("recs"))
. filter ( entry - > entry . getKey ( ) . endsWith ( "out_port_center_recs" ) )
. filter ( entry - > entry . getKey ( ) . endsWith ( "recs" ) )
//.filter(entry -> entry.getKey().endsWith("out_port_center_recs"))
. mapToInt ( entry - > {
try {
return Integer . parseInt ( entry . getValue ( ) . toString ( ) ) ;
@ -267,16 +255,8 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
int fromIndex = ( currentPage - 1 ) * pageSize ;
int toIndex = Math . min ( fromIndex + pageSize , filteredList . size ( ) ) ;
List < NetDataConnectedJava > pageData = filteredList . subList ( fromIndex , toIndex ) ;
Page < NetDataConnectedJava > page = new Page < > ( ) ;
page . setCurrent ( currentPage ) ;
page . setSize ( pageSize ) ;
page . setTotal ( filteredList . size ( ) ) ;
page . setRecords ( pageData ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + objectMap + ",查询收费站积压数据信息条数" + page . getTotal ( ) , "NetDataConnectedJavaServiceImpl-queryStationDataBacklog" ) ;
return page ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询收费站积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryStationDataBacklog" ) ;
return filteredList ;
}
@Override
@ -307,11 +287,9 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
}
@Override
public Page < NetDataConnectedJava > queryLWZXFrontUnitDataBacklog ( Map < String , Object > objectMap ) {
public List < NetDataConnectedJava > queryLWZXFrontUnitDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + objectMap + ",查询联网中心前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryLWZXFrontUnitDataBacklog" ) ;
int currentPage = ( int ) objectMap . get ( "currentPage" ) ;
int pageSize = ( int ) objectMap . get ( "pageSize" ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询联网中心前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryLWZXFrontUnitDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
@ -351,24 +329,14 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
int fromIndex = ( currentPage - 1 ) * pageSize ;
int toIndex = Math . min ( fromIndex + pageSize , filteredList . size ( ) ) ;
List < NetDataConnectedJava > pageData = filteredList . subList ( fromIndex , toIndex ) ;
Page < NetDataConnectedJava > page = new Page < > ( ) ;
page . setCurrent ( currentPage ) ;
page . setSize ( pageSize ) ;
page . setTotal ( filteredList . size ( ) ) ;
page . setRecords ( pageData ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + objectMap + ",查询联网中心前置机积压数据信息条数" + page . getTotal ( ) , "NetDataConnectedJavaServiceImpl-queryLWZXFrontUnitDataBacklog" ) ;
return page ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询联网中心前置机积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryLWZXFrontUnitDataBacklog" ) ;
return filteredList ;
}
@Override
public Page < NetDataConnectedJava > queryYEJLLDFrontUnitDataBacklog ( Map < String , Object > objectMap ) {
public List < NetDataConnectedJava > queryYEJLLDFrontUnitDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + objectMap + ",查询一二级路路段前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLDFrontUnitDataBacklog" ) ;
int currentPage = ( int ) objectMap . get ( "currentPage" ) ;
int pageSize = ( int ) objectMap . get ( "pageSize" ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询一二级路路段前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLDFrontUnitDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
@ -408,24 +376,14 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
int fromIndex = ( currentPage - 1 ) * pageSize ;
int toIndex = Math . min ( fromIndex + pageSize , filteredList . size ( ) ) ;
List < NetDataConnectedJava > pageData = filteredList . subList ( fromIndex , toIndex ) ;
Page < NetDataConnectedJava > page = new Page < > ( ) ;
page . setCurrent ( currentPage ) ;
page . setSize ( pageSize ) ;
page . setTotal ( filteredList . size ( ) ) ;
page . setRecords ( pageData ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + objectMap + ",查询一二级路路段前置机积压数据信息条数" + page . getTotal ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLDFrontUnitDataBacklog" ) ;
return page ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询一二级路路段前置机积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLDFrontUnitDataBacklog" ) ;
return filteredList ;
}
@Override
public Page < NetDataConnectedJava > queryYEJLLWFrontUnitDataBacklog ( Map < String , Object > objectMap ) {
public List < NetDataConnectedJava > queryYEJLLWFrontUnitDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + objectMap + ",查询一二级路联网中心前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
int currentPage = ( int ) objectMap . get ( "currentPage" ) ;
int pageSize = ( int ) objectMap . get ( "pageSize" ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询一二级路联网中心前置机积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
@ -465,15 +423,193 @@ public class NetDataConnectedJavaServiceImpl implements NetDataConnectedJavaServ
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
int fromIndex = ( currentPage - 1 ) * pageSize ;
int toIndex = Math . min ( fromIndex + pageSize , filteredList . size ( ) ) ;
List < NetDataConnectedJava > pageData = filteredList . subList ( fromIndex , toIndex ) ;
Page < NetDataConnectedJava > page = new Page < > ( ) ;
page . setCurrent ( currentPage ) ;
page . setSize ( pageSize ) ;
page . setTotal ( filteredList . size ( ) ) ;
page . setRecords ( pageData ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + objectMap + ",查询一二级路联网中心前置机积压数据信息条数" + page . getTotal ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
return page ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询一二级路联网中心前置机积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
return filteredList ;
}
@Override
public List < NetDataConnectedJava > queryCenterConnected ( ) {
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
. eq ( NetDataConnectedJava : : getBaseType , 2 ) ;
List < NetDataConnectedJava > netdataConnectedList = netDataConnectedJavaMapper . selectList ( netdataConnectedQueryWrapper ) ;
//过滤掉dataJson数据为空的就不展示
List < NetDataConnectedJava > filteredList = netdataConnectedList . stream ( )
. filter ( data - > data . getDataJson ( ) ! = null & & ! data . getDataJson ( ) . isEmpty ( ) )
. collect ( Collectors . toList ( ) ) ;
for ( NetDataConnectedJava item : filteredList ) {
Map < String , Object > map = JSONObject . parseObject ( item . getDataJson ( ) , Map . class ) ;
map . remove ( "minDate" ) ;
map . remove ( "allrecs" ) ;
map . remove ( "fileds" ) ;
map . remove ( "gantry_pass_lwcenter_recs" ) ;
map . remove ( "gantry_pass_lwcenter_mintime" ) ;
map . remove ( "in_port_lwcenter_recs" ) ;
map . remove ( "in_port_lwcenter_mintime" ) ;
map . remove ( "out_port_lwcenter_recs" ) ;
map . remove ( "out_port_lwcenter_mintime" ) ;
item . setDataJson ( new JSONObject ( map ) . toString ( ) ) ;
}
filteredList . sort ( Comparator . comparingInt ( ( data ) - > {
try {
Map < String , Object > map = JSONObject . parseObject ( data . getDataJson ( ) , Map . class ) ;
int sum = map . entrySet ( ) . stream ( )
. filter ( entry - > entry . getKey ( ) . endsWith ( "recs" ) )
. mapToInt ( entry - > {
try {
return Integer . parseInt ( entry . getValue ( ) . toString ( ) ) ;
} catch ( NumberFormatException e ) {
return 0 ; // 如果转换失败,返回 0
}
} )
. sum ( ) ;
return - sum ; // 以负数形式排序,使得数量最多的数据排在最前面
} catch ( Exception e ) {
e . printStackTrace ( ) ;
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
return filteredList ;
}
@Override
public List < NetDataConnectedJava > stationServerEcharts ( Date date ) {
QueryWrapper < NetDataConnectedJava > queryWrapper = new QueryWrapper < > ( ) ;
queryWrapper . lambda ( ) . eq ( NetDataConnectedJava : : getBaseType , 3 )
. eq ( NetDataConnectedJava : : getClassDate , date ) ;
return netDataConnectedJavaMapper . selectList ( queryWrapper ) ;
}
@Override
public List < NetDataConnectedJava > queryLWZXmpayServer ( Map < String , Object > map ) {
Date formatDate ;
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + map + ",查询联网中心mpay的服务器和数据库信息" , "NetDataConnectedJavaServiceImpl-YEJLLDFrontUnitServer" ) ;
if ( ObjectUtils . isNotEmpty ( map . get ( "classDate" ) ) ) {
String classDate = ( String ) map . get ( "classDate" ) ;
formatDate = DateTimeUtil . getFormatDate ( classDate , Constant . YYYY_MM_DD ) ;
} else {
formatDate = DateTimeUtil . getDateByDay ( new Date ( ) ) ;
}
QueryWrapper < NetDataConnectedJava > queryWrapper = new QueryWrapper < > ( ) ;
queryWrapper . lambda ( ) . eq ( NetDataConnectedJava : : getClassDate , formatDate )
. eq ( NetDataConnectedJava : : getBaseType , 7 ) ;
List < NetDataConnectedJava > netDataConnectedJavas = netDataConnectedJavaMapper . selectList ( queryWrapper ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + map + ",查询联网中心mpay的服务器和数据库信息条数为" + netDataConnectedJavas . size ( ) , "NetDataConnectedJavaServiceImpl-YEJLLDFrontUnitServer" ) ;
return netDataConnectedJavas ;
}
@Override
public List < NetDataConnectedJava > queryLWZXbyServer ( Map < String , Object > map ) {
Date formatDate ;
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始根据条件" + map + ",查询联网中心by的服务器和数据库信息" , "NetDataConnectedJavaServiceImpl-YEJLLDFrontUnitServer" ) ;
if ( ObjectUtils . isNotEmpty ( map . get ( "classDate" ) ) ) {
String classDate = ( String ) map . get ( "classDate" ) ;
formatDate = DateTimeUtil . getFormatDate ( classDate , Constant . YYYY_MM_DD ) ;
} else {
formatDate = DateTimeUtil . getDateByDay ( new Date ( ) ) ;
}
QueryWrapper < NetDataConnectedJava > queryWrapper = new QueryWrapper < > ( ) ;
queryWrapper . lambda ( ) . eq ( NetDataConnectedJava : : getClassDate , formatDate )
. eq ( NetDataConnectedJava : : getBaseType , 8 ) ;
List < NetDataConnectedJava > netDataConnectedJavas = netDataConnectedJavaMapper . selectList ( queryWrapper ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-根据条件" + map + ",查询联网中心by的服务器和数据库信息条数为" + netDataConnectedJavas . size ( ) , "NetDataConnectedJavaServiceImpl-YEJLLDFrontUnitServer" ) ;
return netDataConnectedJavas ;
}
@Override
public List < NetDataConnectedJava > getLWZXmpayDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-开始查询联网中心mpay积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
. eq ( NetDataConnectedJava : : getBaseType , 7 ) ;
List < NetDataConnectedJava > netdataConnectedList = netDataConnectedJavaMapper . selectList ( netdataConnectedQueryWrapper ) ;
//过滤掉dataJson数据为空的就不展示
List < NetDataConnectedJava > filteredList = netdataConnectedList . stream ( )
. filter ( data - > data . getDataJson ( ) ! = null & & ! data . getDataJson ( ) . isEmpty ( ) )
. collect ( Collectors . toList ( ) ) ;
for ( NetDataConnectedJava item : filteredList ) {
Map < String , Object > map = JSONObject . parseObject ( item . getDataJson ( ) , Map . class ) ;
map . remove ( "minDate" ) ;
map . remove ( "allrecs" ) ;
map . remove ( "fileds" ) ;
// 移除所有键名后缀为"mintime"的记录
// 使用迭代器的remove方法安全移除元素
//map.entrySet().removeIf(entry -> entry.getKey().endsWith("mintime"));
item . setDataJson ( new JSONObject ( map ) . toString ( ) ) ;
}
filteredList . sort ( Comparator . comparingInt ( ( data ) - > {
try {
Map < String , Object > map = JSONObject . parseObject ( data . getDataJson ( ) , Map . class ) ;
int sum = map . entrySet ( ) . stream ( )
. filter ( entry - > entry . getKey ( ) . endsWith ( "recs" ) )
. mapToInt ( entry - > {
try {
return Integer . parseInt ( entry . getValue ( ) . toString ( ) ) ;
} catch ( NumberFormatException e ) {
return 0 ; // 如果转换失败,返回 0
}
} )
. sum ( ) ;
return - sum ; // 以负数形式排序,使得数量最多的数据排在最前面
} catch ( Exception e ) {
e . printStackTrace ( ) ;
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询联网中心mpay积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
return filteredList ;
}
@Override
public List < NetDataConnectedJava > getLWZXbyDataBacklog ( ) {
String uuid = UuidUtil . getUuid ( ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询联网中心by积压数据信息" , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
String truncSysDateSQL = SqlStringUtil . getTruncSysDateSQL ( ) ;
QueryWrapper < NetDataConnectedJava > netdataConnectedQueryWrapper = new QueryWrapper < > ( ) ;
netdataConnectedQueryWrapper . lambda ( ) . apply ( truncSysDateSQL )
. eq ( NetDataConnectedJava : : getBaseType , 8 ) ;
List < NetDataConnectedJava > netdataConnectedList = netDataConnectedJavaMapper . selectList ( netdataConnectedQueryWrapper ) ;
//过滤掉dataJson数据为空的就不展示
List < NetDataConnectedJava > filteredList = netdataConnectedList . stream ( )
. filter ( data - > data . getDataJson ( ) ! = null & & ! data . getDataJson ( ) . isEmpty ( ) )
. collect ( Collectors . toList ( ) ) ;
for ( NetDataConnectedJava item : filteredList ) {
Map < String , Object > map = JSONObject . parseObject ( item . getDataJson ( ) , Map . class ) ;
map . remove ( "minDate" ) ;
map . remove ( "allrecs" ) ;
map . remove ( "fileds" ) ;
// 移除所有键名后缀为"mintime"的记录
// 使用迭代器的remove方法安全移除元素
//map.entrySet().removeIf(entry -> entry.getKey().endsWith("mintime"));
item . setDataJson ( new JSONObject ( map ) . toString ( ) ) ;
}
filteredList . sort ( Comparator . comparingInt ( ( data ) - > {
try {
Map < String , Object > map = JSONObject . parseObject ( data . getDataJson ( ) , Map . class ) ;
int sum = map . entrySet ( ) . stream ( )
. filter ( entry - > entry . getKey ( ) . endsWith ( "recs" ) )
. mapToInt ( entry - > {
try {
return Integer . parseInt ( entry . getValue ( ) . toString ( ) ) ;
} catch ( NumberFormatException e ) {
return 0 ; // 如果转换失败,返回 0
}
} )
. sum ( ) ;
return - sum ; // 以负数形式排序,使得数量最多的数据排在最前面
} catch ( Exception e ) {
e . printStackTrace ( ) ;
return 0 ; // 如果解析或计算出现异常,返回 0
}
} ) ) ;
LogUtil . WriteLog_Info ( "[uuid:" + uuid + "]-查询联网中心by积压数据信息条数" + filteredList . size ( ) , "NetDataConnectedJavaServiceImpl-queryYEJLLWFrontUnitDataBacklog" ) ;
return filteredList ;
}
}