|
@@ -2,6 +2,7 @@ package com.ruoyi.system.service.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.ruoyi.system.domain.CountyDailyTrafficRanking;
|
|
|
+import com.ruoyi.system.domain.DailyTrafficRanking;
|
|
|
import com.ruoyi.system.domain.DailyUpdateRanking;
|
|
|
import com.ruoyi.system.mapper.CountyDailyTrafficRankingMapper;
|
|
|
import com.ruoyi.system.mapper.DailyUpdateRankingMapper;
|
|
@@ -12,7 +13,9 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
+import java.util.Comparator;
|
|
|
import java.util.List;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
import static com.ruoyi.common.core.domain.AjaxResult.success;
|
|
|
|
|
@@ -36,6 +39,6 @@ public class CountyDailyTrafficRankingServiceImpl implements ICountyDailyTraffic
|
|
|
countyDailyTrafficRankingMapper.deleteCountyDailyTrafficRankingAll();
|
|
|
}
|
|
|
countyDailyTrafficRankingMapper.insertBatch(list);
|
|
|
- WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
|
|
|
+ WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list.stream().sorted(Comparator.comparing(CountyDailyTrafficRanking::getRanking)).collect(Collectors.toList()))));
|
|
|
}
|
|
|
}
|