添加websocket

ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysIndexController.java

@@ -177,6 +177,8 @@ public class SysIndexController extends BaseController {
     //日更新量排行
     @GetMapping("/dailyUpdateVolume")
     public String dailyUpdateVolume(ModelMap mmap) {
+        ModelAndView modelAndView = new ModelAndView("dailyUpdateVolume.html");
+        modelAndView.addObject("dataSourceOne",censusElementsService.selectCensusElementsList());
         mmap.put("version", RuoYiConfig.getVersion());
         return "dailyUpdateVolume";
     }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/AreaInteractiveColumnsServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.AreaInteractiveColumns;
 import com.ruoyi.system.domain.CensusElements;
 import com.ruoyi.system.mapper.AreaInteractiveColumnsMapper;
 import com.ruoyi.system.mapper.CensusElementsMapper;
 import com.ruoyi.system.service.IAreaInteractiveColumnsService;
 import com.ruoyi.system.service.ICensusElementsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class AreaInteractiveColumnsServiceImpl implements IAreaInteractiveColumnsService {
@@ -32,5 +36,6 @@ public class AreaInteractiveColumnsServiceImpl implements IAreaInteractiveColumn
             areaInteractiveColumnsMapper.deleteAreaInteractiveColumnsAll();
         }
         areaInteractiveColumnsMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/ColumnPageViewServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.ColumnPageView;
 import com.ruoyi.system.domain.WebSiteTenDaysHits;
 import com.ruoyi.system.mapper.ColumnPageViewMapper;
 import com.ruoyi.system.mapper.WebSiteTenDaysHitsMapper;
 import com.ruoyi.system.service.IColumnPageViewService;
 import com.ruoyi.system.service.IWebSiteTenDaysHitsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class ColumnPageViewServiceImpl implements IColumnPageViewService {
@@ -32,5 +36,6 @@ public class ColumnPageViewServiceImpl implements IColumnPageViewService {
             columnPageViewMapper.deleteColumnPageViewAll();
         }
         columnPageViewMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CountyAndDistrictMisprintServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CountyAndDistrictMisprint;
 import com.ruoyi.system.domain.MunicipalMisprint;
 import com.ruoyi.system.mapper.CountyAndDistrictMisprintMapper;
 import com.ruoyi.system.mapper.MunicipalMisprintMapper;
 import com.ruoyi.system.service.ICountyAndDistrictMisprintService;
 import com.ruoyi.system.service.IMunicipalMisprintService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class CountyAndDistrictMisprintServiceImpl implements ICountyAndDistrictMisprintService {
@@ -32,5 +36,6 @@ public class CountyAndDistrictMisprintServiceImpl implements ICountyAndDistrictM
             countyAndDistrictMisprintMapper.deleteCountyAndDistrictMisprintAll();
         }
         countyAndDistrictMisprintMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CountyDailyTrafficRankingServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CountyDailyTrafficRanking;
 import com.ruoyi.system.domain.DailyUpdateRanking;
 import com.ruoyi.system.mapper.CountyDailyTrafficRankingMapper;
 import com.ruoyi.system.mapper.DailyUpdateRankingMapper;
 import com.ruoyi.system.service.ICountyDailyTrafficRankingService;
 import com.ruoyi.system.service.IDailyUpdateRankingService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class CountyDailyTrafficRankingServiceImpl implements ICountyDailyTrafficRankingService {
@@ -32,5 +36,6 @@ public class CountyDailyTrafficRankingServiceImpl implements ICountyDailyTraffic
             countyDailyTrafficRankingMapper.deleteCountyDailyTrafficRankingAll();
         }
         countyDailyTrafficRankingMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CountyDailyUpdateRankingServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CensusElements;
 import com.ruoyi.system.domain.CountyDailyUpdateRanking;
 import com.ruoyi.system.mapper.CensusElementsMapper;
 import com.ruoyi.system.mapper.CountyDailyUpdateRankingMapper;
 import com.ruoyi.system.service.ICensusElementsService;
 import com.ruoyi.system.service.ICountyDailyUpdateRankingService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class CountyDailyUpdateRankingServiceImpl implements ICountyDailyUpdateRankingService {
@@ -32,5 +36,6 @@ public class CountyDailyUpdateRankingServiceImpl implements ICountyDailyUpdateRa
             countyDailyUpdateRankingMapper.deleteCountyDailyUpdateRankingAll();
         }
         countyDailyUpdateRankingMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/CountyInteractiveColumnsServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CensusElements;
 import com.ruoyi.system.domain.CountyInteractiveColumns;
 import com.ruoyi.system.mapper.CensusElementsMapper;
 import com.ruoyi.system.mapper.CountyInteractiveColumnsMapper;
 import com.ruoyi.system.service.ICensusElementsService;
 import com.ruoyi.system.service.ICountyInteractiveColumnsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class CountyInteractiveColumnsServiceImpl implements ICountyInteractiveColumnsService {
@@ -32,5 +36,6 @@ public class CountyInteractiveColumnsServiceImpl implements ICountyInteractiveCo
             countyInteractiveColumnsMapper.deleteCountyInteractiveColumnsAll();
         }
         countyInteractiveColumnsMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/DailyTrafficRankingServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CensusElements;
 import com.ruoyi.system.domain.DailyTrafficRanking;
 import com.ruoyi.system.mapper.CensusElementsMapper;
 import com.ruoyi.system.mapper.DailyTrafficRankingMapper;
 import com.ruoyi.system.service.ICensusElementsService;
 import com.ruoyi.system.service.IDailyTrafficRankingService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class DailyTrafficRankingServiceImpl implements IDailyTrafficRankingService {
@@ -32,5 +36,6 @@ public class DailyTrafficRankingServiceImpl implements IDailyTrafficRankingServi
             dailyTrafficRankingMapper.deleteDailyTrafficRankingAll();
         }
         dailyTrafficRankingMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/DailyUpdateRankingServiceImpl.java

@@ -1,14 +1,18 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.DailyUpdateRanking;
 import com.ruoyi.system.mapper.DailyUpdateRankingMapper;
 import com.ruoyi.system.service.IDailyUpdateRankingService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class DailyUpdateRankingServiceImpl implements IDailyUpdateRankingService {
@@ -29,5 +33,6 @@ public class DailyUpdateRankingServiceImpl implements IDailyUpdateRankingService
             dailyUpdateRankingMapper.deleteDailyUpdateRankingAll();
         }
         dailyUpdateRankingMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/MunicipalErrorLinkMonitorServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CountyAndDistrictMisprint;
 import com.ruoyi.system.domain.MunicipalErrorLinkMonitor;
 import com.ruoyi.system.mapper.CountyAndDistrictMisprintMapper;
 import com.ruoyi.system.mapper.MunicipalErrorLinkMonitorMapper;
 import com.ruoyi.system.service.ICountyAndDistrictMisprintService;
 import com.ruoyi.system.service.IMunicipalErrorLinkMonitorService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class MunicipalErrorLinkMonitorServiceImpl implements IMunicipalErrorLinkMonitorService {
@@ -32,5 +36,6 @@ public class MunicipalErrorLinkMonitorServiceImpl implements IMunicipalErrorLink
             municipalErrorLinkMonitorMapper.deleteMunicipalErrorLinkMonitorAll();
         }
         municipalErrorLinkMonitorMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/MunicipalInteractiveColumnsServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.CountyDailyUpdateRanking;
 import com.ruoyi.system.domain.MunicipalInteractiveColumns;
 import com.ruoyi.system.mapper.CountyDailyUpdateRankingMapper;
 import com.ruoyi.system.mapper.MunicipalInteractiveColumnsMapper;
 import com.ruoyi.system.service.ICountyDailyUpdateRankingService;
 import com.ruoyi.system.service.IMunicipalInteractiveColumnsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class MunicipalInteractiveColumnsServiceImpl implements IMunicipalInteractiveColumnsService {
@@ -32,5 +36,6 @@ public class MunicipalInteractiveColumnsServiceImpl implements IMunicipalInterac
             municipalInteractiveColumnsMapper.deleteMunicipalInteractiveColumnsAll();
         }
         municipalInteractiveColumnsMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/MunicipalMisprintServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.MunicipalMisprint;
 import com.ruoyi.system.domain.WebSiteTenDaysHits;
 import com.ruoyi.system.mapper.MunicipalMisprintMapper;
 import com.ruoyi.system.mapper.WebSiteTenDaysHitsMapper;
 import com.ruoyi.system.service.IMunicipalMisprintService;
 import com.ruoyi.system.service.IWebSiteTenDaysHitsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class MunicipalMisprintServiceImpl implements IMunicipalMisprintService {
@@ -32,5 +36,6 @@ public class MunicipalMisprintServiceImpl implements IMunicipalMisprintService {
             municipalMisprintMapper.deleteMunicipalMisprintAll();
         }
         municipalMisprintMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/PopularInformationServiceImpl.java

@@ -1,17 +1,21 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.MunicipalMisprint;
 import com.ruoyi.system.domain.PopularInformation;
 import com.ruoyi.system.mapper.MunicipalMisprintMapper;
 import com.ruoyi.system.mapper.PopularInformationMapper;
 import com.ruoyi.system.service.IMunicipalMisprintService;
 import com.ruoyi.system.service.IPopularInformationService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class PopularInformationServiceImpl implements IPopularInformationService {
@@ -32,5 +36,6 @@ public class PopularInformationServiceImpl implements IPopularInformationService
             popularInformationMapper.deletePopularInformationAll();
         }
         popularInformationMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/VisitingWebsiteRankingServiceImpl.java

@@ -1,5 +1,6 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.UnableToAccessWebsiteListToday;
 import com.ruoyi.system.domain.VisitingWebsiteRanking;
 import com.ruoyi.system.domain.WebSiteTenDaysHits;
@@ -9,6 +10,7 @@ import com.ruoyi.system.mapper.VisitingWebsiteRankingMapper;
 import com.ruoyi.system.mapper.WebsiteAvailabilityMonitorMapper;
 import com.ruoyi.system.service.IVisitingWebsiteRankingService;
 import com.ruoyi.system.service.IWebsiteAvailabilityMonitorService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -18,6 +20,8 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class VisitingWebsiteRankingServiceImpl implements IVisitingWebsiteRankingService {
@@ -55,5 +59,6 @@ public class VisitingWebsiteRankingServiceImpl implements IVisitingWebsiteRankin
             saveList.add(visitingWebsiteRanking);
         }
         visitingWebsiteRankingMapper.insertBatch(saveList);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(dto)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/WebSiteTenDaysHitsServiceImpl.java

@@ -1,5 +1,6 @@
 package com.ruoyi.system.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.ruoyi.system.domain.VisitingWebsiteRanking;
 import com.ruoyi.system.domain.WebSiteTenDaysHits;
 import com.ruoyi.system.domain.WebsiteAvailabilityMonitor;
@@ -9,6 +10,7 @@ import com.ruoyi.system.mapper.VisitingWebsiteRankingMapper;
 import com.ruoyi.system.mapper.WebSiteTenDaysHitsMapper;
 import com.ruoyi.system.service.IVisitingWebsiteRankingService;
 import com.ruoyi.system.service.IWebSiteTenDaysHitsService;
+import com.ruoyi.websocket.WebSocketUsers;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -18,6 +20,8 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class WebSiteTenDaysHitsServiceImpl implements IWebSiteTenDaysHitsService {
@@ -55,5 +59,6 @@ public class WebSiteTenDaysHitsServiceImpl implements IWebSiteTenDaysHitsService
             saveList.add(webSiteTenDaysHits);
         }
         webSiteTenDaysHitsMapper.insertBatch(saveList);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(dto)));
     }
 }

ruoyi-system/src/main/java/com/ruoyi/system/service/impl/WebsiteAvailabilityMonitorServiceImpl.java

@@ -1,6 +1,7 @@
 package com.ruoyi.system.service.impl;
 
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.ruoyi.system.domain.WebsiteAvailabilityMonitor;
 import com.ruoyi.system.mapper.WebsiteAvailabilityMonitorMapper;
@@ -12,6 +13,8 @@ import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
 
 @Service
 public class WebsiteAvailabilityMonitorServiceImpl implements IWebsiteAvailabilityMonitorService {
@@ -33,6 +36,7 @@ public class WebsiteAvailabilityMonitorServiceImpl implements IWebsiteAvailabili
             websiteAvailabilityMonitorMapper.deleteWebsiteAvailabilityMonitorAll();
         }
         websiteAvailabilityMonitorMapper.insertBatch(list);
+        WebSocketUsers.sendMessageToUsersByText(JSON.toJSONString(success(list)));
     }
 
 }