src/main/java/com/flightfeather/monitor/controller/dust/ExceptionSettingController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/controller/dust/RequestSettingController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/domain/ds1/entity/RequestTaskSetting.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/service/ExceptionSettingService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/service/RequestSettingService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/service/impl/ExceptionSettingImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/flightfeather/monitor/service/impl/RequestSettingImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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); } }