package com.fastbee.iot.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.fastbee.common.core.redis.RedisCache;
import com.fastbee.common.core.redis.RedisKeyBuilder;
import com.fastbee.common.enums.FunctionReplyStatus;
import com.fastbee.common.enums.ThingsModelType;
import com.fastbee.common.utils.DateUtils;
import com.fastbee.iot.domain.DeviceLog;
import com.fastbee.iot.domain.FunctionLog;
import com.fastbee.iot.model.Specs;
import com.fastbee.iot.service.IDeviceRuntimeService;
import com.fastbee.iot.service.IFunctionLogService;
import com.fastbee.iot.service.IThingsModelService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 设备运行时数据
 *
 * @author gsb
 * @date 2023/2/1 15:11
 */
@Service
public class DeviceRuntimeServiceImpl implements IDeviceRuntimeService {

    @Autowired
    private RedisCache redisCache;
    @Resource
    private IFunctionLogService logService;
    @Resource
    private IThingsModelService thingsModelService;

    /**
     * 根据设备编号查询设备实时运行状态
     *
     * @param serialNumber 设备编号
     * @param type         物模型类型
     * @return 设备实时数据
     */
    @Override
    public List<DeviceLog> runtimeBySerialNumber(String serialNumber, ThingsModelType type, Long productId, Integer slaveId) {
        //获取redis中的物模型
        String thingsModel = thingsModelService.getCacheThingsModelByProductId(productId);
        JSONObject thingModelObject = JSONObject.parseObject(thingsModel);
        String key = type == ThingsModelType.PROP ? "properties" : "functions";
        String properties = thingModelObject.getString(key);
        /*在redis中查找实时数据*/
        String cacheKey = RedisKeyBuilder.buildDeviceRtCacheKey(serialNumber);
        /*物模型标识符 -- value*/
        Map<String, String> cacheMap = redisCache.getCacheMap(cacheKey);
        /*查询是否有计算公式参数*/
        String paramsKey = RedisKeyBuilder.buildDeviceRtParamsKey(serialNumber);
        Map<String, String> params = redisCache.getCacheMap(paramsKey);
        List<DeviceLog> results = new ArrayList<>();
        List<Specs> propList = JSONObject.parseArray(properties, Specs.class);
        for (Specs specs : propList) {
            if (specs.getSlaveId().equals(slaveId)) {
                DeviceLog log = new DeviceLog();
                log.setModelName(specs.getName());
                log.setLogType(type.getCode());
                log.setSpecs(JSONObject.toJSONString(specs.getDatatype()));
                log.setIdentity(specs.getId());
                log.setSerialNumber(serialNumber);
                log.setSlaveId(specs.getSlaveId());
                log.setIsMonitor(specs.getIsMonitor());
                log.setFormula(specs.getFormula());
                if (!CollectionUtils.isEmpty(cacheMap) && cacheMap.containsKey(specs.getId())) {
                    DeviceLog valueLog = JSONObject.parseObject(JSONObject.parse(cacheMap.get(specs.getId())).toString(), DeviceLog.class);
                    log.setLogValue(valueLog.getLogValue());
                    log.setUpdateTime(valueLog.getTs());
                    log.setTs(valueLog.getTs());
                    //if (log.getFormula() != null && !log.getFormula().equals("")) {
                    //    params.put("%s", log.getLogValue());
                    //    BigDecimal value = CaculateUtils.execute(log.getFormula(), params);
                    //    log.setLogValue(value.toString());
                    //}
                }
                results.add(log);
            }
        }
        List<DeviceLog> result = results.stream().
                filter(log -> log.getLogType() == type.getCode()).collect(Collectors.toList());
        for (DeviceLog log : result) {
            parseSpecs(log);
        }
        return result;
    }


    /**
     * 根据设备编号查询设备服务调用日志情况
     *
     * @param serialNumber 设备编号
     * @return 服务下发日志
     */
    @Override
    public List<FunctionLog> runtimeReply(String serialNumber) {
        FunctionLog log = new FunctionLog();
        log.setSerialNumber(serialNumber);
        // 1-服务下发
        log.setFunType(1);
        List<FunctionLog> logList = logService.selectFunctionLogList(log);
        for (FunctionLog l : logList) {
            if (l.getReplyTime() == null) {
                l.setReplyTime(DateUtils.getNowDate());
            }

            l.setShowValue(l.getResultMsg());
            //设备超过10s未回复，则认为下发失败
            if (l.getResultCode().equals(FunctionReplyStatus.NORELY.getCode()) && DateUtils.getTimestamp() - l.getCreateTime().getTime() >10000){
                l.setShowValue(FunctionReplyStatus.FAIl.getMessage());
                l.setResultCode(FunctionReplyStatus.FAIl.getCode());
            }
        }
        return logList;
    }

    /**
     * 定时任务，自动更新设备响应超时状态
     */
    private void autoUpdateFuncLogStatus() {
        FunctionLog functionLog = new FunctionLog();
        functionLog.setResultCode(FunctionReplyStatus.NORELY.getCode());
        List<FunctionLog> logList = logService.selectFunctionLogList(functionLog);
        List<Long> ids = new ArrayList<>();
        for (FunctionLog log : logList) {
            //如果设备回复超过20s，自动更新设备回复状态为设备超时
            if (DateUtils.getTimestamp() - log.getCreateTime().getTime() > 20000) {
                ids.add(log.getId());
            }
        }
        //更新状态为超时未回复
        if (!CollectionUtils.isEmpty(ids)) {
            FunctionLog log = new FunctionLog();
            log.setList(ids);
            log.setResultMsg(FunctionReplyStatus.UNKNOWN.getMessage());
            log.setResultCode(FunctionReplyStatus.UNKNOWN.getCode());
            log.setReplyTime(DateUtils.getNowDate());
            logService.updateFuncLogBatch(log);
        }
    }

    /**
     * 解析数据定义specs
     *
     * @param log
     */
    public void parseSpecs(DeviceLog log) {
        DeviceLog.DataType spesc = new DeviceLog.DataType();
        if (null != log.getSpecs() && !log.getSpecs().equals("null")) {
            DeviceLog.DataType dataType = JSONObject.parseObject(JSONObject.parse(log.getSpecs()).toString(), DeviceLog.DataType.class);
            log.setDataType(dataType);
        } else {
            spesc.setType("integer");
            log.setDataType(spesc);
        }
    }



}