From 772a31df287d1b289f18f676e72f08b7133843ee Mon Sep 17 00:00:00 2001
From: zmc <zmc_li@foxmail.com>
Date: 星期一, 13 十一月 2023 16:07:59 +0800
Subject: [PATCH] 新增按站点名称或按类型查询风险值的接口

---
 src/main/java/com/flightfeather/monitor/service/RiskAnalysisService.java          |    9 +++
 src/main/java/com/flightfeather/monitor/mapper/RiskAnalysisMapper.java            |   13 ++++
 src/main/java/com/flightfeather/monitor/service/impl/RiskAnalysisServiceImpl.java |   21 +++++++
 src/main/resources/mapper/RiskAnalysisMapper.xml                                  |   42 ++++++++++++++
 src/main/java/com/flightfeather/monitor/controller/dust/RiskValueController.java  |   33 +++++++++++
 src/main/resources/application.yml                                                |   12 ++--
 src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.java |    6 ++
 7 files changed, 130 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.java b/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.java
index 9105baa..d4f6e42 100644
--- a/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.java
+++ b/src/main/java/com/flightfeather/monitor/analysis/dust/RiskAnalysisController.java
@@ -1,7 +1,13 @@
 package com.flightfeather.monitor.analysis.dust;
 
+import com.flightfeather.monitor.service.AnalysisDataService;
+import org.springframework.beans.factory.annotation.Autowired;
+
 /**
  * 鏁版嵁椋庨櫓鍒嗘瀽鎺у埗鍣�
  */
 public class RiskAnalysisController {
+
+    @Autowired
+    private AnalysisDataService analysisDataService;
 }
diff --git a/src/main/java/com/flightfeather/monitor/controller/dust/RiskValueController.java b/src/main/java/com/flightfeather/monitor/controller/dust/RiskValueController.java
new file mode 100644
index 0000000..3808351
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/controller/dust/RiskValueController.java
@@ -0,0 +1,33 @@
+package com.flightfeather.monitor.controller.dust;
+
+
+import com.flightfeather.monitor.domain.ds1.entity.RiskValue;
+import com.flightfeather.monitor.pojo.AnalysisData;
+import com.flightfeather.monitor.pojo.Result;
+import com.flightfeather.monitor.service.AnalysisDataService;
+import com.flightfeather.monitor.service.RiskAnalysisService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping("/dust/risk")
+@CrossOrigin
+public class RiskValueController {
+    @Autowired
+    private RiskAnalysisService riskAnalysisService;
+
+
+    /*鏍规嵁绔欑偣鍚嶅瓧锛堝彲閫夊�硷級锛屾湀浠斤紝绫诲瀷鏉ヨ繑鍥為闄╁��*/
+    @GetMapping("/month")
+    public Result queryRiskDataByMonth(String siteName,String month,String type){
+        List<RiskValue> list =riskAnalysisService.queryRiskDataByMonth(siteName,month,type);
+        return Result.success(list);
+    }
+}
diff --git a/src/main/java/com/flightfeather/monitor/mapper/RiskAnalysisMapper.java b/src/main/java/com/flightfeather/monitor/mapper/RiskAnalysisMapper.java
new file mode 100644
index 0000000..43a2290
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/mapper/RiskAnalysisMapper.java
@@ -0,0 +1,13 @@
+package com.flightfeather.monitor.mapper;
+
+import com.flightfeather.monitor.domain.ds1.entity.RiskValue;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+
+@Mapper
+public interface RiskAnalysisMapper {
+
+    List<RiskValue> queryRiskDataByMonth(String siteName,String month, String type);
+}
diff --git a/src/main/java/com/flightfeather/monitor/service/RiskAnalysisService.java b/src/main/java/com/flightfeather/monitor/service/RiskAnalysisService.java
new file mode 100644
index 0000000..9374e3a
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/RiskAnalysisService.java
@@ -0,0 +1,9 @@
+package com.flightfeather.monitor.service;
+
+import com.flightfeather.monitor.domain.ds1.entity.RiskValue;
+
+import java.util.List;
+
+public interface RiskAnalysisService {
+    List<RiskValue> queryRiskDataByMonth(String siteName,String month,String type);
+}
diff --git a/src/main/java/com/flightfeather/monitor/service/impl/RiskAnalysisServiceImpl.java b/src/main/java/com/flightfeather/monitor/service/impl/RiskAnalysisServiceImpl.java
new file mode 100644
index 0000000..6e8dd21
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/impl/RiskAnalysisServiceImpl.java
@@ -0,0 +1,21 @@
+package com.flightfeather.monitor.service.impl;
+
+import com.flightfeather.monitor.domain.ds1.entity.RiskValue;
+import com.flightfeather.monitor.mapper.RiskAnalysisMapper;
+import com.flightfeather.monitor.service.RiskAnalysisService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class RiskAnalysisServiceImpl implements RiskAnalysisService {
+    @Autowired
+    private RiskAnalysisMapper riskAnalysisMapper;
+
+    @Override
+    public List<RiskValue> queryRiskDataByMonth(String siteName,String month,String type) {
+        List<RiskValue> list = riskAnalysisMapper.queryRiskDataByMonth(siteName,month,type);
+        return list;
+    }
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 0889e17..ceaf07e 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -6,17 +6,17 @@
 #      username: fume
 #      password: fume_feiyu2023
 
-#      url: jdbc:mysql://localhost:3306/qianduan_sql
-#      username: root
-#      password: 1234
+      url: jdbc:mysql://localhost:3306/qianduan_sql
+      username: root
+      password: 1234
 
 #      url: jdbc:mysql://localhost:3306/fume
 #      username: root
 #      password: 123456
 
-      url: jdbc:mysql://114.215.109.124:3306/fume
-      username: fumeRemote
-      password: feiyu2023
+#      url: jdbc:mysql://114.215.109.124:3306/fume
+#      username: fumeRemote
+#      password: feiyu2023
 
 mybatis:
   configuration:
diff --git a/src/main/resources/mapper/RiskAnalysisMapper.xml b/src/main/resources/mapper/RiskAnalysisMapper.xml
new file mode 100644
index 0000000..7ec8340
--- /dev/null
+++ b/src/main/resources/mapper/RiskAnalysisMapper.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.flightfeather.monitor.mapper.RiskAnalysisMapper">
+
+    <select id="queryRiskDataByMonth" resultType="com.flightfeather.monitor.domain.ds1.entity.RiskValue">
+        select b.name,a.*
+        from du_js_t_risk_value as a join ja_t_dust_site_info as b on a.mn_code = b.mn_code
+        <where>
+            <if test="siteName != null and siteName != '' ">
+                b.name = #{siteName}
+            </if>
+
+            <if test="month != null and month != '' ">
+                and  a.lst = #{month}
+            </if>
+
+            <if test="type != null and type != '' ">
+                and a.type = #{type}
+            </if>
+        </where>
+    </select>
+
+</mapper>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

--
Gitblit v1.9.3