From d4020168658efdee89a633083cd9c14b06c4d863 Mon Sep 17 00:00:00 2001
From: zhangf <1603559716@qq.com>
Date: 星期三, 11 九月 2024 17:09:10 +0800
Subject: [PATCH] 修改消息推送时间间隔
---
src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java | 24 ++++++++++++++++++++++++
1 files changed, 24 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java
index ec65961..a29057e 100644
--- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java
+++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java
@@ -1,12 +1,22 @@
package com.gkhy.fourierSpecialGasMonitor.controller;
+import com.gkhy.fourierSpecialGasMonitor.annotation.RepeatedClick;
import com.gkhy.fourierSpecialGasMonitor.commons.domain.ForeignResult;
import com.gkhy.fourierSpecialGasMonitor.entity.req.DeviceMonitorReqDTO;
import com.gkhy.fourierSpecialGasMonitor.entity.req.UploadGasConcentrationReqDTO;
import com.gkhy.fourierSpecialGasMonitor.entity.req.UploadGasFluxReqDTO;
import com.gkhy.fourierSpecialGasMonitor.service.DataReceiveService;
+import org.redisson.api.RBucket;
+import org.redisson.api.RedissonClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
/**
* @author Mr.huang
@@ -19,6 +29,18 @@
@Autowired
private DataReceiveService dataReceiveService;
+ private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ //@PostConstruct
+ //private void clearGasConcentrationCache(){
+ // LocalDateTime time = LocalDateTime.now();
+ // String cacheName = time.format(formatter);
+ // //清除redis缓存
+ // RBucket<Object> bucket = redissonClient.getBucket(gasConcentrationCachePrefix+cacheName);
+ // if (bucket.isExists()) {
+ // bucket.delete();
+ // }
+ //}
@PostMapping("/upload/gasConcentration")
public ForeignResult uploadGasConcentration(@RequestBody UploadGasConcentrationReqDTO reqDto){
@@ -28,11 +50,13 @@
@PostMapping("/upload/gasFlux")
public ForeignResult uploadGasFlux(@RequestBody UploadGasFluxReqDTO reqDto){
+ //UploadGasFluxReqDTO uploadGasFluxReqDTO = reqDto.expansionFactor();
ForeignResult result = dataReceiveService.uploadGasFlux(reqDto);
return result;
}
@PostMapping("/list/gasCategory")
+ @RepeatedClick
public ForeignResult listGasCategory(){
ForeignResult result = dataReceiveService.listGasCategory();
return result;
--
Gitblit v1.9.2