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