From 9f9b40c22e24daf68881e2c404b6daebd7e7af0d Mon Sep 17 00:00:00 2001
From: liuguijing <123456>
Date: Mon, 26 Jun 2023 18:53:31 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A3=85=E7=BD=AE=E6=9F=A5=E8=AF=A2=E5=92=8C?=
 =?UTF-8?q?=E9=A6=96=E9=A1=B5=E6=9F=A5=E8=AF=A2bug=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dto/TermAndChannelDto.java                |  2 +-
 .../dto/TerminalsAndStatusDto.java            |  2 ++
 .../src/main/resources/mappers/DyLevelDao.xml | 23 ++++++++++---------
 .../src/main/resources/mappers/LinesDao.xml   |  6 ++++-
 .../resources/mappers/TerminalChannelsDao.xml |  4 +++-
 .../main/resources/mappers/TerminalsDao.xml   |  9 ++++++--
 .../src/main/resources/mappers/TowerDao.xml   |  7 +++++-
 .../impl/CacheServiceImpl.java                | 20 ++++++++--------
 .../impl/TerminalServiceImpl.java             | 13 +++++++----
 9 files changed, 54 insertions(+), 32 deletions(-)

diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TermAndChannelDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TermAndChannelDto.java
index 1106692..dccbbe7 100644
--- a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TermAndChannelDto.java
+++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TermAndChannelDto.java
@@ -12,7 +12,7 @@ public class TermAndChannelDto {
 
     private Integer termid;
 
-    private List<TermChannelAndMapperDto> channellist;
+    private List<TermChannelAndMapperDto> list;
 
 
 }
diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalsAndStatusDto.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalsAndStatusDto.java
index 517b96d..ce0a1a7 100644
--- a/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalsAndStatusDto.java
+++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/dto/TerminalsAndStatusDto.java
@@ -39,6 +39,8 @@ public class TerminalsAndStatusDto implements Serializable {
 
     private Double longitude;
 
+    private Integer status;
+
     private Short signalStrength4g;
 
     private BigInteger bootTime;
diff --git a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml
index eceec0d..a85b3cd 100644
--- a/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml
+++ b/xymanager_dao/src/main/resources/mappers/DyLevelDao.xml
@@ -137,18 +137,19 @@
         b.name as line_name,
         b.bs_manufacturer as bs_manufacturer,
         b.dy_level_id as dy_level_id,
-        c.id as term_id,
-        c.tower_id as tower_id,
-        d.name as tower_name,
-        c.cmdid as cmdid,
-        c.equip_name as equip_name,
-        c.display_name as display_name,
-        c.model as model,
+        d.id as term_id,
+        d.tower_id as tower_id,
+        c.name as tower_name,
+        d.cmdid as cmdid,
+        d.equip_name as equip_name,
+        d.display_name as display_name,
+        d.model as model,
         e.last_heartbeat as last_heartbeat
-        from ((((dy_level a left join `lines` b on a.id = b.dy_level_id and b.status = #{status} and a.status = #{status})
-        left join towers d on c.tower_id = d.id)
-        left join terminals c on b.id = c.line_id and c.status = #{status})
-        left join terminal_status e on e.term_id = c.id)
+        from ((((dy_level a left join `lines` b on a.id = b.dy_level_id )
+        left join towers c on b.id = c.line_id )
+        left join terminals d on c.id = d.tower_id )
+        left join terminal_status e on e.term_id = d.id)
+        where b.status = #{status} and a.status = #{status} and c.status = #{status} and d.status = #{status}
     </select>
 
     <select id="selectTreeListByChannelId" resultMap="LineAndTerminalNoHeartMap">
diff --git a/xymanager_dao/src/main/resources/mappers/LinesDao.xml b/xymanager_dao/src/main/resources/mappers/LinesDao.xml
index 28fc9a9..c99c3b0 100644
--- a/xymanager_dao/src/main/resources/mappers/LinesDao.xml
+++ b/xymanager_dao/src/main/resources/mappers/LinesDao.xml
@@ -33,7 +33,11 @@
         y.name as dy_level_name
         from `lines` x,
         dy_level y
-        where x.dy_level_id = y.id and x.status = #{status} order by x.create_time desc
+        where x.dy_level_id = y.id
+        <if test="status != null">
+            and x.status = #{status}
+        </if>
+        order by x.create_time desc
     </select>
     <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
         select
diff --git a/xymanager_dao/src/main/resources/mappers/TerminalChannelsDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalChannelsDao.xml
index 638d39c..98c58df 100644
--- a/xymanager_dao/src/main/resources/mappers/TerminalChannelsDao.xml
+++ b/xymanager_dao/src/main/resources/mappers/TerminalChannelsDao.xml
@@ -72,7 +72,9 @@
         select
         <include refid="Base_Column_List"/>
         from terminal_channels
-        where status = #{status}
+        <if test="status != null">
+            where status = #{status}
+        </if>
     </select>
 
     <select id="selectTermChannelList" resultMap="TermAndChannelMap">
diff --git a/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml b/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml
index 1687495..93f6318 100644
--- a/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml
+++ b/xymanager_dao/src/main/resources/mappers/TerminalsDao.xml
@@ -38,6 +38,7 @@
         <result column="bs_identifier" jdbcType="VARCHAR" property="bsIdentifier"/>
         <result column="latitude" jdbcType="DOUBLE" property="latitude"/>
         <result column="longitude" jdbcType="DOUBLE" property="longitude"/>
+        <result column="status" jdbcType="INTEGER" property="status"/>
         <result column="signal_strength_4g" jdbcType="SMALLINT" property="signalStrength4g"/>
         <result column="boot_time" jdbcType="INTEGER" property="bootTime"/>
         <result column="battery_capacity" jdbcType="FLOAT" property="batteryCapacity"/>
@@ -64,7 +65,10 @@
         select
         <include refid="Base_Column_List"/>
         from terminals
-        where status = #{status}
+        <if test="status != null">
+            where status = #{status}
+        </if>
+
     </select>
 
     <select id="selectById" resultMap="BaseResultMap">
@@ -132,6 +136,7 @@
         a.bs_identifier as bs_identifier,
         a.latitude as latitude,
         a.longitude as longitude,
+        a.status as status,
         b.signal_strength_4g as signal_strength_4g,
         b.boot_time as boot_time,
         b.battery_capacity as battery_capacity,
@@ -140,7 +145,7 @@
         from
         (terminals a left join terminal_status b on a.id = b.term_id )
         <if test="status != null">
-            a.status = #{status}
+            where a.status = #{status}
         </if>
         order by a.create_time desc
     </select>
diff --git a/xymanager_dao/src/main/resources/mappers/TowerDao.xml b/xymanager_dao/src/main/resources/mappers/TowerDao.xml
index d56dc8b..bf7ad56 100644
--- a/xymanager_dao/src/main/resources/mappers/TowerDao.xml
+++ b/xymanager_dao/src/main/resources/mappers/TowerDao.xml
@@ -25,7 +25,12 @@
         t.status as status
         from towers t,
         `lines` l
-        where t.line_id = l.id and t.status =  #{status,jdbcType=INTEGER} order by t.`order` asc,l.id desc
+        where t.line_id = l.id
+        <if test="status != null">
+            and t.status = #{status,jdbcType=INTEGER}
+        </if>
+        order by t.`order` asc,l.id desc
+
     </select>
 
     <select id="selectAllByLineid" resultType="com.shxy.xymanager_common.entity.Towers">
diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CacheServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CacheServiceImpl.java
index 3214f7d..297da12 100644
--- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CacheServiceImpl.java
+++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CacheServiceImpl.java
@@ -238,7 +238,7 @@ public class CacheServiceImpl implements CacheService {
     @Cacheable(value = "termchannelMap")
     public Map<Integer, TerminalChannels> getTermChannelMap() {
         Map<Integer, TerminalChannels> termchannelMap = new HashMap<Integer, TerminalChannels>();
-        List<TerminalChannels> channelslist = terminalChannelsDao.selectChannelList(CommonStatus.EFFECTIVE.value());
+        List<TerminalChannels> channelslist = terminalChannelsDao.selectChannelList(null);
         for (TerminalChannels item : channelslist) {
             termchannelMap.put(item.getId(), item);
         }
@@ -249,7 +249,7 @@ public class CacheServiceImpl implements CacheService {
     @Cacheable(value = "termAndchannelMap")
     public Map<Integer, TermAndChannelDto> getTermAndChannelMap() {
         Map<Integer, TermAndChannelDto> termchannelMap = new HashMap<Integer, TermAndChannelDto>();
-        List<TermAndChannelDto> list = terminalChannelsDao.selectTermChannelList(CommonStatus.EFFECTIVE.value());
+        List<TermAndChannelDto> list = terminalChannelsDao.selectTermChannelList(null);
         for (TermAndChannelDto item : list) {
             termchannelMap.put(item.getTermid(), item);
         }
@@ -261,7 +261,7 @@ public class CacheServiceImpl implements CacheService {
     @Cacheable(value = "towerMap")
     public Map<Integer, TowerDto> getTowerMap() {
         Map<Integer, TowerDto> towerMap = new HashMap<Integer, TowerDto>();
-        List<TowerDto> towerlist = towerDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<TowerDto> towerlist = towerDao.selectAll(null);
         for (TowerDto item : towerlist) {
             towerMap.put(item.getId(), item);
         }
@@ -272,7 +272,7 @@ public class CacheServiceImpl implements CacheService {
     @Cacheable(value = "terminalMap")
     public Map<Integer, Terminals> getTerminalMap() {
         Map<Integer, Terminals> terminalMap = new HashMap<Integer, Terminals>();
-        List<Terminals> termslist = terminalsDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<Terminals> termslist = terminalsDao.selectAll(null);
         for (Terminals item : termslist) {
             terminalMap.put(item.getId(), item);
         }
@@ -283,7 +283,7 @@ public class CacheServiceImpl implements CacheService {
     @Cacheable(value = "lineMap")
     public Map<Integer, LineAndDyNameDto> getLineMap() {
         Map<Integer, LineAndDyNameDto> lineMap = new HashMap<Integer, LineAndDyNameDto>();
-        List<LineAndDyNameDto> lineAndDyNameDtos = linesDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<LineAndDyNameDto> lineAndDyNameDtos = linesDao.selectAll(null);
         for (LineAndDyNameDto lineitem : lineAndDyNameDtos) {
             lineMap.put(lineitem.getId(), lineitem);
         }
@@ -329,7 +329,7 @@ public class CacheServiceImpl implements CacheService {
     @CachePut(value = "termchannelMap")
     public Map<Integer, TerminalChannels> updateTermChannelMap() {
         Map<Integer, TerminalChannels> termchannelMap = new HashMap<Integer, TerminalChannels>();
-        List<TerminalChannels> channelslist = terminalChannelsDao.selectChannelList(CommonStatus.EFFECTIVE.value());
+        List<TerminalChannels> channelslist = terminalChannelsDao.selectChannelList(null);
         for (TerminalChannels item : channelslist) {
             termchannelMap.put(item.getId(), item);
         }
@@ -340,7 +340,7 @@ public class CacheServiceImpl implements CacheService {
     @CachePut(value = "termAndchannelMap")
     public Map<Integer, TermAndChannelDto> updateTermAndChannelMap() {
         Map<Integer, TermAndChannelDto> termchannelMap = new HashMap<Integer, TermAndChannelDto>();
-        List<TermAndChannelDto> list = terminalChannelsDao.selectTermChannelList(CommonStatus.EFFECTIVE.value());
+        List<TermAndChannelDto> list = terminalChannelsDao.selectTermChannelList(null);
         for (TermAndChannelDto item : list) {
             termchannelMap.put(item.getTermid(), item);
         }
@@ -351,7 +351,7 @@ public class CacheServiceImpl implements CacheService {
     @CachePut(value = "towerMap")
     public Map<Integer, TowerDto> updateTowerMap() {
         Map<Integer, TowerDto> towerMap = new HashMap<Integer, TowerDto>();
-        List<TowerDto> towerlist = towerDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<TowerDto> towerlist = towerDao.selectAll(null);
         for (TowerDto item : towerlist) {
             towerMap.put(item.getId(), item);
         }
@@ -362,7 +362,7 @@ public class CacheServiceImpl implements CacheService {
     @CachePut(value = "terminalMap")
     public Map<Integer, Terminals> updateTerminalMap() {
         Map<Integer, Terminals> terminalMap = new HashMap<Integer, Terminals>();
-        List<Terminals> termslist = terminalsDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<Terminals> termslist = terminalsDao.selectAll(null);
         for (Terminals item : termslist) {
             terminalMap.put(item.getId(), item);
         }
@@ -373,7 +373,7 @@ public class CacheServiceImpl implements CacheService {
     @CachePut(value = "lineMap")
     public Map<Integer, LineAndDyNameDto> updateLineMap() {
         Map<Integer, LineAndDyNameDto> lineMap = new HashMap<Integer, LineAndDyNameDto>();
-        List<LineAndDyNameDto> lineAndDyNameDtos = linesDao.selectAll(CommonStatus.EFFECTIVE.value());
+        List<LineAndDyNameDto> lineAndDyNameDtos = linesDao.selectAll(null);
         for (LineAndDyNameDto lineitem : lineAndDyNameDtos) {
             lineMap.put(lineitem.getId(), lineitem);
         }
diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java
index d4f7853..1ef2b50 100644
--- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java
+++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/TerminalServiceImpl.java
@@ -86,7 +86,7 @@ public class TerminalServiceImpl implements TerminalService {
         int pageindex = vo.getPageindex();
         int pagesize = vo.getPagesize();
         PageUtils.SetPage(pageindex, pagesize);
-        List<TerminalsAndStatusDto> list2 = terminalsDao.selectTermAndStatusList(CommonStatus.EFFECTIVE.value());
+        List<TerminalsAndStatusDto> list2 = terminalsDao.selectTermAndStatusList(null);
         boolean empty = CollectionUtil.isEmpty(list2);
         if (empty) {
             model.setList(new ArrayList<>());
@@ -100,9 +100,12 @@ public class TerminalServiceImpl implements TerminalService {
                 Integer towerid = item.getTowerid();
                 terminalsBean.setId(item.getId());
                 terminalsBean.setTowerId(towerid);
-                terminalsBean.setTowerName(towerMap.get(towerid).getName());
-                terminalsBean.setLineId(towerMap.get(towerid).getLineId());
-                terminalsBean.setLineName(towerMap.get(towerid).getLineName());
+                TowerDto towerDto = towerMap.get(towerid);
+                if (BeanUtil.isNotEmpty(towerDto)) {
+                    terminalsBean.setTowerName(towerDto.getName());
+                    terminalsBean.setLineId(towerDto.getLineId());
+                    terminalsBean.setLineName(towerDto.getLineName());
+                }
                 terminalsBean.setCmdId(item.getCmdid());
                 terminalsBean.setOrgId(item.getOrgId());
                 terminalsBean.setEquipName(item.getEquipName());
@@ -127,7 +130,7 @@ public class TerminalServiceImpl implements TerminalService {
                 if (BeanUtil.isEmpty(termAndChannelDto)) {
                     terminalsBean.setList(list);
                 } else {
-                    List<TermChannelAndMapperDto> channellist = termAndChannelDto.getChannellist();
+                    List<TermChannelAndMapperDto> channellist = termAndChannelDto.getList();
                     if (CollectionUtil.isEmpty(channellist)) {
                         terminalsBean.setList(list);
                     } else {