增加数据请求配置表和异常分析配置表的接口

zmc

2023-12-14 357c5a3c4659f1fe9e46e8c20827ab757c5d3929

增加数据请求配置表和异常分析配置表的接口

 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();
    }

}

 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();
    }


}

 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.*;


 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);
}

 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);
}

 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);
    }
}

 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);
    }


}