package com.ld.igds.protocol.fzzy.analysis;

import com.alibaba.fastjson.JSONObject;
import com.ld.igds.common.CoreDeviceIotService;
import com.ld.igds.constant.RedisConst;
import com.ld.igds.grain.dto.GrainIotData;
import com.ld.igds.models.DeviceIot;
import com.ld.igds.models.DeviceSer;
import com.ld.igds.models.WeatherInfo;
import com.ld.igds.protocol.fzzy.command.BaseRemoteImpl;
import com.ld.igds.protocol.fzzy.dto.ReMessage;
import com.ld.igds.protocol.fzzy.resp.Response6001;
import com.ld.igds.util.RedisUtil;
import com.ld.igds.weather.CoreWeatherService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.List;

/**
 * 物联网设备数据解析
 *
 * @author chen
 */
@Slf4j
@Component(AnalysisIot.BEAN_ID)
public class AnalysisIot extends BaseRemoteImpl {

    public static final String BEAN_ID = "fzzy.analysisIot";

    @Autowired
    private CoreDeviceIotService coreDeviceIotService;
    @Autowired
    private CoreWeatherService weatherService;
    @Autowired
    private RedisUtil redisUtil;

    public void analysis6001(ReMessage reMessage, DeviceSer ser) {

        Response6001 resp = JSONObject.parseObject(reMessage.getContent(), Response6001.class);

        if (null == resp || StringUtils.isEmpty(resp.getDeviceId())) {
            log.error("控制柜------>>>平台：未获取IOt设备编码" + resp);
            return;
        }

        try {
            List<DeviceIot> deviceIots = coreDeviceIotService.getCacheDeviceIotBySerId(ser.getCompanyId(), ser.getId());

            DeviceIot deviceIot = deviceIots.stream().filter(item -> (item.getPassCode() + "").equals(resp.getDeviceId())).findAny().orElse(null);

            if (null == deviceIot) {
                log.error("控制柜------>>>平台：未获取IOt设备" + resp);
                return;
            }

            GrainIotData data = new GrainIotData();
            data.setCompanyId(ser.getCompanyId());

            data.setDepotId(deviceIot.getDepotId());
            data.setName(deviceIot.getName());

            data.setDeviceId(deviceIot.getId());
            data.setHum(resp.getHum());
            data.setTemp(resp.getTemp());
            data.setTime(resp.getTime());

            //外温外湿
            WeatherInfo weatherInfo = weatherService.getCacheWeather(ser.getCompanyId());
            Double tOut = -100.0, hOut = -100.0;
            if (null != weatherInfo) {
                if (weatherInfo.getTemp().indexOf("℃") > 0) {
                    weatherInfo.setTemp(weatherInfo.getTemp().replace("℃", ""));
                }
                if (weatherInfo.getHumidity().indexOf("%") > 0) {
                    weatherInfo.setHumidity(weatherInfo.getHumidity().replace("%",
                            ""));
                }
                tOut = Double.valueOf(weatherInfo.getTemp());
                hOut = Double.valueOf(weatherInfo.getHumidity());
            }
            if(tOut > -100){
                data.setOutTemp(tOut);
            }
            if(hOut > -100){
                data.setOutHum(hOut);
            }

            //物联网关温湿度设备解析数据暂时存入缓存，以供后续使用。
            String ket = RedisConst.buildKey(ser.getCompanyId(), RedisConst.KEY_IOT_DEPOT_TEMP_HUM, deviceIot.getDepotId(), deviceIot.getId());
            redisUtil.set(ket, data);
            log.info("物联网关设备温湿度解析成功：" + data.toString());

        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}