From 7e0ddef04dba365a677192c5d9cdcc687291a974 Mon Sep 17 00:00:00 2001
From: cwchen <1048842385@qq.com>
Date: Fri, 25 Apr 2025 11:12:52 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=B5=E5=AD=90=E7=9C=8B=E6=9D=BF-=E6=9D=86?=
 =?UTF-8?q?=E5=A1=94=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../backstage/dao/DigitalSignageDao.java      |  9 +++
 .../backstage/entity/vo/DigitalSignageVo.java | 38 +++++++++++++
 .../impl/DigitalSignageServiceImpl.java       |  9 ++-
 .../backstage/DigitalSignageMapper.xml        | 57 +++++++++++++++++--
 4 files changed, 108 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/bonus/digitalSignage/backstage/dao/DigitalSignageDao.java b/src/main/java/com/bonus/digitalSignage/backstage/dao/DigitalSignageDao.java
index 791fc0a..bd04f5c 100644
--- a/src/main/java/com/bonus/digitalSignage/backstage/dao/DigitalSignageDao.java
+++ b/src/main/java/com/bonus/digitalSignage/backstage/dao/DigitalSignageDao.java
@@ -69,4 +69,13 @@ public interface DigitalSignageDao {
      * @date 2025/4/25 9:11
      */
     List<DigitalSignageVo.TowerInfoVo> getTowersInfo(QueryParamDto dto);
+
+    /**
+     * 查询交叉跨越信息
+     * @param dto
+     * @return List<TowerInfoVo>
+     * @author cwchen
+     * @date 2025/4/25 10:35
+     */
+    List<DigitalSignageVo.SpanInfoVo> getSpanInfoVos(QueryParamDto dto);
 }
diff --git a/src/main/java/com/bonus/digitalSignage/backstage/entity/vo/DigitalSignageVo.java b/src/main/java/com/bonus/digitalSignage/backstage/entity/vo/DigitalSignageVo.java
index 4c7e5df..b0498f5 100644
--- a/src/main/java/com/bonus/digitalSignage/backstage/entity/vo/DigitalSignageVo.java
+++ b/src/main/java/com/bonus/digitalSignage/backstage/entity/vo/DigitalSignageVo.java
@@ -1,6 +1,7 @@
 package com.bonus.digitalSignage.backstage.entity.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonInclude;
 import lombok.Data;
 
 import java.util.Date;
@@ -147,6 +148,7 @@ public class DigitalSignageVo {
 
     @Data
     public static class TowerInfoVo{
+        private Long id;
         /**杆塔名称*/
         private String towerName;
         /**百度经度*/
@@ -176,5 +178,41 @@ public class DigitalSignageVo {
         private Date time7;
         /**是否存在跨越 1.存在 0.不存在*/
         private int existSpan;
+        /**杆塔完成进度 1.基础开挖 2.基础开挖完成 3.基础浇筑完成 4.铁塔组立 5.铁塔组立完成 6.架线施工完成 7.附件安装完成*/
+        private int towerProgress;
+    }
+
+    @Data
+    public static class SpanInfoVo{
+
+        private Long id;
+
+        private String spanTowerName;
+
+        private TowerInfoVo towerInfoVo;
+
+        private String lonAndLat;
+
+        /**
+         * 上层线路
+         */
+        private String upperLine;
+        /**
+         * 下层线路
+         */
+        private String lowerLine;
+        /**
+         * 交叉角度
+         */
+        private String intersectionAngle;
+        /**
+         * 垂直距离（m）
+         */
+        private String verticalDistance;
+        /**
+         * 安全裕度（°）
+         */
+        private String safetyMargin;
+
     }
 }
diff --git a/src/main/java/com/bonus/digitalSignage/backstage/service/impl/DigitalSignageServiceImpl.java b/src/main/java/com/bonus/digitalSignage/backstage/service/impl/DigitalSignageServiceImpl.java
index 77e8959..d0c2e02 100644
--- a/src/main/java/com/bonus/digitalSignage/backstage/service/impl/DigitalSignageServiceImpl.java
+++ b/src/main/java/com/bonus/digitalSignage/backstage/service/impl/DigitalSignageServiceImpl.java
@@ -96,10 +96,17 @@ public class DigitalSignageServiceImpl implements DigitalSignageService {
         try {
             // 查询索道运输信息
             List<DigitalSignageVo.CablewaTransVo> cablewaTransVos = Optional.ofNullable(dao.getCablewaTrans(dto)).orElseGet(ArrayList::new);
-            // 查询交叉跨越信息
             // 查询杆塔数据
             List<DigitalSignageVo.TowerInfoVo> towerInfoVos = Optional.ofNullable(dao.getTowersInfo(dto)).orElseGet(ArrayList::new);
+            // 查询交叉跨越信息
+            List<DigitalSignageVo.SpanInfoVo> spanInfoVo = Optional.ofNullable(dao.getSpanInfoVos(dto)).orElseGet(ArrayList::new);
+            for (DigitalSignageVo.SpanInfoVo vo : spanInfoVo) {
+                Optional<DigitalSignageVo.TowerInfoVo> first = towerInfoVos.stream().filter(towerInfoVo -> towerInfoVo.getId().equals(vo.getId())).findFirst();
+                vo.setTowerInfoVo(first.get());
+            }
             map.put("cablewaTransVos", cablewaTransVos);
+            map.put("towerInfoVos", towerInfoVos);
+            map.put("spanInfoVos", spanInfoVo);
         } catch (Exception e) {
             log.error(e.toString(),e);
         }
diff --git a/src/main/resources/mappers/backstage/DigitalSignageMapper.xml b/src/main/resources/mappers/backstage/DigitalSignageMapper.xml
index 1915d1d..c2b6c18 100644
--- a/src/main/resources/mappers/backstage/DigitalSignageMapper.xml
+++ b/src/main/resources/mappers/backstage/DigitalSignageMapper.xml
@@ -99,14 +99,63 @@
     <!--查询杆塔数据-->
     <select id="getTowersInfo"
             resultType="com.bonus.digitalSignage.backstage.entity.vo.DigitalSignageVo$TowerInfoVo">
-        SELECT tt.tower_name AS towerName,
+        SELECT tt.id,
+               tt.tower_name AS towerName,
                tt.baidu_lon AS baiduLon,
-               tt.baidu_lat AS baiduLat
+               tt.baidu_lat AS baiduLat,
+               A.time1,
+               A.time2,
+               A.time3,
+               A.time4,
+               A.time5,
+               A.time6,
+               A.time7,
+               IF(B.tower_id IS NOT NULL OR B.tower_id IS NOT NULL, 1, 0) AS existSpan,
+               tt.tower_progress AS towerProgress
         FROM tb_tower tt
         LEFT JOIN (
-            SELECT ttp.tower_id
-            FROM tb_tower_progress ttp
+            SELECT tower_id,next_tower_id
+            FROM tb_three_span tts
+            WHERE tts.span_type = '1'
+            GROUP BY tower_id,next_tower_id
+        ) B ON (tt.id = B.tower_id) OR (tt.id = B.next_tower_id)
+        LEFT JOIN (
+            SELECT
+                ttp.tower_id,
+                MAX(CASE WHEN progress_type = 1 THEN create_time END) AS time1,
+                MAX(CASE WHEN progress_type = 2 THEN create_time END) AS time2,
+                MAX(CASE WHEN progress_type = 3 THEN create_time END) AS time3,
+                MAX(CASE WHEN progress_type = 4 THEN create_time END) AS time4,
+                MAX(CASE WHEN progress_type = 5 THEN create_time END) AS time5,
+                MAX(CASE WHEN progress_type = 6 THEN create_time END) AS time6,
+                MAX(CASE WHEN progress_type = 7 THEN create_time END) AS time7
+            FROM
+                tb_tower_progress ttp
+            GROUP BY
+                ttp.tower_id
         ) A ON tt.id = A.tower_id
         WHERE tt.pro_id = #{id}
+        ORDER BY tt.sort
+    </select>
+    <!--查询交叉跨越信息-->
+    <select id="getSpanInfoVos"
+            resultType="com.bonus.digitalSignage.backstage.entity.vo.DigitalSignageVo$SpanInfoVo">
+        SELECT CONCAT(tt.tower_name,'-',tt2.tower_name) AS spanTowerName,
+               tts.upper_line AS upperLine,
+               tts.lower_line AS lowerLine,
+               tts.intersection_angle AS intersectionAngle,
+               tts.vertical_distance AS verticalDistance,
+               tts.safety_margin AS safetyMargin,
+               A.lonAndLat AS lonAndLat,
+               tts.tower_id AS id
+        FROM tb_three_span tts
+        LEFT JOIN tb_tower tt ON tts.tower_id = tt.id
+        LEFT JOIN tb_tower tt2 ON tts.next_tower_id = tt2.id
+        LEFT JOIN (
+            SELECT three_span_id,GROUP_CONCAT(baidu_lon,'@',baidu_lat) AS lonAndLat
+            FROM tb_span_tower
+            GROUP BY three_span_id
+        ) A ON tts.id = A.three_span_id
+        WHERE tts.pro_id = #{id} AND tts.span_type = '1'
     </select>
 </mapper>