From 2dd2e7f54db7149965acaa11d933f85b31fbd59c Mon Sep 17 00:00:00 2001
From: huangzhen <867217663@qq.com>
Date: Tue, 19 Dec 2023 16:54:00 +0800
Subject: [PATCH] 解决验收过程中出现的问题
---
src/main/java/com/gkhy/fourierSpecialGasMonitor/controller/DataReceiveController.java | 26 +++++++++++++++++++++++++-
1 files changed, 25 insertions(+), 1 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..883a378 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){
- ForeignResult result = dataReceiveService.uploadGasFlux(reqDto);
+ UploadGasFluxReqDTO uploadGasFluxReqDTO = reqDto.expansionFactor();
+ ForeignResult result = dataReceiveService.uploadGasFlux(uploadGasFluxReqDTO);
return result;
}
@PostMapping("/list/gasCategory")
+ @RepeatedClick
public ForeignResult listGasCategory(){
ForeignResult result = dataReceiveService.listGasCategory();
return result;
--
Gitblit v1.9.2