From 4ea16b20eb3749765d64f7a65f317f87abe04d89 Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期二, 16 十二月 2025 18:19:15 +0800
Subject: [PATCH] 最新版本541200007
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java | 91 +++++++++++++++++++++++++++++++++++++++------
1 files changed, 78 insertions(+), 13 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
index fe4025f..de372a2 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
@@ -45,8 +45,10 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
+import javax.annotation.PostConstruct;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
@@ -95,6 +97,9 @@
private PlatformDeviceMapper platformDeviceMapper;
@Autowired
private CategoryMapper categoryMapper;
+
+ @Autowired
+ private RedisTemplate<String,Object> stringRedisTemplate;
@Value("${debug_model}")
private Boolean isDebug;
/**
@@ -216,6 +221,32 @@
*/
@Override
public List<PageRegionInfoResponse> getRegionTree(CarmeraListVO req){
+ List<PageRegionInfoResponse> allList =null;
+ if(req.getRefresh() == 0){
+ //榛樿鍙栫紦瀛樻暟鎹�
+ allList = (List<PageRegionInfoResponse>) stringRedisTemplate.opsForValue().get(Constants.RedisKeys.HK_REGIONS_TREE);
+ }
+ if(allList!=null && allList.size()>0){
+ return allList;
+ }
+ allList = getAllRegionList();
+ if(allList==null && allList.size()==0){
+ return allList;
+ }
+ if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){
+ initReginCameralList(allList,req );//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+ }else if(Constants.equalsInteger(req.getWithCameras(),Constants.TWO)){
+ initReginCameralList(allList,req );//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+ initReginFireDeviveList(allList, req);//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+ initReginSensorList(allList,req);//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+ }
+ List<PageRegionInfoResponse> data = new RegionTreeVO(allList).buildTree();
+ //鍔犲叆缂撳瓨
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_REGIONS_TREE,data);
+ return data;
+ }
+
+ private List<PageRegionInfoResponse> getAllRegionList() {
List<PageRegionInfoResponse> allList = new ArrayList<>();
boolean hasNext = true;
int curTotal = 0;
@@ -242,17 +273,11 @@
}
curPage++;
}
- if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){
- initReginCameralList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
- }else if(Constants.equalsInteger(req.getWithCameras(),Constants.TWO)){
- initReginCameralList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
- initReginFireDeviveList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
- initReginSensorList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
- }
- List<PageRegionInfoResponse> data = new RegionTreeVO(allList).buildTree();
- return data;
+ return allList;
}
- private void initReginFireDeviveList(List<PageRegionInfoResponse> allList,String name) {
+
+ private void initReginFireDeviveList(List<PageRegionInfoResponse> allList,CarmeraListVO req) {
+ String name =req.getName();
List<CarmeraListVO> carmeraListVOList = fireDeviceList();
if(carmeraListVOList!=null && carmeraListVOList.size()>0){
for(PageRegionInfoResponse p : allList){
@@ -268,7 +293,8 @@
}
}
}
- private void initReginSensorList(List<PageRegionInfoResponse> allList,String name) {
+ private void initReginSensorList(List<PageRegionInfoResponse> allList,CarmeraListVO req) {
+ String name =req.getName();
List<CarmeraListVO> carmeraListVOList = sensorList();
if(carmeraListVOList!=null && carmeraListVOList.size()>0){
for(PageRegionInfoResponse p : allList){
@@ -284,7 +310,29 @@
}
}
}
- private void initReginCameralList(List<PageRegionInfoResponse> allList,String name) {
+ @PostConstruct
+ public void cacheRegionAndDeviceData(){
+ log.error("===============缂撳瓨娴峰悍骞冲彴鍖哄煙璁惧淇℃伅======寮�濮�============");
+ try {
+ CarmeraListVO param =new CarmeraListVO();
+ param.setWithCameras(2);
+ List<PageRegionInfoResponse> resultTree = getRegionTree(param);
+ List<PageRegionInfoResponse> result = getAllRegionList();
+ List<CarmeraListVO> carmeraListVOList = initAllReginCameralList(result);
+ List<CarmeraListVO> sensorList = sensorList();
+ List<CarmeraListVO> fireDeviceList = fireDeviceList();
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_REGIONS_TREE,resultTree);
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_REGIONS,result);//骞抽摵鍖哄煙鍒楄〃
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_CAMERAS,carmeraListVOList);//鎵�鏈夌洃鎺х偣鏁版嵁
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_FIRE_DEVICE,fireDeviceList);//鎵�鏈夋秷闃茶澶囨暟鎹�
+ stringRedisTemplate.opsForValue().set(Constants.RedisKeys.HK_SENSOR,sensorList);//鎵�鏈変紶鎰熷櫒
+ log.error("===============缂撳瓨娴峰悍骞冲彴鍖哄煙璁惧淇℃伅======鎴愬姛============");
+ }catch (Exception e){
+ log.error("===============缂撳瓨娴峰悍骞冲彴鍖哄煙璁惧淇℃伅澶辫触==================");
+ }
+ }
+ private void initReginCameralList(List<PageRegionInfoResponse> allList,CarmeraListVO req) {
+ String name = req.getName();
CarmeraListVO re = new CarmeraListVO();
re.setName(name);
List<CarmeraListVO> carmeraListVOList = cameraList(re);
@@ -296,11 +344,26 @@
if(p.getCarmeraList()==null){
p.setCarmeraList(new ArrayList<>());
}
+ c.setRegionName(p.getName());
p.getCarmeraList().add(c);
}
}
}
}
+ }
+ private List<CarmeraListVO> initAllReginCameralList(List<PageRegionInfoResponse> allList ) {
+ CarmeraListVO re = new CarmeraListVO();
+ List<CarmeraListVO> carmeraListVOList = cameraList(re);
+ if(carmeraListVOList!=null && carmeraListVOList.size()>0){
+ for(PageRegionInfoResponse p : allList){
+ for(CarmeraListVO c : carmeraListVOList){
+ if(StringUtils.equals(p.getIndexCode(),c.getReginCode())){
+ c.setRegionName(p.getName());
+ }
+ }
+ }
+ }
+ return carmeraListVOList;
}
/**
* 鑾峰彇鍖哄煙鏍戝舰缁撴瀯鏁版嵁
@@ -335,7 +398,7 @@
curPage++;
}
if(Constants.equalsInteger(req.getWithCameras(),Constants.ONE)){
- initReginCameralList(allList,req.getName());//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
+ initReginCameralList(allList,req);//鑾峰彇鍏ㄩ儴鐩戞帶鐐规暟鎹�
}
return allList;
}
@@ -417,6 +480,7 @@
t.setReginCode(p.getRegionIndexCode());
t.setName(p.getCn());
t.setStatus(p.getUnitStatus());
+ t.setRegionName(p.getRegionName());
//0锛氭湭娉ㄥ唽 1锛氭甯� 2: 淇涓� 3锛氬紓甯哥姸鎬�
if(t.getStatus()!=null && t.getStatus() == 0){
t.setStatusName("鏈敞鍐�");
@@ -469,6 +533,7 @@
t.setReginCode(p.getRegionIndexCode());
t.setName(p.getCn());
t.setStatus(p.getUnitStatus());
+ t.setRegionName(p.getRegionName());
//0锛氭湭娉ㄥ唽 1锛氭甯� 2: 淇涓� 3锛氬紓甯哥姸鎬�
if(t.getStatus()!=null && t.getStatus() == 0){
t.setStatusName("鏈敞鍐�");
--
Gitblit v1.9.3