package com.gk.hotwork.Scheduls.location;

import com.alibaba.fastjson.JSONObject;
import com.gk.hotwork.Config.Oauth2.IRedisService;
import com.gk.hotwork.Domain.DeviceLocation;
import com.gk.hotwork.Domain.DevicePing;
import com.gk.hotwork.Domain.DevicePressKey;
import com.gk.hotwork.Domain.Exception.BusinessException;
import com.gk.hotwork.Domain.Utils.StringUtils;
import com.gk.hotwork.Service.DeviceLocationService;
import com.gk.hotwork.Service.DevicePingService;
import com.gk.hotwork.Service.DevicePressKeyService;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;

//@Component
//@EnableScheduling
//@ConditionalOnProperty(prefix = "scheduling",name = "enabled",havingValue = "true")
public class DeviceDataPersisting {

    private Logger logger = LogManager.getLogger(DeviceDataPersisting.class);

    @Value("${scheduling.enabled}")
    private boolean isSwitch;
    @Value("${slice.size}")
    private Integer sliceSize;
    @Autowired
    private IRedisService redisService;
    @Autowired
    private DevicePingService devicePingService;
    @Autowired
    private DevicePressKeyService devicePressKeyService;
    @Autowired
    private DeviceLocationService deviceLocationService;

//    @Scheduled(cron = "0/1 * * * * ?") //每隔1秒执行一次
    public void locationDataPersisting() {
        redisService.setDbIndex(1);
        String key = "device:location";
        while (redisService.hasKey(key) && redisService.listSize(key) > 0) {
            try {  String res = redisService.leftPop(key);
            if (StringUtils.isBlank(res)) return;
            DeviceLocation deviceLocation = JSONObject.parseObject(res, DeviceLocation.class);
            deviceLocation.setCreateTime(new Date());
            deviceLocationService.insertRecord(deviceLocation);
            } catch (BusinessException e) {
                e.printStackTrace();
                logger.warn(e.getMessage());
            }
        }
    }






//    @Scheduled(cron = "0/10 * * * * ?") //每隔10秒执行一次
    public void pingDataPersisting() {
        redisService.setDbIndex(2);
        String key = "device:ping";
        while (redisService.hasKey(key) && redisService.listSize(key) > 0){
            String res = redisService.leftPop(key);
            if (StringUtils.isBlank(res)) return;
            DevicePing devicePing = JSONObject.parseObject(res, DevicePing.class);
            devicePing.setCreateTime(new Date());
            devicePingService.save(devicePing);
        }

    }




    @Scheduled(cron = "0/10 * * * * ?") //每隔10秒执行一次
    public void pressKeyDataPersisting() {
        redisService.setDbIndex(3);
        String key = "device:presskey";
        while (redisService.hasKey(key) && redisService.listSize(key) > 0){
            String res = redisService.leftPop(key);
            if (StringUtils.isBlank(res)) return;
            DevicePressKey devicePressKey = JSONObject.parseObject(res, DevicePressKey.class);
            devicePressKey.setCreateTime(new Date());
            devicePressKeyService.save(devicePressKey);
        }

    }


    /**
    * @Description: 定位信息只保留90天信息  每天0点执行
    * @date 2021/12/27 15:12
    */
    @Scheduled(cron = "0 0 0 * * ?")
    public void deviceLocationCleanUp() {
        //location
        deviceLocationService.cleanUp(sliceSize,90);
    }
}