修改

“djh”

2024-12-05 eee41a5fb58e6547a43929430f4b72908119db6e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package com.gkhy.testFourierSpecialGasMonitor.controller;
 
import com.gkhy.testFourierSpecialGasMonitor.annotation.RepeatedClick;
import com.gkhy.testFourierSpecialGasMonitor.commons.domain.ForeignResult;
import com.gkhy.testFourierSpecialGasMonitor.entity.req.DeviceMonitorReqDTO;
import com.gkhy.testFourierSpecialGasMonitor.entity.req.UploadGasConcentrationReqDTO;
import com.gkhy.testFourierSpecialGasMonitor.entity.req.UploadGasFluxReqDTO;
import com.gkhy.testFourierSpecialGasMonitor.service.DataReceiveService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
 
/**
 * @author Mr.huang
 * @decription
 * @date 2023/8/7 14:19
 */
@RestController
@RequestMapping("/api")
public class DataReceiveController {
 
    @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){
        ForeignResult result = dataReceiveService.uploadGasConcentration(reqDto);
        return result;
    }
 
    @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;
    }
 
    @PostMapping("/device/monitor")
    public ForeignResult deviceMonitor(@RequestBody DeviceMonitorReqDTO reqDTO){
        ForeignResult result = dataReceiveService.deviceMonitor(reqDTO);
        return result;
    }
}