|
@@ -6,6 +6,7 @@ import cn.com.ty.lift.batch.applet.dao.model.LiftDataModel;
|
|
|
import cn.com.ty.lift.batch.applet.dao.model.request.CommonRequest;
|
|
|
import cn.com.ty.lift.batch.applet.dao.model.request.LiftDataRequest;
|
|
|
import cn.com.ty.lift.batch.applet.dao.model.response.RegionLiftResponse;
|
|
|
+import cn.com.ty.lift.batch.applet.dao.model.response.RegionLiftResponseTotal;
|
|
|
import cn.com.ty.lift.batch.applet.util.DataStatisticsUtil;
|
|
|
import cn.com.ty.lift.common.constants.ApiConstants;
|
|
|
import cn.com.ty.lift.common.constants.CommonEnum;
|
|
@@ -172,10 +173,12 @@ public class LiftDataService {
|
|
|
* @date 2020/2/5 2:43 下午
|
|
|
*/
|
|
|
public RestResponse regionRank(LiftDataRequest liftDataRequest) {
|
|
|
+ RegionLiftResponseTotal regionLiftResponseTotal = new RegionLiftResponseTotal();
|
|
|
//区域电梯数据
|
|
|
List<RegionLiftResponse> regionLiftResponseList = new ArrayList<>();
|
|
|
List<LiftDataModel> liftDataModelList = getLiftDataListFromRedis(liftDataRequest);
|
|
|
if (liftDataModelList != null && liftDataModelList.size() > 0) {
|
|
|
+ regionLiftResponseTotal.setTotalLiftNum(liftDataModelList.size());
|
|
|
final List<RegionLiftResponse> finalRegionLiftResponseList = new ArrayList<>();
|
|
|
//将数据转化为 区域名称->电梯数据列表
|
|
|
Map<String, List<LiftDataModel>> regionNameToLiftData = liftDataModelList.stream()
|
|
@@ -203,6 +206,7 @@ public class LiftDataService {
|
|
|
.sorted(Comparator.comparing(RegionLiftResponse::getLostLiftNums)).limit(5)
|
|
|
.collect(Collectors.toList());
|
|
|
}
|
|
|
+ regionLiftResponseTotal.setRegionLiftResponseList(regionLiftResponseList);
|
|
|
//通过丢失台量排序获取前五的台量
|
|
|
return RestResponse.success(regionLiftResponseList, ApiConstants.RESULT_SUCCESS, "获取统计数据成功");
|
|
|
}
|