From 6842af1dcf0658a01139451fbee142dfa051f2ec Mon Sep 17 00:00:00 2001
From: sgj <1442489573@qq.com>
Date: 星期一, 30 三月 2026 15:07:02 +0800
Subject: [PATCH] 大屏首页轮播图改为每个库区十天内最新的三张图片

---
 fzzy-igdss-web/src/main/java/com/fzzy/group/manager/GroupManager.java |   93 +++++++++++++++++++++++++++++++++++-----------
 1 files changed, 71 insertions(+), 22 deletions(-)

diff --git a/fzzy-igdss-web/src/main/java/com/fzzy/group/manager/GroupManager.java b/fzzy-igdss-web/src/main/java/com/fzzy/group/manager/GroupManager.java
index 48e673a..27c0461 100644
--- a/fzzy-igdss-web/src/main/java/com/fzzy/group/manager/GroupManager.java
+++ b/fzzy-igdss-web/src/main/java/com/fzzy/group/manager/GroupManager.java
@@ -17,10 +17,7 @@
 
 import javax.annotation.Resource;
 import java.text.DecimalFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.LinkedHashMap;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -52,13 +49,12 @@
     private SecCameraService cameraService;
     @Resource
     private BankService bankService;
-
     @Resource
     private PledgeContractService pledgeContractService;
-
-
     @Resource
-    private  PledgeContractDepotService pledgeContractDepotService;
+    private PledgeContractDepotService pledgeContractDepotService;
+    @Resource
+    private GatewaySerService gatewaySerService;
 
     /**
      * 鑾峰彇鐪佸強涓嬪睘甯傚窞闆嗗悎
@@ -137,11 +133,11 @@
         if (null == area) {
             return null;
         }
-        List<DicArea> areaChildren =  new ArrayList<>();
+        List<DicArea> areaChildren = new ArrayList<>();
 
         List<DicArea> list = new ArrayList<>();
         if (Constant.AREA_TYPE_1.equals(area.getType())) {
-           //鏌ヨ鎵�鏈夌殑璐ㄦ娂鍚堝悓
+            //鏌ヨ鎵�鏈夌殑璐ㄦ娂鍚堝悓
             List<PledgeContract> pledgeContractList = pledgeContractService.listAll(null);
             //鏌ヨ鎵�鏈夌殑搴撳尯
             List<Dept> depotList = deptService.listDept(null, ContextUtil.getCompanyId(), null);
@@ -158,12 +154,12 @@
                     IgdsBaseParam param = new IgdsBaseParam();
                     param.setParentId(pledgeContract.getId());
                     List<PledgeContractDepot> pledgeContractDepots = pledgeContractDepotService.listAll(param);
-                    if (null == pledgeContractDepots || pledgeContractDepots.isEmpty()){
+                    if (null == pledgeContractDepots || pledgeContractDepots.isEmpty()) {
                         continue;
                     }
                     //鎵惧埌pledgeContractDepots涓殑deptId闆嗗悎锛屽苟鍘婚噸
                     List<String> deptIdList = pledgeContractDepots.stream().map(PledgeContractDepot::getPledgeDept).distinct().collect(Collectors.toList());
-                    if( deptIdList.contains(dept.getId())){
+                    if (deptIdList.contains(dept.getId())) {
                         //浠巐ist涓壘鍒板綋鍓嶈川鎶奸摱琛岀殑鏁版嵁
                         DicArea pledgeBank = null;
                         int indexBank = -1;
@@ -174,11 +170,11 @@
                                 break;
                             }
                         }
-                        if( null == pledgeBank){
+                        if (null == pledgeBank) {
                             //鏈壘鍒拌川鎶奸摱琛屾暟鎹垯鏂板缓
                             pledgeBank = new DicArea();
                             pledgeBank.setCode(pledgeContract.getPledgeBank());
-                            pledgeBank.setName("璐ㄦ娂閾惰_"+pledgeContract.getPledgeBank());
+                            pledgeBank.setName("璐ㄦ娂閾惰_" + pledgeContract.getPledgeBank());
                             //浠庨摱琛屾暟鎹腑鎵惧埌璐ㄦ娂閾惰鐨勪俊鎭�
                             for (Bank bank : bankList) {
                                 if (pledgeContract.getPledgeBank().equals(bank.getId())) {
@@ -197,9 +193,9 @@
                             pledgeBank.getChildren().add(deptDic);
                             //鏂板璐ㄦ娂閾惰鏁版嵁鍒發ist涓�
                             areaChildren.add(pledgeBank);
-                            isPledge=true;
+                            isPledge = true;
                             break;
-                        }else{
+                        } else {
                             //娣诲姞璐ㄦ娂閾惰涓嬬殑搴撳尯鏁版嵁
                             DicArea deptDic = new DicArea();
                             deptDic.setCode(dept.getId());
@@ -211,14 +207,14 @@
                             }
                             pledgeBank.getChildren().add(deptDic);
                             //鏇存柊list涓殑璐ㄦ娂閾惰鏁版嵁
-                            areaChildren.set(indexBank,pledgeBank);
-                            isPledge=true;
+                            areaChildren.set(indexBank, pledgeBank);
+                            isPledge = true;
                             break;
                         }
                     }
 
                 }
-                if(!isPledge){
+                if (!isPledge) {
                     DicArea deptDic = new DicArea();
                     deptDic.setCode(dept.getId());
                     deptDic.setName(dept.getKqmc());
@@ -231,7 +227,7 @@
                 }
             }
             List<DicArea> defaultBankChildren = defaultBank.getChildren();
-            if (defaultBankChildren.size()>0) {
+            if (defaultBankChildren.size() > 0) {
                 areaChildren.add(defaultBank);
             }
             area.setChildren(areaChildren);
@@ -522,7 +518,11 @@
                         }
                     }
                 }
-
+                //鍒ゆ柇缃戝叧鏄惁鍦ㄧ嚎
+                GatewaySer cacheSerByDeptId = gatewaySerService.getCacheSerByDeptId(dept.getId());
+                if (null == cacheSerByDeptId || (null != cacheSerByDeptId && StringUtils.isNotBlank(cacheSerByDeptId.getStatus()) && cacheSerByDeptId.getStatus().equals(Constant.YN_N))) {
+                    deptData.setDailyTotal(-1);
+                }
                 list.add(deptData);
             }
         }
@@ -599,7 +599,6 @@
     }
 
 
-
     public GroupGisData getGisDataByCompanyId() {
 
         GroupGisData groupGisData = new GroupGisData();
@@ -662,6 +661,7 @@
 
         return groupGisData;
     }
+
     /**
      * 澶у睆棣栭〉-鎶撴媿璺熻釜淇℃伅
      *
@@ -692,4 +692,53 @@
 
         return new PageResponse<>(RespCodeEnum.CODE_0000, resultListSnap);
     }
+
+
+    /**
+     * 澶у睆棣栭〉-鎶撴媿璺熻釜淇℃伅-灞曠ずAI鏃堕棿鍥剧墖
+     * 灞曠ず鍥剧墖鐨勪笟鍔¢�昏緫锛氭瘡涓簱鍖哄睍绀轰竴寮狅紝鍥剧墖涓哄綋澶╁崄鐐逛互鍚庢渶鏂扮殑涓�寮�
+     *
+     * @param param
+     * @return
+     */
+    public PageResponse<List<EventInfo>> indexEventInfoList(IgdsBaseParam param) {
+//        Date start =DateUtils.setHours(DateUtil.getNewByDay(new Date(), -3), 10);
+        //param.setStart(start);
+//        param.setEnd(DateUtil.getNewByDay(new Date(), -3));
+        Date start =DateUtil.getNewByDay(new Date(), -10);
+        param.setStart(start);
+        param.setEnd(new Date());
+
+        //鑾峰彇褰撴棩鐨勬姄鎷嶄俊鎭�
+        List<EventInfo> listByParam = eventInfoService.getListByParam(param);
+        if (null == listByParam || listByParam.isEmpty()) {
+            return new PageResponse<>(RespCodeEnum.CODE_0000, new ArrayList<>());
+        }
+
+        //鑾峰彇鎵�鏈夌殑搴撳尯淇℃伅
+        List<Dept> deptList = deptService.getDeptByUserType(null);
+        //鏍规嵁搴撳尯浠巐istByParam鏉ヨ幏鍙栨瘡涓�涓簱鍖轰笅锛屾渶鏂扮殑涓�寮犳姄鎷嶅浘鐗�
+        List<EventInfo> resultList = new ArrayList<>();
+
+        for (Dept dept : deptList) {
+            EventInfo latestEvent = null;
+            //浠巐istByParam涓瓫閫夊嚭涓庡綋鍓峣d鍖归厤鐨勬暟鎹�
+            List<EventInfo> collect = listByParam.stream().filter(info -> info.getDeptId().equals(dept.getId())).sorted(Comparator.comparing(EventInfo::getTime).reversed()).collect(Collectors.toList());
+            //姣忎釜搴撳尯鑾峰彇鏈�鏂扮殑3寮犲浘鐗�
+            int i = 0;
+            for (EventInfo info : collect) {
+                if (i > 2) break;
+                resultList.add(info);
+                i++;
+            }
+        }
+        if (null != resultList && !resultList.isEmpty()) {
+            //鍒ゆ柇鏂囦欢鏄惁瀛樺湪
+            for (EventInfo record : resultList) {
+                record.setImgName(commonManager.isImgExit(record.getImgName(), null));
+            }
+        }
+
+        return new PageResponse<>(RespCodeEnum.CODE_0000, resultList);
+    }
 }

--
Gitblit v1.9.3