From 4457b0c0766cfe4f1a8388e1a52432a79c0faf65 Mon Sep 17 00:00:00 2001
From: zhuxinyu <1799009482@qq.com>
Date: Fri, 21 Apr 2023 00:38:42 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8C=BA=E5=9F=9F=E6=8A=A5=E5=91=8A=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../device/pq/mapper/mapping/LineMapper.xml   | 15 ++++++--------
 .../device/pq/mapper/mapping/TopMagMapper.xml | 11 +++++-----
 .../system/pojo/param/EventDictParam.java     |  9 +++++++++
 .../system/pojo/vo/EventReportDictVO.java     |  2 ++
 .../controller/EventTemplateController.java   | 20 +++++++++++++++++++
 .../njcn/system/mapper/TemplateRelMapper.java |  8 +++++---
 .../mapper/mapping/TemplateRelMapper.xml      |  7 +++++++
 .../system/service/IEventTemplateService.java |  3 +++
 .../service/impl/EventDictServiceImpl.java    |  2 +-
 .../impl/EventTemplateServiceImpl.java        | 16 ++++++++++++++-
 10 files changed, 73 insertions(+), 20 deletions(-)

diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml
index 22539dd87..1c894e8f4 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml
@@ -844,24 +844,21 @@
         (t.statisValue)/t.flowMeal flowProportion
         from (
         SELECT
-        a.id,
-        a.Name name,
+        device.Name name,
         sub.Name substation,
-        a.level,
         m.Time_Id updateTime,
         b.run_flag runFlag,
         b.com_flag comFlag,
-        b.id deviceId,
         ifnull(d.flow, (select flow from cld_flow_meal where type = 0 and flag = 1)) + ifnull(d1.flow, 0) flowMeal,
         ROUND(ifnull(m.Actual_Value,0)/1024/1024,2) statisValue
-        FROM pq_line a
-        INNER JOIN pq_line sub ON sub.id = a.pid
-        INNER JOIN pq_device b ON a.id = b.id
-        LEFT JOIN  cld_month_flow  m ON b.id = m.Dev_Id
+        FROM cld_month_flow m
+        INNER JOIN pq_line device ON device.id=m.Dev_Id
+        INNER JOIN pq_device b ON device.id=b.id
+        INNER JOIN pq_line sub ON device.pid = sub.id
         LEFT JOIN cld_dev_meal c ON b.id = c.line_id
         LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
         LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id
-        where a.id in
+        where device.id in
         <foreach item="item" collection="devs" separator="," open="(" close=")">
             #{item}
         </foreach>
diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TopMagMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TopMagMapper.xml
index feb86b3d7..6b6460956 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TopMagMapper.xml
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TopMagMapper.xml
@@ -6,11 +6,11 @@
         SELECT
                 ptm.Time_Id AS time,
                 IFNULL(COUNT(ptm.Dev_Id),3.14159)AS deviceAbnormalNum
-        FROM pq_line line
-        INNER JOIN pq_line vol ON line.pid=vol.id
-        INNER JOIN pq_line device ON vol.pid=device.id
-        LEFT JOIN pqs_top_msg ptm ON ptm.Dev_Id = device.Id
-        LEFT JOIN pq_line_detail pld ON pld.Id=line.Id
+        FROM pqs_top_msg ptm
+        INNER JOIN pq_line device ON ptm.Dev_Id = device.Id
+        INNER JOIN pq_line vol ON vol.pid = device.Id
+        INNER JOIN pq_line line ON line.pid = vol.id
+        INNER JOIN pq_line_detail pld ON pld.Id=line.Id
         WHERE
             ptm.State=1
         AND
@@ -19,7 +19,6 @@
             AND pld.Line_Grade=#{lineGrade}
         </if>
         GROUP BY ptm.Time_Id
-
     </select>
 
     <select id="getTopMsgDetail" resultType="com.njcn.device.pq.pojo.po.TopMsgPO">
diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EventDictParam.java b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EventDictParam.java
index f61fa3b4d..c9226feaf 100644
--- a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EventDictParam.java
+++ b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EventDictParam.java
@@ -62,5 +62,14 @@ public class EventDictParam {
         private String id;
 
 
+        /**
+         *  0.监测点模板 1.区域模板
+         */
+        @ApiModelProperty("type")
+        @NotBlank(message = ValidMessage.DICT_TYPE_ID_NOT_BLANK)
+        @Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
+        private String type;
+
+
     }
 }
diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EventReportDictVO.java b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EventReportDictVO.java
index 7f2017fb3..c366658b8 100644
--- a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EventReportDictVO.java
+++ b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EventReportDictVO.java
@@ -33,4 +33,6 @@ public class EventReportDictVO implements Serializable {
     @ApiModelProperty("子级")
     List<EventReportDictVO> children;
 
+    private Boolean flag;
+
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/controller/EventTemplateController.java b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/EventTemplateController.java
index 217184836..637b73b1f 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/controller/EventTemplateController.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/controller/EventTemplateController.java
@@ -10,6 +10,7 @@ import com.njcn.common.utils.HttpResultUtil;
 import com.njcn.common.utils.LogUtil;
 import com.njcn.system.pojo.param.EventTemplateParam;
 import com.njcn.system.pojo.po.EventTemplate;
+import com.njcn.system.pojo.vo.EventReportDictVO;
 import com.njcn.system.pojo.vo.EventTemplateVO;
 import com.njcn.system.service.IEventTemplateService;
 import com.njcn.web.controller.BaseController;
@@ -155,4 +156,23 @@ public class EventTemplateController extends BaseController{
             return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.DELETE_PID_UNEXIST, null, methodDescribe);
         }
     }
+
+
+
+    /**
+     * 根据模板id查询关系
+     * @param id
+     * @return
+     */
+    @OperateInfo(info = LogEnum.SYSTEM_COMMON)
+    @PostMapping("/selectReleation")
+    @ApiOperation("根据模板id查询关系")
+    @ApiImplicitParam(name = "id", value = "角色索引", required = true)
+    public HttpResult<List<EventReportDictVO>> selectReleation(@RequestParam @Validated String id) {
+        String methodDescribe = getMethodDescribe("selectReleation");
+        LogUtil.njcnDebug(log, "{}，查询数据为：{}", methodDescribe, id);
+        List<EventReportDictVO> res = iEventTemplateService.selectReleation(id);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, res, methodDescribe);
+
+    }
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/TemplateRelMapper.java b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/TemplateRelMapper.java
index f951891d0..185bcdacc 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/TemplateRelMapper.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/TemplateRelMapper.java
@@ -19,9 +19,11 @@ public interface TemplateRelMapper extends BaseMapper<TemplateRel> {
      * @param ids
      * @return
      */
-    List<TemplateRel> selectRelevance(@Param("ids") List<String> ids);
+    List<TemplateRel> selectRelevance (@Param("ids") List<String> ids);
 
-    boolean batchInsert(@Param("list") List<TemplateRel> list);
+    boolean batchInsert (@Param("list") List<TemplateRel> list);
 
-    boolean deleteByRtId(@Param("rtId") String id);
+    boolean deleteByRtId (@Param("rtId") String id);
+
+    List<String> selectReleation (@Param("id") String id);
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/TemplateRelMapper.xml b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/TemplateRelMapper.xml
index cf1ca27c7..961e31cff 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/TemplateRelMapper.xml
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/TemplateRelMapper.xml
@@ -25,4 +25,11 @@
             #{item}
         </foreach>
     </select>
+    <select id="selectReleation" resultType="java.lang.String">
+        SELECT
+        rd.Name
+        FROM report_relevancy rr
+        INNER JOIN report_dict rd ON rr.Rd_Id = rd.Id
+        WHERE rr.Rt_Id = #{id}
+    </select>
 </mapper>
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventTemplateService.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventTemplateService.java
index fb5df537f..0855ac7c5 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventTemplateService.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventTemplateService.java
@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.njcn.system.pojo.param.EventTemplateParam;
 import com.njcn.system.pojo.po.EventTemplate;
+import com.njcn.system.pojo.vo.EventReportDictVO;
 import com.njcn.system.pojo.vo.EventTemplateVO;
 
 import java.util.List;
@@ -51,4 +52,6 @@ public interface IEventTemplateService extends IService<EventTemplate> {
      * @return
      */
     Boolean selectRelevance(List<String> ids);
+
+    List<EventReportDictVO> selectReleation (String id);
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java
index e313206c8..75263d0b3 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java
@@ -143,7 +143,7 @@ public class EventDictServiceImpl extends ServiceImpl<EventDictMapper, ReportDic
                 queryWrapper.orderBy(true, true, "report_dict.update_time");
             }
         }
-        queryWrapper.eq("report_dict.state", DataStateEnum.ENABLE.getCode());
+        queryWrapper.eq("report_dict.state", DataStateEnum.ENABLE.getCode()).eq("report_dict.Type",dictQueryParam.getType());
         List<ReportDict> reportAllDicts = this.baseMapper.selectList(queryWrapper);
         List<ReportDict> reportDicts = new ArrayList<>();
         reportAllDicts.stream().filter(reportDict -> reportDict.getId().equals(dictQueryParam.getId())).forEach(reportDict -> {
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventTemplateServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventTemplateServiceImpl.java
index 9dd05985c..cc18fb8db 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventTemplateServiceImpl.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventTemplateServiceImpl.java
@@ -16,6 +16,7 @@ import com.njcn.system.pojo.param.EventTemplateParam;
 import com.njcn.system.pojo.po.EventTemplate;
 import com.njcn.system.pojo.po.ReportTemplate;
 import com.njcn.system.pojo.po.TemplateRel;
+import com.njcn.system.pojo.vo.EventReportDictVO;
 import com.njcn.system.pojo.vo.EventTemplateVO;
 import com.njcn.system.service.IEventTemplateService;
 import com.njcn.web.factory.PageFactory;
@@ -168,10 +169,23 @@ public class EventTemplateServiceImpl extends ServiceImpl<EventTemplateMapper, E
         }
     }
 
+    @Override
+    public List<EventReportDictVO> selectReleation(String id) {
+        List<EventReportDictVO> list = new ArrayList<>();
+        List<String> configs = templateRelMapper.selectReleation(id);
+        configs.forEach(config -> {
+            EventReportDictVO eventReportDictVO = new EventReportDictVO();
+            eventReportDictVO.setName(config);
+            eventReportDictVO.setFlag(true);
+            list.add(eventReportDictVO);
+        });
+        return list;
+    }
+
     /**
      * 名称重复校验
      */
-    private void checkName(EventTemplateParam eventTemplateParam,boolean flag){
+    private void checkName(EventTemplateParam eventTemplateParam,boolean flag) {
         LambdaQueryWrapper<EventTemplate> lambdaQueryWrapper = new LambdaQueryWrapper<>();
         lambdaQueryWrapper.eq(EventTemplate::getName,eventTemplateParam.getName())
                 .eq(EventTemplate::getType,eventTemplateParam.getType());