From 357c5a3c4659f1fe9e46e8c20827ab757c5d3929 Mon Sep 17 00:00:00 2001
From: zmc <zmc_li@foxmail.com>
Date: 星期四, 14 十二月 2023 15:27:34 +0800
Subject: [PATCH] 增加数据请求配置表和异常分析配置表的接口
---
src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java | 1
src/main/java/com/flightfeather/monitor/controller/dust/ExceptionSettingController.java | 58 +++++++++++
src/main/java/com/flightfeather/monitor/service/ExceptionSettingService.java | 16 +++
src/main/java/com/flightfeather/monitor/controller/dust/RequestSettingController.java | 59 +++++++++++
src/main/java/com/flightfeather/monitor/service/RequestSettingService.java | 16 +++
src/main/java/com/flightfeather/monitor/service/impl/RequestSettingImpl.java | 70 ++++++++++++++
src/main/java/com/flightfeather/monitor/service/impl/ExceptionSettingImpl.java | 63 ++++++++++++
7 files changed, 283 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/flightfeather/monitor/controller/dust/ExceptionSettingController.java b/src/main/java/com/flightfeather/monitor/controller/dust/ExceptionSettingController.java
new file mode 100644
index 0000000..74b97f8
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/controller/dust/ExceptionSettingController.java
@@ -0,0 +1,58 @@
+package com.flightfeather.monitor.controller.dust;
+import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting;
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+import com.flightfeather.monitor.pojo.Result;
+import com.flightfeather.monitor.service.ExceptionSettingService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @ClassName: ExceptionSettingController
+ * @Description: TODO
+ * @author: yourname
+ */
+@Slf4j
+@RestController
+@RequestMapping("/dust/exception")
+@CrossOrigin
+public class ExceptionSettingController {
+ @Autowired
+ private ExceptionSettingService exceptionSettingService;
+
+ /*鏌ヨ寮傚父鍒嗘瀽閰嶇疆琛ㄧ殑鎵�鏈夋暟鎹� 缁撴灉鏄寜鏇存柊鏃堕棿 闄嶅簭鎺掑垪*/
+ @GetMapping("/querySetting")
+ public Result queryRequestSettingData(){
+ List<DustExceptionSetting> list = exceptionSettingService.queryExceptionSettingData();
+ return Result.success(list);
+ }
+
+ /*鏍规嵁鐗堟湰鍙� 鏌ヨ*/
+ @GetMapping("/byVersion")
+ public Result queryByVersion(String version) {
+ if (version == "" || version == null) {
+ return Result.error("鐗堟湰鍙蜂笉鑳戒负绌猴紒");
+ }
+
+ List<DustExceptionSetting> list = exceptionSettingService.queryByVersion(version);
+ return Result.success(list);
+ }
+
+
+ /*淇敼鏁版嵁璇锋眰鐨勯厤缃�*/
+ @PostMapping("/alertSetting")
+ public Result alertRequestSetting(@RequestBody DustExceptionSetting dustExceptionSetting) {
+ exceptionSettingService.alertExceptionSetting(dustExceptionSetting);
+ return Result.success();
+ }
+
+ /*鏂板寮傚父鍒嗘瀽鐨勯厤缃�*/
+ @PostMapping("/addSetting")
+ public Result addNewRequestSetting(@RequestBody DustExceptionSetting dustExceptionSetting){
+ exceptionSettingService.addNewExceptionSetting(dustExceptionSetting);
+ return Result.success();
+ }
+
+}
diff --git a/src/main/java/com/flightfeather/monitor/controller/dust/RequestSettingController.java b/src/main/java/com/flightfeather/monitor/controller/dust/RequestSettingController.java
new file mode 100644
index 0000000..463aee6
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/controller/dust/RequestSettingController.java
@@ -0,0 +1,59 @@
+package com.flightfeather.monitor.controller.dust;
+
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+import com.flightfeather.monitor.pojo.Result;
+import com.flightfeather.monitor.service.RequestSettingService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * @ClassName: RequestSettingController
+ * @Description: TODO
+ * @author: yourname
+ */
+
+@Slf4j
+@RestController
+@RequestMapping("/dust/request")
+@CrossOrigin
+public class RequestSettingController {
+ @Autowired
+ private RequestSettingService requestSettingService;
+
+ /*鏌ヨ鏁版嵁璇锋眰閰嶇疆琛ㄧ殑鎵�鏈夋暟鎹� 缁撴灉鏄寜鏇存柊鏃堕棿 闄嶅簭鎺掑垪*/
+ @GetMapping("/querySetting")
+ public Result queryRequestSettingData() {
+ List<RequestTaskSetting> list = requestSettingService.queryRequestSettingData();
+ return Result.success(list);
+ }
+
+ /*鏍规嵁鐗堟湰鍙� 鏌ヨ*/
+ @GetMapping("/byVersion")
+ public Result queryByVersion(String version) {
+ if (version == "" || version == null) {
+ return Result.error("鐗堟湰鍙蜂笉鑳戒负绌猴紒");
+ }
+
+ List<RequestTaskSetting> list = requestSettingService.queryByVersion(version);
+ return Result.success(list);
+ }
+
+ /*淇敼鏁版嵁璇锋眰鐨勯厤缃�*/
+ @PostMapping("/alertSetting")
+ public Result alertRequestSetting(@RequestBody RequestTaskSetting requestTaskSetting) {
+ requestSettingService.alertRequestSetting(requestTaskSetting);
+ return Result.success();
+ }
+
+ /*鏂板鏁版嵁璇锋眰鐨勯厤缃�*/
+ @PostMapping("/addSetting")
+ public Result addNewRequestSetting(@RequestBody RequestTaskSetting requestTaskSetting) {
+ requestSettingService.addNewRequestSetting(requestTaskSetting);
+ return Result.success();
+ }
+
+
+}
diff --git a/src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java b/src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java
index d50e42b..b2a80be 100644
--- a/src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java
+++ b/src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java
@@ -1,5 +1,6 @@
package com.flightfeather.monitor.domain.ds1.entity;
+import java.time.LocalDateTime;
import java.util.Date;
import javax.persistence.*;
diff --git a/src/main/java/com/flightfeather/monitor/service/ExceptionSettingService.java b/src/main/java/com/flightfeather/monitor/service/ExceptionSettingService.java
new file mode 100644
index 0000000..8ad8c2b
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/ExceptionSettingService.java
@@ -0,0 +1,16 @@
+package com.flightfeather.monitor.service;
+
+import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting;
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+
+import java.util.List;
+
+public interface ExceptionSettingService {
+ List<DustExceptionSetting> queryExceptionSettingData();
+
+ void addNewExceptionSetting(DustExceptionSetting dustExceptionSetting);
+
+ List<DustExceptionSetting> queryByVersion(String version);
+
+ void alertExceptionSetting(DustExceptionSetting dustExceptionSetting);
+}
diff --git a/src/main/java/com/flightfeather/monitor/service/RequestSettingService.java b/src/main/java/com/flightfeather/monitor/service/RequestSettingService.java
new file mode 100644
index 0000000..f6ac6bd
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/RequestSettingService.java
@@ -0,0 +1,16 @@
+package com.flightfeather.monitor.service;
+
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+
+import java.util.List;
+
+public interface RequestSettingService {
+
+ void addNewRequestSetting(RequestTaskSetting requestTaskSetting);
+
+ List<RequestTaskSetting> queryRequestSettingData();
+
+ List<RequestTaskSetting> queryByVersion(String version);
+
+ void alertRequestSetting(RequestTaskSetting requestTaskSetting);
+}
diff --git a/src/main/java/com/flightfeather/monitor/service/impl/ExceptionSettingImpl.java b/src/main/java/com/flightfeather/monitor/service/impl/ExceptionSettingImpl.java
new file mode 100644
index 0000000..3178c75
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/impl/ExceptionSettingImpl.java
@@ -0,0 +1,63 @@
+package com.flightfeather.monitor.service.impl;
+
+import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting;
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+import com.flightfeather.monitor.domain.ds1.mapper.DustExceptionSettingMapper;
+import com.flightfeather.monitor.service.ExceptionSettingService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @ClassName: ExceptionSettingImpl
+ * @Description: TODO
+ * @author: yourname
+ */
+@Slf4j
+@Service
+public class ExceptionSettingImpl implements ExceptionSettingService {
+ @Autowired
+ private DustExceptionSettingMapper dustExceptionSettingMapper;
+
+ @Override
+ public List<DustExceptionSetting> queryExceptionSettingData() {
+ Example example = new Example(DustExceptionSetting.class);
+ example.orderBy("updateTime").desc();
+ List<DustExceptionSetting> list = dustExceptionSettingMapper.selectByExample(example);
+ return list;
+ }
+
+
+ @Override
+ public void addNewExceptionSetting(DustExceptionSetting dustExceptionSetting) {
+ /*鐗堟湰鍙峰姞涓�*/
+ dustExceptionSetting.setUpdateTime(new Date());
+ double v = Double.parseDouble(dustExceptionSetting.getVersion()) + 1;
+ dustExceptionSetting.setVersion(Double.toString(v));
+ dustExceptionSettingMapper.insertSelective(dustExceptionSetting);
+ }
+
+
+ @Override
+ public List<DustExceptionSetting> queryByVersion(String version) {
+ Example example = new Example(DustExceptionSetting.class);
+ example.createCriteria().andEqualTo("version", version);
+ List<DustExceptionSetting> list = dustExceptionSettingMapper.selectByExample(example);
+ return list;
+ }
+
+
+ @Override
+ public void alertExceptionSetting(DustExceptionSetting dustExceptionSetting) {
+ /*璁剧疆鏇存柊鏃堕棿*/
+ dustExceptionSetting.setUpdateTime(new Date());
+ /* */
+ Example example = new Example(RequestTaskSetting.class);
+ example.createCriteria().andEqualTo("version", "1.0");
+ dustExceptionSettingMapper.updateByExampleSelective(dustExceptionSetting, example);
+ }
+}
diff --git a/src/main/java/com/flightfeather/monitor/service/impl/RequestSettingImpl.java b/src/main/java/com/flightfeather/monitor/service/impl/RequestSettingImpl.java
new file mode 100644
index 0000000..5acfe0f
--- /dev/null
+++ b/src/main/java/com/flightfeather/monitor/service/impl/RequestSettingImpl.java
@@ -0,0 +1,70 @@
+package com.flightfeather.monitor.service.impl;
+
+import com.flightfeather.monitor.domain.ds1.entity.RequestTaskSetting;
+import com.flightfeather.monitor.domain.ds1.mapper.RequestTaskSettingMapper;
+import com.flightfeather.monitor.service.RequestSettingService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @ClassName: RequestSettingImpl
+ * @Description: TODO
+ * @author: yourname
+ */
+@Slf4j
+@Service
+public class RequestSettingImpl implements RequestSettingService {
+
+ @Autowired
+ private RequestTaskSettingMapper requestTaskSettingMapper;
+
+ @Override
+ public List<RequestTaskSetting> queryRequestSettingData() {
+ Example example = new Example(RequestTaskSetting.class);
+ example.orderBy("updateTime").desc();
+ List<RequestTaskSetting> list = requestTaskSettingMapper.selectByExample(example);
+ return list;
+ }
+
+ @Override
+ public List<RequestTaskSetting> queryByVersion(String version) {
+ Example example = new Example(RequestTaskSetting.class);
+ example.createCriteria().andEqualTo("version", version);
+ List<RequestTaskSetting> list = requestTaskSettingMapper.selectByExample(example);
+ return list;
+ }
+
+
+ @Override
+ public void alertRequestSetting(RequestTaskSetting requestTaskSetting) {
+ /*璁剧疆鏇存柊鏃堕棿*/
+ requestTaskSetting.setUpdateTime(new Date());
+ /*鑾峰彇棰戠巼 鎹㈢畻鎴愮*/
+ requestTaskSetting.setRequestIntervalSeconds(requestTaskSetting.getRequestIntervalSeconds() * 3600);
+
+ Example example = new Example(RequestTaskSetting.class);
+ example.createCriteria().andEqualTo("version", "1.0");
+ requestTaskSettingMapper.updateByExampleSelective(requestTaskSetting, example);
+
+ }
+
+
+ @Override
+ public void addNewRequestSetting(RequestTaskSetting requestTaskSetting) {
+ /*璁剧疆鏇存柊鏃堕棿*/
+ requestTaskSetting.setUpdateTime(new Date());
+ /*鐗堟湰鍙峰姞涓�*/
+ double v = Double.parseDouble(requestTaskSetting.getVersion()) + 1;
+ requestTaskSetting.setVersion(Double.toString(v));
+ /*鑾峰彇棰戠巼 鎹㈢畻鎴愮*/
+ requestTaskSetting.setRequestIntervalSeconds(requestTaskSetting.getRequestIntervalSeconds() * 3600);
+ requestTaskSettingMapper.insertSelective(requestTaskSetting);
+ }
+
+
+}
--
Gitblit v1.9.3